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


@@ -6,13 +6,11 @@


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.google.protobuf.ServiceException;


import com.vci.ubcs.code.applyjtcodeservice.entity.DockingPreAttrMapping;


import com.vci.ubcs.code.applyjtcodeservice.feign.IMdmInterJtClient;


import com.vci.ubcs.code.applyjtcodeservice.vo.DockingPreAttrMappingVO;


import com.vci.ubcs.code.bo.AttributeValue;


import com.vci.ubcs.code.bo.CodeClassifyFullInfoBO;


import com.vci.ubcs.code.bo.CodeTemplateAttrSqlBO;


import com.vci.ubcs.code.constant.MdmEngineConstant;


import com.vci.ubcs.code.dto.*;


import com.vci.ubcs.code.entity.CodeAllCode;


import com.vci.ubcs.code.enumpack.CodeDefaultLC;


@@ -62,6 +60,7 @@


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


import org.aspectj.apache.bcel.classfile.Code;


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;


@@ -73,6 +72,7 @@


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;


import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import java.beans.BeanInfo;


import java.beans.Introspector;


import java.beans.PropertyDescriptor;


@@ -90,7 +90,6 @@


import java.util.concurrent.CopyOnWriteArrayList;


import java.util.concurrent.CopyOnWriteArraySet;


import java.util.concurrent.atomic.AtomicBoolean;


import java.util.concurrent.atomic.AtomicReference;


import java.util.stream.Collectors;




import static com.alibaba.druid.util.FnvHash.Constants.LIMIT;


@@ -201,9 +200,9 @@


   private SaveLogUtil saveLogUtil;




   /**


    * 导出的十万条


    * 客户现场excel为老版本，导出的总数限制为65535


    */


   public static final int EXPORT_LIMIT = 100000;


   public static final int EXPORT_LIMIT = 65535;




   /**


    * 批量申请：选取选中分类下的所有模板关键属性，相似属性，必填属性，写入execl中


@@ -614,6 +613,7 @@


      ExcelUtil.writeDataToFile(excelName,eo);


      return excelName;


   }




   /**


    * 获取码段宽度


    * @param codeClassifyOid


@@ -774,7 +774,8 @@




         //除去默认的属性.还有只有表单显示的字段才导入


         List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->


            !DEFAULT_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


            !DEFAULT_ATTR_LIST.contains(s.getId()) &&


               ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


         ).collect(Collectors.toList());




         Map<String/**模板属性字段oid**/, String /**模板属性外部名称**/> fieldNameMap =attrVOS.stream().collect(Collectors.toMap(CodeClassifyTemplateAttrVO::getId,s->s.getName()));


@@ -1209,6 +1210,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);


@@ -1225,7 +1227,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);


@@ -1276,6 +1278,7 @@


         throw e;


      }


   }




   /**


    * 导入批量编辑数据


    *


@@ -1284,14 +1287,18 @@


    * @param file            excel文件的信息


    * @return 有错误信息的excel


    */


   @Transactional


   @Override


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


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


      ReadExcelOption reo = new ReadExcelOption();


      reo.setReadAllSheet(true);


      List<SheetDataSet> sheetDataSetList = ExcelUtil.readDataObjectFromExcel(file,null,reo);


      if (sheetDataSetList.size() > LIMIT + 1) {


         throw new VciBaseException("为了保证系统的稳定性，请一次不要导入超过1万条的数据");


      if (sheetDataSetList.get(0).getRowData().size() > LIMIT + 1) {


         throw new ServiceException("为了保证系统的稳定性，请一次不要导入超过1万条的数据");


      }


      if (sheetDataSetList.get(0).getRowData().size() == 0) {


         throw new ServiceException("未读取到excle相关数据，请确认！！！");


      }


      boolean isExport=false;


      Map<String,List<WriteExcelData>> shetNameMap=new HashMap<>();


@@ -1327,7 +1334,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;


@@ -1354,32 +1361,18 @@


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


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


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


//               String rowIndex = cbo.getAttributeValue(IMPORT_ROW_INDEX);


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


//            });


            }


         }




         if (errorMap.size() > 0) {


            isExport = true;


         }


@@ -1594,7 +1587,8 @@




         //除去默认的属性.还有只有表单显示的字段才导入


         List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->


            !DEFAULT_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


            !DEFAULT_ATTR_LIST.contains(s.getId()) &&


               ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


         ).collect(Collectors.toList());


         Map<Integer/**列号**/,String/**字段的名称**/> fieldIndexMap = new HashMap<>();


         List<String> titleRowData = dataSet.getColName();


@@ -1686,7 +1680,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);


