modify

Helius

2021-03-05 9e6054ca0612a05ec2b698b8a63db7605c600725

 src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java

@@ -2,14 +2,10 @@

import com.alibaba.fastjson.JSONObject;
import com.huobi.client.SubscriptionClient;
import com.huobi.client.SubscriptionOptions;
import com.huobi.client.model.Candlestick;
import com.huobi.client.model.enums.CandlestickInterval;
import com.xcong.excoin.modules.symbols.service.SymbolsService;
import com.xcong.excoin.netty.common.ChannelManager;
import com.xcong.excoin.netty.common.ServerChannelManager;
import com.xcong.excoin.netty.common.NettyTools;
import com.xcong.excoin.rabbit.pricequeue.WebsocketPriceService;
import com.xcong.excoin.utils.CoinTypeConvert;
import com.xcong.excoin.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -46,12 +42,12 @@
    @Autowired
    private SubscriptionClient subscriptionClient;

    @PostConstruct
//    @PostConstruct
    public void initNewestPrice() {
        log.info("#=======价格更新开启=======#");

        subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt,xrpusdt,ltcusdt,bchusdt,eosusdt,etcusdt", tradeEvent -> {
            ChannelManager.getTcpGroup().writeAndFlush(NettyTools.textBytes(JSONObject.toJSONString(tradeEvent)));
            ServerChannelManager.getTcpGroup().writeAndFlush(NettyTools.textBytes(JSONObject.toJSONString(tradeEvent)));
//            String symbol = tradeEvent.getSymbol();
//            // 根据symbol判断做什么操作
//            symbol = CoinTypeConvert.convert(symbol);