From b96e1ec3940493fab35ecba2853cc395989fc597 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Mon, 10 Dec 2018 17:43:52 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E8=BF=94=E5=9B=9E=E7=9A=84?=
 =?UTF-8?q?=E6=97=A5=E8=AE=A1=E5=88=92=E4=B8=BA=E5=B7=B2=E5=A4=84=E7=90=86?=
 =?UTF-8?q?=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java
index a4449e8f..b0901383 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java
@@ -1,5 +1,7 @@
 package com.gzzn.omms.msgexchangeapi.runner;
 
+import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Date;
 import java.util.Optional;
 import java.util.concurrent.Executors;
@@ -61,6 +63,11 @@ public class SchdWaitRunner implements Runnable {
 				continue ;
 			}
 
+			
+			//更新返回消息为已处理
+			cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get()));
+			
+			
 			//更新
 	    	logger.info("找到返回的动态航班计划,开始更新动态航班信息...");
 	    	Boolean updateResult = flightInfoService.updateByDaySchd(opCminmsg.get());