diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqAlarmRule.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqAlarmRule.java index 39fea9d..b8c3098 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqAlarmRule.java +++ b/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); } } diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAlarm.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAlarm.java index 10f19e6..514f3cf 100644 --- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAlarm.java +++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAlarm.java @@ -68,12 +68,12 @@ public class DeviceAlarm extends TenantEntity { /** * 经度 */ - private Long longitude; + private Double longitude; /** * 纬度 */ - private Long latitude; + private Double latitude; /** * 报警位置 @@ -99,7 +99,7 @@ public class DeviceAlarm extends TenantEntity { * 0已处理,1未处理 * treatment_state */ - private Long treatmentState; + private Integer treatmentState; /** diff --git a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml index 1b30d14..14dbd02 100644 --- a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml +++ b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml @@ -351,13 +351,13 @@ - SELECT * FROM device WHERE device_imei = #{deviceImei} + SELECT * + FROM device + WHERE device_imei = #{deviceImei} \ No newline at end of file