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 06dde627a..6ea6fac0d 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 @@ -314,25 +314,25 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler { } relation.setStationId(Long.parseLong(orderInfo.getStationId())); ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation); - if (Objects.nonNull(relationInfo)) { - String pileConnectorCode = pileSn + connectorCode; - if (StringUtils.equals("1", relationInfo.getThirdPartyType())) { - // 联联 - log.info("推送联联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo)); - // 设备状态变化推送 notification_stationStatus - lianLianService.pushConnectorStatus(pileConnectorCode, connectorStatus); - if (StringUtils.equals(connectorStatus, "03")) { - // 充电中 - lianLianService.pushPileChargeStatusChange(orderInfo.getOrderCode()); - } - // 推送充电状态 - lianLianService.pushChargeStatus(orderInfo.getOrderCode()); - }else if (StringUtils.equals("2", relationInfo.getThirdPartyType())) { - // 中电联 - log.info("推送中电联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo)); - zdlService.notificationStationStatus(pileConnectorCode, connectorStatus); + if (Objects.isNull(relationInfo)) { + return null; + } + String pileConnectorCode = pileSn + connectorCode; + if (StringUtils.equals("1", relationInfo.getThirdPartyType())) { + // 联联 + log.info("推送联联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo)); + // 设备状态变化推送 notification_stationStatus + lianLianService.pushConnectorStatus(pileConnectorCode, connectorStatus); + if (StringUtils.equals(connectorStatus, "03")) { + // 充电中 + lianLianService.pushPileChargeStatusChange(orderInfo.getOrderCode()); } - + // 推送充电状态 + lianLianService.pushChargeStatus(orderInfo.getOrderCode()); + }else if (StringUtils.equals("2", relationInfo.getThirdPartyType())) { + // 中电联 + log.info("推送中电联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo)); + zdlService.notificationStationStatus(pileConnectorCode, connectorStatus); } } catch (Exception e) { log.error("推送第三方平台 实时数据 异常", e);