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