From 7c1e2217d0e4aad7498a5c136710c33cb55d00d0 Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: 星期三, 17 七月 2024 15:11:00 +0800
Subject: [PATCH] 三一车辆模型bug修改提交

---
 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java |  382 ++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 256 insertions(+), 126 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
index 70c35e3..8197af4 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
@@ -26,6 +26,7 @@
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
 import com.ruoyi.sy.domain.ArdAccessFence;
+import com.ruoyi.sy.mapper.ArdTankLockMapper;
 import com.ruoyi.sy.param.ArdSyCarParam;
 import com.ruoyi.sy.vo.ArdSyCarVo;
 import com.ruoyi.system.mapper.SysDeptMapper;
@@ -98,6 +99,9 @@
 
     @Resource
     private SysDeptMapper sysDeptMapper;
+
+    @Resource
+    private ArdTankLockMapper ardTankLockMapper;
 
     @Value("${minio.endpoint}")
     private String minioEndpoint;
@@ -212,7 +216,16 @@
             }
         }
         MinioUtil.removeObjects("sycar", objectNames);
-        return ardSyCarMapper.deleteArdSyCarByIds(ids);
+        try{
+            return ardSyCarMapper.deleteArdSyCarByIds(ids);
+        }finally {
+            List<String> carIds = new ArrayList();
+            for(ArdSyCar ardSyCar : result){
+                carIds.add(ardSyCar.getCarId());
+            }
+            ardTankLockMapper.deleteArdTankLockAndWallByCarIds(carIds);
+        }
+
     }
 
     /**
@@ -328,59 +341,26 @@
 
     @Override
     public List<Map<String, String>> getAllCarModel() {
-        boolean exsit = MinioUtil.exitsBucket("sycar");
+        boolean exsit = MinioUtil.exitsBucket("system");
         if (exsit) {
             List<Map<String, String>> listObjetcName = new ArrayList<>();
             try {
-               // ListObjectsArgs listObjectsArgs = ListObjectsArgs.builder().prefix("carmodel/").bucket("sycar").build();
-                Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("sycar","carmodel");
+                //Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("sycar","carmodel");
+                Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("system","model/car");
                 for (Result<Item> result : myObjects) {
                     Item item = result.get();
                     Map<String, String> map = new HashMap();
                     String[] strArr = item.objectName().split("/");
-                    map.put("carType", strArr[1]);
-                    map.put("carModel", "sycar/" + item.objectName());
-                    /*switch (item.objectName()) {
-                        case "carmodel/aodi.glb":
-                            map.put("carType", "濂ヨ开");
-                            break;
-                        case "carmodel/baolai.glb":
-                            map.put("carType", "瀹濇潵");
-                            break;
-                        case "carmodel/bieke.glb":
-                            map.put("carType", "鍒厠");
-                            break;
-                        case "carmodel/bus1.glb":
-                            map.put("carType", "澶у杞�");
-                            break;
-                        case "carmodel/car.glb":
-                            map.put("carType", "灏忓瀷杞�");
-                            break;
-                        case "carmodel/fire(1).glb":
-                            map.put("carType", "娑堥槻杞�");
-                            break;
-                        case "carmodel/fute.glb":
-                            map.put("carType", "绂忕壒");
-                            break;
-                        case "carmodel/jingche_a.glb":
-                            map.put("carType", "璀﹁溅");
-                            break;
-                        case "carmodel/jiuhu.glb":
-                            map.put("carType", "鏁戞姢杞�");
-                            break;
-                        case "carmodel/oil.glb":
-                            map.put("carType", "娌圭綈杞�");
-                            break;
-                        case "carmodel/truck.glb":
-                            map.put("carType", "宸ョ▼鐢ㄨ溅");
-                            break;
-                        case "carmodel/van1.glb":
-                            map.put("carType", "澶ц揣杞�");
-                            break;
-                        default:
-                            break;
-                    }*/
-                    listObjetcName.add(map);
+                    try{
+                        String carType = strArr[2];
+                        if(!carType.contains(".")){
+                            map.put("carType", carType);
+                            map.put("carModel", "system/" + item.objectName());
+                            listObjetcName.add(map);
+                        }
+                    }catch(Exception e){
+                        e.printStackTrace();
+                    }
                 }
                 return listObjetcName;
             } catch (Exception ex) {
@@ -474,13 +454,15 @@
     public Map<String, Object> getArdSyCarAndDeptByCarId(String carId) {
         Map<String, Object> result = ardSyCarMapper.getArdSyCarAndDeptByCarId(carId);
         if (result != null) {
-            if (result.get("carPicture") != null) {
+            /*if (result.get("carPicture") != null) {
                 if (!((String) result.get("carPicture")).equals("")) {
-                    /*String url = ((String) result.get("carPicture")).split("sycar")[0];
-                    String carModel = url + (String) result.get("carModel");*/
                     String carModel = this.minioEndpoint + "/" + (String) result.get("carModel");
                     result.put("carModel", carModel);
                 }
+            }*/
+            if(result.get("carModel") != null || "".equals(result.get("carModel"))){
+                String carModel = this.minioEndpoint + "/" + (String) result.get("carModel");
+                result.put("carModel", carModel);
             }
         }
         return result;
@@ -725,9 +707,9 @@
                     break;
                 }
             }
