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 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));