From 4b66cd48d9e0ca8288dae11f3a895367d30a7b8a Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期二, 19 九月 2023 10:05:49 +0800
Subject: [PATCH] 增加三场数字化报警

---
 ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java |   48 ++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 38 insertions(+), 10 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java
index e3f965c..8b0eb56 100644
--- a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java
+++ b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java
@@ -6,6 +6,12 @@
 import com.ruoyi.alarm.external.service.IArdAlarmExternalService;
 import com.ruoyi.alarm.global.domain.GuideTask;
 import com.ruoyi.alarm.radar.domain.ArdAlarmRadar;
+import com.ruoyi.alarm.radar.domain.ArdAlarmRadarFire;
+import com.ruoyi.alarm.radar.domain.ArdAlarmRadarMove;
+import com.ruoyi.alarm.radar.domain.ArdAlarmRadarPump;
+import com.ruoyi.alarm.radar.service.IArdAlarmRadarFireService;
+import com.ruoyi.alarm.radar.service.IArdAlarmRadarMoveService;
+import com.ruoyi.alarm.radar.service.IArdAlarmRadarPumpService;
 import com.ruoyi.alarm.radar.service.IArdAlarmRadarService;
 import com.ruoyi.alarm.tube.domain.ArdAlarmTube;
 import com.ruoyi.alarm.tube.service.IArdAlarmTubeService;
@@ -29,11 +35,16 @@
 @Slf4j(topic = "guideQueue")
 public class QueueTaskExecutor {
     @Resource
+    IArdAlarmRadarMoveService ardAlarmRadarMoveService;
+    @Resource
+    IArdAlarmRadarFireService ardAlarmRadarFireService;
+    @Resource
+    IArdAlarmRadarPumpService ardAlarmRadarPumpService;
+    @Resource
     IHikClientService hikClientService;
     @Resource
     IArdAlarmTubeService ardAlarmTubeService;
-    @Resource
-    IArdAlarmRadarService ardAlarmRadarService;
+
     @Resource
     IArdAlarmExternalService ardAlarmExternalService;
     @Resource
@@ -42,7 +53,7 @@
         try {
             CameraCmd cmd = new CameraCmd();
             cmd.setCameraId(guideTask.getCameraId());
-            cmd.setChannelNum(guideTask.getChanNum());
+            cmd.setChanNo(guideTask.getChanNum());
             cmd.setTargetPosition(guideTask.getTargetPosition());
             cmd.setOperator(guideTask.getAlarmType());
             cmd.setExpired(30);
@@ -69,16 +80,33 @@
                             ardAlarmTubeService.updateArdAlarmTube(ardAlarmTube);
                             break;
                         case "sys_radar_move":
-                        case "sys_radar_fire":
-                        case "sys_radar_pumpshutdown":
-                            ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar();
-                            ardAlarmRadar.setId(guideTask.getAlarmId());
+                            ArdAlarmRadarMove ardAlarmRadarMove = new ArdAlarmRadarMove();
+                            ardAlarmRadarMove.setId(guideTask.getAlarmId());
                             if (guideTask.getRecordSn().equals(1)) {
-                                ardAlarmRadar.setRecordUrl1(url);
+                                ardAlarmRadarMove.setRecordUrl1(url);
                             } else {
-                                ardAlarmRadar.setRecordUrl2(url);
+                                ardAlarmRadarMove.setRecordUrl2(url);
                             }
-                            ardAlarmRadarService.updateArdAlarmRadar(ardAlarmRadar);
+                            ardAlarmRadarMoveService.updateArdAlarmRadarMove(ardAlarmRadarMove);
+                            break;
+                        case "sys_radar_fire":
+                            ArdAlarmRadarFire ardAlarmRadarFire = new ArdAlarmRadarFire();
+                            ardAlarmRadarFire.setId(guideTask.getAlarmId());
+                            if (guideTask.getRecordSn().equals(1)) {
+                                ardAlarmRadarFire.setRecordUrl1(url);
+                            } else {
+                                ardAlarmRadarFire.setRecordUrl2(url);
+                            }
+                            ardAlarmRadarFireService.updateArdAlarmRadarFire(ardAlarmRadarFire);
+                        case "sys_radar_pump":
+                            ArdAlarmRadarPump ardAlarmRadarPump = new ArdAlarmRadarPump();
+                            ardAlarmRadarPump.setId(guideTask.getAlarmId());
+                            if (guideTask.getRecordSn().equals(1)) {
+                                ardAlarmRadarPump.setRecordUrl1(url);
+                            } else {
+                                ardAlarmRadarPump.setRecordUrl2(url);
+                            }
+                            ardAlarmRadarPumpService.updateArdAlarmRadarPump(ardAlarmRadarPump);
                             break;
                         case "sys_external":
                             ArdAlarmExternal ardAlarmExternal = new ArdAlarmExternal();

--
Gitblit v1.9.3