fix-数据字典-因缓存导致的新增数据不能及时展示

ximatai · Oct 29, 2024 · e350fdb · e350fdb
1 parent 5c600dd
commit e350fdb
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 5 deletions.
diff --git a/...-platform/src/main/java/net/ximatai/muyun/platform/controller/DictCategoryController.java b/...-platform/src/main/java/net/ximatai/muyun/platform/controller/DictCategoryController.java
@@ -42,6 +42,15 @@ public class DictCategoryController extends ScaffoldForPlatform implements ITree
         .expireAfterWrite(1, TimeUnit.MINUTES)
         .build(this::loadCategory);
 
+    @Override
+    protected void afterInit() {
+        super.afterInit();
+        String address = dictController.getDataChangeChannel().getAddress();
+        getEventBus().consumer(address).handler(it -> {
+            categoryCache.invalidateAll();
+        });
+    }
+
     @Override
     public String getMainTable() {
         return "app_dictcategory";
@@ -71,9 +80,6 @@ private List<DictTreeNode> loadCategory(String id) {
     @GET
     @Path("/tree/{id}")
     public List<DictTreeNode> tree(@PathParam("id") String id) {
-        if (getConfig().isTestMode()) {
-            categoryCache.invalidateAll();
-        }
         return categoryCache.get(id);
     }
 
@@ -126,7 +132,9 @@ public Integer sort(String id, String prevId, String nextId, String parentId) {
             if (parentId == null) {
                 parentId = dict.get("id_at_app_dictcategory").toString();
             }
-            return dictController.sort(id, prevId, nextId, parentId);
+            Integer sorted = dictController.sort(id, prevId, nextId, parentId);
+            categoryCache.invalidate(parentId);
+            return sorted;
         }
 
         return 0;

diff --git a/muyun-platform/src/main/java/net/ximatai/muyun/platform/controller/DictController.java b/muyun-platform/src/main/java/net/ximatai/muyun/platform/controller/DictController.java
@@ -2,6 +2,7 @@
 
 import jakarta.enterprise.context.ApplicationScoped;
 import net.ximatai.muyun.ability.IChildAbility;
+import net.ximatai.muyun.ability.IDataBroadcastAbility;
 import net.ximatai.muyun.ability.IReferableAbility;
 import net.ximatai.muyun.ability.ITreeAbility;
 import net.ximatai.muyun.ability.curd.std.IDataCheckAbility;
@@ -23,7 +24,7 @@
 
 //@Path(BASE_PATH + "/dict")
 @ApplicationScoped
-public class DictController extends ScaffoldForPlatform implements ITreeAbility, IChildAbility, IReferableAbility, IDataCheckAbility, IQueryAbility {
+public class DictController extends ScaffoldForPlatform implements ITreeAbility, IChildAbility, IReferableAbility, IDataCheckAbility, IQueryAbility, IDataBroadcastAbility {
 
     @Override
     public String getMainTable() {