队列相关的调整

2025-05-30 13:46:16 +08:00
parent 8d0e54dfd1
commit 3404f3e138
1 changed files with 2 additions and 2 deletions
--- a/application/common/QueueJob.php
+++ b/application/common/QueueJob.php
@@ -20,7 +20,7 @@ class QueueJob
        }
        $result = 0;
        if(!empty($aInsert)){
-            $result = DB::name('queue_job_logs')->insertGetId($aParam);
+            $result = DB::name('wechat_queue_logs')->insertGetId($aParam);
        }
        return $result;
    }
@@ -41,7 +41,7 @@ class QueueJob
           }
        }
        unset($aParam['log_id']);
-        $result = DB::name('queue_job_logs')->where('log_id',$iLogId)->limit(1)->update($aUpdate);
+        $result = DB::name('wechat_queue_logs')->where('log_id',$iLogId)->limit(1)->update($aUpdate);
        return $result;
    }
 }