消息增加ai提问分类

baqing-admin/src/main/java/com/ruoyi/web/kb/support/KbOpenAiProxyHeaders.java

@@ -0,0 +1,19 @@
+package com.ruoyi.web.kb.support;
+
+/**
+ * 大模型 OpenAI 兼容转发响应头。
+ */
+public final class KbOpenAiProxyHeaders
+{
+    /** 本次对话请求耗时（毫秒） */
+    public static final String X_COST = "X-COST";
+
+    private KbOpenAiProxyHeaders()
+    {
+    }
+
+    public static String formatCostMs(long elapsedMs)
+    {
+        return String.valueOf(Math.max(0L, elapsedMs));
+    }
+}

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/domain/BizConsultMessage.java

@@ -30,6 +30,9 @@ public class BizConsultMessage extends BaseEntity
     /** AI 提问分类，可为空（最长 32 字符） */
     private String aiCategory;
 
+    /** 大模型对话耗时（毫秒），可为空 */
+    private Long costTime;
+
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private Date sendTime;
 
@@ -123,6 +126,16 @@ public class BizConsultMessage extends BaseEntity
         this.aiCategory = aiCategory;
     }
 
+    public Long getCostTime()
+    {
+        return costTime;
+    }
+
+    public void setCostTime(Long costTime)
+    {
+        this.costTime = costTime;
+    }
+
     public Date getSendTime()
     {
         return sendTime;

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/domain/BizDiagnosisUser.java

@@ -0,0 +1,48 @@
+package com.ruoyi.web.modules.diagnosis.domain;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+
+/**
+ * AI 诊断使用用户 biz_diagnosis_user
+ */
+public class BizDiagnosisUser
+{
+    private Long userId;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date firstUseTime;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date lastUseTime;
+
+    public Long getUserId()
+    {
+        return userId;
+    }
+
+    public void setUserId(Long userId)
+    {
+        this.userId = userId;
+    }
+
+    public Date getFirstUseTime()
+    {
+        return firstUseTime;
+    }
+
+    public void setFirstUseTime(Date firstUseTime)
+    {
+        this.firstUseTime = firstUseTime;
+    }
+
+    public Date getLastUseTime()
+    {
+        return lastUseTime;
+    }
+
+    public void setLastUseTime(Date lastUseTime)
+    {
+        this.lastUseTime = lastUseTime;
+    }
+}

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/domain/VetConsultSendBody.java

@@ -30,6 +30,12 @@ public class VetConsultSendBody
     @JsonAlias({ "ai_category", "category" })
     private String aiCategory;
 
+    /**
+     * 大模型对话耗时（毫秒），写入 AI 回复消息 cost_time，可为空。
+     */
+    @JsonAlias({ "cost_time", "xCost" })
+    private Long costTime;
+
     public Integer getMsgType()
     {
         return msgType;
@@ -89,4 +95,14 @@ public class VetConsultSendBody
     {
         this.aiCategory = aiCategory;
     }
+
+    public Long getCostTime()
+    {
+        return costTime;
+    }
+
+    public void setCostTime(Long costTime)
+    {
+        this.costTime = costTime;
+    }
 }

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/mapper/BizDiagnosisUserMapper.java

@@ -0,0 +1,17 @@
+package com.ruoyi.web.modules.diagnosis.mapper;
+
+import java.util.Date;
+import org.apache.ibatis.annotations.Param;
+import com.ruoyi.web.modules.diagnosis.domain.BizDiagnosisUser;
+
+/**
+ * AI 诊断使用用户 Mapper。
+ */
+public interface BizDiagnosisUserMapper
+{
+    BizDiagnosisUser selectByUserId(@Param("userId") Long userId);
+
+    int insertBizDiagnosisUser(BizDiagnosisUser row);
+
+    int updateLastUseTime(@Param("userId") Long userId, @Param("lastUseTime") Date lastUseTime);
+}

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/service/impl/BizAiOnlineConsultServiceImpl.java

@@ -17,6 +17,8 @@ import com.ruoyi.web.modules.diagnosis.domain.BizConsultMessage;
 import com.ruoyi.web.modules.diagnosis.domain.BizConsultSession;
 import com.ruoyi.web.modules.diagnosis.domain.ConsultPushPayload;
 import com.ruoyi.web.modules.diagnosis.domain.VetConsultSendBody;
+import com.ruoyi.web.modules.diagnosis.domain.BizDiagnosisUser;
+import com.ruoyi.web.modules.diagnosis.mapper.BizDiagnosisUserMapper;
 import com.ruoyi.web.modules.diagnosis.mapper.BizConsultMessageMapper;
 import com.ruoyi.web.modules.diagnosis.mapper.BizConsultSessionMapper;
 import com.ruoyi.web.modules.diagnosis.service.IBizAiOnlineConsultService;
@@ -39,6 +41,9 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
     @Autowired
     private BizConsultSessionMapper bizConsultSessionMapper;
 
+    @Autowired
+    private BizDiagnosisUserMapper bizDiagnosisUserMapper;
+
     @Autowired
     private BizConsultMessageMapper bizConsultMessageMapper;
 
@@ -90,6 +95,7 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
         row.setCreateTime(now);
         row.setUpdateTime(now);
         bizConsultSessionMapper.insertBizConsultSession(row);
+        ensureDiagnosisUserOnNewSession(askerUserId, now);
 
         AiConsultSessionView view = new AiConsultSessionView();
         view.setId(row.getId());
@@ -139,6 +145,7 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
         {
             VetConsultValidation.validateSendBody(body);
             AiConsultValidation.validateAiCategory(body.getAiCategory());
+            AiConsultValidation.validateCostTime(body.getCostTime());
             String displayName = resolveDisplayName(askerUserId, askerName);
             BizConsultMessage userMessage = persistUserMessage(session, body, askerUserId, displayName);
 
@@ -148,7 +155,7 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
                 throw new ServiceException("AI 回复失败，请稍后重试");
             }
 
-            BizConsultMessage aiMessage = persistAiMessage(session, aiText);
+            BizConsultMessage aiMessage = persistAiMessage(session, aiText, body.getCostTime());
             updateSessionAfterAiReply(session, body, aiText);
             saveRealSessionIdIfPresent(session, body.getRealSessionId());
 
@@ -205,13 +212,13 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
         patch.setLastMessageTime(now);
         patch.setLastMessagePreview(preview);
         patch.setUpdateTime(now);
-        bizConsultSessionMapper.updateSessionLastMessage(patch);
+        updateSessionLastMessageAndUserLastUse(session, patch);
 
         consultPushService.publishNewMessage(buildPushPayload(message, session, preview, now));
         return message;
     }
 
