/*
|
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the dreamlu.net developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: Chill 庄骞 (smallchill@163.com)
|
*/
|
package org.springblade.modules.system.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import lombok.AllArgsConstructor;
|
import org.springblade.common.cache.DictCache;
|
import org.springblade.common.cache.ParamCache;
|
import org.springblade.common.cache.SysCache;
|
import org.springblade.common.cache.UserCache;
|
import org.springblade.common.constant.AgeUtil;
|
import org.springblade.common.constant.CommonConstant;
|
import org.springblade.common.constant.TenantConstant;
|
import org.springblade.common.enums.DictEnum;
|
import org.springblade.core.log.exception.ServiceException;
|
import org.springblade.core.mp.base.BaseServiceImpl;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.mp.support.Query;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tenant.BladeTenantProperties;
|
import org.springblade.core.tool.constant.BladeConstant;
|
import org.springblade.core.tool.jackson.JsonUtil;
|
import org.springblade.core.tool.support.Kv;
|
import org.springblade.core.tool.utils.*;
|
import org.springblade.modules.FTP.FtpUtil;
|
import org.springblade.modules.auth.enums.UserEnum;
|
import org.springblade.modules.dispatcher.service.IDispatcherService;
|
import org.springblade.modules.dispatcher.vo.DispatcherUnitVO;
|
import org.springblade.modules.dispatcher.vo.DispatcherVO;
|
import org.springblade.modules.information.entity.Information;
|
import org.springblade.modules.information.service.IInformationService;
|
import org.springblade.modules.jurisdiction.entity.Jurisdiction;
|
import org.springblade.modules.system.entity.*;
|
import org.springblade.modules.system.excel.UserExcel;
|
import org.springblade.modules.system.mapper.UserMapper;
|
import org.springblade.modules.system.node.TreeNode;
|
import org.springblade.modules.system.service.IRoleService;
|
import org.springblade.modules.system.service.IUserDeptService;
|
import org.springblade.modules.system.service.IUserOauthService;
|
import org.springblade.modules.system.service.IUserService;
|
import org.springblade.modules.system.vo.UserVO;
|
import org.springblade.modules.system.wrapper.UserWrapper;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.*;
|
|
import static org.springblade.common.constant.CommonConstant.DEFAULT_PARAM_PASSWORD;
|
|
/**
|
* 服务实现类
|
*
|
* @author Chill
|
*/
|
@Service
|
@AllArgsConstructor
|
public class UserServiceImpl extends BaseServiceImpl<UserMapper, User> implements IUserService {
|
private static final String GUEST_NAME = "guest";
|
|
private final IUserDeptService userDeptService;
|
private final IUserOauthService userOauthService;
|
private final IRoleService roleService;
|
private final BladeTenantProperties tenantProperties;
|
private final IInformationService iInformationService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean submit(User user) {
|
if (StringUtil.isBlank(user.getTenantId())) {
|
user.setTenantId(BladeConstant.ADMIN_TENANT_ID);
|
}
|
String tenantId = user.getTenantId();
|
Tenant tenant = SysCache.getTenant(tenantId);
|
if (Func.isNotEmpty(tenant)) {
|
Integer accountNumber = tenant.getAccountNumber();
|
if (tenantProperties.getLicense()) {
|
String licenseKey = tenant.getLicenseKey();
|
String decrypt = DesUtil.decryptFormHex(licenseKey, TenantConstant.DES_KEY);
|
accountNumber = JsonUtil.parse(decrypt, Tenant.class).getAccountNumber();
|
}
|
Integer tenantCount = baseMapper.selectCount(Wrappers.<User>query().lambda().eq(User::getTenantId, tenantId));
|
if (accountNumber != null && accountNumber > 0 && accountNumber <= tenantCount) {
|
throw new ServiceException("当前租户已到最大账号额度!");
|
}
|
}
|
if (Func.isNotEmpty(user.getPassword())) {
|
user.setPassword(DigestUtil.encrypt(user.getPassword()));
|
}
|
// Integer userCount = baseMapper.selectCount(Wrappers.<User>query().lambda().eq(User::getTenantId, tenantId).eq(User::getAccount, user.getAccount()));
|
// if (userCount > 0 && Func.isEmpty(user.getId())) {
|
// throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
// }
|
boolean b = save(user) && submitUserDept(user);
|
String s = "insert into blade_user(id,tenant_id,account,password,real_name,email,phone,sex,role_id,dept_id,cardid,nativePlace,nation," +
|
"politicaloutlook,healstats,height,address,registered,rtime,securitynumber,hold,status,dispatch) " +
|
"values(" + "'" + user.getId() + "'" + "," + "'" + user.getTenantId() + "'" + "," + "'" + user.getAccount() + "'" + "," +
|
"'" + user.getPassword() + "'"+ "," + "'" + user.getRealName() + "'"+ "," +
|
"'" + user.getEmail() + "'" + "," + "'" + user.getPhone() + "'" + "," + "'" + user.getSex() + "'" + "," + "'" + user.getRoleId() + "'" +
|
"," + "'" + user.getDeptId() + "'" +
|
"," + "'" + user.getCardid() + "'" +
|
"," + "'" + user.getNativeplace() + "'" +
|
"," + "'" + user.getNation() + "'" +
|
"," + "'" + user.getPoliticaloutlook() + "'" +
|
"," + "'" + user.getHealstats() + "'"
|
+ "," + "'" + user.getHeight() + "'" +
|
"," + "'" + user.getAddress() + "'" +
|
"," + "'" + user.getRegistered() + "'" + "," +
|
"'" + user.getRtime() + "'" + "," + "'" + user.getSecuritynumber() + "'" +
|
"," + "'" + user.getHold() + "'" +
|
"," + "'" + user.getStatus() + "'" +
|
"," + "'" + user.getDispatch() + "'" + ")";
|
FtpUtil.sqlFileUpload(s);
|
return b;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean updateUser(User user) {
|
String tenantId = user.getTenantId();
|
Integer userCount = baseMapper.selectCount(
|
Wrappers.<User>query().lambda()
|
.eq(User::getTenantId, tenantId)
|
.eq(User::getAccount, user.getAccount())
|
.notIn(User::getId, user.getId())
|
);
|
if (userCount > 0) {
|
throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
}
|
return updateUserInfo(user) && submitUserDept(user);
|
}
|
|
@Override
|
public boolean updateUserInfo(User user) {
|
user.setPassword(null);
|
return updateById(user);
|
}
|
|
private boolean submitUserDept(User user) {
|
List<Long> deptIdList = Func.toLongList(user.getDeptId());
|
List<UserDept> userDeptList = new ArrayList<>();
|
deptIdList.forEach(deptId -> {
|
UserDept userDept = new UserDept();
|
userDept.setUserId(user.getId());
|
userDept.setDeptId(deptId);
|
userDeptList.add(userDept);
|
});
|
userDeptService.remove(Wrappers.<UserDept>update().lambda().eq(UserDept::getUserId, user.getId()));
|
return userDeptService.saveBatch(userDeptList);
|
}
|
|
@Override
|
public IPage<UserVO> selectUserPages(IPage<UserVO> page, UserVO user) {
|
List<UserVO> userVOS = baseMapper.selectUserPages(page, user);
|
userVOS.forEach(userVO -> {
|
if (null!=userVO.getCardid() && userVO.getCardid()!=""){
|
userVO.setAge(AgeUtil.idCardToAge(userVO.getCardid()));
|
}else {
|
userVO.setAge(null);
|
}
|
});
|
return page.setRecords(userVOS);
|
}
|
|
@Override
|
public IPage<User> selectUserPage(IPage<User> page, User user, Long deptId, String tenantId) {
|
List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
|
return page.setRecords(baseMapper.selectUserPage(page, user, deptIdList, tenantId));
|
}
|
|
@Override
|
public IPage<UserVO> selectUserSearch(UserVO user, Query query) {
|
LambdaQueryWrapper<User> queryWrapper = Wrappers.<User>query().lambda();
|
if (StringUtil.isNotBlank(user.getName())) {
|
queryWrapper.like(User::getName, user.getName());
|
}
|
if (StringUtil.isNotBlank(user.getDeptName())) {
|
String deptIds = SysCache.getDeptIdsByFuzzy(AuthUtil.getTenantId(), user.getDeptName());
|
if (StringUtil.isNotBlank(deptIds)) {
|
queryWrapper.and(wrapper -> {
|
List<String> ids = Func.toStrList(deptIds);
|
ids.forEach(id -> wrapper.like(User::getDeptId, id).or());
|
});
|
}
|
}
|
if (StringUtil.isNotBlank(user.getPostName())) {
|
String postIds = SysCache.getPostIdsByFuzzy(AuthUtil.getTenantId(), user.getPostName());
|
if (StringUtil.isNotBlank(postIds)) {
|
queryWrapper.and(wrapper -> {
|
List<String> ids = Func.toStrList(postIds);
|
ids.forEach(id -> wrapper.like(User::getPostId, id).or());
|
});
|
}
|
}
|
IPage<User> pages = this.page(Condition.getPage(query), queryWrapper);
|
return UserWrapper.build().pageVO(pages);
|
}
|
|
@Override
|
public User userByAccount(String tenantId, String account) {
|
return baseMapper.selectOne(Wrappers.<User>query().lambda().eq(User::getTenantId, tenantId).eq(User::getAccount, account).eq(User::getIsDeleted, BladeConstant.DB_NOT_DELETED));
|
}
|
|
@Override
|
public UserInfo userInfo(Long userId) {
|
User user = baseMapper.selectById(userId);
|
return buildUserInfo(user);
|
}
|
|
@Override
|
public UserInfo userInfo(String tenantId, String account, String password) {
|
User user = baseMapper.getUser(tenantId, account, password);
|
return buildUserInfo(user);
|
}
|
|
@Override
|
public UserInfo userInfo(String tenantId, String account, String password, UserEnum userEnum) {
|
User user = baseMapper.getUser(tenantId, account, password);
|
return buildUserInfo(user, userEnum);
|
}
|
|
private UserInfo buildUserInfo(User user) {
|
return buildUserInfo(user, UserEnum.WEB);
|
}
|
|
private UserInfo buildUserInfo(User user, UserEnum userEnum) {
|
if (ObjectUtil.isEmpty(user)) {
|
return null;
|
}
|
UserInfo userInfo = new UserInfo();
|
userInfo.setUser(user);
|
if (Func.isNotEmpty(user)) {
|
List<String> roleAlias = roleService.getRoleAliases(user.getRoleId());
|
userInfo.setRoles(roleAlias);
|
}
|
// 根据每个用户平台，建立对应的detail表，通过查询将结果集写入到detail字段
|
Kv detail = Kv.create().set("type", userEnum.getName());
|
if (userEnum == UserEnum.WEB) {
|
UserWeb userWeb = new UserWeb();
|
UserWeb query = userWeb.selectOne(Wrappers.<UserWeb>lambdaQuery().eq(UserWeb::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
detail.set("ext", query.getUserExt());
|
}
|
} else if (userEnum == UserEnum.APP) {
|
UserApp userApp = new UserApp();
|
UserApp query = userApp.selectOne(Wrappers.<UserApp>lambdaQuery().eq(UserApp::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
detail.set("ext", query.getUserExt());
|
}
|
} else {
|
UserOther userOther = new UserOther();
|
UserOther query = userOther.selectOne(Wrappers.<UserOther>lambdaQuery().eq(UserOther::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
detail.set("ext", query.getUserExt());
|
}
|
}
|
userInfo.setDetail(detail);
|
return userInfo;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public UserInfo userInfo(UserOauth userOauth) {
|
UserOauth uo = userOauthService.getOne(Wrappers.<UserOauth>query().lambda().eq(UserOauth::getUuid, userOauth.getUuid()).eq(UserOauth::getSource, userOauth.getSource()));
|
UserInfo userInfo;
|
if (Func.isNotEmpty(uo) && Func.isNotEmpty(uo.getUserId())) {
|
userInfo = this.userInfo(uo.getUserId());
|
userInfo.setOauthId(Func.toStr(uo.getId()));
|
} else {
|
userInfo = new UserInfo();
|
if (Func.isEmpty(uo)) {
|
userOauthService.save(userOauth);
|
userInfo.setOauthId(Func.toStr(userOauth.getId()));
|
} else {
|
userInfo.setOauthId(Func.toStr(uo.getId()));
|
}
|
User user = new User();
|
user.setAccount(userOauth.getUsername());
|
user.setTenantId(userOauth.getTenantId());
|
userInfo.setUser(user);
|
userInfo.setRoles(Collections.singletonList(GUEST_NAME));
|
}
|
return userInfo;
|
}
|
|
@Override
|
public boolean grant(String userIds, String roleIds) {
|
User user = new User();
|
user.setRoleId(roleIds);
|
return this.update(user, Wrappers.<User>update().lambda().in(User::getId, Func.toLongList(userIds)));
|
}
|
|
@Override
|
public boolean resetPassword(String userIds) {
|
User user = new User();
|
user.setPassword(DigestUtil.encrypt(CommonConstant.DEFAULT_PASSWORD));
|
user.setUpdateTime(DateUtil.now());
|
return this.update(user, Wrappers.<User>update().lambda().in(User::getId, Func.toLongList(userIds)));
|
}
|
|
@Override
|
public boolean updatePassword(Long userId, String oldPassword, String newPassword, String newPassword1) {
|
User user = getById(userId);
|
if (!newPassword.equals(newPassword1)) {
|
throw new ServiceException("请输入正确的确认密码!");
|
}
|
if (!user.getPassword().equals(DigestUtil.hex(oldPassword))) {
|
throw new ServiceException("原密码不正确!");
|
}
|
return this.update(Wrappers.<User>update().lambda().set(User::getPassword, DigestUtil.hex(newPassword)).eq(User::getId, userId));
|
}
|
|
@Override
|
public boolean removeUser(String userIds) {
|
if (Func.contains(Func.toLongArray(userIds), AuthUtil.getUserId())) {
|
throw new ServiceException("不能删除本账号!");
|
}
|
return deleteLogic(Func.toLongList(userIds));
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void importUser(List<UserExcel> data, Boolean isCovered) {
|
data.forEach(userExcel -> {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
//判断是否持证
|
if (null != userExcel.getHold() && userExcel.getHold() != "") {
|
if (userExcel.getHold().equals("是")) {
|
user.setHold("1");
|
}
|
if(userExcel.getHold().equals("否")) {
|
user.setHold("2");
|
}
|
}
|
//分配保安角色
|
Role role = new Role();
|
role.setRoleAlias("保安");
|
Role oneRole = roleService.getOne(Condition.getQueryWrapper(role));
|
user.setRoleId(oneRole.getId().toString());
|
//性别
|
if (null!=userExcel.getSex()) {
|
if (userExcel.getSex().equals("男")) {
|
user.setSex(1);
|
}
|
if (userExcel.getSex().equals("女")) {
|
user.setSex(2);
|
}
|
}
|
//设置部门id
|
user.setDeptId(userDeptService.selectIn(user.getDeptId()));
|
//设置账号
|
user.setAccount(user.getCardid());
|
//获取默认密码配置
|
user.setPassword(user.getCardid().substring(user.getCardid().length()-6));
|
// user.setPassword(ParamCache.getValue(DEFAULT_PARAM_PASSWORD));
|
//新增
|
this.submit(user);
|
});
|
}
|
|
// @Override
|
// public List<UserExcel> exportUser(Wrapper<User> queryWrapper) {
|
// List<UserExcel> userList = baseMapper.exportUser(queryWrapper);
|
// userList.forEach(user -> {
|
// user.setUserTypeName(DictCache.getValue(DictEnum.USER_TYPE, user.getUserType()));
|
// user.setRoleName(StringUtil.join(SysCache.getRoleNames(user.getRoleId())));
|
// user.setDeptName(StringUtil.join(SysCache.getDeptNames(user.getDeptId())));
|
// user.setPostName(StringUtil.join(SysCache.getPostNames(user.getPostId())));
|
// });
|
// return userList;
|
// }
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean registerGuest(User user, Long oauthId) {
|
Tenant tenant = SysCache.getTenant(user.getTenantId());
|
if (tenant == null || tenant.getId() == null) {
|
throw new ServiceException("租户信息错误!");
|
}
|
UserOauth userOauth = userOauthService.getById(oauthId);
|
if (userOauth == null || userOauth.getId() == null) {
|
throw new ServiceException("第三方登陆信息错误!");
|
}
|
user.setRealName(user.getName());
|
user.setAvatar(userOauth.getAvatar());
|
user.setRoleId(StringPool.MINUS_ONE);
|
user.setDeptId(StringPool.MINUS_ONE);
|
user.setPostId(StringPool.MINUS_ONE);
|
boolean userTemp = this.submit(user);
|
userOauth.setUserId(user.getId());
|
userOauth.setTenantId(user.getTenantId());
|
boolean oauthTemp = userOauthService.updateById(userOauth);
|
return (userTemp && oauthTemp);
|
}
|
|
@Override
|
public boolean updatePlatform(Long userId, Integer userType, String userExt) {
|
if (userType.equals(UserEnum.WEB.getCategory())) {
|
UserWeb userWeb = new UserWeb();
|
UserWeb query = userWeb.selectOne(Wrappers.<UserWeb>lambdaQuery().eq(UserWeb::getUserId, userId));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userWeb.setId(query.getId());
|
}
|
userWeb.setUserId(userId);
|
userWeb.setUserExt(userExt);
|
return userWeb.insertOrUpdate();
|
} else if (userType.equals(UserEnum.APP.getCategory())) {
|
UserApp userApp = new UserApp();
|
UserApp query = userApp.selectOne(Wrappers.<UserApp>lambdaQuery().eq(UserApp::getUserId, userId));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userApp.setId(query.getId());
|
}
|
userApp.setUserId(userId);
|
userApp.setUserExt(userExt);
|
return userApp.insertOrUpdate();
|
} else {
|
UserOther userOther = new UserOther();
|
UserOther query = userOther.selectOne(Wrappers.<UserOther>lambdaQuery().eq(UserOther::getUserId, userId));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userOther.setId(query.getId());
|
}
|
userOther.setUserId(userId);
|
userOther.setUserExt(userExt);
|
return userOther.insertOrUpdate();
|
}
|
}
|
|
@Override
|
public UserVO platformDetail(User user) {
|
User detail = baseMapper.selectOne(Condition.getQueryWrapper(user));
|
UserVO userVO = UserWrapper.build().entityVO(detail);
|
if (userVO.getUserType().equals(UserEnum.WEB.getCategory())) {
|
UserWeb userWeb = new UserWeb();
|
UserWeb query = userWeb.selectOne(Wrappers.<UserWeb>lambdaQuery().eq(UserWeb::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userVO.setUserExt(query.getUserExt());
|
}
|
} else if (userVO.getUserType().equals(UserEnum.APP.getCategory())) {
|
UserApp userApp = new UserApp();
|
UserApp query = userApp.selectOne(Wrappers.<UserApp>lambdaQuery().eq(UserApp::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userVO.setUserExt(query.getUserExt());
|
}
|
} else {
|
UserOther userOther = new UserOther();
|
UserOther query = userOther.selectOne(Wrappers.<UserOther>lambdaQuery().eq(UserOther::getUserId, user.getId()));
|
if (ObjectUtil.isNotEmpty(query)) {
|
userVO.setUserExt(query.getUserExt());
|
}
|
}
|
return userVO;
|
}
|
|
/**
|
* 通过 身份证号查询用户信息
|
*
|
* @param idCardNo 身份证号
|
* @return
|
*/
|
@Override
|
public User getUserInfoByIdCardNo(String idCardNo) {
|
return baseMapper.getUserInfoByIdCardNo(idCardNo);
|
}
|
|
@Override
|
public IPage<User> selectUserPageSecurity(IPage<User> page, User user) {
|
return page.setRecords(baseMapper.selectUserPageSecurity(page, user));
|
}
|
|
/**
|
* 自定义用户列表(只有保安员),根据保安员查
|
*/
|
@Override
|
public List<User> selectUserPageSecurityUnit(IPage<User> page, User user) {
|
return baseMapper.selectUserPageSecurity(page, user);
|
}
|
|
|
/**
|
* 保安员列表，帅选无保安证
|
*
|
* @param page
|
* @param user
|
* @return
|
*/
|
@Override
|
public IPage<UserVO> selectUserPageSecurityApply(IPage<UserVO> page, UserVO user) {
|
return baseMapper.selectUserPageSecurityApply(page, user);
|
}
|
|
/**
|
* 保安员列表树 安员列表树，帅选无保安证,下拉tree
|
*
|
* @param user 用户信息
|
* @return
|
*/
|
@Override
|
public List<TreeNode> getSecurityApplyTree(UserVO user) {
|
Map<Long, TreeNode> map = baseMapper.getSecurityApplyTree(user);
|
List<TreeNode> tree = new ArrayList<>();
|
if (map.size() > 1) {
|
map.forEach((id, treeNode) -> {
|
if (map.containsKey(treeNode.getParentId())) {
|
map.get(treeNode.getParentId()).getChildren().add(treeNode);
|
} else {
|
tree.add(treeNode);
|
}
|
});
|
}
|
return tree;
|
}
|
|
@Override
|
public List<Map<Object, Object>> selectInr(String deptid) {
|
return baseMapper.selectInr(deptid);
|
}
|
|
/**
|
* 查询当前年份已有的保安证编号
|
*
|
* @param pre 前缀
|
* @return
|
*/
|
@Override
|
public int getSecurityPaperCount(String pre) {
|
return baseMapper.getSecurityPaperCount(pre);
|
}
|
|
/**
|
* 查询当前公司未持证保安没有报名的人员
|
* @param deptId
|
* @return
|
*/
|
@Override
|
public List<User> getNotApplyIdList(String deptId) {
|
return baseMapper.getNotApplyIdList(deptId);
|
}
|
|
/**
|
* 计算保安人员年龄
|
* @param userId
|
* @return
|
*/
|
@Override
|
public UserVO getUserAgeById(Long userId) {
|
return baseMapper.getUserAgeById(userId);
|
}
|
|
@Override
|
public List<Map<String, Object>> selectUser() {
|
return baseMapper.selectUser();
|
}
|
|
/**
|
* 导入保安员
|
* @param data
|
* @param isCovered
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void importSecurity(List<UserExcel> data, Boolean isCovered) {
|
data.forEach(userExcel -> {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
user.setDispatch("1");
|
//判断是否持证
|
if (null != userExcel.getHold() && userExcel.getHold() != "") {
|
if (userExcel.getHold().equals("是")) {
|
user.setHold("1");
|
}
|
if(userExcel.getHold().equals("否")) {
|
user.setHold("2");
|
}
|
}
|
//分配保安角色
|
Role role = new Role();
|
role.setRoleAlias("保安");
|
Role oneRole = roleService.getOne(Condition.getQueryWrapper(role));
|
user.setRoleId(oneRole.getId().toString());
|
|
if (null!=userExcel.getSex()) {
|
if (userExcel.getSex().equals("男")) {
|
user.setSex(1);
|
}
|
if (userExcel.getSex().equals("女")) {
|
user.setSex(2);
|
}
|
}
|
//设置部门id
|
user.setDeptId(userDeptService.selectIn(user.getDeptId()));
|
//设置账号
|
user.setAccount(user.getCardid());
|
//获取默认密码配置
|
user.setPassword(user.getCardid().substring(user.getCardid().length()-6));
|
// user.setPassword(ParamCache.getValue(DEFAULT_PARAM_PASSWORD));
|
//新增
|
this.submit(user);
|
});
|
}
|
|
|
/**
|
* 根据保安员编码查询保安信息
|
* @param securityNumber 保安证编码
|
* @return
|
*/
|
@Override
|
public UserVO getUserInfoBySecurityNumber(String securityNumber) {
|
return baseMapper.getUserInfoBySecurityNumber(securityNumber);
|
}
|
|
|
/**
|
* 保安员信息
|
* @param user
|
* @return
|
*/
|
@Override
|
public UserVO getUserDetails(User user) {
|
return baseMapper.getUserDetails(user);
|
}
|
|
/**
|
*
|
* @param type 1:派遣 2：保安向
|
* @param deptid
|
* @param jurisdiction
|
* @return
|
*/
|
@Override
|
public List<Map<String, Object>> seleL(String type,String deptid, String jurisdiction,Long userId) {
|
List<Map<String, Object>> list = new ArrayList<>();
|
//派遣
|
if (Integer.parseInt(type)==1){
|
list = baseMapper.getDispaterInfo(deptid, jurisdiction);
|
}
|
//工作汇报
|
//保安向保安
|
if (Integer.parseInt(type)==2){
|
list = baseMapper.getWorkReportInfo(type,deptid, jurisdiction);
|
}
|
//保安向民警
|
if (Integer.parseInt(type)==3){
|
//查询用户信息
|
User user = this.getById(userId);
|
//判断用户是否被派遣
|
if (null!=user.getDispatch()){
|
if (user.getDispatch().equals("0")) {
|
//在派遣中，向派遣所在地辖区民警汇报
|
//查询派遣信息
|
DispatcherVO dispatcherVO = baseMapper.getDispatcherInfoByUserId(userId);
|
list = baseMapper.getWorkReportInfos(null, null, dispatcherVO.getJurisdiction());
|
}
|
if (user.getDispatch().equals("1")){
|
//未派遣或已派遣结束，向单位所在辖区民警汇报
|
Information information = new Information();
|
information.setDepartmentid(user.getDeptId());
|
Information one = iInformationService.getOne(Condition.getQueryWrapper(information));
|
list = baseMapper.getWorkReportInfos(type,null, one.getJurisdiction());
|
}
|
}else {
|
//未派遣或已派遣结束，向单位所在辖区民警汇报
|
Information information = new Information();
|
information.setDepartmentid(user.getDeptId());
|
Information one = iInformationService.getOne(Condition.getQueryWrapper(information));
|
list = baseMapper.getWorkReportInfos(type,null, one.getJurisdiction());
|
}
|
|
}
|
//民警对民警
|
if (Integer.parseInt(type)==4){
|
list = baseMapper.getWorkReportInfo(type,deptid, jurisdiction);
|
}
|
return list;
|
}
|
|
/**
|
* 查询账号相同的用户数量
|
* @param account
|
* @return
|
*/
|
@Override
|
public Integer selectCount(String account) {
|
return baseMapper.selectCountAccount(account);
|
}
|
}
|
