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 7db179c5..49dfbe0d 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
@@ -2,10 +2,14 @@ package com.gzzn.omms.msgexchangeapi.msghandler.schd.base;
 
 import java.util.Arrays;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
 import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
 import com.gzzn.omms.msgexchangeapi.msghandler.IBaseHandler;
+import com.gzzn.omms.msgexchangeapi.msghandler.schd.DNLDHandler;
 import com.gzzn.omms.msgexchangeapi.service.ICminmsgService;
 import com.gzzn.omms.msgexchangeapi.service.IKafkaService;
 import com.gzzn.omms.msgexchangeapi.service.exchange.IExchangeService;
@@ -19,6 +23,8 @@ import com.gzzn.omms.msgexchangeapi.utils.SpringUtil;
  *
  */
 public class SchdBaseHandler  implements IBaseHandler{
+	private static  Logger logger = LoggerFactory.getLogger(SchdBaseHandler.class);
+	
 	protected IExchangeService exchangeService;
 	protected  IFlightInfoService flightInfoService;
 	protected IKafkaService kafkaservice;
@@ -28,6 +34,8 @@ public class SchdBaseHandler  implements IBaseHandler{
 	{
 		 exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService");
 		 flightInfoService =  (IFlightInfoService) SpringUtil.getBean("flightInfoService");
+		 kafkaservice = (IKafkaService) SpringUtil.getBean("kafkaservice");
+		 cminmsgService = (ICminmsgService) SpringUtil.getBean("cminmsgService");
 	}
 
 	@Override
@@ -45,7 +53,10 @@ public class SchdBaseHandler  implements IBaseHandler{
 		String msg = exchangeService.xmlstrToJson(
 				cminmsg.getCminmsgsClobMsg()
                 );
+		
+		logger.info("准备发送日计划到kafka");
         kafkaservice.msgSend("dschd", msg);
+        logger.info("发送日计划到kafka完毕");
 	}