feat: token改为本地缓存

db/tenantAccessToken/index.ts

@@ -1,11 +1,14 @@
 import pbClient from "../pbClient";
 
+let token = "";
+
 /**
  * 更新租户的token
  * @param {string} value 新的token
  */
 const update = async (value: string) => {
   await pbClient.collection("config").update("ugel8f0cpk0rut6", { value });
+  token = value;
   console.log("reset access token success", value);
 };
 
@@ -14,6 +17,7 @@ const update = async (value: string) => {
  * @returns {string} 租户的token
  */
 const get = async () => {
+  if (token) return token;
   const { value } = await pbClient
     .collection("config")
     .getOne("ugel8f0cpk0rut6");

utils/sendMsg.ts

@@ -21,27 +21,35 @@ export const sendMsg = async (
     Authorization: `Bearer ${tenant_access_token}`,
   };
   const body = { receive_id, msg_type, content };
-  const res = await fetch(URL, {
-    method: "POST",
-    headers: header,
-    body: JSON.stringify(body),
-  });
-  const data = (await res.json()) as any;
-  if (data.code !== 0) {
-    console.log("sendMsg error", data);
+  try {
+    const res = await fetch(URL, {
+      method: "POST",
+      headers: header,
+      body: JSON.stringify(body),
+    });
+    const data = (await res.json()) as any;
+    if (data.code !== 0) {
+      console.log("sendMsg error", data);
+      return {
+        code: data.code,
+        msg: data.msg,
+      };
+    }
+    console.log("sendMsg success", data);
     return {
-      code: data.code,
-      msg: data.msg,
+      code: 0,
+      msg: "success",
+      data: {
+        message_id: data.data.message_id,
+      },
+    };
+  } catch (error) {
+    console.log("sendMsg error", error);
+    return {
+      code: 1,
+      msg: "fetch error",
     };
   }
-  console.log("sendMsg success", data);
-  return {
-    code: 0,
-    msg: "success",
-    data: {
-      message_id: data.data.message_id,
-    },
-  };
 };
 
 // sendMsg('user_id', 'liuke9', 'text', JSON.stringify({text: '这是测试消息，不要回复'}))