From 87d815dc1764bcfe127bd159a1374942db77a4d9 Mon Sep 17 00:00:00 2001
From: wangjinlei <751475802@qq.com>
Date: Thu, 16 Apr 2026 13:30:40 +0800
Subject: [PATCH] 1

---
 application/api/job/FillExpertCountry.php | 36 +++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 application/api/job/FillExpertCountry.php

diff --git a/application/api/job/FillExpertCountry.php b/application/api/job/FillExpertCountry.php
new file mode 100644
index 0000000..8c9a3cf
--- /dev/null
+++ b/application/api/job/FillExpertCountry.php
@@ -0,0 +1,36 @@
+<?php
+
+namespace app\api\job;
+
+use think\queue\Job;
+use app\common\ExpertFinderService;
+
+/**
+ * 队列任务：用本地大模型从 affiliation 推断国家，写入 expert.country_id / country。
+ * 处理完当前专家后，自动找下一个推入队列（链式执行），直到全部处理完。
+ *
+ * 队列名：FetchExperts
+ * 启动 worker：php think queue:listen --queue FetchExperts
+ */
+class FillExpertCountry
+{
+    public function fire(Job $job, $data)
+    {
+        $expertId    = intval(isset($data['expert_id']) ? $data['expert_id'] : 0);
+        $affiliation = isset($data['affiliation']) ? trim((string)$data['affiliation']) : '';
+
+        $service = new ExpertFinderService();
+
+        if ($expertId && $affiliation !== '') {
+            try {
+                $service->fillExpertCountry($expertId, $affiliation);
+            } catch (\Exception $e) {
+                $service->log('[FillExpertCountry] expert_id=' . $expertId . ' exception=' . $e->getMessage());
+            }
+        }
+
+        $job->delete();
+
+        $service->enqueueNextCountryFill(1);
+    }
+}