设备告警

fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqAlarmRule.java

@@ -38,7 +38,6 @@ import static com.fuyuanshen.global.mqtt.constants.DeviceRedisKeyConstants.*;
 @Slf4j
 public class BjqAlarmRule implements MqttMessageRule {
 
-
     private final IDeviceAlarmService deviceAlarmService;
     private final DeviceService deviceService;
 
@@ -89,6 +88,8 @@ public class BjqAlarmRule implements MqttMessageRule {
                     deviceAlarmBo.setFinishTime(new Date());
                     String durationBetween = DurationUtils.getDurationBetween(deviceAlarmVo.getStartTime(), deviceAlarmBo.getFinishTime());
                     deviceAlarmBo.setDurationTime(durationBetween);
+                    // 0已处理，1未处理
+                    deviceAlarmBo.setTreatmentState(0);
                     deviceAlarmService.updateByBo(deviceAlarmBo);
                 }
             }