package org.springblade.modules.quartz.task;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
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.modules.FTP.*;
|
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.service.TrainingRegistrationService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
import static org.springblade.common.config.FtpConfig.*;
|
import static org.springblade.common.config.FtpConfig.ftpPath;
|
|
/**
|
* 定时任务
|
* @author zhongrj
|
* @since 2022-03-10
|
*/
|
@Component("task")
|
public class Task {
|
|
@Autowired
|
private TrainingRegistrationService trainingRegistrationService;
|
|
@Autowired
|
private IUserService userService;
|
|
|
@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();
|
}
|
|
/**
|
* 读取内外推送的文件,每30秒读取一次
|
* @return
|
*/
|
// @Scheduled(cron = "*/30 * * * * ?")
|
public boolean readFile() {
|
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();
|
if (files.length==0){
|
ftp.logout();
|
return false;
|
}
|
else {
|
for (FTPFile file : files) {
|
String fileName = file.getName();
|
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));
|
//把文件下载到本地
|
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 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);
|
});
|
}
|
}
|
|
}
|
