From e608073f05f955bf168a5e42ecfb8200b57a77e3 Mon Sep 17 00:00:00 2001 From: ludc Date: 星期三, 23 八月 2023 09:23:26 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/pagemodel/DockingSystemConfigVO.java | 16 ++ Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/vo/DockingApplyGroupCode.java | 5 Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/controller/DockingPreApplyCodeController.java | 2 Source/UBCS/ubcs-service/ubcs-code/src/main/resources/mapper/DockingSystemConfigMapper.xml | 1 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmIOService.java | 2 Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java | 21 +++ Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/Scheduling/DockingApplyGroupCodeSyncScheduling.java | 55 +++++++++ Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingClassSyncScheduling.java | 2 Source/UBCS/ubcs-codeApply/src/main/java/com/vci/ubcs/codeapply/CodeApplyPanelFor410ActionListener.java | 17 ++ Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java | 10 + Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/CodeApplySwingController.java | 11 + Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java | 36 +++++ Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/xml/XMLResultDataObjectDetailDO.java | 2 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmEngineService.java | 9 + /dev/null | 0 Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingSystemConfigDTO.java | 8 + Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/entity/DockingSystemConfig.java | 59 +++++++++ Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java | 62 ++++++++++ Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/data/data.json | 22 ++- 19 files changed, 313 insertions(+), 27 deletions(-) diff --git a/Source/UBCS/ubcs-codeApply/src/main/java/com/vci/ubcs/codeapply/CodeApplyPanelFor410ActionListener.java b/Source/UBCS/ubcs-codeApply/src/main/java/com/vci/ubcs/codeapply/CodeApplyPanelFor410ActionListener.java index 0b977594..db1ae5c 100644 --- a/Source/UBCS/ubcs-codeApply/src/main/java/com/vci/ubcs/codeapply/CodeApplyPanelFor410ActionListener.java +++ b/Source/UBCS/ubcs-codeApply/src/main/java/com/vci/ubcs/codeapply/CodeApplyPanelFor410ActionListener.java @@ -110,15 +110,28 @@ codeOrderSecDTO.setSecValue(keyValue.getValue()); secDTOList.add(codeOrderSecDTO); }); + codeOrderDTO.setLcStatus("Released"); codeOrderDTO.setSecDTOList(secDTOList); codeOrderDTO.setData(dataMap); Object object = JSONObject.toJSON(codeOrderDTO); Map<String,String> headerMap=new HashMap<>(); headerMap.put("content-type","application/json"); headerMap.put("Blade-Auth",this.owner.getTokenUserObject().getAccess_token()); - R r= HttpUtil.sendPost(url+"/addSaveCode",object.toString(),headerMap); - //R r= HttpUtil.sendPost(url+"/addSaveCode",object.toString(),headerMap); String code=""; + //鏍¢獙鍏抽敭灞炴�у瓨鍦ㄧ殑鏁版嵁鐩存帴杩斿洖缂栫爜 + R checkKeyAttrOnOrderR= HttpUtil.sendPost(url+"/checkKeyAttrOnOrderFordatas",object.toString(),headerMap); + if(checkKeyAttrOnOrderR.isSuccess()){ + List<Map> list=(List)checkKeyAttrOnOrderR.getData(); + if(!CollectionUtils.isEmpty(list)) { + code=list.get(0).get("ID")!=null?list.get(0).get("ID").toString():""; + this.owner.setApplyCode(code); + this.owner.getApplyTxt().requestFocusInWindow(); + this.owner.getApplyTxt().selectAll(); + this.owner.setAttrNameAndValMap(attrNameAndValMap); + return; + } + } + R r= HttpUtil.sendPost(url+"/addSaveCode",object.toString(),headerMap); if(r.isSuccess()){ code=r.getData().toString(); this.owner.setApplyCode(code); diff --git a/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java index 761a940..7882b0c 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java +++ b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java @@ -19,13 +19,30 @@ value = "ubcs-code" ) public interface IMdmInterJtClient { - String API_PREFIX = "/mdmInterService"; + String APPLYGROUPCODE = API_PREFIX + "/applyGroupCode"; String RETURNGROUPCODE = API_PREFIX + "/getApplyGroupCode"; - String PUBMDMMODEL = API_PREFIX + "/pubMdmModel"; + String RECEIVE_EDITAPPLY =API_PREFIX + "/receiveEditApply"; + + /*** + * 灏嗛泦鍥㈢敵璇锋垚鍔熺殑缂栫爜瀛樺叆鐩稿叧鏁版嵁涔嬩腑 + * @param oids + * @param btmName + * @return 杩斿洖瀛樺偍鏄惁鎴愬姛淇℃伅 + */ + @GetMapping(APPLYGROUPCODE) + public R applyGroupCode(String oids,String btmName); + /*** + * 闆嗗洟缂栫爜鏁版嵁淇敼 + * @param oids + * @param btmName + * @return 杩斿洖瀛樺偍鏄惁鎴愬姛淇℃伅 + */ + @PostMapping(RECEIVE_EDITAPPLY) + public R receiveEditApply(String oids,String btmName); /*** * 灏嗛泦鍥㈢敵璇锋垚鍔熺殑缂栫爜瀛樺叆鐩稿叧鏁版嵁涔嬩腑 diff --git a/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/vo/DockingApplyGroupCode.java b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/vo/DockingApplyGroupCode.java new file mode 100644 index 0000000..ae01f14 --- /dev/null +++ b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/vo/DockingApplyGroupCode.java @@ -0,0 +1,5 @@ +package com.vci.ubcs.code.applyjtcodeservice.vo; + +public class DockingApplyGroupCode { + +} diff --git a/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/data/data.json b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/data/data.json index ffb9747..d982538 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/data/data.json +++ b/Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/data/data.json @@ -1,10 +1,16 @@ { - "parentOid":"XJ-FC9B6-FE27-241F-5FCA-ED4DC17CF95B", - "parentBtmName":"jclass", - "valueField":"oid", - "textField":"name", - "parentFieldName":"id", - "conditionMap":[{ - "codeclsfid": "XJ-FC9B6-FE27-241F-5FCA-ED4DC17CF95B" - }] + "data": { + "systemId": "MPM", + "user": { + "userName": "weidy", + "trueName": "榄忓ぇ鍕�", + "ip": "127.0.0.1" + }, + "library": { + "id": "wupin", + "classifyid":[ + "020202" + ] + } + } } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingLogeDO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingLogeDO.java deleted file mode 100644 index e69de29..0000000 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingLogeDO.java +++ /dev/null diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingSystemConfigDTO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingSystemConfigDTO.java index d5d0221..54a243f 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingSystemConfigDTO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/dto/DockingSystemConfigDTO.java @@ -252,11 +252,14 @@ * header淇℃伅瀵硅薄 */ private List<DockingSysIntHeaderDTO> sysIntHeaderDTOS; - + /*** + * 闆嗗洟鐮佹槸鍚﹀弬涓庣敵璇�/鏇存柊/鍙戦�� + */ + private String isGroupCodeFlag; @Override public String toString() { - return "SysIntInfoDTO{" + + return "DockingSystemConfigDTO{" + "authorityOid='" + authorityOid + '\'' + ", authorityOidName='" + authorityOidName + '\'' + ", authorityType='" + authorityType + '\'' + @@ -303,6 +306,7 @@ ", classifyName='" + classifyName + '\'' + ", sysIntParamDTOS=" + sysIntParamDTOS + ", sysIntHeaderDTOS=" + sysIntHeaderDTOS + + ", isGroupCodeFlag=" + isGroupCodeFlag + '}'; } } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/entity/DockingSystemConfig.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/entity/DockingSystemConfig.java index b775a19..1d2a57c 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/entity/DockingSystemConfig.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/entity/DockingSystemConfig.java @@ -312,4 +312,63 @@ */ @ApiModelProperty(value = "鍒嗙被鍚嶇О") private String classifyName; + + /*** + * 闆嗗洟鐮佹槸鍚﹀弬涓庣敵璇�/鏇存柊/鍙戦�� + */ + /** + * 鍒嗙被鍚嶇О + */ + @ApiModelProperty(value = "闆嗗洟鐮佹槸鍚﹀弬涓庣敵璇�/鏇存柊/鍙戦��") + private String isGroupCodeFlag; + + @Override + public String toString() { + return "DockingSystemConfig{" + + "authorityOid='" + authorityOid + '\'' + + ", authorityOidName='" + authorityOidName + '\'' + + ", authorityType='" + authorityType + '\'' + + ", authorityTypeText='" + authorityTypeText + '\'' + + ", userAccount='" + userAccount + '\'' + + ", userCode='" + userCode + '\'' + + ", token='" + token + '\'' + + ", interfaceFunction='" + interfaceFunction + '\'' + + ", interfaceType='" + interfaceType + '\'' + + ", interfaceTypeText='" + interfaceTypeText + '\'' + + ", paramType='" + paramType + '\'' + + ", paramTypeText='" + paramTypeText + '\'' + + ", requestMethod='" + requestMethod + '\'' + + ", requestMethodText='" + requestMethodText + '\'' + + ", classifyOid='" + classifyOid + '\'' + + ", usedFlag='" + usedFlag + '\'' + + ", sysBaseOid='" + sysBaseOid + '\'' + + ", sysBaseId='" + sysBaseId + '\'' + + ", sysBaseName='" + sysBaseName + '\'' + + ", requestUrl='" + requestUrl + '\'' + + ", returnType='" + returnType + '\'' + + ", returnTypeText='" + returnTypeText + '\'' + + ", sourceSystemOid='" + sourceSystemOid + '\'' + + ", sourceSysName='" + sourceSysName + '\'' + + ", sourceSysId='" + sourceSysId + '\'' + + ", sourceSystemOidName='" + sourceSystemOidName + '\'' + + ", targetSystemOid='" + targetSystemOid + '\'' + + ", targetSysName='" + targetSysName + '\'' + + ", targetSysId='" + targetSysId + '\'' + + ", targetSystemOidName='" + targetSystemOidName + '\'' + + ", classPath='" + classPath + '\'' + + ", dataFlowType='" + dataFlowType + '\'' + + ", dataFlowTypeText='" + dataFlowTypeText + '\'' + + ", btmTypeId='" + btmTypeId + '\'' + + ", btmTypeName='" + btmTypeName + '\'' + + ", namespace='" + namespace + '\'' + + ", soapAction='" + soapAction + '\'' + + ", cxfAxis='" + cxfAxis + '\'' + + ", targetName='" + targetName + '\'' + + ", pushType='" + pushType + '\'' + + ", pushTypeText='" + pushTypeText + '\'' + + ", classifyId='" + classifyId + '\'' + + ", classifyName='" + classifyName + '\'' + + ", isGroupCodeFlag=" + isGroupCodeFlag + + '}'; + } } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/pagemodel/DockingSystemConfigVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/pagemodel/DockingSystemConfigVO.java index de9096b..2b2b23b 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/pagemodel/DockingSystemConfigVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/pagemodel/DockingSystemConfigVO.java @@ -237,7 +237,10 @@ * 鍒嗙被鍚嶇О */ private String classifyName; - + /*** + * 闆嗗洟鐮佹槸鍚﹀弬涓庣敵璇�/鏇存柊/鍙戦�� + */ + private String isGroupCodeFlag; /*** * 鍙傛暟淇℃伅瀵硅薄 */ @@ -618,9 +621,17 @@ this.sysIntHeaderVOs = sysIntHeaderVOs; } + public String getIsGroupCodeFlag() { + return isGroupCodeFlag; + } + + public void setIsGroupCodeFlag(String isGroupCodeFlag) { + this.isGroupCodeFlag = isGroupCodeFlag; + } + @Override public String toString() { - return "SysIntInfoVO{" + + return "DockingSystemConfigVO{" + "authorityOid='" + authorityOid + '\'' + ", authorityOidName='" + authorityOidName + '\'' + ", authorityType='" + authorityType + '\'' + @@ -665,6 +676,7 @@ ", pushTypeText='" + pushTypeText + '\'' + ", classifyId='" + classifyId + '\'' + ", classifyName='" + classifyName + '\'' + + ", isGroupCodeFlag=" + isGroupCodeFlag + ", sysIntParamVOs=" + sysIntParamVOs + ", sysIntHeaderVOs=" + sysIntHeaderVOs + '}'; diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/xml/XMLResultDataObjectDetailDO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/xml/XMLResultDataObjectDetailDO.java index 70ef140..4ad6ec6 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/xml/XMLResultDataObjectDetailDO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/xml/XMLResultDataObjectDetailDO.java @@ -26,7 +26,7 @@ this.id = id; } - public String getErrorid() { + public String getErrorid() { return errorid; } diff --git a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/Scheduling/DockingApplyGroupCodeSyncScheduling.java b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/Scheduling/DockingApplyGroupCodeSyncScheduling.java new file mode 100644 index 0000000..4b5b57b --- /dev/null +++ b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/Scheduling/DockingApplyGroupCodeSyncScheduling.java @@ -0,0 +1,55 @@ +package com.vci.ubcs.code.applyjtcodeservice.Scheduling; + +import com.vci.ubcs.starter.web.enumpck.BooleanEnum; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import javax.annotation.Resource; +import java.text.SimpleDateFormat; +import java.util.Date; + +/** + * 闆嗘垚浠诲姟瀹氭椂鍣� + * 鎻掑叆dockingtask涓� + * 浠巇ockingtask涓彇鍑烘潵鏁版嵁锛屾帹閫佸嚭鍘荤殑鎿嶄綔 + */ +@Component +@Slf4j +public class DockingApplyGroupCodeSyncScheduling { + + @Resource + private IGroupCodeDuckingSyncService groupCodeDuckingSyncService; + + @Value("${apply.groupCode.isStart:false}") + public boolean APPLY_GRUPCODE_SYNC_ISSTARE; + + /** + * 鏄惁鍒濆鍖栧畬鎴愪簡 + */ + public static volatile String FINISH_INIT = "false"; + + /** + * 鍦ㄥ垵濮嬪寲瀹屾垚鍚庢墽琛� + */ + @PostConstruct() + public void onInit(){ + FINISH_INIT = "true"; + } + + //榛樿姣忓垎閽熸墽琛屾柟娉� + @Scheduled(cron = "${groupcode.cronTime:0 0/10 * * * ?}") + public void scheduled() { + log.info("鎵ц璋冪敤闆嗗洟缂栫爜鐢宠鎺ュ彛鐢宠闆嗗洟缂栫爜 start:"); + if(APPLY_GRUPCODE_SYNC_ISSTARE && BooleanEnum.TRUE.getValue().equalsIgnoreCase(FINISH_INIT)) { + //a codeDuckingSyncServiceI.DockingClassSyncScheduing(); + SimpleDateFormat formatter= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss."); + String time = formatter.format(new Date()); + String outinfo = "============鍦� "+time+" 鎵ц浜嗗垎绫婚泦鎴愭帹閫�"; + log.info(outinfo); + } + log.info("鎵ц璋冪敤闆嗗洟缂栫爜鐢宠鎺ュ彛鐢宠闆嗗洟缂栫爜 end: "+ "寮�鍏虫槸鍚﹀紑鍚�:" +APPLY_GRUPCODE_SYNC_ISSTARE); + } +} diff --git a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/controller/DockingPreApplyCodeController.java b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/controller/DockingPreApplyCodeController.java index 55c785b..edacf34 100644 --- a/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/controller/DockingPreApplyCodeController.java +++ b/Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/controller/DockingPreApplyCodeController.java @@ -3,9 +3,9 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; +import com.vci.ubcs.code.applyjtcodeservice.service.*; import com.vci.ubcs.code.applyjtcodeservice.entity.DockingPreApplyForm; import com.vci.ubcs.code.feign.ICodeClassifyClient; -import com.vci.ubcs.code.applyjtcodeservice.service.*; import com.vci.ubcs.code.applyjtcodeservice.vo.*; import com.vci.ubcs.code.applyjtcodeservice.vo.collection.DockingPreAttrMappingVOList; import com.vci.ubcs.code.applyjtcodeservice.wrapper.DockingPreApplyFormWrapper; 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 820abb3..113b4af 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 @@ -10,7 +10,6 @@ import com.vci.ubcs.starter.revision.model.BaseModel; import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil; import com.vci.ubcs.starter.util.MdmBtmTypeConstant; -import com.vci.ubcs.starter.web.constant.MdmEnumIdConstant; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.tenant.annotation.NonDS; @@ -48,16 +47,47 @@ private final IDockingPreMetaAttrService dockingPreMetaAttrService; /** - * 闆嗗洟鐢宠鍗曟湇鍔� + * 闆嗗洟鍒嗙被鐢宠鍗曟湇鍔� */ private final IDockingPreClassifyService dockingPreClassifyService; /** - * 闆嗗洟鐢宠鍗曟湇鍔� + * 闆嗗洟鍙栧�艰寖鍥寸敵璇峰崟鏈嶅姟 */ private final IDockingPreAttrRangeService dockingPreAttrRangeService; + /** + * 闆嗗洟灞炴�ф槧灏勯厤缃睘鎬� + */ + private final IGroupMdmInterService groupMdmInterService; + + + /*** + * 鐢宠闆嗗洟缂栫爜 + * @return + */ + public R applyGroupCode(String oids,String btmName){ + try { + return groupMdmInterService.applyGroupCode(oids,btmName); + }catch (Throwable e){ + return R.fail("闆嗗洟鐮佺敵璇峰け璐ワ細"+e.getMessage()); + } + } + /*** + * 鐢宠闆嗗洟缂栫爜鏁版嵁缁存姢 + * @return + */ + @Override + public R receiveEditApply(String oids, String btmName) { + try { + return groupMdmInterService.applyGroupCode(oids,btmName); + }catch (Throwable e){ + return R.fail("闆嗗洟鐮佹暟鎹慨鏀瑰け璐ワ細"+e.getMessage()); + } + } + + /* * 涓绘暟鎹笟鍔℃湇鍔� diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingClassSyncScheduling.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingClassSyncScheduling.java index b0fbc9e..9b136b2 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingClassSyncScheduling.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingClassSyncScheduling.java @@ -43,6 +43,7 @@ //榛樿姣忓垎閽熸墽琛屾柟娉� @Scheduled(cron = "${clsfSyncPush.cronTime:0 0/10 * * * ?}") public void scheduled() { + log.info("鎵ц鍒嗙被闆嗘垚鎺ㄩ�� start:"); if(CLSF_SYNC_PUSH_ISSTARE && BooleanEnum.TRUE.getValue().equalsIgnoreCase(FINISH_INIT)) { codeDuckingSyncServiceI.DockingClassSyncScheduing(); SimpleDateFormat formatter= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss."); @@ -50,5 +51,6 @@ String outinfo = "============鍦� "+time+" 鎵ц浜嗗垎绫婚泦鎴愭帹閫�"; log.info(outinfo); } + log.info("鎵ц鍒嗙被闆嗘垚鎺ㄩ�� end: "+ "寮�鍏虫槸鍚﹀紑鍚�:" +CLSF_SYNC_PUSH_ISSTARE); } } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java index 08a1e3e..315f97a 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java @@ -2,6 +2,7 @@ import com.vci.ubcs.code.service.ICodeDuckingSyncService; import com.vci.ubcs.starter.web.enumpck.BooleanEnum; +import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; @@ -19,9 +20,10 @@ * 浠巇ockingtask涓彇鍑烘潵鏁版嵁锛屾帹閫佸嚭鍘荤殑鎿嶄綔 */ @Component +@Slf4j public class DockingDataSyncScheduling { - private Logger logger = LoggerFactory.getLogger(getClass()); +// private Logger logger = LoggerFactory.getLogger(getClass()); @Resource private ICodeDuckingSyncService codeDuckingSyncServiceI; @@ -45,12 +47,14 @@ //榛樿姣忓垎閽熸墽琛屾柟娉� @Scheduled(cron = "${dataSyncPush.cronTime:0 0/10 * * * ?}") public void scheduled() { + log.info("鎵ц涓绘暟鎹泦鎴愭暟鎹帹閫� start:"); if(DATA_SYNC_PUSH_ISSTARE && BooleanEnum.TRUE.getValue().equalsIgnoreCase(FINISH_INIT)) { codeDuckingSyncServiceI.DockingDataSyncScheduing(); SimpleDateFormat formatter= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss."); String time = formatter.format(new Date()); - String outinfo = "============鍦� "+time+" 鎵ц浜嗕富鏁版嵁闆嗘垚鏁版嵁鎺ㄩ��"; - logger.info(outinfo); + String outinfo = "============ 鎵ц浜嗕富鏁版嵁闆嗘垚鏁版嵁鎺ㄩ��"; + log.info(outinfo); } + log.info("鎵ц涓绘暟鎹泦鎴愭暟鎹帹閫� end: "+ "寮�鍏虫槸鍚﹀紑鍚�:" +DATA_SYNC_PUSH_ISSTARE); } } 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 6e08c7d..5b5112a 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 @@ -226,5 +226,14 @@ public R addSaveCode(@RequestBody CodeOrderDTO orderDTO) throws Exception { return R.data(mdmEngineService.addSaveCode(orderDTO)); } - + /** + * 鐢宠缂栫爜淇濆瓨 + * @param orderDTO 缂栫爜鐢宠鐩稿叧鐨勪俊鎭紝闇�瑕佹湁灞炴�у拰鐮佹鐩稿叧鐨勪俊鎭� + * @return 鎵ц缁撴灉 + */ + @PostMapping("/checkKeyAttrOnOrderFordatas") + @VciBusinessLog(operateName = "鐢宠鍗曚釜缂栫爜") + public R checkKeyAttrOnOrderFordatas(@RequestBody CodeOrderDTO orderDTO) throws Exception { + return R.data(mdmEngineService.checkKeyAttrOnOrderFordatas(orderDTO)); + } } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmEngineService.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmEngineService.java index 674e2fd..2815bf0 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmEngineService.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmEngineService.java @@ -446,4 +446,11 @@ * @return */ R processChangeStatus(FlowStatusDTO flowDTO); -} + + /** + * 鏍¢獙鍏抽敭灞炴�� + * @param orderDTO 缂栫爜鐢宠鐨勭浉鍏崇殑淇℃伅 + */ + public List<Map> checkKeyAttrOnOrderFordatas(CodeOrderDTO orderDTO) ; + + } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmIOService.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmIOService.java index 897b2e7..82dab4b 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmIOService.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/MdmIOService.java @@ -110,5 +110,5 @@ * @param resultDataObjectDetailDOs 閿欒淇℃伅 * @return 鏈夐敊璇俊鎭殑excel */ - void batchSyncApplyCode(CodeOrderDTO orderDTO, DataObjectVO dataObjectVO, LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs); + void batchSyncApplyCode(CodeOrderDTO orderDTO, DataObjectVO dataObjectVO, LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs,boolean isCodeOrGroupCode); } 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 e3cfd10..534b064 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 @@ -683,6 +683,68 @@ } } + /** + * 鏍¢獙鍏抽敭灞炴�� + * + * @param classifyFullInfo 鍒嗙被鐨勫叏閮ㄤ俊鎭� + * @param templateVO 妯℃澘鐨勫唴瀹癸紝蹇呴』鍖呭惈妯℃澘灞炴�� + * @param orderDTO 缂栫爜鐢宠鐨勭浉鍏崇殑淇℃伅 + */ + public List<Map> checkKeyAttrOnOrderFordatas(CodeOrderDTO orderDTO) { + List<Map>dataList=new ArrayList<>(); + CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(orderDTO.getCodeClassifyOid()); + CodeClassifyTemplateVO templateVO = templateService.getObjectHasAttrByOid(orderDTO.getTemplateOid()); + //鍏堣幏鍙栧叧閿睘鎬х殑瑙勫垯锛屼篃鍒╃敤缁ф壙鐨勬柟寮� + CodeKeyAttrRepeatVO keyRuleVO = keyRuleService.getRuleByClassifyFullInfo(classifyFullInfo); + //娉ㄦ剰鐨勬槸keyRuleVO鍙兘涓虹┖锛岃〃绀轰笉浣跨敤瑙勫垯鎺у埗 + //鑾峰彇鎵�鏈夌殑鍏抽敭灞炴�� + Map<String, CodeClassifyTemplateAttrVO> ketAttrMap = templateVO.getAttributes().stream().filter(s -> VciBaseUtil.getBoolean(s.getKeyAttrFlag())).collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t)); + Map<String, String> conditionMap = new HashMap<>(); + boolean trimAll = keyRuleVO == null ? false : VciBaseUtil.getBoolean(keyRuleVO.getIgnoreallspaceflag()); + //鍏ㄩ儴鍘荤┖鐨勪紭鍏堢骇澶т簬鍘荤┖ + boolean trim = keyRuleVO == null ? false : VciBaseUtil.getBoolean(keyRuleVO.getIgnorespaceflag()); + boolean ignoreCase = keyRuleVO == null ? false : VciBaseUtil.getBoolean(keyRuleVO.getIgnorecaseflag()); + boolean ignoreWidth = keyRuleVO == null ? false : VciBaseUtil.getBoolean(keyRuleVO.getIgnorewidthflag()); + ketAttrMap.forEach((attrId, attrVO) -> { + String value = getValueFromOrderDTO(orderDTO, attrId); + if (value == null) { + value = ""; + } + wrapperKeyAttrConditionMap(value, keyRuleVO, attrId, trim, ignoreCase, ignoreWidth, trimAll, conditionMap); + }); + + //娌℃湁闄愬埗鍒嗙被锛屼絾鏄竴涓ā鏉垮彧鍙兘鍦ㄤ竴涓笟鍔$被鍨嬮噷闈紝鎵�浠ョ洿鎺ユ煡璇㈣繖涓笟鍔$被鍨嬪嵆鍙� + if (!CollectionUtils.isEmpty(conditionMap)) { + conditionMap.put("CODETEMPLATEOID","'" + orderDTO.getTemplateOid() + "'"); +// final String[] sql = {"select count(*) from " + VciBaseUtil.getTableName(classifyFullInfo.getTopClassifyVO().getBtmtypeid()) + " t where 1 = 1 "}; + R<List<BtmTypeVO>> listR = btmTypeClient.selectByIdCollection(Collections.singletonList(classifyFullInfo.getTopClassifyVO().getBtmTypeId())); +// String referTable = VciBaseUtil.getTableName(referVO.getReferType()); + if (!listR.isSuccess() || listR.getData().size() == 0) { + throw new VciBaseException("浼犲叆涓氬姟绫诲瀷鏈煡璇㈠埌鐩稿簲琛ㄥ崟锛岃妫�鏌ワ紒"); + } + final String[] sql = {"select * from " + listR.getData().get(0).getTableName() + " t where 1 = 1 "}; + conditionMap.forEach((key, value) -> { + sql[0] += " and " + key + " = " + value; + }); + if (StringUtils.isNotBlank(orderDTO.getOid())) { + //淇敼鐨勬椂鍊欙紝闇�瑕佹帓闄よ嚜宸� + sql[0] += " and oid != '" + orderDTO.getOid() + "'"; + } else if (StringUtils.isNotBlank(orderDTO.getCopyFromVersion())) { + sql[0] += " and oid != '" + orderDTO.getCopyFromVersion() + "'"; + } + sql[0] += " and lastR = '1' and lastV = '1' "; +// if (boService.queryCountBySql(sql[0], new HashMap<>()) > 0) { + dataList=commonsMapper.selectBySql(sql[0]); + if (!CollectionUtils.isEmpty(dataList)) { +// String ruleInfoMsg = keyRuleVO == null ? "" : "鏌ヨ瑙勫垯锛氬幓闄ょ┖鏍�--{0},蹇界暐澶у皬鍐�--{1},蹇界暐鍏ㄥ崐瑙�--{2},蹇界暐鍏ㄩ儴绌烘牸--{3}"; +// String[] objs = new String[]{trim ? "鏄�" : "鍚�", ignoreCase ? "鏄�" : "鍚�", ignoreWidth ? "鏄�" : "鍚�", trimAll ? "鏄�" : "鍚�"}; +// throw new VciBaseException("鏍规嵁鎮ㄥ~鍐欑殑鍏抽敭灞炴�х殑鍐呭锛岀粨鍚堝叧閿睘鎬ф煡璇㈣鍒欙紝鍙戠幇杩欎釜鏁版嵁宸茬粡鍦ㄧ郴缁熶腑瀛樺湪浜嗐�傝淇!銆�" + ruleInfoMsg, objs); + return dataList; + } + } + return dataList; + } + /** * 灏佽鍏抽敭灞炴�х殑鏌ヨ璇彞 * diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/resources/mapper/DockingSystemConfigMapper.xml b/Source/UBCS/ubcs-service/ubcs-code/src/main/resources/mapper/DockingSystemConfigMapper.xml index 6831b11..d11ab3f 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/resources/mapper/DockingSystemConfigMapper.xml +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/resources/mapper/DockingSystemConfigMapper.xml @@ -58,6 +58,7 @@ <result column="NAMESPACE" property="namespace"/> <result column="SOAPACTION" property="soapAction"/> <result column="CXFAXIS" property="cxfAxis"/> + <result column="ISGROUPCODEFLAG" property="isGroupCodeFlag"/> </resultMap> -- Gitblit v1.9.3