From d46beba25ccb64a1047a98d642b6ce45e82f0bee Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期一, 17 十月 2022 18:07:28 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master' into master
---
ycl-common/src/main/java/com/ycl/service/user/impl/UmsAdminServiceImpl.java | 232 +++++++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 196 insertions(+), 36 deletions(-)
diff --git a/ycl-common/src/main/java/com/ycl/service/user/impl/UmsAdminServiceImpl.java b/ycl-common/src/main/java/com/ycl/service/user/impl/UmsAdminServiceImpl.java
index 60beaa5..86a520b 100644
--- a/ycl-common/src/main/java/com/ycl/service/user/impl/UmsAdminServiceImpl.java
+++ b/ycl-common/src/main/java/com/ycl/service/user/impl/UmsAdminServiceImpl.java
@@ -4,22 +4,31 @@
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ycl.bo.AdminUserDetails;
import com.ycl.dto.UmsAdminParam;
import com.ycl.dto.UpdateAdminPasswordParam;
+import com.ycl.entity.depart.UmsDepart;
import com.ycl.entity.user.*;
+import com.ycl.exception.ApiException;
import com.ycl.exception.Asserts;
-import com.ycl.mapper.user.UmsAdminLoginLogMapper;
-import com.ycl.mapper.user.UmsAdminMapper;
-import com.ycl.mapper.user.UmsResourceMapper;
-import com.ycl.mapper.user.UmsRoleMapper;
+import com.ycl.mapper.user.*;
+import com.ycl.service.depart.UmsDepartService;
+import com.ycl.service.redis.RedisService;
import com.ycl.service.user.UmsAdminCacheService;
import com.ycl.service.user.UmsAdminRoleRelationService;
import com.ycl.service.user.UmsAdminService;
import com.ycl.utils.JwtTokenUtil;
import com.ycl.utils.SpringUtil;
+import com.ycl.utils.common.LiveTimeMillisecond;
+import com.ycl.utils.common.MacUtils;
+import com.ycl.utils.common.PojoUtils;
+import com.ycl.utils.common.RandomUtils;
+import com.ycl.utils.redis.RedisKey;
+import com.ycl.vo.user.UserVO;
+import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
@@ -31,6 +40,7 @@
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@@ -40,6 +50,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
+import java.util.stream.Collectors;
/**
* 鍚庡彴绠＄悊鍛樼鐞哠ervice瀹炵幇绫�
@@ -60,13 +71,25 @@
private UmsRoleMapper umsRoleMapper;
@Resource
private UmsResourceMapper umsResourceMapper;
+ @Resource
+ private UmsDepartService departService;
+ @Resource
+ private RedisService redisService;
+ @Resource
+ private UmsDepartManageMapper umsDepartManageMapper;
+ @Resource
+ UmsRoleMenuRelationMapper umsRoleMenuRelationMapper;
+ @Resource
+ AdminMenuRelationMapper adminMenuRelationMapper;
+ @Resource
+ UmsMenuMapper umsMenuMapper;
@Override
public UmsAdmin getAdminByUsername(String username) {
UmsAdmin admin = getCacheService().getAdmin(username);
- if(admin!=null) return admin;
+ if (admin != null) return admin;
QueryWrapper<UmsAdmin> wrapper = new QueryWrapper<>();
- wrapper.lambda().eq(UmsAdmin::getUsername,username);
+ wrapper.lambda().eq(UmsAdmin::getUsername, username);
List<UmsAdmin> adminList = list(wrapper);
if (adminList != null && adminList.size() > 0) {
admin = adminList.get(0);
@@ -77,14 +100,17 @@
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public UmsAdmin register(UmsAdminParam umsAdminParam) {
UmsAdmin umsAdmin = new UmsAdmin();
+ //TODO mac,ip,鑱屽姟锛岀敤鎴风被鍨�
BeanUtils.copyProperties(umsAdminParam, umsAdmin);
umsAdmin.setCreateTime(new Date());
umsAdmin.setStatus(1);
+ umsAdmin.setMacAddress(MacUtils.getMac());
//鏌ヨ鏄惁鏈夌浉鍚岀敤鎴峰悕鐨勭敤鎴�
QueryWrapper<UmsAdmin> wrapper = new QueryWrapper<>();
- wrapper.lambda().eq(UmsAdmin::getUsername,umsAdmin.getUsername());
+ wrapper.lambda().eq(UmsAdmin::getUsername, umsAdmin.getUsername());
List<UmsAdmin> umsAdminList = list(wrapper);
if (umsAdminList.size() > 0) {
return null;
@@ -93,6 +119,49 @@
String encodePassword = passwordEncoder.encode(umsAdmin.getPassword());
umsAdmin.setPassword(encodePassword);
baseMapper.insert(umsAdmin);
+
+ //娣诲姞瑙掕壊鎺堟潈
+ List<Long> ids = umsAdminParam.getRoleIds();
+ if (!ids.isEmpty()) {
+ List<UmsAdminRoleRelation> roleIds = new ArrayList<>();
+ for (Long id : ids) {
+ UmsAdminRoleRelation urr = new UmsAdminRoleRelation();
+ urr.setAdminId(umsAdmin.getId());
+ urr.setRoleId(id);
+ roleIds.add(urr);
+ }
+ umsAdminRoleRelationService.saveBatch(roleIds);
+ }
+ //缁戝畾鑿滃崟浜庣敤鎴�
+ if (!ids.isEmpty()) {
+ Integer size = 0;
+ Long maxId = null;
+ for (Long id : ids) {
+ if (size < umsRoleMenuRelationMapper
+ .selectList(new LambdaQueryWrapper<UmsRoleMenuRelation>()
+ .eq(UmsRoleMenuRelation::getRoleId, id)).size()) {
+ size = umsRoleMenuRelationMapper
+ .selectList(new LambdaQueryWrapper<UmsRoleMenuRelation>()
+ .eq(UmsRoleMenuRelation::getRoleId, id)).size();
+ maxId = id;
+ }
+ }
+ umsRoleMenuRelationMapper
+ .selectList(new LambdaQueryWrapper<UmsRoleMenuRelation>()
+ .eq(UmsRoleMenuRelation::getRoleId, maxId))
+ .stream()
+ .forEach(item -> {
+ AdminMenuRelation adminMenuRelation = new AdminMenuRelation();
+ adminMenuRelation.setAdminId(umsAdmin.getId());
+ adminMenuRelation.setMenuId(item.getMenuId());
+ adminMenuRelation.setSort(umsMenuMapper.selectOne(new LambdaQueryWrapper<UmsMenu>().eq(UmsMenu::getId, item.getMenuId())).getSort());
+ adminMenuRelationMapper.insert(adminMenuRelation);
+ });
+ }
+ //瀵圭敤鎴峰悕绯荤粺榛樿娣诲姞
+ umsAdmin.setNickName(RandomUtils.getUserId(umsAdmin.getId()));
+ baseMapper.updateById(umsAdmin);
+
return umsAdmin;
}
@@ -101,16 +170,18 @@
String token = null;
//瀵嗙爜闇�瑕佸鎴风鍔犲瘑鍚庝紶閫�
try {
- UserDetails userDetails = loadUserByUsername(username);
- if(!passwordEncoder.matches(password,userDetails.getPassword())){
+ AdminUserDetails userDetails = (AdminUserDetails) loadUserByUsername(username);
+ if (!passwordEncoder.matches(password, userDetails.getPassword())) {
Asserts.fail("瀵嗙爜涓嶆纭�");
}
- if(!userDetails.isEnabled()){
+ if (!userDetails.isEnabled()) {
Asserts.fail("甯愬彿宸茶绂佺敤");
}
UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(userDetails, null, userDetails.getAuthorities());
SecurityContextHolder.getContext().setAuthentication(authentication);
- token = jwtTokenUtil.generateToken(userDetails);
+ //鏍规嵁鐢ㄦ埛id锛岀敤鎴峰鍚�
+ token = jwtTokenUtil.generateToken(userDetails.getUserId(), userDetails.getUsername());
+ redisService.set(RedisKey.PLATFORM_TOKEN_KEY.concat(username), token, LiveTimeMillisecond.s7200.time);
// updateLoginTimeByUsername(username);
insertLoginLog(username);
} catch (AuthenticationException e) {
@@ -121,11 +192,12 @@
/**
* 娣诲姞鐧诲綍璁板綍
+ *
* @param username 鐢ㄦ埛鍚�
*/
private void insertLoginLog(String username) {
UmsAdmin admin = getAdminByUsername(username);
- if(admin==null) return;
+ if (admin == null) return;
UmsAdminLoginLog loginLog = new UmsAdminLoginLog();
loginLog.setAdminId(admin.getId());
loginLog.setCreateTime(new Date());
@@ -142,8 +214,8 @@
UmsAdmin record = new UmsAdmin();
record.setLoginTime(new Date());
QueryWrapper<UmsAdmin> wrapper = new QueryWrapper<>();
- wrapper.lambda().eq(UmsAdmin::getUsername,username);
- update(record,wrapper);
+ wrapper.lambda().eq(UmsAdmin::getUsername, username);
+ update(record, wrapper);
}
@Override
@@ -153,28 +225,29 @@
@Override
public Page<UmsAdmin> list(String keyword, Integer pageSize, Integer pageNum) {
- Page<UmsAdmin> page = new Page<>(pageNum,pageSize);
+ Page<UmsAdmin> page = new Page<>(pageNum, pageSize);
QueryWrapper<UmsAdmin> wrapper = new QueryWrapper<>();
LambdaQueryWrapper<UmsAdmin> lambda = wrapper.lambda();
- if(StrUtil.isNotEmpty(keyword)){
- lambda.like(UmsAdmin::getUsername,keyword);
- lambda.or().like(UmsAdmin::getNickName,keyword);
+ if (StrUtil.isNotEmpty(keyword)) {
+ lambda.like(UmsAdmin::getUsername, keyword);
+ lambda.or().like(UmsAdmin::getNickName, keyword);
}
- return page(page,wrapper);
+ return page(page, wrapper);
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public boolean update(Long id, UmsAdmin admin) {
admin.setId(id);
UmsAdmin rawAdmin = getById(id);
- if(rawAdmin.getPassword().equals(admin.getPassword())){
+ if (rawAdmin.getPassword().equals(admin.getPassword())) {
//涓庡師鍔犲瘑瀵嗙爜鐩稿悓鐨勪笉闇�瑕佷慨鏀�
admin.setPassword(null);
- }else{
+ } else {
//涓庡師鍔犲瘑瀵嗙爜涓嶅悓鐨勯渶瑕佸姞瀵嗕慨鏀�
- if(StrUtil.isEmpty(admin.getPassword())){
+ if (StrUtil.isEmpty(admin.getPassword())) {
admin.setPassword(null);
- }else{
+ } else {
admin.setPassword(passwordEncoder.encode(admin.getPassword()));
}
}
@@ -196,7 +269,7 @@
int count = roleIds == null ? 0 : roleIds.size();
//鍏堝垹闄ゅ師鏉ョ殑鍏崇郴
QueryWrapper<UmsAdminRoleRelation> wrapper = new QueryWrapper<>();
- wrapper.lambda().eq(UmsAdminRoleRelation::getAdminId,adminId);
+ wrapper.lambda().eq(UmsAdminRoleRelation::getAdminId, adminId);
umsAdminRoleRelationService.remove(wrapper);
//寤虹珛鏂板叧绯�
if (!CollectionUtils.isEmpty(roleIds)) {
@@ -221,31 +294,31 @@
@Override
public List<UmsResource> getResourceList(Long adminId) {
List<UmsResource> resourceList = getCacheService().getResourceList(adminId);
- if(CollUtil.isNotEmpty(resourceList)){
- return resourceList;
+ if (CollUtil.isNotEmpty(resourceList)) {
+ return resourceList;
}
resourceList = umsResourceMapper.getResourceList(adminId);
- if(CollUtil.isNotEmpty(resourceList)){
- getCacheService().setResourceList(adminId,resourceList);
+ if (CollUtil.isNotEmpty(resourceList)) {
+ getCacheService().setResourceList(adminId, resourceList);
}
return resourceList;
}
@Override
public int updatePassword(UpdateAdminPasswordParam param) {
- if(StrUtil.isEmpty(param.getUsername())
- ||StrUtil.isEmpty(param.getOldPassword())
- ||StrUtil.isEmpty(param.getNewPassword())){
+ if (StrUtil.isEmpty(param.getUsername())
+ || StrUtil.isEmpty(param.getOldPassword())
+ || StrUtil.isEmpty(param.getNewPassword())) {
return -1;
}
QueryWrapper<UmsAdmin> wrapper = new QueryWrapper<>();
- wrapper.lambda().eq(UmsAdmin::getUsername,param.getUsername());
+ wrapper.lambda().eq(UmsAdmin::getUsername, param.getUsername());
List<UmsAdmin> adminList = list(wrapper);
- if(CollUtil.isEmpty(adminList)){
+ if (CollUtil.isEmpty(adminList)) {
return -2;
}
UmsAdmin umsAdmin = adminList.get(0);
- if(!passwordEncoder.matches(param.getOldPassword(),umsAdmin.getPassword())){
+ if (!passwordEncoder.matches(param.getOldPassword(), umsAdmin.getPassword())) {
return -3;
}
umsAdmin.setPassword(passwordEncoder.encode(param.getNewPassword()));
@@ -255,12 +328,12 @@
}
@Override
- public UserDetails loadUserByUsername(String username){
+ public UserDetails loadUserByUsername(String username) {
//鑾峰彇鐢ㄦ埛淇℃伅
UmsAdmin admin = getAdminByUsername(username);
if (admin != null) {
List<UmsResource> resourceList = getResourceList(admin.getId());
- return new AdminUserDetails(admin,resourceList);
+ return new AdminUserDetails(admin, resourceList);
}
throw new UsernameNotFoundException("鐢ㄦ埛鍚嶆垨瀵嗙爜閿欒");
}
@@ -269,4 +342,91 @@
public UmsAdminCacheService getCacheService() {
return SpringUtil.getBean(UmsAdminCacheService.class);
}
+
+ @Override
+ public IPage<UmsAdmin> pageUser(UserVO.PageUserVO pageUserVO) {
+ int pageSize = pageUserVO.getPageSize();
+ int current = pageUserVO.getCurrent();
+ Page<UmsAdmin> page = new Page<>(current, pageSize);
+ LambdaQueryWrapper<UmsAdmin> queryWrapper = new LambdaQueryWrapper<>();
+
+ if (StringUtils.isNotBlank(pageUserVO.getKeyword())) {
+ queryWrapper.like(UmsAdmin::getUsername, pageUserVO.getKeyword())
+ .or().like(UmsAdmin::getNickName, pageUserVO.getKeyword())
+ .or().like(UmsAdmin::getMobile, pageUserVO.getKeyword());
+ }
+ if (StringUtils.isNotBlank(pageUserVO.getJobTitle())) {
+ queryWrapper.eq(UmsAdmin::getJobTitle, pageUserVO.getJobTitle());
+ }
+ if (PojoUtils.Vo.isUsefulSearchParam(pageUserVO.getUserType())) {
+ queryWrapper.eq(UmsAdmin::getUserType, pageUserVO.getUserType());
+ }
+ if (PojoUtils.Vo.isUsefulSearchParam(pageUserVO.getDepartmentId())) {
+ queryWrapper.eq(UmsAdmin::getDepartmentId, pageUserVO.getDepartmentId());
+ }
+ Page<UmsAdmin> page1 = baseMapper.selectPage(page, queryWrapper);
+ List<UmsAdmin> records = page1.getRecords();
+ if (CollUtil.isNotEmpty(records)) {
+ records.forEach(e -> {
+ UmsDepart umsDepart = departService.getById(e.getDepartmentId());
+ if (null != umsDepart) {
+ e.setDepartName(umsDepart.getDepartName());
+ }
+ //鑾峰彇瑙掕壊鍒楄〃
+ List<UmsRole> roles = umsRoleMapper.getRoleList(e.getId());
+ e.setRoles(roles);
+ });
+ }
+ return page1;
+ }
+
+ @Override
+ public boolean deleteBatch(List<Long> ids) {
+ boolean success = removeByIds(ids);
+ getCacheService().delBatchAdmin(ids);
+ return success;
+ }
+
+ @Override
+ public boolean updateStatusBatch(List<Long> ids, Integer status) {
+ List<UmsAdmin> users = new ArrayList<>();
+ for (Long id : ids) {
+ UmsAdmin umsAdmin = UmsAdmin.builder().
+ id(id).status(status).build();
+ users.add(umsAdmin);
+ }
+ updateBatchById(users, users.size());
+ getCacheService().delBatchAdmin(ids);
+ return true;
+ }
+
+ @Override
+ public List<UmsAdmin> getDepartUser(Long departId) {
+ QueryWrapper<UmsDepartManage> wrapper = new QueryWrapper<>();
+ wrapper.lambda().eq(UmsDepartManage::getDepartId, departId);
+ List<UmsDepartManage> list = umsDepartManageMapper.selectList(wrapper);
+ List<Long> userIds = list.stream().map(UmsDepartManage::getUserId).collect(Collectors.toList());
+ QueryWrapper<UmsAdmin> wrapperUser = new QueryWrapper<>();
+ wrapperUser.in("id", userIds);
+ List<UmsAdmin> adminList = baseMapper.selectList(wrapperUser);
+ return adminList;
+ }
+
+ @Override
+ public String getTargetTo(String ids, String sendType) {
+ String str = null;
+ String[] arr = ids.split(",");
+ QueryWrapper<UmsAdmin> wrapperUser = new QueryWrapper<>();
+ wrapperUser.in("id", arr);
+ List<UmsAdmin> adminList = baseMapper.selectList(wrapperUser);
+ if (adminList == null || adminList.isEmpty()) {
+ throw new ApiException("鏈煡璇㈠埌鐢ㄦ埛");
+ }
+ if ("02".equals(sendType)) {
+ str = adminList.stream().map(UmsAdmin::getEmail).collect(Collectors.joining(","));
+ } else {
+ str = adminList.stream().map(UmsAdmin::getMobile).collect(Collectors.joining(","));
+ }
+ return str;
+ }
}
--
Gitblit v1.8.0