捕获异常

model/moralis_sdk.js

@@ -1427,16 +1427,20 @@ async function getTokenTransfersV2(opt) {
                 logger.log('getTokenTransfersV2 native ret -->>> t_1', t_1);
                 break
             } catch (error) {
-                if (tryCount == 1) {
-                    t_1 = await getTransferRecord(options, 'native', 0);
-                    if (t_1) {
-                        logger.info('sync-node-native-data', JSON.stringify(t_1))
-                        break
-                    } else {
-                        logger.error('sync-node-native-data error', JSON.stringify(options))
+                try {
+                    if (tryCount == 1) {
+                        t_1 = await getTransferRecord(options, 'native', 0);
+                        if (t_1) {
+                            logger.info('sync-node-native-data', options)
+                            break
+                        } else {
+                            logger.error('sync-node-native-data error', JSON.stringify(options))
+                        }
+                        logger.error("getTokenTransfersV2 error:", '主流币：', error.toString(), JSON.stringify(options))
+                        return toJson(ERROR_CODE_001, null, error.toString());
                     }
-                    logger.error("getTokenTransfersV2 error:", '主流币：', error.toString(), JSON.stringify(options))
-                    return toJson(ERROR_CODE_001, null, error.toString());
+                } catch (error) {
+                    logger.error("getTokenTransfersV2 error:", '主流币：', error.toString())
                 }
                 tryCount -= 1;
                 await utils.sleep(delay)
@@ -1460,16 +1464,20 @@ async function getTokenTransfersV2(opt) {
                 logger.log('getTokenTransfersV2 token ret -->>> t_2', t_2);
                 break
             } catch (error) {
-                if (tryCount == 1) {
-                    t_2 = await getTransferRecord(options, 'token', 0);
-                    if (t_2) {
-                        logger.error('sync-node-token-data', JSON.stringify(t_2))
-                        break
-                    } else {
-                        logger.error('sync-node-token-data error', JSON.stringify(options))
+                try {
+                    if (tryCount == 1) {
+                        t_2 = await getTransferRecord(options, 'token', 0);
+                        if (t_2) {
+                            logger.error('sync-node-token-data', JSON.stringify(t_2))
+                            break
+                        } else {
+                            logger.error('sync-node-token-data error', JSON.stringify(options))
+                        }
+                        logger.error("getTokenTransfersV2 error:", 'token币：', error.toString(), JSON.stringify(options))
+                        return toJson(ERROR_CODE_001, null, error.toString());
                     }
-                    logger.error("getTokenTransfersV2 error:", 'token币：', error.toString(), JSON.stringify(options))
-                    return toJson(ERROR_CODE_001, null, error.toString());
+                } catch (error) {
+                    logger.error("getTokenTransfersV2 error:", 'token币：', error.toString())
                 }
                 tryCount -= 1;
                 await utils.sleep(delay)
@@ -1518,15 +1526,19 @@ async function getTokenTransfersV2(opt) {
                 logger.log('getTokenTransfersV2 getTransaction ret-->>> ', transaction);
                 return transaction;
             } catch (error) {
-                if (tryCount == 1) {
-                    logger.error("native getTokenTransfersV2 error:", error.toString(), JSON.stringify(options))
-                    var transaction = await getTransferRecord(options, 'hash', 0);
-                    if (transaction) {
-                        logger.error('sync-node-hash-data', JSON.stringify(transaction))
-                        logger.log('getTokenTransfersV2 getTransaction ret-->>> ', transaction);
-                        return transaction;
+                try {
+                    if (tryCount == 1) {
+                        logger.error("native getTokenTransfersV2 error:", error.toString(), JSON.stringify(options))
+                        var transaction = await getTransferRecord(options, 'hash', 0);
+                        if (transaction) {
+                            logger.error('sync-node-hash-data', JSON.stringify(transaction))
+                            logger.log('getTokenTransfersV2 getTransaction ret-->>> ', transaction);
+                            return transaction;
+                        }
+                        return toJson(ERROR_CODE_001, null, error.toString());
                     }
-                    return toJson(ERROR_CODE_001, null, error.toString());
+                } catch (error) {
+                    logger.error('sync-node-hash-data', error.toString())
                 }
                 tryCount -= 1;
             }

routes/sdk.js

@@ -246,7 +246,10 @@ async function check_czz_withdraw_task() {
             }
             await utils.sleep(2 * 60 * 1000)
         } catch (error) {
-            logger.error('check_czz_withdraw_task error', error.toString(), JSON.stringify(exec_obj))
+            if (exec_obj)
+                logger.error('check_czz_withdraw_task error', error.toString(), JSON.stringify(exec_obj))
+            else
+                logger.error('check_czz_withdraw_task error', error.toString())
         }
     }
 }
@@ -807,7 +810,12 @@ async function bsc_log_monitoring() {
             logger.log("no new check tasks")
             continue
         }
-        checkout_taxhash(exec_obj)
+        try {
+            checkout_taxhash(exec_obj)
+        } catch (error) {
+            logger.error("checkout_taxhash", error.toString())
+        }
+
     }
 }