From ed83fdced0b1ce7a4476c32673b9349a2595d59b Mon Sep 17 00:00:00 2001
From: tjx <t2856754968@163.com>
Date: 星期三, 24 十二月 2025 18:47:14 +0800
Subject: [PATCH] 获取设备打卡数据
---
src/main/java/com/gs/dingtalk/task/ScheduledTasks.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 56 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/gs/dingtalk/task/ScheduledTasks.java b/src/main/java/com/gs/dingtalk/task/ScheduledTasks.java
index 0da632c..170e661 100644
--- a/src/main/java/com/gs/dingtalk/task/ScheduledTasks.java
+++ b/src/main/java/com/gs/dingtalk/task/ScheduledTasks.java
@@ -1,6 +1,8 @@
package com.gs.dingtalk.task;
+import com.gs.dingtalk.service.QwCheckinDayDataService;
+import com.gs.dingtalk.service.QwHardwareCheckinDataService;
import com.gs.dingtalk.service.SendDingtalkService;
import com.gs.dingtalk.service.VwCjScSjTsBbService;
import lombok.RequiredArgsConstructor;
@@ -20,7 +22,15 @@
private final VwCjScSjTsBbService vwCjScSjTsBbService;
+ private final QwCheckinDayDataService qwCheckinDayDataService;
+
+ private final QwHardwareCheckinDataService qwHardwareCheckinDataService;
+
private final AtomicBoolean exportTaskRunning = new AtomicBoolean(false);
+
+ private final AtomicBoolean checkinDayDataTaskRunning = new AtomicBoolean(false);
+
+ private final AtomicBoolean hardwareCheckinTaskRunning = new AtomicBoolean(false);
// /**
// * 姣忎袱鍒嗛挓鎵ц涓�娆�
@@ -88,4 +98,50 @@
exportTaskRunning.set(false);
}
}
+
+ /**
+ * 姣忓ぉ鏃╀笂7:30鎵ц
+ * 鍚屾鍓嶄竴澶╃殑浼佷笟寰俊鎵撳崱鏃ユ姤鏁版嵁鍒版暟鎹簱
+ */
+ @Async("taskExecutor")
+ @Scheduled(cron = "0 30 7 * * ?")
+ public void syncCheckinDayDataTask() {
+ if (!checkinDayDataTaskRunning.compareAndSet(false, true)) {
+ log.warn("鎵撳崱鏃ユ姤鏁版嵁鍚屾浠诲姟姝ｅ湪鎵ц涓紝璺宠繃鏈鎵ц");
+ return;
+ }
+
+ try {
+ log.info("寮�濮嬫墽琛屾墦鍗℃棩鎶ユ暟鎹悓姝ヤ换鍔★紙鍚屾鏄ㄥぉ鏁版嵁锛�");
+ int insertCount = qwCheckinDayDataService.syncYesterdayDayData();
+ log.info("鎵撳崱鏃ユ姤鏁版嵁鍚屾浠诲姟鎵ц鎴愬姛锛屾柊澧炶褰曟暟: {}", insertCount);
+ } catch (Exception e) {
+ log.error("鎵撳崱鏃ユ姤鏁版嵁鍚屾浠诲姟鎵ц寮傚父", e);
+ } finally {
+ checkinDayDataTaskRunning.set(false);
+ }
+ }
+
+ /**
+ * 姣忓ぉ鏃╀笂7:35鎵ц锛堢◢鏅氫簬鎵撳崱鏃ユ姤鍚屾浠诲姟锛�
+ * 鍚屾鍓嶄竴澶╃殑浼佷笟寰俊璁惧鎵撳崱鏁版嵁鍒版暟鎹簱
+ */
+ @Async("taskExecutor")
+ @Scheduled(cron = "0 35 7 * * ?")
+ public void syncHardwareCheckinDataTask() {
+ if (!hardwareCheckinTaskRunning.compareAndSet(false, true)) {
+ log.warn("璁惧鎵撳崱鏁版嵁鍚屾浠诲姟姝ｅ湪鎵ц涓紝璺宠繃鏈鎵ц");
+ return;
+ }
+
+ try {
+ log.info("寮�濮嬫墽琛岃澶囨墦鍗℃暟鎹悓姝ヤ换鍔★紙鍚屾鏄ㄥぉ鏁版嵁锛�");
+ int insertCount = qwHardwareCheckinDataService.syncYesterdayHardwareData();
+ log.info("璁惧鎵撳崱鏁版嵁鍚屾浠诲姟鎵ц鎴愬姛锛屾柊澧炶褰曟暟: {}", insertCount);
+ } catch (Exception e) {
+ log.error("璁惧鎵撳崱鏁版嵁鍚屾浠诲姟鎵ц寮傚父", e);
+ } finally {
+ hardwareCheckinTaskRunning.set(false);
+ }
+ }
}
--
Gitblit v1.9.3