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 |   52 +++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 45 insertions(+), 7 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 8908602..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,30 +11,30 @@
 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.mapper.CodeAllCodeMapper;
+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;
-import com.vci.ubcs.code.vo.CodeClstemplateVO;
 import com.vci.ubcs.code.vo.pagemodel.CodeBasicSecVO;
+import com.vci.ubcs.code.vo.pagemodel.CodeClassifyTemplateVO;
 import com.vci.ubcs.code.vo.pagemodel.CodeClassifyVO;
 import com.vci.ubcs.code.vo.pagemodel.CodeRuleVO;
 import com.vci.ubcs.starter.exception.VciBaseException;
 import com.vci.ubcs.starter.web.constant.QueryOptionConstant;
 import com.vci.ubcs.starter.web.constant.RegExpConstant;
 import com.vci.ubcs.starter.web.enumpck.OsCodeFillTypeEnum;
-import com.vci.ubcs.starter.web.pagemodel.PageHelper;
 import com.vci.ubcs.starter.web.util.VciBaseUtil;
 import com.vci.ubcs.starter.web.util.VciDateUtil;
-import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 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.*;
-
+@Service
 public class MdmProductCodeServiceImpl  implements MdmProductCodeService {
 
 	/**
@@ -56,7 +56,7 @@
 	private ICodeWupinService iCodeWupinService;
 
 	@Override
-	public List<String> productCodeAndSaveData(CodeClassifyFullInfoBO classifyFullInfoBO, CodeClstemplateVO templateVO, CodeRuleVO ruleVO, List<CodeOrderSecDTO> secDTOList, List<CodeWupinEntity> dataCBOList) {
+	public List<String> productCodeAndSaveData(CodeClassifyFullInfoBO classifyFullInfoBO, CodeClassifyTemplateVO templateVO, CodeRuleVO ruleVO, List<CodeOrderSecDTO> secDTOList, List<CodeWupinEntity> dataCBOList) {
 //		BatchCBO batchCBO = new BatchCBO();
 //		WebUtil.setPersistence(false);
 //		dataCBOList = dataCBOList.stream().sorted(((o1, o2) -> o1.getCreateTime().compareTo(o2.getCreateTime()))).collect(Collectors.toList());
@@ -587,7 +587,7 @@
 	 * @param allCodeDOList 鎵�鏈夌殑鐮佸�肩殑瀵硅薄鍒楄〃
 	 */
 	private void wrapperAllCode(CodeClassifyFullInfoBO classifyFullInfoBO,CodeRuleVO ruleVO,
-								CodeWupinEntity cbo,CodeClstemplateVO templateVO,
+								CodeWupinEntity cbo,CodeClassifyTemplateVO templateVO,
 								List<CodeAllCode> allCodeDOList,String serialUnitString,String serialValueString){
 		CodeAllCode allCodeDO = new CodeAllCode();
 		allCodeDO.setCodeClassifyOid(classifyFullInfoBO.getCurrentClassifyVO().getOid());
@@ -704,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