修复爬db事件漏事件隐患

This commit is contained in:
aozhiwei 2024-08-17 18:45:14 +08:00
parent cde152b268
commit 9bf8d92694

View File

@ -68,7 +68,7 @@ class PullDbEvent extends BaseService {
} }
const {err, rows} = await this.conn.execQuery( const {err, rows} = await this.conn.execQuery(
'SELECT * FROM t_blockchain_event WHERE `idx` > ? AND `idx` <= ? ' + 'SELECT * FROM t_blockchain_event WHERE `idx` > ? AND `idx` <= ? ' +
'AND net_id = ? AND event_name = ? AND contract_address = ? ' + 'AND net_id = ? AND event_name = ? AND contract_address = ? ORDER BY idx ' +
'LIMIT ' + LIMIT_COUNT, 'LIMIT ' + LIMIT_COUNT,
[ [
startIdx.toString(), startIdx.toString(),