/*
|
* 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.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.google.zxing.WriterException;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springblade.common.cache.SysCache;
|
import org.springblade.common.constant.AgeUtil;
|
import org.springblade.common.constant.CommonConstant;
|
import org.springblade.common.constant.TenantConstant;
|
import org.springblade.common.utils.DesensitizedUtil;
|
import org.springblade.common.utils.IdCardNoUtil;
|
import org.springblade.common.utils.ImageUtils;
|
import org.springblade.common.utils.QRCodeUtil;
|
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.api.R;
|
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.FTP.Monitor;
|
import org.springblade.modules.FTP.Result;
|
import org.springblade.modules.auth.enums.UserEnum;
|
import org.springblade.modules.dispatcher.entity.Dispatcher;
|
import org.springblade.modules.dispatcher.vo.DispatcherVO;
|
import org.springblade.modules.exam.util.SecurityPaperUtil;
|
import org.springblade.modules.experience.entity.Experience;
|
import org.springblade.modules.experience.service.IExperienceService;
|
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.jurisdiction.service.JurisdictionService;
|
import org.springblade.modules.securitypaper.entity.SecurityPaper;
|
import org.springblade.modules.securitypaper.service.SecurityPaperService;
|
import org.springblade.modules.system.entity.*;
|
import org.springblade.modules.system.excel.QrCodeExcel;
|
import org.springblade.modules.system.excel.SecurityExcel;
|
import org.springblade.modules.system.excel.SecurityYyExcel;
|
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.*;
|
import org.springblade.modules.system.vo.UserVO;
|
import org.springblade.modules.system.wrapper.UserWrapper;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.io.FileNotFoundException;
|
import java.io.FileOutputStream;
|
import java.io.IOException;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.stream.Collectors;
|
|
/**
|
* 服务实现类
|
*
|
* @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;
|
private final IDeptService deptService;
|
private final JurisdictionService jurisdictionService;
|
private final IExperienceService experienceService;
|
private final MyAsyncService myAsyncService;
|
private final SecurityPaperService securityPaperService;
|
private final RedisTemplate redisTemplate;
|
|
@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()));
|
Integer userCount = baseMapper.selectCountAccount(user.getAccount());
|
if (userCount > 0 && Func.isEmpty(user.getId())) {
|
throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
}
|
boolean b = save(user) && submitUserDept(user);
|
user.setIsDeleted(0);
|
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,securitynumber,hold,status,dispatch,jurisdiction,is_deleted) " +
|
"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.getSecuritynumber() + "'" +
|
"," + "'" + user.getHold() + "'" +
|
"," + "'" + user.getStatus() + "'" +
|
"," + "'" + user.getDispatch() + "'"+
|
"," + "'" + user.getJurisdiction() + "'"+
|
"," + "'" + user.getIsDeleted() + "'"
|
+ ")";
|
//FtpUtil.sqlFileUpload(s);
|
myAsyncService.FTP(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) {
|
if (null!=user.getAgeType() && user.getAgeType()!=4){
|
List<UserVO> userVOS = baseMapper.selectUserPagesByAge(page, user);
|
//机构名称拼接
|
userVOS.forEach(userVO -> {
|
// if (null != userVO.getCardid() && userVO.getCardid() != "") {
|
// userVO.setAge(AgeUtil.idCardToAge(userVO.getCardid()));
|
// } else {
|
// userVO.setAge(null);
|
// }
|
if (null!=userVO.getDeptId()) {
|
List<String> list = baseMapper.getDeptName(userVO.getDeptId());
|
if (list.size() > 1) {
|
if (null != list.get(1) && list.get(1) != "") {
|
String s = list.get(1).toString();
|
if (s.equals("本市保安公司") || s.equals("保安培训学校") || s.equals("自招保安单位") || s.equals("武装押运公司") || s.equals("分公司") || s.equals("其他")){
|
userVO.setDeptName(list.get(0));
|
}
|
else {
|
userVO.setDeptName(list.get(1) + "," + list.get(0));
|
}
|
} else {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
if (list.size() == 1) {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
});
|
return page.setRecords(userVOS);
|
}else {
|
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);
|
// }
|
if (null!=userVO.getDeptId()) {
|
List<String> list = baseMapper.getDeptName(userVO.getDeptId());
|
if (list.size() > 1) {
|
if (null != list.get(1) && list.get(1) != "") {
|
String s = list.get(1).toString();
|
if (s.equals("本市保安公司") || s.equals("保安培训学校") || s.equals("自招保安单位") || s.equals("武装押运公司") || s.equals("分公司") || s.equals("其他")){
|
userVO.setDeptName(list.get(0));
|
}
|
else {
|
userVO.setDeptName(list.get(1) + "," + list.get(0));
|
}
|
} else {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
if (list.size() == 1) {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
});
|
return page.setRecords(userVOS);
|
}
|
}
|
|
@Override
|
public IPage<UserVO> selectUserPage(IPage<UserVO> page, User user, Long deptId, String tenantId) {
|
List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
|
List<UserVO> users = baseMapper.selectUserPage(page, user, deptIdList, tenantId);
|
if(users.size()>0){
|
//遍历获取部门名称，角色名称
|
users.forEach(userVO -> {
|
//查询当前部门名称及父级部门名称
|
if (null!=userVO.getDeptId()) {
|
List<String> list = baseMapper.getDeptName(userVO.getDeptId());
|
if (list.size() > 1) {
|
if (null != list.get(1) && list.get(1) != "") {
|
userVO.setDeptName(list.get(1) + "," + list.get(0));
|
} else {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
if (list.size() == 1) {
|
userVO.setDeptName(list.get(0));
|
}
|
}
|
//查询角色名称
|
if (null!=userVO.getRoleId()) {
|
List<String> asList = Arrays.asList(userVO.getRoleId().split(","));
|
StringBuilder builder = new StringBuilder();
|
asList.forEach(roleIs -> {
|
Role role = roleService.getById(roleIs);
|
if (null != role) {
|
builder.append(role.getRoleName() + ",");
|
}
|
});
|
String substringRoleName = null;
|
if (builder.toString().length() > 0) {
|
substringRoleName = builder.toString().substring(0, builder.toString().length() - 1);
|
}
|
userVO.setRoleName(substringRoleName);
|
}
|
});
|
}
|
return page.setRecords(users);
|
}
|
|
@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));
|
}
|
|
/**
|
* 用户民警的导入
|
* @param data
|
* @param isCovered
|
* @param deptId
|
*/
|
@Override
|
// @Transactional(rollbackFor = Exception.class) 去除事务回滚
|
public void importUser(List<UserExcel> data, Boolean isCovered,String deptId) {
|
//将不能导入的账号存起来
|
List<String> errorList = new ArrayList<>();
|
//导入状态，默认为true ,如果有一个出现问题则为 false
|
AtomicBoolean status = new AtomicBoolean(true);
|
data.forEach(userExcel -> {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
//设置部门id
|
String deptIds = userDeptService.selectIn(user.getDeptId());
|
// if (null!=deptIds && !deptIds.equals("")) {
|
// if (null != deptId && !deptId.equals("")) {
|
// if (!deptId.equals(deptIds)) {
|
// throw new ServiceException("导入失败!不能导入不是当前辖区(机构)的数据!");
|
// }
|
// }
|
// user.setDeptId(deptIds);
|
// }else {
|
// //如果deptIds 为空，则说明还没有改公司
|
// throw new ServiceException("导入失败!机构名:["+user.getDeptId()+"]不存在!");
|
// }
|
user.setDeptId(deptIds);
|
//判断当前用户是否已在本单位，如果是的更新数据
|
User user1 = new User();
|
user1.setAccount(user.getDeptId());
|
// user1.setAccount(user.getCode());
|
user1.setIsDeleted(0);
|
user1.setStatus(1);
|
User user2 = this.getOne(Condition.getQueryWrapper(user1));
|
if (null==user2){
|
//用户不存在，去新增
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
user.setCreateTime(new Date());
|
user.setUpdateTime(new Date());
|
//设置账号
|
user.setAccount(userExcel.getDeptId());
|
//user.setAccount(user.getCode());
|
//分配角色
|
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);
|
}
|
}
|
|
//获取辖区的数据
|
Jurisdiction jurisdiction = new Jurisdiction();
|
jurisdiction.setDeptName(userExcel.getDeptId());
|
Jurisdiction one = jurisdictionService.getOne(Condition.getQueryWrapper(jurisdiction));
|
user.setJurisdiction(one.getId().toString());
|
|
|
//获取默认密码配置
|
user.setPassword("123456");
|
// user.setPassword(user.getCode());
|
//加密
|
if (Func.isNotEmpty(user.getPassword())) {
|
user.setPassword(DigestUtil.encrypt(user.getPassword()));
|
}
|
Integer userCount = baseMapper.selectCountAccount(user.getAccount());
|
if (userCount > 0 && Func.isEmpty(user.getId())) {
|
throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
}
|
//新增
|
this.save(user);
|
//内网同步
|
String s = "insert into blade_user(" +
|
"id,tenant_id,code,account,password,real_name,phone,sex,role_id,dept_id," +
|
"create_time,update_time,cardid,status,is_deleted,jurisdiction) " +
|
"values(" + "'" + user.getId() + "'" + "," +
|
"'" + user.getTenantId() + "'" + "," +
|
"'" + user.getCode() + "'" + "," +
|
"'" + user.getAccount() + "'" + "," +
|
"'" + user.getPassword() + "'" + "," +
|
"'" + user.getRealName() + "'" + "," +
|
"'" + user.getPhone() + "'" + "," +
|
"'" + user.getSex() + "'" + "," +
|
"'" + user.getRoleId() + "'" +
|
"," + "'" + user.getDeptId() + "'" +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getCreateTime()) + "'" +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
|
"," + "'" + user.getCardid() + "'" +
|
"," + "'" + user.getStatus() + "'" +
|
"," + "'" + user.getIsDeleted() + "'" +
|
"," + "'" + user.getJurisdiction() + "'"
|
+ ")";
|
//FtpUtil.sqlFileUpload(s);
|
myAsyncService.FTP(s);
|
}else {
|
//匹配组织机构是否一致,如果不一致
|
if(!user2.getDeptId().equals(user.getDeptId())){
|
Dept dept = deptService.getById(user2.getDeptId());
|
status.set(false);
|
//加入集合
|
errorList.add(user.getCardid());
|
//forEach 只能使用 return 跳出本次循环
|
return;
|
}else {
|
//如果是一致，则更新用户数据
|
//更新用户数据
|
user2.setUpdateTime(new Date());
|
if (null!=user.getPhone() && !user.getPhone().equals("")){
|
user2.setPhone(user.getPhone());
|
}
|
if (null!=user.getRealName() && !user.getRealName().equals("")){
|
user2.setRealName(user.getRealName());
|
}
|
if (null!=user.getCardid() && !user.getCardid().equals("")){
|
user2.setCardid(user.getCardid());
|
}
|
if (null!=user.getCode() && !user.getCode().equals("")){
|
user2.setCode(user.getCode());
|
user2.setAccount(user.getCode());
|
}
|
user2.setAccount(userExcel.getDeptId());
|
this.updateById(user2);
|
String s1 =
|
"update blade_user set account = " + "'" + user2.getAccount() + "'"
|
+ ",code = " + "'" + user2.getCode() + "'"
|
+ ",real_name = " + "'" + user2.getRealName() + "'"
|
+ ",phone = " + "'" + user2.getPhone() + "'"
|
+ ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
+ ",cardid = " + "'" + user2.getCardid() + "'"
|
+ " " + "where id = " + "'" + user2.getId() + "'";
|
//FtpUtil.sqlFileUpload(s1);
|
myAsyncService.FTP(s1);
|
}
|
}
|
});
|
//如果所有数据导入有一个异常
|
if (!status.get()){
|
String errorAccount = StringUtils.join(errorList, "\\\n");
|
throw new ServiceException("用户:["+errorAccount+"]导入失败!已在其他单位存在!");
|
}
|
}
|
|
// @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(null, 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;
|
}
|
|
/**
|
* 派遣保安员列表树 安员列表树，帅选无保安证,下拉tree
|
*
|
* @param user 用户信息
|
* @return
|
*/
|
@Override
|
public List<TreeNode> getSecurityDispatcherTree(UserVO user) {
|
Map<Long, TreeNode> map = baseMapper.getSecurityDispatcherTree(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);
|
}
|
});
|
//将原有的保安员加入到集合
|
if (null!=user.getId()){
|
TreeNode treeNode = new TreeNode();
|
treeNode.setId(user.getId());
|
treeNode.setHasChildren(false);
|
treeNode.setName(user.getRealName());
|
treeNode.setParentId(Long.parseLong(user.getDeptId()));
|
tree.get(0).getChildren().add(treeNode);
|
}
|
//获取子节点
|
List<TreeNode> children = tree.get(0).getChildren();
|
//排序
|
List<TreeNode> nodes = children.stream().sorted(Comparator.comparing(TreeNode::getId)).collect(Collectors.toList());
|
//设置排序后的集合
|
tree.get(0).setChildren(nodes);
|
}
|
//返回
|
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
|
// public void importSecurity(List<SecurityExcel> data, Boolean isCovered, String deptId) {
|
// long time = System.currentTimeMillis();
|
// //将不能导入的保安员账号存起来
|
// List<String> errorList = new ArrayList<>();
|
// //年龄不符的保安员信息存入集合
|
// List<String> ageErrorList = new ArrayList<>();
|
// //保安员证编号不符的保安员信息存入集合
|
// List<String> securityInvalidList = new ArrayList<>();
|
// //将需要更新的保安员信息存入集合
|
// List<User> updateList = new ArrayList<>();
|
// //需要新增的保安员集合
|
// List<User> userList = new ArrayList<>();
|
// //需要新增的从业记录集合
|
// List<Experience> experienceList = new ArrayList<>();
|
// //导入状态，默认为true ,如果有一个出现问题则为 false
|
// AtomicBoolean status = new AtomicBoolean(true);
|
// AtomicBoolean agetStatus = new AtomicBoolean(true);
|
// AtomicBoolean securityInvalidStatus = new AtomicBoolean(true);
|
// //遍历
|
// for (SecurityExcel userExcel : data) {
|
// User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
// //设置部门id
|
// String deptIds = userDeptService.selectIn(user.getDeptId());
|
// if (null!=deptIds && !deptIds.equals("")) {
|
// if (null != deptId && !deptId.equals("")) {
|
// if (!deptId.equals(deptIds)) {
|
// throw new ServiceException("导入失败!不能导入不是本公司的保安员数据!");
|
// }
|
// }
|
// user.setDeptId(deptIds);
|
// }else {
|
// //如果deptIds 为空，则说明还没有改公司
|
// throw new ServiceException("导入失败!公司名:["+user.getDeptId()+"]不存在!");
|
// }
|
//
|
// //身份证校验
|
// if (null==user.getCardid() || user.getCardid().equals("")){
|
// throw new ServiceException("导入失败!身份证号码不能为空!");
|
// }
|
// //身份证住址校验
|
// if (null==user.getRegistered() || user.getRegistered().equals("")){
|
// throw new ServiceException("导入失败!身份证住址不能为空!");
|
// }
|
// if (null!=user.getCardid() && !user.getCardid().equals("")){
|
// //去除所有空格
|
// String cardid = user.getCardid().replaceAll(" ", "");
|
// //校验
|
// boolean b = IdCardNoUtil.checkIdCardNo(cardid);
|
// if(b){
|
// user.setCardid(cardid);
|
// }else {
|
// agetStatus.set(false);
|
// ageErrorList.add(user.getCardid());
|
//// throw new ServiceException("导入失败!身份证号码[ "+user.getCardid()+" ]不正确,请核对!");
|
// //forEach 只能使用 return 跳出本次循环
|
//// return;
|
// continue;
|
// }
|
// }
|
//
|
// //判断当前用户是否已在本单位，如果是的更新数据
|
// User user1 = new User();
|
// user1.setAccount(user.getCardid());
|
// user1.setIsDeleted(0);
|
// user1.setStatus(1);
|
// User user2 = this.getOne(Condition.getQueryWrapper(user1));
|
// if (null==user2){
|
// //用户不存在，去新增
|
// // 设置租户ID
|
// user.setTenantId("000000");
|
// //默认在职
|
// user.setStatus(1);
|
// user.setIsDeleted(0);
|
// //判断是否持证
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user.setHold("1");
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user.setHold("2");
|
// user.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user.setHold("2");
|
// user.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user.setHold("2");
|
// }
|
// //判断年龄，超过60岁的不入
|
//// if (AgeUtil.idCardToAge(user.getCardid())<60) {
|
// //分配保安角色
|
// 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);
|
// }
|
// }
|
//
|
// //设置账号
|
// user.setAccount(user.getCardid());
|
// //获取默认密码配置
|
// user.setPassword(user.getCardid().substring(user.getCardid().length() - 6));
|
// //加密
|
// if (Func.isNotEmpty(user.getPassword())) {
|
// user.setPassword(DigestUtil.encrypt(user.getPassword()));
|
// }
|
// Integer userCount = baseMapper.selectCountAccount(user.getAccount());
|
// if (userCount > 0 && Func.isEmpty(user.getId())) {
|
// throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
// }
|
// user.setCreateTime(new Date());
|
// user.setDispatch("1");
|
// user.setExaminationType("0");
|
// //新增
|
//// this.save(user);
|
// //加入集合
|
// userList.add(user);
|
// //从业记录新增
|
// Experience experience = new Experience();
|
// experience.setCardid(user.getCardid());
|
//// experience.setSecurityid(user.getId().toString());
|
// experience.setCompanyname(userExcel.getDeptId());
|
// experience.setName(user.getRealName());
|
// experience.setPost("保安员");
|
// experience.setEntrytime(new Date());
|
//// experienceService.save(experience);
|
// //加入集合
|
// experienceList.add(experience);
|
//
|
// }else {
|
// //匹配组织机构是否一致,如果不一致
|
// if(!user2.getDeptId().equals(user.getDeptId())){
|
// Dept dept = deptService.getById(user2.getDeptId());
|
// Dept dept1 = deptService.getById(user.getDeptId());
|
// //如果是南昌总公司分公司导入的
|
// if (dept.getId().equals(1432626178757275649L) && dept1.getParentId().equals(1432626178757275649L)){
|
// user2.setDeptId(dept1.getId().toString());
|
// //判断是否持证
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user2.setHold("1");
|
// user2.setSecuritynumber(user.getSecuritynumber());
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// }
|
// //更新用户数据
|
// user2.setUpdateTime(new Date());
|
// this.updateById(user2);
|
// //qfqk异步推送
|
// myAsyncService.updateUserByQfqk(user2);
|
// String s1 =
|
// "update blade_user set hold = " + "'" + user2.getHold() + "'"
|
// + ",securitynumber = " + "'" + user2.getSecuritynumber() + "'"
|
// + ",dept_id = " + "'" + user2.getDeptId() + "'"
|
// + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
// + ",registered = " + "'" + user2.getRegistered() + "'"
|
// + " " + "where id = " + "'" + user2.getId() + "'";
|
// //FtpUtil.sqlFileUpload(s1);
|
// myAsyncService.FTP(s1);
|
// }else {
|
// status.set(false);
|
// //加入集合
|
// errorList.add(user.getCardid());
|
// //forEach 只能使用 return 跳出本次循环
|
//// return;
|
// continue;
|
// }
|
// }else {
|
// //如果是一致，则更新用户数据
|
// //判断是否持证
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user2.setHold("1");
|
// user2.setSecuritynumber(user.getSecuritynumber());
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// }
|
// if (null!=userExcel.getRegistered()){
|
// user2.setRegistered(userExcel.getRegistered());
|
// }else {
|
// user2.setRegistered("");
|
// }
|
// user2.setUpdateTime(new Date());
|
// //更新用户数据
|
// this.updateById(user2);
|
// //qfqk异步推送
|
// myAsyncService.updateUserByQfqk(user2);
|
// //内网数据sql
|
// String s1 =
|
// "update blade_user set hold = " + "'" + user2.getHold() + "'"
|
// + ",securitynumber = " + "'" + user2.getSecuritynumber() + "'"
|
// + ",registered = " + "'" + user2.getRegistered() + "'"
|
// + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
// + " " + "where id = " + "'" + user2.getId() + "'";
|
// //FtpUtil.sqlFileUpload(s1);
|
// myAsyncService.FTP(s1);
|
// }
|
// }
|
// }
|
// //批量插入
|
// //用户批量插入
|
// if (userList.size()>0) {
|
// baseMapper.batchUserList(userList);
|
// //用户批量插入异步推送
|
// myAsyncService.batchUserList(userList);
|
// //sql 拼接
|
// StringBuilder builder = new StringBuilder();
|
// StringBuilder builder1 = new StringBuilder();
|
// //遍历
|
// for (User user : userList) {
|
// //内网同步，sql 拼接
|
// String sql = "insert into blade_user(" +
|
// "id,tenant_id,account,password,name,real_name,avatar,email,phone,sex," +
|
// "role_id,dept_id,cardid,nativePlace,nation,fingerprint,education," +
|
// "politicaloutlook,healstats,height,address,registered," +
|
// "securitynumber,hold,jurisdiction,examination_type,status,is_deleted,dispatch,create_time) " +
|
// "values(" + "'" + user.getId() + "'" +
|
// "," + "'" + user.getTenantId() + "'" +
|
// "," + "'" + user.getAccount() + "'" +
|
// "," + "'" + user.getPassword() + "'" +
|
// "," + "'" + user.getName() + "'" +
|
// "," + "'" + user.getRealName() + "'" +
|
// "," + "'" + user.getAvatar() + "'" +
|
// "," + "'" + user.getEmail() + "'" +
|
// "," + "'" + user.getPhone() + "'" +
|
// "," + "'" + user.getSex() + "'" +
|
// "," + "'" + user.getRoleId() + "'" +
|
// "," + "'" + user.getDeptId() + "'" +
|
// "," + "'" + user.getCardid() + "'" +
|
// "," + "'" + user.getNativeplace() + "'" +
|
// "," + "'" + user.getNation() + "'" +
|
// "," + "'" + user.getFingerprint() + "'" +
|
// "," + "'" + user.getEducation() + "'" +
|
// "," + "'" + user.getPoliticaloutlook() + "'" +
|
// "," + "'" + user.getHealstats() + "'" +
|
// "," + "'" + user.getHeight() + "'" +
|
// "," + "'" + user.getAddress() + "'" +
|
// "," + "'" + user.getRegistered() + "'" +
|
// "," + "'" + user.getSecuritynumber() + "'" +
|
// "," + "'" + user.getHold() + "'" +
|
// "," + "'" + user.getJurisdiction() + "'" +
|
// "," + "'" + user.getExaminationType() + "'" +
|
// "," + "'" + user.getStatus() + "'" +
|
// "," + "'" + user.getIsDeleted() + "'" +
|
// "," + "'" + user.getDispatch() + "'" +
|
// "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getCreateTime()) + "'" + ")";
|
// //拼接
|
// builder = builder.append(sql).append(";");
|
// List<String> list = Arrays.asList(builder.toString().split(";"));
|
// //判断list.size 大小
|
// if (list.size()==1000){
|
// //执行
|
// //FtpUtil.sqlFileUpload(builder.toString());
|
// myAsyncService.FTP(builder.toString());
|
// //清空
|
// builder.delete(0,builder.length());
|
// }
|
// }
|
//
|
// //装换成map
|
// Map<String, User> userMap = userList.stream().collect(Collectors.toMap(user -> user.getCardid(), user -> user));
|
// //匹配
|
// experienceList = experienceList.stream().map(experience -> {
|
// if (experience.getCardid().equals(userMap.get(experience.getCardid()).getCardid())) {
|
// experience.setSecurityid(userMap.get(experience.getCardid()).getId().toString());
|
// }
|
// return experience;
|
// }).collect(Collectors.toList());
|
// //批量插入从业记录
|
// baseMapper.batchExperienceList(experienceList);
|
// //遍历，拼接sql ，同步数据到内网
|
// for (Experience experience : experienceList) {
|
// String sql1 = "insert into sys_experience(id,name,post,entryTime,cardId,companyname,securityId) " +
|
// "values(" + "'" + experience.getId() + "'" + "," +
|
// "'" + experience.getName() + "'" + "," +
|
// "'" + experience.getPost() + "'" + "," +
|
// "," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(experience.getEntrytime()) + "'" +
|
// "," + "'" + experience.getCardid() + "'" +
|
// "," + "'" + experience.getCompanyname() + "'" +
|
// "," + "'" + experience.getSecurityid() + "'" + ")";
|
// //拼接
|
// builder1 = builder1.append(sql1).append(";");
|
// String[] split1 = builder.toString().split(";");
|
// //判断list.size 大小
|
// if (split1.length==1000){
|
// //执行
|
// //FtpUtil.sqlFileUpload(builder1.toString());
|
// myAsyncService.FTP(builder1.toString());
|
// //清空
|
// builder1.delete(0,builder1.length());
|
// }
|
// }
|
// //剩余的继续执行
|
// //FtpUtil.sqlFileUpload(builder.toString());
|
// myAsyncService.FTP(builder.toString());
|
// //FtpUtil.sqlFileUpload(builder1.toString());
|
// myAsyncService.FTP(builder1.toString());
|
// }
|
//// System.out.println("导入时间： = " + (System.currentTimeMillis()-time));
|
//
|
// //如果所有数据导入有一个异常
|
// StringBuilder errorBuilder = new StringBuilder();
|
// if (!status.get()){
|
// String errorAccount = StringUtils.join(errorList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
// }
|
// if (!agetStatus.get()){
|
// String errorAccount = StringUtils.join(ageErrorList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
// }
|
// if (!securityInvalidStatus.get()){
|
// String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
|
// }
|
// //抛出异常
|
// if (errorBuilder.length()>0){
|
// throw new ServiceException(errorBuilder.toString());
|
// }
|
// }
|
|
/**
|
* 导入保安员(需加密，部分字段需要脱敏处理)
|
* @since 修改时间 ： 2022-04-28
|
* @author: 修改人 zhongrj
|
* @param data
|
* @param isCovered
|
*/
|
@Override
|
public void importSecurity(List<SecurityExcel> data, Boolean isCovered, String deptId) {
|
long time = System.currentTimeMillis();
|
//uuidList
|
List<String> uuidList = new ArrayList<>();
|
//将不能导入的保安员账号存起来
|
List<String> errorList = new ArrayList<>();
|
//年龄不符的保安员信息存入集合
|
List<String> ageErrorList = new ArrayList<>();
|
//保安员证编号不符的保安员信息存入集合
|
List<String> securityInvalidList = new ArrayList<>();
|
//将需要更新的保安员信息存入集合
|
List<User> updateList = new ArrayList<>();
|
//需要推送内网的保安员信息集合
|
List<User> userList = new ArrayList<>();
|
//需要新增的保安员集合
|
List<User> addList = new ArrayList<>();
|
//需要新增的从业记录集合
|
List<Experience> experienceList = new ArrayList<>();
|
//导入状态，默认为true ,如果有一个出现问题则为 false
|
AtomicBoolean status = new AtomicBoolean(true);
|
AtomicBoolean agetStatus = new AtomicBoolean(true);
|
AtomicBoolean securityInvalidStatus = new AtomicBoolean(true);
|
//遍历
|
for (SecurityExcel userExcel : data) {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
//设置部门id
|
String deptIds = userDeptService.selectIn(user.getDeptId());
|
if (null!=deptIds && !deptIds.equals("")) {
|
if (null != deptId && !deptId.equals("")) {
|
if (!deptId.equals(deptIds)) {
|
throw new ServiceException("导入失败!不能导入不是本公司的保安员数据!");
|
}
|
}
|
user.setDeptId(deptIds);
|
}else {
|
//如果deptIds 为空，则说明还没有改公司
|
throw new ServiceException("导入失败!公司名:["+user.getDeptId()+"]不存在!");
|
}
|
|
//身份证校验
|
if (null==user.getCardid() || user.getCardid().equals("")){
|
throw new ServiceException("导入失败!身份证号码不能为空!");
|
}
|
//身份证住址校验
|
if (null==user.getRegistered() || user.getRegistered().equals("")){
|
throw new ServiceException("导入失败!身份证住址不能为空!");
|
}
|
if (null!=user.getCardid() && !user.getCardid().equals("")){
|
//去除所有空格
|
String cardid = user.getCardid().replaceAll(" ", "");
|
//校验
|
boolean b = IdCardNoUtil.checkIdCardNo(cardid);
|
if(b){
|
user.setCardid(cardid);
|
}else {
|
agetStatus.set(false);
|
ageErrorList.add(user.getCardid());
|
// throw new ServiceException("导入失败!身份证号码[ "+user.getCardid()+" ]不正确,请核对!");
|
//forEach 只能使用 return 跳出本次循环
|
// return;
|
continue;
|
}
|
}
|
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
//分配保安角色
|
// Role role = new Role();
|
// role.setRoleAlias("保安");
|
// Role oneRole = roleService.getOne(Condition.getQueryWrapper(role));
|
user.setRoleId("1412226235153731586");
|
|
if (null!=user.getSecuritynumber() && !user.getSecuritynumber().equals("")){
|
user.setHold("1");
|
}else {
|
user.setHold("2");
|
}
|
|
//性别
|
if (null != userExcel.getSex()) {
|
if (userExcel.getSex().equals("男")) {
|
user.setSex(1);
|
}else if (userExcel.getSex().equals("女")) {
|
user.setSex(2);
|
}else {
|
user.setSex(1);
|
}
|
}else {
|
user.setSex(1);
|
}
|
|
//设置账号
|
String realName = user.getRealName();
|
String cardid = user.getCardid();
|
// user.setAccount(user.getRealName());
|
user.setAccount(realName.substring(0,1)+cardid.substring(cardid.length()-4));
|
//加密
|
user.setPassword(DigestUtil.encrypt(user.getCardid().substring(user.getCardid().length() - 6)));
|
user.setCreateTime(new Date());
|
user.setUpdateTime(new Date());
|
user.setDispatch("1");
|
//待审查
|
user.setExaminationType("2");
|
|
//推送内网的数据
|
User user0 = Objects.requireNonNull(BeanUtil.copy(user,User.class));
|
|
//生成随机数
|
String uuid = UUID.randomUUID().toString();
|
//将 user 存入 redis
|
redisTemplate.opsForValue().set(uuid, JSON.toJSONString(user));
|
//user0 临时设置uuid 到 reason_for_leav 离职原因字段
|
user0.setReasonForLeav(uuid);
|
//加入集合
|
userList.add(user0);
|
uuidList.add(uuid);
|
}
|
|
Result result = new Result();
|
//用户批量插入
|
if (userList.size()>0) {
|
//生成随机数
|
String uuid = UUID.randomUUID().toString();
|
//数据推送
|
Map<String, Object> map = new HashMap<>(1);
|
map.put(uuid, userList);
|
myAsyncService.FTPObjectList(map);
|
|
int count = 0;
|
//调用ftp获取返回数据
|
while (true){
|
try {
|
Thread.sleep(3000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
//调用ftp获取返回数据
|
result = Monitor.getFtpDataByUuidList(uuid);
|
//如果返回true,就退处
|
if (result.getCode() == 200) {
|
break;
|
}
|
else {
|
count++;
|
if (count == 60) {
|
break;
|
}
|
}
|
}
|
}
|
|
if (null!=result){
|
//获取 result
|
List<Result> data1 = result.getData();
|
if (data1.size()>0){
|
for (Result result1 : data1) {
|
// 取出 Msg ,此 msg 存的对应的 uuid
|
String uuid = result1.getMsg();
|
//从redis 中获取用户数据
|
Object o1 = redisTemplate.opsForValue().get(uuid);
|
User user0 = JSON.parseObject(o1.toString(), User.class);
|
// 从redis 中获取对应的用户信息,脱敏处理过
|
User user = handlerUserInfo(uuid);
|
if (result1.getCode()==200){
|
user.setId(result1.getUserId());
|
boolean save = this.save(user);
|
//同步用户数据到群防群控
|
if (save) {
|
myAsyncService.qfqkUserSave(user);
|
}
|
//加入新增集合
|
// addList.add(user);
|
}
|
if (result1.getCode()==201){
|
user.setId(result1.getUserId());
|
user.setCreateTime(null);
|
this.updateById(user);
|
//加入更新集合
|
// updateList.add(user);
|
}
|
if (result1.getCode()==202){
|
status.set(false);
|
//已在其他单位存在
|
errorList.add(user0.getCardid());
|
}
|
if (result1.getCode()==203){
|
securityInvalidStatus.set(false);
|
//保安证编号不匹配
|
securityInvalidList.add(user0.getCardid());
|
}
|
}
|
// //批量插入
|
// if (addList.size()>0){
|
// baseMapper.batchUserList(addList);
|
// }
|
// //批量更新
|
// if (updateList.size()>0){
|
// baseMapper.batchUpdateUserList(updateList);
|
// }
|
}
|
}
|
|
//如果所有数据导入有一个异常
|
StringBuilder errorBuilder = new StringBuilder();
|
if (!status.get()){
|
String errorAccount = StringUtils.join(errorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
}
|
if (!agetStatus.get()){
|
String errorAccount = StringUtils.join(ageErrorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
|
}
|
if (!securityInvalidStatus.get()){
|
String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
|
errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
|
}
|
//抛出异常
|
if (errorBuilder.length()>0){
|
throw new ServiceException(errorBuilder.toString());
|
}
|
}
|
|
/**
|
* 用户数据获取和处理
|
* @param uuid 随机参数
|
* @return
|
*/
|
private User handlerUserInfo(String uuid){
|
//从redis 中获取用户数据
|
Object o1 = redisTemplate.opsForValue().get(uuid);
|
User user = JSON.parseObject(o1.toString(), User.class);
|
//取出后将 redis 删除
|
redisTemplate.delete(uuid);
|
//返回的user,需处理敏感数据
|
User user1 = Objects.requireNonNull(BeanUtil.copy(user,User.class));
|
//敏感数据处理
|
user1.setRealName(DesensitizedUtil.desensitizedName(user.getRealName()));
|
user1.setCardid(DesensitizedUtil.desensitizedIdNumberBy4(user.getCardid()));
|
user1.setPhone(DesensitizedUtil.desensitizedPhoneNumber(user.getPhone()));
|
user1.setRegistered(DesensitizedUtil.desensitizedAddress(user.getRegistered()));
|
if (user.getHold().equals("1")) {
|
user1.setSecuritynumber(DesensitizedUtil.desensitizedSecurityNumber(user.getSecuritynumber()));
|
}else {
|
user1.setSecuritynumber("");
|
}
|
user1.setAvatar("");
|
user1.setEmail("");
|
user1.setFingerprint("");
|
user1.setNation("");
|
user1.setNativeplace("");
|
user1.setEducation("");
|
user1.setPoliticaloutlook("");
|
user1.setMyPicture("");
|
user1.setHeight("");
|
user1.setRtime(null);
|
user1.setGuncode("");
|
//返回
|
return user1;
|
}
|
|
/**
|
* 保安员导入（押运人员导入）
|
* @param data
|
* @param isCovered
|
* @param deptId
|
*/
|
@Override
|
public void importSecurityYy(List<SecurityYyExcel> data, Boolean isCovered, String deptId) {
|
//uuidList
|
List<String> uuidList = new ArrayList<>();
|
//将不能导入的保安员账号存起来
|
List<String> errorList = new ArrayList<>();
|
//年龄不符的保安员信息存入集合
|
List<String> ageErrorList = new ArrayList<>();
|
//保安员证编号不符的保安员信息存入集合
|
List<String> securityInvalidList = new ArrayList<>();
|
//需要推送内网的保安员信息集合
|
List<User> userList = new ArrayList<>();
|
//导入状态，默认为true ,如果有一个出现问题则为 false
|
AtomicBoolean status = new AtomicBoolean(true);
|
AtomicBoolean agetStatus = new AtomicBoolean(true);
|
AtomicBoolean securityInvalidStatus = new AtomicBoolean(true);
|
//遍历
|
for (SecurityYyExcel userExcel : data) {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
//设置部门id
|
String deptIds = userDeptService.selectIn(user.getDeptId());
|
if (null!=deptIds && !deptIds.equals("")) {
|
if (null != deptId && !deptId.equals("")) {
|
if (!deptId.equals(deptIds)) {
|
throw new ServiceException("导入失败!不能导入不是本公司的保安员数据!");
|
}
|
}
|
user.setDeptId(deptIds);
|
}else {
|
//如果deptIds 为空，则说明还没有改公司
|
throw new ServiceException("导入失败!公司名:["+user.getDeptId()+"]不存在!");
|
}
|
|
//身份证校验
|
if (null==user.getCardid() || user.getCardid().equals("")){
|
throw new ServiceException("导入失败!身份证号码不能为空!");
|
}
|
//身份证住址校验
|
if (null==user.getRegistered() || user.getRegistered().equals("")){
|
throw new ServiceException("导入失败!身份证住址不能为空!");
|
}
|
if (null!=user.getCardid() && !user.getCardid().equals("")){
|
//去除所有空格
|
String cardid = user.getCardid().replaceAll(" ", "");
|
//校验
|
boolean b = IdCardNoUtil.checkIdCardNo(cardid);
|
if(b){
|
user.setCardid(cardid);
|
}else {
|
agetStatus.set(false);
|
ageErrorList.add(user.getCardid());
|
continue;
|
}
|
}
|
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
//分配保安角色
|
Role role = new Role();
|
role.setRoleAlias("保安");
|
Role oneRole = roleService.getOne(Condition.getQueryWrapper(role));
|
user.setRoleId(oneRole.getId().toString());
|
|
if (null!=user.getSecuritynumber() && !user.getSecuritynumber().equals("")){
|
user.setHold("1");
|
}else {
|
user.setHold("2");
|
}
|
|
//性别
|
if (null != userExcel.getSex()) {
|
if (userExcel.getSex().equals("男")) {
|
user.setSex(1);
|
}else if (userExcel.getSex().equals("女")) {
|
user.setSex(2);
|
}else {
|
user.setSex(1);
|
}
|
}else {
|
user.setSex(1);
|
}
|
|
//设置账号
|
String realName = user.getRealName();
|
String cardid = user.getCardid();
|
// user.setAccount(user.getRealName());
|
user.setAccount(realName.substring(0,1)+cardid.substring(cardid.length()-4));
|
//加密
|
user.setPassword(DigestUtil.encrypt(user.getCardid().substring(user.getCardid().length() - 6)));
|
user.setCreateTime(new Date());
|
user.setUpdateTime(new Date());
|
user.setDispatch("1");
|
//待审查
|
user.setExaminationType("2");
|
|
//推送内网的数据
|
User user0 = Objects.requireNonNull(BeanUtil.copy(user,User.class));
|
|
//生成随机数
|
String uuid = UUID.randomUUID().toString();
|
//将 user 存入 redis
|
redisTemplate.opsForValue().set(uuid, JSON.toJSONString(user));
|
//user0 临时设置uuid 到 reason_for_leav 离职原因字段
|
user0.setReasonForLeav(uuid);
|
//加入集合
|
userList.add(user0);
|
uuidList.add(uuid);
|
}
|
|
Result result = new Result();
|
//用户批量插入
|
if (userList.size()>0) {
|
//生成随机数
|
String uuid = UUID.randomUUID().toString();
|
//数据推送
|
Map<String, Object> map = new HashMap<>(1);
|
map.put(uuid, userList);
|
myAsyncService.FTPObjectList(map);
|
|
int count = 0;
|
//调用ftp获取返回数据
|
while (true){
|
try {
|
Thread.sleep(2000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
//调用ftp获取返回数据
|
result = Monitor.getFtpDataByUuidList(uuid);
|
//如果返回true,就退处
|
if (result.getCode() == 200) {
|
break;
|
}
|
}
|
}
|
|
if (null!=result){
|
//获取 result
|
List<Result> data1 = result.getData();
|
if (data1.size()>0){
|
for (Result result1 : data1) {
|
// 取出 Msg ,此 msg 存的对应的 uuid
|
String uuid = result1.getMsg();
|
//从redis 中获取用户数据
|
Object o1 = redisTemplate.opsForValue().get(uuid);
|
User user0 = JSON.parseObject(o1.toString(), User.class);
|
// 从redis 中获取对应的用户信息,脱敏处理过
|
User user = handlerUserInfo(uuid);
|
if (result1.getCode()==200){
|
user.setId(result1.getUserId());
|
boolean save = this.save(user);
|
if (save){
|
//数据异步同步到群防群控
|
myAsyncService.qfqkUserSave(user);
|
}
|
//加入新增集合
|
// addList.add(user);
|
}
|
if (result1.getCode()==201){
|
user.setId(result1.getUserId());
|
user.setCreateTime(null);
|
boolean update = this.updateById(user);
|
if (update){
|
//数据异步同步到群防群控
|
myAsyncService.updateUserByQfqk(user);
|
}
|
//加入更新集合
|
// updateList.add(user);
|
}
|
if (result1.getCode()==202){
|
status.set(false);
|
//已在其他单位存在
|
errorList.add(user0.getCardid());
|
}
|
if (result1.getCode()==203){
|
securityInvalidStatus.set(false);
|
//保安证编号不匹配
|
securityInvalidList.add(user0.getCardid());
|
}
|
}
|
}
|
}
|
|
//如果所有数据导入有一个异常
|
StringBuilder errorBuilder = new StringBuilder();
|
if (!status.get()){
|
String errorAccount = StringUtils.join(errorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
}
|
if (!agetStatus.get()){
|
String errorAccount = StringUtils.join(ageErrorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
|
}
|
if (!securityInvalidStatus.get()){
|
String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
|
// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
|
}
|
//抛出异常
|
if (errorBuilder.length()>0){
|
throw new ServiceException(errorBuilder.toString());
|
}
|
}
|
|
|
///**
|
// * 保安员导入（押运人员导入）
|
// * @param data
|
// * @param isCovered
|
// * @param deptId
|
// */
|
// @Override
|
// public void importSecurityYy(List<SecurityYyExcel> data, Boolean isCovered, String deptId) {
|
// //将不能导入的保安员账号存起来
|
// List<String> errorList = new ArrayList<>();
|
// //将需要新增的保安员信息存入集合
|
// List<String> ageErrorList = new ArrayList<>();
|
// //保安员证编号不符的保安员信息存入集合
|
// List<String> securityInvalidList = new ArrayList<>();
|
// //将需要更新的保安员信息存入集合
|
// List<User> updateList = new ArrayList<>();
|
// //导入状态，默认为true ,如果有一个出现问题则为 false
|
// AtomicBoolean status = new AtomicBoolean(true);
|
// AtomicBoolean agetStatus = new AtomicBoolean(true);
|
// AtomicBoolean securityInvalidStatus = new AtomicBoolean(true);
|
// data.forEach(userExcel -> {
|
// User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
// //设置部门id
|
// String deptIds = userDeptService.selectIn(user.getDeptId());
|
// if (null!=deptIds && !deptIds.equals("")) {
|
// if (null != deptId && !deptId.equals("")) {
|
// if (!deptId.equals(deptIds)) {
|
// throw new ServiceException("导入失败!不能导入不是本公司的保安员数据!");
|
// }
|
// }
|
// user.setDeptId(deptIds);
|
// }else {
|
// //如果deptIds 为空，则说明还没有改公司
|
// throw new ServiceException("导入失败!公司名:["+user.getDeptId()+"]不存在!");
|
// }
|
//
|
// //身份证号码校验
|
// if (null==user.getCardid() || user.getCardid().equals("")){
|
// throw new ServiceException("导入失败!身份证号码不能为空!");
|
// }
|
// //身份证住址校验
|
// if (null==user.getRegistered() || user.getRegistered().equals("")){
|
// throw new ServiceException("导入失败!身份证住址不能为空!");
|
// }
|
// if (null!=user.getCardid() && !user.getCardid().equals("")){
|
// //去除所有空格
|
// String cardid = user.getCardid().replaceAll(" ", "");
|
// //校验
|
// boolean b = IdCardNoUtil.checkIdCardNo(cardid);
|
// if(b){
|
// user.setCardid(cardid);
|
// }else {
|
// agetStatus.set(false);
|
// ageErrorList.add(user.getCardid());
|
//// throw new ServiceException("导入失败!身份证号码[ "+user.getCardid()+" ]不正确,请核对!");
|
// //forEach 只能使用 return 跳出本次循环
|
// return;
|
// }
|
// }
|
// //判断当前用户是否已在本单位，如果是的更新数据
|
// User user1 = new User();
|
// user1.setAccount(user.getCardid());
|
// user1.setIsDeleted(0);
|
// user1.setStatus(1);
|
// user1.setGuncode(user.getGuncode());
|
// User user2 = this.getOne(Condition.getQueryWrapper(user1));
|
// if (null==user2){
|
// //用户不存在，去新增
|
// // 设置租户ID
|
// user.setTenantId("000000");
|
// //默认在职
|
// user.setStatus(1);
|
// user.setIsDeleted(0);
|
// //判断是否持证
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user.setHold("1");
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user.setHold("2");
|
// user.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user.setHold("2");
|
// user.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// 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);
|
// }
|
// }
|
//
|
// //设置账号
|
// user.setAccount(user.getCardid());
|
// //获取默认密码配置
|
// user.setPassword(user.getCardid().substring(user.getCardid().length() - 6));
|
// //加密
|
// if (Func.isNotEmpty(user.getPassword())) {
|
// user.setPassword(DigestUtil.encrypt(user.getPassword()));
|
// }
|
// Integer userCount = baseMapper.selectCountAccount(user.getAccount());
|
// if (userCount > 0 && Func.isEmpty(user.getId())) {
|
// throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
// }
|
// user.setCreateTime(new Date());
|
// //新增
|
// this.save(user);
|
// //qfqk 推送
|
// myAsyncService.qfqkUserSave(user);
|
//
|
// //从业记录新增
|
// Experience experience = new Experience();
|
// experience.setCardid(user.getCardid());
|
// experience.setSecurityid(user.getId().toString());
|
// experience.setCompanyname(userExcel.getDeptId());
|
// experience.setName(user.getRealName());
|
// experience.setPost("保安员");
|
// experience.setEntrytime(new Date());
|
// experienceService.save(experience);
|
//
|
// //内网同步
|
// String s = "insert into blade_user(" +
|
// "id,tenant_id,account,password,name,real_name,avatar,email,phone,sex," +
|
// "role_id,dept_id,cardid,nativePlace,nation,fingerprint,education," +
|
// "politicaloutlook,healstats,height,address,registered," +
|
// "securitynumber,hold,jurisdiction,examination_type,status,is_deleted,dispatch,create_time,guncode) " +
|
// "values(" + "'" + user.getId() + "'" +
|
// "," + "'" + user.getTenantId() + "'" +
|
// "," + "'" + user.getAccount() + "'" +
|
// "," + "'" + user.getPassword() + "'" +
|
// "," + "'" + user.getName() + "'" +
|
// "," + "'" + user.getRealName() + "'" +
|
// "," + "'" + user.getAvatar() + "'" +
|
// "," + "'" + user.getEmail() + "'" +
|
// "," + "'" + user.getPhone() + "'" +
|
// "," + "'" + user.getSex() + "'" +
|
// "," + "'" + user.getRoleId() + "'" +
|
// "," + "'" + user.getDeptId() + "'" +
|
// "," + "'" + user.getCardid() + "'" +
|
// "," + "'" + user.getNativeplace() + "'" +
|
// "," + "'" + user.getNation() + "'" +
|
// "," + "'" + user.getFingerprint() + "'" +
|
// "," + "'" + user.getEducation() + "'" +
|
// "," + "'" + user.getPoliticaloutlook() + "'" +
|
// "," + "'" + user.getHealstats() + "'"+
|
// "," + "'" + user.getHeight() + "'" +
|
// "," + "'" + user.getAddress() + "'" +
|
// "," + "'" + user.getRegistered() + "'" +
|
// "," + "'" + user.getSecuritynumber() + "'" +
|
// "," + "'" + user.getHold() + "'" +
|
// "," + "'" + user.getJurisdiction() + "'" +
|
// "," + "'" + user.getExaminationType() + "'" +
|
// "," + "'" + user.getStatus() + "'" +
|
// "," + "'" + user.getIsDeleted() + "'" +
|
// "," + "'" + user.getDispatch() + "'" +
|
// "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getCreateTime()) + "'" +
|
// "," + "'" + user.getGuncode() + "'" + ");"+
|
// "insert into sys_experience(id,name,post,entryTime," +
|
// "cardId,companyname,securityId) " +
|
// "values(" + "'" + experience.getId() + "'" + "," +
|
// "'" + experience.getName() + "'" + "," +
|
// "'" + experience.getPost() + "'" + "," +
|
// "," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(experience.getEntrytime()) + "'" +
|
// "," + "'" + experience.getCardid() + "'" +
|
// "," + "'" + experience.getCompanyname() + "'" +
|
// "," + "'" + experience.getSecurityid() + "'"
|
// + ")";
|
// //FtpUtil.sqlFileUpload(s);
|
// myAsyncService.FTP(s);
|
// }
|
// else {
|
// //匹配组织机构是否一致,如果不一致
|
// if(!user2.getDeptId().equals(user.getDeptId())){
|
// Dept dept = deptService.getById(user2.getDeptId());
|
// Dept dept1 = deptService.getById(user.getDeptId());
|
// //如果是南昌总公司分公司导入的
|
// if (dept.getId().equals(1432626178757275649L) && dept1.getParentId().equals(1432626178757275649L)){
|
// user2.setDeptId(dept1.getId().toString());
|
// //判断是否持证
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user2.setHold("1");
|
// user2.setSecuritynumber(user.getSecuritynumber());
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// }
|
// if (null!=userExcel.getRegistered()){
|
// user2.setRegistered(userExcel.getRegistered());
|
// }else {
|
// user2.setRegistered("");
|
// }
|
// user2.setUpdateTime(new Date());
|
// //更新用户数据
|
// this.updateById(user2);
|
// //qfqk 推送
|
// myAsyncService.updateUserByQfqk(user);
|
//
|
// String s1 =
|
// "update blade_user set hold = " + "'" + user2.getHold() + "'"
|
// + ",securitynumber = " + "'" + user2.getSecuritynumber() + "'"
|
// + ",dept_id = " + "'" + user2.getDeptId() + "'"
|
// + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
// + ",registered = " + "'" + user2.getRegistered() + "'"
|
// + " " + "where id = " + "'" + user2.getId() + "'";
|
// //FtpUtil.sqlFileUpload(s1);
|
// myAsyncService.FTP(s1);
|
// }else {
|
// status.set(false);
|
// //加入集合
|
// errorList.add(user.getCardid());
|
// //forEach 只能使用 return 跳出本次循环
|
// return;
|
// }
|
// }else {
|
// //如果是一致，则更新用户数据
|
// if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
// user2.setHold("1");
|
// user2.setSecuritynumber(user.getSecuritynumber());
|
// //校验保安员证编号是否合规
|
// SecurityPaper securityPaper = new SecurityPaper();
|
// securityPaper.setIdCardNo(userExcel.getCardid());
|
// List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
// if (securityPaperList.size()>0){
|
// boolean state = false;
|
// //遍历
|
// for (SecurityPaper paper : securityPaperList) {
|
// if (paper.getNumber().equals(user.getSecuritynumber())){
|
// state = true;
|
// }
|
// }
|
// if (!state){
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// user2.setSecuritynumber(null);
|
// securityInvalidList.add(userExcel.getCardid());
|
// securityInvalidStatus.set(false);
|
// }
|
// }else {
|
// user2.setHold("2");
|
// }
|
// if (null!=userExcel.getRegistered()){
|
// user2.setRegistered(userExcel.getRegistered());
|
// }else {
|
// user2.setRegistered("");
|
// }
|
// user2.setUpdateTime(new Date());
|
// //更新用户数据
|
// this.updateById(user2);
|
// //qfqk 推送
|
// myAsyncService.updateUserByQfqk(user);
|
//
|
// String s1 =
|
// "update blade_user set hold = " + "'" + user2.getHold() + "'"
|
// + ",securitynumber = " + "'" + user2.getSecuritynumber() + "'"
|
// + ",registered = " + "'" + user2.getRegistered() + "'"
|
// + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
// + " " + "where id = " + "'" + user2.getId() + "'";
|
// //FtpUtil.sqlFileUpload(s1);
|
// myAsyncService.FTP(s1);
|
// }
|
// }
|
// });
|
// //如果所有数据导入有一个异常
|
// StringBuilder errorBuilder = new StringBuilder();
|
// if (!status.get()){
|
// String errorAccount = StringUtils.join(errorList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
// }
|
// if (!agetStatus.get()){
|
// String errorAccount = StringUtils.join(ageErrorList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
// }
|
// if (!securityInvalidStatus.get()){
|
// String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
|
// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
|
// }
|
// //抛出异常
|
// if (errorBuilder.length()>0){
|
// throw new ServiceException(errorBuilder.toString());
|
// }
|
// }
|
|
|
/**
|
* 根据保安员编码查询保安信息
|
*
|
* @param securityNumber 保安证编码
|
* @return
|
*/
|
@Override
|
public UserVO getUserInfoBySecurityNumber(String securityNumber,String cardid) {
|
UserVO userVO = baseMapper.getUserInfoBySecurityNumber(securityNumber,cardid);
|
//查询派遣信息
|
if (null!=userVO) {
|
DispatcherVO dispatcherVO = baseMapper.getUserDispatcherInfo(userVO.getId());
|
if (null != dispatcherVO) {
|
userVO.setDispatchUnitName(dispatcherVO.getDispatcherCompany());
|
userVO.setDispatchStartTime(new SimpleDateFormat("yyyy-MM-dd").format(dispatcherVO.getDispatchertime()));
|
userVO.setDispatchEndTime(new SimpleDateFormat("yyyy-MM-dd").format(dispatcherVO.getEndTime()));
|
}
|
}
|
return userVO;
|
}
|
|
|
/**
|
* 保安员信息
|
*
|
* @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);
|
}
|
//现场检查获取保安员
|
if (Integer.parseInt(type) == 5) {
|
list = baseMapper.getSecurityInfo(jurisdiction);
|
}
|
return list;
|
}
|
|
/**
|
* 查询账号相同的用户数量
|
*
|
* @param account
|
* @return
|
*/
|
@Override
|
public Integer selectCount(String account) {
|
return baseMapper.selectCountAccount(account);
|
}
|
|
/**
|
* 查询用户表中未删除，未离职的用户信息
|
* @param username
|
* @return
|
*/
|
@Override
|
public User getUserInfo(String username) {
|
return baseMapper.getUserInfo(username);
|
}
|
|
/**
|
* 生成二维码
|
* @param data
|
* @param isCovered
|
* @param deptId
|
*/
|
@Override
|
public void importQrCode(List<QrCodeExcel> data, Boolean isCovered, String deptId) {
|
String url = "http://61.131.136.25:2080/securityInfo.html";
|
//二维码生成
|
data.forEach(qrCodeExcel -> {
|
if (null!=qrCodeExcel.getSecuritynumber()) {
|
String encoded = null;
|
try {
|
//中文字符串编码
|
encoded = URLEncoder.encode(qrCodeExcel.getSecuritynumber(),"UTF-8");
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
//url 拼接
|
String content = url + "?securityNumber=" + encoded;
|
byte[] qrCodeImage = new byte[0];
|
try {
|
//生成二维码字节流
|
qrCodeImage = QRCodeUtil.getQRCodeImage(content, 350, 350);
|
} catch (WriterException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
String path = "D:\\QrCode\\";
|
FileOutputStream fileOutputStream = null;
|
try {
|
fileOutputStream = new FileOutputStream(path+qrCodeExcel.getSecuritynumber()+".png");
|
} catch (FileNotFoundException e) {
|
e.printStackTrace();
|
}
|
try {
|
//图片下载到本地
|
fileOutputStream.write(qrCodeImage,0,qrCodeImage.length);
|
fileOutputStream.flush();
|
fileOutputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
});
|
//头像生成
|
data.forEach(qrCodeExcel -> {
|
if (null!=qrCodeExcel.getSecuritynumber()) {
|
//查询用户头像url
|
User user = new User();
|
user.setRealName(qrCodeExcel.getRealName());
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
user.setSecuritynumber(qrCodeExcel.getSecuritynumber());
|
User user1 = this.getOne(Condition.getQueryWrapper(user));
|
//url 拼接
|
byte[] qrCodeImage = new byte[0];
|
//获取图片
|
qrCodeImage = ImageUtils.getFileStream(user1.getAvatar());
|
//路径
|
String path = "D:\\QrCode\\";
|
FileOutputStream fileOutputStream = null;
|
try {
|
fileOutputStream = new FileOutputStream(path+user1.getRealName()+user1.getCardid()+".png");
|
} catch (FileNotFoundException e) {
|
e.printStackTrace();
|
}
|
try {
|
//图片下载到本地
|
fileOutputStream.write(qrCodeImage,0,qrCodeImage.length);
|
fileOutputStream.flush();
|
fileOutputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
});
|
}
|
|
/**
|
* 根据用户账户查询用户是否存在
|
* @param account
|
* @return
|
*/
|
@Override
|
public Integer selectCountAccount(String account) {
|
return baseMapper.selectCountAccount(account);
|
}
|
|
/**
|
* 保安员信息导出
|
* @param user
|
* @return
|
*/
|
@Override
|
public List<SecurityExcel> exportSecurityInfo(UserVO user) {
|
return baseMapper.exportSecurityInfo(user);
|
}
|
|
|
/**
|
* 导入保安员（admin 专用）
|
*
|
* @param data
|
*/
|
@Override
|
public void importSecurityTest(List<SecurityExcel> data) {
|
//将不能导入的保安员账号存起来
|
List<String> errorList = new ArrayList<>();
|
//年龄不符的保安员信息存入集合
|
List<String> ageErrorList = new ArrayList<>();
|
//保安员证编号不符的保安员信息存入集合
|
List<String> securityInvalidList = new ArrayList<>();
|
//将需要更新的保安员信息存入集合
|
List<User> updateList = new ArrayList<>();
|
//需要新增的保安员集合
|
List<User> userList = new ArrayList<>();
|
//需要新增的从业记录集合
|
List<Experience> experienceList = new ArrayList<>();
|
//导入状态，默认为true ,如果有一个出现问题则为 false
|
AtomicBoolean status = new AtomicBoolean(true);
|
AtomicBoolean agetStatus = new AtomicBoolean(true);
|
AtomicBoolean securityInvalidStatus = new AtomicBoolean(true);
|
//遍历
|
for (SecurityExcel userExcel : data) {
|
User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class));
|
//设置部门id
|
String deptIds = userDeptService.selectIn(user.getDeptId());
|
user.setDeptId(deptIds);
|
|
//身份证校验
|
if (null==user.getCardid() || user.getCardid().equals("")){
|
throw new ServiceException("导入失败!身份证号码不能为空!");
|
}
|
//身份证住址校验
|
if (null==user.getRegistered() || user.getRegistered().equals("")){
|
throw new ServiceException("导入失败!身份证住址不能为空!");
|
}
|
if (null!=user.getCardid() && !user.getCardid().equals("")){
|
//去除所有空格
|
String cardid = user.getCardid().replaceAll(" ", "");
|
//校验
|
boolean b = IdCardNoUtil.checkIdCardNo(cardid);
|
if(b){
|
user.setCardid(cardid);
|
}else {
|
agetStatus.set(false);
|
ageErrorList.add(user.getCardid());
|
//forEach 只能使用 return 跳出本次循环
|
// return;
|
continue;
|
}
|
}
|
|
//判断当前用户是否已在本单位，如果是的更新数据
|
User user1 = new User();
|
user1.setAccount(user.getCardid());
|
user1.setIsDeleted(0);
|
user1.setStatus(1);
|
User user2 = this.getOne(Condition.getQueryWrapper(user1));
|
if (null==user2){
|
//用户不存在，去新增
|
// 设置租户ID
|
user.setTenantId("000000");
|
//默认在职
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
//判断是否持证
|
if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
user.setHold("1");
|
//校验保安员证编号是否合规
|
SecurityPaper securityPaper = new SecurityPaper();
|
securityPaper.setIdCardNo(userExcel.getCardid());
|
List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
if (securityPaperList.size()>0){
|
boolean state = false;
|
//遍历
|
for (SecurityPaper paper : securityPaperList) {
|
if (paper.getNumber().equals(user.getSecuritynumber())){
|
state = true;
|
}
|
}
|
if (!state){
|
user.setHold("2");
|
user.setSecuritynumber(null);
|
securityInvalidList.add(userExcel.getCardid());
|
securityInvalidStatus.set(false);
|
}
|
}else {
|
user.setHold("2");
|
user.setSecuritynumber(null);
|
securityInvalidList.add(userExcel.getCardid());
|
securityInvalidStatus.set(false);
|
}
|
}else {
|
//创建保安证编号
|
user.setHold("1");
|
//去生成保安证编号
|
String pre = SecurityPaperUtil.getSecurityPaper();
|
//查询当前年份已有的保安证编号
|
int max = this.getSecurityPaperCount(pre);
|
String result = null;
|
if (max == 0) {
|
result = pre + "00001";
|
} else {
|
//格式化
|
DecimalFormat decimalFormat = new DecimalFormat("00000");
|
max++;
|
result = pre + (decimalFormat.format(max));
|
}
|
user.setSecuritynumber(result);
|
|
//生成保安证的同时向保安证管理表中插入一条数据
|
SecurityPaper securityPaper = new SecurityPaper();
|
securityPaper.setNumber(result);
|
securityPaper.setCreateTime(new Date());
|
securityPaper.setIdCardNo(user.getCardid());
|
securityPaper.setPeopleName(user.getRealName());
|
securityPaper.setSource(3);
|
//新增保安员证信息
|
securityPaperService.save(securityPaper);
|
}
|
//分配保安角色
|
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().contains("男")) {
|
user.setSex(1);
|
}
|
if (userExcel.getSex().contains("女")) {
|
user.setSex(2);
|
}
|
}
|
|
//设置账号
|
user.setAccount(user.getCardid());
|
//获取默认密码配置
|
user.setPassword(user.getCardid().substring(user.getCardid().length() - 6));
|
//加密
|
if (Func.isNotEmpty(user.getPassword())) {
|
user.setPassword(DigestUtil.encrypt(user.getPassword()));
|
}
|
Integer userCount = baseMapper.selectCountAccount(user.getAccount());
|
if (userCount > 0 && Func.isEmpty(user.getId())) {
|
throw new ServiceException(StringUtil.format("当前用户 [{}] 已存在!", user.getAccount()));
|
}
|
user.setCreateTime(new Date());
|
user.setDispatch("1");
|
user.setExaminationType("0");
|
//加入集合
|
userList.add(user);
|
//从业记录新增
|
Experience experience = new Experience();
|
experience.setCardid(user.getCardid());
|
experience.setCompanyname(userExcel.getDeptId());
|
experience.setName(user.getRealName());
|
experience.setPost("保安员");
|
experience.setEntrytime(new Date());
|
//加入集合
|
experienceList.add(experience);
|
|
}else {
|
//匹配组织机构是否一致,如果不一致
|
if(!user2.getDeptId().equals(user.getDeptId())){
|
status.set(false);
|
//加入集合
|
errorList.add(user.getCardid());
|
//forEach 只能使用 return 跳出本次循环
|
continue;
|
}else {
|
//如果是一致，则更新用户数据
|
//判断是否持证
|
if (null != userExcel.getSecuritynumber() && userExcel.getSecuritynumber() != "") {
|
user2.setHold("1");
|
user2.setSecuritynumber(user.getSecuritynumber());
|
//校验保安员证编号是否合规
|
SecurityPaper securityPaper = new SecurityPaper();
|
securityPaper.setIdCardNo(userExcel.getCardid());
|
List<SecurityPaper> securityPaperList = securityPaperService.list(Condition.getQueryWrapper(securityPaper));
|
if (securityPaperList.size()>0){
|
boolean state = false;
|
//遍历
|
for (SecurityPaper paper : securityPaperList) {
|
if (paper.getNumber().equals(user.getSecuritynumber())){
|
state = true;
|
}
|
}
|
if (!state){
|
user2.setHold("2");
|
user2.setSecuritynumber(null);
|
securityInvalidList.add(userExcel.getCardid());
|
securityInvalidStatus.set(false);
|
}
|
}else {
|
user2.setHold("2");
|
user2.setSecuritynumber(null);
|
securityInvalidList.add(userExcel.getCardid());
|
securityInvalidStatus.set(false);
|
}
|
}else {
|
//创建保安证编号
|
user2.setHold("1");
|
//去生成保安证编号
|
String pre = SecurityPaperUtil.getSecurityPaper();
|
//查询当前年份已有的保安证编号
|
int max = this.getSecurityPaperCount(pre);
|
String result = null;
|
if (max == 0) {
|
result = pre + "00001";
|
} else {
|
//格式化
|
DecimalFormat decimalFormat = new DecimalFormat("00000");
|
max++;
|
result = pre + (decimalFormat.format(max));
|
}
|
user2.setSecuritynumber(result);
|
|
//生成保安证的同时向保安证管理表中插入一条数据
|
SecurityPaper securityPaper = new SecurityPaper();
|
securityPaper.setNumber(result);
|
securityPaper.setCreateTime(new Date());
|
securityPaper.setIdCardNo(user2.getCardid());
|
securityPaper.setPeopleName(user2.getRealName());
|
securityPaper.setSource(3);
|
//新增保安员证信息
|
securityPaperService.save(securityPaper);
|
}
|
if (null!=userExcel.getRegistered()){
|
user2.setRegistered(userExcel.getRegistered());
|
}else {
|
user2.setRegistered("");
|
}
|
user2.setUpdateTime(new Date());
|
//更新用户数据
|
this.updateById(user2);
|
//qfqk异步推送
|
myAsyncService.updateUserByQfqk(user2);
|
//内网数据sql
|
String s1 =
|
"update blade_user set hold = " + "'" + user2.getHold() + "'"
|
+ ",securitynumber = " + "'" + user2.getSecuritynumber() + "'"
|
+ ",registered = " + "'" + user2.getRegistered() + "'"
|
+ ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
|
+ " " + "where id = " + "'" + user2.getId() + "'";
|
myAsyncService.FTP(s1);
|
}
|
}
|
}
|
//批量插入
|
//用户批量插入
|
if (userList.size()>0) {
|
baseMapper.batchUserList(userList);
|
//用户批量插入异步推送
|
myAsyncService.batchUserList(userList);
|
//sql 拼接
|
StringBuilder builder = new StringBuilder();
|
StringBuilder builder1 = new StringBuilder();
|
//遍历
|
for (User user : userList) {
|
//内网同步，sql 拼接
|
String sql = "insert into blade_user(" +
|
"id,tenant_id,account,password,name,real_name,avatar,email,phone,sex," +
|
"role_id,dept_id,cardid,nativePlace,nation,fingerprint,education," +
|
"politicaloutlook,healstats,height,address,registered," +
|
"securitynumber,hold,jurisdiction,examination_type,status,is_deleted,dispatch,create_time) " +
|
"values(" + "'" + user.getId() + "'" +
|
"," + "'" + user.getTenantId() + "'" +
|
"," + "'" + user.getAccount() + "'" +
|
"," + "'" + user.getPassword() + "'" +
|
"," + "'" + user.getName() + "'" +
|
"," + "'" + user.getRealName() + "'" +
|
"," + "'" + user.getAvatar() + "'" +
|
"," + "'" + user.getEmail() + "'" +
|
"," + "'" + user.getPhone() + "'" +
|
"," + "'" + user.getSex() + "'" +
|
"," + "'" + user.getRoleId() + "'" +
|
"," + "'" + user.getDeptId() + "'" +
|
"," + "'" + user.getCardid() + "'" +
|
"," + "'" + user.getNativeplace() + "'" +
|
"," + "'" + user.getNation() + "'" +
|
"," + "'" + user.getFingerprint() + "'" +
|
"," + "'" + user.getEducation() + "'" +
|
"," + "'" + user.getPoliticaloutlook() + "'" +
|
"," + "'" + user.getHealstats() + "'" +
|
"," + "'" + user.getHeight() + "'" +
|
"," + "'" + user.getAddress() + "'" +
|
"," + "'" + user.getRegistered() + "'" +
|
"," + "'" + user.getSecuritynumber() + "'" +
|
"," + "'" + user.getHold() + "'" +
|
"," + "'" + user.getJurisdiction() + "'" +
|
"," + "'" + user.getExaminationType() + "'" +
|
"," + "'" + user.getStatus() + "'" +
|
"," + "'" + user.getIsDeleted() + "'" +
|
"," + "'" + user.getDispatch() + "'" +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getCreateTime()) + "'" + ")";
|
//拼接
|
builder = builder.append(sql).append(";");
|
List<String> list = Arrays.asList(builder.toString().split(";"));
|
//判断list.size 大小
|
if (list.size()==1000){
|
//执行
|
myAsyncService.FTP(builder.toString());
|
//清空
|
builder.delete(0,builder.length());
|
}
|
}
|
|
//装换成map
|
Map<String, User> userMap = userList.stream().collect(Collectors.toMap(user -> user.getCardid(), user -> user));
|
//匹配
|
experienceList = experienceList.stream().map(experience -> {
|
if (experience.getCardid().equals(userMap.get(experience.getCardid()).getCardid())) {
|
experience.setSecurityid(userMap.get(experience.getCardid()).getId().toString());
|
}
|
return experience;
|
}).collect(Collectors.toList());
|
//批量插入从业记录
|
baseMapper.batchExperienceList(experienceList);
|
//遍历，拼接sql ，同步数据到内网
|
for (Experience experience : experienceList) {
|
String sql1 = "insert into sys_experience(id,name,post,entryTime,cardId,companyname,securityId) " +
|
"values(" + "'" + experience.getId() + "'" + "," +
|
"'" + experience.getName() + "'" + "," +
|
"'" + experience.getPost() + "'" + "," +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(experience.getEntrytime()) + "'" +
|
"," + "'" + experience.getCardid() + "'" +
|
"," + "'" + experience.getCompanyname() + "'" +
|
"," + "'" + experience.getSecurityid() + "'" + ")";
|
//拼接
|
builder1 = builder1.append(sql1).append(";");
|
String[] split1 = builder.toString().split(";");
|
//判断list.size 大小
|
if (split1.length==1000){
|
//执行
|
myAsyncService.FTP(builder1.toString());
|
//清空
|
builder1.delete(0,builder1.length());
|
}
|
}
|
//剩余的继续执行
|
myAsyncService.FTP(builder.toString());
|
myAsyncService.FTP(builder1.toString());
|
}
|
|
//如果所有数据导入有一个异常
|
StringBuilder errorBuilder = new StringBuilder();
|
if (!status.get()){
|
String errorAccount = StringUtils.join(errorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
}
|
if (!agetStatus.get()){
|
String errorAccount = StringUtils.join(ageErrorList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
|
}
|
if (!securityInvalidStatus.get()){
|
String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
|
errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
|
}
|
//抛出异常
|
if (errorBuilder.length()>0){
|
throw new ServiceException(errorBuilder.toString());
|
}
|
}
|
|
@Override
|
public List<Map<String, Object>> selectEquipent() {
|
return baseMapper.selectEquipent();
|
}
|
|
|
/**
|
* 年龄分布查询
|
* @param user
|
* @return
|
*/
|
@Override
|
public Object getAgeStatistics(UserVO user) {
|
//获取年龄分布数据
|
List<Integer> list = baseMapper.getAgeStatistics(user);
|
//返回
|
return list;
|
}
|
|
/**
|
* 查询登录密码还是 123456 的单位信息
|
* @return
|
*/
|
@Override
|
public Object getNotUpdatePwdInfo() {
|
//查询角色为保安公司管理员的用户信息
|
User user = new User();
|
user.setRoleId("1414575196264300546");
|
user.setStatus(1);
|
user.setIsDeleted(0);
|
List<User> list = this.list(Condition.getQueryWrapper(user));
|
List<User> list1 = new ArrayList<>();
|
//遍历
|
if (list.size()>0){
|
byte[] bytes = DigestUtil.decodeHex(list.get(0).getPassword());
|
try {
|
System.out.println("解密的密码 = " + new String(bytes));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
return list;
|
}
|
|
/**
|
* 根据用户 id 查询用户信息
|
* @param id
|
* @return
|
*/
|
@Override
|
public User getUserById(String id) {
|
return baseMapper.getUserById(Long.parseLong(id));
|
}
|
|
/**
|
* 手动新增用户信息
|
* @param user
|
* @return
|
*/
|
@Override
|
public boolean insert(User user) {
|
int i = baseMapper.insertUser(user);
|
if (i>0){
|
return true;
|
}
|
return false;
|
}
|
}
|
