diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java
index f55f1496..55dbacaf 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java
+++ b/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
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 b89b438c..7db179c5 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
@@ -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);
+	}
+	
 	
 	/**
 	 * 仅发送动态消息