feat: show activity address by contract in daily statistic

Signed-off-by: Miles Zhang <[email protected]>

app/models/daily_statistic.rb

@@ -5,7 +5,7 @@ class DailyStatistic < ApplicationRecord
     transactions_count addresses_count total_dao_deposit live_cells_count dead_cells_count avg_hash_rate avg_difficulty uncle_rate
     total_depositors_count address_balance_distribution total_tx_fee occupied_capacity daily_dao_deposit daily_dao_depositors_count
     circulation_ratio daily_dao_withdraw nodes_count circulating_supply burnt locked_capacity treasury_amount mining_reward
-    deposit_compensation liquidity created_at_unixtimestamp ckb_hodl_wave holder_count knowledge_size
+    deposit_compensation liquidity created_at_unixtimestamp ckb_hodl_wave holder_count knowledge_size activity_address_contract_distribution
   ).freeze
   MILLISECONDS_IN_DAY = BigDecimal(24 * 60 * 60 * 1000)
   GENESIS_TIMESTAMP = 1573852190812
@@ -409,8 +409,25 @@ def liquidity
     dead_query = CellOutput.dead.generated_before(to_be_counted_date.to_i * 1000 - 1).consumed_after(to_be_counted_date.to_i * 1000).select(:address_id).to_sql
     combined_query = "#{live_query} UNION #{dead_query}"
     count_query = "SELECT COUNT(DISTINCT address_id) AS count FROM (#{combined_query}) AS combined_results;"
-    count = ActiveRecord::Base.connection.execute(count_query).first["count"]
-    count
+    ActiveRecord::Base.connection.execute(count_query).first["count"]
+  end
+
+  define_logic :activity_address_contract_distribution do
+    block_ids = blocks_in_current_period.pluck(:id)
+    results = CellOutput.joins(:lock_script).established_status.where(block_id: block_ids).group(:code_hash).count
+    parsed_results =
+      results.each_with_object({}) do |(key, value), hash|
+        hex_key = "0x#{key.unpack1('H*')}"
+        hash[hex_key] = value
+      end.sort_by { |_k, v| -v }
+    data =
+      parsed_results.map do |result|
+        { Contract.where(is_lock_script: true).where.not(name: nil).where("type_hash = ? OR data_hash = ?", result[0], result[0]).first&.name => result[1] }
+      end
+    nil_sum = data.select { |item| item.keys.include?(nil) }.sum { |item| item[nil] }
+    filtered_data = data.reject { |item| item.keys.include?(nil) }
+    filtered_data << { "Others" => nil_sum } if nil_sum > 0
+    filtered_data
   end
 
   private
@@ -534,47 +551,48 @@ def aggron_first_day?
 #
 # Table name: daily_statistics
 #
-#  id                           :bigint           not null, primary key
-#  transactions_count           :string           default("0")
-#  addresses_count              :string           default("0")
-#  total_dao_deposit            :string           default("0.0")
-#  block_timestamp              :decimal(30, )
-#  created_at_unixtimestamp     :integer
-#  created_at                   :datetime         not null
-#  updated_at                   :datetime         not null
-#  dao_depositors_count         :string           default("0")
-#  unclaimed_compensation       :string           default("0")
-#  claimed_compensation         :string           default("0")
-#  average_deposit_time         :string           default("0")
-#  estimated_apc                :string           default("0")
-#  mining_reward                :string           default("0")
-#  deposit_compensation         :string           default("0")
-#  treasury_amount              :string           default("0")
-#  live_cells_count             :string           default("0")
-#  dead_cells_count             :string           default("0")
-#  avg_hash_rate                :string           default("0")
-#  avg_difficulty               :string           default("0")
-#  uncle_rate                   :string           default("0")
-#  total_depositors_count       :string           default("0")
-#  total_tx_fee                 :decimal(30, )
-#  address_balance_distribution :jsonb
-#  occupied_capacity            :decimal(30, )
-#  daily_dao_deposit            :decimal(30, )
-#  daily_dao_depositors_count   :integer
-#  daily_dao_withdraw           :decimal(30, )
-#  circulation_ratio            :decimal(, )
-#  total_supply                 :decimal(30, )
-#  circulating_supply           :decimal(, )
-#  block_time_distribution      :jsonb
-#  epoch_time_distribution      :jsonb
-#  epoch_length_distribution    :jsonb
-#  average_block_time           :jsonb
-#  nodes_distribution           :jsonb
-#  nodes_count                  :integer
-#  locked_capacity              :decimal(30, )
-#  ckb_hodl_wave                :jsonb
-#  holder_count                 :integer
-#  knowledge_size               :decimal(30, )
+#  id                                     :bigint           not null, primary key
+#  transactions_count                     :string           default("0")
+#  addresses_count                        :string           default("0")
+#  total_dao_deposit                      :string           default("0.0")
+#  block_timestamp                        :decimal(30, )
+#  created_at_unixtimestamp               :integer
+#  created_at                             :datetime         not null
+#  updated_at                             :datetime         not null
+#  dao_depositors_count                   :string           default("0")
+#  unclaimed_compensation                 :string           default("0")
+#  claimed_compensation                   :string           default("0")
+#  average_deposit_time                   :string           default("0")
+#  estimated_apc                          :string           default("0")
+#  mining_reward                          :string           default("0")
+#  deposit_compensation                   :string           default("0")
+#  treasury_amount                        :string           default("0")
+#  live_cells_count                       :string           default("0")
+#  dead_cells_count                       :string           default("0")
+#  avg_hash_rate                          :string           default("0")
+#  avg_difficulty                         :string           default("0")
+#  uncle_rate                             :string           default("0")
+#  total_depositors_count                 :string           default("0")
+#  total_tx_fee                           :decimal(30, )
+#  address_balance_distribution           :jsonb
+#  occupied_capacity                      :decimal(30, )
+#  daily_dao_deposit                      :decimal(30, )
+#  daily_dao_depositors_count             :integer
+#  daily_dao_withdraw                     :decimal(30, )
+#  circulation_ratio                      :decimal(, )
+#  total_supply                           :decimal(30, )
+#  circulating_supply                     :decimal(, )
+#  block_time_distribution                :jsonb
+#  epoch_time_distribution                :jsonb
+#  epoch_length_distribution              :jsonb
+#  average_block_time                     :jsonb
+#  nodes_distribution                     :jsonb
+#  nodes_count                            :integer
+#  locked_capacity                        :decimal(30, )
+#  ckb_hodl_wave                          :jsonb
+#  holder_count                           :integer
+#  knowledge_size                         :decimal(30, )
+#  activity_address_contract_distribution :jsonb
 #
 # Indexes
 #

db/migrate/20241225045757_add_activity_address_contract_distribution_to_daily_statistic.rb

@@ -0,0 +1,5 @@
+class AddActivityAddressContractDistributionToDailyStatistic < ActiveRecord::Migration[7.0]
+  def change
+    add_column :daily_statistics, :activity_address_contract_distribution, :jsonb
+  end
+end

db/structure.sql

@@ -1574,7 +1574,8 @@ CREATE TABLE public.daily_statistics (
     locked_capacity numeric(30,0),
     ckb_hodl_wave jsonb,
     holder_count integer,
-    knowledge_size numeric(30,0)
+    knowledge_size numeric(30,0),
+    activity_address_contract_distribution jsonb
 );
 
 
@@ -6327,6 +6328,7 @@ INSERT INTO "schema_migrations" (version) VALUES
 ('20241205023729'),
 ('20241212022531'),
 ('20241213053309'),
-('20241218085721');
+('20241218085721'),
+('20241225045757');