-    private BizConsultMessage persistAiMessage(BizConsultSession session, String aiText)
+    private BizConsultMessage persistAiMessage(BizConsultSession session, String aiText, Long costTime)
     {
         Date now = new Date();
         BizConsultMessage message = new BizConsultMessage();
@@ -221,6 +228,7 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
         message.setSenderName(AiConsultConstants.AI_SENDER_NAME);
         message.setMsgType(ConsultSessionRules.MSG_TYPE_TEXT);
         message.setContent(aiText);
+        message.setCostTime(AiConsultValidation.normalizeCostTime(costTime));
         message.setSendTime(now);
         message.setCreateTime(now);
         bizConsultMessageMapper.insertBizConsultMessage(message);
@@ -246,7 +254,39 @@ public class BizAiOnlineConsultServiceImpl implements IBizAiOnlineConsultService
             String userPreview = ConsultMessagePreview.build(body.getMsgType(), body.getContent());
             patch.setSessionTitle(userPreview);
         }
+        updateSessionLastMessageAndUserLastUse(session, patch);
+    }
+
+    /**
+     * 更新会话最后消息时间，并同步提问人在 AI 诊断用户表的末次使用时间。
+     */
+    private void updateSessionLastMessageAndUserLastUse(BizConsultSession session, BizConsultSession patch)
+    {
         bizConsultSessionMapper.updateSessionLastMessage(patch);
+        if (session != null && session.getAskerUserId() != null && patch.getLastMessageTime() != null)
+        {
+            bizDiagnosisUserMapper.updateLastUseTime(session.getAskerUserId(), patch.getLastMessageTime());
+        }
+    }
+
+    /**
+     * 新建 AI 会话：用户表无记录则插入（首次/末次均为当前时间）。
+     */
+    private void ensureDiagnosisUserOnNewSession(Long askerUserId, Date now)
+    {
+        if (askerUserId == null || now == null)
+        {
+            return;
+        }
+        if (bizDiagnosisUserMapper.selectByUserId(askerUserId) != null)
+        {
+            return;
+        }
+        BizDiagnosisUser row = new BizDiagnosisUser();
+        row.setUserId(askerUserId);
+        row.setFirstUseTime(now);
+        row.setLastUseTime(now);
+        bizDiagnosisUserMapper.insertBizDiagnosisUser(row);
     }
 
     private String resolveAiReplyText(VetConsultSendBody body)

baqing-admin/src/main/java/com/ruoyi/web/modules/diagnosis/support/AiConsultValidation.java

@@ -59,4 +59,24 @@ public final class AiConsultValidation
         String trimmed = aiCategory.trim();
         return trimmed.isEmpty() ? null : trimmed;
     }
