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-29 20:44:54 +08:00
parent 39c351217b
commit b1f754bd38
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/family/DisbandFamilyCmdExe.java
View File

@ -18,7 +18,11 @@ import com.red.circle.other.infra.enums.family.FamilyNewsTypeEnum;
import com.red.circle.other.infra.enums.family.FamilyStatusEnum; import com.red.circle.other.infra.enums.family.FamilyStatusEnum;
import com.red.circle.other.inner.asserts.FamilyErrorCode; import com.red.circle.other.inner.asserts.FamilyErrorCode;
import com.red.circle.tool.core.collection.CollectionUtils; import com.red.circle.tool.core.collection.CollectionUtils;
import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -57,8 +61,8 @@ public class DisbandFamilyCmdExe {
disbandFamilyStatus(familyId); disbandFamilyStatus(familyId);
// recordDisbandNews(cmd.getReqSysOrigin().getOrigin(), familyId, familyBaseInfo.getFamilyName()); List<FamilyMemberInfo> allMembers = familyMemberInfoService.listByFamilyId(familyId);
notifyAllMembers(allMembers, familyId);
} }
private void clearFamilyData(Long familyId) { private void clearFamilyData(Long familyId) {
@ -94,10 +98,7 @@ public class DisbandFamilyCmdExe {
return; return;
} }
members.forEach(member -> { userProfileGateway.removeCacheAll(members.stream().map(FamilyMemberInfo::getMemberUserId).collect(Collectors.toSet()));
familyCommon.removeGroup(familyId, member.getMemberUserId());
userProfileGateway.removeCacheAll(member.getMemberUserId());
});
} }
} }