增加与ai大模型对话

doc/灵活用工-mysql.sql

@@ -457,7 +457,7 @@ CREATE TABLE `fe_worker_registration` (
   `id_card_no_enc` TEXT COMMENT '登记身份证密文。可空；高度敏感。',
   `bank_account_enc` TEXT COMMENT '登记银行卡密文。可空；高度敏感。',
   `confirmed_work_type` VARCHAR(100) COMMENT '临时工确认的工种或具体任务描述。提交时勾选或填写。可空。',
-  `reg_status` VARCHAR(20)     NOT NULL DEFAULT 'pending' COMMENT '登记流程状态。枚举：pending=待登记（占位）；registering=填写中；completed=已完成；verify_failed=实名核验失败；under_review=待企业审核。非空，默认 pending。',
+  `reg_status` VARCHAR(20)     NOT NULL DEFAULT 'pending' COMMENT '登记流程状态。枚举：pending=待登记；registering=填写中；under_review=待企业审核；contract_signing=待签约（审核通过）；completed=已完成；verify_failed=实名核验失败；rejected=企业驳回。非空，默认 pending。',
   `fail_reason` TEXT COMMENT '失败或企业驳回原因。可空。',
   `submitted_at` datetime COMMENT '临时工点击提交时间。可空。',
   `reviewed_at` datetime COMMENT '企业审核完成时间。可空。',
@@ -510,6 +510,7 @@ CREATE TABLE `fe_contract` (
   `del_flag` tinyint        NOT NULL DEFAULT 0 COMMENT '逻辑删除标记。枚举：0=正常；1=已删除。非空，默认 0。',
   PRIMARY KEY (`id`),
   UNIQUE KEY `uk_fe_contract_no` (`contract_no`),
+  UNIQUE KEY `uk_fe_contract_registration` (`registration_id`),
   KEY `idx_fe_contract_order` (`order_id`, `sign_status`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='电子劳动合同表，合规流程「合同签署」节点核心数据。一人一登记一条合同；MVP 阶段 sign_provider 可用 mock，对接电子签平台后替换。关联 fe_employment_order、fe_worker_registration、fe_worker。';
 

doc/灵活用工.sql

@@ -500,7 +500,7 @@ CREATE TABLE fe_worker_registration (
     id_card_no_enc      TEXT,
     bank_account_enc    TEXT,
     confirmed_work_type VARCHAR(100),                               -- 工种或任务确认
-    reg_status          VARCHAR(20)     NOT NULL DEFAULT 'pending', -- pending/registering/completed/verify_failed/under_review
+    reg_status          VARCHAR(20)     NOT NULL DEFAULT 'pending', -- pending/registering/under_review/contract_signing/completed/verify_failed/rejected
     fail_reason         TEXT,
     submitted_at        TIMESTAMPTZ,
     reviewed_at         TIMESTAMPTZ,
@@ -557,6 +557,7 @@ CREATE TABLE fe_contract (
     del_flag        SMALLINT        NOT NULL DEFAULT 0
 );
 CREATE UNIQUE INDEX uk_fe_contract_no ON fe_contract (contract_no);
+CREATE UNIQUE INDEX uk_fe_contract_registration ON fe_contract (registration_id);
 CREATE INDEX idx_fe_contract_order ON fe_contract (order_id, sign_status);
 
 
@@ -1138,7 +1139,7 @@ COMMENT ON COLUMN fe_worker_registration.mobile_mask IS '登记手机号脱敏
 COMMENT ON COLUMN fe_worker_registration.id_card_no_enc IS '登记身份证密文。可空；高度敏感。';
 COMMENT ON COLUMN fe_worker_registration.bank_account_enc IS '登记银行卡密文。可空；高度敏感。';
 COMMENT ON COLUMN fe_worker_registration.confirmed_work_type IS '临时工确认的工种或具体任务描述。提交时勾选或填写。可空。';
-COMMENT ON COLUMN fe_worker_registration.reg_status IS '登记流程状态。枚举：pending=待登记（占位）；registering=填写中；completed=已完成；verify_failed=实名核验失败；under_review=待企业审核。非空，默认 pending。';
+COMMENT ON COLUMN fe_worker_registration.reg_status IS '登记流程状态。枚举：pending=待登记；registering=填写中；under_review=待企业审核；contract_signing=待签约（审核通过）；completed=已完成；verify_failed=实名核验失败；rejected=企业驳回。非空，默认 pending。';
 COMMENT ON COLUMN fe_worker_registration.fail_reason IS '失败或企业驳回原因。可空。';
 COMMENT ON COLUMN fe_worker_registration.submitted_at IS '临时工点击提交时间。可空。';
 COMMENT ON COLUMN fe_worker_registration.reviewed_at IS '企业审核完成时间。可空。';

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

@@ -0,0 +1,56 @@
+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.contract.ContractService;
+import com.huimv.employment.service.contract.dto.ContractSummaryResponse;
+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.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 电子合同（企业端）：重新生成待签合同。
+ */
+@RestController
+@RequestMapping("/api/v1/mp/contracts")
+@Tag(name = "电子合同", description = "审核通过后自动生成待签合同；失败可重试")
+@SecurityRequirement(name = "Authorization")
+public class ContractController {
+
+    private static final String USER_TYPE_ENTERPRISE = "enterprise";
+
+    private final ContractService contractService;
+
+    public ContractController(ContractService contractService) {
+        this.contractService = contractService;
+    }
+
+    @PostMapping("/by-registration/{registrationId}/regenerate")
+    @Operation(summary = "重新生成待签合同",
+            description = "电子签失败或签署链接缺失时调用。同一 registration 幂等；已签署不可重生成。",
+            parameters = {
+                    @Parameter(name = "registrationId", in = ParameterIn.PATH, required = true,
+                            description = "fe_worker_registration.id")
+            })
+    public R<ContractSummaryResponse> regenerate(@PathVariable("registrationId") Long registrationId) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(contractService.regeneratePendingContract(loginUser.getUserId(), registrationId));
+    }
+
+    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-api/src/main/java/com/huimv/employment/controller/mp/WorkerRegistrationController.java

@@ -51,9 +51,9 @@ public class WorkerRegistrationController {
 
     @PostMapping("/{id}/approve")
     @Operation(summary = "企业审核通过用工登记",
-            description = "企业主审核 under_review 登记：该人 reg_status→contract_signing（进入签合同）；"
-                    + "写 reviewed_at/reviewed_by；批次 completed_count+1；"
-                    + "订单若尚未签约则推进到 contract_signing（不要求整批审完）。",
+            description = "企业主审核 under_review 登记：该人 reg_status→contract_signing；"
+                    + "自动生成待签电子合同（fe_contract，幂等）；"
+                    + "订单推进到 contract_signing。合同生成失败不影响审核结果，可调用重新生成接口。",
             parameters = {
                     @Parameter(name = "id", in = ParameterIn.PATH, required = true,
                             description = "fe_worker_registration.id（进度人员列表 registration_id）")

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

@@ -0,0 +1,190 @@
+package com.huimv.employment.dao.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.time.LocalDateTime;
+
+/**
+ * 电子合同 {@code fe_contract} 实体。一人一登记一条主合同。
+ */
+@TableName("fe_contract")
+public class FeContract {
+
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    private String contractNo;
+
+    private Long orderId;
+
+    private Long registrationId;
+
+    private Long workerId;
+
+    private Long enterpriseId;
+
+    /** labor / labor_flexible / labor_dispatch 等模板编码 */
+    private String contractType;
+
+    private String contractTitle;
+
+    /** pending / signing / signed / rejected / expired / voided */
+    private String signStatus;
+
+    /** mock / esign_partner */
+    private String signProvider;
+
+    private String externalContractId;
+
+    private String signUrl;
+
+    private LocalDateTime signedAt;
+
+    private String fileUrl;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    @TableLogic
+    private Integer delFlag;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getContractNo() {
+        return contractNo;
+    }
+
+    public void setContractNo(String contractNo) {
+        this.contractNo = contractNo;
+    }
+
+    public Long getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Long orderId) {
+        this.orderId = orderId;
+    }
+
+    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 Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public String getContractType() {
+        return contractType;
+    }
+
+    public void setContractType(String contractType) {
+        this.contractType = contractType;
+    }
+
+    public String getContractTitle() {
+        return contractTitle;
+    }
+
+    public void setContractTitle(String contractTitle) {
+        this.contractTitle = contractTitle;
+    }
+
+    public String getSignStatus() {
+        return signStatus;
+    }
+
+    public void setSignStatus(String signStatus) {
+        this.signStatus = signStatus;
+    }
+
+    public String getSignProvider() {
+        return signProvider;
+    }
+
+    public void setSignProvider(String signProvider) {
+        this.signProvider = signProvider;
+    }
+
+    public String getExternalContractId() {
+        return externalContractId;
+    }
+
+    public void setExternalContractId(String externalContractId) {
+        this.externalContractId = externalContractId;
+    }
+
+    public String getSignUrl() {
+        return signUrl;
+    }
+
+    public void setSignUrl(String signUrl) {
+        this.signUrl = signUrl;
+    }
+
+    public LocalDateTime getSignedAt() {
+        return signedAt;
+    }
+
+    public void setSignedAt(LocalDateTime signedAt) {
+        this.signedAt = signedAt;
+    }
+
+    public String getFileUrl() {
+        return fileUrl;
+    }
+
+    public void setFileUrl(String fileUrl) {
+        this.fileUrl = fileUrl;
+    }
+
+    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;
+    }
+
+    public Integer getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(Integer delFlag) {
+        this.delFlag = delFlag;
+    }
+}

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

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

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/contract/ContractService.java

@@ -0,0 +1,285 @@
+package com.huimv.employment.service.contract;
+
+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.FeContract;
+import com.huimv.employment.dao.entity.FeEmploymentOrder;
+import com.huimv.employment.dao.entity.FeEnterprise;
+import com.huimv.employment.dao.entity.FeServicePlan;
+import com.huimv.employment.dao.entity.FeWorkerRegistration;
+import com.huimv.employment.dao.mapper.FeContractMapper;
+import com.huimv.employment.dao.mapper.FeEmploymentOrderMapper;
+import com.huimv.employment.dao.mapper.FeServicePlanMapper;
+import com.huimv.employment.dao.mapper.FeWorkerRegistrationMapper;
+import com.huimv.employment.service.contract.dto.ContractSummaryResponse;
+import com.huimv.employment.service.enterprise.EnterpriseService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.dao.DuplicateKeyException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.StringUtils;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.concurrent.ThreadLocalRandom;
+
+/**
+ * 电子合同：审核通过后生成待签合同；支持幂等与重新生成。
+ */
+@Service
+public class ContractService {
+
+    private static final Logger log = LoggerFactory.getLogger(ContractService.class);
+
+    private static final String SIGN_PENDING = "pending";
+    private static final String SIGN_SIGNING = "signing";
+    private static final String SIGN_SIGNED = "signed";
+    private static final String SIGN_VOIDED = "voided";
+    private static final String PROVIDER_MOCK = "mock";
+    private static final String REG_CONTRACT_SIGNING = "contract_signing";
+    private static final String REG_COMPLETED = "completed";
+
+    private static final DateTimeFormatter CONTRACT_NO_DAY = DateTimeFormatter.ofPattern("yyyyMMdd");
+
+    private final FeContractMapper feContractMapper;
+    private final FeEmploymentOrderMapper feEmploymentOrderMapper;
+    private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
+    private final FeServicePlanMapper feServicePlanMapper;
+    private final EnterpriseService enterpriseService;
+    private final ESignClient eSignClient;
+
+    public ContractService(FeContractMapper feContractMapper,
+                           FeEmploymentOrderMapper feEmploymentOrderMapper,
+                           FeWorkerRegistrationMapper feWorkerRegistrationMapper,
+                           FeServicePlanMapper feServicePlanMapper,
+                           EnterpriseService enterpriseService,
+                           ESignClient eSignClient) {
+        this.feContractMapper = feContractMapper;
+        this.feEmploymentOrderMapper = feEmploymentOrderMapper;
+        this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
+        this.feServicePlanMapper = feServicePlanMapper;
+        this.enterpriseService = enterpriseService;
+        this.eSignClient = eSignClient;
+    }
+
+    /**
+     * 审核通过后创建或返回已有待签合同（同一 registration_id 幂等）。
+     * <p>电子签调用失败时仍保留 pending 合同记录，便于后续 {@link #regeneratePendingContract}。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public ContractSummaryResponse createOrGetPendingForRegistration(FeWorkerRegistration reg, FeEmploymentOrder order) {
+        if (reg == null || reg.getId() == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "登记记录无效");
+        }
+        if (order == null || order.getId() == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "订单无效");
+        }
+
+        FeContract existing = findActiveByRegistrationId(reg.getId());
+        if (existing != null) {
+            if (needsESignRetry(existing)) {
+                tryFillESign(existing, reg);
+                existing = feContractMapper.selectById(existing.getId());
+            }
+            return toSummary(existing, false, "已存在待签合同");
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+        String contractType = resolveContractType(order);
+        String title = buildContractTitle(contractType, reg.getRealName(), order.getTitle());
+        String contractNo = nextContractNo();
+
+        FeContract contract = new FeContract();
+        contract.setContractNo(contractNo);
+        contract.setOrderId(order.getId());
+        contract.setRegistrationId(reg.getId());
+        contract.setWorkerId(reg.getWorkerId());
+        contract.setEnterpriseId(order.getEnterpriseId() != null ? order.getEnterpriseId() : reg.getEnterpriseId());
+        contract.setContractType(contractType);
+        contract.setContractTitle(title);
+        contract.setSignStatus(SIGN_PENDING);
+        contract.setSignProvider(PROVIDER_MOCK);
+        contract.setCreateTime(now);
+        contract.setUpdateTime(now);
+        contract.setDelFlag(0);
+
+        try {
+            feContractMapper.insert(contract);
+        } catch (DuplicateKeyException ex) {
+            FeContract raced = findActiveByRegistrationId(reg.getId());
+            if (raced != null) {
+                return toSummary(raced, false, "已存在待签合同");
+            }
+            throw new BizException(ErrorCode.BAD_REQUEST, "合同编号冲突，请重试");
+        }
+
+        try {
+            tryFillESign(contract, reg);
+        } catch (Exception ex) {
+            log.error("登记 registrationId={} 电子签创建失败，合同已落库待重试: {}", reg.getId(), ex.getMessage());
+            FeContract saved = feContractMapper.selectById(contract.getId());
+            ContractSummaryResponse response = toSummary(saved, true, "待签合同已创建，电子签通道暂不可用，请稍后重新生成");
+            return response;
+        }
+
+        FeContract saved = feContractMapper.selectById(contract.getId());
+        return toSummary(saved, true, "待签合同已生成");
+    }
+
+    /**
+     * 重新生成签署链接（电子签失败或链接失效时）。
+     * <p>仅允许 pending/signing；已签署不可重生成。无合同记录时按登记补建。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public ContractSummaryResponse regeneratePendingContract(Long userId, Long registrationId) {
+        enterpriseService.requireEnterpriseUser(userId);
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "企业信息不存在");
+        }
+        if (registrationId == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "registration_id 不能为空");
+        }
+
+        FeWorkerRegistration reg = feWorkerRegistrationMapper.selectById(registrationId);
+        if (reg == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "登记记录不存在");
+        }
+        if (reg.getEnterpriseId() == null || !reg.getEnterpriseId().equals(enterprise.getId())) {
+            throw new BizException(ErrorCode.FORBIDDEN, "无权操作该登记合同");
+        }
+        if (!REG_CONTRACT_SIGNING.equals(reg.getRegStatus()) && !REG_COMPLETED.equals(reg.getRegStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "仅审核通过待签约的登记可重新生成合同");
+        }
+
+        FeEmploymentOrder order = feEmploymentOrderMapper.selectById(reg.getOrderId());
+        if (order == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "用工订单不存在");
+        }
+
+        FeContract contract = findActiveByRegistrationId(registrationId);
+        if (contract == null) {
+            return createOrGetPendingForRegistration(reg, order);
+        }
+        if (SIGN_SIGNED.equals(contract.getSignStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "合同已签署，无法重新生成");
+        }
+        if (SIGN_VOIDED.equals(contract.getSignStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "合同已作废，无法重新生成");
+        }
+        if (!SIGN_PENDING.equals(contract.getSignStatus()) && !SIGN_SIGNING.equals(contract.getSignStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "当前签署状态不可重新生成：" + contract.getSignStatus());
+        }
+
+        tryFillESign(contract, reg);
+        FeContract saved = feContractMapper.selectById(contract.getId());
+        return toSummary(saved, false, "签署链接已重新生成");
+    }
+
+    public FeContract findActiveByRegistrationId(Long registrationId) {
+        if (registrationId == null) {
+            return null;
+        }
+        return feContractMapper.selectOne(new LambdaQueryWrapper<FeContract>()
+                .eq(FeContract::getRegistrationId, registrationId)
+                .ne(FeContract::getSignStatus, SIGN_VOIDED)
+                .orderByDesc(FeContract::getId)
+                .last("LIMIT 1"));
+    }
+
+    private void tryFillESign(FeContract contract, FeWorkerRegistration reg) {
+        ESignClient.ESignCreateResult result = eSignClient.createPendingContract(
+                contract.getContractNo(),
+                contract.getContractType(),
+                contract.getContractTitle(),
+                reg != null ? reg.getRealName() : null);
+        FeContract update = new FeContract();
+        update.setId(contract.getId());
+        update.setExternalContractId(result.getExternalContractId());
+        update.setSignUrl(result.getSignUrl());
+        update.setSignProvider(PROVIDER_MOCK);
+        update.setSignStatus(SIGN_PENDING);
+        update.setUpdateTime(LocalDateTime.now());
+        feContractMapper.updateById(update);
+        contract.setExternalContractId(result.getExternalContractId());
+        contract.setSignUrl(result.getSignUrl());
+    }
+
+    private static boolean needsESignRetry(FeContract contract) {
+        if (contract == null) {
+            return false;
+        }
+        if (SIGN_SIGNED.equals(contract.getSignStatus()) || SIGN_VOIDED.equals(contract.getSignStatus())) {
+            return false;
+        }
+        return !StringUtils.hasText(contract.getSignUrl()) || !StringUtils.hasText(contract.getExternalContractId());
+    }
+
+    /**
+     * 按订单所选方案类型选择合同模板编码。
+     */
+    private String resolveContractType(FeEmploymentOrder order) {
+        if (order.getSelectedPlanId() == null) {
+            return "labor";
+        }
+        FeServicePlan plan = feServicePlanMapper.selectById(order.getSelectedPlanId());
+        if (plan == null || !StringUtils.hasText(plan.getPlanType())) {
+            return "labor";
+        }
+        String planType = plan.getPlanType().trim().toLowerCase();
+        if ("flexible".equals(planType)) {
+            return "labor_flexible";
+        }
+        if ("traditional".equals(planType)) {
+            return "labor_dispatch";
+        }
+        if ("hybrid".equals(planType)) {
+            return "labor_hybrid";
+        }
+        return "labor";
+    }
+
+    private static String buildContractTitle(String contractType, String workerName, String orderTitle) {
+        String typeLabel;
+        if ("labor_flexible".equals(contractType)) {
+            typeLabel = "灵活用工协议";
+        } else if ("labor_dispatch".equals(contractType)) {
+            typeLabel = "劳务派遣协议";
+        } else if ("labor_hybrid".equals(contractType)) {
+            typeLabel = "混合用工协议";
+        } else {
+            typeLabel = "劳动合同";
+        }
+        String name = StringUtils.hasText(workerName) ? workerName.trim() : "临时工";
+        if (StringUtils.hasText(orderTitle)) {
+            return typeLabel + "-" + name + "-" + orderTitle.trim();
+        }
+        return typeLabel + "-" + name;
+    }
+
+    private String nextContractNo() {
+        String day = LocalDateTime.now().format(CONTRACT_NO_DAY);
+        int rand = ThreadLocalRandom.current().nextInt(1000, 10000);
+        return "CT" + day + rand;
+    }
+
+    private static ContractSummaryResponse toSummary(FeContract contract, boolean created, String message) {
+        ContractSummaryResponse response = new ContractSummaryResponse();
+        if (contract != null) {
+            response.setContractId(contract.getId());
+            response.setContractNo(contract.getContractNo());
+            response.setRegistrationId(contract.getRegistrationId());
+            response.setContractType(contract.getContractType());
+            response.setContractTitle(contract.getContractTitle());
+            response.setSignStatus(contract.getSignStatus());
+            response.setSignProvider(contract.getSignProvider());
+            response.setSignUrl(contract.getSignUrl());
+            response.setExternalContractId(contract.getExternalContractId());
+        }
+        response.setCreated(created);
+        response.setMessage(message);
+        return response;
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/contract/ESignClient.java

@@ -0,0 +1,36 @@
+package com.huimv.employment.service.contract;
+
+/**
+ * 电子签平台客户端。生产替换为厂商实现；开发态用 Mock。
+ */
+public interface ESignClient {
+
+    /**
+     * 创建待签合同。
+     *
+     * @param contractNo   业务合同号
+     * @param contractType 模板/类型编码
+     * @param title        合同标题
+     * @param workerName   工人姓名
+     * @return 平台返回的外部合同 ID 与签署链接
+     */
+    ESignCreateResult createPendingContract(String contractNo, String contractType, String title, String workerName);
+
+    class ESignCreateResult {
+        private final String externalContractId;
+        private final String signUrl;
+
+        public ESignCreateResult(String externalContractId, String signUrl) {
+            this.externalContractId = externalContractId;
+            this.signUrl = signUrl;
+        }
+
+        public String getExternalContractId() {
+            return externalContractId;
+        }
+
+        public String getSignUrl() {
+            return signUrl;
+        }
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/contract/MockESignClient.java

@@ -0,0 +1,20 @@
+package com.huimv.employment.service.contract;
+
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+/**
+ * 开发态电子签 Stub：不调用外部平台，生成可联调的 mock 签署链接。
+ */
+@Component
+public class MockESignClient implements ESignClient {
+
+    @Override
+    public ESignCreateResult createPendingContract(String contractNo, String contractType, String title, String workerName) {
+        String no = StringUtils.hasText(contractNo) ? contractNo.trim() : "UNKNOWN";
+        String externalId = "MOCK-" + no;
+        String signUrl = "https://mock-esign.local/sign?contractNo=" + no
+                + "&type=" + (StringUtils.hasText(contractType) ? contractType : "labor");
+        return new ESignCreateResult(externalId, signUrl);
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/contract/dto/ContractSummaryResponse.java

@@ -0,0 +1,129 @@
+package com.huimv.employment.service.contract.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "待签合同摘要")
+public class ContractSummaryResponse {
+
+    @JsonProperty("contract_id")
+    private Long contractId;
+
+    @JsonProperty("contract_no")
+    private String contractNo;
+
+    @JsonProperty("registration_id")
+    private Long registrationId;
+
+    @JsonProperty("contract_type")
+    private String contractType;
+
+    @JsonProperty("contract_title")
+    private String contractTitle;
+
+    @JsonProperty("sign_status")
+    private String signStatus;
+
+    @JsonProperty("sign_provider")
+    private String signProvider;
+
+    @JsonProperty("sign_url")
+    private String signUrl;
+
+    @JsonProperty("external_contract_id")
+    private String externalContractId;
+
+    @Schema(description = "是否本次新创建")
+    private Boolean created;
+
+    @Schema(description = "提示")
+    private String message;
+
+    public Long getContractId() {
+        return contractId;
+    }
+
+    public void setContractId(Long contractId) {
+        this.contractId = contractId;
+    }
+
+    public String getContractNo() {
+        return contractNo;
+    }
+
+    public void setContractNo(String contractNo) {
+        this.contractNo = contractNo;
+    }
+
+    public Long getRegistrationId() {
+        return registrationId;
+    }
+
+    public void setRegistrationId(Long registrationId) {
+        this.registrationId = registrationId;
+    }
+
+    public String getContractType() {
+        return contractType;
+    }
+
+    public void setContractType(String contractType) {
+        this.contractType = contractType;
+    }
+
+    public String getContractTitle() {
+        return contractTitle;
+    }
+
+    public void setContractTitle(String contractTitle) {
+        this.contractTitle = contractTitle;
+    }
+
+    public String getSignStatus() {
+        return signStatus;
+    }
+
+    public void setSignStatus(String signStatus) {
+        this.signStatus = signStatus;
+    }
+
+    public String getSignProvider() {
+        return signProvider;
+    }
+
+    public void setSignProvider(String signProvider) {
+        this.signProvider = signProvider;
+    }
+
+    public String getSignUrl() {
+        return signUrl;
+    }
+
+    public void setSignUrl(String signUrl) {
+        this.signUrl = signUrl;
+    }
+
+    public String getExternalContractId() {
+        return externalContractId;
+    }
+
+    public void setExternalContractId(String externalContractId) {
+        this.externalContractId = externalContractId;
+    }
+
+    public Boolean getCreated() {
+        return created;
+    }
+
+    public void setCreated(Boolean created) {
+        this.created = created;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+}

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

@@ -5,18 +5,23 @@ import com.huimv.employment.common.exception.BizException;
 import com.huimv.employment.common.exception.ErrorCode;
 import com.huimv.employment.dao.entity.FeEmploymentOrder;
 import com.huimv.employment.dao.entity.FeEnterprise;
+import com.huimv.employment.dao.entity.FeContract;
 import com.huimv.employment.dao.entity.FeRegistrationBatch;
 import com.huimv.employment.dao.entity.FeWorker;
 import com.huimv.employment.dao.entity.FeWorkerRegistration;
 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.service.contract.ContractService;
+import com.huimv.employment.service.contract.dto.ContractSummaryResponse;
 import com.huimv.employment.service.enterprise.EnterpriseService;
 import com.huimv.employment.service.registration.dto.WorkerRegistrationApplyRequest;
 import com.huimv.employment.service.registration.dto.WorkerRegistrationApplyResponse;
 import com.huimv.employment.service.registration.dto.WorkerRegistrationRejectRequest;
 import com.huimv.employment.service.registration.dto.WorkerRegistrationReviewResponse;
 import com.huimv.employment.service.worker.WorkerService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
@@ -29,6 +34,8 @@ import java.time.LocalDateTime;
 @Service
 public class WorkerRegistrationService {
 
+    private static final Logger log = LoggerFactory.getLogger(WorkerRegistrationService.class);
+
     private static final String BATCH_ACTIVE = "active";
     private static final String REG_UNDER_REVIEW = "under_review";
     /** 审核通过后进入个人签合同阶段 */
@@ -52,17 +59,20 @@ public class WorkerRegistrationService {
     private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
     private final WorkerService workerService;
     private final EnterpriseService enterpriseService;
+    private final ContractService contractService;
 
     public WorkerRegistrationService(FeRegistrationBatchMapper feRegistrationBatchMapper,
                                      FeEmploymentOrderMapper feEmploymentOrderMapper,
                                      FeWorkerRegistrationMapper feWorkerRegistrationMapper,
                                      WorkerService workerService,
-                                     EnterpriseService enterpriseService) {
+                                     EnterpriseService enterpriseService,
+                                     ContractService contractService) {
         this.feRegistrationBatchMapper = feRegistrationBatchMapper;
         this.feEmploymentOrderMapper = feEmploymentOrderMapper;
         this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
         this.workerService = workerService;
         this.enterpriseService = enterpriseService;
+        this.contractService = contractService;
     }
 
     /**
@@ -142,7 +152,10 @@ public class WorkerRegistrationService {
         FeEmploymentOrder order = requireOrder(reg.getOrderId());
 
         if (REG_CONTRACT_SIGNING.equals(reg.getRegStatus()) || REG_COMPLETED.equals(reg.getRegStatus())) {
-            return toReviewResponse(reg, batch, order, REVIEW_ALREADY, "该登记已审核通过");
+            order = feEmploymentOrderMapper.selectById(order.getId());
+            WorkerRegistrationReviewResponse already = toReviewResponse(reg, batch, order, REVIEW_ALREADY, "该登记已审核通过");
+            attachContract(already, reg.getId());
+            return already;
         }
         if (REG_REJECTED.equals(reg.getRegStatus())) {
             throw new BizException(ErrorCode.BAD_REQUEST, "该登记已被驳回，无法再通过");
@@ -170,7 +183,23 @@ public class WorkerRegistrationService {
         maybeAdvanceOrderToContractSigning(order, now);
 
         order = feEmploymentOrderMapper.selectById(order.getId());
-        return toReviewResponse(reg, batch, order, REVIEW_APPROVED, "审核通过，已进入合同签署");
+        WorkerRegistrationReviewResponse response = toReviewResponse(reg, batch, order, REVIEW_APPROVED, "审核通过，已进入合同签署");
+        try {
+            ContractSummaryResponse contract = contractService.createOrGetPendingForRegistration(reg, order);
+            fillContractFields(response, contract);
+            if (contract != null && Boolean.TRUE.equals(contract.getCreated())
+                    && StringUtils.hasText(contract.getSignUrl())) {
+                response.setMessage("审核通过，待签合同已生成");
+            } else if (contract != null && !StringUtils.hasText(contract.getSignUrl())) {
+                response.setMessage("审核通过，待签合同已创建但签署链接未就绪，请重新生成");
+                response.setContractCreateFailed(Boolean.TRUE);
+            }
+        } catch (Exception ex) {
+            log.error("登记 registrationId={} 自动生成待签合同失败", reg.getId(), ex);
+            response.setMessage("审核通过，待签合同生成失败，请重新生成");
+            response.setContractCreateFailed(Boolean.TRUE);
+        }
+        return response;
     }
 
     /**
@@ -451,4 +480,30 @@ public class WorkerRegistrationService {
         response.setMessage(message);
         return response;
     }
+
+    private void attachContract(WorkerRegistrationReviewResponse response, Long registrationId) {
+        try {
+            FeContract existing = contractService.findActiveByRegistrationId(registrationId);
+            if (existing != null) {
+                response.setContractId(existing.getId());
+                response.setContractNo(existing.getContractNo());
+                response.setSignStatus(existing.getSignStatus());
+                response.setSignUrl(existing.getSignUrl());
+                response.setContractType(existing.getContractType());
+            }
+        } catch (Exception ignored) {
+            // ignore attach failure
+        }
+    }
+
+    private static void fillContractFields(WorkerRegistrationReviewResponse response, ContractSummaryResponse contract) {
+        if (response == null || contract == null) {
+            return;
+        }
+        response.setContractId(contract.getContractId());
+        response.setContractNo(contract.getContractNo());
+        response.setSignStatus(contract.getSignStatus());
+        response.setSignUrl(contract.getSignUrl());
+        response.setContractType(contract.getContractType());
+    }
 }

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

@@ -22,7 +22,7 @@ public class WorkerRegistrationReviewResponse {
     private String orderNo;
 
     @JsonProperty("reg_status")
-    @Schema(description = "登记状态", example = "completed")
+    @Schema(description = "登记状态", example = "contract_signing")
     private String regStatus;
 
     @JsonProperty("fail_reason")
@@ -33,6 +33,30 @@ public class WorkerRegistrationReviewResponse {
     @Schema(description = "订单当前办理步骤")
     private String currentStepCode;
 
+    @JsonProperty("contract_id")
+    @Schema(description = "待签合同 ID")
+    private Long contractId;
+
+    @JsonProperty("contract_no")
+    @Schema(description = "合同编号")
+    private String contractNo;
+
+    @JsonProperty("contract_type")
+    @Schema(description = "合同模板类型")
+    private String contractType;
+
+    @JsonProperty("sign_status")
+    @Schema(description = "签署状态", example = "pending")
+    private String signStatus;
+
+    @JsonProperty("sign_url")
+    @Schema(description = "签署链接")
+    private String signUrl;
+
+    @JsonProperty("contract_create_failed")
+    @Schema(description = "待签合同生成是否失败（可重新生成）")
+    private Boolean contractCreateFailed;
+
     @Schema(description = "提示文案")
     private String message;
 
@@ -92,6 +116,54 @@ public class WorkerRegistrationReviewResponse {
         this.currentStepCode = currentStepCode;
     }
 
+    public Long getContractId() {
+        return contractId;
+    }
+
+    public void setContractId(Long contractId) {
+        this.contractId = contractId;
+    }
+
+    public String getContractNo() {
+        return contractNo;
+    }
+
+    public void setContractNo(String contractNo) {
+        this.contractNo = contractNo;
+    }
+
+    public String getContractType() {
+        return contractType;
+    }
+
+    public void setContractType(String contractType) {
+        this.contractType = contractType;
+    }
+
+    public String getSignStatus() {
+        return signStatus;
+    }
+
+    public void setSignStatus(String signStatus) {
+        this.signStatus = signStatus;
+    }
+
+    public String getSignUrl() {
+        return signUrl;
+    }
+
+    public void setSignUrl(String signUrl) {
+        this.signUrl = signUrl;
+    }
+
+    public Boolean getContractCreateFailed() {
+        return contractCreateFailed;
+    }
+
+    public void setContractCreateFailed(Boolean contractCreateFailed) {
+        this.contractCreateFailed = contractCreateFailed;
+    }
+
     public String getMessage() {
         return message;
     }