package com.tianbo.analysis.handle;

import com.tianbo.analysis.model.*;
import com.tianbo.analysis.service.CustomMessageService;
import com.tianbo.analysis.service.SendLogService;
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.Node;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Autowired;
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.List;
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;

    @Autowired
    SendLogService sendLogService;

    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 Consignment =  "//Manifest/Response/Consignment";
    public final static String WaybillMaster_NODE =  "TransportContractDocument/ID";
    public final static String WaybillSecond_NODE =  "AssociatedTransportDocument/ID";
    public final static String ResponseCode_NODE =   "ResponseType/Code";
    public final static String ResponseText_NODE =   "ResponseType/Text";

    /**
     * 海关普通业务新舱单回执报体
     */
    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;
        customXmlHandle.sendLogService = this.sendLogService;

        // 初使化时将已静态化的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;
        SAXReader saxReader = new SAXReader();
        Document document = saxReader.read(xmlfile);
        Element contentRoot = document.getRootElement();

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

        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);
        //开始解析
        String msgType = XMLXPath.getSingleValueByPath(document,MessageType);
        String journeyid = XMLXPath.getSingleValueByPath(document,JourneyID);

        List<Node>  ConsignmentNodes = XMLXPath.getPathValues(document,Consignment);

        String awbA=null ,awbH=null,resCode=null,resText= null;

        //说明有带运单的回执
        if (!ConsignmentNodes.isEmpty()){
            for (Node node: ConsignmentNodes ) {

                //全格式的分单 如 17212345678_ADBD
                 awbH = XMLXPath.getSingleValueByNodePath(node,WaybillSecond_NODE);
                 awbA = XMLXPath.getSingleValueByNodePath(node,WaybillMaster_NODE);
                 resCode = XMLXPath.getSingleValueByNodePath(node,ResponseCode_NODE);
                 resText = XMLXPath.getSingleValueByNodePath(node,ResponseText_NODE);

                log.info("主单:{}-分单:{}-回执代码:{}-回执内容:{}",awbA, awbH,resCode,resText);
                i =+ normalXmlHandel(msgType,
                        flightNo,
                        flightDate,
                        awbA,
                        awbH,
                        resCode,
                        resText,
                        messageId,
                        sendTime,
                        sendId,
                        reciveId,
                        version,
                        functionCode,
                        journeyid,
                        document);
            }
            return i;
        }else{//国际转运回执在这里处理
             awbA = XMLXPath.getSingleValueByPath(document,WaybillMaster);
            //全格式的分单 如 17212345678_ADBD
             awbH = XMLXPath.getSingleValueByPath(document,WaybillSecond);
             resCode = XMLXPath.getSingleValueByPath(document,ResponseCode);
             resText = XMLXPath.getSingleValueByPath(document,ResponseText);
            i =+ normalXmlHandel(msgType,
                    flightNo,
                    flightDate,
                    awbA,
                    awbH,
                    resCode,
                    resText,
                    messageId,
                    sendTime,
                    sendId,
                    reciveId,
                    version,
                    functionCode,
                    journeyid,
                    document);
            return i;

        }





    }

    private int normalXmlHandel(String msgType,
                                String flightNo,
                                String flightDate,
                                String awbA,
                                String awbH,
                                String resCode,
                                String resText,
                                String messageId,
                                String sendTime,
                                String sendId,
                                String reciveId,
                                String version,
                                String functionCode,
                                String journeyid,
                                Document document
    ){
        String secondSplit = "_";
        int i = 0;
        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 "MT8204":
                PREPAREMASTER preparemaster1201= new PREPAREMASTER(customReception);
                preparemaster1201.masterAnalysisReception();
                i = customXmlHandle.sendLogService .updateMT8204(customReception);
                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();
        }
    }

}