package com.yami.trading.huobi.data;
|
|
import com.yami.trading.huobi.data.model.AdjustmentValue;
|
|
import java.math.BigDecimal;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
public class AdjustmentValueCache {
|
/**
|
* 当前值
|
*/
|
private static volatile Map<String, BigDecimal> currentValue = new ConcurrentHashMap();
|
/**
|
* 延时值
|
*/
|
private static volatile Map<String, AdjustmentValue> delayValue = new ConcurrentHashMap();
|
|
private static volatile Map<String, BigDecimal> lastValue = new ConcurrentHashMap();
|
|
public static Map<String, BigDecimal> getCurrentValue() {
|
return currentValue;
|
}
|
|
public static Map<String, AdjustmentValue> getDelayValue() {
|
return delayValue;
|
}
|
|
public static Map<String, BigDecimal> getLastValue() {
|
return lastValue;
|
}
|
|
|
|
//计算已分配次数
|
private static final Map<String, Integer> allocatedCount = new ConcurrentHashMap<>();
|
//初始总值
|
private static final Map<String, BigDecimal> totalValue = new ConcurrentHashMap<>();
|
//更新累计值
|
private static final Map<String, BigDecimal> accumulatedValue = new ConcurrentHashMap<>();
|
//初始次数
|
private static final Map<String, Integer> frequency = new ConcurrentHashMap<>();
|
|
// 相应的getter方法
|
public static Map<String, Integer> getAllocatedCount() {
|
return allocatedCount;
|
}
|
|
public static Map<String, BigDecimal> getTotalValue() {
|
return totalValue;
|
}
|
|
public static Map<String, BigDecimal> getAccumulatedValue() {
|
return accumulatedValue;
|
}
|
|
public static Map<String, Integer> getFrequency() {
|
return frequency;
|
}
|
}
|