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.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;
|
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;
|
|
|
@Autowired
|
private ExamAnswerRecordService examAnswerRecordService;
|
|
@Autowired
|
private ExamScoreService examScoreService;
|
|
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){
|
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 {
|
try {
|
ftp.logout();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
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<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);
|
}
|
//删除本地文件
|
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 {
|
try {
|
ftp.logout();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
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){
|
|
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<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 文件
|
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 {
|
try {
|
ftp.logout();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
if (ftp.isConnected()) {
|
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);
|
}
|
}
|
}
|
}
|
|
/**
|
* 读取内外推送的保安员报名信息
|
* @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<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 文件
|
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 {
|
try {
|
ftp.logout();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
if (ftp.isConnected()) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return false;
|
}
|
|
// /**
|
// * 读取内外推送的实操成绩导入情况信息
|
// * @return
|
// */
|
// public boolean readExamScoreFile() {
|
// 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("ne")) {
|
// //把文件下载到本地
|
// 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);
|
// //取出 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) {
|
// examScoreHandler(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 {
|
// try {
|
// ftp.logout();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// if (ftp.isConnected()) {
|
// try {
|
// ftp.disconnect();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// }
|
// }
|
// return false;
|
// }
|
|
// /**
|
// * 实操成绩导入修改
|
// * @param result
|
// */
|
// private void examScoreHandler(Result result) {
|
// //导入的人员不存在
|
// HandlerLog handlerLog = new HandlerLog();
|
// handlerLog.setCreateTime(new Date());
|
// handlerLog.setDeptId(deptId);
|
// handlerLog.setOperatorTime(new Date());
|
// handlerLog.setType(4);
|
// handlerLog.setRemark(result.getMsg());
|
// //插入记录
|
// handlerLogService.save(handlerLog);
|
// }
|
|
/**
|
* 报名信息处理
|
* @param result
|
*/
|
@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);
|
}
|
|
|
|
|
|
/**
|
* 用户信息处理
|
* @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<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);
|
}
|
}
|
}
|
}
|
|
|
}
|
