定时任务修改

Administrator

2022-05-17 e3997e08bf8c0ed292a552ec4efea39a03cfbc83

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

@@ -24,6 +24,7 @@
@Component
public class Monitor {


   /**
    * 读取文件（用户对象）单用户新增
    * @param uuid 随机数
@@ -44,7 +45,7 @@
            ftp.disconnect();
            return new Result(400,null,"ftp 连接失败",null);
         }
         System.out.println("开始读取内网回传消息");

         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
@@ -52,18 +53,23 @@

         // 设置编码格式
         ftp.setControlEncoding("GBK");

         // 检验文件是否存在
         ftp.changeWorkingDirectory(ftpPath);
         boolean ftpFile = ftp.changeWorkingDirectory(ftpPath);
         System.out.println("检验文件是否存在 = " + ftpFile);
         FTPFile[] files = ftp.listFiles();
         System.out.println("files = " + files);
         System.out.println("开始读取内网回传消息");
         if (files.length==0){
            System.out.println("未读取到文件");
            return new Result(400,null,"未读取到文件",null);
         } else {
            System.out.println("-----有读取到文件--------");
            for (FTPFile file : files){
               String fileName = file.getName();
               System.out.println("fileName = " + fileName);
               InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
               String substring1 = fileName.substring(0, 1);
               System.out.println("substring1 = " + substring1);
               if (substring1.equals("n")){
                  System.out.println("-------接收到内网回传的文件： " + substring1);
                   //把文件下载到本地