windy/msgexchange-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复日航班计划转kafka

Browse Source
This commit is contained in:
zhouxiunai
2018-12-20 09:29:22 +08:00
parent a6e8979d39
commit 8128b1c861
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
+11
View File
@@ -2,10 +2,14 @@ package com.gzzn.omms.msgexchangeapi.msghandler.schd.base;
import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
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;
@@ -19,6 +23,8 @@ import com.gzzn.omms.msgexchangeapi.utils.SpringUtil;
*
*/
public class SchdBaseHandler implements IBaseHandler{
private static Logger logger = LoggerFactory.getLogger(SchdBaseHandler.class);
protected IExchangeService exchangeService;
protected IFlightInfoService flightInfoService;
protected IKafkaService kafkaservice;
@@ -28,6 +34,8 @@ public class SchdBaseHandler implements IBaseHandler{
{
exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService");
flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService");
kafkaservice = (IKafkaService) SpringUtil.getBean("kafkaservice");
cminmsgService = (ICminmsgService) SpringUtil.getBean("cminmsgService");
}
@Override
@@ -45,7 +53,10 @@ public class SchdBaseHandler implements IBaseHandler{
String msg = exchangeService.xmlstrToJson(
cminmsg.getCminmsgsClobMsg()
);
logger.info("准备发送日计划到kafka");
kafkaservice.msgSend("dschd", msg);
logger.info("发送日计划到kafka完毕");
}