From 440864110e45fdb5484e8d533a978c409d6f9643 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Wed, 26 Dec 2018 17:44:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A8=B3=E5=AE=9A=E6=80=A7?=
 =?UTF-8?q?=EF=BC=8C=E5=BE=80=E5=90=8E=E5=81=8F=E7=A7=BB10=E5=88=86?=
 =?UTF-8?q?=E9=92=9F=E8=8E=B7=E5=8F=96=E6=9C=80=E6=96=B0=E8=AE=A1=E5=88=92?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java | 6 +++++-
 src/main/resources/application-dev.yml                      | 1 +
 2 files changed, 6 insertions(+), 1 deletion(-)

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 464ac356..a3b0c29e 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java
@@ -6,6 +6,7 @@ import java.util.concurrent.Executors;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
 
@@ -24,6 +25,8 @@ public class AppRunner implements CommandLineRunner  {
 	@Autowired
 	private ICmoutmsgService cmoutmsgService;
 
+	@Value("${msgExchange.waitDateLeftOffset}")
+	private  Long waitDateLeftOffset;
 	
 	@Override
 	public void run(String... args) throws Exception {
@@ -32,11 +35,12 @@ public class AppRunner implements CommandLineRunner  {
 		
 		
 		Date nowDate = new Date();
+		Date waitDate = new Date(nowDate.getTime() - waitDateLeftOffset);//往后偏移指定时钟，避免因不同应用系统时钟相差过大导致的问题。
 		cmoutmsgService.sendSchdGetMsg(null,null);//发送获取当天日计划的申请
 		
 		//
 		redisService.set(RedisKeyConstant.KEY_ISWAITSCHD, true);  //等待返回日计划状态
-		redisService.set(RedisKeyConstant.KEY_WAITSCHDDATE,nowDate); //初始化消息进度
+		redisService.set(RedisKeyConstant.KEY_WAITSCHDDATE,waitDate); //初始化消息进度
 		
 		logger.info("发送获取动态航班日计划的消息完成");
 		
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 9deb1a76..374d195d 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -51,6 +51,7 @@ kafka:
       id: test
 msgExchange:
   intervalSeconds: 5
+  waitDateLeftOffset: 600000
 logstash:
   host: 130.120.3.233:5000
 scheduled: