CustomXmlHandle.java 3.9 KB
package com.tianbo.analysis.handle;

import com.tianbo.analysis.model.CustomReception;
import com.tianbo.analysis.service.CoustomAnalysisService;
import com.tianbo.util.XML.XMLXPath;
import org.apache.commons.io.FileUtils;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.xml.sax.SAXParseException;

import javax.annotation.PostConstruct;
import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.List;

/**
 * @author mrz
 * @e
 * 海关新舱单回执解析xml文件
 */
@Component
public class CustomXmlHandle {

    private  static  CustomXmlHandle 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 =   "//Manifest/Response/Consignment/ResponseType/Code";
    public final static String responseText =   "//Manifest/Response/Consignment/ResponseType/Text";

    @Autowired
    private CoustomAnalysisService coustomAnalysisService;

    //通过@PostConstruct实现初始化bean之前进行的操作,解决service调用空指针问题
    @PostConstruct
    public void init() {
        customXmlHandle = this;
        customXmlHandle.coustomAnalysisService = this.coustomAnalysisService;
        // 初使化时将已静态化的testService实例化
    }

    /**
     *
     * @param file 回执目录的文件
     * @return
     * @throws DocumentException
     * @throws UnsupportedEncodingException
     * @throws SAXParseException
     */
    public int handelXmlDocument(File file) throws DocumentException,UnsupportedEncodingException,SAXParseException {

        SAXReader saxReader = new SAXReader();
        Document document = saxReader.read(file);
        Element contentRoot = document.getRootElement();

        //要解析的回执类型
        String type= "MT9999";

        //开始解析
//        fzeFoh.setGrossweightmeasureuc(XMLXPath.getSingleValueByPath(document,GrossWeightMeasureUc));
        String msgType = XMLXPath.getSingleValueByPath(document,MessageType);
        if (type.equals(msgType)){
            String journeyid = XMLXPath.getSingleValueByPath(document,JourneyID);
            String[] flightList = journeyid.split("/");
            String flightNo = flightList[0];
            String flightDate = flightList[1];
            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);

            CustomReception customReception = new CustomReception(msgType,flightNo,flightDate,awbA,awbH,resText);

            int i = customXmlHandle.coustomAnalysisService.insertRecept(customReception);

            return i;

        }
        return 0;

    }
}