From 309de8506f5e08dea1c8fdd0d377f0884aa21dd7 Mon Sep 17 00:00:00 2001 From: ludc Date: 星期一, 18 三月 2024 18:21:39 +0800 Subject: [PATCH] 集成相关更改 --- Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java | 81 ++++++++++++++++++++++++++++++---------- 1 files changed, 61 insertions(+), 20 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java index 49df7b6..344f981 100644 --- a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java +++ b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java @@ -2,6 +2,7 @@ import com.alibaba.cloud.commons.lang.StringUtils; import com.alibaba.fastjson.JSONObject; +import com.alibaba.nacos.shaded.com.google.protobuf.ServiceException; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.vci.ubcs.code.applyjtcodeservice.entity.*; import com.vci.ubcs.code.applyjtcodeservice.feign.IMdmInterJtClient; @@ -12,10 +13,13 @@ import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil; import com.vci.ubcs.starter.util.MdmBtmTypeConstant; import lombok.AllArgsConstructor; +import lombok.Data; import lombok.extern.slf4j.Slf4j; +import org.jetbrains.annotations.NotNull; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.RestController; @@ -30,9 +34,13 @@ @NonDS @ApiIgnore @RestController -@AllArgsConstructor +@Data @Slf4j public class MdmInterJtClient implements IMdmInterJtClient { + + @Value("${docking.apply.partCoe:10}") + public String partCoe; + /** * 闆嗗洟鐢宠鍗曟湇鍔� */ @@ -53,6 +61,10 @@ */ private final IDockingPreClassifyService dockingPreClassifyService; + /*** + * 灞炴�ф槧灏勬湇鍔� + */ + private final IDockingPreAttrMappingService dockingPreAttrMappingService; /** * 闆嗗洟鍙栧�艰寖鍥寸敵璇峰崟鏈嶅姟 @@ -66,6 +78,7 @@ @Autowired(required = false) private IMdmEngineClient mdmEngineClient; + /*** * 鐢宠闆嗗洟缂栫爜 * @return @@ -77,6 +90,22 @@ return R.fail("闆嗗洟鐮佺敵璇峰け璐ワ細"+e.getMessage()); } } + + /*** + * 鏌ヨ闆嗗洟灞炴�ф槧灏� + * @param codeClassifyOid:缂栫爜鍒嗙被oid + * @return + */ + @Override + public R<List<DockingPreAttrMappingVO>> list_mapping(String codeClassifyOid) { + List<DockingPreAttrMapping> dockingPreAttrMappings= dockingPreAttrMappingService.selectByWrapper(Wrappers.<DockingPreAttrMapping>query().lambda().eq(DockingPreAttrMapping::getTargetClassifyId,codeClassifyOid)); + List<DockingPreAttrMappingVO> dockingPreAttrMappingVOList=new ArrayList<>(); + if(!CollectionUtils.isEmpty(dockingPreAttrMappings)){ + dockingPreAttrMappingVOList=dockingPreAttrMappingService.dockingPreAttrMappingDO2VOS(dockingPreAttrMappings,true); + } + return R.data(dockingPreAttrMappingVOList); + } + /*** * 鐢宠闆嗗洟缂栫爜鏁版嵁缁存姢 * @return @@ -90,12 +119,9 @@ } } - - /* * 涓绘暟鎹笟鍔℃湇鍔� */ - /** * 鑾峰彇闆嗗洟闆嗗洟鐮侊紝璧嬪�煎埌涓绘暟鎹� * @param dockingReturnStoreVO @@ -106,7 +132,7 @@ public R getApplyGroupCode(DockingReturnStoreVO dockingReturnStoreVO) { log.info("鑾峰彇闆嗗洟闆嗗洟鐮侊紝璧嬪�煎埌涓绘暟鎹� start"); try { - List<BaseModel> editObjectList = new ArrayList(); + Map<String,List<BaseModel>> editObjectMap = new HashMap<>(); List<DockingPreApplyForm> dockingPreApplyFormList = new ArrayList(); //String classId = javaObject.getClassId(); @@ -165,23 +191,38 @@ String jdataid = dockingPreApplyForm.getDataOid(); String jdatabtmname = dockingPreApplyForm.getDataBtmName(); if (res) { - //姝ゅ闇�瑕佹煡璇笟鍔℃暟鎹紝鍘绘洿鏀� - BaseModel baseModel = new BaseModel(); - baseModel.setId(customCoding); - log.info("鐢宠鍗�:"+applyId+",闆嗗洟鐮侊細"+customCoding+"缂栫爜锛�"+baseModel.getId()); - editObjectList.add(baseModel); + R<List<BaseModel>> R = mdmEngineClient.selectByTypeAndOid(jdatabtmname,jdataid); + if(R.isSuccess()){ + List<BaseModel> oldDatalist=new ArrayList<>(); + List<BaseModel> newDatalist=R.getData(); + if(!CollectionUtils.isEmpty(newDatalist)){ + if(editObjectMap.containsKey(jdatabtmname)){ + oldDatalist=editObjectMap.getOrDefault(jdatabtmname,new ArrayList<>()); + } + BaseModel baseModel=oldDatalist.get(0); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel); + baseModel.setLastModifyTime(new Date()); + baseModel.getData().put("groupcode",customCoding); + log.info("鐢宠鍗�:"+applyId+",闆嗗洟鐮侊細"+customCoding+"缂栫爜锛�"+baseModel.getId()); + oldDatalist.add(baseModel); + editObjectMap.put(jdatabtmname,oldDatalist); + } + } } - List<String> dataOidList=new ArrayList<>(); - dataOidList.add(jdataid); - //璋冪敤涓绘暟鎹湇鍔℃壒閲忎繚瀛樻帴鍙� - mdmEngineClient.updateBatchByType(jdatabtmname,editObjectList); } - dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList); - + if(!CollectionUtils.isEmpty(editObjectMap)) { + //璋冪敤涓绘暟鎹湇鍔℃壒閲忎繚瀛樻帴鍙� + editObjectMap.forEach((btmName, modeList) -> { + mdmEngineClient.updateBatchBtypeDatas(btmName, modeList); + }); + } + if(!CollectionUtils.isEmpty(dockingPreApplyFormList)){ + dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList); + } }catch (Throwable e){ e.printStackTrace(); - return R.fail("闆嗗洟鐮侀泦鎴愯祴鍊煎け璐�"+e); + return R.fail("闆嗗洟鐮侀泦鎴愯祴鍊煎け璐ワ紝鍘熷洜锛�"+e.getMessage()); } log.info("鑾峰彇闆嗗洟闆嗗洟鐮侊紝璧嬪�煎埌涓绘暟鎹� end"); return R.success("闆嗗洟鐮佽祴鍊兼垚鍔�"); @@ -259,13 +300,14 @@ throw new Throwable("瀛樺偍瑙嗗浘妯″瀷鍑虹幇闂"); } } + /*** * 鑾峰彇鍒嗙被瑙嗗浘 * * @param jclassObject * @throws Throwable */ - private void getVilewMode(DockingClassifyVO jclassObject, List<DockingClassifyViewVO> list) + private void getVilewMode(@NotNull DockingClassifyVO jclassObject, List<DockingClassifyViewVO> list) throws Throwable { String nodeLinkName = jclassObject.getNodeLinkName(); try { @@ -280,7 +322,7 @@ for (DockingClassifyViewVO viewInfo : list) { String viewName =StringUtils.isBlank(viewInfo.getViewName())?"":viewInfo.getViewName(); - String impactList = 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); @@ -314,7 +356,6 @@ throw new Throwable("缁勭粐鍒嗙被" + nodeLinkName + "妯″瀷瑙嗗浘瀛樺偍鍑虹幇闂"); } } - /*** * 鑾峰彇妯″瀷瑙嗗浘灞炴�� -- Gitblit v1.9.3