fix of sgt

src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelRestConfiguration.java

@@ -183,7 +183,7 @@ public class CamelRestConfiguration extends RouteBuilder {
 //                    String offset = jsonObject.getString("offset");
                     String jh = well_id.replace(" ", "");
                     z.setWell_common_name(jh);
-                    String gtsj = TransUtil.trans(jsonObject.getString("offset"),jsonObject.getString("load"));
+                    String gtsj = TransUtil.tranSGT(jsonObject.getString("offset"),jsonObject.getString("load"));
                     Date timeRtu = null;
                     String  rtutime = jsonObject.getString("time");
                     timeRtu = fomat3.parse("0000-00-00 00:".equals(rtutime)? "2021-04-10 10:10": rtutime);
@@ -223,7 +223,7 @@ public class CamelRestConfiguration extends RouteBuilder {
     @Override
     public synchronized void configure() throws Exception {
 
-      /*  JSONObject body = new JSONObject();
+        JSONObject body = new JSONObject();
 
           restConfiguration()
                 .component("servlet")
@@ -239,21 +239,16 @@ public class CamelRestConfiguration extends RouteBuilder {
                     in.setHeader("id",aRow.get("data"));
                     in.setHeader("date", getDate());
                 })
-//                .setBody(simple("${header[data]}"))
-//                .setBody(simple(body.toJSONString()))
+
                 .setBody(simple("${in.header.id}"))
-//                .log("${header.id}")
                 .split(body()).process(
                 exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
-//                    loadDate(,aRow.get("id")+"/analyse/功图数据", );
-//                    in.setHeader("id",aRow.get("id")+"/analyse/功图数据");
-//                    in.setHeader("wellid",aRow.get("code"));
                     if (aRow.get("typeName").toString().indexOf("油井")> 0){
                         Double phd = "".equals(loadPhdDate(aRow.get("id").toString())) ?  0 : Double.valueOf(loadPhdDate(aRow.get("id").toString()) );
                         ZDJG_WELL zdjg_well = loadGtData(aRow.get("id")+"/analyse/功图数据", aRow.get("code").toString(), "2021-08-17");
-                        aRow.put("sgt",gtTransUtil(zdjg_well.getZd_init_sgt()) );//null
+                        aRow.put("sgt",zdjg_well.getZd_init_sgt() );//null
                         aRow.put("susp_max_load",zdjg_well.getSxzh());//最大载荷
                         aRow.put("susp_min_load",zdjg_well.getXxzh());//最小载荷
                         aRow.put("stroke",zdjg_well.getStroke());
@@ -262,8 +257,6 @@ public class CamelRestConfiguration extends RouteBuilder {
                         aRow.put("well_name",aRow.get("code"));
                         aRow.put("phd",phd== null ? 0: phd);
                     }
-
-
                 })
 //                .log("${body[phd]}"+ "sql" + "${body[well_name]}")
                 .doTry()
@@ -272,7 +265,7 @@ public class CamelRestConfiguration extends RouteBuilder {
 //                        "where NOT EXISTS (SELECT * FROM centralbase.cb_temp_well_mech_runtime WHERE well_id = '${body[well_name]}' and  prod_date = '${in.header.date}' )"))
                 .to("jdbc:centralbase")
                 .doCatch(Exception.class)
-                .end();*/
+                .end();
 
       /* JSONArray jsonArray = new JSONArray();
         JSONObject search = new JSONObject();

src/main/java/com/gct/tools/etlcamelhuge/util/TransUtil.java

@@ -77,6 +77,25 @@ public class TransUtil {
         }
         return sb.toString();
     }
+    public static String tranSGT(String displacement,String dispLoad){
+        StringBuffer sb = new StringBuffer();
+        if(displacement == null || dispLoad ==null || "0".equals(displacement) || "0".equals(dispLoad)){
+            return "";
+        }
+        displacement = displacement.substring(1, displacement.length() - 1);
+        dispLoad = dispLoad.substring(1,dispLoad.length()-1);
+
+        String[] offset = displacement.split(",");
+        String[] load = dispLoad.split(",");
+        for(int i=0;i<offset.length && i< load.length; i++){
+            if (i != 0) sb.append(",");
+            int o  = new Double(Double.valueOf(offset[i]) * 100 ).intValue();
+            sb.append(o);
+            int l = new Double(Double.valueOf(load[i]) * 100).intValue();
+            sb.append(",").append(l);
+        }
+        return sb.toString();
+    }
 }
 /* "0.00;0.00;0.01;0.01;0.02;0.02;0.03;0.04;0.06;0.07;0.09;0.11;0.12;0.14;0.17;0.19;0.22;0.24;0.27;0.30;0.34;" +
         "0.37;0.40;0.43;0.46;0.49;0.53;0.56;0.59;0.62;0.65;0.69;0.72;0.75;0.78;0.81;0.84;0.88;0.91;0.94;0.97;" +