From e2e76076861f0019d127c03273f111a2dcda5913 Mon Sep 17 00:00:00 2001 From: xiejun <xj@2023> Date: 星期五, 22 九月 2023 08:59:18 +0800 Subject: [PATCH] webservice标准接口增加 --- Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZDataVO.java | 112 +++++++++++ Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java | 361 +++++++++++++++++++++++------------ Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/apply/ApplyDataVO.java | 50 ---- Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ClassfyBZVO.java | 6 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/enumpack/SysIntegrationLogTypeEnum.java | 18 + Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZVO.java | 2 Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/json/tt.json | 4 Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/coderule/data.json | 5 8 files changed, 371 insertions(+), 187 deletions(-) diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/apply/ApplyDataVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/apply/ApplyDataVO.java index 0f86f0b..73ade5c 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/apply/ApplyDataVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/apply/ApplyDataVO.java @@ -44,22 +44,7 @@ @XStreamAsAttribute private String editor; - /*** - * 鏄惁淇 - */ - private boolean amendmentFlag; - /*** - *鏄惁鏄郴鍒楁爣鍑� - */ - private boolean seriesStandardFlag; - /** - * 鏄惁缁х画缂栧彿 - */ - private boolean continueNumberFlag; - /*** - * 骞翠唬鍙� - */ - private String yearNumber; + /*** * 鏁版嵁灞炴�у璞� */ @@ -121,39 +106,6 @@ public void setProp(List<ProppertyVO> prop) { this.prop = prop; } - - public boolean isAmendmentFlag() { - return amendmentFlag; - } - - public void setAmendmentFlag(boolean amendmentFlag) { - this.amendmentFlag = amendmentFlag; - } - - public boolean isSeriesStandardFlag() { - return seriesStandardFlag; - } - - public void setSeriesStandardFlag(boolean seriesStandardFlag) { - this.seriesStandardFlag = seriesStandardFlag; - } - - public boolean isContinueNumberFlag() { - return continueNumberFlag; - } - - public void setContinueNumberFlag(boolean continueNumberFlag) { - this.continueNumberFlag = continueNumberFlag; - } - - public String getYearNumber() { - return yearNumber; - } - - public void setYearNumber(String yearNumber) { - this.yearNumber = yearNumber; - } - @Override public String toString() { return "ApplyDataVO{" + diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZDataVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZDataVO.java index 1090c66..56073cd 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZDataVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZDataVO.java @@ -40,4 +40,116 @@ */ @XStreamImplicit private List<ProppertyVO> prop; + /*** + * 鏄惁淇 + */ + private boolean amendmentFlag; + /*** + *鏄惁鏄郴鍒楁爣鍑� + */ + private boolean seriesStandardFlag; + /** + * 鏄惁缁х画缂栧彿 + */ + private boolean continueNumberFlag; + /*** + * 骞翠唬鍙� + */ + private String yearNumber; + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + public String getCreator() { + return creator; + } + + public void setCreator(String creator) { + this.creator = creator; + } + + public String getEditor() { + return editor; + } + + public void setEditor(String editor) { + this.editor = editor; + } + + public List<ProppertyVO> getProp() { + return prop; + } + + public void setProp(List<ProppertyVO> prop) { + this.prop = prop; + } + + public boolean isAmendmentFlag() { + return amendmentFlag; + } + + public void setAmendmentFlag(boolean amendmentFlag) { + this.amendmentFlag = amendmentFlag; + } + + public boolean isSeriesStandardFlag() { + return seriesStandardFlag; + } + + public void setSeriesStandardFlag(boolean seriesStandardFlag) { + this.seriesStandardFlag = seriesStandardFlag; + } + + public boolean isContinueNumberFlag() { + return continueNumberFlag; + } + + public void setContinueNumberFlag(boolean continueNumberFlag) { + this.continueNumberFlag = continueNumberFlag; + } + + public String getYearNumber() { + return yearNumber; + } + + public void setYearNumber(String yearNumber) { + this.yearNumber = yearNumber; + } + + @Override + public String toString() { + return "ApplyBZDataVO{" + + "id='" + id + '\'' + + ", code='" + code + '\'' + + ", status='" + status + '\'' + + ", creator='" + creator + '\'' + + ", editor='" + editor + '\'' + + ", prop=" + prop + + ", amendmentFlag=" + amendmentFlag + + ", seriesStandardFlag=" + seriesStandardFlag + + ", continueNumberFlag=" + continueNumberFlag + + ", yearNumber='" + yearNumber + '\'' + + '}'; + } } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZVO.java index f27a6fd..f3a302a 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ApplyBZVO.java @@ -2,7 +2,9 @@ import com.thoughtworks.xstream.annotations.XStreamAlias; import com.thoughtworks.xstream.annotations.XStreamAsAttribute; +import com.vci.ubcs.code.vo.webserviceModel.apply.ClassfyVO; import com.vci.ubcs.code.vo.webserviceModel.apply.UserVO; + /** *鏁版嵁淇℃伅 */ diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ClassfyBZVO.java b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ClassfyBZVO.java index 9319aac..88ae6d2 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ClassfyBZVO.java +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/applybz/ClassfyBZVO.java @@ -27,7 +27,7 @@ /** * 鏁版嵁闆嗗悎 */ - private ApplyDatasVO objects; + private ApplyBZDatasVO objects; public String getClassCode() { return classCode; @@ -53,11 +53,11 @@ this.fullclsfNamePath = fullclsfNamePath; } - public ApplyDatasVO getObjects() { + public ApplyBZDatasVO getObjects() { return objects; } - public void setObjects(ApplyDatasVO objects) { + public void setObjects(ApplyBZDatasVO objects) { this.objects = objects; } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/coderule/data.json b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/coderule/data.json index 9b0e9c6..d45ed30 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/coderule/data.json +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/coderule/data.json @@ -1,6 +1,6 @@ { "data":{ - "systemId": "MPM", + "systemId": "PDM", "user": { "userName": "weidy", "trueName": "榄忓ぇ鍕�", @@ -9,8 +9,7 @@ "library": { "id": "wupin", "classifyid":[ - "020201", - "020202" + "020201" ] } } diff --git a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/json/tt.json b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/json/tt.json index 848d6d3..ef1de0a 100644 --- a/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/json/tt.json +++ b/Source/UBCS/ubcs-service-api/ubcs-code-api/src/main/java/com/vci/ubcs/code/vo/webserviceModel/result/json/tt.json @@ -1,7 +1,7 @@ { "data": { "classifys": { - "classfy": [ + "classify": [ { "fullclsfNamePath": "鐗╁搧##VCI##鏍囧噯浠�##VCI##铻烘爴", "classCode": "020101", @@ -59,4 +59,4 @@ ] } } -} \ No newline at end of file +} diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/enumpack/SysIntegrationLogTypeEnum.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/enumpack/SysIntegrationLogTypeEnum.java index 635c733..d0829b3 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/enumpack/SysIntegrationLogTypeEnum.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/enumpack/SysIntegrationLogTypeEnum.java @@ -36,7 +36,23 @@ /*** * 鏁版嵁鏌ヨ */ - TYPE_ACCPET_QUERYDATA("queryData","鏁版嵁鏌ヨ"); + TYPE_ACCPET_QUERYDATA("queryData","鏁版嵁鏌ヨ"), + + /*** + * 鏍囧噯鐢宠 + */ + TYPE_ACCPET_APPLYCODEFORBZ("applyCodeForBZ","鏍囧噯鐢宠"), + + /*** + * 閮ㄩ棬鐢宠 + */ + TYPE_ACCPET_SYNCDATAFORORG("syncDataForOrg","閮ㄩ棬鐢宠"), + + + /*** + * 浜哄憳鐢宠 + */ + TYPE_ACCPET_SYNCDATAFORPERSON("syncDataForPerson","浜哄憳鐢宠"); /** * 鏋氫妇鐨勫�� 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 a5016f5..6b63a24 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 @@ -17,8 +17,7 @@ import com.vci.ubcs.code.util.ClientBusinessObject; import com.vci.ubcs.code.util.gennerAttrMapUtil; import com.vci.ubcs.code.vo.pagemodel.*; -import com.vci.ubcs.code.vo.webserviceModel.applybz.ApplyBZParamVO; -import com.vci.ubcs.code.vo.webserviceModel.applybz.ApplyBZVO; +import com.vci.ubcs.code.vo.webserviceModel.applybz.*; import com.vci.ubcs.code.vo.webserviceModel.person.*; import com.vci.ubcs.code.vo.webserviceModel.apply.*; import com.vci.ubcs.code.vo.webserviceModel.attrmap.*; @@ -55,7 +54,6 @@ import com.vci.ubcs.system.vo.DeptVO; import com.vci.ubcs.system.vo.RoleVO; import lombok.extern.slf4j.Slf4j; -import org.apache.tools.ant.taskdefs.condition.Http; import org.springblade.core.log.exception.ServiceException; import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.tool.api.R; @@ -67,9 +65,7 @@ import javax.annotation.Resource; import javax.jws.WebMethod; -import javax.servlet.ServletRequest; import javax.servlet.http.HttpServletRequest; -import javax.ws.rs.core.Context; import javax.xml.ws.WebServiceContext; import javax.xml.ws.handler.MessageContext; import java.util.*; @@ -1938,131 +1934,181 @@ return resultStr; } + /*** + * 鏍囧噯鍖栫敓鎴愭帴鍙� + * @param data 鏁版嵁淇℃伅 + * @param dataType 鏁版嵁鏍煎紡绫诲瀷 + * @return + */ public String applyCodeForBZ(String data,String dataType){ String resultStr = ""; -// log.info("鏂规硶->applyCodeForBZ start"); -// -// final String[] errorid = {"0"}; -// msg="鎴愬姛"; -// objerrorCode="0"; -// objerrorMsg="鎴愬姛"; -// log.info("鐢宠缂栫爜鐨勬暟鎹弬鏁�:->"+data); -// log.info("鐢宠缂栫爜鐨勬暟鎹被鍨�:->"+dataType); -// String systemId=""; -// List<XMLResultClassfyVO> resultClassfyVOList = new ArrayList<>(); -// LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>(); -// try{ -// try { -// if(StringUtils.isBlank(data)) { -// errorid[0] ="101"; -// throw new Throwable("鎺ュ彛鍙傛暟锛氫紶閫掍负绌�"); -// } -// ApplyBZParamVO applyBZParamVO =new ApplyBZParamVO(); -// //濡傛灉dataType鏄痻ml鍒欙紝閫氳繃xml搴忓垪鍖栨垚瀵硅薄褰㈠紡锛屽鏋滄槸json鍒欓�氳繃json杞崲鎴愬璞℃牸寮� -// try { -// if ("xml".equals(dataType)) { -// XStream xStream = new XStream(new DomDriver()); -// xStream.processAnnotations(RootDataVO.class); -// xStream.autodetectAnnotations(true); -// ApplyBZVO rootDataVO = (ApplyBZVO) xStream.fromXML(data); -// applyBZParamVO.setData(rootDataVO); -// } else { -// applyBZParamVO = JSONObject.toJavaObject(JSONObject.parseObject(data), ApplyBZParamVO.class); -// } -// }catch (Throwable e){ -// errorid[0] ="101"; -// throw new Throwable("鎺ュ彛鍙傛暟锛氫紶鍏ユ暟鎹弬鏁拌В鏋愬け璐�"); -// } -// ClassfysVO classfysVO = interParameterVO.getData().getClassifys(); -// systemId = interParameterVO.getData().getSystemId(); -// UserVO userVo = interParameterVO.getData().getUser(); -// //鍏嶅瘑鐧诲綍鐢宠token锛宺equest涓坊鍔犵敤鎴蜂俊鎭� -// passwordFreeLoginService.passwordFreeLogin(userVo.getUserName(),this.getRequest()); -// AuthUtil.getUser(); -// List<ClassfyVO> classVOList = classfysVO.getClassify(); -// 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<>(); -// String finalSystemId = systemId; -// } catch (Throwable e) { -// List<ApplyDataVO> applyDataVOList= classVO.getObjects().getObject(); -// objerrorCode="1"; -// if(!CollectionUtils.isEmpty(applyDataVOList)) { -// applyDataVOList.stream().forEach(applyDataVO -> { -// XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO(); -// xmlResultDataObjectDetailDO.setCode(""); -// xmlResultDataObjectDetailDO.setId(applyDataVO.getId()); -// xmlResultDataObjectDetailDO.setErrorid(objerrorCode); -// xmlResultDataObjectDetailDO.setMsg("缂栫爜鐢宠澶辫触:" + e.getMessage()); -// resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO); -// }); -// }else{ -// XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO(); -// xmlResultDataObjectDetailDO.setCode(""); -// xmlResultDataObjectDetailDO.setId(""); -// xmlResultDataObjectDetailDO.setErrorid(objerrorCode); -// xmlResultDataObjectDetailDO.setMsg("缂栫爜鐢宠澶辫触:" + e.getMessage()); -// resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO); -// } -// e.printStackTrace(); -// }finally { -// XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO(); -// resultClassfyVO.setClassCode(classVO.getClassCode()); -// resultClassfyVO.setLibrary(classVO.getLibrary()); -// resultClassfyVO.setFullclsfNamePath(classVO.getFullclsfNamePath()); -// resultClassfyVO.setObjects(resultDataObjectDetailDOs); -// resultClassfyVOList.add(resultClassfyVO); -// } -// XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO(); -// xmlResultSystemVO.setClassifys(resultClassfyVOList); -// xmlResultSystemVO.setMsg(msg); -// xmlResultSystemVO.setErrorid(errorid[0]); -// resultStr= transferResultXMl(xmlResultSystemVO,dataType); -// }catch (Throwable e){ -// e.printStackTrace(); -// msg="鐢宠缂栫爜澶辫触:"+e.getMessage(); -// /* XMLResultSystemVO XMLResultSystemVO=new XMLResultSystemVO(); -// XMLResultSystemVO.setErrorid(errorid); -// XMLResultSystemVO.setMsg("鐢宠缂栫爜澶辫触锛�->"+e.getMessage()); -// XMLResultSystemVO.setClassifys(resultClassfyVOList); -// resultStr=transferResultXMl(XMLResultSystemVO,dataType); -// -// log.error("鐢宠缂栫爜澶辫触锛�->"+e); -// return resultStr;*/ -// }finally { -// XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO(); -// xmlResultSystemVO.setClassifys(resultClassfyVOList); -// xmlResultSystemVO.setMsg(msg); -// xmlResultSystemVO.setErrorid(errorid[0]); -// resultStr= transferResultXMl(xmlResultSystemVO,dataType); -// final boolean[] issucess = {true}; -// if(!errorid[0].equals("0")) { -// issucess[0] = false; -// }else { -// if(!CollectionUtils.isEmpty(resultClassfyVOList)) { -// resultClassfyVOList.stream().forEach(xMLResultClassfyVO -> { -// xMLResultClassfyVO.getObjects().stream().forEach(objec -> { -// if (!(objec.getErrorid().equals("0") || objec.getErrorid().equals("204"))) { -// issucess[0] = false; -// msg=objec.getMsg(); -// } -// }); -// }); -// } -// } -// try { -// //璁板綍鏃ュ織 -// this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "applyCodeForBZ"); -// }catch (Throwable e){ -// e.printStackTrace(); -// } -// } -// log.info("杩斿洖鍙傛暟:"+resultStr); + log.info("鏂规硶->applyCodeForBZ start"); + final String[] errorid = {"0"}; + msg="鎴愬姛"; + objerrorCode="0"; + objerrorMsg="鎴愬姛"; + log.info("鐢宠缂栫爜鐨勬暟鎹弬鏁�:->"+data); + log.info("鐢宠缂栫爜鐨勬暟鎹被鍨�:->"+dataType); + String systemId=""; + List<XMLResultClassfyVO> resultClassfyVOList = new ArrayList<>(); + LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>(); + try { + ClassfyBZVO classfyBZVO = null; + if (StringUtils.isBlank(data)) { + errorid[0] = "101"; + throw new Throwable("鎺ュ彛鍙傛暟锛歞ataString 浼犻�掍负绌�"); + } + ApplyBZParamVO applyBZParamVO = new ApplyBZParamVO(); + //濡傛灉dataType鏄痻ml鍒欙紝閫氳繃xml搴忓垪鍖栨垚瀵硅薄褰㈠紡锛屽鏋滄槸json鍒欓�氳繃json杞崲鎴愬璞℃牸寮� + try { + if ("xml".equals(dataType)) { + XStream xStream = new XStream(new DomDriver()); + xStream.processAnnotations(RootDataVO.class); + xStream.autodetectAnnotations(true); + ApplyBZVO rootDataVO = (ApplyBZVO) xStream.fromXML(data); + applyBZParamVO.setData(rootDataVO); + } else { + applyBZParamVO = JSONObject.toJavaObject(JSONObject.parseObject(data), ApplyBZParamVO.class); + } + } catch (Throwable e) { + errorid[0] = "101"; + throw new Throwable("鎺ュ彛鍙傛暟锛氫紶鍏ユ暟鎹弬鏁拌В鏋愬け璐�"); + } + classfyBZVO = applyBZParamVO.getData().getClassify(); + systemId = applyBZParamVO.getData().getSystemId(); + UserVO userVo = applyBZParamVO.getData().getUser(); + //鍏嶅瘑鐧诲綍鐢宠token锛宺equest涓坊鍔犵敤鎴蜂俊鎭� + passwordFreeLoginService.pwdFreeLoginByBoolean(userVo.getUserName(), this.getRequest()); + AuthUtil.getUser(); + //杩欐槸璐﹀彿淇℃伅 + SessionInfo sessionInfo = new SessionInfo(); + sessionInfo.setUserId(userVo.getUserName()); + sessionInfo.setUserName(userVo.getTrueName()); + sessionInfo.setIp(userVo.getIp()); + VciBaseUtil.setCurrentUserSessionInfo(sessionInfo); +// List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>(); + String finalSystemId = systemId; + String libray=""; + boolean isCodeOrGroupCode=false; + try { + libray = classfyBZVO.getLibrary(); + CodeClassifyVO codeClassifyVO = getClassfy(classfyBZVO,libray); + log.info("end锛氬垎绫绘煡璇㈠畬姣�"); + //鑾峰彇鍒嗙被妯℃澘淇℃伅 + if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){ + objerrorCode="100"; + throw new Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙栧埌鍒嗙被淇℃伅"); + } + String operation=""; + if(CODE_CHECKCONFIG) { + //鏍¢獙鏄惁閰嶇疆 + DockingSystemConfig dockingSystemConfig=null; + dockingSystemConfig=checkIspass(finalSystemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue(),codeClassifyVO.getOid()); + if(dockingSystemConfig==null){ + errorid[0] ="101"; + throw new Throwable("绯荤粺鏍囪瘑涓恒��"+ finalSystemId +"銆戯紝闆嗘垚鍒嗙被涓恒��"+codeClassifyVO.getName()+"銆戜互涓婂垎绫伙紝"+sysIntegrationPushTypeEnum.ACCPET_APPCODE.getText()+"鎺ュ彛閰嶇疆宸插仠鐢ㄦ垨鑰呮湭閰嶇疆锛岃鑱旂郴缂栫爜绠$悊鍛橈紒"); + } + isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false; + } + CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid()); + if(templateVO==null||StringUtils.isBlank(templateVO.getOid())){ + objerrorCode="1"; + throw new Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙朚DM绯荤粺涓搴旀ā鏉�"); + } + log.info("end锛氭ā鏉挎煡璇㈠畬姣�"); + ApplyBZDatasVO applyDatasVO = classfyBZVO.getObjects(); + DataObjectVO dataObjectVO = new DataObjectVO(); + List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag()) + ).collect(Collectors.toList()); + //this.getConfigDatas(finalSystemId, libray, applyDatasVO, attrVOS, dataObjectVO); + log.info("end锛氭暟鎹粍缁囧畬姣�"); + //瑙勫垯鐨勪富閿渶瑕佸幓鑾峰彇 + CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(codeClassifyVO.getOid()); + if(classifyFullInfo==null ||classifyFullInfo.getCurrentClassifyVO()==null || StringUtils.isBlank(classifyFullInfo.getCurrentClassifyVO().getOid())){ + objerrorCode="1"; + log.info("classifyFullInfo:"+"鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙栧垎绫荤浉鍏充俊鎭�"); + throw new Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙栧垎绫荤浉鍏充俊鎭�"); + } + CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo); + if(ruleVO==null||StringUtils.isBlank(ruleVO.getOid())){ + objerrorCode="102"; + throw new Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙朚DM绯荤粺涓搴旇鍒�"); + } + log.info("end锛氳鍒欒幏鍙栧畬姣�"); + //List<CodeOrderSecDTO> codeOrderSecDTOList = getRuleCodeOrderSecDTOs(ruleVO,classifyFullInfo); + log.info("end锛氱爜娈佃幏鍙栧畬姣�"); + CodeOrderDTO orderDTO = new CodeOrderDTO(); + orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//鍒嗙被涓婚敭 + //orderDTO.setSecDTOList(codeOrderSecDTOList);//鍒嗙被鐮佹 + mdmIOService.batchSyncApplyCode(orderDTO, dataObjectVO, resultDataObjectDetailDOs,isCodeOrGroupCode); + //allResultDataObjectDetailDOS.add(resultDataObjectDetailDOs); + log.info("end锛氱敵璇疯幏鍙栧畬姣�"); + } catch (Throwable e) { + List<ApplyBZDataVO> applyDataVOList = classfyBZVO.getObjects().getObject(); + objerrorCode = "1"; + if (!CollectionUtils.isEmpty(applyDataVOList)) { + applyDataVOList.stream().forEach(applyDataVO -> { + XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO(); + xmlResultDataObjectDetailDO.setCode(""); + xmlResultDataObjectDetailDO.setId(applyDataVO.getId()); + xmlResultDataObjectDetailDO.setErrorid(objerrorCode); + xmlResultDataObjectDetailDO.setMsg("缂栫爜鐢宠澶辫触:" + e.getMessage()); + resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO); + }); + } else { + XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO(); + xmlResultDataObjectDetailDO.setCode(""); + xmlResultDataObjectDetailDO.setId(""); + xmlResultDataObjectDetailDO.setErrorid(objerrorCode); + xmlResultDataObjectDetailDO.setMsg("缂栫爜鐢宠澶辫触:" + e.getMessage()); + resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO); + } + e.printStackTrace(); + } finally { + XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO(); + resultClassfyVO.setClassCode(classfyBZVO.getClassCode()); + resultClassfyVO.setLibrary(classfyBZVO.getLibrary()); + resultClassfyVO.setFullclsfNamePath(classfyBZVO.getFullclsfNamePath()); + resultClassfyVO.setObjects(resultDataObjectDetailDOs); + resultClassfyVOList.add(resultClassfyVO); + } + XMLResultSystemVO xmlResultSystemVO = new XMLResultSystemVO(); + xmlResultSystemVO.setClassifys(resultClassfyVOList); + xmlResultSystemVO.setMsg(msg); + xmlResultSystemVO.setErrorid(errorid[0]); + resultStr = transferResultXMl(xmlResultSystemVO, dataType); + }catch (Throwable e){ + e.printStackTrace(); + msg="鐢宠缂栫爜澶辫触:"+e.getMessage(); + }finally { + XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO(); + xmlResultSystemVO.setClassifys(resultClassfyVOList); + xmlResultSystemVO.setMsg(msg); + xmlResultSystemVO.setErrorid(errorid[0]); + resultStr= transferResultXMl(xmlResultSystemVO,dataType); + final boolean[] issucess = {true}; + if(!errorid[0].equals("0")) { + issucess[0] = false; + }else { + if(!CollectionUtils.isEmpty(resultClassfyVOList)) { + resultClassfyVOList.stream().forEach(xMLResultClassfyVO -> { + xMLResultClassfyVO.getObjects().stream().forEach(objec -> { + if (!(objec.getErrorid().equals("0") || objec.getErrorid().equals("204"))) { + issucess[0] = false; + msg=objec.getMsg(); + } + }); + }); + } + } + try { + //璁板綍鏃ュ織 + this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "applyCodeForBZ"); + }catch (Throwable e){ + e.printStackTrace(); + } + } + log.info("杩斿洖鍙傛暟:"+resultStr); //璋冪敤闆嗗洟鐢宠鎺ュ彛鐢宠闆嗗洟鐮� return resultStr; } @@ -2071,6 +2117,48 @@ * @param classfyVO */ private CodeClassifyVO getClassfy(ClassfyVO classfyVO,String libray) throws Throwable{ + CodeClassifyVO classifyVO = new CodeClassifyVO(); + try { + String classCode = classfyVO.getClassCode(); + String className = classfyVO.getFullclsfNamePath(); + //鏍规嵁鍒嗙被浠e彿鏌ヨ鍒嗙被淇℃伅 + if (StringUtils.isNotBlank(classfyVO.getClassCode())) { + Map<String, String> conditionMap = new HashMap<>(); + List<CodeClassify> codeClassifyList = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId, classCode)); + final CodeClassify[] newCodeClassify = {new CodeClassify()}; + if (!CollectionUtils.isEmpty(codeClassifyList)) { + codeClassifyList.stream().forEach(codeClassify -> { + CodeClassifyVO codeClassifyVO= classifyService.getTopClassifyVO(codeClassify.getOid()); + if(codeClassifyVO.getId().equals(libray)){ + newCodeClassify[0] =codeClassify; + } + }); + classifyVO = new CodeClassifyVO(); + BeanUtilForVCI.copyPropertiesIgnoreCase(newCodeClassify[0], classifyVO); + //灏咲TO杞崲涓篋O + if(StringUtils.isBlank(classifyVO.getOid())){ + throw new Throwable("鐢宠缂栫爜鐨勫垎绫伙細銆�"+classCode+"銆戜笉灞炰簬搴撹妭鐐广��"+libray+"銆戯紝璇锋鏌ュ弬鏁板垎绫昏妭鐐�/搴撹妭鐐逛俊鎭槸鍚﹀尮閰�"); + } + }else{ + throw new Throwable("鏍规嵁鍒嗙被浠e彿鏈煡璇㈠埌鐩稿簲鐨勫垎绫讳俊鎭�"); + } + } else { + classifyVO = classifyService.getObjectByClsfNamePath(className.replace(separator, "/")); + if(StringUtils.isBlank(classifyVO.getOid())){ + throw new Throwable("鏍规嵁鍒嗙被鍚嶇О璺緞鏈煡璇㈠埌鐩稿簲鐨勫垎绫讳俊鎭�"); + } + } + }catch (Throwable e){ + objerrorCode="100"; + throw new Throwable("鑾峰彇鍒嗙被淇℃伅澶辫触:"+e.getMessage()); + } + return classifyVO; + } + /*** + * 鏌ヨ鏍¢獙鍒嗙被淇℃伅 + * @param classfyVO + */ + private CodeClassifyVO getClassfy(ClassfyBZVO classfyVO,String libray) throws Throwable{ CodeClassifyVO classifyVO = new CodeClassifyVO(); try { String classCode = classfyVO.getClassCode(); @@ -2122,6 +2210,21 @@ }); return clientBusinessObjectList; } + + + private List<CodeOrderSecDTO> getRuleCodeOrderSecDTOsBZ(CodeRuleVO ruleVO,CodeClassifyFullInfoBO classifyFullInfo){ + List<CodeBasicSecVO> codeBasicSecVOS= ruleVO.getSecVOList(); + List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>(); + Map<String,String> errorMap=new HashMap<>(); + for(CodeBasicSecVO codeBasicSecVO: codeBasicSecVOS) { + String sectype = codeBasicSecVO.getSecType(); + String classifySecOid= codeBasicSecVO.getOid(); + String message=""; + } + return codeOrderSecDTOList; + } + + /*** * 鏍规嵁绌垮叆鐨勫弬鏁颁俊鎭牎楠岀爜娈佃鍒� */ @@ -2131,7 +2234,7 @@ SectionVOList.stream().forEach(SectionVO->{ sectionVOMap.put(SectionVO.getName(),SectionVO.getValue()); }); - Map<String,CodeClassifyVO> codeClassifyVOMap= classifyFullInfo.getParentClassifyVOs().stream().collect(Collectors.toMap(s -> s.getId(), t -> t,(o1, o2)->o2)); + //Map<String,CodeClassifyVO> codeClassifyVOMap= classifyFullInfo.getParentClassifyVOs().stream().collect(Collectors.toMap(s -> s.getId(), t -> t,(o1, o2)->o2)); List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>(); Map<String,String> errorMap=new HashMap<>(); for(CodeBasicSecVO codeBasicSecVO: codeBasicSecVOS) { -- Gitblit v1.9.3