增加与ai大模型对话

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

@@ -0,0 +1,58 @@
+package com.huimv.employment.controller.mp;
+
+import com.huimv.employment.common.exception.BizException;
+import com.huimv.employment.common.exception.ErrorCode;
+import com.huimv.employment.common.web.R;
+import com.huimv.employment.security.LoginUser;
+import com.huimv.employment.security.LoginUserHolder;
+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.Parameter;
+import io.swagger.v3.oas.annotations.enums.ParameterIn;
+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;
+
+/**
+ * 临时工扫码登记批次（企业主进度管理）。
+ */
+@RestController
+@RequestMapping("/api/v1/mp/registration-batches")
+@Tag(name = "登记批次", description = "企业主查看扫码登记进度详情，需企业端 JWT")
+@SecurityRequirement(name = "Authorization")
+public class RegistrationBatchController {
+
+    private static final String USER_TYPE_ENTERPRISE = "enterprise";
+
+    private final RegistrationBatchService registrationBatchService;
+
+    public RegistrationBatchController(RegistrationBatchService registrationBatchService) {
+        this.registrationBatchService = registrationBatchService;
+    }
+
+    @GetMapping
+    @Operation(summary = "查询登记批次详情",
+            description = "按草稿 ID 查询进度管理页数据：人数统计、登记进度条、办理流程步骤、人员列表。"
+                    + "路径：草稿 → 订单 → 登记批次。仅可查询本企业草稿。",
+            parameters = {
+                    @Parameter(name = "draft_id", in = ParameterIn.QUERY, required = true,
+                            description = "用工草稿 ID（generate / confirm 返回的 draft_id）")
+            })
+    public R<RegistrationBatchDetailResponse> getDetail(
+            @RequestParam("draft_id") Long draftId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(registrationBatchService.getDetailByDraftId(loginUser.getUserId(), draftId));
+    }
+
+    private static LoginUser requireEnterprise() {
+        LoginUser loginUser = LoginUserHolder.require();
+        if (!USER_TYPE_ENTERPRISE.equals(loginUser.getUserType())) {
+            throw new BizException(ErrorCode.ENTERPRISE_ONLY);
+        }
+        return loginUser;
+    }
+}

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

@@ -0,0 +1,95 @@
+package com.huimv.employment.dao.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.time.LocalDateTime;
+
+/**
+ * 合规流程定义 {@code fe_workflow_definition} 实体。
+ */
+@TableName("fe_workflow_definition")
+public class FeWorkflowDefinition {
+
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    private String workflowCode;
+
+    private String workflowName;
+
+    private String description;
+
+    private Integer version;
+
+    private Boolean isActive;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getWorkflowCode() {
+        return workflowCode;
+    }
+
+    public void setWorkflowCode(String workflowCode) {
+        this.workflowCode = workflowCode;
+    }
+
+    public String getWorkflowName() {
+        return workflowName;
+    }
+
+    public void setWorkflowName(String workflowName) {
+        this.workflowName = workflowName;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public Integer getVersion() {
+        return version;
+    }
+
+    public void setVersion(Integer version) {
+        this.version = version;
+    }
+
+    public Boolean getIsActive() {
+        return isActive;
+    }
+
+    public void setIsActive(Boolean active) {
+        isActive = active;
+    }
+
+    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;
+    }
+}

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

