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; + } +}