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 6afa76d..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.success("鐢宠鎺ュ彛璋冪敤鎴愬姛"+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