update user rcmd

content/content-service/src/main/java/cn/reghao/tnb/content/app/vod/service/impl/RecommendServiceImpl.java

@@ -166,13 +166,14 @@ public class RecommendServiceImpl implements RecommendService {
             return Result.fail("此功能仅对 VIP 用户开放");
         }
 
+        boolean changed;
         if (mode) {
-            userService.setRecommendMode(loginUser, RcmdMode.VIP.getValue());
+            changed = userService.setRecommendMode(loginUser, RcmdMode.VIP.getValue());
         } else {
-            userService.setRecommendMode(loginUser, RcmdMode.USER.getValue());
+            changed = userService.setRecommendMode(loginUser, RcmdMode.USER.getValue());
         }
 
-        if (getRecommendMode()) {
+        if (changed) {
             String itemsKey = RedisKeys.getUserItemKey(loginUser);
             redisOps.del(itemsKey);
         }

user/user-api/src/main/java/cn/reghao/tnb/user/api/iface/UserService.java

@@ -15,5 +15,5 @@ public interface UserService {
     boolean isVip(long userId);
     void sendUserMessage(UserMessageDto userMessageDto);
     int getRecommendMode(long userId);
-    void setRecommendMode(long userId, int mode);
+    boolean setRecommendMode(long userId, int mode);
 }

user/user-service/src/main/java/cn/reghao/tnb/user/app/rpc/UserServiceImpl.java

@@ -79,13 +79,18 @@ public class UserServiceImpl implements UserService {
     }
 
     @Override
-    public void setRecommendMode(long userId, int mode) {
-        Integer mode1 = userRecommendMapper.findByUserId(userId);
-        if (mode1 == null) {
+    public boolean setRecommendMode(long userId, int mode) {
+        boolean changed = true;
+        Integer currentMode = userRecommendMapper.findByUserId(userId);
+        if (currentMode == null) {
             UserRecommend userRecommend = new UserRecommend(userId, mode);
             userRecommendMapper.save(userRecommend);
-        } else if (mode1 != mode) {
+        } else if (currentMode != mode) {
             userRecommendMapper.updateMode(userId, mode);
+        } else {
+            changed = false;
         }
+
+        return changed;
     }
 }