From df529c44b672b5094344ed46c2142a727dcab98b Mon Sep 17 00:00:00 2001 From: Lemon Date: Fri, 15 Dec 2023 15:35:29 +0800 Subject: [PATCH] =?UTF-8?q?update=20=20=E5=90=91=E7=AC=AC=E4=B8=89?= =?UTF-8?q?=E6=96=B9=E5=B9=B3=E5=8F=B0=E6=8E=A8=E9=80=81=E5=AE=9E=E6=97=B6?= =?UTF-8?q?=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/handler/UploadRealTimeMonitorHandler.java | 2 +- .../mqtt/BootNettyMqttChannelInboundHandler.java | 10 ++++++++++ .../netty/server/mqtt/BootNettyMqttMsgBack.java | 10 ++++++++++ 3 files changed, 21 insertions(+), 1 deletion(-) create mode 100644 jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttChannelInboundHandler.java create mode 100644 jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttMsgBack.java diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java index 2cb3e0a2a..48f41ea1c 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java @@ -364,7 +364,7 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler { log.info("推送中电联平台实时数据 pileConnectorCode:{}, connectorStatus:{}", pileConnectorCode, connectorStatus); zdlService.notificationStationStatus(pileConnectorCode, connectorStatus); } - if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), relation.getThirdPartyType())) { + if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), relationInfo.getThirdPartyType())) { // 江苏省平台 String result = nrService.pushPileStatus(realTimeMonitorData); log.info("推送江苏省平台实时数据 result:{}", result); diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttChannelInboundHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttChannelInboundHandler.java new file mode 100644 index 000000000..6c56d75be --- /dev/null +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttChannelInboundHandler.java @@ -0,0 +1,10 @@ +package com.jsowell.netty.server.mqtt; + +/** + * TODO + * + * @author Lemon + * @Date 2023/12/14 11:33:03 + */ +public class BootNettyMqttChannelInboundHandler { +} diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttMsgBack.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttMsgBack.java new file mode 100644 index 000000000..d8967a2bd --- /dev/null +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttMsgBack.java @@ -0,0 +1,10 @@ +package com.jsowell.netty.server.mqtt; + +/** + * TODO + * + * @author Lemon + * @Date 2023/12/14 11:36:30 + */ +public class BootNettyMqttMsgBack { +}