diff --git a/application/common/QueueJob.php b/application/common/QueueJob.php index 93fb51e..b336fb7 100644 --- a/application/common/QueueJob.php +++ b/application/common/QueueJob.php @@ -29,6 +29,10 @@ class QueueJob */ public function addLog($aParam = []) { + + $sJobId = empty($aParam['job_id']) ? uniqid() : $aParam['job_id']; + return $sJobId; + // 数据过滤(只保留必填字段) $aInsert = []; foreach ($this->aField as $field) { @@ -60,6 +64,7 @@ class QueueJob */ public function updateLog($aParam = []) { + return true; $iLogId = empty($aParam['log_id']) ? 0 : $aParam['log_id']; if (empty($iLogId)) { $this->log("更新日志失败: 缺少log_id");