From fb41ec2cee3d47c32ad7b0e94e4966fec0c4f069 Mon Sep 17 00:00:00 2001
From: Administrator <1144154118@qq.com>
Date: 星期三, 26 七月 2023 09:15:53 +0800
Subject: [PATCH] 获取31用户名
---
ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java | 320 ++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 292 insertions(+), 28 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 79ac29f..50a72bc 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
@@ -11,6 +11,7 @@
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.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.common.websocket.util.WebSocketUtils;
import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
@@ -21,16 +22,15 @@
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.mapper.SysUserMapper;
-import com.ruoyi.utils.httpclient.SYCarClient;
-import com.ruoyi.utils.result.Constants;
+import com.ruoyi.utils.forest.SYClient;
import com.ruoyi.utils.result.Results;
import io.minio.GetPresignedObjectUrlArgs;
import io.minio.ListObjectsArgs;
import io.minio.PutObjectArgs;
import io.minio.Result;
import io.minio.http.Method;
-import io.minio.messages.Contents;
import io.minio.messages.Item;
+import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.stereotype.Service;
import com.ruoyi.sy.mapper.ArdSyCarMapper;
import com.ruoyi.sy.domain.ArdSyCar;
@@ -61,6 +61,10 @@
@Resource
private SysUserMapper userMapper;
+ @Resource
+ private SYClient sYClient;
+
+ private Map<Integer,Map<String,String>> logInMap = new HashMap();
/**
* 鏌ヨ涓変竴杞﹁締
@@ -161,9 +165,12 @@
return result;
}else{
ArdSyUser ardSyUser = ardSyUserList.get(0);
- Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
+ //Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
+ 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> carListMap = SYCarClient.getCarList(syURL,sessionId);
+ //Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
+ Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
if(((String)carListMap.get("rspCode")).equals("1")){
List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
ArdSyCar ardSyCar = new ArdSyCar();
@@ -213,25 +220,14 @@
return result;
}else{
ArdSyUser ardSyUser = ardSyUserList.get(0);
- Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
+ //Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
+ 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> carListMap = SYCarClient.getCarList(syURL,sessionId);
+ //Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
+ Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
if(((String)carListMap.get("rspCode")).equals("1")){
List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
- /*ArdSyCar ardSyCar = new ArdSyCar();
- List<ArdSyCar> ardSyCarList = ardSyCarMapper.selectArdSyCarList(ardSyCar);
- List<String> carIdList = new ArrayList();
- for(ArdSyCar innerArdSyCar : ardSyCarList){
- carIdList.add(innerArdSyCar.getCarId());
- }
-
- List<Map<String,Object>> carList = list.stream().filter(new Predicate<Map<String,Object>>(){
- @Override
- public boolean test(Map<String,Object> map) {
- return !carIdList.contains((String)map.get("carId"));
- }
- }).collect(Collectors.toList());
- result.put("data",carList);*/
result.put("data",list);
result.put("code","200");
return result;
@@ -372,12 +368,136 @@
SysUser sysUser = userMapper.selectUserById(key);
String deptId = String.valueOf(sysUser.getDeptId());
Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
- System.out.println("/////////////");
- System.out.println(PositionContainer.getDeptPositionMap());
- Map<Integer,Object> data = new HashMap();
- data.put(30000, map.values());
- WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+ if(map != null){
+ Map<String,Object> data = new HashMap();
+ data.put("30000", map.values());
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+ }
}
+ }
+
+ @Override
+ 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");
+ 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;
}
/**
@@ -386,9 +506,153 @@
* @return
*/
@Override
- public List<ArdSyCar> carIdByDeptList(List<Long> deptList){
+ public List<Map<String,String>> carIdByDeptList(List<Long> deptList,List<Map<String,String>> list){
QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>();
queryWrapper.in("dept_id",deptList);
- return ardSyCarMapper.selectList(queryWrapper);
+ 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())){
+ 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>>();
+ }
}
}
--
Gitblit v1.9.3