From 50c3a58e057c219d64232b74c8f5b0e1451bbf42 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Wed, 26 Dec 2018 17:27:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E5=81=8F=E7=A7=BB=E6=9C=80?=
 =?UTF-8?q?=E6=96=B0=E7=9A=84=E8=8E=B7=E5=8F=96=E6=B6=88=E6=81=AF=E4=BD=8D?=
 =?UTF-8?q?=E7=BD=AE=EF=BC=8C=E6=8F=90=E5=8D=87=E6=80=A7=E8=83=BD=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
index a34a8257..e2b81b2e 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
@@ -4,6 +4,7 @@ import java.util.List;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.msghandler.MsgHandlerDispatcher;
@@ -58,7 +59,11 @@ public class MsgExchangeRunner  implements Runnable{
 			msgHandlerDispatcher.dispatch(cminmsg);
 		}//end for
 		
-		
+		if(!CollectionUtils.isEmpty(lsCminmsgs))
+		{
+			beginId =  lsCminmsgs.get(lsCminmsgs.size()-1).getCminmsgsId();//偏移到最新位置，等待最新的消息
+			redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);
+		}
 		logger.info("本次定时获取新消息完成...");
 	}//end run
 }