From 47e473d9b174b6822d98466fc9d260fe91138327 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Thu, 6 Dec 2018 14:57:32 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E5=8F=96=E5=8F=91=E9=80=81=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96=E6=97=A5=E8=88=AA=E7=8F=AD=E8=AE=A1=E5=88=92=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E7=9A=84=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../omms/msgexchangeapi/runner/AppRunner.java | 35 +++------------
 .../service/CmoutmsgServiceImpl.java          | 45 +++++++++++++++++++
 .../service/ICmoutmsgService.java             | 18 ++++++++
 3 files changed, 69 insertions(+), 29 deletions(-)
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/service/ICmoutmsgService.java

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);
+}