增加与ai大模型对话

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

@@ -15,6 +15,8 @@ import com.huimv.employment.service.conversation.dto.ConversationMessagePageResp
 import com.huimv.employment.service.conversation.dto.ConversationSummaryResponse;
 import com.huimv.employment.service.draft.DraftService;
 import com.huimv.employment.service.draft.dto.McpDraftCalculateResponse;
+import com.huimv.employment.service.registration.RegistrationBatchService;
+import com.huimv.employment.service.registration.dto.RegistrationBatchDetailResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -57,15 +59,18 @@ public class ConversationController {
     private final ConversationChatService conversationChatService;
     private final ConversationMessageService conversationMessageService;
     private final DraftService draftService;
+    private final RegistrationBatchService registrationBatchService;
 
     public ConversationController(ConversationService conversationService,
                                   ConversationChatService conversationChatService,
                                   ConversationMessageService conversationMessageService,
-                                  DraftService draftService) {
+                                  DraftService draftService,
+                                  RegistrationBatchService registrationBatchService) {
         this.conversationService = conversationService;
         this.conversationChatService = conversationChatService;
         this.conversationMessageService = conversationMessageService;
         this.draftService = draftService;
+        this.registrationBatchService = registrationBatchService;
     }
 
     /**
@@ -126,6 +131,21 @@ public class ConversationController {
                 loginUser.getUserId(), conversationId));
     }
 
+    /**
+     * 查询指定会话下全部草稿的登记进度。
+     */
+    @GetMapping("/{id}/drafts/registration-progress")
+    @Operation(summary = "按会话查询全部草稿登记进度",
+            description = "返回该会话下已确认方案并建有登记批次的草稿进度列表；"
+                    + "每个元素结构与 GET /api/v1/mp/registration-batches?draft_id= 一致。"
+                    + "尚未确认方案、无批次的草稿自动跳过。仅可查询本企业用户自己的会话。")
+    public R<List<RegistrationBatchDetailResponse>> listDraftRegistrationProgress(
+            @PathVariable("id") Long conversationId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(registrationBatchService.listDetailsByConversation(
+                loginUser.getUserId(), conversationId));
+    }
+
     /**
      * 在已有会话内发起 AI 对话（SSE 流式，流结束后落库）。
      */

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/registration/RegistrationBatchService.java

@@ -17,6 +17,7 @@ import com.huimv.employment.dao.mapper.FeWorkerRegistrationMapper;
 import com.huimv.employment.dao.mapper.FeWorkflowDefinitionMapper;
 import com.huimv.employment.dao.mapper.FeWorkflowStepMapper;
 import com.huimv.employment.service.config.RegistrationQrProperties;
+import com.huimv.employment.service.conversation.ConversationService;
 import com.huimv.employment.service.enterprise.EnterpriseService;
 import com.huimv.employment.service.registration.dto.RegistrationBatchDetailResponse;
 import com.huimv.employment.service.registration.dto.RegistrationBatchProgressResponse;
@@ -76,6 +77,7 @@ public class RegistrationBatchService {
     private final FeWorkflowDefinitionMapper feWorkflowDefinitionMapper;
     private final FeWorkflowStepMapper feWorkflowStepMapper;
     private final EnterpriseService enterpriseService;
+    private final ConversationService conversationService;
     private final WeChatMiniAppService weChatMiniAppService;
     private final RegistrationQrProperties qrProperties;
 
@@ -86,6 +88,7 @@ public class RegistrationBatchService {
                                     FeWorkflowDefinitionMapper feWorkflowDefinitionMapper,
                                     FeWorkflowStepMapper feWorkflowStepMapper,
                                     EnterpriseService enterpriseService,
+                                    ConversationService conversationService,
                                     WeChatMiniAppService weChatMiniAppService,
                                     RegistrationQrProperties qrProperties) {
         this.feRegistrationBatchMapper = feRegistrationBatchMapper;
@@ -95,6 +98,7 @@ public class RegistrationBatchService {
         this.feWorkflowDefinitionMapper = feWorkflowDefinitionMapper;
         this.feWorkflowStepMapper = feWorkflowStepMapper;
         this.enterpriseService = enterpriseService;
+        this.conversationService = conversationService;
         this.weChatMiniAppService = weChatMiniAppService;
         this.qrProperties = qrProperties;
     }
@@ -180,6 +184,35 @@ public class RegistrationBatchService {
         return toDetailResponse(batch, order, draft);
     }
 
+    /**
+     * 按会话查询其下全部草稿的登记进度详情。
+     * <p>元素结构与 {@link #getDetailByDraftId} 相同；尚未确认方案、无批次的草稿跳过。</p>
+     */
+    public List<RegistrationBatchDetailResponse> listDetailsByConversation(Long userId, Long conversationId) {
+        conversationService.requireOwned(userId, conversationId);
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "企业信息不存在");
+        }
+        List<FeEmploymentDraft> drafts = feEmploymentDraftMapper.selectList(
+                new LambdaQueryWrapper<FeEmploymentDraft>()
+                        .eq(FeEmploymentDraft::getConversationId, conversationId)
+                        .eq(FeEmploymentDraft::getEnterpriseId, enterprise.getId())
+                        .orderByAsc(FeEmploymentDraft::getId));
+        List<RegistrationBatchDetailResponse> result = new ArrayList<>();
+        if (drafts == null || drafts.isEmpty()) {
+            return result;
+        }
+        for (FeEmploymentDraft draft : drafts) {
+            try {
+                result.add(getDetailByDraftId(userId, draft.getId()));
+            } catch (BizException ignored) {
+                // 未确认方案或无批次时跳过
+            }
+        }
+        return result;
+    }
+
     /**
      * 企业端登记进度详情：按批次主键 ID 或业务编号（如 bat_1）。
      */
@@ -215,6 +248,7 @@ public class RegistrationBatchService {
         String batchNo = batch.getBatchNo();
 
         RegistrationBatchDetailResponse response = new RegistrationBatchDetailResponse();
+        response.setDraftId(draft != null ? draft.getId() : order.getDraftId());
         response.setBatchId(batch.getId());
         response.setBatchNo(batchNo);
         response.setTitle(title);

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/registration/dto/RegistrationBatchDetailResponse.java

@@ -10,6 +10,10 @@ import java.util.List;
 @Schema(description = "登记批次详情（进度管理）")
 public class RegistrationBatchDetailResponse {
 
+    @JsonProperty("draft_id")
+    @Schema(description = "关联草稿 ID")
+    private Long draftId;
+
     @JsonProperty("batch_id")
     @Schema(description = "批次主键 ID")
     private Long batchId;
@@ -69,6 +73,14 @@ public class RegistrationBatchDetailResponse {
     @Schema(description = "人员列表")
     private List<RegistrationBatchWorkerItemResponse> workers = new ArrayList<>();
 
+    public Long getDraftId() {
+        return draftId;
+    }
+
+    public void setDraftId(Long draftId) {
+        this.draftId = draftId;
+    }
+
     public Long getBatchId() {
         return batchId;
     }