zhba/zhba_management_w.git

			@@ -17,45 +17,69 @@
			package org.springblade.modules.system.service.impl;


			import com.baomidou.mybatisplus.core.conditions.Wrapper;
			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.springblade.common.cache.DictCache;
			import org.springblade.common.cache.ParamCache;
			import org.apache.commons.lang3.StringUtils;
			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.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.dto.UserDTO;
			import org.springblade.modules.system.entity.*;
			import org.springblade.modules.system.excel.UserExcel;
			import org.springblade.modules.system.excel.*;
			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.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 static org.springblade.common.constant.CommonConstant.DEFAULT_PARAM_PASSWORD;
			import java.util.concurrent.atomic.AtomicBoolean;
			import java.util.concurrent.atomic.AtomicInteger;
			import java.util.stream.Collectors;

			/**
			* 服务实现类
			@@ -71,6 +95,13 @@
			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)
			@@ -96,25 +127,51 @@
			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()));
			// }
			return save(user) && submitUserDept(user);
			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()));
			}
			// 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);
			}

			@@ -138,15 +195,110 @@
			}

			@Override
			public IPage<UserVO> selectUserPages(IPage<UserVO> page, UserVO user, Long deptId, String tenantId) {
			List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
			return page.setRecords(baseMapper.selectUserPages(page, user, deptIdList, tenantId));
			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<User> selectUserPage(IPage<User> page, User user, Long deptId, String tenantId) {
			public IPage<UserVO> selectUserPage(IPage<UserVO> page, User user, Long deptId, String tenantId) {
			List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
			return page.setRecords(baseMapper.selectUserPage(page, user, deptIdList, tenantId));
			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
			@@ -196,8 +348,12 @@

			@Override
			public UserInfo userInfo(String tenantId, String account, String password, UserEnum userEnum) {
			User user = baseMapper.getUser(tenantId, account, password);
			return buildUserInfo(user, userEnum);
			try {
			User user = baseMapper.getUser(tenantId, account, password);
			return buildUserInfo(user, userEnum);
			}catch (Exception e){
			throw new ServiceException("账号["+account+"]"+"重复!");
			}
			}

			private UserInfo buildUserInfo(User user) {
			@@ -276,7 +432,25 @@
			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)));
			boolean update = this.update(user, Wrappers.<User>update().lambda().in(User::getId, Func.toLongList(userIds)));
			if (update){
			//如果是保安员同步群防群控
			List<String> list = Arrays.asList(userIds.split(","));
			for (String s : list) {
			User user1 = getById(userIds);
			UserDTO userDTO = new UserDTO();
			userDTO.setAccount(user1.getAccount());
			userDTO.setPassword(user1.getPassword());
			userDTO.setSecurityId(user1.getId().toString());
			userDTO.setPhone(user1.getPhone());
			userDTO.setRealName(user1.getRealName());
			userDTO.setCardid(user1.getCardid());
			userDTO.setSex(user1.getSex());
			//异步修改群防群控
			myAsyncService.updateUserByAccount(userDTO);
			}
			}
			return update;
			}

			@Override
			@@ -299,36 +473,158 @@
			return deleteLogic(Func.toLongList(userIds));
			}

			/**
			* 用户民警的导入
			* @param data
			* @param isCovered
			* @param deptId
			*/
			@Override
			@Transactional(rollbackFor = Exception.class)
			public void importUser(List<UserExcel> data, Boolean isCovered) {
			// @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
			if (!AuthUtil.isAdministrator() \|\| StringUtil.isBlank(user.getTenantId())) {
			user.setTenantId(AuthUtil.getTenantId());
			}
			if (null != userExcel.getStatus() && userExcel.getStatus() != "") {
			if (userExcel.getStatus().equals("在职")) {
			user.setStatus(1);
			} else {
			user.setStatus(2);
			//设置部门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 (userExcel.getSex().equals("男性")) {
			user.setSex(1);
			} else {
			user.setSex(2);
			}
			user.setRoleId("1412226235153731586");
			String deptname = user.getDeptId();
			String id = userDeptService.selectIn(deptname);
			user.setDeptId(id);
			//获取默认密码配置
			String initPassword = ParamCache.getValue(DEFAULT_PARAM_PASSWORD);
			user.setPassword(initPassword);
			this.submit(user);
			});
			//如果所有数据导入有一个异常
			if (!status.get()){
			String errorAccount = StringUtils.join(errorList, "\\\n");
			throw new ServiceException("用户:["+errorAccount+"]导入失败!已在其他单位存在!");
			}
			}

			// @Override
			@@ -445,7 +741,7 @@
			*/
			@Override
			public List<User> selectUserPageSecurityUnit(IPage<User> page, User user) {
			return baseMapper.selectUserPageSecurity(page, user);
			return baseMapper.selectUserPageSecurity(null, user);
			}


			@@ -483,6 +779,44 @@
			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);
			@@ -501,6 +835,7 @@

			/**
			* 查询当前公司未持证保安没有报名的人员
			*
			* @param deptId
			* @return
			*/
			@@ -511,6 +846,7 @@

			/**
			* 计算保安人员年龄
			*
			* @param userId
			* @return
			*/
			@@ -518,4 +854,1866 @@
			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) {
			//年龄不符的保安员信息存入集合
			List<String> ageErrorList = new ArrayList<>();
			//需要推送内网的保安员信息集合
			List<User> userList = new ArrayList<>();
			AtomicBoolean agetStatus = 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)) {
			if(!deptId.equals("1123598813738675201")) {
			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()+" ]不正确,请核对!");
			continue;
			}
			}

			// 设置租户ID
			user.setTenantId("000000");
			//默认在职
			user.setStatus(1);
			user.setIsDeleted(0);
			//分配保安角色
			user.setRoleId("1412226235153731586");

			if (null!=user.getSecuritynumber() && !user.getSecuritynumber().equals("")){
			user.setHold("1");
			}else {
			user.setHold("2");
			}

			//性别
			if (IdCardNoUtil.getSex(userExcel.getCardid()).equals("男")) {
			user.setSex(1);
			}else {
			user.setSex(2);
			}

			//设置账号
			String realName = user.getRealName();
			String cardid = user.getCardid();
			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);
			}

			//用户批量插入
			if (userList.size()>0) {
			//生成随机数
			String uuid = UUID.randomUUID().toString();
			//数据推送
			Map<String, Object> map = new HashMap<>(1);
			map.put(uuid, userList);
			myAsyncService.FTPObjectList(map);
			}

			// 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 user1 = this.getById(result1.getUserId());
			// if (null!=user1) {
			// //存在，更新
			// user.setId(result1.getUserId());
			// user.setCreateTime(null);
			// boolean update = this.updateById(user);
			// if (update) {
			// //数据异步同步到群防群控
			// myAsyncService.updateUserByQfqk(user);
			// }
			// }else {
			// //不存在，则新增
			// user.setId(result1.getUserId());
			// boolean save = this.save(user);
			// if (save){
			// //数据异步同步到群防群控
			// myAsyncService.qfqkUserSave(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(4000);
			// } catch (InterruptedException e) {
			// e.printStackTrace();
			// }
			// //调用ftp获取返回数据
			// result = Monitor.getFtpDataByUuidList(uuid);
			// //如果返回true,就退处
			// if (result.getCode() == 200) {
			// break;
			// }
			// else {
			// count++;
			// if (count == 20) {
			// 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 user1 = this.getById(result1.getUserId());
			// if (null!=user1) {
			// //存在，更新
			// user.setId(result1.getUserId());
			// user.setCreateTime(null);
			// boolean update = this.updateById(user);
			// if (update) {
			// //数据异步同步到群防群控
			// myAsyncService.updateUserByQfqk(user);
			// }
			// }else {
			// //不存在，则新增
			// user.setId(result1.getUserId());
			// boolean save = this.save(user);
			// if (save){
			// //数据异步同步到群防群控
			// myAsyncService.qfqkUserSave(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<ExportSecurityExcel> 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;
			}
			}