|
@@ -72,6 +72,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
// TODO: 2023-08-21 更新数据库中设备的状态
|
|
// TODO: 2023-08-21 更新数据库中设备的状态
|
|
|
var connectorStatusInfo = JSONObject.parseObject(data).getJSONObject("ConnectorStatusInfo").toJavaObject(EnConnectorStatusInfo.class);
|
|
var connectorStatusInfo = JSONObject.parseObject(data).getJSONObject("ConnectorStatusInfo").toJavaObject(EnConnectorStatusInfo.class);
|
|
|
if (connectorStatusInfo.getStatus() == 0) {
|
|
if (connectorStatusInfo.getStatus() == 0) {
|
|
|
|
|
+ LOGGER.info("充电桩设备离线:{}", connectorStatusInfo.getConnectorId());
|
|
|
// 如果设备离线,则存入redis,有效期24h,5分钟之内如果收到该设备上线的推送,则不发送通知并删除redis记录,否则发送通知
|
|
// 如果设备离线,则存入redis,有效期24h,5分钟之内如果收到该设备上线的推送,则不发送通知并删除redis记录,否则发送通知
|
|
|
var monitorLog = new MonitorLog()
|
|
var monitorLog = new MonitorLog()
|
|
|
.setStationId(kymCache.getStationId(connectorStatusInfo.getConnectorId()))
|
|
.setStationId(kymCache.getStationId(connectorStatusInfo.getConnectorId()))
|
|
@@ -82,7 +83,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
redisTemplate.opsForValue().set(RedisKeys.OFFLINE.concat(connectorStatusInfo.getConnectorId()), "", 1, TimeUnit.DAYS);
|
|
redisTemplate.opsForValue().set(RedisKeys.OFFLINE.concat(connectorStatusInfo.getConnectorId()), "", 1, TimeUnit.DAYS);
|
|
|
MailUtil.send("skyline@kuaiyuman.cn", "通知", "站点:%s,设备%s离线".formatted(monitorLog.getStationId(), monitorLog.getSn()), false);
|
|
MailUtil.send("skyline@kuaiyuman.cn", "通知", "站点:%s,设备%s离线".formatted(monitorLog.getStationId(), monitorLog.getSn()), false);
|
|
|
} else {
|
|
} else {
|
|
|
- // 查询redis是否有记录,有就删除并更新数据库恢复时间
|
|
|
|
|
|
|
+ // 查询redis是否有记录,则是之前离线的机器上线了,有就删除并更新数据库恢复时间
|
|
|
var exist = redisTemplate.hasKey(RedisKeys.OFFLINE.concat(connectorStatusInfo.getConnectorId()));
|
|
var exist = redisTemplate.hasKey(RedisKeys.OFFLINE.concat(connectorStatusInfo.getConnectorId()));
|
|
|
if (Boolean.TRUE.equals(exist)) {
|
|
if (Boolean.TRUE.equals(exist)) {
|
|
|
monitorLogService.lambdaUpdate()
|
|
monitorLogService.lambdaUpdate()
|