增加与ai大模型对话

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

@@ -0,0 +1,53 @@
+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.WorkerRegistrationService;
+import com.huimv.employment.service.registration.dto.WorkerRegistrationApplyRequest;
+import com.huimv.employment.service.registration.dto.WorkerRegistrationApplyResponse;
+import io.swagger.v3.oas.annotations.Operation;
+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.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")
+@SecurityRequirement(name = "Authorization")
+public class WorkerRegistrationController {
+
+    private static final String USER_TYPE_WORKER = "worker";
+
+    private final WorkerRegistrationService workerRegistrationService;
+
+    public WorkerRegistrationController(WorkerRegistrationService workerRegistrationService) {
+        this.workerRegistrationService = workerRegistrationService;
+    }
+
+    @PostMapping("/apply")
+    @Operation(summary = "申请加入用工邀请",
+            description = "临时工扫码进入用工邀约后调用。body.scene 为小程序码参数（订单编号）。"
+                    + "需已完成档案登记；写入 fe_worker_registration（reg_status=under_review）。")
+    public R<WorkerRegistrationApplyResponse> apply(@Validated @RequestBody WorkerRegistrationApplyRequest request) {
+        LoginUser loginUser = requireWorker();
+        return R.ok(workerRegistrationService.apply(loginUser.getUserId(), request));
+    }
+
+    private static LoginUser requireWorker() {
+        LoginUser loginUser = LoginUserHolder.require();
+        if (!USER_TYPE_WORKER.equals(loginUser.getUserType())) {
+            throw new BizException(ErrorCode.WORKER_ONLY);
+        }
+        return loginUser;
+    }
+}

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

@@ -0,0 +1,228 @@
+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_worker_registration} 实体。
+ */
+@TableName("fe_worker_registration")
+public class FeWorkerRegistration {
+
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    private Long batchId;
+
+    private Long orderId;
+
+    private Long enterpriseId;
+
+    private Long workerId;
+
+    private String realName;
+
+    private String mobileEnc;
+
+    private String mobileMask;
+
+    private String idCardNoEnc;
+
+    private String bankAccountEnc;
+
+    private String confirmedWorkType;
+
+    /** pending / registering / completed / verify_failed / under_review */
+    private String regStatus;
+
+    private String failReason;
+
+    private LocalDateTime submittedAt;
+
+    private LocalDateTime reviewedAt;
+
+    private Long reviewedBy;
+
+    private Integer remindCount;
+
+    private LocalDateTime lastRemindAt;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    @TableLogic
+    private Integer delFlag;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getBatchId() {
+        return batchId;
+    }
+
+    public void setBatchId(Long batchId) {
+        this.batchId = batchId;
+    }
+
+    public Long getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Long orderId) {
+        this.orderId = orderId;
+    }
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    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 getMobileEnc() {
+        return mobileEnc;
+    }
+
+    public void setMobileEnc(String mobileEnc) {
+        this.mobileEnc = mobileEnc;
+    }
+
+    public String getMobileMask() {
+        return mobileMask;
+    }
+
+    public void setMobileMask(String mobileMask) {
+        this.mobileMask = mobileMask;
+    }
+
+    public String getIdCardNoEnc() {
+        return idCardNoEnc;
+    }
+
+    public void setIdCardNoEnc(String idCardNoEnc) {
+        this.idCardNoEnc = idCardNoEnc;
+    }
+
+    public String getBankAccountEnc() {
+        return bankAccountEnc;
+    }
+
+    public void setBankAccountEnc(String bankAccountEnc) {
+        this.bankAccountEnc = bankAccountEnc;
+    }
+
+    public String getConfirmedWorkType() {
+        return confirmedWorkType;
+    }
+
+    public void setConfirmedWorkType(String confirmedWorkType) {
+        this.confirmedWorkType = confirmedWorkType;
+    }
+
+    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 LocalDateTime getSubmittedAt() {
+        return submittedAt;
+    }
+
+    public void setSubmittedAt(LocalDateTime submittedAt) {
+        this.submittedAt = submittedAt;
+    }
+
+    public LocalDateTime getReviewedAt() {
+        return reviewedAt;
+    }
+
+    public void setReviewedAt(LocalDateTime reviewedAt) {
+        this.reviewedAt = reviewedAt;
+    }
+
+    public Long getReviewedBy() {
+        return reviewedBy;
+    }
+
+    public void setReviewedBy(Long reviewedBy) {
+        this.reviewedBy = reviewedBy;
+    }
+
+    public Integer getRemindCount() {
+        return remindCount;
+    }
+
+    public void setRemindCount(Integer remindCount) {
+        this.remindCount = remindCount;
+    }
+
+    public LocalDateTime getLastRemindAt() {
+        return lastRemindAt;
+    }
+
+    public void setLastRemindAt(LocalDateTime lastRemindAt) {
+        this.lastRemindAt = lastRemindAt;
+    }
+
+    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/FeWorkerRegistrationMapper.java

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

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

