package com.lxzn.base.service.impl;

import cn.hutool.crypto.SmUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.lxzn.base.dao.DncPassLogMapper;
import com.lxzn.base.service.IDncPassLogService;
import com.lxzn.base.service.ISingleDictionaryService;
import com.lxzn.framework.domain.activiti.response.ActivitiCode;
import com.lxzn.framework.domain.base.DncPassLog;
import com.lxzn.framework.domain.base.SingleDictionary;
import com.lxzn.framework.domain.base.SysLogMessageDto;
import com.lxzn.framework.domain.base.SysLogTypeObjectDto;
import com.lxzn.framework.exception.ExceptionCast;
import com.lxzn.framework.utils.FileClient;
import com.lxzn.framework.utils.SyslogClient;
import com.lxzn.framework.utils.TelnetUtil;
import com.lxzn.framework.utils.ValidateUtil;
import com.lxzn.framework.utils.date.DateUtil;
import com.lxzn.framework.utils.file.FileUtil;
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.File;
import java.io.IOException;
import java.net.InetAddress;
import java.net.URLEncoder;
import java.net.UnknownHostException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.time.Duration;
import java.time.Instant;
import java.util.Date;
import java.util.List;
import java.util.stream.Stream;

/**
 * @author clown
 * * @date 2023/11/29
 */
@Service
@PropertySource("classpath:/scheduled.properties")
public class DncPassLogServiceImpl extends ServiceImpl<DncPassLogMapper,DncPassLog> implements IDncPassLogService {

    @Value("${securedoc.serverIp}")
    private String serverIp;
    @Value("${securedoc.serverPort}")
    private String serverPort;
    @Value("${securedoc.username}")
    private String usernameService;
    @Value("${securedoc.pwd}")
    private String pwdService;
    @Value("${securedoc.addressToken}")
    private String addressToken;
    @Value("${securedoc.addressUploadFile}")
    private String addressUploadFile;
    @Value("${securedoc.localFilePath}")
    private String localFilePathC;
    @Value("${securedoc.servicePath}")
    private String servicePathS;
    @Value("${securedoc.copyFilePath}")
    private String newFilePathC;
    @Value("${securedoc.logIp}")
    private String logIp;
    @Value("${securedoc.logPort}")
    private String logPort;
    @Autowired
    private ISingleDictionaryService iSingleDictionaryService;

