From 5a7cfb9266c7e03ccee44811b0fba1d4aceae6fd Mon Sep 17 00:00:00 2001
From: 许鹏程 <1821349743@qq.com>
Date: 星期日, 12 五月 2024 22:39:25 +0800
Subject: [PATCH] 123
---
product-server-data-center/src/main/java/com/product/data/center/service/CommonService.java | 2 ++
product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java | 11 +++++++++++
product-server-data-center/src/main/java/com/product/data/center/service/DataCollectService.java | 19 +++++++++++++++++++
3 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/product-server-data-center/src/main/java/com/product/data/center/service/CommonService.java b/product-server-data-center/src/main/java/com/product/data/center/service/CommonService.java
index 97a6007..1eccf84 100644
--- a/product-server-data-center/src/main/java/com/product/data/center/service/CommonService.java
+++ b/product-server-data-center/src/main/java/com/product/data/center/service/CommonService.java
@@ -232,6 +232,8 @@
// } while (fs != null && fs.getInteger("del_count") != null && fs.getInteger("del_count") > 0);
} catch (Exception e) {
e.printStackTrace();
+ SpringMVCContextHolder.getSystemLogger().error("鍒犻櫎閲囬泦鎻愬彇鏃ュ織閿欒锛侊紒锛侊細" + e.getMessage());
+ SpringMVCContextHolder.getSystemLogger().error(e);
throw e;
}
}
diff --git a/product-server-data-center/src/main/java/com/product/data/center/service/DataCollectService.java b/product-server-data-center/src/main/java/com/product/data/center/service/DataCollectService.java
index 815c7c4..fe629a8 100644
--- a/product-server-data-center/src/main/java/com/product/data/center/service/DataCollectService.java
+++ b/product-server-data-center/src/main/java/com/product/data/center/service/DataCollectService.java
@@ -53,6 +53,14 @@
// 閲囬泦鏈�澶ф壒娆�
public static final long COLLECT_MAX_BATCH_COUNT = 100L;
+ public static void main(String[] args) {
+ Calendar calendar = Calendar.getInstance();
+ int hour = calendar.get(Calendar.HOUR_OF_DAY);
+ int minute = calendar.get(Calendar.MINUTE);
+ if (hour == 1 && minute == 10) {
+ System.out.println("2222222");
+ }
+ }
/**
* 鏁版嵁閲囬泦-瀹氭椂浠诲姟鎵ц鏂规硶
*
@@ -60,6 +68,17 @@
*/
public void dataCollect(String uuid) {
synchronized (uuid.intern()) {
+ //鍑屾櫒1鐐�10鍒嗗紑濮嬭繘鍏ユ鏂规硶鐨勪紤鐪犲埌1鐐�20鍒�
+ Calendar calendar = Calendar.getInstance();
+ int hour = calendar.get(Calendar.HOUR_OF_DAY);
+ int minute = calendar.get(Calendar.MINUTE);
+ if (hour == 1 && minute == 10) {
+ try {
+ Thread.sleep(600000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
Calendar startCalendar = Calendar.getInstance();
Date preExecuteTime = null;
Date curExecuteTime = startCalendar.getTime();
diff --git a/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java b/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
index 31c710e..b2a2997 100644
--- a/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
+++ b/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
@@ -363,6 +363,17 @@
WriteExtractUtil.append("宸叉湁浠诲姟鍦ㄨ繍琛岃烦杩囨娆¤繍琛岋紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒:::" + uuid);
return;
}
+ //鍑屾櫒1鐐�10鍒嗗紑濮嬭繘鍏ユ鏂规硶鐨勪紤鐪犲埌1鐐�20鍒�
+ Calendar calendar = Calendar.getInstance();
+ int hour = calendar.get(Calendar.HOUR_OF_DAY);
+ int minute = calendar.get(Calendar.MINUTE);
+ if (hour == 1 && minute == 10) {
+ try {
+ Thread.sleep(600000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
WriteExtractUtil.append("寮�濮嬫彁鍙栵紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒:::" + uuid);
TimeInterval tempTestTimer = DateUtil.timer();
WriteExtractUtil.append("鎻愬彇-绛夊緟鑰楁椂锛�" + tempTestTimer.intervalMs() + ",:::" + uuid);
--
Gitblit v1.9.2