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


@@ -2,21 +2,24 @@




import com.alibaba.nacos.common.utils.StringUtils;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


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


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


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


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


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


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


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


import com.sun.org.apache.bcel.internal.generic.NEW;


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


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


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


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


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


import com.vci.ubcs.code.mapper.CodeClassifyMapper;


import com.vci.ubcs.code.mapper.CodeClassifyTemplateMapper;


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


import com.vci.ubcs.code.po.CodeClassifyPO;


import com.vci.ubcs.code.service.ICodeClassifyService;


import com.vci.ubcs.code.service.ICodeKeyAttrRepeatService;


import com.vci.ubcs.code.service.ICodeRuleService;


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


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


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


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


@@ -58,7 +61,9 @@


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


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.context.annotation.Bean;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import javax.annotation.Resource;


@@ -69,6 +74,7 @@


import java.util.stream.Stream;




import static com.vci.ubcs.code.constant.FrameWorkDefaultValueConstant.*;


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




@Service


public class CodeClassifyServiceImpl extends ServiceImpl<CodeClassifyMapper, CodeClassify> implements ICodeClassifyService {


@@ -85,6 +91,9 @@


   @Resource


   private IBtmTypeClient btmTypeClient;




   @Resource


   private CommonsMapper commonsMapper;




   /**


    * 日志


    */


@@ -97,6 +106,15 @@




   @Resource


   private ICodeKeyAttrRepeatService iCodeKeyattrrepeatService;




   @Resource


   private CodeAllCodeMapper codeAllCodeMapper;




   @Resource


   private CodeSerialValueMapper codeSerialValueMapper;




   @Resource


   private CodeBasicSecMapper codeBasicSecMapper;


   /**


    * 上级节点的属性名称


    */


@@ -173,6 +191,7 @@


    * @return 执行结果


    */


   @Override


   @Transactional(rollbackFor = Exception.class)


   public R editSave(CodeClassify codeClassifyEntity) {


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


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


@@ -186,18 +205,36 @@


      if(StringUtils.isNotBlank(codeClassifyEntity.getParentCodeClassifyOid()) && StringUtils.isNotBlank(codeClassifyEntity.getBtmTypeId())){


         return R.fail("只有在顶层的主题库分类才能设置业务类型");


      }


      codeClassifyEntity.setLastModifier(String.valueOf(AuthUtil.getUser().getUserId()));


      // codeClassifyEntity.setLastModifier(String.valueOf(AuthUtil.getUser().getUserId()));


      codeClassifyEntity.setLastModifier(String.valueOf(AuthUtil.getUser().getAccount()));


      codeClassifyEntity.setLastModifyTime(new Date());


      codeClassifyEntity.setTs(new Date());


      int insertNumber = codeClassifyMapper.updateById(codeClassifyEntity);


      int updateEntity = codeClassifyMapper.updateById(codeClassifyEntity);


      // 如果不是叶子结点，则需要修改其下所有的子分类，是否参与关键属性校验的值


      String oid = codeClassifyEntity.getOid();


      List<CodeClassify> codeClassifies = codeClassifyMapper.selectStartWithCurrentOid(oid);


      int updateAttr = 0;


      // 不为空就需要该当前分类下所有子分类的isParticipateCheck


      if(!codeClassifies.isEmpty()){


         List<String> oids = codeClassifies.stream().map(CodeClassify::getOid).collect(Collectors.toList());


         LambdaUpdateWrapper<CodeClassify> updateWrapper = Wrappers.<CodeClassify>update()


            .lambda().in(CodeClassify::getOid, oids)


            .set(CodeClassify::getIsParticipateCheck, codeClassifyEntity.getIsParticipateCheck());


         // 父分类的业务类型做了更改，所有子分类的都得进行更改


         if(!codeClassifyEntity.getBtmTypeId().equals(detail.getBtmTypeId())){


            updateWrapper.set(CodeClassify::getBtmTypeId,codeClassifyEntity.getBtmTypeId())


               .set(CodeClassify::getBtmTypeName,codeClassifyEntity.getBtmTypeName());


         }


         updateAttr = codeClassifyMapper.update(null,updateWrapper);




      }




//         //处理数据集成逻辑,成功后执行集成第一步,分类数据特殊处理。只有启用状态的分类才推送


//         if(FRAMEWORK_DATA_ENABLED.equals(codeClassifyDO.getLcStatus()));


//         {


//             codeDuckingServiceI.insertCache1(CACHE_TYPE_CLASSIFY_EDIT,FRAMEWORK_DATA_ENABLED,DOCKING_DEFAULT_CLASSIFY, DOCKING_DEFAULT_CLASSIFYOID, codeClassifyDO.getOid(), codeClassifyDTO.getTs());


//         }


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


//      return BaseResult.success(codeClassifyDO2VO(codeClassifyDO));


      return R.status(SqlHelper.retBool(updateAttr) & SqlHelper.retBool(updateEntity));


   }




