From edc63516dcac2834fa278301cb16fb2df8047bff Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Tue, 11 Dec 2018 11:28:07 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E6=9B=B4=E6=96=B0=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=EF=BC=8C=E5=8F=AA=E6=9C=89=E6=9B=B4=E6=96=B0=E5=8A=A8?=
 =?UTF-8?q?=E6=80=81=E8=88=AA=E7=8F=AD=E4=BF=A1=E6=81=AF=E6=88=90=E5=8A=9F?=
 =?UTF-8?q?=E5=90=8E=E6=89=8D=E8=AE=BE=E5=AE=9A=E4=B8=BA=E5=B7=B2=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E6=B6=88=E6=81=AF=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, 3 insertions(+), 4 deletions(-)

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 a56a2781..1e53cbe1 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java
@@ -61,10 +61,6 @@ public class SchdWaitRunner implements Runnable {
 				sleepInMs(intervalMs);
 				continue ;
 			}
-
-			
-			//更新返回消息为已处理
-			cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get()));
 			
 			
 			//更新
@@ -77,6 +73,9 @@ public class SchdWaitRunner implements Runnable {
 	    		continue ;
 	    	}
 	    	
+	    	//更新返回消息为已处理
+			cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get()));
+			
 	    	//状态记录
 	    	Long beginId = opCminmsg.get().getCminmsgsId();
 	    	redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);