chore: update rgbpp assets transactions count

app/workers/generate_rgbpp_assets_statistic_worker.rb

@@ -24,8 +24,8 @@ def perform(datetime = nil)
 
   def ft_count_attributes
     timestamp = CkbUtils.time_in_milliseconds(ended_at) - 1
-    scope = Udt.where(udt_type: %i[xudt xudt_compatible], block_timestamp: ..timestamp)
-    xudts_count = scope.joins(:xudt_tag).where("xudt_tags.tags && ARRAY[?]::varchar[]", ["rgb++"])
+    xudts = Udt.where(udt_type: %i[xudt xudt_compatible], block_timestamp: ..timestamp)
+    xudts_count = xudts.joins(:xudt_tag).where("xudt_tags.tags && ARRAY[?]::varchar[]", ["rgb++"]).count
     { indicator: "ft_count", value: xudts_count, network: "global" }
   end
 
@@ -42,9 +42,21 @@ def btc_transactions_count_attributes
   end
 
   def ckb_transactions_count_attributes
-    ended_timestamp = CkbUtils.time_in_milliseconds(ended_at) - 1
-    transactions_count = BitcoinAnnotation.includes(:ckb_transaction).
-      where(ckb_transactions: { block_timestamp: ..ended_timestamp }).count
+    timestamp = CkbUtils.time_in_milliseconds(ended_at) - 1
+
+    ft_transaction_ids = Set.new
+    xudts = Udt.where(udt_type: %i[xudt xudt_compatible])
+    xudts.joins(:xudt_tag).where("xudt_tags.tags && ARRAY[?]::varchar[]", ["rgb++"]).find_each do |xudt|
+      ft_transaction_ids.merge(xudt.ckb_transactions.where(block_timestamp: ..timestamp).ids)
+    end
+
+    dob_transaction_ids = Set.new
+    TokenCollection.where("tags && ARRAY[?]::varchar[]", ["rgb++"]).find_each do |token_collection|
+      transfers = token_collection.transfers.joins(:ckb_transaction).where("ckb_transactions.block_timestamp <= ?", timestamp)
+      dob_transaction_ids.merge(transfers.map(&:transaction_id))
+    end
+
+    transactions_count = ft_transaction_ids.length + dob_transaction_ids.length
     { indicator: "transactions_count", value: transactions_count, network: "ckb" }
   end