增加与ai大模型对话

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

@@ -13,6 +13,8 @@ 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.DraftService;
+import com.huimv.employment.service.draft.dto.McpDraftCalculateResponse;
 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 DraftService draftService;
 
     public ConversationController(ConversationService conversationService,
                                   ConversationChatService conversationChatService,
-                                  ConversationMessageService conversationMessageService) {
+                                  ConversationMessageService conversationMessageService,
+                                  DraftService draftService) {
         this.conversationService = conversationService;
         this.conversationChatService = conversationChatService;
         this.conversationMessageService = conversationMessageService;
+        this.draftService = draftService;
     }
 
     /**
@@ -106,6 +111,21 @@ public class ConversationController {
                 loginUser.getUserId(), conversationId, page, size));
     }
 
+    /**
+     * 查询指定会话下全部草稿的成本测算（方案对比）。
+     */
+    @GetMapping("/{id}/drafts/cost-comparison")
+    @Operation(summary = "按会话查询全部草稿成本测算",
+            description = "返回该会话下可测算草稿的方案对比列表；"
+                    + "每个元素结构与 GET /api/v1/mp/drafts/{id}/cost-comparison 一致（含 draft_id、schemes）。"
+                    + "字段不完整无法测算的草稿自动跳过。仅可查询本企业用户自己的会话。")
+    public R<List<McpDraftCalculateResponse>> listDraftCostComparisons(
+            @PathVariable("id") Long conversationId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(draftService.listCostComparisonsByConversation(
+                loginUser.getUserId(), conversationId));
+    }
+
     /**
      * 在已有会话内发起 AI 对话（SSE 流式，流结束后落库）。
      */

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/draft/DraftService.java

@@ -24,6 +24,7 @@ import com.huimv.employment.service.draft.dto.DraftFieldResponse;
 import com.huimv.employment.service.draft.dto.DraftUpdateRequest;
 import com.huimv.employment.service.draft.dto.McpDraftCalculateResponse;
 import com.huimv.employment.service.enterprise.EnterpriseService;
+import com.huimv.employment.service.conversation.ConversationService;
 import com.huimv.employment.service.registration.RegistrationBatchService;
 import org.springframework.dao.DuplicateKeyException;
 import org.springframework.stereotype.Service;
@@ -32,6 +33,7 @@ import org.springframework.util.StringUtils;
 
 import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
@@ -81,6 +83,7 @@ public class DraftService {
     private final FeEmploymentOrderMapper feEmploymentOrderMapper;
     private final FeRegistrationBatchMapper feRegistrationBatchMapper;
     private final EnterpriseService enterpriseService;
+    private final ConversationService conversationService;
     private final DraftCostCalculationEngine draftCostCalculationEngine;
     private final RegistrationBatchService registrationBatchService;
     private final ObjectMapper objectMapper;
@@ -91,6 +94,7 @@ public class DraftService {
                         FeEmploymentOrderMapper feEmploymentOrderMapper,
                         FeRegistrationBatchMapper feRegistrationBatchMapper,
                         EnterpriseService enterpriseService,
+                        ConversationService conversationService,
                         DraftCostCalculationEngine draftCostCalculationEngine,
                         RegistrationBatchService registrationBatchService,
                         ObjectMapper objectMapper) {
@@ -100,6 +104,7 @@ public class DraftService {
         this.feEmploymentOrderMapper = feEmploymentOrderMapper;
         this.feRegistrationBatchMapper = feRegistrationBatchMapper;
         this.enterpriseService = enterpriseService;
+        this.conversationService = conversationService;
         this.draftCostCalculationEngine = draftCostCalculationEngine;
         this.registrationBatchService = registrationBatchService;
         this.objectMapper = objectMapper;
@@ -173,6 +178,46 @@ public class DraftService {
         return response;
     }
 
+    /**
+     * 按会话查询其下全部草稿的成本测算结果。
+     * <p>返回元素结构与 {@link #calculateCostComparison} / {@code GET .../drafts/{id}/cost-comparison} 相同。
+     * 字段不足以测算的草稿跳过，不中断整次查询。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public List<McpDraftCalculateResponse> listCostComparisonsByConversation(Long userId, Long conversationId) {
+        conversationService.requireOwned(userId, conversationId);
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "请先完成企业登记");
+        }
+        List<FeEmploymentDraft> drafts = feEmploymentDraftMapper.selectList(
+                new LambdaQueryWrapper<FeEmploymentDraft>()
+                        .eq(FeEmploymentDraft::getConversationId, conversationId)
+                        .eq(FeEmploymentDraft::getEnterpriseId, enterprise.getId())
+                        .orderByAsc(FeEmploymentDraft::getId));
+        List<McpDraftCalculateResponse> result = new ArrayList<>();
+        if (drafts == null || drafts.isEmpty()) {
+            return result;
+        }
+        LocalDateTime now = LocalDateTime.now();
+        for (FeEmploymentDraft draft : drafts) {
+            try {
+                List<DraftCostCalculationEngine.CalculatedScheme> schemes =
+                        draftCostCalculationEngine.calculate(draft);
+                if (STATUS_PENDING.equals(draft.getStatus())) {
+                    persistCostSnapshots(draft, schemes);
+                    updateDraftEstimates(draft, schemes, now);
+                }
+                McpDraftCalculateResponse response = draftCostCalculationEngine.toApiResponse(schemes);
+                response.setDraftId(draft.getId());
+                result.add(response);
+            } catch (BizException ignored) {
+                // 草稿不完整或无法测算时跳过
+            }
+        }
+        return result;
+    }
+
     /**
      * 微信端确认此方案：选定 SCHEME_A/SCHEME_B，转正式订单。
      * <p>若尚未测算，将自动先测算再确认。</p>