数据汇聚

src/main/java/com/sxtvs/open/api/odata/controller/OauthController.java

@@ -67,10 +67,10 @@ public class OauthController {
     private WbYmAccountServiceImpl weiboAccountService;
 
     @RequestMapping("weibo/callback")
-    public String weiboCallback(String code, String state) throws JsonProcessingException {
-        logger.info("key", "oauth/weibo/callback", "code", code);
+    public String weiboCallback(@RequestParam("network_group_id") String networkGroupId, String state) throws JsonProcessingException {
+        logger.info("key", "oauth/weibo/callback", "code", networkGroupId);
         // todo 用户数据入库
-        weiboAccountService.upsert(code);
+        weiboAccountService.upsert(networkGroupId);
         return "redirect:https://open.sxtvs.net";
     }
 

src/main/java/com/sxtvs/open/api/odata/service/impl/WbYmAccountServiceImpl.java

@@ -13,6 +13,7 @@ import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.Arrays;
 import java.util.Map;
 
 /**
@@ -34,7 +35,7 @@ public class WbYmAccountServiceImpl extends ServiceImpl<WbYmAccountMapper, WbYmA
     public void upsert(String networkGroupId) throws JsonProcessingException {
         String accessToken = youmeiAccountService.getSxgdAccount().getAccessToken();
         String body = HttpUtil.createPost("https://api-open.51wyq.cn/dataapp/api/umei/fw/open/network_group/get_weibo_user_info")
-                .form(Map.of("accessToken", accessToken, "network_group_ids", new String[]{networkGroupId}))
+                .form(Map.of("accessToken", accessToken, "network_group_ids", networkGroupId))
                 .execute().body();
         YMWeiboAccount o = objectMapper.readValue(body, YMWeiboAccount.class);