Merge remote-tracking branch 'origin/develop' into develop

bocloud.sms.service/src/main/java/com/bocloud/sms/service/TrxServiceImpl.java

@@ -154,7 +154,7 @@ public class TrxServiceImpl implements TrxService {
 
             // 处理ukey登录用户
             log.info("开始uKey登录用户入库, userId:" + userId);
-            saveUserByTrx(userId);
+            saveUserByTrx(userId,"");
             log.info("uKey登录用户入库结束");
             // 登录
             log.info("开始uKey登录用户登录云管平台");
@@ -202,7 +202,7 @@ public class TrxServiceImpl implements TrxService {
 
             // 处理ukey登录用户
             log.info("开始软Key登录用户入库, userId:" + userId);
-            saveUserByTrx(userId);
+            saveUserByTrx(userId,trxAuthModel.getPassword());
             log.info("软Key登录用户入库结束");
             // 登录
             log.info("开始软Key登录用户登录云管平台");
@@ -220,7 +220,7 @@ public class TrxServiceImpl implements TrxService {
 
     }
 
-    private void saveUserByTrx(String userId) {
+    private void saveUserByTrx(String userId, String password) {
         User user = userRepository.getByUserId(userId);
         // 根据userId获取运控系统用户信息
         JSONObject params = new JSONObject();
@@ -239,7 +239,11 @@ public class TrxServiceImpl implements TrxService {
             log.info("开始新增天融信登录用户，userId: " + userId);
             // 新增  以userId作为account 并添加注释
             UserBean userBean = new UserBean();
+            if (password.isEmpty()) {
                 userBean.setPassword(userId + "CMP");
+            } else {
+                userBean.setPassword(password);
+            }
             userBean.setSex(true);
             userBean.setIsManager(true);
             userBean.setUserId(userId);

bocloud.sms.service/src/main/java/com/bocloud/sms/service/UserServiceImpl.java

@@ -3,14 +3,17 @@ package com.bocloud.sms.service;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.event.AnalysisEventListener;
 import com.alibaba.excel.write.handler.CellWriteHandler;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.bocloud.cmp.boot.model.BocloudStatus;
 import com.bocloud.sms.entity.*;
+import com.bocloud.sms.enums.YkInf;
 import com.bocloud.sms.interfaces.UserService;
 import com.bocloud.sms.model.*;
 import com.bocloud.sms.repository.*;
 import com.bocloud.sms.service.utils.ExportUtil;
 import com.bocloud.sms.service.utils.ImportExcelUtil;
+import com.bocloud.sms.service.utils.YkUtils;
 import com.bocloud.sms.utils.FavoriteComparator;
 import com.google.common.collect.Lists;
 import com.megatron.common.encrypt.AESEncryptor;
@@ -83,6 +86,8 @@ public class UserServiceImpl implements UserService {
     private final FavoriteRepository favoriteRepository;
     private final CloudServiceBeanRepository cloudServiceBeanRepository;
     private final ApiPermissionRepository apiPermissionRepository;
+    private final YkUtils ykUtils;
+
 
     /**
      * 分页查询用户列表
@@ -636,6 +641,19 @@ public class UserServiceImpl implements UserService {
     @Override
     @Transactional
     public Result changePwd(Long id, String oldPassword, String password, RequestContext requestContext) {
+
+        //1 需要优先调用运控系统修改密码接口，修改完成才能同步本端数据库
+        // 根据userId获取运控系统用户信息
+        log.info("查询当前用户信息，userId: " + id);
+        JSONObject params = new JSONObject();
+        params.put("userId", String.valueOf(id));
+        params.put("oldPwd", oldPassword);
+        params.put("newPwd", password);
+        //请求运控修改密码机接口
+        JSONObject result = ykUtils.call(YkInf.updateUserPwd, params, JSONObject.class);
+        if (result.getInteger("returnCode") == 1) {
+            log.info("运控密码修改成功");
+
             String path = User.class.getSimpleName() + "_" + id;
             try (AutoCloseLock lock = lockFactory.getACLock(path)) {
                 Assert.isTrue(lock.acquire(10, TimeUnit.SECONDS), "请求超时");
@@ -667,6 +685,11 @@ public class UserServiceImpl implements UserService {
                 securityRepository.update(security);
                 return new Result(true, "修改密码成功");
             }
+
+        } else {
+            return new Result(true, "修改密码失败");
+        }
+
     }
 
     @Override

bocloud.sms.service/src/main/java/com/bocloud/sms/service/utils/YkUtils.java

@@ -37,7 +37,11 @@ public class YkUtils {
             throw new IllegalArgumentException("调用运控接口异常" + result.getString("msg"));
         }
         if (JSONObject.class.equals(expectCls)) {
+            if (result.getJSONObject("data") != null) {
                 return (T) result.getJSONObject("data");
+            } else {
+                return (T) result;
+            }
         } else {
             return (T) result.getString("data");
         }

bocloud.sms.storage/src/main/java/com/bocloud/sms/enums/YkInf.java

@@ -7,6 +7,8 @@ public enum YkInf {
     getAppList("/system/sysapp/getAppList"),
     //获取运维工单接口
     getTaskList("/activiti/rwMainTask/getTaskList"),
+    //修改密码接口
+    updateUserPwd("/system/user/updateUserPwd"),
 
     getTaskByUser("/system/task/countTaskByUser");