添加航班时，如果是共享航班添加到主航班。并发送更新后的主航班信息

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
 }

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