package com.tianbo.analysis.handle;

import com.tianbo.analysis.model.*;
import com.tianbo.analysis.tools.AWBTools;
import com.tianbo.util.Date.DateUtil;
import com.tianbo.util.RabitMq.MQSendMsg;
import com.tianbo.util.RabitMq.exchange.ExSendMsg;
import com.tianbo.util.XML.XMLXPath;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileExistsException;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringUtils;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.xml.sax.SAXParseException;

import javax.annotation.PostConstruct;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.concurrent.CountDownLatch;

/**
 * @author mrz
 * @e
 * 海关新舱单回执解析xml文件
 */
@Data
@Component
@Slf4j
public class SendXml2MqThread implements Runnable{

    private CountDownLatch latch;

    private File xmlfile;

    private  String mqIp;

    private  int mqPort;

    private  String mqVhost;

    private  String mqUsername;

    private  String mqPassword;

    private String queueName;

    private String exchangeName;

    private String exchangeType;

    private String routingName;


    @Override
    public void run() {
        String filename = xmlfile.getName();
        log.info("线程:{}开始",filename);

        try{
            //解析前先转发
            int i = handelXmlDocument();
            //发送成功删除，发送失败不管保留报文
            if(i==1){
                FileUtils.forceDelete(xmlfile);
            }

        }catch (IOException ioe){
            log.error("文件不存在",ioe);
            ioe.printStackTrace();
        } catch (Exception e){
            log.error("错误的解析文件剪切失败,目标目录已存在同名文件",e);
            e.printStackTrace();
        }



        log.info("线程:{}结束",xmlfile.getName());
        latch.countDown();
        log.info("剩余线程数量{}",latch.getCount());
    }
    /**
     *
     *
     * @return
     * @throws DocumentException
     * @throws UnsupportedEncodingException
     * @throws SAXParseException
     * @throws FileNotFoundException
     */
    private int handelXmlDocument() throws DocumentException,UnsupportedEncodingException,SAXParseException,FileNotFoundException, IOException {

        int i = 0;
        String content = FileUtils.readFileToString(xmlfile,"UTF-8");
        /**
         * 发送消息到交换上
         */
        boolean success = ExSendMsg.sendMsg(
                exchangeName,
                exchangeType,
                routingName,
                queueName,
                content,
                mqIp,
                mqPort,
                mqVhost,
                mqUsername,
                mqPassword
        );

        return success ? 1 : 0;

    }


}