From 61fc5baf7754f7c84cc9ccf6825bf1b99b8ebaa8 Mon Sep 17 00:00:00 2001 From: shaojunda Date: Wed, 25 Dec 2019 21:43:07 +0800 Subject: [PATCH] feat: save capacity involved to ckb_transaction --- app/models/ckb_sync/node_data_processor.rb | 3 ++- ...191225131337_add_capacity_involved_to_ckb_transactions.rb | 5 +++++ 2 files changed, 7 insertions(+), 1 deletion(-) create mode 100644 db/migrate/20191225131337_add_capacity_involved_to_ckb_transactions.rb diff --git a/app/models/ckb_sync/node_data_processor.rb b/app/models/ckb_sync/node_data_processor.rb index c8743b6ce..dba8f19cf 100644 --- a/app/models/ckb_sync/node_data_processor.rb +++ b/app/models/ckb_sync/node_data_processor.rb @@ -502,10 +502,11 @@ def calculate_tx_fee(local_block, ckb_transactions, input_capacities, outputs) txs = [] ckb_transactions.each do |ckb_transaction| update_transaction_fee(ckb_transaction, input_capacities[ckb_transaction.id].sum, output_capacities[ckb_transaction.id].sum) + ckb_transaction.capacity_involved = input_capacities[ckb_transaction.id].sum txs << ckb_transaction end - CkbTransaction.import!(txs, validate: false, on_duplicate_key_update: [:transaction_fee]) + CkbTransaction.import!(txs, validate: false, on_duplicate_key_update: [:transaction_fee, :capacity_involved]) local_block.total_transaction_fee = local_block.ckb_transactions.sum(:transaction_fee) local_block.save! rescue ActiveRecord::RecordInvalid diff --git a/db/migrate/20191225131337_add_capacity_involved_to_ckb_transactions.rb b/db/migrate/20191225131337_add_capacity_involved_to_ckb_transactions.rb new file mode 100644 index 000000000..7cca9dc36 --- /dev/null +++ b/db/migrate/20191225131337_add_capacity_involved_to_ckb_transactions.rb @@ -0,0 +1,5 @@ +class AddCapacityInvolvedToCkbTransactions < ActiveRecord::Migration[6.0] + def change + add_column :ckb_transactions, :capacity_involved, :decimal, precision: 30, scale: 0 + end +end