package org.springblade.modules.FTP;

import com.alibaba.fastjson.JSON;
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.ArrayList;
import java.util.List;
import java.util.Map;

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) {
		String name = "ni"+uuid;
//		System.out.println("uuid = " + uuid);
		//创建 ftp 对象
		FTPClient ftp = new FTPClient();
		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");
			// 检验文件是否存在
			boolean ftpFile = 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();
					if (fileName.equals(name)){
						System.out.println("-------接收到内网回传的文件： " + fileName);
						//把文件下载到本地
						FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
						// 解析数据
						String json = OutJson.TestJson(fileName);
						//数据处理
						Map map = JSON.parseObject(json, Map.class);
						//获取结果
						Object o = map.get(uuid);
						if (null!= o || !o.equals("")){
							Result result = JSON.parseObject(o.toString(), Result.class);
							System.out.println("读取返回结果 result = " + result);
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
//							ftp.dele(fileName);
							List<Result> list = new ArrayList<>();
							list.add(result);
							//返回
							return new Result(200,null,list);
						}
					}
				}
				ftp.completePendingCommand();
				ftp.logout();
				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);
	}

	/**
	 * 读取文件（对象）用户批量操作返回
	 * @param uuid 随机数
	 * @return
	 */
	public static Result getFtpDataByUuidList(String uuid) {
		//创建 ftp 对象
		FTPClient ftp = new FTPClient();
		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 {
				boolean flag = false;
				for (FTPFile file : files){
					String fileName = file.getName();
					if (fileName.contains("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) {
							flag = true;
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
//							ftp.dele(fileName);
							//返回
							return result;
						}
						ftp.completePendingCommand();
						ftp.logout();
					}
				}
//				if (!flag){
//					ftp.logout();
//				}
				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);
	}

	/**
	 * 读取文件（对象）报名返回
	 * @param uuid 随机数
	 * @return
	 */
	public static Result getFtpDataByUuidListTrain(String uuid) {
		//创建 ftp 对象
		FTPClient ftp = new FTPClient();
		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 {
				boolean flag = false;
				for (FTPFile file : files){
					String fileName = file.getName();
					if (fileName.contains("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) {
							flag = true;
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
//							ftp.dele(fileName);
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
							//返回
							return result;
						}
						ftp.completePendingCommand();
						ftp.logout();
					}
				}
//				if (!flag){
//					ftp.logout();
//				}
				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);
	}

	/**
	 * 获取保安证编号位数
	 * @param uuid 随机数
	 * @return
	 */
	public static Result getSecurityNumberBit(String uuid) {
		//创建 ftp 对象
		FTPClient ftp = new FTPClient();
		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 {
				boolean flag = false;
				for (FTPFile file : files){
					String fileName = file.getName();
					if (fileName.contains("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) {
							flag = true;
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
//							ftp.dele(fileName);
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);

							//返回
							return result;
						}
						ftp.completePendingCommand();
						ftp.logout();
					}
				}
//				if (!flag){
//					ftp.logout();
//				}
				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);
	}
}