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/wsql.json";
	//本地路径
	private static String localPath = "D:\\anbao";
	//文件名
	private static String fileName = "wsql.json";

	@Scheduled(cron = "*/30 * * * * ?")
	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) {
				System.out.println(false);
				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/", "wsql.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;

	}
}