|
|
@@ -303,16 +303,12 @@ public class LiveRedConfServiceImpl implements ILiveRedConfService {
|
|
|
|
|
|
@Override
|
|
|
public void updateRedQuantityNum() {
|
|
|
- Set<String> allLiveKeys = redisCache.redisTemplate.keys(REDPACKET_REMAININGLOTS_KEY + "*");
|
|
|
- Optional.ofNullable(allLiveKeys)
|
|
|
- .filter(CollUtil::isNotEmpty)
|
|
|
- .ifPresent(keys -> keys
|
|
|
- .parallelStream()
|
|
|
- .map(key -> key.replace(REDPACKET_REMAININGLOTS_KEY, ""))
|
|
|
- .map(Long::valueOf)
|
|
|
- .map(baseMapper::selectLiveRedConfByRedId)
|
|
|
- .filter(Objects::nonNull)
|
|
|
- .forEach(this::updateDbByRed));
|
|
|
+ LiveRedConf redConf = new LiveRedConf();
|
|
|
+ redConf.setRedStatus(1L);
|
|
|
+ List<LiveRedConf> liveRedConfs = baseMapper.selectLiveRedConfList(redConf);
|
|
|
+ for (LiveRedConf liveRedConf : liveRedConfs) {
|
|
|
+ updateDbByRed(liveRedConf);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
private void updateDbByRed(LiveRedConf red) {
|