增加与ai大模型对话

doc/灵活用工-mysql.sql

@@ -269,6 +269,7 @@ CREATE TABLE `fe_employment_draft` (
   `id` bigint NOT NULL AUTO_INCREMENT COMMENT '表主键，自增。AI 子模块生成草稿时创建。非空；被 fe_draft_field、fe_draft_cost_snapshot 引用。',
   `draft_no` VARCHAR(32)     NOT NULL COMMENT '草稿业务编号，对外 API 使用。生成时由编号器写入。示例：draft_001。非空；唯一索引 uk_fe_draft_no。',
   `enterprise_id` BIGINT          NOT NULL COMMENT '所属企业，外键 REFERENCES fe_enterprise(id)。从对话上下文写入。非空；索引 idx_fe_draft_ent。',
+  `user_id` BIGINT          NOT NULL COMMENT '发起草稿的企业主用户，外键 REFERENCES fe_user(id)。创建时从 fe_conversation.user_id 写入。非空；索引 idx_fe_draft_user。',
   `conversation_id` BIGINT COMMENT '来源 AI 对话，外键 REFERENCES fe_conversation(id)。对话触发生成时写入；后台批量生成可为空。可空。',
   `scenario` VARCHAR(50)     NOT NULL COMMENT '用工业务场景类型。AI 识别用户意图时写入。枚举：existing_worker_regularization=已有非正规临时工规范转正；new_demand=全新用工需求。非空。',
   `title` VARCHAR(200) COMMENT '草稿标题，列表与卡片展示。AI 摘要或用户输入。示例：浦东仓库暑期搬运。可空。',
@@ -301,7 +302,9 @@ CREATE TABLE `fe_employment_draft` (
   PRIMARY KEY (`id`),
   UNIQUE KEY `uk_fe_draft_no` (`draft_no`),
   KEY `idx_fe_draft_ent` (`enterprise_id`, `status`, `create_time`),
+  KEY `idx_fe_draft_user` (`user_id`, `status`, `create_time`),
   CONSTRAINT `fk_fe_employment_draft_enterprise_id` FOREIGN KEY (`enterprise_id`) REFERENCES `fe_enterprise` (`id`),
+  CONSTRAINT `fk_fe_employment_draft_user_id` FOREIGN KEY (`user_id`) REFERENCES `fe_user` (`id`),
   CONSTRAINT `fk_fe_employment_draft_conversation_id` FOREIGN KEY (`conversation_id`) REFERENCES `fe_conversation` (`id`),
   CONSTRAINT `fk_fe_employment_draft_selected_plan_id` FOREIGN KEY (`selected_plan_id`) REFERENCES `fe_service_plan` (`id`),
   CONSTRAINT `fk_fe_employment_draft_confirmed_by` FOREIGN KEY (`confirmed_by`) REFERENCES `fe_user` (`id`)
@@ -366,6 +369,7 @@ CREATE TABLE `fe_employment_order` (
   `id` bigint NOT NULL AUTO_INCREMENT COMMENT '表主键，自增。草稿确认接口成功时创建。非空。',
   `order_no` VARCHAR(32)     NOT NULL COMMENT '订单业务编号，企业主可见。示例：2024-001、ORD20260707001。非空；唯一索引 uk_fe_order_no。',
   `enterprise_id` BIGINT          NOT NULL COMMENT '所属企业，外键 REFERENCES fe_enterprise(id)。非空；索引 idx_fe_order_ent。',
+  `user_id` BIGINT          NOT NULL COMMENT '下单企业主用户，外键 REFERENCES fe_user(id)。确认草稿时从 fe_employment_draft.user_id 复制。非空；索引 idx_fe_order_user。',
   `draft_id` BIGINT COMMENT '来源草稿，外键 REFERENCES fe_employment_draft(id)。确认时写入，追溯对话与方案选择。可空（极少数后台直创订单）。',
   `selected_plan_id` BIGINT COMMENT '确认选用的用工方案，外键 REFERENCES fe_service_plan(id)。草稿确认时从 draft.selected_plan_id 复制。可空；应尽早补齐。',
   `title` VARCHAR(200)    NOT NULL COMMENT '订单标题，通常继承草稿标题。非空。',
@@ -387,7 +391,9 @@ CREATE TABLE `fe_employment_order` (
   PRIMARY KEY (`id`),
   UNIQUE KEY `uk_fe_order_no` (`order_no`),
   KEY `idx_fe_order_ent` (`enterprise_id`, `order_status`, `create_time`),
+  KEY `idx_fe_order_user` (`user_id`, `order_status`, `create_time`),
   CONSTRAINT `fk_fe_employment_order_enterprise_id` FOREIGN KEY (`enterprise_id`) REFERENCES `fe_enterprise` (`id`),
+  CONSTRAINT `fk_fe_employment_order_user_id` FOREIGN KEY (`user_id`) REFERENCES `fe_user` (`id`),
   CONSTRAINT `fk_fe_employment_order_draft_id` FOREIGN KEY (`draft_id`) REFERENCES `fe_employment_draft` (`id`),
   CONSTRAINT `fk_fe_employment_order_selected_plan_id` FOREIGN KEY (`selected_plan_id`) REFERENCES `fe_service_plan` (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用工订单主表，草稿确认并选定方案后生成，承载办理全流程业务状态与登记进度冗余统计。current_step_code 驱动合规状态机；关联 fe_enterprise、fe_employment_draft、fe_service_plan，一对多关联登记批次与结算单。';

doc/灵活用工.sql

@@ -292,6 +292,7 @@ CREATE TABLE fe_employment_draft (
     id                  BIGSERIAL       PRIMARY KEY,
     draft_no            VARCHAR(32)     NOT NULL,                   -- draft_001
     enterprise_id       BIGINT          NOT NULL REFERENCES fe_enterprise(id),
+    user_id             BIGINT          NOT NULL REFERENCES fe_user(id),
     conversation_id     BIGINT          REFERENCES fe_conversation(id),
     scenario            VARCHAR(50)     NOT NULL,                   -- existing_worker_regularization / new_demand
     title               VARCHAR(200),                               -- 浦东仓库搬运
@@ -386,6 +387,7 @@ CREATE TABLE fe_employment_order (
     id                  BIGSERIAL       PRIMARY KEY,
     order_no            VARCHAR(32)     NOT NULL,                   -- 2024-001
     enterprise_id       BIGINT          NOT NULL REFERENCES fe_enterprise(id),
+    user_id             BIGINT          NOT NULL REFERENCES fe_user(id),
     draft_id            BIGINT          REFERENCES fe_employment_draft(id),
     selected_plan_id    BIGINT          REFERENCES fe_service_plan(id),
     title               VARCHAR(200)    NOT NULL,

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

@@ -7,12 +7,14 @@ 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.ConversationDraftQueryService;
 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 com.huimv.employment.service.draft.dto.DraftDetailResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -54,13 +56,16 @@ public class ConversationController {
     private final ConversationService conversationService;
     private final ConversationChatService conversationChatService;
     private final ConversationMessageService conversationMessageService;
+    private final ConversationDraftQueryService conversationDraftQueryService;
 
     public ConversationController(ConversationService conversationService,
                                   ConversationChatService conversationChatService,
-                                  ConversationMessageService conversationMessageService) {
+                                  ConversationMessageService conversationMessageService,
+                                  ConversationDraftQueryService conversationDraftQueryService) {
         this.conversationService = conversationService;
         this.conversationChatService = conversationChatService;
         this.conversationMessageService = conversationMessageService;
+        this.conversationDraftQueryService = conversationDraftQueryService;
     }
 
     /**
@@ -106,6 +111,19 @@ public class ConversationController {
                 loginUser.getUserId(), conversationId, page, size));
     }
 
+    /**
+     * 查询当前会话关联的最新草稿（兜底：消息未带 draft_id 时使用）。
+     */
+    @GetMapping("/{id}/draft")
+    @Operation(summary = "查询会话当前草稿",
+            description = "返回该会话下最新一条 fe_employment_draft 详情（含 fields）。"
+                    + "Agent 回复未携带 card_draft 时，前端可在对话结束后调用此接口拉取草稿。")
+    public R<DraftDetailResponse> getConversationDraft(@PathVariable("id") Long conversationId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(conversationDraftQueryService.getDraftByConversation(
+                loginUser.getUserId(), conversationId));
+    }
+
     /**
      * 在已有会话内发起 AI 对话（SSE 流式，流结束后落库）。
      */
@@ -113,7 +131,9 @@ public class ConversationController {
     @Operation(summary = "会话内 AI 对话（SSE 流式 + 落库）",
             description = "需先 POST /conversations 创建会话。请求体仅需 message 字段；"
                     + "服务端组装上游 console/chat 请求，流式开始前写入 user 消息，"
-                    + "流式结束后写入 assistant 消息。可选请求头 X-Agent-Id。")
+                    + "流式结束后解析 assistant 卡片（content_type/card_payload/next_action）并落库；"
+                    + "若 Agent 未返回卡片且会话草稿 status=ready，服务端自动补全 card_draft。"
+                    + "可选请求头 X-Agent-Id。")
     public void chat(@PathVariable("id") Long conversationId,
                      @Validated @RequestBody ConversationChatRequest request,
                      HttpServletResponse response,

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

@@ -0,0 +1,151 @@
+package com.huimv.employment.service.conversation;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.huimv.employment.service.conversation.dto.ParsedAssistantReply;
+import org.springframework.util.StringUtils;
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 从 Agent assistant 纯文本中解析结构化卡片（支持 {@code ```fe-card```}/{@code ```json```} 代码块或整段 JSON）。
+ */
+public final class AssistantReplyParser {
+
+    private static final Pattern FENCED_BLOCK = Pattern.compile(
+            "```(?:fe-card|json)?\\s*([\\s\\S]*?)```",
+            Pattern.CASE_INSENSITIVE);
+
+    private AssistantReplyParser() {
+    }
+
+    public static ParsedAssistantReply parse(String rawText, ObjectMapper objectMapper) {
+        if (!StringUtils.hasText(rawText)) {
+            return ParsedAssistantReply.textOnly("");
+        }
+        String trimmed = rawText.trim();
+        Matcher matcher = FENCED_BLOCK.matcher(trimmed);
+        while (matcher.find()) {
+            ParsedAssistantReply fromBlock = tryParseJsonBlock(
+                    trimmed.substring(0, matcher.start()).trim(),
+                    matcher.group(1).trim(),
+                    objectMapper);
+            if (fromBlock != null) {
+                return fromBlock;
+            }
+        }
+        if (trimmed.startsWith("{") && trimmed.endsWith("}")) {
+            ParsedAssistantReply whole = tryParseJsonBlock("", trimmed, objectMapper);
+            if (whole != null) {
+                return whole;
+            }
+        }
+        return ParsedAssistantReply.textOnly(trimmed);
+    }
+
+    private static ParsedAssistantReply tryParseJsonBlock(String prefixText,
+                                                          String jsonPayload,
+                                                          ObjectMapper objectMapper) {
+        if (!StringUtils.hasText(jsonPayload)) {
+            return null;
+        }
+        try {
+            JsonNode root = objectMapper.readTree(jsonPayload);
+            if (!looksLikeCard(root)) {
+                return null;
+            }
+            String contentType = resolveContentType(root);
+            if (!StringUtils.hasText(contentType)
+                    || MessageCardConstants.CONTENT_TYPE_TEXT.equals(contentType)) {
+                return null;
+            }
+            String nextAction = textOrNull(root, "next_action");
+            String cardPayload = resolveCardPayloadJson(root, objectMapper);
+            Long relatedDraftId = resolveRelatedDraftId(root);
+            String displayText = resolveDisplayText(prefixText, root);
+            return new ParsedAssistantReply(displayText, contentType, cardPayload, nextAction, relatedDraftId);
+        } catch (Exception ignored) {
+            return null;
+        }
+    }
+
+    private static boolean looksLikeCard(JsonNode root) {
+        if (root == null || !root.isObject()) {
+            return false;
+        }
+        return root.has("content_type")
+                || root.has("card_type")
+                || root.has("card_payload")
+                || root.has("next_action");
+    }
+
+    private static String resolveContentType(JsonNode root) {
+        String contentType = textOrNull(root, "content_type");
+        if (StringUtils.hasText(contentType)) {
+            return contentType.trim();
+        }
+        String cardType = textOrNull(root, "card_type");
+        if (!StringUtils.hasText(cardType)) {
+            return MessageCardConstants.CONTENT_TYPE_TEXT;
+        }
+        switch (cardType.trim()) {
+            case "cost_calculation_result":
+                return MessageCardConstants.CONTENT_TYPE_CARD_COST;
+            case "employment_draft":
+            case "draft_card":
+                return MessageCardConstants.CONTENT_TYPE_CARD_DRAFT;
+            case "process_action":
+            case "order_progress":
+                return MessageCardConstants.CONTENT_TYPE_CARD_ORDER;
+            default:
+                return MessageCardConstants.CONTENT_TYPE_TEXT;
+        }
+    }
+
+    private static String resolveCardPayloadJson(JsonNode root, ObjectMapper objectMapper) throws Exception {
+        JsonNode payload = root.get("card_payload");
+        if (payload != null && !payload.isNull()) {
+            return objectMapper.writeValueAsString(payload);
+        }
+        JsonNode data = root.get("data");
+        if (data != null && !data.isNull()) {
+            return objectMapper.writeValueAsString(data);
+        }
+        return null;
+    }
+
+    private static Long resolveRelatedDraftId(JsonNode root) {
+        JsonNode payload = root.get("card_payload");
+        if (payload != null && payload.has("draft_id")) {
+            return payload.get("draft_id").asLong(0L) > 0 ? payload.get("draft_id").asLong() : null;
+        }
+        JsonNode data = root.get("data");
+        if (data != null && data.has("draft_id")) {
+            return data.get("draft_id").asLong(0L) > 0 ? data.get("draft_id").asLong() : null;
+        }
+        if (root.has("draft_id")) {
+            return root.get("draft_id").asLong(0L) > 0 ? root.get("draft_id").asLong() : null;
+        }
+        return null;
+    }
+
+    private static String resolveDisplayText(String prefixText, JsonNode root) {
+        String fromJson = textOrNull(root, "content");
+        if (!StringUtils.hasText(fromJson)) {
+            fromJson = textOrNull(root, "reply_text");
+        }
+        if (StringUtils.hasText(fromJson)) {
+            return fromJson.trim();
+        }
+        return StringUtils.hasText(prefixText) ? prefixText.trim() : "请查看卡片详情";
+    }
+
+    private static String textOrNull(JsonNode root, String field) {
+        if (root == null || !root.has(field) || root.get(field).isNull()) {
+            return null;
+        }
+        String text = root.get(field).asText("");
+        return text.isEmpty() ? null : text;
+    }
+}

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

@@ -6,7 +6,11 @@ import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.huimv.employment.dao.entity.FeConversation;
 import com.huimv.employment.integration.kb.KbOpenAiProxyService;
 import com.huimv.employment.service.conversation.dto.ConversationChatRequest;
+import com.huimv.employment.service.conversation.dto.ParsedAssistantReply;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
 
 import java.io.IOException;
 import java.io.OutputStream;
@@ -17,20 +21,25 @@ import java.io.OutputStream;
 @Service
 public class ConversationChatService {
 
+    private static final Logger log = LoggerFactory.getLogger(ConversationChatService.class);
+
     private final ConversationService conversationService;
     private final ConversationMessageService conversationMessageService;
     private final ConversationIntentService conversationIntentService;
+    private final ConversationDraftCardEnricher conversationDraftCardEnricher;
     private final KbOpenAiProxyService kbOpenAiProxyService;
     private final ObjectMapper objectMapper;
 
     public ConversationChatService(ConversationService conversationService,
                                    ConversationMessageService conversationMessageService,
                                    ConversationIntentService conversationIntentService,
+                                   ConversationDraftCardEnricher conversationDraftCardEnricher,
                                    KbOpenAiProxyService kbOpenAiProxyService,
                                    ObjectMapper objectMapper) {
         this.conversationService = conversationService;
         this.conversationMessageService = conversationMessageService;
         this.conversationIntentService = conversationIntentService;
+        this.conversationDraftCardEnricher = conversationDraftCardEnricher;
         this.kbOpenAiProxyService = kbOpenAiProxyService;
         this.objectMapper = objectMapper;
     }
@@ -52,7 +61,13 @@ public class ConversationChatService {
         }
         String assistantText = kbOpenAiProxyService.streamConsoleChatCollecting(
                 upstreamBody, agentId, output, objectMapper);
-        conversationMessageService.saveAssistantMessage(conversation.getId(), assistantText);
+        ParsedAssistantReply parsed = AssistantReplyParser.parse(assistantText, objectMapper);
+        parsed = conversationDraftCardEnricher.enrichIfReady(conversation.getId(), parsed);
+        if (!StringUtils.hasText(parsed.getDisplayText()) && !parsed.hasCard()) {
+            log.warn("assistant 回复为空，未写入 fe_conversation_message conversationId={} conversationNo={}",
+                    conversation.getId(), conversation.getConversationNo());
+        }
+        conversationMessageService.saveAssistantMessage(conversation.getId(), parsed);
     }
 
     private byte[] buildUpstreamBody(FeConversation conversation, Long userId, String userText) throws IOException {

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

@@ -0,0 +1,101 @@
+package com.huimv.employment.service.conversation;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.huimv.employment.dao.entity.FeEmploymentDraft;
+import com.huimv.employment.dao.mapper.FeEmploymentDraftMapper;
+import com.huimv.employment.service.conversation.dto.ParsedAssistantReply;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+import java.util.Collections;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 当 Agent 未返回卡片 JSON 时，根据会话 pending 且 ready 的草稿自动补全 card_draft 消息。
+ */
+@Component
+public class ConversationDraftCardEnricher {
+
+    private static final Logger log = LoggerFactory.getLogger(ConversationDraftCardEnricher.class);
+
+    private static final String DB_STATUS_PENDING = "pending";
+
+    private final FeEmploymentDraftMapper feEmploymentDraftMapper;
+    private final ObjectMapper objectMapper;
+
+    public ConversationDraftCardEnricher(FeEmploymentDraftMapper feEmploymentDraftMapper,
+                                         ObjectMapper objectMapper) {
+        this.feEmploymentDraftMapper = feEmploymentDraftMapper;
+        this.objectMapper = objectMapper;
+    }
+
+    public ParsedAssistantReply enrichIfReady(Long conversationId, ParsedAssistantReply parsed) {
+        if (parsed == null || parsed.hasCard() || conversationId == null) {
+            return parsed;
+        }
+        FeEmploymentDraft draft = findPendingDraft(conversationId);
+        if (draft == null || !isReady(draft)) {
+            return parsed;
+        }
+        try {
+            Map<String, Object> payload = buildDraftCardPayload(draft);
+            String cardPayload = objectMapper.writeValueAsString(payload);
+            log.debug("会话 {} 草稿 {} 已 ready，自动补全 card_draft 消息", conversationId, draft.getId());
+            return parsed.withCard(
+                    MessageCardConstants.CONTENT_TYPE_CARD_DRAFT,
+                    MessageCardConstants.NEXT_ACTION_SHOW_EMPLOYMENT_DRAFT,
+                    cardPayload,
+                    draft.getId());
+        } catch (Exception ex) {
+            log.warn("会话 {} 草稿卡片补全失败: {}", conversationId, ex.getMessage());
+            return parsed;
+        }
+    }
+
+    private FeEmploymentDraft findPendingDraft(Long conversationId) {
+        return feEmploymentDraftMapper.selectOne(new LambdaQueryWrapper<FeEmploymentDraft>()
+                .eq(FeEmploymentDraft::getConversationId, conversationId)
+                .eq(FeEmploymentDraft::getStatus, DB_STATUS_PENDING)
+                .orderByDesc(FeEmploymentDraft::getCreateTime)
+                .last("LIMIT 1"));
+    }
+
+    private boolean isReady(FeEmploymentDraft draft) {
+        return parseMissingFields(draft.getMissingFields()).isEmpty();
+    }
+
+    private List<String> parseMissingFields(String json) {
+        if (!StringUtils.hasText(json)) {
+            return Collections.emptyList();
+        }
+        try {
+            List<String> parsed = objectMapper.readValue(json.trim(), new TypeReference<List<String>>() {
+            });
+            return parsed != null ? parsed : Collections.emptyList();
+        } catch (Exception ex) {
+            return Collections.emptyList();
+        }
+    }
+
+    private Map<String, Object> buildDraftCardPayload(FeEmploymentDraft draft) {
+        Map<String, Object> payload = new LinkedHashMap<>();
+        payload.put("draft_id", draft.getId());
+        payload.put("draft_no", draft.getDraftNo());
+        payload.put("title", draft.getTitle());
+        payload.put("worker_count", draft.getWorkerCount());
+        payload.put("work_days", draft.getWorkDays());
+        payload.put("work_type", draft.getWorkType());
+        payload.put("work_location", draft.getWorkLocation());
+        payload.put("settlement_mode", draft.getSettlementMode());
+        payload.put("total_amount", draft.getEstimatedTotal());
+        payload.put("status", "ready");
+        payload.put("missing_fields", Collections.emptyList());
+        return payload;
+    }
+}

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

@@ -0,0 +1,44 @@
+package com.huimv.employment.service.conversation;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.huimv.employment.common.exception.BizException;
+import com.huimv.employment.common.exception.ErrorCode;
+import com.huimv.employment.dao.entity.FeEmploymentDraft;
+import com.huimv.employment.dao.mapper.FeEmploymentDraftMapper;
+import com.huimv.employment.service.draft.DraftService;
+import com.huimv.employment.service.draft.dto.DraftDetailResponse;
+import org.springframework.stereotype.Service;
+
+/**
+ * 按会话查询当前关联草稿（小程序兜底，无需 draft_id）。
+ */
+@Service
+public class ConversationDraftQueryService {
+
+    private final ConversationService conversationService;
+    private final FeEmploymentDraftMapper feEmploymentDraftMapper;
+    private final DraftService draftService;
+
+    public ConversationDraftQueryService(ConversationService conversationService,
+                                         FeEmploymentDraftMapper feEmploymentDraftMapper,
+                                         DraftService draftService) {
+        this.conversationService = conversationService;
+        this.feEmploymentDraftMapper = feEmploymentDraftMapper;
+        this.draftService = draftService;
+    }
+
+    /**
+     * 返回会话下最新一条草稿详情（含 pending / confirmed）。
+     */
+    public DraftDetailResponse getDraftByConversation(Long userId, Long conversationId) {
+        conversationService.requireOwned(userId, conversationId);
+        FeEmploymentDraft draft = feEmploymentDraftMapper.selectOne(new LambdaQueryWrapper<FeEmploymentDraft>()
+                .eq(FeEmploymentDraft::getConversationId, conversationId)
+                .orderByDesc(FeEmploymentDraft::getCreateTime)
+                .last("LIMIT 1"));
+        if (draft == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "当前会话暂无草稿");
+        }
+        return draftService.getDetail(userId, draft.getId());
+    }
+}

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

@@ -6,6 +6,7 @@ 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 com.huimv.employment.service.conversation.dto.ParsedAssistantReply;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
@@ -21,7 +22,6 @@ public class ConversationMessageService {
 
     private static final String ROLE_USER = "user";
     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;
@@ -74,7 +74,8 @@ public class ConversationMessageService {
         if (conversationId == null || !StringUtils.hasText(userText)) {
             return;
         }
-        insertMessage(conversationId, ROLE_USER, userText.trim());
+        insertMessage(conversationId, ROLE_USER, userText.trim(),
+                MessageCardConstants.CONTENT_TYPE_TEXT, null, null, null);
         conversationService.refreshAfterMessage(conversationId, refreshTitle ? userText : null);
     }
 
@@ -91,19 +92,74 @@ public class ConversationMessageService {
 
     @Transactional(rollbackFor = Exception.class)
     public void saveAssistantMessage(Long conversationId, String assistantText) {
-        if (conversationId == null || !StringUtils.hasText(assistantText)) {
+        saveAssistantMessage(conversationId, ParsedAssistantReply.textOnly(
+                assistantText != null ? assistantText.trim() : ""));
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public void saveAssistantMessage(Long conversationId, ParsedAssistantReply parsed) {
+        if (conversationId == null || parsed == null) {
             return;
         }
-        insertMessage(conversationId, ROLE_ASSISTANT, assistantText.trim());
+        String content = resolveAssistantContent(parsed);
+        if (!StringUtils.hasText(content) && !parsed.hasCard()) {
+            return;
+        }
+        String contentType = parsed.hasCard()
+                ? parsed.getContentType()
+                : MessageCardConstants.CONTENT_TYPE_TEXT;
+        String nextAction = parsed.getNextAction();
+        if (parsed.hasCard() && !StringUtils.hasText(nextAction)) {
+            nextAction = defaultNextAction(contentType);
+        }
+        insertMessage(conversationId, ROLE_ASSISTANT, content,
+                contentType, parsed.getCardPayload(), nextAction, parsed.getRelatedDraftId());
         conversationService.refreshAfterMessage(conversationId, null);
     }
 
-    private void insertMessage(Long conversationId, String role, String content) {
+    private static String resolveAssistantContent(ParsedAssistantReply parsed) {
+        if (StringUtils.hasText(parsed.getDisplayText())) {
+            return parsed.getDisplayText().trim();
+        }
+        if (parsed.hasCard()) {
+            if (MessageCardConstants.CONTENT_TYPE_CARD_DRAFT.equals(parsed.getContentType())) {
+                return "用工草稿已生成，请查看并确认。";
+            }
+            if (MessageCardConstants.CONTENT_TYPE_CARD_COST.equals(parsed.getContentType())) {
+                return "成本测算完成，请选择方案。";
+            }
+            return "请查看卡片详情。";
+        }
+        return "";
+    }
+
+    private static String defaultNextAction(String contentType) {
+        if (MessageCardConstants.CONTENT_TYPE_CARD_DRAFT.equals(contentType)) {
+            return MessageCardConstants.NEXT_ACTION_SHOW_EMPLOYMENT_DRAFT;
+        }
+        if (MessageCardConstants.CONTENT_TYPE_CARD_COST.equals(contentType)) {
+            return MessageCardConstants.NEXT_ACTION_OPEN_COST_COMPARISON;
+        }
+        return null;
+    }
+
+    private void insertMessage(Long conversationId,
+                               String role,
+                               String content,
+                               String contentType,
+                               String cardPayload,
+                               String nextAction,
+                               Long relatedDraftId) {
         FeConversationMessage message = new FeConversationMessage();
         message.setConversationId(conversationId);
         message.setRole(role);
         message.setContent(content);
-        message.setContentType(CONTENT_TYPE_TEXT);
+        message.setContentType(StringUtils.hasText(contentType)
+                ? contentType
+                : MessageCardConstants.CONTENT_TYPE_TEXT);
+        message.setCardPayload(cardPayload);
+        message.setNextAction(nextAction);
+        message.setRelatedDraftId(relatedDraftId);
         message.setCreateTime(LocalDateTime.now());
         feConversationMessageMapper.insert(message);
     }
@@ -116,6 +172,7 @@ public class ConversationMessageService {
         response.setContentType(entity.getContentType());
         response.setCardPayload(entity.getCardPayload());
         response.setNextAction(entity.getNextAction());
+        response.setRelatedDraftId(entity.getRelatedDraftId());
         response.setCreateTime(entity.getCreateTime());
         return response;
     }

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

@@ -0,0 +1,18 @@
+package com.huimv.employment.service.conversation;
+
+/**
+ * 会话消息卡片类型与前端动作编码（对齐 fe_conversation_message 与 v2 交互规则）。
+ */
+public final class MessageCardConstants {
+
+    public static final String CONTENT_TYPE_TEXT = "text";
+    public static final String CONTENT_TYPE_CARD_DRAFT = "card_draft";
+    public static final String CONTENT_TYPE_CARD_COST = "card_cost";
+    public static final String CONTENT_TYPE_CARD_ORDER = "card_order";
+
+    public static final String NEXT_ACTION_SHOW_EMPLOYMENT_DRAFT = "show_employment_draft";
+    public static final String NEXT_ACTION_OPEN_COST_COMPARISON = "open_cost_comparison";
+
+    private MessageCardConstants() {
+    }
+}

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

@@ -28,6 +28,9 @@ public class ConversationMessageResponse {
     @Schema(description = "建议前端下一步动作编码")
     private String nextAction;
 
+    @Schema(description = "关联草稿 ID")
+    private Long relatedDraftId;
+
     @Schema(description = "消息时间")
     private LocalDateTime createTime;
 
@@ -79,6 +82,14 @@ public class ConversationMessageResponse {
         this.nextAction = nextAction;
     }
 
+    public Long getRelatedDraftId() {
+        return relatedDraftId;
+    }
+
+    public void setRelatedDraftId(Long relatedDraftId) {
+        this.relatedDraftId = relatedDraftId;
+    }
+
     public LocalDateTime getCreateTime() {
         return createTime;
     }

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

@@ -0,0 +1,69 @@
+package com.huimv.employment.service.conversation.dto;
+
+import com.huimv.employment.service.conversation.MessageCardConstants;
+import org.springframework.util.StringUtils;
+
+/**
+ * 解析后的 assistant 回复：展示文本 + 可选卡片元数据。
+ */
+public class ParsedAssistantReply {
+
+    private final String displayText;
+    private final String contentType;
+    private final String cardPayload;
+    private final String nextAction;
+    private final Long relatedDraftId;
+
+    public ParsedAssistantReply(String displayText,
+                                String contentType,
+                                String cardPayload,
+                                String nextAction,
+                                Long relatedDraftId) {
+        this.displayText = displayText;
+        this.contentType = contentType;
+        this.cardPayload = cardPayload;
+        this.nextAction = nextAction;
+        this.relatedDraftId = relatedDraftId;
+    }
+
+    public static ParsedAssistantReply textOnly(String displayText) {
+        return new ParsedAssistantReply(
+                displayText,
+                MessageCardConstants.CONTENT_TYPE_TEXT,
+                null,
+                null,
+                null);
+    }
+
+    public boolean hasCard() {
+        return StringUtils.hasText(contentType)
+                && !MessageCardConstants.CONTENT_TYPE_TEXT.equals(contentType);
+    }
+
+    public ParsedAssistantReply withCard(String contentType,
+                                         String nextAction,
+                                         String cardPayload,
+                                         Long relatedDraftId) {
+        return new ParsedAssistantReply(displayText, contentType, cardPayload, nextAction, relatedDraftId);
+    }
+
+    public String getDisplayText() {
+        return displayText;
+    }
+
+    public String getContentType() {
+        return contentType;
+    }
+
+    public String getCardPayload() {
+        return cardPayload;
+    }
+
+    public String getNextAction() {
+        return nextAction;
+    }
+
+    public Long getRelatedDraftId() {
+        return relatedDraftId;
+    }
+}