From c134d6137dff1d4533b12a07f85e44a1d7d57362 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 24 Apr 2025 23:03:55 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/utils/task/stock/StockTask.java | 20 ++++++++++++--------
1 files changed, 12 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/nq/utils/task/stock/StockTask.java b/src/main/java/com/nq/utils/task/stock/StockTask.java
index f7787b7..c076153 100644
--- a/src/main/java/com/nq/utils/task/stock/StockTask.java
+++ b/src/main/java/com/nq/utils/task/stock/StockTask.java
@@ -88,7 +88,7 @@
//原油
private static final String crude_oil_API_URL = "http://47.112.169.122/fOption_curr.action?username=Qq112233&password=3ce25a66d5b3a8cd661024fea6c79388&id=@CL0W";
- @Scheduled(cron = "0/10 * * * * ?") // 每6秒执行一次
+ @Scheduled(cron = "0/6 * * * * ?") // 每6秒执行一次
public void gold() {
try {
// 使用RestTemplate发起HTTP请求
@@ -96,7 +96,7 @@
String response = restTemplate.getForObject(gold_API_URL, String.class);
// 解析返回的CSV格式数据，去除可能存在的换行符
- if (response != null) {
+ if (response != null && !response.contains("参数错误")) {
// 清除换行符并按逗号分割数据
String[] parts = response.trim().split(",");
String price = parts[2].trim(); // "3348.4"
@@ -113,7 +113,7 @@
}
}
- @Scheduled(cron = "0/15 * * * * ?") // 每6秒执行一次
+ @Scheduled(cron = "0/7 * * * * ?") // 每6秒执行一次
public void crudeOil() {
try {
// 使用RestTemplate发起HTTP请求
@@ -121,7 +121,7 @@
String response = restTemplate.getForObject(crude_oil_API_URL, String.class);
// 解析返回的CSV格式数据，去除可能存在的换行符
- if (response != null) {
+ if (response != null && !response.contains("参数错误")) {
// 清除换行符并按逗号分割数据
String[] parts = response.trim().split(",");
String price = parts[2].trim(); // "3348.4"
@@ -151,11 +151,15 @@
String[] arr = {"d", "w", "m", "1", "5", "30"};
for (String str : arr) {
String g = restTemplate.getForObject(k_gold_API_URL+str, String.class);
- RedisShardedPoolUtils.set("k_gold_"+str, g);
- Thread.sleep(6000);
+ if(!g.contains("参数错误")){
+ RedisShardedPoolUtils.set("k_gold_"+str, g);
+ Thread.sleep(10000);
+ }
String c = restTemplate.getForObject(k_crude_oil_API_URL+str, String.class);
- RedisShardedPoolUtils.set("k_crude_oil_"+str, c);
- Thread.sleep(6000);
+ if(!c.contains("参数错误")){
+ RedisShardedPoolUtils.set("k_crude_oil_"+str, c);
+ Thread.sleep(10000);
+ }
}
}
/**
--
Gitblit v1.9.3