最新版本541200007

jiangping

2025-03-07 c7bf8d9b6b63b28ecf8755301d0b66d94dcfe58f

 server/system_service/src/main/java/com/doumee/core/utils/FtpUtil.java

@@ -1,6 +1,8 @@
package com.doumee.core.utils;

import java.io.*;
import java.net.MalformedURLException;
import java.util.Date;
import java.util.UUID;

import lombok.extern.slf4j.Slf4j;
@@ -50,6 +52,37 @@
      FtpUtil.password =password;
      connect();
   }
   /**
    * 初始化ftp服务器
    */
   public boolean connect() {
      boolean flag = false;
      try {
         System.out.println("connecting...ftp服务器:"+this.hostname+":"+this.port);
         ftpClient.setRemoteVerificationEnabled(false);
         ftpClient.connect(hostname, port); //连接ftp服务器
         ftpClient.login(username, password); //登录ftp服务器
//            if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {
//               LOCAL_CHARSET = "UTF-8";
//         }
         ftpClient.setControlEncoding("GBK");
         ftpClient.enterLocalPassiveMode();
         int replyCode = ftpClient.getReplyCode(); //是否成功登录服务器
         if(!FTPReply.isPositiveCompletion(replyCode)){
            log.error("connect failed...ftp服务器:"+this.hostname+":"+this.port+"返回码："+replyCode);
         }else {
            flag = true;
            log.info("connect successful...ftp服务器:"+this.hostname+":"+this.port+"返回码："+replyCode);
         }
      }catch (MalformedURLException e) {
         e.printStackTrace();
         log.error("connect exception...ftp服务器:"+this.hostname+":"+this.port+   e.getMessage());
      }catch (IOException e) {
         e.printStackTrace();
         log.error("connect exception...ftp服务器:"+this.hostname+":"+this.port+   e.getMessage());
      }
      return flag;
   }

   /** */
   /**
@@ -59,7 +92,7 @@
    * @return 是否连接成功
    * @throws IOException
    */
   public boolean connect() throws IOException {
   public boolean connect2() throws IOException {
      ftpClient.connect(hostname, port);
      ftpClient.setControlEncoding("GBK");
      if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
@@ -236,6 +269,8 @@
   }
   public boolean uploadInputstream(InputStream inputStream, String remote)  {
      // 设置PassiveMode传输
      Date d1 = new Date();
      log.error("上传文件成功=============开始========="+DateUtil.getPlusTime2(d1));
      try {
         ftpClient.enterLocalPassiveMode();
         // 设置以二进制流的方式传输
@@ -259,6 +294,8 @@
         }else{
            log.error("上传文件失败======================="+remote);
         }
         Date d2= new Date();
         log.error("上传文件成功=============结束========="+DateUtil.getPlusTime2(d2) +"耗时毫秒："+( (d2.getTime()-d1.getTime())  ));
         return result;
      }catch (Exception e){
         e.printStackTrace();