From 5768d3388b747bd9e83933934ee7f252ad2e98ad Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Fri, 21 Dec 2018 16:20:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B0=86=E6=97=A5=E8=AE=A1=E5=88=92=E8=BF=9B?=
 =?UTF-8?q?=E8=A1=8C=E6=8B=86=E5=88=86=EF=BC=8C=E6=AF=8F=E4=B8=AA=E8=88=AA?=
 =?UTF-8?q?=E7=8F=ADid=E7=9A=84=E6=97=A5=E8=AE=A1=E5=88=92=E4=BD=9C?=
 =?UTF-8?q?=E4=B8=BA=E4=B8=80=E6=9D=A1=E6=B6=88=E6=81=AF=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E5=88=B0kafka=20=E3=80=82=E5=87=8F=E8=BD=BB=E5=89=8D=E7=AB=AF?=
 =?UTF-8?q?=E5=8E=8B=E5=8A=9B=E5=8F=8A=E6=8F=90=E5=8D=87=E5=A4=84=E7=90=86?=
 =?UTF-8?q?=E6=80=A7=E8=83=BD=E5=92=8C=E7=A8=B3=E5=AE=9A=E6=80=A7=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/schd/base/SchdBaseHandler.java | 25 ++++++++++++++-----
 1 file changed, 19 insertions(+), 6 deletions(-)

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 49dfbe0d..35e0eee9 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
@@ -1,15 +1,17 @@
 package com.gzzn.omms.msgexchangeapi.msghandler.schd.base;
 
 import java.util.Arrays;
+import java.util.List;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
+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.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;
@@ -49,13 +51,24 @@ public class SchdBaseHandler  implements IBaseHandler{
 	 */
 	protected void sendDschd(Cminmsg cminmsg)
 	{
-		//send msg
-		String msg = exchangeService.xmlstrToJson(
-				cminmsg.getCminmsgsClobMsg()
-                );
+		//将每条计划转成一条json消息推送到kafka
+		String   clobMsg = cminmsg.getCminmsgsClobMsg();
+		MSG  dnldMsg = exchangeService.xmlstrToObject(clobMsg, MSG.class);
+                		
+		//
+		List<SCHD.FLTR> lsFltr = dnldMsg
+                .getSCHD()
+                .getFLTR();
 		
 		logger.info("准备发送日计划到kafka");
-        kafkaservice.msgSend("dschd", msg);
+		
+		for(FLTR fltr : lsFltr) 
+		{
+			//send msg
+			String msgJson =  JsonUtil.getStringWithNoneKey(fltr);
+			kafkaservice.msgSend("dschd", msgJson);
+		}
+        
         logger.info("发送日计划到kafka完毕");
 	}