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