修复因为载荷数据为空时导入失败的bug

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

@@ -1,7 +1,6 @@
 package com.gct.tools.etlcamelhuge.routeconfig;
 
 import com.gct.common.util.SGTUtil;
-import com.gct.tools.etlcamelhuge.MQ.MessageBody;
 import com.gct.tools.etlcamelhuge.MQ.MessageProducer;
 import com.gct.tools.etlcamelhuge.entity.DiagnoseMsg;
 import org.apache.camel.Message;
@@ -11,6 +10,7 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.util.StringUtils;
 
 import javax.annotation.Resource;
+import java.lang.management.MemoryMXBean;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.time.LocalDateTime;
@@ -34,7 +34,8 @@ public class CamelJDBCCofRealTimeConfiguration  {
         for (int i = 0; i < strings.length; i++) {
             doubles[i] = Double.parseDouble(strings[i]);
         }
-        return Arrays.stream(doubles).min().getAsDouble();
+        OptionalDouble min = Arrays.stream(doubles).min();
+        return min.isPresent()? min.getAsDouble() : null;
     }
     //获取最大载荷
     public Double max(String[] strings){
@@ -42,7 +43,8 @@ public class CamelJDBCCofRealTimeConfiguration  {
         for (int i = 0; i < strings.length; i++) {
             doubles[i] = Double.parseDouble(strings[i]);
         }
-        return Arrays.stream(doubles).max().getAsDouble();
+        OptionalDouble max = Arrays.stream(doubles).max();
+        return max.isPresent() ? max.getAsDouble() : null;
     }
 
 
@@ -122,8 +124,12 @@ public class CamelJDBCCofRealTimeConfiguration  {
                             }
                         }
                         String[] loads = list.toArray(new String[0]);
-                        Double susp_max_load = max(loads);
-                        Double susp_min_load = min(loads);
+                         Double susp_max_load =null;
+                         Double susp_min_load =null;
+                        if (loads.length>0  ) {
+                            susp_max_load = max(loads);
+                            susp_min_load = min(loads);
+                        }
                         aRow.put("susp_max_load",susp_max_load);
                         aRow.put("susp_min_load",susp_min_load);
                     }