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

风险预警调整

dev-tmp1
zhanglei 2026-08-13 16:45:10 +08:00
parent 970b2041d1
commit 0511f365bb
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/impl/EvalProjectOrgWaringRepositoryImpl.java
View File

@ -7,9 +7,11 @@ import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import org.qinan.safetyeval.client.waring.request.EvalProjectOrgWaringPageQry; import org.qinan.safetyeval.client.waring.request.EvalProjectOrgWaringPageQry;
import org.qinan.safetyeval.domain.constant.BooleanQAEnum; import org.qinan.safetyeval.domain.constant.BooleanQAEnum;
import org.qinan.safetyeval.infrastructure.adapter.ThreadLocalUserInfoAdapter;
import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectOrgWaringDO; import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectOrgWaringDO;
import org.qinan.safetyeval.infrastructure.persistence.mapper.EvalProjectOrgWaringMapper; import org.qinan.safetyeval.infrastructure.persistence.mapper.EvalProjectOrgWaringMapper;
import org.qinan.safetyeval.infrastructure.persistence.repository.EvalProjectOrgWaringRepository; import org.qinan.safetyeval.infrastructure.persistence.repository.EvalProjectOrgWaringRepository;
import org.qinan.safetyeval.infrastructure.support.InsertFieldDefaults;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Arrays; import java.util.Arrays;
@ -40,11 +42,20 @@ public class EvalProjectOrgWaringRepositoryImpl extends BaseRepositoryImpl<EvalP
@Override @Override
public Boolean addEvalProjectOrgWaring(EvalProjectOrgWaringDO evalProjectOrgWaringDO) { public Boolean addEvalProjectOrgWaring(EvalProjectOrgWaringDO evalProjectOrgWaringDO) {
if (baseMapper.exists(new LambdaQueryWrapper<EvalProjectOrgWaringDO>()
.eq(EvalProjectOrgWaringDO::getProjectId, evalProjectOrgWaringDO.getProjectId())
.eq(EvalProjectOrgWaringDO::getOrgId, ThreadLocalUserInfoAdapter.get())
.eq(EvalProjectOrgWaringDO::getWarningType, evalProjectOrgWaringDO.getWarningType()))) {
// 存在不新增
return false;
}
InsertFieldDefaults.apply(evalProjectOrgWaringDO);
return super.save(evalProjectOrgWaringDO); return super.save(evalProjectOrgWaringDO);
} }
@Override @Override
public Boolean updateEvalProjectOrgWaring(EvalProjectOrgWaringDO evalProjectOrgWaringDO) { public Boolean updateEvalProjectOrgWaring(EvalProjectOrgWaringDO evalProjectOrgWaringDO) {
InsertFieldDefaults.applyForUpdate(evalProjectOrgWaringDO);
return super.updateById(evalProjectOrgWaringDO); return super.updateById(evalProjectOrgWaringDO);
} }