package com.mm.service.impl;

import com.fasterxml.jackson.core.type.TypeReference;
import com.mm.service.IReceiveFileService;
import com.mm.util.DateUtil;
import com.mm.util.FileUtil;
import com.mm.util.JsonMapper;
import com.mm.vo.NcTxtFilePathInfo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.PropertySource;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.io.*;
import java.nio.charset.Charset;
import java.util.Scanner;

/**
 * @author clown
 * * @date 2023/12/15
 */
@Service
@PropertySource("classpath:/scheduled.properties")
public class ReceiveFileServiceImpl implements IReceiveFileService {
    @Value("${giveServiceTo.filePath}")
    private String filePath;

    @Value("${giveServiceTo.newFilePath}")
    private String newFilePath;
    @Value("${fileNCPath}")
    private String fileNCPath;

    @Override
    @Scheduled(cron = "${equipmentCron}")
    public void analysisAndCopyFile() {
        if (StringUtils.isBlank(filePath)) {
            return;
        }
        File f3 = new File(filePath);
        File[] files = f3.listFiles();
        for (File fi : files){
            InputStreamReader input =null;
            BufferedReader bufferedReader =null;
            String loFilePath = filePath + "\\" + fi.getName();
            System.out.println(loFilePath);
            try {
                if (FileUtil.getFileSuffix(fi.getName()).equals("nc")) {
                    String line;
                    int count = 0;
                    NcTxtFilePathInfo result = new NcTxtFilePathInfo();
                    FileInputStream fis = null;
                    try {
                        fis = new FileInputStream(loFilePath);
                    } catch (Exception e1) {
                        e1.printStackTrace();
                    }
                    Scanner sc = new Scanner(fis, "UTF-8");
                    while (count < 8 &&  sc.hasNext()) {
                        line = sc.nextLine();
                        if (count ==0) {
                            result.setFileTxtName(line.trim());
                        } else  if (count ==1) {
                            result.setFileNcName(line.trim());
                        }else  if (count ==2) {
                            result.setOrigFileName(line.trim());
                        }else  if (count ==3) {
                            result.setOrigFileSuffix(line.trim());
                        }else  if (count ==4) {
                            result.setFilePath(line.trim());
                        }else  if (count ==5) {
                            result.setEquipmentId(line.trim());
                        }else  if (count ==6) {
                            result.setFileAddOrDelete(Integer.valueOf(line.trim()));
                        }else  if (count == 7) {
                            result.setFileSize(line.trim());
                        }
                        count++;
                    }
                    if (sc != null) {
                        sc.close();
                    }
                    if (bufferedReader != null) {
                        bufferedReader.close();
                    }
                    if (input != null) {
                        input.close();
                    }
                    if (result == null) {
                        continue;
                    }
                    if (result.getFileAddOrDelete() != null ) {
                        if ( result.getFileAddOrDelete()==1) {
                            String path;
                            /*if(StringUtils.isBlank(result.getOrigFileSuffix())) {
                                path = filePath + "\\" + result.getFileNcName();
                            } else {
                                path = filePath + "\\" + result.getFileNcName() + "." + result.getOrigFileSuffix();
                            }*/
                            path = filePath + "\\" + result.getFileNcName()+ ".NC";
                            if (StringUtils.isNotBlank(result.getFileNcName()) &&
                                    result.getFileNcName().equals("null")) {
                                //备份数据
                                boolean b = FileUtil.copyFile(loFilePath,newFilePath + "/" + DateUtil.format(DateUtil.getNow(),DateUtil.STRDATE) + "/" +fi.getName(),null);
                                if (b) {
                                    FileUtil.deleteFile(loFilePath);
                                }
                                continue;
                            }
                            File ncFile = new File(path);
                            if (ncFile == null) {
                                continue;
                            } else {
                                //已经存在文件需要备份
                                String size = String.valueOf(ncFile.length());
                                if (!size.equals(result.getFileSize())) {
                                    continue;
                                }
                                boolean nc = false;
                                //FileUtil.copyFileNcToBak(result.getFilePath(),result.getOrigFileName(),result.getOrigFileSuffix());
                                if(StringUtils.isBlank(result.getOrigFileSuffix())) {
                                    nc = FileUtil.copyFile(path,fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName(),
                                            fileNCPath + "/" + result.getFilePath() + "/send_bak/" + DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE) + "/"
                                                    +result.getOrigFileName());
                                } else {
                                    nc = FileUtil.copyFile(path,fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName()+ "." + result.getOrigFileSuffix()
                                    ,fileNCPath + "/" + result.getFilePath() + "/send_bak/" + DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE) + "/" +result.getOrigFileName()+ "." + result.getOrigFileSuffix());
                                }
                                try {
                                    if (bufferedReader != null) {
                                        bufferedReader.close();
                                    }
                                    if (input != null) {
                                        input.close();
                                    }
                                } catch (IOException e1) {
                                    e1.printStackTrace();
                                }
                                if (nc) {
                                    //备份数据
                                    boolean b = FileUtil.copyFile(loFilePath,newFilePath + "/" + DateUtil.format(DateUtil.getNow(),DateUtil.STRDATE) + "/" +fi.getName(),null);
                                    if (b) {
                                        FileUtil.deleteFile(loFilePath);
                                    }
                                    //备份数据
                                    boolean c = FileUtil.copyFile(path,newFilePath + "/" + DateUtil.format(DateUtil.getNow(),DateUtil.STRDATE) + "/" +result.getFileNcName() + "." + result.getOrigFileSuffix(),null);
                                    if (c) {
                                        FileUtil.deleteFile(path);
                                    }
                                }
                            }
                        } else {
                            String path;
                            if(StringUtils.isBlank(result.getOrigFileSuffix())) {
                                path = fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName();
                            } else {
                                path = fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName()+ "." + result.getOrigFileSuffix();
                            }

                            File ncFile = new File(path);
                            if (ncFile == null) {
                                return;
                            } else {
                                //待优化
                                boolean deleteFile = FileUtil.copyFileNcToBak(result.getFilePath(),
                                        result.getOrigFileName(), result.getOrigFileSuffix());
                                FileUtil.deleteFile(path);
                                FileUtil.deleteFile(loFilePath);
                            }
                        }

                    }
                }
            } catch (Exception e1) {
                try {
                    if (bufferedReader != null) {
                        bufferedReader.close();
                    }
                    if (input != null) {
                        input.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
                e1.printStackTrace();
            } finally {
                try {
                    if (bufferedReader != null) {
                        bufferedReader.close();
                    }
                    if (input != null) {
                        input.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}