From f21bdede8546a348e2b16ffc3bbe292df7eeba76 Mon Sep 17 00:00:00 2001 From: ludc Date: 星期五, 12 四月 2024 23:24:21 +0800 Subject: [PATCH] 集成相关代码修改 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java | 129 +++++---- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java | 10 Source/UBCS/ubcs-service-api/ubcs-applyjtcodeservice-api/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feign/IMdmInterJtClient.java | 1 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmEngineServiceImpl.java | 94 ++++--- Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/OrgMasterData.java | 117 ++++++--- Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java | 166 +++++++++---- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/UniversalInterfaceI.java | 3 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/MdmEngineController.java | 2 Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonDataVO.java | 2 Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonMasterData.java | 156 +++++++++++- Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/feigh/MdmInterJtClient.java | 4 11 files changed, 454 insertions(+), 230 deletions(-) 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 0aad149..25e7756 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 @@ -1,7 +1,6 @@ package com.vci.ubcs.code.applyjtcodeservice.feign; -import com.alibaba.nacos.shaded.com.google.protobuf.ServiceException; import com.vci.ubcs.code.applyjtcodeservice.vo.DockingClassifyModelAttrVO; import com.vci.ubcs.code.applyjtcodeservice.vo.DockingPreAttrMappingVO; import com.vci.ubcs.code.applyjtcodeservice.vo.DockingReturnStoreVO; diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/OrgMasterData.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/OrgMasterData.java index 9c47ad8..731cb06 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/OrgMasterData.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/OrgMasterData.java @@ -5,116 +5,152 @@ /** * 闅跺睘鍗曚綅浠g爜 */ - private String company_code; + private String company_code; + /** * 闅跺睘鍗曚綅鍚嶇О/鎵�灞炲叕鍙� */ - private String company_name; + private String company_name; + /** * 閮ㄩ棬缂栫爜 */ private String department_code; + /** * 閮ㄩ棬鍚嶇О */ private String department_name; + /** * 閮ㄩ棬绫诲瀷 1=鏅�氶儴闂紝2=鍐崇瓥閮ㄩ棬 */ private String department_type; + /** * 涓婄骇閮ㄩ棬缂栫爜 鎵�灞嬩笂绾ч儴闂紝寮曠敤閮ㄩ棬涓绘暟鎹紝闆嗗洟鍛藉悕鈥滀笂绾ч儴闂ㄤ唬鐮� */ - private String parent_department_code; + private String parent_department_code; + /** * 涓婄骇閮ㄩ棬鍚嶇О */ - private String parent_department_name; + private String parent_department_name; + /** * 閮ㄩ棬璐熻矗浜� */ - private String department_head; + private String department_head; + /*** * 璐熻矗浜虹紪鐮� */ private String department_head_code; + /*** * 鐢佃瘽 */ private String telephone_number; + /*** * 鎺掑簭鍙� */ private String sort_order; + /** *鍚敤鐘舵�� 1=鏈惎鐢紝2=宸插惎鐢紝3e宸插仠鐢� */ - private int enable_datus; + private int enable_status; + /** * 閮ㄩ棬灞傜骇 */ private String department_level; + /*** * 鏄铏氭嫙閮ㄩ棬 */ private String is_virtual; + /*** * 閮ㄩ棬鐘舵��,鏈夋晥銆佷綔搴� */ private String department_status; + /*** * 閮ㄩ棬鏄剧ず鐘舵��,鏄剧ず銆佷笉鏄剧ず */ - private String diplay_status; + private String display_status; + /*** * 閮ㄩ棬ID璺緞 */ private String id_route; + /*** *閮ㄩ棬鍚嶇О璺緞 */ private String name_route; + /*** *鑺傜偣绫诲瀷,褰撳墠鏂板姞鑺傜偣鐨勭被鍒紝閮ㄩ棬锛屼紒涓�(娉曚汉鍗曚綅)锛岄粯璁� */ private String node_type; + /*** * 閮ㄩ棬鍘熺紪鐮�,璁板綍璇ラ儴闂ㄧ殑鍘熸湁缂栫爜锛屼綔涓烘崲鍙锋椂鐨勫瑙� */ - private String onginal_code; + private String original_code; + /** * 鍒涘缓鑰� */ private String creator; + /*** * 鍒涘缓鏃堕棿 */ private String createtime; + /*** * 淇敼鑰� */ private String modifier; + /** * 淇敼鏃堕棿 */ private String modifytime; + private String mdm_parentcode; + private int mdm_workflow_status; + private String mdm_datastatus; + private String mdm_cleanstatus; + private String link_fieldvalue; - private String floy_middatastatus; - private String originalcode; + + private String flow_middatastatus; + private String pk_mdm; + private String mdm_duplicate; + private String mdm_code; + private String mdm_version; - private String original_nane; + + private String original_name; + private String ts; + /*** *0:姝e父锛�1鏁版嵁琚垹闄わ紝榛樿涓�0; */ private int dr; + private String dr_ndm_code; public String getCompany_code() { @@ -205,12 +241,12 @@ this.sort_order = sort_order; } - public int getEnable_datus() { - return enable_datus; + public int getEnable_status() { + return enable_status; } - public void setEnable_datus(int enable_datus) { - this.enable_datus = enable_datus; + public void setEnable_status(int enable_status) { + this.enable_status = enable_status; } public String getDepartment_level() { @@ -237,12 +273,12 @@ this.department_status = department_status; } - public String getDiplay_status() { - return diplay_status; + public String getDisplay_status() { + return display_status; } - public void setDiplay_status(String diplay_status) { - this.diplay_status = diplay_status; + public void setDisplay_status(String display_status) { + this.display_status = display_status; } public String getId_route() { @@ -269,12 +305,12 @@ this.node_type = node_type; } - public String getOnginal_code() { - return onginal_code; + public String getOriginal_code() { + return original_code; } - public void setOnginal_code(String onginal_code) { - this.onginal_code = onginal_code; + public void setOriginal_code(String original_code) { + this.original_code = original_code; } public String getCreator() { @@ -349,20 +385,12 @@ this.link_fieldvalue = link_fieldvalue; } - public String getFloy_middatastatus() { - return floy_middatastatus; + public String getFlow_middatastatus() { + return flow_middatastatus; } - public void setFloy_middatastatus(String floy_middatastatus) { - this.floy_middatastatus = floy_middatastatus; - } - - public String getOriginalcode() { - return originalcode; - } - - public void setOriginalcode(String originalcode) { - this.originalcode = originalcode; + public void setFlow_middatastatus(String flow_middatastatus) { + this.flow_middatastatus = flow_middatastatus; } public String getPk_mdm() { @@ -397,12 +425,12 @@ this.mdm_version = mdm_version; } - public String getOriginal_nane() { - return original_nane; + public String getOriginal_name() { + return original_name; } - public void setOriginal_nane(String original_nane) { - this.original_nane = original_nane; + public void setOriginal_name(String original_name) { + this.original_name = original_name; } public String getTs() { @@ -443,15 +471,14 @@ ", department_head_code='" + department_head_code + '\'' + ", telephone_number='" + telephone_number + '\'' + ", sort_order='" + sort_order + '\'' + - ", enable_datus=" + enable_datus + + ", enable_status=" + enable_status + ", department_level='" + department_level + '\'' + ", is_virtual='" + is_virtual + '\'' + ", department_status='" + department_status + '\'' + - ", diplay_status='" + diplay_status + '\'' + + ", display_status='" + display_status + '\'' + ", id_route='" + id_route + '\'' + ", name_route='" + name_route + '\'' + ", node_type='" + node_type + '\'' + - ", onginal_code='" + onginal_code + '\'' + ", creator='" + creator + '\'' + ", createtime='" + createtime + '\'' + ", modifier='" + modifier + '\'' + @@ -461,13 +488,13 @@ ", mdm_datastatus='" + mdm_datastatus + '\'' + ", mdm_cleanstatus='" + mdm_cleanstatus + '\'' + ", link_fieldvalue='" + link_fieldvalue + '\'' + - ", floy_middatastatus='" + floy_middatastatus + '\'' + - ", originalcode='" + originalcode + '\'' + + ", floy_middatastatus='" + flow_middatastatus + '\'' + + ", original_code='" + original_code + '\'' + ", pk_mdm='" + pk_mdm + '\'' + ", mdm_duplicate='" + mdm_duplicate + '\'' + ", mdm_code='" + mdm_code + '\'' + ", mdm_version='" + mdm_version + '\'' + - ", original_nane='" + original_nane + '\'' + + ", original_name='" + original_name + '\'' + ", ts='" + ts + '\'' + ", dr=" + dr + ", dr_ndm_code='" + dr_ndm_code + '\'' + diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonDataVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonDataVO.java index 5223442..692423b 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonDataVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonDataVO.java @@ -2,8 +2,6 @@ import lombok.Data; -import java.util.List; - /** * @author ludc * @date 2024/3/20 16:39 diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonMasterData.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonMasterData.java index 7c200d0..e021e1f 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonMasterData.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/person/PersonMasterData.java @@ -15,51 +15,62 @@ * 闆嗗洟鍛樺伐缂栧彿 */ private String group_code; + /*** * 鍛樺伐濮撳悕 */ private String name; + /** * 涓绘暟鎹紪鐮� */ private String mdm_code; + /*** *0:姝e父锛�1鏁版嵁琚垹闄わ紝榛樿涓�0; */ private int dr; + /*** * 琛屾斂鍖哄煙鍖� */ private String admin_division; + /*** * 琛屾斂鍖哄煙鍖栧彿鐮� */ private String admin_division_code; + /** * 鍑虹敓鏃ユ湡(yyyy-MM-dd) */ private String birthday; + /** * 鍑虹敓鍦� */ private String birthplace; + /*** * 绫嶈疮 */ - private String cittizenship; + private String citiizenship; /** * 鍥藉/鍦板尯 */ private String country; + /*** * 閮ㄩ棬 */ private String dept_type; + /*** * 閮ㄩ棬鍚嶇О */ - private String deptName; + private String dept_name; + /*** * 瀛﹀巻 */ @@ -69,28 +80,32 @@ * 浠昏亴鍗曚綅缂栫爜 */ private String employer_code; + /*** * 鐢ㄥ伐褰㈠紡 */ private String employment_form; - /** * 韬唤璇佺紪鍙� */ private String id_number; + /*** * 璇佷欢绫诲瀷 */ private String id_type; + /*** * 鏄惁涓昏亴 */ private String is_keyposion; + /** * 濠氬Щ鐘跺喌 */ private String marital_status; + /** * 鎵嬫満鍙风爜 */ @@ -100,6 +115,7 @@ * 鍚嶆棌 */ private String nationality; + /** * 鍔炲叕鐢佃瘽 */ @@ -114,6 +130,7 @@ *涓婄骇闂ㄧ紪鐮� */ private String parent_dept_code; + /*** *涓婄骇闂ㄥ悕绉� */ @@ -123,6 +140,7 @@ *鏀挎不闈㈣矊 */ private String politiccountenance; + /*** * 宀椾綅 */ @@ -132,10 +150,16 @@ * 鑱岀О */ private String work_title; + /*** * 浜哄憳绫诲埆 */ private String worker_category; + + /*** + * 浜哄憳绫诲埆缂栫爜 + */ + private String worker_category_code; /*** * 鑱屽姟 @@ -153,6 +177,31 @@ private String worker_level; /*** + * 鑱岀骇缂栫爜 + */ + private String worker_level_code; + + /** + * 鍥藉瘑绛夌骇缂栫爜 + */ + private String country_level_code; + + /** + * 鍥藉瘑绛夌骇鍚嶇О + */ + private String country_level_name; + + /** + * 鍟嗗瘑绛夌骇缂栫爜 + */ + private String business_level_code; + + /** + * 鍟嗗瘑绛夌骇缂栫爜 + */ + private String business_level_name; + + /*** * 浜哄憳瀵嗙骇 */ private String worker_security_level; @@ -161,44 +210,62 @@ * 娴佺▼鐘舵�� */ private int mdm_workflow; + /*** * 淇敼鑰� */ private String modifier; + /*** * 淇敼鏃堕棿 */ private String modifytime; + /*** * 鍒涘缓鑰� */ private String creator; + /*** * 鍒涘缓鏃堕棿 */ private String createtime; - /** * 鏁版嵁鐘舵�� */ private int mdm_datastatus; + private String link_fieldvalue; + private String flow_middatastatus; + private String employer; + private int mdm_duplicate; + private EnumerableData gender_entity; + private EnumerableData employment_type_entity; - private String gerder; + + private String gender; + private String employment_type; + private String employment_type_nane; + private String mdm_cleanstatus; + private String mdm_parentcode; + private String mdm_yersion; + private String dr_mdm_code; + private String pk_mdm; private String gender_name; + private String ts; public String getId() { @@ -281,12 +348,12 @@ this.birthplace = birthplace; } - public String getCittizenship() { - return cittizenship; + public String getCitiizenship() { + return citiizenship; } - public void setCittizenship(String cittizenship) { - this.cittizenship = cittizenship; + public void setCitiizenship(String citiizenship) { + this.citiizenship = citiizenship; } public String getCountry() { @@ -305,12 +372,12 @@ this.dept_type = dept_type; } - public String getDeptName() { - return deptName; + public String getDept_name() { + return dept_name; } - public void setDeptName(String deptName) { - this.deptName = deptName; + public void setDept_name(String dept_name) { + this.dept_name = dept_name; } public String getEducation() { @@ -469,6 +536,54 @@ return worker_level; } + public String getWorker_category_code() { + return worker_category_code; + } + + public String getWorker_level_code() { + return worker_level_code; + } + + public String getCountry_level_code() { + return country_level_code; + } + + public String getCountry_level_name() { + return country_level_name; + } + + public String getBusiness_level_code() { + return business_level_code; + } + + public String getBusiness_level_name() { + return business_level_name; + } + + public void setWorker_category_code(String worker_category_code) { + this.worker_category_code = worker_category_code; + } + + public void setWorker_level_code(String worker_level_code) { + this.worker_level_code = worker_level_code; + } + + public void setCountry_level_code(String country_level_code) { + this.country_level_code = country_level_code; + } + + public void setCountry_level_name(String country_level_name) { + this.country_level_name = country_level_name; + } + + public void setBusiness_level_code(String business_level_code) { + this.business_level_code = business_level_code; + } + + public void setBusiness_level_name(String business_level_name) { + this.business_level_name = business_level_name; + } + public void setWorker_level(String worker_level) { this.worker_level = worker_level; } @@ -577,12 +692,12 @@ this.employment_type_entity = employment_type_entity; } - public String getGerder() { - return gerder; + public String getGender() { + return gender; } - public void setGerder(String gerder) { - this.gerder = gerder; + public void setGender(String gender) { + this.gender = gender; } public String getEmployment_type() { @@ -670,10 +785,10 @@ ", admin_division_code='" + admin_division_code + '\'' + ", birthday='" + birthday + '\'' + ", birthplace='" + birthplace + '\'' + - ", cittizenship='" + cittizenship + '\'' + + ", citiizenship='" + citiizenship + '\'' + ", country='" + country + '\'' + ", dept_type='" + dept_type + '\'' + - ", deptName='" + deptName + '\'' + + ", dept_name='" + dept_name + '\'' + ", education='" + education + '\'' + ", employer_code='" + employer_code + '\'' + ", employment_form='" + employment_form + '\'' + @@ -707,7 +822,7 @@ ", mdm_duplicate=" + mdm_duplicate + ", gender_entity=" + gender_entity + ", employment_type_entity=" + employment_type_entity + - ", gerder='" + gerder + '\'' + + ", gender='" + gender + '\'' + ", employment_type='" + employment_type + '\'' + ", employment_type_nane='" + employment_type_nane + '\'' + ", mdm_cleanstatus='" + mdm_cleanstatus + '\'' + @@ -719,4 +834,5 @@ ", ts='" + ts + '\'' + '}'; } + } 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 51b5770..7ba6101 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 @@ -28,6 +28,7 @@ import org.springframework.web.bind.annotation.RestController; import springfox.documentation.annotations.ApiIgnore; +import javax.servlet.http.HttpServletRequest; import java.util.*; import java.util.stream.Collectors; @@ -172,7 +173,7 @@ } else if ("9".equals(formState)) { msg = "瀹℃牳涓�"; } - msg = Func.isNotBlank(mainData.getExamineOpinion()) ? mainData.getExamineOpinion():msg; + msg = Func.isNotBlank(mainData.getExamineOpinion()) ? msg+"锛屾剰瑙侊細"+mainData.getExamineOpinion():msg; jcontent.put("applyId", applyId); jcontent.put("formState", formState); jcontent.put("customCoding", customCoding); @@ -185,6 +186,7 @@ DockingPreApplyForm dockingPreApplyForm = oldDockingPreApplyFormList.get(0); dockingPreApplyForm.setMsg(msg); dockingPreApplyForm.setCode("1"); + dockingPreApplyForm.setLastModifyTime(new Date()); if (res) { dockingPreApplyForm.setGroupCode(customCoding); } 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 c22e677..1cf91b0 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 @@ -6,14 +6,10 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import com.vci.ubcs.code.applyjtcodeservice.service.*; import com.vci.ubcs.code.feign.IMdmEngineClient; 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; @@ -50,7 +46,7 @@ private String msg=""; @Value("${docking.apply.partCode:101}") - public String partCoe; + public String partCode; @Value("${docking.apply.usedFlag:false}") public boolean usedFlag; @@ -61,6 +57,9 @@ @Value("${docking.apply.sysName:410-MDM}") public String dockingApplySysName; + @Value("${docking.apply.personUserAccount:28201728}") + public String applyCodeUserAccount; + @Autowired(required = false) private MdmApplyGroupCodeProvider mdmApplyGroupCodeProvider; @@ -68,36 +67,37 @@ * 闆嗗洟鍒嗙被鏈嶅姟 */ @Autowired(required = false) - private com.vci.ubcs.code.applyjtcodeservice.service.IDockingPreClassifyService dockingPreClassifyService; + private IDockingPreClassifyService dockingPreClassifyService; /*** * 鐢宠鍗曟湇鍔� */ @Autowired(required = false) - private com.vci.ubcs.code.applyjtcodeservice.service.IDockingPreApplyFormService dockingPreApplyFormService; + private IDockingPreApplyFormService dockingPreApplyFormService; /*** * 妯″瀷瑙嗗浘鍗曟湇鍔� */ @Autowired(required = false) - private com.vci.ubcs.code.applyjtcodeservice.service.IDockingPreViewModelService dockingPreViewModelService; + private IDockingPreViewModelService dockingPreViewModelService; /*** * 闆嗗洟鍒嗙被灞炴�у睘鎬ф槧灏勯厤缃湇鍔� */ @Autowired(required = false) private DockingPreAttrMappingMapper dockingPreAttrMappingMapper; + /*** * 灞炴�у彇鍊艰寖鍥存湇鍔� */ @Autowired(required = false) - private com.vci.ubcs.code.applyjtcodeservice.service.IDockingPreAttrRangeService dockingPreAttrRangeService; + private IDockingPreAttrRangeService dockingPreAttrRangeService; /*** * 闆嗗洟灞炴�ф湇鍔� */ @Autowired(required = false) - private com.vci.ubcs.code.applyjtcodeservice.service.IDockingPreMetaAttrService dockingPreMetaAttrService; + private IDockingPreMetaAttrService dockingPreMetaAttrService; @Autowired(required = false) private IMdmEngineClient mdmEngineClient; @@ -109,8 +109,8 @@ * @return 杩斿洖缁撴灉淇℃伅 * @throws Exception */ - @Transactional(rollbackFor = VciBaseException.class) @Override + @Transactional(rollbackFor = Exception.class) public R applyGroupCode(String oids, String btmName) throws VciBaseException { if(usedFlag) { try { @@ -144,7 +144,8 @@ code = resultDataObject.getCode(); msg = resultDataObject.getMsg(); boolean res=false; - if ("1".equals(resultDataObject.getCode())) {//缁撴灉姝g‘鐨勬儏鍐� + if ("1".equals(code)) { + //缁撴灉姝g‘鐨勬儏鍐� List<DockingDataVO> dataObjectVOList = resultDataObject.getData(); res=true; dataObjectVOList.stream().forEach(dataObject -> { @@ -164,7 +165,7 @@ if (editDockingPreApplyFormMap.containsKey(applyId)) { DockingPreApplyForm dockingPreApplyForm = editDockingPreApplyFormMap.get(applyId); dockingPreApplyForm.setCode(code2); - //dockingPreApplyForm.setDescription(baseModel.getId()); + dockingPreApplyForm.setDescription(baseModel.getId()); dockingPreApplyForm.setMsg("鐢宠锛�" + msg); if(StringUtils.isBlank(dockingPreApplyForm.getGroupCode())) { dockingPreApplyForm.setGroupCode(customCoding); @@ -181,7 +182,11 @@ dockingPreApplyForm.setContent(writeValueAsString); } catch (JsonProcessingException e) { } - DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); + Date date = new Date(); + baseModel.setLastModifyTime(date); + baseModel.setTs(date); + baseModel.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); } //鏂板鐨勭敵璇峰崟鏁版嵁 if (addDockingPreApplyFormMap.containsKey(applyId)) { @@ -197,7 +202,14 @@ dockingPreApplyForm.setContent(writeValueAsString); } catch (JsonProcessingException e) { } - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + Date date = new Date(); + dockingPreApplyForm.setCreateTime(date); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setBtmname(MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + dockingPreApplyForm.setCreator(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + // DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); } //濡傛灉鏈夐泦鍥㈢爜鍒欐洿鏂版暟鎹� if (isEditDatas) { @@ -205,13 +217,16 @@ baseModel = baseModelMap.get(applyId); Map<String,String> dataValueMap=new CaseInsensitiveMap<>(baseModel.getData()); /*String classOid=baseModel.getId(); - if(partCoe.equals(classOid)){ + if(partCode.equals(classOid)){ baseModel.setId(10+customCoding); customCoding=10+customCoding; }*/ BeanUtilForVCI.copyDeclaredIgnoreCase(baseModel, baseModel); - DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel); - // DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel); + Date date = new Date(); + baseModel.setLastModifyTime(date); + baseModel.setTs(date); + baseModel.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel); baseModel.getData().put("GROUPCODE",customCoding); updateCbos.add(baseModel);//鏇存柊鏁版嵁闆嗗洟code } @@ -224,14 +239,25 @@ dockingPreApplyForm.setMsg("鐢宠锛�" + msg); dockingPreApplyForm.setContent(""); dockingPreApplyForm.setGroupCode(""); - DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); + Date date = new Date(); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); }); addDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> { dockingPreApplyForm.setCode("2"); dockingPreApplyForm.setMsg("鐢宠锛�" + msg); dockingPreApplyForm.setContent(""); dockingPreApplyForm.setGroupCode(""); - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + Date date = new Date(); + dockingPreApplyForm.setCreateTime(date); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + dockingPreApplyForm.setCreator(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + dockingPreApplyForm.setBtmname(MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + //DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); }); } if (editDockingPreApplyFormMap.size() > 0) { @@ -263,8 +289,8 @@ * @return 杩斿洖缁撴灉淇℃伅 * @throws Throwable */ - @Transactional(rollbackFor = VciBaseException.class) @Override + @Transactional(rollbackFor = Exception.class) public R receiveEditApply(String oids, String btmName) throws VciBaseException { if(!usedFlag) { log.info("鏇存柊鎺ュ彛鍔熻兘宸插叧闂紒->"+usedFlag); @@ -322,7 +348,11 @@ dockingPreApplyForm.setContent(writeValueAsString); } catch (JsonProcessingException e) { } - DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); + Date date = new Date(); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); } //鏂板鐨勭敵璇峰崟鏁版嵁 if (addDockingPreApplyFormMap.containsKey(applyId)) { @@ -339,7 +369,14 @@ dockingPreApplyForm.setContent(writeValueAsString); } catch (JsonProcessingException e) { } - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + Date date = new Date(); + dockingPreApplyForm.setCreateTime(date); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setBtmname(MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + dockingPreApplyForm.setCreator(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); } //濡傛灉鏈夐泦鍥㈢爜鍒欐洿鏂版暟鎹� if (isEditDatas) { @@ -347,9 +384,13 @@ BaseModel baseModel = baseModelMap.get(applyId); //BeanUtilForVCI.copyDeclaredIgnoreCase(baseModelVO, baseModel); /*String classOid=baseModel.getData().getOrDefault("CODECLSFID",""); - if(partCoe.equals(classOid)){ + if(partCode.equals(classOid)){ baseModel.setId(10+customCoding); }*/ + Date date = new Date(); + baseModel.setLastModifyTime(date); + baseModel.setTs(date); + baseModel.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel); // baseModel.setId(customCoding); baseModel.getData().put("GROUPCODE", customCoding); @@ -363,14 +404,25 @@ dockingPreApplyForm.setMsg("淇敼锛�" + msg); dockingPreApplyForm.setContent(""); dockingPreApplyForm.setGroupCode(""); - DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); + Date date = new Date(); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreApplyForm); }); addDockingPreApplyFormMap.forEach((key, dockingPreApplyForm) -> { dockingPreApplyForm.setCode("2"); dockingPreApplyForm.setMsg("淇敼锛�" + msg); dockingPreApplyForm.setContent(""); dockingPreApplyForm.setGroupCode(""); - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + Date date = new Date(); + dockingPreApplyForm.setCreateTime(date); + dockingPreApplyForm.setLastModifyTime(date); + dockingPreApplyForm.setTs(date); + dockingPreApplyForm.setBtmname(MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); + dockingPreApplyForm.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + dockingPreApplyForm.setCreator(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); + //DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreApplyForm, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM); }); } if (editDockingPreApplyFormMap.size() > 0) { @@ -558,6 +610,11 @@ dockingModelQueryVO.setSysName(dockingApplySysName); DockingApplyFormQueryStatusVO dockingApplyFormQueryStatusVO = mdmApplyGroupCodeProvider.queryApplyState(dockingModelQueryVO); + if(Func.isEmpty(dockingApplyFormQueryStatusVO)){ + log.error("鑾峰彇鐢宠鍗曚负绌猴紒"); + return R.fail("娌℃湁鑾峰彇鍒扮浉鍏虫暟鎹俊鎭紒"); + } + int code=dockingApplyFormQueryStatusVO.getCode(); String mesg=dockingApplyFormQueryStatusVO.getMsg(); if(code==1){ @@ -591,7 +648,7 @@ e.printStackTrace(); //message=""+e; log.error("鑾峰彇鐢宠鍗曠姸鎬佸け璐�"+e); - throw new VciBaseException(e.getMessage()); + throw new VciBaseException(e.getMessage()); } log.info("鏌ヨ鐢宠鍗曠姸鎬佹帴鍙nd"); return R.success(message); @@ -861,10 +918,18 @@ /** * 缁勭粐鏁版嵁 - * */ - private DockingGroupDataVO queryApplycodeDataObjects(int optationtype,List<BaseModel> codeWupins,Map<String,DockingPreApplyForm> addDockingPreApplyFormMap,Map<String,DockingPreApplyForm> editDockingPreApplyFormMap,Map<String,BaseModel> codeWupinMap) throws VciBaseException{ + * @param optationtype + * @param codeWupins + * @param addDockingPreApplyFormMap + * @param editDockingPreApplyFormMap + * @param codeWupinMap + * @return + * @throws VciBaseException + */ + 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(); + // TODO锛氫富鏁版嵁鎺ㄩ�佽繃鏉ョ殑鏁版嵁鏄嬁涓嶅埌鍙互鐢宠闆嗗洟鐮佺殑鐢ㄦ埛淇℃伅鐨勶紝骞朵笖杩欎竴鍧楀効鐨勯�昏緫涔熻繕娌℃暡瀹氾紝鎵�浠ヨ繖鍎块噰鐢ㄩ厤缃殑鐢ㄦ埛鏉ョ敵璇烽泦鍥㈢爜 + String curUserName = Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount(); //鐢宠鐨勬暟鎹� List<DockingMainData> mainDataList=new ArrayList<DockingMainData>(); for (BaseModel dataBusinessObject : codeWupins) { @@ -876,29 +941,29 @@ 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)); - // DockingPreApplyForm dockingPreApplyForm=new DockingPreApplyForm(); - String apllyCode = ""; + // 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)); + // DockingPreApplyForm dockingPreApplyForm=new DockingPreApplyForm(); + String applyCode = ""; /*if (!CollectionUtils.isEmpty(applyFormObjects)) { dockingPreApplyForm = applyFormObjects.get(0); - apllyCode = dockingPreApplyForm.getId(); - editDockingPreApplyFormMap.put(apllyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯� + applyCode = dockingPreApplyForm.getId(); + editDockingPreApplyFormMap.put(applyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯� } else {*/ - apllyCode = dockingApplyUnitCode + "-" + format; - dockingPreApplyForm.setId(apllyCode); + applyCode = dockingApplyUnitCode + "-" + format; + dockingPreApplyForm.setId(applyCode); dockingPreApplyForm.setName(""); dockingPreApplyForm.setOperationType(optationtype+""); dockingPreApplyForm.setDescription(dataBusinessObject.getId());//鑾峰彇鏁版嵁鎻忚堪淇℃伅 dockingPreApplyForm.setDataOid(oid); dockingPreApplyForm.setDataBtmName(btmName); - addDockingPreApplyFormMap.put(apllyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯� - // } + addDockingPreApplyFormMap.put(applyCode, dockingPreApplyForm);//鐢宠鍗曞拰鐢宠鍗曞璞″叧绯� + // } - codeWupinMap.put(apllyCode, dataBusinessObject);//鐢宠鍗曞拰瀵瑰簲鏁版嵁鍏崇郴 - conditionsMap = new HashMap<String, String>(); - conditionsMap.put("jtargetclsfid", codeclsfid);//瑙嗗浘oid + codeWupinMap.put(applyCode, dataBusinessObject);//鐢宠鍗曞拰瀵瑰簲鏁版嵁鍏崇郴 + // conditionsMap = new HashMap<String, String>(); + // conditionsMap.put("jtargetclsfid", codeclsfid);//瑙嗗浘oid List<DockingPreAttrMapping> dockingPreAttrMappingList = dockingPreAttrMappingMapper.selectList(Wrappers.<DockingPreAttrMapping>query().lambda().eq(DockingPreAttrMapping::getTargetClassifyId, codeclsfid)); if (CollectionUtils.isEmpty(dockingPreAttrMappingList)) { @@ -909,7 +974,7 @@ DockingPreClassify dockingPreClassify = dockingPreClassifyService.getById(jsourceclsfid); DockingMainData mainData = new DockingMainData(); mainData.setApplyEntId(dockingApplyUnitCode);//鐢宠鍗曚綅浠g爜 - mainData.setApplyId(apllyCode);//鐢宠鍗曞彿 + mainData.setApplyId(applyCode);//鐢宠鍗曞彿 mainData.setClassName(dockingPreClassify.getNodeLinkName());//鍒嗙被鍚嶇О mainData.setCreateBy(curUserName);// if(optationtype==2) { @@ -928,7 +993,7 @@ return postParameters; } catch (Throwable e) { // TODO Auto-generated catch block - throw new VciBaseException("鏌ヨ鏁版嵁鍑洪敊"+e); + throw new VciBaseException("鏌ヨ鏁版嵁鍑洪敊锛屽師鍥狅細"+e.getMessage()); } } @@ -1035,14 +1100,15 @@ if(attrRangeMap.containsKey(jmetalistoid)) { return; } - Map<String,String>conditionsMap=new HashMap<String, String>(); - conditionsMap.put("jmetalistid", jmetalistoid);//瑙嗗浘oid + // Map<String,String>conditionsMap=new HashMap<String, String>(); + // conditionsMap.put("jmetalistid", jmetalistoid);//瑙嗗浘oid List<DockingPreAttrRange> dockingPreAttrRangeList = dockingPreAttrRangeService.selectByWrapper(Wrappers.<DockingPreAttrRange>query().lambda().eq(DockingPreAttrRange::getMetaListId, jmetalistoid)); if (CollectionUtils.isEmpty(dockingPreAttrRangeList)) { return; } Map<String, DockingPreAttrRange> rangeMap = new HashMap<String, DockingPreAttrRange>(); - rangeMap = dockingPreAttrRangeList.stream().collect(Collectors.toMap(s -> s.getNumTextValue(), t -> t, (o1, o2) -> o2)); + // TODO: 杩欏効瀛樺唴閮ㄥ瓨鍌ㄥ�硷紝鏃犳硶鍦ㄥ悗缁繘琛岃浆鎹� + rangeMap = dockingPreAttrRangeList.stream().collect(Collectors.toMap(s -> s.getTargetNumText(), t -> t, (o1, o2) -> o2)); attrRangeMap.put(jmetalistoid, rangeMap); } diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/MdmEngineController.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/MdmEngineController.java index 540cb51..9058165 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/MdmEngineController.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/controller/MdmEngineController.java @@ -358,7 +358,7 @@ * @param baseModelDTO 鏁版嵁浼犺緭瀵硅薄 * @return 鎵ц缁撴灉 */ - @PostMapping("changeStatus") + @PostMapping("/changeStatus") public R changeStatus(@RequestBody BaseModelDTO baseModelDTO) { engineService.changeStatus(baseModelDTO); return R.success("鎿嶄綔鎴愬姛锛�"); diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/UniversalInterfaceI.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/UniversalInterfaceI.java index fc2d124..3e09485 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/UniversalInterfaceI.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/UniversalInterfaceI.java @@ -2,12 +2,9 @@ import com.vci.ubcs.code.vo.webserviceModel.person.OrgData; import com.vci.ubcs.code.vo.webserviceModel.person.PersonData; import com.vci.ubcs.code.vo.webserviceModel.person.ResultOrgData; -import org.springframework.web.bind.annotation.RequestParam; import javax.jws.WebService; -import javax.servlet.ServletRequest; import javax.servlet.http.HttpServletRequest; -import javax.ws.rs.core.Context; /** * 缁熶竴鎺ュ彛 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 6e1dacc..5eb6253 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 @@ -146,7 +146,9 @@ * 绯诲垪娴佹按 */ @Value("${bzApply.seriesFlow:seriesFlow}") + private String seriesFlow; + /*** * 鏄惁鍙樻洿绯诲垪 */ @@ -316,6 +318,12 @@ public static final String BTM_NAME = "btm:name"; /** + * 閰嶇疆鐨勭敤鏉ョ敵璇烽泦鍥㈢爜鐨勭敤鎴� + */ + @Value("${docking.apply.personUserAccount:28201728}") + public String applyCodeUserAccount; + + /** * 瀵嗙骇鐨勫瓧娈� */ public static final String SECRET_FILED = "secretgrade"; @@ -451,7 +459,7 @@ } R r = updateBatchByBaseModel(baseModelDTO.getBtmname(), baseModels); if (!r.isSuccess()) { - throw new VciBaseException("鏇存柊鏁版嵁鍑洪敊锛岄噸璇曪紒" + r.getMsg()); + throw new VciBaseException("鏇存柊鏁版嵁鍑洪敊锛岃閲嶈瘯锛�" + r.getMsg()); } } // 鍒氬ソ椤哄簭鏄竴鑷寸殑锛屾墍浠ョ洿鎺ユ寜鐓odeallcode鐨勯『搴忔潵鎷夸笟鍔℃暟鎹� @@ -3468,19 +3476,19 @@ cbos.add(data); }); -// List<ClientBusinessObject> cbos = boService.queryByOnlySql(sqlBO.getSqlUnPage()); + // List<ClientBusinessObject> cbos = boService.queryByOnlySql(sqlBO.getSqlUnPage()); if (CollectionUtils.isEmpty(cbos)) { - throw new VciBaseException("鏁版嵁鍦ㄧ郴缁熶腑涓嶅瓨鍦紝鏄惁鍥犱负淇敼杩囦笟鍔$被鍨嬶紵"); + return R.fail("鏁版嵁鍦ㄧ郴缁熶腑涓嶅瓨鍦紝鏄惁鍥犱负淇敼杩囦笟鍔$被鍨嬶紵"); } -// Map<String, String> data = new HashMap<>(); + // Map<String, String> data = new HashMap<>(); Map<String, String> cbo = cbos.get(0); -// WebUtil.copyValueToMapFromCbos(cbo, data); + // WebUtil.copyValueToMapFromCbos(cbo, data); List<Map<String, String>> dataList = new ArrayList<>(); dataList.add(cbo); wrapperData(dataList, templateVO, sqlBO.getSelectFieldList(), true); R<List<Map<String, String>>> result = R.data(Collections.singletonList(cbo)); if(templateVO.getAttributes().isEmpty()){ - throw new ServiceException(String.format("涓婚敭涓猴細{}鐨勬ā鏉夸笅锛屾ā鏉垮睘鎬ч厤缃负绌猴紒",templateVO.getOid())); + return R.fail(String.format("涓婚敭涓猴細%s鐨勬ā鏉夸笅锛屾ā鏉垮睘鎬ч厤缃负绌猴紒",templateVO.getOid())); } //澶勭悊杩斿洖鏁版嵁涓庢ā鏉挎暟鎹厤缃殑瀛楁涓嶄竴鏍烽棶棰� templateVO.getAttributes().stream().forEach(e -> { @@ -3493,42 +3501,42 @@ }); //鎴戜滑瑕佺湅鏄惁涓嶆槸鍗囩増鐨勶紝鍗囩増鐨勮瘽锛岄渶瑕佸姣斾笉鐩哥瓑鐨勫睘鎬� -/* String copy = cbo.get("copyfromversion"); -// if (StringUtils.isBlank(copy)) { -// copy = cbo.getAttributeValue("copyfromversion"); -// } - if (StringUtils.isNotBlank(copy)) { - //璇存槑鏈夊彉鏇寸殑鍐呭 + /* String copy = cbo.get("copyfromversion"); + // if (StringUtils.isBlank(copy)) { + // copy = cbo.getAttributeValue("copyfromversion"); + // } + if (StringUtils.isNotBlank(copy)) { + //璇存槑鏈夊彉鏇寸殑鍐呭 - CodeTemplateAttrSqlBO oldSqlBO = getSqlByTemplateVO(btmId, templateVO, WebUtil.getOidQuery(copy), new PageHelper(-1)); - //鎴戜滑浣跨敤鍜屼笟鍔$被鍨嬬殑鏉ユ煡璇� -// List<Map> cbos = commonsMapper.selectBySql(sqlBO.getSqlUnPage()); - List<Map> oldCbos = commonsMapper.selectBySql(oldSqlBO.getSqlUnPage()); - if (!CollectionUtils.isEmpty(oldCbos)) { -// Map<String, String> newData = new HashMap<>(); -// WebUtil.copyValueToMapFromCbos(cbo, newData); - Map<String, String> oldData = new HashMap<>(); - oldData = oldCbos.get(0); - Map<String, String> difFieldMap = new HashMap<>(); - Map<String, String> finalOldData = oldData; - cbo.forEach((key, value) -> { - // 杩欏効oldmap涓殑鍏ㄦ槸澶у啓锛岃�宑bo涓殑鍏ㄦ槸灏忓啓鎵�浠ヤ細鎷夸笉鍒板彧锛岃繖鍎跨洿鎺ュ鐞嗘垚灏忓啓鎷夸笉鍒板氨鐢ㄥぇ鍐欐嬁 - String oldValue = String.valueOf(finalOldData.getOrDefault(key.toUpperCase(Locale.ROOT), finalOldData.getOrDefault(key, ""))); - if (value == null || value == "null") { - value = ""; - } - if (oldValue == null || oldValue == "null") { - oldValue = ""; - } - if (!value.equalsIgnoreCase(oldValue)) { - difFieldMap.put(key, oldValue); - } - }); - List<Map<String, String>> difFieldList = new ArrayList<>(); - difFieldList.add(difFieldMap); - result.setData(difFieldList); - } - }*/ + CodeTemplateAttrSqlBO oldSqlBO = getSqlByTemplateVO(btmId, templateVO, WebUtil.getOidQuery(copy), new PageHelper(-1)); + //鎴戜滑浣跨敤鍜屼笟鍔$被鍨嬬殑鏉ユ煡璇� + // List<Map> cbos = commonsMapper.selectBySql(sqlBO.getSqlUnPage()); + List<Map> oldCbos = commonsMapper.selectBySql(oldSqlBO.getSqlUnPage()); + if (!CollectionUtils.isEmpty(oldCbos)) { + // Map<String, String> newData = new HashMap<>(); + // WebUtil.copyValueToMapFromCbos(cbo, newData); + Map<String, String> oldData = new HashMap<>(); + oldData = oldCbos.get(0); + Map<String, String> difFieldMap = new HashMap<>(); + Map<String, String> finalOldData = oldData; + cbo.forEach((key, value) -> { + // 杩欏効oldmap涓殑鍏ㄦ槸澶у啓锛岃�宑bo涓殑鍏ㄦ槸灏忓啓鎵�浠ヤ細鎷夸笉鍒板彧锛岃繖鍎跨洿鎺ュ鐞嗘垚灏忓啓鎷夸笉鍒板氨鐢ㄥぇ鍐欐嬁 + String oldValue = String.valueOf(finalOldData.getOrDefault(key.toUpperCase(Locale.ROOT), finalOldData.getOrDefault(key, ""))); + if (value == null || value == "null") { + value = ""; + } + if (oldValue == null || oldValue == "null") { + oldValue = ""; + } + if (!value.equalsIgnoreCase(oldValue)) { + difFieldMap.put(key, oldValue); + } + }); + List<Map<String, String>> difFieldList = new ArrayList<>(); + difFieldList.add(difFieldMap); + result.setData(difFieldList); + } + }*/ return result; } @@ -4399,8 +4407,8 @@ if (cboMap.containsKey(oid)) { CodeAllCode codeAllCode = cboMap.get(oid); codeAllCode.setId(baseModel.getId()); - // codeAllCode.setLastModifier(AuthUtil.getUser().getUserName()); - codeAllCode.setLastModifier(AuthUtil.getUser().getAccount()); + // 涓绘暟鎹帹閫佸舰寮忥紝鏄嬁涓嶅埌鐢ㄦ埛淇℃伅鐨� + codeAllCode.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); codeAllCode.setLastModifyTime(new Date()); codeAllCode.setLcStatus(baseModel.getLcStatus()); newCodeAllCodeList.add(codeAllCode); diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java index db7167c..eb21267 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java @@ -68,6 +68,7 @@ import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; import javax.xml.bind.ValidationEvent; import java.beans.BeanInfo; import java.beans.Introspector; @@ -2826,9 +2827,9 @@ List<CodeAllCode> codeAllCodeList = new ArrayList<>(); List<String> deleteList = new ArrayList<>(); - CodeClassifyTemplateVO firstTemplateVO = templateService.getObjectHasAttrByOid(orderDTOMap.values().stream().findFirst().get().getTemplateOid()); + // CodeClassifyTemplateVO firstTemplateVO = templateService.getObjectHasAttrByOid(orderDTOMap.values().stream().findFirst().get().getTemplateOid()); Map<String, ClientBusinessObject> cboMap = cboList.stream().filter(cbo -> cbo != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId(), t -> t)); - // boolean finalIsProcess = isProcess; + // boolean finalIsProcess = isProcess; orderDTOMap.keySet().stream().forEach(code -> { CodeOrderDTO orderDTO = orderDTOMap.get(code); ClientBusinessObject cbo = cboMap.get(code); @@ -2981,9 +2982,6 @@ //鏄惁璋冪敤闆嗗洟鎺ュ彛鐢宠鎺ュ彛 if(isCodeOrGroupCode){ List<String> IdList=resultDataObjectDetailDOs.stream().filter(xMLResultDataObjectDetailDO-> com.alibaba.cloud.commons.lang.StringUtils.isNotBlank(xMLResultDataObjectDetailDO.getId())).map(XMLResultDataObjectDetailDO::getId).distinct().collect(Collectors.toList()); - - - if(!CollectionUtils.isEmpty(IdList)) { this.sendApplyGroupcode(IdList, classifyFullInfo.getTopClassifyVO().getBtmTypeId(),sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getValue()); } @@ -5286,8 +5284,8 @@ * @param file * @return */ - @Transactional(rollbackFor = VciBaseException.class) @Override + @Transactional(rollbackFor = Exception.class) public String importGroupCode(String codeClassifyOid, File file) throws Throwable { VciBaseUtil.alertNotNull(codeClassifyOid,"鍒嗙被鐨勪富閿�"); ReadExcelOption reo = new ReadExcelOption(); 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 0c37fdb..ca3d624 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 @@ -73,6 +73,7 @@ import java.io.StringWriter; import java.util.*; import java.util.concurrent.CopyOnWriteArrayList; +import java.util.concurrent.ForkJoinPool; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Function; import java.util.stream.Collectors; @@ -114,11 +115,13 @@ */ @Value("${bzApply.seriesFlow:seriesFlow}") private String seriesFlow; + /*** * 鏄惁鍙樻洿绯诲垪 */ @Value("${bzApply.isEditSeries:isEditSeries}") private String isEditSeries; + /*** * 鎺у埗鏄惁鍐欏叆鍊肩殑鐮佹鍚嶇О */ @@ -130,7 +133,6 @@ */ @Value("${bzApply.yearSecName:骞翠唬鍙穧") private String yearSecName; - @Value("${code.universalinterface.checkSystemConfig:true}") public boolean CODE_CHECKCONFIG; @@ -203,8 +205,14 @@ */ @Resource private IDockingLogeService dockingLogeService; + @Resource private IPasswordFreeLoginService passwordFreeLoginService; + + /** + * 鑷畾涔夊苟鍙慒orkJoinPool + */ + private static final ForkJoinPool customForkJoinPool = new ForkJoinPool(Runtime.getRuntime().availableProcessors() - 1); private static String separator="##VCI##"; private String errorid="0"; @@ -290,14 +298,14 @@ throw new Throwable("鐢ㄦ埛閴存潈澶辫触."); } List<ClassfyVO> classVOList = classfysVO.getClassify(); - InterParameterVO finalInterParameterVO = interParameterVO; + //InterParameterVO finalInterParameterVO = interParameterVO; //杩欐槸璐﹀彿淇℃伅 SessionInfo sessionInfo = new SessionInfo(); sessionInfo.setUserId(userVo.getUserName()); sessionInfo.setUserName(userVo.getTrueName()); sessionInfo.setIp(userVo.getIp()); VciBaseUtil.setCurrentUserSessionInfo(sessionInfo); -// List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>(); + //List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>(); String finalSystemId = systemId; classVOList.stream().forEach(classVO -> { log.info("鍙傛暟锛氬垎绫籆Ode:" + classVO.getClassCode()); @@ -451,7 +459,6 @@ */ @Override public ResultOrgData syncDataForPerson(PersonData personData) { - boolean isUsedFlag= personAndDeptConfig.isUsedFlag(); ResultOrgData resultOrgData=new ResultOrgData(); @@ -618,7 +625,8 @@ throw new Throwable("缂栫爜瑙勫垯"); } List<XMLResultDataObjectDetailDO> xDOs=new CopyOnWriteArrayList<>(); - dataObjectVO.getRowData().parallelStream().forEach(rowData->{ + final List<RowDatas> rowDatas = dataObjectVO.getRowData(); + rowDatas.parallelStream().forEach(rowData->{ String mesg=""; try { CodeOrderDTO orderDTO = new CodeOrderDTO(); @@ -681,16 +689,19 @@ resultDataObjectDetailDOs.addAll(xDOs); boolean finalSuccess1 = success.get(); String finalMessage1 = message; - resultDataObjectDetailDOs.stream().forEach(resultDataObjectDetailDO->{ - ResultMdMapping resultMdMapping=new ResultMdMapping(); - resultMdMapping.setBusiDataId(resultDataObjectDetailDO.getId()); - resultMdMapping.setSuccess(finalSuccess1); - resultMdMapping.setEntityCode(" "); - resultMdMapping.setMdmCode(resultDataObjectDetailDO.getCode()); - resultMdMapping.setMessage(finalMessage1); - resultMdMapping.setSubMdMappings(null); - resultMdMappingList.add(resultMdMapping); - }); + // 闄愬埗绾跨▼骞惰鏁伴噺 + customForkJoinPool.submit(()->{ + resultDataObjectDetailDOs.stream().forEach(resultDataObjectDetailDO->{ + ResultMdMapping resultMdMapping=new ResultMdMapping(); + resultMdMapping.setBusiDataId(resultDataObjectDetailDO.getId()); + resultMdMapping.setSuccess(finalSuccess1); + resultMdMapping.setEntityCode(" "); + resultMdMapping.setMdmCode(resultDataObjectDetailDO.getCode()); + resultMdMapping.setMessage(finalMessage1); + resultMdMapping.setSubMdMappings(null); + resultMdMappingList.add(resultMdMapping); + }); + }).join(); log.info("end锛氱敵璇疯幏鍙栧畬姣�"); } }catch (Throwable e){ @@ -738,7 +749,7 @@ public ResultOrgData syncDataForOrg(OrgData orgData) { boolean isUsedFlag= personAndDeptConfig.isUsedFlag(); ResultOrgData resultOrgData=new ResultOrgData(); - boolean isPersonApplyGroupCode= personAndDeptConfig.isDeptApplyGroupCode(); + //boolean isPersonApplyGroupCode= personAndDeptConfig.isDeptApplyGroupCode(); List<ResultMdMapping> resultMdMappingList=new ArrayList<>(); AtomicBoolean success= new AtomicBoolean(true); String message=""; @@ -783,7 +794,6 @@ List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag())) ).collect(Collectors.toList()); - List<Map> dataList=new ArrayList<>(); List<String> codeList=new ArrayList<>(); List<ApplyDataVO> applyDataVOList=new ArrayList<>(); List<ApplyDataVO> deleteDataVOList=new ArrayList<>(); @@ -882,7 +892,7 @@ DataObjectVO dataObjectVO = new DataObjectVO(); this.getConfigDatas(systemCode, deptLibrary, editDatasVO, attrVOS, dataObjectVO); log.info("start锛氫慨鏀规暟鎹墽琛屽畬姣�"); - boolean personApplyGroupCode =personAndDeptConfig.isPersonApplyGroupCode(); + boolean personApplyGroupCode = personAndDeptConfig.isPersonApplyGroupCode(); mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,personApplyGroupCode); log.info("end锛氫慨鏀规暟鎹墽琛屽畬姣�"); } @@ -896,32 +906,34 @@ throw new Throwable("缂栫爜瑙勫垯"); } List<XMLResultDataObjectDetailDO> xDOs=new CopyOnWriteArrayList<>(); - dataObjectVO.getRowData().parallelStream().forEach(rowData->{ - String mesg=""; - try { - CodeOrderDTO orderDTO = new CodeOrderDTO(); - List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>(); - orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//鍒嗙被涓婚敭 - orderDTO.setTemplateOid(templateVO.getOid()); - orderDTO.setCreator(rowData.getCreator()); - orderDTO.setLastModifier(rowData.getEditor()); - orderDTO.setLcStatus(rowData.getStatus()); - if(!CollectionUtils.isEmpty(ruleVO.getSecVOList())) { - ruleVO.getSecVOList().stream().forEach(codeBasicSecVO -> { - if (codeBasicSecVO.getSecType().equals("codevariablesec")) {//瑙勫垯涔嬪畾涔変负鍙彉鐮佹瀛樺偍涓绘暟鎹紶閫掕繃鏉ョ殑鏁版嵁 - CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO(); - CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid()); - CodeOrderSecDTO.setSecValue(rowData.getCode()); - codeOrderSecDTOList.add(CodeOrderSecDTO); - - } - }); - } - orderDTO.setCodeRuleOid(ruleVO.getOid()); - orderDTO.setSecDTOList(codeOrderSecDTOList);//瀛樺偍缂栫爜 - orderDTO.setData(rowData.getFiledValue()); - String code=engineService.addSaveCodeNotauthUser(orderDTO,false); - if(StringUtils.isNotBlank(code)) { + //闄愬埗绾跨▼骞惰鏁伴噺 + customForkJoinPool.submit(()->{ + dataObjectVO.getRowData().parallelStream().forEach(rowData->{ + String mesg=""; + try { + CodeOrderDTO orderDTO = new CodeOrderDTO(); + List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>(); + orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//鍒嗙被涓婚敭 + orderDTO.setTemplateOid(templateVO.getOid()); + orderDTO.setCreator(rowData.getCreator()); + orderDTO.setLastModifier(rowData.getEditor()); + orderDTO.setLcStatus(rowData.getStatus()); + if(!CollectionUtils.isEmpty(ruleVO.getSecVOList())) { + ruleVO.getSecVOList().stream().forEach(codeBasicSecVO -> { + if (codeBasicSecVO.getSecType().equals("codevariablesec")) { + //瑙勫垯涔嬪畾涔変负鍙彉鐮佹瀛樺偍涓绘暟鎹紶閫掕繃鏉ョ殑鏁版嵁 + CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO(); + CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid()); + CodeOrderSecDTO.setSecValue(rowData.getOid()); + codeOrderSecDTOList.add(CodeOrderSecDTO); + } + }); + } + orderDTO.setCodeRuleOid(ruleVO.getOid()); + orderDTO.setSecDTOList(codeOrderSecDTOList);//瀛樺偍缂栫爜 + orderDTO.setData(rowData.getFiledValue()); + String code = engineService.addSaveCodeNotauthUser(orderDTO,false); + /*if(StringUtils.isNotBlank(code)) { //rowData.setCode(code); StringBuffer sqlsb = new StringBuffer(); sqlsb.append(" select * from "); @@ -943,20 +955,21 @@ mesg = "鏁版嵁淇濆瓨鎴愬姛锛岀瓑寰呯敵璇烽泦鍥㈢爜"; } } + }*/ + } catch (Exception e) { + mesg=e.getMessage(); + e.printStackTrace(); + throw new ServiceException(e.getMessage()); + }finally { + XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO(); + x.setId(rowData.getOid()); + x.setCode(rowData.getCode()); + x.setMsg(mesg); + x.setErrorid("1"); + xDOs.add(x); } - } catch (Exception e) { - mesg=e.getMessage(); - e.printStackTrace(); - throw new ServiceException(e.getMessage()); - }finally { - XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO(); - x.setId(rowData.getOid()); - x.setCode(rowData.getCode()); - x.setMsg(mesg); - x.setErrorid("1"); - xDOs.add(x); - } - }); + }); + }).join(); resultDataObjectDetailDOs.addAll(xDOs); boolean finalSuccess1 = success.get(); String finalMessage1 = message; @@ -1059,7 +1072,7 @@ throw new Throwable("鐢ㄦ埛閴存潈澶辫触"); } List<ClassfyVO> classVOList = classfysVO.getClassify(); - InterParameterVO finalInterParameterVO = interParameterVO; + //InterParameterVO finalInterParameterVO = interParameterVO; //杩欐槸璐﹀彿淇℃伅 SessionInfo sessionInfo = new SessionInfo(); sessionInfo.setUserId(userVo.getUserName()); -- Gitblit v1.9.3