统一业务系统系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
ludc
2023-07-11 9d8be8e7580ef577def96c852288a5a95eab4ea3 
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java


@@ -38,10 +38,7 @@


import com.vci.ubcs.starter.web.enumpck.BooleanEnum;


import com.vci.ubcs.starter.web.enumpck.UserSecretEnum;


import com.vci.ubcs.starter.web.enumpck.VciFieldTypeEnum;


import com.vci.ubcs.starter.web.pagemodel.DataGrid;


import com.vci.ubcs.starter.web.pagemodel.KeyValue;


import com.vci.ubcs.starter.web.pagemodel.PageHelper;


import com.vci.ubcs.starter.web.pagemodel.UIFormReferVO;


import com.vci.ubcs.starter.web.pagemodel.*;


import com.vci.ubcs.starter.web.toolmodel.DateConverter;


import com.vci.ubcs.starter.web.util.*;


import lombok.AllArgsConstructor;


@@ -54,6 +51,7 @@


import org.apache.poi.ss.usermodel.Font;


import org.apache.poi.ss.usermodel.RichTextString;


import org.apache.poi.ss.usermodel.Workbook;


import org.springblade.core.cache.utils.CacheUtil;


import org.springblade.core.redis.cache.BladeRedis;


import org.springblade.core.tool.api.R;


import org.springframework.beans.BeanUtils;


@@ -363,16 +361,23 @@


         //参照的自行输入名称


         //分类注入的不用，都是导入后自动处理的


         //编码，状态等字段不导入


         List<CodeClassifyTemplateAttrVO> templateAttrVOS = codeClassifyTemplateVO.getAttributes().stream().filter(s ->


         List<CodeClassifyTemplateAttrVO> codeClassifyTemplateAttrVOList=codeClassifyTemplateVO.getAttributes();


         if(!CollectionUtils.isEmpty(codeClassifyTemplateAttrVOList)) {


            if (CollectionUtils.isEmpty(codeClassifyTemplateAttrVOList)) {


               throw new VciBaseException("模板没有配置属性");


            }


         }


         List<CodeClassifyTemplateAttrVO> templateAttrVOS = codeClassifyTemplateAttrVOList.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("模板没有配置任何【表单显示】为【是】的属性");


         }


            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();


@@ -1016,7 +1021,7 @@


               thisCbos.stream().forEach(clientBusinessObject -> {


                  BaseModel baseModel=new BaseModel();


                  BeanUtil.convert(clientBusinessObject,baseModel);


                  baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


                  //baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


                  dataCBOList.add(baseModel);


                  dataCBOIdList.add(baseModel);


               });


@@ -1030,9 +1035,14 @@


                        String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


                        errorMap.put(rowIndex, errorMap.getOrDefault(rowIndex, "") + ";系统错误，存储数据的时候出错了");


                     });




                  }


               }


            });


            if (errorMap.size() > 0) {


               isExport = true;


            }


            createWriteExcelData(rowDataList, errorMap, new ArrayList<>(), titleRowData, shetNameMap, finalTemplateVO);


            engineService.batchSaveSelectChar(templateVO, dataCBOIdList);


         }


      }


