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

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

@@ -58,10 +58,6 @@ public class CamelJDBCCofRealTimeConfiguration  {
    // @Async
     public void sendDataToRocketMQ(String wellName, String wellId, String prodDate, Double stroke_length , Double stroke_frequency, String sgt){
         String orgId = "0";
-        prodDate = prodDate.substring(0,19);
-        if (sgt == null || sgt.length() ==0){
-            sgt = "0,0";
-        }
         DiagnoseMsg diagnoseMsg = new DiagnoseMsg(wellId, wellName, orgId, prodDate, sgt, LocalDateTime.now().toString(), stroke_length, stroke_frequency);
         sendMsgRunTime++;
         producer.send(diagnoseMsg);