-            if(!isCar){
+            /*if(!isCar){
                 list.remove(list.get(i));
-            }
+            }*/
         }
         return list;
     }
@@ -748,7 +730,12 @@
         String passwordMd5 = DigestUtils.md5Hex(password31);
         Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
         Map<String, Object> result0 = new HashMap();
-        result0 = sYClient.getCarGPSTrack(syURL, carId, startTime, endTime, maxSpeed, (String) result1.get("sessionId"));
+        //result0 = sYClient.getCarGPSTrack(syURL, carId, startTime, endTime, maxSpeed, (String) result1.get("sessionId"));
+        try {
+            result0 = getCarGPSTrack(syURL, carId, startTime, endTime, maxSpeed, (String) result1.get("sessionId"));
+        } catch (Exception e) {
+            return Results.error("鏌ヨ鍘嗗彶鏁版嵁鏁伴噺杩囧瀵艰嚧瓒呮椂锛岃缂╁皬鑼冨洿鏌ヨ锛�");
+        }
         List<Map<String, Object>> list = (List<Map<String, Object>>) result0.get("list");
         if (list.isEmpty()) {
             return Results.succeed();
@@ -765,6 +752,37 @@
                 m.putAll(sgnMap);
             }
             return Results.succeed(list);
+        }
+    }
+
+    public static Map<String,Object> getCarGPSTrack(String syURL,String carId,String startTime,String endTime,String maxSpeed,String sessionId){
+        OkHttpClient okHttpClient = new OkHttpClient();
+
+        Request request = new Request.Builder()
+                .url(syURL + "/gps-web/api/get_gps_h.jsp?carId=" + carId + "&startTime=" + startTime + "&endTime=" + endTime + "&sessionId=" + sessionId)
+                .build();
+
+        Response response = null;
+        try {
+            response = okHttpClient.newCall(request).execute();
+        } catch (IOException e1) {
+            // TODO Auto-generated catch block
+            e1.printStackTrace();
+        }
+
+        response.headers(); //鍝嶅簲澶�
+
+        ResponseBody responseBody = response.body();
+
+        try {
+            String message = responseBody.string();// 鍝嶅簲浣�
+            Map<String,Object> map = (Map<String, Object>) JSON.parse(message);
+            //System.out.println(message);
+            return map;
+        } catch (IOException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+            return new HashMap();
         }
     }
 
