//package cc.mrbird.febs.job; // //import cc.mrbird.febs.common.contants.AppContants; //import cc.mrbird.febs.common.utils.RedisUtils; //import com.huobi.client.SubscriptionClient; //import com.huobi.client.SubscriptionOptions; //import lombok.extern.slf4j.Slf4j; //import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.stereotype.Component; // //import javax.annotation.PostConstruct; // ///** // * @author // * @date 2022-03-24 // **/ //@Slf4j //@Component //public class NewPriceUpdateJob{ // // @Autowired // private RedisUtils redisUtils; // // @PostConstruct // public void initNewPriceUpdate() { //// log.info("#最新价更新启动#"); //// redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30); //// SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); //// subscriptionOptions.setConnectionDelayOnFailure(5); //// subscriptionOptions.setUri("wss://api.hadax.com/ws"); //// SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions); //// subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> { //// redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice()); //// }); // } //}