| | |
|---|
| | | package org.example.server.impl; |
|---|
| | | |
|---|
| | | import org.example.websocket.server.WsServer; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.fasterxml.jackson.core.JsonProcessingException; |
|---|
| | | import com.fasterxml.jackson.databind.JsonNode; |
|---|
| | |
|---|
| | | import org.example.pojo.bo.MarketBo; |
|---|
| | | import org.example.server.CurrencySerivce; |
|---|
| | | import org.example.util.RedisUtil; |
|---|
| | | import org.example.websocket.server.WsServer; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.yaml.snakeyaml.error.Mark; |
|---|
| | |
|---|
| | | marketDataOut.setBuyTotalPrice(markets1.getBids().getP().multiply(markets1.getBids().getV()).toString()); // 设置买入总价 |
|---|
| | | marketDataOut.setSellTotalPrice(markets2.getAsks().getP().multiply(markets2.getAsks().getV()).toString()); // 设置卖出总价 |
|---|
| | | marketDataOut.setServceTime(formattedDateTime); // 设置服务时间 |
|---|
| | | marketDataOut.setBuyAndSell(marketDataOut.getBaseAsset()+markets1.getExchange()+markets2.getExchange()); |
|---|
| | | marketDataOuts.add(marketDataOut); // 添加到输出列表 |
|---|
| | | } |
|---|
| | | |
|---|
