From 61069cd095c15d8f12acb0c8bc514e3e53e3e7c1 Mon Sep 17 00:00:00 2001
From: Hermes Agent <hermes@aicrm.local>
Date: Sat, 19 Sep 2026 18:51:44 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=9F=A5=E8=AF=86=E7=AE=A1=E7=90=86?=
 =?UTF-8?q?=E5=8A=A0=E6=9B=B4=E6=96=B0=E6=97=B6=E9=97=B4=E5=88=97=EF=BC=9B?=
 =?UTF-8?q?=E8=B6=8B=E5=8A=BF=E7=AE=A1=E7=90=86=E5=BE=85=E8=A1=A5=E7=AD=9B?=
 =?UTF-8?q?=E9=80=89+=E7=BB=9F=E8=AE=A1+AI=E6=89=B9=E9=87=8F=E8=A1=A5?=
 =?UTF-8?q?=E9=BD=90=E4=BA=BA=E8=AF=9D=E8=A7=A3=E8=AF=BB=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 admin/src/views/Knowledge.vue |  4 +++
 admin/src/views/Trends.vue    | 20 +++++++++++--
 server/src/routes/admin.js    | 54 +++++++++++++++++++++++++++++++++--
 3 files changed, 74 insertions(+), 4 deletions(-)

diff --git a/admin/src/views/Knowledge.vue b/admin/src/views/Knowledge.vue
index 7d8db59..25456b0 100644
--- a/admin/src/views/Knowledge.vue
+++ b/admin/src/views/Knowledge.vue
@@ -21,6 +21,9 @@
         </template>
       </el-table-column>
       <el-table-column prop="viewCount" label="浏览" width="70" />
+      <el-table-column label="更新时间" width="150">
+        <template #default="{ row }">{{ fmt(row.updatedAt || row.createdAt) }}</template>
+      </el-table-column>
       <el-table-column label="状态" width="80">
         <template #default="{ row }">
           <el-tag :type="row.status === 'approved' ? 'success' : 'warning'" size="small">{{ STATUS[row.status] || row.status }}</el-tag>
@@ -130,6 +133,7 @@ async function del(row) {
   try { await apiDelete(`/api/admin/knowledge/${row._id}`); ElMessage.success('已删除'); load() }
   catch (e) { ElMessage.error(e.message || '删除失败') }
 }
+function fmt(t) { return t ? new Date(t).toLocaleString('zh-CN', { hour12: false }) : '—' }
 onMounted(load)
 </script>
 
diff --git a/admin/src/views/Trends.vue b/admin/src/views/Trends.vue
index 72ccbb9..69e50c8 100644
--- a/admin/src/views/Trends.vue
+++ b/admin/src/views/Trends.vue
@@ -3,6 +3,8 @@
     <div class="toolbar">
       <el-input v-model="q" placeholder="搜索标题" style="width: 220px" clearable @keyup.enter="search" />
       <el-button type="primary" @click="search">搜索</el-button>
+      <el-button :type="missingOnly ? 'warning' : 'default'" @click="filterMissing">待补 {{ missingCount }}</el-button>
+      <el-button type="success" :loading="filling" :disabled="!missingCount" @click="fillMissing">AI 补齐人话解读</el-button>
       <el-button type="success" @click="openEdit(null)">新增资讯</el-button>
     </div>
     <el-table :data="list" stripe v-loading="loading">
@@ -18,7 +20,7 @@
       <el-table-column label="人话解读" min-width="170" show-overflow-tooltip>
         <template #default="{ row }">
           <span v-if="row.plainExplain">{{ row.plainExplain }}<template v-if="row.takeAway"> ｜ {{ row.takeAway }}</template></span>
-          <el-tag v-else type="info" size="small">待补</el-tag>
+          <el-tag v-else type="warning" size="small" style="cursor:pointer" @click="filterMissing">待补（点击筛选）</el-tag>
         </template>
       </el-table-column>
       <el-table-column label="日期" width="110">
@@ -65,12 +67,26 @@ const list = ref([]), total = ref(0), page = ref(1), pageSize = 20, q = ref(''),
 const dlg = ref(false)
 const form = ref({})
 function search() { page.value = 1; load() }
