diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/botm/BOTMMsg.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/botm/BOTMMsg.java new file mode 100644 index 00000000..ecd3cc84 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/botm/BOTMMsg.java @@ -0,0 +1,39 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.botm; + +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:43:2 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@JacksonXmlRootElement(localName="MSG") +@JsonIgnoreProperties(ignoreUnknown = true) +public class BOTMMsg { + + @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/botm/FLOP.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/botm/FLOP.java new file mode 100644 index 00000000..3028308f --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/botm/FLOP.java @@ -0,0 +1,44 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.botm; + +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; + +/** + * Auto-generated: 2018-12-05 20:43:2 + * + * @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 ="BOTM") + private String BOTM; + + 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 setBOTM(String BOTM) { + this.BOTM = BOTM; + } + public String getBOTM() { + return BOTM; + } + +} \ No newline at end of file diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/BOTMHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/BOTMHandler.java new file mode 100644 index 00000000..73c8b3cb --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/BOTMHandler.java @@ -0,0 +1,43 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.flop.botm.BOTMMsg; +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 BOTMHandler implements IBaseHandler { + private static Logger logger = LoggerFactory.getLogger(ACFTHandler.class); + + @Override + public HandlerResult run(String msg) { + IExchangeService exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService"); + IFlightInfoService flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService"); + + BOTMMsg botmMsg = exchangeService.xmlstrToObject(msg, BOTMMsg.class); + FLTR fltr = flightInfoService.getByFlid(botmMsg.getFLOP().getFLID()); + if(null != fltr) + { + fltr.setBOTM(botmMsg.getFLOP().getBOTM()); + flightInfoService.saveFltr(fltr); + return HandlerResult.success(fltr); + } + else { + //没有该动态航班信息 + logger.warn("没有flid为:{}的消息",botmMsg.getFLOP().getFLID()); + } + + return HandlerResult.failure(); + } + +}