增加与ai大模型对话

huimv-employment/fe-api/src/main/java/com/huimv/employment/config/MybatisConfig.java

@@ -1,15 +1,25 @@
 package com.huimv.employment.config;
 
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
 import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
 
 /**
- * MyBatis-Plus Mapper 扫描配置。
- * <p>扫描 fe-dao 模块下所有 Mapper 接口，MyBatis-Plus 全局配置见 application-dev.yml。</p>
+ * MyBatis-Plus Mapper 扫描与分页插件配置。
  */
 @Configuration
 @Profile("!test")
 @MapperScan("com.huimv.employment.dao.mapper")
 public class MybatisConfig {
+
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
+        return interceptor;
+    }
 }

huimv-employment/fe-api/src/main/java/com/huimv/employment/controller/mp/ConversationController.java

@@ -7,9 +7,11 @@ import com.huimv.employment.integration.kb.SseStreamSupport;
 import com.huimv.employment.security.LoginUser;
 import com.huimv.employment.security.LoginUserHolder;
 import com.huimv.employment.service.conversation.ConversationChatService;
+import com.huimv.employment.service.conversation.ConversationMessageService;
 import com.huimv.employment.service.conversation.ConversationService;
 import com.huimv.employment.service.conversation.dto.ConversationChatRequest;
 import com.huimv.employment.service.conversation.dto.ConversationCreateRequest;
+import com.huimv.employment.service.conversation.dto.ConversationMessagePageResponse;
 import com.huimv.employment.service.conversation.dto.ConversationSummaryResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
