统一业务系统系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
ludc
2023-04-26 7f0570d20aac189f1b170942bd7100b281a1c824 
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java


@@ -5,7 +5,8 @@


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;


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


import com.vci.ubcs.starter.revision.model.TreeQueryObject;


import com.vci.ubcs.starter.revision.model.TreeWrapperOptions;


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


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


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


@@ -24,22 +25,22 @@


import com.vci.ubcs.code.vo.pagemodel.CodeClassifyVO;


import com.vci.ubcs.code.vo.pagemodel.CodeKeyAttrRepeatRuleVO;


import com.vci.ubcs.code.vo.pagemodel.CodeRuleVO;


import com.vci.ubcs.code.vo.pagemodel.TreeQueryObject;


import com.vci.ubcs.com.vci.starter.bo.WriteExcelData;


import com.vci.ubcs.com.vci.starter.exception.VciBaseException;


import com.vci.ubcs.com.vci.starter.poi.bo.ReadExcelOption;


import com.vci.ubcs.com.vci.starter.poi.bo.WriteExcelOption;


import com.vci.ubcs.com.vci.starter.poi.constant.ExcelLangCodeConstant;


import com.vci.ubcs.com.vci.starter.poi.util.ExcelUtil;


import com.vci.ubcs.com.vci.starter.revision.service.RevisionModelUtil;


import com.vci.ubcs.com.vci.starter.util.LocalFileUtil;


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


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


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


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


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


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


import com.vci.ubcs.core.log.exception.ServiceException;


import com.vci.ubcs.starter.revision.model.TreeQueryObject;


import com.vci.ubcs.starter.bo.WriteExcelData;


import com.vci.ubcs.starter.exception.VciBaseException;


import com.vci.ubcs.starter.poi.bo.ReadExcelOption;


import com.vci.ubcs.starter.poi.bo.WriteExcelOption;


import com.vci.ubcs.starter.poi.constant.ExcelLangCodeConstant;


import com.vci.ubcs.starter.poi.util.ExcelUtil;


import com.vci.ubcs.starter.revision.service.RevisionModelUtil;


import com.vci.ubcs.starter.util.LocalFileUtil;


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


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


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


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


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


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


import org.springblade.core.log.exception.ServiceException;


import org.apache.poi.hssf.util.HSSFColor;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


@@ -67,12 +68,11 @@


   @Resource


   private CodeClstemplateMapper codeClstemplateMapper;




//   @Resource


//   private ICodeRuleService codeRuleService;


   @Resource


   private ICodeRuleService codeRuleService;




   @Resource


   private CodeOsbtmtypeMapper codeOsbtmtypeMapper;




   @Resource


   CodeOsbtmtypeattributeMapper codeOsbtmtypeattributeMapper;




@@ -116,8 +116,11 @@


      codeClassifyEntity.setCreator(AuthUtil.getUser().getUserName());


      codeClassifyEntity.setCreateTime(new Date());


      codeClassifyEntity.setTs(new Date());


      codeClassifyEntity.setOwner(AuthUtil.getUser().getUserName());


      codeClassifyEntity.setLastModifier(AuthUtil.getUser().getUserName());


      codeClassifyEntity.setLastModifyTime(new Date());


      codeClassifyEntity.setRevisionSeq(1);


      codeClassifyEntity.setVersionSeq(1);


      int insertNumber = codeClassifyMapper.insert(codeClassifyEntity);


      return R.status(SqlHelper.retBool(insertNumber));


   }


@@ -168,7 +171,11 @@


      if(codeClassifyEntity == null || codeClassifyEntity.getOid() == null){


         return R.fail("传入数据不能为空！");


      }


      codeClassifyEntity = selectByOid(codeClassifyEntity.getOid());


      CodeClassify codeClassifyNew = selectByOid(codeClassifyEntity.getOid());


      if(codeClassifyNew == null){


         return R.fail("未查询到相关数据！");


      }


      codeClassifyNew.setTs(codeClassifyEntity.getTs());


      return checkIsCanDeleteForDO(codeClassifyEntity);


   }




