From 6c47588406827fa706e4068c692de3be0ae0188e Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期一, 04 十二月 2023 11:04:26 +0800
Subject: [PATCH] 雷达引导追踪优化

---
 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java |  132 +++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 117 insertions(+), 15 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
index e726cf5..e34debc 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -8,22 +8,21 @@
 package com.ruoyi.sy.gps31;
 
 import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONObject;
 import com.gps31.push.netty.PushClient;
 import com.gps31.push.netty.PushMsg;
 import com.gps31.push.netty.client.TcpClient;
 import com.gps31.push.util.MapUtil;
 import com.ruoyi.common.utils.spring.SpringUtils;
 import com.ruoyi.sy.domain.*;
-import com.ruoyi.sy.service.ArdAccessFenceService;
-import com.ruoyi.sy.service.ArdAccessNumService;
-import com.ruoyi.sy.service.ArdOilWallService;
-import com.ruoyi.sy.service.ArdSyCarRtuService;
+import com.ruoyi.sy.service.*;
 import com.ruoyi.sy.service.impl.*;
 import com.ruoyi.utils.gps.GeoTools;
-import com.ruoyi.utils.mqtt.MqttConsumer;
+import com.ruoyi.utils.qymqtt.newM.EmqClient;
+import com.ruoyi.utils.qymqtt.newM.QosEnum;
+import com.ruoyi.utils.qymqtt.oldM.MqttCustomerClient;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.eclipse.paho.client.mqttv3.MqttException;
 
 import java.awt.geom.Point2D;
 import java.text.SimpleDateFormat;
@@ -93,6 +92,7 @@
                 String deptName = (String) result.get("deptName");//鑾峰彇閮ㄩ棬鍚嶇О
                 String carModel = (String) result.get("carModel");//鑾峰彇杞﹁締妯″瀷
                 Integer drct = (Integer) gpsMap.get("drct");//鑾峰彇杞﹁締妯″瀷
+                Integer speed = (Integer) gpsMap.get("speed");
                 //瀹氫箟2缁寸┖闂�
                 Point2D.Double point = new Point2D.Double(Double.parseDouble(lng), Double.parseDouble(lat));
                 List<Point2D.Double> pts = new ArrayList<Point2D.Double>();
@@ -104,10 +104,20 @@
                 ArdAccessNumService accessNumService = SpringUtils.getBean(ArdAccessNumService.class);
                 //娉ㄥ叆鐢靛瓙閿丅ean
                 ArdSyCarRtuService carRtuService = SpringUtils.getBean(ArdSyCarRtuService.class);
+                //娉ㄥ叆閿丅ean
+                ArdSyCarLockService lockService = SpringUtils.getBean(ArdSyCarLockService.class);
                 //鏌ヨ瀹氫綅娌硅溅琛ㄤ腑鏄惁鏈夎杞﹁締
                 ArdAccessFence ardAccessFence = ardAccessFenceService.queryAccess(carId);
                 //鏌ヨ鎵�鏈夎娌圭偣鍥存爮
                 List<ArdOilWall> ardOilWalls = ardOilWallService.accessAll();
+                //杞﹂�熸爣璁�
+                Boolean stop = true;
+                //鍒ゆ柇杞﹂��
+                if(speed>5){
+                    //mqtt鍙戦�佹棦瀹歊tu鐘舵��
+                    feng(carId,"鏂藉皝",carRtuService,lockService);
+                    stop = false;
+                }
                 //濡傛灉娌℃湁璇存槑杞﹁締鏈繘鍏ヨ娌圭偣锛岄渶瑕佸尮閰嶆墍鏈夎娌圭偣鍥存爮
                 if(ardAccessFence==null){
                     //杞﹁締鏈繘鍏ヨ娌圭偣
@@ -137,6 +147,10 @@
                             ardAccessFence1.setDrct(drct);
                             ardAccessFence1.setIsAlarm(0);
                             ardAccessFenceService.access(ardAccessFence1);
+                            if(stop){
+                                //mqtt鍙戦�佹棦瀹歊tu鐘舵��
+                                feng(carId,"瑁呮补鐐�",carRtuService,lockService);
+                            }
                             break;
                         }
                     }
@@ -195,6 +209,10 @@
                                     ardAccessFence.setIntoShipmentTime(time);
                                     ardAccessFence.setNowWallName(ardOilWall.getName());
                                     ardAccessFence.setLastTime(time);
+                                    if(stop){
+                                        //mqtt鍙戦�佹棦瀹歊tu鐘舵��
+                                        feng(carId,"瑁呮补鐐�",carRtuService,lockService);
+                                    }
                                     break;
                                 }
                             }
@@ -221,11 +239,8 @@
                                     ardAccessFence.setLng(lng);
                                     ardAccessFence.setLat(lat);
                                     ardAccessFenceService.updAccess(ardAccessFence);
-//寮�鍑鸿娌圭偣鍥存爮锛屽彂閫佷笂閿佸強鏂藉皝鍛戒护
-
-
-
-
+                                    //寮�鍑鸿娌圭偣鍥存爮锛屽彂閫佷笂閿佸強鏂藉皝鍛戒护
+                                    feng(carId,"鏂藉皝",carRtuService,lockService);
                                 }
                             }else {
                                 //杞﹁締宸茬粡寮�鍑鸿娌圭偣锛屾煡鐪嬫槸鍚︽湁鍗告补鐐笽D
@@ -255,6 +270,10 @@
                                             ardAccessFenceService.updAccess(ardAccessFence);
                                             //宸茬粡杩涘叆鍗告补鐐癸紝涓嶅湪璺笂涓嶉渶瑕佸仠杞︽姤璀�
                                             isRoad = false;
+                                            if(stop){
+                                                //mqtt鍙戦�佹棦瀹歊tu鐘舵��
+                                                feng(carId,"鍗告补鐐�",carRtuService,lockService);
+                                            }
                                             break;
                                         }
                                     }
