From 2df696b07d0ffdf7829d4d9cd3da23162dec8799 Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期五, 23 二月 2024 14:04:38 +0800
Subject: [PATCH] 更新

---
 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java |  143 +++++++++++++++++++++++++++++++++--------------
 1 files changed, 101 insertions(+), 42 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 c3486d2..bf31f63 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
@@ -26,6 +26,7 @@
 import org.eclipse.paho.client.mqttv3.MqttException;
 
 import java.awt.geom.Point2D;
+import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -80,13 +81,13 @@
             /*String carName = MapUtil.getStrVal(gpsMap, "carName","");//鑾峰彇杞︾墝鍙�
             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             System.out.println(sdf.format(new Date()));*/
-            log.debug(String.format("   ---->鏀跺埌瀹氫綅鏁版嵁:%s",JSON.toJSONString(gpsMap)));
+            log.debug(String.format("   ---->----鏀跺埌瀹氫綅鏁版嵁濡備笅:%s",JSON.toJSONString(gpsMap)));
             String carId = (String)gpsMap.get("carId");
             ((ArdSyCarDayServiceImpl)SpringUtils.getBean("ardSyCarDayServiceImpl")).insertArdSyCarDay(carId);//鏂板杞﹁締涓婃姤鏃堕棿
             Map<String,Object> result = ((ArdSyCarServiceImpl)SpringUtils.getBean("ardSyCarServiceImpl")).getArdSyCarAndDeptByCarId(carId);//鏌ヨ杞﹁締鍙婇儴闂�
             if(result != null){
-//                if("30".equals(carId)){
-                    //娓呮筏寮�濮�----------
+                //娓呮筏寮�濮�----------
+                try{
                     String lng = (String) gpsMap.get("lng").toString();//鑾峰彇缁忓害
                     String lat = (String) gpsMap.get("lat").toString();//鑾峰彇绾害
                     String carName = (String) gpsMap.get("carName");//鑾峰彇杞︾墝鍙�
@@ -108,7 +109,7 @@
                         //鏃犻攣
                         rtuType = false;
                     }
-//                    log.debug("瀹氫綅鏁版嵁锛氳溅杈哻arId:"+carId+"缁忓害lng:"+lng+"绾害lat:"+lat);
+    //                    log.debug("瀹氫綅鏁版嵁锛氳溅杈哻arId:"+carId+"缁忓害lng:"+lng+"绾害lat:"+lat);
                     //瀹氫箟2缁寸┖闂�
                     Point2D.Double point = new Point2D.Double(Double.parseDouble(lng), Double.parseDouble(lat));
                     List<Point2D.Double> pts = new ArrayList<Point2D.Double>();
@@ -176,42 +177,7 @@
                             }
                         }
                         //杞﹁締鏈夊�间紭鍏堝垽鏂槸鍚︿负鎵嬪姩娣诲姞杞﹁締
