From 9ab35c4cbc2bf535ab15305b173d0e6d27ffb3ba Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期五, 15 三月 2024 15:28:07 +0800
Subject: [PATCH] 增加密码验证接口

---
 ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java |   97 +++++++++++++++++++++++++++++++++++-------------
 1 files changed, 70 insertions(+), 27 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java
index 2762f49..2de1c2c 100644
--- a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java
@@ -30,7 +30,9 @@
 import com.ruoyi.alarmpoints.tube.mapper.ArdTubesDetailsMapper;
 import com.ruoyi.alarmpoints.tube.mapper.ArdTubesMapper;
 import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
+import com.ruoyi.alarmpoints.well.domain.ArdWellGuideCamera;
 import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
+import com.ruoyi.alarmpoints.well.mapper.ArdWellGuideCameraMapper;
 import com.ruoyi.common.constant.CacheConstants;
 import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.ConfigUtils;
@@ -53,9 +55,12 @@
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.io.File;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
+
+import static com.ruoyi.utils.tools.ArdTool.writeStringToFile;
 
 
 /**
@@ -113,6 +118,9 @@
     private QueueHandler queueHandler;
     @Resource
     private ArdEquipRadarMapper ardEquipRadarMapper;
+    @Resource
+    private ArdWellGuideCameraMapper ardWellGuideCameraMapper;
+
     //endregion
 
     /**
@@ -1031,15 +1039,15 @@
                         if (StringUtils.isNull(longitude) || StringUtils.isNull(latitude)) {
                             return;
                         }
-                        double[] coordinate = new double[]{longitude, latitude};
-                        String cameraId = getCameraByNear(new double[]{ardAlarmTube.getLongitude(), ardAlarmTube.getLatitude()});
+                        GuidePoint guidePoint = new GuidePoint().setLongitude(longitude).setLatitude(latitude);
+                        String cameraId = getCameraByNear(guidePoint);
                         if (StringUtils.isNotEmpty(cameraId)) {
                             GuideDataDto guideDataDto = new GuideDataDto()
-                                    .setAlarmId(cameraId)
+                                    .setCameraId(cameraId)
                                     .setAlarmId(ardAlarmTube.getId())
                                     .setAlarmType("sys_tube_leak")
                                     .setReceiveTime(ardAlarmTube.getCreateTime())
-                                    .setTargetPosition(coordinate);
+                                    .setTargetPosition(guidePoint);
                             messagesEnqueued(guideDataDto);
                         }
                         //endregion
@@ -1067,7 +1075,9 @@
                         String alarmpointName = ardAlarmRadar.getName();//鍏磋叮鐐瑰悕绉�
                         ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
                         if (well == null) {
-                            return;
+                            String path = System.getProperty("user.dir") + File.separator + "noExistWell.txt";
+                            writeStringToFile(alarmpointName, path);
+                            continue;
                         }
 
                         Double longitude = well.getLongitude();
@@ -1143,15 +1153,16 @@
                         if (StringUtils.isNull(ardAlarmExternal.getLongitude()) || StringUtils.isNull(ardAlarmExternal.getLatitude())) {
                             return;
                         }
-                        double[] coordinate = new double[]{ardAlarmExternal.getLongitude(), ardAlarmExternal.getLatitude()};//寮曞鍧愭爣
-                        String cameraId = getCameraByNear(coordinate);//鏈�杩戠浉鏈篒D
+                        GuidePoint guidePoint = new GuidePoint().setLongitude(ardAlarmExternal.getLongitude()).setLatitude(ardAlarmExternal.getLatitude());
+                        //寮曞鍧愭爣
+                        String cameraId = getCameraByNear(guidePoint);//鏈�杩戠浉鏈篒D
                         if (StringUtils.isNotEmpty(cameraId)) {
                             GuideDataDto guideDataDto = new GuideDataDto()
-                                    .setAlarmId(cameraId)
+                                    .setCameraId(cameraId)
                                     .setAlarmId(ardAlarmExternal.getId())
                                     .setAlarmType("sys_external")
                                     .setReceiveTime(ardAlarmExternal.getCreateTime())
-                                    .setTargetPosition(coordinate)
+                                    .setTargetPosition(guidePoint)
                                     .setWellId(well.getId());
                             messagesEnqueued(guideDataDto);
                         }
@@ -1181,15 +1192,15 @@
                         if (StringUtils.isNull(ardAlarmAccess.getLongitude()) || StringUtils.isNull(ardAlarmAccess.getLatitude())) {
                             return;
                         }
-                        double[] coordinate = new double[]{ardAlarmAccess.getLongitude(), ardAlarmAccess.getLatitude()};//寮曞鍧愭爣
-                        String cameraId = getCameraByNear(coordinate);//鏈�杩戠浉鏈篒D
+                        GuidePoint guidePoint = new GuidePoint().setLongitude(ardAlarmAccess.getLongitude()).setLatitude(ardAlarmAccess.getLatitude());//寮曞鍧愭爣
+                        String cameraId = getCameraByNear(guidePoint);//鏈�杩戠浉鏈篒D
                         if (StringUtils.isNotEmpty(cameraId)) {
                             GuideDataDto guideDataDto = new GuideDataDto()
-                                    .setAlarmId(cameraId)
+                                    .setCameraId(cameraId)
                                     .setAlarmId(ardAlarmAccess.getId())
                                     .setAlarmType("sys_external")
                                     .setReceiveTime(ardAlarmAccess.getCreateTime())
-                                    .setTargetPosition(coordinate);
+                                    .setTargetPosition(guidePoint);
                             messagesEnqueued(guideDataDto);
                         }
                         //endregion
@@ -1258,6 +1269,11 @@
             }
             GuideTask guideTask = new GuideTask();
             guideTask.setCameraId(cameraId);//鐩告満ID
+            guideTask.setIsGuidePTZ(guideDataDto.getIsGuidePTZ());
+            if(guideTask.getIsGuidePTZ())
+            {
+                guideTask.setTargetPTZ(guideDataDto.getGuidePTZ());
+            }
             String alarmType = guideDataDto.getAlarmType();
             switch (alarmType) {
                 case "杩愬姩鐩爣妫�娴�":
@@ -1312,7 +1328,7 @@
     /**
      * 鑾峰彇闄勮繎寮�鍚姤璀﹀紩瀵煎姛鑳藉厜鐢�
      */
