队列相关的调整

2025-05-30 13:36:15 +08:00
parent e75b57d1da
commit b6a03c6ea1
3 changed files with 171 additions and 0 deletions
--- a/application/common/QueueJob.php
+++ b/application/common/QueueJob.php
@@ -0,0 +1,48 @@
+<?php
+namespace app\common;
+use think\Db;
+class QueueJob
+{
+
+    //必填参数
+    protected $aField = ['job_id','job_class','status','create_time','update_time','error','params'];
+
+    // 记录任务开始
+    public function addLog($aParam = []) {
+
+        //数据处理
+        $aField = $this->aField;
+        $aInsert = [];
+        foreach ($aField as $key => $value) {
+           if(isset($aParam[$value])){
+                $aInsert[$value] = $aParam[$value];
+           }
+        }
+        $result = 0;
+        if(!empty($aInsert)){
+            $result = DB::name('queue_job_logs')->insertGetId($aParam);
+        }
+        return $result;
+    }
+
+    // 记录任务成功
+    public function updateLog($aParam = []) {
+
+        $iLogId = empty($aParam['log_id']) ? 0 : $aParam['log_id'];
+        if(empty($iLogId)){
+            return false;
+        }
+        //数据处理
+        $aField = $this->aField;
+        $aUpdate = [];
+        foreach ($aField as $key => $value) {
+           if(isset($aParam[$value])){
+                $aUpdate[$value] = $aParam[$value];
+           }
+        }
+        unset($aParam['log_id']);
+        $result = DB::name('queue_job_logs')->where('log_id',$iLogId)->limit(1)->update($aUpdate);
+        return $result;
+    }
+}
+?>