From 9058dcfcb1d0095166998f84891162909d4e4bc9 Mon Sep 17 00:00:00 2001 From: daiyongfei <974332738@qq.com> Date: Sat, 20 Sep 2025 11:45:11 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=E5=91=8A=E8=AD=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fuyuanshen/global/mqtt/rule/bjq/BjqAlarmRule.java | 3 ++- .../com/fuyuanshen/equipment/domain/DeviceAlarm.java | 6 +++--- .../main/resources/mapper/equipment/DeviceMapper.xml | 10 ++++++---- 3 files changed, 11 insertions(+), 8 deletions(-) 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 39fea9dd4..b8c309883 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 10f19e6c4..514f3cf44 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 1b30d1414..14dbd0252 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