找不到检测影子报错 修改

src/main/java/com/cn/esermis/constant/Constant.java

@@ -14,6 +14,16 @@ public class Constant {
         public static final String REAL = "2011"; //实时值
         public static final String DAY = "2031"; //日数据
 
+
+        public static final String HOUR_STR = "CN=2061"; //日数据
+        public static final String MINUTE_STR = "CN=2051"; //日数据
+
+        public static final String HJ2122005 = "2005"; //日数据
+        public static final String HJ2122017 = "2017"; //日数据
+
+
+
+
         public static final  String CN = "CN"; //大气环境污染源
         public static final  String SERVER = "server"; //大气环境污染源
 

src/main/java/com/cn/esermis/datawarn/common/ExceptionDataDispose.java

@@ -53,6 +53,9 @@ public class ExceptionDataDispose {
             dataAll.add(Long.toString(dataTime1));
         }
         Integer flag = monitorFactorMapper.waterOrAir(factor);
+        if (flag==null){
+            return "0";
+        }
         if (flag.equals(1)) {
             dataAll.replaceAll(s -> s.concat("0000"));
             all = (ArrayList<Double>) countAirChargeMapper.airSixHour(mn, factor, dataAll.get(0),

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -76,9 +76,11 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
             if (msg == null) {
                 return;
             }
-            log.info("=============" + (new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date()) + "=============");
             String message = msg.toString();
-            log.info("收到数据：" + message);
+            if (message.contains(Constant.MINUTE_STR) || message.contains(Constant.HOUR_STR)) {
+                log.info("=============" + (new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date()) + "=============");
+                log.info("收到数据：" + message);
+            }
             if (message.contains("&&")) {
                 String[] split = message.split("&&");
                 if (split.length == 3) {