package com.ruoyi.interchange.service.impl;

import com.alibaba.fastjson2.JSON;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.uuid.UUID;
import com.ruoyi.framework.config.ActiveManager;
import com.ruoyi.interchange.domain.TbDataRules;
import com.ruoyi.interchange.domain.TbDataSendRecords;
import com.ruoyi.interchange.service.ITbDataSendRecordsService;
import com.ruoyi.interchange.service.PlatformService;
import com.ruoyi.utils.DESUtil;
import com.ruoyi.utils.FileUtils;
import com.ruoyi.utils.FtpUtils;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.jms.Destination;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Service
public class PlatformServiceImpl implements PlatformService {
    @Autowired
    public ITbDataSendRecordsService tbDataSendRecordsService;
    @Autowired
    private ActiveManager activeManager;
    /**
     * 将文件夹下的文件校验，发送
     *
     * @param rule 校验规则对象
     * @param list 接收文件列表
     */
    public void checkFileName(TbDataRules rule, List<File> list){
        try {
            Date date=new Date();
            SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String path=rule.getReceiveUrl();
            FtpUtils ftpUtil=new FtpUtils();
            String ftpPath= RuoYiConfig.getFtpPath()+"/"+path;        //接收文件路径
            String sendPath= RuoYiConfig.getFtpPath()+"/send/"+path; //待发送路径
            String bakPath=RuoYiConfig.getFtpPath()+"/bak/"+path;    //备份路径
            TbDataSendRecords records=new TbDataSendRecords();      //接收文件记录
            if(StringUtils.isNotEmpty(rule.getCoalMineCode())){
                records.setCoalMineId(Long.parseLong(rule.getCoalMineCode()));
            }
            UUID uuid=UUID.randomUUID();
            records.setId(uuid.toString());
            records.setSystemId(rule.getSystemId());
            records.setRuleId(rule.getId());
            records.setDetectionTime(new Date());
            String dataHeader=rule.getCheckHead()+"0;"+sdf.format(date);
            records.setDataHeader(dataHeader);
            if(list==null||list.size()==0){
                //生成校验记录未接收到文件，已经生成空白文件
                String fileName= FileUtils.createFtpFile(path,rule.getCheckTitle(),rule.getCheckHead());
                records.setFileName(fileName);
                records.setDataNumber(0l);
                records.setSendFileUrl(sendPath);
                records.setDetectionResult("0");
                records.setCheckResult("1");
                fileName=fileName.substring(0,fileName.length()-4)+".tmp";
                String fileRoot=sendPath+"/"+fileName;
                boolean storeFlag=ftpUtil.uploadFile(path,"",fileName,fileRoot);
                if(storeFlag){
                    records.setSendResult("0");
                }else{
                    records.setSendResult("1");
                }
                tbDataSendRecordsService.recordSaveMongo(records);
                Boolean flag= FileUtils.deleteFile(fileRoot);
                System.out.println("是否成功删除=====================================================================》"+flag);
            }else{
                boolean noHave = true;
                for(File file:list){
                    if(file.getName().contains(rule.getCheckTitle())){
                        //生成校验记录已接收到文件，文件标题校验通过
                        records.setFileName(file.getName());
                        records.setSendFileUrl(sendPath);
                        records.setDetectionResult("0");
                        records.setCheckResult("0");
                        tbDataSendRecordsService.recordSaveMongo(records);
                        //文件名符合规范
                        //文件发送到send文件夹下
                        FileUtils.copyFile(new File(ftpPath+"/"+file.getName()),new File(sendPath+"/"+file.getName()));
                        //文件发送bak文件夹下
                        FileUtils.copyFile(new File(ftpPath+"/"+file.getName()),new File(bakPath+"/"+file.getName()));
                        //删除201目录下的文件
                        file.delete();
                        //校验与加密队列
                        Destination destination = new ActiveMQQueue("encryption");//P2P模式单个消费者
                        rule.setSendPath(sendPath+"/"+file.getName());
                        activeManager.send(destination,JSON.toJSONString(rule));
                        noHave = false;
                    }
                }
                if (noHave){
                    String fileName=FileUtils.createFtpFile(path,rule.getCheckTitle(),rule.getCheckHead());
                    records.setFileName(fileName);
                    records.setDataNumber(0l);
                    records.setSendFileUrl(sendPath);
                    records.setDetectionResult("0");
                    records.setCheckResult("1");
                    fileName=fileName.substring(0,fileName.length()-4)+".tmp";
                    String fileRoot=sendPath+"/"+fileName;
                    boolean storeFlag=ftpUtil.uploadFile(path,"",fileName,fileRoot);
                    if(storeFlag){
                        records.setSendResult("0");
                    }else{
                        records.setSendResult("1");
                    }
                    tbDataSendRecordsService.recordSaveMongo(records);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 将发送失败的文件重新发送
     *
     */
    public void waitFileSend(String path){
        try {
            String filePath=RuoYiConfig.getFtpPath()+"/wait"+"/"+path;        //接收文件路径
            FtpUtils ftpUtils=new FtpUtils();
            List<File>list= FileUtils.getAllFile(filePath);
            if(list!=null&&list.size()>0){
                for(File file:list){
                    Boolean flag=ftpUtils.uploadFile(path,"",file.getName(),file.getPath());
                    if(flag){
                        Files.delete(Paths.get(file.getPath()));
                    }
                }
            }
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }




    public void  fileEncrypt(String path,String tmpPath) throws Exception {
        FileOutputStream fot=null;
        OutputStreamWriter ops=null;
        File tmpFile=new File(tmpPath);
        tmpFile.createNewFile();
        try {
            //文件加密
            List<String>list=FileUtils.readFile(path);
            byte []fileByte=new byte[list.size()];
            fot=new FileOutputStream(tmpFile);
            ops=new OutputStreamWriter(fot);
            for(int i=0;i<list.size();i++){
                fileByte=list.get(i).getBytes(StandardCharsets.UTF_8);
                byte[] byte2= DESUtil.encrypt(fileByte,RuoYiConfig.getPass());
                String line=DESUtil.byteToHex(byte2);
                ops.write(line);
            }
            //FileUtils.moveFile(path,tmpPath);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(ops!=null){
                ops.flush();
                ops.close();
            }
            if(fot!=null){
                fot.flush();
                fot.close();
            }
        }
    }
    public  void  fileEncrypt2(String path,String tmpPath) throws Exception {
        FileOutputStream fot=null;
        OutputStreamWriter ops=null;
        File file=new File(path);
        try {
            //文件加密
            List<String>list=FileUtils.readFile(path);
            byte []fileByte=new byte[list.size()];
            fot=new FileOutputStream(file);
            ops=new OutputStreamWriter(fot);
            for(int i=0;i<list.size();i++){
                fileByte=list.get(i).getBytes(StandardCharsets.UTF_8);
                byte[] byte2= DESUtil.encrypt(fileByte,"xxxltk00");
                String line=DESUtil.byteToHex(byte2);
                ops.write(line);
            }
            ops.flush();
            fot.flush();
            ops.close();
            fot.close();
            FileUtils.moveFile(path,tmpPath);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(ops!=null){
                ops.close();
            }
            if(fot!=null){
                fot.close();
            }
        }
    }
    public void  fileEncrypt3(String path,String tmpPath) throws Exception {
        FileOutputStream fot=null;
        OutputStreamWriter ops=null;
        File file=new File(path);
        try {
            //文件加密
            List<String>list=FileUtils.readFile(path);
            byte []fileByte=new byte[list.size()];
            fot=new FileOutputStream(file);
            ops=new OutputStreamWriter(fot);
            for(int i=0;i<list.size();i++){
                fileByte=list.get(i).getBytes(StandardCharsets.UTF_8);
                byte[] byte2= DESUtil.encrypt(fileByte,"xxxltk00");
                String line=DESUtil.byteToHex(byte2);
                ops.write(line);
            }
            FileUtils.moveFile(path,tmpPath);
            ops.flush();
            fot.flush();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(ops!=null){
                ops.close();
            }
            if(fot!=null){
                fot.close();
            }
        }
    }

}