@@ -194,11 +201,11 @@


   private R checkIsCanDeleteForDO(CodeClassify codeClassifyEntity) {




      //检查ts


      Map<String,Object> condition = new HashMap<>(2);


      condition.put("oid",codeClassifyEntity.getOid());


      condition.put("ts",codeClassifyEntity.getTs());


      CodeClassify detail = codeClassifyMapper


         .selectOne(Condition.getQueryWrapper(condition,CodeClassify.class));


//      Map<String,Object> condition = new HashMap<>(2);


//      condition.put("oid",codeClassifyEntity.getOid());


//      condition.put("ts",codeClassifyEntity.getTs());


      CodeClassify detail = codeClassifyMapper.selectOne(Condition.getQueryWrapper(codeClassifyEntity));


//         .selectOne(Condition.getQueryWrapper(condition,CodeClassify.class));


      if(detail == null){//不是最新的不让改


         throw new ServiceException("当前数据不是最新，请刷新后再修改！");


//         return R.fail("当前数据不是最新，请刷新后再修改！");


@@ -327,6 +334,9 @@


      //查询修改前ts


      CodeClassify codeClassify = codeClassifyMapper.selectById(oid);//主要是为了查询ts


      codeClassify.setLcStatus(lcStatus);


      codeClassify.setTs(new Date());


      codeClassify.setLastModifyTime(new Date());


      codeClassify.setLastModifier(AuthUtil.getUser().getUserName());


      //启用、停用


//      int u = codeClassifyMapper.updateLcStatus(oid,lcStatus);


      int count = codeClassifyMapper.updateById(codeClassify);


@@ -667,19 +677,24 @@


         });


         throw new VciBaseException("路径有重复,{0}",new String[]{rowIndexList.stream().collect(Collectors.joining(","))});


      }


      //编号获取业务类型服务还未完成，所以等业务类型完成后进行后续的完成


//      Map<String, CodeRuleVO> ruleVOMap = Optional.ofNullable(codeRuleService.listCodeRuleByIds(


//         poList.stream().filter(s->StringUtils.isNotBlank(s.getCodeRuleId())).map(CodeClassifyPO::getCodeRuleId).collect(Collectors.toList()))


//      ).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t,(o1,o2)->o2));


      Map<String, CodeRuleVO> ruleVOMap = null;


      Map<String,CodeKeyAttrRepeatRuleVO> keyRuleVOMap =Optional.ofNullable(iCodeKeyattrrepeatService.listCodeKeyAttrRepeatRuleByOids(


         poList.stream().filter(s->StringUtils.isNotBlank(s.getKeyRepeatRuleId())).map(CodeClassifyPO::getKeyRepeatRuleId).collect(Collectors.toList()))


      //编号获取业务类型服务


      List<String> ruleOids = poList.stream().filter(


            s -> StringUtils.isNotBlank(s.getCodeRuleId()))


         .map(CodeClassifyPO::getCodeRuleId)


         .collect(Collectors.toList());


      Map<String, CodeRuleVO> ruleVOMap = Optional.ofNullable(ruleOids.size()==0 ? null:codeRuleService.listCodeRuleByOids(ruleOids)


      ).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t,(o1,o2)->o2));


//      codeOsbtmtypeMapper.selectList((Wrapper<CodeOsbtmtypeEntity>) poList);


//      Map<String, CodeOsbtmtypeVO> btmVOMap = Optional.ofNullable(


//         codeOsbtmtypeMapper.selectList((Wrapper<CodeOsbtmtypeEntity>) poList)


