diff --git a/server/web3service/models/log.js b/server/web3service/models/log.js index c6106d1..d585d59 100644 --- a/server/web3service/models/log.js +++ b/server/web3service/models/log.js @@ -4,14 +4,10 @@ const BaseModel = require('./basemodel'); class Log extends BaseModel { async add(params) { - const result = { - err: null, - seqId: 0 - }; const nowTime = utils.getUtcTime(); const fields = [ ['type', params['type']], - ['subType', params['sub_type']], + ['sub_type', params['sub_type']], ['net_id', params['net_id']], ['createtime', nowTime], ['modifytime', nowTime], diff --git a/server/web3service/models/transaction.js b/server/web3service/models/transaction.js new file mode 100644 index 0000000..6f016da --- /dev/null +++ b/server/web3service/models/transaction.js @@ -0,0 +1,43 @@ +const utils = require('j7/utils'); +const BaseModel = require('./basemodel'); + +class Transaction extends BaseModel { + + async add(account, data, netId) { + const result = { + err: null, + seqId: 0 + }; + const nowTime = utils.getUtcTime(); + const lastId = await this.getSession().marketConn + ( + 'insertEx', + 't_transaction', + [ + ['account', account], + ['data', data], + ['net_id', netId], + ['createtime', nowTime], + ['modifytime', nowTime], + ] + ); + result['seqId'] = lastId; + return result; + } + + async update(idx, fields) { + const err = await this.getSession().marketConn + ( + 'update', + 't_transaction', + [ + ['idx', idx] + ], + fields + ); + return err; + } + +} + +module.exports = Transaction; diff --git a/server/web3service/models/used_tokenid.js b/server/web3service/models/used_tokenid.js index 26e1326..c310ba3 100644 --- a/server/web3service/models/used_tokenid.js +++ b/server/web3service/models/used_tokenid.js @@ -3,25 +3,17 @@ const BaseModel = require('./basemodel'); class UsedTokenId extends BaseModel { - async add(params) { - const result = { - err: null, - seqId: 0 - }; + async add(account, tokenId, transId, netId) { const nowTime = utils.getUtcTime(); const fields = [ - ['type', params['type']], - ['subType', params['sub_type']], - ['net_id', params['net_id']], - ['createtime', nowTime], - ['modifytime', nowTime], + ['account', account], + ['token_id', tokenId], + ['trans_id', transId], + ['net_id', netId], + ['confirmed', 1], + ['createtime', nowTime], + ['modifytime', nowTime], ]; - for (i = 1; i <= 4; ++i) { - const key = 'param' + i; - if (utils.hasKey(params, key)) { - fields.push([key, params[key]]); - } - } await this.getSession().marketConn ( 'insert', @@ -30,6 +22,18 @@ class UsedTokenId extends BaseModel { ); } + async find(tokenId) { + const {err, row} = await this.getSession().marketConn + ( + 'ormSelectOne', + 't_used_token_id', + [ + ['token_id', tokenId] + ] + ); + return row; + } + } module.exports = UsedTokenId;