diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java index 007a33d2..e8fdabd9 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java @@ -1,7 +1,6 @@ package com.gzzn.omms.msgexchangeapi.runner; import java.util.Date; -import java.util.Locale; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -9,14 +8,9 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; -import com.gzzn.omms.msgexchangeapi.dao.CmoutmsgDao; -import com.gzzn.omms.msgexchangeapi.entity.Cmoutmsg; -import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsg; -import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsgBody; import com.gzzn.omms.msgexchangeapi.redis.RedisKeyConstant; import com.gzzn.omms.msgexchangeapi.redis.RedisService; -import com.gzzn.omms.msgexchangeapi.service.IExchangeService; -import com.gzzn.omms.msgexchangeapi.utils.DateTimeUtil; +import com.gzzn.omms.msgexchangeapi.service.ICmoutmsgService; @Component public class AppRunner implements CommandLineRunner { @@ -26,35 +20,18 @@ public class AppRunner implements CommandLineRunner { @Autowired RedisService redisService; - @Autowired - private CmoutmsgDao cmoutmsgDao; - - - @Autowired - private IExchangeService exchangeService; + private ICmoutmsgService cmoutmsgService; + @Override public void run(String... args) throws Exception { + logger.info("发送获取动态航班日计划的消息"); - //构造消息 - Date nowDate = new Date(); - Cmoutmsg cmoutmsg = new Cmoutmsg(); - RefdMsgBody body = new RefdMsgBody(); - body.setStdb( - DateTimeUtil.gtFormatStr( - nowDate, - "ddMMMyyHHmm", - Locale.ENGLISH) - .toUpperCase() - ); - RefdMsg msg = new RefdMsg(); - msg.setRefd(body); - cmoutmsg.setCminmsgsClobMsg(exchangeService.objectToXmlstr(msg)); - cmoutmsg.setCminmsgsStatus("VALID"); - cmoutmsgDao.save(cmoutmsg); + Date nowDate = new Date(); + cmoutmsgService.sendSchdGetMsg(nowDate); // redisService.set(RedisKeyConstant.KEY_ISWAITSCHD, true); //等待返回日计划状态 diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java new file mode 100644 index 00000000..cce53125 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java @@ -0,0 +1,45 @@ +package com.gzzn.omms.msgexchangeapi.service; + +import java.util.Date; +import java.util.Locale; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import com.gzzn.omms.msgexchangeapi.dao.CmoutmsgDao; +import com.gzzn.omms.msgexchangeapi.entity.Cmoutmsg; +import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsg; +import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsgBody; +import com.gzzn.omms.msgexchangeapi.utils.DateTimeUtil; + +@Service +public class CmoutmsgServiceImpl implements ICmoutmsgService { + @Autowired + private IExchangeService exchangeService; + + @Autowired + private CmoutmsgDao cmoutmsgDao; + + public Boolean sendSchdGetMsg(Date date) + { + //构造消息 + Cmoutmsg cmoutmsg = new Cmoutmsg(); + RefdMsgBody body = new RefdMsgBody(); + body.setStdb( + DateTimeUtil.gtFormatStr( + date, + "ddMMMyyHHmm", + Locale.ENGLISH) + .toUpperCase() + ); + RefdMsg msg = new RefdMsg(); + msg.setRefd(body); + cmoutmsg.setCminmsgsClobMsg(exchangeService.objectToXmlstr(msg)); + cmoutmsg.setCminmsgsStatus("VALID"); + + Cmoutmsg rtCmoutmsg = cmoutmsgDao.save(cmoutmsg); + + return rtCmoutmsg != null; + } + +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/ICmoutmsgService.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/ICmoutmsgService.java new file mode 100644 index 00000000..4c41a70f --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/ICmoutmsgService.java @@ -0,0 +1,18 @@ +package com.gzzn.omms.msgexchangeapi.service; + +import java.util.Date; + +/** + * + * @author Administrator + * + */ +public interface ICmoutmsgService { + + /** + * 向Cmoutmsgs发送日航班计划获取消息 + * @param date 发送获取指定时间后的日航班计划 + * @return 成功或失败 + */ + public Boolean sendSchdGetMsg(Date date); +}