//      ).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t,(o1,o2)->o2));


      Map<String, CodeOsbtmtypeVO> btmVOMap = null;




      List<String> keyOids = poList.stream().filter(s -> StringUtils.isNotBlank(s.getKeyRepeatRuleId()))


         .map(CodeClassifyPO::getKeyRepeatRuleId).collect(Collectors.toList());


      Map<String,CodeKeyAttrRepeatRuleVO> keyRuleVOMap =Optional.ofNullable(keyOids.size()==0 ? null: iCodeKeyattrrepeatService.listCodeKeyAttrRepeatRuleByOids(keyOids)


      ).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t,(o1,o2)->o2));




      List<String> btmOids = poList.stream().filter(s -> StringUtils.isNotBlank(s.getKeyRepeatRuleId()))


         .map(CodeClassifyPO::getBtmTypeId).collect(Collectors.toList());


      Map<String, CodeOsbtmtypeEntity> btmVOMap = Optional.ofNullable(btmOids.size()==0 ? null: codeOsbtmtypeMapper.selectBatchIds(btmOids)


      ).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t,(o1,o2)->o2));


//      Map<String, CodeOsbtmtypeVO> btmVOMap = null;


      Map<String/**路径**/,String/**主键**/> oidPathMap = new HashMap<>();




      //我们需要查询所有已经存在的分类，主要是路径，用来判断分类的数据


@@ -709,7 +724,7 @@


         classify.setDescription(po.getDescription());


         oidPathMap.put(po.getPath(),classify.getOid());


         if(StringUtils.isNotBlank(po.getBtmTypeId())){


            CodeOsbtmtypeVO typeVO = btmVOMap.get(po.getBtmTypeId().toLowerCase(Locale.ROOT));


            CodeOsbtmtypeVO typeVO = (CodeOsbtmtypeVO)btmVOMap.get(po.getBtmTypeId().toLowerCase(Locale.ROOT));


            classify.setBtmTypeId(typeVO.getId());


            classify.setBtmTypeName(typeVO.getName());


         }


@@ -801,7 +816,7 @@


               classifyDO.setTs(new Date());


               classifyDO.setBtmname("codeclassify");


               classifyDO.setLcStatus("Enabled");


               classifyDO.setId("0");


               classifyDO.setOwner(AuthUtil.getUser().getUserName());


               classifyDO.setCreator(AuthUtil.getUser().getUserName());


               classifyDO.setLastModifier(AuthUtil.getUser().getUserName());


               classifyDO.setLastModifyTime(new Date());


@@ -913,14 +928,14 @@


    */


   @Override


   public List<CodeClassify> selectAllLevelParentByOid(String oid){


//      String sql = "select oid,level from " + VciBaseUtil.getTableName(MdmBtmTypeConstant.CODE_CLASSIFY) + " start with oid= :oid connect by prior PARENTCODECLASSIFYOID = oid ";


//      Map< String,String> conditionMap = new HashMap< String,String>();


//      conditionMap.put("oid",oid);


      // String sql = "select oid,level from " + VciBaseUtil.getTableName(MdmBtmTypeConstant.CODE_CLASSIFY) + " start with oid= :oid connect by prior PARENTCODECLASSIFYOID = oid ";


      // Map< String,String> conditionMap = new HashMap< String,String>();


      // conditionMap.put("oid",oid);




      List<Map<String,Object>> cbos = codeClassifyMapper.selectAllLevelParentByOid(oid);


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


      Optional.ofNullable(cbos).orElseGet(()->new ArrayList<>()).stream().forEach(cbo->{


         oidLevelMap.put(cbo.get("oid").toString(),cbo.get("level").toString());


         oidLevelMap.put(cbo.get("OID").toString(),cbo.get("LEVEL").toString());


      });


      if(CollectionUtils.isEmpty(oidLevelMap)){


         return new ArrayList<>();


@@ -952,7 +967,6 @@


      return codeClassifyDO2VO(classifyDO);


   }






   /**


    * 主题库的树


    *


@@ -970,4 +984,5 @@


      treeQueryObject.getConditionMap().put(PARENT_FIELD_NAME, "=null");


      return treeCodeClassify(treeQueryObject);


   }




}