diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/UserShieldBlackAddCmdExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/UserShieldBlackAddCmdExe.java index 64aabb40..23e9c901 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/UserShieldBlackAddCmdExe.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/UserShieldBlackAddCmdExe.java @@ -11,10 +11,7 @@ import com.red.circle.other.infra.database.mongo.service.live.RoomProfileManager import com.red.circle.other.infra.database.mongo.service.live.RoomUserBlacklistService; import com.red.circle.other.infra.database.rds.entity.user.user.BaseInfo; import com.red.circle.other.infra.database.rds.entity.user.user.CpRelationship; -import com.red.circle.other.infra.database.rds.service.user.user.BaseInfoService; -import com.red.circle.other.infra.database.rds.service.user.user.CpRelationshipService; -import com.red.circle.other.infra.database.rds.service.user.user.RelationshipFriendService; -import com.red.circle.other.infra.database.rds.service.user.user.ShieldBlackService; +import com.red.circle.other.infra.database.rds.service.user.user.*; import com.red.circle.other.inner.asserts.OtherErrorCode; import com.red.circle.other.inner.enums.config.EnumConfigKey; import com.red.circle.other.inner.enums.live.RoomUserRolesEnum; @@ -43,6 +40,7 @@ public class UserShieldBlackAddCmdExe { private final RoomProfileManagerService roomProfileManagerService; private final RelationshipFriendService relationshipFriendService; private final CpRelationshipService cpRelationshipService; + private final UserSubscriptionService userSubscriptionService; public void execute(UserShieldBlackUserCmd cmd) { @@ -67,6 +65,9 @@ public class UserShieldBlackAddCmdExe { relationshipFriendService.removeFriend(cmd.requiredReqUserId(), cmd.getShieldUserId()); relationshipFriendService.removeFriend(cmd.getShieldUserId(), cmd.requiredReqUserId()); + userSubscriptionService.remove(cmd.requiredReqUserId(), cmd.getShieldUserId()); + userSubscriptionService.remove(cmd.getShieldUserId(), cmd.requiredReqUserId()); + // 拉黑房间 BaseInfo beBlackUser = baseInfoService.getById(cmd.getShieldUserId()); ResponseAssert.notNull(UserErrorCode.USER_INFO_NOT_FOUND, beBlackUser);