【8.0】【sys】【menu】更新菜单功能的缓存化

kernel-s-system/system-business-permission/src/main/java/cn/stylefeng/roses/kernel/sys/modular/menu/cache/MenuClearListener.java

@@ -33,4 +33,17 @@ public class MenuClearListener {
         }
     }
 
+    /**
+     * 监听菜单功能的更新
+     *
+     * @author fengshuonan
+     * @since 2023/7/15 0:37
+     */
+    @BusinessListener(businessCode = MenuConstants.MENU_OPTIONS_UPDATE_EVENT)
+    public void updateMenuOptionsCodeCache(Long optionsId) {
+        if (ObjectUtil.isNotEmpty(optionsId)) {
+            menuCodeCache.remove(optionsId.toString());
+        }
+    }
+
 }

kernel-s-system/system-business-permission/src/main/java/cn/stylefeng/roses/kernel/sys/modular/menu/cache/menucode/MenuCodeMemoryCache.java

@@ -6,6 +6,8 @@ import cn.stylefeng.roses.kernel.sys.modular.menu.constants.MenuConstants;
 
 /**
  * 菜单编码的缓存
+ * <p>
+ * 同时用在，菜单功能编码缓存
  *
  * @author fengshuonan
  * @since 2023/7/15 0:08

kernel-s-system/system-business-permission/src/main/java/cn/stylefeng/roses/kernel/sys/modular/menu/cache/menucode/MenuCodeRedisCache.java

@@ -6,6 +6,8 @@ import org.springframework.data.redis.core.RedisTemplate;
 
 /**
  * 菜单编码的缓存
+ * <p>
+ * 同时用在，菜单功能编码缓存
  *
  * @author fengshuonan
  * @since 2023/7/15 0:11

kernel-s-system/system-business-permission/src/main/java/cn/stylefeng/roses/kernel/sys/modular/menu/constants/MenuConstants.java

@@ -18,4 +18,9 @@ public interface MenuConstants {
      */
     String MENU_UPDATE_EVENT = "MENU_UPDATE_EVENT";
 
+    /**
+     * 菜单功能更新的事件
+     */
+    String MENU_OPTIONS_UPDATE_EVENT = "MENU_OPTIONS_UPDATE_EVENT";
+
 }

kernel-s-system/system-business-permission/src/main/java/cn/stylefeng/roses/kernel/sys/modular/menu/service/impl/SysMenuOptionsServiceImpl.java

@@ -3,11 +3,13 @@ package cn.stylefeng.roses.kernel.sys.modular.menu.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.ListUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi;
 import cn.stylefeng.roses.kernel.db.api.factory.PageFactory;
 import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
 import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
 import cn.stylefeng.roses.kernel.rule.exception.base.ServiceException;
 import cn.stylefeng.roses.kernel.sys.api.callback.RemoveMenuCallbackApi;
+import cn.stylefeng.roses.kernel.sys.api.constants.SysConstants;
 import cn.stylefeng.roses.kernel.sys.modular.menu.entity.SysMenuOptions;
 import cn.stylefeng.roses.kernel.sys.modular.menu.enums.SysMenuOptionsExceptionEnum;
 import cn.stylefeng.roses.kernel.sys.modular.menu.factory.MenuOptionsValidateFactory;
@@ -27,7 +29,6 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.stream.Collectors;
 
 /**
  * 菜单下的功能操作业务实现层
@@ -45,6 +46,9 @@ public class SysMenuOptionsServiceImpl extends ServiceImpl<SysMenuOptionsMapper,
     @Resource
     private SysRoleMenuOptionsService sysRoleMenuOptionsService;
 
+    @Resource(name = "menuCodeCache")
+    private CacheOperatorApi<String> menuCodeCache;
+
     @Override
     public void add(SysMenuOptionsRequest sysMenuOptionsRequest) {
 
@@ -111,20 +115,40 @@ public class SysMenuOptionsServiceImpl extends ServiceImpl<SysMenuOptionsMapper,
     @Override
     public List<String> getOptionsCodeList(List<Long> optionsIdList) {
 
+        List<String> result = new ArrayList<>();
+
         if (ObjectUtil.isEmpty(optionsIdList)) {
-            return new ArrayList<>();
+            return result;
         }
 
-        LambdaQueryWrapper<SysMenuOptions> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.in(SysMenuOptions::getMenuOptionId, optionsIdList);
-        queryWrapper.select(SysMenuOptions::getOptionCode);
-        List<SysMenuOptions> sysMenuOptionsList = this.list(queryWrapper);
+        for (Long optionsId : optionsIdList) {
 
-        if (ObjectUtil.isEmpty(sysMenuOptionsList)) {
-            return new ArrayList<>();
+            String optionsIdKey = optionsId.toString();
+
+            // 先从缓存获取是否有对应的编码
+            String cachedCode = menuCodeCache.get(optionsIdKey);
+
+            if (ObjectUtil.isNotEmpty(cachedCode)) {
+                result.add(cachedCode);
+                continue;
+            }
+
+            // 缓存没有，从数据库查询功能的编码
+            LambdaQueryWrapper<SysMenuOptions> queryWrapper = new LambdaQueryWrapper<>();
+            queryWrapper.eq(SysMenuOptions::getMenuOptionId, optionsId);
+            queryWrapper.select(SysMenuOptions::getOptionCode);
+            SysMenuOptions sysMenuOptions = this.getOne(queryWrapper, false);
+
+            if (sysMenuOptions != null) {
+                String optionCodeQueryResult = sysMenuOptions.getOptionCode();
+                result.add(optionCodeQueryResult);
+
+                // 添加到缓存中一份
+                menuCodeCache.put(optionsIdKey, optionCodeQueryResult, SysConstants.DEFAULT_SYS_CACHE_TIMEOUT_SECONDS);
+            }
         }
 
-        return sysMenuOptionsList.stream().map(SysMenuOptions::getOptionCode).collect(Collectors.toList());
+        return result;
     }
 
     @Override