From 79b4e03daa567642473277508df98a33cfcb90d6 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Wed, 19 Dec 2018 16:41:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B6=E5=8F=96=E6=97=A5=E8=88=AA=E7=8F=AD?=
 =?UTF-8?q?=E8=AE=A1=E5=88=92=E5=90=8E=E6=8E=A8=E9=80=81=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E5=88=B0kafka=E7=BA=A6=E5=AE=9A=E7=9A=84dschd=20=E9=98=9F?=
 =?UTF-8?q?=E5=88=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msgexchangeapi/msghandler/schd/DNLDHandler.java |  4 +++-
 .../msghandler/schd/base/SchdBaseHandler.java       | 13 +++++++++++++
 2 files changed, 16 insertions(+), 1 deletion(-)

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);
+	}
+	
 	
 	/**
 	 * 仅发送动态消息