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.FTPFile;
|
import org.apache.commons.net.ftp.FTPReply;
|
import org.springblade.core.tool.api.R;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.UnsupportedEncodingException;
|
import java.net.SocketException;
|
import java.util.List;
|
|
import static org.springblade.common.config.FtpConfig.*;
|
|
/**
|
* FTP 监听器，监听文件
|
* @author
|
* @since 2021-04-26 修改
|
*/
|
@Component
|
public class Monitor {
|
|
|
/**
|
* 读取文件（用户对象）单用户新增
|
* @param uuid 随机数
|
* @return
|
*/
|
public static Result isFTPFileExist(String uuid) {
|
// System.out.println("uuid = " + uuid);
|
//创建 ftp 对象
|
FTPClient ftp = new FTPClient();
|
boolean flag = false;
|
try {
|
//连接
|
ftp.connect(ftpHost, ftpPort);
|
|
// 登陆
|
ftp.login(ftpUserNameIn, ftpPasswordIn);
|
// 检验登陆操作的返回码是否正确
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
ftp.disconnect();
|
return new Result(400,null,"ftp 连接失败",null);
|
}
|
|
ftp.enterLocalActiveMode();
|
|
|
// 设置文件类型为二进制，与ASCII有区别
|
ftp.setFileType(FTP.BINARY_FILE_TYPE);
|
|
// 设置编码格式
|
ftp.setControlEncoding("GBK");
|
// 检验文件是否存在
|
boolean ftpFile = ftp.changeWorkingDirectory(ftpPath);
|
// System.out.println("检验文件是否存在 = " + ftpFile);
|
// Use passive mode as default
|
ftp.enterLocalPassiveMode();
|
|
FTPFile[] files = ftp.listFiles();
|
// System.out.println("files = " + files);
|
// System.out.println("开始读取内网回传消息");
|
if (files.length==0){
|
// System.out.println("未读取到文件");
|
return new Result(400,null,"未读取到文件",null);
|
} else {
|
// System.out.println("-----有读取到文件--------");
|
for (FTPFile file : files){
|
String fileName = file.getName();
|
// System.out.println("fileName = " + fileName);
|
InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
String substring1 = fileName.substring(0, 1);
|
// System.out.println("substring1 = " + substring1);
|
if (substring1.equals("n")){
|
System.out.println("-------接收到内网回传的文件： " + fileName);
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
|
// 解析数据
|
String s = OutJson.TestJson(fileName);
|
//数据处理
|
Result result = DataHandler.handler(s,uuid);
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
|
is.close();
|
ftp.completePendingCommand();
|
if (result.getCode()==200) {
|
//返回
|
return new Result(200,null,"新增成功",null);
|
}
|
if (result.getCode()==201) {
|
//返回
|
return new Result(201,null,"修改成功",null);
|
}
|
if (result.getCode()==202) {
|
//返回
|
return new Result(202,null,result.getMsg(),null);
|
}
|
if (result.getCode()==203) {
|
//返回
|
return new Result(203,null,result.getMsg(),null);
|
}
|
if (result.getCode()==205){
|
//返回
|
return new Result(202,null,"新增失败,找不到该用户",null);
|
}
|
}
|
}
|
System.out.println("未读取到对应的文件");
|
return new Result(400,null,"未读取到对应的文件",null);
|
}
|
} catch (Exception e) {
|
System.out.println("ftp连接失败");
|
e.printStackTrace();
|
} finally {
|
if (ftp != null) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return new Result(400,null,"失败",null);
|
}
|
|
/**
|
* 读取文件（对象）用户批量操作返回
|
* @param uuid 随机数
|
* @return
|
*/
|
public static Result getFtpDataByUuidList(String uuid) {
|
//创建 ftp 对象
|
FTPClient ftp = new FTPClient();
|
boolean flag = false;
|
try {
|
//连接
|
ftp.connect(ftpHost, ftpPort);
|
// 登陆
|
ftp.login(ftpUserNameIn, ftpPasswordIn);
|
// 检验登陆操作的返回码是否正确
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
ftp.disconnect();
|
return new Result(400,null,"ftp 连接失败",null);
|
}
|
|
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 new Result(400,null,"未读取到文件",null);
|
} else {
|
for (FTPFile file : files){
|
String fileName = file.getName();
|
InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
String substring1 = fileName.substring(0, 2);
|
if (substring1.equals("nl")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
|
// 解析数据
|
String s = OutJson.TestJson(fileName);
|
//数据处理
|
Result result = DataHandler.handlerList(s,uuid);
|
//匹配上了删除文件
|
if (result.getCode()==200) {
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
|
//返回
|
return result;
|
}
|
is.close();
|
ftp.completePendingCommand();
|
}
|
}
|
return new Result(400,null,"未读取到对应的文件",null);
|
}
|
} catch (Exception e) {
|
System.out.println("ftp连接失败");
|
e.printStackTrace();
|
} finally {
|
if (ftp != null) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return new Result(400,null,"失败",null);
|
}
|
|
/**
|
* 读取文件（对象）报名返回
|
* @param uuid 随机数
|
* @return
|
*/
|
public static Result getFtpDataByUuidListTrain(String uuid) {
|
//创建 ftp 对象
|
FTPClient ftp = new FTPClient();
|
boolean flag = false;
|
try {
|
//连接
|
ftp.connect(ftpHost, ftpPort);
|
// 登陆
|
ftp.login(ftpUserNameIn, ftpPasswordIn);
|
// 检验登陆操作的返回码是否正确
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
ftp.disconnect();
|
return new Result(400,null,"ftp 连接失败",null);
|
}
|
|
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 new Result(400,null,"未读取到文件",null);
|
} else {
|
for (FTPFile file : files){
|
String fileName = file.getName();
|
InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
String substring1 = fileName.substring(0, 2);
|
if (substring1.equals("nt")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
|
// 解析数据
|
String s = OutJson.TestJson(fileName);
|
//数据处理
|
Result result = DataHandler.handlerList(s,uuid);
|
//匹配上了删除文件
|
if (result.getCode()==200) {
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
|
//返回
|
return result;
|
}
|
is.close();
|
ftp.completePendingCommand();
|
}
|
}
|
return new Result(400,null,"未读取到对应的文件",null);
|
}
|
} catch (Exception e) {
|
System.out.println("ftp连接失败");
|
e.printStackTrace();
|
} finally {
|
if (ftp != null) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return new Result(400,null,"失败",null);
|
}
|
|
/**
|
* 读取内外推送的文件,每30秒读取一次
|
* @return
|
*/
|
// @Scheduled(cron = "*/30 * * * * ?")
|
public static boolean isFTPFileExist() {
|
FTPClient ftp = new FTPClient();
|
try {
|
//设置超时时间
|
ftp.setConnectTimeout(2000);
|
//连接
|
ftp.connect(ftpHost, ftpPort);
|
// 登陆
|
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 (FTPFile file : files) {
|
String fileName = file.getName();
|
InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
if (null == is) {
|
return false;
|
} else {
|
String substring1 = fileName.substring(0, 4);
|
if (substring1.equals("nsql")) {
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, 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 服务器文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
|
}
|
//关闭流
|
is.close();
|
ftp.completePendingCommand();
|
}
|
return true;
|
}
|
}
|
} catch (Exception e) {
|
System.out.println("ftp连接失败");
|
e.printStackTrace();
|
} finally {
|
if (ftp != null) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return false;
|
}
|
|
/**
|
* 获取保安证编号位数
|
* @param uuid 随机数
|
* @return
|
*/
|
public static Result getSecurityNumberBit(String uuid) {
|
//创建 ftp 对象
|
FTPClient ftp = new FTPClient();
|
boolean flag = false;
|
try {
|
//设置超时时间
|
ftp.setDataTimeout(60000);
|
//连接超时为60秒
|
ftp.setConnectTimeout(60000);
|
//连接
|
ftp.connect(ftpHost, ftpPort);
|
// 登陆
|
ftp.login(ftpUserNameIn, ftpPasswordIn);
|
// 检验登陆操作的返回码是否正确
|
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
|
ftp.disconnect();
|
return new Result(400,null,"ftp 连接失败",null);
|
}
|
|
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 new Result(400,null,"未读取到文件",null);
|
} else {
|
for (FTPFile file : files){
|
String fileName = file.getName();
|
InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
|
String substring1 = fileName.substring(0, 2);
|
if (substring1.equals("ns")){
|
//把文件下载到本地
|
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
|
// 解析数据
|
String s = OutJson.TestJson(fileName);
|
//数据处理
|
Result result = DataHandler.handlerSecurityNumberBit(s,uuid);
|
//匹配上了删除文件
|
if (result.getCode()==200) {
|
//删除本地文件
|
MysqlCenlint.deletess(fileName);
|
//删除 ftp 文件
|
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
|
//返回
|
return result;
|
}
|
is.close();
|
ftp.completePendingCommand();
|
}
|
}
|
return new Result(400,null,"未读取到对应的文件",null);
|
}
|
} catch (Exception e) {
|
System.out.println("ftp连接失败");
|
e.printStackTrace();
|
} finally {
|
if (ftp.isConnected()) {
|
try {
|
ftp.disconnect();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return new Result(400,null,"失败",null);
|
}
|
}
|
