From f967ff6f6e7bcba144e61b4ff4cc07dd2bc3d8c6 Mon Sep 17 00:00:00 2001 From: zhouxiunai <154707516@qq.com> Date: Wed, 5 Dec 2018 20:27:50 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=88=AA=E7=8F=AD=E5=AE=9E?= =?UTF-8?q?=E9=99=85=E6=97=B6=E9=97=B4=E4=BA=8B=E4=BB=B6=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/msg/flop/actt/ACTTMsg.java | 39 ++++++++++++++++ .../entity/msg/flop/actt/FLOP.java | 44 +++++++++++++++++++ .../msghandler/flop/ACFTHandler.java | 7 +++ .../msghandler/flop/ACTTHandler.java | 42 ++++++++++++++++++ 4 files changed, 132 insertions(+) create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/ACTTMsg.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/FLOP.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACTTHandler.java diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/ACTTMsg.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/ACTTMsg.java new file mode 100644 index 00000000..4cf5652e --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/ACTTMsg.java @@ -0,0 +1,39 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.actt; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlRootElement; +import com.gzzn.omms.msgexchangeapi.entity.msg.META; + +/** + * Auto-generated: 2018-12-05 20:16:56 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@JacksonXmlRootElement(localName="MSG") +@JsonIgnoreProperties(ignoreUnknown = true) +public class ACTTMsg { + + @JacksonXmlProperty(localName ="META") + private META META; + @JacksonXmlProperty(localName ="FLOP") + private FLOP FLOP; + public void setMETA(META META) { + this.META = META; + } + public META getMETA() { + return META; + } + + public void setFLOP(FLOP FLOP) { + this.FLOP = FLOP; + } + public FLOP getFLOP() { + return FLOP; + } + +} \ No newline at end of file diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/FLOP.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/FLOP.java new file mode 100644 index 00000000..6efd6a6f --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/actt/FLOP.java @@ -0,0 +1,44 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.actt; + +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; + +/** + * Auto-generated: 2018-12-05 20:16:56 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +public class FLOP { + + @JacksonXmlProperty(localName ="FLID") + private String FLID; + @JacksonXmlProperty(localName ="FFID") + private String FFID; + @JacksonXmlProperty(localName ="ACTT") + private String ACTT; + + public void setFLID(String FLID) { + this.FLID = FLID; + } + public String getFLID() { + return FLID; + } + + public void setFFID(String FFID) { + this.FFID = FFID; + } + public String getFFID() { + return FFID; + } + + public void setACTT(String ACTT) { + this.ACTT = ACTT; + } + public String getACTT() { + return ACTT; + } + +} \ No newline at end of file diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACFTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACFTHandler.java index 9cca531b..2d171de9 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACFTHandler.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACFTHandler.java @@ -11,12 +11,19 @@ import com.gzzn.omms.msgexchangeapi.service.IExchangeService; import com.gzzn.omms.msgexchangeapi.service.flightInfo.IFlightInfoService; import com.gzzn.omms.msgexchangeapi.utils.SpringUtil; +/** + * 航班机型事件 + * @author zhouxiunai + * + */ public class ACFTHandler implements IBaseHandler { private static Logger logger = LoggerFactory.getLogger(ACFTHandler.class); /** * 处理航班消息,更新航班动态信息 + * @param msg 要处理的xml消息 + * @return 处理结果及影响的动态航班信息 */ @Override public HandlerResult run(String msg) { diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACTTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACTTHandler.java new file mode 100644 index 00000000..a0967c51 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ACTTHandler.java @@ -0,0 +1,42 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.flop.actt.ACTTMsg; +import com.gzzn.omms.msgexchangeapi.entity.msg.schd.dnld.FLTR; +import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult; +import com.gzzn.omms.msgexchangeapi.msghandler.IBaseHandler; +import com.gzzn.omms.msgexchangeapi.service.IExchangeService; +import com.gzzn.omms.msgexchangeapi.service.flightInfo.IFlightInfoService; +import com.gzzn.omms.msgexchangeapi.utils.SpringUtil; + +/** + * 航班实际时间事件 + * @author zhouxiunai + * + */ +public class ACTTHandler implements IBaseHandler{ + private static Logger logger = LoggerFactory.getLogger(ACTTHandler.class); + + @Override + public HandlerResult run(String msg) { + IExchangeService exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService"); + IFlightInfoService flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService"); + + ACTTMsg acttMsg = exchangeService.xmlstrToObject(msg, ACTTMsg.class); + FLTR fltr = flightInfoService.getByFlid(acttMsg.getFLOP().getFLID()); + if(null != fltr) + { + fltr.setACTT(acttMsg.getFLOP().getACTT()); + flightInfoService.saveFltr(fltr); + return HandlerResult.success(fltr); + } + else { + //没有该动态航班信息 + logger.warn("没有flid为:{}的消息",acttMsg.getFLOP().getFLID()); + } + + return HandlerResult.failure(); + } +}