es

@@ -31,7 +31,15 @@ class SyncToEsCmd {
         $db = db();
         $db = db();
 
 
         $maxNum = 10000; // 最大执行数量
         $maxNum = 10000; // 最大执行数量
+        $minTime = 60; // 最小执行时间 秒
+        $maxTime = 1200; // 最大执行时间 秒
+        $runTime = time(); // 开始执行时间
         while ($maxNum > 0){
         while ($maxNum > 0){
+            // 验证最大执行时间
+            if(time() - $runTime > $maxTime){
+                break;
+            }
+
             // 检查是否接收到信号
             // 检查是否接收到信号
             pcntl_signal_dispatch();
             pcntl_signal_dispatch();
 
 
@@ -62,6 +70,12 @@ class SyncToEsCmd {
             }
             }
 
 
             echo '没有找到数据'.PHP_EOL;
             echo '没有找到数据'.PHP_EOL;
+
+            if(time() - $runTime > $minTime){
+                break;
+            }
+
+            sleep(1);
         }
         }
 
 
     }
     }