去除队列冗余代码
This commit is contained in:
@@ -35,7 +35,6 @@ class WechatMomentsCommand extends Command
|
|||||||
|
|
||||||
// 检查队列是否已经在运行
|
// 检查队列是否已经在运行
|
||||||
$queueLockKey = "queue_lock:{$this->queueName}";
|
$queueLockKey = "queue_lock:{$this->queueName}";
|
||||||
Cache::rm($queueLockKey);
|
|
||||||
if (Cache::get($queueLockKey)) {
|
if (Cache::get($queueLockKey)) {
|
||||||
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
|
|||||||
@@ -34,7 +34,6 @@ class WorkbenchGroupCreateCommand extends Command
|
|||||||
|
|
||||||
// 检查队列是否已经在运行
|
// 检查队列是否已经在运行
|
||||||
$queueLockKey = "queue_lock:{$this->queueName}";
|
$queueLockKey = "queue_lock:{$this->queueName}";
|
||||||
Cache::rm($queueLockKey);
|
|
||||||
if (Cache::get($queueLockKey)) {
|
if (Cache::get($queueLockKey)) {
|
||||||
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
|
|||||||
@@ -34,7 +34,6 @@ class WorkbenchGroupPushCommand extends Command
|
|||||||
|
|
||||||
// 检查队列是否已经在运行
|
// 检查队列是否已经在运行
|
||||||
$queueLockKey = "queue_lock:{$this->queueName}";
|
$queueLockKey = "queue_lock:{$this->queueName}";
|
||||||
Cache::rm($queueLockKey);
|
|
||||||
if (Cache::get($queueLockKey)) {
|
if (Cache::get($queueLockKey)) {
|
||||||
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
|
|||||||
@@ -34,7 +34,6 @@ class WorkbenchMomentsCommand extends Command
|
|||||||
|
|
||||||
// 检查队列是否已经在运行
|
// 检查队列是否已经在运行
|
||||||
$queueLockKey = "queue_lock:{$this->queueName}";
|
$queueLockKey = "queue_lock:{$this->queueName}";
|
||||||
Cache::rm($queueLockKey);
|
|
||||||
if (Cache::get($queueLockKey)) {
|
if (Cache::get($queueLockKey)) {
|
||||||
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
$output->writeln("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
Log::warning("队列 {$this->queueName} 已经在运行中,跳过执行");
|
||||||
|
|||||||
Reference in New Issue
Block a user