历史报表

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(){

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){