chris/Workbench
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Workbench/backend/target/site/jacoco/com.workbenchclassic/UpdateContact.java.html

189 lines
16 KiB
HTML
Raw Permalink Blame History

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"><html xmlns="http://www.w3.org/1999/xhtml" lang="de"><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8"/><link rel="stylesheet" href="../jacoco-resources/report.css" type="text/css"/><link rel="shortcut icon" href="../jacoco-resources/report.gif" type="image/gif"/><title>UpdateContact.java</title><link rel="stylesheet" href="../jacoco-resources/prettify.css" type="text/css"/><script type="text/javascript" src="../jacoco-resources/prettify.js"></script></head><body onload="window['PR_TAB_WIDTH']=4;prettyPrint()"><div class="breadcrumb" id="breadcrumb"><span class="info"><a href="../jacoco-sessions.html" class="el_session">Sessions</a></span><a href="../index.html" class="el_report">backend</a> &gt; <a href="index.source.html" class="el_package">com.workbenchclassic</a> &gt; <span class="el_source">UpdateContact.java</span></div><h1>UpdateContact.java</h1><pre class="source lang-java linenums">package com.workbenchclassic;
import org.json.JSONArray;
import org.json.JSONObject;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Map;
import java.util.stream.Collectors;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path(&quot;/updateContacts&quot;)
<span class="nc" id="L20">public class UpdateContact {</span>
<span class="nc" id="L22"> private final DBService dbService = new DBService(&quot;dsTranNJTA&quot;);</span>
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public Response doUpdate(String jsonBody) {
try {
<span class="nc" id="L29"> JSONObject json = new JSONObject(jsonBody);</span>
<span class="nc" id="L30"> String station = json.getString(&quot;station&quot;);</span>
<span class="nc" id="L31"> JSONArray dataArray = json.getJSONArray(&quot;data&quot;);</span>
<span class="nc" id="L33"> String vendor = dbService.getDatabaseProductName();</span>
<span class="nc" id="L34"> System.out.println(&quot;Aktueller DB-Vendor: &quot; + vendor);</span>
<span class="nc" id="L36"> Connection conn = dbService.getConnection();</span>
<span class="nc" id="L37"> GetMetadata metadata = new GetMetadata();</span>
<span class="nc" id="L38"> String extPlantResponseString = metadata.getExtPlantJson(station);</span>
<span class="nc" id="L39"> JSONObject extPlantResponse = new JSONObject(extPlantResponseString);</span>
<span class="nc" id="L41"> String errorCode = extPlantResponse.optString(&quot;errorCode&quot;, &quot;0&quot;);</span>
<span class="nc bnc" id="L42" title="All 2 branches missed."> if (!&quot;0&quot;.equals(errorCode)) {</span>
// Return an HTTP 400 or 500 with that JSON
<span class="nc" id="L44"> return Response.status(Response.Status.BAD_REQUEST).entity(extPlantResponse.toString()).build();</span>
}
// 3) werknummer ermitteln
// werkResultJson könnte z.B. so aussehen:
// {&quot;errorCode&quot;:&quot;0&quot;,&quot;errorMessage&quot;:&quot;Done&quot;,&quot;data&quot;:&quot;[{\&quot;werknummer\&quot;:\&quot;ABC\&quot;}]&quot;}
<span class="nc" id="L51"> String werkData = extPlantResponse.optString(&quot;data&quot;, &quot;[]&quot;);</span>
<span class="nc" id="L52"> JSONArray werkArr = new JSONArray(werkData);</span>
<span class="nc" id="L54"> String WERK_NR = null;</span>
<span class="nc" id="L55"> String COMPANY_NO = null;</span>
<span class="nc" id="L56"> String CLIENT_NO = null;</span>
<span class="nc bnc" id="L57" title="All 2 branches missed."> if (werkArr.length() &gt; 0) {</span>
<span class="nc" id="L58"> JSONObject row = werkArr.getJSONObject(0);</span>
<span class="nc" id="L59"> WERK_NR = row.optString(&quot;ext_company_nr&quot;, null);</span>
<span class="nc" id="L60"> COMPANY_NO = row.optString(&quot;werk_nr&quot;, null);</span>
<span class="nc" id="L61"> CLIENT_NO = row.optString(&quot;client_nr&quot;, null);</span>
}
<span class="nc" id="L64"> System.out.println(&quot;Ermittelte werknummer: &quot; + COMPANY_NO);</span>
<span class="nc" id="L66"> boolean isMSSQL = &quot;Microsoft SQL Server&quot;.equals(vendor);</span>
<span class="nc" id="L67"> boolean isOracle = &quot;Oracle&quot;.equals(vendor);</span>
<span class="nc" id="L69"> insertIdocStatus(conn, isMSSQL, isOracle);</span>
<span class="nc" id="L71"> conn.setAutoCommit(false);</span>
try {
<span class="nc bnc" id="L73" title="All 2 branches missed."> for (int i = 0; i &lt; dataArray.length(); i++) {</span>
<span class="nc" id="L74"> JSONObject obj = dataArray.getJSONObject(i);</span>
<span class="nc" id="L75"> Map&lt;String, String&gt; keyMap = obj.keySet().stream()</span>
<span class="nc" id="L76"> .collect(Collectors.toMap(String::toLowerCase, key -&gt; key,</span>
<span class="nc" id="L77"> (existing, replacement) -&gt; existing));</span>
<span class="nc" id="L78"> insertContact(conn, obj, COMPANY_NO, WERK_NR, CLIENT_NO, isMSSQL, isOracle, keyMap);</span>
<span class="nc bnc" id="L79" title="All 4 branches missed."> if (obj.has(&quot;artikel&quot;) &amp;&amp; !obj.isNull(&quot;artikel&quot;)</span>
<span class="nc bnc" id="L80" title="All 2 branches missed."> &amp;&amp; !String.valueOf(obj.get(&quot;artikel&quot;)).trim().isEmpty()) {</span>
<span class="nc" id="L81"> insertMaterialContact(conn, obj, COMPANY_NO, WERK_NR, CLIENT_NO, isMSSQL, isOracle, keyMap);</span>
}
}
<span class="nc" id="L85"> conn.commit();</span>
<span class="nc" id="L86"> } catch (SQLException e) {</span>
<span class="nc" id="L87"> conn.rollback();</span>
<span class="nc" id="L88"> throw e;</span>
} finally {
<span class="nc" id="L90"> conn.setAutoCommit(true);</span>
<span class="nc" id="L91"> conn.close();</span>
}
<span class="nc" id="L94"> JSONObject response = new JSONObject();</span>
<span class="nc" id="L95"> response.put(&quot;status&quot;, &quot;ok&quot;);</span>
<span class="nc" id="L96"> response.put(&quot;message&quot;, &quot;Daten wurden erfolgreich verarbeitet.&quot;);</span>
<span class="nc" id="L97"> return Response.ok(response.toString()).build();</span>
<span class="nc" id="L99"> } catch (Exception e) {</span>
<span class="nc" id="L100"> e.printStackTrace();</span>
<span class="nc" id="L101"> JSONObject error = new JSONObject();</span>
<span class="nc" id="L102"> error.put(&quot;status&quot;, &quot;error&quot;);</span>
<span class="nc" id="L103"> error.put(&quot;message&quot;, e.getMessage());</span>
<span class="nc" id="L104"> return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(error.toString()).build();</span>
}
}
private void insertContact(Connection conn, JSONObject obj, String COMPANY_NO, String WERK_NR, String CLIENT_NO,
boolean isMSSQL, boolean isOracle, Map&lt;String, String&gt; keyMap) throws SQLException {
String sql;
<span class="nc bnc" id="L111" title="All 2 branches missed."> if (isMSSQL) {</span>
<span class="nc" id="L112"> sql = &quot;INSERT INTO xtran.tran_contact (TRAN_ID, IDOC_ID, SOURCE, STATUS, CREATED, STAMP, PLANT_NO, CLIENT_NO, COMPANY_NO, CONTACT_CODE, CONTACT_NAME, CONTACT_GROUP, STREET, ZIP_CODE, COUNTRY, CITY, IS_SUPPLIER, IS_CUSTOMER, IS_MANUFACTURER, CONTACT_CODE_ERP, INVENTORY, CONTACT_STATE, LATITUDE, LONGITUDE) &quot;</span>
+ &quot;VALUES (NEXT VALUE FOR xtran.SEQ_tran_contact, (SELECT MAX(id) FROM xtran.tran_idocstatus), ?, ?, GETDATE(), GETDATE(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)&quot;;
<span class="nc bnc" id="L114" title="All 2 branches missed."> } else if (isOracle) {</span>
<span class="nc" id="L115"> sql = &quot;INSERT INTO tran.tran_contact (TRAN_ID, IDOC_ID, SOURCE, STATUS, CREATED, STAMP, PLANT_NO, CLIENT_NO, COMPANY_NO, CONTACT_CODE, CONTACT_NAME, CONTACT_GROUP, STREET, ZIP_CODE, COUNTRY, CITY, IS_SUPPLIER, IS_CUSTOMER, IS_MANUFACTURER, CONTACT_CODE_ERP, INVENTORY, CONTACT_STATE, LATITUDE, LONGITUDE) &quot;</span>
+ &quot;VALUES (tran.SEQ_TRAN_contact.nextVal, (SELECT MAX(id) FROM tran.tran_idocstatus), ?, ?, SYSDATE, SYSDATE, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)&quot;;
} else {
<span class="nc" id="L118"> throw new SQLException(&quot;DB-Vendor nicht implementiert&quot;);</span>
}
<span class="nc" id="L121"> try (PreparedStatement ps = conn.prepareStatement(sql)) {</span>
<span class="nc" id="L122"> ps.setInt(1, obj.optInt(keyMap.getOrDefault(&quot;source&quot;, &quot;source&quot;), 0));</span>
<span class="nc" id="L123"> ps.setInt(2, obj.optInt(keyMap.getOrDefault(&quot;status&quot;, &quot;status&quot;), 0));</span>
<span class="nc" id="L124"> ps.setString(3, WERK_NR);</span>
<span class="nc" id="L125"> ps.setString(4, CLIENT_NO);</span>
<span class="nc" id="L126"> ps.setString(5, COMPANY_NO);</span>
<span class="nc" id="L127"> ps.setString(6, obj.optString(keyMap.getOrDefault(&quot;contact_code&quot;, &quot;contact_code&quot;), &quot;&quot;));</span>
<span class="nc" id="L128"> ps.setString(7, obj.optString(keyMap.getOrDefault(&quot;contact_name&quot;, &quot;contact_name&quot;), &quot;&quot;));</span>
<span class="nc" id="L129"> ps.setString(8, obj.optString(keyMap.getOrDefault(&quot;contact_group&quot;, &quot;contact_group&quot;), &quot;&quot;));</span>
<span class="nc" id="L130"> ps.setString(9, obj.optString(keyMap.getOrDefault(&quot;street&quot;, &quot;street&quot;), &quot;&quot;));</span>
<span class="nc" id="L131"> ps.setString(10, obj.optString(keyMap.getOrDefault(&quot;zip_code&quot;, &quot;zip_code&quot;), &quot;&quot;));</span>
<span class="nc" id="L132"> ps.setString(11, obj.optString(keyMap.getOrDefault(&quot;country&quot;, &quot;country&quot;), &quot;&quot;));</span>
<span class="nc" id="L133"> ps.setString(12, obj.optString(keyMap.getOrDefault(&quot;city&quot;, &quot;city&quot;), &quot;&quot;));</span>
<span class="nc" id="L134"> ps.setInt(13, obj.optInt(keyMap.getOrDefault(&quot;is_supplier&quot;, &quot;is_supplier&quot;), 0));</span>
<span class="nc" id="L135"> ps.setInt(14, obj.optInt(keyMap.getOrDefault(&quot;is_customer&quot;, &quot;is_customer&quot;), 0));</span>
<span class="nc" id="L136"> ps.setInt(15, obj.optInt(keyMap.getOrDefault(&quot;is_manufacturer&quot;, &quot;is_manufacturer&quot;), 0));</span>
<span class="nc" id="L137"> ps.setString(16, obj.optString(keyMap.getOrDefault(&quot;contact_code_erp&quot;, &quot;contact_code_erp&quot;), &quot;&quot;));</span>
<span class="nc" id="L138"> ps.setInt(17, obj.optInt(keyMap.getOrDefault(&quot;inventory&quot;, &quot;inventory&quot;), 0));</span>
<span class="nc" id="L139"> ps.setInt(18, obj.optInt(keyMap.getOrDefault(&quot;contact_state&quot;, &quot;contact_state&quot;), 0));</span>
<span class="nc" id="L140"> ps.setDouble(19, obj.optDouble(keyMap.getOrDefault(&quot;latitude&quot;, &quot;latitude&quot;), 0.0));</span>
<span class="nc" id="L141"> ps.setDouble(20, obj.optDouble(keyMap.getOrDefault(&quot;longitude&quot;, &quot;longitude&quot;), 0.0));</span>
<span class="nc" id="L142"> ps.executeUpdate();</span>
}
<span class="nc" id="L144"> }</span>
private void insertIdocStatus(Connection conn, boolean isMSSQL, boolean isOracle) throws SQLException {
String sql;
<span class="nc bnc" id="L148" title="All 2 branches missed."> if (isMSSQL) {</span>
<span class="nc" id="L149"> sql = &quot;INSERT INTO xtran.tran_idocstatus (ID, DATE_CREATION, ewstatus, errorcode, content_type, source) VALUES (NEXT VALUE FOR xtran.seq_tranidocstatus, GETDATE(), 1, 0, 57, 0)&quot;;</span>
<span class="nc bnc" id="L150" title="All 2 branches missed."> } else if (isOracle) {</span>
<span class="nc" id="L151"> sql = &quot;INSERT INTO tran.tran_idocstatus (ID, DATE_CREATION, ewstatus, errorcode, content_type, source) VALUES (tran.seq_tranidocstatus.nextval, SYSDATE, 1, 0, 57, 0)&quot;;</span>
} else {
<span class="nc" id="L153"> throw new SQLException(&quot;DB-Vendor nicht implementiert&quot;);</span>
}
<span class="nc" id="L155"> try (PreparedStatement ps = conn.prepareStatement(sql)) {</span>
<span class="nc" id="L156"> ps.executeUpdate();</span>
}
<span class="nc" id="L158"> }</span>
private void insertMaterialContact(Connection conn, JSONObject obj, String COMPANY_NO, String WERK_NR,
String CLIENT_NO, boolean isMSSQL, boolean isOracle, Map&lt;String, String&gt; keyMap) throws SQLException {
String sql;
<span class="nc bnc" id="L163" title="All 2 branches missed."> if (isMSSQL) {</span>
<span class="nc" id="L164"> sql = &quot;INSERT INTO xtran.tran_material_contact (TRAN_ID, SOURCE, STATUS, CREATED, STAMP, CONTACT_CODE, MATERIAL_NO, MATERIAL_NO_EXT, MATERIAL_DESC_EXT, CONTACT_TYPE, DELETE_FLAG, PLANT_NO, COMPANY_NO, CLIENT_NO, IDOC_ID) &quot;</span>
+ &quot;VALUES (NEXT VALUE FOR xtran.SEQ_tran_material_contact, ?, ?, GETDATE(), GETDATE(), ?, ?, ?, ?, ?, ?, ?, ?, ?, (SELECT MAX(id) FROM xtran.tran_idocstatus))&quot;;
<span class="nc bnc" id="L166" title="All 2 branches missed."> } else if (isOracle) {</span>
<span class="nc" id="L167"> sql = &quot;INSERT INTO tran.tran_material_contact (TRAN_ID, SOURCE, STATUS, CREATED, STAMP, CONTACT_CODE, MATERIAL_NO, MATERIAL_NO_EXT, MATERIAL_DESC_EXT, CONTACT_TYPE, DELETE_FLAG, PLANT_NO, COMPANY_NO, CLIENT_NO, IDOC_ID) &quot;</span>
+ &quot;VALUES (tran.SEQ_TRAN_material_contact.nextVal, ?, ?, SYSDATE, SYSDATE, ?, ?, ?, ?, ?, ?, ?, ?, ?, (SELECT MAX(id) FROM tran.tran_idocstatus))&quot;;
} else {
<span class="nc" id="L170"> throw new SQLException(&quot;DB-Vendor nicht implementiert&quot;);</span>
}
<span class="nc" id="L173"> try (PreparedStatement ps = conn.prepareStatement(sql)) {</span>
<span class="nc" id="L174"> ps.setInt(1, obj.optInt(keyMap.getOrDefault(&quot;source&quot;, &quot;source&quot;), 0));</span>
<span class="nc" id="L175"> ps.setInt(2, obj.optInt(keyMap.getOrDefault(&quot;status&quot;, &quot;status&quot;), 0));</span>
<span class="nc" id="L176"> ps.setString(3, obj.optString(keyMap.getOrDefault(&quot;contact_code&quot;, &quot;contact_code&quot;), &quot;&quot;));</span>
<span class="nc" id="L177"> ps.setString(4, obj.optString(keyMap.getOrDefault(&quot;artikel&quot;, &quot;artikel&quot;), &quot;&quot;));</span>
<span class="nc" id="L178"> ps.setString(5, obj.optString(keyMap.getOrDefault(&quot;part_ext&quot;, &quot;part_ext&quot;), &quot;&quot;));</span>
<span class="nc" id="L179"> ps.setString(6, obj.optString(keyMap.getOrDefault(&quot;part_ext&quot;, &quot;material_desc_ext&quot;), &quot;&quot;));</span>
<span class="nc" id="L180"> ps.setInt(7, obj.optInt(keyMap.getOrDefault(&quot;art_bez_ext&quot;, &quot;art_bez_ext&quot;), 0));</span>
<span class="nc" id="L181"> ps.setInt(8, obj.optInt(keyMap.getOrDefault(&quot;delete_flag&quot;, &quot;delete_flag&quot;), 0));</span>
<span class="nc" id="L182"> ps.setString(9, WERK_NR);</span>
<span class="nc" id="L183"> ps.setString(10, COMPANY_NO);</span>
<span class="nc" id="L184"> ps.setString(11, CLIENT_NO);</span>
<span class="nc" id="L185"> ps.executeUpdate();</span>
}
<span class="nc" id="L187"> }</span>
}
</pre><div class="footer"><span class="right">Created with <a href="http://www.jacoco.org/jacoco">JaCoCo</a> 0.8.4.201905082037</span></div></body></html>
Reference in New Issue View Git Blame Copy Permalink