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