DevYK 2 rokov pred
rodič
commit
b53b6fe825
2 zmenil súbory, kde vykonal 6 pridanie a 5 odobranie
  1. 3 3
      model/moralis_sdk.js
  2. 3 2
      routes/sdk.js

+ 3 - 3
model/moralis_sdk.js

@@ -899,7 +899,7 @@ async function getTokenTransfers(opt) {
 
             //异常
             if (t_2 && t_2.total > 0 && Array.isArray(t_2.result) && t_2.result.length <= 0) {
-                logger.error('getTokenTransfers token 数据异常 -->>>', t_2.toString(), options.toString());
+                logger.error('getTokenTransfers token 数据异常 -->>>', t_2.toString(), JSON.stringify(options));
             }
 
             logger.log('getTokenTransfers token ret -->>> t_2', t_2);
@@ -924,7 +924,7 @@ async function getTokenTransfers(opt) {
             logger.log('getTokenTransfers-->>> sort t_1', t_1);
             return toJson(SUCCEED_CODE, t_1, null);
         } catch (error) {
-            logger.error("getTransactions error:", error.toString(), options.toString())
+            logger.error("getTransactions error:", error.toString(), JSON.stringify(options))
             return toJson(ERROR_CODE_001, null, error.toString());
         }
     } else if (options.type == 'transaction_hash') {//根据哈希查询
@@ -939,7 +939,7 @@ async function getTokenTransfers(opt) {
             logger.log('transaction_hash getTransaction ret-->>> ', transaction,obj);
             return toJson(SUCCEED_CODE, obj, null);
         } catch (error) {
-            logger.error("native getTransaction error:", error.toString(), options.toString())
+            logger.error("native getTransaction error:", error.toString(), JSON.stringify(options))
             return toJson(ERROR_CODE_001, null, error.toString());
         }
     } else {

+ 3 - 2
routes/sdk.js

@@ -138,12 +138,13 @@ async function withdraw_task() {
                 var tryCount = 10;
                 do {
                     try {
+                        //通过获取上一个交易记录来进行确认
                         var transaction = await moralis.getTokenTransfers(options);
                         logger.log('withdraw_task exectransaction', transaction, options, tryCount);
                         transaction = JSON.parse(transaction)
                         if (transaction.code == 0) {
                             if (transaction.data.result.length <= 0) {
-                                await utils.sleep(1500)
+                                await utils.sleep(5000)
                             } else {
                                 break
                             }
@@ -196,7 +197,7 @@ async function withdraw_task() {
             update_obj.withdraw_status = 3
             update_obj.errorMsg = error.toString()
             await withdraw_db.update_withdraw_task(exec_obj.withdraw_id, update_obj)
-            logger.error('withdraw_task error=', error)
+            logger.error('withdraw_task error=', error.toString())
         }
     }
 }