    @Override
    public DncPassLog findDayTime(String dateDay) {
        if (!ValidateUtil.validateString(dateDay)) {
            return null;
        }
        return super.baseMapper.findDateTimeDay(dateDay);
    }

//    @Override
//    @Scheduled(cron = "${fileCron}")
//    public void fileClientTxtOrNc() {
//        SysLogMessageDto message = new SysLogMessageDto();
//        String host = "127.0.0.1";
//        if (StringUtils.isNotBlank(serverIp)) {
//            host = serverIp;
//        }
//        String port = "8299";
//        if (StringUtils.isNotBlank(serverPort)) {
//            port = serverPort;
//        }
//        String username = "admin";
//        if (StringUtils.isNotBlank(usernameService)) {
//            username = usernameService;
//        }
//        String pwd = "123";
//        if (StringUtils.isNotBlank(pwdService)) {
//            pwd = pwdService;
//        }
//        //文件本地地址，根据地址找到文件，将文件解析成文件流
//        String localFilePath = "E:\\test\\a\\";
//        if (StringUtils.isNotBlank(localFilePathC)) {
//            localFilePath = localFilePathC;
//        }
//        //文件上传目的地址，将文件上传到该地址
//        String servicePath = "E:\\test\\b\\";
//        if (StringUtils.isNotBlank(servicePathS)) {
//            servicePath = servicePathS;
//        }
//        boolean btelnetPort =  TelnetUtil.telnetPort(serverIp,Integer.valueOf(serverPort),10);
//        if (!btelnetPort) {
//            System.out.println("服务器连接： " + serverIp + ":" + serverPort + " 异常！" );
//            return;
//        }
//        //第一步，获取token
//        String token = null;
//        try {
//            token = FileClient.getToken(host,port,username,pwd,addressToken);
//        } catch (Throwable throwable) {
//            throwable.printStackTrace();
//        }
//
//        //若获取token成功，再进行上传文件接口调用
//        if (token !=null && !token.equals("")){
//            try {
//                File f3 = new File(localFilePath);
//                File[] files = f3.listFiles();
//                for (File fi : files){
//                    if (fi.isFile()){
//                        SysLogTypeObjectDto objectName = new SysLogTypeObjectDto();
//                        objectName.setDateTime(DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE_TIME_SMALL));
//                        objectName.setFileName(fi.getName());
//                        objectName.setFileSize(FileUtil.changeFileFormatKb(String.valueOf(new File(localFilePath).length())));
//                        objectName.setSourceAddress(localFilePath);
//                        objectName.setDestination(serverIp);//服务端IP
//                        //顺序号
//                        DncPassLog passLog = getById("num0001");
//                        if (passLog == null) {
//                            passLog = new DncPassLog();
//                            passLog.setId("num0001");
//                            passLog.setSequenceNumber(1);
//                            objectName.setFileNum(Integer.toString(1));
//                            save(passLog);
//                        } else {
//                            Integer number = passLog.getSequenceNumber()+1;
//                            removeById("num0001");
//                            objectName.setFileNum(Integer.toString(number));
//
//                            passLog = new DncPassLog();
//                            passLog.setId("num0001");
//                            passLog.setSequenceNumber(number);
//                            save(passLog);
//                        }
//
//                        InetAddress address = null;
//                        try {
//                            address = InetAddress.getLocalHost();
//                            String ip = address.getHostAddress();
//                            objectName.setSourceAddress("20.10.17.11");//客户端IP
//                            objectName.setAddress(ip);
//                        } catch (UnknownHostException e) {
//                            objectName.setSourceAddress("127.0.0.1");
//                            objectName.setAddress("127.0.0.1");
//                        }
//                        objectName.setDestination(host);
//                        objectName.setResult("失败");
//                        //获取某个文件下的所有文件
//                        String loFilePath = localFilePath + fi.getName();
//                        String servicePathName =servicePath+"//" + fi.getName();
//                        File file = new File(loFilePath);
//                        if (file == null || !file.exists()){
//                            objectName.setAbstract1("sm3");
//                        } else {
//                            String sm3 = SmUtil.sm3(file);
//                            objectName.setAbstract1(sm3);
//                        }
//
//                        String b  = FileClient.uploadFile(host,port,token,fi.getName(),servicePathName,loFilePath,addressUploadFile);
//                        //文件备份删除
//                        if (b == null) {
//                            try {
//                                objectName.setResult("失败");
//                                objectName.setTypes("error");
//                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
//                            }catch (Exception e) {
//                                return;
//                            }
//                        }
//                        else if ( b.equals("成功")) {
//                            //备份数据
//                            boolean fCopy = FileUtil.copyNcFile(loFilePath,newFilePathC + "/" + DateUtil.format(DateUtil.getNow(),
//                                    DateUtil.STR_YEARMONTHDAY) + "/" +fi.getName());
//                            if (fCopy) {
//                                FileUtil.deleteNcFile(loFilePath);
//                            } else {
//                                FileUtil.copyNcFile(loFilePath,newFilePathC + "/" + DateUtil.format(DateUtil.getNow(),
//                                        DateUtil.STR_YEARMONTHDAY) + "/" +fi.getName());
//                                FileUtil.deleteNcFile(loFilePath);
//                            }
//                            try {
//                                objectName.setTypes("Info");
//                                objectName.setResult("成功");
//                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
//                            }catch (Exception e) {
//                                return;
//                            }
//                        } else {
//                            try {
//                                objectName.setResult("失败");
//                                objectName.setTypes("error");
//                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
//                            }catch (Exception e) {
//                                return;
//                            }
//                        }
//                    }
//                }
//
//            } catch (Throwable throwable) {
//                throwable.printStackTrace();
//            }
//        }
//    }
//
//    /**
//     * 定时任务执行器参数  每天凌晨1.30执行
//     */
//    @Override
//    @Scheduled(cron = "0 30 1 * * ?")
//    public void deleteNcSendFile() {
//        Integer day;
//        //取字典时间
//        List<SingleDictionary> singleDictionaries=iSingleDictionaryService.findListFromTypeCode("DEL_TIME_SEND");
//        if (singleDictionaries.size()!=1){
//            return;
//        }else {
//            day= singleDictionaries.get(0).getDicValue();
//        }
//        Path ncDirectory = Paths.get("D:\\NC");
//        //天转秒
//        long dayToSecond = day * 24 * 60 * 60;
//        if (Files.exists(ncDirectory) && Files.isDirectory(ncDirectory)) {
//            // 递归查找NC目录下所有名为send的文件夹
//            try (Stream<Path> sendFolders = Files.walk(ncDirectory)
//                    .filter(Files::isDirectory)
//                    .filter(path -> path.getFileName().toString().equalsIgnoreCase("send"))) {
//                sendFolders.forEach(sendFolder -> {
//                    try {
//                        // 获取当前时间
//                        Instant now = Instant.now();
//                        // 遍历SEND文件夹内的所有文件
//                        Files.walk(sendFolder)
//                                .filter(Files::isRegularFile)
//                                .forEach(file -> {
//                                    try {
//                                        // 获取文件的最后修改时间
//                                        Instant lastModified = Files.getLastModifiedTime(file).toInstant();
//                                        // 计算时间差
//                                        Duration duration = Duration.between(lastModified, now);
//                                        // 判断是否超时（时间存在字典中，base_single_dictionary）
//                                        if (duration.getSeconds() > dayToSecond) {
//                                            try {
//                                                Files.delete(file);
//                                                System.out.println("已删除文件: " + file);
//                                            } catch (IOException e) {
//                                                System.err.println("删除文件 " + file + " 时出现错误: " + e.getMessage());
//                                            }
//                                        }
//                                    } catch (IOException e) {
//                                        System.err.println("获取文件 " + file + " 的最后修改时间时出现错误: " + e.getMessage());
//                                    }
//                                });
//                    } catch (IOException e) {
//                        System.err.println("遍历 " + sendFolder + " 文件夹时出现错误: " + e.getMessage());
//                    }
//                });
//            } catch (IOException e) {
//                System.err.println("查找send文件夹时出现错误: " + e.getMessage());
//            }
//        } else {
//            System.err.println("D盘的NC目录不存在或不是有效的目录");
//        }
//    }

}