| | |
| | | import com.yami.trading.common.util.Arith; |
| | | import com.yami.trading.common.util.IPHelper; |
| | | import com.yami.trading.common.util.ThreadUtils; |
| | | import com.yami.trading.huobi.data.AdjustmentValueCache; |
| | | import com.yami.trading.huobi.data.DataCache; |
| | | import com.yami.trading.huobi.data.internal.AdjustmentValueService; |
| | | import com.yami.trading.huobi.data.model.AdjustmentValue; |
| | |
| | | } |
| | | |
| | | public void adjust(String symbol, Double second, BigDecimal value) { |
| | | AdjustmentValueCache.getDelayValue().remove(symbol); |
| | | AdjustmentValueCache.getPreAllocatedAdjustments().remove(symbol); |
| | | AdjustmentValueCache.getCurrentAdjustmentIndex().remove(symbol); |
| | | AdjustmentValueCache.getFrequency().remove(symbol); |
| | | |
| | | BigDecimal currentValue = this.adjustmentValueService.getCurrentValue(symbol); |
| | | if (currentValue == null) { |
| | | Realtime realtime = this.dataService.realtime(symbol).get(0); |