月充值爬榜bug
This commit is contained in:
@@ -353,9 +353,9 @@ public class ActivityOfChargeService {
|
||||
String levelListKey = getLevelListKey(level, date, partitionId);
|
||||
String levelSetKey = getLevelSetKey(level, date, partitionId);
|
||||
RSet<Long> set = redissonClient.getSet(levelSetKey, LongCodec.INSTANCE);
|
||||
boolean receiveStatus = set.add(uid);
|
||||
boolean levelStatus = set.add(uid);
|
||||
set.expire(expire, TimeUnit.DAYS);
|
||||
if (!receiveStatus) {
|
||||
if (!levelStatus) {
|
||||
return;
|
||||
}
|
||||
RList<Long> list = redissonClient.getList(levelListKey, LongCodec.INSTANCE);
|
||||
@@ -363,9 +363,9 @@ public class ActivityOfChargeService {
|
||||
list.expire(expire, TimeUnit.DAYS);
|
||||
for (int i = level - 1; i > 0; i--) {
|
||||
levelListKey = getLevelListKey(i, date, partitionId);
|
||||
redissonClient.getList(levelListKey, LongCodec.INSTANCE).remove(partitionId);;
|
||||
redissonClient.getList(levelListKey, LongCodec.INSTANCE).remove(uid);;
|
||||
levelSetKey = getLevelSetKey(i, date, partitionId);
|
||||
redissonClient.getSet(levelSetKey, LongCodec.INSTANCE).remove(partitionId);
|
||||
redissonClient.getSet(levelSetKey, LongCodec.INSTANCE).remove(uid);
|
||||
}
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user