| | |
| | | if (StrUtil.isNotBlank(recordNoExit)) { |
| | | redisUtils.del(AppContants.KJ_RECORD_NO); |
| | | } |
| | | redisUtils.set(AppContants.KJ_RECORD_NO, kjNo, 600); |
| | | redisUtils.set(AppContants.KJ_RECORD_NO, kjNo, AppContants.KJ_RECORD_TIME_INTERVAL*60); |
| | | //开奖时间 |
| | | if (StrUtil.isNotBlank(redisUtils.getString(AppContants.KJ_RECORD_TIME))) { |
| | | redisUtils.del(AppContants.KJ_RECORD_TIME); |
| | | } |
| | | redisUtils.set(AppContants.KJ_RECORD_TIME, kjRecord.getCreatedTime(), 600); |
| | | redisUtils.set(AppContants.KJ_RECORD_TIME, kjRecord.getCreatedTime(), AppContants.KJ_RECORD_TIME_INTERVAL*60); |
| | | |
| | | agentProducer.sendChouJiangDelayMsg(kjNo, 10 * 60 * 1000L); |
| | | agentProducer.sendNoTimeDelayMsg(kjNo, 9 * 60 * 1000L);//提一分钟停止下注 |
| | | agentProducer.sendChouJiangDelayMsg(kjNo, AppContants.KJ_RECORD_TIME_INTERVAL * 60 * 1000L); |
| | | agentProducer.sendNoTimeDelayMsg(kjNo, (AppContants.KJ_RECORD_TIME_INTERVAL-1) * 60 * 1000L);//提一分钟停止下注 |
| | | |
| | | //todo 测试下注 |
| | | ApiCreateDto apiCreateDto = new ApiCreateDto(); |
| | |
| | | if (StrUtil.isNotBlank(recordNoExit)) { |
| | | redisUtils.del(AppContants.KJ_RECORD_NO_OLD); |
| | | } |
| | | redisUtils.set(AppContants.KJ_RECORD_NO_OLD, kjNo, 600); |
| | | redisUtils.set(AppContants.KJ_RECORD_NO_OLD, kjNo, AppContants.KJ_RECORD_TIME_INTERVAL * 60); |
| | | |
| | | //开奖号码 |
| | | if (StrUtil.isNotBlank(redisUtils.getString(AppContants.KJ_RECORD_NUM_OLD))) { |
| | | redisUtils.del(AppContants.KJ_RECORD_NUM_OLD); |
| | | } |
| | | redisUtils.set(AppContants.KJ_RECORD_NUM_OLD, randomInt, 600); |
| | | redisUtils.set(AppContants.KJ_RECORD_NUM_OLD, randomInt, AppContants.KJ_RECORD_TIME_INTERVAL * 60); |
| | | OpenPrice openPrice = new OpenPrice(); |
| | | openPrice.setKjNo(kjNo); |
| | | openPrice.setKjNum(String.valueOf(randomInt)); |