增加与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.order.EmploymentOrderService;
+import com.huimv.employment.service.order.dto.EmploymentOrderItemResponse;
 import com.huimv.employment.service.registration.RegistrationBatchService;
 import com.huimv.employment.service.registration.dto.RegistrationBatchDetailResponse;
 import io.swagger.v3.oas.annotations.Operation;
@@ -60,17 +62,20 @@ public class ConversationController {
     private final ConversationMessageService conversationMessageService;
     private final DraftService draftService;
     private final RegistrationBatchService registrationBatchService;
+    private final EmploymentOrderService employmentOrderService;
 
     public ConversationController(ConversationService conversationService,
                                   ConversationChatService conversationChatService,
                                   ConversationMessageService conversationMessageService,
                                   DraftService draftService,
-                                  RegistrationBatchService registrationBatchService) {
+                                  RegistrationBatchService registrationBatchService,
+                                  EmploymentOrderService employmentOrderService) {
         this.conversationService = conversationService;
         this.conversationChatService = conversationChatService;
         this.conversationMessageService = conversationMessageService;
         this.draftService = draftService;
         this.registrationBatchService = registrationBatchService;
+        this.employmentOrderService = employmentOrderService;
     }
 
     /**
@@ -146,6 +151,21 @@ public class ConversationController {
                 loginUser.getUserId(), conversationId));
     }
 
+    /**
+     * 查询指定会话下全部草稿已转成正式订单的列表。
+     */
+    @GetMapping("/{id}/drafts/orders")
+    @Operation(summary = "按会话查询草稿关联订单列表",
+            description = "返回该会话下草稿已确认并生成的正式订单；"
+                    + "仅「有订单」的草稿会出现在结果中，尚未确认方案的草稿不返回。"
+                    + "仅可查询本企业用户自己的会话。")
+    public R<List<EmploymentOrderItemResponse>> listDraftOrders(
+            @PathVariable("id") Long conversationId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(employmentOrderService.listByConversation(
+                loginUser.getUserId(), conversationId));
+    }
+
     /**
      * 在已有会话内发起 AI 对话（SSE 流式，流结束后落库）。
      */

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/order/EmploymentOrderService.java

@@ -0,0 +1,111 @@
+package com.huimv.employment.service.order;
+
+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.entity.FeEmploymentOrder;
+import com.huimv.employment.dao.entity.FeEnterprise;
+import com.huimv.employment.dao.mapper.FeEmploymentDraftMapper;
+import com.huimv.employment.dao.mapper.FeEmploymentOrderMapper;
+import com.huimv.employment.service.conversation.ConversationService;
+import com.huimv.employment.service.enterprise.EnterpriseService;
+import com.huimv.employment.service.order.dto.EmploymentOrderItemResponse;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * 企业端用工订单查询。
+ */
+@Service
+public class EmploymentOrderService {
+
+    private final FeEmploymentOrderMapper feEmploymentOrderMapper;
+    private final FeEmploymentDraftMapper feEmploymentDraftMapper;
+    private final ConversationService conversationService;
+    private final EnterpriseService enterpriseService;
+
+    public EmploymentOrderService(FeEmploymentOrderMapper feEmploymentOrderMapper,
+                                  FeEmploymentDraftMapper feEmploymentDraftMapper,
+                                  ConversationService conversationService,
+                                  EnterpriseService enterpriseService) {
+        this.feEmploymentOrderMapper = feEmploymentOrderMapper;
+        this.feEmploymentDraftMapper = feEmploymentDraftMapper;
+        this.conversationService = conversationService;
+        this.enterpriseService = enterpriseService;
+    }
+
+    /**
+     * 按会话查询其下草稿已转成正式订单的列表。
+     * <p>仅返回已存在订单的草稿；无订单的草稿不出现在结果中。</p>
+     */
+    public List<EmploymentOrderItemResponse> listByConversation(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));
+        if (drafts == null || drafts.isEmpty()) {
+            return Collections.emptyList();
+        }
+
+        List<Long> draftIds = new ArrayList<>(drafts.size());
+        for (FeEmploymentDraft draft : drafts) {
+            if (draft.getId() != null) {
+                draftIds.add(draft.getId());
+            }
+        }
+        if (draftIds.isEmpty()) {
+            return Collections.emptyList();
+        }
+
+        List<FeEmploymentOrder> orders = feEmploymentOrderMapper.selectList(
+                new LambdaQueryWrapper<FeEmploymentOrder>()
+                        .eq(FeEmploymentOrder::getEnterpriseId, enterprise.getId())
+                        .in(FeEmploymentOrder::getDraftId, draftIds)
+                        .orderByDesc(FeEmploymentOrder::getCreateTime)
+                        .orderByDesc(FeEmploymentOrder::getId));
+        if (orders == null || orders.isEmpty()) {
+            return Collections.emptyList();
+        }
+
+        List<EmploymentOrderItemResponse> result = new ArrayList<>(orders.size());
+        for (FeEmploymentOrder order : orders) {
+            result.add(toItem(order));
+        }
+        return result;
+    }
+
+    private static EmploymentOrderItemResponse toItem(FeEmploymentOrder order) {
+        EmploymentOrderItemResponse item = new EmploymentOrderItemResponse();
+        item.setDraftId(order.getDraftId());
+        item.setOrderId(order.getId());
+        item.setOrderNo(order.getOrderNo());
+        item.setTitle(order.getTitle());
+        item.setWorkerCount(order.getWorkerCount());
+        item.setWorkDays(order.getWorkDays());
+        item.setWorkType(order.getWorkType());
+        item.setWorkLocation(order.getWorkLocation());
+        item.setWorkStartDate(order.getWorkStartDate());
+        item.setWorkEndDate(order.getWorkEndDate());
+        item.setOrderStatus(order.getOrderStatus());
+        item.setCurrentStepCode(order.getCurrentStepCode());
+        item.setRegisteredCount(order.getRegisteredCount());
+        item.setPendingCount(order.getPendingCount());
+        item.setAbnormalCount(order.getAbnormalCount());
+        item.setTotalOutflow(order.getTotalOutflow());
+        item.setSelectedPlanId(order.getSelectedPlanId());
+        item.setCreateTime(order.getCreateTime());
+        item.setUpdateTime(order.getUpdateTime());
+        return item;
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/order/dto/EmploymentOrderItemResponse.java

@@ -0,0 +1,231 @@
+package com.huimv.employment.service.order.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Schema(description = "用工订单列表项")
+public class EmploymentOrderItemResponse {
+
+    @JsonProperty("draft_id")
+    @Schema(description = "关联草稿 ID")
+    private Long draftId;
+
+    @JsonProperty("order_id")
+    @Schema(description = "订单主键 ID")
+    private Long orderId;
+
+    @JsonProperty("order_no")
+    @Schema(description = "订单编号", example = "ord_123")
+    private String orderNo;
+
+    @Schema(description = "订单标题")
+    private String title;
+
+    @JsonProperty("worker_count")
+    @Schema(description = "用工人数")
+    private Integer workerCount;
+
+    @JsonProperty("work_days")
+    @Schema(description = "工作天数")
+    private Integer workDays;
+
+    @JsonProperty("work_type")
+    @Schema(description = "岗位类型")
+    private String workType;
+
+    @JsonProperty("work_location")
+    @Schema(description = "工作地点")
+    private String workLocation;
+
+    @JsonProperty("work_start_date")
+    private LocalDate workStartDate;
+
+    @JsonProperty("work_end_date")
+    private LocalDate workEndDate;
+
+    @JsonProperty("order_status")
+    @Schema(description = "订单状态", example = "confirmed")
+    private String orderStatus;
+
+    @JsonProperty("current_step_code")
+    @Schema(description = "当前流程步骤")
+    private String currentStepCode;
+
+    @JsonProperty("registered_count")
+    private Integer registeredCount;
+
+    @JsonProperty("pending_count")
+    private Integer pendingCount;
+
+    @JsonProperty("abnormal_count")
+    private Integer abnormalCount;
+
+    @JsonProperty("total_outflow")
+    @Schema(description = "企业总支出")
+    private BigDecimal totalOutflow;
+
+    @JsonProperty("selected_plan_id")
+    private Long selectedPlanId;
+
+    @JsonProperty("create_time")
+    private LocalDateTime createTime;
+
+    @JsonProperty("update_time")
+    private LocalDateTime updateTime;
+
+    public Long getDraftId() {
+        return draftId;
+    }
+
+    public void setDraftId(Long draftId) {
+        this.draftId = draftId;
+    }
+
+    public Long getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Long orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getOrderNo() {
+        return orderNo;
+    }
+
+    public void setOrderNo(String orderNo) {
+        this.orderNo = orderNo;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public Integer getWorkerCount() {
+        return workerCount;
+    }
+
+    public void setWorkerCount(Integer workerCount) {
+        this.workerCount = workerCount;
+    }
+
+    public Integer getWorkDays() {
+        return workDays;
+    }
+
+    public void setWorkDays(Integer workDays) {
+        this.workDays = workDays;
+    }
+
+    public String getWorkType() {
+        return workType;
+    }
+
+    public void setWorkType(String workType) {
+        this.workType = workType;
+    }
+
+    public String getWorkLocation() {
+        return workLocation;
+    }
+
+    public void setWorkLocation(String workLocation) {
+        this.workLocation = workLocation;
+    }
+
+    public LocalDate getWorkStartDate() {
+        return workStartDate;
+    }
+
+    public void setWorkStartDate(LocalDate workStartDate) {
+        this.workStartDate = workStartDate;
+    }
+
+    public LocalDate getWorkEndDate() {
+        return workEndDate;
+    }
+
+    public void setWorkEndDate(LocalDate workEndDate) {
+        this.workEndDate = workEndDate;
+    }
+
+    public String getOrderStatus() {
+        return orderStatus;
+    }
+
+    public void setOrderStatus(String orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+
+    public String getCurrentStepCode() {
+        return currentStepCode;
+    }
+
+    public void setCurrentStepCode(String currentStepCode) {
+        this.currentStepCode = currentStepCode;
+    }
+
+    public Integer getRegisteredCount() {
+        return registeredCount;
+    }
+
+    public void setRegisteredCount(Integer registeredCount) {
+        this.registeredCount = registeredCount;
+    }
+
+    public Integer getPendingCount() {
+        return pendingCount;
+    }
+
+    public void setPendingCount(Integer pendingCount) {
+        this.pendingCount = pendingCount;
+    }
+
+    public Integer getAbnormalCount() {
+        return abnormalCount;
+    }
+
+    public void setAbnormalCount(Integer abnormalCount) {
+        this.abnormalCount = abnormalCount;
+    }
+
+    public BigDecimal getTotalOutflow() {
+        return totalOutflow;
+    }
+
+    public void setTotalOutflow(BigDecimal totalOutflow) {
+        this.totalOutflow = totalOutflow;
+    }
+
+    public Long getSelectedPlanId() {
+        return selectedPlanId;
+    }
+
+    public void setSelectedPlanId(Long selectedPlanId) {
+        this.selectedPlanId = selectedPlanId;
+    }
+
+    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;
+    }
+}