+
+    /**
+     * 大模型耗时（毫秒，可为空）；非空时须为非负且不超过 24 小时。
+     */
+    public static void validateCostTime(Long costTime)
+    {
+        if (costTime == null)
+        {
+            return;
+        }
+        if (costTime < 0L || costTime > 86_400_000L)
+        {
+            throw new ServiceException("对话耗时无效");
+        }
+    }
+
+    public static Long normalizeCostTime(Long costTime)
+    {
+        return costTime == null || costTime < 0L ? null : costTime;
+    }
 }

baqing-admin/src/main/resources/mapper/diagnosis/BizConsultMessageMapper.xml

@@ -12,13 +12,14 @@
         <result property="content"       column="content"/>
         <result property="mediaDuration" column="media_duration"/>
         <result property="aiCategory"    column="ai_category"/>
+        <result property="costTime"      column="cost_time"/>
         <result property="sendTime"      column="send_time"/>
         <result property="createTime"    column="create_time"/>
     </resultMap>
 
     <select id="selectMessagesBeforeId" resultMap="BizConsultMessageResult">
         select id, session_id, sender_role, sender_user_id, sender_name, msg_type, content, media_duration,
-               ai_category, send_time, create_time
+               ai_category, cost_time, send_time, create_time
         from biz_consult_message
         where session_id = #{sessionId}
         <if test="beforeId != null">
@@ -32,10 +33,10 @@
             useGeneratedKeys="true" keyProperty="id">
         insert into biz_consult_message (
             session_id, sender_role, sender_user_id, sender_name, msg_type, content, media_duration, ai_category,
-            send_time, create_time
+            cost_time, send_time, create_time
         ) values (
             #{sessionId}, #{senderRole}, #{senderUserId}, #{senderName}, #{msgType}, #{content}, #{mediaDuration},
-            #{aiCategory}, #{sendTime}, #{createTime}
+            #{aiCategory}, #{costTime}, #{sendTime}, #{createTime}
         )
     </insert>
 </mapper>

baqing-admin/src/main/resources/mapper/diagnosis/BizConsultSessionMapper.xml

@@ -145,7 +145,7 @@
         update biz_consult_session
         set last_message_time = #{lastMessageTime},
             last_message_preview = #{lastMessagePreview},
-            update_time = #{updateTime}
+            update_time = sysdate()
             <if test="sessionTitle != null and sessionTitle != ''">
                 , session_title = #{sessionTitle}
             </if>