@@ -1061,7 +1071,19 @@




      return codeImProtRusultVO;


   }


   /*private void converBaseModels(List<ClientBusinessObject> clientBusinessObjects,List<BaseModel>dataCBOList){


      clientBusinessObjects.stream().forEach(clientBusinessObject -> {


         BaseModel baseModel=new BaseModel();


         BeanUtil.convert(clientBusinessObject,baseModel);


         Map<String,String> dataMap=new HashMap<>();


         clientBusinessObject.getHisAttrValList()


         baseModel.setData(VciBaseUtil.objectToMapString(baseModel));




         AttributeValue[] newAttributeValue=    clientBusinessObject.getNewAttrValList();


         dataCBOList.add(baseModel);


      });




   }*/


   /***


    * 从execl里构建对象


    * @param rowDataList


@@ -1338,7 +1360,7 @@


            cboList.stream().forEach(clientBusinessObject -> {


               BaseModel baseModel=new BaseModel();


               BeanUtil.convert(clientBusinessObject,baseModel);


               baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


               //baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


               dataCBOList.add(baseModel);


               dataCBOIdList.add(baseModel.getOid());


            });


@@ -1362,8 +1384,7 @@


   public List<CodeImportTemplateVO> gridclassifys(String redisOid) {


      List<CodeImportTemplateVO> codeImportTemplateVOs=new ArrayList<>();


      VciBaseUtil.alertNotNull(redisOid,"分类",redisOid,"分类缓存主键");




      List<CodeImportTemplateVO> redisServiceCacheObjects=bladeRedis.lRange(redisOid,0,-1);


      List<CodeImportTemplateVO> redisServiceCacheObjects=bladeRedis.get(redisOid);


      if(redisServiceCacheObjects!=null){


         codeImportTemplateVOs=  redisServiceCacheObjects;


      }


@@ -1379,7 +1400,7 @@


   @Override


   public DataGrid<Map<String, String>> gridDatas(String codeClssifyOid, String redisOid) {


      VciBaseUtil.alertNotNull(redisOid,"导入相似数据",redisOid,"数据缓存主键");


      List<CodeImprotDataVO> codeImprotDataVOs = bladeRedis.lRange(redisOid+"-"+codeClssifyOid,0,-1);


      List<CodeImprotDataVO> codeImprotDataVOs = bladeRedis.get(redisOid+"-"+codeClssifyOid);


//      redisService.getCacheList(redisOid+"-"+codeClssifyOid);


      CodeImprotDataVO codeImprotDataVO=new CodeImprotDataVO();


      if(!CollectionUtils.isEmpty(codeImprotDataVOs)){


@@ -1413,7 +1434,7 @@


   @Override


   public DataGrid<Map<String,String>> gridRowResemble(String oid,String redisOid){


      VciBaseUtil.alertNotNull(redisOid,"导入相似数据",redisOid,"数据缓存主键");


      List<DataResembleVO> codeImprotDataVOs = bladeRedis.lRange(redisOid,0,-1);;


      List<DataResembleVO> codeImprotDataVOs = bladeRedis.get(redisOid);;


      DataGrid<Map<String, String>> dataGrid = new DataGrid<>();


      List<Map<String, String>> dataList = new ArrayList<>();




@@ -1434,7 +1455,8 @@




   @Override


   public R batchImportData(List<CodeImprotSaveDatVO> codeImprotSaveDatVOList, String classifyAttr, boolean isImprot) {


      List<BaseModel> dataCBOList=new ArrayList<>();




      boolean success=true;


      codeImprotSaveDatVOList.stream().forEach(codeImprotSaveDatVO -> {


         List<SheetRowData> rowDataList = new ArrayList<>();


         List<ClientBusinessObject>cboList=new ArrayList<>();


@@ -1473,19 +1495,31 @@


         String fullPath = getFullPath(classifyFullInfo);


         excelToCbo(classifyFullInfo,fieldIndexMap,rowDataList, codeClassifyTemplateVO,cboList,fullPath,!isImprot);


         Map<String,String> errorMap=new HashMap<>();


         Map<String/**路径**/, CodeClassifyVO> pathMap=new HashMap<>() ;


         //校验编码规则和码段是否正确


         Map<String, List<String>> ruleRowIndexMap = new ConcurrentHashMap<>();


         Map<String, CodeRuleVO> ruleVOMap =new ConcurrentHashMap<>();


         if(isImprot) {


            Map<String/**主键**/, String/**路径**/> childOidPathMap = getChildClassifyPathMap(classifyFullInfo, fullPath);


            //都转换完了。需要批量检查


            //找所有的分类路径,需要校验路径是否正确，是否都在当前的分类的下级


            List<CodeClassifyVO> childClassifyVOs = classifyService.listChildrenClassify(orderDTO.getCodeClassifyOid(), true, classifyAttr, true);


            Map<String/**路径**/, CodeClassifyVO> pathMap = Optional.ofNullable(childClassifyVOs).orElseGet(() -> new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getPath().startsWith("#") ? s.getPath().substring(1) : s.getPath(), t -> t));


            pathMap = Optional.ofNullable(childClassifyVOs).orElseGet(() -> new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getPath().startsWith("#") ? s.getPath().substring(1) : s.getPath(), t -> t));


            Map<String/**主键**/, CodeClassifyVO> classifyVOMap = Optional.ofNullable(childClassifyVOs).orElseGet(() -> new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));


            classifyVOMap.put(classifyFullInfo.getCurrentClassifyVO().getOid(), classifyFullInfo.getCurrentClassifyVO());


            pathMap.put("#current#", classifyFullInfo.getCurrentClassifyVO());


            //我们需要判断这些分类的模板是不是一样的，只需要校验，不用获取


            //检查分类的路径


            checkClassifyPathInHistory(cboList, errorMap, pathMap, childOidPathMap);


            //检查规则


            Map<String/**分类主键**/, String/**规则主键**/> ruleOidMap = new ConcurrentHashMap<String, String>();


            List<String> unExistRuleClassifyOidList = new CopyOnWriteArrayList<>();


            checkRuleOidInHistory(classifyVOMap, ruleOidMap, unExistRuleClassifyOidList);


            ruleVOMap = ruleService.listCodeRuleByIds(ruleOidMap.values(), true).stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));




            checkSecLengthInHistory(cboList, classifyVOMap, ruleVOMap, ruleOidMap, errorMap, ruleRowIndexMap);


         }




         //分类注入


         batchSwitchClassifyAttrOnOrder(attrVOS,cboList,classifyFullInfo,isImprot);


         //boolean


