Source/UBCS/ubcs-service-api/ubcs-omd-api/src/main/java/com/vci/ubcs/omd/cache/BtmTypeCache.java

ÎļþÃû´Ó Source/UBCS/ubcs-service-api/ubcs-omd-api/src/main/java/com/vci/ubcs/omd/cache/OmdBtmTypeCache.java ÐÞ¸Ä
@@ -1,7 +1,7 @@
package com.vci.ubcs.omd.cache;

import com.vci.ubcs.omd.feign.IOmdBtmTypeClient;
import com.vci.ubcs.omd.vo.OmdBtmTypeVO;
import com.vci.ubcs.omd.feign.IBtmTypeClient;
import com.vci.ubcs.omd.vo.BtmTypeVO;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
@@ -18,7 +18,7 @@
 * @author LiHang
 * @date 2023/4/24
 */
public class OmdBtmTypeCache {
public class BtmTypeCache {

   private static final String BTM_DETAIL = "btm:id";

@@ -28,11 +28,11 @@

   private static final String BTM_IDS = "btm:ids";

   private static IOmdBtmTypeClient btmTypeClient;
   private static IBtmTypeClient btmTypeClient;

   private static IOmdBtmTypeClient getBtmTypeClient() {
   private static IBtmTypeClient getBtmTypeClient() {
      if (btmTypeClient == null) {
         btmTypeClient = SpringUtil.getBean(IOmdBtmTypeClient.class);
         btmTypeClient = SpringUtil.getBean(IBtmTypeClient.class);
      }
      return btmTypeClient;
   }
@@ -43,10 +43,10 @@
    * @param oid ä¸»é”®
    * @return ä¸šåŠ¡ç±»åž‹è¯¦æƒ…信息
    */
   public static OmdBtmTypeVO getDetail(String oid){
   public static BtmTypeVO getDetail(String oid){
      String keyPrefix = BTM_DETAIL.concat(StringPool.DASH).concat(AuthUtil.getTenantId()).concat(StringPool.COLON);
      return CacheUtil.get(BTM_TYPE_CACHE, keyPrefix, oid, () -> {
         R<OmdBtmTypeVO> result = getBtmTypeClient().getDetail(oid);
         R<BtmTypeVO> result = getBtmTypeClient().getDetail(oid);
         return result.getData();
      });
   }
@@ -56,10 +56,10 @@
    * @param ids å¯¹è±¡è‹±æ–‡åç§° ä½†æ˜¯ä¸èƒ½è¶…过1000
    * @return ä¸šåŠ¡å¯¹è±¡
    */
   public static List<OmdBtmTypeVO> selectByIdCollection(List<String> ids) {
   public static List<BtmTypeVO> selectByIdCollection(List<String> ids) {
      String  keyPrefix = BTM_IDS.concat(StringPool.DASH).concat(AuthUtil.getTenantId()).concat(StringPool.COLON);
      return CacheUtil.get(BTM_TYPE_CACHE,keyPrefix,Func.toStr(ids), () -> {
         R<List<OmdBtmTypeVO>> result = getBtmTypeClient().selectByIdCollection(ids);
         R<List<BtmTypeVO>> result = getBtmTypeClient().selectByIdCollection(ids);
         return result.getData();
      });
   }
@@ -70,10 +70,10 @@
    * @param pkBtmTypeCollection ä¸šåŠ¡ç±»åž‹ä¸»é”®é›†åˆ
    * @return ä¸šåŠ¡ç±»åž‹åˆ—表，如果有不存在的不会返回，全部不存在的则返回空列表
    */
   public static List<OmdBtmTypeVO> listBtmTypeByOidCollection(Collection<String> pkBtmTypeCollection) {
   public static List<BtmTypeVO> listBtmTypeByOidCollection(Collection<String> pkBtmTypeCollection) {
      String  keyPrefix = BTM_IDS.concat(StringPool.DASH).concat(AuthUtil.getTenantId()).concat(StringPool.COLON);
      return CacheUtil.get(BTM_TYPE_CACHE,keyPrefix,Func.toStr(pkBtmTypeCollection.stream().map(s -> s.substring(0,5))),() ->{
         R<List<OmdBtmTypeVO>> result = getBtmTypeClient().listBtmTypeByOidCollection(pkBtmTypeCollection);
         R<List<BtmTypeVO>> result = getBtmTypeClient().listBtmTypeByOidCollection(pkBtmTypeCollection);
         return result.getData();
      });
   }