@@ -51,11 +53,14 @@ public class ConversationController {
 
     private final ConversationService conversationService;
     private final ConversationChatService conversationChatService;
+    private final ConversationMessageService conversationMessageService;
 
     public ConversationController(ConversationService conversationService,
-                                  ConversationChatService conversationChatService) {
+                                  ConversationChatService conversationChatService,
+                                  ConversationMessageService conversationMessageService) {
         this.conversationService = conversationService;
         this.conversationChatService = conversationChatService;
+        this.conversationMessageService = conversationMessageService;
     }
 
     /**
@@ -86,6 +91,21 @@ public class ConversationController {
         return R.ok(conversationService.create(loginUser.getUserId(), request));
     }
 
+    /**
+     * 查询指定会话下的消息列表（分页，时间正序）。
+     */
+    @GetMapping("/{id}/messages")
+    @Operation(summary = "查询会话消息列表",
+            description = "按 create_time 正序分页返回。仅可查询当前用户自己的会话；已归档会话仍可查看历史。")
+    public R<ConversationMessagePageResponse> listMessages(
+            @PathVariable("id") Long conversationId,
+            @RequestParam(required = false, defaultValue = "1") Integer page,
+            @RequestParam(required = false, defaultValue = "50") Integer size) {
+        LoginUser loginUser = LoginUserHolder.require();
+        return R.ok(conversationMessageService.listByConversation(
+                loginUser.getUserId(), conversationId, page, size));
+    }
+
     /**
      * 在已有会话内发起 AI 对话（SSE 流式，流结束后落库）。
      */

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/conversation/ConversationMessageService.java

@@ -1,15 +1,20 @@
 package com.huimv.employment.service.conversation;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huimv.employment.dao.entity.FeConversationMessage;
 import com.huimv.employment.dao.mapper.FeConversationMessageMapper;
+import com.huimv.employment.service.conversation.dto.ConversationMessagePageResponse;
+import com.huimv.employment.service.conversation.dto.ConversationMessageResponse;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
 
 import java.time.LocalDateTime;
+import java.util.stream.Collectors;
 
 /**
- * AI 对话消息落库：user 消息在流式开始前写入，assistant 消息在流式结束后写入。
+ * AI 对话消息落库与查询。
  */
 @Service
 public class ConversationMessageService {
@@ -18,6 +23,11 @@ public class ConversationMessageService {
     private static final String ROLE_ASSISTANT = "assistant";
     private static final String CONTENT_TYPE_TEXT = "text";
 
+    private static final int MIN_PAGE = 1;
+    private static final int MIN_SIZE = 1;
+    private static final int MAX_SIZE = 200;
+    private static final int DEFAULT_SIZE = 50;
+
     private final ConversationService conversationService;
     private final FeConversationMessageMapper feConversationMessageMapper;
 
@@ -27,6 +37,30 @@ public class ConversationMessageService {
         this.feConversationMessageMapper = feConversationMessageMapper;
     }
 
+    /**
+     * 分页查询指定会话下的消息，按时间正序。
+     */
+    public ConversationMessagePageResponse listByConversation(Long userId, Long conversationId, Integer page, Integer size) {
+        conversationService.requireOwned(userId, conversationId);
+        int resolvedPage = page == null || page < MIN_PAGE ? MIN_PAGE : page;
+        int resolvedSize = size == null || size < MIN_SIZE ? DEFAULT_SIZE : Math.min(size, MAX_SIZE);
+
+        Page<FeConversationMessage> pageParam = new Page<>(resolvedPage, resolvedSize);
+        LambdaQueryWrapper<FeConversationMessage> wrapper = new LambdaQueryWrapper<FeConversationMessage>()
+                .eq(FeConversationMessage::getConversationId, conversationId)
+                .orderByAsc(FeConversationMessage::getCreateTime)
+                .orderByAsc(FeConversationMessage::getId);
+        Page<FeConversationMessage> result = feConversationMessageMapper.selectPage(pageParam, wrapper);
+
+        ConversationMessagePageResponse response = new ConversationMessagePageResponse();
+        response.setItems(result.getRecords().stream().map(this::toResponse).collect(Collectors.toList()));
+        response.setTotal(result.getTotal());
+        response.setPage(resolvedPage);
+        response.setSize(resolvedSize);
+        response.setHasMore((long) resolvedPage * resolvedSize < result.getTotal());
+        return response;
+    }
+
     @Transactional(rollbackFor = Exception.class)
     public void saveUserMessage(Long conversationId, String userText) {
         if (conversationId == null || !StringUtils.hasText(userText)) {
@@ -54,4 +88,16 @@ public class ConversationMessageService {
         message.setCreateTime(LocalDateTime.now());
         feConversationMessageMapper.insert(message);
     }
+
+    private ConversationMessageResponse toResponse(FeConversationMessage entity) {
+        ConversationMessageResponse response = new ConversationMessageResponse();
+        response.setId(entity.getId());
+        response.setRole(entity.getRole());
+        response.setContent(entity.getContent());
+        response.setContentType(entity.getContentType());
+        response.setCardPayload(entity.getCardPayload());
+        response.setNextAction(entity.getNextAction());
+        response.setCreateTime(entity.getCreateTime());
+        return response;
+    }
 }

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/conversation/ConversationService.java

@@ -116,9 +116,9 @@ public class ConversationService {
     }
 
     /**
-     * 校验会话归属与状态，供落库聊天接口使用。
+     * 校验会话归属，供消息列表等只读接口使用（含已归档会话）。
      */
-    public FeConversation requireOwnedActive(Long userId, Long conversationId) {
+    public FeConversation requireOwned(Long userId, Long conversationId) {
         if (userId == null || conversationId == null) {
             throw new BizException(ErrorCode.NOT_FOUND, "会话不存在");
         }
@@ -126,6 +126,14 @@ public class ConversationService {
         if (conversation == null || !userId.equals(conversation.getUserId())) {
             throw new BizException(ErrorCode.NOT_FOUND, "会话不存在");
         }
+        return conversation;
+    }
+
+    /**
+     * 校验会话归属与状态，供落库聊天接口使用。
+     */
+    public FeConversation requireOwnedActive(Long userId, Long conversationId) {
+        FeConversation conversation = requireOwned(userId, conversationId);
         if (!STATUS_ACTIVE.equals(conversation.getStatus())) {
             throw new BizException(ErrorCode.BAD_REQUEST, "会话已归档，无法继续对话");
         }

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/conversation/dto/ConversationMessagePageResponse.java

@@ -0,0 +1,67 @@
+package com.huimv.employment.service.conversation.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.util.List;
+
+/**
+ * 会话消息分页结果。
+ */
+@Schema(description = "会话消息分页结果")
+public class ConversationMessagePageResponse {
+
+    @Schema(description = "消息列表，按 create_time 正序")
+    private List<ConversationMessageResponse> items;
+
+    @Schema(description = "总条数", example = "128")
+    private long total;
+
+    @Schema(description = "当前页码，从 1 开始", example = "1")
+    private int page;
+
+    @Schema(description = "每页条数", example = "50")
+    private int size;
+
+    @Schema(description = "是否还有下一页", example = "true")
+    private boolean hasMore;
+
+    public List<ConversationMessageResponse> getItems() {
+        return items;
+    }
+
+    public void setItems(List<ConversationMessageResponse> items) {
+        this.items = items;
+    }
+
+    public long getTotal() {
+        return total;
+    }
+
+    public void setTotal(long total) {
+        this.total = total;
+    }
+
+    public int getPage() {
+        return page;
+    }
+
+    public void setPage(int page) {
+        this.page = page;
+    }
+
+    public int getSize() {
+        return size;
+    }
+
+    public void setSize(int size) {
+        this.size = size;
+    }
+
+    public boolean isHasMore() {
+        return hasMore;
+    }
+
+    public void setHasMore(boolean hasMore) {
+        this.hasMore = hasMore;
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/conversation/dto/ConversationMessageResponse.java

@@ -0,0 +1,89 @@
+package com.huimv.employment.service.conversation.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.time.LocalDateTime;
+
+/**
+ * 会话内单条消息，供聊天气泡展示。
+ */
+@Schema(description = "AI 对话消息")
+public class ConversationMessageResponse {
+
+    @Schema(description = "消息 ID", example = "1001")
+    private Long id;
+
+    @Schema(description = "角色：user / assistant / system", example = "user")
+    private String role;
+
+    @Schema(description = "消息正文", example = "帮我招 10 个仓库临时工")
+    private String content;
+
+    @Schema(description = "内容类型：text / card_draft / card_cost / card_order", example = "text")
+    private String contentType;
+
+    @Schema(description = "卡片结构化数据 JSON，仅卡片类型时有值")
+    private String cardPayload;
+
+    @Schema(description = "建议前端下一步动作编码")
+    private String nextAction;
+
+    @Schema(description = "消息时间")
+    private LocalDateTime createTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getRole() {
+        return role;
+    }
+
+    public void setRole(String role) {
+        this.role = role;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public String getContentType() {
+        return contentType;
+    }
+
+    public void setContentType(String contentType) {
+        this.contentType = contentType;
+    }
+
+    public String getCardPayload() {
+        return cardPayload;
+    }
+
+    public void setCardPayload(String cardPayload) {
+        this.cardPayload = cardPayload;
+    }
+
+    public String getNextAction() {
+        return nextAction;
+    }
+
+    public void setNextAction(String nextAction) {
+        this.nextAction = nextAction;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/conversation/dto/ConversationSummaryResponse.java

@@ -6,7 +6,7 @@ import java.time.LocalDateTime;
 
 /**
  * AI 对话会话列表项，供小程序侧边栏展示。
- * <p>不含消息正文；详情消息见后续 {@code GET /conversations/{id}/messages}（规划中）。</p>
+ * <p>不含消息正文；详情见 {@code GET /conversations/{id}/messages}。</p>
  */
 @Schema(description = "AI 对话会话摘要")
 public class ConversationSummaryResponse {