analysis_imf for station version 1.0

+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/build/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/

+log4j=log_api.xml
+
+isneedlog=N
+
+psip=10.50.3.74
+
+psport=7484
+
+
+
+

+#log4j.rootLogger=DEBUG, Console  
+#Console
+#log4j.appender.Console=org.apache.log4j.ConsoleAppender  
+#log4j.appender.Console.layout=org.apache.log4j.PatternLayout  
+#log4j.appender.Console.layout.ConversionPattern=%d [%t] %-5p [%c] - %m%n  
+#log4j.logger.java.sql.ResultSet=INFO
+#log4j.logger.org.apache=INFO  
+#log4j.logger.net.cxp.blog.dao=DEBUG
+#log4j.logger.java.sql.Connection=DEBUG  
+#log4j.logger.java.sql.Statement=DEBUG  
+#log4j.logger.java.sql.PreparedStatement=DEBUG  
+# Output pattern : date [thread] priority category - message   FATAL 0  ERROR 3  WARN 4  INFO 6  DEBUG 7
+log4j.rootLogger=INFO, stdout, fileout
+
+log4j.logger.com.fiscal = INFO
+#*******************************
+log4j.logger.com.system = INFO
+#*******************************
+log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+log4j.appender.stdout.layout.ConversionPattern=%d{MM-dd HH:mm:ss,SSSS}[%p] %m%n
+
+#RollingFile
+log4j.appender.fileout=org.apache.log4j.RollingFileAppender
+log4j.appender.fileout.File=logs/imf.log
+log4j.appender.fileout.MaxFileSize=50MB
+log4j.appender.fileout.MaxBackupIndex=10
+log4j.appender.fileout.layout=org.apache.log4j.PatternLayout
+log4j.appender.fileout.layout.ConversionPattern=%d{MM-dd HH:mm:ss,SSSS}[%p] %m%n
+
+

+<?xml version="1.0" encoding="UTF-8"?>    
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+<log4j:configuration xmlns:log4j='http://jakarta.apache.org/log4j/'>
+	<appender name="INFOFILE" class="org.apache.log4j.RollingFileAppender">
+		<param name="File" value="Logs/INFO.log" />
+		<param name="MaxFileSize" value="3000KB" />
+		<param name="MaxBackupIndex" value="20" />
+		<param name="Encoding" value="UTF-8" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="[runtime] %d -%-4r [%t] %x - %m%n" />
+		</layout>
+		<filter class="org.apache.log4j.varia.LevelRangeFilter">
+			<param name="levelMin" value="debug" />
+			<param name="levelMax" value="info" />
+			<param name="AcceptOnMatch" value="true" />
+		</filter>
+	</appender>
+	<appender name="ERRFILE" class="org.apache.log4j.RollingFileAppender">
+		<param name="File" value="Logs/ERROR.log" />
+		<param name="MaxFileSize" value="3000KB" />
+		<param name="MaxBackupIndex" value="20" />
+		<param name="Encoding" value="UTF-8" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="[runtime] %d -%-4r [%t] %x - %m%n" />
+		</layout>
+		<filter class="org.apache.log4j.varia.LevelRangeFilter">
+			<param name="levelMin" value="error" />
+			<param name="levelMax" value="error" />
+			<param name="AcceptOnMatch" value="true" />
+		</filter>
+	</appender>
+	<appender name="WSINFOFILE" class="org.apache.log4j.RollingFileAppender">
+		<param name="File" value="Logs/wsINFO.log" />
+		<param name="MaxFileSize" value="3000KB" />
+		<param name="MaxBackupIndex" value="20" />
+		<param name="Encoding" value="UTF-8" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="[runtime] %d -%-4r [%t] %x - %m%n" />
+		</layout>
+		<filter class="org.apache.log4j.varia.LevelRangeFilter">
+			<param name="levelMin" value="debug" />
+			<param name="levelMax" value="info" />
+			<param name="AcceptOnMatch" value="true" />
+		</filter>
+	</appender>
+	<appender name="WSERRFILE" class="org.apache.log4j.RollingFileAppender">
+		<param name="File" value="Logs/wsERROR.log" />
+		<param name="MaxFileSize" value="3000KB" />
+		<param name="MaxBackupIndex" value="20" />
+		<param name="Encoding" value="UTF-8" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="[runtime] %d -%-4r [%t] %x - %m%n" />
+		</layout>
+		<filter class="org.apache.log4j.varia.LevelRangeFilter">
+			<param name="levelMin" value="error" />
+			<param name="levelMax" value="error" />
+			<param name="AcceptOnMatch" value="true" />
+		</filter>
+	</appender>
+	<logger name="apiLog">
+		<level value="INFO" />
+		<appender-ref ref="INFOFILE" />
+		<appender-ref ref="ERRFILE" />
+	</logger>
+	<logger name="WS">
+		<appender-ref ref="WSINFOFILE" />
+		<appender-ref ref="WSERRFILE" />
+	</logger>
+	<root>
+		<priority value="ERROR" />
+	</root>
+</log4j:configuration>    

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.sy</groupId>
+    <artifactId>analysis_imf</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <packaging>war</packaging>
+
+    <name>analysis_imf</name>
+    <description>Demo project for Spring Boot</description>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.1.0.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <java.version>1.8</java.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-tomcat</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <!--使用durid连接池的依赖-->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+            <version>1.1.9</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tomcat.embed</groupId>
+            <artifactId>tomcat-embed-jasper</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.thoughtworks.xstream</groupId>
+            <artifactId>xstream</artifactId>
+            <version>1.4.7</version>
+        </dependency>
+
+        <dependency>
+            <groupId>net.sf.sociaal</groupId>
+            <artifactId>xmlpull-xpp3</artifactId>
+            <version>3.0.0.20130526</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper-spring-boot-starter</artifactId>
+            <version>1.2.3</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.mybatis.generator</groupId>
+            <artifactId>mybatis-generator-core</artifactId>
+            <version>1.3.6</version>
+        </dependency>
+
+        <dependency>
+            <groupId>log4j</groupId>
+            <artifactId>log4j</artifactId>
+            <version>1.2.17</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+            <!-- mybatis generator 自动生成代码插件 -->
+            <plugin>
+                <groupId>org.mybatis.generator</groupId>
+                <artifactId>mybatis-generator-maven-plugin</artifactId>
+                <version>1.3.5</version>
+                <configuration>
+                    <configurationFile>${basedir}/src/main/resources/generator/generatorConfig.xml</configurationFile>
+                    <overwrite>true</overwrite>
+                    <verbose>true</verbose>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+
+</project>

