zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

队列相关的调整

Browse Source
This commit is contained in:
chengxl
2025-05-30 13:39:47 +08:00
parent b6a03c6ea1
commit 8d0e54dfd1
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
application/api/job/WechatDraft.php
View File

@@ -41,8 +41,8 @@ class WechatDraft
//更新任务状态 //更新任务状态
$aParam = ['log_id' => $iLogId,'status' => 1,'update_time' => time(),'error' => $sMsg]; $aParam = ['log_id' => $iLogId,'status' => 1,'update_time' => time(),'error' => $sMsg];
$oQueueJob->updateLog($aParam); $oQueueJob->updateLog($aParam);
// 记录日志 // // 记录日志
\think\Log::info("WechatDraft-延迟任务执行成功: ".json_encode($data)); // \think\Log::info("WechatDraft-延迟任务执行成功: ".json_encode($data));
} catch (\Exception $e) { } catch (\Exception $e) {
//实例化 //实例化
@@ -52,8 +52,8 @@ class WechatDraft
$aParam = ['log_id' => $iLogId,'status' => 2,'update_time' => time(),'error' => $sMsg]; $aParam = ['log_id' => $iLogId,'status' => 2,'update_time' => time(),'error' => $sMsg];
$oQueueJob->updateLog($aParam); $oQueueJob->updateLog($aParam);
$job->delete(); $job->delete();
// 记录错误日志 // // 记录错误日志
\think\Log::error("WechatDraft-延迟任务失败: ".$e->getMessage()); // \think\Log::error("WechatDraft-延迟任务失败: ".$e->getMessage());
}finally { }finally {
gc_collect_cycles(); // 强制垃圾回收 gc_collect_cycles(); // 强制垃圾回收
} }

8
application/api/job/WechatQueryStatus.php
View File

@@ -40,8 +40,8 @@ class WechatQueryStatus
//更新任务状态 //更新任务状态
$aParam = ['log_id' => $iLogId,'status' => 1,'update_time' => time(),'error' => $sMsg]; $aParam = ['log_id' => $iLogId,'status' => 1,'update_time' => time(),'error' => $sMsg];
$oQueueJob->updateLog($aParam); $oQueueJob->updateLog($aParam);
// 记录日志 // // 记录日志
\think\Log::info("WechatQueryStatus延迟任务执行成功: ".json_encode($data)); // \think\Log::info("WechatQueryStatus延迟任务执行成功: ".json_encode($data));
} catch (\Exception $e) { } catch (\Exception $e) {
//实例化 //实例化
@@ -51,8 +51,8 @@ class WechatQueryStatus
$aParam = ['log_id' => $iLogId,'status' => 2,'update_time' => time(),'error' => $sMsg]; $aParam = ['log_id' => $iLogId,'status' => 2,'update_time' => time(),'error' => $sMsg];
$oQueueJob->updateLog($aParam); $oQueueJob->updateLog($aParam);
$job->delete(); $job->delete();
// 记录错误日志 // // 记录错误日志
\think\Log::error("WechatQueryStatus延迟任务失败: ".$e->getMessage()); // \think\Log::error("WechatQueryStatus延迟任务失败: ".$e->getMessage());
}finally { }finally {
gc_collect_cycles(); // 强制垃圾回收 gc_collect_cycles(); // 强制垃圾回收
} }