-    private String getCameraByNear(double[] targetPosition) {
+    private String getCameraByNear(GuidePoint guidePoint) {
         String minDistanceCameraId = "";
         try {
             //鑾峰彇鎵�鏈夊ぇ鍏夌數
@@ -1325,6 +1341,7 @@
                     continue;
                 }
                 double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()};
+                double[] targetPosition = new double[]{guidePoint.getLongitude(), guidePoint.getLatitude()};
                 double distance = GisUtil.getDistance(targetPosition, camPosition);
                 if (distance != 0.0 && distance <= camera.getCamMaxVisibleDistance()) {
                     distanceMap.put(camera.getId(), distance);
@@ -1352,15 +1369,37 @@
 
     //鑾峰彇鐩告満寮曞鍏ラ槦
     private void getCameraGuideToQueue(GuideDataDto guideDataDto) {
-        //鑾峰彇闆疯揪鎵�鍦ㄥ涓婄殑澶у厜鐢�
-        ArdCameras cameraWithTower = ardEquipRadarMapper.getCameraByRadar(guideDataDto.getRadarId());
-        if (StringUtils.isNotNull(cameraWithTower)) {
-            log.debug("鑾峰彇鍒伴浄杈惧涓婄殑鍏夌數:" + cameraWithTower.getId());
-            //濡傛灉闆疯揪濉斾笂鏈夊厜鐢�
-            guideDataDto.setCameraId(cameraWithTower.getId());
+        //鑾峰彇鍏磋叮鐐瑰叧鑱旂殑鐩告満
+        ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(guideDataDto.getWellId());
+        ArdWellGuideCamera ardWellGuideCamera = new ArdWellGuideCamera();
+        ardWellGuideCamera.setWellId(well.getId());
+        List<ArdWellGuideCamera> ardWellGuideCameras = ardWellGuideCameraMapper.selectArdWellGuideCameraList(ardWellGuideCamera);
+        if (ardWellGuideCameras.size() > 0) {
+            //浼樺厛鑾峰彇浜曞叧鑱旂浉鏈虹殑棰勭疆浣�
+            ardWellGuideCamera = ardWellGuideCameras.get(0);
+            guideDataDto.setIsGuidePTZ(true);
+            guideDataDto.setCameraId(ardWellGuideCamera.getCameraId());
+            guideDataDto.setGuidePTZ(new GuidePTZ()
+                    .setP1(ardWellGuideCamera.getP1())
+                    .setT1(ardWellGuideCamera.getT1())
+                    .setZ1(ardWellGuideCamera.getZ1())
+                    .setP2(ardWellGuideCamera.getP2())
+                    .setT2(ardWellGuideCamera.getT2())
+                    .setZ2(ardWellGuideCamera.getZ2())
+            );
             messagesEnqueued(guideDataDto);
         } else {
-            log.debug("鏈幏鍙栧埌闆疯揪濉斾笂鐨勫厜鐢�,鏃犳硶寮曞");
+            //鑾峰彇闆疯揪鎵�鍦ㄥ涓婄殑澶у厜鐢�
+            ArdCameras cameraWithTower = ardEquipRadarMapper.getCameraByRadar(guideDataDto.getRadarId());
+            if (StringUtils.isNotNull(cameraWithTower)) {
+                log.debug("鑾峰彇鍒伴浄杈惧涓婄殑鍏夌數:" + cameraWithTower.getId());
+                //濡傛灉闆疯揪濉斾笂鏈夊厜鐢�
+                guideDataDto.setIsGuidePTZ(false);
+                guideDataDto.setCameraId(cameraWithTower.getId());
+                messagesEnqueued(guideDataDto);
+            } else {
+                log.debug("鏈幏鍙栧埌闆疯揪濉斾笂鐨勫厜鐢�,鏃犳硶寮曞");
+            }
         }
     }
 
@@ -1375,7 +1414,9 @@
             log.debug("鍧愭爣涓虹┖涓嶅紩瀵�");
             return;
         }
-        double[] coordinate = new double[]{ardAlarmRadarMove.getLongitude(), ardAlarmRadarMove.getLatitude()};//鎶ヨ鍧愭爣
+        GuidePoint guidePoint = new GuidePoint().setLongitude(ardAlarmRadarMove.getLongitude())
+                .setLatitude(ardAlarmRadarMove.getLatitude());
+        //鎶ヨ鍧愭爣
         //寮曞鍏ラ槦
         GuideDataDto guideDataDto = new GuideDataDto()
                 .setRadarId(ardAlarmRadarMove.getRadarId())
@@ -1384,7 +1425,7 @@
                 .setAlarmType(ardAlarmRadarMove.getAlarmType())
                 .setReceiveTime(ardAlarmRadarMove.getCreateTime())
                 .setWellId(ardAlarmRadarMove.getWellId())
-                .setTargetPosition(coordinate);
+                .setTargetPosition(guidePoint);
         getCameraGuideToQueue(guideDataDto);//鑾峰彇鐩告満鍏ラ槦
     }
 
@@ -1399,7 +1440,8 @@
             log.debug("鍧愭爣涓虹┖涓嶅紩瀵�");
             return;
         }
