diff --git a/xm-core/src/main/java/com/xm/core/listener/XmMenuSumParentsListener.java b/xm-core/src/main/java/com/xm/core/listener/XmMenuSumParentsListener.java index 6de5ecab..cd11eb6d 100644 --- a/xm-core/src/main/java/com/xm/core/listener/XmMenuSumParentsListener.java +++ b/xm-core/src/main/java/com/xm/core/listener/XmMenuSumParentsListener.java @@ -44,16 +44,17 @@ public class XmMenuSumParentsListener extends MessageListener { /** * 每隔一段时间更新一次数据库 */ - @Scheduled(cron = "0 0/30 * * * ?") + @Scheduled(cron = "0 */35 * * * ?") public void autoUpdateToDb(){ Map> myMenusAllMap=new HashMap<>(); synchronized (this.menusAllMap){ myMenusAllMap.putAll(this.menusAllMap); + myMenusAllMap.clear(); } if(myMenusAllMap.size()>0){ List menus=new ArrayList<>(); - myMenusAllMap.forEach((projectId,menusMap)->{ + myMenusAllMap.forEach((productId,menusMap)->{ menus.addAll(menusMap.values()); if(menus.size()>100){ new Thread(){ diff --git a/xm-core/src/main/java/com/xm/core/listener/XmTaskSumParentsListener.java b/xm-core/src/main/java/com/xm/core/listener/XmTaskSumParentsListener.java index 1a7ddb0a..f38aea27 100644 --- a/xm-core/src/main/java/com/xm/core/listener/XmTaskSumParentsListener.java +++ b/xm-core/src/main/java/com/xm/core/listener/XmTaskSumParentsListener.java @@ -44,11 +44,12 @@ public class XmTaskSumParentsListener extends MessageListener { /** * 每隔一段时间更新一次数据库 */ - @Scheduled(cron = "0 0/30 * * * ?") + @Scheduled(cron = "0 */25 * * * ?") public void autoUpdateToDb(){ Map> myTasksAllMap=new HashMap<>(); synchronized (this.tasksAllMap){ myTasksAllMap.putAll(this.tasksAllMap); + this.tasksAllMap.clear(); } if(myTasksAllMap.size()>0){