Commit 7a3b0d9f authored by suhuiguang's avatar suhuiguang

feat(jg): 压力管道后续业务

1.启用停用管道大编辑逻辑
parent d70a50ec
......@@ -65,10 +65,9 @@ public abstract class DefaultBizDataChangeHandler<U extends BaseBizDataChangeEve
}
/**
* 是否需要暂存数据-暂存保存数据到json--管道专用
*
* 管道专用-是否需要暂存数据-暂存保存数据到json
* @param applyNo 单据号
* @return yes-存json;no-实时存库
* @return true-存json;false-实时存库
*/
protected Boolean requiresTemporarySave(String applyNo) {
return !bizIsFinished(applyNo);
......
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.enableDisable;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.google.common.collect.Sets;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.common.biz.event.CommonPublisher;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
......@@ -52,9 +53,8 @@ public class EnableDisableDataChangeHandler extends DefaultBizDataChangeHandler<
}
/**
* 管道专用
* 管道专用-判断数据是实时落库,还是先存到json
* @param applyNo 单据号
* 判断数据是实时落库,还是先存到json
* @return 是否需要临时存储
*/
@Override
......@@ -70,7 +70,13 @@ public class EnableDisableDataChangeHandler extends DefaultBizDataChangeHandler<
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
JgEnableDisable jgEnableDisable = enableDisableEditUpdateService.getEnableDisableService()
.getOne(new LambdaQueryWrapper<JgEnableDisable>().eq(JgEnableDisable::getApplyNo, applyNo)
.select(BaseEntity::getSequenceNbr, JgEnableDisable::getProjectContraptionId));
Set<String> pIds = Sets.newHashSet(jgEnableDisable.getProjectContraptionId());
pIds.remove(null);
pIds.remove("");
return pIds;
}
@Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment