From 61905638f3be061aeaa5a8ef0b032a4c4a4d494c Mon Sep 17 00:00:00 2001
From: yulin <240160934@qq.com>
Date: Wed, 13 Mar 2024 09:46:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=88=B7=E6=96=B0=E7=BC=93=E5=AD=98=20=E5=9B=A0?=
 =?UTF-8?q?=E4=B8=BA=E8=AF=A5=E9=A1=B9=E7=9B=AE=E9=83=A8=E7=BD=B2=E4=BA=86?=
 =?UTF-8?q?=E4=B8=A4=E4=B8=AA=E6=9C=8D=E5=8A=A1=20=E5=AF=BC=E8=87=B4?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=B8=8D=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../biz/mztb/web/controller/MztbController.java    | 18 ++++++++++-----
 .../smtweb/biz/mztb/web/task/FlushRedisTask.java   | 26 ++++++++++++++++++++++
 2 files changed, 38 insertions(+), 6 deletions(-)
 create mode 100644 mztb/src/main/java/cc/smtweb/biz/mztb/web/task/FlushRedisTask.java

diff --git a/mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java b/mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java
index 4c4a1a8..dce6834 100644
--- a/mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java
+++ b/mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java
@@ -203,12 +203,18 @@ public class MztbController {
                         + " SET srg_party_id = CONCAT(srg_party_id,',' ,'" + String.join(",", ptIdList) + "') where srg_id = ? ", 927515588790587392L); // 角色组填报员
             }
             // 将机构、用户信息放入缓存,或者刷新缓存
-            PartyCache.getInstance().putList(sysPartyList);
-            UserCache.getInstance().putList(userList);
-            UserPartyCache.getInstance().putList(userPartyList);
-            DeptCache.getInstance().putList(deptList);
-            UserRoleCache.getInstance().putList(userRoleList);
-            UserStatuCache.getInstance().putList(userStatuList);
+//            PartyCache.getInstance().putList(sysPartyList);
+            PartyCache.getInstance().refresh();
+//            UserCache.getInstance().putList(userList);
+            UserCache.getInstance().refresh();
+//            UserPartyCache.getInstance().putList(userPartyList);
+            UserPartyCache.getInstance().refresh();
+//            DeptCache.getInstance().putList(deptList);
+            DeptCache.getInstance().refresh();
+//            UserRoleCache.getInstance().putList(userRoleList);
+            UserRoleCache.getInstance().refresh();
+//            UserStatuCache.getInstance().putList(userStatuList);
+            UserStatuCache.getInstance().refresh();
             RoleGroupCache.getInstance().refresh();
             log.debug("机构缓存刷新完成！");
         });
diff --git a/mztb/src/main/java/cc/smtweb/biz/mztb/web/task/FlushRedisTask.java b/mztb/src/main/java/cc/smtweb/biz/mztb/web/task/FlushRedisTask.java
new file mode 100644
index 0000000..a3efa0e
--- /dev/null
+++ b/mztb/src/main/java/cc/smtweb/biz/mztb/web/task/FlushRedisTask.java
@@ -0,0 +1,26 @@
+package cc.smtweb.biz.mztb.web.task;
+
+import cc.smtweb.system.bpm.util.UtilLogger;
+import cc.smtweb.system.bpm.web.sys.base.job.BaseJob;
+import cc.smtweb.system.bpm.web.sys.user.dept.DeptCache;
+import cc.smtweb.system.bpm.web.sys.user.party.PartyCache;
+import cc.smtweb.system.bpm.web.sys.user.role.group.RoleGroupCache;
+import cc.smtweb.system.bpm.web.sys.user.user.UserCache;
+import cc.smtweb.system.bpm.web.sys.user.user.UserPartyCache;
+import cc.smtweb.system.bpm.web.sys.user.user.UserRoleCache;
+import cc.smtweb.system.bpm.web.sys.user.user.UserStatuCache;
+
+public class FlushRedisTask extends BaseJob {
+    @Override
+    protected String work() {
+        PartyCache.getInstance().refresh();
+        UserCache.getInstance().refresh();
+        UserPartyCache.getInstance().refresh();
+        DeptCache.getInstance().refresh();
+        UserRoleCache.getInstance().refresh();
+        UserStatuCache.getInstance().refresh();
+        RoleGroupCache.getInstance().refresh();
+        UtilLogger.info("定时任务刷新缓存完成。。");
+        return null;
+    }
+}