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

总结expert领域的功能

Browse Source
This commit is contained in:
wangjinlei
2026-06-05 15:50:48 +08:00
parent 93d25de094
commit 633ec028b0
4 changed files with 537 additions and 149 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
application/api/job/ExpertFieldAiFill.php
View File

@@ -6,13 +6,7 @@ use think\queue\Job;
use app\common\ExpertFieldAiService;
/**
* Expert field_ai 链式任务（阶段1：邮箱关联 user.field_ai）
*
* data:
* - expert_id
* - queue 队列名，默认 ExpertFieldAi
* - force 1=强制重算
* - mode link（默认）
* Expert field_ai 链式任务：先尝试 user 关联，主流程 AI 总结
*
* Worker: php think queue:work --queue ExpertFieldAi
*/
@@ -23,16 +17,15 @@ class ExpertFieldAiFill
$expertId = isset($data['expert_id']) ? intval($data['expert_id']) : 0;
$queue = isset($data['queue']) ? (string)$data['queue'] : ExpertFieldAiService::QUEUE_NAME;
$force = !empty($data['force']);
$mode = isset($data['mode']) ? (string)$data['mode'] : 'link';
$svc = new ExpertFieldAiService();
if ($expertId > 0 && $mode === 'link') {
$svc->linkFromUser($expertId, $force);
if ($expertId > 0) {
$svc->processExpert($expertId, $force);
}
$job->delete();
$delay = max(0, (int)(isset($data['delay']) ? $data['delay'] : 1));
$svc->enqueueNextLink($delay, $queue, $expertId, $force);
$svc->enqueueNext($delay, $queue, $expertId, $force);
}
}