ftp 个人保安新增修改

Administrator

2022-06-08 7f36a55767f870937a473f9c0eebf0240300a5ef

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -74,7 +74,6 @@
//   @Scheduled(cron = "*/30 * * * * ?")
   public boolean readFile() {
      FTPClient ftp = new FTPClient();
      System.out.println("ftp 创建客户端");
      try {
         //设置传输超时时间为60秒
         ftp.setDataTimeout(10000);
@@ -117,7 +116,10 @@
               if (fileName.contains("nq")) {
//                  InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
                  //把文件下载到本地
                  long l = System.currentTimeMillis();
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
                  long x = System.currentTimeMillis();
                  System.out.println("下载文件耗时 = " + (x-l)+" 毫秒");
                  //
                  String s = OutJson.TestJson(fileName);
                  //sql语句
@@ -144,14 +146,14 @@
                  //删除本地服务器文件
                  MysqlCenlint.deletess(fileName);
                  //删除 ftp 服务器文件
//                     ftp.dele(fileName);
//                  ftp.dele(fileName);
                  FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                  System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName);
                  //关闭流
                  ftp.completePendingCommand();
                  ftp.logout();
               }
            }
            //关闭流
            ftp.completePendingCommand();
            ftp.logout();
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");