From 4c4bf4cc32a99435777f06bc281fe8e942f7c323 Mon Sep 17 00:00:00 2001
From: futian.liu <liufutianyoo@163.com>
Date: 星期四, 14 十二月 2023 12:03:24 +0800
Subject: [PATCH] 修改规约

---
 consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java |  451 +++++++++++++++++++++-----------------------------------
 1 files changed, 169 insertions(+), 282 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
index 6a92d2c..42f11ce 100644
--- a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
@@ -1,6 +1,26 @@
 package com.consum.base.controller;
 
-import cn.hutool.core.util.ReflectUtil;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.Set;
+
+import org.apache.commons.compress.utils.Lists;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.event.AnalysisEventListener;
@@ -8,6 +28,7 @@
 import com.consum.base.BaseController;
 import com.consum.base.core.utils.CommonUtil;
 import com.consum.base.core.utils.MapperUtil;
+import com.consum.base.core.utils.PageUtil;
 import com.consum.base.pojo.FinSysTenantUserSearchParam;
 import com.consum.base.pojo.FinSysTenantUserUpdParam;
 import com.consum.base.pojo.ImportUserParam;
@@ -16,9 +37,10 @@
 import com.consum.base.pojo.response.FinSysTenantUserVO;
 import com.consum.base.pojo.response.FinSysTenantVO;
 import com.consum.base.pojo.response.UserVO;
+import com.consum.base.service.BaseWarehouseManagerService;
 import com.consum.base.service.FinSysTenantDepartmentService;
-import com.consum.base.service.FinSysTenantServiceImpl;
-import com.consum.base.service.FinSysTenantUserServiceImpl;
+import com.consum.base.service.FinSysTenantService;
+import com.consum.base.service.FinSysTenantUserService;
 import com.consum.model.po.FinSysTenant;
 import com.consum.model.po.FinSysTenantDepartment;
 import com.consum.model.po.FinSysTenantUser;
@@ -30,23 +52,17 @@
 import com.iplatform.model.po.S_dept;
 import com.iplatform.model.po.S_role;
 import com.iplatform.model.po.S_user_core;
-import com.walker.db.page.GenericPager;
-import com.walker.infrastructure.utils.*;
+import com.walker.infrastructure.utils.CollectionUtils;
+import com.walker.infrastructure.utils.DateUtils;
+import com.walker.infrastructure.utils.NumberGenerator;
+import com.walker.infrastructure.utils.PhoneNumberUtils;
+import com.walker.infrastructure.utils.StringUtils;
 import com.walker.web.ResponseValue;
