forked from gzzfw/backEnd/gz-dyh

xusd
2024-09-10 6cdbd8f9cb636cfa43c26651f76b14ce81f16ef6
dyh-service/dyh-sys/src/main/java/cn/huge/module/file/utils/FtpUtils.java
@@ -7,6 +7,7 @@
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.springframework.stereotype.Component;
@@ -117,10 +118,12 @@
            clientConfig.setLenientFutureDates(true);
            ftpClient.configure(clientConfig);
            // 连接ftp
            log.info("xsd host:{},{}",FtpFileConfig.getHostname(), FtpFileConfig.getPort());
            ftpClient.connect(FtpFileConfig.getHostname(), FtpFileConfig.getPort());
            if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
                log.info("连接ftp成功!");
                ftpClient.login(FtpFileConfig.getUsername(), FtpFileConfig.getPassword());
                boolean login = ftpClient.login(FtpFileConfig.getUsername(), FtpFileConfig.getPassword());
                log.info("登录ftp成功:{}",login);
                if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
                    // 设置以二进制方式传输
                    ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
@@ -130,6 +133,7 @@
                    ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE);
                    // 设置缓冲区大小
                    ftpClient.setBufferSize(1024);
                    log.info("登录ftp成功!");
                    flag = true;
                } else {
@@ -179,6 +183,8 @@
            }else{
                flag = true;
            }
            FTPFile[] ftpFiles = ftpClient.listFiles(path);
            log.info("xsd{}",ftpFiles);
            return flag;
        }catch (Exception e){
            log.error("方法[FtpUtils.makeDir]调用异常:"+e, e);
@@ -198,7 +204,10 @@
        try {
            fileName = new String(fileName.getBytes("UTF-8"), "iso-8859-1");
            log.info("上传文件名为:" + fileName);
            ftpClient.storeFile(fileName, fileInputStream);
            log.info("上传文件流:" + fileInputStream);
            boolean b = ftpClient.storeFile(fileName, fileInputStream);
            String status = ftpClient.getStatus();
            log.info("上传状态:{},{}" ,b, status);
            int reply = ftpClient.getReplyCode();
            if (FTPReply.isPositiveCompletion(reply)) {
                flag = true;