feat: (authCtl) 磐农项目 token function 优化

icp-deliver/app/base/controller/impl/auth/authCtl.js

@@ -5,6 +5,7 @@ var settings = require("../../../../config/settings");
 
 
 const CtlBase = require("../../ctl.base");
 const CtlBase = require("../../ctl.base");
 const axios = require("axios");
 const axios = require("axios");
+const co = require("co");
 
 
 class AuthCtl extends CtlBase {
 class AuthCtl extends CtlBase {
     constructor() {
     constructor() {
@@ -29,24 +30,7 @@ class AuthCtl extends CtlBase {
     async getOpenToken(body) {
     async getOpenToken(body) {
         const url = `${settings.ydzUrl()}/auth/getToken`
         const url = `${settings.ydzUrl()}/auth/getToken`
         const ydzKey = settings.ydzKey();
         const ydzKey = settings.ydzKey();
-        let params = {
-            grantType: "authorization_code",
-            appKey: ydzKey.appKey,
-            redirectUri: "",
-            code: body.code
-        }
-        const res = await this.getRequest(url, params);
-        if (res.data.code == 200) {
-            let ydzToken = {
-                access_token: res.data.result.access_token,
-                refresh_token: res.data.result.refresh_token
-            }
-            const addRedisResult = await this.redisClient.setWithEx('ydzToken', JSON.stringify(ydzToken), 6 * 24 * 60 * 60);
-            // const getRedisResult = await this.redisClient.get('ydzToken');
-            return system.getResult(addRedisResult);
-        } else {
-            return system.getResultFail(201, res.data.message);
-        }
+        return await this.publicTokenFun(url, "authorization_code", ydzKey.appKey, body.code, "code");
     }
     }
 
 
     /**
     /**
@@ -56,11 +40,15 @@ class AuthCtl extends CtlBase {
         const url = `${settings.ydzUrl()}/auth/refreshToken`
         const url = `${settings.ydzUrl()}/auth/refreshToken`
         const ydzKey = settings.ydzKey();
         const ydzKey = settings.ydzKey();
         const getRedisResult = JSON.parse(await this.redisClient.get('ydzToken')).refresh_token;
         const getRedisResult = JSON.parse(await this.redisClient.get('ydzToken')).refresh_token;
+        return await this.publicTokenFun(url, "refresh_token", ydzKey.appKey, getRedisResult, "refreshToken")
+    }
+
+    async publicTokenFun(url, grantType, appKey, data, specialKey) {
         let params = {
         let params = {
-            grantType: "refresh_token",
-            appKey: ydzKey.appKey,
-            refreshToken: getRedisResult
+            grantType,
+            appKey
         }
         }
+        params[specialKey] = data;
         const res = await this.getRequest(url, params);
         const res = await this.getRequest(url, params);
         if (res.data.code == 200) {
         if (res.data.code == 200) {
             let ydzToken = {
             let ydzToken = {