增加与ai大模型对话

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

@@ -0,0 +1,60 @@
+package com.huimv.employment.controller.mp;
+
+import com.huimv.employment.common.web.R;
+import com.huimv.employment.security.LoginUser;
+import com.huimv.employment.security.LoginUserHolder;
+import com.huimv.employment.service.conversation.ConversationService;
+import com.huimv.employment.service.conversation.dto.ConversationSummaryResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.security.SecurityRequirement;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * 小程序 AI 对话会话接口。
+ * <p>
+ * 路径 {@code /api/v1/mp/conversations}，需 JWT 鉴权。
+ * 从 JWT 解析 {@code userId}，仅返回当前用户自己的会话，不支持跨用户查询。
+ * </p>
+ * <p>
+ * 典型用法：对话中心侧边栏加载历史会话列表；点击某条后带 {@code conversationNo}（即 AI {@code session_id}）
+ * 继续多轮对话。
+ * </p>
+ */
+@RestController
+@RequestMapping("/api/v1/mp/conversations")
+@Tag(name = "AI 会话", description = "对话会话列表，需 JWT 鉴权")
+@SecurityRequirement(name = "Authorization")
+public class ConversationController {
+
+    private final ConversationService conversationService;
+
+    public ConversationController(ConversationService conversationService) {
+        this.conversationService = conversationService;
+    }
+
+    /**
+     * 查询当前登录用户的全部 AI 对话会话。
+     *
+     * @param status       可选，{@code active} / {@code archived}
+     * @param chatType     可选，如 {@code employment}
+     * @param enterpriseId 可选，多企业时按企业筛选
+     */
+    @GetMapping
+    @Operation(summary = "查询当前用户的 AI 对话会话列表",
+            description = "按 last_message_at 倒序返回。可选按 status、chatType、enterpriseId 筛选。"
+                    + "数据来源 fe_conversation，需先有会话落库记录。")
+    public R<List<ConversationSummaryResponse>> list(
+            @RequestParam(required = false) String status,
+            @RequestParam(required = false) String chatType,
+            @RequestParam(required = false) Long enterpriseId) {
+        LoginUser loginUser = LoginUserHolder.require();
+        return R.ok(conversationService.listByUser(
+                loginUser.getUserId(), status, chatType, enterpriseId));
+    }
+}

huimv-employment/fe-dao/src/main/java/com/huimv/employment/dao/entity/FeConversation.java

