增加与ai大模型对话

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

@@ -8,25 +8,31 @@ import com.huimv.employment.security.LoginUserHolder;
 import com.huimv.employment.service.registration.WorkerRegistrationService;
 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 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.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
- * 临时工批次登记 / 用工邀请申请加入。
+ * 临时工批次登记 / 用工邀请申请加入；企业审核。
  */
 @RestController
 @RequestMapping("/api/v1/mp/worker-registration")
-@Tag(name = "用工邀请登记", description = "扫码后申请加入用工批次，需临时工 JWT")
+@Tag(name = "用工邀请登记", description = "临时工申请加入；企业审核通过/驳回")
 @SecurityRequirement(name = "Authorization")
 public class WorkerRegistrationController {
 
     private static final String USER_TYPE_WORKER = "worker";
+    private static final String USER_TYPE_ENTERPRISE = "enterprise";
 
     private final WorkerRegistrationService workerRegistrationService;
 
@@ -43,6 +49,33 @@ public class WorkerRegistrationController {
         return R.ok(workerRegistrationService.apply(loginUser.getUserId(), request));
     }
 
+    @PostMapping("/{id}/approve")
+    @Operation(summary = "企业审核通过用工登记",
+            description = "企业主审核 under_review 登记：reg_status→completed，写 reviewed_at/reviewed_by；"
+                    + "批次 completed_count+1；订单若仍为 registration 则推进到 enterprise_audit。",
+            parameters = {
+                    @Parameter(name = "id", in = ParameterIn.PATH, required = true,
+                            description = "fe_worker_registration.id（进度人员列表 registration_id）")
+            })
+    public R<WorkerRegistrationReviewResponse> approve(@PathVariable("id") Long id) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(workerRegistrationService.approve(loginUser.getUserId(), id));
+    }
+
+    @PostMapping("/{id}/reject")
+    @Operation(summary = "企业驳回用工登记",
+            description = "企业主驳回 under_review 登记：reg_status→rejected，必填 fail_reason；"
+                    + "写 reviewed_at/reviewed_by，并释放批次/订单名额。",
+            parameters = {
+                    @Parameter(name = "id", in = ParameterIn.PATH, required = true,
+                            description = "fe_worker_registration.id")
+            })
+    public R<WorkerRegistrationReviewResponse> reject(@PathVariable("id") Long id,
+                                                      @RequestBody(required = false) WorkerRegistrationRejectRequest request) {
+        LoginUser loginUser = requireEnterprise();
+        return R.ok(workerRegistrationService.reject(loginUser.getUserId(), id, request));
+    }
+
     private static LoginUser requireWorker() {
         LoginUser loginUser = LoginUserHolder.require();
         if (!USER_TYPE_WORKER.equals(loginUser.getUserType())) {
@@ -50,4 +83,12 @@ public class WorkerRegistrationController {
         }
         return loginUser;
     }
+
+    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/FeWorkerRegistration.java

@@ -36,7 +36,7 @@ public class FeWorkerRegistration {
 
     private String confirmedWorkType;
 
-    /** pending / registering / completed / verify_failed / under_review */
+    /** pending / registering / completed / verify_failed / under_review / rejected */
     private String regStatus;
 
     private String failReason;

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

@@ -67,6 +67,7 @@ public class RegistrationBatchService {
     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 REG_REJECTED = "rejected";
 
     private static final String WORKFLOW_CODE_EMPLOYMENT = "employment_compliance";
 
@@ -495,7 +496,7 @@ public class RegistrationBatchService {
         if (REG_COMPLETED.equals(regStatus)) {
             return "done";
         }
-        if (REG_VERIFY_FAILED.equals(regStatus)) {
+        if (REG_VERIFY_FAILED.equals(regStatus) || REG_REJECTED.equals(regStatus)) {
             return "fail";
         }
         if (REG_UNDER_REVIEW.equals(regStatus)) {
@@ -511,6 +512,9 @@ public class RegistrationBatchService {
         if (REG_COMPLETED.equals(regStatus)) {
             return "已完成";
         }
+        if (REG_REJECTED.equals(regStatus)) {
+            return "已驳回";
+        }
         if (REG_VERIFY_FAILED.equals(regStatus)) {
             return "核验失败";
         }

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

@@ -4,14 +4,18 @@ 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.FeEmploymentOrder;
+import com.huimv.employment.dao.entity.FeEnterprise;
 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.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.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -20,29 +24,40 @@ import org.springframework.util.StringUtils;
 import java.time.LocalDateTime;
 
 /**
- * 用工邀请 / 批次登记：临时工扫码后申请加入。
+ * 用工邀请 / 批次登记：临时工扫码申请；企业主审核通过/驳回。
  */
 @Service
 public class WorkerRegistrationService {
 
     private static final String BATCH_ACTIVE = "active";
     private static final String REG_UNDER_REVIEW = "under_review";
+    private static final String REG_COMPLETED = "completed";
+    /** 企业审核驳回（与实名核验失败 verify_failed 区分） */
+    private static final String REG_REJECTED = "rejected";
+    private static final String STEP_REGISTRATION = "registration";
+    private static final String STEP_ENTERPRISE_AUDIT = "enterprise_audit";
     private static final String APPLY_SUCCESS = "success";
     private static final String APPLY_ALREADY = "already_applied";
+    private static final String REVIEW_APPROVED = "approved";
+    private static final String REVIEW_REJECTED = "rejected";
+    private static final String REVIEW_ALREADY = "already_reviewed";
 
     private final FeRegistrationBatchMapper feRegistrationBatchMapper;
     private final FeEmploymentOrderMapper feEmploymentOrderMapper;
     private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
     private final WorkerService workerService;
+    private final EnterpriseService enterpriseService;
 
     public WorkerRegistrationService(FeRegistrationBatchMapper feRegistrationBatchMapper,
                                      FeEmploymentOrderMapper feEmploymentOrderMapper,
                                      FeWorkerRegistrationMapper feWorkerRegistrationMapper,
-                                     WorkerService workerService) {
+                                     WorkerService workerService,
+                                     EnterpriseService enterpriseService) {
         this.feRegistrationBatchMapper = feRegistrationBatchMapper;
         this.feEmploymentOrderMapper = feEmploymentOrderMapper;
         this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
         this.workerService = workerService;
+        this.enterpriseService = enterpriseService;
     }
 
     /**
@@ -108,6 +123,186 @@ public class WorkerRegistrationService {
         return toResponse(reg, batch, order, APPLY_SUCCESS, "申请已提交，请等待企业确认");
     }
 
+    /**
+     * 企业审核通过用工登记。
+     * <p>仅 {@code under_review} 可审核；写 reviewed_*，登记置 completed，批次 completed_count+1；
+     * 若订单仍停在 registration 则推进到 enterprise_audit。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public WorkerRegistrationReviewResponse approve(Long userId, Long registrationId) {
+        enterpriseService.requireEnterpriseUser(userId);
+        FeEnterprise enterprise = requireEnterpriseOfUser(userId);
+        FeWorkerRegistration reg = requireOwnedRegistration(enterprise.getId(), registrationId);
+        FeRegistrationBatch batch = requireBatch(reg.getBatchId());
+        FeEmploymentOrder order = requireOrder(reg.getOrderId());
+
+        if (REG_COMPLETED.equals(reg.getRegStatus())) {
+            return toReviewResponse(reg, batch, order, REVIEW_ALREADY, "该登记已审核通过");
+        }
+        if (REG_REJECTED.equals(reg.getRegStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该登记已被驳回，无法再通过");
+        }
+        if (!REG_UNDER_REVIEW.equals(reg.getRegStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "当前状态不可审核：" + reg.getRegStatus());
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+        FeWorkerRegistration update = new FeWorkerRegistration();
+        update.setId(reg.getId());
+        update.setRegStatus(REG_COMPLETED);
+        update.setFailReason(null);
+        update.setReviewedAt(now);
+        update.setReviewedBy(userId);
+        update.setUpdateTime(now);
+        feWorkerRegistrationMapper.updateById(update);
+
+        reg.setRegStatus(REG_COMPLETED);
+        reg.setFailReason(null);
+        reg.setReviewedAt(now);
+        reg.setReviewedBy(userId);
+
+        bumpCompletedCounters(batch, now);
+        maybeAdvanceOrderToEnterpriseAudit(order, now);
+
+        // 回读订单步骤
+        order = feEmploymentOrderMapper.selectById(order.getId());
+        return toReviewResponse(reg, batch, order, REVIEW_APPROVED, "审核通过");
+    }
+
+    /**
+     * 企业驳回用工登记。
+     * <p>仅 {@code under_review} 可驳回；写 fail_reason / reviewed_*，登记置 rejected，并释放名额（registered-1、pending+1）。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public WorkerRegistrationReviewResponse reject(Long userId, Long registrationId,
+                                                   WorkerRegistrationRejectRequest request) {
+        enterpriseService.requireEnterpriseUser(userId);
+        FeEnterprise enterprise = requireEnterpriseOfUser(userId);
+        if (request == null || !StringUtils.hasText(request.getFailReason())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "驳回原因不能为空");
+        }
+        String reason = request.getFailReason().trim();
+        if (reason.length() > 500) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "驳回原因过长");
+        }
+
+        FeWorkerRegistration reg = requireOwnedRegistration(enterprise.getId(), registrationId);
+        FeRegistrationBatch batch = requireBatch(reg.getBatchId());
+        FeEmploymentOrder order = requireOrder(reg.getOrderId());
+
+        if (REG_REJECTED.equals(reg.getRegStatus())) {
+            return toReviewResponse(reg, batch, order, REVIEW_ALREADY, "该登记已驳回");
+        }
+        if (REG_COMPLETED.equals(reg.getRegStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该登记已审核通过，无法驳回");
+        }
+        if (!REG_UNDER_REVIEW.equals(reg.getRegStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "当前状态不可驳回：" + reg.getRegStatus());
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+        FeWorkerRegistration update = new FeWorkerRegistration();
+        update.setId(reg.getId());
+        update.setRegStatus(REG_REJECTED);
+        update.setFailReason(reason);
+        update.setReviewedAt(now);
+        update.setReviewedBy(userId);
+        update.setUpdateTime(now);
+        feWorkerRegistrationMapper.updateById(update);
+
+        reg.setRegStatus(REG_REJECTED);
+        reg.setFailReason(reason);
+        reg.setReviewedAt(now);
+        reg.setReviewedBy(userId);
+
+        releaseSlotCounters(batch, order, now);
+
+        return toReviewResponse(reg, batch, order, REVIEW_REJECTED, "已驳回");
+    }
+
+    private FeEnterprise requireEnterpriseOfUser(Long userId) {
+        FeEnterprise enterprise = enterpriseService.findEnterpriseByUserId(userId);
+        if (enterprise == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "企业信息不存在");
+        }
+        return enterprise;
+    }
+
+    private FeWorkerRegistration requireOwnedRegistration(Long enterpriseId, Long registrationId) {
+        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(enterpriseId)) {
+            throw new BizException(ErrorCode.FORBIDDEN, "无权审核该登记");
+        }
+        return reg;
+    }
+
+    private FeRegistrationBatch requireBatch(Long batchId) {
+        FeRegistrationBatch batch = feRegistrationBatchMapper.selectById(batchId);
+        if (batch == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "登记批次不存在");
+        }
+        return batch;
+    }
+
+    private FeEmploymentOrder requireOrder(Long orderId) {
+        FeEmploymentOrder order = feEmploymentOrderMapper.selectById(orderId);
+        if (order == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "用工订单不存在");
+        }
+        return order;
+    }
+
+    private void bumpCompletedCounters(FeRegistrationBatch batch, LocalDateTime now) {
+        int completed = batch.getCompletedCount() != null ? batch.getCompletedCount() : 0;
+        FeRegistrationBatch update = new FeRegistrationBatch();
+        update.setId(batch.getId());
+        update.setCompletedCount(completed + 1);
+        update.setUpdateTime(now);
+        feRegistrationBatchMapper.updateById(update);
+        batch.setCompletedCount(completed + 1);
+    }
+
+    /**
+     * 驳回后释放名额：申请时 registered+1/pending-1，此处回退。
+     */
+    private void releaseSlotCounters(FeRegistrationBatch batch, FeEmploymentOrder order, LocalDateTime now) {
+        int registered = batch.getRegisteredCount() != null ? batch.getRegisteredCount() : 0;
+        int pending = batch.getPendingCount() != null ? batch.getPendingCount() : 0;
+        FeRegistrationBatch batchUpdate = new FeRegistrationBatch();
+        batchUpdate.setId(batch.getId());
+        batchUpdate.setRegisteredCount(Math.max(0, registered - 1));
+        batchUpdate.setPendingCount(pending + 1);
+        batchUpdate.setUpdateTime(now);
+        feRegistrationBatchMapper.updateById(batchUpdate);
+
+        int orderRegistered = order.getRegisteredCount() != null ? order.getRegisteredCount() : 0;
+        int orderPending = order.getPendingCount() != null ? order.getPendingCount() : 0;
+        FeEmploymentOrder orderUpdate = new FeEmploymentOrder();
+        orderUpdate.setId(order.getId());
+        orderUpdate.setRegisteredCount(Math.max(0, orderRegistered - 1));
+        orderUpdate.setPendingCount(orderPending + 1);
+        orderUpdate.setUpdateTime(now);
+        feEmploymentOrderMapper.updateById(orderUpdate);
+    }
+
+    private void maybeAdvanceOrderToEnterpriseAudit(FeEmploymentOrder order, LocalDateTime now) {
+        String step = order.getCurrentStepCode();
+        if (STEP_REGISTRATION.equals(step) || !StringUtils.hasText(step)) {
+            FeEmploymentOrder update = new FeEmploymentOrder();
+            update.setId(order.getId());
+            update.setCurrentStepCode(STEP_ENTERPRISE_AUDIT);
+            update.setUpdateTime(now);
+            feEmploymentOrderMapper.updateById(update);
+            order.setCurrentStepCode(STEP_ENTERPRISE_AUDIT);
+        }
+    }
+
     private FeRegistrationBatch requireActiveBatchByScene(String scene) {
         FeRegistrationBatch batch = feRegistrationBatchMapper.selectOne(new LambdaQueryWrapper<FeRegistrationBatch>()
                 .eq(FeRegistrationBatch::getQrToken, scene)
@@ -185,4 +380,21 @@ public class WorkerRegistrationService {
         response.setMessage(message);
         return response;
     }
+
+    private static WorkerRegistrationReviewResponse toReviewResponse(FeWorkerRegistration reg,
+                                                                     FeRegistrationBatch batch,
+                                                                     FeEmploymentOrder order,
+                                                                     String status,
+                                                                     String message) {
+        WorkerRegistrationReviewResponse response = new WorkerRegistrationReviewResponse();
+        response.setStatus(status);
+        response.setRegistrationId(reg.getId());
+        response.setBatchNo(batch.getBatchNo());
+        response.setOrderNo(order.getOrderNo());
+        response.setRegStatus(reg.getRegStatus());
+        response.setFailReason(reg.getFailReason());
+        response.setCurrentStepCode(order.getCurrentStepCode());
+        response.setMessage(message);
+        return response;
+    }
 }

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

@@ -0,0 +1,22 @@
+package com.huimv.employment.service.registration.dto;
+
+import com.fasterxml.jackson.annotation.JsonAlias;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "企业驳回用工登记请求")
+public class WorkerRegistrationRejectRequest {
+
+    @JsonProperty("fail_reason")
+    @JsonAlias({"failReason", "reason"})
+    @Schema(description = "驳回原因", example = "身份信息不符", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String failReason;
+
+    public String getFailReason() {
+        return failReason;
+    }
+
+    public void setFailReason(String failReason) {
+        this.failReason = failReason;
+    }
+}

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

@@ -0,0 +1,102 @@
+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 WorkerRegistrationReviewResponse {
+
+    @Schema(description = "处理结果", example = "approved")
+    private String status;
+
+    @JsonProperty("registration_id")
+    @Schema(description = "批次登记记录 ID")
+    private Long registrationId;
+
+    @JsonProperty("batch_no")
+    @Schema(description = "登记批次编号")
+    private String batchNo;
+
+    @JsonProperty("order_no")
+    @Schema(description = "订单编号")
+    private String orderNo;
+
+    @JsonProperty("reg_status")
+    @Schema(description = "登记状态", example = "completed")
+    private String regStatus;
+
+    @JsonProperty("fail_reason")
+    @Schema(description = "驳回原因（仅拒绝时有值）")
+    private String failReason;
+
+    @JsonProperty("current_step_code")
+    @Schema(description = "订单当前办理步骤")
+    private String currentStepCode;
+
+    @Schema(description = "提示文案")
+    private String message;
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public Long getRegistrationId() {
+        return registrationId;
+    }
+
+    public void setRegistrationId(Long registrationId) {
+        this.registrationId = registrationId;
+    }
+
+    public String getBatchNo() {
+        return batchNo;
+    }
+
+    public void setBatchNo(String batchNo) {
+        this.batchNo = batchNo;
+    }
+
+    public String getOrderNo() {
+        return orderNo;
+    }
+
+    public void setOrderNo(String orderNo) {
+        this.orderNo = orderNo;
+    }
+
+    public String getRegStatus() {
+        return regStatus;
+    }
+
+    public void setRegStatus(String regStatus) {
+        this.regStatus = regStatus;
+    }
+
+    public String getFailReason() {
+        return failReason;
+    }
+
+    public void setFailReason(String failReason) {
+        this.failReason = failReason;
+    }
+
+    public String getCurrentStepCode() {
+        return currentStepCode;
+    }
+
+    public void setCurrentStepCode(String currentStepCode) {
+        this.currentStepCode = currentStepCode;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+}