baqing-admin/src/main/resources/mapper/diagnosis/BizDiagnosisUserMapper.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.web.modules.diagnosis.mapper.BizDiagnosisUserMapper">
+
+    <resultMap type="com.ruoyi.web.modules.diagnosis.domain.BizDiagnosisUser" id="BizDiagnosisUserResult">
+        <id     property="userId"       column="user_id"/>
+        <result property="firstUseTime" column="first_use_time"/>
+        <result property="lastUseTime"  column="last_use_time"/>
+    </resultMap>
+
+    <select id="selectByUserId" resultMap="BizDiagnosisUserResult">
+        select user_id, first_use_time, last_use_time
+        from biz_diagnosis_user
+        where user_id = #{userId}
+    </select>
+
+    <insert id="insertBizDiagnosisUser" parameterType="com.ruoyi.web.modules.diagnosis.domain.BizDiagnosisUser">
+        insert into biz_diagnosis_user (user_id, first_use_time, last_use_time)
+        values (#{userId}, #{firstUseTime}, #{lastUseTime})
+    </insert>
+
+    <update id="updateLastUseTime">
+        update biz_diagnosis_user
+        set last_use_time = #{lastUseTime}
+        where user_id = #{userId}
+    </update>
+</mapper>

baqing-admin/src/test/java/com/ruoyi/web/kb/KbOpenAiProxyControllerApiTest.java

@@ -1,6 +1,5 @@
 package com.ruoyi.web.kb;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.doAnswer;
@@ -10,9 +9,8 @@ import static org.springframework.test.web.servlet.request.MockMvcRequestBuilder
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
-import java.io.ByteArrayOutputStream;
-import java.nio.charset.StandardCharsets;
 import java.io.OutputStream;
+import java.nio.charset.StandardCharsets;
 import org.springframework.mock.web.MockHttpServletRequest;
 import org.springframework.mock.web.MockHttpServletResponse;
 

baqing-admin/src/test/java/com/ruoyi/web/modules/diagnosis/service/impl/BizAiOnlineConsultServiceImplTest.java

@@ -31,6 +31,8 @@ import com.ruoyi.web.modules.diagnosis.domain.AiConsultOpenBody;
 import com.ruoyi.web.modules.diagnosis.domain.AiConsultSendResult;
 import com.ruoyi.web.modules.diagnosis.domain.BizConsultSession;
 import com.ruoyi.web.modules.diagnosis.domain.VetConsultSendBody;
+import com.ruoyi.web.modules.diagnosis.domain.BizDiagnosisUser;
+import com.ruoyi.web.modules.diagnosis.mapper.BizDiagnosisUserMapper;
 import com.ruoyi.web.modules.diagnosis.mapper.BizConsultMessageMapper;
 import com.ruoyi.web.modules.diagnosis.mapper.BizConsultSessionMapper;
 import com.ruoyi.web.modules.diagnosis.support.AiConsultConstants;
@@ -47,6 +49,9 @@ class BizAiOnlineConsultServiceImplTest
     @Mock
     private BizConsultSessionMapper sessionMapper;
 
+    @Mock
+    private BizDiagnosisUserMapper diagnosisUserMapper;
+
     @Mock
     private BizConsultMessageMapper messageMapper;
 
@@ -93,12 +98,28 @@ class BizAiOnlineConsultServiceImplTest
     @DisplayName("创建会话 receiver 全 NULL")
     void createSession()
     {
+        when(diagnosisUserMapper.selectByUserId(AiOnlineConsultTestSamples.VA_USER_ID)).thenReturn(null);
         service.createAiSession(AiOnlineConsultTestSamples.VA_USER_ID, "甲", null);
         verify(sessionMapper).insertBizConsultSession(argThat(r -> r.getConsultType() == ConsultSessionRules.CONSULT_TYPE_AI
                 && r.getReceiverProviderId() == null
                 && r.getReceiverUserId() == null
                 && AiConsultConstants.SESSION_TITLE_NEW.equals(r.getSessionTitle())
                 && r.getLastMessageTime() != null));
+        verify(diagnosisUserMapper).insertBizDiagnosisUser(argThat(u -> u != null
+                && AiOnlineConsultTestSamples.VA_USER_ID.equals(u.getUserId())
+                && u.getFirstUseTime() != null
+                && u.getLastUseTime() != null));
+    }
+
+    @Test
+    @DisplayName("创建会话不重复插入用户")
+    void createSessionSkipsExistingUser()
+    {
+        BizDiagnosisUser existing = new BizDiagnosisUser();
+        existing.setUserId(AiOnlineConsultTestSamples.VA_USER_ID);
+        when(diagnosisUserMapper.selectByUserId(AiOnlineConsultTestSamples.VA_USER_ID)).thenReturn(existing);
+        service.createAiSession(AiOnlineConsultTestSamples.VA_USER_ID, "甲", null);
+        verify(diagnosisUserMapper, never()).insertBizDiagnosisUser(any());
     }
 
     @Test
@@ -116,6 +137,7 @@ class BizAiOnlineConsultServiceImplTest
         assertNotNull(result.getAiMessage());
         assertEquals(ConsultSessionRules.SENDER_ROLE_AI, result.getAiMessage().getSenderRole());
         verify(consultPushService, atLeastOnce()).publishNewMessage(any());
+        verify(diagnosisUserMapper, atLeastOnce()).updateLastUseTime(eq(AiOnlineConsultTestSamples.VA_USER_ID), any());
     }
 
     @Test
@@ -150,6 +172,24 @@ class BizAiOnlineConsultServiceImplTest
         verify(sessionMapper).updateRealSessionId(AiOnlineConsultTestSamples.SESSION_ID, "gateway-session-001");
     }
 
+    @Test
+    @DisplayName("AI消息保存 cost_time")
+    void sendWithCostTime()
+    {
+        when(sessionMapper.selectAiSessionById(AiOnlineConsultTestSamples.SESSION_ID))
+                .thenReturn(AiOnlineConsultTestSamples.activeAiSession());
+        VetConsultSendBody body = new VetConsultSendBody();
+        body.setMsgType(ConsultSessionRules.MSG_TYPE_TEXT);
+        body.setContent("牛不吃草");
+        body.setAiReplyContent("请先观察体温");
+        body.setCostTime(1523L);
+        service.sendAiMessage(AiOnlineConsultTestSamples.SESSION_ID, body,
+                AiOnlineConsultTestSamples.VA_USER_ID, "甲");
+        verify(messageMapper).insertBizConsultMessage(argThat(m -> m != null
+                && Long.valueOf(1523L).equals(m.getCostTime())
+                && Integer.valueOf(ConsultSessionRules.SENDER_ROLE_AI).equals(m.getSenderRole())));
+    }
+
     @Test
     @DisplayName("提问消息保存 ai_category")
     void sendWithAiCategory()