@@ -0,0 +1,188 @@
+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.FeEmploymentOrder;
+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.registration.dto.WorkerRegistrationApplyRequest;
+import com.huimv.employment.service.registration.dto.WorkerRegistrationApplyResponse;
+import com.huimv.employment.service.worker.WorkerService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+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 APPLY_SUCCESS = "success";
+    private static final String APPLY_ALREADY = "already_applied";
+
+    private final FeRegistrationBatchMapper feRegistrationBatchMapper;
+    private final FeEmploymentOrderMapper feEmploymentOrderMapper;
+    private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
+    private final WorkerService workerService;
+
+    public WorkerRegistrationService(FeRegistrationBatchMapper feRegistrationBatchMapper,
+                                     FeEmploymentOrderMapper feEmploymentOrderMapper,
+                                     FeWorkerRegistrationMapper feWorkerRegistrationMapper,
+                                     WorkerService workerService) {
+        this.feRegistrationBatchMapper = feRegistrationBatchMapper;
+        this.feEmploymentOrderMapper = feEmploymentOrderMapper;
+        this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
+        this.workerService = workerService;
+    }
+
+    /**
+     * 临时工申请加入用工邀请（scene = 订单编号）。
+     * <p>要求已完成档案登记（{@code fe_worker}）。同一批次重复申请返回已有记录。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public WorkerRegistrationApplyResponse apply(Long userId, WorkerRegistrationApplyRequest request) {
+        workerService.requireWorkerUser(userId);
+        if (request == null || !StringUtils.hasText(request.getScene())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "scene 不能为空");
+        }
+        FeWorker worker = workerService.findWorkerByUserId(userId);
+        if (worker == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "请先完成临时工档案登记");
+        }
+
+        String scene = request.getScene().trim();
+        FeRegistrationBatch batch = requireActiveBatchByScene(scene);
+        FeEmploymentOrder order = feEmploymentOrderMapper.selectById(batch.getOrderId());
+        if (order == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "用工订单不存在");
+        }
+
+        FeWorkerRegistration existing = feWorkerRegistrationMapper.selectOne(new LambdaQueryWrapper<FeWorkerRegistration>()
+                .eq(FeWorkerRegistration::getBatchId, batch.getId())
+                .eq(FeWorkerRegistration::getWorkerId, worker.getId())
+                .orderByDesc(FeWorkerRegistration::getId)
+                .last("LIMIT 1"));
+        if (existing != null) {
+            return toResponse(existing, batch, order, APPLY_ALREADY, "您已申请加入该用工，请等待企业确认");
+        }
+
+        assertBatchHasCapacity(batch);
+
+        LocalDateTime now = LocalDateTime.now();
+        FeWorkerRegistration reg = new FeWorkerRegistration();
+        reg.setBatchId(batch.getId());
+        reg.setOrderId(order.getId());
+        reg.setEnterpriseId(batch.getEnterpriseId());
+        reg.setWorkerId(worker.getId());
+        reg.setRealName(worker.getRealName());
+        reg.setMobileEnc(worker.getMobileEnc());
+        reg.setMobileMask(worker.getMobileMask());
+        reg.setIdCardNoEnc(worker.getIdCardNoEnc());
+        reg.setBankAccountEnc(worker.getBankAccountEnc());
+        if (StringUtils.hasText(request.getConfirmedWorkType())) {
+            reg.setConfirmedWorkType(request.getConfirmedWorkType().trim());
+        } else if (StringUtils.hasText(order.getWorkType())) {
+            reg.setConfirmedWorkType(order.getWorkType());
+        }
+        reg.setRegStatus(REG_UNDER_REVIEW);
+        reg.setSubmittedAt(now);
+        reg.setRemindCount(0);
+        reg.setCreateTime(now);
+        reg.setUpdateTime(now);
+        reg.setDelFlag(0);
+        feWorkerRegistrationMapper.insert(reg);
+
+        bumpBatchCounters(batch, now);
+        bumpOrderCounters(order, now);
+
+        return toResponse(reg, batch, order, APPLY_SUCCESS, "申请已提交，请等待企业确认");
+    }
+
+    private FeRegistrationBatch requireActiveBatchByScene(String scene) {
+        FeRegistrationBatch batch = feRegistrationBatchMapper.selectOne(new LambdaQueryWrapper<FeRegistrationBatch>()
+                .eq(FeRegistrationBatch::getQrToken, scene)
+                .orderByDesc(FeRegistrationBatch::getId)
+                .last("LIMIT 1"));
+        if (batch == null) {
+            FeEmploymentOrder order = feEmploymentOrderMapper.selectOne(new LambdaQueryWrapper<FeEmploymentOrder>()
+                    .eq(FeEmploymentOrder::getOrderNo, scene)
+                    .orderByDesc(FeEmploymentOrder::getId)
+                    .last("LIMIT 1"));
+            if (order != null) {
+                batch = feRegistrationBatchMapper.selectOne(new LambdaQueryWrapper<FeRegistrationBatch>()
+                        .eq(FeRegistrationBatch::getOrderId, order.getId())
+                        .orderByDesc(FeRegistrationBatch::getId)
+                        .last("LIMIT 1"));
+            }
+        }
+        if (batch == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "未找到对应用工邀请");
+        }
+        if (!BATCH_ACTIVE.equals(batch.getStatus())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该用工邀请已关闭或失效");
+        }
+        LocalDateTime now = LocalDateTime.now();
+        if (batch.getValidUntil() != null && now.isAfter(batch.getValidUntil())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该用工邀请已过期");
+        }
+        if (batch.getValidFrom() != null && now.isBefore(batch.getValidFrom())) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该用工邀请尚未生效");
+        }
+        return batch;
+    }
+
+    private void assertBatchHasCapacity(FeRegistrationBatch batch) {
+        int expected = batch.getExpectedCount() != null ? batch.getExpectedCount() : 0;
+        int registered = batch.getRegisteredCount() != null ? batch.getRegisteredCount() : 0;
+        if (expected > 0 && registered >= expected) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "该用工名额已满");
+        }
+    }
+
+    private void bumpBatchCounters(FeRegistrationBatch batch, LocalDateTime now) {
+        int registered = batch.getRegisteredCount() != null ? batch.getRegisteredCount() : 0;
+        int pending = batch.getPendingCount() != null ? batch.getPendingCount() : 0;
+        FeRegistrationBatch update = new FeRegistrationBatch();
+        update.setId(batch.getId());
+        update.setRegisteredCount(registered + 1);
+        update.setPendingCount(Math.max(0, pending - 1));
+        update.setUpdateTime(now);
+        feRegistrationBatchMapper.updateById(update);
+    }
+
+    private void bumpOrderCounters(FeEmploymentOrder order, LocalDateTime now) {
+        int registered = order.getRegisteredCount() != null ? order.getRegisteredCount() : 0;
+        int pending = order.getPendingCount() != null ? order.getPendingCount() : 0;
+        FeEmploymentOrder update = new FeEmploymentOrder();
+        update.setId(order.getId());
+        update.setRegisteredCount(registered + 1);
+        update.setPendingCount(Math.max(0, pending - 1));
+        update.setUpdateTime(now);
+        feEmploymentOrderMapper.updateById(update);
+    }
+
+    private static WorkerRegistrationApplyResponse toResponse(FeWorkerRegistration reg,
+                                                              FeRegistrationBatch batch,
+                                                              FeEmploymentOrder order,
+                                                              String status,
+                                                              String message) {
+        WorkerRegistrationApplyResponse response = new WorkerRegistrationApplyResponse();
+        response.setStatus(status);
+        response.setRegistrationId(reg.getId());
+        response.setBatchNo(batch.getBatchNo());
+        response.setOrderNo(order.getOrderNo());
+        response.setRegStatus(reg.getRegStatus());
+        response.setMessage(message);
+        return response;
+    }
+}

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

@@ -0,0 +1,38 @@
+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;
+
+import javax.validation.constraints.NotBlank;
+
+@Schema(description = "用工邀请申请加入请求")
+public class WorkerRegistrationApplyRequest {
+
+    @NotBlank(message = "scene 不能为空")
+    @JsonProperty("scene")
+    @JsonAlias({"order_no", "orderNo", "qr_token"})
+    @Schema(description = "小程序码 scene（订单编号）", example = "ord_123", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String scene;
+
+    @JsonProperty("confirmed_work_type")
+    @JsonAlias({"confirmedWorkType", "work_type"})
+    @Schema(description = "确认工种/任务（可选）", example = "仓库搬运")
+    private String confirmedWorkType;
+
+    public String getScene() {
+        return scene;
+    }
+
+    public void setScene(String scene) {
+        this.scene = scene;
+    }
+
+    public String getConfirmedWorkType() {
+        return confirmedWorkType;
+    }
+
+    public void setConfirmedWorkType(String confirmedWorkType) {
+        this.confirmedWorkType = confirmedWorkType;
+    }
+}

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

@@ -0,0 +1,78 @@
+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 WorkerRegistrationApplyResponse {
+
+    @Schema(description = "处理结果", example = "success")
+    private String status;
+
+    @JsonProperty("registration_id")
+    @Schema(description = "批次登记记录 ID")
+    private Long registrationId;
+
+    @JsonProperty("batch_no")
+    @Schema(description = "登记批次编号", example = "bat_1")
+    private String batchNo;
+
+    @JsonProperty("order_no")
+    @Schema(description = "订单编号 / scene", example = "ord_123")
+    private String orderNo;
+
+    @JsonProperty("reg_status")
+    @Schema(description = "登记状态", example = "under_review")
+    private String regStatus;
+
+    @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 getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+}