From 3c075575f95f2e10a66d38e1b28c284e938f2e52 Mon Sep 17 00:00:00 2001
From: 艾金辉 <1144154118@qq.com>
Date: 星期五, 21 七月 2023 17:20:42 +0800
Subject: [PATCH] 根据用户名获取三一列表

---
 ard-work/pom.xml                                                           |    7 ++
 ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java            |    6 +
 ruoyi-admin/src/main/resources/application-druid.yml                       |    4 
 ard-work/src/main/java/com/ruoyi/client/ARDCarGPSLogInClient.java          |   10 +-
 ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java         |    2 
 ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java     |   78 +++++++++++++------------
 ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml                  |    5 +
 ard-work/src/main/java/com/ruoyi/sy/mapper/SysParaMapper.java              |    4 +
 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java |    5 +
 ard-work/src/main/java/com/ruoyi/client/ARDCarSYGPSClient.java             |   10 +-
 10 files changed, 79 insertions(+), 52 deletions(-)

diff --git a/ard-work/pom.xml b/ard-work/pom.xml
index 7924856..bd7875b 100644
--- a/ard-work/pom.xml
+++ b/ard-work/pom.xml
@@ -117,6 +117,13 @@
             <artifactId>lombok</artifactId>
             <optional>true</optional>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/com.alibaba.fastjson2/fastjson2 -->
+        <dependency>
+            <groupId>com.alibaba.fastjson2</groupId>
+            <artifactId>fastjson2</artifactId>
+            <version>2.0.36</version>
+        </dependency>
+
     </dependencies>
 
     <build>
diff --git a/ard-work/src/main/java/com/ruoyi/client/ARDCarGPSLogInClient.java b/ard-work/src/main/java/com/ruoyi/client/ARDCarGPSLogInClient.java
index 6c53444..afe65a5 100644
--- a/ard-work/src/main/java/com/ruoyi/client/ARDCarGPSLogInClient.java
+++ b/ard-work/src/main/java/com/ruoyi/client/ARDCarGPSLogInClient.java
@@ -1,10 +1,10 @@
 package com.ruoyi.client;
 
-import com.alibaba.fastjson.JSON;
-import com.squareup.okhttp.OkHttpClient;
-import com.squareup.okhttp.Request;
-import com.squareup.okhttp.Response;
-import com.squareup.okhttp.ResponseBody;
+import com.alibaba.fastjson2.JSON;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
 import org.apache.commons.codec.digest.DigestUtils;
 import java.io.IOException;
 import java.util.HashMap;
diff --git a/ard-work/src/main/java/com/ruoyi/client/ARDCarSYGPSClient.java b/ard-work/src/main/java/com/ruoyi/client/ARDCarSYGPSClient.java
index d2dff2e..c8d6f9a 100644
--- a/ard-work/src/main/java/com/ruoyi/client/ARDCarSYGPSClient.java
+++ b/ard-work/src/main/java/com/ruoyi/client/ARDCarSYGPSClient.java
@@ -1,10 +1,10 @@
 package com.ruoyi.client;
 
-import com.alibaba.fastjson.JSON;
-import com.squareup.okhttp.OkHttpClient;
-import com.squareup.okhttp.Request;
-import com.squareup.okhttp.Response;
-import com.squareup.okhttp.ResponseBody;
+import com.alibaba.fastjson2.JSON;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
 
 import java.io.IOException;
 import java.util.HashMap;
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 102b824..2eb89b7 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
@@ -11,6 +11,7 @@
 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.service.IArdSyUserService;
 import com.ruoyi.sy.service.SysParaService;
 import com.ruoyi.system.domain.SysConfig;
@@ -226,48 +227,49 @@
     @ApiOperation("鏍规嵁鐢ㄦ埛鑾峰彇涓変竴鍒楄〃")
     public Map<String,Object> allListByUser(){
         String usersId = SecurityUtils.getUserId();
-        Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
-        String syURL = sysParaService.getSYURL();
-        if(result == null){
-            Map<String,Object> m = iArdSyUserService.selectArdSyUserByUsersId(Integer.parseInt(usersId));
-            if(m == null){
-                Map<String,Object> map0 = new HashMap();
-                map0.put("rspDesc", "褰撳墠鐧诲綍鐢ㄦ埛鏈寕鎺ヨ溅杈嗘潈闄�");
-                map0.put("rspCode", "0");
-                return map0;
-            }
-            Map<String, Object> result0 = ARDCarGPSLogInClient.loginIn(syURL,(String) m.get("userId"), (String) m.get("password"));
-            result = new HashMap();
-            result.put("userId", (String) m.get("userId"));
-            result.put("sessionId", (String) result0.get("sessionId"));
-        }
+        ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
         Map<String,Object> result0 = new HashMap();
-        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;
-                }
+        //鍒ゆ柇鍏宠仈琛ㄦ槸鍚︽湁鏁版嵁
+        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;
             }
