FTP上传修改

lxw

2022-11-03 dd3290c514d8e9790faf674b9a4fef9276a042c7

FTP上传修改

 src/main/java/com/whyc/dto/FtpHelper.java

@@ -1,6 +1,5 @@
package com.whyc.dto;

import ch.qos.logback.core.joran.spi.InterpretationContext;
import com.enterprisedt.net.ftp.FTPClient;
import com.enterprisedt.net.ftp.FTPConnectMode;
import com.enterprisedt.net.ftp.FTPTransferType;
@@ -10,6 +9,10 @@
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedList;
import java.util.List;

public class FtpHelper {
    private FTPClient ftp;
@@ -38,7 +41,7 @@
    public void connect(String ftpServer, int ftpPort, String ftpUsername, String ftpPassword) {
        ftp = new FTPClient();
        try {
            ftp.setControlEncoding("UTF-8");
            ftp.setControlEncoding("GBK");
            ftp.setRemoteHost(ftpServer);
            ftp.setRemotePort(ftpPort);
            ftp.setTimeout(6000);
@@ -159,6 +162,7 @@
            String type = filePath.substring(0, len);
            String[] typeArray = type.split("/");
            for (String s : typeArray) {
                s.trim();
                if (!checkDirectory(ftp, s)) {
                    ftp.mkdir(s);
                    changeDirectory(s);
@@ -210,12 +214,69 @@
            }
        }
    }

    //读取文件列表
    public List<File> getFileList(String path) {
        List<File> rsList = new ArrayList<>();
        if (path == null || path.equals("")) {
            return rsList;
        }
        File file = new File(path);
        if (!file.exists()) {
            return rsList;
        }
        // 处理文件
        if (file.isFile()) {
            rsList.add(file);
            return rsList;
        }
        // 处理文件夹
        if (null == file.listFiles()) {
            rsList.add(file);
            return rsList;
        }
        LinkedList<File> forDealList = new LinkedList<>();
        forDealList.addAll(Arrays.asList(file.listFiles()));
        while (!forDealList.isEmpty()) {
            File firstFile = forDealList.removeFirst();
            // 处理文件
            if (firstFile.isFile()) {
                // 把文件自身先加入结果
                rsList.add(firstFile);
                continue;
            }
            // 处理文件夹
            File[] files = firstFile.listFiles();
            if (files == null) {
                continue;
            }
            for (File curr : files) {
                if (curr.isDirectory()) {
                    // 将此文件夹放入待处理列表
                    forDealList.add(curr);
                } else {
                    rsList.add(curr);
                }
            }
        }
        return rsList;
    }

    public static void main(String[] args) {
        try { // 从ftp下载文件
            FtpHelper ftp = new FtpHelper("192.168.10.80", 21, "lxw", "lxw810412026");
            File file = new File("D:\\IDEAWorkSpace\\CadDrawManager\\target\\face.zip");
            ftp.uploadFile(file, "test/lxw/face.zip");
            ftp.disconnect();
            //File file = new File("D:\\fileTest\\内阻分析软件-问题反馈-20221031.docx");
            /*ftp.uploadFile(file, "test/"+"内阻分析软件-问题反馈-20221031.docx");
            ftp.disconnect();*/
            List<File> list=ftp.getFileList("D:\\fileTest\\software");
            if(list!=null&&list.size()>0){
                for (File file:list) {
                    String name=file.getPath().substring(file.getPath().lastIndexOf("software"));
                    System.out.println(name);
                    String pathName="/"+name.replace("\\","/");
                    ftp.uploadFile(file, pathName);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

 src/main/java/com/whyc/service/FtpService.java

@@ -12,12 +12,13 @@
import java.io.File;
import java.io.FileOutputStream;
import java.util.Date;
import java.util.List;

@Service
@EnableScheduling   // 2.开启定时任务
public class FtpService {
    //定时上传指定目录下文件
    @Scheduled(cron = "59 59 23 * * ?")
    @Scheduled(cron = "0 03 15 ? * FRI")
    private void sendFtpFile(){
        FtpHelper ftp = new FtpHelper(YamlProperties.ftpIp, YamlProperties.ftpPort, YamlProperties.ftpUserName, YamlProperties.ftpPassword);
        String fileDirName = FileDirPath.getFileDirName();
@@ -31,11 +32,19 @@
            ftp.uploadFile(filerootFace, timeStr+"/face.zip");
            filerootFace.delete();

            FileOutputStream forootDoc = new FileOutputStream(new File(rootDoc+".zip"));
            /*FileOutputStream forootDoc = new FileOutputStream(new File(rootDoc+".zip"));
            ZipUtils.toZip(rootDoc, forootDoc,true);
            File filerootDoc = new File(rootDoc+".zip");
            ftp.uploadFile(filerootDoc, timeStr+"/doc_file.zip");
            filerootDoc.delete();
            filerootDoc.delete();*/
            List<File> list=ftp.getFileList(rootDoc);
            if(list!=null&&list.size()>0){
                for (File file:list) {
                    String name=file.getPath().substring(file.getPath().lastIndexOf("doc_file"));
                    String pathName=timeStr+"/"+name.replace("\\","/");
                    ftp.uploadFile(file, pathName);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }