diff --git a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java index db274aa..7fb2782 100644 --- a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java +++ b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java @@ -263,24 +263,29 @@ public class RefinitivConsumer implements ApplicationRunner { } JSONObject data = JSONObject.parseObject(token); token = data.getString("access_token"); - String baseURL = "https://api.refinitiv.com/data/historical-pricing/v1/views/intraday-summaries/"; - + String baseURLToday = "https://api.refinitiv.com/data/historical-pricing/v1/views/intraday-summaries/"; + String baseURLHistory = "https://api.refinitiv.com/data/historical-pricing/v1/views/interday-summaries/"; int countback = 5; String interval = null; - + String resourceEndpoint = null; if(StringUtils.equals("H",resolution)){ countback = 30; interval = "PT1H"; + resourceEndpoint = baseURLToday + symbol; }else if(StringUtils.equals("D",resolution)){ - interval ="PT1D"; + countback = 30; + interval ="P1D"; + resourceEndpoint = baseURLHistory + symbol; }else if(StringUtils.equals("W",resolution)){ countback = 30; - interval ="PT1W"; + interval ="P1W"; + resourceEndpoint = baseURLHistory + symbol; }else if(StringUtils.equals("M",resolution)){ countback = 30; - interval ="PT1M"; + interval ="P1M"; + resourceEndpoint = baseURLHistory + symbol; } - String resourceEndpoint = baseURL + symbol; + HttpResponse response = HttpUtil.createGet(resourceEndpoint) .form("eventTypes","trade,quote") .form("start","2023-05-11T18:30:12.000000000Z")