doc/牧业疫病诊疗服务/AI诊断(兽医、机构)/AI诊断(兽医、机构)技术方案.md

@@ -1,7 +1,7 @@
 # AI 诊断（兽医、机构）— 技术方案
 
 > 依据：`AI诊断(兽医、机构)功能需求.md`（v1.1）；关联 `在线接诊(兽医)技术方案.md`（v1.1）、`在线接诊(兽医)功能需求.md`  
-> **本文档版本：1.5**（`real_session_id`、`ai_category` 字段与落库接口 Body 同步，见 **§3.1**、**§3.2**、**§4.3**）
+> **本文档版本：1.6**（`biz_diagnosis_user` 使用用户表，见 **§3.0**）
 
 ---
 
@@ -12,7 +12,7 @@
 | **整体** | RuoYi **v3.9.2**（**springboot2** 分支）单体后端 + 若依 **Vue2** 管理端 + 移动端 |
 | **运行时** | JDK 8、Spring Boot 2.x、Spring MVC、MyBatis、Druid |
 | **数据库** | MySQL **5.7.39**，InnoDB，`utf8mb4` |
-| **问诊 IM 表** | **复用** `biz_consult_session`、`biz_consult_message`（与在线接诊共用，见 **§2**） |
+| **问诊 IM 表** | **复用** `biz_consult_session`、`biz_consult_message`（与在线接诊共用，见 **§2**）；另增 `biz_diagnosis_user` 记录提问人首次/末次使用时间（**§3.0**） |
 | **近实时** | 复用 **Redis Pub/Sub** `consult:push` + STOMP（与在线接诊 **§5.1** 一致）；提问落库即推；AI 回复落库后推，**≤ 1 秒** |
 | **文件** | `POST /common/upload`；消息存 URL |
 | **AI 能力（对话框）** | 管理端/移动端 **直连或经本服务转发** `GET /v1/models`、`POST /v1/chat/completions`（`com.ruoyi.web.kb.controller.KbOpenAiProxyController`，配置 `ruoyi.kb`）；详见 `doc/大模型/大模型网关转发接口说明.md`、前端方案 §4 |
@@ -27,12 +27,12 @@
 | `Controller` | 后台 `.../onlineConsult/ai`；移动端 `.../app/consult/ai` |
 | `Service` | 列表/新建/消息/提问；调用 AI 生成回复；`hide` |
 | `ConsultAiGateway` | 文本/图片调用模型；视频/语音返回固定引导文案 |
-| `Mapper` + XML | 扩展 `BizConsultSessionMapper`（`consult_type=2` 查询） |
+| `Mapper` + XML | 扩展 `BizConsultSessionMapper`（`consult_type=2` 查询）；`BizDiagnosisUserMapper`（**§3.0**） |
 | `support` | 复用 `ConsultSessionRules`、`ConsultThreeMonthsWindow`、`ConsultMessagePreview`、`VetConsultValidation`；新增 `AiConsultValidation` |
 
 **代码包**：`com.ruoyi.web.modules.diagnosis`（与在线接诊、医疗资源同域）  
 **大模型转发包**：`com.ruoyi.web.kb`（与知识库共用 `ruoyi.kb`，见 **§1.2**）  
-**DDL**：已存在 `sql/biz_consult_session.sql`、`sql/biz_consult_message.sql`（在线接诊迭代已建则**无需新表**）
+**DDL**：`sql/biz_consult_session.sql`、`sql/biz_consult_message.sql`（会话/消息，与在线接诊共用）；`sql/biz_diagnosis_user.sql`（AI 诊断使用用户，**§3.0**）
 
 ### 1.2 大模型 OpenAI 兼容转发（`/v1`）
 
@@ -108,7 +108,24 @@ Payload 同在线接诊 **§4.2**（`senderRole`：1 提问人，**3** AI 助手
 
 ## 3. 数据库设计
 
-**不新建表**；在共用表上按 `consult_type=2` 读写。
+会话/消息在共用表上按 `consult_type=2` 读写；另增 **AI 诊断使用用户** 表记录提问人首次/末次使用时间。
+
+### 3.0 表 `biz_diagnosis_user`（AI 诊断使用用户）
+
+| 字段 | 类型 | 说明 |
+| --- | --- | --- |
+| `user_id` | `bigint(20)` | 主键；与提问人 `asker_user_id` 一致 |
+| `first_use_time` | `datetime` | 开始使用 AI 诊断时间 |
+| `last_use_time` | `datetime` | 最后一次使用 AI 诊断时间 |
+
+**写入规则**
+
+| 时机 | 行为 |
+| --- | --- |
+| `POST .../session` 新建会话 | 若 `user_id` 不存在则 **INSERT**，`first_use_time`、`last_use_time` 均为当前时间 |
+| 更新 `biz_consult_session.last_message_time` | 同步 **UPDATE** 对应 `asker_user_id` 的 `last_use_time`（与 `last_message_time` 一致） |
+
+**DDL**：`sql/biz_diagnosis_user.sql`。
 
 ### 3.1 表 `biz_consult_session`（AI 会话写入约定）
 
