对于位移没有数据,所有数据都在载荷中的特殊数据做特别处理

src/main/java/com/gct/tools/etlcamelhuge/MQ/MessageProducer.java

@@ -24,7 +24,7 @@ public interface MessageProducer {
     void init();
 
     default void send(MessageBody msgBody) {
-        LoggerFactory.getLogger(MessageProducer.class).info("sending msg :==>{}", ((DiagnoseMsg) msgBody).getWellId() + " " + ((DiagnoseMsg) msgBody).getProdDate() + " " + ((DiagnoseMsg) msgBody).getSgt().substring(0, 5));
+        LoggerFactory.getLogger(MessageProducer.class).info("sending msg :==>{}", ((DiagnoseMsg) msgBody).getWellId() + " " + ((DiagnoseMsg) msgBody).getProdDate() + " ");
     }
 
     void destroy() throws Exception;

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

@@ -108,6 +108,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                     String prod_date = aRow.get("dyna_create_time").toString().split("\\+")[0];
                     System.out.println("prod_date---"+prod_date);
                     aRow.put("dyna_create_time", prod_date);
+                    aRow.put("sgt", "");
                     if (aRow.get("displacement") != null && !aRow.get("displacement").equals("") && aRow.get("disp_load") != null && !aRow.get("disp_load").equals("")) {
                         String[] displacements = aRow.get("displacement").toString().split(";");//10 四舍五入
                         String[] disp_loads = aRow.get("disp_load").toString().split(";");