diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/CKDT.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDT.java similarity index 75% rename from src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/CKDT.java rename to src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDT.java index 82676b33..071147d7 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/CKDT.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDT.java @@ -1,42 +1,30 @@ /** * Copyright 2018 bejson.com */ -package com.gzzn.omms.msgexchangeapi.entity.msg.schd.dnld; +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.ckdt; -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility; import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; /** - * Auto-generated: 2018-12-05 11:38:31 + * Auto-generated: 2018-12-05 20:49:22 * * @author bejson.com (i@bejson.com) * @website http://www.bejson.com/java2pojo/ */ -@JsonAutoDetect(setterVisibility=Visibility.NONE,getterVisibility=Visibility.NONE) public class CKDT { - @JacksonXmlProperty(localName ="CKNO") - @JsonProperty("CKNO") private String CKNO; @JacksonXmlProperty(localName ="CHKC") - @JsonProperty("CHKC") private String CHKC; @JacksonXmlProperty(localName ="CCLS") - @JsonProperty("CCLS") private String CCLS; @JacksonXmlProperty(localName ="PCOT") - @JsonProperty("PCOT") private String PCOT; @JacksonXmlProperty(localName ="PCCT") - @JsonProperty("PCCT") private String PCCT; @JacksonXmlProperty(localName ="CCTM") - @JsonProperty("CCTM") private String CCTM; @JacksonXmlProperty(localName ="CTYP") - @JsonProperty("CTYP") private String CTYP; public void setCKNO(String CKNO) { this.CKNO = CKNO; diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDTMsg.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDTMsg.java new file mode 100644 index 00000000..e7b4787d --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/CKDTMsg.java @@ -0,0 +1,39 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.ckdt; + +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:49:22 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@JacksonXmlRootElement(localName="MSG") +@JsonIgnoreProperties(ignoreUnknown = true) +public class CKDTMsg { + + @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/ckdt/FLOP.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/FLOP.java new file mode 100644 index 00000000..d872c858 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/flop/ckdt/FLOP.java @@ -0,0 +1,47 @@ +/** + * Copyright 2018 bejson.com + */ +package com.gzzn.omms.msgexchangeapi.entity.msg.flop.ckdt; + +import java.util.List; + +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlElementWrapper; +import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; + +/** + * Auto-generated: 2018-12-05 20:49:22 + * + * @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 ="CKDT") + @JacksonXmlElementWrapper(localName ="CKDT", useWrapping =false) + private List CKDT; + 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 List getCKDT() { + return CKDT; + } + public void setCKDT(List cKDT) { + CKDT = cKDT; + } + + +} \ No newline at end of file diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/FLTR.java b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/FLTR.java index 9bb54513..94e9a060 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/FLTR.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/entity/msg/schd/dnld/FLTR.java @@ -5,10 +5,11 @@ package com.gzzn.omms.msgexchangeapi.entity.msg.schd.dnld; import java.util.List; import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility; +import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlElementWrapper; import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty; +import com.gzzn.omms.msgexchangeapi.entity.msg.flop.ckdt.CKDT; /** * Auto-generated: 2018-12-05 11:38:31 diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java new file mode 100644 index 00000000..aaa80bbb --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java @@ -0,0 +1,44 @@ +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.flop.ckdt.CKDTMsg; +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 CKDTHandler 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"); + + CKDTMsg ckdtMsg = exchangeService.xmlstrToObject(msg, CKDTMsg.class); + FLTR fltr = flightInfoService.getByFlid(ckdtMsg.getFLOP().getFLID()); + if(null != fltr) + { + fltr.setCKDT(ckdtMsg.getFLOP().getCKDT()); + flightInfoService.saveFltr(fltr); + return HandlerResult.success(fltr); + } + else { + //没有该动态航班信息 + logger.warn("没有flid为:{}的消息",ckdtMsg.getFLOP().getFLID()); + } + + return HandlerResult.failure(); + } + +}