Administrator
2022-04-27 8e6f6217e52a635d1dfd4ccbb549b0427d3f9fa6
src/main/java/org/springblade/modules/FTP/FtpUtil.java
@@ -51,7 +51,7 @@
            logger.info("未连接到FTP,用户名或密码错误。");
            ftpClient.disconnect();
         } else {
            logger.info("FTP连接成功。");
//            logger.info("FTP连接成功。");
         }
      } catch (SocketException e) {
         e.printStackTrace();
@@ -295,14 +295,15 @@
   public static void sqlFileUpload(String s1){
      String json1 = JSON.toJSONString(s1);
      String response1 = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json1, localPath, "n"+response1);
      OutJson.createJsonFile(json1, localPath, "nsql"+response1);
      FileInputStream in1 = null;
      try {
         in1 = new FileInputStream(new File(localPath + "n"+response1+".json"));
         in1 = new FileInputStream(new File(localPath + "nsql"+response1+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, "/",  "n"+response1+".json", in1);
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, "/",  "nsql"+response1+".json", in1);
//      MysqlCenlint.deletess("nsql"+response1+".json");
   }
   /**
    *
@@ -357,5 +358,24 @@
   }
   /**
    * 执行 对象数据(用户,报名对象信息等) 上传
    * @param obj 对象信息
    */
   public static void objectFileUpload(Object obj){
      String json1 = JSON.toJSONString(obj);
      String response1 = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json1, localPath, "n"+response1);
      FileInputStream in1 = null;
      try {
         in1 = new FileInputStream(new File(localPath + "n"+response1+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, "/",  "n"+response1+".json", in1);
//      MysqlCenlint.deletess("n"+response1+".json");
   }
}