@@ -1706,7 +1700,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) {


@@ -1843,21 +1837,23 @@


         " and lastr = '1'" +


         " and lastv='1'" +


         " and codeclsfpath like '%" + exportAttrDTO.getCodeClassifyOid() + "%'";




      //先查询总数


      int total = 0;


      if(exportAttrDTO.getEndPage()!=null && exportAttrDTO.getEndPage()>0


         &&exportAttrDTO.getPage() !=null && exportAttrDTO.getPage() >0


         &&exportAttrDTO.getEndPage()>exportAttrDTO.getPage()){


         //从多少页到多少页的查询方式，


         String countPageSql = "select count(*) from (select * FROM " + tableName +" where 1=1" +


            " and lastr = '1'" +


            " and lastv='1'" +


            " and codeclsfpath like '%" + exportAttrDTO.getCodeClassifyOid() + "%' {}";


         for(int i = exportAttrDTO.getPage() ;i <= exportAttrDTO.getEndPage();i++){


            PageHelper thisPage = new PageHelper(exportAttrDTO.getLimit()==null?-1:exportAttrDTO.getLimit());


            thisPage.setPage(exportAttrDTO.getPage()==null?1:exportAttrDTO.getPage());


            thisPage.setSort(exportAttrDTO.getSort());


            thisPage.setOrder(exportAttrDTO.getOrder());


            thisPage.addDefaultDesc("createTime");




            total += commonsMapper.queryCountBySql(countSql);


            total += commonsMapper.queryCountBySql(StringUtil.format(countPageSql," limit " + exportAttrDTO.getLimit() +" offset "+ i +")subquery;"));


         }


      }else{


         total = commonsMapper.queryCountBySql(countSql);


@@ -2055,7 +2051,8 @@


         CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo);


         //除去默认的属性.还有只有表单显示的字段才导入


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


            !DEFAULT_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


            !DEFAULT_ATTR_LIST.contains(s.getId()) &&


               ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


         ).collect(Collectors.toList());


         String fullPath = getFullPath(classifyFullInfo);


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


@@ -2122,7 +2119,9 @@


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


            List<ClientBusinessObject> finalNeedSaveCboList = needSaveCboList;


            Map<String, CodeRuleVO> finalRuleVOMap = ruleVOMap;


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


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


            final BladeUser user = AuthUtil.getUser();


            ruleRowIndexMap.keySet().stream().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());


@@ -2133,7 +2132,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);


@@ -2146,6 +2145,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);


@@ -2159,7 +2159,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 -> {


@@ -2257,8 +2257,10 @@




      //校验模板是不是最新的


      //checkTemplateSync(sheetDataSetList,templateVO);


      //除去默认的属性.还有只有表单显示的字段才导入


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->!DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


      //除去默认的属性.还有只有具有分类注入的才过滤出来


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(


         s ->!DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) &&


            ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


      ).collect(Collectors.toList());


      Map<Integer/**列号**/,String/**字段的名称**/> fieldIndexMap = new HashMap<>();


      List<String> titleRowData = dataObjectVO.getColName();


@@ -2467,6 +2469,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);


@@ -2476,7 +2479,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){


@@ -2504,7 +2507,6 @@


                  resultDataObjectDetailDO.setErrorid("0");


               }


               resultDataObjectDetailDO.setId(sourceOid);




               resultDataObjectDetailDO.setMsg(msg);


               resultDataObjectDetailDOs.add(resultDataObjectDetailDO);


               //处理传送的数据中关键属性重复的，直接拿到已经申请到编码的数据编码直接将赋给关键属性重复的数据


@@ -2628,7 +2630,8 @@


      //校验模板是不是最新的


      //checkTemplateSync(sheetDataSetList,templateVO);


      //除去默认的属性.还有只有表单显示的字段才导入


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) &&


         ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


      ).collect(Collectors.toList());


      Map<Integer/**列号**/, String/**字段的名称**/> fieldIndexMap = new HashMap<>();


      List<String> titleRowData = dataObjectVO.getColName();


@@ -3567,7 +3570,7 @@


            if (StringUtils.isBlank(field)) {


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


            }


            map.put(field,value);


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


         });




      try {


@@ -4273,6 +4276,7 @@


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


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


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


      final BladeUser user = AuthUtil.getUser();


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


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


         //VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);


@@ -4304,7 +4308,7 @@


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


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


                  BaseModel baseModel=new BaseModel();


                  DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(stringStringMap,baseModel,true);


                  DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(stringStringMap,baseModel,false);


                  baseModel.setData(stringStringMap);


                  newCboList.add(baseModel);


               });


@@ -4625,7 +4629,8 @@


   private void createExeclClassData(List<String> titleRowData, CodeClassifyTemplateVO newTemplateVO, Map<Integer, String> execlData, CodeImprotDataVO codeImprotDataVO){


      //除去默认的属性.还有只有表单显示的字段才导入


      List<CodeClassifyTemplateAttrVO> attrVOS = newTemplateVO.getAttributes().stream().filter(s ->


         !DEFAULT_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


         !DEFAULT_ATTR_LIST.contains(s.getId()) &&


            ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


      ).collect(Collectors.toList());


      Map<String/**中文名称**/, String/**英文名称**/> attrNameIdMap = attrVOS.stream().collect(Collectors.toMap(s -> s.getName(), t -> t.getId()));


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


@@ -5106,7 +5111,8 @@


      CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(codeClassifyOid);


      //获取最新的模板


      CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyOid);      //除去默认的属性.还有只有表单显示的字段才导入


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->!DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


      List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->!DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) &&


         ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


      ).collect(Collectors.toList());


      ExecGroupCodePortDataDTO execGroupCodePortDataDTO=new ExecGroupCodePortDataDTO();


      createExportGroupCodeMapConfig(templateVO,execGroupCodePortDataDTO);//组织数据


@@ -5316,7 +5322,8 @@


               errorMap.put(rowIndex,"第"+rowIndex+"行，在系统中未查询到相应的码值数据");


            }


            //除去默认的属性.还有只有表单显示的字段才导入


            List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->!fieldIndexMap.containsValue(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())


            List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s ->!fieldIndexMap.containsValue(s.getId()) &&


               ((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))


            ).collect(Collectors.toList());


            attrVOS.stream().forEach(codeClassifyTemplateAttrVO -> {//将不需要更改的默认字段或者不更改的属性复制到新的版本上


               String arrtibuteKey=codeClassifyTemplateAttrVO.getId();