From 8238e7215367e39de004c29244d2597bb1e5519b Mon Sep 17 00:00:00 2001
From: xiejun <xiejun@vci-tech.com>
Date: 星期二, 23 一月 2024 10:13:16 +0800
Subject: [PATCH] 集团码申请接口调试

---
 Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java |  409 ++++++++++++++++++++++++++++++++++++---------------------
 1 files changed, 257 insertions(+), 152 deletions(-)

diff --git a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java
index 7bd34db..7267079 100644
--- a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java
@@ -1,5 +1,6 @@
 package com.vci.ubcs.code.applyjtcodeservice.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -9,6 +10,10 @@
 import com.vci.ubcs.code.applyjtcodeservice.entity.*;
 import com.vci.ubcs.code.applyjtcodeservice.service.IGroupMdmInterService;
 import com.vci.ubcs.code.applyjtcodeservice.vo.*;
+import com.vci.ubcs.code.vo.pagemodel.CodeClassifyTemplateAttrVO;
+import com.vci.ubcs.code.vo.webserviceModel.apply.ApplyDataVO;
+import com.vci.ubcs.code.vo.webserviceModel.apply.InterParameterVO;
+import com.vci.ubcs.code.vo.webserviceModel.result.xml.XMLResultDataObjectDetailDO;
 import com.vci.ubcs.starter.util.MdmBtmTypeConstant;
 import com.vci.ubcs.code.applyjtcodeservice.feign.MdmApplyGroupCodeProvider;
 import com.vci.ubcs.code.applyjtcodeservice.mapper.DockingPreAttrMappingMapper;
@@ -17,8 +22,10 @@
 import com.vci.ubcs.starter.web.util.BeanUtilForVCI;
 import com.vci.ubcs.starter.web.util.VciBaseUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.map.CaseInsensitiveMap;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
+import org.springblade.core.tool.utils.Func;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -41,9 +48,11 @@
 	private String code="";
 
 	private String msg="";
-
-
-	@Value("${docking.apply.unitCode:41000}")
+	@Value("${docking.apply.partCode:101}")
+	public String partCoe;
+	@Value("${docking.apply.usedFlag:false}")
+	public boolean usedFlag;
+	@Value("${docking.apply.unitCode:4100}")
 	public String dockingApplyUnitCode;
 
 	@Value("${docking.apply.sysName:410-MDM}")
@@ -101,111 +110,149 @@
 	@Transactional(rollbackFor = VciBaseException.class)
 	@Override
 	public R applyGroupCode(String oids, String btmName) throws VciBaseException {
-		try {
-			List<BaseModel> updateCbos = new ArrayList<BaseModel>();
-			List<DockingPreApplyForm> dockingPreAttrMappings = new ArrayList<>();
-			VciBaseUtil.alertNotNull(oids, "閫夋嫨鐨勬暟鎹�");
-			VciBaseUtil.alertNotNull(btmName, "涓氬姟绫诲瀷");
-			R<List<BaseModel>> baseModelR =mdmEngineClient.selectByTypeAndOid(btmName,oids);
-			List<BaseModel> dataModelList= baseModelR.getData();
-			if (!CollectionUtils.isEmpty(dataModelList)) {
-				DockingGroupDataVO dockingGroupDataVO = new DockingGroupDataVO();
-				//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯�
-				Map<String, DockingPreApplyForm> addDockingPreApplyFormMap = new HashMap<String, DockingPreApplyForm>();
-				Map<String, DockingPreApplyForm> editDockingPreApplyFormMap = new HashMap<String, DockingPreApplyForm>();
-				Map<String, BaseModel> baseModelMap = new HashMap<String, BaseModel>();
-				//缁勭粐鏁版嵁
-				dockingGroupDataVO = queryApplycodeDataObjects(1, dataModelList, addDockingPreApplyFormMap, editDockingPreApplyFormMap, baseModelMap);
-				DockingResultVO resultDataObject = mdmApplyGroupCodeProvider.receiveAddApply(dockingGroupDataVO);
-				code = resultDataObject.getCode();
-				msg = resultDataObject.getMsg();
-				if ("1".equals(resultDataObject.getCode())) {//缁撴灉姝g‘鐨勬儏鍐�
-					List<DockingDataVO> dataObjectVOList = resultDataObject.getData();
-					dataObjectVOList.stream().forEach(dataObject -> {
-						boolean isEditDatas = false;
-						String code2 = dataObject.getCode();
-						DockingMainDataVO data2 = dataObject.getData();
-						String applyId = data2.getApplyId();//鐢宠鍗昳d
-						String customCoding = StringUtils.isBlank(data2.getCustomCoding()) ? "" : data2.getCustomCoding();//闆嗗洟鐮佹
-						msg = dataObject.getMsg();
-						if (code2.equals("1")) {//缁撴灉姝g‘鐨勬儏鍐�
-							if (!"".equals(customCoding)) {
-								isEditDatas = true;
+		if(usedFlag) {
+			try {
+				List<BaseModel> updateCbos = new ArrayList<BaseModel>();
+				List<DockingPreApplyForm> dockingPreAttrMappings = new ArrayList<>();
+				VciBaseUtil.alertNotNull(oids, "閫夋嫨鐨勬暟鎹�");
+				VciBaseUtil.alertNotNull(btmName, "涓氬姟绫诲瀷");
+				R<List<BaseModel>> baseModelR = mdmEngineClient.selectByTypeAndOid(btmName, oids);
+				List<BaseModel> dataModelList = baseModelR.getData();
+				if (!CollectionUtils.isEmpty(dataModelList)) {
+					DockingGroupDataVO dockingGroupDataVO = new DockingGroupDataVO();
+					//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯�
+					Map<String, DockingPreApplyForm> addDockingPreApplyFormMap = new HashMap<String, DockingPreApplyForm>();
+					Map<String, DockingPreApplyForm> editDockingPreApplyFormMap = new HashMap<String, DockingPreApplyForm>();
+					Map<String, BaseModel> baseModelMap = new HashMap<String, BaseModel>();
+					//鏁版嵁搴撲笉瀛樺湪鐨�
+					/*List<BaseModel> newDdataModelList = dataModelList.stream().filter(cbo -> {
+						String groupcode =cbo.getData().getOrDefault("GROUPCODE","");
+						return StringUtils.isBlank(groupcode);
+					}).collect(Collectors.toList());
+					if(newDdataModelList.size()==0)
+						return R.fail("鐢宠鎺ュ彛璋冪敤鎴愬姛,鎵�鏈夋暟鎹凡缁忓瓨鍦ㄩ泦鍥㈢爜");*/
+
+					//缁勭粐鏁版嵁
+					dockingGroupDataVO = queryApplycodeDataObjects(1, dataModelList, addDockingPreApplyFormMap, editDockingPreApplyFormMap, baseModelMap);
+					Object object = JSONObject.toJSON(dockingGroupDataVO);
+					String resultStr = object.toString();
+					log.info("鐢宠闆嗗洟鐮佹暟鎹牸寮�:->"+resultStr);
+					DockingResultVO resultDataObject =new DockingResultVO();
+					resultDataObject=	mdmApplyGroupCodeProvider.receiveAddApply(dockingGroupDataVO);
+					code = resultDataObject.getCode();
+					msg = resultDataObject.getMsg();
+					boolean res=false;
+					if ("1".equals(resultDataObject.getCode())) {//缁撴灉姝g‘鐨勬儏鍐�
+						List<DockingDataVO> dataObjectVOList = resultDataObject.getData();
+						res=true;
+						dataObjectVOList.stream().forEach(dataObject -> {
+							boolean isEditDatas = false;
+							String code2 = dataObject.getCode();
+							DockingMainDataVO data2 = dataObject.getData();
+							String applyId = data2.getApplyId();//鐢宠鍗昳d
+							BaseModel baseModel = baseModelMap.get(applyId);
+							String customCoding = StringUtils.isBlank(data2.getCustomCoding()) ? "" : data2.getCustomCoding();//闆嗗洟鐮佹
+							msg = dataObject.getMsg();
+							if (code2.equals("1")) {//缁撴灉姝g‘鐨勬儏鍐�
+								if (!"".equals(customCoding)) {
+									isEditDatas = true;
+								}
 							}
-						}
-						//闇�瑕佷慨鏀圭殑鐢宠鍗曟暟鎹�
-						if (editDockingPreApplyFormMap.containsKey(applyId)) {
-							DockingPreApplyForm dockingPreApplyForm = editDockingPreApplyFormMap.get(applyId);
-							dockingPreApplyForm.setCode(code2);
+							//闇�瑕佷慨鏀圭殑鐢宠鍗曟暟鎹�
+							if (editDockingPreApplyFormMap.containsKey(applyId)) {
+								DockingPreApplyForm dockingPreApplyForm = editDockingPreApplyFormMap.get(applyId);
+								dockingPreApplyForm.setCode(code2);
+								//dockingPreApplyForm.setDescription(baseModel.getId());
+								dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
+								if(StringUtils.isBlank(dockingPreApplyForm.getGroupCode())) {
+									dockingPreApplyForm.setGroupCode(customCoding);
+								}else{
+									isEditDatas = true;
+									if (StringUtils.isBlank(customCoding)) {
+										customCoding=dockingPreApplyForm.getGroupCode();
+									}
+								}
+								ObjectMapper mp = new ObjectMapper();
+								String writeValueAsString = null;
+								try {
+									writeValueAsString = mp.writeValueAsString(dataObject);
+									dockingPreApplyForm.setContent(writeValueAsString);
+								} catch (JsonProcessingException e) {
+								}
+								DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm);
+							}
+							//鏂板鐨勭敵璇峰崟鏁版嵁
+							if (addDockingPreApplyFormMap.containsKey(applyId)) {
+								DockingPreApplyForm dockingPreApplyForm = addDockingPreApplyFormMap.get(applyId);
+								dockingPreApplyForm.setCode(code2);
+								dockingPreApplyForm.setDescription(baseModel.getId());
+								dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
+								dockingPreApplyForm.setGroupCode(customCoding);
+								ObjectMapper mp = new ObjectMapper();
+								String writeValueAsString = null;
+								try {
+									writeValueAsString = mp.writeValueAsString(dataObject);
+									dockingPreApplyForm.setContent(writeValueAsString);
+								} catch (JsonProcessingException e) {
+								}
+								DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM);
+							}
+							//濡傛灉鏈夐泦鍥㈢爜鍒欐洿鏂版暟鎹�
+							if (isEditDatas) {
+								if (baseModelMap.containsKey(applyId)) {
+									baseModel = baseModelMap.get(applyId);
+									Map<String,String> dataValueMap=new CaseInsensitiveMap<>(baseModel.getData());
+									String classOid=dataValueMap.getOrDefault("CODECLSFID","");
+									if(partCoe.equals(classOid)){
+										baseModel.setId(10+customCoding);
+										customCoding=10+customCoding;
+									}
+									BeanUtilForVCI.copyDeclaredIgnoreCase(baseModel, baseModel);
+									DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
+								//	DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
+									baseModel.getData().put("GROUPCODE",customCoding);
+									updateCbos.add(baseModel);//鏇存柊鏁版嵁闆嗗洟code
+								}
+							}
+						});
+					} else {
+						res=false;
+						editDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> {
+							dockingPreApplyForm.setCode("2");
 							dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
-							dockingPreApplyForm.setGroupCode(customCoding);
-							ObjectMapper mp = new ObjectMapper();
-							String writeValueAsString = null;
-							try {
-								writeValueAsString = mp.writeValueAsString(dataObject);
-								dockingPreApplyForm.setContent(writeValueAsString);
-							} catch (JsonProcessingException e) {
-							}
-						}
-						//鏂板鐨勭敵璇峰崟鏁版嵁
-						if (addDockingPreApplyFormMap.containsKey(applyId)) {
-							DockingPreApplyForm dockingPreApplyForm = addDockingPreApplyFormMap.get(applyId);
-							dockingPreApplyForm.setCode(code2);
+							dockingPreApplyForm.setContent("");
+							dockingPreApplyForm.setGroupCode("");
+							DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm);
+						});
+						addDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> {
+							dockingPreApplyForm.setCode("2");
 							dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
-							dockingPreApplyForm.setGroupCode(customCoding);
-							ObjectMapper mp = new ObjectMapper();
-							String writeValueAsString = null;
-							try {
-								writeValueAsString = mp.writeValueAsString(dataObject);
-								dockingPreApplyForm.setContent(writeValueAsString);
-							} catch (JsonProcessingException e) {
-							}
-						}
-						//濡傛灉鏈夐泦鍥㈢爜鍒欐洿鏂版暟鎹�
-						if (isEditDatas) {
-							if (baseModelMap.containsKey(applyId)) {
-								BaseModel baseModel = baseModelMap.get(applyId);
-								BeanUtilForVCI.copyDeclaredIgnoreCase(baseModel, baseModel);
-								DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
-								DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
-								//baseModel.setId(customCoding);
-								baseModel.getData().getOrDefault("groupCode",customCoding);
-								updateCbos.add(baseModel);//鏇存柊鏁版嵁闆嗗洟code
-							}
-						}
-					});
-				} else {
-					editDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> {
-						dockingPreApplyForm.setCode("2");
-						dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
-						dockingPreApplyForm.setContent("");
-						dockingPreApplyForm.setGroupCode("");
-						DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm);
-					});
-					addDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> {
-						dockingPreApplyForm.setCode("2");
-						dockingPreApplyForm.setMsg("鐢宠锛�" + msg);
-						dockingPreApplyForm.setContent("");
-						dockingPreApplyForm.setGroupCode("");
-						DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM);
-					});
+							dockingPreApplyForm.setContent("");
+							dockingPreApplyForm.setGroupCode("");
+							DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM);
+						});
+					}
+					if (editDockingPreApplyFormMap.size() > 0) {
+						dockingPreAttrMappings.addAll(editDockingPreApplyFormMap.values());//娣诲姞鐢宠鍗曟暟鎹�
+					}
+					if (addDockingPreApplyFormMap.size() > 0) {
+						dockingPreAttrMappings.addAll(addDockingPreApplyFormMap.values());//闇�瑕佷慨鏀圭殑鐢宠鍗曟暟鎹�
+					}
+					//淇濆瓨琛ㄥ崟鏁版嵁
+					dockingPreApplyFormService.saveOrUpdateBatch(dockingPreAttrMappings);
+					mdmEngineClient.updateBatchBtypeDatas(btmName, updateCbos);//淇濆瓨鏁版嵁
+					if(!res){
+						throw new VciBaseException(msg);
+					}
 				}
