1

fhKeeper/formulahousekeeper/management-platform/src/main/java/com/management/platform/task/TimingTask.java

@@ -1711,8 +1711,8 @@ public class TimingTask {
 //            if(projectPlanSapSyncLogs.size()>0){
 //                sapSyncLogService.saveBatch(projectPlanSapSyncLogs);
 //            }
-            Map<String, List<Map<String, Object>>> listGroupEmployeeID = pushProjectPlanHour.stream().collect(Collectors.groupingBy(r -> String.valueOf(r.get("EmployeeID"))));
-            List<String> employeeIDList = pushProjectPlanHour.stream().map(r -> String.valueOf(r.get("EmployeeID"))).distinct().collect(Collectors.toList());
+            Map<String, List<Map<String, Object>>> listGroupEmployeeID = mapList.stream().collect(Collectors.groupingBy(r -> String.valueOf(r.get("EmployeeID"))));
+            List<String> employeeIDList = mapList.stream().map(r -> String.valueOf(r.get("EmployeeID"))).distinct().collect(Collectors.toList());
             //按照人员集合长度来创建多个个线程来处理
             int threadNum = employeeIDList.size();
             //多加一个作为预算工时推送