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

@@ -1,9 +1,11 @@
package com.vci.ubcs.code.applyjtcodeservice.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.vci.ubcs.code.applyjtcodeservice.vo.GroupAttrPoolMappingVO;
import com.vci.ubcs.code.entity.CodeClassify;
import com.vci.ubcs.code.feign.ICodeClassifyClient;
import com.vci.ubcs.code.applyjtcodeservice.entity.*;
@@ -18,16 +20,16 @@
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import com.vci.ubcs.code.applyjtcodeservice.vo.DockingPreAttrMappingVO;
import com.vci.ubcs.code.applyjtcodeservice.vo.DockingPreAttrRangeVO;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.core.tool.utils.Func;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;

/***
@@ -36,6 +38,7 @@
 * @date 2023-05-22
 */
@Service
@Slf4j
public class DockingPreAttrMappingServiceImpl extends ServiceImpl<DockingPreAttrMappingMapper, DockingPreAttrMapping> implements IDockingPreAttrMappingService {

   /***
@@ -43,6 +46,7 @@
    */
   @Autowired(required = false)
   private DockingPreAttrMappingMapper dockingPreAttrMappingMapper;

   /***
    * 主数据分类服务
    */
@@ -60,18 +64,17 @@
    */
   @Autowired(required = false)
   private IDockingPreMetaAttrService dockingPreMetaAttrService;

   /***
    * 属性取值范围服务
    */
   @Autowired(required = false)
   private IDockingPreAttrRangeService dockingPreAttrRangeService;


   /***
    * 集团分类视图模型服务
    */
   @Autowired(required = false)

   private IDockingPreViewModelService dockingPreViewModelService;

   /***
@@ -92,7 +95,7 @@
      VciBaseUtil.alertNotNull(sourceClassifyId,"集团分类主键");
      //首先获取分类模板属性，然后与属性配置坐比较，以防被有增删属性的可能
      DockingPreClassify dockingPreClassify=dockingPreClassifyService.getById(sourceClassifyId);
      List<DockingPreMetaAttr> dockingPreMetaAttrList=   dockingPreMetaAttrService.selectByWrapper(Wrappers.<DockingPreMetaAttr>query().lambda().eq(DockingPreMetaAttr::getSourceClassifyId,sourceClassifyId));
      List<DockingPreMetaAttr> dockingPreMetaAttrList = dockingPreMetaAttrService.selectByWrapper(Wrappers.<DockingPreMetaAttr>query().lambda().eq(DockingPreMetaAttr::getSourceClassifyId,sourceClassifyId));
      List<DockingPreAttrMapping> dockingPreAttrMappings=this.selectByWrapper(Wrappers.<DockingPreAttrMapping>query().lambda().eq(DockingPreAttrMapping::getSourceClassifyId, sourceClassifyId).eq(DockingPreAttrMapping::getTargetClassifyId, codeClassifyId));
      Map<String/**属性主键**/, DockingPreAttrMapping> dockingPreAttrMappingMap = dockingPreAttrMappings.stream().filter(cbo -> cbo != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getMetaListId(), t -> t));
      List<DockingPreViewModel> dockingPreViewModelList= dockingPreViewModelService.list(Wrappers.<DockingPreViewModel>query().lambda().eq(DockingPreViewModel::getSourceClassifyId,sourceClassifyId));
@@ -103,10 +106,10 @@
         String attrOid=dockingPreMetaAttr.getOid();
         DockingPreAttrMapping dockingPreAttrMapping=new DockingPreAttrMapping();
         if(dockingPreAttrMappingMap.containsKey(attrOid)){
            dockingPreAttrMapping=   dockingPreAttrMappingMap.get(attrOid);
            DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreAttrMapping,null);
            dockingPreAttrMapping = dockingPreAttrMappingMap.get(attrOid);
            DefaultAttrAssimtUtil.updateDefaultAttrAssimt(dockingPreAttrMapping);
         }else{
            DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreAttrMapping, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM,null);
            DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingPreAttrMapping, MdmBtmTypeConstant.DOCKING_PRE_JAPPLYFORM);
            dockingPreAttrMapping.setMetaListId(dockingPreMetaAttr.getOid());//属性主键
            dockingPreAttrMapping.setSourceAttrKey(dockingPreMetaAttr.getEnglishName());//英文名称
            dockingPreAttrMapping.setSourceAttrName(dockingPreMetaAttr.getChineseName());//中文名称
