新增保安员新增审查

Administrator

2022-04-27 8e6f6217e52a635d1dfd4ccbb549b0427d3f9fa6

 src/main/java/org/springblade/modules/FTP/monitor.java

@@ -2,6 +2,7 @@

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;
@@ -9,88 +10,113 @@
import java.io.IOException;
import java.io.InputStream;

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


@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/sql.json";

   @Scheduled(cron = "*/5 * * * * ?")
   //文件名
   //private static String fileName = "nsql.json";


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

      FTPClient ftp = new FTPClient();

      String fileName = null;
      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 + "/", "");
         //ftpPath = ftpPath.replace("ftp://" + ftpHost + ":" + ftpPort + "/", "");

         String dir = ftpPath.substring(0, ftpPath.lastIndexOf("/"));
         //String dir = ftpPath.substring(0, ftpPath.lastIndexOf("/"));

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

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

         ftp.changeWorkingDirectory(new String(dir.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
         //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);
         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);
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                  }else if(substring1.equals("o")){
                     //获取对象字符串
                     String json = OutJson.TestJson(fileName);
                     //数据处理
                     DataHanlder.handler(json);
                     //删除本地文件
                     MysqlCenlint.deletess(fileName);
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                  }
                  is.close();
                  ftp.completePendingCommand();
               }
            }
            return true;
         }

         if (is != null) {
            System.out.println(true);
            is.close();

            ftp.completePendingCommand();

         }

         return true;

      } catch (Exception e) {

         MysqlCenlint.deletess(fileName);
         FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
         e.printStackTrace();

      } finally {