@@ -28,4 +28,6 @@ public interface MaterialUploadTaskMapper extends BaseMapper<MaterialUploadTask>
void syncBytedance(@Param("signature") String signature);
void syncKuaishou(@Param("signature") String signature);
+
+ String getKuaiShouTokenByAccountId(@Param("accountId") Long accountId);
}
@@ -47,4 +47,19 @@
limit 1
</select>
+ <select id="getKuaiShouTokenByAccountId" resultType="java.lang.String">
+ SELECT
+ (CASE
+ WHEN
+ t2.access_token IS NOT NULL THEN
+ t2.access_token
+ ELSE t1.access_token
+ END
+ ) as 'access_token'
+ FROM
+ ctop_oauth_token t1
+ LEFT JOIN ctop_oauth_agent_token t2 ON t1.app_id = t2.app_id
+ WHERE
+ t1.account_id = = #{accountId}
+ </select>
</mapper>
@@ -122,7 +122,7 @@ public class MaterialUploadTaskServiceImpl
log.error("账户不能为空。");
return;
- String token = materialUploadTaskMapper.getTokenByAccountId(accountId);
+ String token = materialUploadTaskMapper.getKuaiShouTokenByAccountId(accountId);
if (Check.isNull(token)) {
log.error("此账户id未获取到token,accountId:{}", accountId);