+package com.sy;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@SpringBootApplication
+@EnableScheduling
+@MapperScan(value = "com.sy.mapper")
+public class AnalysisImfApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(AnalysisImfApplication.class, args);
+    }
+}

+package com.sy.IMF;
+
+import com.caac.imf.api.IMFClient;
+import com.caac.imf.api.IMFClientFactory;
+import org.apache.log4j.Logger;
+import org.apache.log4j.PropertyConfigurator;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author zhangfan
+ * @web www.sy.com
+ * @company 郑州商友科技有限公司
+ * @time 2018-11-27 16:05
+ */
+@Component
+public class IMF_Tesk {
+
+    protected static final Logger logger = Logger.getLogger(IMF_Tesk.class);
+
+    public static boolean LOGIN_OK = false;
+    public static boolean isSuc = true;
+    public static IMFClient client = null;
+
+    @Scheduled(fixedRate = 5000)
+    private static void start() throws Exception {
+        PropertyConfigurator.configure("config/log4j.properties");
+        client = IMFClientFactory.createInstance();
+
+
+        if (client != null) {
+            if (!KAKO_Reader.isrunning) {
+                KAKO_Reader kako_reader = new KAKO_Reader(client);
+                kako_reader.start();
+                logger.info("*********KAKO读取线程已开启***********");
+            } else {
+                logger.info("*********KAKO读取线程已开启-不再启动线程*********");
+            }
+
+            if(!KAKO_Sender.isrunning){
+                KAKO_Sender kako_sender = new KAKO_Sender(client);
+                kako_sender.start();
+                logger.info("<<<<<<<<<KAKO发送线程已开启>>>>>>>>>>>>");
+            }else {
+                logger.info("<<<<<<<<<KAKO发送线程已开启-不再启动线程>>>>>>>>>>>>");
+            }
+
+        }
+        if (!LOGIN_OK){
+             loginIMF(client, "KAOR", "KAOR", "config/imf_config.properties");
+        }
+
+
+
+    }
+
+    private static void loginIMF(IMFClient client, String userName, String password, String confFileName) {
+        if (client.initial(confFileName)) {
+            String message = client.login(userName, password);
+            logger.info("message=" + message);
+            if (message.indexOf("<CODE>1</CODE>") > 0) {
+                logger.info("登陆成功");
+                LOGIN_OK = true;
+            } else {
+                int times = 0;
+
+                while(times <= 3) {
+                    logger.info("try connection...");
+                    ++times;
+                    logger.info("message.=" + message);
+                    if (message.indexOf("<CODE>1</CODE>") > 0) {
+                        logger.info("登陆成功");
+                        LOGIN_OK = true;
+                        break;
+                    }
+
+                    logger.info("登录失败~~~~");
+                    message = client.login(userName, password);
+
+                    try {
+                        Thread.sleep(4000L);
+                    } catch (InterruptedException var7) {
+                        var7.printStackTrace();
+                    }
+                }
+
+                if (!LOGIN_OK) {
+                    logger.info("多次尝试登录失败，退出登陆");
+                    client.disconnect();
+                    isSuc =false;
+                    System.exit(-1);
+                }
+            }
+        }
+
+    }
+}

+package com.sy.IMF;
+
+import com.caac.imf.api.IMFClient;
+import com.sy.controller.AnalysisRoute;
+import org.apache.log4j.Logger;
+
+public class KAKO_Reader extends Thread{
+    protected static final Logger logger = Logger.getLogger(KAKO_Reader.class);
+    private IMFClient client;
+    public static  boolean isrunning;
+
+    public KAKO_Reader(IMFClient client) {
+        this.client = client;
+    }
+
+    public void run() {
+
+        try{
+            isrunning =true;
+            while(true) {
+                if (IMF_Tesk.LOGIN_OK) synchronized (this) {
+                    String message = this.client.getMSG();
+                    if (message != null) {
+                        logger.info(message);
+                        AnalysisRoute route = new AnalysisRoute();
+                        route.analysis(message);
+                    }
+                }
+                else {
+                    //logger.info("***");
+                }
+
+                try {
+                    Thread.sleep(100L);
+                } catch (InterruptedException var3) {
+                    var3.printStackTrace();
+
+                }
+            }
+
+        }catch (Exception e){
+
+        }
+        isrunning=false;
+        logger.info("****************读取线程不在了****************");
+    }
+}

+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("<<<<<<<<<<<发送线程不在了>>>>>>>>>>>>");
+    }
+}

+package com.sy;
+
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+
+public class ServletInitializer extends SpringBootServletInitializer {
+
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
+        return application.sources(AnalysisImfApplication.class);
+    }
+
+}