+
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
-import org.apache.commons.compress.utils.Lists;
-import org.springframework.beans.BeanUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.util.*;
 
 /**
  * @Description 绯荤粺鐢ㄦ埛
@@ -60,11 +76,11 @@
 
     private String roleName;
 
-    private FinSysTenantUserServiceImpl finSysTenantUserService;
+    private FinSysTenantUserService finSysTenantUserService;
 
     private UserServiceImpl userService;
 
-    private FinSysTenantServiceImpl finSysTenantService;
+    private FinSysTenantService finSysTenantService;
 
     private RoleServiceImpl roleService;
 
@@ -72,16 +88,15 @@
     private FinSysTenantDepartmentService finSysTenantDepartmentService;
 
     @Autowired
-    public void setUserService(UserServiceImpl userService) {
-        this.userService = userService;
-    }
+    private BaseWarehouseManagerService baseWarehouseManagerService;
 
     @Autowired
-    public FinSysTenantUserController(FinSysTenantServiceImpl finSysTenantService,
-        FinSysTenantUserServiceImpl finSysTenantUserService, RoleServiceImpl roleService) {
+    public FinSysTenantUserController(FinSysTenantService finSysTenantService,
+        FinSysTenantUserService finSysTenantUserService, RoleServiceImpl roleService, UserServiceImpl userService) {
         this.finSysTenantUserService = finSysTenantUserService;
         this.finSysTenantService = finSysTenantService;
         this.roleService = roleService;
+        this.userService = userService;
     }
 
     /**
@@ -96,74 +111,25 @@
         CommonUtil.copyProperties(param, param2);
         param = param2;
         if (param.getTenantCode() == 0) {
-            FinSysTenantUser user = new FinSysTenantUser();
-            Long id = this.getCurrentUser().getId();
-            user.setSysUserId(id);
-            List<FinSysTenantUser> select = finSysTenantUserService.select(user);
-            if (select.size() > 0) {
-                param.setTenantCode(new Long(select.get(0).getTenantCode()));
+            String tenantId = this.getSysInfo().getTenantId();
+            FinSysTenant finSysTenant = finSysTenantService.selectById(Long.valueOf(tenantId));
+            if (finSysTenant != null) {
+                param.setTenantCode(Long.valueOf(finSysTenant.getCode()));
             }
         }
-        GenericPager<FinSysTenantUser> pager = this.finSysTenantUserService.queryAllPageUser(param);
+        PageUtil<FinSysTenantUserVO> pager = this.finSysTenantUserService.queryAllPageUser(param);
+        for (FinSysTenantUserVO finSysTenantUser : pager.getDatas()) {
+            String tel = finSysTenantUser.getUserPhone() != null
+                ? AESUtils.decryptStrAES(finSysTenantUser.getUserPhone(), PlatformRSAUtils.AES_KEY) : null;
+            finSysTenantUser.setUserPhone(StringUtils.isNotEmpty(tel) ? PhoneNumberUtils.maskMobile(tel) : "");
 
-        List<FinSysTenantUserVO> resultList = Lists.newArrayList();
-        List<FinSysTenantUser> datas = pager.getDatas();
-        if (datas.size() > 0) {
-            for (FinSysTenantUser finSysTenantUser : datas) {
-                FinSysTenantUserVO userVO = new FinSysTenantUserVO();
-                if (finSysTenantUser.getUserPhone() != null) {
-                    // 瑙e瘑骞惰劚鏁�
-                    String tel = null;
-                    try {
-                        tel = AESUtils.decryptStrAES(finSysTenantUser.getUserPhone(), PlatformRSAUtils.AES_KEY);
-                    } catch (Exception e) {
-                        logger.error("瑙e瘑鎵嬫満鍙峰け璐ワ紝鍘熷洜锛�" + e);
-                        tel = null;
-                    }
-                    if (StringUtils.isNotEmpty(tel)) {
-                        finSysTenantUser.setUserPhone(PhoneNumberUtils.maskMobile(tel));
-                    } else {
-                        finSysTenantUser.setUserPhone("");
-                    }
-                } else {
-                    finSysTenantUser.setUserPhone("");
-                }
+            // 鍒楄〃涓嶉渶瑕佹煡璇㈣鑹诧紝鍙樉绀哄垪琛ㄦ墍闇�瑕佺殑淇℃伅
+            /*List<S_role> list = finSysTenantUserService.getByUserId(finSysTenantUser.getSysUserId());
+            StringBuilder roleStr = new StringBuilder();
+            list.forEach(s_role -> roleStr.append(s_role.getRole_name()).append(" "));
+            finSysTenantUser.setRoleStr(roleStr.toString());
+            finSysTenantUser.setIsSupplier(finSysTenantUser.getSupplierId() != null ? "鏄�" : "鍚�");*/
 
-                // 寰幆鍘绘煡瑙掕壊
-                Long sysUserId = finSysTenantUser.getSysUserId();
-                if (sysUserId != null) {
-                    List<S_role> list = finSysTenantUserService.getByUserId(sysUserId);
-                    String roleStr = "";
-                    for (S_role s_role : list) {
-                        roleStr = roleStr + s_role.getRole_name() + "  ";
-                    }
-                    finSysTenantUser.setRoleStr(roleStr);
-                }
-
-                // 寰幆鏌ヨ杩愮淮鍟唅d
-                if (finSysTenantUser.getSupplierId() != null) {
-                    finSysTenantUser.setIsSupplier("鏄�");
-                } else {
-                    finSysTenantUser.setIsSupplier("鍚�");
-                }
-                BeanUtils.copyProperties(finSysTenantUser, userVO);
-                Long sysDeptId = finSysTenantUser.getSysDeptId();
-                FinSysTenantDepartment department = finSysTenantDepartmentService.getById(sysDeptId);
-                if (Objects.nonNull(department)) {
-                    userVO.setSysDeptName(department.getName());
-                }
-                resultList.add(userVO);
-            }
-        }
-
-        try {
-            Field fieldDatas = GenericPager.class.getDeclaredField("datas");
-            // fieldDatas.setAccessible(true);
-            // fieldDatas.set(pager, resultList);
-            ReflectUtil.setFieldValue(pager, fieldDatas, resultList);
-
-        } catch (Exception e) {
-            logger.error("鍒嗛〉鍒楄〃鏌ヨ澶辫触锛屽師鍥狅細" + e);
         }
         return ResponseValue.success(pager);
     }
@@ -195,60 +161,94 @@
             return ResponseValue.error("鍙傛暟涓虹┖");
         }
         // 鏍规嵁鍛樺伐缂栧彿鏌ヨ锛屽鏋滃瓨鍦ㄥ垯鎻愮ず
