This commit is contained in:
aozhiwei 2023-07-04 20:29:57 +08:00
parent 735360e079
commit 3eef84940a

View File

@ -27,10 +27,7 @@ class DbSpider extends BaseTask {
'eventConf': eventConf, 'eventConf': eventConf,
'progressInfo': { 'progressInfo': {
'pullCount': 0, 'pullCount': 0,
'eventCount': 0, 'eventCount': 0
'fromBlock': 0,
'toBlock': 0,
'currBlock': 0
} }
}; };
events.push(event); events.push(event);
@ -40,8 +37,6 @@ class DbSpider extends BaseTask {
} }
createPullDbEventService(net, event) { createPullDbEventService(net, event) {
const bc = serviceFactory.create('BlockChain');
bc.init(net['net_id']);
const pullDbEventService = serviceFactory.create('PullDbEvent'); const pullDbEventService = serviceFactory.create('PullDbEvent');
event['pullDbEventService'] = pullDbEventService; event['pullDbEventService'] = pullDbEventService;
pullDbEventService.init(bc, net, event); pullDbEventService.init(bc, net, event);
@ -62,10 +57,7 @@ class DbSpider extends BaseTask {
eventConf['event_name'] + ' ' + eventConf['event_name'] + ' ' +
' pullCount:' + progInfo['pullCount'] + ' pullCount:' + progInfo['pullCount'] +
' eventCount:' + progInfo['eventCount'] + ' eventCount:' + progInfo['eventCount'] +
' fromBlock:' + progInfo['fromBlock'] + '';
' toBlock:' + progInfo['toBlock'] +
' currBlock:' + progInfo['currBlock']
;
log.info(logObj); log.info(logObj);
} }
); );