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 = "*/1 * * * * ?")
	public static boolean isFTPFileExist() {

		FTPClient ftp = new FTPClient();
		String fileName = null;
		try {

			ftp.connect(ftpHost, ftpPort);

			// 登陆
			ftp.login(ftpUserName, ftpPassword);

			// 检验登陆操作的返回码是否正确
			if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
				ftp.disconnect();
				return false;
			}

			System.out.println("ftp 连接成功!");

			//被动模式，文件上传不成功会有提示
			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) {
					 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, 1);
						//把文件下载到本地
						FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
						if (substring1.equals("w")) {
							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, ftpUserName, ftpPassword, "anbao/", fileName);
						}else if(substring1.equals("o")){
							//获取对象字符串
							String json = OutJson.TestJson(fileName);
							//数据处理
							DataHanlder.handler(json);
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
						}else if(substring1.equals("l")){
							//用户集合数据
							//获取对象字符串
							String json = OutJson.TestJson(fileName);
							//数据处理
							DataHanlder.handlerList(json);
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
						}else if(substring1.equals("t")){
							//培训报名数据
							//获取对象字符串
							String json = OutJson.TestJson(fileName);
							//数据处理
							DataHanlder.handlerListTrain(json);
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
						}else if(substring1.equals("s")){
							//获取保安员证编号数据
							//获取对象字符串
							String json = OutJson.TestJson(fileName);
							//数据处理
							DataHanlder.handlerSecurityNumerBit(json);
							//删除本地文件
							MysqlCenlint.deletess(fileName);
							//删除 ftp 文件
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
						}
//						else if(substring1.equals("f")){
//							//把文件下载到本地(图片文件类),测试内外网使用同一台服务器
//							FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
//							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
//						}
						else {
							//把文件下载到本地(图片文件类),ftp 内外网服务器分开时使用
							FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
						}
						//删除本地文件,ftp 文件没有对应读取的不删除
						MysqlCenlint.deletess(fileName);
						is.close();
						ftp.completePendingCommand();
					}
				}
				return true;
			}

		} catch (Exception e) {
			MysqlCenlint.deletess(fileName);
			FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
			e.printStackTrace();
		} finally {
			if (ftp != null) {
				try {
					ftp.disconnect();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		return false;
	}
}