| | |
| | | return; |
| | | } |
| | | nettyUdpServer.init(udpPort); |
| | | log.info("管线泄露UDP服务已启动"); |
| | | log.debug("管线泄露UDP服务已启动"); |
| | | } |
| | | |
| | | |
| | |
| | | map.put("alarmType", start); |
| | | map.put("position", position); |
| | | map.put("watcher", watcher); |
| | | log.info("开始解析" + start); |
| | | log.info("主机:" + host); |
| | | log.info("管线编号:" + tubeId); |
| | | log.info("报警时间:" + alarmTime); |
| | | log.info("报警类型:" + type); |
| | | log.info("位置:" + position); |
| | | log.info("值班人:" + watcher); |
| | | log.info("结束解析" + stop); |
| | | log.debug("开始解析" + start); |
| | | log.debug("主机:" + host); |
| | | log.debug("管线编号:" + tubeId); |
| | | log.debug("报警时间:" + alarmTime); |
| | | log.debug("报警类型:" + type); |
| | | log.debug("位置:" + position); |
| | | log.debug("值班人:" + watcher); |
| | | log.debug("结束解析" + stop); |
| | | MqttConsumer.publish(2, false, "tube", JSON.toJSONString(map)); |
| | | } else { |
| | | log.error("数据异常"); |