-        if (finSysTenantUserService.getByUserCode(tenantUser.getUserCode()) != null
-            && finSysTenantUserService.getByUserCode(tenantUser.getUserCode()) > 0) {
+        FinSysTenantUser userCode = finSysTenantUserService.getByUserCode(tenantUser.getUserCode());
+        if (userCode != null) {
             return ResponseValue.error("鍛樺伐缂栧彿閲嶅");
         }
-
         if (StringUtils.isEmpty(tenantUser.getTenantId()) || "0".equals(tenantUser.getTenantId())) {
             return ResponseValue.error("娣诲姞鏃惰閫夋嫨鍖哄幙");
         }
 
-        if (StringUtils.isEmpty(tenantUser.getTenantCode()) || "0".equals(tenantUser.getTenantCode())) {
-            return ResponseValue.error("娣诲姞鏃惰閫夋嫨鍖哄幙");
-        }
         // 鎻掑叆绯荤粺鐢ㄦ埛
+        buildTenantUser(tenantUser, null);
+        this.finSysTenantUserService.insert(tenantUser);
+
+        // 鎻掑叆骞冲彴鐢ㄦ埛
+        S_user_core userCore = getsUserCore(tenantUser);
+        this.userService.insert(userCore);
+        // 鎻掑叆骞冲彴鏈烘瀯
+        // 灏戣鑹瞚d
+        // 鏈烘瀯id 澶氫釜
+        List<Long> roleList = user.getRoleList();
+        if (!CollectionUtils.isEmpty(roleList)) {
+            // 鐢ㄦ埛id
+            Long sysUserId = tenantUser.getSysUserId();
+            this.finSysTenantUserService.execInsertRoleUserList(roleList, sysUserId);
+        }
+        // this.getFinCustomerCache().remove();
+        return ResponseValue.success(1);
+    }
+
+    private void buildTenantUser(FinSysTenantUser tenantUser, FinSysTenantUser sysInfo) {
         tenantUser.setId(NumberGenerator.getLongSequenceNumber());
         tenantUser.setCreateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
         tenantUser.setCreateBy(this.getCurrentUser().getUser_name());
         tenantUser.setUpdateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
         tenantUser.setUpdateBy(this.getCurrentUser().getUser_name());
-        // user.setStatus(1);// 0绂佺敤 1鍚敤
+        // 鏄惁鍒犻櫎 0鏄� 1鍚�
         tenantUser.setIsDelete(0);
         tenantUser.setSysUserId(NumberGenerator.getLongSequenceNumber());
+        setUserPhone(tenantUser, tenantUser.getUserPhone());
+        String tenantId = tenantUser.getTenantId();
+        FinSysTenant finSysTenant = finSysTenantService.selectById(Long.valueOf(tenantId));
+        tenantUser.setTenantCode(finSysTenant.getCode());
+
+        // 澶勭悊鏂规硶addSupplier
+        if (sysInfo != null) {
+            tenantUser.setIsDelete(1);
+            tenantUser.setLv(sysInfo.getLv());
+            tenantUser.setTenantCode(sysInfo.getTenantCode());
+            tenantUser.setTenantId(sysInfo.getTenantId());
+            // 杩愮淮绠$悊
+            tenantUser.setSysDeptId(2L);
+        }
+
+    }
+
+    private void setUserPhone(FinSysTenantUser tenantUser, String userPhone) {
         // 鍔犲瘑鎵嬫満鍙�
         String key = PlatformRSAUtils.AES_KEY;
         String encPhone = "";
         if (tenantUser.getUserPhone() != null) {
-            encPhone = AESUtils.encryptStrAES(tenantUser.getUserPhone(), key);
+            encPhone = AESUtils.encryptStrAES(userPhone, key);
         }
         tenantUser.setUserPhone(encPhone);
-        // 鎬庝箞鑾峰彇宸︿晶鏈烘瀯鏍戞暟鎹�
-        tenantUser.setSysDeptId(3L); // 瀵瑰簲骞冲彴鏈烘瀯id 榛樿涓哄钩鍙扮鐞�
-        this.finSysTenantUserService.insert(tenantUser);
+    }
 
