From fd5ce22212a2527af9368bd83e326e27b584a17f Mon Sep 17 00:00:00 2001 From: fanghongchao <601470458@qq.com> Date: Tue, 11 Dec 2018 13:47:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E8=E7=B1=BB=E8=88=AA=E7=8F=AD?= =?UTF-8?q?=E5=8A=A8=E6=80=81=E4=BF=A1=E6=81=AF=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../msghandler/flop/FDIVHandler.java | 30 ++++++++++++++++ .../msghandler/flop/FTSSHandler.java | 24 +++++++++++++ .../msghandler/flop/GTDTHandler.java | 34 +++++++++++++++++++ .../msghandler/flop/HNAGHandler.java | 32 +++++++++++++++++ .../msghandler/flop/LACLTHandler.java | 24 +++++++++++++ .../msghandler/flop/PADTHandler.java | 24 +++++++++++++ .../msghandler/flop/PSDTHandler.java | 34 +++++++++++++++++++ .../msghandler/flop/REMCHandler.java | 24 +++++++++++++ 8 files changed, 226 insertions(+) create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FDIVHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FTSSHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/GTDTHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/HNAGHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/LACLTHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PADTHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PSDTHandler.java create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/REMCHandler.java diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FDIVHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FDIVHandler.java new file mode 100644 index 00000000..2ef07e26 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FDIVHandler.java @@ -0,0 +1,30 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.DIVERSIONDATA; +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDIVERSIONDATA; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班转场事件 + * @author fhc + * + */ +public class FDIVHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(FDIVHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + OPTDIVERSIONDATA optDiversionData = flop.getFDIV(); + DIVERSIONDATA diversionData = new DIVERSIONDATA(); + BeanUtils.copyProperties(optDiversionData, diversionData); + fltr.setFDIV(diversionData); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FTSSHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FTSSHandler.java new file mode 100644 index 00000000..8fafeb1e --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FTSSHandler.java @@ -0,0 +1,24 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班状态事件 + * @author fhc + * + */ +public class FTSSHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(FTSSHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.setFTSS(flop.getFTSS()); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/GTDTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/GTDTHandler.java new file mode 100644 index 00000000..63e8cf97 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/GTDTHandler.java @@ -0,0 +1,34 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.GATEDATA; +import com.gzzn.omms.msgexchangeapi.entity.msg.OPTGATEDATA; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班登机门事件 + * @author fhc + * + */ +public class GTDTHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(GTDTHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.getGTDT().clear(); //清空旧数据 + for(OPTGATEDATA optgatedata : flop.getGTDT() ) + { + GATEDATA gatedata = new GATEDATA(); + BeanUtils.copyProperties(optgatedata, gatedata); + + fltr.getGTDT().add(gatedata); + } //添加新数据 + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/HNAGHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/HNAGHandler.java new file mode 100644 index 00000000..7699104c --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/HNAGHandler.java @@ -0,0 +1,32 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import java.math.BigInteger; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.StringUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班服务代理事件 + * @author fhc + * + */ +public class HNAGHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(HNAGHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + //机坪（或外场）服务代理 + fltr.setFHAG(StringUtils.isEmpty(flop.getFHAG())?null:new BigInteger(flop.getFHAG())); + //旅客服务代理 + fltr.setPHAG(StringUtils.isEmpty(flop.getPHAG())?null:new BigInteger(flop.getPHAG())); + //维护服务代理 + fltr.setMHAG(StringUtils.isEmpty(flop.getMHAG())?null:new BigInteger(flop.getMHAG())); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/LACLTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/LACLTHandler.java new file mode 100644 index 00000000..7074f4e4 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/LACLTHandler.java @@ -0,0 +1,24 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班最后通知时间事件 + * @author fhc + * + */ +public class LACLTHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(LACLTHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.setLACL(flop.getLACL()); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PADTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PADTHandler.java new file mode 100644 index 00000000..67530273 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PADTHandler.java @@ -0,0 +1,24 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班前站实际起飞时间事件 + * @author fhc + * + */ +public class PADTHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(PADTHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.setPADT(flop.getPADT()); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PSDTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PSDTHandler.java new file mode 100644 index 00000000..da4eaf43 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PSDTHandler.java @@ -0,0 +1,34 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.OPTSTANDDATA; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; +import com.gzzn.omms.msgexchangeapi.entity.msg.STANDDATA; + +/** + * 航班计划机位事件 + * @author fhc + * + */ +public class PSDTHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(PSDTHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.getPSDT().clear(); //清空旧数据 + for(OPTSTANDDATA optStandata : flop.getPSDT() ) + { + STANDDATA standata = new STANDDATA(); + BeanUtils.copyProperties(optStandata, standata); + + fltr.getPSDT().add(standata); + } //添加新数据 + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/REMCHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/REMCHandler.java new file mode 100644 index 00000000..2d6a9568 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/REMCHandler.java @@ -0,0 +1,24 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班注释事件 + * @author fhc + * + */ +public class REMCHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(REMCHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.setREMC(flop.getREMC()); + return fltr; + } +}