关注监听器更新

src/main/java/cn/meteor/beyondclouds/modules/user/listener/UserFollowedListener.java

@@ -61,4 +61,25 @@ public class UserFollowedListener implements DataItemChangeListener {
         }
         }
     }
     }
 
 
+    @Override
+    public void onDataItemDelete(DataItemChangeMessage dataItemChangeMessage) {
+        String operatorId = dataItemChangeMessage.getOperatorId();
+        String itemId = (String) dataItemChangeMessage.getItemId();
+        UserFollow userFollow = userFollowService.getById(itemId);
+        String followerId = userFollow.getFollowerId();
+
+        Assert.isTrue(followerId.equals(operatorId), "数据不合法");
+
+        String followedId = userFollow.getFollowedId();
+        // 用户关注
+        if (dataItemChangeMessage.getItemType().equals(DataItemType.USER_FOLLOW)) {
+            // 更新关注者的关注列表
+            redisHelper.setRemove(RedisKey.USER_FOLLOWED(operatorId), followedId);
+
+            // 检查被关注者
+            if (redisHelper.hasKey(RedisKey.USER_FANS(followedId))) {
+                redisHelper.setRemove(RedisKey.USER_FANS(followedId), operatorId);
+            }
+        }
+    }
 }
 }