diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js index 0da7c60..5f3ae01 100644 --- a/server/web3bcspider/services/erc721_refresher.js +++ b/server/web3bcspider/services/erc721_refresher.js @@ -115,9 +115,11 @@ class Erc721Refresher extends BaseService { } async updateConfirmed(newOwner, blockNumber, row) { + const logHead = this.genLogHead('updateConfirmed '); + const tokenId = row['token_id']; const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME); if (err) { - log.error('updateConfirmed:' + this.tokenId + ' err:' + err); + log.error(logHead + tokenId + ' err:' + err); return false; } try { @@ -137,7 +139,7 @@ class Erc721Refresher extends BaseService { ['confirm_block_number', blockNumber] ]); if (err) { - log.error('updateConfirmed:' + this.tokenId + ' err:' + err); + log.error(logHead + tokenId + ' err:' + err); return false; } } @@ -148,9 +150,11 @@ class Erc721Refresher extends BaseService { } async tokenIsExists(rawRow) { + const logHead = this.genLogHead('tokenIsExists '); + const tokenId = rawRow['token_id']; const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME); if (err) { - log.error('updateConfirmed:' + this.tokenId + ' err:' + err); + log.error(logHead + tokenId + ' err:' + err); return false; } try { @@ -163,7 +167,7 @@ class Erc721Refresher extends BaseService { ['contract_address', rawRow['contract_address']], ]); if (err) { - log.error('updateConfirmed:' + this.tokenId + ' err:' + err); + log.error(logHead + tokenId + ' err:' + err); return false; } if (row) {