2011 不接收

src/main/java/com/cn/esermis/dpld/business/MonitorBusiness.java

@@ -330,6 +330,7 @@ public class MonitorBusiness {
                 }
             }
         } catch (Exception e) {
+//            throw new RuntimeException(e);
             log.error("插入数据库异常："+e);
         }
     }

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

@@ -83,7 +83,7 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                 String[] split = message.split("&&");
                 if (split.length == 3) {
                     JSONObject jsonObject = HJ212MsgUtils.dealMsg2(message);
-                    if (jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
+                    if (jsonObject!=null && jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
                             || jsonObject.getString(Constant.CN).equals(Constant.HOUR)
                             || jsonObject.getString(Constant.CN).equals(Constant.REAL)){
                         adapter.publisherService.pubMsg(jsonObject);
@@ -94,7 +94,7 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                         String startStr = dataMap.get(ctx.channel().id().toString());
                         startStr = startStr + message;
                         JSONObject jsonObject = HJ212MsgUtils.dealMsg2(startStr);
-                        if (jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
+                        if (jsonObject!=null &&  jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
                                 || jsonObject.getString(Constant.CN).equals(Constant.HOUR)
                                 || jsonObject.getString(Constant.CN).equals(Constant.REAL)){
 //                            adapter.redisQueueService.sendMessage(Constant.SERVER, jsonObject);

src/main/java/com/cn/esermis/utils/HJ212MsgUtils.java

@@ -68,7 +68,7 @@ public class HJ212MsgUtils {
             data.put("SIZE", headStr.substring(0, 4));
             data.putAll(JSONObject.parseObject("{\"" + headStr.substring(4) + "\"}"));
             if (!Constant.COMMAND.contains(data.getString("CN"))){
-                return data;
+                return null;
             }
             // 清洗数据体基本数据
             String[] monitors = subMsg[1].split(";");