package project.hobi.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
|
import kernel.util.Arith;
|
import kernel.util.StringUtils;
|
import kernel.util.ThreadUtils;
|
import project.data.model.Depth;
|
import project.data.model.DepthEntry;
|
import project.data.model.Kline;
|
import project.data.model.Realtime;
|
import project.data.model.Symbols;
|
import project.data.model.Trade;
|
import project.data.model.TradeEntry;
|
import project.data.websocket.model.market.MarketDepthEvent;
|
import project.data.websocket.model.market.MarketTrade;
|
import project.data.websocket.model.market.MarketTradeEvent;
|
import project.data.websocket.model.market.PriceLevel;
|
import project.hobi.Config;
|
import project.hobi.HobiDataService;
|
import project.hobi.http.HttpHelper;
|
import project.hobi.http.HttpMethodType;
|
import project.item.ItemService;
|
import project.item.model.Item;
|
|
public class HobiDataServiceImpl implements HobiDataService {
|
|
private Logger logger = LoggerFactory.getLogger(HobiDataServiceImpl.class);
|
/**
|
* 接口调用间隔（毫秒）
|
*/
|
private int interval = 100;
|
|
private int sleep = 100;
|
/**
|
* 最后一次访问接口时间
|
*/
|
private volatile Date last_time = new Date();
|
|
private volatile boolean lock = false;
|
|
private ItemService itemService;
|
|
@Override
|
public List<Realtime> realtime(int maximum) {
|
List<Realtime> list = new ArrayList<Realtime>();
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= 100) {
|
return list;
|
} else {
|
return realtime(++maximum);
|
}
|
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
Map<String, Object> param = new HashMap<String, Object>();
|
String result = HttpHelper.getJSONFromHttp(Config.url + Config.tickers, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("ok".equals(status)) {
|
JSONArray dataArray = resultJson.getJSONArray("data");
|
Long ts = resultJson.getLongValue("ts");
|
|
/*HashMap<String,JSONObject> symbolMap=new HashMap<String,JSONObject>();
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject realtimeJson = dataArray.getJSONObject(i);
|
if(null==realtimeJson) continue;
|
String symbol=realtimeJson.getString("symbol");
|
if(null==symbol || (symbol=symbol.trim()).isEmpty()) continue;
|
symbolMap.put(symbol,realtimeJson);
|
}
|
|
if(symbolMap.isEmpty()) return list;
|
|
HashMap<String,Item> itemMap=itemService.cacheBySymbolDatas(symbolMap.keySet());
|
if(null==itemMap || itemMap.isEmpty()) return list;
|
|
for(Map.Entry<String,Item> itemEntry:itemMap.entrySet()) {
|
Item item=itemEntry.getValue();
|
JSONObject realtimeJson=symbolMap.get(itemEntry.getKey());
|
|
Realtime realtime = new Realtime();
|
realtime.setSymbol(item.getSymbol());
|
realtime.setName(item.getName());
|
realtime.setTs(ts);
|
realtime.setOpen(realtimeJson.getDouble("open"));
|
realtime.setClose(realtimeJson.getDouble("close"));
|
realtime.setHigh(realtimeJson.getDouble("high"));
|
realtime.setLow(realtimeJson.getDouble("low"));
|
realtime.setAmount(realtimeJson.getDouble("amount"));
|
realtime.setVolume(realtimeJson.getDouble("vol"));
|
list.add(realtime);
|
}*/
|
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject realtimeJson = dataArray.getJSONObject(i);
|
Realtime realtime = new Realtime();
|
Item item = itemService.cacheBySymbolData(realtimeJson.getString("symbol"));
|
if (item == null) {
|
continue;
|
}
|
realtime.setSymbol(item.getSymbol());
|
realtime.setName(item.getName());
|
realtime.setTs(ts);
|
realtime.setOpen(realtimeJson.getDouble("open"));
|
realtime.setClose(realtimeJson.getDouble("close"));
|
realtime.setHigh(realtimeJson.getDouble("high"));
|
realtime.setLow(realtimeJson.getDouble("low"));
|
realtime.setAmount(realtimeJson.getDouble("amount"));
|
realtime.setVolume(realtimeJson.getDouble("vol"));
|
list.add(realtime);
|
if("ethusdt".equals(realtimeJson.getString("symbol"))) {
|
logger.error("ethusdt当前价格{}", realtime.getClose());
|
}
|
}
|
} else {
|
logger.error(" realtime()error, resultJson [ " + resultJson.toJSONString() + " ]");
|
}
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
}
|
return list;
|
}
|
|
@Override
|
public List<Kline> kline(String symbol, String period, Integer num, int maximum) {
|
List<Kline> list = new ArrayList<Kline>();
|
Item item = itemService.cacheBySymbolData(symbol);
|
if (item == null) {
|
return list;
|
}
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= 100) {
|
return list;
|
} else {
|
return this.kline(symbol, period, num, ++maximum);
|
}
|
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("symbol", symbol);
|
param.put("period", period);
|
if (num == null) {
|
if (Kline.PERIOD_1MIN.equals(period)) {
|
param.put("size", 1440);
|
}
|
if (Kline.PERIOD_5MIN.equals(period)) {
|
param.put("size", 576);
|
}
|
if (Kline.PERIOD_15MIN.equals(period)) {
|
param.put("size", 576);
|
}
|
if (Kline.PERIOD_30MIN.equals(period)) {
|
param.put("size", 576);
|
}
|
if (Kline.PERIOD_60MIN.equals(period)) {
|
param.put("size", 576);
|
}
|
|
if (Kline.PERIOD_4HOUR.equals(period)) {
|
param.put("size", 576);
|
}
|
if (Kline.PERIOD_1DAY.equals(period)) {
|
param.put("size", 500);
|
}
|
if (Kline.PERIOD_1MON.equals(period)) {
|
param.put("size", 500);
|
}
|
if (Kline.PERIOD_1WEEK.equals(period)) {
|
param.put("size", 500);
|
}
|
|
} else {
|
param.put("size", num);
|
}
|
|
String result = HttpHelper.getJSONFromHttp(Config.url + Config.kline, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("ok".equals(status)) {
|
JSONArray dataArray = resultJson.getJSONArray("data");
|
/**
|
* 丢弃第一行数据
|
*/
|
int start = 1;
|
if (num != null && num == 1)
|
start = 0;
|
for (int i = start; i < dataArray.size(); i++) {
|
JSONObject realtimeJson = dataArray.getJSONObject(i);
|
Kline kline = new Kline();
|
kline.setSymbol(item.getSymbol());
|
kline.setPeriod(period);
|
kline.setTs(Long.valueOf(realtimeJson.getString("id") + "000"));
|
kline.setOpen(realtimeJson.getDouble("open"));
|
kline.setClose(realtimeJson.getDouble("close"));
|
kline.setHigh(realtimeJson.getDouble("high"));
|
kline.setLow(realtimeJson.getDouble("low"));
|
kline.setVolume(realtimeJson.getDouble("vol"));
|
list.add(kline);
|
}
|
|
}
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
}
|
return list;
|
}
|
|
/**
|
* 市场深度数据（20档）,包装，数据本地化处理
|
*/
|
public Depth depthDecorator(String symbol, int maximum) {
|
Depth depth = this.depth(symbol, maximum);
|
Item item = itemService.cacheBySymbolData(symbol);
|
item = itemService.cacheBySymbol(item.getSymbol(), false);
|
if ((depth == null || item.getAdjustment_value() == null || item.getAdjustment_value() == 0) &&
|
(item.getMultiple() == 0 || item.getMultiple() == 1)) {
|
return depth;
|
}
|
|
List<DepthEntry> asks = depth.getAsks();
|
for (int i = 0; i < asks.size(); i++) {
|
DepthEntry depthEntry = asks.get(i);
|
|
/**
|
* 调整交易量倍数和 行情值
|
*/
|
if (item.getMultiple() > 0) {
|
depthEntry.setAmount(Arith.mul(depthEntry.getAmount(), item.getMultiple()));
|
}else {
|
depthEntry.setAmount(depthEntry.getAmount());
|
}
|
depthEntry.setPrice(Arith.add(depthEntry.getPrice(), item.getAdjustment_value()));
|
}
|
|
List<DepthEntry> bids = depth.getBids();
|
for (int i = 0; i < bids.size(); i++) {
|
DepthEntry depthEntry = bids.get(i);
|
/**
|
* 调整交易量倍数和 行情值
|
*/
|
if (item.getMultiple() > 0) {
|
depthEntry.setAmount(Arith.mul(depthEntry.getAmount(), item.getMultiple()));
|
}else {
|
depthEntry.setAmount(depthEntry.getAmount());
|
}
|
depthEntry.setPrice(Arith.add(depthEntry.getPrice(), item.getAdjustment_value()));
|
}
|
|
return depth;
|
}
|
|
/**
|
* 市场深度数据（20档）,包装，数据本地化处理
|
*/
|
public Depth depthDecorator(MarketDepthEvent event, Item item) {
|
Depth depth = new Depth();
|
depth.setSymbol(item.getSymbol());
|
depth.setTs(event.getTs());
|
|
double multiple = item.getMultiple() == 0 ? 1 : item.getMultiple();
|
double adjustmentValue = item.getAdjustment_value() == null ? 0 : item.getMultiple();
|
|
for (PriceLevel priceLevel : event.getDepth().getAsks()) {
|
DepthEntry depthEntry = new DepthEntry();
|
depthEntry.setPrice(Arith.add(depthEntry.getPrice(), adjustmentValue));
|
depthEntry.setAmount(Arith.mul(priceLevel.getAmount().doubleValue(), multiple));
|
depth.getAsks().add(depthEntry);
|
}
|
|
for (PriceLevel priceLevel : event.getDepth().getBids()) {
|
DepthEntry depthEntry = new DepthEntry();
|
depthEntry.setPrice(Arith.add(depthEntry.getPrice(), adjustmentValue));
|
depthEntry.setAmount(Arith.mul(priceLevel.getAmount().doubleValue(), multiple));
|
depth.getBids().add(depthEntry);
|
}
|
|
return depth;
|
}
|
|
@Override
|
public Depth depth(String symbol, int maximum) {
|
boolean current_lock = false;
|
if (StringUtils.isNullOrEmpty(symbol)) {
|
return null;
|
}
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= 100) {
|
return null;
|
} else {
|
return this.depth(symbol, ++maximum);
|
}
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("symbol", symbol);
|
param.put("type", "step0");
|
|
String result = HttpHelper.getJSONFromHttp(Config.url + Config.depth, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("ok".equals(status)) {
|
JSONObject dataJson = resultJson.getJSONObject("tick");
|
Long ts = resultJson.getLongValue("ts");
|
Depth depth = new Depth();
|
|
Item item = itemService.cacheBySymbolData(symbol);
|
if (item == null) {
|
return null;
|
}
|
depth.setSymbol(item.getSymbol());
|
depth.setTs(ts);
|
|
JSONArray bidsArray = dataJson.getJSONArray("bids");
|
for (int i = 0; i < bidsArray.size(); i++) {
|
|
JSONArray object = (JSONArray) bidsArray.get(i);
|
DepthEntry depthEntry = new DepthEntry();
|
depthEntry.setPrice(object.getDouble(0));
|
depthEntry.setAmount(object.getDouble(1));
|
depth.getBids().add(depthEntry);
|
|
}
|
|
JSONArray asksArray = dataJson.getJSONArray("asks");
|
for (int i = 0; i < asksArray.size(); i++) {
|
JSONArray object = (JSONArray) asksArray.get(i);
|
DepthEntry depthEntry = new DepthEntry();
|
depthEntry.setPrice(object.getDouble(0));
|
depthEntry.setAmount(object.getDouble(1));
|
depth.getAsks().add(depthEntry);
|
|
}
|
|
return depth;
|
}
|
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 获得近期交易记录,包装，数据本地化处理
|
*/
|
public Trade tradeDecorator(String symbol, int maximum) {
|
Trade trade = this.trade(symbol, maximum);
|
Item item = itemService.cacheBySymbolData(symbol);
|
item = itemService.cacheBySymbol(item.getSymbol(), false);
|
if ((trade == null || item.getAdjustment_value() == null || item.getAdjustment_value() == 0) &&
|
(item.getMultiple() == 0 || item.getMultiple() == 1)) {
|
return trade;
|
}
|
List<TradeEntry> data = trade.getData();
|
for (int i = 0; i < data.size(); i++) {
|
TradeEntry tradeEntry = data.get(i);
|
|
/**
|
* 调整交易量倍数和 行情值
|
*/
|
if (item.getMultiple() > 0) {
|
tradeEntry.setAmount(Arith.mul(tradeEntry.getAmount(), item.getMultiple()));
|
}else {
|
tradeEntry.setAmount(tradeEntry.getAmount());
|
}
|
tradeEntry.setPrice(Arith.add(tradeEntry.getPrice(), item.getAdjustment_value()));
|
}
|
return trade;
|
|
}
|
|
/**
|
* 获得近期交易记录,包装，数据本地化处理
|
*/
|
public Trade tradeDecorator(MarketTradeEvent event, Item item) {
|
Trade trade = new Trade();
|
trade.setSymbol(item.getSymbol());
|
trade.setTs(event.getTs());
|
double multiple = item.getMultiple() == 0 ? 1 : item.getMultiple();
|
double adjustmentValue = item.getAdjustment_value() == null ? 0 : item.getMultiple();
|
for (MarketTrade value : event.getList()) {
|
TradeEntry entry = new TradeEntry();
|
entry.setAmount(Arith.mul(value.getAmount().doubleValue(), multiple));
|
entry.setPrice(Arith.add(value.getPrice().doubleValue(), adjustmentValue));
|
entry.setTs(value.getTs());
|
entry.setPrice(value.getPrice().doubleValue());
|
entry.setAmount(value.getAmount().doubleValue());
|
entry.setDirection(value.getDirection());
|
trade.getData().add(entry);
|
}
|
return trade;
|
}
|
|
@Override
|
public Trade trade(String symbol, int maximum) {
|
boolean current_lock = false;
|
if (StringUtils.isNullOrEmpty(symbol)) {
|
return null;
|
}
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= 100) {
|
|
return null;
|
} else {
|
return this.trade(symbol, ++maximum);
|
}
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("symbol", symbol);
|
|
String result = HttpHelper.getJSONFromHttp(Config.url + Config.trade, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("ok".equals(status)) {
|
JSONObject dataJson = resultJson.getJSONObject("tick");
|
Long ts = resultJson.getLongValue("ts");
|
|
Trade trade = new Trade();
|
|
Item item = itemService.cacheBySymbolData(symbol);
|
if (item == null) {
|
return null;
|
}
|
trade.setSymbol(item.getSymbol());
|
trade.setTs(ts);
|
|
JSONArray dataArray = dataJson.getJSONArray("data");
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject object = dataArray.getJSONObject(i);
|
TradeEntry tradeEntry = new TradeEntry();
|
tradeEntry.setTs(object.getLong("ts"));
|
tradeEntry.setPrice(object.getDouble("price"));
|
tradeEntry.setAmount(object.getDouble("amount"));
|
tradeEntry.setDirection(object.getString("direction"));
|
trade.getData().add(tradeEntry);
|
|
}
|
return trade;
|
}
|
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public List<Symbols> symbols() {
|
List<Symbols> list = new ArrayList<Symbols>();
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
|
return list;
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
Map<String, Object> param = new HashMap<String, Object>();
|
String result = HttpHelper.getJSONFromHttp(Config.url + Config.symbols, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("ok".equals(status)) {
|
JSONArray dataArray = resultJson.getJSONArray("data");
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject realtimeJson = dataArray.getJSONObject(i);
|
Symbols symbols = new Symbols();
|
symbols.setBase_currency(realtimeJson.getString("base-currency"));
|
symbols.setQuote_currency(realtimeJson.getString("quote-currency"));
|
symbols.setLeverage_ratio(realtimeJson.getDouble("leverage-ratio"));
|
symbols.setPrice_precision(realtimeJson.getIntValue("price-precision"));
|
symbols.setState(realtimeJson.getString("state"));
|
symbols.setSymbol(realtimeJson.getString("symbol"));
|
list.add(symbols);
|
}
|
|
} else {
|
logger.error(" symbols()error, resultJson [ " + resultJson.toJSONString() + " ]");
|
}
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
}
|
return list;
|
}
|
|
public void setItemService(ItemService itemService) {
|
this.itemService = itemService;
|
}
|
|
}
|