-				if (editDockingPreApplyFormMap.size() > 0) {
-					dockingPreAttrMappings.addAll(editDockingPreApplyFormMap.values());//娣诲姞鐢宠鍗曟暟鎹�
-				}
-				if (addDockingPreApplyFormMap.size() > 0) {
-					dockingPreAttrMappings.addAll(addDockingPreApplyFormMap.values());//闇�瑕佷慨鏀圭殑鐢宠鍗曟暟鎹�
-				}
-				//淇濆瓨琛ㄥ崟鏁版嵁
-				dockingPreApplyFormService.saveOrUpdateBatch(dockingPreAttrMappings);
-				mdmEngineClient.updateBatchByType(btmName,updateCbos);//淇濆瓨鏁版嵁
+				return R.success("鐢宠鎺ュ彛璋冪敤鎴愬姛");
+			} catch (VciBaseException e) {
+				return R.fail("鐢宠鎺ュ彛璋冪敤澶辫触" + e);
 			}
-			return R.success("鐢宠鎺ュ彛璋冪敤鎴愬姛");
-		}catch (VciBaseException e){
-			return R.fail("鐢宠鎺ュ彛璋冪敤澶辫触"+e);
+		}else{
+			return R.fail("鐢宠鎺ュ彛寮�鍏冲凡鍏抽棴锛屼笉鐢宠闆嗗洟鐮�");
 		}
 	}
