接着上一篇 SpringBoot 开发抖音开放平台获取用户的粉丝统计和短视频数据(一篇) 的内容,我们继续来说。
1、开发细节
1.1、选择资源中心 -> Open Api -> 账号授权及绑定 查看接口文档,
1.2、用户扫码授权,回调我们的接口,拿到code,再调用获取access_token的接口,也可以拿到用户对应的open_id,因为access_token是有时效性的,所以我们要做缓存,要在过期前先用refresh_token刷新延长access_token的有效期,又过期后只能让用户重新授权。
授权相关的service
private static final String OAUTH_STATE_SESSION_KEY = "OAUTH_STATE_SESSION_KEY";
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Value("${redis.key.douyinTokenKeyPrefix}")
private String douyinTokenKeyPrefix;
@Value("${redis.key.douyinRefreshTokenKeyPrefix}")
private String douyinRefreshTokenKeyPrefix;
@Value("${redis.key.douyinClientTokenKey}")
private String douyinClientTokenKey;
/**
* 获取授权码(code)
* @param clientKey
* @param redirectUri
* @param state
* @return
*/
@Override
public String qrcodeAuth(String clientKey,String redirectUri,String state) {
String requestUrl = Urls.BASE_URL+String.format(Urls.PERSON_CONNECT_URL,clientKey,redirectUri,state);
ShiroUtils.setSessionAttribute(OAUTH_STATE_SESSION_KEY,state);
logger.info("qrConnect requestUrl=" + requestUrl);
return requestUrl;
}
/**
* 获取access_token
* @param request
* @param clientKey
* @param clientSecret
* @return
*/
@Override
public TokenResult accessToken(HttpServletRequest request,String clientKey,String clientSecret) {
String code = request.getParameter("code");
String state = request.getParameter("state");
Object sessionState = SecurityUtils.getSubject().getSession().getAttribute(OAUTH_STATE_SESSION_KEY);
TokenResult token = new TokenResult();
//校验state
if (sessionState != null && state.equalsIgnoreCase(sessionState.toString())) {
SecurityUtils.getSubject().getSession().removeAttribute(OAUTH_STATE_SESSION_KEY);
String requestUrl = Urls.BASE_URL+String.format(Urls.ACCESS_TOKEN_URL,clientKey,clientSecret,code);
JSONObject response = (CommonUtil.httpsRequestJson(requestUrl, "GET", null));
JSONObject object = response.getJSONObject("data");
logger.info("accessToken result=" + response);
int errorCode = object.getInteger("error_code");
String description = object.getString("description");
if (errorCode == 0) {
token.setErrorCode(0);
token.setAccessToken(object.getString("access_token"));
token.setExpiresIn(object.getInteger("expires_in"));
token.setRefreshToken(object.getString("refresh_token"));
token.setOpenId(object.getString("open_id"));
token.setScope(object.getString("scope"));
} else {
token.setErrorCode(errorCode);
token.setDescription(description);
}
} else {
token.setErrorCode(500);
token.setDescription("state校验失败");
}
return token;
}
/**
* 刷新access_token
* @param clientKey
* @param refreshToken
* @return
*/
@Override
public TokenResult refreshToken(String clientKey,String refreshToken) {
String requestUrl = Urls.BASE_URL+String.format(Urls.REFRESH_TOKEN_URL,clientKey,refreshToken);
JSONObject response = (CommonUtil.httpsRequestJson(requestUrl, "GET", null));
JSONObject object = response.getJSONObject("data");
logger.info("refreshToken result=" + response);
int errorCode = object.getInteger("error_code");
String description = object.getString("description");
TokenResult token = new TokenResult();
if (errorCode == 0) {
token.setErrorCode(0);
token.setAccessToken(object.getString("access_token"));
token.setExpiresIn(object.getInteger("expires_in"));
token.setRefreshToken(object.getString("refresh_token"));
token.setOpenId(object.getString("open_id"));
token.setScope(object.getString("scope"));
} else {
token.setErrorCode(errorCode);
token.setDescription(description);
}
return token;
}
授权相关的controller
private String douyinTokenKeyPrefix;
@Value("${redis.key.douyinRefreshTokenKeyPrefix}")
private String douyinRefreshTokenKeyPrefix;
@Value("${open.douyin.clientKey}")
private String clientKey;
@Value("${open.douyin.clientSecret}")
private String clientSecret;
/**
* 抖音授权登录
* @param anchorUuid
* @param response
* @throws IOException
*/
@RequestMapping(value = "qrcodeAuth")
public void qrcodeAuth(String anchorUuid, HttpServletResponse response) throws IOException {
String redirectUrl = parameter.getSERVER_PATH() + "/mobile/douyin/authCallback";
String state = UuidUtils.randomUUID() + "::" + anchorUuid;
String requestUrl = oauthService.qrcodeAuth(clientKey, URLEncoder.encode(redirectUrl, "UTF-8"), state);
response.sendRedirect(requestUrl);
}
/**
* 抖音授权回调
* @param request
* @return
*/
@RequestMapping(value = "authCallback")
public void authCallback(HttpServletRequest request) {
String state = request.getParameter("state");
String anchorUuid = state.split("::")[1];
TokenResult result = oauthService.accessToken(request, clientKey, clientSecret);
if (result.getErrorCode() == 0) {
String openId = result.getOpenId();
String accessToken = result.getAccessToken();
//保存accessToken等信息到缓存
stringRedisTemplate.opsForValue().set(douyinTokenKeyPrefix + anchorUuid,
accessToken, 14, TimeUnit.DAYS);
stringRedisTemplate.opsForValue().set(douyinRefreshTokenKeyPrefix + anchorUuid,
result.getRefreshToken(), 29, TimeUnit.DAYS);
logger.info("accessToken===" + accessToken);
anchorService.saveDouyin(accessToken, anchorUuid, openId);
}
}
1.3、根据access_token和open_id就可以获取到该用户的基本信息和粉丝统计数据
* 获取用户信息
* @param accessToken
* @param openId
* @return
*/
@Override
public JSONObject userInfo(String accessToken,String openId) {
String requestUrl = Urls.BASE_URL+String.format(Urls.USERINFO_URL,accessToken,openId);
JSONObject response = (CommonUtil.httpsRequestJson(requestUrl, "GET", null));
JSONObject object = response.getJSONObject("data");
logger.info("userInfo result=" + response);
return object;
}
/**
* 获取用户粉丝数据
* @param accessToken
* @param openId
* @return
*/
@Override
public JSONObject fansData(String accessToken,String openId) {
String requestUrl = Urls.BASE_URL+String.format(Urls.FANS_DATA_URL,accessToken,openId);
JSONObject response = (CommonUtil.httpsRequestJson(requestUrl, "GET", null));
JSONObject object = response.getJSONObject("data");
logger.info("fansData result=" + response);
return object;
}
用户信息接口没有返回该用户的粉丝数,倒是在粉丝统计数据接口那边返回来粉丝数,可以在这边拿到粉丝数存到用户表,结合前端开发,把数据传给前端就可以显示出来了。这边叫了一个漂亮的小姐姐授权了,下面有短视频截图,你们就说好不好看吧。
用户基本信息
粉丝年龄分布、区域分布和性别分布
粉丝活跃分布
粉丝设备分布
粉丝兴趣分布
1.4、根据access_token和open_id就可以获取到该用户所有的抖音短视频数据
* 该接口用于分页获取用户所有视频的数据。返回的数据是实时的。
* 列出已发布的视频
* @param accessToken
* @param openId
* @param cursor
* @param count
* @return
*/
@Override
public JSONObject videoList(String accessToken,String openId,Long cursor,Integer count) {
String requestUrl = Urls.BASE_URL+String.format(Urls.VIDEO_LIST_URL,accessToken,openId,cursor,count);
JSONObject response = (CommonUtil.httpsRequestJson(requestUrl, "GET", null));
logger.info("videoList result=" + response);
return response;
}
和粉丝数一样,开放平台没有提供接口直接获取用户的作品数、点赞数、总评论数、总分享数、平均点赞数、平均评论数、平均分享数,所以我们在获取到所有视频的时候要根据每条视频返回来的相应字段计算出这些数据再存到数据库,结合前端开发,把数据传给前端就可以显示出来了。
这里不得不吐槽一下,像粉丝数、作品数、点赞数、总评论数、总分享数等这些和用户相关的字段应该统计出来在用户信息那个接口就要返回来的,这样能给开发者省了很多时间,而且更符合常理,不知道抖音是怎么想的。
5、总结
5.1、看完这些代码之后,其实也不难,和对接其他第三方接口一样,只要照着文档写,总能调出结果来。现在看到的抖音开放平台文档是更新过的,看上去会比之前要好些,不管是版面、注意点还是参数注释都有改进,虽然还是没提供demo下载,但是增加了几种语言的接口调用样例虽然没有什么实际的作用,但是手心手背都是肉,还是知足些吧。
5.2、第一次对接新的第三方接口基本都有坑,大部分时候我们都寄希望于踩过坑的前人能够填好这些坑,给后来的人一些参考,少走弯路,节省时间,提高效率。起初抖音官方在飞书建了开放平台技术讨论群,可以在里面问问题,但是没多久上线了工单平台,要开发者有问题就提工单,就关掉了飞书群。有过对接第三方开发经验的应该都有感触,提交工单的途径来问问题的效率有多慢。下面就列出一些在开发过程中遇到的坑,小伙伴们感受一波。
问题:当时对接的时候,修改回调域名需要重新审核,不知道现在平台改过来没有。
解决:所以为了保险起见,还是一开始就填正确,这点微信开放平台修改回调域名不需要审核。
问题:在做OAuth 2.0授权时,scope传入多个,像这样scope=aweme.share,hotsearch,enterprise.data,user_info,fans.list,following.list,fans.data,video.create,video.delete,video.data,video.list,video.comment,总是报“权限非法”,我去掉一个就可以,我试了多次后猜想应该是scope太长了,最后一个权限被抖音截掉了(比如video.comment被截断变成了video.com,而video.com确实不是完整的权限,所以就报权限非法的错误)。
解决:然后向平台反应了,果然这是他们的一个bug,现在已经修复了。
问题:接口不稳定,有时候可以,有时候不可以。
解决:所有的接口路径,最后面都要加上“/”,比如/fans/data/,这个不知道为什么,是问了抖音工作人员给出的解决方案。
问题:调用授权二维码的时候,如果因为自身业务需要在用户扫码确认授权后回调我们的接口那边携带自己的参数,要注意,不能在回调接口的路径上拼接参数,因为回调那边获取不到,比如回调接口路径是/mobile/douyin/authCallback,不能这样携带参数/mobile/douyin/authCallback?userId=36781631,这应该也是被抖音限制了吧,但是做微信扫码授权就可以这样传参。
解决:扫码的时候为了安全需要传入一个随机数state,可以在state后面拼接我们的业务参数,然后在回调那边获取到state后截取。
山水有相逢,来日皆可期,谢谢阅读,我们再会
我手中的金箍棒,上能通天,下能探海