hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

徽章存在存在则更新过期

Browse Source
This commit is contained in:
tianfeng 2025-12-18 23:27:04 +08:00
parent db3c779db6
commit 586a461efa
1 changed files with 42 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeOperateListener.java
View File

@ -19,6 +19,7 @@ import com.red.circle.other.infra.database.rds.entity.badge.BadgeConfig;
import com.red.circle.other.infra.database.rds.service.badge.BadgeBackpackService;
import com.red.circle.other.infra.database.rds.service.badge.BadgeConfigService;
import java.sql.Timestamp;
import java.util.List;
import java.util.Objects;
import java.util.Set;
@ -44,8 +45,8 @@ public class BadgeOperateListener implements MessageListener {
private final MessageEventProcess messageEventProcess;
private final UserRunProfileService userRunProfileService;
private final UserBadgeCommon userBadgeCommon;
private final UserProfileGateway userProfileGateway;
private final DistributedLockUtil distributedLockUtil;
private final UserProfileGateway userProfileGateway;
private final DistributedLockUtil distributedLockUtil;
@Override
public Action consume(ConsumerMessage message) {
@ -106,22 +107,38 @@ public class BadgeOperateListener implements MessageListener {
String lockKey = "badge:operate:wear:" + userId + ":" + badgeId;
distributedLockUtil.executeWithLock(lockKey, () -> {
BadgeBackpack existBadge = badgeBackpackService.query()
.eq(BadgeBackpack::getUserId, userId)
.eq(BadgeBackpack::getBadgeId, badgeId)
.getOne();
// 在锁内查询，避免并发问题
BadgeBackpack existBadge = badgeBackpackService.getByUserIdByBadgeId(userId, badgeId);
if (existBadge != null) {
log.warn("用户已拥有该徽章, 跳过发放, userId: {}, badgeId: {}", userId, badgeId);
return null;
}
BadgeBackpack badgeBackpack = badgeBackpackService.getByUserIdByBadgeId(userId, badgeId);
if (Objects.isNull(badgeBackpack)) {
// 已存在徽章，执行更新操作（而不是跳过！）
Timestamp newExpireTime = calculateExpireTime(days);
String expireType = (days != null && days > 0)
? BadgeBackpackExpireTypeEnum.TEMPORARY.name()
: BadgeBackpackExpireTypeEnum.PERMANENT.name();
// 更新：确保useProps=true 且更新过期时间
boolean updateCount = badgeBackpackService.update()
.set(BadgeBackpack::getUseProps, Boolean.TRUE)
.set(BadgeBackpack::getExpireTime, newExpireTime)
.set(BadgeBackpack::getExpireType, expireType)
.eq(BadgeBackpack::getId, existBadge.getId())
.execute();
if (updateCount) {
log.info("更新已存在的徽章, userId: {}, badgeId: {}, days: {}", userId, badgeId, days);
userProfileGateway.removeCacheAll(userId);
} else {
log.warn("更新徽章失败, userId: {}, badgeId: {}", userId, badgeId);
}
} else {
// 不存在则插入
badgeBackpackService.save(buildSaveUserBadgeBackpack(badgeId, userId, days));
log.info("新增徽章, userId: {}, badgeId: {}, days: {}", userId, badgeId, days);
userProfileGateway.removeCacheAll(userId);
}
return null;
return null;
});
}
@ -144,8 +161,18 @@ public class BadgeOperateListener implements MessageListener {
Set<Long> saveWear = wearBadge.stream().map(UserUseBadgeDTO::getId)
.filter(id -> !badgeId.equals(id)).collect(Collectors.toSet());
userRunProfileService.updateUserWearBadgesOverlay(userId,
userBadgeCommon.listUseBadge(userId, userProfile.getSysOriginChild(), saveWear)
);
userBadgeCommon.listUseBadge(userId, userProfile.getSysOriginChild(), saveWear));
}
/**
* 计算过期时间.
*/
private Timestamp calculateExpireTime(Long days) {
if (days != null && days > 0) {
return TimestampUtils.nowPlusDays(days.intValue());
} else {
return TimestampUtils.now();
}
}
private BadgeBackpack buildSaveUserBadgeBackpack(Long badgeId, Long userId, Long days) {