From 642d3a5e472d2142103d8bae160a203b0af5f953 Mon Sep 17 00:00:00 2001 From: Lemon Date: Fri, 29 Dec 2023 11:41:34 +0800 Subject: [PATCH] =?UTF-8?q?update=20=20=E6=B1=9F=E8=8B=8F=E7=9C=81?= =?UTF-8?q?=E5=B9=B3=E5=8F=B0=E6=8E=A8=E9=80=81=E9=A2=91=E7=8E=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/UploadRealTimeMonitorHandler.java | 21 ++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) 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 48f41ea1c..08acb8ec0 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 @@ -365,9 +365,24 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler { zdlService.notificationStationStatus(pileConnectorCode, connectorStatus); } if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), relationInfo.getThirdPartyType())) { - // 江苏省平台 - String result = nrService.pushPileStatus(realTimeMonitorData); - log.info("推送江苏省平台实时数据 result:{}", result); + // 先判断缓存中是否有数据 + String redisKey = "JIANGSU_PUSH_PILE_STATUS:" + pileConnectorCode; + Object cacheObject = redisCache.getCacheObject(redisKey); + + // 江苏省平台(充电状态至少一分钟推送一次) + if (!StringUtils.equals(realTimeMonitorData.getConnectorStatus(), "03")) { + // 如果不是充电状态，直接推送就可以 + nrService.pushPileStatus(realTimeMonitorData); + }else { + // 充电状态 + // 如果缓存有数据，证明上次推送未超过一分钟，不予推送，若缓存中无数据，说明需要推送 + if (cacheObject == null) { + nrService.pushPileStatus(realTimeMonitorData); + redisCache.setCacheObject(redisKey, realTimeMonitorData, 1, TimeUnit.MINUTES); + } + } + + // log.info("推送江苏省平台实时数据 result:{}", result); } if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), relationInfo.getThirdPartyType())) { // 甬城泊车