新增5类动态消息处理 hander

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java

@@ -0,0 +1,33 @@
+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.ROUTEDAILY;
+import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
+
+/**
+ * 航班航线事件
+ * @author fhc
+ *
+ */
+public class ROUTHandler extends FlopBaseHandler {
+   
+    private static  Logger logger = LoggerFactory.getLogger(ROUTHandler.class);	
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		fltr.getROUT().clear();
+		for(ROUTEDAILY optRouteDaily : flop.getROUT() ) 
+		{
+			ROUTEDAILY routeDaily = new ROUTEDAILY();
+			BeanUtils.copyProperties(optRouteDaily, routeDaily);
+			
+			fltr.getROUT().add(routeDaily);
+		} //添加新数据
+		return fltr;
+	}
+}

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java

@@ -0,0 +1,25 @@
+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 STNDHandler extends FlopBaseHandler {
+   
+    private static  Logger logger = LoggerFactory.getLogger(STNDHandler.class);	
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		//update
+		fltr.setSTND(flop.getSTND());
+		return fltr;
+	}
+}

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java

@@ -0,0 +1,30 @@
+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 TAOPHandler extends FlopBaseHandler {
+   
+    private static  Logger logger = LoggerFactory.getLogger(TAOPHandler.class);	
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		//update
+		fltr.setTAOP(flop.getTAOP());
+		fltr.setTAFL(flop.getTAFL());
+		fltr.setTAID(StringUtils.isEmpty(flop.getTAID())?null:new BigInteger(flop.getTAID()));
+		return fltr;
+	}
+}

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java

@@ -0,0 +1,26 @@
+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 TRMLHandler extends FlopBaseHandler {
+   
+    private static  Logger logger = LoggerFactory.getLogger(TRMLHandler.class);	
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		//update
+		fltr.setTRML(flop.getTRML());
+	
+		return fltr;
+	}
+}

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java

@@ -0,0 +1,31 @@
+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;
+
+/**
+ * 航班VIP旅客事件
+ * @author fhc
+ *
+ */
+public class VIPPHandler extends FlopBaseHandler {
+   
+    private static  Logger logger = LoggerFactory.getLogger(VIPPHandler.class);	
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		//update
+		//null 表示已有的VIP旅客数删除
+		fltr.setVIPP(StringUtils.isEmpty(flop.getVIPP())?null:new BigInteger(flop.getVIPP()));
+	
+		fltr.setVIPR(StringUtils.isEmpty(flop.getVIPR())?null:new BigInteger(flop.getVIPR()));
+		return fltr;
+	}
+}