统一业务系统系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
田源
2023-12-06 f099be6e30adfdea4580b09e33d75dc146a7a475 
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmIOServiceImpl.java


@@ -58,6 +58,7 @@


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


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


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


import org.springblade.core.secure.BladeUser;


import org.springblade.core.secure.utils.AuthUtil;


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


import org.springblade.core.tool.utils.Func;


@@ -1206,6 +1207,7 @@


               //SessionInfo sessionInfo = VciBaseUtil.getCurrentUserSessionInfo();


               List<ClientBusinessObject> finalNeedSaveCboList = needSaveCboList;


               CodeClassifyTemplateVO finalTemplateVO = templateVO;


               final BladeUser user = AuthUtil.getUser();


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


                  //VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);


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


@@ -1222,7 +1224,7 @@


                  if (!CollectionUtils.isEmpty(thisCbos)) {


                     try {


                        // TODO 多线程流问题


                        productCodeService.productCodeAndSaveData(classifyFullInfo, finalTemplateVO, ruleVOMap.get(ruleOid), null, dataCBOList);


                        productCodeService.productCodeAndSaveData(classifyFullInfo, finalTemplateVO, ruleVOMap.get(ruleOid), null, dataCBOList,user);


                        importCount.add(dataCBOList.size());


                     } catch (Throwable e) {


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


@@ -1282,6 +1284,7 @@


    * @param file            excel文件的信息


    * @return 有错误信息的excel


    */


   @Transactional


   @Override


   public CodeImProtRusultVO batchImportEdit(String codeClassifyOid, String classifyAttr,File file) throws  Throwable{


      VciBaseUtil.alertNotNull(codeClassifyOid,"分类的主键");


@@ -1328,7 +1331,7 @@


            titleRowData.remove(titleRowData.size()-1);


            templateVO= templateVOList.get(0);


         }catch (Throwable e){


            throw  new VciBaseException(e.getMessage());


            throw new ServiceException(e.getMessage());


         }




         CodeClassifyTemplateVO finalTemplateVO = templateVO;


@@ -1355,23 +1358,13 @@


            //我们使用和业务类型的来查询


            List<Map> cbosB = commonsMapper.selectBySql(sqlBO.getSqlUnPage());


            if(cbosB.size() == 0){


               throw  new ServiceException("编码："+ sheetRowData.getData().get(0) + ",未能查询到相关数据。");


               throw new ServiceException("编码："+ sheetRowData.getData().get(0) + ",未能查询到相关数据。");


            }


            excelToCboEdit(fieldIndexMap, sheetRowData, orderDTO, cbosB.get(0));


            orderDTO.setCopyFromVersion(orderDTO.getOid());


            orderDTO.setOid(null);


            try {


               mdmEngineService.upSaveCode(orderDTO);


               List<Map> newCbos = commonsMapper.selectBySql(sqlBO.getSqlUnPage());


               //对码值表进行处理替换创建数据的oid


               QueryWrapper<CodeAllCode> wrapper = new QueryWrapper<>();


               wrapper.eq("CREATECODEOID",orderDTO.getCopyFromVersion());


               List<CodeAllCode> codeAllCodes = codeAllCodeService.selectByWrapper(wrapper);


               codeAllCodes.get(0).setCreateCodeOid(newCbos.get(0).get("OID").toString());


               codeAllCodes.get(0).setLastModifyTime(new Date());


               codeAllCodes.get(0).setTs(new Date());


               codeAllCodes.get(0).setLastModifier(AuthUtil.getUser().getUserName());


               codeAllCodeService.updateBatchById(codeAllCodes);


            } catch (Throwable e) {


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


               errorMap.put(sheetRowData.getRowIndex(), ";系统错误，存储数据的时候出错了:"+e.getMessage());


@@ -1683,7 +1676,7 @@


            createRedisDatas(uuid + "-ok",templateVO, rowIndexCboMap, dataSet, fieldIndexMap, newErrorMap,true);


         }else {


            uuid="";




            final BladeUser user = AuthUtil.getUser();


            //要把以上的错误的都抛出后，再继续处理时间和组合规则


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


               String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


@@ -1703,7 +1696,7 @@


                  dataCBOIdList.add(baseModel.getOid());


               });


               try {


                  codeList = productCodeService.productCodeAndSaveData(classifyFullInfo,templateVO,ruleVO, orderDTO.getSecDTOList(),dataCBOList);


                  codeList = productCodeService.productCodeAndSaveData(classifyFullInfo,templateVO,ruleVO, orderDTO.getSecDTOList(),dataCBOList,user);


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


                  engineService.batchSaveSelectChar(templateVO, dataCBOList);


               } catch (Exception e) {


@@ -2118,7 +2111,8 @@


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


            List<ClientBusinessObject> finalNeedSaveCboList = needSaveCboList;


            Map<String, CodeRuleVO> finalRuleVOMap = ruleVOMap;


            // TODO： 多线程流套多线程流，有坑，我把这儿改了


            // TODO： 多线程流套多线程流，有坑，我把这儿改成单线程了


            final BladeUser user = AuthUtil.getUser();


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


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


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


@@ -2130,7 +2124,7 @@


                     dataCBOList.add(baseModel);


                  });


                  try {


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


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


                  } catch (Throwable e) {


                     //success=false;


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


@@ -2143,6 +2137,7 @@


               engineService.batchSaveSelectChar(codeClassifyTemplateVO, dataCBOList);


            });


         }else {


            final BladeUser user = AuthUtil.getUser();


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


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


               String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


@@ -2156,7 +2151,7 @@


                  dataCBOList.add(baseModel);


               });


               try {


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


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


               } catch (Exception e) {


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


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


@@ -2464,6 +2459,7 @@




         List<String>allNeedSaveCboList=new ArrayList<>();


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


         final BladeUser user = AuthUtil.getUser();


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


            BaseModel baseModel=new BaseModel();


            BeanUtil.convert(clientBusinessObject,baseModel);


@@ -2473,7 +2469,7 @@


         });


         try {


            List<String>applyGroupCodeIdList=new ArrayList<>();


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


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


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


            engineService.batchSaveSelectChar(templateVO, dataCBOList);


            // if(!isProcess){


@@ -3346,7 +3342,7 @@


         String oid=rowData.getOid();


         String rowNumber=rowData.getRowIndex();


         ClientBusinessObject cbo = new ClientBusinessObject();


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId(),null);


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId());


         rowData.getData().forEach((index,value)->{


            String field = fieldIndexMap.get(index);


            if(StringUtils.isBlank(field)){


@@ -3452,7 +3448,7 @@


      String fullPath = getFullPath(classifyFullInfo);


      codeImprotDataVO.getDatas().stream().forEach(rowData -> {


         ClientBusinessObject cbo=new ClientBusinessObject();


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId(),null);


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId());


         rowData.forEach((field,value)->{


            try {


               cbo.setAttributeValueWithNoCheck(field,value);


@@ -3506,7 +3502,7 @@


                     String fullPath,boolean newCode){


      rowDataList.stream().forEach(rowData -> {


         ClientBusinessObject cbo=new ClientBusinessObject();


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId(),null);


         DefaultAttrAssimtUtil.addDefaultAttrAssimt(cbo, classifyFullInfo.getTopClassifyVO().getBtmTypeId());


         rowData.getData().forEach((index,value)->{


               String field = fieldIndexMap.get(index);


            if (StringUtils.isBlank(field)) {


@@ -3563,7 +3559,7 @@


            if (StringUtils.isBlank(field)) {


               throw new VciBaseException("第" + (index + 1) + "列的标题在系统中不存在");


            }


            map.put(field,value);


            map.put(field.toUpperCase(),value);


         });




      try {


@@ -4269,7 +4265,7 @@


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


      // 查询不需要参与关键属性校验的除自己以外的所有分类oid


      final String isParticipateCheckOids = classifyService.selectLeafByParentClassifyOid(classifyFullInfo.getTopClassifyVO().getOid(), classifyFullInfo.getCurrentClassifyVO().getOid());


      final HttpServletRequest request = org.springblade.core.tool.utils.WebUtil.getRequest();


      final BladeUser user = AuthUtil.getUser();


      List<ClientBusinessObject> repeatDataMap = cboList.parallelStream().filter(cbo -> {


         //每行都得查询.如果其中出现了错误，我们就直接抛出异常，其余的显示


         //VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);


@@ -4295,7 +4291,7 @@


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


               newDataList.stream().forEach(stringStringMap -> {


                  BaseModel baseModel=new BaseModel();


                  DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(stringStringMap,baseModel,request);


                  DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(stringStringMap,baseModel,user);


                  baseModel.setData(stringStringMap);


                  newCboList.add(baseModel);


               });


@@ -4521,7 +4517,7 @@


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


      oldDataMap.stream().forEach(dataMap->{


         ClientBusinessObject clientBusinessObject=new ClientBusinessObject();


         DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(dataMap,clientBusinessObject,null);


         DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(dataMap,clientBusinessObject);


         for (String key:dataMap.keySet()){


            Object value= dataMap.getOrDefault(key,"");


            clientBusinessObject.setAttributeValue(key.toLowerCase(Locale.ROOT),value==null?"":value.toString());