package com.tianbo.analysis.task;

import com.tianbo.util.Date.DateUtil;
import com.tianbo.util.IO.FileTool;
import com.tianbo.analysis.handle.CustomXmlHandleThread;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.File;
import java.util.Iterator;
import java.util.List;

/**
 * 回执解析定时任务
 */
@Slf4j
@Component
public class TaskAnalysis {

    //回执读取目录
    @Value("${custom.receptDirectory}")
    private  String receptDir;

    @Scheduled(fixedDelay = 500000)
    public void startTask(){
        //回执目录
        String readDir = receptDir;
        try{
            File fileDirectory = new File(readDir);
                List<File> files = FileTool.readDirectoryFiles(fileDirectory);
                Iterator<File> it = files.iterator();
                while(it.hasNext()){
                    File file = it.next();
                    try {
                        CustomXmlHandleThread customXmlHandleThread = new CustomXmlHandleThread();
                        customXmlHandleThread.setXmlfile(file);
                        Thread thread = new Thread(customXmlHandleThread);
                        thread.start();

                    }catch (Exception e){
                        e.printStackTrace();
                        log.error("解析回执出错",e);
                    }
                }
        }catch (Exception e){
            e.printStackTrace();
            log.error("获取目录文件出错",e);
        }

    }
}