@@ -296,10 +315,8 @@
                                         pts.add(new Point2D.Double(Double.parseDouble(coord[j]), Double.parseDouble(coord[j + 1])));
                                     }
                                     if (!GeoTools.IsPtInPoly(point, pts)) {
-//寮�鍑轰簡鍗告补鐐瑰洿鏍忥紝鍙戦�佷笂閿佸強鏂借В灏佹寚浠�
-
-
-
+                                        //寮�鍑轰簡鍗告补鐐瑰洿鏍忥紝鍙戦�佷笂閿佸強鏂借В灏佹寚浠�
+                                        feng(carId,"鏂藉皝",carRtuService,lockService);
                                         //鍒犻櫎璇ユ潯杞﹁締鏁版嵁
                                         ardAccessFenceService.delAccess(carId);
                                     }else {
@@ -414,4 +431,89 @@
     public void run() {
         sendMassage();
     }
+
+    private void feng(String carId,String type,ArdSyCarRtuService carRtuService,ArdSyCarLockService lockService) throws MqttException {
+        //鏌ヨ瑁呮补鐐规棦瀹歊tu鐘舵��
+        ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
+        //鏌ヨ閿佷俊鎭�
+        List<ArdSyCarLock> ardSyCarLocks = lockService.carLock(ardSyCarRtu.getId());
+        Integer fengType = null;
+        if("瑁呮补鐐�".equals(type)){
+            fengType = ardSyCarRtu.getInstallType();
+        }else if("鍗告补鐐�".equals(type)){
+            fengType = ardSyCarRtu.getUnloadType();
+        }else if("鏂藉皝".equals(type)){
+            fengType = 0;
+        }
+        if(ardSyCarLocks.size()>0){
+            //1瑙e皝
+            if(fengType==1){
+                //濡傛灉涓嶆槸瑙e皝灏佺姸鎬侊紝鍒欏彂閫佹柦灏佸懡浠�
+                if(ardSyCarLocks.get(0).getRelayInfo()==0){
+                    Map<String,Object> map = new HashMap<>();
+                    map.put("A01", 110000);//瀵奸�氱涓�璺户鐢靛櫒
+                    map.put("A02", 110000);//瀵奸�氱浜岃矾缁х數鍣�
+                    map.put("res", String.valueOf(System.currentTimeMillis()));
+                    String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
+                    EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
+                    emqClient.connect();
+                    emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
+                    log.info("杞﹁締"+carId+"瑙e皝鍛戒护鍙戦�佹垚鍔燂紒");
+//                mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"瑙e皝");
+                }
+            }
+            //0鏂藉皝
+            if(fengType==0){
+                //閿佸紑鍏崇姸鎬�
+                int lockCloseNum = 0;
+                //濡傛灉涓嶆槸鏂藉皝鐘舵�侊紝鍒欏彂閫佹柦灏佸懡浠�
+                if(ardSyCarLocks.get(0).getRelayInfo()==1){
+                    for (int j = 0; j < ardSyCarLocks.size(); j++) {
+                        ArdSyCarLock ardSyCarLock = ardSyCarLocks.get(j);
+                        String currents = ardSyCarLock.getCurrents();
+                        Double currentInfo = ardSyCarLock.getCurrentInfo();
+                        //鐢垫祦鍊间负4.0鏄叧閿佺姸鎬�
+                        if(currentInfo.equals(4.00) || currentInfo.equals(4)){
+                            lockCloseNum += 1;
+                        }else {
+                            String key = "";
+                            if(currents.equals("C01")){
+                                key = "D03";
+                            }else if(currents.equals("C02")){
+                                key = "D04";
+                            }
+                            Map<String,Object> map = new HashMap();
+                            map.put(key, 0.01);
+                            map.put("res", String.valueOf(System.currentTimeMillis()));
+                            String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
+                            EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
+                            emqClient.connect();
+                            emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
+//                        mqttOnce.publishCar("carId",ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"寮�閿侊細"+currents);
+                            while(true){
+                                ArdSyCarLock ardSyCarLock1 = lockService.getCurrentInfo(ardSyCarRtu.getId(),currents);
+                                Double currentInfo1 = ardSyCarLock1.getCurrentInfo();
+                                if(currentInfo1.equals(4.00) || currentInfo1.equals(4)){
+                                    lockCloseNum +=1;
+                                    break;
+                                }
+                            }
+                        }
+                    }
+                    if(lockCloseNum == 2){
+                        Map<String,Object> map = new HashMap<>();
+                        map.put("A01", 100000);//鏂紑绗竴璺户鐢靛櫒
+                        map.put("A02", 100000);//鏂紑绗簩璺户鐢靛櫒
+                        map.put("res", String.valueOf(System.currentTimeMillis()));
+                        String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
+                        EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
+                        emqClient.connect();
+                        emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
+                        log.info("杞﹁締"+carId+"鏂藉皝鍛戒护鍙戦�佹垚鍔燂紒");
+//                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"鏂藉皝");
+                    }
+                }
+            }
+        }
+    }
 }

--
Gitblit v1.9.3