package project.data.internal;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import kernel.util.DateUtils;
|
import project.data.DataService;
|
import project.data.model.Depth;
|
import project.data.model.Kline;
|
import project.data.model.Realtime;
|
import project.data.model.Trade;
|
import project.data.model.Trend;
|
import project.syspara.SysparaService;
|
|
public class DataServiceImpl implements DataService {
|
|
private DataService remoteDataService;
|
|
private SysparaService sysparaService;
|
|
private volatile static Map<String, TimeObject> cache = new ConcurrentHashMap<String, TimeObject>();
|
|
/**
|
* 行情实时价格
|
*/
|
@Override
|
public List<Realtime> realtime(String symbol) {
|
String key = "realtime_" + symbol;
|
List<Realtime> list = new ArrayList<Realtime>();
|
list = remoteDataService.realtime(symbol);
|
RealtimeTimeObject realtimeTimeObject = new RealtimeTimeObject();
|
realtimeTimeObject.setLastTime(new Date());
|
realtimeTimeObject.setList(list);
|
cache.put(key, realtimeTimeObject);
|
|
return list;
|
}
|
|
/**
|
* 分时图
|
*/
|
@Override
|
public List<Trend> trend(String symbol) {
|
String key = "trend_" + symbol;
|
List<Trend> list = new ArrayList<Trend>();
|
TimeObject timeObject = cache.get(key);
|
if (isRemote(timeObject)) {
|
list = remoteDataService.trend(symbol);
|
TrendTimeObject trendTimeObject = new TrendTimeObject();
|
trendTimeObject.setLastTime(new Date());
|
trendTimeObject.setTrend(list);
|
cache.put(key, trendTimeObject);
|
} else {
|
list = ((TrendTimeObject) timeObject).getTrend();
|
}
|
|
return list;
|
}
|
|
/**
|
* Kline
|
*/
|
@Override
|
public List<Kline> kline(String symbol, String line) {
|
|
String key = "kline_" + symbol + "_" + line;
|
List<Kline> list = new ArrayList<Kline>();
|
TimeObject timeObject = cache.get(key);
|
if (isRemote(timeObject)) {
|
list = remoteDataService.kline(symbol, line);
|
Collections.sort(list); // 按时间升序
|
KlineTimeObject klineTimeObject = new KlineTimeObject();
|
klineTimeObject.setLastTime(new Date());
|
klineTimeObject.setKline(list);
|
cache.put(key, klineTimeObject);
|
} else {
|
list = ((KlineTimeObject) timeObject).getKline();
|
}
|
|
return list;
|
|
}
|
|
/**
|
* 深度数据
|
*/
|
@Override
|
public Depth depth(String symbol) {
|
String key = "depth_" + symbol;
|
Depth depth = new Depth();
|
TimeObject timeObject = cache.get(key);
|
if (isRemote(timeObject)) {
|
depth = remoteDataService.depth(symbol);
|
DepthTimeObject depthTimeObject = new DepthTimeObject();
|
depthTimeObject.setLastTime(new Date());
|
depthTimeObject.setDepth(depth);
|
cache.put(key, depthTimeObject);
|
} else {
|
depth = ((DepthTimeObject) timeObject).getDepth();
|
}
|
|
return depth;
|
|
}
|
|
/**
|
* 近期交易记录
|
*/
|
@Override
|
public Trade trade(String symbol) {
|
|
String key = "trade_" + symbol;
|
Trade trade = new Trade();
|
TimeObject timeObject = cache.get(key);
|
if (isRemote(timeObject)) {
|
trade = remoteDataService.trade(symbol);
|
if(trade!=null) {
|
TradeTimeObject tradeTimeObject = new TradeTimeObject();
|
tradeTimeObject.setLastTime(new Date());
|
tradeTimeObject.put(symbol, trade.getData());
|
cache.put(key, tradeTimeObject);
|
}
|
|
} else {
|
trade = ((TradeTimeObject) timeObject).getTrade();
|
}
|
|
return trade;
|
}
|
|
private boolean isRemote(TimeObject timeObject) {
|
if (timeObject == null) {
|
return true;
|
}
|
|
/**
|
* 判断是否远程 读取数据，先完成3秒过期。后期补上非开盘时间不调用。
|
*/
|
Date timestamps = timeObject.getLastTime();
|
|
/**
|
* 数据超时时间
|
*/
|
// 15秒
|
//默认3秒
|
double huobi_data_timeout = Double.valueOf(sysparaService.find("symbol_data_timeout").getValue());
|
|
//int timeout = 3;
|
|
int timeout = (int) huobi_data_timeout;
|
if (DateUtils.addSecond(timestamps, timeout).before(new Date())) {
|
return true;
|
}
|
|
return false;
|
}
|
|
public void setRemoteDataService(DataService remoteDataService) {
|
this.remoteDataService = remoteDataService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
|
}
|
