| | |
|---|
| | | 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()+":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()); |
|---|
