From 4dbd2e0a473ef33ecf8a7200f62b61d4dbd87f25 Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: 星期二, 06 八月 2024 10:31:45 +0800
Subject: [PATCH] 电磁锁主动操控记录查询提交

---
 ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java |  424 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 419 insertions(+), 5 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
index 2df19c5..2582ec2 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
@@ -1,5 +1,6 @@
 package com.ruoyi.sy.controller;
 
+import java.io.IOException;
 import java.io.UnsupportedEncodingException;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -12,22 +13,30 @@
 import com.github.pagehelper.PageInfo;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.spring.SpringUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
+import com.ruoyi.sy.domain.ArdTankLock;
+import com.ruoyi.sy.gps31.PushClientImplSerialPort;
 import com.ruoyi.sy.param.ArdSyCarParam;
+import com.ruoyi.sy.service.*;
+import com.ruoyi.sy.service.impl.ArdTankLockServiceImpl;
 import com.ruoyi.sy.vo.ArdSyCarVo;
 import com.ruoyi.sy.domain.ArdSyUser;
 import com.ruoyi.sy.gps31.PositionContainer;
 import com.ruoyi.sy.gps31.PushClientImplAlarm;
 import com.ruoyi.sy.gps31.PushClientImplPosition;
-import com.ruoyi.sy.service.IArdSyUserService;
 import com.ruoyi.common.core.domain.entity.SysConfig;
 import com.ruoyi.system.service.ISysConfigService;
 import com.ruoyi.system.service.ISysDeptService;
 import com.ruoyi.system.service.ISysUserService;
+import com.ruoyi.system.service.impl.SysConfigServiceImpl;
 import com.ruoyi.utils.forest.SYClient;
 import com.ruoyi.utils.result.Results;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -38,9 +47,10 @@
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.enums.BusinessType;
 import com.ruoyi.sy.domain.ArdSyCar;
