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.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.io.InputStream;

import static org.springblade.common.config.FtpConfig.*;


@Component
public class monitor {

	@Scheduled(cron = "*/30 * * * * ?")
	public static boolean isFTPFileExist() {

		FTPClient ftp = new FTPClient();

		try {

			// 连接ftp服务器
//			System.out.println("ftpHost = " + ftpHost);

			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("/"));

			// file = ftpPath.substring(ftpPath.lastIndexOf("/") + 1);

			// 进入文件所在目录，注意编码格式，以能够正确识别中文目录

			//ftp.changeWorkingDirectory(new String(dir.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));

			// 检验文件是否存在
			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));
					String substring1 = fileName.substring(0, 1);
					if (substring1.equals("n")){
						//把文件下载到本地
						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.deletes(fileName);
						MysqlCenlint.deletess(fileName);
						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, fileName);
						is.close();
						ftp.completePendingCommand();
					}
				}
				return true;
			}

			//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[] 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.delete();
//				FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "nsql.json");
//				is.close();
//				ftp.completePendingCommand();
//
//			}


		} catch (Exception e) {
			System.out.println("ftp连接失败");
			e.printStackTrace();

		} finally {

			if (ftp != null) {

				try {

					ftp.disconnect();

				} catch (IOException e) {

					e.printStackTrace();

				}

			}

		}

		return false;

	}
}