From a36d30cfc2cbbb117ea669ea0bb5cfa8cfde4d23 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 12 Jun 2023 20:08:52 +0800
Subject: [PATCH] 1

---
 server/web3spider/services/event_process.js | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/server/web3spider/services/event_process.js b/server/web3spider/services/event_process.js
index 253e290..611d390 100644
--- a/server/web3spider/services/event_process.js
+++ b/server/web3spider/services/event_process.js
@@ -12,7 +12,6 @@ class EventProcess extends BaseService {
     this.cb = cb;
     this.lastBlockNumber = 0;
     this.bc = bc;
-    this.netId = await this.bc.getNetId();
     await this.start();
   }
 
@@ -185,6 +184,7 @@ class EventProcess extends BaseService {
         [
           ['txhash', event['transactionHash']],
           ['log_index', event['logIndex']],
+          ['net_id', this.bc.getNetId()],
         ],
         [
         ],
@@ -196,6 +196,7 @@ class EventProcess extends BaseService {
           ['block_number', event['blockNumber']],
           ['raw_data', utils.jsonEncode(event)],
           ['return_values', utils.jsonEncode(returnValues)],
+          ['net_id', this.bc.getNetId()],
           ['createtime', utils.getUtcTime()],
           ['modifytime', utils.getUtcTime()],
         ]
@@ -209,11 +210,11 @@ class EventProcess extends BaseService {
   }
 
   getBlockNumberDbName() {
-    return this.instance['name'] + '.' + this.instance['eventName'] + '.last_block_number';
+    return this.instance['name'] + '.' + this.instance['eventName'] + '.last_block_number.' + this.bc.getNetId();
   }
 
   getFirstBlockNumberDbName() {
-    return this.instance['name'] + '.' + this.instance['eventName'] + '.first_block_number';
+    return this.instance['name'] + '.' + this.instance['eventName'] + '.first_block_number.' + this.bc.getNetId();
   }
 
 }