diff --git a/application/common/QueueJob.php b/application/common/QueueJob.php index 676a1ce..eaf1c3d 100644 --- 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; } }