Quellcode durchsuchen

小店token刷新

yumeng vor 7 Monaten
Ursprung
Commit
92ddfcb107

+ 9 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/controller/KuaishouItemListController.java

@@ -142,6 +142,15 @@ public class KuaishouItemListController extends BaseController {
         accessTokenService.refreshJYAccessToken();
     }
 
+
+    @GetMapping("/kwaixiaodianAccessToken")
+    @ApiOperation(value = "jyAccessToken")
+    public void kwaixiaodianAccessToken() {
+        accessTokenService.refreshKwaixiaodianAccessToken();
+    }
+
+
+
     @GetMapping("/getRegimental")
     @ApiOperation(value = "团长信息")
     public JSONObject getRegimental() {

+ 6 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/mapper/AccessTokenMapper.java

@@ -1,5 +1,7 @@
 package com.ruixuan.isc.mapper;
 
+
+import com.alibaba.fastjson.JSONObject;
 import com.ruixuan.isc.entity.JYAccessToken;
 import com.ruixuan.isc.entity.KuaishouAccessToken;
 import org.apache.ibatis.annotations.Param;
@@ -30,4 +32,8 @@ public interface AccessTokenMapper {
     void updateJYAccessToken(JYAccessToken updateToken);
 
     JYAccessToken getJYTokenInfoByPromoter(@Param("promoterId") Long promoterId);
+
+    List<JSONObject> getKwaixiaodianTokens();
+
+    void updateKwaixiaodianAccessToken(@Param("id") String id, @Param("updateAccessToken") String updateAccessToken, @Param("updateRefreshToken") String updateRefreshToken);
 }

+ 4 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/IAccessTokenService.java

@@ -14,6 +14,9 @@ public interface IAccessTokenService {
 
     void refreshByteDanceAccessToken();
 
+    void refreshKwaixiaodianAccessToken();
+
+
     List<KuaishouAccessToken> getTokenInfos();
 
     List<KuaishouAccessToken> getMgsTokenInfos();
@@ -24,4 +27,5 @@ public interface IAccessTokenService {
 
     List<KuaishouAccessToken> getRocketTokenInfos();
 
+
 }

+ 31 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/AccessTokenServiceImpl.java

@@ -109,6 +109,36 @@ public class AccessTokenServiceImpl implements IAccessTokenService {
     }
 
     @Override
+    public void refreshKwaixiaodianAccessToken() {
+        List<JSONObject> tokens = accessTokenMapper.getKwaixiaodianTokens();
+        if (!Check.isNull(tokens)) {
+            for (int i = 0; i < tokens.size(); i++) {
+                JSONObject tokenJson = tokens.get(i);
+                String id = tokenJson.getString("id");
+                String appKey = tokenJson.getString("appKey");
+                String appSecret = tokenJson.getString("appSecret");
+                String refreshToken = tokenJson.getString("refreshToken");
+
+                OauthAccessTokenKsClient oauthAccessTokenKsClient = new OauthAccessTokenKsClient(appKey, appSecret);
+                try {
+                    KsAccessTokenResponse response = oauthAccessTokenKsClient.refreshAccessToken(refreshToken);
+                    JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(response));
+                    log.info("刷新token,id:{},返回结果:{}", id, jsonObject);
+                    if (jsonObject.getInteger("result") == 1) {
+                        String updateAccessToken = jsonObject.getString("accessToken");
+                        String updateRefreshToken = jsonObject.getString("refreshToken");
+                        accessTokenMapper.updateKwaixiaodianAccessToken(id, updateAccessToken, updateRefreshToken);
+                    }
+                } catch (KsMerchantApiException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+
+
+    }
+
+    @Override
     public void refreshJYAccessToken() {
         List<JYAccessToken> tokens = accessTokenMapper.getJYTokenInfos();
         if (!Check.isNull(tokens)) {
@@ -134,6 +164,7 @@ public class AccessTokenServiceImpl implements IAccessTokenService {
             }
         }
     }
+
     @Override
     public List<KuaishouAccessToken> getTokenInfos() {
         return accessTokenMapper.getTokenInfos();

+ 15 - 0
ruixuan-live/src/main/resources/mapper/isc/AccessTokenMapper.xml

@@ -24,6 +24,12 @@
             update_time   = #{updateTime}
         where id = #{id}
     </update>
+    <update id="updateKwaixiaodianAccessToken">
+        UPDATE kwaixiaodian_access_token
+        SET access_token  = #{updateAccessToken},
+            refresh_token = #{updateRefreshToken}
+        WHERE id = #{id}
+    </update>
 
 
     <select id="getAccessToken" resultType="com.ruixuan.isc.entity.KuaishouAccessToken">
@@ -73,5 +79,14 @@
         WHERE promoter_id = #{promoterId}
 
     </select>
+    <select id="getKwaixiaodianTokens" resultType="com.alibaba.fastjson.JSONObject">
+        SELECT  id AS 'id',
+                access_token AS 'accessToken',
+                refresh_token AS 'refreshToken',
+                app_key AS 'appKey',
+                app_secret AS 'appSecret',
+                sign_secret AS 'signSecret'
+        FROM kwaixiaodian_access_token
+    </select>
 
 </mapper>