Source/UBCS/ubcs-service/ubcs-user/src/main/java/com/vci/ubcs/system/user/service/impl/UserServiceImpl.java

@@ -20,8 +20,10 @@
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import com.vci.ubcs.system.cache.DictCache;
import com.vci.ubcs.system.cache.NacosConfigCache;
import com.vci.ubcs.system.cache.ParamCache;
@@ -34,6 +36,7 @@
import com.vci.ubcs.system.user.cache.UserCache;
import com.vci.ubcs.system.user.entity.*;
import com.vci.ubcs.system.user.enums.UserEnum;
import com.vci.ubcs.system.user.enums.UserStatus;
import com.vci.ubcs.system.user.excel.UserExcel;
import com.vci.ubcs.system.user.mapper.UserMapper;
import com.vci.ubcs.system.user.service.IUserDeptService;
@@ -42,6 +45,7 @@
import com.vci.ubcs.system.user.vo.UserVO;
import com.vci.ubcs.system.user.wrapper.UserWrapper;
import lombok.RequiredArgsConstructor;
import org.springblade.core.log.annotation.GrantLog;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.mp.support.Condition;
@@ -77,21 +81,21 @@
   private final IUserOauthService userOauthService;
   private final ISysClient sysClient;
   private final BladeTenantProperties tenantProperties;
   //拿到配置的超管
   private final NacosConfigCache nacosConfigCache;

   @Override
   @Transactional(rollbackFor = Exception.class)
   public boolean submit(User user) {
      if (StringUtil.isBlank(user.getTenantId())) {
         // user.setTenantId(nacosConfigCache.getAdminUserInfo().getTenantId());
         // 默认设置为管理组下的用户
         user.setTenantId(nacosConfigCache.getAdminUserInfo().getTenantId());
         user.setTenantId(NacosConfigCache.getAdminUserInfo().getTenantId());
      }
      String tenantId = user.getTenantId();
      //Tenant tenant = SysCache.getTenant(tenantId);
      if (Func.isNotEmpty(user.getPassword())) {
         user.setPassword(DigestUtil.encrypt(user.getPassword()));
      }
      if(Func.isEmpty(user.getUserStatus())){
         user.setUserStatus(UserStatus.Enable.getValue());
      }
      Long userCount = baseMapper.selectCount(Wrappers.<User>query().lambda().eq(User::getTenantId, tenantId).eq(User::getAccount, user.getAccount()));
      if (userCount > 0L && Func.isEmpty(user.getId())) {
@@ -106,7 +110,7 @@
      Boolean flag = true;
      for (User user : users){
         if (StringUtil.isBlank(user.getTenantId())) {
            user.setTenantId(nacosConfigCache.getAdminUserInfo().getTenantId());
            user.setTenantId(NacosConfigCache.getAdminUserInfo().getTenantId());
         }
         String tenantId = user.getTenantId();
         if (Func.isNotEmpty(user.getPassword())) {
@@ -124,6 +128,7 @@

   @Override
   @Transactional(rollbackFor = Exception.class)
   @GrantLog("grantUser")
   public boolean updateUser(User user) {
      String tenantId = user.getTenantId();
      Long userCount = baseMapper.selectCount(
@@ -132,6 +137,7 @@
            .eq(User::getAccount, user.getAccount())
            .notIn(User::getId, user.getId())
      );
      // 判断是否被修改为已存在的用户名
      if (userCount > 0L) {
         throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
      }
@@ -144,8 +150,41 @@
      return updateById(user);
   }

   /**
    * 根据旧账号，修改为新账号名
    * @param oldAccount
    * @param newAccount
    * @return
    */
   @Override
   public boolean updateByAccount(String oldAccount,String newAccount) {
      User user = this.userByAccount(AuthUtil.getTenantId(), oldAccount);
      if(Func.isEmpty(user)){
         return true;
      }
      user.setAccount(newAccount);
      return this.updateUser(user);
   }

   /**
    * 据账号，修改为用户状态
    * @param accounts
    * @param status
    * @return
    */
   @Override
   public boolean updateStatusByAccount(String accounts, String status) {
      LambdaUpdateWrapper<User> updateWrapper = Wrappers.<User>update()
         .lambda().in(User::getAccount, accounts)
         .set(User::getUserStatus, status);
      return this.update(updateWrapper);
   }

   private boolean submitUserDept(User user) {
      List<Long> deptIdList = Func.toLongList(user.getDeptId());
      if(deptIdList.isEmpty()){
         return true;
      }
      List<UserDept> userDeptList = new ArrayList<>();
      deptIdList.forEach(deptId -> {
         UserDept userDept = new UserDept();
@@ -166,7 +205,7 @@
   @Override
   public List<User> selectAllUser(User user, Long deptId){
      List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
      List<User> users = baseMapper.selectUserPage(user, deptIdList, (AuthUtil.getTenantId().equals(nacosConfigCache.getAdminUserInfo().getTenantId()) ? StringPool.EMPTY : AuthUtil.getTenantId()));
      List<User> users = baseMapper.selectUserPage(user, deptIdList, (VciBaseUtil.checkAdminTenant() ? StringPool.EMPTY : AuthUtil.getTenantId()));
      return users;
   }

@@ -313,6 +352,16 @@
      User user = new User();
      user.setRoleId(roleIds);
      return this.update(user, Wrappers.<User>update().lambda().in(User::getId, Func.toLongList(userIds)));
   }

   /**
    * 授权日志插入操作
    * @param res
    */
   @Override
   @GrantLog("grantUser")
   public boolean grantLog(String res, boolean isException){
      return true;
   }

   @Override
@@ -514,7 +563,7 @@
   @Override
   public Long checkRenAndExpr(Long userId) {
      //超级管理员直接返回不需要提醒密码修改
      if(nacosConfigCache.getAdminUserInfo().getUserId().equals(userId)){
      if(NacosConfigCache.getAdminUserInfo().getUserId().equals(userId)){
         return 0L;
      }
      QueryWrapper<User> wrapper = Wrappers.<User>query().eq("ID", userId);
@@ -526,6 +575,9 @@
         pwdupdateday = dateToDay(pwdUpdateTime);
      }
      Strategy strategy = sysClient.getByUserId(userId).getData();
      if(Func.isEmpty(strategy)){
         throw new ServiceException("密码策略查询为空，请检查当前租户下是否存在默认密码策略！");
      }
      //是否提醒通过最后一次修改密码的时间加上过期时间减去当前时间，如果小于过期提醒时间就进行提醒，如果<=0就提醒必须修改密码
      long reminder = pwdupdateday+strategy.getExpirationTime()-dateToDay(new Date());
      //提醒用户必须修改密码
@@ -578,11 +630,11 @@
    */
   @Override
   public boolean updateUserStatus(String userIds, boolean status) {
      Integer user_status=0;
      Integer userStatus = 0;
      if(!status){
         user_status=1;
         userStatus = 1;
      }
      return this.update(Wrappers.<User>lambdaUpdate().in(User::getId, Func.toLongList(userIds)).set(User::getUserStatus,user_status));
      return this.update(Wrappers.<User>lambdaUpdate().in(User::getId, Func.toLongList(userIds)).set(User::getUserStatus,userStatus));
   }

   /**