@@ -140,8 +157,9 @@ Payload 同在线接诊 **§4.2**（`senderRole`：1 提问人，**3** AI 助手
 | 字段 | 说明 |
 | --- | --- |
 | `ai_category` | **varchar(32)**，可为空；仅 **提问人消息**（`sender_role=1`）写入；AI 回复为 `NULL`。纯数字时须为 `1`～`4`（与 `AiConsultConstants` 分类一致），亦可存业务编码字符串 |
+| `cost_time` | **bigint**，可为空；大模型对话耗时（**毫秒**），仅 **AI 消息**（`sender_role=3`）写入；来自 `/v1/chat/completions` 响应头 **`X-COST`** |
 
-**已有库迁移**：`sql/alter_biz_consult_session_real_session_id.sql`、`sql/alter_biz_consult_message_ai_category.sql`。
+**已有库迁移**：`sql/biz_diagnosis_user.sql`（或 `sql/alter_rename_biz_ai_diagnosis_user_to_biz_diagnosis_user.sql`）；`sql/alter_biz_consult_session_real_session_id.sql`、`sql/alter_biz_consult_message_ai_category.sql`、`sql/alter_biz_consult_message_cost_time.sql`。
 
 ### 3.3 AI 列表查询语义
 
@@ -215,7 +233,7 @@ ORDER BY COALESCE(last_message_time, create_time) DESC
 | 4.1 | 历史会话列表 | GET | `/session/list` | `...:list` | Query：`pageNum`、`pageSize`（默认 20）、`contentKeyword`、`searchMode`；`asker_user_id` 服务端注入 |
 | 4.2 | 新增会话 | POST | `/session` | `...:add` | 创建 `consult_type=2` 空会话；`session_title=新会话`；`last_message_time=create_time`（**§3.5 #1**）；返回 `sessionId`、`disclaimer` |
 | 4.3 | 历史消息 | GET | `/session/{sessionId}/messages` | `...:query` | 校验 `consult_type=2` + `asker_user_id` + `vet_visible=1`；`beforeId`、`pageSize`（默认 50） |
-| 4.4 | 提问（触发 AI） | POST | `/session/{sessionId}/message` | `...:send` | Body：`msgType`、`content`、`mediaDuration?`、`aiReplyContent?`、`realSessionId?`、`aiCategory?`；流程见 **§5** |
+| 4.4 | 提问（触发 AI） | POST | `/session/{sessionId}/message` | `...:send` | Body：`msgType`、`content`、`mediaDuration?`、`aiReplyContent?`、`realSessionId?`、`aiCategory?`、`costTime?`（毫秒，来自 `X-COST`）；落库时更新 `last_message_*` 与 **`update_time`**；流程见 **§5** |
 | 4.5 | 隐藏会话 | POST | `/session/{sessionId}/hide` | `...:remove` | 管理端隐藏 AI 诊断会话；`vet_visible=0`；仅本人会话；隐藏后列表/消息/提问不可用 |
 
 ### 4.1 列表 `rows[]` 字段
@@ -245,7 +263,8 @@ ORDER BY COALESCE(last_message_time, create_time) DESC
   "content": "牛不吃草、精神沉郁，请问可能原因？",
   "aiReplyContent": "可能原因包括…",
   "realSessionId": "gateway-session-001",
