From c511bd724b1a34411b8e28116bbc5baf9353a03d Mon Sep 17 00:00:00 2001 From: zhangnaisong <2434969829@qq.com> Date: 星期六, 22 七月 2023 09:56:40 +0800 Subject: [PATCH] 三一车辆sdk引入提交 --- ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java | 117 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 117 insertions(+), 0 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 340f154..27d8afc 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,13 +1,21 @@ package com.ruoyi.sy.controller; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; import java.util.Map; +import javax.annotation.PostConstruct; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; +import com.ruoyi.client.ARDCarGPSLogInClient; +import com.ruoyi.client.ARDCarSYGPSClient; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.uuid.IdUtils; +import com.ruoyi.sy.domain.ArdSyUser; +import com.ruoyi.sy.gps31.PushClientImplPosition; +import com.ruoyi.sy.service.IArdSyUserService; +import com.ruoyi.sy.service.SysParaService; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.service.ISysConfigService; import com.ruoyi.utils.httpclient.SYCarClient; @@ -45,6 +53,39 @@ @Autowired private ISysConfigService sysConfigService; + + private Map<Integer,Map<String,String>> logInMap = new HashMap(); + + @Autowired + private SysParaService sysParaService; + + @Autowired + private IArdSyUserService iArdSyUserService; + + private ArdSyCarController ardSyCarController; + + @PostConstruct + public void init(){ + ardSyCarController = this; + ardSyCarController.sysConfigService = this.sysConfigService; + ardSyCarController.iArdSyUserService = this.iArdSyUserService; + + 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 ip = syURL.split(":")[1].replace("//", ""); + List<ArdSyUser> ardSyUserList = iArdSyUserService.selectSyUser(); + //杞﹁締瀹炴椂浣嶇疆绾跨▼ + PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword()); + Thread pushClientImplPositionThread = new Thread(pushClientImplPosition); + pushClientImplPositionThread.start(); + } /** * 鏌ヨ涓変竴杞﹁締鍒楄〃 @@ -161,6 +202,24 @@ } /** + * 鑾峰彇鍏ㄩ儴鐨勪笁涓�杞﹁締 + */ + @PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyCarAll')") + @PostMapping("/getArdSyCarAll") + @ApiOperation("鑾峰彇鍏ㄩ儴鐨勪笁涓�杞﹁締") + public Map<String,Object> getArdSyCarAll(){ + String userId = SecurityUtils.getUserId(); + Map<String,Object> result = ardSyCarService.getArdSyCarAll(userId); + if(((String)result.get("code")).equals("500")){ + return error((String) result.get("data")); + }else if(((String)result.get("code")).equals("200")){ + return success(result.get("data")); + }else{ + return error(""); + } + } + + /** * 鑾峰彇鍏ㄩ儴杞﹁締妯″瀷 */ @PreAuthorize("@ss.hasPermi('sy:syCar:getAllCarModel')") @@ -190,4 +249,62 @@ } } + @PreAuthorize("@ss.hasPermi('sy:syCar:allListByUser')") + @PostMapping("allListByUser") + @ApiOperation("鏍规嵁鐢ㄦ埛鑾峰彇涓変竴鍒楄〃") + public Map<String,Object> allListByUser(){ + String usersId = SecurityUtils.getUserId(); + ArdSyUser ardSyUser = iArdSyUserService.userById(usersId); + Map<String,Object> result0 = new HashMap(); + //鍒ゆ柇鍏宠仈琛ㄦ槸鍚︽湁鏁版嵁 + if(ardSyUser!=null){ + //31鐢ㄦ埛鍚嶅瘑鐮� + String username31 = ardSyUser.getUserId(); + String password31 = ardSyUser.getPassword(); + //鏌ヨ鍦板潃 + Map<String, String> result = logInMap.get(Integer.parseInt(usersId)); + String syURL = sysParaService.getSYURL(); + Map<String, Object> result1 = ARDCarGPSLogInClient.loginIn(syURL,username31, password31); + result = new HashMap(); + result.put("userId", username31); + result.put("sessionId", (String) result1.get("sessionId")); + try { + result0 = ARDCarSYGPSClient.getCarGPSTeamList(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 = (Map<String, Object>) ARDCarSYGPSClient.getCarListByTeamId(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; + } + + @PreAuthorize("@ss.hasPermi('sy:syCar:carListById')") + @GetMapping("carListById") + @ApiOperation("鏍规嵁杞﹁締ID鑾峰彇杞﹁締鍒楄〃") + public List<ArdSyCar> carListById(String id){ + return ardSyCarService.carListById(id); + } } -- Gitblit v1.9.3