[更新]修改系统任务

application/admin/queue/Queue.php

@@ -17,14 +17,27 @@ namespace app\admin\queue;
 
 use think\console\Input;
 use think\console\Output;
+use think\Db;
 
 /**
- * 基础任务基类
+ * 异步任务基类
  * Class Queue
  * @package app\admin\queue
  */
 abstract class Queue
 {
+    /**
+     * 当前任务ID
+     * @var integer
+     */
+    public $jobid = 0;
+
+    /**
+     * 当前任务标题
+     * @var string
+     */
+    public $title = '';
+
     /**
      * 判断是否WIN环境
      * @return boolean
@@ -34,5 +47,33 @@ abstract class Queue
         return PATH_SEPARATOR === ';';
     }
 
+    /**
+     * 重发异步任务记录
+     * @param integer $wait 等待时间
+     * @return boolean
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @throws \think\exception\DbException
+     */
+    protected function redo($wait = 0)
+    {
+        if ($this->jobid > 0) {
+            if ($queue = Db::name('SystemQueue')->where(['id' => $this->jobid])->find()) {
+                $queue['time'] = time() + $wait;
+                $queue['title'] .= " - 来自任务{$this->jobid} 重发任务";
+                unset($queue['id'], $queue['create_at'], $queue['desc']);
+                return Db::name('SystemQueue')->insert($queue) !== false;
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 执行异步任务
+     * @param Input $input 输入对象
+     * @param Output $output 输出对象
+     * @param array $data 任务参数
+     * @return mixed
+     */
     abstract function execute(Input $input, Output $output, array $data = []);
 }

application/admin/queue/task/Work.php

@@ -76,8 +76,12 @@ class Work extends Task
             if (class_exists($queue['preload'])) {
                 if (method_exists($class = new $queue['preload'], 'execute')) {
                     $data = json_decode($queue['data'], true);
+                    if (isset($class->jobid)) $class->jobid = $this->id;
+                    if (isset($class->title)) $class->title = $queue['title'];
                     $this->update('3', $class->execute($input, $output, is_array($data) ? $data : []));
-                } else throw new Exception("任务处理类 {$queue['preload']} 未定义 execute 入口！");
+                } else {
+                    throw new Exception("任务处理类 {$queue['preload']} 未定义 execute 入口！");
+                }
             } else {
                 $this->update('3', Console::call($queue['preload'], [], 'console'));
             }