From b1a64aab247f89cbd44c50f6356536dafac7b150 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E5=95=B8=E9=9D=9E?= <8153694@qq.com>
Date: Mon, 20 May 2024 16:46:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E6=B1=87?=
=?UTF-8?q?=E6=80=BB=E8=80=83=E5=8B=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../xhx/daemon/task/SyncDoorsEventAfterTaskImpl.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/SyncDoorsEventAfterTaskImpl.java b/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/SyncDoorsEventAfterTaskImpl.java
index 8d1f40cb..a129320a 100644
--- a/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/SyncDoorsEventAfterTaskImpl.java
+++ b/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("缁熻褰撴棩鑰冨嫟");
--
2.24.3