收取日航班计划后推送消息到kafka约定的dschd 队列

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java

@@ -25,7 +25,9 @@ public class DNLDHandler  extends SchdBaseHandler{
 			return HandlerResult.failure();
 		}
 
-		//日航班计划第二天的，不需要通知前端
+		//发送日计划到kafka队列
+		this.sendDschd(cminmsg);
+		
 		this.updateCminmsgToProcessed(cminmsg);
 		return HandlerResult.success();
 	} //end function

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java

@@ -35,6 +35,19 @@ public class SchdBaseHandler  implements IBaseHandler{
 		return null;
 	}
 
+	/**
+	 * 发送日计划到kafka队列
+	 * @param cminmsg
+	 */
+	protected void sendDschd(Cminmsg cminmsg)
+	{
+		//send msg
+		String msg = exchangeService.xmlstrToJson(
+				cminmsg.getCminmsgsClobMsg()
+                );
+        kafkaservice.msgSend("dschd", msg);
+	}
+	
 	
 	/**
 	 * 仅发送动态消息