From 36847ea70c1176d484279368e4162dfbfa259819 Mon Sep 17 00:00:00 2001
From: ShengLong <452591453@qq.com>
Date: Thu, 7 May 2026 17:36:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E6=8B=89=E5=8F=96=E8=81=8A?=
 =?UTF-8?q?=E5=A4=A9=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 admin/src/api/tcm.ts                          |  5 +++
 .../components/ImChatRecordPanel.vue          | 42 ++++++++++++++-----
 .../controller/tcm/DiagnosisController.php    | 30 +++++++++++++
 .../add_sync_im_chat_archive_crontab.sql      | 20 +++++++++
 .../add_tcm_im_chat_message_table.sql         | 28 +++++++++++++
 5 files changed, 114 insertions(+), 11 deletions(-)
 create mode 100644 server/sql/1.9.20260507/add_sync_im_chat_archive_crontab.sql
 create mode 100644 server/sql/1.9.20260507/add_tcm_im_chat_message_table.sql

diff --git a/admin/src/api/tcm.ts b/admin/src/api/tcm.ts
index 85277648..242e1744 100644
--- a/admin/src/api/tcm.ts
+++ b/admin/src/api/tcm.ts
@@ -261,6 +261,11 @@ export function getImChatMessages(params: { diagnosis_id: number; only_archived?
     return request.get({ url: '/tcm.diagnosis/getImChatMessages', params })
 }
 
+/** 触发后台异步同步：从腾讯云 IM 拉取诊单聊天记录入归档表，请求即返回 */
+export function triggerImChatSync(data: { diagnosis_id: number }) {
+    return request.post({ url: '/tcm.diagnosis/triggerImChatSync', data })
+}
+
 // 获取企业微信聊天记录
 export function getWechatChatRecords(params: any) {
     return request.get({ url: '/tcm.diagnosis/getWechatChatRecords', params })
diff --git a/admin/src/views/tcm/diagnosis/components/ImChatRecordPanel.vue b/admin/src/views/tcm/diagnosis/components/ImChatRecordPanel.vue
index 27289296..317ae8e0 100644
--- a/admin/src/views/tcm/diagnosis/components/ImChatRecordPanel.vue
+++ b/admin/src/views/tcm/diagnosis/components/ImChatRecordPanel.vue
@@ -4,14 +4,18 @@
             <p class="panel-tip">
                 展示单聊记录：已合并患者  与
                 <strong>所有医生 / 医助账号</strong>分别产生的会话，按时间排序。
-                数据来自 IM 漫游；若未开通漫游或某账号与该患者无会话，对应侧无消息。
+                数据由后台定时任务从腾讯云 IM 漫游消息同步至本地归档；点击下方按钮可立即触发后台同步。
             </p>
         </el-alert>
 
         <div class="toolbar mb-3">
-            <el-button type="primary" link :loading="loading" @click="refreshLive">
+            <el-button type="primary" link :loading="syncing" @click="triggerSync">
+                <el-icon class="mr-1"><Promotion /></el-icon>
+                同步最新（后台异步）
+            </el-button>
+            <el-button type="primary" link :loading="loading" @click="reloadArchived">
                 <el-icon class="mr-1"><Refresh /></el-icon>
-                刷新（同步云端最新）
+                重新加载已归档
             </el-button>
         </div>
 
@@ -68,8 +72,9 @@
 <script setup lang="ts">
 import { ref, shallowRef, watch, computed } from 'vue'
 import dayjs from 'dayjs'
-import { Refresh } from '@element-plus/icons-vue'
-import { getImChatMessages } from '@/api/tcm'
+import { Refresh, Promotion } from '@element-plus/icons-vue'
+import { ElMessage } from 'element-plus'
+import { getImChatMessages, triggerImChatSync } from '@/api/tcm'
 import type { FriendlyParse } from '@/utils/im-business-message-parse'
 import { parseImBusinessPayload } from '@/utils/im-business-message-parse'
 
@@ -78,6 +83,7 @@ const props = defineProps<{
 }>()
 
 const loading = ref(false)
+const syncing = ref(false)
 const rawRows = shallowRef<any[]>([])
 const patientImId = ref('')
 const patientName = ref('')
@@ -139,13 +145,13 @@ function senderLabel(row: any) {
     return patientName.value ? `患者（${patientName.value}）` : '患者'
 }
 
-async function load(onlyArchived = false) {
+async function load() {
     if (!props.diagnosisId) return
     loading.value = true
     try {
         const res = (await getImChatMessages({
             diagnosis_id: props.diagnosisId,
-            only_archived: onlyArchived ? 1 : 0
+            only_archived: 1
         })) as {
             lists?: any[]
             patient_im_id?: string
@@ -162,19 +168,33 @@ async function load(onlyArchived = false) {
     }
 }
 
-function refreshLive() {
-    load(false)
+function reloadArchived() {
+    load()
+}
+
+async function triggerSync() {
+    if (!props.diagnosisId) return
+    syncing.value = true
+    try {
+        await triggerImChatSync({ diagnosis_id: props.diagnosisId })
+        ElMessage.success('已发起后台同步，几秒后请点击"重新加载已归档"查看新消息')
+    } catch (e) {
+        console.error(e)
+        ElMessage.error('发起同步失败')
+    } finally {
+        syncing.value = false
+    }
 }
 
 watch(
     () => props.diagnosisId,
     () => {
-        load(true)
+        load()
     },
     { immediate: true }
 )
 
-defineExpose({ refresh: refreshLive })
+defineExpose({ refresh: reloadArchived })
 </script>
 
 <style scoped lang="scss">
diff --git a/server/app/adminapi/controller/tcm/DiagnosisController.php b/server/app/adminapi/controller/tcm/DiagnosisController.php
index ecac300b..7fc60720 100644
--- a/server/app/adminapi/controller/tcm/DiagnosisController.php
+++ b/server/app/adminapi/controller/tcm/DiagnosisController.php
@@ -407,6 +407,36 @@ class DiagnosisController extends BaseAdminController
         return $this->data($result);
     }
 
+    /**
+     * @notes 触发后台异步同步当前诊单的腾讯云 IM 聊天记录到本地归档表
+     * 请求即返回，真正的同步逻辑在 fastcgi_finish_request 之后执行
+     */
+    public function triggerImChatSync()
+    {
+        $diagnosisId = (int)$this->request->post('diagnosis_id', 0);
+        if ($diagnosisId <= 0) {
+            $diagnosisId = (int)$this->request->get('diagnosis_id', 0);
+        }
+        if ($diagnosisId <= 0) {
+            return $this->fail('诊单ID不能为空');
+        }
+
+        register_shutdown_function(function () use ($diagnosisId) {
+            try {
+                @set_time_limit(300);
+                ignore_user_abort(true);
+                DiagnosisLogic::syncImChatArchiveForDiagnosis($diagnosisId);
+            } catch (\Throwable $e) {
+                \think\facade\Log::warning('triggerImChatSync failed', [
+                    'diagnosis_id' => $diagnosisId,
+                    'err' => $e->getMessage(),
+                ]);
+            }
+        });
+
+        return $this->success('已发起后台同步，几秒后请重新加载查看', ['queued' => true]);
+    }
+
     /**
      * @notes 绑定 TRTC 房间号到当前诊单通话记录（便于云端录制回调关联）
      * @return \think\response\Json
diff --git a/server/sql/1.9.20260507/add_sync_im_chat_archive_crontab.sql b/server/sql/1.9.20260507/add_sync_im_chat_archive_crontab.sql
new file mode 100644
index 00000000..66f2ec0a
--- /dev/null
+++ b/server/sql/1.9.20260507/add_sync_im_chat_archive_crontab.sql
@@ -0,0 +1,20 @@
+-- 注册「同步诊单 IM 聊天记录归档」定时任务，每 30 分钟跑一次
+-- 命令本体：server/app/common/command/SyncImChatArchive.php，已在 server/config/console.php 注册为 sync_im_chat_archive
+-- 参数：--since-days=7 仅处理最近 7 天有更新的诊单，--limit=200 单轮最多处理 200 个诊单
+-- expression 字段为 5 段标准 cron（分 时 日 月 周），与 likeadmin la_dev_crontab 保持一致
+
+INSERT INTO `zyt_dev_crontab` (
+    `name`, `type`, `system`, `remark`, `command`, `params`,
+    `status`, `expression`, `create_time`, `update_time`
+) VALUES (
+    '同步诊单IM聊天记录',
+    1,
+    0,
+    '从腾讯云 IM 拉取近 7 天有更新诊单的漫游消息归档到 tcm_im_chat_message',
+    'sync_im_chat_archive',
+    '--since-days=7 --limit=200',
+    1,
+    '*/30 * * * *',
+    UNIX_TIMESTAMP(),
+    UNIX_TIMESTAMP()
+);
diff --git a/server/sql/1.9.20260507/add_tcm_im_chat_message_table.sql b/server/sql/1.9.20260507/add_tcm_im_chat_message_table.sql
new file mode 100644
index 00000000..ce7c711e
--- /dev/null
+++ b/server/sql/1.9.20260507/add_tcm_im_chat_message_table.sql
@@ -0,0 +1,28 @@
+-- 诊单腾讯云 IM 单聊消息归档（定时从 admin_getroammsg 同步，突破云端约 7 天漫游限制）
+-- 已在生产部分环境创建（参见 server/database/migrations/create_tcm_im_chat_message.sql）
+-- 此处使用 IF NOT EXISTS 安全重入，确保新环境部署时一并建表
+
+CREATE TABLE IF NOT EXISTS `zyt_tcm_im_chat_message` (
+  `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `diagnosis_id` int unsigned NOT NULL DEFAULT 0 COMMENT '诊单ID',
+  `patient_id` int unsigned NOT NULL DEFAULT 0 COMMENT '患者ID（冗余，便于按患者维度排查/统计）',
+  `msg_id` varchar(160) NOT NULL DEFAULT '' COMMENT '业务唯一键：MsgSeq_MsgRandom_From_Account',
+  `from_account` varchar(64) NOT NULL DEFAULT '' COMMENT '发送方 IM UserID',
+  `to_account` varchar(64) NOT NULL DEFAULT '' COMMENT '接收方 IM UserID',
+  `msg_time` int unsigned NOT NULL DEFAULT 0 COMMENT '消息时间 Unix 时间戳',
+  `is_from_doctor` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '是否医生/医助侧发送',
+  `msg_type` varchar(32) NOT NULL DEFAULT '' COMMENT 'text/image/file/sound/video/custom/...',
+  `text` mediumtext COMMENT '文本或自定义消息 Data',
+  `image_url` varchar(1024) NOT NULL DEFAULT '' COMMENT '图片 URL',
+  `file_url` varchar(1024) NOT NULL DEFAULT '' COMMENT '文件/语音/视频 URL',
+  `file_name` varchar(512) NOT NULL DEFAULT '' COMMENT '文件名',
+  `raw_elem_type` varchar(64) NOT NULL DEFAULT '' COMMENT 'TIM 元素类型',
+  `from_staff_name` varchar(64) NOT NULL DEFAULT '' COMMENT '医生侧姓名快照',
+  `doctor_peer_account` varchar(64) NOT NULL DEFAULT '' COMMENT '拉取会话时使用的医生侧账号 doctor_*',
+  `create_time` int unsigned NOT NULL DEFAULT 0 COMMENT '入库时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uk_msg_id` (`msg_id`),
+  KEY `idx_diagnosis_time` (`diagnosis_id`,`msg_time`),
+  KEY `idx_patient_time` (`patient_id`,`msg_time`),
+  KEY `idx_msg_time` (`msg_time`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='诊单IM聊天记录归档';