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) {
		//创建 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);
			}
			System.out.println("开始读取内网回传消息");
			ftp.enterLocalActiveMode();

			// 设置文件类型为二进制，与ASCII有区别
			ftp.setFileType(FTP.BINARY_FILE_TYPE);

			// 设置编码格式
			ftp.setControlEncoding("GBK");

			// 检验文件是否存在
			ftp.changeWorkingDirectory(ftpPath);
			FTPFile[] files = ftp.listFiles();
			if (files.length==0){
				System.out.println("未读取到文件");
				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, 1);
					if (substring1.equals("n")){
						System.out.println("-------接收到内网回传的文件： " + substring1);
					    //把文件下载到本地
						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);
						}
					}
				}
				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);
			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);
			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.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);
			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.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);
			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 != null) {
				try {
					ftp.disconnect();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		return new Result(400,null,"失败",null);
	}
}