package org.springblade.modules.FTP;
|
|
import org.apache.commons.net.ftp.FTP;
|
import org.apache.commons.net.ftp.FTPClient;
|
import org.apache.commons.net.ftp.FTPReply;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
|
@Component
|
public class monitor {
|
//ftp服务器IP地址
|
private static String ftpHost = "192.168.0.105";
|
//ftp服务器端口
|
private static int ftpPort = 21;
|
//ftp服务器用户名
|
private static String ftpUserName = "yly";
|
//ftp服务器密码
|
private static String ftpPassword = "Yly@123";
|
//ftp服务器路径
|
private static String ftpPath = "anbao/nsql.json";
|
//本地路径
|
private static String localPath = "D:\\anbao";
|
//文件名
|
private static String fileName = "nsql.json";
|
|
|
@Scheduled(cron = "*/5 * * * * ?")
|
public static boolean isFTPFileExist() {
|
|
FTPClient ftp = new FTPClient();
|
|
try {
|
|
// 连接ftp服务器
|
|
ftp.connect(ftpHost, ftpPort);
|
|
// 登陆
|
|
ftp.login(ftpUserName, ftpPassword);
|
|
// 检验登陆操作的返回码是否正确
|
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
|
ftp.disconnect();
|
|
return false;
|
|
}
|
|
ftp.enterLocalActiveMode();
|
|
// 设置文件类型为二进制，与ASCII有区别
|
|
ftp.setFileType(FTP.BINARY_FILE_TYPE);
|
|
// 设置编码格式
|
|
ftp.setControlEncoding("GBK");
|
|
// 提取绝对地址的目录以及文件名
|
|
ftpPath = ftpPath.replace("ftp://" + ftpHost + ":" + ftpPort + "/", "");
|
|
String dir = ftpPath.substring(0, ftpPath.lastIndexOf("/"));
|
|
String file = ftpPath.substring(ftpPath.lastIndexOf("/") + 1);
|
|
// 进入文件所在目录，注意编码格式，以能够正确识别中文目录
|
|
ftp.changeWorkingDirectory(new String(dir.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
|
// 检验文件是否存在
|
|
InputStream is = ftp.retrieveFileStream(new String(file.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
|
if (is == null || ftp.getReplyCode() == FTPReply.FILE_UNAVAILABLE) {
|
return false;
|
|
}
|
|
if (is != null) {
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
|
//
|
String s = OutJson.TestJson();
|
//sql语句
|
String sql = OutJson.stringReplace(s);
|
//判断是否是新增，删除，修改
|
String substring = sql.substring(0, 2);
|
//新增
|
if (substring.equals("in")){
|
//运行sql语句
|
MysqlCenlint.inster(sql);
|
}
|
//修改
|
else if (substring.equals("up")){
|
|
}
|
//删除
|
else {
|
|
}
|
//删除本地文件
|
MysqlCenlint.delete();
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "nsql.json");
|
is.close();
|
ftp.completePendingCommand();
|
|
}
|
|
return true;
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
} finally {
|
|
if (ftp != null) {
|
|
try {
|
|
ftp.disconnect();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
}
|
