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-04 20:19:58 +08:00
parent 977ccff1b8
commit 7e6b8fa5bf
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/gateway/user/UserRunProfileTransportGatewayImpl.java
View File

@ -103,7 +103,9 @@ public class UserRunProfileTransportGatewayImpl implements UserRunProfileTranspo
if (Objects.nonNull(userSpecialId)) { if (Objects.nonNull(userSpecialId)) {
userRunProfile.setOwnSpecialId(userSpecialId); userRunProfile.setOwnSpecialId(userSpecialId);
} }
return userProfileInfraConvertor.toUserProfile(userRunProfile); //处理首充字段缓存
checkAndUpdateFirstCharge(userRunProfile);
return userProfileInfraConvertor.toUserProfile(userRunProfile);
} }
return getFirstUserRunProfile(listByUserIds(Collections.singleton(userId))); return getFirstUserRunProfile(listByUserIds(Collections.singleton(userId)));
} }
@ -112,6 +114,8 @@ public class UserRunProfileTransportGatewayImpl implements UserRunProfileTranspo
public UserProfile getByAccount(String account) { public UserProfile getByAccount(String account) {
UserRunProfile userRunProfile = userRunProfileService.getByAccount(account); UserRunProfile userRunProfile = userRunProfileService.getByAccount(account);
if (Objects.nonNull(userRunProfile)) { if (Objects.nonNull(userRunProfile)) {
//处理首充字段缓存
checkAndUpdateFirstCharge(userRunProfile);
return userProfileInfraConvertor.toUserProfile(userRunProfile); return userProfileInfraConvertor.toUserProfile(userRunProfile);
} }
@ -123,6 +127,17 @@ public class UserRunProfileTransportGatewayImpl implements UserRunProfileTranspo
assembleUserRunProfiles(Collections.singletonList(baseInfo))); assembleUserRunProfiles(Collections.singletonList(baseInfo)));
} }
private static void checkAndUpdateFirstCharge(UserRunProfile userRunProfile) {
if (userRunProfile.getFirstRecharge() != null && userRunProfile.getFirstRecharge()) {
LocalDateTime createTime = userRunProfile.getCreateTime().toLocalDateTime();
Duration duration = Duration.between(createTime, LocalDateTime.now());
if (duration.toDays() >= 7) {
userRunProfile.setFirstRecharge(false);
userRunProfile.setFirstRechargeEndTime(null);
}
}
}
@Override @Override
public UserProfile getByAccount(String account, String sysOrigin) { public UserProfile getByAccount(String account, String sysOrigin) {
BaseInfo baseInfo = baseInfoService.getByAccount(account,sysOrigin); BaseInfo baseInfo = baseInfoService.getByAccount(account,sysOrigin);
@ -266,7 +281,7 @@ public class UserRunProfileTransportGatewayImpl implements UserRunProfileTranspo
OneTimeTask response = oneTimeTaskService.queryCompletedFirstCharge(newUserRunProfile.getId(), newUserRunProfile.getOriginSys()); OneTimeTask response = oneTimeTaskService.queryCompletedFirstCharge(newUserRunProfile.getId(), newUserRunProfile.getOriginSys());
if (response == null) { if (response == null) {
newUserRunProfile.setFirstRecharge(true); newUserRunProfile.setFirstRecharge(true);
newUserRunProfile.setFirstRechargeEndTime(ZonedDateTimeUtils.toTimestamp(createTime.plusDays(7))); newUserRunProfile.setFirstRechargeEndTime(ZonedDateTimeUtils.toTimestampDefault(createTime.plusDays(7)));
} }
} }