-            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")));
+            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;
             }
-            map.put("online", online);
-            online = 0;
+        }else {
+            result0.put("鍒楄〃涓虹┖锛�","鏃犲叧鑱旇处鍙凤紒");
         }
         return result0;
     }
diff --git a/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java b/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
index 9c823c7..79b167b 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
@@ -5,6 +5,7 @@
 
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.sy.domain.ArdSyUser;
+import org.apache.ibatis.annotations.MapKey;
 
 /**
  * 涓変竴杞﹁締鐢ㄦ埛Mapper鎺ュ彛
@@ -76,5 +77,8 @@
      */
     public List<SysUser> getSysUserNoSY();
 
-    public Map<String,Object> selectArdSyUserByUsersId(Integer usersId);
+    @MapKey("id")
+    Map<String,Object> selectArdSyUserByUsersId(Integer usersId);
+
+    ArdSyUser userById(String id);
 }
diff --git a/ard-work/src/main/java/com/ruoyi/sy/mapper/SysParaMapper.java b/ard-work/src/main/java/com/ruoyi/sy/mapper/SysParaMapper.java
index fbdb80d..ecc4dca 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/mapper/SysParaMapper.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/mapper/SysParaMapper.java
@@ -1,6 +1,8 @@
 package com.ruoyi.sy.mapper;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.ruoyi.common.annotation.DataSource;
+import com.ruoyi.common.enums.DataSourceType;
 import com.ruoyi.sy.domain.SysPara;
 import com.ruoyi.sy.domain.SysParaExample;
 import java.util.List;
@@ -8,7 +10,7 @@
 /**
  * @author 11441
  */
-@DS("slave")
+@DataSource(value = DataSourceType.SLAVE)
 public interface SysParaMapper {
 
     List<SysPara> selectByExample(String sysType);
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
index 289dd7f..cdb48ea 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
@@ -75,4 +75,6 @@
     public List<SysUser> getSysUserNoSY();
 
     Map<String,Object> selectArdSyUserByUsersId(Integer usersId);
+
+    ArdSyUser userById(String id);
 }
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
index 924fb9a..de6ae1b 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
@@ -121,4 +121,9 @@
         Map<String,Object> result = ardSyUserMapper.selectArdSyUserByUsersId(usersId);
         return result;
     }
+
+    @Override
+    public ArdSyUser userById(String id) {
+        return ardSyUserMapper.userById(id);
+    }
 }
diff --git a/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml b/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
index 249ef50..7918055 100644
--- a/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
+++ b/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
@@ -132,4 +132,9 @@
         inner join ard_users au on aus.users_id = au.id
         where aus.users_id = #{usersId}
   </select>
+
+    <select id="userById" parameterType="String" resultMap="ArdSyUserResult">
+        <include refid="selectArdSyUserVo"/>
+        where sys_user_id = #{id}
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/ruoyi-admin/src/main/resources/application-druid.yml b/ruoyi-admin/src/main/resources/application-druid.yml
index 916b601..103ba5c 100644
--- a/ruoyi-admin/src/main/resources/application-druid.yml
+++ b/ruoyi-admin/src/main/resources/application-druid.yml
@@ -15,7 +15,7 @@
             # 浠庡簱鏁版嵁婧�
             slave:
                 # 浠庢暟鎹簮寮�鍏�/榛樿鍏抽棴
-#                enabled: true
+                enabled: true
                 url: jdbc:postgresql://112.98.126.2:35432/ard732
                 username: postgres
                 password: Yykj.2017
@@ -38,7 +38,7 @@
             testWhileIdle: true
             testOnBorrow: false
             testOnReturn: false
-            webStatFilter: 
+            webStatFilter:
                 enabled: true
             statViewServlet:
                 enabled: true

--
Gitblit v1.9.3