最新版本541200007

jiangping

2024-10-31 fa3ee102bfbd8b5ac86ff46c7d938d61e5549634

最新版本541200007

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

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

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

@@ -51,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;
    }

    /** */
    /**
@@ -60,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())) {
@@ -238,7 +270,7 @@
    public boolean uploadInputstream(InputStream inputStream, String remote)  {
        // 设置PassiveMode传输
        Date d1 = new Date();
        log.info("上传文件成功=============开始========="+DateUtil.getPlusTime2(d1));
        log.error("上传文件成功=============开始========="+DateUtil.getPlusTime2(d1));
        try {
            ftpClient.enterLocalPassiveMode();
            // 设置以二进制流的方式传输
@@ -263,7 +295,7 @@
                log.error("上传文件失败======================="+remote);
            }
            Date d2= new Date();
            log.info("上传文件成功=============结束========="+DateUtil.getPlusTime2(d2) +"耗时秒："+( (d2.getTime()-d1.getTime()) /1000));
            log.error("上传文件成功=============结束========="+DateUtil.getPlusTime2(d2) +"耗时毫秒："+( (d2.getTime()-d1.getTime())  ));
            return result;
        }catch (Exception e){
            e.printStackTrace();