cq_anquan
/
safety-eval-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1

dev
luotaiqian 2026-07-24 15:10:06 +08:00
parent 6a2b962fb0
commit 5cb71429cd
1 changed files with 31 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/institution/EvalSignTaskExecutor.java
View File

@ -13,10 +13,7 @@ import org.qinan.safetyeval.client.dto.SingleResponse;
import org.qinan.safetyeval.client.dto.institution.EditSignTaskSaveCmd; import org.qinan.safetyeval.client.dto.institution.EditSignTaskSaveCmd;
import org.qinan.safetyeval.client.dto.institution.EvalSignTaskPageQuery; import org.qinan.safetyeval.client.dto.institution.EvalSignTaskPageQuery;
import org.qinan.safetyeval.client.dto.institution.EvalSignTaskSaveCmd; import org.qinan.safetyeval.client.dto.institution.EvalSignTaskSaveCmd;
import org.qinan.safetyeval.domain.constant.MsgConstant; import org.qinan.safetyeval.domain.constant.*;
import org.qinan.safetyeval.domain.constant.NoticeTypeEnum;
import org.qinan.safetyeval.domain.constant.ProjectStageEnum;
import org.qinan.safetyeval.domain.constant.SignTaskStatusEnum;
import org.qinan.safetyeval.domain.entity.EvalSignTaskEntity; import org.qinan.safetyeval.domain.entity.EvalSignTaskEntity;
import org.qinan.safetyeval.domain.entity.SafetyMessageEntity; import org.qinan.safetyeval.domain.entity.SafetyMessageEntity;
import org.qinan.safetyeval.domain.exception.BizException; import org.qinan.safetyeval.domain.exception.BizException;
@ -25,12 +22,8 @@ import org.qinan.safetyeval.domain.gateway.SafetyMessageGateway;
import org.qinan.safetyeval.domain.query.EvalSignTaskQuery; import org.qinan.safetyeval.domain.query.EvalSignTaskQuery;
import org.qinan.safetyeval.domain.query.PageResult; import org.qinan.safetyeval.domain.query.PageResult;
import org.qinan.safetyeval.domain.service.EvalSignTaskDomainService; import org.qinan.safetyeval.domain.service.EvalSignTaskDomainService;
import org.qinan.safetyeval.infrastructure.dataobject.EvalProjectMemberDO; import org.qinan.safetyeval.infrastructure.dataobject.*;
import org.qinan.safetyeval.infrastructure.dataobject.EvalRiskParticipantDO; import org.qinan.safetyeval.infrastructure.mapper.*;
import org.qinan.safetyeval.infrastructure.dataobject.EvalSignTaskDO;
import org.qinan.safetyeval.infrastructure.mapper.EvalProjectMemberMapper;
import org.qinan.safetyeval.infrastructure.mapper.EvalRiskParticipantMapper;
import org.qinan.safetyeval.infrastructure.mapper.EvalSignTaskMapper;
import org.qinan.safetyeval.infrastructure.support.InstitutionOrgSupport; import org.qinan.safetyeval.infrastructure.support.InstitutionOrgSupport;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -63,6 +56,12 @@ public class EvalSignTaskExecutor implements EvalSignTaskApi {
private EvalProjectMemberMapper evalProjectMemberMapper; private EvalProjectMemberMapper evalProjectMemberMapper;
@Autowired @Autowired
private EvalRiskParticipantMapper evalRiskParticipantMapper; private EvalRiskParticipantMapper evalRiskParticipantMapper;
@Autowired
private EvalInternalReviewMapper evalInternalReviewMapper;
@Autowired
private EvalTechReviewMapper evalTechReviewMapper;
@Autowired
private EvalProcessControlMapper evalProcessControlMapper;
@Override @Override
public SingleResponse<EvalSignTaskCO> save(EvalSignTaskSaveCmd cmd) { public SingleResponse<EvalSignTaskCO> save(EvalSignTaskSaveCmd cmd) {
@ -142,6 +141,28 @@ public class EvalSignTaskExecutor implements EvalSignTaskApi {
.set(EvalRiskParticipantDO::getSignFileUrl, cmd.getSignerUrl()) .set(EvalRiskParticipantDO::getSignFileUrl, cmd.getSignerUrl())
.set(EvalRiskParticipantDO::getSignStatusCode, SignTaskStatusEnum.SIGNED.getCode())); .set(EvalRiskParticipantDO::getSignStatusCode, SignTaskStatusEnum.SIGNED.getCode()));
} }
if (ProjectStageEnum.INTERNAL_REVIEW.getMsg().equals(evalSignTaskDO.getNodeCode())) {
evalInternalReviewMapper.update(new LambdaUpdateWrapper<EvalInternalReviewDO>()
.eq(EvalInternalReviewDO::getId, evalSignTaskDO.getBizRefId())
.eq(EvalInternalReviewDO::getProjectId, evalSignTaskDO.getProjectId())
.set(EvalInternalReviewDO::getReviewerSignatureUrl, cmd.getSignerUrl())
.set(EvalInternalReviewDO::getReviewerSignatureTaskStatus, SignatureTaskStatusEnum.COMPLETED.getCode()));
}
if (ProjectStageEnum.TECHNICAL_REVIEW.getMsg().equals(evalSignTaskDO.getNodeCode())) {
evalTechReviewMapper.update(new LambdaUpdateWrapper<EvalTechReviewDO>()
.eq(EvalTechReviewDO::getId, evalSignTaskDO.getBizRefId())
.eq(EvalTechReviewDO::getProjectId, evalSignTaskDO.getProjectId())
.set(EvalTechReviewDO::getReviewerSignatureUrl, cmd.getSignerUrl())
.set(EvalTechReviewDO::getReviewerSignatureTaskStatus, SignatureTaskStatusEnum.COMPLETED.getCode()));
}
if (ProjectStageEnum.PROCESS_CONTROL.getMsg().equals(evalSignTaskDO.getNodeCode())) {
evalProcessControlMapper.update(new LambdaUpdateWrapper<EvalProcessControlDO>()
.eq(EvalProcessControlDO::getId, evalSignTaskDO.getBizRefId())
.eq(EvalProcessControlDO::getProjectId, evalSignTaskDO.getProjectId())
.set(EvalProcessControlDO::getReviewerSignatureUrl, cmd.getSignerUrl())
.set(EvalProcessControlDO::getReviewerSignatureTaskStatus, SignatureTaskStatusEnum.COMPLETED.getCode()));
}
return SingleResponse.success(true); return SingleResponse.success(true);
} }
} }