| | |
| | | package com.vci.web.service.impl; |
| | | |
| | | import cn.hutool.core.io.FileUtil; |
| | | import cn.hutool.core.util.ZipUtil; |
| | | import com.fasterxml.jackson.core.type.TypeReference; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | | import com.vci.constant.FrameWorkLangCodeConstant; |
| | | import com.vci.corba.common.PLException; |
| | | import com.vci.corba.omd.atm.AttributeDef; |
| | | import com.vci.corba.omd.btm.BizType; |
| | | import com.vci.corba.omd.data.BusinessObject; |
| | | import com.vci.corba.omd.ltm.LinkType; |
| | | import com.vci.corba.omd.ltm.LinkTypeServicePrx; |
| | | import com.vci.dto.OsAttributeDTO; |
| | | import com.vci.omd.constants.LinkTypeConstants; |
| | | import com.vci.omd.utils.ObjectTool; |
| | | import com.vci.pagemodel.*; |
| | | import com.vci.po.OsAttributePO; |
| | | 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.annotation.log.VciUnLog; |
| | | import com.vci.starter.web.enumpck.ResultCodeEnum; |
| | | import com.vci.starter.web.enumpck.VciFieldTypeEnum; |
| | | import com.vci.starter.web.exception.VciBaseException; |
| | | import com.vci.starter.web.pagemodel.BaseQueryObject; |
| | | import com.vci.starter.web.pagemodel.BaseResult; |
| | | import com.vci.starter.web.pagemodel.DataGrid; |
| | | import com.vci.starter.web.util.BeanUtil; |
| | | import com.vci.starter.web.util.VciBaseUtil; |
| | | import com.vci.starter.web.util.VciDateUtil; |
| | | import com.vci.starter.web.util.*; |
| | | import com.vci.model.OsLinkTypeDO; |
| | | import com.vci.web.service.*; |
| | | import com.vci.web.util.Func; |
| | | import com.vci.web.util.PlatformClientUtil; |
| | | import com.vci.web.util.WebUtil; |
| | | import javafx.scene.shape.HLineTo; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | |
| | | import org.springframework.context.annotation.Lazy; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import java.io.IOException; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.*; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | */ |
| | | @Service |
| | | public class OsLinkTypeServiceImpl implements OsLinkTypeServiceI { |
| | | |
| | | private static final String OID = "oid"; |
| | | private static final String NAME = "name"; |
| | | private static final String LABEL = "label"; |
| | | private static final String DESCRIPTION = "description"; |
| | | private static final String TS = "ts"; |
| | | private static final String CREATOR = "creator"; |
| | | private static final String CREATETIME = "createTime"; |
| | | private static final String MODIFIER = "modifier"; |
| | | private static final String MODIFYTIME = "modifyTime"; |
| | | |
| | | /** |
| | | * 日志 |
| | |
| | | returnData.put("btmCheckMap",btmCheckMap); |
| | | List<Map> list = new ArrayList<>(); |
| | | list.add(returnData); |
| | | return BaseResult.dataList(500,list,"需要进行列的修复!!"); |
| | | BaseResult<List<Map>> listBaseResult = BaseResult.dataList(200, list, "需要进行列的修复!!"); |
| | | listBaseResult.setSuccess(false); |
| | | return listBaseResult; |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 导出链接类型 |
| | | * name 链接类型名称 |
| | | * @return 创建结果 |
| | | */ |
| | | @Override |
| | | public void expData(String names, HttpServletResponse response) throws PLException, IOException { |
| | | String defaultTempFolder = LocalFileUtil.getDefaultTempFolder(); |
| | | //写excel |
| | | String excelPath = defaultTempFolder + File.separator + "lt.xls"; |
| | | //设置列名 |
| | | List<String> columns = new ArrayList<>( |
| | | Arrays.asList("名称", "标签", "实现类", "形状", "From端类型列表", "From端主类型", "From端对应关系", |
| | | "To端类型列表", "To端主类型", "To端对应关系", "属性列表", "描述") |
| | | ); |
| | | try { |
| | | new File(excelPath).createNewFile(); |
| | | //设置列 |
| | | List<WriteExcelData> excelDataList = new ArrayList<>(); |
| | | //设置列头 |
| | | for (int index = 0; index < columns.size(); index++) { |
| | | excelDataList.add(new WriteExcelData(0,index, columns.get(index))); |
| | | } |
| | | HashSet<String> attributes = new HashSet<>(); |
| | | int i = 0; |
| | | for (String name : names.split(",")) { |
| | | LinkType lt = platformClientUtil.getLinkTypeService().getLinkType(name); |
| | | excelDataList.add(new WriteExcelData(i+1,0, lt.name)); |
| | | excelDataList.add(new WriteExcelData(i+1,1, lt.tag)); |
| | | excelDataList.add(new WriteExcelData(i+1,2, lt.implClass)); |
| | | excelDataList.add(new WriteExcelData(i+1,3, lt.shape)); |
| | | excelDataList.add(new WriteExcelData(i+1,4, String.join(",",lt.btmItemsFrom))); |
| | | excelDataList.add(new WriteExcelData(i+1,5, lt.primitivesFrom)); |
| | | excelDataList.add(new WriteExcelData(i+1,6, lt.relationFrom)); |
| | | excelDataList.add(new WriteExcelData(i+1,7, String.join(",",lt.btmItemsTo))); |
| | | excelDataList.add(new WriteExcelData(i+1,8, lt.primitivesTo)); |
| | | excelDataList.add(new WriteExcelData(i+1,9, lt.relationTo)); |
| | | excelDataList.add(new WriteExcelData(i+1,10, String.join(",",lt.attributes))); |
| | | excelDataList.add(new WriteExcelData(i+1,11, lt.description)); |
| | | attributes.addAll(Arrays.asList(lt.attributes)); |
| | | i++; |
| | | } |
| | | WriteExcelOption excelOption = new WriteExcelOption(excelDataList); |
| | | ExcelUtil.writeDataToFile(excelPath, excelOption); |
| | | //导出属性 |
| | | String attrPath = attributeService.exportAttributes("attr", |
| | | String.valueOf(attributes.stream().collect(Collectors.joining(","))),true); |
| | | //移动属性到链接类型文件夹里面去 |
| | | FileUtil.move(new File(attrPath), new File(defaultTempFolder),true); |
| | | FileUtil.del(attrPath.substring(0,attrPath.lastIndexOf("\\"))); |
| | | //todo 导出业务类型还没有实现 |
| | | // List<BizType> bts = new ArrayList<BizType>(); |
| | | // for (String btName : btNameSet) { |
| | | // BizType bt = BtmProvider.getBtmItemByName(btName); |
| | | // bts.add(bt); |
| | | // } |
| | | // boolean btFlag = BtmProvider.expData(rootPath, bts.toArray(new BizType[0])); |
| | | }catch (IOException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | File zip = ZipUtil.zip(defaultTempFolder); |
| | | FileUtil.del(defaultTempFolder + File.separator); |
| | | ControllerUtil.writeFileToResponse(response,zip.getAbsoluteFile()); |
| | | } |
| | | |
| | | /** |
| | | * 导入链接类型 |
| | | * @param file 上传的文件 |
| | | * @return |
| | | */ |
| | | @Override |
| | | public BaseResult impData(MultipartFile file) throws Exception { |
| | | String defaultTempFolder = LocalFileUtil.getDefaultTempFolder(); |
| | | String fileName = defaultTempFolder + File.separator + LocalFileUtil.getFileNameForIE(file.getOriginalFilename()); |
| | | file.transferTo(new File(fileName)); |
| | | if (file == null) { |
| | | return BaseResult.fail(FrameWorkLangCodeConstant.IMPORT_FAIL, new String[]{"无导入的文件"}); |
| | | } |
| | | if (!fileName.endsWith(".zip")) { |
| | | throw new VciBaseException("仅能上传zip压缩文件,请重新上传!"); |
| | | } |
| | | File unzip = ZipUtil.unzip(fileName); |
| | | File ltExcel = new File(unzip.getAbsolutePath() + File.separator + "lt.xls"); |
| | | File attrExcel = new File(unzip.getAbsolutePath() + File.separator + "attr.xls"); |
| | | if (!attrExcel.exists()) { |
| | | //增加解压的路径,看文件还在没有 |
| | | attrExcel = new File(unzip.getAbsolutePath() + File.separator + unzip.getName() + File.separator + "attr.xls"); |
| | | if (!attrExcel.exists()) { |
| | | return BaseResult.fail(FrameWorkLangCodeConstant.IMPORT_FAIL, new String[]{"没有导入的属性文件。导入终止!"}); |
| | | } |
| | | } |
| | | BaseResult baseResult = attributeService.importAttributes(attrExcel); |
| | | if(!baseResult.isSuccess()){ |
| | | //删除上传的文件夹 |
| | | FileUtil.del(defaultTempFolder + File.separator); |
| | | return baseResult; |
| | | } |
| | | //todo 还需导入业务类型,等待功能实现 |
| | | if (!ltExcel.exists()) { |
| | | //增加解压的路径,看文件还在没有 |
| | | ltExcel = new File(unzip.getAbsolutePath() + File.separator + unzip.getName() + File.separator + "lt.xls"); |
| | | if (!ltExcel.exists()) { |
| | | //删除上传的文件夹 |
| | | FileUtil.del(defaultTempFolder + File.separator); |
| | | return BaseResult.fail(FrameWorkLangCodeConstant.IMPORT_FAIL, new String[]{"没有导入的链接文件。导入终止!"}); |
| | | } |
| | | } |
| | | try{ |
| | | //1、读取excel中的数据,组成对象 |
| | | ReadExcelOption excelOption = new ReadExcelOption(); |
| | | List<OsLinkTypePO> poList = ExcelUtil.readDataObjectFromExcel(ltExcel, OsLinkTypePO.class,excelOption,(value, po, fieldName)->{}); |
| | | //去除都是空的情况 |
| | | if(CollectionUtils.isEmpty(poList)){ |
| | | return BaseResult.fail(ExcelLangCodeConstant.IMPORT_CONTENT_NULL,new String[]{}); |
| | | } |
| | | //当前excel中是否重复用的判重Map:(key:判重属性,value:行号) |
| | | Map<String, String> excelReapeat = new HashMap<>(); |
| | | int maxLength = platformClientUtil.getLinkTypeService().getLTNameMaxLength(); |
| | | |
| | | //判断必填属性是否为空,用户是否已存在,以及部门是否填错等校验逻辑 |
| | | poList.stream().forEach(osLinkTypePO -> { |
| | | if(Func.isBlank(osLinkTypePO.getName())){//属性名判空 |
| | | throw new VciBaseException("第【"+osLinkTypePO.getRowIndex()+"】行,name"); |
| | | }else if(osLinkTypePO.getName().length() > maxLength){ |
| | | throw new VciBaseException("第【"+osLinkTypePO.getRowIndex()+"】行,链接类型名长度不能超过" + maxLength); |
| | | }else if(!osLinkTypePO.getName().matches("^[A-Za-z]+$")){ |
| | | throw new VciBaseException("第【"+osLinkTypePO.getRowIndex()+"】行,链接类型名称只能为英文字母"); |
| | | }else if(excelReapeat.containsKey(osLinkTypePO.getName())){//属性名表格中判重 |
| | | throw new VciBaseException("第【"+excelReapeat.get(osLinkTypePO.getName())+"】行和第【"+osLinkTypePO.getRowIndex()+"】行数据,属性名重复"); |
| | | } |
| | | try { |
| | | LinkType historyLink = platformClientUtil.getLinkTypeService().getLinkType(osLinkTypePO.getName()); |
| | | //已有此数据进行删除覆盖 |
| | | if(historyLink != null && !historyLink.name.equals("")){ |
| | | platformClientUtil.getLinkTypeService().deleteLinkType(historyLink); |
| | | } |
| | | } catch (PLException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | |
| | | //属性名excel中判重处理 |
| | | excelReapeat.put(osLinkTypePO.getName(),osLinkTypePO.getRowIndex()); |
| | | LinkType linkType = new LinkType(); |
| | | linkType.name = osLinkTypePO.getName(); |
| | | linkType.attributes = osLinkTypePO.getAttributes().split(","); |
| | | linkType.btmItemsFrom = osLinkTypePO.getBtmItemsFrom().split(","); |
| | | linkType.primitivesFrom = osLinkTypePO.getPrimitivesFrom(); |
| | | linkType.relationFrom = osLinkTypePO.getRelationFrom(); |
| | | linkType.btmItemsTo = osLinkTypePO.getBtmItemsTo().split(","); |
| | | linkType.primitivesTo = osLinkTypePO.getPrimitivesTo(); |
| | | linkType.relationTo = osLinkTypePO.getRelationTo(); |
| | | linkType.relation = osLinkTypePO.getRelationFrom() + ":" + osLinkTypePO.getRelationTo(); |
| | | linkType.description = osLinkTypePO.getDescription(); |
| | | linkType.tag = osLinkTypePO.getTag(); |
| | | linkType.shape = osLinkTypePO.getShape(); |
| | | linkType.implClass = osLinkTypePO.getImplClass(); |
| | | linkType.modifier = WebUtil.getCurrentUserId(); |
| | | linkType.creator = WebUtil.getCurrentUserId(); |
| | | try { |
| | | platformClientUtil.getLinkTypeService().addLinkType(linkType); |
| | | } catch (PLException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | |
| | | }); |
| | | }catch (Exception e){ |
| | | if(logger.isErrorEnabled()){ |
| | | logger.error("读取excel内容时或保存用户信息时出现了错误,具体原因:",VciBaseUtil.getExceptionMessage(e)); |
| | | } |
| | | e.printStackTrace(); |
| | | return BaseResult.fail(VciBaseUtil.getExceptionMessage(e),new String[]{},e); |
| | | } |
| | | //删除上传的文件夹 |
| | | FileUtil.del(defaultTempFolder + File.separator); |
| | | return BaseResult.success("链接类型导入成功!"); |
| | | } |
| | | |
| | | /** |
| | | * 修复链接类型的xml文件 |