From a2d25ea9a02ac33221a97025dd5d4823506ccc45 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Wed, 16 Jan 2019 11:25:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=88=AA=E7=8F=AD=E6=97=B6?=
 =?UTF-8?q?=EF=BC=8C=E5=A6=82=E6=9E=9C=E6=98=AF=E5=85=B1=E4=BA=AB=E8=88=AA?=
 =?UTF-8?q?=E7=8F=AD=E6=B7=BB=E5=8A=A0=E5=88=B0=E4=B8=BB=E8=88=AA=E7=8F=AD?=
 =?UTF-8?q?=E3=80=82=E5=B9=B6=E5=8F=91=E9=80=81=E6=9B=B4=E6=96=B0=E5=90=8E?=
 =?UTF-8?q?=E7=9A=84=E4=B8=BB=E8=88=AA=E7=8F=AD=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/schd/ADFTHandler.java            | 17 +++++++++++++++++
 .../msghandler/schd/base/SchdBaseHandler.java   | 11 +++++++++++
 2 files changed, 28 insertions(+)

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/ADFTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/ADFTHandler.java
index d7692aa4..57f6a142 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/ADFTHandler.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/ADFTHandler.java
@@ -5,7 +5,9 @@ import org.slf4j.LoggerFactory;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.entity.CminmsgWapper;
+import com.gzzn.omms.msgexchangeapi.entity.msg.MAFLDATA;
 import com.gzzn.omms.msgexchangeapi.entity.msg.MSG;
+import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
 import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD.FLTR;
 import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
 import com.gzzn.omms.msgexchangeapi.msghandler.schd.base.SchdBaseHandler;
@@ -31,9 +33,24 @@ public class ADFTHandler   extends SchdBaseHandler{
 		FLTR fltr = msg.getSCHD().getFLTR().get(0);  
 		flightInfoService.saveFltr(fltr);
 		
+		
 		this.sendFltrAndMsg(fltr, cminmsg);
 		this.updateCminmsgToProcessed(cminmsg);
 		
+		
+		//如果是共享航班，要对应更新
+		if(null != fltr.getMAID())
+		{
+			SCHD.FLTR  fltrMafl =  flightInfoService.getByFlid(fltr.getMAID().toString()); //获取对应的主航班
+			MAFLDATA mafldata = new MAFLDATA();
+			mafldata.setFlid(fltr.getFLID());
+			mafldata.setFlno(fltr.getFLNO());
+			fltrMafl.getMafl().add(mafldata);
+			
+			//推送变更后的主航班信息
+			this.sendFltr(fltrMafl);
+		}
+		
 		return HandlerResult.success();
 	} //end function
 }
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
index 91a16dcd..28e65ec0 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
@@ -98,6 +98,17 @@ public class SchdBaseHandler  implements IBaseHandler{
         kafkaservice.msgSend("msg", msg);
 	}
 	
+	/**
+	 * 发送动态航班信息
+	 * @param fltr
+	 */
+	protected void sendFltr(SCHD.FLTR  fltr)
+	{
+		//send schd
+		String schdMsg =  JsonUtil.getString(fltr);
+		kafkaservice.msgSend("schd", schdMsg);
+	}
+	
 	/**
 	 * 更新Cminmsg状态为已处理
 	 * @param cminmsg