package com.lxzn.base.service.impl;

import com.lxzn.base.service.IReceiveFileService;
import com.lxzn.base.service.ISingleDictionaryService;
import com.lxzn.framework.domain.base.SingleDictionary;
import com.lxzn.framework.domain.base.ext.NcTxtFilePathInfo;
import com.lxzn.framework.utils.date.DateUtil;
import com.lxzn.framework.utils.file.FileUtil;
import com.lxzn.nc.service.IDocInfoService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
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.util.Scanner;

/**
 * @author clown
 * * @date 2023/12/15
 */
@Service
@PropertySource("classpath:/scheduled.properties")
public class ReceiveFileServiceImpl implements IReceiveFileService {

    @Autowired
    private IDocInfoService docInfoService;
    @Autowired
    private ISingleDictionaryService dictionaryService;
    @Value("${serviceIntranet.filePath}")
    private String filePath;

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

//    @Override
//    @Scheduled(cron = "${ncFileRec}")
//    public void analysisAndCopyFileRec() {
//        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 = "";
//                            SingleDictionary singleDictionary=dictionaryService.findListFromTypeCode("virtual_equipment_id").get(0);
//                            String docEquipmentId = null;
//                            if (singleDictionary != null) {
//                                docEquipmentId= String.valueOf(singleDictionary.getDicValue());
//                            }
//                            if (result.getEquipmentId().equals(docEquipmentId)) {
//                                //虚拟设备处理
//                                path = filePath + result.getOrigFileName();
//                                if (StringUtils.isNotBlank(result.getOrigFileName()) &&
//                                        result.getOrigFileName().equals("null")) {
//                                    //文件待处理
//                                    //备份数据
//                                    FileUtil.deleteFileNewRec(loFilePath);
//                                    continue;
//                                }
//                            }else {
//                                path = filePath + result.getFileNcName()+ ".NC";
//                                if (StringUtils.isNotBlank(result.getFileNcName()) &&
//                                        result.getFileNcName().equals("null")) {
//                                    //文件待处理
//                                    //备份数据
//                                    FileUtil.deleteFileNewRec(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 bool = docInfoService.addDocInfoRecService(result.getEquipmentId(),
//                                        ncFile,result.getOrigFileSuffix(),
//                                        FileUtil.getFilenameNonSuffix(result.getOrigFileName())
//                                        ,result.getFilePath());
//                                if (bool) {
//                                    FileUtil.deleteFileNewRec(path);
//                                    FileUtil.deleteFileNewRec(loFilePath);
//                                }
//                            }
//                        } 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();
//                }
//            }
//        }
//    }
}