-import com.ruoyi.sy.service.IArdSyCarService;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import org.springframework.web.multipart.MultipartFile;
+
+import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;
 
 /**
  * 涓変竴杞﹁締Controller
@@ -71,6 +81,15 @@
     @Autowired
     private ISysDeptService sysDeptService;
 
+    @Autowired
+    private IArdTankAbnormalParkAlarmService ardTankAbnormalParkAlarmService;
+
+    @Autowired
+    private IArdTankLockService ardTankLockService;
+
+    @Autowired
+    private IArdTankWallTemporaryService ardTankWallTemporaryService;
+
     @Resource
     private SYClient sYClient;
 
@@ -78,6 +97,12 @@
 
     @Value("${syCar.enabled}")
     private Boolean syCarEnabled;
+
+    @Value("${syCar.userId}")
+    private String userId;
+
+    @Value("${syCar.password}")
+    private String password;
 
     @PostConstruct
     public void init(){
@@ -101,7 +126,8 @@
         {
             return;
         }
-        PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+        //PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+        PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,userId,password);
         Thread pushClientImplPositionThread = new Thread(pushClientImplPosition);
         pushClientImplPositionThread.start();
 
@@ -115,9 +141,369 @@
         };
         //carPositionTimer.scheduleAtFixedRate(carPositionTask,date,3*1000);//寮冪敤
         //杞﹁締瀹炴椂鎶ヨ绾跨▼
-        PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+        //PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+        PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,userId,password);
         Thread pushClientImplAlarmThread = new Thread(pushClientImplAlarm);
         pushClientImplAlarmThread.start();
+        //涓插彛绾跨▼
+        PushClientImplSerialPort pushClientImplSerialPort = new PushClientImplSerialPort(ip,userId,password);
+        Thread pushClientImplSerialPortThread = new Thread(pushClientImplSerialPort);
+        pushClientImplSerialPortThread.start();
+
+        //鍒犻櫎缁撴潫鏃堕棿涓簄ull鐨勮褰�
+        int result = ardTankAbnormalParkAlarmService.deleteArdTankAbnormalParkAlarmByEndTime();
+
+        List<ArdSyCar> ardSyCarAndLockList = ardSyCarService.selectArdSyCarAndTankLock();//鏌ヨ鍏ㄩ儴缃愯溅鍙婁笅鎸傜數纾侀攣
+
+        for(ArdSyCar ardSyCar : ardSyCarAndLockList){//鏋勯�犲鍣�
+            Map<String,Map<String,Thread>> carMap = new HashMap();//杞﹁締瀹瑰櫒
+            for(ArdTankLock ardTankLock : ardSyCar.getArdTankLockList()){
+                Map<String,Thread> lockMap = new HashMap();//閿佸鍣�
+                carMap.put(ardTankLock.getLockNum(),lockMap);
+            }
+            PositionContainer.getCarLockProcessThreadMap().put(ardSyCar.getCarId(),carMap);
+        }
+
+        Timer lockStateTimer = new Timer();//瀹氭椂鑾峰彇鍚勪釜閿佺殑鐘舵��
+        TimerTask lockStateTask =new TimerTask(){
+            @Override
+            public void run(){
+                Thread thread = new Thread(){
+                    @Override
+                    public void run() {
+                        SysConfig config = new SysConfig();
+                        config.setConfigKey("syCarPT");
+                        List<SysConfig> sysConfigResult = sysConfigService.selectConfigList(config);
+                        String syURL = "";
+
+                        if(sysConfigResult.size() == 0){
+                            return;
+                        }else{
+                            syURL = sysConfigResult.get(0).getConfigValue();
+                        }
+                        String passwordMd5 = DigestUtils.md5Hex(password);
+                        Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, userId);
+                        String sessionId = (String) LogInResult.get("sessionId");
+
+                        String finalSyURL = syURL;
+
+                        List<ArdTankLock> result = ardTankLockService.getArdTankLockAll();//鏌ヨ鍏ㄩ儴鐢电閿�
+                        for(ArdTankLock ardTankLock : result){
+                            Thread lockThread = new Thread(finalSyURL){
+                                @Override
+                                public void run() {
+                                    String lockNumHead = ardTankLock.getLockNum().substring(0,2);
+                                    String lockNumTail = ardTankLock.getLockNum().substring(2,4);
+                                    //璁$畻鏍¢獙
+                                    String checkNum = Integer.toHexString(Integer.parseInt(lockNumHead, 16) + Integer.parseInt(lockNumTail, 16) + Integer.parseInt("01", 16));
+
+                                    if(checkNum.length() == 1){
+                                        checkNum = "0" + checkNum;
+                                    }else if(checkNum.length() > 2){
+                                        checkNum = checkNum.substring(checkNum.length() - 2,checkNum.length());
+                                    }
+
+                                    String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "01" + checkNum + "%22%7D";
+                                    try{
+                                        sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
+                                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockState");
+                                    }catch(Exception e){
+                                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockState");
+                                    }
+                                }
+                            };
+                            //lockThread.start();
+                            //灏嗙姸鎬佺嚎绋嬫斁鍏ュ鍣�
+                            if(PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).get("lockState") == null){
+                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockState",lockThread);
+                            }
+
+                        }
+                    }
+                };
+                thread.start();
+            }
+        };
+        //lockStateTimer.scheduleAtFixedRate(lockStateTask,date,3000);
+        lockStateTimer.scheduleAtFixedRate(lockStateTask,date,5000);
+
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Timer lockCheckTimeTimer = new Timer();//瀹氭椂鏍″噯鏃堕棿
+        TimerTask lockCheckTimeTask = new TimerTask(){
+            @Override
+            public void run() {
+                SysConfig config = new SysConfig();
+                config.setConfigKey("syCarPT");
+                List<SysConfig> sysConfigResult = sysConfigService.selectConfigList(config);
+                String syURL = "";
+
+                if(sysConfigResult.size() == 0){
+                    return;
+                }else{
+                    syURL = sysConfigResult.get(0).getConfigValue();
+                }
+                String passwordMd5 = DigestUtils.md5Hex(password);
+                Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, userId);
+                String sessionId = (String) LogInResult.get("sessionId");
+
+                String finalSyURL = syURL;
+
+                List<ArdTankLock> result = ardTankLockService.getArdTankLockAll();//鏌ヨ鍏ㄩ儴鐢电閿�
+                for(ArdTankLock ardTankLock : result){
+                    Thread lockThread = new Thread(finalSyURL){
+                        @Override
+                        public void run() {
+                            //鑾峰彇鏃堕棿骞舵媶鍒嗗勾鏈堟棩鏃跺垎绉�
+                            String nowTime = sdf.format(new Date());
+                            String nowYear = nowTime.substring(2,4);
+                            String nowMonth = nowTime.substring(5,7);
+                            String nowDay = nowTime.substring(8,10);
+                            String nowHour = nowTime.substring(11,13);
+                            String nowMinute = nowTime.substring(14,16);
+                            String nowSecond = nowTime.substring(17,19);
+
+                            String nowYearHex = Integer.toHexString(Integer.parseInt(nowYear));
+                            if(nowYearHex.length() == 1){
+                                nowYearHex = "0" + nowYearHex;
+                            }
+                            String nowMonthHex = Integer.toHexString(Integer.parseInt(nowMonth));
+                            if(nowMonthHex.length() == 1){
+                                nowMonthHex = "0" + nowMonthHex;
+                            }
+                            String nowDayHex = Integer.toHexString(Integer.parseInt(nowDay));
+                            if(nowDayHex.length() == 1){
+                                nowDayHex = "0" + nowDayHex;
+                            }
+                            String nowHourHex = Integer.toHexString(Integer.parseInt(nowHour));
+                            if(nowHourHex.length() == 1){
+                                nowHourHex = "0" + nowHourHex;
+                            }
+                            String nowMinuteHex = Integer.toHexString(Integer.parseInt(nowMinute));
+                            if(nowMinuteHex.length() == 1){
+                                nowMinuteHex = "0" + nowMinuteHex;
+                            }
+                            String nowSecondHex = Integer.toHexString(Integer.parseInt(nowSecond));
+                            if(nowSecondHex.length() == 1){
+                                nowSecondHex = "0" + nowSecondHex;
+                            }
+                            //16杩涘埗鏃堕棿
+                            String timeHex = nowYearHex + nowMonthHex + nowDayHex + nowHourHex + nowMinuteHex + nowSecondHex;
+                            String lockNumHead = ardTankLock.getLockNum().substring(0,2);
+                            String lockNumTail = ardTankLock.getLockNum().substring(2,4);
+                            //璁$畻鏍¢獙
+                            String checkNum = Integer.toHexString(Integer.parseInt(lockNumHead, 16) + Integer.parseInt(lockNumTail, 16) + Integer.parseInt("08", 16) +
+                                    Integer.parseInt(nowYearHex, 16) + Integer.parseInt(nowMonthHex, 16) + Integer.parseInt(nowDayHex, 16) +
+                                    Integer.parseInt(nowHourHex, 16) + Integer.parseInt(nowMinuteHex, 16) + Integer.parseInt(nowSecondHex, 16));
+                            if(checkNum.length() == 1){
+                                checkNum = "0" + checkNum;
+                            }else if(checkNum.length() > 2){
+                                checkNum = checkNum.substring(checkNum.length() - 2,checkNum.length());
+                            }
+                            String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "08" + timeHex + checkNum + "%22%7D";
+                            try{
+                                sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
+                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockTime");
+                            }catch(Exception e){
+                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockTime");
+                            }
+                        }
+                    };
+                    //lockThread.start();
+                    if(PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).get("lockTime") == null){
+                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockTime",lockThread);
+                    }
+                }
+            }
+        };
+        //lockCheckTimeTimer.scheduleAtFixedRate(lockCheckTimeTask,date,7000);
+        lockCheckTimeTimer.scheduleAtFixedRate(lockCheckTimeTask,date,67000);
+
+        Timer sendTimer = new Timer();//瀹氭椂鍙戦�侀攣鐘舵��
+        TimerTask sendLockStateTask = new TimerTask(){
+            @Override
+            public void run() {
+                for (String key : ONLINE_USER_SESSIONS.keySet()){
+                    Thread lockThread = new Thread() {
+                        @Override
+                        public void run() {
+                            ardTankLockService.sendLockState(key,userId,password);
+                        }
+                    };
+                    lockThread.start();
+                }
+            }
+        };
+        sendTimer.scheduleAtFixedRate(sendLockStateTask,date,3000);
+
+        Timer passwordTimer = new Timer();//瀹氭椂鏌ョ湅鐢电閿佸瘑鐮佺姸鎬�
+        TimerTask passwordTask = new TimerTask(){
+            @Override
+            public void run() {
+                ardTankLockService.readPassword(userId,password);
+            }
+        };
+        //passwordTimer.scheduleAtFixedRate(passwordTask,date,11000);
+        passwordTimer.scheduleAtFixedRate(passwordTask,date,13000);
+
+        Timer lockRestartStateTimer = new Timer();//瀹氭椂鍚勪釜閿佺殑澶嶄綅鐘舵��
+        TimerTask lockRestartStateTask = new TimerTask(){
+            @Override
+            public void run(){
+                Thread thread = new Thread(){
+                    @Override
+                    public void run() {
+                        SysConfig config = new SysConfig();
+                        config.setConfigKey("syCarPT");
+                        List<SysConfig> sysConfigResult = sysConfigService.selectConfigList(config);
+                        String syURL = "";
+
+                        if(sysConfigResult.size() == 0){
+                            return;
+                        }else{
+                            syURL = sysConfigResult.get(0).getConfigValue();
+                        }
+                        String passwordMd5 = DigestUtils.md5Hex(password);
+                        Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, userId);
+                        String sessionId = (String) LogInResult.get("sessionId");
+
+                        String finalSyURL = syURL;
+
+                        List<ArdTankLock> result = ardTankLockService.getArdTankLockAllWithState();//鏌ヨ鍏ㄩ儴鐢电閿佸強鏈�缁堢姸鎬�
+                        for(ArdTankLock ardTankLock : result){
+                            String restartState = ardTankLock.getRestartState();
+                            String sRestartState = "";
+                            if(ardTankLock.getArdTankLockState() != null){
+                                sRestartState = ardTankLock.getArdTankLockState().getRestartState();
+                            }
+
+                            if(sRestartState.equals("")){
+                                continue;
+                            }else{
+                                sRestartState = sRestartState.substring(0,2);
+                                if(!restartState.equals(sRestartState)){
+                                    Thread lockThread = new Thread(finalSyURL){
+                                        @Override
+                                        public void run() {
+                                            String process = "";
+                                            if(restartState.equals("寮�閿�")){
+                                                process = "01";
+                                            }else if(restartState.equals("鍏抽攣")){
+                                                process = "02";
+                                            }else{
+                                                return;
+                                            }
+
+                                            String lockNumHead = ardTankLock.getLockNum().substring(0,2);
+                                            String lockNumTail = ardTankLock.getLockNum().substring(2,4);
+                                            //璁$畻鏍¢獙
+                                            String checkNum = Integer.toHexString(Integer.parseInt(lockNumHead, 16) + Integer.parseInt(lockNumTail, 16) + Integer.parseInt("03", 16) + Integer.parseInt(process, 16));
+
+                                            if(checkNum.length() == 1){
+                                                checkNum = "0" + checkNum;
+                                            }else if(checkNum.length() > 2){
+                                                checkNum = checkNum.substring(checkNum.length() - 2,checkNum.length());
+                                            }
+
+                                            String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "03" + process + checkNum + "%22%7D";
+                                            try{
+                                                sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
+                                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockRestart");
+                                            }catch (Exception e){
+                                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockRestart");
+                                            }
+                                        }
+                                    };
+                                    //lockThread.start();
+                                    if(PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).get("lockRestart") == null){
+                                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockRestart",lockThread);
+                                    }
+                                }
+                            }
+                        }
+                    }
+                };
+                thread.start();
+            }
+        };
+        lockRestartStateTimer.scheduleAtFixedRate(lockRestartStateTask,date,17000);
+
+        Set<String> lockNumSet = new HashSet();//瀛樻斁鍙戦�佽繃鐨勯攣缂栧彿
+
+        Timer mainLockTimer = new Timer();//涓诲畾鏃跺櫒
+        TimerTask mainLockTask = new TimerTask(){
+            @Override
+            public void run() {
+                Long count = ardTankLockService.getArdTankLockCount();
+                if(lockNumSet.size() >= count){//闃叉閿佽鍒犻櫎锛岄噰鐢ㄥぇ浜庣瓑浜�
+                    lockNumSet.clear();//鍏ㄩ儴鎵ц杩囷紝娓呯┖瀹瑰櫒
+                }
+                for(String carId : PositionContainer.getCarLockProcessThreadMap().keySet()){
+                    Thread thread = new Thread(){
+                        @Override
+                        public void run() {
+                            Map<String, Map<String,Thread>> lockMap = PositionContainer.getCarLockProcessThreadMap().get(carId);
+                            for(String lockNum : lockMap.keySet()){
+                                if(lockNumSet.contains(lockNum)){//鑻ユ墽琛岃繃锛屾湰娆″拷鐣�
+                                    continue;
+                                }
+                                if(lockMap.get(lockNum).get("lockProcess") != null){
+                                    break;//閿佹搷浣滅骇鍒渶楂�
+                                }else{
+                                    if(lockMap.get(lockNum).get("lockTime") != null){
+                                        if(lockMap.get(lockNum).get("lockTime").isAlive()){
+                                            lockNumSet.add(lockNum);
+                                            break;//閿佹牎鏃舵涔�
+                                        }else{
+                                            lockMap.get(lockNum).get("lockTime").start();
+                                            lockNumSet.add(lockNum);
+                                            break;//閿佹牎鏃舵涔�
+                                        }
+                                    }else{
+                                        if(lockMap.get(lockNum).get("lockPassword") != null){
+                                            if(lockMap.get(lockNum).get("lockPassword").isAlive()){
+                                                lockNumSet.add(lockNum);
+                                                break;//閿佸瘑鐮佹涔�
+                                            }else{
+                                                lockMap.get(lockNum).get("lockPassword").start();
+                                                lockNumSet.add(lockNum);
+                                                break;//閿佸瘑鐮佹涔�
+                                            }
+                                        }else{
+                                            if(lockMap.get(lockNum).get("lockRestart") != null) {
+                                                if(lockMap.get(lockNum).get("lockRestart").isAlive()){
+                                                    lockNumSet.add(lockNum);
+                                                }else{
+                                                    lockMap.get(lockNum).get("lockRestart").start();
+                                                    lockNumSet.add(lockNum);
+                                                    break;//閿佸浣嶆涔�
+                                                }
+                                            }else{
+                                                if(lockMap.get(lockNum).get("lockState") != null) {
+                                                    if(lockMap.get(lockNum).get("lockState").isAlive()){
+                                                        lockNumSet.add(lockNum);
+                                                    }else{
+                                                        lockMap.get(lockNum).get("lockState").start();
+                                                        lockNumSet.add(lockNum);
+                                                        break;//閿佺姸鎬佹涔�
+                                                    }
+                                                }else{
+                                                    break;
+                                                }
+                                            }
+                                        }
+                                    }
+                                }
+                            }
+                        }
+                    };
+                    thread.start();
+                }
+            }
+        };
+        mainLockTimer.scheduleAtFixedRate(mainLockTask,date,2000);
+
+        //寮傚父閲嶅惎閲嶅缓鏈埌鏈熶复鏃剁數瀛愬洿鏍忕嚎绋�
+        ardTankWallTemporaryService.restartArdTankWallTemporaryThread(userId, password);
     }
 
     /**
@@ -369,7 +755,7 @@
         SysUser sysUser = sysUserService.selectUserById(usersId);
         Map<String, Map<String,Map<String,Object>>> deptPositionMap = PositionContainer.getDeptPositionMap();
         if(deptPositionMap.isEmpty()){
-            return Results.succeed();
+            return Results.error("31骞冲彴鏃犺溅杈嗕綅缃繑鍥�");
         }else {
 //            return Results.succeed(deptPositionMap.get(sysUser.getDeptId().toString()).get(map.get("carId")));
             return Results.succeed(deptPositionMap.get(sysUser.getDeptId().toString()));
@@ -491,4 +877,32 @@
         }
     }
 
+    public Map<String,Object> sendCmd(String syURL,String userId,String carId,Integer cmdId,String cmd,String paramsStr,String sessionId){
+        OkHttpClient okHttpClient = new OkHttpClient();
+
+        Request request = new Request.Builder()
+                .url(syURL + "/gps-web/api/send_cmd.jsp?params="+paramsStr+"&userId="+userId+"&carId="+carId+"&cmdId="+cmdId+"&cmd="+cmd+"&sessionId="+sessionId)
+                .build();
+        //System.out.println("url = " + syURL + "/gps-web/api/send_cmd.jsp?params="+paramsStr+"&userId="+userId+"&carId="+carId+"&cmdId="+cmdId+"&cmd="+cmd+"&sessionId="+sessionId);
+        Response response = null;
+        try {
+            response = okHttpClient.newCall(request).execute();
+        } catch (IOException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+
+        okhttp3.ResponseBody responseBody = response.body();
+
+        try {
+            String message = responseBody.string();// 鍝嶅簲浣�
+            Map<String,Object> map = (Map<String, Object>) JSON.parse(message);
+            return map;
+        } catch (IOException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+            return new HashMap();
+        }
+    }
+
 }

--
Gitblit v1.9.3