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

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

@@ -13,8 +13,10 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
+import java.util.List;
 
 /**
  * class name: CamelJDBCCofRealTimeConfiguration.java
@@ -125,6 +127,25 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         aRow.put("susp_max_load",susp_max_load);
                         aRow.put("susp_min_load",susp_min_load);
                     }
+                    //对于位移没有数据,所有数据都在载荷中的特殊数据做特别处理
+                    if ((aRow.get("displacement") == null || aRow.get("displacement").equals("")) && (aRow.get("disp_load") != null && !aRow.get("disp_load").equals(""))){
+                        String disp_load = aRow.get("disp_load").toString().replaceAll(";", ",");
+                        Double[][] doubles = SGTUtil.encodeToDoubleArray(disp_load);
+                        aRow.put("sgt", SGTUtil.encodeToString(doubles));
+                        String[] split = disp_load.split(",");
+                        List<String> list = new ArrayList<>();
+                        for (int i = 0; i < split.length; i++) {
+                            if (i%2 != 0){
+                                BigDecimal bigDecimal = new  BigDecimal(split[i]).divide(new BigDecimal("100.0"));
+                                list.add(bigDecimal.toString());
+                            }
+                        }
+                        String[] loads = list.toArray(new String[0]);
+                        Double susp_max_load = max(loads);
+                        Double susp_min_load = min(loads);
+                        aRow.put("susp_max_load",susp_max_load);
+                        aRow.put("susp_min_load",susp_min_load);
+                    }
                     if (aRow.get("stroke") == null) aRow.put("stroke", "0.0");
                     if (aRow.get("frequency") == null) aRow.put("frequency", "0.0");
                     if (aRow.get("susp_max_load") == null) aRow.put("susp_max_load", "0.0");

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

@@ -27,13 +27,6 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
 
-@Data
-class LogMessage{
-    String id;
-    LocalDateTime date;
-    Object data;
-    String msg;
-}
 /**
  * class name: CamelJDBCConfiguration
  *