Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java

@@ -4,22 +4,22 @@
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.CommonsMapper;
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;
@@ -61,6 +61,7 @@
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;
@@ -105,6 +106,15 @@

   @Resource
   private ICodeKeyAttrRepeatService iCodeKeyattrrepeatService;

   @Resource
   private CodeAllCodeMapper codeAllCodeMapper;

   @Resource
   private CodeSerialValueMapper codeSerialValueMapper;

   @Resource
   private CodeBasicSecMapper codeBasicSecMapper;
   /**
    * 上级节点的属性名称
    */
@@ -207,12 +217,16 @@
      // 不为空就需要该当前分类下所有子分类的isParticipateCheck
      if(!codeClassifies.isEmpty()){
         List<String> oids = codeClassifies.stream().map(CodeClassify::getOid).collect(Collectors.toList());
         updateAttr = codeClassifyMapper.update(
            null,
            Wrappers.<CodeClassify>update()
               .lambda().in(CodeClassify::getOid, oids)
               .set(CodeClassify::getIsParticipateCheck, codeClassifyEntity.getIsParticipateCheck())
         );
         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);

      }

//         //处理数据集成逻辑,成功后执行集成第一步,分类数据特殊处理。只有启用状态的分类才推送
@@ -678,6 +692,52 @@
      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("操作成功！");
   }

   /***
    * 根据分类描述备注和库节点查询分类信息
    * @param desc