瀏覽代碼

redis_db add readRedis fun

DevYK 3 年之前
父節點
當前提交
f7b79b4b92
共有 2 個文件被更改,包括 18 次插入9 次删除
  1. 2 9
      model/moralis_sdk.js
  2. 16 0
      model/redis_db.js

+ 2 - 9
model/moralis_sdk.js

@@ -147,14 +147,7 @@ const getAllTokenWithdrawInfoLists = async (obj) => {
     }
 }
 
-function readRedis(key) {
-    return new Promise((resolve) => {
-        redis.redis_get(key).then(result => {
-            // console.log("redis_get=", JSON.parse(result)); // Prints "value"
-            resolve(result);
-        });
-    })
-}
+
 
 /**
  * 获取代币价格 -> usdPrice
@@ -164,7 +157,7 @@ const getAllTotkenPrice = async () => {
         console.log('当前环境:', process.env.NODE_ENV);
         console.log("getAllTotkenPrice in"); // Prints "value"
         var token_price_key = reids_token_config.TOKENPRICE;
-        return await readRedis(token_price_key)
+        return await redis.readRedis(token_price_key)
     } catch (error) {
         console.error("getTotkenPrice=", error);
         return toJson(ERROR_CODE_001, null, error.toString());

+ 16 - 0
model/redis_db.js

@@ -57,7 +57,23 @@ async function redis_get(key) {
   return await REDIS_INSTANCE.get(key);
 }
 
+/**
+ * 同步
+ * 
+ * @param {*} key 
+ * @returns 
+ */
+function readRedis(key) {
+  return new Promise((resolve) => {
+      redis_get(key).then(result => {
+          // console.log("redis_get=", JSON.parse(result)); // Prints "value"
+          resolve(result);
+      });
+  })
+}
+
 module.exports = {
   redis_set,
   redis_get,
+  readRedis,
 }