新增8类航班动态信息处理

2018-12-11 13:47:36 +08:00
parent cd209ee926
commit fd5ce22212
8 changed files with 226 additions and 0 deletions
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}
@@ -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;
+	}
+}