@@ -1515,36 +1549,58 @@


         //4.校验规则


         batchCheckVerifyOnOrder(attrVOS, cboList,errorMap);






         //SessionInfo sessionInfo = VciBaseUtil.getCurrentUserSessionInfo();


         List<ClientBusinessObject>needSaveCboList = cboList.stream().filter(cbo -> {


            String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


            return !errorMap.containsKey(rowIndex);


         }).collect(Collectors.toList());




         log.info("分类："+classifyFullInfo.getCurrentClassifyVO().getName()+"数据:"+needSaveCboList.size());


         if (!CollectionUtils.isEmpty(needSaveCboList)) {


//            List<BaseModel> dataCBOList=new ArrayList<>();


            needSaveCboList.stream().forEach(clientBusinessObject -> {


               BaseModel baseModel=new BaseModel();


               BeanUtil.convert(clientBusinessObject,baseModel);


               baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


               dataCBOList.add(baseModel);


//               allNeedSaveCboList.add(baseModel);


            });


            try {


            //9.我们处理业务数据


               if (isImprot) {


                  productCodeService.productCodeAndSaveData(classifyFullInfo, codeClassifyTemplateVO, ruleVO, null, dataCBOList);


               }else {


                  productCodeService.productCodeAndSaveData(classifyFullInfo, codeClassifyTemplateVO, ruleVO, orderDTO.getSecDTOList(), dataCBOList);


         if(isImprot){


            List<ClientBusinessObject> needSaveCboList = cboList.stream().filter(cbo -> {


               String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


               return !errorMap.containsKey(rowIndex);


            }).collect(Collectors.toList());


            List<ClientBusinessObject> finalNeedSaveCboList = needSaveCboList;


            Map<String, CodeRuleVO> finalRuleVOMap = ruleVOMap;


            ruleRowIndexMap.keySet().parallelStream().forEach(ruleOid -> {


               List <BaseModel>dataCBOList=new CopyOnWriteArrayList<>();


               List<String> rowIndexList = ruleRowIndexMap.get(ruleOid);


               List<ClientBusinessObject> thisCbos = needSaveCboList.stream().filter(cbo -> rowIndexList.contains(cbo.getAttributeValue(IMPORT_ROW_INDEX)) && !errorMap.containsKey(cbo.getAttributeValue(IMPORT_ROW_INDEX))).collect(Collectors.toList());


               if (!CollectionUtils.isEmpty(thisCbos)) {


                  thisCbos.stream().forEach(clientBusinessObject -> {


                     BaseModel baseModel = new BaseModel();


                     BeanUtil.convert(clientBusinessObject, baseModel);


                     dataCBOList.add(baseModel);


                  });


                  try {


                     productCodeService.productCodeAndSaveData(classifyFullInfo, codeClassifyTemplateVO, finalRuleVOMap.get(ruleOid), null, dataCBOList);


                  } catch (Throwable e) {


                     //success=false;


                     log.error("批量产生编码的时候出错了", e);


                     thisCbos.stream().forEach(cbo -> {


                        String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


                        errorMap.put(rowIndex, errorMap.getOrDefault(rowIndex, "") + ";系统错误，存储数据的时候出错了");


                     });


                  }


               }


            } catch (Exception e) {


               e.printStackTrace();


               engineService.batchSaveSelectChar(codeClassifyTemplateVO, dataCBOList);


            });


         }else {


            List<BaseModel> dataCBOList=new ArrayList<>();


            List<ClientBusinessObject> needSaveCboList = cboList.stream().filter(cbo -> {


               String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


               return !errorMap.containsKey(rowIndex);


            }).collect(Collectors.toList());


            log.info("分类：" + classifyFullInfo.getCurrentClassifyVO().getName() + "数据:" + needSaveCboList.size());


            if (!CollectionUtils.isEmpty(needSaveCboList)) {


               needSaveCboList.stream().forEach(clientBusinessObject -> {


                  BaseModel baseModel = new BaseModel();


                  BeanUtil.convert(clientBusinessObject, baseModel);


                  dataCBOList.add(baseModel);


               });


               try {


                  productCodeService.productCodeAndSaveData(classifyFullInfo, codeClassifyTemplateVO, ruleVO, orderDTO.getSecDTOList(), dataCBOList);


               } catch (Exception e) {


                  e.printStackTrace();


               }


               //如果是编码生成失败，则直接就失败了，其他的判断出来有错误的我们都统一返回到excel里面


               engineService.batchSaveSelectChar(codeClassifyTemplateVO, dataCBOList);


            }


         }


         //如果是编码生成失败，则直接就失败了，其他的判断出来有错误的我们都统一返回到excel里面


         engineService.batchSaveSelectChar(codeClassifyTemplateVO, dataCBOList);


      });


      return  R.success(isImprot?"批量历史导入成功":"批量申请成功");


   }


