模拟考试修改

Administrator

2022-06-16 8b375fe00a241b3a769b82fe3dac8d1c9dce8a02

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -2,14 +2,23 @@

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.exam.entity.ExamAnswerRecord;
import org.springblade.modules.exam.entity.ExamScore;
import org.springblade.modules.exam.service.ExamAnswerRecordService;
import org.springblade.modules.exam.service.ExamScoreService;
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;
@@ -19,8 +28,10 @@

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;
@@ -41,11 +52,21 @@
   private IUserService userService;

   @Autowired
   private HandlerLogService handlerLogService;

   @Autowired
   private RedisTemplate redisTemplate;


   @Autowired
   private MyAsyncService myAsyncService;


   @Autowired
   private ExamAnswerRecordService examAnswerRecordService;

   @Autowired
   private ExamScoreService examScoreService;

   public void testTask(){
        System.out.println("测试定时任务执行-----------------");
@@ -78,6 +99,7 @@
    */
   public boolean readFile() {
      FTPClient ftp = new FTPClient();
      String fileName = null;
      try {
         //设置传输超时时间为60秒
         ftp.setDataTimeout(10000);
@@ -85,7 +107,7 @@
         ftp.setConnectTimeout(10000);
         //连接
         ftp.connect(ftpHost, ftpPort);
         System.out.println("ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         System.out.println("定时读取内网返回的 sql 文件!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         // 登陆
         ftp.login(ftpUserNameIn, ftpPasswordIn);
         // 检验登陆操作的返回码是否正确
@@ -94,7 +116,8 @@
            return false;
         }

         ftp.enterLocalActiveMode();
         //主动模式
//         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
         ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -105,20 +128,19 @@
         // 检验文件是否存在
         ftp.changeWorkingDirectory(ftpPath);

         // Use passive mode as default
         // 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();
            for (int i = files.length-1; i >=0 ; i--) {
               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 (fileName.contains("nq")) {
//                  InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
               if (substring1.contains("nq")) {
                  //把文件下载到本地
                  long l = System.currentTimeMillis();
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
@@ -156,13 +178,19 @@
               }
            }
            //关闭流
            ftp.completePendingCommand();
            ftp.logout();
//            ftp.completePendingCommand();
//            ftp.logout();
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         //发生异常删除文件，有可能是空文件
         FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
         e.printStackTrace();
      } finally {
         try {
            ftp.logout();
         } catch (IOException e) {
            e.printStackTrace();
         }
         if (ftp.isConnected()) {
            try {
               ftp.disconnect();
@@ -187,7 +215,7 @@
         ftp.setConnectTimeout(10000);
         //连接
         ftp.connect(ftpHost, ftpPort);
         System.out.println("ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         System.out.println("定时任务：处理单个用户新增文件，ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         // 登陆
         ftp.login(ftpUserNameIn, ftpPasswordIn);
         // 检验登陆操作的返回码是否正确
@@ -196,7 +224,7 @@
            return false;
         }

         ftp.enterLocalActiveMode();
//         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
         ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -212,15 +240,17 @@

         FTPFile[] files = ftp.listFiles();
         //文件个数大于10个时开始处理
         if (files.length==0 || files.length<6){
            ftp.logout();
//         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--) {
            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 (fileName.contains("ni")) {
               if (substring.contains("ni")) {
//                  InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
                  //把文件下载到本地
                  long l = System.currentTimeMillis();
@@ -257,13 +287,18 @@
               }
            }
            //关闭流
            ftp.completePendingCommand();
            ftp.logout();
//            ftp.completePendingCommand();
//            ftp.logout();
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         try {
            ftp.logout();
         } catch (IOException e) {
            e.printStackTrace();
         }
         if (ftp.isConnected()) {
            try {
               ftp.disconnect();
@@ -276,7 +311,7 @@
   }

   /**
    * 读取内外推送的保安员单个新增文件
    * 读取内外推送的保安员批量导入文件
    * @return
    */
   public boolean readSecurityListFile() {
@@ -288,7 +323,7 @@
         ftp.setConnectTimeout(10000);
         //连接
         ftp.connect(ftpHost, ftpPort);
         System.out.println("ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         System.out.println("定时任务：读取内外推送的保安员批量导入文件!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         // 登陆
         ftp.login(ftpUserNameIn, ftpPasswordIn);
         // 检验登陆操作的返回码是否正确
@@ -297,7 +332,7 @@
            return false;
         }

         ftp.enterLocalActiveMode();
//         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
         ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -313,41 +348,61 @@

         FTPFile[] files = ftp.listFiles();
         //文件个数大于10个时开始处理
         if (files.length==0 || files.length<10){
            ftp.logout();
         if (files.length==0){

            return false;
         }
         else {
            for (int i = files.length-1; i >0 ; i--) {
            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 (fileName.contains("nl")) {
//                  InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
               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 s = OutJson.TestJson(fileName);
                  //sql语句
                  String sql = OutJson.stringReplace(s);
                  //删除本地服务器文件
                  //数据转换
                  String json = OutJson.TestJson(fileName);
                  //取出map
                  Map<String,Object> 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 服务器文件
//                  ftp.dele(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();
//            ftp.completePendingCommand();
//            ftp.logout();
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         try {
            ftp.logout();
         } catch (IOException e) {
            e.printStackTrace();
         }
         if (ftp.isConnected()) {
            try {
               ftp.disconnect();
@@ -357,6 +412,257 @@
         }
      }
      return false;
   }


   /**
    * 读取内外推送的管理员导入的保安员返回文件（带保安证编号）
    * @return
    */
   public boolean readPaperListFile() {
      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;
         }

         // 设置文件类型为二进制，与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){
            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("np")) {
                  //把文件下载到本地
                  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<String,Object> map = JSON.parseObject(json, Map.class);
                  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 {
                        paperListInfoHandler(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);
               }
            }
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         if (ftp.isConnected()) {
            try {
               ftp.logout();
            } catch (IOException e) {
               e.printStackTrace();
            }
            try {
               ftp.disconnect();
            } catch (IOException e) {
               e.printStackTrace();
            }
         }
      }
      return false;
   }

   /**
    * 用户集合信息处理
    * @param result
    */
   @Async
   public void userListInfoHandler(Result result) {
      //获取 result
      List<Result> 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);
            }
         }
      }
   }

   /**
    * 管理员导入用户集合信息处理
    * @param result
    */
   @Async
   public void paperListInfoHandler(Result result) {
      //获取 result
      List<Result> data1 = result.getData();
      System.out.println("批量导入数据 = " + data1);
      if (data1.size()>0){
         for (Result result1 : data1) {
            // 取出 Msg ,此 msg 存的对应的 uuid
            String[] split = result1.getMsg().split(",");
            String uuid = split[0];
            //从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());
               user.setSecuritynumber(split[1]);
               user.setHold("1");
               user.setExaminationType("0");
               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()==205){
               //审查异常
               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);
            }
         }
      }
   }

   /**
@@ -372,7 +678,7 @@
         ftp.setConnectTimeout(10000);
         //连接
         ftp.connect(ftpHost, ftpPort);
         System.out.println("ftp 连接成功!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         System.out.println("读取内外推送的保安员报名信息!"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
         // 登陆
         ftp.login(ftpUserNameIn, ftpPasswordIn);
         // 检验登陆操作的返回码是否正确
@@ -381,7 +687,7 @@
            return false;
         }

         ftp.enterLocalActiveMode();
//         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
         ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -390,47 +696,64 @@
         ftp.setControlEncoding("GBK");

         // 检验文件是否存在
         ftp.changeWorkingDirectory(ftpPath);
//         ftp.changeWorkingDirectory(ftpPath);

         // Use passive mode as default
         ftp.enterLocalPassiveMode();

         FTPFile[] files = ftp.listFiles();
         //文件个数大于10个时开始处理
         if (files.length==0 || files.length<10){
            ftp.logout();
         if (files.length==0){
//            ftp.logout();
            return false;
         }
         else {
            for (int i = files.length-1; i >0 ; i--) {
            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 (fileName.contains("nt")) {
               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 s = OutJson.TestJson(fileName);
                  //sql语句
                  String sql = OutJson.stringReplace(s);
                  //删除本地服务器文件
                  //数据转换
                  String json = OutJson.TestJson(fileName);
                  //取出map
                  Map<String,Object> 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 服务器文件
//                  ftp.dele(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();
//            ftp.completePendingCommand();
//            ftp.logout();
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         try {
            ftp.logout();
         } catch (IOException e) {
            e.printStackTrace();
         }
         if (ftp.isConnected()) {
            try {
               ftp.disconnect();
@@ -443,26 +766,132 @@
   }

   /**
    *  用户审查
    * @return
    * 报名信息处理
    * @param result
    */
   public void userExamine() {
      //查询审查状态为未审查的保安员
      User user = new User();
      user.setStatus(1);
      user.setIsDeleted(0);
      user.setRoleId("1412226235153731586");
      //未审查
      user.setExaminationType("2");
      //查询
      List<User> users = userService.list(new QueryWrapper<>(user));
      //遍历
      if (users.size()>0){
         users.forEach(user1 -> {
            myAsyncService.userExamineFTP(user1);
         });
   @Async
   public void applyHandler(String uuid,Result result) {
      //取出培训学校id
      //从redis 中获取用户数据
      String s = redisTemplate.opsForValue().get(uuid).toString();
      //删除
      redisTemplate.delete(uuid);
      if (null!=s && !s.equals("")) {
         //创建集合，存年龄符合要求
         List<String> ageList = new ArrayList<>();
         //创建年龄不符合集合
         List<User> errorList = new ArrayList<>();
         AtomicInteger number = new AtomicInteger();
         if (null != result) {
            //获取 result
            List<Result> 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<String> 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);
   }





@@ -473,6 +902,9 @@
    */
   @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) {
@@ -510,6 +942,8 @@
            }
         } else if (result.getCode() == 203) {
            //保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 用户为新增
            users.setHold("2");
            users.setSecuritynumber("");
            //新增
            users.setId(result.getUserId());
            //插入数据库
@@ -518,8 +952,19 @@
               //异步同步到群防群控
               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());
@@ -540,6 +985,90 @@
                  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<User> users = userService.list(new QueryWrapper<>(user));
      //遍历
      if (users.size()>0){
         users.forEach(user1 -> {
            myAsyncService.userExamineFTP(user1);
         });
      }
   }

   /**
    * 考试成绩同步
    * @return
    */
   public void examScoreSync() {
      System.out.println("考试成绩同步"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
      //查询当天的考试成绩
      List<ExamScore> examScoreList = examScoreService.getExamScoreList();
      if (examScoreList.size()>0) {
         //遍历计算成绩
         for (ExamScore examScore : examScoreList) {
            ExamAnswerRecord record = new ExamAnswerRecord();
            record.setScoreId(examScore.getId());
            List<ExamAnswerRecord> list = examAnswerRecordService.list(new QueryWrapper<>(record));
            if (list.size()>0){
               int num = 0;
               for (ExamAnswerRecord examAnswerRecord : list) {
                  num = num + examAnswerRecord.getAnswerScore();
                  examScore.setExamEndTime(examAnswerRecord.getAnswerTime());
               }
               examScore.setTheoryGrade(num);
               examScore.setAllGrade(Math.round(num/2));
               //设置状态
               if (num >= 60) {
                  examScore.setQualified(2);
               } else {
                  examScore.setQualified(1);
               }
               String s1 =
                  "update exam_score set exam_id = " + examScore.getExamId() +
                     ",theory_grade = " + "'" + examScore.getTheoryGrade() + "'" +
                     ",all_grade = " + "'" + examScore.getAllGrade() + "'" +
                     ",exam_end_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:dd").format(examScore.getExamEndTime()) + "'" +
                     ",qualified = " + "'" + examScore.getQualified() + "'" +
                     " " + "where id = " + "'" + examScore.getId() + "'";
               myAsyncService.FTP(s1);
            }
         }
      }
   }