-  "aiCategory": "2"
+  "aiCategory": "2",
+  "costTime": 1523
 }
 ```
 
@@ -257,6 +276,7 @@ ORDER BY COALESCE(last_message_time, create_time) DESC
 | `aiReplyContent` | string | N | 非空时服务端**仅落库**，不调 `ConsultAiGateway` |
 | `realSessionId` | string | N | 大模型 `session_id`；写入 `biz_consult_session.real_session_id`（别名 `real_session_id`、`session_id`、`llmSessionId`） |
 | `aiCategory` | string | N | 写入提问人消息 `ai_category`（别名 `ai_category`、`category`）；最长 32 |
+| `costTime` | long | N | 写入 **AI 消息** `cost_time`（别名 `cost_time`、`xCost`）；毫秒，来自大模型响应头 `X-COST` |
 
 **提问成功 `data`**
 
@@ -423,3 +443,4 @@ ORDER BY COALESCE(last_message_time, create_time) DESC
 | 1.3 | §1.2：`/v1/**` 须若依 Token，取消匿名访问 |
 | 1.4 | 管理端 **§4.5** `POST /session/{id}/hide` 隐藏 AI 诊断会话；权限 `...:remove` |
 | 1.5 | **§3.1** `biz_consult_session.real_session_id`；**§3.2** `biz_consult_message.ai_category`（varchar32）；**§4.3** 落库 Body/响应字段；**§5** 前端 `aiReplyContent` 落库通道 |
+| 1.6 | **§3.0** `biz_diagnosis_user`：新建会话写入首次用户、更新 `last_message_time` 同步 `last_use_time` |

doc/牧业疫病诊疗服务/AI诊断(兽医、机构)/AI诊断(兽医、机构)测试用例.md

@@ -1,6 +1,6 @@
 # AI 诊断（兽医、机构）— 测试用例
 
-> 依据：`AI诊断(兽医、机构)功能需求.md`（v1.1）、`AI诊断(兽医、机构)技术方案.md`（v1.1）  
+> 依据：`AI诊断(兽医、机构)功能需求.md`（v1.1）、`AI诊断(兽医、机构)技术方案.md`（v1.6）  
 > **后台 Base Path**：`/diseaseTreatments/onlineConsult/ai`；**移动端**：`/app/consult/ai`；鉴权与若依一致。
 
 **通用前置（无特殊说明）**
@@ -8,7 +8,7 @@
 - 兽医账号 **VA**（角色 **100**）、机构账号 **OA**（角色 **102**）；权限 `diseaseTreatment:aiOnlineConsult:list|query|send|add|remove`（**不要求**绑定 `biz_medical_resource`）。  
 - 普通后台账号 **NB**（有 AI 权限、无医疗资源绑定）、另一用户 **VB**（有 AI 会话）。  
 - 牧民 **U1** 已登录移动端。  
-- `biz_consult_session` / `biz_consult_message` 已执行 DDL；宜预置：
+- `biz_consult_session` / `biz_consult_message` / `biz_diagnosis_user` 已执行 DDL（见 `sql/biz_diagnosis_user.sql`）；宜预置：
 
 | 样本 | 说明 | 要点 |
 | --- | --- | --- |
@@ -50,6 +50,9 @@
 | ZCZX-AIZD-UT-023 | 隔离 | 不进接诊列表 | 单元测试 | JUnit5+Mockito | AI-05 | 有 AV0 | 兽医接诊 `list` | 无 AS0 |
 | ZCZX-AIZD-UT-024 | 隔离 | 接诊不进 AI 列表 | 单元测试 | JUnit5+Mockito | AI-05 | 有 AV0 | VA `ai list` | 无 AV0 |
 | ZCZX-AIZD-UT-025 | 约束 | 不校验预约 | 单元测试 | JUnit5+Mockito | §3.4 | 无预约单 | `create`+`send` | 成功；不查 `biz_service_appointment` |
+| ZCZX-AIZD-UT-026 | 诊断用户 | 新建会话插入 | 单元测试 | JUnit5+Mockito | §3.0 | `biz_diagnosis_user` 无 VA | `createAiSession` | `INSERT` 一行；`user_id=VA`；`first_use_time`、`last_use_time` 非空且相等 |
+| ZCZX-AIZD-UT-027 | 诊断用户 | 已存在不重复插 | 单元测试 | JUnit5+Mockito | §3.0 | VA 已在用户表 | `createAiSession` | 不调用 `insertBizDiagnosisUser` |
+| ZCZX-AIZD-UT-028 | 诊断用户 | 发消息更新末次 | 单元测试 | JUnit5+Mockito | §3.0 | 有 AS0 | `sendAiMessage` | `updateLastUseTime(VA, last_message_time)` 至少 1 次 |
 
 ---
 
@@ -100,6 +103,8 @@
 | ZCZX-AIZD-API-041 | 落库 | realSessionId | 接口测试 | Postman | §4.3、§5 | VA；AS0 | `POST .../message` Body 含 `aiReplyContent` + `realSessionId` | `code=200`；`data.realSessionId` 与库 `real_session_id` 一致 |
 | ZCZX-AIZD-API-042 | 落库 | aiCategory | 接口测试 | Postman | §3.2、§4.3 | VA；AS0 | `POST .../message` Body `aiCategory=2` + `aiReplyContent` | `userMessage.aiCategory=2`；`aiMessage.aiCategory` 为空 |
 | ZCZX-AIZD-API-043 | 校验 | aiCategory 无效 | 接口测试 | Postman | §4.4 | VA；AS0 | `aiCategory=99`（纯数字超范围） | 失败；「AI提问分类无效」 |
+| ZCZX-AIZD-API-044 | 诊断用户 | 新建写入用户表 | 接口测试 | Postman/SQL | §3.0 | VA；`biz_diagnosis_user` 无 VA | `POST /session` 后查库 | 新增 1 行；`first_use_time`、`last_use_time`≈会话 `create_time` |
+| ZCZX-AIZD-API-045 | 诊断用户 | 提问更新末次 | 接口测试 | Postman/SQL | §3.0 | VA；AS0；记下提问前 `last_use_time` | `POST .../message` 成功后查库 | `biz_diagnosis_user.last_use_time` 与 `biz_consult_session.last_message_time` 一致（或晚于提问前） |
 
 ---
 
@@ -185,3 +190,4 @@
 | 版本 | 说明 |
 | --- | --- |
 | 1.0 | 初版：单元 25、接口 37、UI 23；覆盖列表/新建/提问/AI 回复/搜索/hide/隔离/机构/移动/网关/免责声明；Playwright+Chrome |
+| 1.1 | 补充 `biz_diagnosis_user`：UT-026～028、API-044～045；前置 DDL 含 `sql/biz_diagnosis_user.sql` |

doc/牧业疫病诊疗服务/在线接诊(兽医)/在线接诊(兽医)技术方案.md

@@ -132,6 +132,7 @@ AI 回复消息由异步任务调用大模型后 `INSERT`（`sender_role=AI`）
 | `content` | `text` | N | 文本内容或媒体 URL |
 | `media_duration` | `int(11)` | N | 语音/视频时长（秒，可选） |
 | `ai_category` | `varchar(32)` | N | AI 提问分类（仅 AI 诊断提问人消息，见 AI 诊断方案 §3.2） |
+| `cost_time` | `bigint(20)` | N | 大模型耗时毫秒（仅 AI 诊断 AI 消息，见 AI 诊断方案 §3.2） |
 | `send_time` | `datetime` | Y | 发送时间 |
 | `create_time` | `datetime` | N | 创建时间 |
 
@@ -190,7 +191,7 @@ ORDER BY last_message_time DESC
 | --- | --- | --- | --- | --- |
 | 4.1 | 接诊会话列表 | GET | `/session/list` | `...:list` | Query：`pageNum`、`pageSize`（默认 20）、`askerName`、`contentKeyword`、**`searchMode`**（**仅「搜索」为 `true`**，见 **§4.6**）；服务端注入 `receiverProviderId`，禁止前端传 |
 | 4.2 | 历史消息 | GET | `/session/{sessionId}/messages` | `...:query` | 校验会话归属与 `vet_visible=1`；未传 `beforeId` 取最新 50 条（**§3.4 #5**）；传 `beforeId` 上拉更早；`pageSize` 默认 50；响应 `rows` **升序** |
-| 4.3 | 发送消息 | POST | `/session/{sessionId}/message` | `...:send` | Body：`msgType`（1～4）、`content`（文本或上传后的 URL）、`mediaDuration`（可选）；落库后 **WebSocket 推送**；更新 `last_message_*` |
+| 4.3 | 发送消息 | POST | `/session/{sessionId}/message` | `...:send` | Body：`msgType`（1～4）、`content`（文本或上传后的 URL）、`mediaDuration`（可选）；落库后 **WebSocket 推送**；更新 `last_message_*` 与 **`update_time`** |
 
 ### 4.1 列表 `rows[]` 字段
 

sql/biz_consult_message.sql

@@ -9,6 +9,7 @@ CREATE TABLE IF NOT EXISTS `biz_consult_message` (
   `content` text COMMENT '文本或媒体URL',
   `media_duration` int(11) DEFAULT NULL COMMENT '音视频时长秒',
   `ai_category` varchar(32) DEFAULT NULL COMMENT 'AI提问分类',
+  `cost_time` bigint(20) DEFAULT NULL COMMENT '大模型对话耗时毫秒',
   `send_time` datetime NOT NULL COMMENT '发送时间',
   `create_time` datetime DEFAULT NULL COMMENT '创建时间',
   PRIMARY KEY (`id`),

sql/biz_diagnosis_user.sql

@@ -0,0 +1,7 @@
+-- AI 诊断使用用户（按提问人 asker_user_id 记录首次/末次使用时间）
+CREATE TABLE IF NOT EXISTS `biz_diagnosis_user` (
+  `user_id` bigint(20) NOT NULL COMMENT '用户ID(提问人asker_user_id)',
+  `first_use_time` datetime NOT NULL COMMENT '开始使用AI诊断时间',
+  `last_use_time` datetime NOT NULL COMMENT '最后一次使用AI诊断时间',
+  PRIMARY KEY (`user_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AI诊断使用用户';