增加与ai大模型对话

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

@@ -6,27 +6,33 @@ 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.ContractItemResponse;
 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.GetMapping;
 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.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 /**
- * 电子合同（企业端）：重新生成待签合同。
+ * 电子合同：临时工列表/签署确认；企业端重新生成待签合同。
  */
 @RestController
 @RequestMapping("/api/v1/mp/contracts")
-@Tag(name = "电子合同", description = "审核通过后自动生成待签合同；失败可重试")
+@Tag(name = "电子合同", description = "临时工查看与签署；企业重生成待签合同")
 @SecurityRequirement(name = "Authorization")
 public class ContractController {
 
     private static final String USER_TYPE_ENTERPRISE = "enterprise";
+    private static final String USER_TYPE_WORKER = "worker";
 
     private final ContractService contractService;
 
@@ -34,6 +40,37 @@ public class ContractController {
         this.contractService = contractService;
     }
 
+    @GetMapping
+    @Operation(summary = "我的电子合同列表",
+            description = "临时工 JWT；按 worker_id 查询本人合同。可选 sign_status=pending|signing|signed 过滤。")
+    public R<List<ContractItemResponse>> listMine(
+            @RequestParam(value = "sign_status", required = false) String signStatus) {
+        LoginUser loginUser = requireWorker();
+        return R.ok(contractService.listMyContracts(loginUser.getUserId(), signStatus));
+    }
+
+    @GetMapping("/{id}")
+    @Operation(summary = "合同详情",
+            description = "临时工查看本人合同详情",
+            parameters = {
+                    @Parameter(name = "id", in = ParameterIn.PATH, required = true, description = "fe_contract.id")
+            })
+    public R<ContractItemResponse> detail(@PathVariable("id") Long id) {
+        LoginUser loginUser = requireWorker();
+        return R.ok(contractService.getMyContract(loginUser.getUserId(), id));
+    }
+
+    @PostMapping("/{id}/confirm-sign")
+    @Operation(summary = "确认签署完成",
+            description = "临时工确认签署（Mock 闭环）。sign_status→signed，登记 contract_signing→completed。已签署幂等返回。",
+            parameters = {
+                    @Parameter(name = "id", in = ParameterIn.PATH, required = true, description = "fe_contract.id")
+            })
+    public R<ContractItemResponse> confirmSign(@PathVariable("id") Long id) {
+        LoginUser loginUser = requireWorker();
+        return R.ok(contractService.confirmSign(loginUser.getUserId(), id));
+    }
+
     @PostMapping("/by-registration/{registrationId}/regenerate")
     @Operation(summary = "重新生成待签合同",
             description = "电子签失败或签署链接缺失时调用。同一 registration 幂等；已签署不可重生成。",
@@ -53,4 +90,12 @@ public class ContractController {
         }
         return loginUser;
     }
+
+    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-service/src/main/java/com/huimv/employment/service/contract/ContractService.java

@@ -7,13 +7,17 @@ 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.FeWorker;
 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.FeEnterpriseMapper;
 import com.huimv.employment.dao.mapper.FeServicePlanMapper;
 import com.huimv.employment.dao.mapper.FeWorkerRegistrationMapper;
+import com.huimv.employment.service.contract.dto.ContractItemResponse;
 import com.huimv.employment.service.contract.dto.ContractSummaryResponse;
 import com.huimv.employment.service.enterprise.EnterpriseService;
+import com.huimv.employment.service.worker.WorkerService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.dao.DuplicateKeyException;
@@ -23,6 +27,13 @@ import org.springframework.util.StringUtils;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.ThreadLocalRandom;
 
 /**
@@ -47,20 +58,26 @@ public class ContractService {
     private final FeEmploymentOrderMapper feEmploymentOrderMapper;
     private final FeWorkerRegistrationMapper feWorkerRegistrationMapper;
     private final FeServicePlanMapper feServicePlanMapper;
+    private final FeEnterpriseMapper feEnterpriseMapper;
     private final EnterpriseService enterpriseService;
+    private final WorkerService workerService;
     private final ESignClient eSignClient;
 
     public ContractService(FeContractMapper feContractMapper,
                            FeEmploymentOrderMapper feEmploymentOrderMapper,
                            FeWorkerRegistrationMapper feWorkerRegistrationMapper,
                            FeServicePlanMapper feServicePlanMapper,
+                           FeEnterpriseMapper feEnterpriseMapper,
                            EnterpriseService enterpriseService,
+                           WorkerService workerService,
                            ESignClient eSignClient) {
         this.feContractMapper = feContractMapper;
         this.feEmploymentOrderMapper = feEmploymentOrderMapper;
         this.feWorkerRegistrationMapper = feWorkerRegistrationMapper;
         this.feServicePlanMapper = feServicePlanMapper;
+        this.feEnterpriseMapper = feEnterpriseMapper;
         this.enterpriseService = enterpriseService;
+        this.workerService = workerService;
         this.eSignClient = eSignClient;
     }
 
@@ -189,6 +206,175 @@ public class ContractService {
                 .last("LIMIT 1"));
     }
 
+    /**
+     * 临时工查看自己的合同列表；可选按 {@code sign_status} 过滤。
+     */
+    public List<ContractItemResponse> listMyContracts(Long userId, String signStatus) {
+        FeWorker worker = requireWorkerProfile(userId);
+        LambdaQueryWrapper<FeContract> qw = new LambdaQueryWrapper<FeContract>()
+                .eq(FeContract::getWorkerId, worker.getId())
+                .ne(FeContract::getSignStatus, SIGN_VOIDED)
+                .orderByDesc(FeContract::getId);
+        if (StringUtils.hasText(signStatus)) {
+            qw.eq(FeContract::getSignStatus, signStatus.trim());
+        }
+        List<FeContract> contracts = feContractMapper.selectList(qw);
+        if (contracts == null || contracts.isEmpty()) {
+            return Collections.emptyList();
+        }
+        return toItemList(contracts);
+    }
+
+    /**
+     * 临时工查看自己的合同详情。
+     */
+    public ContractItemResponse getMyContract(Long userId, Long contractId) {
+        FeWorker worker = requireWorkerProfile(userId);
+        FeContract contract = requireOwnedContract(worker.getId(), contractId);
+        List<ContractItemResponse> items = toItemList(Collections.singletonList(contract));
+        return items.isEmpty() ? null : items.get(0);
+    }
+
+    /**
+     * 临时工确认签署完成（Mock 电子签闭环；真实电子签可改为回调驱动）。
+     * <p>将合同置为 {@code signed}，登记 {@code contract_signing → completed}。</p>
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public ContractItemResponse confirmSign(Long userId, Long contractId) {
+        FeWorker worker = requireWorkerProfile(userId);
+        FeContract contract = requireOwnedContract(worker.getId(), contractId);
+
+        if (SIGN_SIGNED.equals(contract.getSignStatus())) {
+            return getMyContract(userId, contractId);
+        }
+        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());
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+        FeContract update = new FeContract();
+        update.setId(contract.getId());
+        update.setSignStatus(SIGN_SIGNED);
+        update.setSignedAt(now);
+        update.setUpdateTime(now);
+        feContractMapper.updateById(update);
+
+        markRegistrationCompleted(contract.getRegistrationId(), now);
+        log.info("合同签署完成 contractId={} workerId={} registrationId={}",
+                contract.getId(), worker.getId(), contract.getRegistrationId());
+        return getMyContract(userId, contractId);
+    }
+
+    private void markRegistrationCompleted(Long registrationId, LocalDateTime now) {
+        if (registrationId == null) {
+            return;
+        }
+        FeWorkerRegistration reg = feWorkerRegistrationMapper.selectById(registrationId);
+        if (reg == null) {
+            return;
+        }
+        if (!REG_CONTRACT_SIGNING.equals(reg.getRegStatus())) {
+            return;
+        }
+        FeWorkerRegistration update = new FeWorkerRegistration();
+        update.setId(reg.getId());
+        update.setRegStatus(REG_COMPLETED);
+        update.setUpdateTime(now);
+        feWorkerRegistrationMapper.updateById(update);
+    }
+
+    private FeWorker requireWorkerProfile(Long userId) {
+        workerService.requireWorkerUser(userId);
+        FeWorker worker = workerService.findWorkerByUserId(userId);
+        if (worker == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "请先完成临时工实名登记");
+        }
+        return worker;
+    }
+
+    private FeContract requireOwnedContract(Long workerId, Long contractId) {
+        if (contractId == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "合同 ID 无效");
+        }
+        FeContract contract = feContractMapper.selectById(contractId);
+        if (contract == null || SIGN_VOIDED.equals(contract.getSignStatus())) {
+            throw new BizException(ErrorCode.NOT_FOUND, "合同不存在");
+        }
+        if (contract.getWorkerId() == null || !contract.getWorkerId().equals(workerId)) {
+            throw new BizException(ErrorCode.FORBIDDEN, "无权查看该合同");
+        }
+        return contract;
+    }
+
+    private List<ContractItemResponse> toItemList(List<FeContract> contracts) {
+        Set<Long> orderIds = new HashSet<>();
+        Set<Long> enterpriseIds = new HashSet<>();
+        for (FeContract c : contracts) {
+            if (c.getOrderId() != null) {
+                orderIds.add(c.getOrderId());
+            }
+            if (c.getEnterpriseId() != null) {
+                enterpriseIds.add(c.getEnterpriseId());
+            }
+        }
+
+        Map<Long, FeEmploymentOrder> orderMap = new HashMap<>();
+        if (!orderIds.isEmpty()) {
+            List<FeEmploymentOrder> orders = feEmploymentOrderMapper.selectBatchIds(orderIds);
+            if (orders != null) {
+                for (FeEmploymentOrder o : orders) {
+                    orderMap.put(o.getId(), o);
+                }
+            }
+        }
+
+        Map<Long, FeEnterprise> enterpriseMap = new HashMap<>();
+        if (!enterpriseIds.isEmpty()) {
+            List<FeEnterprise> enterprises = feEnterpriseMapper.selectBatchIds(enterpriseIds);
+            if (enterprises != null) {
+                for (FeEnterprise e : enterprises) {
+                    enterpriseMap.put(e.getId(), e);
+                }
+            }
+        }
+
+        List<ContractItemResponse> result = new ArrayList<>(contracts.size());
+        for (FeContract c : contracts) {
+            result.add(toItem(c, orderMap.get(c.getOrderId()), enterpriseMap.get(c.getEnterpriseId())));
+        }
+        return result;
+    }
+
+    private static ContractItemResponse toItem(FeContract contract,
+                                               FeEmploymentOrder order,
+                                               FeEnterprise enterprise) {
+        ContractItemResponse item = new ContractItemResponse();
+        item.setContractId(contract.getId());
+        item.setContractNo(contract.getContractNo());
+        item.setRegistrationId(contract.getRegistrationId());
+        item.setOrderId(contract.getOrderId());
+        if (order != null) {
+            item.setOrderTitle(order.getTitle());
+        }
+        item.setEnterpriseId(contract.getEnterpriseId());
+        if (enterprise != null) {
+            item.setEnterpriseName(enterprise.getName());
+        }
+        item.setContractType(contract.getContractType());
+        item.setContractTitle(contract.getContractTitle());
+        item.setSignStatus(contract.getSignStatus());
+        item.setSignProvider(contract.getSignProvider());
+        item.setSignUrl(contract.getSignUrl());
+        item.setExternalContractId(contract.getExternalContractId());
+        item.setFileUrl(contract.getFileUrl());
+        item.setSignedAt(contract.getSignedAt());
+        item.setCreateTime(contract.getCreateTime());
+        return item;
+    }
+
     private void tryFillESign(FeContract contract, FeWorkerRegistration reg) {
         ESignClient.ESignCreateResult result = eSignClient.createPendingContract(
                 contract.getContractNo(),

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

@@ -0,0 +1,186 @@
+package com.huimv.employment.service.contract.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.time.LocalDateTime;
+
+@Schema(description = "电子合同列表项（临时工）")
+public class ContractItemResponse {
+
+    @JsonProperty("contract_id")
+    private Long contractId;
+
+    @JsonProperty("contract_no")
+    private String contractNo;
+
+    @JsonProperty("registration_id")
+    private Long registrationId;
+
+    @JsonProperty("order_id")
+    private Long orderId;
+
+    @JsonProperty("order_title")
+    private String orderTitle;
+
+    @JsonProperty("enterprise_id")
+    private Long enterpriseId;
+
+    @JsonProperty("enterprise_name")
+    private String enterpriseName;
+
+    @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;
+
+    @JsonProperty("file_url")
+    private String fileUrl;
+
+    @JsonProperty("signed_at")
+    private LocalDateTime signedAt;
+
+    @JsonProperty("create_time")
+    private LocalDateTime createTime;
+
+    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 Long getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Long orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getOrderTitle() {
+        return orderTitle;
+    }
+
+    public void setOrderTitle(String orderTitle) {
+        this.orderTitle = orderTitle;
+    }
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public String getEnterpriseName() {
+        return enterpriseName;
+    }
+
+    public void setEnterpriseName(String enterpriseName) {
+        this.enterpriseName = enterpriseName;
+    }
+
+    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 String getFileUrl() {
+        return fileUrl;
+    }
+
+    public void setFileUrl(String fileUrl) {
+        this.fileUrl = fileUrl;
+    }
+
+    public LocalDateTime getSignedAt() {
+        return signedAt;
+    }
+
+    public void setSignedAt(LocalDateTime signedAt) {
+        this.signedAt = signedAt;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+}