Browse Source

批量计算任务汇总数据及菜单汇总数据

master
陈裕财 4 years ago
parent
commit
8977d0fbec
  1. 8
      xm-core/src/main/java/com/xm/core/service/XmMenuService.java
  2. 10
      xm-core/src/main/java/com/xm/core/service/XmTaskService.java

8
xm-core/src/main/java/com/xm/core/service/XmMenuService.java

@ -370,16 +370,15 @@ public class XmMenuService extends BaseService {
Set<String> set=list.get(i); Set<String> set=list.get(i);
set.add(pidPathss[i]); set.add(pidPathss[i]);
} }
}
if(list.size()<=0){ if(list.size()<=0){
return; return;
} }
Set<String> allSet=new HashSet<>();
for (int i = list.size() - 1; i >= 0; i--) { for (int i = list.size() - 1; i >= 0; i--) {
Set<String> set=list.get(i); Set<String> set=list.get(i);
if(set.size()>0){ if(set.size()>0){
List<String> ids=set.stream().filter(k->!allSet.contains(k)).collect(Collectors.toList());
List<String> ids=set.stream().collect(Collectors.toList());
if(ids.size()>0){ if(ids.size()>0){
allSet.addAll(ids.stream().collect(Collectors.toSet()));
super.update("batchSumParents", ids); super.update("batchSumParents", ids);
} }
@ -387,9 +386,6 @@ public class XmMenuService extends BaseService {
} }
}
} }
public List<Map<String,Object>> getXmMenuAttDist(Map<String, Object> xmMenu) { public List<Map<String,Object>> getXmMenuAttDist(Map<String, Object> xmMenu) {

10
xm-core/src/main/java/com/xm/core/service/XmTaskService.java

@ -604,26 +604,22 @@ public class XmTaskService extends BaseService {
Set<String> set=list.get(i); Set<String> set=list.get(i);
set.add(pidPathss[i]); set.add(pidPathss[i]);
} }
}
if(list.size()<=0){ if(list.size()<=0){
return; return;
} }
Set<String> allSet=new HashSet<>();
for (int i = list.size() - 1; i >= 0; i--) { for (int i = list.size() - 1; i >= 0; i--) {
Set<String> set=list.get(i); Set<String> set=list.get(i);
if(set.size()>0){ if(set.size()>0){
List<String> ids=set.stream().filter(k->!allSet.contains(k)).collect(Collectors.toList());
List<String> ids=set.stream().collect(Collectors.toList());
if(ids.size()>0){ if(ids.size()>0){
allSet.addAll(ids.stream().collect(Collectors.toSet()));
super.update("batchSumParents", ids); super.update("batchSumParents", ids);
} }
} }
} }
}
} }

Loading…
Cancel
Save