ad

app/command/Report.php

@@ -36,10 +36,12 @@ class Report extends Command
     protected function execute(Input $input, Output $output)
     {
         // 指令输出
-		$info = Cache::store('redis')->handler()->rpop($this->key);
-
-		if ($info==false) return '';
 
+        $Command = Cache::store('redis')->handler()->get('ExecCommand');
+        if($Command>=3) return '';
+		$info = Cache::store('redis')->handler()->rpop($this->key);
+		if($info==false) return '';
+		Cache::store('redis')->handler()->incrby('ExecCommand',1);
         Db::startTrans();
         try{
         $info = json_decode($info,true);
@@ -125,6 +127,7 @@ class Report extends Command
                     ]);
 			 $output->writeln("[$date]【{$info['name']}】[{$info['apply_name']}]预约记录处理失败 message:【{$e->getMessage()}】");
         }
+       Cache::store('redis')->handler()->decrby('ExecCommand',1);
 		Db::commit();
     }