From c0b116a413ff26775176017674948969c26f2d2a Mon Sep 17 00:00:00 2001 From: yuxc <yuxc@vci-tech.com> Date: 星期五, 16 八月 2024 11:33:35 +0800 Subject: [PATCH] 1、新增链接类型查询模板的普通、高级保存接口的编写及测试,以及查询显示接口的变动。 2、新增链接类型查询模板树查询,用于界面的导出功能接口。 3、新增链接类型查询模板导出功能。 4、新增链接类型查询模板导入功能这里上传文件直接导入了数据并返回了相关导入结果。 5、新增链接类型查询模板删除接口。 --- Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsLinkTypeController.java | 4 Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsQueryTemplateController.java | 64 +++++ Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/impl/OsQueryTemplateImpl.java | 423 ++++++++++++++++++++++++++++++++++++-- Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/OsQuereyTemplateServiceI.java | 27 ++ Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/other/LinkQTExportData.java | 96 ++++++++ 5 files changed, 579 insertions(+), 35 deletions(-) diff --git a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsLinkTypeController.java b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsLinkTypeController.java index 044c644..cb3bc49 100644 --- a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsLinkTypeController.java +++ b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsLinkTypeController.java @@ -272,8 +272,8 @@ * @return */ @PostMapping("/impData") - @VciUnCheckRight - public BaseResult impData(MultipartFile file){try { + public BaseResult impData(MultipartFile file){ + try { return linkTypeService.impData(file); }catch (Throwable e) { throw new VciBaseException(VciBaseUtil.getExceptionMessage(e),new String[0],e); diff --git a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsQueryTemplateController.java b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsQueryTemplateController.java index 7eaabfb..0313038 100644 --- a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsQueryTemplateController.java +++ b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/controller/OsQueryTemplateController.java @@ -124,7 +124,7 @@ /** * 鏌ヨ鏉′欢鐨勬煡璇㈡寜閽煡璇is鍒楄〃 - * @param dataMap 浼犺緭鐨勬暟鎹璞★細 + * @param qtInfoDTO 浼犺緭鐨勬暟鎹璞★細 * linkTypeName 閾炬帴绫诲瀷鍚嶇О銆� * rdPositive 鏂瑰悜锛宼rue姝e悜锛宖alse鍙嶅悜 * btmName 涓氬姟绫诲瀷鍚嶇О @@ -134,10 +134,10 @@ * level 瀛愯妭鐐瑰眰鏁� * @return 鏌ヨ缁撴灉 */ - @GetMapping("/getCriteria") - public BaseResult getCriteria(@RequestBody HashMap<String,Object> dataMap){ + @PostMapping("/getCriteria") + public BaseResult getCriteria(@RequestBody QTInfoDTO qtInfoDTO){ try { - return quereyTemplateServiceI.getCriteria(dataMap); + return quereyTemplateServiceI.getCriteria(qtInfoDTO); } catch (PLException e) { BaseResult objectBaseResult = new BaseResult<>(); objectBaseResult.setCode(Integer.parseInt(e.code)); @@ -202,4 +202,60 @@ return objectBaseResult; } } + + /** + * 閾炬帴绫诲瀷鏌ヨ妯℃澘鏍戞煡璇紝鐢ㄤ簬鐣岄潰鐨勫鍑哄姛鑳� + * @return 鏌ヨ缁撴灉 + */ + @GetMapping("/getLinkTree") + public BaseResult getLinkTree(){ + try { + return quereyTemplateServiceI.getLinkTree(); + } catch (PLException e) { + BaseResult objectBaseResult = new BaseResult<>(); + objectBaseResult.setCode(Integer.parseInt(e.code)); + objectBaseResult.setMsg(Arrays.toString(e.messages)); + return objectBaseResult; + } + } + /** + * 瀵煎嚭閾炬帴绫诲瀷鏌ヨ妯℃澘 + * names 鏌ヨ妯℃澘鍚� + * @return + */ + @PostMapping("/expLinkTemplate") + public void expLinkTemplate(@RequestBody List<String> names,HttpServletResponse response) throws PLException, IOException { + quereyTemplateServiceI.expLinkTemplate(names, response); + } + + /** + * 瀵煎叆閾炬帴绫诲瀷鏌ヨ妯℃澘 + * @param file 涓婁紶鐨勬枃浠� + * @return 瀵煎叆缁撴灉 + */ + @PostMapping("/impLinkTemplate") + public BaseResult impLinkTemplate(MultipartFile file){ + try { + return quereyTemplateServiceI.impLinkTemplate(file); + }catch (Throwable e) { + throw new VciBaseException(VciBaseUtil.getExceptionMessage(e),new String[0],e); + } + } + + /** + * 鏌ヨ鏂规鍒犻櫎 + * @param templateNames 鏌ヨ鏂规鍚� + * @return 鎿嶄綔缁撴灉 + */ + @DeleteMapping("/deleteLinkTemplate") + public BaseResult deleteLinkTemplate(@RequestBody List<String> templateNames){ + try { + return quereyTemplateServiceI.deleteLinkTemplate(templateNames); + } catch (PLException e) { + BaseResult objectBaseResult = new BaseResult<>(); + objectBaseResult.setCode(Integer.parseInt(e.code)); + objectBaseResult.setMsg(Arrays.toString(e.messages)); + return objectBaseResult; + } + } } diff --git a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/other/LinkQTExportData.java b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/other/LinkQTExportData.java new file mode 100644 index 0000000..d2fe2f7 --- /dev/null +++ b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/other/LinkQTExportData.java @@ -0,0 +1,96 @@ +package com.vci.web.other; + +import java.io.Serializable; +import java.util.HashMap; +import java.util.Map; + +import com.vci.corba.omd.ltm.LinkType; +import com.vci.corba.omd.qtm.QTD; +import com.vci.corba.omd.qtm.QTInfo; +import com.vci.corba.common.PLException; +import com.vci.web.util.PlatformClientUtil; +import org.springframework.beans.factory.annotation.Autowired; + +/** + * 鏌ヨ妯℃澘瀵煎嚭鏁版嵁绫伙細鍙簭鍒楀寲涓烘ā鏉挎枃浠�,鍚屾椂涔熷吋瀵煎嚭鏁版嵁鎺у埗绫� + * @Title :QTExportData.java + * @Description : + * @Copyright :瀹忓崥杩滆揪绉戞妧鏈夐檺鍏徃 + * @Author :骞冲彴涓庤鍒掗儴/ZhongGY/E-mail:zhonggy@vci-tech.com + * @Date :2015-6-8 + * @Version :1 + * @Other :浜х敓娉ㄩ噴:Alt+Shift+J + */ +public class LinkQTExportData implements Serializable{ + + private static final long serialVersionUID = 1L; + + + /** + * 闇�瑕佸簭鍒楀寲鐨勬ā鏉挎暟鎹� + */ + // + private Map<String/*绫诲瀷鍚嶇О*/, LinkType/*绫诲瀷瀵硅薄*/> selectedBtmItems = new HashMap<String, LinkType>(); + private Map<String/*绫诲瀷鍚嶇О*/,String[]/*绫诲瀷鎵�灞炲睘鎬�*/> selectedBtmAttrs = new HashMap<String, String[]>(); + private Map<String/*鏌ヨ妯℃澘鍚嶇О*/, QTInfo/*鏌ヨ妯℃澘瀵硅薄*/> allSelectedQTs = new HashMap<String, QTInfo>(); + private Map<String/*绫诲瀷鍚嶇О*/, QTD[]/*鏌ヨ妯℃澘瀹氫箟*/> allQTDs = new HashMap<String, QTD[]>(); + + + public Map<String, LinkType> getSelectedBtmItems() { + return selectedBtmItems; + } + + public void setSelectedBtmItems(Map<String, LinkType> selectedBtmItems) { + this.selectedBtmItems = selectedBtmItems; + } + + public Map<String, String[]> getSelectedBtmAttrs() { + return selectedBtmAttrs; + } + + public void setSelectedBtmAttrs(Map<String, String[]> selectedBtmAttrs) { + this.selectedBtmAttrs = selectedBtmAttrs; + } + + public Map<String, QTD[]> getAllQTDs() { + return allQTDs; + } + + public void setAllQTDs(Map<String, QTD[]> allQTDs) { + this.allQTDs = allQTDs; + } + + public Map<String, QTInfo> getAllQTs() { + return allSelectedQTs; + } + +// public void setAllQTs(Map<String, QTInfo> allQTs) { +// this.allSelectedQTs = allQTs; +//// try { +//// BizType[] btmArray = BtmClient.getService().getAllBtmItem(""); +//// for (int i = 0; i < btmArray.length; i++) { +//// allBtmItems.put(btmArray[i].name, btmArray[i]); +//// } +//// } catch (PLException e) { +//// } +// for (Map.Entry<String, QTInfo> item : allQTs.entrySet()) { +//// BizType bizType = allBtmItems.get(item.getValue().btmName); +// LinkType linkType; +// try { +// linkType = LinkTypeStart.getService().getLinkType(item.getValue().btmName); +// if(linkType != null && !linkType.oid.equals("")){ +// selectedBtmItems.put(linkType.name, linkType); +//// selectedBtmAttrs.put(linkType.name, BtmProvider.getInstance().getAbNames(linkType.name)); +// selectedBtmAttrs.put(linkType.name, linkType.attributes); +// allQTDs.put(linkType.name, .getQTDService().getLinkTypeQTDs(linkType.name)); +// } +// } catch (PLException e1) { +// // TODO Auto-generated catch block +// e1.printStackTrace(); +// } +// } +// //selectedBtmAttrs? +// //allQTDs? +// } + +} diff --git a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/OsQuereyTemplateServiceI.java b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/OsQuereyTemplateServiceI.java index 4cd367d..c4fbb99 100644 --- a/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/OsQuereyTemplateServiceI.java +++ b/Source/plt-web/plt-web-parent/plt-web/src/main/java/com/vci/web/service/OsQuereyTemplateServiceI.java @@ -53,7 +53,7 @@ BaseResult deleteTemplate(String name) throws PLException; /** * - * @param dataMap 浼犺緭鐨勬暟鎹璞★細 + * @param qtInfoDTO 浼犺緭鐨勬暟鎹璞★細 * linkTypeName 閾炬帴绫诲瀷銆� * rdPositive 鏂瑰悜锛宼rue姝e悜锛宖alse鍙嶅悜 * btmName 涓氬姟绫诲瀷鍚嶇О @@ -63,7 +63,7 @@ * level 瀛愯妭鐐瑰眰鏁� * @return 鏌ヨ缁撴灉 */ - BaseResult getCriteria(HashMap<String,Object> dataMap) throws PLException; + BaseResult getCriteria(QTInfoDTO qtInfoDTO) throws PLException; /** * 鏌ヨ妯℃澘鍒楄〃 * @param btName 绫诲瀷鍚嶇О @@ -83,4 +83,27 @@ * @return 淇濆瓨缁撴灉 */ BaseResult linkSave(QTInfoDTO qtInfoDTO) throws PLException; + /** + * 閾炬帴绫诲瀷鏌ヨ妯℃澘鏍戞煡璇紝鐢ㄤ簬鐣岄潰鐨勫鍑哄姛鑳� + * @return 鏌ヨ缁撴灉 + */ + BaseResult getLinkTree() throws PLException ; + /** + * 瀵煎嚭閾炬帴绫诲瀷鏌ヨ妯℃澘 + * names 鏌ヨ妯℃澘鍚� + * @return + */ + void expLinkTemplate(List<String> names, HttpServletResponse response) throws PLException, IOException ; + /** + * 瀵煎叆閾炬帴绫诲瀷鏌ヨ妯℃澘 + * @param file 涓婁紶鐨勬枃浠� + * @return 瀵煎叆缁撴灉 + */ + BaseResult impLinkTemplate(MultipartFile file) throws IOException, ClassNotFoundException; + /** + * 鏌ヨ鏂规鍒犻櫎 + * @param templateNames 鏌ヨ鏂规鍚� + * @return 鎿嶄綔缁撴灉 + */ + BaseResult deleteLinkTemplate(List<String> templateNames) throws PLException; } 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