From aa3863aeecab5556381ff4b345b950d18a6fe684 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Wed, 5 Jul 2023 19:41:03 +0800
Subject: [PATCH] 1

---
 server/web3dbspider/services/pull_dbevent.js | 5 +++++
 server/web3dbspider/tasks/dbspider.js        | 7 ++++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/server/web3dbspider/services/pull_dbevent.js b/server/web3dbspider/services/pull_dbevent.js
index 8bfd892..7beec97 100644
--- a/server/web3dbspider/services/pull_dbevent.js
+++ b/server/web3dbspider/services/pull_dbevent.js
@@ -43,6 +43,7 @@ class PullDbEvent extends BaseService {
     this.eventConf = this.event['eventConf'];
     this.progInfo = this.event['progressInfo'];
     this.contractAddress = this.net.getContractAddressByName(this.getContractName());
+    this.progInfo['lastIdx'] = this.lastIdx.toString();
     await this.start();
   }
 
@@ -199,6 +200,10 @@ class PullDbEvent extends BaseService {
     }
   }
 
+  getMaxIdx() {
+    return PullDbEvent.#maxIdx;
+  }
+
 }
 
 module.exports = PullDbEvent;
diff --git a/server/web3dbspider/tasks/dbspider.js b/server/web3dbspider/tasks/dbspider.js
index 02c7d6e..4d5934b 100644
--- a/server/web3dbspider/tasks/dbspider.js
+++ b/server/web3dbspider/tasks/dbspider.js
@@ -27,7 +27,9 @@ class DbSpider extends BaseTask {
             'eventConf': eventConf,
             'progressInfo': {
               'pullCount': 0,
-              'eventCount': 0
+              'eventCount': 0,
+              'lastIdx': 0,
+              'maxIdx': 0
             }
         };
         events.push(event);
@@ -59,11 +61,14 @@ class DbSpider extends BaseTask {
         (event) => {
           const eventConf = event['eventConf'];
           const progInfo = event['progressInfo'];
+          const pullService = event['pullDbEventService'];
           const logObj = 'net_id: ' + net['net_id'] + ' ' +
                 eventConf['contract_name'] + '.' +
                 eventConf['event_name'] + ' ' +
                 ' pullCount:' + progInfo['pullCount'] +
                 ' eventCount:' + progInfo['eventCount'] +
+                ' lastIdx:' + progInfo['lastIdx'] +
+                ' maxIdx:' + pullService.getMaxIdx().toString() +
                 '';
           log.info(logObj);
         }