From 2b32f3b7e35272a584ecbbb91b7509ba20f837fa Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期五, 08 十一月 2024 16:51:35 +0800
Subject: [PATCH] 11
---
src/main/java/com/yssh/config/ScheduleConfig.java | 17 ++++++++++++++---
1 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/yssh/config/ScheduleConfig.java b/src/main/java/com/yssh/config/ScheduleConfig.java
index 31fd4fc..a042af4 100644
--- a/src/main/java/com/yssh/config/ScheduleConfig.java
+++ b/src/main/java/com/yssh/config/ScheduleConfig.java
@@ -58,22 +58,32 @@
@Value("${email.enable}")
private Boolean enableEmail;
+ private static boolean flag = false;
+
+ private static final Object OBJ = new Object();
+
private final static List<String> md5List = new ArrayList<>();
private final static SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHH");
public void corpReserveDataSync() {
- loadVocSync();
+ //loadVocSync();
loadCsvSync();
}
@Scheduled(cron = "${csv.cron}")
private void loadCsvSync() {
+ synchronized (OBJ) {
+ if (flag) return;
+ flag = true;
+ }
+
logger.info("***************** 寮�濮嬫墽琛孋SV鍏ュ簱 *****************" + "\n");
Calendar calendar = getCalendar(1);
+ calendar.add(Calendar.HOUR, -cronMax);
for (int i = 0; i < cronMax; i++) {
try {
- calendar.add(Calendar.HOUR, -1);
+ calendar.add(Calendar.HOUR, 1);
String time = format.format(calendar.getTime());
String filePath = csvFilePathConfig.getFilePath() + File.separator + time + ".csv";
@@ -102,6 +112,7 @@
}
}
logger.info("***************** CSV鍏ュ簱鎵ц瀹屾垚 *****************" + "\n");
+ flag = false;
}
public Calendar getCalendar(int start) {
@@ -243,7 +254,7 @@
}
}
- @Scheduled(cron = "${email.times}")
+ //@Scheduled(cron = "${email.times}")
public void autoCalcData() {
if (enableEmail) {
//System.out.println("${email.times}");
--
Gitblit v1.9.3