From b055729147de657311c7768e42b2e34b8e6860ea Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Tue, 25 Dec 2018 12:00:20 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=8C=E5=96=84=E6=97=A5?=
 =?UTF-8?q?=E8=88=AA=E7=8F=AD=E8=AE=A1=E5=88=92=E9=80=9A=E7=9F=A5=E4=BA=8B?=
 =?UTF-8?q?=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/schd/base/SchdBaseHandler.java | 23 +++++++------------
 1 file changed, 8 insertions(+), 15 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 35e0eee9..acef8f78 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
@@ -6,6 +6,7 @@ import java.util.List;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.gzzn.omms.msgexchangeapi.dto.ResponseDto;
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.entity.msg.MSG;
 import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
@@ -51,24 +52,16 @@ public class SchdBaseHandler  implements IBaseHandler{
 	 */
 	protected void sendDschd(Cminmsg cminmsg)
 	{
-		//将每条计划转成一条json消息推送到kafka
+		//发送日航班消息的通知给前端，让前端重新加载全部动态
 		String   clobMsg = cminmsg.getCminmsgsClobMsg();
 		MSG  dnldMsg = exchangeService.xmlstrToObject(clobMsg, MSG.class);
-                		
-		//
-		List<SCHD.FLTR> lsFltr = dnldMsg
-                .getSCHD()
-                .getFLTR();
-		
-		logger.info("准备发送日计划到kafka");
-		
-		for(FLTR fltr : lsFltr) 
-		{
-			//send msg
-			String msgJson =  JsonUtil.getStringWithNoneKey(fltr);
-			kafkaservice.msgSend("dschd", msgJson);
-		}
         
+		int recs = dnldMsg.getSCHD().getRECS();
+		logger.info("发送日计划到kafka,条数:{}",recs);
+		
+		ResponseDto<Integer> resDto  =  ResponseDto.success(recs);
+		kafkaservice.msgSend("dschd", JsonUtil.getString(resDto));
+
         logger.info("发送日计划到kafka完毕");
 	}