From 31b8c89bfc68906fc37314336e9aea5d6ca53f5d Mon Sep 17 00:00:00 2001
From: Anyon <zoujingli@qq.com>
Date: Wed, 14 Aug 2019 13:44:23 +0800
Subject: [PATCH] =?UTF-8?q?[=E6=9B=B4=E6=96=B0]=E4=BF=AE=E6=94=B9=E7=B3=BB?=
 =?UTF-8?q?=E7=BB=9F=E4=BB=BB=E5=8A=A1=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 application/admin/queue/task/Listen.php | 2 +-
 application/admin/queue/task/Query.php  | 4 +++-
 application/admin/sys.php               | 7 ++++---
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/application/admin/queue/task/Listen.php b/application/admin/queue/task/Listen.php
index edb6b601a..a06b84a6c 100644
--- a/application/admin/queue/task/Listen.php
+++ b/application/admin/queue/task/Listen.php
@@ -68,7 +68,7 @@ class Listen extends Task
                     $output->error("创建处理任务的子进程失败 --> [{$item['id']}] {$item['title']}，{$e->getMessage()}");
                 }
             }
-            sleep(3);
+            sleep(2);
         }
     }
 
diff --git a/application/admin/queue/task/Query.php b/application/admin/queue/task/Query.php
index a4f58269d..430b1f351 100644
--- a/application/admin/queue/task/Query.php
+++ b/application/admin/queue/task/Query.php
@@ -43,7 +43,9 @@ class Query extends Task
     protected function execute(Input $input, Output $output)
     {
         $this->cmd = "{$this->bin} xtask:";
-        foreach ($this->queryProcess() as $item) {
+        if (count($this->queryProcess()) < 1) {
+            $output->writeln('没有查询到相关任务进程');
+        } else foreach ($this->queryProcess() as $item) {
             $output->writeln("{$item['pid']}\t'{$item['cmd']}'");
         }
     }
diff --git a/application/admin/sys.php b/application/admin/sys.php
index 7f64f8c29..5507b05ae 100644
--- a/application/admin/sys.php
+++ b/application/admin/sys.php
@@ -85,9 +85,10 @@ if (!function_exists('sysqueue')) {
             throw new \think\Exception('该任务已经创建，请耐心等待处理完成！');
         }
         $result = Db::name('SystemQueue')->insert([
-            'title' => $title, 'preload' => $loade,
-            'data'  => json_encode($data, JSON_UNESCAPED_UNICODE),
-            'time'  => $later > 0 ? time() + $later : time(), 'double' => intval($double),
+            'title'  => $title, 'preload' => $loade,
+            'data'   => json_encode($data, JSON_UNESCAPED_UNICODE),
+            'time'   => ($later > 0 ? time() + $later : time()) - 3,
+            'double' => intval($double),
         ]);
         return $result !== false;
     }