@@ -0,0 +1,95 @@
+package com.huimv.employment.dao.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.time.LocalDateTime;
+
+/**
+ * 合规流程步骤 {@code fe_workflow_step} 实体。
+ */
+@TableName("fe_workflow_step")
+public class FeWorkflowStep {
+
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    private Long workflowId;
+
+    private String stepCode;
+
+    private String stepName;
+
+    private Integer stepOrder;
+
+    private Boolean required;
+
+    private Boolean autoAdvance;
+
+    private LocalDateTime createTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getWorkflowId() {
+        return workflowId;
+    }
+
+    public void setWorkflowId(Long workflowId) {
+        this.workflowId = workflowId;
+    }
+
+    public String getStepCode() {
+        return stepCode;
+    }
+
+    public void setStepCode(String stepCode) {
+        this.stepCode = stepCode;
+    }
+
+    public String getStepName() {
+        return stepName;
+    }
+
+    public void setStepName(String stepName) {
+        this.stepName = stepName;
+    }
+
+    public Integer getStepOrder() {
+        return stepOrder;
+    }
+
+    public void setStepOrder(Integer stepOrder) {
+        this.stepOrder = stepOrder;
+    }
+
+    public Boolean getRequired() {
+        return required;
+    }
+
+    public void setRequired(Boolean required) {
+        this.required = required;
+    }
+
+    public Boolean getAutoAdvance() {
+        return autoAdvance;
+    }
+
+    public void setAutoAdvance(Boolean autoAdvance) {
+        this.autoAdvance = autoAdvance;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+}

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

@@ -0,0 +1,9 @@
+package com.huimv.employment.dao.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.employment.dao.entity.FeWorkflowDefinition;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface FeWorkflowDefinitionMapper extends BaseMapper<FeWorkflowDefinition> {
+}

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

@@ -0,0 +1,9 @@
+package com.huimv.employment.dao.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.employment.dao.entity.FeWorkflowStep;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface FeWorkflowStepMapper extends BaseMapper<FeWorkflowStep> {
+}

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

@@ -112,6 +112,7 @@ public class McpOrderService {
 
         McpOrderCloneResponse response = new McpOrderCloneResponse();
         response.setStatus(STATUS_SUCCESS);
+        response.setDraftId(draft.getId());
         return response;
     }
 

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

@@ -1,5 +1,6 @@
 package com.huimv.employment.service.order.dto;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import io.swagger.v3.oas.annotations.media.Schema;
 
 @Schema(description = "MCP 克隆订单至草稿响应（v2 §6.3.7）")
@@ -8,6 +9,10 @@ public class McpOrderCloneResponse {
     @Schema(description = "克隆结果", example = "success")
     private String status;
 
+    @JsonProperty("draft_id")
+    @Schema(description = "新生成的草稿 ID")
+    private Long draftId;
+
     public String getStatus() {
         return status;
     }
@@ -15,4 +20,12 @@ public class McpOrderCloneResponse {
     public void setStatus(String status) {
         this.status = status;
     }
+
+    public Long getDraftId() {
+        return draftId;
+    }
+
+    public void setDraftId(Long draftId) {
+        this.draftId = draftId;
+    }
 }

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

@@ -1,13 +1,28 @@
 package com.huimv.employment.service.registration;
 
+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.entity.FeRegistrationBatch;
+import com.huimv.employment.dao.entity.FeWorkerRegistration;
+import com.huimv.employment.dao.entity.FeWorkflowDefinition;
+import com.huimv.employment.dao.entity.FeWorkflowStep;
+import com.huimv.employment.dao.mapper.FeEmploymentDraftMapper;
 import com.huimv.employment.dao.mapper.FeEmploymentOrderMapper;
 import com.huimv.employment.dao.mapper.FeRegistrationBatchMapper;
+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.enterprise.EnterpriseService;
+import com.huimv.employment.service.registration.dto.RegistrationBatchDetailResponse;
+import com.huimv.employment.service.registration.dto.RegistrationBatchProgressResponse;
+import com.huimv.employment.service.registration.dto.RegistrationBatchStatsResponse;
+import com.huimv.employment.service.registration.dto.RegistrationBatchStepResponse;
+import com.huimv.employment.service.registration.dto.RegistrationBatchWorkerItemResponse;
 import com.huimv.employment.service.wechat.WeChatMiniAppService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -20,11 +35,15 @@ import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
 import java.util.regex.Pattern;
 
 /**
- * 方案确认后创建登记批次，并立刻生成小程序码写入 {@code fe_registration_batch.qr_code_url}。
- * <p>小程序码 scene = 订单编号，page = pages/worker/job-offer（见微信 getwxacodeunlimit）。</p>
+ * 登记批次：确认方案后创建批次与小程序码；企业端查询进度详情。
+ * <p>办理流程步骤来自启用中的 {@code fe_workflow_definition} + {@code fe_workflow_step}。</p>
  */
 @Service
 public class RegistrationBatchService {
@@ -34,20 +53,48 @@ public class RegistrationBatchService {
     private static final String STATUS_ACTIVE = "active";
     private static final String STEP_REGISTRATION = "registration";
     private static final String PUBLIC_PATH_TEMPLATE = "/api/v1/public/registration-qr/%s.png";
-    /** 订单编号 / 文件名安全字符 */
     private static final Pattern SAFE_SCENE = Pattern.compile("^[A-Za-z0-9_-]{1,32}$");
+    private static final Pattern NUMERIC_ID = Pattern.compile("^\\d+$");
+    private static final DateTimeFormatter STEP_TIME_FMT = DateTimeFormatter.ofPattern("MM-dd HH:mm");
+
+    private static final String STEP_STATUS_DONE = "done";
+    private static final String STEP_STATUS_ACTIVE = "active";
+    private static final String STEP_STATUS_PENDING = "pending";
+
+    private static final String REG_PENDING = "pending";
+    private static final String REG_REGISTERING = "registering";
+    private static final String REG_UNDER_REVIEW = "under_review";
+    private static final String REG_COMPLETED = "completed";
+    private static final String REG_VERIFY_FAILED = "verify_failed";
+
+    private static final String WORKFLOW_CODE_EMPLOYMENT = "employment_compliance";
 
     private final FeRegistrationBatchMapper feRegistrationBatchMapper;
     private final FeEmploymentOrderMapper feEmploymentOrderMapper;
+    private final FeEmploymentDraftMapper feEmploymentDraftMapper;
+    private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
+    private final FeWorkflowDefinitionMapper feWorkflowDefinitionMapper;
+    private final FeWorkflowStepMapper feWorkflowStepMapper;
+    private final EnterpriseService enterpriseService;
     private final WeChatMiniAppService weChatMiniAppService;
     private final RegistrationQrProperties qrProperties;
 
     public RegistrationBatchService(FeRegistrationBatchMapper feRegistrationBatchMapper,
                                     FeEmploymentOrderMapper feEmploymentOrderMapper,
+                                    FeEmploymentDraftMapper feEmploymentDraftMapper,
+                                    FeWorkerRegistrationMapper feWorkerRegistrationMapper,
+                                    FeWorkflowDefinitionMapper feWorkflowDefinitionMapper,
+                                    FeWorkflowStepMapper feWorkflowStepMapper,
+                                    EnterpriseService enterpriseService,
                                     WeChatMiniAppService weChatMiniAppService,
                                     RegistrationQrProperties qrProperties) {
         this.feRegistrationBatchMapper = feRegistrationBatchMapper;
         this.feEmploymentOrderMapper = feEmploymentOrderMapper;
+        this.feEmploymentDraftMapper = feEmploymentDraftMapper;
+        this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
+        this.feWorkflowDefinitionMapper = feWorkflowDefinitionMapper;
+        this.feWorkflowStepMapper = feWorkflowStepMapper;
+        this.enterpriseService = enterpriseService;
         this.weChatMiniAppService = weChatMiniAppService;
         this.qrProperties = qrProperties;
     }
@@ -62,7 +109,6 @@ public class RegistrationBatchService {
         if (!StringUtils.hasText(order.getOrderNo()) || !SAFE_SCENE.matcher(order.getOrderNo().trim()).matches()) {
             throw new BizException(ErrorCode.BAD_REQUEST, "订单编号无效，无法作为小程序码 scene");
         }
-        // getwxacodeunlimit.scene = 订单编号（≤32）
         String scene = order.getOrderNo().trim();
         int validDays = resolveValidDays(draft);
         String page = normalizePage(qrProperties.getPage());
@@ -102,6 +148,93 @@ public class RegistrationBatchService {
         return feRegistrationBatchMapper.selectById(batch.getId());
     }
 
+    /**
+     * 企业端登记进度详情：按草稿 ID 定位订单 → 登记批次。
+     */
+    public RegistrationBatchDetailResponse getDetailByDraftId(Long userId, Long draftId) {
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "企业信息不存在");
+        }
+        if (draftId == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "draft_id 不能为空");
+        }
+        FeEmploymentDraft draft = feEmploymentDraftMapper.selectById(draftId);
+        if (draft == null || !enterprise.getId().equals(draft.getEnterpriseId())) {
+            throw new BizException(ErrorCode.NOT_FOUND, "草稿不存在");
+        }
+        FeEmploymentOrder order = feEmploymentOrderMapper.selectOne(new LambdaQueryWrapper<FeEmploymentOrder>()
+                .eq(FeEmploymentOrder::getDraftId, draftId)
+                .orderByDesc(FeEmploymentOrder::getId)
+                .last("LIMIT 1"));
+        if (order == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "尚未确认方案，暂无登记批次");
+        }
+        FeRegistrationBatch batch = feRegistrationBatchMapper.selectOne(new LambdaQueryWrapper<FeRegistrationBatch>()
+                .eq(FeRegistrationBatch::getOrderId, order.getId())
+                .orderByDesc(FeRegistrationBatch::getId)
+                .last("LIMIT 1"));
+        if (batch == null || !enterprise.getId().equals(batch.getEnterpriseId())) {
+            throw new BizException(ErrorCode.NOT_FOUND, "登记批次不存在");
+        }
+        return toDetailResponse(batch, order, draft);
+    }
+
+    /**
+     * 企业端登记进度详情：按批次主键 ID 或业务编号（如 bat_1）。
+     */
+    public RegistrationBatchDetailResponse getDetail(Long userId, String batchKey) {
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "企业信息不存在");
+        }
+        FeRegistrationBatch batch = requireOwnedBatch(enterprise.getId(), batchKey);
+        FeEmploymentOrder order = feEmploymentOrderMapper.selectById(batch.getOrderId());
+        if (order == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "用工订单不存在");
+        }
+        FeEmploymentDraft draft = order.getDraftId() != null
+                ? feEmploymentDraftMapper.selectById(order.getDraftId()) : null;
+        return toDetailResponse(batch, order, draft);
+    }
+
+    private RegistrationBatchDetailResponse toDetailResponse(FeRegistrationBatch batch,
+                                                             FeEmploymentOrder order,
+                                                             FeEmploymentDraft draft) {
+        List<FeWorkerRegistration> registrations = feWorkerRegistrationMapper.selectList(
+                new LambdaQueryWrapper<FeWorkerRegistration>()
+                        .eq(FeWorkerRegistration::getBatchId, batch.getId())
+                        .orderByAsc(FeWorkerRegistration::getId));
+
+        RegistrationBatchStatsResponse stats = buildStats(batch, registrations);
+        RegistrationBatchProgressResponse progress = buildProgress(stats);
+        List<RegistrationBatchStepResponse> steps = buildSteps(order, draft, progress);
+        List<RegistrationBatchWorkerItemResponse> workers = buildWorkers(registrations);
+
+        String title = StringUtils.hasText(order.getTitle()) ? order.getTitle().trim() : "用工批次";
+        String batchNo = batch.getBatchNo();
+
+        RegistrationBatchDetailResponse response = new RegistrationBatchDetailResponse();
+        response.setBatchId(batch.getId());
+        response.setBatchNo(batchNo);
+        response.setTitle(title);
+        response.setSubtitle(title + (StringUtils.hasText(batchNo) ? " " + batchNo : ""));
+        response.setOrderId(order.getId());
+        response.setOrderNo(order.getOrderNo());
+        response.setStatus(batch.getStatus());
+        response.setQrCodeUrl(batch.getQrCodeUrl());
+        response.setRegistrationUrl(batch.getRegistrationUrl());
+        response.setQrToken(batch.getQrToken());
+        response.setValidFrom(batch.getValidFrom());
+        response.setValidUntil(batch.getValidUntil());
+        response.setCurrentStepCode(order.getCurrentStepCode());
+        response.setStats(stats);
+        response.setProgress(progress);
+        response.setSteps(steps);
+        response.setWorkers(workers);
+        return response;
+    }
+
     /** 按订单编号（scene）读取本地小程序码 PNG；不存在返回 null。 */
     public byte[] readQrPng(String scene) {
         if (!StringUtils.hasText(scene) || !SAFE_SCENE.matcher(scene.trim()).matches()) {
@@ -119,6 +252,243 @@ public class RegistrationBatchService {
         }
     }
 
+    private FeRegistrationBatch requireOwnedBatch(Long enterpriseId, String batchKey) {
+        if (!StringUtils.hasText(batchKey)) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "batch_id 不能为空");
+        }
+        String key = batchKey.trim();
+        FeRegistrationBatch batch = null;
+        if (NUMERIC_ID.matcher(key).matches()) {
+            try {
+                batch = feRegistrationBatchMapper.selectById(Long.parseLong(key));
+            } catch (NumberFormatException ignored) {
+                batch = null;
+            }
+        }
+        if (batch == null) {
+            batch = feRegistrationBatchMapper.selectOne(new LambdaQueryWrapper<FeRegistrationBatch>()
+                    .eq(FeRegistrationBatch::getBatchNo, key)
+                    .orderByDesc(FeRegistrationBatch::getId)
+                    .last("LIMIT 1"));
+        }
+        if (batch == null || !enterpriseId.equals(batch.getEnterpriseId())) {
+            throw new BizException(ErrorCode.NOT_FOUND, "登记批次不存在");
+        }
+        return batch;
+    }
+
+    private RegistrationBatchStatsResponse buildStats(FeRegistrationBatch batch,
+                                                      List<FeWorkerRegistration> registrations) {
+        int expected = batch.getExpectedCount() != null ? batch.getExpectedCount() : 0;
+        int completed = 0;
+        int inProgress = 0;
+        int abnormal = 0;
+        int appliedPending = 0;
+        if (registrations != null) {
+            for (FeWorkerRegistration reg : registrations) {
+                String status = reg.getRegStatus();
+                if (REG_COMPLETED.equals(status)) {
+                    completed++;
+                } else if (REG_VERIFY_FAILED.equals(status)) {
+                    abnormal++;
+                } else if (REG_PENDING.equals(status)) {
+                    appliedPending++;
+                } else {
+                    inProgress++;
+                }
+            }
+        }
+        int applied = registrations != null ? registrations.size() : 0;
+        int pending = Math.max(0, expected - applied) + appliedPending;
+        inProgress = inProgress + abnormal;
+        if (expected <= 0) {
+            expected = pending + inProgress + completed;
+        }
+        int registered = Math.max(0, expected - pending);
+
+        RegistrationBatchStatsResponse stats = new RegistrationBatchStatsResponse();
+        stats.setPendingCount(pending);
+        stats.setInProgressCount(inProgress);
+        stats.setCompletedCount(completed);
+        stats.setAbnormalCount(abnormal);
+        stats.setExpectedCount(expected);
+        stats.setRegisteredCount(registered);
+        return stats;
+    }
+
+    private RegistrationBatchProgressResponse buildProgress(RegistrationBatchStatsResponse stats) {
+        int total = stats.getExpectedCount() != null ? stats.getExpectedCount() : 0;
+        int current = stats.getRegisteredCount() != null ? stats.getRegisteredCount() : 0;
+        int percent = total > 0 ? (int) Math.round(current * 100.0 / total) : 0;
+        if (percent > 100) {
+            percent = 100;
+        }
+        RegistrationBatchProgressResponse progress = new RegistrationBatchProgressResponse();
+        progress.setCurrent(current);
+        progress.setTotal(total);
+        progress.setPercent(percent);
+        return progress;
+    }
+
+    private List<RegistrationBatchStepResponse> buildSteps(FeEmploymentOrder order,
+                                                           FeEmploymentDraft draft,
+                                                           RegistrationBatchProgressResponse progress) {
+        List<FeWorkflowStep> flowSteps = listActiveWorkflowSteps();
+        if (flowSteps.isEmpty()) {
+            log.warn("未配置启用的 fe_workflow_step，进度页办理流程为空");
+            return Collections.emptyList();
+        }
+
+        String currentCode = StringUtils.hasText(order.getCurrentStepCode())
+                ? order.getCurrentStepCode().trim() : STEP_REGISTRATION;
+        int currentIndex = indexOfStep(flowSteps, currentCode);
+        if (currentIndex < 0) {
+            currentIndex = indexOfStep(flowSteps, STEP_REGISTRATION);
+        }
+        if (currentIndex < 0) {
+            currentIndex = 0;
+        }
+
+        List<RegistrationBatchStepResponse> steps = new ArrayList<>();
+        for (int i = 0; i < flowSteps.size(); i++) {
+            FeWorkflowStep def = flowSteps.get(i);
+            String code = def.getStepCode();
+            RegistrationBatchStepResponse step = new RegistrationBatchStepResponse();
+            step.setStepCode(code);
+            step.setTitle(def.getStepName());
+            if (i < currentIndex) {
+                step.setStatus(STEP_STATUS_DONE);
+                step.setTime(resolveStepTime(code, draft, order));
+            } else if (i == currentIndex) {
+                step.setStatus(STEP_STATUS_ACTIVE);
+                if (STEP_REGISTRATION.equals(code) && progress != null) {
+                    step.setHighlight(String.format("进行中 %d/%d",
+                            progress.getCurrent() != null ? progress.getCurrent() : 0,
+                            progress.getTotal() != null ? progress.getTotal() : 0));
+                }
+            } else {
+                step.setStatus(STEP_STATUS_PENDING);
+            }
+            steps.add(step);
+        }
+        return steps;
+    }
+
+    /**
+     * 读取当前启用合规流程下的步骤定义（按 step_order 升序）。
+     */
+    private List<FeWorkflowStep> listActiveWorkflowSteps() {
+        FeWorkflowDefinition definition = feWorkflowDefinitionMapper.selectOne(
+                new LambdaQueryWrapper<FeWorkflowDefinition>()
+                        .eq(FeWorkflowDefinition::getWorkflowCode, WORKFLOW_CODE_EMPLOYMENT)
+                        .eq(FeWorkflowDefinition::getIsActive, Boolean.TRUE)
+                        .orderByDesc(FeWorkflowDefinition::getVersion)
+                        .last("LIMIT 1"));
+        if (definition == null) {
+            // 兼容初始化脚本未显式筛选时：取 employment_compliance 最新版
+            definition = feWorkflowDefinitionMapper.selectOne(
+                    new LambdaQueryWrapper<FeWorkflowDefinition>()
+                            .eq(FeWorkflowDefinition::getWorkflowCode, WORKFLOW_CODE_EMPLOYMENT)
+                            .orderByDesc(FeWorkflowDefinition::getVersion)
+                            .last("LIMIT 1"));
+        }
+        if (definition == null) {
+            definition = feWorkflowDefinitionMapper.selectOne(
+                    new LambdaQueryWrapper<FeWorkflowDefinition>()
+                            .eq(FeWorkflowDefinition::getIsActive, Boolean.TRUE)
+                            .orderByDesc(FeWorkflowDefinition::getVersion)
+                            .last("LIMIT 1"));
+        }
+        if (definition == null) {
+            return Collections.emptyList();
+        }
+        List<FeWorkflowStep> steps = feWorkflowStepMapper.selectList(
+                new LambdaQueryWrapper<FeWorkflowStep>()
+                        .eq(FeWorkflowStep::getWorkflowId, definition.getId())
+                        .orderByAsc(FeWorkflowStep::getStepOrder)
+                        .orderByAsc(FeWorkflowStep::getId));
+        return steps != null ? steps : Collections.<FeWorkflowStep>emptyList();
+    }
+
+    private static int indexOfStep(List<FeWorkflowStep> flowSteps, String stepCode) {
+        if (!StringUtils.hasText(stepCode) || flowSteps == null) {
+            return -1;
+        }
+        for (int i = 0; i < flowSteps.size(); i++) {
+            if (stepCode.equals(flowSteps.get(i).getStepCode())) {
+                return i;
+            }
+        }
+        return -1;
+    }
+
+    private static String resolveStepTime(String stepCode, FeEmploymentDraft draft, FeEmploymentOrder order) {
+        LocalDateTime time = null;
+        if ("draft_created".equals(stepCode) && draft != null) {
+            time = draft.getCreateTime();
+        } else if ("plan_confirmed".equals(stepCode)) {
+            if (draft != null && draft.getConfirmedAt() != null) {
+                time = draft.getConfirmedAt();
+            } else if (order != null) {
+                time = order.getCreateTime();
+            }
+        }
+        return time != null ? STEP_TIME_FMT.format(time) : null;
+    }
+
+    private List<RegistrationBatchWorkerItemResponse> buildWorkers(List<FeWorkerRegistration> registrations) {
+        List<RegistrationBatchWorkerItemResponse> workers = new ArrayList<>();
+        if (registrations == null) {
+            return workers;
+        }
+        for (FeWorkerRegistration reg : registrations) {
+            RegistrationBatchWorkerItemResponse item = new RegistrationBatchWorkerItemResponse();
+            item.setRegistrationId(reg.getId());
+            item.setWorkerId(reg.getWorkerId());
+            item.setRealName(reg.getRealName());
+            item.setMobileMask(reg.getMobileMask());
+            item.setRegStatus(reg.getRegStatus());
+            item.setStatusTag(toStatusTag(reg.getRegStatus()));
+            item.setStatusText(toStatusText(reg.getRegStatus()));
+            item.setFailReason(reg.getFailReason());
+            item.setSubmittedAt(reg.getSubmittedAt());
+            workers.add(item);
+        }
+        return workers;
+    }
+
+    private static String toStatusTag(String regStatus) {
+        if (REG_COMPLETED.equals(regStatus)) {
+            return "done";
+        }
+        if (REG_VERIFY_FAILED.equals(regStatus)) {
+            return "fail";
+        }
+        if (REG_UNDER_REVIEW.equals(regStatus)) {
+            return "review";
+        }
+        if (REG_REGISTERING.equals(regStatus)) {
+            return "registering";
+        }
+        return "pending";
+    }
+
+    private static String toStatusText(String regStatus) {
+        if (REG_COMPLETED.equals(regStatus)) {
+            return "已完成";
+        }
+        if (REG_VERIFY_FAILED.equals(regStatus)) {
+            return "核验失败";
+        }
+        if (REG_UNDER_REVIEW.equals(regStatus)) {
+            return "审核中";
+        }
+        if (REG_REGISTERING.equals(regStatus)) {
+            return "登记中";
+        }
+        return "待登记";
+    }
+
     private void attachQrCode(FeRegistrationBatch batch, String scene, LocalDateTime now) {
         try {
             byte[] png;

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

@@ -0,0 +1,207 @@
+package com.huimv.employment.service.registration.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@Schema(description = "登记批次详情（进度管理）")
+public class RegistrationBatchDetailResponse {
+
+    @JsonProperty("batch_id")
+    @Schema(description = "批次主键 ID")
+    private Long batchId;
+
+    @JsonProperty("batch_no")
+    @Schema(description = "批次业务编号", example = "bat_1")
+    private String batchNo;
+
+    @Schema(description = "批次/订单标题", example = "浦东仓库搬运")
+    private String title;
+
+    @Schema(description = "页头副标题：标题 + 批次号", example = "浦东仓库搬运 bat_1")
+    private String subtitle;
+
+    @JsonProperty("order_id")
+    @Schema(description = "订单主键 ID")
+    private Long orderId;
+
+    @JsonProperty("order_no")
+    @Schema(description = "订单编号")
+    private String orderNo;
+
+    @Schema(description = "批次状态：active / expired / closed")
+    private String status;
+
+    @JsonProperty("qr_code_url")
+    @Schema(description = "小程序码图片 URL")
+    private String qrCodeUrl;
+
+    @JsonProperty("registration_url")
+    @Schema(description = "临时工登记页 path")
+    private String registrationUrl;
+
+    @JsonProperty("qr_token")
+    @Schema(description = "扫码 scene / token")
+    private String qrToken;
+
+    @JsonProperty("valid_from")
+    private LocalDateTime validFrom;
+
+    @JsonProperty("valid_until")
+    private LocalDateTime validUntil;
+
+    @JsonProperty("current_step_code")
+    @Schema(description = "订单当前流程步骤编码")
+    private String currentStepCode;
+
+    @Schema(description = "人数统计（待登记 / 登记中 / 已完成 / 总计）")
+    private RegistrationBatchStatsResponse stats;
+
+    @Schema(description = "登记进度条")
+    private RegistrationBatchProgressResponse progress;
+
+    @Schema(description = "办理流程步骤")
+    private List<RegistrationBatchStepResponse> steps = new ArrayList<>();
+
+    @Schema(description = "人员列表")
+    private List<RegistrationBatchWorkerItemResponse> workers = new ArrayList<>();
+
+    public Long getBatchId() {
+        return batchId;
+    }
+
+    public void setBatchId(Long batchId) {
+        this.batchId = batchId;
+    }
+
+    public String getBatchNo() {
+        return batchNo;
+    }
+
+    public void setBatchNo(String batchNo) {
+        this.batchNo = batchNo;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getSubtitle() {
+        return subtitle;
+    }
+
+    public void setSubtitle(String subtitle) {
+        this.subtitle = subtitle;
+    }
+
+    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 getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getQrCodeUrl() {
+        return qrCodeUrl;
+    }
+
+    public void setQrCodeUrl(String qrCodeUrl) {
+        this.qrCodeUrl = qrCodeUrl;
+    }
+
+    public String getRegistrationUrl() {
+        return registrationUrl;
+    }
+
+    public void setRegistrationUrl(String registrationUrl) {
+        this.registrationUrl = registrationUrl;
+    }
+
+    public String getQrToken() {
+        return qrToken;
+    }
+
+    public void setQrToken(String qrToken) {
+        this.qrToken = qrToken;
+    }
+
+    public LocalDateTime getValidFrom() {
+        return validFrom;
+    }
+
+    public void setValidFrom(LocalDateTime validFrom) {
+        this.validFrom = validFrom;
+    }
+
+    public LocalDateTime getValidUntil() {
+        return validUntil;
+    }
+
+    public void setValidUntil(LocalDateTime validUntil) {
+        this.validUntil = validUntil;
+    }
+
+    public String getCurrentStepCode() {
+        return currentStepCode;
+    }
+
+    public void setCurrentStepCode(String currentStepCode) {
+        this.currentStepCode = currentStepCode;
+    }
+
+    public RegistrationBatchStatsResponse getStats() {
+        return stats;
+    }
+
+    public void setStats(RegistrationBatchStatsResponse stats) {
+        this.stats = stats;
+    }
+
+    public RegistrationBatchProgressResponse getProgress() {
+        return progress;
+    }
+
+    public void setProgress(RegistrationBatchProgressResponse progress) {
+        this.progress = progress;
+    }
+
+    public List<RegistrationBatchStepResponse> getSteps() {
+        return steps;
+    }
+
+    public void setSteps(List<RegistrationBatchStepResponse> steps) {
+        this.steps = steps;
+    }
+
+    public List<RegistrationBatchWorkerItemResponse> getWorkers() {
+        return workers;
+    }
+
+    public void setWorkers(List<RegistrationBatchWorkerItemResponse> workers) {
+        this.workers = workers;
+    }
+}

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

@@ -0,0 +1,40 @@
+package com.huimv.employment.service.registration.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "登记进度（进度条）")
+public class RegistrationBatchProgressResponse {
+
+    @Schema(description = "已进入登记流程人数")
+    private Integer current;
+
+    @Schema(description = "计划总人数")
+    private Integer total;
+
+    @Schema(description = "进度百分比 0-100")
+    private Integer percent;
+
+    public Integer getCurrent() {
+        return current;
+    }
+
+    public void setCurrent(Integer current) {
+        this.current = current;
+    }
+
+    public Integer getTotal() {
+        return total;
+    }
+
+    public void setTotal(Integer total) {
+        this.total = total;
+    }
+
+    public Integer getPercent() {
+        return percent;
+    }
+
+    public void setPercent(Integer percent) {
+        this.percent = percent;
+    }
+}

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

@@ -0,0 +1,80 @@
+package com.huimv.employment.service.registration.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "登记批次人数统计")
+public class RegistrationBatchStatsResponse {
+
+    @JsonProperty("pending_count")
+    @Schema(description = "待登记人数")
+    private Integer pendingCount;
+
+    @JsonProperty("in_progress_count")
+    @Schema(description = "登记中人数（填写中 / 审核中等）")
+    private Integer inProgressCount;
+
+    @JsonProperty("completed_count")
+    @Schema(description = "已完成人数")
+    private Integer completedCount;
+
+    @JsonProperty("abnormal_count")
+    @Schema(description = "异常人数（如核验失败）")
+    private Integer abnormalCount;
+
+    @JsonProperty("expected_count")
+    @Schema(description = "计划总人数")
+    private Integer expectedCount;
+
+    @JsonProperty("registered_count")
+    @Schema(description = "已进入登记流程人数（总计 - 待登记）")
+    private Integer registeredCount;
+
+    public Integer getPendingCount() {
+        return pendingCount;
+    }
+
+    public void setPendingCount(Integer pendingCount) {
+        this.pendingCount = pendingCount;
+    }
+
+    public Integer getInProgressCount() {
+        return inProgressCount;
+    }
+
+    public void setInProgressCount(Integer inProgressCount) {
+        this.inProgressCount = inProgressCount;
+    }
+
+    public Integer getCompletedCount() {
+        return completedCount;
+    }
+
+    public void setCompletedCount(Integer completedCount) {
+        this.completedCount = completedCount;
+    }
+
+    public Integer getAbnormalCount() {
+        return abnormalCount;
+    }
+
+    public void setAbnormalCount(Integer abnormalCount) {
+        this.abnormalCount = abnormalCount;
+    }
+
+    public Integer getExpectedCount() {
+        return expectedCount;
+    }
+
+    public void setExpectedCount(Integer expectedCount) {
+        this.expectedCount = expectedCount;
+    }
+
+    public Integer getRegisteredCount() {
+        return registeredCount;
+    }
+
+    public void setRegisteredCount(Integer registeredCount) {
+        this.registeredCount = registeredCount;
+    }
+}

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

@@ -0,0 +1,64 @@
+package com.huimv.employment.service.registration.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "办理流程步骤")
+public class RegistrationBatchStepResponse {
+
+    @JsonProperty("step_code")
+    @Schema(description = "步骤编码", example = "registration")
+    private String stepCode;
+
+    @Schema(description = "步骤标题", example = "扫码登记")
+    private String title;
+
+    @Schema(description = "步骤状态：done / active / pending", example = "active")
+    private String status;
+
+    @Schema(description = "完成时间展示（MM-dd HH:mm），未完成可为空", example = "01-15 14:30")
+    private String time;
+
+    @Schema(description = "进行中高亮文案，如「进行中 7/10」")
+    private String highlight;
+
+    public String getStepCode() {
+        return stepCode;
+    }
+
+    public void setStepCode(String stepCode) {
+        this.stepCode = stepCode;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
+    public String getHighlight() {
+        return highlight;
+    }
+
+    public void setHighlight(String highlight) {
+        this.highlight = highlight;
+    }
+}

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

@@ -0,0 +1,118 @@
+package com.huimv.employment.service.registration.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.time.LocalDateTime;
+
+@Schema(description = "批次登记人员条目")
+public class RegistrationBatchWorkerItemResponse {
+
+    @JsonProperty("registration_id")
+    @Schema(description = "登记记录 ID")
+    private Long registrationId;
+
+    @JsonProperty("worker_id")
+    @Schema(description = "临时工档案 ID")
+    private Long workerId;
+
+    @JsonProperty("real_name")
+    @Schema(description = "姓名")
+    private String realName;
+
+    @JsonProperty("mobile_mask")
+    @Schema(description = "脱敏手机号", example = "138****1234")
+    private String mobileMask;
+
+    @JsonProperty("reg_status")
+    @Schema(description = "登记状态：pending / registering / under_review / completed / verify_failed")
+    private String regStatus;
+
+    @JsonProperty("status_tag")
+    @Schema(description = "前端状态样式标签：pending / registering / review / done / fail")
+    private String statusTag;
+
+    @JsonProperty("status_text")
+    @Schema(description = "状态中文", example = "已完成")
+    private String statusText;
+
+    @JsonProperty("fail_reason")
+    @Schema(description = "失败原因（核验失败时）")
+    private String failReason;
+
+    @JsonProperty("submitted_at")
+    @Schema(description = "提交时间")
+    private LocalDateTime submittedAt;
+
+    public Long getRegistrationId() {
+        return registrationId;
+    }
+
+    public void setRegistrationId(Long registrationId) {
+        this.registrationId = registrationId;
+    }
+
+    public Long getWorkerId() {
+        return workerId;
+    }
+
+    public void setWorkerId(Long workerId) {
+        this.workerId = workerId;
+    }
+
+    public String getRealName() {
+        return realName;
+    }
+
+    public void setRealName(String realName) {
+        this.realName = realName;
+    }
+
+    public String getMobileMask() {
+        return mobileMask;
+    }
+
+    public void setMobileMask(String mobileMask) {
+        this.mobileMask = mobileMask;
+    }
+
+    public String getRegStatus() {
+        return regStatus;
+    }
+
+    public void setRegStatus(String regStatus) {
+        this.regStatus = regStatus;
+    }
+
+    public String getStatusTag() {
+        return statusTag;
+    }
+
+    public void setStatusTag(String statusTag) {
+        this.statusTag = statusTag;
+    }
+
+    public String getStatusText() {
+        return statusText;
+    }
+
+    public void setStatusText(String statusText) {
+        this.statusText = statusText;
+    }
+
+    public String getFailReason() {
+        return failReason;
+    }
+
+    public void setFailReason(String failReason) {
+        this.failReason = failReason;
+    }
+
+    public LocalDateTime getSubmittedAt() {
+        return submittedAt;
+    }
+
+    public void setSubmittedAt(LocalDateTime submittedAt) {
+        this.submittedAt = submittedAt;
+    }
+}