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) { //判断是否是新增，删除，修改 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 文件 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; } }