From 029b101d319812460441d3d706c0654d8b0dcda6 Mon Sep 17 00:00:00 2001 From: yuxc <653031404@qq.com> Date: 星期五, 19 五月 2023 18:43:05 +0800 Subject: [PATCH] 主数据定义接口移植 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java | 40 ++++++++++++++++++++++++++++++++++++++++ 1 files changed, 40 insertions(+), 0 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java index 9c28997..2ebd73a 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java @@ -11,6 +11,7 @@ import com.vci.ubcs.code.enumpack.CodeGetValueTypeEnum; import com.vci.ubcs.code.enumpack.CodeLevelTypeEnum; import com.vci.ubcs.code.enumpack.CodeSecTypeEnum; +import com.vci.ubcs.code.lifecycle.CodeAllCodeLC; import com.vci.ubcs.code.mapper.CodeSerialValueMapper; import com.vci.ubcs.code.service.ICodeWupinService; import com.vci.ubcs.code.service.MdmProductCodeService; @@ -29,6 +30,7 @@ import javax.annotation.Resource; import java.util.*; +import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; import static com.vci.ubcs.code.constant.MdmEngineConstant.*; @@ -702,4 +704,42 @@ return value; } + + /** + * 鍥炴敹鐮佸�� + * + * @param btmId 涓氬姟鏁版嵁鐨勪笟鍔$被鍨� + * @param businessOidCollection 涓氬姟鏁版嵁鐨勪富閿� + * @return 鏄惁鏇存柊鎴愬姛 + */ + @Override + public Boolean recycleCode(String btmId, Collection<String> businessOidCollection) { +// boolean oldPersistence = WebUtil.isPersistence(); +// WebUtil.setPersistence(false); +// BatchCBO batchCBO = new BatchCBO(); + AtomicReference<Boolean> updateFlag = new AtomicReference<>(false); + VciBaseUtil.switchCollectionForOracleIn(businessOidCollection).stream().forEach(oids-> { +// Map<String, String> conditionMap = new HashMap<>(); +// //缂栫爜瑕佽褰曚负鍥炴敹鐨勭姸鎬� +// conditionMap.put("createcodeoid", QueryOptionConstant.IN + "(" + VciBaseUtil.toInSql(oids.toArray(new String[0])) + ")"); +// conditionMap.put("createcodebtm", btmId); + + QueryWrapper<CodeAllCode> wrapper = new QueryWrapper<>(); + wrapper.in("createcodeoid",QueryOptionConstant.IN + "(" + VciBaseUtil.toInSql(oids.toArray(new String[0])) + ")"); + wrapper.eq("createcodebtm", btmId); + + + List<CodeAllCode> allCodeDOS = codeAllCodeService.selectByWrapper(wrapper); +// allCodeMapper.selectByCondition(conditionMap, new PageHelper(-1)); + if (!CollectionUtils.isEmpty(allCodeDOS)) { + allCodeDOS.stream().forEach(codeDO->{ + codeDO.setLcStatus(CodeAllCodeLC.TASK_BACK.getValue()); + }); + updateFlag.set(codeAllCodeService.updateBatchById(allCodeDOS)); +// batchCBO.copyFromOther(allCodeMapper.batchUpdate(allCodeDOS)); + } + }); +// WebUtil.setPersistence(oldPersistence); + return updateFlag.get(); + } } -- Gitblit v1.9.3