@@ -1802,7 +1858,7 @@


         needSaveCboList.stream().forEach(clientBusinessObject -> {


            BaseModel baseModel=new BaseModel();


            BeanUtil.convert(clientBusinessObject,baseModel);


            baseModel.setData(VciBaseUtil.objectToMapString(clientBusinessObject));


         //(VciBaseUtil.objectToMapString(clientBusinessObject));


            dataCBOList.add(baseModel);


            allNeedSaveCboList.add(baseModel.getOid());


         });


@@ -2004,7 +2060,7 @@




            BaseModel baseModel=new BaseModel();


            BeanUtil.convert(cbo,baseModel);


            baseModel.setData(VciBaseUtil.objectToMapString(cbo));


            //baseModel.setData(VciBaseUtil.objectToMapString(cbo));


            updateList.add(baseModel);


         }else if(operation.equals("delete")){//如果在流程中不允许删除，不在流程中状态为发布或者停用的数据不允许删除，将其更改为停用，其他的情况直接删除


            //  if(finalIsProcess){


@@ -2045,7 +2101,7 @@




               BaseModel baseModel=new BaseModel();


               BeanUtil.convert(cbo,baseModel);


               baseModel.setData(VciBaseUtil.objectToMapString(cbo));


               //baseModel.setData(VciBaseUtil.objectToMapString(cbo));


               updateList.add(baseModel);


            }catch (VciBaseException e) {


               e.printStackTrace();


@@ -2209,7 +2265,7 @@


         } else if (StringUtils.isNotBlank(orderDTO.getCopyFromVersion())) {


            sql[0] += " and oid != '" + orderDTO.getCopyFromVersion() + "'";


         }


         sql[0] += " and islastR = '1' and islastV = '1' ";


         sql[0] += " and lastR = '1' and lastV = '1' ";


         if (commonsMapper.queryCountBySql(sql[0]) > 0) {


            String ruleInfoMsg = keyRuleVO == null ? "" : "查询规则：去除空格--{0},忽略大小写--{1},忽略全半角--{2},忽略全部空格--{3}";


            String[] objs = new String[]{trim ? "是" : "否", ignoreCase ? "是" : "否", ignoreWidth ? "是" : "否", trimAll ? "是" : "否"};