-        // 鎻掑叆骞冲彴鐢ㄦ埛
+    private S_user_core getsUserCore(FinSysTenantUser tenantUser) {
         S_user_core userCore = new S_user_core();
         userCore.setId(tenantUser.getSysUserId());
-        userCore.setDept_id(3L); // 閮ㄩ棬id锛岀洰鍓嶅啓姝�
-        userCore.setOrg_id(tenantUser.getSysDeptId()); // 鏈烘瀯id
+        // 閮ㄩ棬id 閮ㄩ棬淇℃伅鏈悓姝ワ紝鍙~鍏呮暟鎹�
+        userCore.setDept_id(tenantUser.getSysDeptId());
+        // 鏈烘瀯id
+        userCore.setOrg_id(tenantUser.getSysDeptId());
         userCore.setOrg_id(1L);
-        userCore.setUser_name(tenantUser.getUserCode()); // 鐢ㄦ埛璐﹀彿
+        // 鐢ㄦ埛璐﹀彿
+        userCore.setUser_name(tenantUser.getUserCode());
         userCore.setNick_name(tenantUser.getUserName());
         // 鐢ㄦ埛绫诲瀷 鍏堥粯璁よ缃负2
         userCore.setUser_type(2);
-        userCore.setPhonenumber(encPhone);
+        userCore.setPhonenumber(tenantUser.getUserPhone());
         userCore.setSex(tenantUser.getSex().toString());
         // 鍒濆鍖栧瘑鐮� 123456
         String pws = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();
         userCore.setPassword(pws);
         // 骞冲彴鐢ㄦ埛琛ㄥ拰绯荤粺鐢ㄦ埛 琛ㄧ姸鎬佺浉鍙�
         if (tenantUser.getStatus() == 0) {
-            tenantUser.setStatus(1);
+            userCore.setStatus(1);
         } else {
-            tenantUser.setStatus(0);
+            userCore.setStatus(0);
         }
-        userCore.setStatus(tenantUser.getStatus());
         userCore.setDel_flag(0);
         userCore.setCreate_by(this.getCurrentUser().getUser_name());
         userCore.setCreate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
@@ -271,16 +271,7 @@
         userCore.setType(1);
         // 鍟嗘埛id锛�0-骞冲彴
         userCore.setMer_id(0L);
-        this.userService.insert(userCore);
-        // 鎻掑叆骞冲彴鏈烘瀯
-        // 灏戣鑹瞚d
-        List<Long> roleList = user.getRoleList(); // 鏈烘瀯id 澶氫釜
-        if (!CollectionUtils.isEmpty(roleList)) {
-            Long sysUserId = tenantUser.getSysUserId(); // 鐢ㄦ埛id
-            this.finSysTenantUserService.execInsertRoleUserList(roleList, sysUserId);
-        }
-        // this.getFinCustomerCache().remove();
-        return ResponseValue.success(1);
+        return userCore;
     }
 
     /**
@@ -292,7 +283,7 @@
     public ResponseValue importUser(@RequestParam String tenantId, @RequestParam String tenantCode, MultipartFile file)
         throws IOException {
         String originalFilename = file.getOriginalFilename();
-        if (!"xls".equals(originalFilename.substring(originalFilename.lastIndexOf(".") + 1))) {
+        if (!originalFilename.endsWith("xls")) {
             return ResponseValue.error("鏂囦欢鏍煎紡鏈夎!");
         }
         S_user_core currentUser = this.getCurrentUser();
@@ -317,7 +308,7 @@
                     throw new ImportUserParamVerifyException("鍗曞厓鏍间笉鑳戒负绌�!");
                 }
                 // 鏍规嵁鍛樺伐缂栧彿鏌ヨ锛屽鏋滃瓨鍦ㄥ垯鎻愮ず
-                if (finSysTenantUserService.getByUserCode(data.getUserCode()) > 0) {
+                if (finSysTenantUserService.getByUserCode(data.getUserCode()) != null) {
                     throw new ImportUserParamVerifyException("鍛樺伐缂栧彿涓虹┖鎴栧凡瀛樺湪!");
                 }
                 if (data.getSex() < 1 && data.getSex() > 0) {
@@ -347,9 +338,7 @@
                 user.setSysUserId(NumberGenerator.getLongSequenceNumber());
                 user.setRemark("鎵归噺瀵煎叆");
                 // 鍔犲瘑鎵嬫満鍙�
-                String key = PlatformRSAUtils.AES_KEY;
-                String encPhone = AESUtils.encryptStrAES(data.getUserPhone(), key);
-                user.setUserPhone(encPhone);
+                setUserPhone(user, data.getUserPhone());
 
                 user.setIsDelete(1);
                 // 鎬庝箞鑾峰彇宸︿晶鏈烘瀯鏍戞暟鎹�
@@ -397,49 +386,7 @@
         ArrayList<S_user_core> sUserCores = new ArrayList<>();
         for (FinSysTenantUser user : finSysTenantUsers) {
             // 鎻掑叆骞冲彴鐢ㄦ埛
-            S_user_core userCore = new S_user_core();
-            userCore.setId(user.getSysUserId());
-            userCore.setDept_id(3L); // 閮ㄩ棬id锛岀洰鍓嶅啓姝�
-            userCore.setOrg_id(user.getSysDeptId()); // 鏈烘瀯id
-            userCore.setOrg_id(1L);
-            userCore.setUser_name(user.getUserCode()); // 鐢ㄦ埛璐﹀彿
-            userCore.setNick_name(user.getUserName());
-            // 鐢ㄦ埛绫诲瀷 鍏堥粯璁よ缃负2
-            userCore.setUser_type(2);
-            userCore.setPhonenumber(user.getUserPhone());
-            userCore.setSex(user.getSex().toString());
-            // 鍒濆鍖栧瘑鐮� 123456
-            String pws = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();
-            userCore.setPassword(pws);
-            // 骞冲彴鐢ㄦ埛琛ㄥ拰绯荤粺鐢ㄦ埛 琛ㄧ姸鎬佺浉鍙�
-            if (user.getStatus() == 0) {
-                user.setStatus(1);
-            } else {
-                user.setStatus(0);
-            }
-            userCore.setStatus(user.getStatus());
-            userCore.setDel_flag(0);
-            userCore.setCreate_by(this.getCurrentUser().getUser_name());
-            userCore.setCreate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
-            userCore.setRemark(user.getRemark());
-            userCore.setType(1);
-            userCore.setBind_client_id("0");
-            userCore.setBind_wechat(0);
-            userCore.setModify_pwd(0);
-            userCore.setBind_mobile(0);
-            userCore.setBind_mail(0);
-            userCore.setProfile_id(0L);
-            userCore.setIs_wechat_public(0);
-            userCore.setIs_wechat_routine(0);
-            userCore.setIs_wechat_ios(0);
-            userCore.setIs_wechat_android(0);
-            userCore.setIs_logoff(0);
-            userCore.setLogoff_time(0L);
-            userCore.setIs_sms(0);
-            // 绠$悊鍛樼被鍨嬶細1= 骞冲彴瓒呯, 2=鍟嗘埛瓒呯, 3=绯荤粺绠$悊鍛橈紝4=鍟嗘埛绠$悊鍛�
-            userCore.setType(1);
-            // 鍟嗘埛id锛�0-骞冲彴
-            userCore.setMer_id(0L);
+            S_user_core userCore = getsUserCore(user);
             sUserCores.add(userCore);
         }
         // 淇濆瓨鐢ㄦ埛淇℃伅
@@ -476,26 +423,45 @@
         if (tenantUser == null) {
             return ResponseValue.error("鍙傛暟涓虹┖");
         }
-        String key = PlatformRSAUtils.AES_KEY;
-        String encPhone = "";
-        if (tenantUser.getUserPhone() != null) {
-            encPhone = AESUtils.encryptStrAES(tenantUser.getUserPhone(), key);
-        }
-        tenantUser.setUserPhone(encPhone);
+        setUserPhone(tenantUser, tenantUser.getUserPhone());
         // 1.鏇存柊绯荤粺鐢ㄦ埛 FIN_SYS_TENANT_USER
         finSysTenantUserService.update(tenantUser);
         // 2.鏇存柊骞冲彴鐢ㄦ埛 S_USER_CORE
+        S_user_core userCore = buildUpdateUserCore(user);
+        this.userService.update(userCore);
+        // 3. 鏇存柊瑙掕壊閰嶇疆 S_ROLE_USER
+        // 1. 鏍规嵁 user.getSysUserId() 鏌ヨ
+        // 宸叉湁鐨勬潈闄�
+        Long sysUserId = user.getSysUserId();
+        List<S_role> list = finSysTenantUserService.getRoleBySysUserId(sysUserId);
+        // 閫夋嫨鐨勬潈闄�
+        List<Long> roleList = user.getRoleList();
+        // 鍏堝垹闄ゅ啀娣诲姞
+        if (!CollectionUtils.isEmpty(list)) {
+            finSysTenantUserService.execDelRoleUserList(sysUserId);
+            // 鍒犻櫎搴撶鍛樹俊鎭褰�
+            list.stream().filter(item -> "浠撳簱绠$悊鍛�".equals(item.getRole_name())).findFirst()
+                .ifPresent(item -> baseWarehouseManagerService.deleteMangerBySysUserId(sysUserId));
+        }
+        if (!CollectionUtils.isEmpty(roleList)) {
+            // 鍥犱负涓嶇煡閬撹鐢ㄦ埛闇�瑕佺鐞嗛偅涓粨搴� 鏁呬笉鏂板浠撳簱绠$悊鍛樹俊鎭紝鍙坊鍔犺鑹�
+            finSysTenantUserService.execInsertRoleUserList(roleList, sysUserId);
+        }
+        this.getFinSysTenantUserCache().remove(sysUserId.toString());
+        return ResponseValue.success(1);
+    }
+
+    private S_user_core buildUpdateUserCore(FinSysTenantUser user) {
         S_user_core userCore = new S_user_core();
         userCore.setId(user.getSysUserId());
         userCore.setUpdate_by(this.getCurrentUser().getUser_name());
         userCore.setUpdate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
         // 骞冲彴鐢ㄦ埛琛ㄥ拰绯荤粺鐢ㄦ埛 琛ㄧ姸鎬佺浉鍙�
         if (user.getStatus() == 0) {
-            user.setStatus(1);
+            userCore.setStatus(1);
         } else {
-            user.setStatus(0);
+            userCore.setStatus(0);
         }
-        userCore.setStatus(user.getStatus());
         if (user.getSex() != null) {
             userCore.setSex(user.getSex().toString());
         }
@@ -503,20 +469,8 @@
         userCore.setNick_name(user.getUserName());
         // 鍔犲瘑鎵嬫満鍙�
         userCore.setPhonenumber(user.getUserPhone());
-        this.userService.update(userCore);
-        // 3. 鏇存柊瑙掕壊閰嶇疆 S_ROLE_USER
-        // 1. 鏍规嵁 user.getSysUserId() 鏌ヨ
-        List<S_role> list = finSysTenantUserService.getByUserId(user.getSysUserId()); // 宸叉湁鐨勬潈闄�
-        List<Long> roleList = user.getRoleList(); // 閫夋嫨鐨勬潈闄�
-        // 鍏堝垹闄ゅ啀娣诲姞
-        if (list != null && list.size() > 0) {
-            finSysTenantUserService.execDelRoleUserList(user.getSysUserId());
-        }
-        if (roleList != null && roleList.size() > 0) {
-            finSysTenantUserService.execInsertRoleUserList(roleList, user.getSysUserId());
-        }
-        this.getFinSysTenantUserCache().remove(user.getSysUserId() + "");
-        return ResponseValue.success(1);
+
+        return userCore;
     }
 
     /**
@@ -534,25 +488,14 @@
             return ResponseValue.error("鍙傛暟涓虹┖");
         }
         // 1.鏇存柊绯荤粺鐢ㄦ埛 FIN_SYS_TENANT_USER 搴旇鏄煡璇� 鐒跺悗鍙敼鐘舵��
-        List<FinSysTenantUser> select = finSysTenantUserService.select(new FinSysTenantUser(tenantUser.getId()));
-        if (select == null || select.size() == 0) {
+        FinSysTenantUser finSysTenantUser = finSysTenantUserService.queryOneById(tenantUser.getId().toString());
+        if (finSysTenantUser == null) {
             return ResponseValue.error("鐢ㄦ埛涓嶅瓨鍦�");
         }
-        FinSysTenantUser finSysTenantUser = select.get(0);
         finSysTenantUser.setStatus(user.getStatus());
         finSysTenantUserService.update(finSysTenantUser);
         // 2.鏇存柊骞冲彴鐢ㄦ埛 S_USER_CORE
-        S_user_core userCore = new S_user_core();
-        userCore.setId(user.getSysUserId());
-        userCore.setUpdate_by(this.getCurrentUser().getUser_name());
-        userCore.setUpdate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
-        // 骞冲彴鐢ㄦ埛琛ㄥ拰绯荤粺鐢ㄦ埛 琛ㄧ姸鎬佺浉鍙�
-        if (user.getStatus() == 0) {
-            user.setStatus(1);
-        } else {
-            user.setStatus(0);
-        }
-        userCore.setStatus(user.getStatus());
+        S_user_core userCore = buildUpdateUserCore(tenantUser);
         this.userService.update(userCore);
         return ResponseValue.success(1);
     }
@@ -573,13 +516,14 @@
             return ResponseValue.error("鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
         }
         // 鍒濆鍖栧瘑鐮� 123456
-        String stringValue = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();// 瀵嗘枃
+        // 瀵嗘枃
+        String password = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();
         // 1. 淇敼鐢ㄦ埛琛�
         // 鐢ㄦ埛琛╥d
         Long sysUserId = user.getSysUserId();
         S_user_core userCore = new S_user_core();
         userCore.setId(sysUserId);
-        userCore.setPassword(stringValue);
+        userCore.setPassword(password);
         userCore.setModify_pwd(0);
         userService.update(userCore);
         // 2. 淇敼骞冲彴鐢ㄦ埛锛堜笉鐢ㄤ慨鏀癸級
@@ -601,13 +545,12 @@
         if (finSysTenantUser == null) {
             return ResponseValue.error("鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
         }
-        String s = AESUtils.decryptStrAES(finSysTenantUser.getUserPhone(), PlatformRSAUtils.AES_KEY);
-
-        finSysTenantUser.setUserPhone(s);
+        String phone = AESUtils.decryptStrAES(finSysTenantUser.getUserPhone(), PlatformRSAUtils.AES_KEY);
+        finSysTenantUser.setUserPhone(phone);
         Long sysUserId = finSysTenantUser.getSysUserId();
-        List<S_role> list = finSysTenantUserService.getByUserId(sysUserId);
+        List<S_role> roleList = finSysTenantUserService.getRoleBySysUserId(sysUserId);
         HashMap<String, Object> map = new HashMap<>();
-        map.put("list", list);
+        map.put("list", roleList);
         map.put("data", finSysTenantUser);
         return ResponseValue.success(map);
     }
@@ -630,10 +573,11 @@
                 sysInfo.setUserPhone(AESUtils.decryptStrAES(userPhone, key));
             }
 
-            // 鏌ヨ 鐢ㄦ埛瑙掕壊 TODO 涓存椂瑙e喅 灏嗘潵鏀鹃厤缃枃浠朵腑
+            // 鏌ヨ 鐢ㄦ埛瑙掕壊
             // 宸叉湁鐨勬潈闄�
-            List<S_role> list = finSysTenantUserService.getByUserId(sysInfo.getSysUserId());
+            List<S_role> list = finSysTenantUserService.getRoleBySysUserId(sysInfo.getSysUserId());
             for (S_role s_role : list) {
+                // TODO 涓存椂瑙e喅 灏嗘潵鏀鹃厤缃枃浠朵腑
                 if (s_role.getRole_id() != null && s_role.getRole_id().equals(1690961420053L)) {
                     sysInfo.setKfStatus(1);
                 }
@@ -641,7 +585,7 @@
 
             // 鏌ヨ鐖剁被鐨刼rgcode 闇�瑕佸皢鑷繁鐨刼rg鍏堟煡鍑烘潵 鍐嶆牴鎹畃arentid 鏌ョ埗绫�
             String tenantId = sysInfo.getTenantId();
-            if (tenantId != null && !tenantId.equals("")) {
+            if (StringUtils.isNotEmpty(tenantId)) {
                 List<FinSysTenant> select = finSysTenantService.select(new FinSysTenant(Long.valueOf(tenantId)));
                 if (select != null && select.size() > 0) {
                     FinSysTenant finSysTenant = select.get(0);
@@ -675,11 +619,17 @@
             return ResponseValue.error("鍙傛暟涓虹┖");
         }
         // 1. 鏍规嵁 user.getSysUserId() 鏌ヨ
-        List<S_role> list = finSysTenantUserService.getByUserId(user.getSysUserId()); // 宸叉湁鐨勬潈闄�
-        List<Long> roleList = user.getRoleList(); // 閫夋嫨鐨勬潈闄�
+        // 宸叉湁鐨勬潈闄�
+        List<S_role> list = finSysTenantUserService.getRoleBySysUserId(user.getSysUserId());
+        // 閫夋嫨鐨勬潈闄�
+        List<Long> roleList = user.getRoleList();
         // 鍏堝垹闄ゅ啀娣诲姞
         if (list != null && list.size() > 0) {
-            finSysTenantUserService.execDelRoleUserList(user.getSysUserId());
+            Long sysUserId = user.getSysUserId();
+            finSysTenantUserService.execDelRoleUserList(sysUserId);
+            // 鍒犻櫎搴撶鍛樹俊鎭褰�
+            list.stream().filter(item -> "浠撳簱绠$悊鍛�".equals(item.getRole_name())).findFirst()
+                .ifPresent(item -> baseWarehouseManagerService.deleteMangerBySysUserId(sysUserId));
         }
         if (roleList != null && roleList.size() > 0) {
             finSysTenantUserService.execInsertRoleUserList(roleList, user.getSysUserId());
@@ -708,76 +658,18 @@
             return ResponseValue.error(roleName + "鐨勮鑹蹭笉瀛樺湪");
         }
         // 鏍规嵁鍛樺伐缂栧彿鏌ヨ锛屽鏋滃瓨鍦ㄥ垯鎻愮ず
-        if (finSysTenantUserService.getByUserCode(user.getUserCode()) != null
-            && finSysTenantUserService.getByUserCode(user.getUserCode()) > 0) {
+        if (finSysTenantUserService.getByUserCode(user.getUserCode()) != null) {
             return ResponseValue.error("鍛樺伐缂栧彿閲嶅");
         }
         FinSysTenantUser sysInfo = this.getSysInfo();
         // 鎻掑叆绯荤粺鐢ㄦ埛
-        user.setId(NumberGenerator.getLongSequenceNumber());
-        user.setCreateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
-        user.setCreateBy(this.getCurrentUser().getUser_name());
-        user.setUpdateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
-        user.setUpdateBy(this.getCurrentUser().getUser_name());
-        user.setIsDelete(0);// 鏄惁鍒犻櫎 0鏄� 1鍚�
-        user.setSysUserId(NumberGenerator.getLongSequenceNumber());
-        user.setIsDelete(1);
-        user.setLv(sysInfo.getLv());
-        user.setTenantCode(sysInfo.getTenantCode());
-        user.setTenantId(sysInfo.getTenantId());
-        user.setSysDeptId(2l); // 杩愮淮绠$悊
-        // 鍔犲瘑鎵嬫満鍙�
-        String key = PlatformRSAUtils.AES_KEY;
-        String userPhone = user.getUserPhone();
-        String encPhone = "";
-        if (userPhone != null) {
-            encPhone = AESUtils.encryptStrAES(userPhone, key);
-            user.setUserPhone(encPhone);
-        }
-
+        buildTenantUser(user, sysInfo);
         this.finSysTenantUserService.insert(user);
         // 鎻掑叆骞冲彴鐢ㄦ埛
-        S_user_core userCore = new S_user_core();
-        userCore.setId(user.getSysUserId());
-        userCore.setDept_id(depts.get(0).getId()); // 閮ㄩ棬
-        userCore.setOrg_id(1L);
-        // userCore.setUser_name(); //鐢ㄦ埛璐﹀彿
-        userCore.setUser_name(user.getUserCode()); // 鐢ㄦ埛璐﹀彿
-        userCore.setNick_name(user.getUserName());
-        // 鐢ㄦ埛绫诲瀷 鍏堥粯璁よ缃负2
-        userCore.setUser_type(2);
-
-        userCore.setPhonenumber(userPhone);
-        // 鍒濆鍖栧瘑鐮� 123456
-        String pws = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();
-        userCore.setPassword(pws);
-        if (user.getStatus() == 0) {
-            userCore.setStatus(1);
-        } else {
-            userCore.setStatus(0);
-        }
-        userCore.setDel_flag(0);
-        userCore.setCreate_by(this.getCurrentUser().getCreate_by());
-        userCore.setCreate_time(DateUtils.getDateTimeNumber());
-        userCore.setRemark(user.getRemark());
-        userCore.setType(1);
-        userCore.setBind_client_id("0");
-        userCore.setBind_wechat(0);
-        userCore.setModify_pwd(0);
-        userCore.setBind_mobile(0);
-        userCore.setBind_mail(0);
-        userCore.setProfile_id(0L);
-        userCore.setIs_wechat_public(0);
-        userCore.setIs_wechat_routine(0);
-        userCore.setIs_wechat_ios(0);
-        userCore.setIs_wechat_android(0);
-        userCore.setIs_logoff(0);
-        userCore.setLogoff_time(0L);
-        userCore.setIs_sms(0);
-        // 绠$悊鍛樼被鍨嬶細1= 骞冲彴瓒呯, 2=鍟嗘埛瓒呯, 3=绯荤粺绠$悊鍛橈紝4=鍟嗘埛绠$悊鍛�
+        S_user_core userCore = buildUpdateUserCore(user);
+        // 閮ㄩ棬
+        userCore.setDept_id(depts.get(0).getId());
         userCore.setType(2);
-        // 鍟嗘埛id锛�0-骞冲彴
-        userCore.setMer_id(0L);
         this.userService.insert(userCore);
         // 鎻掑叆骞冲彴鏈烘瀯
         // 灏戣鑹瞚d
@@ -832,12 +724,7 @@
         updUser.setEmail(userParam.getEmail());
         updUser.setUserName(userParam.getUserName());
         updUser.setSex(userParam.getSex());
-        String encPhone = "";
-        if (userParam.getUserPhone() != null) {
-            String key = PlatformRSAUtils.AES_KEY;
-            encPhone = AESUtils.encryptStrAES(userParam.getUserPhone(), key);
-        }
-        updUser.setUserPhone(encPhone);
+        setUserPhone(updUser, userParam.getUserPhone());
         // 1.鏇存柊绯荤粺鐢ㄦ埛 FIN_SYS_TENANT_USER
         finSysTenantUserService.update(updUser);
         // 2.鏇存柊骞冲彴鐢ㄦ埛 S_USER_CORE

--
Gitblit v1.9.1