bonus
/
gz_att
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

历史考勤推送问题

This commit is contained in:
fl 2024-12-17 16:39:55 +08:00
parent e6b5e8aad4
commit 7257eb68da
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
bonus-modules/bonus-system/src/main/java/com/bonus/system/att/tasks/AttTasks.java
View File

@ -96,6 +96,11 @@ public class AttTasks {
dateList.add("2024-12-01"); dateList.add("2024-12-01");
dateList.add("2024-12-07"); dateList.add("2024-12-07");
dateList.add("2024-12-08"); dateList.add("2024-12-08");
hisAttPush(dateList);
log.info("--------考勤定时器完毕------");
}
private void hisAttPush(List<String> dateList) {
// 创建固定大小的线程池 // 创建固定大小的线程池
ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE); ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE);
// 分批处理日期列表 // 分批处理日期列表
@ -106,7 +111,7 @@ public class AttTasks {
executorService.submit(() -> { executorService.submit(() -> {
for (String date : batch) { for (String date : batch) {
try { try {
// delHisData(date); delHisData(date);
pushAttData(date, 2); pushAttData(date, 2);
} catch (Exception e) { } catch (Exception e) {
// 记录异常并继续处理下一个日期 // 记录异常并继续处理下一个日期
@ -123,9 +128,9 @@ public class AttTasks {
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
log.info("--------考勤定时器完毕------");
} }
private void delHisData(String date) { private void delHisData(String date) {
attSourceDataDao.delHisData(date); attSourceDataDao.delHisData(date);
} }