From a209eaf56ba8e94838f4bb3e4632125bd796ac1f Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 3 Jul 2023 17:29:04 +0800
Subject: [PATCH] 1

---
 server/web3bcspider/services/pull_bcevent.js | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js
index 8a35df7..e515c90 100644
--- a/server/web3bcspider/services/pull_bcevent.js
+++ b/server/web3bcspider/services/pull_bcevent.js
@@ -14,6 +14,7 @@ class PullBcEvent extends BaseService {
     this.bc = bc;
     this.net = net;
     this.event = event;
+    this.eventConf = this.event['eventConf'];
     await this.start();
   }
 
@@ -83,14 +84,15 @@ class PullBcEvent extends BaseService {
 
   async getFromBlock() {
     const logClass = this.getInstanceName() + ' getFromBlock:';
-    const firstBlockNumber  = this.event['eventConf']['init_block'];
+    const firstBlockNumber  = this.getInitBlock();
     while (this.lastBlockNumber < 1) {
       try {
         const {err, row} = await this.conn.ormSelectOne(
           't_last_block',
           [
             ['net_id', this.getNetId()],
-            ['address', this.getNetId()]
+            ['address', this.getContractAddress()],
+            ['event_name', this.getEventName()],
           ]
         );
         if (!err) {
@@ -195,6 +197,18 @@ class PullBcEvent extends BaseService {
     return this.net['net_id'];
   }
 
+  getEventName() {
+    return this.eventConf['event_name'];
+  }
+
+  getInitBlock() {
+    return this.eventConf['init_block'];
+  }
+
+  getContractAddress() {
+    return '';
+  }
+
 }
 
 module.exports = PullBcEvent;