This commit is contained in:
Lemon
2024-01-05 10:40:16 +08:00
parent c72ff5263c
commit 17f32578d3
2 changed files with 16 additions and 2 deletions

View File

@@ -376,13 +376,17 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
// 江苏省平台(充电状态至少一分钟推送一次)
if (!StringUtils.equals(realTimeMonitorData.getConnectorStatus(), "03")) {
// 如果不是充电状态,直接推送就可以
nrService.pushPileStatus(realTimeMonitorData);
log.info("推送江苏省平台 非充电状态 params:{}", realTimeMonitorData);
String result = nrService.pushPileStatus(realTimeMonitorData);
log.info("推送江苏省平台 非充电状态 result:{}", result);
}else {
// 充电状态
// 如果缓存有数据,证明上次推送未超过一分钟,不予推送,若缓存中无数据,说明需要推送
if (cacheObject == null) {
nrService.pushPileStatus(realTimeMonitorData);
log.info("推送江苏省平台 充电状态 params:{}", realTimeMonitorData);
String result = nrService.pushPileStatus(realTimeMonitorData);
redisCache.setCacheObject(redisKey, realTimeMonitorData, 1, TimeUnit.MINUTES);
log.info("推送江苏省平台 充电状态 result:{}", result);
}
}