   /**


@@ -373,11 +410,12 @@




      List<CodeClassify> classifyList = codeClassifyMapper.selectStartWithCurrentOid(oid);


      Date now = new Date();


      String userId = String.valueOf(AuthUtil.getUserId());


      // String userId = String.valueOf(AuthUtil.getUserId());


      String account = AuthUtil.getUserAccount();


      classifyList = classifyList.stream().map(s -> {


         s.setLcStatus(lcStatus);


         s.setTs(now);


         s.setLastModifier(userId);


         s.setLastModifier(account);


         s.setLastModifyTime(now);


         return s;


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


@@ -440,7 +478,7 @@


      List<CodeClassifyVO> voList = new ArrayList<CodeClassifyVO>();


      if(!CollectionUtils.isEmpty(codeClassifys)){


         for(CodeClassify s: codeClassifys){


            CodeClassifyVO vo =  codeClassifyDO2VO(s);


            CodeClassifyVO vo = codeClassifyDO2VO(s);


            if(vo != null){


               voList.add(vo);


            }


@@ -520,20 +558,21 @@


         lcStatus = treeQueryObject.getConditionMap().getOrDefault("lcStatus",null);


      }


      if(StringUtils.isNotBlank(id) || StringUtils.isNotBlank(lcStatus) ){


         //String tableName = this.getTableName(treeQueryObject.getConditionMap().get("btmTypeId"),treeQueryObject.getConditionMap().get("id"), treeQueryObject.getConditionMap().get("lcStatus"));


         doList = codeClassifyMapper


            .selectCodeClassifyDOByTree(treeQueryObject.getConditionMap().get("id"),treeQueryObject.getConditionMap().get("lcStatus"),treeQueryObject.getParentOid(), AuthUtil.getTenantId()


               .equals(


                  NacosConfigCache


                     .getAdminUserInfo()


                     .getTenantId()


               ) ? null:AuthUtil.getTenantId());


            .selectCodeClassifyDOByTree(


               treeQueryObject.getConditionMap().get("id"),


               treeQueryObject.getConditionMap().get("lcStatus"),


               treeQueryObject.getParentOid(),


               VciBaseUtil.checkAdminTenant() ? null:AuthUtil.getTenantId()


               /*tableName*/


            );


      }else{


         doList =codeClassifyMapper.selectCodeClassifyVOByTree(treeQueryObject.getParentOid(), AuthUtil.getTenantId()


            .equals(


               NacosConfigCache


                  .getAdminUserInfo()


                  .getTenantId()


            ) ? null:AuthUtil.getTenantId());


         // 只要前端会传参数过来就不会出现走这句的情况，所以查询总数没在这儿添加


         doList =codeClassifyMapper.selectCodeClassifyVOByTree(


            treeQueryObject.getParentOid(),


            VciBaseUtil.checkAdminTenant() ? null:AuthUtil.getTenantId()


         );


      }


      List<CodeClassifyVO> voList = codeClassifyDO2VOs(doList);


      TreeWrapperOptions treeWrapperOptions = new TreeWrapperOptions(PARENT_FIELD_NAME);


