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

@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import com.vci.ubcs.code.bo.CodeClassifyFullInfoBO;
@@ -55,6 +56,7 @@
import org.slf4j.LoggerFactory;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.launch.constant.AppConstant;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.DateUtil;
@@ -77,7 +79,6 @@
import java.time.ZonedDateTime;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Supplier;
import java.util.stream.Collectors;

import static com.vci.ubcs.code.constant.FrameWorkLangCodeConstant.DATA_OID_NOT_EXIST;
@@ -138,6 +139,15 @@
    */
   @Autowired
   private FormulaServiceImpl formulaService;


   /**
    *  对omd中提供的feign接口进行调用，以及处理相关逻辑
    */
   @Autowired
   ICodeReferBtmTypeService codeReferBtmTypeService;



   /**
    * 相似项查询规则
@@ -1729,9 +1739,9 @@
            String field = UBCSSqlKeyword.getColumn(key, "_like");
            if (referFieldMap.containsKey(field)) {
               //说明还是参照里面的，我们默认这种情况下都是字符串吧，因为参照的属性不一定用的平台的属性池里的，所以大部分情况下，显示的属性都是字符串吧
               return referFieldMap.get(field) + SPACE + "LIKE" + SPACE + "%" + value + "%)" + SPACE;
               return referFieldMap.get(field) + SPACE + "LIKE" + SPACE + "'%" + value + "%'" + SPACE;
            } else {
               return (field.contains(".") ? "" : "t.") + field + SPACE + "LIKE " + "%" + getStringValueInWhere(field, value, attrVOMap) + "%)" + SPACE;
               return (field.contains(".") ? "" : "t.") + field + SPACE + "LIKE " + "'%" + getStringValueInWhere(field, value, attrVOMap) + "%'" + SPACE;
            }
         } else if (key.endsWith("_notequal")) {
            String field = UBCSSqlKeyword.getColumn(key, "_notequal");
@@ -1849,9 +1859,9 @@
         }else if(key.endsWith("_equal")) {
            String field = UBCSSqlKeyword.getColumn(key, "_equal");
            if (referFieldMap.containsKey(field)) {
               return referFieldMap.get(field) + SPACE + "= " + value + SPACE;
               return referFieldMap.get(field) + SPACE + "= '" + value + "'" + SPACE;
            } else {
               return (field.contains(".") ? "" : "t.") + field + SPACE + "= " + getStringValueInWhere(field, value, attrVOMap) + SPACE;
               return (field.contains(".") ? "" : "t.") + field + SPACE + "= '" + getStringValueInWhere(field, value, attrVOMap) + "'"  + SPACE;
            }
         }else {
            if (referFieldMap.containsKey(key)) {
@@ -1914,7 +1924,7 @@
         }
         if (field.contains(".") && attrVOMap != null && attrVOMap.containsKey(field.split("\\.")[0].toLowerCase(Locale.ROOT))) {
            //是参照
            return "'" + value + "'";
            return value;
         } else {
            return value;
         }
@@ -1938,13 +1948,13 @@
               || VciFieldTypeEnum.VTInteger.equals(fieldTypeEnum)) {
               return value;
            } else {
               return "'" + value + "'";
               return value;
            }
         } else {
            if ((value.startsWith("(") && value.endsWith(")")) || (value.startsWith("'") && value.endsWith("'"))) {
               return value;
            }
            return "'" + value + "'";
            return value;
         }
      }

@@ -3349,52 +3359,33 @@
    * 获取参照的信息
    *
    * @param referConfigVO 参照的配置
    * @param pageHelper    分页的工具
    * @return 列表数据
    */
   @Override
   public DataGrid referDataGrid(UIFormReferVO referConfigVO, PageHelper pageHelper) {
   public Page<BtmTypeVO> referDataGrid(UIFormReferVO referConfigVO, BaseQueryObject baseQueryObject) {
//      checkReferConfig(referConfigVO);
      //使用业务类型查询
      R<BtmTypeVO> allAttributeByBtmId = btmTypeClient.getAllAttributeByBtmId(referConfigVO.getReferType());
      BtmTypeVO btmTypeVO = allAttributeByBtmId.getData();
      if (referConfigVO.getWhere() == null) {
         referConfigVO.setWhere(new HashMap<>());
      }
      /**
       * 加上查询最新版次
       */
      Map<String, String> conditionMap = new HashMap<>();
      conditionMap.put("lastr", "1");
      conditionMap.put("lastv", "1");
      referConfigVO.getWhere().putAll(conditionMap);
      if (VciBaseUtil.containsKeyUnCaseForMap(referConfigVO.getWhere(), VciQueryWrapperForDO.LC_STATUS_FIELD) &&
      baseQueryObject.getConditionMap().put("lastr", "1");
      baseQueryObject.getConditionMap().put("lastv", "1");
      if (VciBaseUtil.containsKeyUnCaseForMap(baseQueryObject.getConditionMap(), VciQueryWrapperForDO.LC_STATUS_FIELD) &&
         BtmTypeLcStatusConstant.FRAME_WORK_LIFE_CYCLE_NAME.equalsIgnoreCase(btmTypeVO.getLifeCycleId())) {
         referConfigVO.getWhere().put(VciQueryWrapperForDO.LC_STATUS_FIELD, FrameworkDataLCStatus.ENABLED.getValue());
         baseQueryObject.getConditionMap().put(VciQueryWrapperForDO.LC_STATUS_FIELD, FrameworkDataLCStatus.ENABLED.getValue());
      }
      if (VciBaseUtil.containsKeyUnCaseForMap(referConfigVO.getWhere(), VciQueryWrapperForDO.LC_STATUS_FIELD) &&
      if (VciBaseUtil.containsKeyUnCaseForMap(baseQueryObject.getConditionMap(), VciQueryWrapperForDO.LC_STATUS_FIELD) &&
         BtmTypeLcStatusConstant.RELEASE_LIFE_CYCLE.equalsIgnoreCase(btmTypeVO.getLifeCycleId())) {
         referConfigVO.getWhere().put(VciQueryWrapperForDO.LC_STATUS_FIELD, CodeDefaultLC.RELEASED.getValue());
         baseQueryObject.getConditionMap().put(VciQueryWrapperForDO.LC_STATUS_FIELD, CodeDefaultLC.RELEASED.getValue());
      }
      BaseQueryObject baseQueryObject = new BaseQueryObject();
      Map<String, String> where = referConfigVO.getWhere();
      where.put("domain", AppConstant.APPLICATION_NAME_CODE);
      baseQueryObject.setConditionMap(where);
      baseQueryObject.setPage(pageHelper.getPage());
      baseQueryObject.setSort(pageHelper.getSort());
      baseQueryObject.setLimit(pageHelper.getLimit());
      baseQueryObject.setOrder(pageHelper.getOrder());
      R<List<BtmTypeVO>> ref = btmTypeClient.getRef(baseQueryObject);
      DataGrid<BtmTypeVO> btmTypeVODataGrid = new DataGrid<>();
      List<BtmTypeVO> data = ref.getData();
      btmTypeVODataGrid.setData(data);
      btmTypeVODataGrid.setCode(ref.getCode());
      btmTypeVODataGrid.setLimit(pageHelper.getLimit());
      btmTypeVODataGrid.setMsg(ref.getMsg());
      btmTypeVODataGrid.setSort(pageHelper.getSort());
      btmTypeVODataGrid.setOrder(pageHelper.getOrder());
      btmTypeVODataGrid.setPage(pageHelper.getPage());
      return btmTypeVODataGrid;
      baseQueryObject.getConditionMap().put("domain", AppConstant.APPLICATION_NAME_CODE);
      R<Page<BtmTypeVO>> refPage = btmTypeClient.getRefPage(baseQueryObject);
      if(refPage.getCode() != 200){
         throw new ServiceException("业务类型feign接口调用错误");
      }
      return refPage.getData();
   }

   /**
@@ -3477,6 +3468,17 @@
   }


   @Override
   public boolean checkUnAttrUnEdit(String attrName) {
      return  (VciQueryWrapperForDO.OID_FIELD.equalsIgnoreCase(attrName)
            ||"ts".equalsIgnoreCase(attrName)
            || "lastmodifier".equalsIgnoreCase(attrName)
            || "lastmodifytime".equalsIgnoreCase(attrName)
            || "createtime".equalsIgnoreCase(attrName)
            || "checkintime".equalsIgnoreCase(attrName)
            ||"checkouttime".equalsIgnoreCase(attrName));
   }

   private String getTableName(String refertype){
      if ("codeclassify".equals(refertype)){
         return "pl_code_classify";