-                        if(ardAccessFence.getIsAlarm()==1){
-                            //1涓烘墜鍔ㄦ坊鍔犺溅杈嗘棤闇�鎶ヨ淇℃伅锛屾洿鏂颁綅缃嵆鍙�
-                            ardAccessFence.setLng(lng);
-                            ardAccessFence.setLat(lat);
-                            ardAccessFenceService.updAccess(ardAccessFence);
-                        }else if(ardAccessFence.getIsAlarm() == 2){
-                            //2涓烘墜鍔ㄦ坊鍔犳姤璀﹁溅杈嗘湁鎶ヨ锛屾墍鍦ㄥ洿鏍忓悕绉拌祴null,鎺掓煡鎶ヨ淇℃伅,鍙渶澶勭悊璺笂鎯呭喌
-                            ardAccessFence.setNowWallName(null);
-                            //濡傛灉鍦ㄨ矾涓婂垽鏂潗鏍囨槸鍚︿笌涓婃涓�鏍�
-                            if(ardAccessFence.getLng().equals(lng) && ardAccessFence.getLat().equals(lat)){
-                                if(timeType){
-                                    Date nowTime = sdf.parse(time);
-                                    Date lastTime = sdf.parse(ardAccessFence.getLastTime());
-                                    Long diff = (nowTime.getTime() - lastTime.getTime())/1000;
-                                    ArdAccessNum list = accessNumService.queryNum();
-                                    if(list!=null){
-                                        int alarm = list.getAlarm();
-                                        if(diff>=alarm){
-                                            //鎶ヨ瀛楁涓�1鎻愮ず鎶ヨ
-                                            ardAccessFence.setIsWarning(1);
-                                            ardAccessFence.setAlarmLat(lat);
-                                            ardAccessFence.setAlarmLng(lng);
-                                            ardAccessFenceService.updAccess(ardAccessFence);
-                                        }
-                                    }
-                                }else {
-                                    log.debug(carId+"鍙疯溅瀹氫綅鏃堕棿涓虹┖");
-                                }
-                            }else {
-                                //濡傛灉涓嶄竴鏍锋洿鏂板潗鏍�
-                                ardAccessFence.setLat(lat);
-                                ardAccessFence.setLng(lng);
-                                ardAccessFence.setLastTime(time);
-                                ardAccessFenceService.updAccess(ardAccessFence);
-                            }
-                        }else if(ardAccessFence.getIsAlarm() == 0 || ardAccessFence.getIsAlarm() == null){
+                        if(ardAccessFence.getIsAlarm() == 0 || ardAccessFence.getIsAlarm() == null){
                             //杞﹁締闈炴墜鍔ㄦ坊鍔犳暟鎹紝鍒ゆ柇鏄惁鏈夎繘鍏ュ洿鏍廔D
                             if(ardAccessFence.getIntoShipmentId()==null){
                                 //娌℃湁杩涘叆瑁呮补鐐癸紝璧嬪�肩粡绾害
@@ -367,10 +333,48 @@
                                     }
                                 }
                             }
+                        }else
+                        if(ardAccessFence.getIsAlarm()==1){
+                            //1涓烘墜鍔ㄦ坊鍔犺溅杈嗘棤闇�鎶ヨ淇℃伅锛屾洿鏂颁綅缃嵆鍙�
+                            ardAccessFence.setLng(lng);
+                            ardAccessFence.setLat(lat);
+                            ardAccessFenceService.updAccess(ardAccessFence);
+                        }else if(ardAccessFence.getIsAlarm() == 2){
+                            //2涓烘墜鍔ㄦ坊鍔犳姤璀﹁溅杈嗘湁鎶ヨ锛屾墍鍦ㄥ洿鏍忓悕绉拌祴null,鎺掓煡鎶ヨ淇℃伅,鍙渶澶勭悊璺笂鎯呭喌
+                            ardAccessFence.setNowWallName(null);
+                            //濡傛灉鍦ㄨ矾涓婂垽鏂潗鏍囨槸鍚︿笌涓婃涓�鏍�
+                            if(ardAccessFence.getLng().equals(lng) && ardAccessFence.getLat().equals(lat)){
+                                if(timeType){
+                                    Date nowTime = sdf.parse(time);
+                                    Date lastTime = sdf.parse(ardAccessFence.getLastTime());
+                                    Long diff = (nowTime.getTime() - lastTime.getTime())/1000;
+                                    ArdAccessNum list = accessNumService.queryNum();
+                                    if(list!=null){
+                                        int alarm = list.getAlarm();
+                                        if(diff>=alarm){
+                                            //鎶ヨ瀛楁涓�1鎻愮ず鎶ヨ
+                                            ardAccessFence.setIsWarning(1);
+                                            ardAccessFence.setAlarmLat(lat);
+                                            ardAccessFence.setAlarmLng(lng);
+                                            ardAccessFenceService.updAccess(ardAccessFence);
+                                        }
+                                    }
+                                }else {
+                                    log.debug(carId+"鍙疯溅瀹氫綅鏃堕棿涓虹┖");
+                                }
+                            }else {
+                                //濡傛灉涓嶄竴鏍锋洿鏂板潗鏍�
+                                ardAccessFence.setLat(lat);
+                                ardAccessFence.setLng(lng);
+                                ardAccessFence.setLastTime(time);
+                                ardAccessFenceService.updAccess(ardAccessFence);
+                            }
                         }