-
 	/***
 	 * 涓绘暟鎹儚闆嗗洟鏇存敼缂栫爜
 	 * @param oids 闇�瑕佷慨鏀圭殑鏁版嵁涓婚敭鏁扮粍
@@ -216,13 +263,22 @@
 	@Transactional(rollbackFor = VciBaseException.class)
 	@Override
 	public R receiveEditApply(String oids, String btmName) throws VciBaseException {
-		List<BaseModel> updateCbos=new ArrayList<BaseModel>();
-		List<DockingPreApplyForm> dockingPreAttrMappings=new ArrayList<>();
-		VciBaseUtil.alertNotNull(oids,"閫夋嫨鐨勬暟鎹�");
-		VciBaseUtil.alertNotNull(btmName,"涓氬姟绫诲瀷");
+		if(!usedFlag) {
+			log.info("鏇存柊鎺ュ彛鍔熻兘宸插叧闂紒->"+usedFlag);
+			R.success("鏇存柊鎺ュ彛鍔熻兘宸插叧闂紒");
+		}
+		List<BaseModel> updateCbos = new ArrayList<BaseModel>();
+		List<DockingPreApplyForm> dockingPreAttrMappings = new ArrayList<>();
+		VciBaseUtil.alertNotNull(oids, "閫夋嫨鐨勬暟鎹�");
+		VciBaseUtil.alertNotNull(btmName, "涓氬姟绫诲瀷");
 		//List<BaseModelVO> codeWupins=mdmEngineService.listByIds(VciBaseUtil.str2List(oids));
 		List<BaseModel> dataModelList = new ArrayList<>();
 		try {
+			R<List<BaseModel>> listR = mdmEngineClient.selectByTypeAndOid(btmName, oids);
+			if(listR.getData().size() == 0){
+				return R.fail("涓烘煡璇㈠埌鐩稿叧涓氬姟鏁版嵁锛�");
+			}
+			dataModelList = listR.getData();
 			if (!CollectionUtils.isEmpty(dataModelList)) {
 				DockingGroupDataVO dockingGroupDataVO = new DockingGroupDataVO();
 				//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯�
@@ -253,7 +309,9 @@
 							DockingPreApplyForm dockingPreApplyForm = editDockingPreApplyFormMap.get(applyId);
 							dockingPreApplyForm.setCode(code2);
 							dockingPreApplyForm.setMsg("淇敼锛�" + msg);
-							dockingPreApplyForm.setGroupCode(customCoding);
+							if(StringUtils.isBlank(dockingPreApplyForm.getGroupCode())) {
+								dockingPreApplyForm.setGroupCode(customCoding);
+							}
 							ObjectMapper mp = new ObjectMapper();
 							String writeValueAsString = null;
 							try {
@@ -261,13 +319,16 @@
 								dockingPreApplyForm.setContent(writeValueAsString);
 							} catch (JsonProcessingException e) {
 							}
+							DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm);
 						}
 						//鏂板鐨勭敵璇峰崟鏁版嵁
 						if (addDockingPreApplyFormMap.containsKey(applyId)) {
 							DockingPreApplyForm dockingPreApplyForm = addDockingPreApplyFormMap.get(applyId);
 							dockingPreApplyForm.setCode(code2);
 							dockingPreApplyForm.setMsg("淇敼锛�" + msg);
-							dockingPreApplyForm.setGroupCode(customCoding);
+							if(StringUtils.isBlank(dockingPreApplyForm.getGroupCode())) {
+								dockingPreApplyForm.setGroupCode(customCoding);
+							}
 							ObjectMapper mp = new ObjectMapper();
 							String writeValueAsString = null;
 							try {
@@ -275,15 +336,20 @@
 								dockingPreApplyForm.setContent(writeValueAsString);
 							} catch (JsonProcessingException e) {
 							}
+							DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM);
 						}
 						//濡傛灉鏈夐泦鍥㈢爜鍒欐洿鏂版暟鎹�
 						if (isEditDatas) {
 							if (baseModelMap.containsKey(applyId)) {
 								BaseModel baseModel = baseModelMap.get(applyId);
 								//BeanUtilForVCI.copyDeclaredIgnoreCase(baseModelVO, baseModel);
+								String classOid=baseModel.getData().getOrDefault("CODECLSFID","");
+								if(partCoe.equals(classOid)){
+									baseModel.setId(10+customCoding);
+								}
 								DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
-							//	baseModel.setId(customCoding);
-								baseModel.getData().getOrDefault("groupCode",customCoding);
+								//	baseModel.setId(customCoding);
+								baseModel.getData().put("GROUPCODE", customCoding);
 								updateCbos.add(baseModel);//鏇存柊鏁版嵁闆嗗洟code
 							}
 						}
@@ -312,11 +378,11 @@
 				}
 				//淇濆瓨琛ㄥ崟鏁版嵁
 				dockingPreApplyFormService.saveOrUpdateBatch(dockingPreAttrMappings);
-				mdmEngineClient.updateBatchByType(btmName,updateCbos);//淇濆瓨鏁版嵁
+				mdmEngineClient.updateBatchBtypeDatas(btmName, updateCbos);//淇濆瓨鏁版嵁
 			}
-			return R.success("鐢宠鎺ュ彛璋冪敤鎴愬姛");
-		}catch (VciBaseException e){
-			return R.fail("鐢宠鎺ュ彛璋冪敤澶辫触"+e.getMessage());
+			return R.success("鏇存柊鎺ュ彛璋冪敤鎴愬姛");
+		} catch (VciBaseException e) {
+			return R.fail("鏇存柊鎺ュ彛璋冪敤澶辫触" + e.getMessage());
 		}
 	}
 
@@ -330,6 +396,10 @@
 	public R queryClassModel(String groupClassifyId) throws Throwable {
 		log.info("鑾峰彇闆嗗洟妯″瀷璇︾粏淇℃伅鎵ц淇濆瓨start");
 		String message="鎵ц鎴愬姛锛�";
+		if(!usedFlag){
+			log.info("鑾峰彇闆嗗洟妯″瀷璇︾粏淇℃伅鎵ц淇濆瓨鍔熻兘宸插叧闂紒->"+usedFlag);
+			return R.fail("鑾峰彇闆嗗洟妯″瀷璇︾粏淇℃伅鎺ュ彛宸插叧闂�!");
+		}
 		try {
 			if (StringUtils.isBlank(groupClassifyId)) {
 				message = "鍙傛暟锛氶泦鍥㈠垎绫讳富閿紝涓虹┖!";
@@ -354,19 +424,19 @@
 					log.info(message);
 					throw new Throwable(message);
 				}
-			}else{
-				message="鏈粠闆嗗洟鑾峰彇鍒颁换浣曟ā鍨嬩俊鎭�";
+			} else {
+				message = "鏈粠闆嗗洟鑾峰彇鍒颁换浣曟ā鍨嬩俊鎭�";
 				log.info(message);
 				throw new Throwable(message);
 			}
 			return R.success(message);
-		}catch (Throwable e){
-			e.printStackTrace();;
-			log.error("鑾峰彇鏁版嵁妯″瀷璇︾粏淇℃伅澶辫触"+e);
-			R.fail(message);
+		} catch (Throwable e) {
+			e.printStackTrace();
+			log.error("鑾峰彇鏁版嵁妯″瀷璇︾粏淇℃伅澶辫触" + e);
+			return R.fail(message);
+		}finally {
+			log.info("鑾峰彇闆嗗洟妯″瀷璇︾粏淇℃伅鎵ц淇濆瓨end");
 		}
-		log.info("鑾峰彇闆嗗洟妯″瀷璇︾粏淇℃伅鎵ц淇濆瓨end");
-		return R.success(message);
 	}
 
 	/***
@@ -378,6 +448,10 @@
 	public R queryMdmModel() throws Throwable {
 		String message="鎵ц鎴愬姛锛�";
 		log.info("浠庨泦鍥㈣幏鍙栦富妯″瀷淇℃伅鎵ц淇濆瓨鎺ュ彛statr");
+		if(!usedFlag){
+			log.info("浠庨泦鍥㈣幏鍙栦富妯″瀷淇℃伅鎵ц淇濆瓨鎺ュ彛鍔熻兘宸插叧闂紒->"+usedFlag);
+			return R.fail("鏌ヨ妯″瀷瑙嗗浘鎺ュ彛宸插叧闂�!");
+		}
 		try {
 			if (StringUtils.isBlank(dockingApplySysName)) {
 				message = "鑾峰彇绯荤粺鏍囪瘑" + dockingApplySysName + "涓虹┖锛岃鏌ョ湅閰嶇疆锛�";
@@ -444,7 +518,7 @@
 			}
 			return R.success(message);
 		}catch (Throwable e){
-			e.printStackTrace();;
+			e.printStackTrace();
 			log.error("鑾峰彇鏁版嵁妯″瀷澶辫触"+e);
 			R.fail(message);
 		}
@@ -461,7 +535,10 @@
 	 */
 	@Override
 	public R queryApplyState(String dataOids) throws VciBaseException {
-
+		if(!usedFlag){
+			log.info("鏌ヨ鐢宠鍗曠姸鎬佹帴鍙e紑鍏冲凡鍏抽棴");
+			return R.fail("鏌ヨ鐢宠鍗曠姸鎬佹帴鍙e紑鍏冲凡鍏抽棴");
+		}
 		String message="鎵ц鎴愬姛锛�";
 		log.info("鏌ヨ鐢宠鍗曠姸鎬佹帴鍙tatr");
 		try {
@@ -483,8 +560,9 @@
 			int code=dockingApplyFormQueryStatusVO.getCode();
 			String mesg=dockingApplyFormQueryStatusVO.getMsg();
 			if(code==1){
+				message=mesg;
 				List<DockingApplyFormStatusVO> dockingApplyFormStatusVOList=dockingApplyFormQueryStatusVO.getData();
-				if(CollectionUtils.isEmpty(dockingApplyFormStatusVOList)){
+				if(!CollectionUtils.isEmpty(dockingApplyFormStatusVOList)){
 					for (DockingApplyFormStatusVO applyFormDataState : dockingApplyFormStatusVOList) {
 						String applyId=applyFormDataState.getApplyNum();
 						String state= applyFormDataState.getFormState();
@@ -496,20 +574,23 @@
 						}
 					}
 					boolean res=this.dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList);
-					if(res){
-						R.success("鐢宠闆嗗洟鐮佺姸鎬佹煡璇㈡垚鍔�:"+mesg);
-					}
 				}else{
 					throw new Throwable("娌℃湁鑾峰彇鍒扮浉鍏虫暟鎹俊鎭�");
 				}
 			}else{
-				throw new	Throwable(mesg);
+				message=mesg;
+				dockingPreApplyFormList.stream().forEach(dockingPreApplyForm -> {
+					dockingPreApplyForm.setMsg("鐢宠鍗曟煡鐪嬪け璐ワ細"+mesg);
+				});
+				this.dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList);
+				throw new Throwable(message);
 			}
 
 		}catch (Throwable e){
-			e.printStackTrace();;
+			e.printStackTrace();
+			//message=""+e;
 			log.error("鑾峰彇鐢宠鍗曠姸鎬佸け璐�"+e);
-			throw  new VciBaseException(message);
+			throw  new VciBaseException(e.getMessage());
 		}
 		log.info("鏌ヨ鐢宠鍗曠姸鎬佹帴鍙nd");
 		return R.success(message);
