|
@@ -1,14 +1,15 @@
|
|
|
package com.kxs.user.biz.service.impl;
|
|
package com.kxs.user.biz.service.impl;
|
|
|
|
|
|
|
|
|
|
+import cn.hutool.core.collection.CollectionUtil;
|
|
|
import cn.hutool.core.date.DatePattern;
|
|
import cn.hutool.core.date.DatePattern;
|
|
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
|
|
import cn.hutool.core.text.CharSequenceUtil;
|
|
import cn.hutool.core.text.CharSequenceUtil;
|
|
|
-import cn.hutool.core.text.StrPool;
|
|
|
|
|
import cn.hutool.core.util.IdcardUtil;
|
|
import cn.hutool.core.util.IdcardUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.core.util.RandomUtil;
|
|
import cn.hutool.core.util.RandomUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import cn.hutool.crypto.SecureUtil;
|
|
import cn.hutool.crypto.SecureUtil;
|
|
|
|
|
+import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.kxs.common.core.constant.CacheConstants;
|
|
import com.kxs.common.core.constant.CacheConstants;
|
|
@@ -30,12 +31,18 @@ import com.kxs.store.api.model.KxsWarehouseLimit;
|
|
|
import com.kxs.system.api.feign.RemoteUserMsgService;
|
|
import com.kxs.system.api.feign.RemoteUserMsgService;
|
|
|
import com.kxs.system.api.model.KxsUserMsg;
|
|
import com.kxs.system.api.model.KxsUserMsg;
|
|
|
import com.kxs.system.api.util.MsgTemplateUtil;
|
|
import com.kxs.system.api.util.MsgTemplateUtil;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.RestPwdDTO;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.SysUserLogoutListDTO;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.SysUserPageDTO;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.SysUserUserAccountListDTO;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.SysUserWhereListDTO;
|
|
|
import com.kxs.user.api.dto.kxsapp.ConcealParentDTO;
|
|
import com.kxs.user.api.dto.kxsapp.ConcealParentDTO;
|
|
|
import com.kxs.user.api.dto.kxsapp.app.ForgetPwdDTO;
|
|
import com.kxs.user.api.dto.kxsapp.app.ForgetPwdDTO;
|
|
|
import com.kxs.user.api.dto.kxsapp.app.MchRegisterDTO;
|
|
import com.kxs.user.api.dto.kxsapp.app.MchRegisterDTO;
|
|
|
import com.kxs.user.api.dto.kxsapp.app.RegisterDTO;
|
|
import com.kxs.user.api.dto.kxsapp.app.RegisterDTO;
|
|
|
import com.kxs.user.api.dto.kxsapp.user.*;
|
|
import com.kxs.user.api.dto.kxsapp.user.*;
|
|
|
import com.kxs.user.api.model.*;
|
|
import com.kxs.user.api.model.*;
|
|
|
|
|
+import com.kxs.user.api.vo.admin.user.SysUserWhereListVO;
|
|
|
import com.kxs.user.api.vo.kxsapp.user.*;
|
|
import com.kxs.user.api.vo.kxsapp.user.*;
|
|
|
import com.kxs.user.api.vo.kxsapp.userLevel.LevelDetailVO;
|
|
import com.kxs.user.api.vo.kxsapp.userLevel.LevelDetailVO;
|
|
|
import com.kxs.user.api.vo.kxsapp.userLevel.LevelsVO;
|
|
import com.kxs.user.api.vo.kxsapp.userLevel.LevelsVO;
|
|
@@ -48,7 +55,7 @@ import com.kxs.user.biz.service.KxsUserService;
|
|
|
import com.kxs.user.biz.util.SmsUtils;
|
|
import com.kxs.user.biz.util.SmsUtils;
|
|
|
import io.seata.spring.annotation.GlobalTransactional;
|
|
import io.seata.spring.annotation.GlobalTransactional;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.RequiredArgsConstructor;
|
|
|
-import org.checkerframework.checker.units.qual.K;
|
|
|
|
|
|
|
+import org.apache.commons.lang.StringUtils;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.cache.CacheManager;
|
|
import org.springframework.cache.CacheManager;
|
|
@@ -71,7 +78,6 @@ import java.util.List;
|
|
|
import java.util.Objects;
|
|
import java.util.Objects;
|
|
|
import java.util.UUID;
|
|
import java.util.UUID;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
-import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 用户表(KxsSecurityUser)表服务实现类
|
|
* 用户表(KxsSecurityUser)表服务实现类
|
|
@@ -267,6 +273,92 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
|
|
|
return R.ok();
|
|
return R.ok();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<KxsUser> getUserPage(Page page, SysUserPageDTO param) {
|
|
|
|
|
+ List<KxsUser> list = baseMapper.getUserPage(page, param);
|
|
|
|
|
+ if(page != null){
|
|
|
|
|
+ page.setRecords(list);
|
|
|
|
|
+ }
|
|
|
|
|
+ return list;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<SysUserWhereListVO> getUserWhereList(Page page, SysUserWhereListDTO param) {
|
|
|
|
|
+ String userId = param.getUserId();
|
|
|
|
|
+ KxsUser kxsUser = getById(userId);
|
|
|
|
|
+ if(kxsUser == null){
|
|
|
|
|
+ throw new GlobalCustomerException("创客信息不存在");
|
|
|
|
|
+ }
|
|
|
|
|
+ param.setPid(kxsUser.getPid());
|
|
|
|
|
+ List<SysUserWhereListVO> list = baseMapper.getUserWhereList(page, param);
|
|
|
|
|
+ if(page != null){
|
|
|
|
|
+ page.setRecords(list);
|
|
|
|
|
+ }
|
|
|
|
|
+ return list;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<KxsUser> getLogoutListPage(Page page, SysUserLogoutListDTO param) {
|
|
|
|
|
+ List<KxsUser> list = baseMapper.getLogoutListPage(page, param);
|
|
|
|
|
+ if(page != null){
|
|
|
|
|
+ page.setRecords(list);
|
|
|
|
|
+ }
|
|
|
|
|
+ return list;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void updateStatusByUserId(String userId,UserStatusEnum userStatusEnum) {
|
|
|
|
|
+ KxsUser kxsUser = getById(userId);
|
|
|
|
|
+ if(kxsUser == null){
|
|
|
|
|
+ throw new GlobalCustomerException("创客信息不存在");
|
|
|
|
|
+ }
|
|
|
|
|
+ kxsUser.setStatus(UserStatusEnum.REMOVE.getCode());
|
|
|
|
|
+ updateById(kxsUser);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void updateStatusByUserIds(List<String> userIdList,UserStatusEnum userStatusEnum) {
|
|
|
|
|
+ if(CollectionUtil.isNotEmpty(userIdList)){
|
|
|
|
|
+ List<KxsUser> kxsUsers = listByIds(userIdList);
|
|
|
|
|
+ if(CollectionUtil.isNotEmpty(kxsUsers)){
|
|
|
|
|
+ for(KxsUser kxsUser:kxsUsers){
|
|
|
|
|
+ kxsUser.setStatus(userStatusEnum.getCode());
|
|
|
|
|
+ }
|
|
|
|
|
+ this.updateBatchById(kxsUsers);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void restPwd(RestPwdDTO param) {
|
|
|
|
|
+ KxsUser kxsUser = getById(param.getUserId());
|
|
|
|
|
+ if(kxsUser == null){
|
|
|
|
|
+ throw new GlobalCustomerException("创客信息不存在");
|
|
|
|
|
+ }
|
|
|
|
|
+ String password = param.getPassword();
|
|
|
|
|
+ if(StringUtils.isBlank(password)){
|
|
|
|
|
+ password = "123456";
|
|
|
|
|
+ }
|
|
|
|
|
+ if(StringUtils.isBlank(kxsUser.getSalt())){
|
|
|
|
|
+ kxsUser.setSalt(UUID.randomUUID().toString());
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ //重置密码
|
|
|
|
|
+ kxsUser.setPassword(ENCODER.encode(password + kxsUser.getSalt()));
|
|
|
|
|
+
|
|
|
|
|
+ //保存新密码
|
|
|
|
|
+ this.updateById(kxsUser);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<SysUserWhereListVO> userAccountPage(Page page, SysUserUserAccountListDTO param) {
|
|
|
|
|
+ List<SysUserWhereListVO> list = baseMapper.userAccountPage(page, param);
|
|
|
|
|
+ if(page != null){
|
|
|
|
|
+ page.setRecords(list);
|
|
|
|
|
+ }
|
|
|
|
|
+ return list;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public Boolean sendCode(String mobile) {
|
|
public Boolean sendCode(String mobile) {
|
|
|
|
|
|