diff --git a/app/models/ckb_sync/new_node_data_processor.rb b/app/models/ckb_sync/new_node_data_processor.rb index ec7d77891..b355a297b 100644 --- a/app/models/ckb_sync/new_node_data_processor.rb +++ b/app/models/ckb_sync/new_node_data_processor.rb @@ -1297,10 +1297,8 @@ def build_uncle_blocks!(node_block, local_block_id) node_block.uncles.each do |uncle_block| header = uncle_block.header epoch_info = CkbUtils.parse_epoch_info(header) - UncleBlock.create!( - block_id: local_block_id, + UncleBlock.create_with( compact_target: header.compact_target, - block_hash: header.hash, number: header.number, parent_hash: header.parent_hash, nonce: header.nonce, @@ -1313,6 +1311,9 @@ def build_uncle_blocks!(node_block, local_block_id) proposals_count: uncle_block.proposals.count, epoch: epoch_info.number, dao: header.dao + ).find_or_create_by!( + block_id: local_block_id, + block_hash: header.hash ) end end diff --git a/lib/tasks/migration/async_missing_transactions.rake b/lib/tasks/migration/async_missing_transactions.rake index bd83dc8f5..b06d706e7 100644 --- a/lib/tasks/migration/async_missing_transactions.rake +++ b/lib/tasks/migration/async_missing_transactions.rake @@ -12,7 +12,7 @@ namespace :migration do txs_count2 = local_block.ckb_transactions.count next if txs_count1 == txs_count2 - puts "async missing block number: #{local_block.number} transactions count: #{txs_count1}" + puts "async missing block number: #{local_block.number}, rpc transactions count: #{txs_count1}, db transactions count: #{txs_count2}" node_block = CkbSync::Api.instance.get_block_by_number(local_block.number) CkbSync::NewNodeDataProcessor.new.process_block(node_block, refresh_balance: false)