From 651186d7fce51274500b66d7ed8a53bedc6a1339 Mon Sep 17 00:00:00 2001 From: 艾金辉 <1144154118@qq.com> Date: 星期一, 24 七月 2023 12:47:17 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java | 51 ++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 46 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 d18f016..6f092b0 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 @@ -4,25 +4,32 @@ import java.util.*; import java.util.*; import javax.annotation.PostConstruct; +import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import com.alibaba.fastjson2.JSON; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.ruoyi.client.ARDCarGPSLogInClient; import com.ruoyi.client.ARDCarSYGPSClient; +import com.ruoyi.common.core.domain.entity.SysDept; +import com.ruoyi.common.core.domain.entity.SysUser; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.uuid.IdUtils; import com.ruoyi.sy.domain.ArdSyUser; +import com.ruoyi.sy.gps31.PushClientImplAlarm; import com.ruoyi.sy.gps31.PushClientImplPosition; import com.ruoyi.sy.service.IArdSyUserService; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.service.ISysConfigService; import com.ruoyi.system.service.ISysDeptService; import com.ruoyi.system.service.ISysUserService; +import com.ruoyi.utils.forest.RongCloudClient; +import com.ruoyi.utils.forest.SYClient; import com.ruoyi.utils.httpclient.SYCarClient; import com.ruoyi.utils.result.Results; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; +import org.apache.commons.codec.digest.DigestUtils; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -61,6 +68,14 @@ @Autowired private IArdSyUserService iArdSyUserService; + @Autowired + private ISysUserService sysUserService; + + @Autowired + private ISysDeptService sysDeptService; + + @Resource + private SYClient sYClient; private ArdSyCarController ardSyCarController; @@ -89,11 +104,17 @@ Date date = new Date(); Timer carPositionTimer = new Timer();//瀹氭椂鎺ㄩ�佸疄鏃朵綅缃� TimerTask carPositionTask =new TimerTask(){ + @Override public void run(){ ardSyCarService.sendArdSyCarPosition(); } }; carPositionTimer.scheduleAtFixedRate(carPositionTask,date,3*1000);//鍚敤 + + //杞﹁締瀹炴椂浣嶇疆绾跨▼ + PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword()); + Thread pushClientImplAlarmThread = new Thread(pushClientImplAlarm); + pushClientImplAlarmThread.start(); } /** @@ -187,7 +208,9 @@ return error("涓変竴杞﹁締url娌℃湁褰曞叆"); }else{ syURL = sysConfigResult.get(0).getConfigValue(); - Map<String,Object> result = SYCarClient.logIn(syURL,userId, password); + //Map<String,Object> result = SYCarClient.logIn(syURL,userId, password); + String passwordMd5 = DigestUtils.md5Hex(password); + Map<String,Object> result = sYClient.logIn(syURL,passwordMd5,userId); return success(result); } } @@ -387,13 +410,31 @@ break; } } -// for(Map<String,String> m : list0){ -// for(Map<String,String> ma : list1){ + //鏍规嵁userId鏌ヨ閮ㄩ棬Id + SysUser sysUser = sysUserService.selectUserById(usersId); + Long deptId = sysUser.getDeptId(); + //鏍规嵁褰撳墠deptId鎴栬�呭綋鍓嶅強鎵�灞炰笅绾х殑鎵�鏈塪eptId + List<Long> deptList = sysDeptService.deptIdBySub(deptId); + //鏍规嵁dept闆嗗悎鏌ヨ鍑烘墍鏈夊搴旂殑杞﹁締鍒楄〃 + List<ArdSyCar> carList = ardSyCarService.carIdByDeptList(deptList); + //瀵规瘮鎶婂尮閰嶅埌鐨勬暟鎹坊鍔犲埌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()); + } + } +// for(Map<String,String> ma :){ // if(m.get("carId").equals(ma.get("carId"))){ // m.put("stateCn", ma.get("carState")); // } // } -// } + } // Collections.sort((List)result0.get("list"),new Comparator<Map<String, Object>>() { // @Override // public int compare(Map<String, Object> o1, Map<String, Object> o2) { -- Gitblit v1.9.3