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

1

dev
luotaiqian 2026-07-27 15:09:57 +08:00
parent 9b8d233d8f
commit 9d1cea06d4
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,15 +20,18 @@ import org.qinan.safetyeval.domain.query.EvalProjectMemberQuery;
import org.qinan.safetyeval.domain.query.EvalProjectQuery; import org.qinan.safetyeval.domain.query.EvalProjectQuery;
import org.qinan.safetyeval.domain.query.PageResult; import org.qinan.safetyeval.domain.query.PageResult;
import org.qinan.safetyeval.domain.service.EvalProjectDomainService; import org.qinan.safetyeval.domain.service.EvalProjectDomainService;
import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
import org.qinan.safetyeval.infrastructure.adapter.ThreadLocalUserInfoAdapter; import org.qinan.safetyeval.infrastructure.adapter.ThreadLocalUserInfoAdapter;
import org.qinan.safetyeval.infrastructure.adapter.auth.AuthUserContextAdapter; import org.qinan.safetyeval.infrastructure.adapter.auth.AuthUserContextAdapter;
import org.qinan.safetyeval.infrastructure.mapper.EvalProjectMapper; import org.qinan.safetyeval.infrastructure.mapper.EvalProjectMapper;
import org.qinan.safetyeval.infrastructure.support.InstitutionOrgSupport; import org.qinan.safetyeval.infrastructure.support.InstitutionOrgSupport;
import org.qinan.safetyeval.infrastructure.support.InsertFieldDefaults;
import org.qinan.safetyeval.infrastructure.support.ProjectNoGenerator; import org.qinan.safetyeval.infrastructure.support.ProjectNoGenerator;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy; import org.springframework.context.annotation.Lazy;
import org.springframework.dao.DuplicateKeyException; import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import java.time.LocalDate; import java.time.LocalDate;
@ -60,13 +63,25 @@ public class EvalProjectExecutor implements EvalProjectApi {
private EvalProjectMemberGateway evalProjectMemberGateway; private EvalProjectMemberGateway evalProjectMemberGateway;
@Override @Override
@Transactional(rollbackFor = Exception.class)
public SingleResponse<EvalProjectCO> save(EvalProjectAddCmd cmd) { public SingleResponse<EvalProjectCO> save(EvalProjectAddCmd cmd) {
Long orgId = institutionOrgSupport.resolveCurrentOrgId(); Long orgId = institutionOrgSupport.resolveCurrentOrgId();
EvalProjectEntity entity = evalProjectCmdConvertor.convertAddCmdToE(cmd); EvalProjectEntity entity = evalProjectCmdConvertor.convertAddCmdToE(cmd);
EvalProjectEntity result = saveWithProjectNo(entity, orgId); EvalProjectEntity result = saveWithProjectNo(entity, orgId);
createProcessWaring(result);
return SingleResponse.success(evalProjectCmdConvertor.convertEToCO(result)); return SingleResponse.success(evalProjectCmdConvertor.convertEToCO(result));
} }
/**
* 项目创建成功后，初始化一条项目过程预警记录（默认正常状态）。
*/
private void createProcessWaring(EvalProjectEntity project) {
EvalProjectProcessWaringE waring = EvalProjectProcessWaringE.of();
waring.setProjectId(project.getId());
InsertFieldDefaults.apply(waring);
waring.add();
}
@Override @Override
public SingleResponse<EvalProjectCO> get(Long id) { public SingleResponse<EvalProjectCO> get(Long id) {
EvalProjectEntity entity = evalProjectDomainService.get(id); EvalProjectEntity entity = evalProjectDomainService.get(id);