From 451747dd2443d4846d5cd17dce687a0490b7441a Mon Sep 17 00:00:00 2001
From: vercel <vercel@juyou88.com>
Date: Fri, 10 May 2024 08:38:15 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E6=9C=88=E7=BA=BF=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/stock/market/lesg/RefinitivConsumer.java     | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java
index 3d2591c..198b209 100644
--- a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java
+++ b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java
@@ -214,12 +214,7 @@ public class RefinitivConsumer implements ApplicationRunner {
         }
 
         List<String> topSymbols = RefinitivUtil.decodeTopData(result[0]);
-        for (String topSymbol : topSymbols) {
-            RetifiveStockInfo stockInfo = getDetail(topSymbol);
-            list.add(stockInfo);
-        }
-
-        return list;
+        return getStockList(String.join(",", topSymbols));
     }
 
     /**
@@ -350,7 +345,8 @@ public class RefinitivConsumer implements ApplicationRunner {
                 .header("Authorization","Bearer " + token)
                 .execute();
         if(response.getStatus() != 200){
-            throw new SysTipsException("获取股票K线失败");
+            log.error("获取股票k线信息失败,code:"+response.getStatus());
+            return result;
         }
         JSONArray jsonArray = JSONArray.parseArray(response.body());
         JSONArray dateArray = JSONObject.parseObject(jsonArray.get(0).toString()).getJSONArray("data");
@@ -476,7 +472,8 @@ public class RefinitivConsumer implements ApplicationRunner {
                 .basicAuth(appKey,"")
                 .execute();
         if(response.getStatus() != 200){
-            throw new SysTipsException("获取token失败");
+            log.error("获取toekn失败,code:"+response.getStatus());
+            return null;
         }
         JSONObject data = JSONObject.parseObject(response.body());
         data.put("expiry_tm",System.currentTimeMillis() + (Long.valueOf(data.get("expires_in").toString())-10));