KAKO_Sender.java 6.2 KB
package com.sy.IMF;

import com.caac.imf.api.IMFClient;
import org.apache.log4j.Logger;

public class KAKO_Sender extends Thread{

    protected static final Logger logger = Logger.getLogger(KAKO_Sender.class);
    public static  boolean isrunning;
    private IMFClient client;
    public KAKO_Sender(IMFClient client) {
        this.client = client;
    }
    private String SendMsg = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
            "<Msg>\n" +
            "\t<META>\n" +
            "\t\t<SNDR>ZWY</SNDR>\n" +
            "\t\t<RCVR/>\n" +
            "\t\t<SEQN>16078357182</SEQN>\n" +
            "\t\t<DDTM>20181116175107671</DDTM>\n" +
            "\t\t<TYPE>HYXX</TYPE>\n" +
            "\t\t<STYP>NDLR</STYP>\n" +
            "\t</META>\n" +
            "\t<DECLAREPREPAREMASTERXMLBODY>\n" +
            "\t\t<Head>\n" +
            "\t\t\t<MessageID>CN_MT2201_1p1_4604729604327_20181116174636305</MessageID>\n" +
            "\t\t\t<FunctionCode>9</FunctionCode>\n" +
            "\t\t\t<MessageType>MT2201MASTER</MessageType>\n" +
            "\t\t\t<SenderID>460470678920X_DXPENT0000460002_20181116175107671</SenderID>\n" +
            "\t\t\t<ReceiverID>4604_20181116175107671</ReceiverID>\n" +
            "\t\t\t<SendTime>20181116175107671</SendTime>\n" +
            "\t\t\t<Version>1.0</Version>\n" +
            "\t\t</Head>\n" +
            "\t\t<Declaration>\n" +
            "\t\t\t<Carrier>\n" +
            "\t\t\t\t<ID>KA</ID>\n" +
            "\t\t\t</Carrier>\n" +
            "\t\t\t<ORG>\n" +
            "\t\t\t\t<ID>CGO</ID>\n" +
            "\t\t\t</ORG>\n" +
            "\t\t\t<DES>\n" +
            "\t\t\t\t<ID>LAX</ID>\n" +
            "\t\t\t</DES>\n" +
            "\t\t\t<BorderTransportMeans>\n" +
            "\t\t\t\t<JourneyID>749/2018-11-18</JourneyID>\n" +
            "\t\t\t</BorderTransportMeans>\n" +
            "\t\t\t<Consignment>\n" +
            "\t\t\t\t<TransportContractDocument>\n" +
            "\t\t\t\t\t<ID>160-78357182</ID>\n" +
            "\t\t\t\t</TransportContractDocument>\n" +
            "\t\t\t\t<AssociatedTransportDocument>\n" +
            "\t\t\t\t\t<ID/>\n" +
            "\t\t\t\t</AssociatedTransportDocument>\n" +
            "\t\t\t\t<LoadingLocation>\n" +
            "\t\t\t\t\t<ID>CGO/4620</ID>\n" +
            "\t\t\t\t\t<LoadingDate>2018-11-16 21:46</LoadingDate>\n" +
            "\t\t\t\t</LoadingLocation>\n" +
            "\t\t\t\t<UnloadingLocation>\n" +
            "\t\t\t\t\t<ID>CGO/4620</ID>\n" +
            "\t\t\t\t</UnloadingLocation>\n" +
            "\t\t\t\t<TransportSplitIndicator>0</TransportSplitIndicator>\n" +
            "\t\t\t\t<ConsignmentPackaging>\n" +
            "\t\t\t\t\t<QuantityQuantity>1</QuantityQuantity>\n" +
            "\t\t\t\t</ConsignmentPackaging>\n" +
            "\t\t\t\t<TotalGrossMassMeasure>65</TotalGrossMassMeasure>\n" +
            "\t\t\t\t<PreQuantityQuantity>1</PreQuantityQuantity>\n" +
            "\t\t\t\t<PreTotalGrossMassMeasure>65</PreTotalGrossMassMeasure>\n" +
            "\t\t\t\t<CustomsStatus>001</CustomsStatus>\n" +
            "\t\t\t\t<FreightPayment>\n" +
            "\t\t\t\t\t<MethodCode>PP</MethodCode>\n" +
            "\t\t\t\t</FreightPayment>\n" +
            "\t\t\t\t<ProductName>CELL PHONE</ProductName>\n" +
            "\t\t\t\t<PrepareTime>2018-11-16 21:46</PrepareTime>\n" +
            "\t\t\t\t<CustomsCode>4620</CustomsCode>\n" +
            "\t\t\t\t<AgentName>中外运空运发展股份有限公司郑州分公司</AgentName>\n" +
            "\t\t\t\t<AgentCompany>中外运空运发展股份有限公司郑州分公司</AgentCompany>\n" +
            "\t\t\t\t<NameOfgoods>CELL PHONE</NameOfgoods>\n" +
            "\t\t\t\t<DeliveryStation>001</DeliveryStation>\n" +
            "\t\t\t\t<UNnumber/>\n" +
            "\t\t\t\t<Category/>\n" +
            "\t\t\t\t<Consignee>\n" +
            "\t\t\t\t\t<Name>FEDEX TRADE NETWORKS TRANSPORT</Name>\n" +
            "\t\t\t\t\t<Address>\n" +
            "\t\t\t\t\t\t<Line>17210 SOUTH MAIN STREET GARDENA</Line>\n" +
            "\t\t\t\t\t\t<CityName>LOS ANGELES</CityName>\n" +
            "\t\t\t\t\t\t<CountryCode>US</CountryCode>\n" +
            "\t\t\t\t\t\t<ZipCode/>\n" +
            "\t\t\t\t\t\t<PROVINCECODE/>\n" +
            "\t\t\t\t\t\t<PROVINCENAME/>\n" +
            "\t\t\t\t\t\t<Deltaname/>\n" +
            "\t\t\t\t\t\t<TelePhone>3109655000</TelePhone>\n" +
            "\t\t\t\t\t\t<Fax/>\n" +
            "\t\t\t\t\t\t<CNECUSID>EIN+160807223</CNECUSID>\n" +
            "\t\t\t\t\t\t<CNEAEO/>\n" +
            "\t\t\t\t\t\t<Unlodingcode>LAX</Unlodingcode>\n" +
            "\t\t\t\t\t</Address>\n" +
            "\t\t\t\t</Consignee>\n" +
            "\t\t\t\t<Consignor>\n" +
            "\t\t\t\t\t<name>FEDEX</name>\n" +
            "\t\t\t\t\t<Address>\n" +
            "\t\t\t\t\t\t<Line>ROOM7</Line>\n" +
            "\t\t\t\t\t\t<CountryCode>CN</CountryCode>\n" +
            "\t\t\t\t\t\t<ZipCode/>\n" +
            "\t\t\t\t\t\t<Deltaname/>\n" +
            "\t\t\t\t\t\t<TelePhone>8637155131789</TelePhone>\n" +
            "\t\t\t\t\t\t<Fax/>\n" +
            "\t\t\t\t\t\t<SHPAEO/>\n" +
            "\t\t\t\t\t\t<SHPCUSID>USCI+91410100053384175K</SHPCUSID>\n" +
            "\t\t\t\t\t</Address>\n" +
            "\t\t\t\t</Consignor>\n" +
            "\t\t\t</Consignment>\n" +
            "\t\t</Declaration>\n" +
            "\t</DECLAREPREPAREMASTERXMLBODY>\n" +
            "</Msg>";

    public void run(){
        try {

            if (this.client == null) {
                logger.info("IMFClient has been closed");
                return;
            }
            isrunning=true;
            if(IMF_Tesk.isSuc){
//                logger.info("<<<<<<<<<<<主线程初始化成功>>>>>>>>>>>>");
                if(IMF_Tesk.LOGIN_OK){

                    String returnMsg = this.client.sendMSG(SendMsg);
                    logger.info("《--------发送信息成功开始轮询500mm一次--------"+returnMsg);
                }else{
                    logger.info("<<<<<<<<<<<登陆中>>>>>>>>>>>>");
                }
            }

        }catch (Exception var14) {
            var14.printStackTrace();
            logger.info(var14.getMessage());
        }




        isrunning=false;
        logger.info("<<<<<<<<<<<发送线程不在了>>>>>>>>>>>>");
    }
}