diff --git a/src/main/java/cn/stock/market/dto/RetifiveStockHistoryResponse.java b/src/main/java/cn/stock/market/dto/RetifiveStockHistoryResponse.java new file mode 100644 index 0000000..4d7f002 --- /dev/null +++ b/src/main/java/cn/stock/market/dto/RetifiveStockHistoryResponse.java @@ -0,0 +1,17 @@ +package cn.stock.market.dto; + +import lombok.Data; + +import java.util.List; + +@Data +public class RetifiveStockHistoryResponse { + private String s; + private List t; + private List o; + private List h; + private List l; + private List c; + private List v; + +} \ No newline at end of file diff --git a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java index 6f30a41..fab393f 100644 --- a/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java +++ b/src/main/java/cn/stock/market/lesg/RefinitivConsumer.java @@ -6,6 +6,7 @@ import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpResponse; import cn.hutool.http.HttpUtil; import cn.stock.market.domain.basic.entity.RetifiveStock; +import cn.stock.market.dto.RetifiveStockHistoryResponse; import cn.stock.market.dto.RetifiveStockInfo; import cn.stock.market.dto.StockHistoryResponse; import cn.stock.market.utils.DateTimeUtil; @@ -15,6 +16,7 @@ import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.refinitiv.ema.access.*; import com.refinitiv.ema.rdm.EmaRdm; +import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Value; @@ -24,12 +26,17 @@ import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.text.DateFormat; +import java.text.SimpleDateFormat; import java.time.Instant; +import java.time.ZoneId; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.concurrent.TimeUnit; +import static java.time.format.DateTimeFormatter.ISO_OFFSET_DATE_TIME; import static java.util.concurrent.TimeUnit.SECONDS; /** @@ -257,8 +264,9 @@ public class RefinitivConsumer implements ApplicationRunner { } } - public StockHistoryResponse getKLink(String symbol,String resolution){ - StockHistoryResponse result = new StockHistoryResponse(); + @SneakyThrows + public RetifiveStockHistoryResponse getKLink(String symbol, String resolution){ + RetifiveStockHistoryResponse result = new RetifiveStockHistoryResponse(); String token = getToken(); if(StringUtils.isBlank(token)){ throw new SysTipsException("token为空"); @@ -317,9 +325,13 @@ public class RefinitivConsumer implements ApplicationRunner { resourceEndpoint = baseURLHistory + symbol; } + // 创建DateTimeFormatter以匹配所需的格式 + DateTimeFormatter formatterIso = DateTimeFormatter.ISO_INSTANT; + // 格式化Instant + String startStr = start.toInstant().atZone(ZoneId.of("UTC")).format(formatterIso); HttpResponse response = HttpUtil.createGet(resourceEndpoint) .form("eventTypes","trade,quote") - .form("start","2023-05-11T18:30:12.000000000Z") + .form("start",startStr) .form("count",countback) .form("interval",interval) .header("Authorization","Bearer " + token) @@ -334,20 +346,24 @@ public class RefinitivConsumer implements ApplicationRunner { List h = new ArrayList<>(); // 最高价 List l = new ArrayList<>();//最低价 List c = new ArrayList<>();//当前价 - List v = new ArrayList<>();//交易量 + List v = new ArrayList<>();//交易量 for(int i = 0; i < dateArray.size(); i++){ JSONArray date = dateArray.getJSONArray(i); + if(StringUtils.equals("D",resolution) || StringUtils.equals("W",resolution) || StringUtils.equals("M",resolution)){ + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); + Date d = formatter.parse(date.get(0).toString()); + t.add(d.getTime()); + }else { + Instant instant = Instant.parse(date.get(0).toString()); - Instant instant = Instant.parse(date.get(0).toString()); - long timestampMillis = instant.toEpochMilli(); - t.add(timestampMillis); - + long timestampMillis = instant.getEpochSecond(); + t.add(timestampMillis); + } o.add(Double.valueOf(date.get(3).toString())); - h.add(Double.valueOf(date.get(1).toString())); l.add(Double.valueOf(date.get(2).toString())); c.add(Double.valueOf(date.get(4).toString())); - v.add(Long.valueOf(date.get(6).toString())); + v.add(Double.valueOf(date.get(6).toString())); } result.setT(t); result.setO(o); diff --git a/src/main/java/cn/stock/market/web/RefinitivApiController.java b/src/main/java/cn/stock/market/web/RefinitivApiController.java index 91b42fd..337594f 100644 --- a/src/main/java/cn/stock/market/web/RefinitivApiController.java +++ b/src/main/java/cn/stock/market/web/RefinitivApiController.java @@ -3,6 +3,7 @@ package cn.stock.market.web; import cn.hutool.core.util.StrUtil; import cn.stock.market.domain.basic.entity.RetifiveStock; import cn.stock.market.domain.basic.service.RetifiveStockService; +import cn.stock.market.dto.RetifiveStockHistoryResponse; import cn.stock.market.dto.RetifiveStockInfo; import cn.stock.market.lesg.RefinitivConsumer; import cn.stock.market.listener.AppClient; @@ -133,7 +134,7 @@ public class RefinitivApiController { } - @ApiOperation(value = "查询股票K线", httpMethod = "GET", response = RetifiveStockInfo.class) + @ApiOperation(value = "查询股票K线", httpMethod = "GET", response = RetifiveStockHistoryResponse.class) @ApiImplicitParams({ @ApiImplicitParam(name = "symbol",value = "股票对应代码(symbol)",dataType ="String",required = true, paramType = "query"), @ApiImplicitParam(name = "symbol",value = "股票对应代码(symbol)",dataType ="String",required = true, paramType = "query"),