From 8460849733838c9e84d1016c51f5a0e6875d0a78 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期四, 05 六月 2025 20:03:27 +0800
Subject: [PATCH] 增加接口定时任务入口
---
igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1JcService.java | 61 ++++++++++++++++++++
igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/TestV1Scheduled.java | 34 +++++++++++
igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1YwService.java | 66 ++++++++++++++++++++++
3 files changed, 161 insertions(+), 0 deletions(-)
diff --git a/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1JcService.java b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1JcService.java
new file mode 100644
index 0000000..08d0619
--- /dev/null
+++ b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1JcService.java
@@ -0,0 +1,61 @@
+package com.fzzy.igds.dzhwk.v1.timer;
+
+import com.fzzy.igds.dzhwk.v1.ApiV1Server;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.time.DateUtils;
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.Date;
+
+/**
+ * @Description 鍩虹淇℃伅-瀹氭椂鑾峰彇浠诲姟鍏ュ彛锛岄粯璁ゆ瘡澶╄幏鍙栦竴娆�
+ * @Author CZT
+ * @Date 2025/6/5 19:53
+ */
+@Slf4j
+@Service("JobMwJcService")
+public class JobV1JcService {
+
+ @Resource
+ private ApiV1Server apiV1Server;
+
+ /**
+ * 瀹氭椂鑾峰彇涓氬姟淇℃伅
+ *
+ * @param startTimeStr 璧峰鏃堕棿瀛楃涓�
+ */
+ public void timer(String startTimeStr) {
+
+ try {
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇鍩虹淇℃伅======================");
+
+ Date startTime = DateUtils.parseDate(startTimeStr, "yyyy-MM-dd HH:mm:ss");
+ Date endTime = new Date();
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇浠撳偍鍗曚綅鏁版嵁======================");
+ //鑾峰彇浠撳偍鍗曚綅鏁版嵁
+ apiV1Server.pullData("1001", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇搴撳尯鏁版嵁======================");
+ //鑾峰彇搴撳尯鏁版嵁
+ apiV1Server.pullData("1002", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇浠撴埧鏁版嵁======================");
+ //鑾峰彇浠撴埧鏁版嵁
+ apiV1Server.pullData("1003", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇寤掗棿鏁版嵁======================");
+ //鑾峰彇寤掗棿鏁版嵁
+ apiV1Server.pullData("1004", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇璐т綅鏁版嵁======================");
+ //鑾峰彇璐т綅鏁版嵁
+ apiV1Server.pullData("1005", startTime, endTime);
+
+ }catch (Exception e){
+ log.error("瀹氭椂鑾峰彇鍩虹淇℃伅寮傚父", e);
+ }
+
+ }
+
+}
diff --git a/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1YwService.java b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1YwService.java
new file mode 100644
index 0000000..397a261
--- /dev/null
+++ b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1YwService.java
@@ -0,0 +1,66 @@
+package com.fzzy.igds.dzhwk.v1.timer;
+
+import com.fzzy.igds.dzhwk.v1.ApiV1Server;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.time.DateUtils;
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.Date;
+
+/**
+ * @Description 涓氬姟淇℃伅-瀹氭椂鑾峰彇浠诲姟鍏ュ彛锛屾牴鎹紶閫掔殑鍙傛暟
+ * @Author CZT
+ * @Date 2025/6/5 19:53
+ */
+@Slf4j
+@Service("JobMwYwService")
+public class JobV1YwService {
+
+ @Resource
+ private ApiV1Server apiV1Server;
+
+ /**
+ * 瀹氭椂鑾峰彇涓氬姟淇℃伅
+ *
+ * @param num 闂撮殧灏忔椂锛岃礋鏁�
+ */
+ public void timer(Integer num) {
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇涓氬姟淇℃伅======================");
+
+ Date endTime = new Date();
+ Date startTime = DateUtils.addHours(endTime, num);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇绮儏鏁版嵁======================");
+ //鑾峰彇绮儏鏁版嵁
+ apiV1Server.pullData("2001", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇姘斾綋淇℃伅======================");
+ //鑾峰彇姘斾綋淇℃伅
+ apiV1Server.pullData("2002", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂璐ㄦ璁惧淇℃伅======================");
+ //鑾峰彇璐ㄦ淇℃伅
+ apiV1Server.pullData("2003", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇杩涘嚭浠撹褰曚俊鎭�======================");
+ //鑾峰彇杩涘嚭浠撹褰曚俊鎭�
+ apiV1Server.pullData("2004", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇鏈烘閫氶淇℃伅======================");
+ //鑾峰彇鏈烘閫氶淇℃伅
+ apiV1Server.pullData("2005", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇鐔忚捀浣滀笟淇℃伅======================");
+ //鑾峰彇鐔忚捀浣滀笟淇℃伅
+ apiV1Server.pullData("2006", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇璋峰喎浣滀笟淇℃伅======================");
+ //鑾峰彇璋峰喎浣滀笟淇℃伅
+ apiV1Server.pullData("2007", startTime, endTime);
+
+ log.info("===========================绯荤粺瀹氭椂鑾峰彇鍏呮爱姘旇皟淇℃伅======================");
+ //鑾峰彇鍏呮爱姘旇皟淇℃伅
+ apiV1Server.pullData("2008", startTime, endTime);
+ }
+}
diff --git a/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/TestV1Scheduled.java b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/TestV1Scheduled.java
new file mode 100644
index 0000000..7dc915c
--- /dev/null
+++ b/igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/TestV1Scheduled.java
@@ -0,0 +1,34 @@
+package com.fzzy.igds.dzhwk.v1.timer;
+
+import com.fzzy.igds.dzhwk.v1.ApiV1Server;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.time.DateUtils;
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+
+/**
+ * @Description 瀹氭椂娴嬭瘯
+ * @Author CZT
+ * @Date 2025/6/5 19:53
+ */
+@Slf4j
+@Service("TestScheduled")
+public class TestV1Scheduled {
+
+ @Resource
+ private ApiV1Server apiV1Server;
+
+ /**
+ *
+ * @param interfaceId 鎺ュ彛缂栫爜
+ * @param startTime 璧峰鏃堕棿
+ * @param endTime 鎴鏃堕棿
+ * @throws Exception
+ */
+ public void scheduled(String interfaceId, String startTime, String endTime) throws Exception {
+
+ log.info("=====鎵嬪姩鑾峰彇鏁版嵁锛屾帴鍙ｇ紪鐮�={}锛屾椂闂存={}-->{}======", interfaceId, startTime, endTime);
+
+ apiV1Server.pullData(interfaceId, DateUtils.parseDate(startTime, "yyyy-MM-dd HH:mm:ss"), DateUtils.parseDate(endTime, "yyyy-MM-dd HH:mm:ss"));
+ }
+}
--
Gitblit v1.9.3