From dee2cf1591b135c9bf75dcaf81a96ee48435b5f9 Mon Sep 17 00:00:00 2001
From: Administrator <1144154118@qq.com>
Date: 星期四, 03 八月 2023 17:17:22 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java |  437 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 424 insertions(+), 13 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 f788f0d..efec4be 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
@@ -1,17 +1,15 @@
 package com.ruoyi.sy.service.impl;
 
 import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.utils.uuid.IdUtils;
-import com.ruoyi.common.websocket.util.WebSocketUtils;
+import com.ruoyi.utils.websocket.util.WebSocketUtils;
 import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
 import com.ruoyi.device.hiksdk.util.minio.MinioUtils;
 import com.ruoyi.sy.domain.ArdSyUser;
@@ -37,7 +35,7 @@
 
 import javax.annotation.Resource;
 
-import static com.ruoyi.common.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;
+import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;
 
 /**
  * 涓変竴杞﹁締Service涓氬姟灞傚鐞�
@@ -61,6 +59,10 @@
 
     @Resource
     private SYClient sYClient;
+
+    private Map<Integer,Map<String,String>> logInMap = new HashMap();
+
+    private  Map<String, Timer> userCarTimerMap = new HashMap();
 
     /**
      * 鏌ヨ涓変竴杞﹁締
@@ -355,26 +357,435 @@
     @Override
     public Map<String, Object> getArdSyCarAndDeptByCarId(String carId) {
         Map<String, Object> result = ardSyCarMapper.getArdSyCarAndDeptByCarId(carId);
+        if(result != 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");
+                    result.put("carModel",carModel);
+                }
+            }
+        }
         return result;
     }
 
     @Override
     public void sendArdSyCarPosition() {
         for(String key : ONLINE_USER_SESSIONS.keySet()){
-            SysUser sysUser = userMapper.selectUserById(key);
-            String deptId = String.valueOf(sysUser.getDeptId());
-            Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
-            Map<Integer,Object> data = new HashMap();
-            data.put(30000, map.values());
-            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+            if(PositionContainer.getUserPositionMap().keySet().contains(key)){//褰撹拷韪殑杞﹁締瀹瑰櫒鍖呭惈姝ょ敤鎴稩d锛屽垯瀹炴椂浣嶇疆鎺ㄩ�侀渶瑕佸墧闄よ杞﹁締
+                SysUser sysUser = userMapper.selectUserById(key);
+                if(sysUser == null){
+                    //return;
+                    continue;
+                }
+                String deptId = String.valueOf(sysUser.getDeptId());
+                Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
+                List<String> carIdList = new ArrayList();
+                carIdList.addAll(PositionContainer.getUserPositionMap().get(key).keySet());
+                String carId = carIdList.get(0);
+                map.remove(carId);
+                if(map != null){
+                    Map<String,Object> data = new HashMap();
+                    data.put("30000", map.values());
+                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+                }
+            }else{
+                SysUser sysUser = userMapper.selectUserById(key);
+                if(sysUser == null){
+                    //return;
+                    continue;
+                }
+                String deptId = String.valueOf(sysUser.getDeptId());
+                Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
+                if(map != null){
+                    Map<String,Object> data = new HashMap();
+                    data.put("30000", map.values());
+                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+                }
+            }
+        }
+        for(String userId : userCarTimerMap.keySet()){//鐢ㄦ埛绂荤嚎鍚庡皢杞﹁締杩借釜璧勬簮閲婃斁
+            if(!ONLINE_USER_SESSIONS.keySet().contains(userId)){
+                userCarTimerMap.get(userId).cancel();
+                userCarTimerMap.remove(userId);
+                PositionContainer.getUserPositionMap().remove(userId);
+            }
         }
     }
 
     @Override
-    public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data) {
+    public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data) {
         List<SysUser> result = userMapper.getSysUserByCarId(carId);
         for(SysUser sysUser : result){
             WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data));
         }
     }
+
+    /**
+     * 鏍规嵁鐢ㄦ埛鑾峰彇涓変竴鍒楄〃
+     * @return
+     */
+    @Override
+    public Map<String,Object> allListByUser(ArdSyUser ardSyUser,String syURL,String usersId){
+        Map<String,Object> result0 = new HashMap();
+        //鍒ゆ柇鍏宠仈琛ㄦ槸鍚︽湁鏁版嵁
+        if(ardSyUser!=null){
+            Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
+            //31鐢ㄦ埛鍚嶅瘑鐮�
+            String username31 = ardSyUser.getUserId();
+            String password31 = ardSyUser.getPassword();
+            String passwordMd5 = DigestUtils.md5Hex(password31);
+            Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+            result = new HashMap();
+            result.put("userId", username31);
+            result.put("sessionId", (String) result1.get("sessionId"));
+            try {
+                result0 = sYClient.getTeamList(syURL,result.get("userId"),result.get("sessionId"));
+            } catch (Exception e) {
+                Map<String,Object> map = new HashMap();
+                map.put("rspCode", 0);
+                map.put("list", new ArrayList());
+                return map;
+            }
+            int online = 0;
+            for(Map<String,Object> map : (List<Map<String,Object>>) result0.get("list")){
+                Map<String,Object> resultMap = sYClient.getTeamCarList(syURL,(String)map.get("teamId"),result.get("sessionId"));
+                List<Map<String,Object>> carList = (List<Map<String, Object>>) resultMap.get("carList");
+                for(Map<String,Object> m : carList){
+                    if(((String) m.get("stateCn")).contains("鍦ㄧ嚎")){
+                        online = online + 1;
+                    }else{
+                        continue;
+                    }
+                }
+                for(Map<String,Object> m : (List<Map<String,Object>>) result0.get("list")){
+                    if(((String) m.get("teamId")).equals(((String) map.get("teamId")))){
+                        map.put("count", Integer.parseInt((String) m.get("carNum")));
+                    }
+                }
+                map.put("online", online);
+                online = 0;
+            }
+        }else {
+            result0.put("鍒楄〃涓虹┖锛�","鏃犲叧鑱旇处鍙凤紒");
+        }
+        return result0;
+    }
+
+    @Override
+    public List<Map<String,String>> getCarList(ArdSyUser ardSyUser, String syURL, String usersId,String teamId){
+        List<Map<String,String>> list = new ArrayList<>();
+        Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
+        //31鐢ㄦ埛鍚嶅瘑鐮�
+        String username31 = ardSyUser.getUserId();
+        String password31 = ardSyUser.getPassword();
+        String passwordMd5 = DigestUtils.md5Hex(password31);
+        Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+        result = new HashMap();
+        result.put("userId", username31);
+        result.put("sessionId", (String) result1.get("sessionId"));
+        //鏌ヨ璇eamId涓嬬殑杞﹁締鏁版嵁
+        Map<String,Object> carList31 = new HashMap();
+        carList31 = sYClient.getCarList1(syURL,teamId, result.get("userId"),result.get("sessionId"));
+        //鎷垮埌杞﹁締鏁版嵁
+        list= (List) carList31.get("list");
+        if(list.isEmpty()){
+            return list;
+        }else {
+            List<String> carIdList = new ArrayList();
+            //鎵�鏈塩arId
+            for(Map<String,String> m : list){
+                carIdList.add(m.get("carId"));
+            }
+            if(carIdList.size() == 0){
+                Map<String,String> map0 = new HashMap();
+                map0.put("list", "{}");
+                map0.put("rspCode", "1");
+                list.add(map0);
+                return list;
+            }
+            //娣诲姞杞﹁締灞炴��
+            for(Map<String,String> m : list){
+                switch (m.get("state")) {
+                    case "1":
+                        m.put("carState", "绂荤嚎-浠庢湭鎶ュ畾浣�");break;
+                    case "2":
+                        m.put("carState", "绂荤嚎-娆犺垂");break;
+                    case "3":
+                        m.put("carState", "绂荤嚎");break;
+                    case "4":
+                        m.put("carState", "绂荤嚎-鎶ヨ");break;
+                    case "5":
+                        m.put("carState", "鍦ㄧ嚎-浠庢湭鎶ュ畾浣�");break;
+                    case "6":
+                        m.put("carState", "鍦ㄧ嚎-娆犺垂");break;
+                    case "7":
+                        m.put("carState", "鍦ㄧ嚎-琛岄┒");break;
+                    case "8":
+                        m.put("carState", "鍦ㄧ嚎-琛岄┒-鎶ヨ");break;
+                    case "9":
+                        m.put("carState", "鍦ㄧ嚎-鍋滆溅-ACC鍏�");break;
+                    case "10":
+                        m.put("carState", "鍦ㄧ嚎-鍋滆溅-ACC寮�");break;
+                    case "11":
+                        m.put("carState", "鍦ㄧ嚎-鍋滆溅-ACC鍏�-鎶ヨ");break;
+                    case "12":
+                        m.put("carState", "鍦ㄧ嚎-鍋滆溅-ACC寮�-鎶ヨ");break;
+                    case "13":
+                        m.put("carState", "鍦ㄧ嚎-鏃犳晥瀹氫綅");break;
+                    default:
+                        break;
+                }
+            }
+        }
+        return list;
+    }
+
+    /**
+     * 鏍规嵁dept闆嗗悎鏌ヨ鍑烘墍鏈夊搴旂殑carId
+     * @param deptList
+     * @return
+     */
+    @Override
+    public List<Map<String,String>> carIdByDeptList(List<Long> deptList,List<Map<String,String>> list){
+        QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>();
+        queryWrapper.in("dept_id",deptList);
+        List<ArdSyCar> carList = ardSyCarMapper.selectList(queryWrapper);
+        //瀵规瘮鎶婂尮閰嶅埌鐨勬暟鎹坊鍔犲埌list涓�
+        for(Map<String,String> m : list){
+            String carId = m.get("carId");
+            for (int i = 0; i < carList.size(); i++) {
+                ArdSyCar ardSyCar = carList.get(i);
+                if(carId.equals(ardSyCar.getCarId())){
+                    String url = "";
+                    if(ardSyCar.getCarPicture() != null){
+                        if(!ardSyCar.getCarPicture().equals("")){
+                            url = ardSyCar.getCarPicture().split("sycar")[0];
+                        }
+                    }
+                    m.put("carModel",url + ardSyCar.getCarModel());//zns
+                    //m.put("carModel",ardSyCar.getCarModel());
+                    m.put("carTypeArd",ardSyCar.getCarType());
+                    m.put("carBrand",ardSyCar.getCarBrand());
+                    m.put("carPicture",ardSyCar.getCarPicture());
+                }
+            }
+        }
+        return list;
+    }
+
+    @Override
+    public Results getCarGPSTrack(Map<String,String> map,String syURL, ArdSyUser ardSyUser){
+        String carId = map.get("carId");
+        String startTime = map.get("startTime").replace(" ", "").replace("-", "").replace(":", "");
+        String endTime = map.get("endTime").replace(" ", "").replace("-", "").replace(":", "");
+        String maxSpeed = map.get("maxSpeed");
+        //31鐢ㄦ埛鍚嶅瘑鐮�
+        String username31 = ardSyUser.getUserId();
+        String password31 = ardSyUser.getPassword();
+        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"));
+        List<Map<String,Object>> list = (List<Map<String, Object>>) result0.get("list");
+        if(list.isEmpty()){
+            return Results.succeed();
+        }else {
+            for(Map<String,Object> m : list) {
+                String alarmStts = (String) m.get("alarmStts");
+                Map<String, List<String>> alarmMap = getInfo("alarm", alarmStts);
+                m.putAll(alarmMap);
+                String carStts = (String) m.get("carStts");
+                Map<String, List<String>> carMap = getInfo("car", carStts);
+                m.putAll(carMap);
+                String sgnStts = (String) m.get("sgnStts");
+                Map<String, List<String>> sgnMap = getInfo("sgn", sgnStts);
+                m.putAll(sgnMap);
+            }
+            return Results.succeed(list);
+        }
+    }
+
+
+    public Map<String,List<String>> getInfo(String type,String stts){
+        if(stts.isEmpty()){
+            return new HashMap<>();
+        }
+        String[] alarmTypes = {"绱ф�ユ姤璀�","瓒呴�熸姤璀�","鐤插姵椹鹃┒","鍗遍櫓棰勮","GNSS 妯″潡鍙戠敓鏁呴殰","GNSS 澶╃嚎鏈帴鎴栬鍓柇","GNSS 澶╃嚎鐭矾",
+                "缁堢涓荤數婧愭瑺鍘�","缁堢涓荤數婧愭帀鐢�","缁堢LCD 鎴栨樉绀哄櫒鏁呴殰","TTS 妯″潡鏁呴殰","鎽勫儚澶存晠闅�","閬撹矾杩愯緭璇両C 鍗℃ā鍧楁晠闅�","瓒呴�熼璀�",
+                "鐤插姵椹鹃┒棰勮","杩濊琛岄┒鎶ヨ","鑳庡帇棰勮","鍙宠浆鐩插尯寮傚父鎶ヨ","褰撳ぉ绱椹鹃┒瓒呮椂","瓒呮椂鍋滆溅","杩涘嚭鍖哄煙","杩涘嚭璺嚎","璺琛岄┒鏃堕棿涓嶈冻/杩囬暱",
+                "璺嚎鍋忕鎶ヨ","杞﹁締VSS 鏁呴殰","杞﹁締娌归噺寮傚父","杞﹁締琚洍","杞﹁締闈炴硶鐐圭伀","杞﹁締闈炴硶浣嶇Щ","纰版挒棰勮","渚х炕棰勮","闈炴硶寮�闂ㄦ姤璀�"};
+
+        String[] carTypes89 = {"绌鸿溅","鍗婅浇","淇濈暀","婊¤浇"};
+
+        Object[] carTypes = {"ACC寮�","瀹氫綅","鍗楃含","瑗跨粡","鍋滆繍鐘舵��","缁忕含搴﹀凡缁忎繚瀵嗘彃浠跺姞瀵�","淇濈暀","淇濈暀",carTypes89,"杞﹁締娌硅矾鏂紑","杞﹂棬鍔犻攣",
+                "杞﹁締鐢佃矾鏂紑","闂�1寮�锛堝墠闂級","闂�2寮�锛堜腑闂級","闂�3寮�锛堝悗闂�","闂�4寮�锛堥┚椹跺腑闂�","闂�5寮�","浣跨敤GPS 鍗槦杩涜瀹氫綅","浣跨敤鍖楁枟鍗槦杩涜瀹氫綅",
+                "浣跨敤GLONASS鍗槦杩涜瀹氫綅","浣跨敤Galileo鍗槦杩涜瀹氫綅","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀"};
+
+        String[] sgnTypes = {"杩戝厜鐏俊鍙�","杩滃厜鐏俊鍙�","鍙宠浆鍚戠伅淇″彿","宸﹁浆鍚戠伅淇″彿","鍒跺姩淇″彿","鍊掓。淇″彿","闆剧伅淇″彿","绀哄粨鐏�","鍠囧彮淇″彿","绌鸿皟鐘舵��",
+                "绌烘尅淇″彿","缂撻�熷櫒宸ヤ綔","ABS 宸ヤ綔","鍔犵儹鍣ㄥ伐浣�","绂诲悎鍣ㄧ姸鎬�","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀",
+                "淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀","淇濈暀"};
+        Integer sttsHex = Integer.parseInt(stts, 16);
+        String sttsBin = Integer.toBinaryString(sttsHex);
+        if(sttsBin.length() < 32){
+            while(sttsBin.length() < 32){
+                sttsBin = "0" + sttsBin;
+            }
+        }
+        String[] sttsBinArray = sttsBin.split("");
+        switch (type) {
+            case "alarm":
+                List<String> alarmTypeArray = new ArrayList();
+                for (int i = 0; i < sttsBinArray.length; i++) {
+                    if(sttsBinArray[i].equals("1")){
+                        alarmTypeArray.add(alarmTypes[i]);
+                    }
+                }
+                Map<String,List<String>> alarmMap = new HashMap();
+                alarmMap.put(type, alarmTypeArray);
+                return alarmMap;
+            case "car":
+                List<String> carTypeArray = new ArrayList();
+                for (int i = 0; i < sttsBinArray.length; i++) {
+                    if(i <= 7 || i >= 10){
+                        if(sttsBinArray[i].equals("1")){
+                            carTypeArray.add(alarmTypes[i]);
+                        }
+                    }else if(i == 8){
+                        switch (sttsBinArray[8]+sttsBinArray[9]) {
+                            case "00":
+                                carTypeArray.add(carTypes89[0]);
+                                break;
+                            case "01":
+                                carTypeArray.add(carTypes89[1]);
+                                break;
+                            case "10":
+                                carTypeArray.add(carTypes89[2]);
+                                break;
+                            case "11":
+                                carTypeArray.add(carTypes89[3]);
+                                break;
+                            default:
+                                break;
+                        }
+                    }else if(i == 9){
+                        continue;
+                    }else{
+                        break;
+                    }
+                }
+                Map<String,List<String>> carMap = new HashMap();
+                List<String> carTypeArray0 = new ArrayList();
+                for(String str : carTypeArray){
+                    if(!str.equals("淇濈暀")){
+                        carTypeArray0.add(str);
+                    }
+                }
+                carMap.put(type, carTypeArray0);
+                return carMap;
+            case "sgn":
+                List<String> sgnTypeArray = new ArrayList();
+                for (int i = 0; i < sttsBinArray.length; i++) {
+                    if(sttsBinArray[i].equals("1")){
+                        sgnTypeArray.add(alarmTypes[i]);
+                    }
+                }
+                Map<String,List<String>> sgnMap = new HashMap();
+                List<String> sgnTypeArray0 = new ArrayList();
+                for(String str : sgnTypeArray){
+                    if(!str.equals("淇濈暀")){
+                        sgnTypeArray0.add(str);
+                    }
+                }
+                sgnMap.put(type, sgnTypeArray0);
+                return sgnMap;
+            default:
+                return new HashMap<String,List<String>>();
+        }
+    }
+
+    @Override
+    public Results getCarGPSBycarId(String usersId,String carId,String syURL,ArdSyUser ardSyUser){
+        Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
+        //31鐢ㄦ埛鍚嶅瘑鐮�
+        String username31 = ardSyUser.getUserId();
+        String password31 = ardSyUser.getPassword();
+        String passwordMd5 = DigestUtils.md5Hex(password31);
+        Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+        result = new HashMap();
+        result.put("userId", username31);
+        result.put("sessionId", (String) result1.get("sessionId"));
+        Map<String,Object> result0 = new HashMap();
+        result0 = sYClient.getCarNearPositionByCarId(syURL,carId,result.get("userId"),result.get("sessionId"));
+        return Results.succeed(result0);
+    }
+
+    @Override
+    public Results chaseCarByCarId(String usersId, String carId, String cycle) {
+        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);
+                }
+                return Results.succeed("鍋滄杩借釜");
+            }else{
+                if(userCarTimerMap.get(usersId) != null){
+                    userCarTimerMap.get(usersId).cancel();
+                    userCarTimerMap.remove(usersId);
+                    PositionContainer.getUserPositionMap().remove(usersId);
+                    Map<String,Map<String,Object>> map = new HashMap();
+                    map.put(carId,new HashMap());
+                    PositionContainer.getUserPositionMap().put(usersId,map);
+                    Date date = new Date();
+                    Timer carPositionTimer = new Timer();//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
+                    TimerTask carPositionTask =new TimerTask(){
+                        @Override
+                        public void run(){
+                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
+                            if(position != null){
+                                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));
+                                }
+                            }
+                        }
+                    };
+                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//鍚敤
+                    this.userCarTimerMap.put(usersId,carPositionTimer);
+                    return Results.succeed("寮�濮嬭拷韪�");
+                }else{
+                    Map<String,Map<String,Object>> map = new HashMap();
+                    map.put(carId,new HashMap());
+                    PositionContainer.getUserPositionMap().put(usersId,map);
+                    Date date = new Date();
+                    Timer carPositionTimer = new Timer();//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃�
+                    TimerTask carPositionTask =new TimerTask(){
+                        @Override
+                        public void run(){
+                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
+                            if(position != null){
+                                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));
+                                }
+                            }
+                        }
+                    };
+                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//鍚敤
+                    this.userCarTimerMap.put(usersId,carPositionTimer);
+                    return Results.succeed("寮�濮嬭拷韪�");
+                }
+            }
+        }catch(Exception e){
+            e.printStackTrace();
+            return Results.error("杩借釜澶辫触");
+        }
+    }
 }

--
Gitblit v1.9.3