-        double[] coordinate = new double[]{ardAlarmRadarFire.getLongitude(), ardAlarmRadarFire.getLatitude()};//鎶ヨ鍧愭爣
+        GuidePoint guidePoint = new GuidePoint().setLongitude(ardAlarmRadarFire.getLongitude())//鎶ヨ鍧愭爣
+                .setLatitude(ardAlarmRadarFire.getLatitude());
         //寮曞鍏ラ槦
         GuideDataDto guideDataDto = new GuideDataDto()
                 .setRadarId(ardAlarmRadarFire.getRadarId())
@@ -1408,7 +1450,7 @@
                 .setAlarmType(ardAlarmRadarFire.getAlarmType())
                 .setReceiveTime(ardAlarmRadarFire.getCreateTime())
                 .setWellId(ardAlarmRadarFire.getWellId())
-                .setTargetPosition(coordinate);
+                .setTargetPosition(guidePoint);
         getCameraGuideToQueue(guideDataDto);//鑾峰彇鐩告満鍏ラ槦
     }
 
@@ -1424,7 +1466,8 @@
             log.debug("鍧愭爣涓虹┖涓嶅紩瀵�");
             return;
         }
-        double[] coordinate = new double[]{ardAlarmRadarPump.getLongitude(), ardAlarmRadarPump.getLatitude()};//鎶ヨ鍧愭爣
+        GuidePoint guidePoint = new GuidePoint().setLongitude(ardAlarmRadarPump.getLongitude())
+                .setLatitude(ardAlarmRadarPump.getLatitude());//鎶ヨ鍧愭爣
         //寮曞鍏ラ槦
         GuideDataDto guideDataDto = new GuideDataDto()
                 .setRadarId(ardAlarmRadarPump.getRadarId())
@@ -1433,7 +1476,7 @@
                 .setAlarmType(ardAlarmRadarPump.getAlarmType())
                 .setReceiveTime(ardAlarmRadarPump.getCreateTime())
                 .setWellId(ardAlarmRadarPump.getWellId())
-                .setTargetPosition(coordinate);
+                .setTargetPosition(guidePoint);
         getCameraGuideToQueue(guideDataDto);//鑾峰彇鐩告満鍏ラ槦
     }
 

--
Gitblit v1.9.3