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());