修复内置token获取

back/app.ts

@@ -27,16 +27,4 @@ async function startServer() {
   await require('./loaders/server').default({ server });
 }
 
-function initEnv() {
-  process.env.NODE_ENV = process.env.NODE_ENV || 'development';
-  // 声明QL_DIR环境变量
-  let qlHomePath = path.join(__dirname, '../../');
-  // 生产环境
-  if (qlHomePath.endsWith('/static/')) {
-    qlHomePath = path.join(qlHomePath, '../');
-  }
-  process.env.QL_DIR = qlHomePath;
-}
-
-initEnv();
 startServer();

back/config/index.ts

@@ -2,6 +2,15 @@ import dotenv from 'dotenv';
 import path from 'path';
 import { createRandomString } from './util';
 
+process.env.NODE_ENV = process.env.NODE_ENV || 'development';
+// 声明QL_DIR环境变量
+let qlHomePath = path.join(__dirname, '../../');
+// 生产环境
+if (qlHomePath.endsWith('/static/')) {
+  qlHomePath = path.join(qlHomePath, '../');
+}
+process.env.QL_DIR = qlHomePath;
+
 const lastVersionFile = `http://qn.whyour.cn/version.ts?v=${Date.now()}`;
 
 const envFound = dotenv.config();

back/services/open.ts

@@ -170,6 +170,7 @@ export default class OpenService {
         client_secret: systemApp.client_secret,
       });
       token = authToken.data;
+      token.value = token.token;
     } else {
       token = [...systemApp.tokens].pop();
     }

back/token.ts

@@ -0,0 +1,56 @@
+import 'reflect-metadata';
+import OpenService from './services/open';
+import { Container } from 'typedi';
+import LoggerInstance from './loaders/logger';
+import fs from 'fs';
+import config from './config';
+import path from 'path';
+
+const tokenFile = path.join(config.configPath, 'token.json');
+
+async function getToken() {
+  try {
+    const data = await readFile();
+    const nowTime = Math.round(Date.now() / 1000);
+    if (data.value && data.expiration > nowTime) {
+      console.log(data.value);
+    } else {
+      Container.set('logger', LoggerInstance);
+      const openService = Container.get(OpenService);
+      const appToken = await openService.findSystemToken();
+      console.log(appToken.value);
+      await writeFile({
+        value: appToken.value,
+        expiration: appToken.expiration,
+      });
+    }
+  } catch (error) {
+    console.log(error);
+  }
+}
+
+async function readFile() {
+  return new Promise<any>((resolve, reject) => {
+    fs.readFile(
+      path.join(config.configPath, 'token.json'),
+      { encoding: 'utf8' },
+      (err, data) => {
+        if (err) {
+          resolve({});
+        } else {
+          resolve(JSON.parse(data));
+        }
+      },
+    );
+  });
+}
+
+async function writeFile(data: any) {
+  return new Promise<void>((resolve, reject) => {
+    fs.writeFile(tokenFile, JSON.stringify(data), { encoding: 'utf8' }, () => {
+      resolve();
+    });
+  });
+}
+
+getToken();