@@ -543,6 +582,7 @@


         return s.getId() + " " + s.getName() + (FrameworkDataLCStatus.DISABLED.getValue().equalsIgnoreCase(s


            .getLcStatus()) ? (" 【停用】 ") : "");


      });




      Iterator var6 =  tree.listIterator();


      while(var6.hasNext()){


         Tree trees = (Tree) var6.next();


@@ -554,6 +594,28 @@


         }


      }


      return tree;


   }




   /**


    * 分类加载时获取业务类型id，拼接业务类型表名


    * @return


    */


   private String getTableName(String btmTypeId,String id,String lcStatus){


      if(Func.isNotEmpty(btmTypeId)){


         return VciBaseUtil.getTableName(btmTypeId,true);


      }


      LambdaQueryWrapper<CodeClassify> wrapper = Wrappers.<CodeClassify>query()


         .lambda().select(CodeClassify::getBtmTypeId)


         .eq(CodeClassify::getLcStatus, lcStatus)


         .isNotNull(CodeClassify::getBtmTypeId)


         .last("limit 1")


         .eq(CodeClassify::getId,id).isNull(CodeClassify::getParentCodeClassifyOid);




      CodeClassify codeClassify = codeClassifyMapper.selectOne(wrapper);


      if(Func.isEmpty(codeClassify) || Func.isEmpty(codeClassify.getBtmTypeId())){


         throw new ServiceException("查询主数据总数时，未获取到业务类型ID！");


      }


      return VciBaseUtil.getTableName(codeClassify.getBtmTypeId(),true);


   }




   /**


@@ -600,6 +662,80 @@


         ) ? null:AuthUtil.getTenantId());


      List<CodeClassifyVO> voList = codeClassifyDO2VOs(doList);


      return voList;


   }




   /***


    * 根据oid获取下面所有的分类信息


    * @param oid


    * @return


    */


   public List<CodeClassifyVO> selectAllClassifyByOid(String oid, String fieldInPath){


      List<CodeClassify>  codeClassifyList=codeClassifyMapper.selectAllClassifyByOid(oid,AuthUtil.getTenantId(),fieldInPath);


      List<CodeClassifyVO> voList = codeClassifyDO2VOs(codeClassifyList);


      return voList;




   }




   /**


    * 根据顶层节点oid查询所有除当前节点以外所有不参与校验的分类oid


    * @param topOid


    * @param currentOid


    * @return


    */


   @Override


   public String selectLeafByParentClassifyOid(String topOid, String currentOid) {


      List<CodeClassify> codeClassifies = codeClassifyMapper.selectLeafByParentClassifyOid(topOid, currentOid);


      if(codeClassifies.isEmpty()){


         return "";


      }


      String oids = codeClassifies.stream().map(CodeClassify::getOid).collect(Collectors.joining(","));


      return oids;


   }




   /**


    * 流水依赖生成


    */


   @Override


   public R flowingDependencyGen(String classifyOid) {




      //查询此分类下面的所有分类


      List<CodeClassify>  codeClassifyList=codeClassifyMapper.selectAllClassifyByOid(classifyOid,AuthUtil.getTenantId(),null);


      //查询码值表，获取最大流水


      List<CodeAllCode> codeAllCodeVOS = codeAllCodeMapper.selectGroupByClassify("'" + codeClassifyList.stream()


         .map(classfiy -> classfiy.getOid()).collect(Collectors.joining("','")) + "'","'${sav}'");


      //往流水表里面加数据，有则更新，无则添加数据。


      for (CodeAllCode codeAllCodeVO : codeAllCodeVOS) {


         QueryWrapper<CodeBasicSec> secWrapper = new QueryWrapper<>();


         secWrapper.eq("PKCODERULE",codeAllCodeVO.getCodeRuleOid());


         secWrapper.eq("SECTYPE","codeserialsec");


         List<CodeBasicSec> codeBasicSecs = codeBasicSecMapper.selectList(secWrapper);


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


            throw new ServiceException("根据码值ID：" + codeAllCodeVO.getCodeRuleOid() + ",码段类型为流水码段(codeserialsec),在基础码段中未找到相关数据！");


         }


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


         wrapper.eq("codeRuleOid",codeAllCodeVO.getCodeRuleOid());


         wrapper.eq("serialUnit",codeAllCodeVO.getSerialUnit());


         wrapper.eq("codeSecOid",codeBasicSecs.get(0).getOid());


         List<CodeSerialValue> codeSerialValues = codeSerialValueMapper.selectList(wrapper);


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


            CodeSerialValue newSerialValue = new CodeSerialValue();


            DefaultAttrAssimtUtil.addDefaultAttrAssimt(newSerialValue,"codeserialvalue");


            newSerialValue.setCodeRuleOid(codeAllCodeVO.getCodeRuleOid());


            newSerialValue.setCodeSecOid(codeBasicSecs.get(0).getOid());


            newSerialValue.setSerialUnit(codeAllCodeVO.getSerialUnit());


            newSerialValue.setMaxSerial(codeAllCodeVO.getUnFillSerial());


            newSerialValue.setLctid("defaultLC");


            newSerialValue.setLcStatus("Exist");


            codeSerialValueMapper.insert(newSerialValue);


         }else{


            codeSerialValues.get(0).setMaxSerial(codeAllCodeVO.getUnFillSerial());


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


            codeSerialValues.get(0).setLastModifier(String.valueOf(AuthUtil.getUser().getUserId()));


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


            codeSerialValueMapper.updateById(codeSerialValues.get(0));


         }


      }


      return R.success("操作成功！");


   }




   /***


@@ -764,9 +900,8 @@


   @Override


   public List<CodeClassifyVO> listChildrenClassify(String codeClassifyOid, boolean allLevel, String fieldInPath, boolean enable) {


      if(allLevel){


         List<CodeClassify> classifyDOS = codeClassifyMapper.selectAllLevelChildHasPath(codeClassifyOid,fieldInPath);


         List<CodeClassify> classifyDOS = codeClassifyMapper.selectAllLevelChildHasPath(codeClassifyOid,fieldInPath,AuthUtil.getTenantId());


         if(!CollectionUtils.isEmpty(classifyDOS)){


            // 这儿用stream有点慢


            classifyDOS = classifyDOS.parallelStream().filter(s->FRAMEWORK_DATA_ENABLED.equalsIgnoreCase(s.getLcStatus())).collect(Collectors.toList());


         }


         return codeClassifyDO2VOs(classifyDOS);


@@ -868,7 +1003,7 @@


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


         .map(CodeClassifyPO::getCodeRuleId)


         .collect(Collectors.toList());


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


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


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




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


@@ -885,7 +1020,7 @@


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




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


      List<CodeClassify> existClassifyDOs = codeClassifyMapper.selectAllLevelChildHasPath("",null);


      List<CodeClassify> existClassifyDOs = codeClassifyMapper.selectAllLevelChildHasPath("",null,AuthUtil.getTenantId());


      Map<String/**路径**/, CodeClassify/**已经存在的数据**/> pathDOMap = Optional.ofNullable(existClassifyDOs).orElse(new ArrayList<>()).stream().collect(Collectors.toMap(s -> {


         String path = s.getPath();


         if(StringUtils.isNotBlank(path) && path.startsWith("#")){


@@ -1004,8 +1139,10 @@


               classifyDO.setBtmname("codeclassify");


               classifyDO.setLcStatus("Enabled");


               classifyDO.setOwner(String.valueOf(AuthUtil.getUser().getUserId()));


               classifyDO.setCreator(String.valueOf(AuthUtil.getUser().getUserId()));


               classifyDO.setLastModifier(String.valueOf(AuthUtil.getUser().getUserId()));


               // classifyDO.setCreator(String.valueOf(AuthUtil.getUser().getUserId()));


               // classifyDO.setLastModifier(String.valueOf(AuthUtil.getUser().getUserId()));


               classifyDO.setCreator(String.valueOf(AuthUtil.getUser().getAccount()));


               classifyDO.setLastModifier(String.valueOf(AuthUtil.getUser().getAccount()));


               classifyDO.setLastModifyTime(new Date());


               codeClassifyMapper.insert(classifyDO);


            }


@@ -1219,7 +1356,7 @@


         return null;


      }


      List<Tree> treeList = trees.stream().filter(tree -> !CollectionUtils.isEmpty(btmTypeVOS.stream().filter(btmType -> {


               if(Objects.equals(tree.getAttributes().get("id"), btmType.getId())){


               if(Objects.equals(tree.getAttributes().get("btmTypeId"), btmType.getId())){


                  tree.getAttributes().put("btmTypeOid",btmType.getOid());


                  return true;


               }


@@ -1312,4 +1449,6 @@


      return codeClassifyMapper.selectCount(wrapper).intValue();


   }








}