-//                    }
+                    }
+                    //娓呮筏缁撴潫------------
+                }catch(Exception e){
+
                 }
-                //娓呮筏缁撴潫------------
 
                 gpsMap.putAll(result);
                 String ancestors = (String) gpsMap.get("ancestors");//鑾峰彇鐖剁骇閮ㄩ棬
@@ -409,6 +413,30 @@
                         }
                     }
                 }
+                //鑻ユ湁鐢ㄦ埛闇�瑕佽拷韪溅杈嗭紝鍒欒绠楅浼颁綅缃�
+                if(PositionContainer.getUserPositionMap().size() != 0){
+                    for(String userId : PositionContainer.getUserPositionMap().keySet()){
+                        Map<String,Map<String,Object>> carIdCarMap =  PositionContainer.getUserPositionMap().get(userId);
+                        if(carIdCarMap != null){
+                            if(carIdCarMap.keySet().contains(carId)){
+                                if(PositionContainer.getCarPositionMap().get(carId) == null){
+                                    gpsMap.put("elng",gpsMap.get("lng"));
+                                    gpsMap.put("elat",gpsMap.get("lat"));
+                                }else{
+                                    Double velocityOld = ((Integer) PositionContainer.getCarPositionMap().get(carId).get("speed")).doubleValue();
+                                    Double velocityNew = ((Integer) gpsMap.get("speed")).doubleValue();
+                                    Double acceleration = Double.valueOf(1000*(velocityNew - velocityOld)/3600);
+                                    Double distance = getDistance(velocityNew, acceleration ,"1.5");
+                                    Double[] eposition = azimuth_offset(((BigDecimal)gpsMap.get("lng")).doubleValue(),((BigDecimal)gpsMap.get("lat")).doubleValue(),(Integer)gpsMap.get("drct"),distance);
+                                    gpsMap.put("elng",eposition[0]);
+                                    gpsMap.put("elat",eposition[1]);
+                                }
+                            }
+                        }
+                    }
+                }
+                //瀛樺叆瀹炴椂浣嶇疆瀹瑰櫒
+                PositionContainer.getCarPositionMap().put(carId,gpsMap);
                 //瀛樺叆鐢ㄦ埛瀹瑰櫒
                 if(PositionContainer.getUserPositionMap().size() != 0){
                     for(String userId : PositionContainer.getUserPositionMap().keySet()){
@@ -568,4 +596,35 @@
             }
         }
     }
+
+    public Double[] azimuth_offset(double origin_lon, double origin_lat, Integer direction,double distance){
+        Double[] lonlat = new Double[2];
+        if(direction != null && distance > 0){
+            lonlat[0] = origin_lon + distance * Math.sin(direction* Math.PI / 180) * 180 / ( Math.PI * 6371229 * Math.cos(origin_lat * Math.PI / 180));
+            lonlat[1] = origin_lat + distance * Math.cos(direction* Math.PI / 180) / ( Math.PI * 6371229 / 180);
+        }else{
+            lonlat[0] = origin_lon;
+            lonlat[1] = origin_lat;
+        }
+        return lonlat;
+    }
+
+    public Double getDistance(Double velocity ,Double acceleration ,String time){
+        Double distance = velocity*Double.parseDouble(time) + 0.5*acceleration*Double.parseDouble(time)*Double.parseDouble(time);
+        return distance;
+    }
+
+    /*public Double getVelocity(Double velocity ,Double acceleration ,String time){
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Long t = (long) 0;
+        try {
+            t = (new Date().getTime() - simpleDateFormat.parse(time).getTime())/1000;
+        } catch (Exception e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        Double velocityt = velocity + acceleration*t;
+        return velocityt;
+    }*/
+
 }

--
Gitblit v1.9.3