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

一处原文引用20多个参考文献优化

Browse Source
This commit is contained in:
wyn
2026-08-05 11:58:36 +08:00
parent 32fb903c5d
commit 1e7afcbeff
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
application/common/mq/ReferenceCheckArticleWorker.php
View File

@@ -41,7 +41,11 @@ class ReferenceCheckArticleWorker
} }
// 先释放其它文章上的僵尸 RUNNING，避免全局串行永久堵死 // 先释放其它文章上的僵尸 RUNNING，避免全局串行永久堵死
try {
$this->recoverStaleForeignBatches($batchId); $this->recoverStaleForeignBatches($batchId);
} catch (\Throwable $e) {
$this->svc->log('ReferenceCheckArticleWorker recoverStaleForeignBatches err=' . $e->getMessage());
}
if (!$this->canStartArticleWork($batchId)) { if (!$this->canStartArticleWork($batchId)) {
$this->svc->log('ReferenceCheckArticleWorker defer batch_id=' . $batchId . ' other article running'); $this->svc->log('ReferenceCheckArticleWorker defer batch_id=' . $batchId . ' other article running');
@@ -188,10 +192,12 @@ class ReferenceCheckArticleWorker
{ {
$exceptBatchId = intval($exceptBatchId); $exceptBatchId = intval($exceptBatchId);
$staleBefore = date('Y-m-d H:i:s', time() - self::BATCH_STALE_SECONDS); $staleBefore = date('Y-m-d H:i:s', time() - self::BATCH_STALE_SECONDS);
// ThinkPHP 5：whereRaw 绑参会与命名占位符冲突(HY093)，日期直接拼进 SQL
$staleSql = "(updated_at IS NULL OR updated_at < '" . addslashes($staleBefore) . "')";
$rows = Db::name('article_reference_relevance_check_batch') $rows = Db::name('article_reference_relevance_check_batch')
->where('batch_status', self::BATCH_RUNNING) ->where('batch_status', self::BATCH_RUNNING)
->where('id', '<>', $exceptBatchId) ->where('id', '<>', $exceptBatchId)
->whereRaw('(updated_at IS NULL OR updated_at < ?)', [$staleBefore]) ->whereRaw($staleSql)
->order('id asc') ->order('id asc')
->limit(20) ->limit(20)
->select(); ->select();
@@ -206,7 +212,7 @@ class ReferenceCheckArticleWorker
$affected = Db::name('article_reference_relevance_check_batch') $affected = Db::name('article_reference_relevance_check_batch')
->where('id', $bid) ->where('id', $bid)
->where('batch_status', self::BATCH_RUNNING) ->where('batch_status', self::BATCH_RUNNING)
->whereRaw('(updated_at IS NULL OR updated_at < ?)', [$staleBefore]) ->whereRaw($staleSql)
->update([ ->update([
'batch_status' => self::BATCH_WAITING, 'batch_status' => self::BATCH_WAITING,
'updated_at' => date('Y-m-d H:i:s'), 'updated_at' => date('Y-m-d H:i:s'),