@@ -524,6 +605,10 @@
 	 */
 	@Override
 	public R syncClassifyModel(String classifyId, String operationType) throws VciBaseException {
+		if(!usedFlag){
+			log.info("鍚屾闆嗗洟妯″瀷淇℃伅寮�鍏冲凡鍏抽棴");
+			return R.fail("鍚屾闆嗗洟妯″瀷淇℃伅寮�鍏冲凡鍏抽棴");
+		}
 		VciBaseUtil.alertNotNull(operationType,"闆嗘垚鎿嶄綔绫诲瀷");
 		try {
 			if(operationType.equals("all")){
@@ -548,9 +633,9 @@
 	 */
 	private boolean saveDatas(DockingQueryClassModelVO dockingQueryClassifyModelVO) throws Throwable {
 		try {
-			DockingClassifyMainVO mainData = dockingQueryClassifyModelVO.getMainData();
-			List<DockingClassifyVO> classList = mainData.getClassList();
-			Map<String,List<DockingClassifyViewVO>>classInfoMap = mainData.getClassInfos();
+			DockingClassifyMainVO data = dockingQueryClassifyModelVO.getData();
+			List<DockingClassifyVO> classList = data.getClassList();
+			Map<String,List<DockingClassifyViewVO>>classInfoMap = data.getClassInfos();
 			////initVCIInvocationInfo("1");
 			List<DockingPreClassify> dockingPreClassifyArrayList=new ArrayList<>();
 			for (DockingClassifyVO jclassObject : classList) {
@@ -569,6 +654,7 @@
 				log.info("classify:-------------->閾炬帴鍚嶇О:"+nodeLinkName);
 
 				if (dockingPreClassify == null || StringUtils.isBlank(dockingPreClassify.getOid())) {
+					dockingPreClassify=new DockingPreClassify();
 					DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreClassify,MdmBtmTypeConstant.DOCKING_PRE_JCLASSIFY);
 				} else {
 					DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreClassify);
@@ -609,14 +695,14 @@
 			Map<String, DockingPreViewModel> jviewmodelMap = new HashMap<String, DockingPreViewModel>();
 			//Map<String, String> condtionMa = new HashMap<String, String>();
 			//	condtionMa.put("jsourceclsfid", jclassId);
-			List<DockingPreViewModel> dockingPreViewModelList= dockingPreViewModelService.list(Wrappers.<DockingPreViewModel>query().lambda().eq(DockingPreViewModel::getSourceClassifyId,false));// 鏍规嵁鍒嗙被鏌ヨ妯″瀷瑙嗗浘瀵硅薄
+			List<DockingPreViewModel> dockingPreViewModelList= dockingPreViewModelService.list(Wrappers.<DockingPreViewModel>query().lambda().eq(DockingPreViewModel::getSourceClassifyId,jclassId));// 鏍规嵁鍒嗙被鏌ヨ妯″瀷瑙嗗浘瀵硅薄
 			for (DockingPreViewModel dockingPreViewModel : dockingPreViewModelList) {
 				jviewmodelMap.put(dockingPreViewModel.getViewName(),dockingPreViewModel);
 			}
 
 			for (DockingClassifyViewVO viewInfo : list) {
 				String viewName = com.alibaba.cloud.commons.lang.StringUtils.isBlank(viewInfo.getViewName())?"":viewInfo.getViewName();
-				String impactList = com.alibaba.cloud.commons.lang.StringUtils.isBlank(viewInfo.getImpactList())?"":viewInfo.getImpactList();
+				String impactList = viewInfo.getImpactList() == null ? "" : viewInfo.getImpactList().get(0).get(0);
 				log.info("VilewMode:-------------->瑙嗗浘鍚嶇О:"+viewName);
 				log.info("VilewMode:-------------->褰卞搷缂栫爜椤�:"+impactList);
 				log.info("VilewMode:--------------> 闆嗗洟鍒嗙被涓婚敭:"+jclassId);
@@ -664,7 +750,7 @@
 				.eq(DockingPreMetaAttr::getSourceClassifyId,jclassId).eq(DockingPreMetaAttr::getViewModelId,jviewModelObject.getOid())
 				.eq(DockingPreMetaAttr:: getPid,pid));
 			Map<String,DockingPreMetaAttr> jmetaattrMap = dockingPreMetaAttrList.stream().filter(
-				s -> com.alibaba.cloud.commons.lang.StringUtils.isNotBlank(s.getEnglishName())).collect(Collectors.toMap(s -> s.getEnglishName().toLowerCase(Locale.ROOT), t -> t));
+				s -> com.alibaba.cloud.commons.lang.StringUtils.isNotBlank(s.getEnglishName())).collect(Collectors.toMap(s -> s.getEnglishName(), t -> t));
 
 			for (DockingClassifyMetaAttrVO dockingClassifyMetaAttrVO : metaList) {
 				String chineseName = com.alibaba.cloud.commons.lang.StringUtils.isBlank(dockingClassifyMetaAttrVO.getChineseName())?"":dockingClassifyMetaAttrVO.getChineseName();// 灞炴�у悕绉�
@@ -709,6 +795,8 @@
 					List<DockingClassifyMetaAttrVO> childMetaList = new ArrayList<>();
 					childMetaList.add(compositeMeta);
 					getMetaAttrObject(childMetaList, jclassId,jviewModelObject, pid,allDockingPreMetaAttrList);
+				}else{
+					allDockingPreMetaAttrList.add(dockingPreMetaAttr);
 				}
 
 			}
@@ -731,6 +819,7 @@
 	 */
 	private void getRange(DockingPreMetaAttr metaAttrObject,Map<String, String> range) throws Throwable {
 		String metaAttrOid = com.alibaba.cloud.commons.lang.StringUtils.isBlank(metaAttrObject.getOid())?"":metaAttrObject.getOid();// 灞炴�х殑oid
+
 		String jchinesename = com.alibaba.cloud.commons.lang.StringUtils.isBlank(metaAttrObject.getChineseName())?"":metaAttrObject.getChineseName();
 		Map<String, DockingPreAttrRange> rangeMap = new HashMap<>();
 		try {
@@ -738,7 +827,9 @@
 			condtionMa.put("jmetalistid", metaAttrOid);
 			List<DockingPreAttrRange> jmetaattrList = dockingPreAttrRangeService.selectByWrapper(Wrappers.<DockingPreAttrRange>query().lambda()
 				.eq(DockingPreAttrRange::getMetaListId,metaAttrOid));// 鏍规嵁鍒嗙被鏌ヨ妯″瀷瑙嗗浘瀵硅薄
-			rangeMap= jmetaattrList.stream().collect(Collectors.toMap(s -> com.alibaba.cloud.commons.lang.StringUtils.isNotBlank(s.getNumText().toLowerCase(Locale.ROOT))?"":s.getNumText().toLowerCase(Locale.ROOT), t -> t));
+			log.info("鑾峰彇灞炴�х編鍓� 灞炴�d------->"+metaAttrOid);
+			//rangeMap= jmetaattrList.stream().collect(Collectors.toMap(s ->StringUtils.isNotBlank(s.getNumText())?"":s.getNumText(), t -> t));
+			rangeMap=jmetaattrList.stream().filter(data -> data != null && StringUtils.isNotBlank(data.getNumText())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getNumText(), t -> t));
 
 			for (String rangeKey : range.keySet()) {
 				DockingPreAttrRange rangeObject = new DockingPreAttrRange();
@@ -768,43 +859,42 @@
 		}
 	}
 
-
-
-
 	/**
 	 * 缁勭粐鏁版嵁
 	 * */
 	private DockingGroupDataVO queryApplycodeDataObjects(int optationtype,List<BaseModel>  codeWupins,Map<String,DockingPreApplyForm>   addDockingPreApplyFormMap,Map<String,DockingPreApplyForm>  editDockingPreApplyFormMap,Map<String,BaseModel>  codeWupinMap) throws VciBaseException{
 		try {
-			String curUserName = AuthUtil.getUser().getUserName();
+			String curUserName ="28201728"; //AuthUtil.getUser().getUserName();
 			//鐢宠鐨勬暟鎹�
 			List<DockingMainData> mainDataList=new ArrayList<DockingMainData>();
 			for (BaseModel dataBusinessObject : codeWupins) {
 				String format = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date());
-				String codeclsfid = dataBusinessObject.getData().getOrDefault("codeclsfid","");
+				//String codeclsfid = dataBusinessObject.getData().getOrDefault("codeclsfid".toUpperCase(Locale.ROOT),"");
+			 	Map<String,String> dataMap=new CaseInsensitiveMap<>(dataBusinessObject.getData());
+				String codeclsfid=dataMap.getOrDefault("codeclsfid","");
 				String btmName = dataBusinessObject.getBtmname();
 				String oid = dataBusinessObject.getOid();
-
 				DockingPreApplyForm dockingPreApplyForm = new DockingPreApplyForm();
 
 				String dataOid = dataBusinessObject.getOid();
 				Map<String, String> conditionsMap = new HashMap<String, String>();
-				List<DockingPreApplyForm> applyFormObjects = dockingPreApplyFormService.list(Wrappers.<DockingPreApplyForm>query().lambda().eq(DockingPreApplyForm::getDataOid, dataOid).eq(DockingPreApplyForm::getOperationType, optationtype));
+				//List<DockingPreApplyForm> applyFormObjects = dockingPreApplyFormService.list(Wrappers.<DockingPreApplyForm>query().lambda().eq(DockingPreApplyForm::getDataOid, dataOid).eq(DockingPreApplyForm::getOperationType, optationtype));
+			//	DockingPreApplyForm dockingPreApplyForm=new DockingPreApplyForm();
 				String apllyCode = "";
-				if (!CollectionUtils.isEmpty(applyFormObjects)) {
+				/*if (!CollectionUtils.isEmpty(applyFormObjects)) {
 					dockingPreApplyForm = applyFormObjects.get(0);
 					apllyCode = dockingPreApplyForm.getId();
 					editDockingPreApplyFormMap.put(apllyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯�
-				} else {
+				} else {*/
 					apllyCode = dockingApplyUnitCode + "-" + format;
 					dockingPreApplyForm.setId(apllyCode);
 					dockingPreApplyForm.setName("");
 					dockingPreApplyForm.setOperationType(optationtype+"");
-					dockingPreApplyForm.setDescription(dataBusinessObject.getDescription());//鑾峰彇鏁版嵁鎻忚堪淇℃伅
+					dockingPreApplyForm.setDescription(dataBusinessObject.getId());//鑾峰彇鏁版嵁鎻忚堪淇℃伅
 					dockingPreApplyForm.setDataOid(oid);
 					dockingPreApplyForm.setDataBtmName(btmName);
 					addDockingPreApplyFormMap.put(apllyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯�
-				}
+			//	}
 
 				codeWupinMap.put(apllyCode, dataBusinessObject);//鐢宠鍗曞拰瀵瑰簲鏁版嵁鍏崇郴
 				conditionsMap = new HashMap<String, String>();
@@ -822,6 +912,11 @@
 				mainData.setApplyId(apllyCode);//鐢宠鍗曞彿
 				mainData.setClassName(dockingPreClassify.getNodeLinkName());//鍒嗙被鍚嶇О
 				mainData.setCreateBy(curUserName);//
+				if(optationtype==2) {
+					String groucode=dataBusinessObject.getData().getOrDefault("GROUPCODE","");
+					dockingPreApplyForm.setGroupCode(groucode);
+					mainData.setCustomCoding(groucode);
+				}
 				mainData.setSecretLevel("鍐呴儴");//瀵嗙骇锛岄粯璁や负鍐呴儴
 				mainData.setViewInfos(getviewInfos(optationtype,dockingPreClassify, dataBusinessObject));//鑾峰彇瑙嗗浘妯″瀷
 				mainDataList.add(mainData);
@@ -876,7 +971,7 @@
 		//鏋勯�犳ā鍨嬭鍥炬暟鎹�
 		List<Map<String, Object>> viewValueList=new ArrayList<Map<String,Object>>();
 		String oid = dockingPreViewModel.getOid();
-		Map<String,String> dataValueMap=dataBusinessObject.getData();
+		Map<String,String> dataValueMap=new CaseInsensitiveMap<>(dataBusinessObject.getData());
 		String codeClassifyId=dataValueMap.get("codeclsfid");
 		Map<String,String>conditionsMap=new HashMap<String, String>();
 		List<DockingPreAttrMapping> dockingPreAttrMappingList = dockingPreAttrMappingMapper.selectList(Wrappers.<DockingPreAttrMapping>query().lambda()
@@ -903,7 +998,16 @@
 				Object newVaue=null;
 				if(StringUtils.isNotBlank(jtargetattrkey)){
 					getAttrRange(dockingPreMetaAttr);//鑾峰彇瀛楁鍙栧�艰寖鍥�
-					String value=dataValueMap.get(jtargetattrkey)==null?"":dataValueMap.getOrDefault(jtargetattrkey,"");
+					String value="";
+					if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("name")){
+						value=dataBusinessObject.getName();
+					}else if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("id")){
+						value=dataBusinessObject.getId();
+					}else if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("description")){
+						value=dataBusinessObject.getDescription();
+					}else{
+						value=dataValueMap.get(jtargetattrkey)==null?"":dataValueMap.getOrDefault(jtargetattrkey,"");
+					}
 					newVaue = getVaue(dockingPreMetaAttr, value);
 				}else{
 					newVaue = getVaue(dockingPreMetaAttr, "");
@@ -911,6 +1015,7 @@
 				if(newVaue==null||"".equals(newVaue)){
 					newVaue= dockingPreMetaAttr.getDefaultValue();
 				}
+				//newVaue= Func.isNotEmpty(newVaue)?newVaue:"";
 				viewValueMap.put(jenglishname, newVaue);
 			}
 		}
@@ -976,7 +1081,7 @@
 				return null;
 			}else {
 				try {
-					return simpleDateFormat.parse(value);
+					return simpleDateFormat.format(simpleDateFormat.parse(value));
 				} catch (ParseException e) {
 					throw new VciBaseException("date", new String[]{"鏃ユ湡鏍煎紡杞崲閿欒"});
 				}
@@ -987,7 +1092,7 @@
 				return null;
 			}else{
 				try {
-					return simpleDateFormat.parse(value);
+					return simpleDateFormat.format(simpleDateFormat.parse(value));
 				} catch (ParseException e) {
 					throw new VciBaseException("date", new String[]{"鏃ユ湡鏍煎紡杞崲閿欒"});
 				}

--
Gitblit v1.9.3