Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,381 @@
package com.vci.ubcs.code.service.impl;

import com.vci.ubcs.code.service.MdmIOService;
import org.springframework.stereotype.Service;

@Service
public class MdmIOServiceImpl implements MdmIOService {

//
//   /**
//    * ä¸»é¢˜åº“分类的服务
//    */
//   @Resource
//   private ICodeClassifyService classifyService;
//
//   /**
//    * æ¨¡æ¿çš„服务
//    */
//   @Resource
//   private CodeClstemplateServiceImpl templateService;
//
//   /**
//    * ä¸»æ•°æ®å¼•æ“Žçš„服务
//    */
//   @Resource
//   private MdmEngineService engineService;
//
//   /**
//    * ç”Ÿæˆå¯¼å…¥çš„文件
//    *
//    * @param codeClassifyOid åˆ†ç±»çš„主键
//    * @param isHistory æ˜¯å¦åŽ†å²æ•°æ®å¯¼å…¥
//    * @return excel的文件地址
//    */
//   @Override
//   public String createImportExcel(String codeClassifyOid, boolean isHistory) {
//      List<CodeClstemplateVO> templateVOList=new ArrayList<>();
//
//      VciBaseUtil.alertNotNull("导出模板","导出的配置",codeClassifyOid,"主题库分类的主键");
//
//      CodeClassifyVO codeClassifyVO = classifyService.getObjectByOid(codeClassifyOid);
//
//      if(isHistory){
//         templateVOList= templateService.childTemplates(codeClassifyOid);
//      }else{
//         //找模板
//         CodeClstemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyOid);
//         templateVOList.add(templateVO);
//      }
//
//      WriteExcelOption eo = new WriteExcelOption();
//      eo.setAppend(true);
//      //增加模板的信息导入
//      LinkedList<WriteExcelData> tempEDList = new LinkedList<>();
//      tempEDList.add(new WriteExcelData(0,0,"模板主键"));
//      tempEDList.add(new WriteExcelData(0,1,"模板代号"));
//      tempEDList.add(new WriteExcelData(0,2,"模板名称"));
//      for(int j=0;j<templateVOList.size();j++){
//         CodeClstemplateVO  templateVO=templateVOList.get(j);
//         CodeClassifyTemplateVO codeClassifyTemplateVO = new CodeClassifyTemplateVO();
//         BeanUtils.copyProperties(templateVO,codeClassifyTemplateVO);
//         //组合格式的不导入，
//         // æžšä¸¾çš„提供序列的选择
//         //时间全部统一为yyyy-MM-dd HH:mm:ss
//         //参照的自行输入名称
//         //分类注入的不用，都是导入后自动处理的
//         //编码，状态等字段不导入
//         List<CodeClassifyTemplateAttrVO> templateAttrVOS = codeClassifyTemplateVO.getAttributes().stream().filter(s ->
//            !DEFAULT_ATTR_LIST.contains(s.getId())
//               && StringUtils.isBlank(s.getComponentRule())
//               && StringUtils.isBlank(s.getClassifyInvokeAttr())
//               && (isHistory || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))
//         ).collect(Collectors.toList());
//
//         if(CollectionUtils.isEmpty(templateAttrVOS)){
//            throw new VciBaseException("模板没有配置任何【表单显示】为【是】的属性");
//         }
//         List<CodeClassifyTemplateAttrVO> idAttrVOList = codeClassifyTemplateVO.getAttributes().stream().filter(s -> s.getId().equalsIgnoreCase(CODE_FIELD)).collect(Collectors.toList());
//         LinkedList<WriteExcelData> excelDataList = new LinkedList<>();
//         Workbook workbook = new HSSFWorkbook();
//         if(isHistory){
//            excelDataList.add(new WriteExcelData(0,0,"分类路径"));
//            excelDataList.add(new WriteExcelData(0,1,"码段宽度"));
//            excelDataList.add(new WriteExcelData(0,2,!CollectionUtils.isEmpty(idAttrVOList)?idAttrVOList.get(0).getName():"企业编码"));
//         }
//         for (int i = 0; i < templateAttrVOS.size(); i++) {
//            CodeClassifyTemplateAttrVO attrVO = templateAttrVOS.get(i);
//
//            Object text = attrVO.getName();
//            text = exportKeyAndRequired(workbook,attrVO,text);
//            int colIndex = (isHistory?3:0) + i;
//            WriteExcelData excelData = new WriteExcelData(0, colIndex, text);
//            if(StringUtils.isNotBlank(attrVO.getCodeDateFormat())
//               || VciFieldTypeEnum.VTDateTime.name().equalsIgnoreCase(attrVO.getAttributeDataType())
//               || VciFieldTypeEnum.VTDate.name().equalsIgnoreCase(attrVO.getAttributeDataType())
//               ||VciFieldTypeEnum.VTTime.name().equalsIgnoreCase(attrVO.getAttributeDataType())){
//               excelData.setDateFormat(VciDateUtil.DateTimeFormat);
//            }
//            if(text instanceof RichTextString){
//               excelData.setFontColor(String.valueOf(HSSFColor.HSSFColorPredefined.RED.getIndex()));
//            }
//            excelDataList.add(excelData);
//            if(StringUtils.isNotBlank(attrVO.getEnumString()) || StringUtils.isNotBlank(attrVO.getEnumId())){
//               //添加数据有效性
//               List<String> enumValueList = new ArrayList<>();
//               enumValueList.add("");
//               List<KeyValue> valueList = engineService.listComboboxItems(attrVO);
//               if(!CollectionUtils.isEmpty(valueList)){
//                  valueList.stream().forEach(kv->{
//                     enumValueList.add(kv.getValue());
//                  });
//               }
//               //默认加1万条
//               WriteExcelData ed = new WriteExcelData(1,colIndex,"");
//               ed.setRowTo(100);
//               ed.setColTo(colIndex);
//               ed.setValidation(true);
//               ed.setValidationDataList(enumValueList);
//               ed.setValidationErrorMsg("请在序列中选择正确的值");
//               excelDataList.add(ed);
//            }
//            if(VciFieldTypeEnum.VTBoolean.name().equalsIgnoreCase(attrVO.getAttributeDataType())){
//               List<String> booleanList = new ArrayList<>();
//
//               booleanList.add("是");
//               booleanList.add("否");
//               //默认加1万条
//               WriteExcelData ed = new WriteExcelData(1,colIndex,"");
//               ed.setRowTo(100);
//               ed.setColTo(colIndex);
//               ed.setValidation(true);
//               ed.setValidationDataList(booleanList);
//               ed.setValidationErrorMsg("请在序列中选择正确的值");
//               excelDataList.add(ed);
//            }
//         }
//         eo.addSheetDataList(j+templateVO.getName(),excelDataList);
//         tempEDList.add(new WriteExcelData(j+1,0,templateVO.getOid()));
//         tempEDList.add(new WriteExcelData(j+1,1,templateVO.getId()));
//         tempEDList.add(new WriteExcelData(j+1,2,templateVO.getName()));
//      }
//      String excelName = LocalFileUtil.getDefaultTempFolder() + File.separator + codeClassifyVO.getName() + (isHistory?"_历史数据导入模板.xls": "_导入模板.xls");
//      eo.addSheetDataList(templateVOList.size()+"模板信息【请勿删除或移动】",tempEDList);
//      ExcelUtil.writeDataToFile(excelName,eo);
//      return excelName;
//   }
//
//   /**
//    * å¯¼å‡ºçš„时候封装必输和关键属性
//    * @param attrVO å±žæ€§çš„显示对象
//    * @param text å•å…ƒæ ¼çš„值
//    */
//   private Object exportKeyAndRequired(Workbook workbook,CodeClassifyTemplateAttrVO attrVO,Object text){
//      //必输加*，关键属性为蓝色
//      if (VciBaseUtil.getBoolean(attrVO.getRequireFlag()) || VciBaseUtil.getBoolean(attrVO.getKeyAttrFlag())) {
//         String value = text.toString();
//         if(VciBaseUtil.getBoolean(attrVO.getRequireFlag())) {
//            value += REQUIRED_CHAR;
//         }
//         if(VciBaseUtil.getBoolean(attrVO.getKeyAttrFlag())){
//            value += KEY_ATTR_CHAR;
//         }
//         RichTextString ts = new HSSFRichTextString(value);
//         if(VciBaseUtil.getBoolean(attrVO.getRequireFlag())){
//            Font font =  workbook.createFont();
//            font.setColor(HSSFColor.HSSFColorPredefined.RED.getIndex());
//            ts.applyFont(font);
//         }
//
//         if(VciBaseUtil.getBoolean(attrVO.getKeyAttrFlag())){
//            Font font =  workbook.createFont();
//            font.setColor(HSSFColor.HSSFColorPredefined.BLUE.getIndex());
//            ts.applyFont(font);
//         }
//         return ts;
//      }
//      return text;
//   }
//
//
//   /**
//    * æ‰¹é‡ç”³è¯·ç¼–码数据
//    *
//    * @param orderDTO ç¼–码申请信息，必须包含分类主键和码段的信息
//    * @param file     excel文件的信息
//    * @return  æœ‰é”™è¯¯ä¿¡æ¯çš„excel的文件
//    */
//   @Override
//   public CodeImProtRusultVO batchImportCode(CodeOrderDTO orderDTO, File file) {
//      VciBaseUtil.alertNotNull(orderDTO,"编码申请相关的数据",orderDTO.getCodeClassifyOid(),"主题库分类主键");
//      ReadExcelOption reo = new ReadExcelOption();
//      reo.setReadAllSheet(true);
//      List<SheetDataSet> sheetDataSetList = ExcelUtil.readDataObjectFromExcel(file,null,reo);
//      if(CollectionUtils.isEmpty(sheetDataSetList) || CollectionUtils.isEmpty(sheetDataSetList.get(0).getRowData())
//         ||sheetDataSetList.get(0).getRowData().size()<1){
//         throw new VciBaseException("没有读取到任何的数据");
//      }
//      if(sheetDataSetList.size()>LIMIT+1){
//         throw new VciBaseException("为了保证系统的稳定性，请一次不要导入超过1万条的数据");
//      }
//      //先找到每一行的标题，然后根据标题来获取对应的属性
//      SheetDataSet dataSet = sheetDataSetList.get(0);
//      //找第一行，为了找标题
//      CodeClstemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(orderDTO.getCodeClassifyOid());
//
//      //校验模板是不是最新的
//      checkTemplateSync(sheetDataSetList,templateVO,0);
//      //先不用管属性是否都存在，先转换一下数据
//      Map<String,String> errorMap = new HashMap<>();
//      String redisUUid=batchImportCodes(orderDTO,templateVO,dataSet,errorMap,true);
//      CodeImProtRusultVO codeImProtRusultVO = new CodeImProtRusultVO();
//      List<String> needRowIndexList = new ArrayList<>();
////      String filePath = returnErrorToExcel(dataSet.getRowData(), errorMap, needRowIndexList, dataSet.getColName());
////      if(StringUtils.isNotBlank(filePath)) {
////         codeImProtRusultVO.setFilePath(filePath);
////      }
////      if(StringUtils.isNotBlank(redisUUid)){
////         codeImProtRusultVO.setRedisUuid(redisUUid);
////      }
//      return null;
////      return codeImProtRusultVO;
//   }
//
//   /**
//    * æ ¡éªŒæ¨¡æ¿æ˜¯å¦ä¸ºåŒæ­¥çš„
//    * @param sheetDataSetList excel里的内容
//    * @param templateVO æ¨¡æ¿çš„信息
//    */
//   private void checkTemplateSync(List<SheetDataSet> sheetDataSetList,CodeClstemplateVO templateVO,int i){
//      String templateOidInExcel = "";
//      String templateName="";
//      if(!CollectionUtils.isEmpty(sheetDataSetList)
//         && sheetDataSetList.size()>1 && !CollectionUtils.isEmpty(sheetDataSetList.get(sheetDataSetList.size()-1).getColName())){
//         List<SheetRowData>  rowData=  sheetDataSetList.get(sheetDataSetList.size()-1).getRowData();
//         templateName=rowData.get(i).getData().get(2);
//         templateOidInExcel=rowData.get(i).getData().get(0);
//         //templateOidInExcel = sheetDataSetList.get(sheetDataSetList.size()-1).getColName().get(sheetDataSetList.size()-i);
//      }
//       /* if(!CollectionUtils.isEmpty(sheetDataSetList)
//                && sheetDataSetList.size()>1 && !CollectionUtils.isEmpty(sheetDataSetList.get(sheetDataSetList.size()-1).getColName())){
//            List<SheetRowData>  rowData=  sheetDataSetList.get(sheetDataSetList.size()-1).getRowData();
//            templateOidInExcel=rowData.get(i).getData().get(0);
//           //templateOidInExcel = sheetDataSetList.get(sheetDataSetList.size()-1).getColName().get(sheetDataSetList.size()-i);
//        }*/
//      if(StringUtils.isBlank(templateOidInExcel) || !templateOidInExcel.equalsIgnoreCase(templateVO.getOid())){
//         throw new VciBaseException("模板【"+templateName+"】中的数据获取的模版信息与当前模板不匹配，请确保excel文件里有【模板信息-请勿移动或删除】的工作表，且确保每次导入都是先下载的导入模板后添加的数据");
//      }
//
//   }
//
//
//   /***
//    * æ‰¹é‡å¤„理申请数据
//    * @param orderDTO
//    * @param templateVO
//    * @param dataSet
//    * @return
//    */
//   private String batchImportCodes(CodeOrderDTO orderDTO,CodeClstemplateVO templateVO,SheetDataSet dataSet,Map<String,String> errorMap,boolean isEnumType){
//      List<String> codeList=new ArrayList<>();
////      CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(orderDTO.getCodeClassifyOid());
//      //规则的主键需要去获取
////      CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo);
////      //1.判断规则中除了流水码段，是否有其他码段
////      engineService.checkSecValueOnOrder(ruleVO,orderDTO);
////      List<SheetRowData> rowDataList = dataSet.getRowData();
////
////      //除去默认的属性.还有只有表单显示的字段才导入
////      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->
////         !DEFAULT_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormdisplayflag())
////      ).collect(Collectors.toList());
////      Map<Integer/**列号**/,String/**字段的名称**/> fieldIndexMap = new HashMap<>();
////      List<String> titleRowData = dataSet.getColName();
////      Map<String/**中文名称**/, String/**英文名称**/> attrNameIdMap = attrVOS.stream().collect(Collectors.toMap(s -> s.getName(), t -> t.getId().toLowerCase(Locale.ROOT),(o1, o2)->o2));
////      getFieldIndexMap(titleRowData,attrNameIdMap,fieldIndexMap);
////
////      //需要判断是否所有的属性都在模板上了
////      List<CodeClassifyTemplateAttrVO> unExistAttrVOs = attrVOS.stream().filter(s -> !fieldIndexMap.containsValue(s.getId().toLowerCase(Locale.ROOT))
////         && StringUtils.isBlank(s.getComponentrule()) && StringUtils.isBlank(s.getClassifyinvokeattr())//组合规则和分类注入确实没给用户导出去
////      ).collect(Collectors.toList());
////      if(!CollectionUtils.isEmpty(unExistAttrVOs)){
////         throw new VciBaseException("【" + unExistAttrVOs.stream().map(CodeClassifyTemplateAttrVO::getName) + "】这些属性在列表中没有找到");
////      }
////      List<ClientBusinessObject> cboList = new ArrayList<>();
////      String fullPath = getFullPath(classifyFullInfo);
////      excelToCbo(classifyFullInfo,fieldIndexMap,rowDataList,templateVO,cboList,fullPath,true);
////
////      //都转换完了。需要批量检查
////      //如果出错了，我们依然执行有效的数据，无效的数据写回到excel中
////      //2.判断必输项。。需要全部的属性，如果是必输，但是表单里面不显示的，只能是分类注入或者组合规则
////      batchCheckRequiredAttrOnOrder(templateVO,cboList,errorMap);
////      //3.判断关键属性
////      CodeImportResultVO keyResultVO = batchCheckKeyAttrOnOrder(classifyFullInfo, templateVO, cboList);
////      Set<String> selfRepeatRowIndexList = keyResultVO.getSelfRepeatRowIndexList();
////      Set<String> keyAttrRepeatRowIndexList = keyResultVO.getKeyAttrRepeatRowIndexList();
////      if(!CollectionUtils.isEmpty(selfRepeatRowIndexList)){
////         selfRepeatRowIndexList.stream().forEach(rowIndex->{
////            errorMap.put(rowIndex,errorMap.getOrDefault(rowIndex,"") + ";在当前处理的数据文件中关键属性重复" );
////         });
////      }
////      if(!CollectionUtils.isEmpty(keyAttrRepeatRowIndexList)){
////         keyAttrRepeatRowIndexList.stream().forEach(rowIndex->{
////            errorMap.put(rowIndex,errorMap.getOrDefault(rowIndex,"") + ";关键属性与系统中的重复" );
////         });
////      }
////      //分类注入
////      batchSwitchClassifyAttrOnOrder(attrVOS,cboList,classifyFullInfo,false);
////      //boolean
////      reSwitchBooleanAttrOnOrder(attrVOS,cboList);
////      //4.校验规则
////      batchCheckVerifyOnOrder(attrVOS, cboList,errorMap);
////      if(isEnumType) {//是否需要校验枚举/参照
////         //5.校验枚举是否正确
////         batchSwitchEnumAttrOnOrder(attrVOS, cboList, errorMap);
////         //7.处理参照的情况
////         batchSwitchReferAttrOnOrder(attrVOS,cboList,errorMap);
////      }
////      //6.时间格式的验证
////      //6.时间的，必须统一为yyyy-MM-dd HH:mm:ss
////      batchSwitchDateAttrOnOrder(attrVOS,cboList,errorMap);
////      //最后弄组合规则
////      batchSwitchComponentAttrOnOrder(attrVOS,cboList);
////      String uuid=redisService.getUUIDEveryDay();
////      Map<String, ClientBusinessObject> rowIndexCboMap = cboList.stream().filter(cbo -> cbo != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getAttributeValue((IMPORT_ROW_INDEX)), t -> t));
////
////      if(errorMap.size()>0) {
////         createRedisDatas(uuid + "-error",templateVO, rowIndexCboMap, dataSet, fieldIndexMap, errorMap,false);
////      }
////      boolean isCreateUUid=false;
////      List<ClientBusinessObject> needSaveCboList = cboList.stream().filter(cbo -> {
////         String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);
////         return !errorMap.containsKey(rowIndex);
////      }).collect(Collectors.toList());
////      //相似校验
////      Map<String,String>resembleMap=new HashMap<>();
////      List<DataResembleVO> dataResembleVOS=new ArrayList<>();
////      String btmtypeid= classifyFullInfo.getTopClassifyVO().getBtmtypeid();
////      bathcResembleQuery(orderDTO.getCodeClassifyOid(),templateVO,needSaveCboList,resembleMap,btmtypeid,dataResembleVOS);
////      if(resembleMap.size()>0) {
////         isCreateUUid=true;
////         if(!CollectionUtils.isEmpty(dataResembleVOS)) {
////            redisService.setCacheList(uuid + "-resemble-data", dataResembleVOS);
////            createRedisDatas(uuid + "-resemble",templateVO, rowIndexCboMap, dataSet, fieldIndexMap, resembleMap, false);
////         }
////      }
////      //排除错误的，剩下正确的
////      Map<String,String> newErrorMap=new HashMap<>();
////      newErrorMap.putAll(resembleMap);
////      newErrorMap.putAll(errorMap);
////      needSaveCboList = cboList.stream().filter(cbo -> {
////         String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);
////         return !newErrorMap.containsKey(rowIndex);
////      }).collect(Collectors.toList());
////      if((errorMap.size()>0&&needSaveCboList.size()>0)||resembleMap.size()>0){
////         isCreateUUid=true;
////      }
////      createRedisByCodeClassify(uuid + "-class",templateVO,dataSet,fieldIndexMap,false);
////      if(newErrorMap.size()>0) {
////         createRedisDatas(uuid + "-ok",templateVO, rowIndexCboMap, dataSet, fieldIndexMap, newErrorMap,true);
////      }else {
////         uuid="";
////         //要把以上的错误的都抛出后，再继续处理时间和组合规则
////         needSaveCboList = cboList.stream().filter(cbo -> {
////            String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);
////            return !newErrorMap.containsKey(rowIndex);
////         }).collect(Collectors.toList());
////         if (!CollectionUtils.isEmpty(needSaveCboList)) {
////            //9.我们处理业务数据
////            //生成编码的内容
////            codeList = productCodeService.productCodeAndSaveData(classifyFullInfo, templateVO, ruleVO, orderDTO.getSecDTOList(), needSaveCboList);
////            //如果是编码生成失败，则直接就失败了，其他的判断出来有错误的我们都统一返回到excel里面
////            engineService.batchSaveSelectChar(templateVO, needSaveCboList);
////         }
////      }
////      if(!isCreateUUid){
////         return uuid="";
////      }
////      return uuid;
//      return null;
//   }
}