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 { +}