package com.ibeetl.admin.console.service;
|
|
import java.util.*;
|
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.util.IdUtil;
|
import com.ibeetl.admin.console.dao.CuserConsoleDao;
|
import com.ibeetl.admin.console.model.CoreUserModel;
|
import com.ibeetl.admin.core.dao.CoreUserRoleDao;
|
import com.ibeetl.admin.core.entity.XzxCityPartner;
|
import org.apache.catalina.User;
|
import org.apache.commons.lang3.StringUtils;
|
import org.beetl.sql.core.engine.PageQuery;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.ibeetl.admin.console.dao.UserConsoleDao;
|
import com.ibeetl.admin.console.exception.DeletedException;
|
import com.ibeetl.admin.console.exception.NoResourceException;
|
import com.ibeetl.admin.console.web.dto.UserExcelExportData;
|
import com.ibeetl.admin.console.web.query.UserRoleQuery;
|
import com.ibeetl.admin.core.conf.PasswordConfig.PasswordEncryptService;
|
import com.ibeetl.admin.core.entity.CoreDict;
|
import com.ibeetl.admin.core.entity.CoreUser;
|
import com.ibeetl.admin.core.entity.CoreUserRole;
|
import com.ibeetl.admin.core.file.FileService;
|
import com.ibeetl.admin.core.rbac.tree.OrgItem;
|
import com.ibeetl.admin.core.service.CoreBaseService;
|
import com.ibeetl.admin.core.service.CoreDictService;
|
import com.ibeetl.admin.core.service.CorePlatformService;
|
import com.ibeetl.admin.core.util.PlatformException;
|
import com.ibeetl.admin.core.util.enums.CoreDictType;
|
import com.ibeetl.admin.core.util.enums.DelFlagEnum;
|
import com.ibeetl.admin.core.util.enums.GeneralStateEnum;
|
|
@Service
|
@Transactional
|
public class UserConsoleService extends CoreBaseService<CoreUser> {
|
|
@Autowired
|
UserConsoleDao userDao;
|
@Autowired
|
CoreUserRoleDao roleDao;
|
@Autowired
|
CuserConsoleDao cuserdao;
|
@Autowired
|
XzxCityPartnerService cityPartnerService;
|
|
@Autowired
|
FileService fileService;
|
|
@Autowired
|
PasswordEncryptService passwordEncryptService;
|
@Autowired
|
CoreDictService dictService;
|
|
|
@Autowired
|
CorePlatformService platformService;
|
Snowflake snowflake = IdUtil.getSnowflake(0, 3);
|
/**
|
* 根据条件查询
|
*
|
* @param query
|
*/
|
public List<CoreUserModel> queryByCondtion(CoreUserModel query) {
|
int p = (query.getPage() - 1) * query.getLimit();
|
query.setPage(p);
|
if(null!=query.getStartTime()&&!"".equals(query.getStartTime())){
|
query.setStartTime(query.getStartTime()+" 00:00:00");
|
}
|
if(null!=query.getEndTime()&&!"".equals(query.getEndTime())){
|
query.setEndTime(query.getEndTime()+" 23:59:59");
|
}
|
List<CoreUserModel> ret = userDao.queryByCondtion(query);
|
return ret;
|
}
|
|
public int queryByCondtionCount(CoreUserModel query) {
|
return userDao.queryByCondtionCount(query);
|
}
|
|
public void updateRole(CoreUser user,Long roleId){
|
List<CoreUserRole> list = roleDao.queryRoleByUserId(user.getId(),user.getOrgId());
|
if(list.size()>0){
|
CoreUserRole role = list.get(0);
|
CoreUserRole coreUserRole = new CoreUserRole();
|
coreUserRole.setId(role.getId());
|
coreUserRole.setCreateTime(new Date());
|
coreUserRole.setOrgId(user.getOrgId());
|
coreUserRole.setUserId(user.getId());
|
coreUserRole.setRoleId(roleId);
|
roleDao.updateById(coreUserRole);
|
|
}else{
|
XzxCityPartner partner = cityPartnerService.queryById(user.getId());
|
if(null!=partner){
|
list = roleDao.queryRoleByUserId(user.getId(),partner.getOrgId());
|
if(list.size()>0){
|
CoreUserRole role = list.get(0);
|
CoreUserRole coreUserRole = new CoreUserRole();
|
coreUserRole.setId(role.getId());
|
coreUserRole.setCreateTime(new Date());
|
coreUserRole.setOrgId(user.getOrgId());
|
coreUserRole.setUserId(user.getId());
|
coreUserRole.setRoleId(roleId);
|
roleDao.updateById(coreUserRole);
|
}
|
}
|
|
}
|
|
}
|
/**
|
* 插入一条用户数据
|
*
|
* @param user
|
*/
|
public void saveUser(CoreUser user,Long roleId) {
|
CoreUser query = new CoreUser();
|
query.setCode(user.getCode());
|
CoreUser dbUser = userDao.templateOne(query);
|
if (dbUser != null) {
|
throw new PlatformException("保存用户信息失败,用户已经存在");
|
}
|
user.setCreateTime(new Date());
|
user.setState(GeneralStateEnum.ENABLE.getValue());
|
user.setPassword(passwordEncryptService.password(user.getPassword()));
|
user.setDelFlag(DelFlagEnum.NORMAL.getValue());
|
userDao.insert(user, true);
|
if(StringUtils.isNotEmpty(user.getAttachmentId())){
|
//更新附件详细信息,关联到这个用户
|
fileService.updateFile(user.getAttachmentId(), User.class.getSimpleName(), String.valueOf(user.getId()));
|
}
|
//String roleId = user.getRoleId();
|
CoreUserRole coreUserRole = new CoreUserRole();
|
coreUserRole.setCreateTime(new Date());
|
coreUserRole.setOrgId(user.getOrgId());
|
coreUserRole.setUserId(user.getId());
|
coreUserRole.setRoleId(roleId);
|
roleDao.insert(coreUserRole);
|
//添加用户的账户
|
// 添加账号表
|
Map<String,Object> setMap = new HashMap<>();
|
String value = "0";
|
String accountNo="ZH"+snowflake.nextIdStr();
|
cuserdao.addCuserAccountRole(accountNo, "", user.getId()+"",value);
|
|
}
|
|
/**
|
* 根据用户id查询一条数据
|
*
|
* @param userId
|
*/
|
public CoreUser queryUserById(Long userId) {
|
return userDao.unique(userId);
|
}
|
|
/**
|
* 更新用户 只更新不为空的字段
|
*
|
* @param user
|
* @return
|
*/
|
public int updateSysUser(CoreUser user) {
|
return userDao.updateTemplateById(user);
|
}
|
|
/**
|
* 删除用户
|
*
|
* @param userId
|
* 用户id
|
*/
|
public void delSysUser(Long userId) {
|
CoreUser user = queryUserById(userId);
|
if (user == null) {
|
throw new NoResourceException("用户不存在!");
|
}
|
if (user.getDelFlag() == DelFlagEnum.DELETED.getValue()) {
|
throw new DeletedException("用户已被删除!");
|
}
|
user = new CoreUser();
|
user.setId(userId);
|
user.setDelFlag(DelFlagEnum.DELETED.getValue());
|
userDao.updateTemplateById(user);
|
}
|
|
/**
|
* 批量删除用户 <br/>
|
* 软删除 标记用户删除状态
|
*
|
* @param userIds
|
* 用户id
|
*/
|
public void batchDelSysUser(List<Long> userIds) {
|
try {
|
userDao.batchDelUserByIds(userIds);
|
} catch (Exception e) {
|
throw new PlatformException("批量删除用户失败", e);
|
}
|
}
|
|
/**
|
* 批量停用用户 <br/>
|
* 标记用户状态 停用
|
*
|
* @param userIds
|
* 用户id
|
*/
|
public void batchUpdateUserState(List<Long> userIds, GeneralStateEnum stateEnum) {
|
userDao.batchUpdateUserState(userIds, stateEnum);
|
}
|
|
/**
|
* 重置用户密码
|
*
|
* @param id
|
* @param password
|
*/
|
public int resetPassword(Long id, String password) {
|
CoreUser user = new CoreUser();
|
user.setId(id);
|
user.setPassword(passwordEncryptService.password(password));
|
user.setUpdateTime(new Date());
|
return userDao.updateTemplateById(user);
|
}
|
|
public List<CoreUserRole> getUserRoles(UserRoleQuery roleQuery) {
|
return userDao.queryUserRole(roleQuery.getUserId(), roleQuery.getOrgId(), roleQuery.getRoleId());
|
}
|
|
public void deleteUserRoles(List<Long> ids) {
|
// 考虑到这个操作较少使用，就不做批处理优化了
|
for (Long id : ids) {
|
sqlManager.deleteById(CoreUserRole.class, id);
|
}
|
|
}
|
|
public void saveUserRole(CoreUserRole userRole) {
|
|
long queryCount = sqlManager.templateCount(userRole);
|
|
if (queryCount > 0) {
|
throw new PlatformException("已存在用户角色关系");
|
}
|
sqlManager.insert(userRole);
|
}
|
|
public List<UserExcelExportData> queryExcel(CoreUserModel query) {
|
List<CoreUserModel> list = userDao.queryByCondtion(query);
|
//List<CoreUser> list = ret.getList();
|
OrgItem orgRoot = platformService.buildOrg();
|
List<UserExcelExportData> items = new ArrayList<>();
|
for(CoreUserModel user:list) {
|
UserExcelExportData userItem = new UserExcelExportData();
|
userItem.setCode(user.getCode());
|
userItem.setId(user.getId());
|
userItem.setName(user.getName());
|
CoreDict dict = dictService.findCoreDict(CoreDictType.USER_STATE,user.getState());
|
userItem.setStateText(dict.getName());
|
|
if(StringUtils.isNotEmpty(user.getJobType1())){
|
dict = dictService.findCoreDict("job_type",user.getJobType1());
|
userItem.setJobType1Text(dict.getName());
|
}
|
|
String orgName = orgRoot.findChild(user.getOrgId()).getName();
|
userItem.setOrgText(orgName);
|
items.add(userItem);
|
|
}
|
return items;
|
|
}
|
|
}
|
