From 752cfe9e640712b3e91fe7054e72481d97c19dde Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E8=A3=95=E8=B4=A2?= <cyc58469@163.com>
Date: Tue, 7 Feb 2023 17:07:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=86=E5=8F=B2=E6=8A=A5=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/xm/core/listener/XmMenuSumParentsListener.java  | 5 +++--
 .../java/com/xm/core/listener/XmTaskSumParentsListener.java  | 3 ++-
 2 files changed, 5 insertions(+), 3 deletions(-)

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<XmMenu> {
     /**
      * 每隔一段时间更新一次数据库
      */
-    @Scheduled(cron = "0 0/30 * * * ?")
+    @Scheduled(cron = "0 */35 * * * ?")
     public void autoUpdateToDb(){
         Map<String,Map<String, XmMenu>> myMenusAllMap=new HashMap<>();
         synchronized (this.menusAllMap){
             myMenusAllMap.putAll(this.menusAllMap);
+            myMenusAllMap.clear();
         }
         if(myMenusAllMap.size()>0){
 
             List<XmMenu> 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<XmTask> {
     /**
      * 每隔一段时间更新一次数据库
      */
-    @Scheduled(cron = "0 0/30 * * * ?")
+    @Scheduled(cron = "0 */25 * * * ?")
     public void autoUpdateToDb(){
        Map<String,Map<String,XmTask>> myTasksAllMap=new HashMap<>();
         synchronized (this.tasksAllMap){
             myTasksAllMap.putAll(this.tasksAllMap);
+            this.tasksAllMap.clear();
         }
         if(myTasksAllMap.size()>0){