From 86a483d3f31abccc0ce80c97a6ed457f2ed25e08 Mon Sep 17 00:00:00 2001
From: fanghongchao <601470458@qq.com>
Date: Mon, 10 Dec 2018 18:04:53 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E5=E7=B1=BB=E5=8A=A8=E6=80=81?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86=20hander?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/flop/ROUTHandler.java          | 33 +++++++++++++++++++
 .../msghandler/flop/STNDHandler.java          | 25 ++++++++++++++
 .../msghandler/flop/TAOPHandler.java          | 30 +++++++++++++++++
 .../msghandler/flop/TRMLHandler.java          | 26 +++++++++++++++
 .../msghandler/flop/VIPPHandler.java          | 31 +++++++++++++++++
 5 files changed, 145 insertions(+)
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java
new file mode 100644
index 00000000..9a144971
--- /dev/null
+++ b/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;
+	}
+}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java
new file mode 100644
index 00000000..4ec766ca
--- /dev/null
+++ b/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;
+	}
+}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java
new file mode 100644
index 00000000..2a390b99
--- /dev/null
+++ b/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;
+	}
+}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java
new file mode 100644
index 00000000..fb3d7f25
--- /dev/null
+++ b/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;
+	}
+}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java
new file mode 100644
index 00000000..142536c1
--- /dev/null
+++ b/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;
+	}
+}