@@ -153,7 +156,7 @@
       * 1.传递过来的有可能主数据模板新增属性，这样的需要添加，也有可能删除的属性，这样的映射需要删除
       * 也有更新的这样则更新
       */
      List<DockingPreAttrMapping> newDockingPreAttrMapping=new ArrayList<>();
      List<DockingPreAttrMapping> newDockingPreAttrMapping = new ArrayList<>();
      List<String>appingConfigOidList=new ArrayList<>();
      List<String>attrIdList=new ArrayList<>();
      List<String> attributeOidList=new ArrayList<>();
@@ -236,7 +239,6 @@
      return null;
   }


   /***
    * 对象转换
    * @param dockingPreAttrMappings
@@ -257,4 +259,43 @@
         return dockingPreAttrMappingVOList;
      }

   /**
    * 集团属性池映射数据同步导集团属性映射界面
    * @param groupAttrPoolMappings
    * @return
    */
   @Override
   public R syncGroupAttrMapping(List<GroupAttrPoolMapping> groupAttrPoolMappings) {
      log.info("开始集团属性池同步到集团属性映射配置表");
      List<String> groupAttrKeys = groupAttrPoolMappings.stream().map(GroupAttrPoolMapping::getGroupAttrKey).collect(Collectors.toList());
      List<DockingPreAttrMapping> dockingPreAttrMappings = dockingPreAttrMappingMapper.selectList(
         Wrappers.<DockingPreAttrMapping>query()
            .lambda().in(DockingPreAttrMapping::getSourceAttrKey,groupAttrKeys)
      );
      // 属性映射配置表中不存在要同步的集团属性
      if(Func.isEmpty(dockingPreAttrMappings)){
         return R.fail(String.format("要同步的%s属性，在集团属性映射表中不存在！", JSON.toJSONString(groupAttrKeys)));
      }
      log.info(String.format("这些%s集团属性正在往集团属性映射表中同步。",JSON.toJSONString(groupAttrPoolMappings)));
      Map<String, GroupAttrPoolMapping> syncTargetMap = new HashMap<>();
      // 准备要修改的比对参数
      groupAttrPoolMappings.stream().forEach(item->{
         syncTargetMap.put((item.getGroupAttrKey()+item.getGroupAttrName()).toLowerCase(Locale.ROOT),item);
      });
      List<DockingPreAttrMapping> newGroupAttrPoolMappings = new ArrayList<>();
      //查找到更改就改变查询出来的数据进行修改。
      dockingPreAttrMappings.stream().forEach(item->{
         GroupAttrPoolMapping groupAttrPoolMapping = syncTargetMap.get((item.getSourceAttrKey()+item.getSourceAttrName()).toLowerCase(Locale.ROOT));
         if(Func.isNotEmpty(groupAttrPoolMapping)){
            DockingPreAttrMapping dockingPreAttrMapping = BeanUtil.copy(item, DockingPreAttrMapping.class);
            dockingPreAttrMapping.setTargetAttrKey(groupAttrPoolMapping.getCodeMetaAttrKey());
            dockingPreAttrMapping.setTargetAttrName(groupAttrPoolMapping.getCodeMetaAttrName());
            newGroupAttrPoolMappings.add(dockingPreAttrMapping);
         }
      });
      boolean resBoolean = this.saveOrUpdateBatch(newGroupAttrPoolMappings);
      log.info("集团属性池同步到集团属性映射配置表完成！");
      return resBoolean ? R.success("集团属性池同步到集团属性映射配置表成功！"):R.fail("同步过程中，修改集团属性映射表时失败！");
   }

}