feat(FlowUserController): 更新api地址、收藏同步任务不在同步image

Author: LiggMax

flow-client/src/main/java/com/ligg/flowclient/controller/AccountController.java

@@ -170,6 +170,7 @@ public Result<FlowUserVo> bindEmail(
      * 提交 Bangumi 收藏同步任务（异步执行，立即返回任务状态）。
      * 从 user_oauth 读取 Bangumi token 拉取收藏并写入 user_bgm_collection。
      */
+    @Deprecated
     @PostMapping("/oauth/bangumi/collections/sync")
     @IpEndpointRateLimit(keyPrefix = "animeflow:account:sync-bgm-collection:ip:", seconds = 60, maxRequests = 5)
     public Result<UserBgmCollectionSyncStatusVo> syncBangumiCollections(

flow-client/src/main/java/com/ligg/flowclient/controller/FlowUserController.java

@@ -6,21 +6,18 @@
 package com.ligg.flowclient.controller;
 
 import com.ligg.common.entity.UserOauthEntity;
-import com.ligg.common.exception.LoginExpiredException;
 import com.ligg.common.response.Result;
 import com.ligg.common.statuenum.ResponseCode;
+import com.ligg.flowclient.annotation.IpEndpointRateLimit;
 import com.ligg.flowclient.interceptor.AuthorizationInterceptor;
 import com.ligg.flowclient.module.dto.UpdateUserCollectionDto;
 import com.ligg.flowclient.module.dto.UpdateUserDto;
 import com.ligg.flowclient.module.vo.FlowUserVo;
 import com.ligg.common.vo.bangumi.UserCollectionsVo;
-import com.ligg.flowclient.service.BangumiOAuthTokenService;
-import com.ligg.flowclient.service.JwtTokenService;
-import com.ligg.flowclient.service.UserBgmCollectionService;
-import com.ligg.flowclient.service.UserService;
+import com.ligg.flowclient.module.vo.UserBgmCollectionSyncStatusVo;
+import com.ligg.flowclient.service.*;
 import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
-import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -35,6 +32,8 @@ public class FlowUserController {
 
     private final BangumiOAuthTokenService bangumiOAuthTokenService;
 
+    private final UserBgmCollectionSyncService userBgmCollectionSyncService;
+
     private final JwtTokenService jwtTokenService;
 
     /**
@@ -104,4 +103,29 @@ public Result<Void> updateCollection(
         userBgmCollectionService.updateCollection(accessToken, subjectId, body);
         return Result.success();
     }
+
+    /**
+     * 提交 Bangumi 收藏同步任务（异步执行，立即返回任务状态）。
+     * 从 user_oauth 读取 Bangumi token 拉取收藏并写入 user_bgm_collection。
+     */
+    @PostMapping("/collections/sync")
+    @IpEndpointRateLimit(keyPrefix = "animeflow:account:sync-bgm-collection:ip:", seconds = 60, maxRequests = 5)
+    public Result<UserBgmCollectionSyncStatusVo> syncBangumiCollections(
+            @RequestAttribute(AuthorizationInterceptor.ACCESS_TOKEN_REQUEST_ATTRIBUTE) String accessToken,
+            @RequestParam(defaultValue = "2") int subjectType) {
+        Long userId = jwtTokenService.validateAccessToken(accessToken);
+        UserBgmCollectionSyncStatusVo status = userBgmCollectionSyncService.triggerSync(userId, subjectType);
+        return Result.success(ResponseCode.SUCCESS, status);
+    }
+
+    /**
+     * 查询 Bangumi 收藏同步任务状态。
+     */
+    @GetMapping("/collections/sync")
+    public Result<UserBgmCollectionSyncStatusVo> getBangumiCollectionSyncStatus(
+            @RequestAttribute(AuthorizationInterceptor.ACCESS_TOKEN_REQUEST_ATTRIBUTE) String accessToken) {
+        Long userId = jwtTokenService.validateAccessToken(accessToken);
+        UserBgmCollectionSyncStatusVo status = userBgmCollectionSyncService.getSyncStatus(userId);
+        return Result.success(ResponseCode.SUCCESS, status);
+    }
 }

flow-client/src/main/java/com/ligg/flowclient/service/UserBgmCollectionSyncRunner.java

@@ -139,7 +139,6 @@ private void upsertCollection(Long userId, UserCollectionsDto.Item item) {
         row.setUserId(userId);
         row.setSubjectId(item.getId());
         row.setSubjectType(item.getType() != null ? item.getType() : 2);
-        row.setImages(toJson(item.getImages()));
         row.setBgmInterestId(interest.getId());
         row.setRate(interest.getRate() != null ? interest.getRate() : 0);
         row.setType(interest.getType());