From 60c39bdb211bce90f87a058b9dba0b63d67dea8e Mon Sep 17 00:00:00 2001 From: ludc Date: 星期五, 16 八月 2024 17:53:54 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java | 423 +++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 396 insertions(+), 27 deletions(-) diff --git a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java index 44d39ff..8f49da8 100644 --- a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java +++ b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java @@ -1,19 +1,33 @@ package com.vci.web.service.impl; +import cn.hutool.core.io.FileUtil; +import cn.hutool.core.util.ZipUtil; import com.alibaba.fastjson.JSONObject; import com.vci.client.common.oq.OQTool; import com.vci.common.qt.object.*; +import com.vci.constant.FrameWorkLangCodeConstant; import com.vci.corba.common.PLException; import com.vci.corba.omd.atm.AttributeDef; import com.vci.corba.omd.data.LinkObject; +import com.vci.corba.omd.ltm.LinkType; import com.vci.corba.omd.qtm.QTD; import com.vci.corba.omd.qtm.QTInfo; import com.vci.dto.QTInfoDTO; import com.vci.omd.objects.OtherInfo; +import com.vci.po.OsLinkTypePO; +import com.vci.starter.poi.bo.ReadExcelOption; +import com.vci.starter.poi.bo.WriteExcelData; +import com.vci.starter.poi.bo.WriteExcelOption; +import com.vci.starter.poi.constant.ExcelLangCodeConstant; +import com.vci.starter.poi.util.ExcelUtil; +import com.vci.starter.web.exception.VciBaseException; import com.vci.starter.web.pagemodel.BaseResult; +import com.vci.starter.web.pagemodel.Tree; import com.vci.starter.web.util.*; +import com.vci.web.other.LinkQTExportData; import com.vci.web.service.*; import com.vci.web.util.DateUtil; +import com.vci.web.util.Func; import com.vci.web.util.PlatformClientUtil; import com.vci.web.util.WebUtil; import org.apache.commons.lang3.StringUtils; @@ -23,7 +37,13 @@ import org.dom4j.Element; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; +import org.springframework.web.multipart.MultipartFile; + +import javax.servlet.http.HttpServletResponse; +import java.io.*; import java.util.*; +import java.util.stream.Collectors; /** * 鏌ヨ妯℃澘鏈嶅姟 @@ -142,8 +162,8 @@ * @return 鏌ヨ缁撴灉 */ @Override - public BaseResult getCriteria(HashMap<String,Object> dataMap) throws PLException { - QueryTemplate qt = getQT(dataMap); + public BaseResult getCriteria(QTInfoDTO qtInfoDTO) throws PLException { + QueryTemplate qt = getQT(qtInfoDTO); String checkInfo = OQTool.checkQT(qt); if(!checkInfo.equals("OK")){ throw new PLException("500", new String[]{checkInfo}); @@ -279,6 +299,71 @@ } } + /** + * 閾炬帴绫诲瀷鏌ヨ妯℃澘鏍戞煡璇紝鐢ㄤ簬鐣岄潰鐨勫鍑哄姛鑳� + * @return 鏌ヨ缁撴灉 + */ + @Override + public BaseResult getLinkTree() throws PLException { + LinkType[] linkTypes= null; + QTInfo[] qts = null; + HashMap<String,Object> tree = new HashMap(); + tree.put("text","涓氬姟绫诲瀷"); + if (linkTypes == null) { + List<LinkType> es = new ArrayList<LinkType>(); + linkTypes = platformClientUtil.getLinkTypeService().getLinkTypes(); + for (LinkType lt : linkTypes) { + QTInfo[] qtWrappers = platformClientUtil.getQTDService().getObjTypeQTs(lt.name); + if (qtWrappers.length!=0) { + es.add(lt); + } + } + linkTypes = es.toArray(new LinkType[es.size()]); + //TODO:闇�淇娌℃湁鍏宠仈鏌ヨ妯℃澘涓氬姟绫诲瀷鍘绘帀 + qts = platformClientUtil.getQTDService().getAllQTs();//鑾峰彇鎵�鏈夋煡璇㈡ā鏉� + } + List<HashMap<String,Object>> childList = new ArrayList<>(); + //娣诲姞涓氬姟绫诲瀷鏍硅妭鐐� + for (LinkType plAction : linkTypes) { + HashMap<String,Object> childTree = new HashMap(); + childTree.put("text", plAction.tag + "/" +plAction.name); + childTree.put("oid", plAction.oid); +// tree.put("children", childTree); + addExportTreeNode(plAction, qts, childTree); + childList.add(childTree); + } + tree.put("children", childList); + return BaseResult.success(tree); + } + + /** + * 鐢熸垚瀵煎嚭鏍戦�夋嫨浠ュ強瀵煎叆鏍戞樉绀� + * @param linkType + * @param qts + * @param tree + */ + private void addExportTreeNode(LinkType linkType/*涓氬姟绫诲瀷*/,QTInfo[] qts/*鏌ヨ妯℃澘瀵硅薄*/,HashMap<String,Object> tree) { + List<String> childList = new ArrayList<>(); + // 娣诲姞鏌ヨ妯℃澘瀵硅薄瀛愯妭鐐� + for (QTInfo qtItem : qts) { + //澶勭悊瀵煎叆鏃舵棤娉曡繘琛岀被鍨嬪垽鏂� + int splitLength = linkType.name.indexOf("銆�"); + if(splitLength == -1){ + splitLength = linkType.name.length(); + } + if (qtItem.btmName.equals(linkType.name.substring(0, + splitLength))) { + childList.add(qtItem.qtName); + } + } + tree.put("children",childList); + } + + /** + * 灏嗛珮绾ф潯浠舵暟鎹浆涓簒ml + * @param qtInfoDTO 鏌ヨ妯℃澘鍒楄〃浼犺緭瀵硅薄 + * @return xml鏁版嵁 + */ private String getSeniorXML(QTInfoDTO qtInfoDTO){ HashMap<String, Object> tree = qtInfoDTO.getTree(); if(tree.isEmpty()){ @@ -300,6 +385,12 @@ return xmlStr.append("</root>").toString(); } + + /** + * 灏嗛珮绾ф潯浠舵暟鎹浆涓簒ml + * @param childs 楂樼骇鏉′欢鏁版嵁 + * @return xml鏁版嵁 + */ private String getSeniorChildXML(JSONObject childs){ StringBuilder xmlStr = new StringBuilder("<child>" + childs.get("connector")); @@ -498,8 +589,6 @@ //楂樼骇鏌ヨ鏉′欢 }else if(qtInfoDTO.getLevelFlag() == 1){ ciMap = getCIMapForSeniorTree(qtInfoDTO); - -// OQTool.parseTreeToDoc(seniorTree); } return ciMap; } @@ -797,34 +886,34 @@ return qt; } - /** - * 缁勮鏌ヨ妯℃澘 - * @return - */ - public QueryTemplate getQT(HashMap<String,Object> dataMap){ - QueryTemplate qt = new QueryTemplate(); - qt.setType(QTConstants.TYPE_LINK); - //TODO String qtId = - qt.setLinkType((String) dataMap.get("linkTypeName")); - qt.setDirection( (Boolean)dataMap.get("rdPositive") ? QTConstants.DIRECTION_POSITIVE : QTConstants.DIRECTION_OPPOSITE); - qt.setBtmType((String) dataMap.get("btmName")); - if("鎵�鏈夌被鍨�".equals(dataMap.get("combRelaType"))){ - qt.setBtmType("*"); - } - qt.setVersion(getVersion((String) dataMap.get("versionValue"))); - qt.setQueryISLeaf((Boolean) dataMap.get("isQueryIsLeaf")); - qt.setLevel(StringUtils.isBlank((CharSequence) dataMap.get("level")) ? 1 : Integer.valueOf(String.valueOf(dataMap.get("level")))); - List<String> clauseList = new ArrayList<String>(); - //TODO 鏌ヨ鍒� 鏄剧ず鍒� - clauseList.add("*"); - qt.setClauseList(clauseList); +// /** +// * 缁勮鏌ヨ妯℃澘 +// * @return +// */ +// public QueryTemplate getQT(HashMap<String,Object> dataMap){ +// QueryTemplate qt = new QueryTemplate(); +// qt.setType(QTConstants.TYPE_LINK); +// //TODO String qtId = +// qt.setLinkType((String) dataMap.get("linkTypeName")); +// qt.setDirection( (Boolean)dataMap.get("rdPositive") ? QTConstants.DIRECTION_POSITIVE : QTConstants.DIRECTION_OPPOSITE); +// qt.setBtmType((String) dataMap.get("btmName")); +// if("鎵�鏈夌被鍨�".equals(dataMap.get("combRelaType"))){ +// qt.setBtmType("*"); +// } +// qt.setVersion(getVersion((String) dataMap.get("versionValue"))); +// qt.setQueryISLeaf((Boolean) dataMap.get("isQueryIsLeaf")); +// qt.setLevel(StringUtils.isBlank((CharSequence) dataMap.get("level")) ? 1 : Integer.valueOf(String.valueOf(dataMap.get("level")))); +// List<String> clauseList = new ArrayList<String>(); +// //TODO 鏌ヨ鍒� 鏄剧ず鍒� +// clauseList.add("*"); +// qt.setClauseList(clauseList); // Condition con = new Condition(); // qt.setCondition(con); // HashMap<String, ConditionItem> ciMap = getCIMap(); // con.setCIMap(ciMap); // con.setRootCIName(con.getRootCINameByCIMap(ciMap)); - return qt; - } +// return qt; +// } /** @@ -868,4 +957,284 @@ throw new PLException("500", new String[]{"璇ユā鏉垮畾涔夊悕宸茬粡琚娇鐢�, 璇锋洿鎹�"}); } } + + + /** + * 瀵煎嚭閾炬帴绫诲瀷鏌ヨ妯℃澘 + * names 鏌ヨ妯℃澘鍚� + * @return + */ + @Override + public void expLinkTemplate(List<String> names, HttpServletResponse response) throws PLException, IOException { + String defaultTempFolder = LocalFileUtil.getDefaultTempFolder(); + String vciqtmfFileName = defaultTempFolder + File.separator + "LinkTemplateExp" + new Date().getTime() + ".vciqtf"; + LinkQTExportData exportData = new LinkQTExportData(); + for (String name : names) { + QTInfo qt = platformClientUtil.getQTDService().getQT(name); + exportData.getAllQTs().put(qt.qtName,qt); + LinkType linkType = platformClientUtil.getLinkTypeService().getLinkType(qt.btmName); + if(linkType != null && !linkType.oid.equals("")){ + exportData.getSelectedBtmItems().put(linkType.name, linkType); + exportData.getSelectedBtmAttrs().put(linkType.name, linkType.attributes); + exportData.getAllQTDs().put(linkType.name, platformClientUtil.getQTDService().getLinkTypeQTDs(linkType.name)); + } + } + ObjectOutputStream vciamfFileStream = null; + try { + File vciqtmfFile = new File(vciqtmfFileName); + vciamfFileStream = new ObjectOutputStream(new FileOutputStream(vciqtmfFile)); + vciamfFileStream.writeObject(exportData); + }finally { + try { + if (vciamfFileStream != null) { + vciamfFileStream.flush(); + vciamfFileStream.close(); + } + } catch (Exception e) { + throw new PLException("500",new String[]{"瀵煎嚭娴佸叧闂紓甯革紒"}); + } + } + ControllerUtil.writeFileToResponse(response,vciqtmfFileName); + FileUtil.del(defaultTempFolder + File.separator); + } + /** + * 瀵煎叆閾炬帴绫诲瀷鏌ヨ妯℃澘 + * @param file 涓婁紶鐨勬枃浠� + * @return 瀵煎叆缁撴灉 + */ + @Override + public BaseResult impLinkTemplate(MultipartFile file) throws IOException, ClassNotFoundException { + + if (file == null) { + return BaseResult.fail(FrameWorkLangCodeConstant.IMPORT_FAIL, new String[]{"鏃犲鍏ョ殑鏂囦欢"}); + } + if (!file.getOriginalFilename().endsWith(".vciqtf")) { + throw new VciBaseException("浠呰兘涓婁紶.vciqtf鏍煎紡鏂囦欢锛岃閲嶆柊涓婁紶锛�"); + } + ObjectInputStream obj = new ObjectInputStream( + file.getInputStream()); + LinkQTExportData qtExportData = (LinkQTExportData) obj.readObject(); + List<LinkType> ltsNew = new ArrayList<>(); + List<QTInfo> qTWrapperNew = new ArrayList<>(); + Map<String/* 绫诲瀷鍚嶇О */, QTD[]/* 鏌ヨ妯℃澘瀹氫箟 */> norepQTDs = new HashMap<String, QTD[]>(); + addImportData(qtExportData, ltsNew, qTWrapperNew, norepQTDs); + QTInfo[] qts = qTWrapperNew + .toArray(new QTInfo[qTWrapperNew.size()]); + //澶勭悊鏍戠殑杩斿洖 + HashMap<String,Object> tree = new HashMap(); + tree.put("text","閾炬帴绫诲瀷"); + List<HashMap<String,Object>> childList = new ArrayList<>(); + //娣诲姞涓氬姟绫诲瀷鏍硅妭鐐� + for (LinkType plAction : ltsNew) { + HashMap<String,Object> childTree = new HashMap(); + childTree.put("text", plAction.tag + "/" +plAction.name); + childTree.put("oid", plAction.oid); + addExportTreeNode(plAction, qts, childTree); + childList.add(childTree); + } + tree.put("children", childList); + return BaseResult.success(tree); + } + + // 鏁版嵁杩囨护 + private void addImportData(LinkQTExportData qtExportData, List<LinkType> ltsNew, List<QTInfo> qTWrapperNew, + Map<String/* 绫诲瀷鍚嶇О */, QTD[]/* 鏌ヨ妯℃澘瀹氫箟 */> norepQTDs) { + Map<String/* 绫诲瀷鍚嶇О */, QTD[]/* 鏌ヨ妯℃澘瀹氫箟 */> allQTDs = qtExportData + .getAllQTDs(); + Map<String/* 绫诲瀷鍚嶇О */, LinkType/* 绫诲瀷瀵硅薄 */> selectedBtmItems = qtExportData + .getSelectedBtmItems(); + Map<String/* 绫诲瀷鍚嶇О */, String[]/* 绫诲瀷鎵�灞炲睘鎬� */> selectedBtmAttrs = qtExportData + .getSelectedBtmAttrs(); + Map<String/* 鏌ヨ妯℃澘鍚嶇О */, QTInfo/* 鏌ヨ妯℃澘瀵硅薄 */> allSelectedQTs = qtExportData + .getAllQTs(); + if (allQTDs.size() == 0 || allQTDs == null + || selectedBtmItems.size() == 0 || selectedBtmItems == null + || selectedBtmAttrs.size() == 0 || selectedBtmAttrs == null + || allSelectedQTs.size() == 0 || allSelectedQTs == null) { + throw new VciBaseException("瀵煎叆鐨勬ā鏉挎暟鎹湁璇�!!!"); + } + Set<Map.Entry<String, QTD[]>> pLActions = allQTDs.entrySet(); + Set<Map.Entry<String, QTInfo>> pLQts = allSelectedQTs.entrySet(); + Set<Map.Entry<String, LinkType>> LinkpLQts = selectedBtmItems.entrySet(); + for (Map.Entry<String, QTD[]> entry : pLActions) { + String string = entry.getKey(); + QTD[] qtds = entry.getValue(); + getPLQtIsInDB(string, qtds, norepQTDs); + } + for (Map.Entry<String, LinkType> entry : LinkpLQts) { + String string = entry.getKey(); + LinkType LinkType = entry.getValue(); + getPLQtBtmItem(string, LinkType, ltsNew); + } + Map<String/*绫诲瀷鍚嶇О*/, QTD[]/*鏌ヨ妯℃澘瀹氫箟*/> newNorepQTDs = getnewNorepQTDs(norepQTDs,allSelectedQTs); + for (Map.Entry<String, QTInfo> entry : pLQts) { + String string = entry.getKey(); + QTInfo qtWrapper = entry.getValue(); + getPLQtWrapper(string, qtWrapper, ltsNew, qTWrapperNew, newNorepQTDs); + } + + } + + /** + * 鏌ヨ妯℃澘瀹氫箟鐨勫鐞� + * @param string + * @param qtds + */ + private void getPLQtIsInDB(String string, QTD[] qtds, Map<String/* 绫诲瀷鍚嶇О */, QTD[]/* 鏌ヨ妯℃澘瀹氫箟 */> norepQTDs) { + // TODO Auto-generated method stub + try { + QTD[] qtds2 = platformClientUtil.getQTDService().getBizTypeQTDs(string); + QTD[] qtdsNewQtds = null; + List<QTD> es = new ArrayList<>(); + for (QTD qtd : qtds) { + boolean isleat = true; + for (int i = 0; i < qtds2.length; i++) { + if (qtd.name.equals(qtds2[i].name)) { + isleat = false; + break; + } + } + if (isleat) { + es.add(qtd); + } + } + if (es.size() != 0) { + qtdsNewQtds = es.toArray(new QTD[es.size()]); + norepQTDs.put(string, qtdsNewQtds); + } + } catch (PLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + + private void getPLQtBtmItem(String string, LinkType linkType, List<LinkType> ltsNew) { + // TODO Auto-generated method stub + try { + LinkType queryLinkType = platformClientUtil.getLinkTypeService().getLinkType(string); + LinkType[] btmArray = platformClientUtil.getLinkTypeService().getLinkTypes(); + String[] strings = queryLinkType.attributes; + String[] stringsFrom = queryLinkType.btmItemsFrom; + String[] stringsTo = queryLinkType.btmItemsTo; + boolean b = true; + for (int i = 0; i < btmArray.length; i++) { + if (btmArray[i].name.equals(string)) { + b = false; + if (Arrays.equals(linkType.attributes, strings) + && Arrays + .equals(linkType.btmItemsFrom, stringsFrom) + && Arrays.equals(linkType.btmItemsTo, stringsTo)) { + btmArray[i].name += "銆愰摼鎺ョ被鍨嬪凡瀛樺湪銆�"; + /* this.btmArray[i] = btmArray[i]; */ + ltsNew.add(btmArray[i]); + } else { + btmArray[i].name += "銆愰摼鎺ョ被鍨嬪瓨鍦ㄤ絾灞炴�т笉涓�鑷淬��"; + ltsNew.add(btmArray[i]); + } + } + } + if (b) { + linkType.name += "銆愰摼鎺ョ被鍨嬩笉瀛樺湪銆�"; + ltsNew.add(linkType); + } + } catch (PLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + + private void getPLQtWrapper(String string, QTInfo qtWrapper, List<LinkType> ltsNew, List<QTInfo> qTWrapperNew, Map<String/*绫诲瀷鍚嶇О*/, QTD[]/*鏌ヨ妯℃澘瀹氫箟*/> newNorepQTDs) { + try { + QTInfo[] qtws = platformClientUtil.getQTDService().getAllQTs(); + boolean islaet = true; + for (int i = 0; i < qtws.length; i++) { + if (string.equals(qtws[i].qtName)) { + islaet = false; + for (LinkType lt : ltsNew) { + if (qtWrapper.btmName.equals(lt.name.substring(0, + lt.name.indexOf("銆�")))) { + if (lt.name.endsWith("銆愰摼鎺ョ被鍨嬪凡瀛樺湪銆�")) { + qtWrapper.qtName += "銆愭煡璇㈡ā鏉垮凡瀛樺湪锛屼笉瀵煎叆銆�"; + qTWrapperNew.add(qtWrapper); + }else if(lt.name.endsWith("銆愰摼鎺ョ被鍨嬪瓨鍦ㄤ絾灞炴�т笉涓�鑷淬��")){ + qtWrapper.qtName += "銆愭煡璇㈡ā鏉挎墍灞為摼鎺ョ被鍨嬪睘鎬т笉涓�鑷达紝涓嶅鍏ャ��"; + qTWrapperNew.add(qtWrapper); + }else{ + qtWrapper.qtName += "銆愭煡璇㈡ā鏉挎墍灞為摼鎺ョ被鍨嬩笉瀛樺湪锛屼笉瀵煎叆銆�"; + qTWrapperNew.add(qtWrapper); + } + } + } + } + } + if (islaet) { + for (LinkType btmItem : ltsNew) { + if (qtWrapper.btmName.equals(btmItem.name.substring(0, + btmItem.name.indexOf("銆�")))) { + if (btmItem.name.endsWith("銆愰摼鎺ョ被鍨嬪凡瀛樺湪銆�")) { + //鍒ゆ柇鏌ヨ妯℃澘瀹氫箟鏄惁瀛樺湪锛岃繘琛屼繚瀛� + QTD[] qtds = newNorepQTDs.get(qtWrapper.btmName); + if(qtds != null){ + for (QTD qtd : qtds) { + QTD qtdByName = platformClientUtil.getQTDService().getQTDByName(qtd.name); + if(!(qtdByName != null && StringUtils.isNotBlank(qtdByName.name))){ + boolean b = platformClientUtil.getQTDService().addQTD(qtd); + if(!b){ + qtWrapper.qtName += qtWrapper.qtName+"瀵煎叆鏌ヨ妯℃澘瀹氫箟銆�" + qtdByName.name + "銆戝け璐ワ紒"; + } + } + } + newNorepQTDs.remove(qtWrapper.btmName); + } + boolean success = platformClientUtil.getQTDService().saveQT(qtWrapper); + if(!success){ + qtWrapper.qtName += qtWrapper.qtName+"瀵煎叆澶辫触锛�"; + }else { + qtWrapper.qtName += "銆愭煡璇㈡ā鏉垮鍏ユ垚鍔燂紒銆�"; + } + qTWrapperNew.add(qtWrapper); + }else if(btmItem.name.endsWith("銆愰摼鎺ョ被鍨嬪瓨鍦ㄤ絾灞炴�т笉涓�鑷淬��")){ + qtWrapper.qtName += "銆愭煡璇㈡ā鏉挎墍灞為摼鎺ョ被鍨嬪睘鎬т笉涓�鑷达紝涓嶅鍏ャ��"; + qTWrapperNew.add(qtWrapper); + }else{ + qtWrapper.qtName += "銆愭煡璇㈡ā鏉挎墍灞為摼鎺ョ被鍨嬩笉瀛樺湪锛屼笉瀵煎叆銆�"; + qTWrapperNew.add(qtWrapper); + } + } + } + } + } catch (PLException e) { + e.printStackTrace(); + } + } + + //鏍规嵁閫夋嫨鐨勬煡璇㈡ā鏉胯繃婊ゆā鏉垮畾涔� + private Map<String, QTD[]> getnewNorepQTDs(Map<String, QTD[]> norepQTDs, + Map<String, QTInfo> allQTs) { + // TODO Auto-generated method stub + Map<String, QTD[]> map = new HashMap<String, QTD[]>(); + Set<Map.Entry<String, QTInfo>> pLQts = allQTs.entrySet(); + Set<Map.Entry<String, QTD[]>> pLActions = norepQTDs.entrySet(); + for (Map.Entry<String, QTD[]> entrys : pLActions) { + for (Map.Entry<String, QTInfo> entry : pLQts) { + if(entry.getValue().btmName.equals(entrys.getKey())){ + map.put(entrys.getKey(), entrys.getValue()); + } + } + } + return map; + } + /** + * 鏌ヨ鏂规鍒犻櫎 + * @param templateNames 鏌ヨ鏂规鍚� + * @return 鎿嶄綔缁撴灉 + */ + @Override + public BaseResult deleteLinkTemplate(List<String> templateNames) throws PLException { + boolean b = platformClientUtil.getQTDService().deleteQTs(templateNames.toArray(new String[0])); + if(!b){ + return BaseResult.fail("鍒犻櫎澶辫触锛侊紒锛�"); + } + return BaseResult.success(); + } } -- Gitblit v1.9.3