@@ -934,15 +952,43 @@
 
     @Override
     public Results chaseCarByCarId(String usersId, String carId, String cycle) {
+        ArdSyUser ardSyUser = ardSyUserMapper.userById(usersId);
+        String userId ="";
+        String password = "";
+        if(ardSyUser != null){
+            userId = ardSyUser.getUserId();
+            password = DigestUtils.md5Hex(ardSyUser.getPassword());
+        }else{
+            return Results.error("娌℃湁鎸傛帴涓変竴杞﹁締鐢ㄦ埛");
+        }
+        List<SysConfig> syURLResult = sysConfigMapper.selectByType("syCarPT");
+        String syURL = "";
+        if(syURLResult.size() != 0){
+            syURL = syURLResult.get(0).getConfigValue();
+        }else{
+            return Results.error("涓変竴杞﹁締鍦板潃鏈綍鍏�");
+        }
+
+        String sessionId = "";
+        for(String key : ONLINE_USER_SESSIONS.keySet()){
+            if(key.startsWith(usersId + "_")){
+                sessionId = key;
+            }
+        }
+        if(sessionId.equals("")){//娌℃湁session灏辫繑鍥炲け璐�
+            return Results.error("杩借釜澶辫触");
+        }
         try {
-            /*Map<String,Map<String,Object>> map = new HashMap();
-            map.put(carId,new HashMap());
-            PositionContainer.getUserPositionMap().put(usersId,map);*/
             if (cycle.equals("0")) {
                 if (userCarTimerMap.get(usersId) != null) {
                     userCarTimerMap.get(usersId).cancel();
                     userCarTimerMap.remove(usersId);
                     PositionContainer.getUserPositionMap().remove(usersId);
+                    Map<String,Object> loginResult = sYClient.logIn(syURL, password, userId);
+                    String sySessionId = (String) loginResult.get("sessionId");
+                    String params = "%7B%220020%22:%220%22,%220029%22:%2230%22%7d";
+                    sYClient.changePositionSendMode(syURL, carId,104,"CmdSetParam",params,sySessionId);//鍋滄杩借釜锛屾敼涓哄畾鏃�30s鎺ㄩ��
+                    System.out.println("鍋滄杩借釜");
                 }
                 return Results.succeed("鍋滄杩借釜");
             } else {
@@ -953,8 +999,32 @@
                     Map<String, Map<String, Object>> map = new HashMap();
                     map.put(carId, new HashMap());
                     PositionContainer.getUserPositionMap().put(usersId, map);
+
+                    Map<String,Object> loginResult = sYClient.logIn(syURL, password, userId);
+                    String sySessionId = (String) loginResult.get("sessionId");
+                    List<SysConfig> distanceSYResult = sysConfigMapper.selectByType("31time");
+                    String time = "";
+                    if(distanceSYResult.size() != 0){
+                        time = distanceSYResult.get(0).getConfigValue();
+                    }else{
+                        return Results.error("涓変竴杞﹁締瀹氭椂鏈綍鍏�");
+                    }
+                    String params = "%7B%220020%22:%220%22,%220029%22:%22"+time+"%22%7d";
+                    sYClient.changePositionSendMode(syURL, carId,104,"CmdSetParam",params,sySessionId);//寮�濮嬭拷韪紝鏀逛负瀹氭椂鎺ㄩ��
+
+                    Map<String, Object> position = PositionContainer.getCarPositionMap().get(carId);//鏌ヨ褰撳墠杞﹁締浣嶇疆
+                    if (position != null) {
+                        if (position.size() != 0) {
+                            position.put("elng",position.get("lng"));
+                            position.put("elat",position.get("lat"));
+                            Map<String, Map<String, Object>> data = new HashMap();
+                            data.put("31000", position);
+                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
+                        }
+                    }
+
                     Date date = new Date();
-                    Timer carPositionTimer = new Timer();//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
+                    Timer carPositionTimer = new Timer(sessionId);//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
                     TimerTask carPositionTask = new TimerTask() {
                         @Override
                         public void run() {
@@ -963,18 +1033,32 @@
                                 if (position.size() != 0) {
                                     Map<String, Map<String, Object>> data = new HashMap();
                                     data.put("31000", position);
-                                    //WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
-                                    String sessionId = "";
-                                    for(String key : ONLINE_USER_SESSIONS.keySet()){
-                                        if(key.startsWith(usersId + "_")){
-                                            sessionId = key;
-                                        }
-                                    }
-                                    if(sessionId.equals("")){//鐢ㄦ埛绂荤嚎閲婃斁璧勬簮
+                                    String sessionId = Thread.currentThread().getName();
+                                    if(ONLINE_USER_SESSIONS.get(sessionId) == null){//鐢ㄦ埛绂荤嚎閲婃斁璧勬簮
                                         if (userCarTimerMap.get(usersId) != null) {
                                             userCarTimerMap.get(usersId).cancel();
                                             userCarTimerMap.remove(usersId);
                                             PositionContainer.getUserPositionMap().remove(usersId);
+
+                                            ArdSyUser ardSyUser = ardSyUserMapper.userById(usersId);
+                                            String userId ="";
+                                            String password = "";
+                                            if(ardSyUser != null){
+                                                userId = ardSyUser.getUserId();
+                                                password = ardSyUser.getPassword();
+                                            }
+                                            List<SysConfig> syURLResult = sysConfigMapper.selectByType("syCarPT");
+                                            String syURL = "";
+                                            if(syURLResult.size() != 0){
+                                                syURL = syURLResult.get(0).getConfigValue();
+                                            }
+                                            if(!userId.equals("") && !password.equals("") && !syURL.equals("")){
+                                                Map<String,Object> loginResult = sYClient.logIn(syURL, password, userId);
+                                                String sySessionId = (String) loginResult.get("sessionId");
+                                                String params = "%7B%220020%22:%220%22,%220029%22:%2230%22%7d";
+                                                sYClient.changePositionSendMode(syURL, carId,104,"CmdSetParam",params,sySessionId);//鍋滄杩借釜锛屾敼涓哄畾鏃�30s
+                                            }
+                                            System.out.println("鐢ㄦ埛绂荤嚎锛屽仠姝㈣拷韪�");
                                         }
                                     }
                                     WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
@@ -989,8 +1073,32 @@
                     Map<String, Map<String, Object>> map = new HashMap();
                     map.put(carId, new HashMap());
                     PositionContainer.getUserPositionMap().put(usersId, map);
+
+                    Map<String,Object> loginResult = sYClient.logIn(syURL, password, userId);
+                    String sySessionId = (String) loginResult.get("sessionId");
+                    List<SysConfig> distanceSYResult = sysConfigMapper.selectByType("31time");
+                    String time = "";
+                    if(distanceSYResult.size() != 0){
+                        time = distanceSYResult.get(0).getConfigValue();
+                    }else{
+                        return Results.error("涓変竴杞﹁締瀹氭椂鏈綍鍏�");
+                    }
+                    String params = "%7B%220020%22:%220%22,%220029%22:%22"+time+"%22%7d";
+                    sYClient.changePositionSendMode(syURL, carId,104,"CmdSetParam",params,sySessionId);//寮�濮嬭拷韪紝鏀逛负瀹氭椂鎺ㄩ��
+
+                    Map<String, Object> position = PositionContainer.getCarPositionMap().get(carId);//鏌ヨ褰撳墠杞﹁締浣嶇疆
+                    if (position != null) {
+                        if (position.size() != 0) {
+                            position.put("elng",position.get("lng"));
+                            position.put("elat",position.get("lat"));
+                            Map<String, Map<String, Object>> data = new HashMap();
+                            data.put("31000", position);
+                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
+                        }
+                    }
+
                     Date date = new Date();
-                    Timer carPositionTimer = new Timer();//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
+                    Timer carPositionTimer = new Timer(sessionId);//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
                     TimerTask carPositionTask = new TimerTask() {
                         @Override
                         public void run() {
@@ -999,18 +1107,32 @@
                                 if (position.size() != 0) {
                                     Map<String, Map<String, Object>> data = new HashMap();
                                     data.put("31000", position);
-                                    //WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
-                                    String sessionId = "";
-                                    for(String key : ONLINE_USER_SESSIONS.keySet()){
-                                        if(key.startsWith(usersId + "_")){
-                                            sessionId = key;
-                                        }
-                                    }
-                                    if(sessionId.equals("")){//鐢ㄦ埛绂荤嚎閲婃斁璧勬簮
+                                    String sessionId = Thread.currentThread().getName();
+                                    if(ONLINE_USER_SESSIONS.get(sessionId) == null){//鐢ㄦ埛绂荤嚎閲婃斁璧勬簮
                                         if (userCarTimerMap.get(usersId) != null) {
                                             userCarTimerMap.get(usersId).cancel();
                                             userCarTimerMap.remove(usersId);
                                             PositionContainer.getUserPositionMap().remove(usersId);
+
+                                            ArdSyUser ardSyUser = ardSyUserMapper.userById(usersId);
+                                            String userId ="";
+                                            String password = "";
+                                            if(ardSyUser != null){
+                                                userId = ardSyUser.getUserId();
+                                                password = ardSyUser.getPassword();
+                                            }
+                                            List<SysConfig> syURLResult = sysConfigMapper.selectByType("syCarPT");
+                                            String syURL = "";
+                                            if(syURLResult.size() != 0){
+                                                syURL = syURLResult.get(0).getConfigValue();
+                                            }
+                                            if(!userId.equals("") && !password.equals("") && !syURL.equals("")){
+                                                Map<String,Object> loginResult = sYClient.logIn(syURL, password, userId);
+                                                String sySessionId = (String) loginResult.get("sessionId");
+                                                String params = "%7B%220020%22:%220%22,%220029%22:%2230%22%7d";
+                                                sYClient.changePositionSendMode(syURL, carId,104,"CmdSetParam",params,sySessionId);//鍋滄杩借釜锛屾敼涓哄畾鏃�30s
+                                            }
+                                            System.out.println("鐢ㄦ埛绂荤嚎锛屽仠姝㈣拷韪�");
                                         }
                                     }
                                     WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
@@ -1208,62 +1330,70 @@
      */
     @Override
     public List<Map<String, Object>> getNearCar(SchedulingParam param) {
-        Double longitude = param.getLongitude();
-        Double latitude = param.getLatitude();
-        Integer radius = param.getSealingRadius();
-        if (longitude == null && latitude == null) {
-            log.debug("鍘熺偣鍧愭爣涓虹┖");
-            return null;
-        }
-        if (radius == null) {
-            log.debug("鍗婂緞璺濈涓虹┖");
-            return null;
-        }
-        String userId = SecurityUtils.getUserId();
-        ArdSyUser syUser = new ArdSyUser();
-        syUser.setSysUserId(userId);
-        List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(syUser);
-        if (ardSyUserList.size() == 0) {
-            log.debug("鐢ㄦ埛鏈寕鎺ヤ笁涓�杞﹁締");
-            return null;
-        }
-        ArdSyUser ardSyUser = ardSyUserList.get(0);
-        String syUrl = redisCache.getCacheObject("sys_config:syCarPT");
-        String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
-        Map<String, Object> LogInResult = sYClient.logIn(syUrl, passwordMd5, ardSyUser.getUserId());
-        String sessionId = (String) LogInResult.get("sessionId");
+        try {
+            Double longitude = param.getLongitude();
+            Double latitude = param.getLatitude();
+            Integer radius = param.getSealingRadius();
+            if (longitude == null && latitude == null) {
+                log.debug("鍘熺偣鍧愭爣涓虹┖");
+                return null;
+            }
+            if (radius == null) {
+                log.debug("鍗婂緞璺濈涓虹┖");
+                return null;
+            }
+            String userId = SecurityUtils.getUserId();
+            ArdSyUser syUser = new ArdSyUser();
+            syUser.setSysUserId(userId);
+            List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(syUser);
+            if (ardSyUserList.size() == 0) {
+                log.debug("鐢ㄦ埛鏈寕鎺ヤ笁涓�杞﹁締");
+                return null;
+            }
+            ArdSyUser ardSyUser = ardSyUserList.get(0);
+            String syUrl = redisCache.getCacheObject("sys_config:syCarPT");
+            String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
+            Map<String, Object> LogInResult = sYClient.logIn(syUrl, passwordMd5, ardSyUser.getUserId());
+            String sessionId = (String) LogInResult.get("sessionId");
 
-        Map<String, Object> teamList = sYClient.getTeamList(syUrl, ardSyUser.getUserId(), sessionId);
-        List<Map<String, Object>> listMap = (List<Map<String, Object>>) teamList.get("list");
-        List<Map<String, Object>> allList = new ArrayList<>();
-        for (Map<String, Object> team : listMap) {
-            String teamId = (String) team.get("teamId");
-            Map<String, Object> carListMap = sYClient.getCarList1(syUrl, teamId, ardSyUser.getUserId(), sessionId);
-            if (((String) carListMap.get("rspCode")).equals("1")) {
-                List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
-                allList.addAll(list);
+            Map<String, Object> teamList = sYClient.getTeamList(syUrl, ardSyUser.getUserId(), sessionId);
+            List<Map<String, Object>> listMap = (List<Map<String, Object>>) teamList.get("list");
+            List<Map<String, Object>> allList = new ArrayList<>();
+            for (Map<String, Object> team : listMap) {
+                String teamId = (String) team.get("teamId");
+                Map<String, Object> carListMap = sYClient.getCarList1(syUrl, teamId, ardSyUser.getUserId(), sessionId);
+                if (((String) carListMap.get("rspCode")).equals("1")) {
+                    List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
+                    allList.addAll(list);
+                }
             }
-        }
-        //杩囨护鍦ㄧ嚎杞﹁締
-        List<Map<String, Object>> onlineList = allList.stream()
-                .filter(map -> !"绂荤嚎".equals(map.get("stateCn")))
-                .collect(Collectors.toList());
-        List<Map<String, Object>> filteredList = new ArrayList<>();
-        //杩囨护鍗婂緞
-        for (Map<String, Object> carMap : onlineList) {
-            String carId = (String) carMap.get("carId");
-            Map<String, Object> carGPSTrack = sYClient.getCarNearPositionByCarId(syUrl, carId, ardSyUser.getUserId(), sessionId);
-            List<Map<String, Object>> carGPSMap = (List<Map<String, Object>>) carGPSTrack.get("list");
-            Double lng = Double.valueOf((String) carGPSMap.get(0).get("lng"));
-            Double lat = Double.valueOf((String) carGPSMap.get(0).get("lat"));
-            double distance = GisUtil.getDistance( new double[]{longitude,latitude}, new double[]{lng, lat});
-            if (distance <= radius) {
-                carMap.put("longitude",lng);
-                carMap.put("latitude",lat);
-                filteredList.add(carMap); // 灏嗘弧瓒虫潯浠剁殑杞﹁締娣诲姞鍒扮瓫閫夊垪琛ㄤ腑
+            //杩囨护鍦ㄧ嚎杞﹁締
+            List<Map<String, Object>> onlineList = allList.stream()
+                    .filter(map -> !"绂荤嚎".equals(map.get("stateCn")))
+                    .collect(Collectors.toList());
+            List<Map<String, Object>> filteredList = new ArrayList<>();
+            //杩囨护鍗婂緞
+            for (Map<String, Object> carMap : onlineList) {
+                String carId = (String) carMap.get("carId");
+                Map<String, Object> carGPSTrack = sYClient.getCarNearPositionByCarId(syUrl, carId, ardSyUser.getUserId(), sessionId);
+                List<Map<String, Object>> carGPSMap = (List<Map<String, Object>>) carGPSTrack.get("list");
+                if(carGPSMap.size()>0) {
+                    Double lng = Double.valueOf((String) carGPSMap.get(0).get("lng"));
+                    Double lat = Double.valueOf((String) carGPSMap.get(0).get("lat"));
+                    double distance = GisUtil.getDistance(new double[]{longitude, latitude}, new double[]{lng, lat});
+                    if (distance <= radius) {
+                        carMap.put("longitude", lng);
+                        carMap.put("latitude", lat);
+                        filteredList.add(carMap); // 灏嗘弧瓒虫潯浠剁殑杞﹁締娣诲姞鍒扮瓫閫夊垪琛ㄤ腑
+                    }
+                }
             }
+            return filteredList;
+        }catch (Exception e)
+        {
+           log.error("鑾峰彇闄勮繎鑼冨洿鍐呯殑杞﹁締淇℃伅寮傚父:"+e.getMessage());
+            return null;
         }
-        return filteredList;
     }
     /**
      * 鑾峰彇鑼冨洿鍐呯殑杞﹁締淇℃伅(澶氳竟褰�)

--
Gitblit v1.9.3