src/main/java/com/xcong/excoin/common/contants/AppContants.java
@@ -81,4 +81,6 @@ */ public static final String ORDER_CANCEL_KEY = "COIN_ORDER_CANCEL_"; public static final BigDecimal DEFAULT_PRICE = BigDecimal.valueOf(66); } src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java
@@ -3,6 +3,7 @@ import com.alibaba.fastjson.JSON; import com.huobi.client.model.Candlestick; import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.trade.ExchangeTrade; import com.xcong.excoin.utils.RedisUtils; import lombok.ToString; @@ -314,11 +315,11 @@ Candlestick kLine = new Candlestick(); kLine.setTimestamp(endTick); kLine.setAmount(BigDecimal.ZERO); kLine.setClose(BigDecimal.valueOf(66)); kLine.setLow(BigDecimal.valueOf(66)); kLine.setOpen(BigDecimal.valueOf(66)); kLine.setClose(AppContants.DEFAULT_PRICE); kLine.setLow(AppContants.DEFAULT_PRICE); kLine.setOpen(AppContants.DEFAULT_PRICE); kLine.setVolume(BigDecimal.ZERO); kLine.setHigh(BigDecimal.valueOf(66)); kLine.setHigh(AppContants.DEFAULT_PRICE); String rangeUnit = ""; if (field == Calendar.MINUTE) { rangeUnit = "min"; src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java
@@ -6,6 +6,7 @@ import com.huobi.client.SubscriptionOptions; import com.huobi.client.model.Candlestick; import com.huobi.client.model.enums.CandlestickInterval; import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.modules.coin.dao.OrderCoinDealDao; import com.xcong.excoin.modules.coin.dao.OrderCoinsDao; import com.xcong.excoin.modules.coin.entity.OrderCoinsEntity; @@ -133,6 +134,10 @@ long currentTimeMillis = System.currentTimeMillis(); for (String s : rang) { Candlestick candlestick = new Candlestick(); candlestick.setClose(AppContants.DEFAULT_PRICE); candlestick.setHigh(AppContants.DEFAULT_PRICE); candlestick.setLow(AppContants.DEFAULT_PRICE); candlestick.setOpen(AppContants.DEFAULT_PRICE); candlestick.setTimestamp(currentTimeMillis); currentKlineMap.put(s,candlestick); }
