package org.springblade.modules.quartz.task;
|
|
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.DataHanlder;
|
import org.springblade.modules.FTP.FtpUtil;
|
import org.springblade.modules.FTP.MysqlCenlint;
|
import org.springblade.modules.FTP.OutJson;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
import static org.springblade.common.config.FtpConfig.*;
|
|
/**
|
* 定时任务
|
* @author zhongrj
|
* @since 2022-03-10
|
*/
|
@Component("task")
|
public class Task {
|
|
/**
|
* 定时任务
|
* @return
|
*/
|
public boolean readFile() {
|
|
FTPClient ftp = new FTPClient();
|
String fileName = null;
|
try {
|
//设置超时时间
|
ftp.setDataTimeout(60000);
|
//连接超时为60秒
|
ftp.setConnectTimeout(60000);
|
|
ftp.connect(ftpHost, ftpPort);
|
|
// 登陆
|
ftp.login(ftpUserName, ftpPassword);
|
|
// 检验登陆操作的返回码是否正确
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
ftp.disconnect();
|
return false;
|
}
|
|
System.out.println("ftp 连接成功!时间: "+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
//被动模式，文件上传不成功会有提示
|
ftp.enterLocalActiveMode();
|
|
// 设置文件类型为二进制，与ASCII有区别
|
ftp.setFileType(FTP.BINARY_FILE_TYPE);
|
|
// 设置编码格式
|
ftp.setControlEncoding("GBK");
|
|
// 检验文件是否存在
|
ftp.changeWorkingDirectory(ftpPath);
|
FTPFile[] files = ftp.listFiles();
|
if (files.length == 0) {
|
ftp.disconnect();
|
} else {
|
for (FTPFile file : files) {
|
fileName = file.getName();
|
String substring1 = fileName.substring(0, 1);
|
if (substring1.equals("w")) {
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
String s = OutJson.TestJson(fileName);
|
//sql语句
|
String sql = OutJson.stringReplace(s);
|
String[] split = sql.split(";");//以逗号分割
|
for (String sqls : split) {
|
if (sqls.length()>1) {
|
//判断是否是新增，删除，修改
|
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, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("o")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//数据处理
|
DataHanlder.handler(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
// ftp.dele(fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("l")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//用户集合数据,批量导入用户
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//数据处理
|
DataHanlder.handlerList(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
// ftp.dele(fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("t")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//培训报名数据
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//数据处理
|
DataHanlder.handlerListTrain(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
// ftp.dele(fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("s")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//获取保安员证编号数据
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//数据处理
|
DataHanlder.handlerSecurityNumerBit(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
// ftp.dele(fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("u")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//保安员审查
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//数据处理
|
DataHanlder.handlerUserExamine(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
//考试实操成绩导入
|
if(substring1.equals("e")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//获取对象字符串
|
String json = OutJson.TestJson(fileName);
|
//考试实操成绩数据处理
|
DataHanlder.handlerUserExamScore(json);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
if(substring1.equals("f")){
|
//把文件下载到本地(图片文件类),测试内外网使用同一台服务器
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
}
|
//删除本地文件,ftp 文件没有对应读取的不删除
|
MysqlCenlint.deletess(fileName);
|
// ftp.completePendingCommand();
|
}
|
return true;
|
}
|
} catch (Exception e) {
|
MysqlCenlint.deletess(fileName);
|
// FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
|
e.printStackTrace();
|
} finally {
|
try {
|
ftp.logout();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
//如果ftp 没有关闭,则关闭ftp
|
if (ftp.isConnected()) {
|
try {
|
ftp.disconnect();
|
} catch (IOException io) {
|
io.printStackTrace();
|
}
|
}
|
}
|
return false;
|
}
|
|
}
|
