From 4ed0e9d8ed0e785e62c0f9deb299445e5947c364 Mon Sep 17 00:00:00 2001 From: xiejun <xj@2023> Date: 星期四, 14 九月 2023 15:43:42 +0800 Subject: [PATCH] PDM 集团码提示信息bug修改 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java | 9 +++- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java | 2 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java | 8 +++ Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/DockingManagementController.java | 50 +++++++++++++++++------- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java | 2 Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java | 18 ++++++-- 6 files changed, 64 insertions(+), 25 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 113b4af..49df7b6 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 @@ -7,6 +7,7 @@ import com.vci.ubcs.code.applyjtcodeservice.feign.IMdmInterJtClient; import com.vci.ubcs.code.applyjtcodeservice.service.*; import com.vci.ubcs.code.applyjtcodeservice.vo.*; +import com.vci.ubcs.code.feign.IMdmEngineClient; import com.vci.ubcs.starter.revision.model.BaseModel; import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil; import com.vci.ubcs.starter.util.MdmBtmTypeConstant; @@ -14,6 +15,7 @@ import lombok.extern.slf4j.Slf4j; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.RestController; @@ -62,7 +64,8 @@ */ private final IGroupMdmInterService groupMdmInterService; - + @Autowired(required = false) + private IMdmEngineClient mdmEngineClient; /*** * 鐢宠闆嗗洟缂栫爜 * @return @@ -81,7 +84,7 @@ @Override public R receiveEditApply(String oids, String btmName) { try { - return groupMdmInterService.applyGroupCode(oids,btmName); + return groupMdmInterService.receiveEditApply(oids,btmName); }catch (Throwable e){ return R.fail("闆嗗洟鐮佹暟鎹慨鏀瑰け璐ワ細"+e.getMessage()); } @@ -159,18 +162,23 @@ //杩斿洖缁撴灉淇℃伅 dockingPreApplyForm.setContent(jcontent.toJSONString()); dockingPreApplyFormList.add(dockingPreApplyForm); + String jdataid = dockingPreApplyForm.getDataOid(); + String jdatabtmname = dockingPreApplyForm.getDataBtmName(); if (res) { - String jdataid = dockingPreApplyForm.getDataOid(); - String jdatabtmname = dockingPreApplyForm.getDataBtmName(); + //姝ゅ闇�瑕佹煡璇笟鍔℃暟鎹紝鍘绘洿鏀� BaseModel baseModel = new BaseModel(); baseModel.setId(customCoding); log.info("鐢宠鍗�:"+applyId+",闆嗗洟鐮侊細"+customCoding+"缂栫爜锛�"+baseModel.getId()); editObjectList.add(baseModel); } + List<String> dataOidList=new ArrayList<>(); + dataOidList.add(jdataid); + //璋冪敤涓绘暟鎹湇鍔℃壒閲忎繚瀛樻帴鍙� + mdmEngineClient.updateBatchByType(jdatabtmname,editObjectList); } dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList); - //璋冪敤涓绘暟鎹湇鍔℃壒閲忎繚瀛樻帴鍙� + }catch (Throwable e){ e.printStackTrace(); return R.fail("闆嗗洟鐮侀泦鎴愯祴鍊煎け璐�"+e); diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java index b335410..1e4f607 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java @@ -251,6 +251,6 @@ Map<String,String> codtionMap=new HashMap<>(); codtionMap.put("oid",oid); codtionMap.put("classifyGroupCode",classifyGroupCode); - return R.data(mdmEngineService.checkGroupCode(codtionMap)); + return mdmEngineService.checkGroupCode(codtionMap); } } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/DockingManagementController.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/DockingManagementController.java index 22eb94d..e73f0da 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/DockingManagementController.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/DockingManagementController.java @@ -58,16 +58,20 @@ private final ICodeDuckingSyncService codeDuckingSyncService; /**绯荤粺闆嗘垚鐨勭郴缁熶俊鎭垪琛� - * @param condtionMap 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 + * @param queryObject 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 *@return 绯荤粺闆嗘垚鐨勭郴缁熶俊鎭樉绀哄璞″垪琛� */ @GetMapping("/gridDockingSystem") @ApiOperationSupport(order = 3) @ApiOperation(value = "鍒嗛〉", notes = "condtionMap") - public R<IPage<DockingSystemVO>> page(Map<String,String> condtionMap,Query query) { - if(!CollectionUtils.isEmpty(condtionMap)){}{ + public R<IPage<DockingSystemVO>> page(BaseQueryObject queryObject) { + Map<String,String> condtionMap=queryObject.getConditionMap(); + Query query=new Query(); + if(CollectionUtils.isEmpty(condtionMap)){ condtionMap=new HashMap<>(); } + query.setCurrent(queryObject.getPage()); + query.setSize(queryObject.getLimit()); IPage<DockingSystem> pages = dockingSystemService.page(Condition.getPage(query),UBCSSqlKeyword.buildConditionByMapString(condtionMap)); return R.data(DockingSystemWrapper.build().pageVO(pages)); } @@ -112,16 +116,20 @@ } /** * 绯荤粺闆嗘垚鍩虹淇℃伅鍒楄〃 - * @param condtionMap 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 + * @param queryObject 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 * @return 绯荤粺闆嗘垚鍩虹淇℃伅鏄剧ず瀵硅薄鍒楄〃 */ @GetMapping("/gridSystemConfig") @ApiOperationSupport(order = 3) @ApiOperation(value = "鍒嗛〉", notes = "dockingSystemConfig") - public R<IPage<DockingSystemConfigVO>> gridSystemConfig(Map<String,String> condtionMap, Query query){ - if(!CollectionUtils.isEmpty(condtionMap)){ + public R<IPage<DockingSystemConfigVO>> gridSystemConfig(BaseQueryObject queryObject){ + Map<String,String> condtionMap=queryObject.getConditionMap(); + Query query=new Query(); + if(CollectionUtils.isEmpty(condtionMap)){ condtionMap=new HashMap<>(); } + query.setCurrent(queryObject.getPage()); + query.setSize(queryObject.getLimit()); IPage<DockingSystemConfigVO> pages=dockingSystemConfigService.page(condtionMap,query); return R.data(pages); } @@ -191,16 +199,20 @@ /** * 寰呴泦鎴愭暟鎹� - * @param condtionMap 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 + * @param queryObject 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 * @return 绯荤粺闆嗘垚鍩虹淇℃伅鏄剧ず瀵硅薄鍒楄〃 */ @GetMapping("/gridDockingData") @ApiOperationSupport(order = 3) @ApiOperation(value = "鍒嗛〉", notes = "DockingDataVO") - public R<IPage<DockingDataVO>> gridDockingData(Map<String,String>condtionMap, Query query){ - if(!CollectionUtils.isEmpty(condtionMap)){ + public R<IPage<DockingDataVO>> gridDockingData(BaseQueryObject queryObject){ + Map<String,String> condtionMap=queryObject.getConditionMap(); + Query query=new Query(); + if(CollectionUtils.isEmpty(condtionMap)){ condtionMap=new HashMap<>(); } + query.setCurrent(queryObject.getPage()); + query.setSize(queryObject.getLimit()); IPage<DockingDataVO> pages = dokingSysManaentService.gridDockingData(condtionMap,query); return R.data(pages); } @@ -208,32 +220,40 @@ /** * data鍒楄〃 - * @param condtionMap 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 + * @param queryObject 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 * @return 绯荤粺闆嗘垚鐨勭郴缁熶俊鎭樉绀哄璞″垪琛� */ @GetMapping("/gridDockingTask") @ApiOperationSupport(order = 3) @ApiOperation(value = "鍒嗛〉", notes = "condtionMap") - public R<IPage<DockingTaskVO>> gridDockingTask(Map<String,String> condtionMap, Query query){ - if(!CollectionUtils.isEmpty(condtionMap)){ + public R<IPage<DockingTaskVO>> gridDockingTask(BaseQueryObject queryObject){ + Map<String,String> condtionMap=queryObject.getConditionMap(); + Query query=new Query(); + if(CollectionUtils.isEmpty(condtionMap)){ condtionMap=new HashMap<>(); } + query.setCurrent(queryObject.getPage()); + query.setSize(queryObject.getLimit()); IPage<DockingTaskVO> pages = dokingSysManaentService.gridDockingTask(condtionMap,query); return R.data(pages); } /** * 鎺ㄩ�佹暟鎹泦鎴愭棩蹇楀垪琛� - * @param condtionMap 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 + * @param queryObject 鍩虹鏌ヨ瀵硅薄锛屽寘鍚煡璇㈡潯浠讹紝鍒嗛〉锛屾帓搴忕瓑 * @return 闆嗘垚鏃ュ織鏄剧ず瀵硅薄鍒楄〃 */ @GetMapping("/gridLoge") @ApiOperationSupport(order = 3) @ApiOperation(value = "鍒嗛〉", notes = "DockingLogeVO") - public R<IPage<DockingLogeVO>> gridLoge(Map<String,String> condtionMap, Query query){ - if(!CollectionUtils.isEmpty(condtionMap)){ + public R<IPage<DockingLogeVO>> gridLoge(BaseQueryObject queryObject){ + Map<String,String> condtionMap=queryObject.getConditionMap(); + Query query=new Query(); + if(CollectionUtils.isEmpty(condtionMap)){ condtionMap=new HashMap<>(); } + query.setCurrent(queryObject.getPage()); + query.setSize(queryObject.getLimit()); IPage<DockingLogeVO> pages = dokingSysManaentService.gridLoge(condtionMap,query); return R.data(pages); } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java index 5047545..c3c5def 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java @@ -321,7 +321,6 @@ * 鍙戦�佺紪鐮佷富鏁版嵁 */ private void sendpushDataForService (List<DockingTask> dockingTaskS){ - //姣忎釜task渚濇鎵ц鎺ㄩ�� for (DockingTask dockingTask:dockingTaskS){ //姣忎釜task涓�涓簨鍔★紝寮�鍚� @@ -368,6 +367,13 @@ } if(isGroupCodeFlage){ code=data.getOrDefault("groupcode",""); + if(StringUtils.isBlank(code)) {//濡傛灉鏄泦鍥㈢爜锛屾病鏈夐鍙栧埌闆嗗洟鐮佸垯浠诲姟涓嶇粨鏉熺瓑寰呴泦鍥㈢爜鐢宠鍚庡啀閫氳繃瀹氭椂鍣ㄨ皟鐢ㄩ泦鍥㈢爜娈� + dockingTask.setDescription("绛夊緟闆嗗洟鐢宠闆嗗洟鐮�"); + dockingTask.setSendFlag(MdmDuckingConstant.SEND_FLAG_FALSE); + dockingTask.setLastModifyTime(new Date()); + dockingTaskService.updateById(dockingTask); + continue; + } } String[] classCodeLeves = dockingTask.getClassifyId().split(","); NodeJosnDTO nodeJosnDTO = new NodeJosnDTO(); diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java index cfa0d29..6aa4bca 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java @@ -753,7 +753,7 @@ */ @Override public R checkGroupCode(Map<String, String> parameter) { - List<CodeClassify> codeClassifyList = classifyService.selectAllLevelParents(parameter.get("oid")); + List<CodeClassify> codeClassifyList = classifyService.selectAllLevelParentByOid(parameter.get("oid")); Set<String> configGroupCode = Arrays.stream(parameter.get("classifyGroupCode").split("#")).collect(Collectors.toSet()); // Boolean checkGroupFlag = false;//鏄惁鏌ヨ鍒伴厤缃殑椤跺眰鍒嗙被涓� for (int i = codeClassifyList.size()-1; i >= 0; i--) { diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java index b835bb7..91ee9bc 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java @@ -2234,7 +2234,8 @@ if(StringUtils.isNotBlank(classOid)){ queryWrapper.in(DockingSystemConfig::getClassifyOid,classOid); } - List<DockingSystemConfig> dockingSystemConfigList= dockingSystemConfigList=dockingSystemConfigService.list(queryWrapper); + List<DockingSystemConfig> dockingSystemConfigList=new ArrayList<>(); + dockingSystemConfigList= dockingSystemConfigList=dockingSystemConfigService.list(queryWrapper); if(!CollectionUtils.isEmpty(dockingSystemConfigList)){ return dockingSystemConfigList.get(0); }else{ @@ -2242,6 +2243,10 @@ return checkIspass(systemId, type, operationType, codeClassifyVO.getParentCodeClassifyOid()); } } - return dockingSystemConfigList.get(0); + if(dockingSystemConfigList.size()>0){ + return dockingSystemConfigList.get(0); + }else{ + return new DockingSystemConfig(); + } } } -- Gitblit v1.9.3