From 3a7fd31b5beadda5b3c12450935db9913a52bd92 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期六, 02 三月 2024 11:25:36 +0800
Subject: [PATCH] 有数数据同步及推送
---
src/main/java/com/fzzy/api/timer/SyncDataScheduled.java | 124 +++++++++++++++++++++--------------------
1 files changed, 63 insertions(+), 61 deletions(-)
diff --git a/src/main/java/com/fzzy/api/timer/SyncDataScheduled.java b/src/main/java/com/fzzy/api/timer/SyncDataScheduled.java
index f232f3a..1b5d45f 100644
--- a/src/main/java/com/fzzy/api/timer/SyncDataScheduled.java
+++ b/src/main/java/com/fzzy/api/timer/SyncDataScheduled.java
@@ -36,7 +36,8 @@
* <p>
* 鍥哄畾鏃堕棿锛�0鍒嗛挓鍜�30鍒嗛挓鎵ц
*/
- @Scheduled(cron = "0 0,30 * * * ? ")
+// @Scheduled(cron = "0 0,30 * * * ? ")
+ @Scheduled(cron = "0 * * * * ? ")
public void scheduled() {
log.info("绯荤粺鎵ц瀹氭椂鏁版嵁鍚屾鎿嶄綔<<<<<<<<<<<<<--------");
@@ -72,67 +73,68 @@
Date start = exeDate;
- //鏄惁鎵ц
- boolean isExecute = false;
- boolean isUpdateStart = false;
- //鏍稿澶╂槸鍚﹀尮閰�
- if (conf.getSyncDay99().equals(ApiConfs.TIME_ALL)) {
- isExecute = true;
- } else {
- int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
- if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
- isExecute = true;
+// //鏄惁鎵ц
+// boolean isExecute = false;
+// boolean isUpdateStart = false;
+// //鏍稿澶╂槸鍚﹀尮閰�
+// if (conf.getSyncDay99().equals(ApiConfs.TIME_ALL)) {
+// isExecute = true;
+// } else {
+// int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
+// if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
+// isExecute = true;
+//
+// //寮�濮嬫椂闂存彁鍓�7澶�
+// start = DateUtils.addDays(start, -7);
+// isUpdateStart = true;
+// } else {
+// isExecute = false;
+// }
+// }
+//
+// if (!isExecute) {
+// log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆澶╀笉鍖归厤<<<<<<<<<<<<<-------");
+// return;
+// }
+//
+// //鏍稿鏃堕棿鏄惁鍖归厤
+// if (conf.getSyncHour99().equals(ApiConfs.TIME_ALL)) {
+// isExecute = true;
+// } else {
+// int hourOfDay = ContextUtil.getHourOfDay(exeDate);
+// if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
+// isExecute = true;
+//
+// if (!isUpdateStart) {
+// start = DateUtils.addDays(start, -1);
+// isUpdateStart = true;
+// }
+// } else {
+// isExecute = false;
+// }
+// }
+// if (!isExecute) {
+// log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆灏忔椂涓嶅尮閰�<<<<<<<<<<<<<-------");
+// return;
+// }
+//
+// //鏍稿鏃堕棿鍒嗛挓鏄惁鍖归厤
+// int minute = ContextUtil.getMinuteOfHour(exeDate);
+// if (String.valueOf(minute).equals(conf.getSyncMinute99())) {
+// isExecute = true;
+// if (!isUpdateStart) {
+// start = DateUtils.addHours(start, -1);
+// }
+// } else {
+// isExecute = false;
+// }
+//
+// if (!isExecute) {
+// log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆鍒嗛挓涓嶅尮閰�<<<<<<<<<<<<<-------");
+// return;
+// }
- //寮�濮嬫椂闂存彁鍓�7澶�
- start = DateUtils.addDays(start, -7);
- isUpdateStart = true;
- } else {
- isExecute = false;
- }
- }
-
- if (!isExecute) {
- log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆澶╀笉鍖归厤<<<<<<<<<<<<<-------");
- return;
- }
-
- //鏍稿鏃堕棿鏄惁鍖归厤
- if (conf.getSyncHour99().equals(ApiConfs.TIME_ALL)) {
- isExecute = true;
- } else {
- int hourOfDay = ContextUtil.getHourOfDay(exeDate);
- if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
- isExecute = true;
-
- if (!isUpdateStart) {
- start = DateUtils.addDays(start, -1);
- isUpdateStart = true;
- }
- } else {
- isExecute = false;
- }
- }
- if (!isExecute) {
- log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆灏忔椂涓嶅尮閰�<<<<<<<<<<<<<-------");
- return;
- }
-
- //鏍稿鏃堕棿鍒嗛挓鏄惁鍖归厤
- int minute = ContextUtil.getMinuteOfHour(exeDate);
- if (String.valueOf(minute).equals(conf.getSyncMinute99())) {
- isExecute = true;
- if (!isUpdateStart) {
- start = DateUtils.addHours(start, -1);
- }
- } else {
- isExecute = false;
- }
-
- if (!isExecute) {
- log.debug("涓氬姟鏁版嵁鍚屾---鏃堕棿閰嶇疆鍒嗛挓涓嶅尮閰�<<<<<<<<<<<<<-------");
- return;
- }
-
+ log.debug("涓氬姟鏁版嵁鍚屾---寮�濮嬫煡璇笟鍔℃暟鎹繘琛屽悓姝�<<<<<<<<<<<<<-------");
ApiParam param = new ApiParam();
param.setSyncProtocol(conf.getSyncProtocol());
param.setPushProtocol(conf.getPushProtocol());
--
Gitblit v1.9.3