From 0809888de619c8ec10f6df0e28d5b27689fabe08 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 29 Sep 2025 10:01:55 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/utils/task/stock/StockTask.java | 40 ++++++++++++++++++++++++----------------
1 files changed, 24 insertions(+), 16 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 34f54af..3febc4c 100644
--- a/src/main/java/com/nq/utils/task/stock/StockTask.java
+++ b/src/main/java/com/nq/utils/task/stock/StockTask.java
@@ -1,10 +1,12 @@
package com.nq.utils.task.stock;
import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.nq.Repository.StockRepository;
+import com.nq.dao.StockConfigMapper;
import com.nq.dao.StockMapper;
import com.nq.dao.UserPositionMapper;
import com.nq.enums.EConfigKey;
@@ -65,22 +67,14 @@
@Autowired
private ExchangeRateService exchangeRateService;
+ @Autowired
+ StockConfigMapper stockConfigMapper;
+
/**
* test
*/
- //@Scheduled(cron = "0 0/1 * * * ?")
- @Scheduled(cron = "*/5 * * * * *")
- public void test() {
- /*ExchangeRate model = new ExchangeRate();
- model.setCurrency("MXN");
- model.setConversionCurrency("USD");
- model.setRata(BigDecimal.valueOf(0.0520));
- exchangeRateService.updateRate(model,null);*/
-
- //iStockService.getStockByType(1, 20, "desc","st" , "US", null);
- //istockService.getIndicesList("US");
- //istockService.getIndicesAndKData("15882", "US");
- }
+ //@Scheduled(cron = "*/5 * * * * *")
+ public void test() {}
/**
* 同步系统所需要的股票
@@ -186,14 +180,28 @@
* 同步指数股票后缓存k线图
*/
public void cacheKData(String stockType, List<DataStockBean> list) {
- StringBuilder codeList = new StringBuilder();
+ /*StringBuilder codeList = new StringBuilder();
codeList.append(PropertiesUtil.getProperty("us_home_indices_code"));
codeList.append(PropertiesUtil.getProperty("hk_home_indices_code"));
codeList.append(PropertiesUtil.getProperty("in_home_indices_code"));
- codeList.append(PropertiesUtil.getProperty("tw_home_indices_code"));
+ codeList.append(PropertiesUtil.getProperty("tw_home_indices_code"));*/
+
+
+ List<StockConfig> stockConfigList = stockConfigMapper.selectList
+ (new LambdaQueryWrapper<StockConfig>()
+ .like(StockConfig::getCKey, EConfigKey.INDICES.getCode()));
+ String codeList = null;
+ if (stockConfigList != null && !stockConfigList.isEmpty()) {
+ codeList = stockConfigList.stream().filter(Objects::nonNull)
+ .map(x -> { return x.getCValue() == null ? "" : x.getCValue();
+ }).collect(Collectors.joining(","));
+ }
+ if (codeList == null || codeList.isEmpty()) {
+ return;
+ }
for (DataStockBean dataStockBean : list) {
//缓存首页指数k线图
- if (codeList.toString().contains(dataStockBean.getId())) {
+ if (codeList.contains(dataStockBean.getId())) {
// 获取K线数据
Object kData = istockService.getKData(dataStockBean.getId(), "D", stockType);
if (kData != null) {
--
Gitblit v1.9.3