修改完善日航班计划通知事件

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完毕");
 	}