优化考勤计算

attendance-performance-manager/src/main/java/com/mortals/xhx/module/attendance/service/impl/AttendanceRecordHikServiceImpl.java

@@ -159,11 +159,12 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte
         Map<Long, List<AttendanceLeaveRecordEntity>> leaveRecordGroupMap = attendanceLeaveRecordService.find(leaveRecordQuery).parallelStream().collect(Collectors.groupingBy(x -> x.getLeavePersonId()));
 */
         //获取日期
+        List<AttendanceRecordEntity> saveList = new ArrayList<>();
+        List<AttendanceRecordEntity> updateList = new ArrayList<>();
 
         for (Map.Entry<Long, List<AttendanceRecordHikEntity>> itemEntry : listMap.entrySet()) {
             //按人员  todo 改为多线程并行计算
-            List<AttendanceRecordEntity> saveList = new ArrayList<>();
-            List<AttendanceRecordEntity> updateList = new ArrayList<>();
+
             Long staffId = itemEntry.getKey();
             List<AttendanceRecordHikEntity> recordHikEntityList = itemEntry.getValue();
             Map<String, List<AttendanceRecordHikEntity>> dateRecordMap = recordHikEntityList.stream().collect(Collectors.groupingBy(hikEntity -> DateUtil.formatDate(hikEntity.getAttendanceDate())));
@@ -302,24 +303,23 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte
                     }
                 }
             }
-            if (!ObjectUtils.isEmpty(saveList)) {
-                log.info("新增考勤记录数：" + saveList.size());
-                attendanceRecordService.save(saveList);
+        }
+        if (!ObjectUtils.isEmpty(saveList)) {
+            log.info("新增考勤记录数：" + saveList.size());
+            attendanceRecordService.save(saveList);
 /*                for (AttendanceRecordEntity attendanceRecordEntity : saveList) {
                     attendanceRecordService.save(attendanceRecordEntity, context);
                 }*/
-            }
+        }
 
-            if (!ObjectUtils.isEmpty(updateList)) {
-                log.info("更新考勤记录数：" + updateList.size());
-                attendanceRecordService.update(updateList);
+        if (!ObjectUtils.isEmpty(updateList)) {
+            log.info("更新考勤记录数：" + updateList.size());
+            attendanceRecordService.update(updateList);
  /*               for (AttendanceRecordEntity attendanceRecordEntity : updateList) {
                     attendanceRecordService.update(attendanceRecordEntity, context);
                 }*/
-            }
         }
 
-
     }