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