|
@@ -47,7 +47,8 @@ public class RedisSensorAlarmMessagePushService {
|
|
|
MessagePushService pushService = pushServices.get(channel.name());
|
|
|
if (pushService != null) {
|
|
|
try {
|
|
|
- pushService.sendAlarmMessage(alarm);
|
|
|
+ boolean b = pushService.sendAlarmMessage(alarm);
|
|
|
+ alarm.setNotified(b);
|
|
|
log.info("Alarm message sent successfully {},{}",channel.name(), alarm);
|
|
|
} catch (Exception e) {
|
|
|
log.error("推送消息失败,渠道: {},错误: {}", channel.getChannelName(), e.getMessage());
|
|
@@ -58,8 +59,6 @@ public class RedisSensorAlarmMessagePushService {
|
|
|
}
|
|
|
recordPushTime(openid, deviceID, alarmType);
|
|
|
}
|
|
|
-
|
|
|
- alarm.setNotified(true);
|
|
|
saveAlarmToDatabase(alarm);
|
|
|
}
|
|
|
|