添加定时汇总考勤

attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/SyncDoorsEventAfterTaskImpl.java

@@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSON;
 import com.mortals.framework.common.Rest;
 import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
+import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.service.ITask;
 import com.mortals.framework.service.ITaskExcuteService;
 import com.mortals.framework.util.DateUtils;
@@ -14,6 +15,7 @@ import com.mortals.xhx.base.system.user.model.UserEntity;
 import com.mortals.xhx.common.code.YesNoEnum;
 import com.mortals.xhx.module.attendance.model.AttendanceRecordHikEntity;
 import com.mortals.xhx.module.attendance.model.AttendanceRecordHikQuery;
+import com.mortals.xhx.module.attendance.model.vo.AttendanceSummaryQuery;
 import com.mortals.xhx.module.attendance.service.AttendanceRecordHikService;
 import com.mortals.xhx.module.attendance.service.AttendanceStatService;
 import com.mortals.xhx.module.hik.door.model.req.door.DoorEventReq;
@@ -33,6 +35,8 @@ import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
 
+import static com.mortals.xhx.common.key.RedisKey.KEY_ATTENDANCE_STAT_CACHE;
+
 /**
  * 同步获取下午海康门禁事件
  */
@@ -44,6 +48,8 @@ public class SyncDoorsEventAfterTaskImpl implements ITaskExcuteService {
     private AttendanceRecordHikService recordHikService;
     @Autowired
     private AttendanceStatService attendanceStatService;
+    @Autowired
+    private ICacheService cacheService;
 
     @Value("${hik.host:}")
     protected String hikhost;
@@ -60,6 +66,10 @@ public class SyncDoorsEventAfterTaskImpl implements ITaskExcuteService {
         boolean in = DateUtil.isIn(new Date(), beginDateTime, endDateTime);
         if (in) {
             calculateAttendByDay();
+            AttendanceSummaryQuery query = new AttendanceSummaryQuery();
+            query.setSummaryTimeStart(DateUtil.today());
+            query.setSummaryTimeEnd(DateUtil.today());
+            cacheService.lpush(KEY_ATTENDANCE_STAT_CACHE, query);
         }
         //统计当日
         log.info("统计当日考勤");