package org.springblade.modules.quartz.task; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.apache.commons.lang3.StringUtils; import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; import org.springblade.common.utils.DesensitizedUtil; import org.springblade.modules.FTP.*; import org.springblade.modules.log.entity.HandlerLog; import org.springblade.modules.log.service.HandlerLogService; import org.springblade.modules.system.entity.User; import org.springblade.modules.system.service.IUserService; import org.springblade.modules.system.service.MyAsyncService; import org.springblade.modules.training.entity.TrainingRegistration; import org.springblade.modules.training.service.TrainingRegistrationService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; import java.io.IOException; import java.io.InputStream; import java.lang.reflect.Array; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.atomic.AtomicInteger; import static org.springblade.common.config.FtpConfig.*; import static org.springblade.common.config.FtpConfig.ftpPath; import static org.springblade.modules.FTP.DataHandler.handlerUserInfo; /** * 定时任务 * @author zhongrj * @since 2022-03-10 */ @Component("task") public class Task { @Autowired private TrainingRegistrationService trainingRegistrationService; @Autowired private IUserService userService; @Autowired private HandlerLogService handlerLogService; @Autowired private RedisTemplate redisTemplate; @Autowired private MyAsyncService myAsyncService; public void testTask(){ System.out.println("测试定时任务执行-----------------"); } /** * 定时任务，每天凌晨1点执行一次， * 自动处理之前报了名，申请了考试又没有去考试的，做缺考标记，并将报名状态修改为已取消报名 */ // @Scheduled(cron = "0 0 23 * * ?") public void examApplyStatus(){ System.out.println("定时任务1：执行时间："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); //自动处理之前报了名，申请了考试又没有去考试的，做缺考标记，并将报名状态修改为已取消报名 trainingRegistrationService.examApplyStatus(); } /** * 定时任务，处理考试中的人员 */ // @Scheduled(cron = "0 0 22 * * ?") public void examLoading(){ System.out.println("定时任务2：执行时间："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); //自动处理之前报了名，考试忘记提交或者中断考试的 trainingRegistrationService.examLoading(); } /** * 读取内外推送的sql文件 * @return */ public boolean readFile() { FTPClient ftp = new FTPClient(); try { //设置传输超时时间为60秒 ftp.setDataTimeout(10000); //连接超时为60秒 ftp.setConnectTimeout(10000); //连接 ftp.connect(ftpHost, ftpPort); System.out.println("定时读取内网返回的 sql 文件!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 登陆 ftp.login(ftpUserNameIn, ftpPasswordIn); // 检验登陆操作的返回码是否正确 if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { ftp.disconnect(); return false; } ftp.enterLocalActiveMode(); // 设置文件类型为二进制，与ASCII有区别 ftp.setFileType(FTP.BINARY_FILE_TYPE); // 设置编码格式 ftp.setControlEncoding("GBK"); // 检验文件是否存在 ftp.changeWorkingDirectory(ftpPath); // Use passive mode as default ftp.enterLocalPassiveMode(); FTPFile[] files = ftp.listFiles(); if (files.length==0){ ftp.logout(); return false; } else { for (int i = files.length-1; i >=0 ; i--) { String fileName = files[i].getName(); String substring1 = fileName.substring(0, 2); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName); if (substring1.contains("nq")) { //把文件下载到本地 long l = System.currentTimeMillis(); FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); long x = System.currentTimeMillis(); System.out.println("下载文件耗时 = " + (x-l)+" 毫秒"); // String s = OutJson.TestJson(fileName); //sql语句 String sql = OutJson.stringReplace(s); //以逗号分割 String[] split = sql.split(";"); for (String sqls : split) { //判断是否是新增，删除，修改 String substring = sqls.substring(0, 2); //新增 if (substring.equals("in")) { //运行sql语句 MysqlCenlint.inster(sqls); } //修改 else if (substring.equals("up")) { MysqlCenlint.update(sqls); } //删除 else { MysqlCenlint.delete(sqls); } } //删除本地服务器文件 MysqlCenlint.deletess(fileName); //删除 ftp 服务器文件 // ftp.dele(fileName); FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName); } } //关闭流 ftp.completePendingCommand(); ftp.logout(); } } catch (Exception e) { System.out.println("ftp连接失败"); e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException e) { e.printStackTrace(); } } } return false; } /** * 读取内外推送的保安员单个新增文件 * @return */ public boolean readOneSecurityFile() { FTPClient ftp = new FTPClient(); try { //设置传输超时时间为60秒 ftp.setDataTimeout(10000); //连接超时为60秒 ftp.setConnectTimeout(10000); //连接 ftp.connect(ftpHost, ftpPort); System.out.println("定时任务：处理单个用户新增文件，ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 登陆 ftp.login(ftpUserNameIn, ftpPasswordIn); // 检验登陆操作的返回码是否正确 if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { ftp.disconnect(); return false; } ftp.enterLocalActiveMode(); // 设置文件类型为二进制，与ASCII有区别 ftp.setFileType(FTP.BINARY_FILE_TYPE); // 设置编码格式 ftp.setControlEncoding("GBK"); // 检验文件是否存在 ftp.changeWorkingDirectory(ftpPath); // Use passive mode as default ftp.enterLocalPassiveMode(); FTPFile[] files = ftp.listFiles(); //文件个数大于10个时开始处理 // if (files.length==0 || files.length<10){ if (files.length==0){ ftp.logout(); return false; } else { for (int i = files.length-1; i >=0 ; i--) { String fileName = files[i].getName(); String substring = fileName.substring(0, 2); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName); if (substring.contains("ni")) { // InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING)); //把文件下载到本地 long l = System.currentTimeMillis(); FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); long x = System.currentTimeMillis(); System.out.println("下载文件耗时 = " + (x-l)+" 毫秒"); //数据转换 String json = OutJson.TestJson(fileName); //取出map Map map = JSON.parseObject(json, Map.class); //取出 key/uuid,取出结果 String uuid = null; Result result = new Result(); for (Map.Entry entry : map.entrySet()) { uuid = entry.getKey().toString(); Object value = entry.getValue(); //转换 result = JSON.parseObject(value.toString(), Result.class); } //删除本地文件 MysqlCenlint.deletess(fileName); //删除 ftp 文件 FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName); if (null!=result) { try { userInfoHandler(uuid, result); }catch (Exception e) { //异步用户处理逻辑 e.printStackTrace(); } } } } //关闭流 ftp.completePendingCommand(); ftp.logout(); } } catch (Exception e) { System.out.println("ftp连接失败"); e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException e) { e.printStackTrace(); } } } return false; } /** * 读取内外推送的保安员批量导入文件 * @return */ public boolean readSecurityListFile() { FTPClient ftp = new FTPClient(); try { //设置传输超时时间为60秒 ftp.setDataTimeout(10000); //连接超时为60秒 ftp.setConnectTimeout(10000); //连接 ftp.connect(ftpHost, ftpPort); System.out.println("定时任务：读取内外推送的保安员批量导入文件!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 登陆 ftp.login(ftpUserNameIn, ftpPasswordIn); // 检验登陆操作的返回码是否正确 if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { ftp.disconnect(); return false; } ftp.enterLocalActiveMode(); // 设置文件类型为二进制，与ASCII有区别 ftp.setFileType(FTP.BINARY_FILE_TYPE); // 设置编码格式 ftp.setControlEncoding("GBK"); // 检验文件是否存在 ftp.changeWorkingDirectory(ftpPath); // Use passive mode as default ftp.enterLocalPassiveMode(); FTPFile[] files = ftp.listFiles(); //文件个数大于10个时开始处理 if (files.length==0){ ftp.logout(); return false; } else { for (int i = files.length-1; i >=0 ; i--) { String fileName = files[i].getName(); String substring = fileName.substring(0, 2); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName); if (substring.contains("nl")) { //把文件下载到本地 long l = System.currentTimeMillis(); FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); long x = System.currentTimeMillis(); System.out.println("下载文件耗时 = " + (x-l)+" 毫秒"); //数据转换 String json = OutJson.TestJson(fileName); //取出map Map map = JSON.parseObject(json, Map.class); //取出 key/uuid,取出结果 String uuid = null; Result result = new Result(); for (Map.Entry entry : map.entrySet()) { Object value = entry.getValue(); //转换 result = JSON.parseObject(value.toString(), Result.class); } if (null!=result) { try { userListInfoHandler(result); }catch (Exception e) { //异步用户处理逻辑 e.printStackTrace(); } } //删除本地文件 MysqlCenlint.deletess(fileName); //删除 ftp 文件 FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName); } } //关闭流 ftp.completePendingCommand(); ftp.logout(); } } catch (Exception e) { System.out.println("ftp连接失败"); e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException e) { e.printStackTrace(); } } } return false; } /** * 用户集合信息处理 * @param result */ private void userListInfoHandler(Result result) { //获取 result List data1 = result.getData(); System.out.println("批量导入数据 = " + data1); 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 = userService.save(user); if (save){ //数据异步同步到群防群控 myAsyncService.qfqkUserSave(user); } } //更新 if (result1.getCode()==201){ //先查询当前库是否有改用户？ User user1 = userService.getById(result1.getUserId()); if (null!=user1) { //存在，更新 user.setId(result1.getUserId()); user.setCreateTime(null); boolean update = userService.updateById(user); if (update) { //数据异步同步到群防群控 myAsyncService.updateUserByQfqk(user); } }else { //不存在，则新增 user.setId(result1.getUserId()); boolean save = userService.save(user); if (save){ //数据异步同步到群防群控 myAsyncService.qfqkUserSave(user); } } } if (result1.getCode()==202){ //已在其他单位存在 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(user.getDeptId()); handlerLog.setOperatorTime(user.getCreateTime()); handlerLog.setRemark("用户["+DesensitizedUtil.desensitizedIdNumberBy4(user0.getCardid())+"]已在其他单位存在"); handlerLog.setType(2); //插入记录 handlerLogService.save(handlerLog); } if (result1.getCode()==203){ //保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 内网用户已存在情况 user.setHold("2"); user.setSecuritynumber(""); user.setId(result1.getUserId()); //先查询当前库是否有改用户？ User user2 = userService.getById(result1.getUserId()); //判断 if (null != user2) { //修改 //数据修改 boolean b = userService.updateById(user); if (b) { //异步同步到群防群控 myAsyncService.updateUserByQfqk(user); } } else { //新增 boolean save = userService.save(user); if (save) { //异步同步到群防群控 myAsyncService.qfqkUserSave(user); } } //保安证编号不匹配 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(user.getDeptId()); handlerLog.setOperatorTime(user.getCreateTime()); handlerLog.setRemark("用户["+DesensitizedUtil.desensitizedIdNumberBy4(user0.getCardid())+"]保安证编号不匹配,请核实!"); handlerLog.setType(2); //插入记录 handlerLogService.save(handlerLog); } } } } /** * 读取内外推送的保安员报名信息 * @return */ public boolean readSecurityApplyFile() { FTPClient ftp = new FTPClient(); try { //设置传输超时时间为60秒 ftp.setDataTimeout(10000); //连接超时为60秒 ftp.setConnectTimeout(10000); //连接 ftp.connect(ftpHost, ftpPort); System.out.println("读取内外推送的保安员报名信息!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 登陆 ftp.login(ftpUserNameIn, ftpPasswordIn); // 检验登陆操作的返回码是否正确 if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { ftp.disconnect(); return false; } ftp.enterLocalActiveMode(); // 设置文件类型为二进制，与ASCII有区别 ftp.setFileType(FTP.BINARY_FILE_TYPE); // 设置编码格式 ftp.setControlEncoding("GBK"); // 检验文件是否存在 ftp.changeWorkingDirectory(ftpPath); // Use passive mode as default ftp.enterLocalPassiveMode(); FTPFile[] files = ftp.listFiles(); //文件个数大于10个时开始处理 if (files.length==0){ ftp.logout(); return false; } else { for (int i = files.length-1; i >=0 ; i--) { String fileName = files[i].getName(); String substring = fileName.substring(0, 2); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName); if (substring.contains("nt")) { //把文件下载到本地 long l = System.currentTimeMillis(); FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); long x = System.currentTimeMillis(); System.out.println("下载文件耗时 = " + (x-l)+" 毫秒"); //数据转换 String json = OutJson.TestJson(fileName); //取出map Map map = JSON.parseObject(json, Map.class); //取出 key/uuid,取出结果 String uuid = null; Result result = new Result(); for (Map.Entry entry : map.entrySet()) { uuid = entry.getKey().toString(); Object value = entry.getValue(); //转换 result = JSON.parseObject(value.toString(), Result.class); } if (null!=result) { applyHandler(uuid,result); } //删除本地文件 MysqlCenlint.deletess(fileName); //删除 ftp 文件 FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName); } } //关闭流 ftp.completePendingCommand(); ftp.logout(); } } catch (Exception e) { System.out.println("ftp连接失败"); e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException e) { e.printStackTrace(); } } } return false; } /** * 报名信息处理 * @param result */ private void applyHandler(String uuid,Result result) { //取出培训学校id //从redis 中获取用户数据 String s = redisTemplate.opsForValue().get(uuid).toString(); //删除 redisTemplate.delete(uuid); if (null!=s && !s.equals("")) { //创建集合，存年龄符合要求 List ageList = new ArrayList<>(); //创建年龄不符合集合 List errorList = new ArrayList<>(); AtomicInteger number = new AtomicInteger(); if (null != result) { //获取 result List data1 = result.getData(); if (data1.size() > 0) { for (Result result1 : data1) { // 取出 Msg ,此 msg 存的对应的 uuid Long userId = result1.getUserId(); if (result1.getCode() == 200) { //加入新增集合 ageList.add(userId.toString()); } //年龄不符合要求 if (result1.getCode() == 201) { //number ++ number.getAndIncrement(); //查询用户信息 User user = userService.getById(userId); //加入更新集合 errorList.add(user); } } } } if (ageList.size() > 0) { //遍历 ageList.forEach(userId -> { User user = userService.getUserById(userId); //未报名的新增，已报名的不做处理 if (null == user.getIsTrain()) { TrainingRegistration trainingRegistration1 = new TrainingRegistration(); trainingRegistration1.setCancel(1); //默认为未考试状态 trainingRegistration1.setIsExam(1); //未提交考试审核 trainingRegistration1.setAuditStatus(4); trainingRegistration1.setTrainingTime(new Date()); trainingRegistration1.setUserId(userId); trainingRegistration1.setTrainingUnitId(s); trainingRegistrationService.save(trainingRegistration1); //修改保安报名状态 user.setIsTrain(1); userService.updateById(user); //数据同步 saveTrainingRegistration(trainingRegistration1, user); } else { if (user.getIsTrain() != 1) { TrainingRegistration trainingRegistration1 = new TrainingRegistration(); trainingRegistration1.setCancel(1); //默认为未考试状态 trainingRegistration1.setIsExam(1); //未提交考试审核 trainingRegistration1.setAuditStatus(4); trainingRegistration1.setTrainingTime(new Date()); trainingRegistration1.setUserId(userId); trainingRegistration1.setTrainingUnitId(s); trainingRegistrationService.save(trainingRegistration1); //修改保安报名状态 user.setIsTrain(1); userService.updateById(user); //数据同步 saveTrainingRegistration(trainingRegistration1, user); } } }); } //如果存在年龄不符的，则抛出异常 if (number.get()>0){ String deptId = errorList.get(0).getDeptId(); List arrayList = new ArrayList<>(); errorList.forEach(user -> { arrayList.add(user.getAccount()); }); //已在其他单位存在 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(deptId); handlerLog.setOperatorTime(new Date()); handlerLog.setType(3); String errorAccount = StringUtils.join(arrayList, "\\\n"); handlerLog.setRemark("保安员:[" + errorAccount + "]报名失败!年龄不符,报名年龄为[18-60]周岁!"); //插入记录 handlerLogService.save(handlerLog); } } } /** * 报名 */ private void saveTrainingRegistration(TrainingRegistration trainingRegistration,User user1){ String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); Long id = trainingRegistration.getId(); String sql = "insert into sys_training_registration(id,training_unit_id,training_time,cancel,user_id,is_exam,audit_status) " + "values(" + "'" + id + "'" + "," + "'" + trainingRegistration.getTrainingUnitId() +"'" + "," + "'" + formatStr +"'" + "," + "'" + trainingRegistration.getCancel() + "'" + "," + "'" + trainingRegistration.getUserId() + "'" + "," + "'" + trainingRegistration.getIsExam() + "'" + "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" + "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'"; myAsyncService.FTP(sql); } /** * 用户信息处理 * @param uuid * @param result */ @Async public void userInfoHandler(String uuid, Result result){ //从redis 中获取用户数据 Object o1 = redisTemplate.opsForValue().get(uuid); User user0 = JSON.parseObject(o1.toString(), User.class); //用户数处理 User users = handlerUserInfo(uuid); if (null!=users) { System.out.println("用户数据 = " + users); //判断结果 if (result.getCode() == 200) { //新增 users.setId(result.getUserId()); users.setStatus(1); //插入数据库 boolean save = userService.save(users); if (save) { //异步同步到群防群控 myAsyncService.qfqkUserSave(users); } } else if (result.getCode() == 201) { //修改 users.setId(result.getUserId()); //先查询当前库是否有改用户？ User user2 = userService.getById(result.getUserId()); if (null != user2) { //数据修改 boolean b = userService.updateById(users); if (b) { //异步同步到群防群控 myAsyncService.updateUserByQfqk(users); } } else { //新增 boolean save = userService.save(users); if (save) { //异步同步到群防群控 myAsyncService.qfqkUserSave(users); } } } else if (result.getCode() == 203) { //保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 用户为新增 users.setHold("2"); users.setSecuritynumber(""); //新增 users.setId(result.getUserId()); //插入数据库 boolean save = userService.save(users); if (save) { //异步同步到群防群控 myAsyncService.qfqkUserSave(users); } //保安证编号不匹配 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(user0.getDeptId()); handlerLog.setOperatorTime(user0.getCreateTime()); handlerLog.setRemark("用户["+DesensitizedUtil.desensitizedIdNumberBy4(user0.getCardid())+"]保安证编号不匹配,请核实!"); handlerLog.setType(1); //插入记录 handlerLogService.save(handlerLog); } else if (result.getCode() == 204) { //保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 内网用户已存在情况 users.setHold("2"); users.setSecuritynumber(""); users.setId(result.getUserId()); //先查询当前库是否有改用户？ User user2 = userService.getById(result.getUserId()); //判断 if (null != user2) { //修改 //数据修改 boolean b = userService.updateById(users); if (b) { //异步同步到群防群控 myAsyncService.updateUserByQfqk(users); } } else { //新增 boolean save = userService.save(users); if (save) { //异步同步到群防群控 myAsyncService.qfqkUserSave(users); } } //保安证编号不匹配 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(user0.getDeptId()); handlerLog.setOperatorTime(user0.getCreateTime()); handlerLog.setRemark("用户["+DesensitizedUtil.desensitizedIdNumberBy4(user0.getCardid())+"]保安证编号不匹配,请核实!"); handlerLog.setType(1); //插入记录 handlerLogService.save(handlerLog); }else { //已在其他单位存在 HandlerLog handlerLog = new HandlerLog(); handlerLog.setCreateTime(new Date()); handlerLog.setDeptId(user0.getDeptId()); handlerLog.setOperatorTime(user0.getCreateTime()); handlerLog.setRemark("用户["+DesensitizedUtil.desensitizedIdNumberBy4(user0.getCardid())+"]已在其他单位存在"); handlerLog.setType(1); //插入记录 handlerLogService.save(handlerLog); } } } /** * 用户审查 * @return */ public void userExamine() { System.out.println("用户审查任务发起"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); //查询审查状态为未审查的保安员 User user = new User(); user.setStatus(1); user.setIsDeleted(0); user.setRoleId("1412226235153731586"); //未审查 user.setExaminationType("2"); //查询 List users = userService.list(new QueryWrapper<>(user)); //遍历 if (users.size()>0){ users.forEach(user1 -> { myAsyncService.userExamineFTP(user1); }); } } }