package com.whyc.service;

import com.whyc.dto.FTPClientUtil;
import com.whyc.dto.FileDirPath;
import com.whyc.dto.ZipUtils;
import com.whyc.util.ActionUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Arrays;
import java.util.Date;
import java.util.List;

@ConditionalOnProperty(prefix = "configFile",name = "type",havingValue = "2")
@Service
@EnableScheduling   // 2.开启定时任务
@Slf4j
public class FtpService2 {
    //定时上传指定目录下文件,每周五凌晨开启备份
    @Scheduled(cron = "59 59 23 ? * FRI")
    public void sendFtpFile() throws IOException {
        //先连接ftp服务器
        FTPClient client = FTPClientUtil.connect();
        String fileDirName = FileDirPath.getFileDirName();
        String rootDoc=fileDirName+File.separator+"doc_file";
        String timeStr= ActionUtil.sdfwithFTP.format(new Date());
        client.makeDirectory(timeStr);
        client.disconnect();
        //备份过程是否出现过问题,标识符
        boolean isError=false;
        try {

            File docFile = new File(rootDoc);
            File[] fileList = docFile.listFiles();
            //File[] fileList2 = new File[fileList.length];
            //BeanUtils.copyProperties(fileList2,fileList);
            for (File file:fileList) {
                //压缩传输
                File fileZip = new File(file.getAbsolutePath() + ".zip");
                ZipUtils.toZip(file.getAbsolutePath(),new FileOutputStream(fileZip),true);
                //System.out.println(fileZip.toString()+"压缩完毕");
                //System.out.println("进行FTP传输中...");
                try {
                    //ZipUtils.toZip(file.getAbsolutePath(),new FileOutputStream(fileZip),true);
                    String pathName=timeStr+"/"+file.getName()+".zip";
                    //System.out.println("传输目标路径确认为:"+pathName);
                    FTPClientUtil.transferFile(fileZip, pathName);
                    //System.out.println(fileZip+"传输完毕");
                    fileZip.delete();
                    //System.out.println(fileZip+"传输中转压缩包删除完毕");
                } catch (Exception e) {
                    isError = true;
                    log.error("---------------文件"+ file.getName() +" FTP 传输异常2:"+e.toString()+"------------------");
                    fileZip.delete();
                }
            }
            //System.out.println("传输完毕");

            //获取备份目录,保留4次.
            //如果过程出现错误,则不删除
            if (!isError) {
                FTPClient client2 = FTPClientUtil.connect();
                String[] dirList = client2.listNames();
                List<String> dirList2 = Arrays.asList(dirList);

                for (int i = 0; i < dirList2.size()-4; i++) {
                    String dirToBeDelete = dirList2.get(i);
                    if(!client2.removeDirectory(dirToBeDelete)){
                        // 删除失败，可以尝试递归删除目录内的所有内容
                        FTPFile[] subFiles = client2.listFiles(dirToBeDelete);
                        if (subFiles != null && subFiles.length > 0) {
                            for (FTPFile subFile : subFiles) {
                                if (!subFile.isDirectory()) {
                                    // 删除文件
                                    client2.deleteFile(dirToBeDelete + "/" + subFile.getName());
                                }
                            }
                            // 再次尝试删除目录
                            client2.removeDirectory(dirToBeDelete);
                        }
                    }
                }
                client2.disconnect();
            }
        } catch (Exception e) {
            log.error("备份失败:"+e.toString());
        }
    }
}