package com.xcong.excoin.modules.okxNewPrice.okxWs;
|
|
import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.CoinEnums;
|
import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.OrderParamEnums;
|
import com.xcong.excoin.utils.RedisUtils;
|
import lombok.extern.slf4j.Slf4j;
|
|
/**
|
* @author Administrator
|
*/
|
@Slf4j
|
public class InstrumentsWs {
|
|
public static final String INSTRUMENTSWS_CHANNEL = "instruments";
|
|
public static void handleEvent(RedisUtils redisUtils) {
|
log.info("开始执行InstrumentsWs......");
|
// 将账户数据保存到Redis中，设置过期时间为30分钟
|
try {
|
boolean setResult =
|
redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":instId", CoinEnums.HE_YUE.getCode(), 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":ctVal", "0.01", 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":tickSz", "2", 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":minSz", "2", 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":instIdCode", CoinEnums.HE_YUE.getCode(), 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":state", OrderParamEnums.STATE_0.getValue(), 0)
|
&& redisUtils.set(INSTRUMENTSWS_CHANNEL+":" + CoinEnums.HE_YUE.getCode()+":out", OrderParamEnums.OUT_NO.getValue(), 0)
|
;
|
if (!setResult) {
|
log.warn("Redis set operation failed for key: account:{}", CoinEnums.HE_YUE.getCode());
|
}
|
} catch (Exception e) {
|
log.error("Redis操作异常，key: account:{}, error: {}", CoinEnums.HE_YUE.getCode(), e.getMessage(), e);
|
}
|
}
|
}
|