@@ -0,0 +1,138 @@
+package com.huimv.employment.dao.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.time.LocalDateTime;
+
+/**
+ * AI 对话会话主表 {@code fe_conversation} 实体。
+ * <p>
+ * 企业主与智能体交互的容器；{@code conversation_no} 与上游 AI 网关 {@code session_id} 对应，
+ * 用于多轮对话上下文关联。消息明细见 {@code fe_conversation_message}。
+ * </p>
+ */
+@TableName("fe_conversation")
+public class FeConversation {
+
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /** 对外业务编号，全局唯一，与 AI 接口 session_id 一致，最长 32 字符 */
+    private String conversationNo;
+
+    /** 所属企业，创建会话时从当前用户企业绑定关系写入 */
+    private Long enterpriseId;
+
+    /** 发起对话的用户，与 JWT 中 userId 对应 */
+    private Long userId;
+
+    /** 侧边栏展示标题，可由首条消息摘要或 AI 生成 */
+    private String title;
+
+    /** employment / knowledge / order / cost / attendance / emergency */
+    private String chatType;
+
+    /** active=进行中；archived=已归档（只读） */
+    private String status;
+
+    /** 最后一条消息时间，列表排序依据 */
+    private LocalDateTime lastMessageAt;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    @TableLogic
+    private Integer delFlag;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getConversationNo() {
+        return conversationNo;
+    }
+
+    public void setConversationNo(String conversationNo) {
+        this.conversationNo = conversationNo;
+    }
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getChatType() {
+        return chatType;
+    }
+
+    public void setChatType(String chatType) {
+        this.chatType = chatType;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public LocalDateTime getLastMessageAt() {
+        return lastMessageAt;
+    }
+
+    public void setLastMessageAt(LocalDateTime lastMessageAt) {
+        this.lastMessageAt = lastMessageAt;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+
+    public LocalDateTime getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(LocalDateTime updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    public Integer getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(Integer delFlag) {
+        this.delFlag = delFlag;
+    }
+}

huimv-employment/fe-dao/src/main/java/com/huimv/employment/dao/mapper/FeConversationMapper.java

@@ -0,0 +1,10 @@
+package com.huimv.employment.dao.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.employment.dao.entity.FeConversation;
+import org.apache.ibatis.annotations.Mapper;
+
+/** {@code fe_conversation} MyBatis-Plus Mapper。 */
+@Mapper
+public interface FeConversationMapper extends BaseMapper<FeConversation> {
+}

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

@@ -0,0 +1,154 @@
+package com.huimv.employment.service.conversation;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.huimv.employment.dao.entity.FeConversation;
+import com.huimv.employment.dao.entity.FeEnterprise;
+import com.huimv.employment.dao.mapper.FeConversationMapper;
+import com.huimv.employment.service.conversation.dto.ConversationSummaryResponse;
+import com.huimv.employment.service.enterprise.EnterpriseService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.dao.DuplicateKeyException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.StringUtils;
+
+import java.time.LocalDateTime;
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * AI 对话会话业务层。
+ * <p>
+ * 一期提供按登录用户查询会话列表；{@link #touchFromChat(Long, String)} 供后续在对话入口落库时调用
+ *（当前未接入 {@code AiProxyController}）。
+ * </p>
+ */
+@Service
+public class ConversationService {
+
+    private static final Logger log = LoggerFactory.getLogger(ConversationService.class);
+
+    private static final String STATUS_ACTIVE = "active";
+    private static final String CHAT_TYPE_EMPLOYMENT = "employment";
+
+    /** 与表字段 {@code conversation_no} VARCHAR(32) 一致 */
+    private static final int CONVERSATION_NO_MAX_LEN = 32;
+
+    private final FeConversationMapper feConversationMapper;
+    private final EnterpriseService enterpriseService;
+
+    public ConversationService(FeConversationMapper feConversationMapper,
+                               EnterpriseService enterpriseService) {
+        this.feConversationMapper = feConversationMapper;
+        this.enterpriseService = enterpriseService;
+    }
+
+    /**
+     * 查询指定用户的 AI 对话会话列表。
+     *
+     * @param userId       当前登录用户 ID（来自 JWT）
+     * @param status       可选，{@code active} / {@code archived}
+     * @param chatType     可选，专题类型
+     * @param enterpriseId 可选，按企业筛选（多企业场景）
+     * @return 按 {@code last_message_at}、{@code create_time} 倒序
+     */
+    public List<ConversationSummaryResponse> listByUser(Long userId, String status, String chatType, Long enterpriseId) {
+        if (userId == null) {
+            return Collections.emptyList();
+        }
+        LambdaQueryWrapper<FeConversation> wrapper = new LambdaQueryWrapper<FeConversation>()
+                .eq(FeConversation::getUserId, userId)
+                .eq(StringUtils.hasText(status), FeConversation::getStatus, status)
+                .eq(StringUtils.hasText(chatType), FeConversation::getChatType, chatType)
+                .eq(enterpriseId != null, FeConversation::getEnterpriseId, enterpriseId)
+                .orderByDesc(FeConversation::getLastMessageAt)
+                .orderByDesc(FeConversation::getCreateTime);
+        return feConversationMapper.selectList(wrapper).stream()
+                .map(this::toSummary)
+                .collect(Collectors.toList());
+    }
+
+    /**
+     * 用户发起 AI 对话时刷新会话记录。
+     * <p>
+     * 已存在则更新 {@code last_message_at}；不存在则新建。新建要求用户已绑定企业（{@code enterprise_id} 非空约束）。
+     * {@code sessionId} 写入 {@code conversation_no}，与上游 {@code /api/console/chat} 的 {@code session_id} 保持一致。
+     * </p>
+     *
+     * @param userId    当前用户 ID
+     * @param sessionId 客户端或 AI 网关会话 ID
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void touchFromChat(Long userId, String sessionId) {
+        if (userId == null || !StringUtils.hasText(sessionId)) {
+            return;
+        }
+        String conversationNo = normalizeConversationNo(sessionId.trim());
+        FeConversation existing = feConversationMapper.selectOne(new LambdaQueryWrapper<FeConversation>()
+                .eq(FeConversation::getConversationNo, conversationNo)
+                .eq(FeConversation::getUserId, userId)
+                .last("LIMIT 1"));
+        LocalDateTime now = LocalDateTime.now();
+        if (existing != null) {
+            FeConversation update = new FeConversation();
+            update.setId(existing.getId());
+            update.setLastMessageAt(now);
+            update.setUpdateTime(now);
+            feConversationMapper.updateById(update);
+            return;
+        }
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            log.debug("用户 {} 未绑定企业，跳过会话落库 sessionId={}", userId, conversationNo);
+            return;
+        }
+        FeConversation created = new FeConversation();
+        created.setConversationNo(conversationNo);
+        created.setEnterpriseId(enterprise.getId());
+        created.setUserId(userId);
+        created.setChatType(CHAT_TYPE_EMPLOYMENT);
+        created.setStatus(STATUS_ACTIVE);
+        created.setLastMessageAt(now);
+        created.setCreateTime(now);
+        created.setUpdateTime(now);
+        try {
+            feConversationMapper.insert(created);
+        } catch (DuplicateKeyException ex) {
+            // conversation_no 全局唯一，并发创建时回退为更新
+            FeConversation retry = feConversationMapper.selectOne(new LambdaQueryWrapper<FeConversation>()
+                    .eq(FeConversation::getConversationNo, conversationNo)
+                    .eq(FeConversation::getUserId, userId)
+                    .last("LIMIT 1"));
+            if (retry != null) {
+                FeConversation update = new FeConversation();
+                update.setId(retry.getId());
+                update.setLastMessageAt(now);
+                update.setUpdateTime(now);
+                feConversationMapper.updateById(update);
+            }
+        }
+    }
+
+    private ConversationSummaryResponse toSummary(FeConversation entity) {
+        ConversationSummaryResponse response = new ConversationSummaryResponse();
+        response.setId(entity.getId());
+        response.setConversationNo(entity.getConversationNo());
+        response.setEnterpriseId(entity.getEnterpriseId());
+        response.setTitle(entity.getTitle());
+        response.setChatType(entity.getChatType());
+        response.setStatus(entity.getStatus());
+        response.setLastMessageAt(entity.getLastMessageAt());
+        response.setCreateTime(entity.getCreateTime());
+        return response;
+    }
+
+    /** 截断超长 session_id，满足 {@code uk_fe_conversation_no} 长度限制 */
+    private static String normalizeConversationNo(String sessionId) {
+        if (sessionId.length() <= CONVERSATION_NO_MAX_LEN) {
+            return sessionId;
+        }
+        return sessionId.substring(0, CONVERSATION_NO_MAX_LEN);
+    }
+}

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

@@ -0,0 +1,101 @@
+package com.huimv.employment.service.conversation.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.time.LocalDateTime;
+
+/**
+ * AI 对话会话列表项，供小程序侧边栏展示。
+ * <p>不含消息正文；详情消息见后续 {@code GET /conversations/{id}/messages}（规划中）。</p>
+ */
+@Schema(description = "AI 对话会话摘要")
+public class ConversationSummaryResponse {
+
+    @Schema(description = "会话主键 ID", example = "1")
+    private Long id;
+
+    @Schema(description = "会话编号（与 AI 接口 session_id 一致）", example = "a1b2c3d4e5f6")
+    private String conversationNo;
+
+    @Schema(description = "所属企业 ID", example = "10")
+    private Long enterpriseId;
+
+    @Schema(description = "会话标题", example = "浦东仓库暑期用工")
+    private String title;
+
+    @Schema(description = "对话类型：employment/knowledge/order/cost/attendance/emergency", example = "employment")
+    private String chatType;
+
+    @Schema(description = "状态：active/archived", example = "active")
+    private String status;
+
+    @Schema(description = "最后一条消息时间，列表排序依据")
+    private LocalDateTime lastMessageAt;
+
+    @Schema(description = "会话创建时间")
+    private LocalDateTime createTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getConversationNo() {
+        return conversationNo;
+    }
+
+    public void setConversationNo(String conversationNo) {
+        this.conversationNo = conversationNo;
+    }
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getChatType() {
+        return chatType;
+    }
+
+    public void setChatType(String chatType) {
+        this.chatType = chatType;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public LocalDateTime getLastMessageAt() {
+        return lastMessageAt;
+    }
+
+    public void setLastMessageAt(LocalDateTime lastMessageAt) {
+        this.lastMessageAt = lastMessageAt;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+}