package com.tianbo.analysis.handle;

import com.tianbo.analysis.model.*;
import com.tianbo.analysis.service.CustomMessageService;
import com.tianbo.analysis.tools.AWBTools;
import com.tianbo.util.Date.DateUtil;
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 CustomXmlHandleThread implements Runnable{

    private CountDownLatch latch;
    //备份目录
    @Value("${custom.receptBakDir}")
    private String bakupDir;

    //解析出错转移目录
    @Value("${custom.errBakDir}")
    private String errBakDir;

    //回执转发目录
    @Value("${custom.transmitDir}")
    private String transmitDir;

    //匹配技术回执正则
    @Value("${custom.delTechnologyReceptMatch}")
    private String delTechnologyReceptMatch;

    private File xmlfile;

    private  static CustomXmlHandleThread customXmlHandle;
    //海关新舱单回执报头
    public final static String MessageID =      "//Manifest/Head/MessageID";
    public final static String FunctionCode =   "//Manifest/Head/FunctionCode";
    public final static String MessageType =    "//Manifest/Head/MessageType";
    public final static String SenderID =       "//Manifest/Head/SenderID";
    public final static String ReceiverID =     "//Manifest/Head/ReceiverID";
    public final static String SendTime =       "//Manifest/Head/SendTime";
    public final static String Version =        "//Manifest/Head/Version";


    /**
     * 海关普通业务新舱单回执报体
     */
    public final static String JourneyID =      "//Manifest/Response/BorderTransportMeans/JourneyID";
    public final static String WaybillMaster =  "//Manifest/Response/Consignment/TransportContractDocument/ID";
    public final static String WaybillSecond =  "//Manifest/Response/Consignment/AssociatedTransportDocument/ID";
    public final static String ResponseCode =   "//ResponseType/Code";
    public final static String ResponseText =   "//ResponseType/Text";

    /**
     * 海关国际转运业务回执报体
     */
    public final static String ImportJourneyID = "//Manifest/Response/ImportInformation/BorderTransportMeans/JourneyID";
    public final static String ImportWaybillMaster = "//Manifest/Response/ImportInformation/Consignment/TransportContractDocument/ID";
    public final static String ImportWaybillSecond = "//Manifest/Response/ImportInformation/Consignment/AssociatedTransportDocument/ID";
    public final static String ExportJourneyID = "//Manifest/Response/ExportInformation/BorderTransportMeans/JourneyID";
    public final static String ExportWaybillMaster = "//Manifest/Response/ExportInformation/Consignment/TransportContractDocument/ID";
    public final static String ExportWaybillSecond = "//Manifest/Response/ExportInformation/Consignment/AssociatedTransportDocument/ID";
//    public final static String TransResponseCode =   "//Manifest/Response/ResponseType/Code";
//    public final static String TransResponseText =   "//Manifest/Response/ResponseType/Text";
    public final static String TransResponseCode =   "//ResponseType/Code";
    public final static String TransResponseText =   "//ResponseType/Text";


    //通过@PostConstruct实现初始化bean之前进行的操作,解决service调用空指针问题
    @PostConstruct
    public void init() {
        customXmlHandle = this;

        customXmlHandle.bakupDir = this.bakupDir;

        customXmlHandle.errBakDir = this.errBakDir;

        customXmlHandle.delTechnologyReceptMatch = this.delTechnologyReceptMatch;

        customXmlHandle.transmitDir = this.transmitDir;

        // 初使化时将已静态化的testService实例化
    }

    @Override
    public void run() {
        String filename = xmlfile.getName();
        log.info("线程:{}开始",filename);
        if(filename.matches(customXmlHandle.delTechnologyReceptMatch)){
            log.warn("{}报文为技术回执,剪切到错误备份目录，不解析",filename);
            errBak(xmlfile);
            log.info("{}报文为技术回执,剪切备份成功..开始解析下一文件,当前线程即将结束",filename);
        }
        else
        {
            try{
                //解析前先转发
                FileUtils.copyFileToDirectory(xmlfile, new File(customXmlHandle.transmitDir));
                int i =handelXmlDocument();
                String today = DateUtil.getTodayBy_yyyyMMdd();
                String backdireByDay =  customXmlHandle.bakupDir + "/" + today;
                //操作成功,则转移剪切解析文件到备份目录，否则转移到error目录备份
                if(i>0){
                    File bakupDirectory = new File(backdireByDay);
                    //解析成功备份一份到备份目录
                    FileUtils.moveFileToDirectory(xmlfile,bakupDirectory,true);
                }else {
                    errBak(xmlfile);
                }
            }catch (FileExistsException e){
                log.error("错误的解析文件剪切失败,目标目录已存在同名文件");
            }catch (Exception e){
                log.error("错误的解析文件剪切失败,目标目录已存在同名文件",e);
                errBak(xmlfile);
                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 {

        int i = 0;
        String secondSplit = "_";
        SAXReader saxReader = new SAXReader();
        Document document = saxReader.read(xmlfile);
        Element contentRoot = document.getRootElement();

        String flightNo = "UNKONW";
        String flightDate = "20101010";

        //开始解析
        String msgType = XMLXPath.getSingleValueByPath(document,MessageType);
        String journeyid = XMLXPath.getSingleValueByPath(document,JourneyID);
//            XMLXPath.getSingleValueByPath(document, )


        String awbA = XMLXPath.getSingleValueByPath(document,WaybillMaster);
        //全格式的分单 如 17212345678_ADBD
        String awbH = XMLXPath.getSingleValueByPath(document,WaybillSecond);
        String resCode = XMLXPath.getSingleValueByPath(document,ResponseCode);
        String resText = XMLXPath.getSingleValueByPath(document,ResponseText);
        String messageId = XMLXPath.getSingleValueByPath(document, MessageID);
        String sendTime = XMLXPath.getSingleValueByPath(document,SendTime);
        String sendId = XMLXPath.getSingleValueByPath(document,SenderID);
        String reciveId = XMLXPath.getSingleValueByPath(document,ReceiverID);
        String version = XMLXPath.getSingleValueByPath(document,Version);
        String functionCode = XMLXPath.getSingleValueByPath(document,FunctionCode);



        CustomReception customReception = new CustomReception(  msgType,
                                                                flightNo,
                                                                flightDate,
                                                                awbA,
                                                                awbH,
                                                                resCode,
                                                                resText,
                                                                messageId,
                                                                sendTime,
                                                                sendId,
                                                                reciveId,
                                                                version,
                                                                functionCode);

        /**
         * 如果回执中没有携带航班信息节点，说明是出错报文
         * 到发送日志表根据messageid 找到相应的发送日志报文的航班及运单信息，再进行解析
         */
        if(!StringUtils.isEmpty(journeyid)){

            String[] flightList = journeyid.split("/");
            if(flightList.length > 0){
                flightNo = flightList[0];
                flightDate = flightList[1];
                customReception.setFlightNo(flightNo);
                customReception.setFlightDate(flightDate);
            }
        }else {
            CUSTOMSMESSAGE customsmessage = new CUSTOMSMESSAGE();
            customReception = customsmessage.getWaybillInfoByCutomResponse(customReception);
        }

        switch (msgType){
            case "MT9999":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    PREPARESECONDARY preparesecondary = new PREPARESECONDARY(customReception);
                    int pre_i = preparesecondary.secondAnalysisReception();

                    if (pre_i>0){
                        i=1;
                    }else {
                        ARRIVEDSECONDARY arrivedsecondary = new ARRIVEDSECONDARY(customReception);
                        int arr_i=arrivedsecondary.secondAnalysisReception();

                        if (arr_i>0){
                            i= 1;
                        }else {
                            Originmanifestsecondary originmanifestsecondary = new Originmanifestsecondary(customReception);
                            int org_i=originmanifestsecondary.secondAnalysisReception();
                            if (org_i>0){
                                i=1;
                            }
                        }
                    }
                }else{
                    ORIGINMANIFESTMASTER originmanifestmaster = new ORIGINMANIFESTMASTER(customReception);
                    PREPAREMASTER preparemaster= new PREPAREMASTER(customReception);
                    ARRIVEDMASTER arrivedmaster9999 = new ARRIVEDMASTER(customReception);
                    if(originmanifestmaster.masterAnalysisReception()>0){
                        i=1;
                    }else if(preparemaster.masterAnalysisReception()>0){
                        i=1;
                    }else {
                        i=arrivedmaster9999.masterAnalysisReception();
                    }
                }
                AgentXmlHandle agentXmlHandle=new AgentXmlHandle();
                agentXmlHandle.Http_resolver(customReception);
                break;
            case "MT3201":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    ARRIVEDSECONDARY arrivedsecondary = new ARRIVEDSECONDARY(customReception);
                    i=arrivedsecondary.secondAnalysisReception();
                }else {
                    ARRIVEDMASTER arrivedmaster = new ARRIVEDMASTER(customReception);
                    i=arrivedmaster.masterAnalysisReception();
                }
                break;
            case "MT5202":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    TALLYSECONDARY tallysecondary = new TALLYSECONDARY(customReception);
                    i=tallysecondary.secondAnalysisReception();
                }else {
                    TALLYMASTER tallymaster= new TALLYMASTER(customReception);
                    i = tallymaster.masterAnalysisReception();
                }
                break;
            case "MT5201":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    TALLYSECONDARY tallysecondary = new TALLYSECONDARY(customReception);
                    i=tallysecondary.secondAnalysisReception();
                }else {
                    TALLYMASTER tallymaster= new TALLYMASTER(customReception);
                    i = tallymaster.masterAnalysisReception();
                }
                break;
            case "MT4201":
                DEPARTURESLOADING departuresloading = new DEPARTURESLOADING(customReception);
                i=departuresloading.masterAnalysisReception();
                break;
            case "MT1201":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    Originmanifestsecondary originmanifestsecondary = new Originmanifestsecondary(customReception);
                    i=originmanifestsecondary.secondAnalysisReception();
                }else {
                    ORIGINMANIFESTMASTER originmanifestmaster1201 = new ORIGINMANIFESTMASTER(customReception);
                    i = originmanifestmaster1201.masterAnalysisReception();
                }
                break;
            case "MT2201":
                if (customReception.getWayBillSecond()!=null && customReception.getWayBillSecond().contains(secondSplit)){
                    PREPARESECONDARY preparesecondary = new PREPARESECONDARY(customReception);
                    i = preparesecondary.secondAnalysisReception();
                }else {
                    PREPAREMASTER preparemaster1201= new PREPAREMASTER(customReception);
                    i = preparemaster1201.masterAnalysisReception();
                }
                break;
            case "MT6202":
                INPORTALLOCATE inportallocate = new INPORTALLOCATE(customReception);
                i = inportallocate.masterAnalysisReception();
                break;
            case "MT3202":
                ALLOCATEARRIVAL allocatearrival = new ALLOCATEARRIVAL(customReception);
                i= allocatearrival.masterAnalysisReception();
                break;
            case "MT8205":
                i = transXmlHandel(document,customReception);
                break;
            case "MT8202":
                MANIFESTLOAD manifestload = new MANIFESTLOAD(customReception);
                i= manifestload.secondAnalysisReception();
                break;
            case "MT8203":
                MANIFESTLOSTCHANGE manifestlostchange = new MANIFESTLOSTCHANGE(customReception);
                i= manifestlostchange.secondAnalysisReception();
                break;
            case "MT8024":
                PREPAREMASTER preparemaster1201= new PREPAREMASTER(customReception);
                i = preparemaster1201.masterAnalysisReception();
                break;
            default:
                break;

        }

        updateCustomMessage(customReception);
        return i;

    }

    /**
     * 国际转运回执处理,特殊业务
     * @param document
     * @param customReception
     * @return
     */
    private int transXmlHandel(Document document,CustomReception customReception){

        String importJourneyID = XMLXPath.getSingleValueByPath(document,ImportJourneyID);
        String importFlightNo = "UNKONW";
        String importFlightDate = "20101010";
        if(!StringUtils.isEmpty(importJourneyID)){
            importFlightNo = AWBTools.splitFlightAndDate(importJourneyID)[0];
            importFlightDate = AWBTools.splitFlightAndDate(importJourneyID)[1];
        }


        String importWaybillMaster= XMLXPath.getSingleValueByPath(document,ImportWaybillMaster);
        String importWaybillSecond= XMLXPath.getSingleValueByPath(document,ImportWaybillSecond);
        String transResponseCode=XMLXPath.getSingleValueByPath(document,TransResponseCode);
        String transResponseText=XMLXPath.getSingleValueByPath(document,TransResponseText);
        CustomReception transCustomReception = new CustomReception(  customReception.getMessageType(),
                importFlightNo,
                importFlightDate,
                importWaybillMaster,
                importWaybillSecond,
                transResponseCode,
                transResponseText,
                customReception.getMessageID(),
                customReception.getSendTime(),
                customReception.getSenderID(),
                customReception.getReceiverID(),
                customReception.getVersion(),
                customReception.getFunctionCode());
        INTERNATIONALTRANSIT internationaltransit = new INTERNATIONALTRANSIT(transCustomReception);

        int i=internationaltransit.masterAnalysisReception();

        return i;

    }

    private int updateCustomMessage(CustomReception customReception){
        CUSTOMSMESSAGE customsmessage = new CUSTOMSMESSAGE(customReception);
        return customsmessage.updateMessageByMessageid();
    }

    private void errBak(File file){
        try {
            String today = DateUtil.getTodayBy_yyyyMMdd();
            String errDirByDay = customXmlHandle.errBakDir + "/" + today;
            File berrDirectory = new File(errDirByDay);
            FileUtils.moveFileToDirectory(file,berrDirectory,true);
            log.info("数据库未找到与回执适配的信息备份文件:{}:",file.getName());
        }catch (FileExistsException e){
            log.error("备份解析错误文件失败，目标文件夹存在同名文件{}",file.getName());
        }catch (Exception e){
            e.printStackTrace();
        }
    }

}