From 08a962d2925baa255207fdf979e6fee794f1773b Mon Sep 17 00:00:00 2001
From: ke <893754509@qq.com>
Date: Fri, 19 Jul 2024 12:25:19 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jtdev' into jtdev
---
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SjztXxlJob.java | 34 +++++++++++++++++++++++++++++++---
1 files changed, 31 insertions(+), 3 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SjztXxlJob.java b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SjztXxlJob.java
index 8cf925f..f11b757 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SjztXxlJob.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SjztXxlJob.java
@@ -1,11 +1,13 @@
package cn.gistack.job.executor.jobhandler;
import cn.gistack.alerts.sms.feign.ISmsRecordClient;
+import cn.gistack.sm.sjztmd.feign.ISjztMdClient;
import cn.gistack.sm.sjztods.feign.ISkxsQkTjClient;
import cn.gistack.sm.sjztods.feign.IXsfsQktjClient;
import cn.gistack.sm.sjztods.vo.SkxsQkTjVO;
import cn.gistack.sm.sjztods.vo.XsfsQktjVO;
import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
@@ -16,6 +18,8 @@
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
/**
* @PROJECT_NAME: skjcmanager
@@ -31,6 +35,9 @@
@Autowired
private ISkxsQkTjClient skxsQkTjClient;
+
+ @Autowired
+ private ISjztMdClient sjztMdClient;
/**
* 大中型水库蓄水量日报
@@ -78,7 +85,28 @@
return ReturnT.SUCCESS;
}
-
-
-
+ /**
+ * 水库降雨量预报
+ */
+ @XxlJob("reservoirRainfallForecastJobHandler")
+ public ReturnT<String> reservoirRainfallForecastJobHandler(String param) throws Exception {
+ XxlJobLogger.log("开始执行水库降雨量预报...");
+ JSONObject jsonParam = JSON.parseObject(param);
+ // 获取 dayIndexList 数组
+ JSONArray dayIndexArray = jsonParam.getJSONArray("dayIndexList");
+ List<String> dayIndexList = new ArrayList<>();
+ if (null != dayIndexArray && !dayIndexArray.isEmpty()) {
+ for (int i = 0; i < dayIndexArray.size(); i++) {
+ dayIndexList.add(dayIndexArray.getString(i));
+ }
+ }
+ if (dayIndexList.isEmpty()) {
+ // dayIndex默认值为0
+ dayIndexList.add("0");
+ }
+ XxlJobLogger.log("dayIndex: " + dayIndexList);
+ sjztMdClient.getReservoirRainfallForecast(dayIndexList);
+ XxlJobLogger.log("结束执行水库降雨量预报任务...");
+ return ReturnT.SUCCESS;
+ }
}
--
Gitblit v1.9.3