+const missingOnly = ref(false)
+const missingCount = ref(0)
+const filling = ref(false)
+function filterMissing() { missingOnly.value = !missingOnly.value; page.value = 1; load() }
+async function fillMissing() {
+  if (!missingCount.value || filling.value) return
+  filling.value = true
+  try {
+    const r = await apiPost('/api/admin/trends/fill-plain', {})
+    ElMessage.success(`已补齐 ${r.filled || 0} 条人话解读`)
+    load()
+  } catch (e) { ElMessage.error(e.message || '补齐失败') } finally { filling.value = false }
+}
 async function load() {
   loading.value = true
   try {
-    const r = await apiGet(`/api/admin/trends?page=${page.value}&limit=${pageSize}&keyword=${encodeURIComponent(q.value)}`)
+    const r = await apiGet(`/api/admin/trends?page=${page.value}&limit=${pageSize}&keyword=${encodeURIComponent(q.value)}${missingOnly.value ? '&missing=1' : ''}`)
     list.value = r.items || []
     total.value = r.pagination?.total || 0
+    missingCount.value = r.missingCount ?? 0
   } finally { loading.value = false }
 }
 function openEdit(row) {
diff --git a/server/src/routes/admin.js b/server/src/routes/admin.js
index 4626f61..b064fd2 100755
--- a/server/src/routes/admin.js
+++ b/server/src/routes/admin.js
@@ -1157,18 +1157,68 @@ router.get('/login-logs', requirePermission('user:read'), async (req, res) => {
  */
 router.get('/trends', requirePermission('trend:read'), async (req, res) => {
   try {
-    const { page = 1, limit = 20, keyword = '' } = req.query
+    const { page = 1, limit = 20, keyword = '', missing } = req.query
     const query = keyword ? { title: { $regex: escapeRegExp(keyword), $options: 'i' } } : {}
+    if (missing === '1') query.plainExplain = { $in: ['', null, undefined] }
     const total = await Trend.countDocuments(query)
+    const missingCount = await Trend.countDocuments({ plainExplain: { $in: ['', null, undefined] } })
     const items = await Trend.find(query).sort({ newsDate: -1, createdAt: -1 })
       .skip((parseInt(page) - 1) * parseInt(limit)).limit(parseInt(limit)).lean()
-    return ApiResponse.paginated(res, items, { page: parseInt(page), limit: parseInt(limit), total })
+    return res.status(200).json({
+      success: true,
+      message: '查询成功',
+      data: { items, missingCount, pagination: { page: parseInt(page), limit: parseInt(limit), total, totalPages: Math.ceil(total / parseInt(limit)) } },
+    })
   } catch (error) {
     logger.error('获取趋势列表失败:', error)
     return ApiResponse.serverError(res, '获取趋势列表失败')
   }
 })
 
+// AI 批量补齐人话解读（复用 aiChat 的模型配置：数据库活跃模型或环境变量）
+router.post('/trends/fill-plain', requirePermission('trend:write'), async (req, res) => {
+  try {
+    const limit = Math.min(30, parseInt(req.body?.limit) || 20)
+    const missing = await Trend.find({ plainExplain: { $in: ['', null, undefined] } })
+      .sort({ newsDate: -1 }).limit(limit).lean()
+    if (!missing.length) return ApiResponse.success(res, { filled: 0, total: 0 }, '没有待补条目')
+
+    // 取模型配置
+    const active = await AIModel.getActiveModels().catch(() => [])
+    const model = (active && active[0]) || {
+      apiUrl: process.env.OPENAI_API_URL || 'https://api.openai.com/v1/chat/completions',
+      apiKey: process.env.OPENAI_API_KEY,
+      modelId: process.env.OPENAI_MODEL || 'gpt-3.5-turbo',
+    }
+    if (!model.apiKey) return ApiResponse.error(res, '未配置 AI 模型（系统设置→AI模型）', 400)
+
+    let filled = 0
+    for (const t of missing) {
+      try {
+        const prompt = `给下面这条AI行业新闻写两句中文解读。要求：1) 第一句"人话"：用不超过40字的大白话说清这件事；2) 第二句"对你"：说明对普通用户/从业者意味着什么，不超过40字。只输出两行，格式：人话内容\n对你内容\n\n新闻标题：${t.title}\n摘要：${(t.summary || '').slice(0, 200)}`
+        const r = await fetch(model.apiUrl, {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json', Authorization: `Bearer ${model.apiKey}` },
+          body: JSON.stringify({ model: model.modelId, messages: [{ role: 'user', content: prompt }], max_tokens: 300, temperature: 0.5 }),
+          signal: AbortSignal.timeout(60_000),
+        })
+        const j = await r.json()
+        const text = String(j?.choices?.[0]?.message?.content || '').trim()
+        const lines = text.split('\n').map(x => x.replace(/^(人话|对你)[：:]?\s*/, '').trim()).filter(Boolean)
+        if (lines.length >= 2) {
+          await Trend.updateOne({ _id: t._id }, { plainExplain: lines[0].slice(0, 60), takeAway: lines[1].slice(0, 60) })
+          filled++
+        }
+      } catch (e) { logger.warn('补齐失败:', t.title, e.message) }
+    }
+    const remain = await Trend.countDocuments({ plainExplain: { $in: ['', null, undefined] } })
+    return ApiResponse.success(res, { filled, remain }, `已补齐 ${filled} 条，剩余 ${remain} 条待补`)
+  } catch (error) {
+    logger.error('批量补齐失败:', error)
+    return ApiResponse.serverError(res, '批量补齐失败')
+  }
+})
+
 router.post('/trends', requirePermission('trend:write'), async (req, res) => {
   try {
     const { title, summary, source, sourceUrl, category, tags, hot, picked, newsDate, plainExplain, takeAway } = req.body