feat(Dr. Rai Reports): BP Fudging Indicator (#5729)

**Story card:**
[sc-15924](https://app.shortcut.com/simpledotorg/story/15924/add-bp-fudging-indicator)

## Because

BP Fudging has been identified as one of the key indicators we want to
track in Simple.

## This addresses

Adding "BP Fudging" as an indicator in Simple. This indicator is
SQL-backed — like Statins (#5644) and Titration (#5643), and follow the
same semantics.

## Test instructions

suite tests

Author: igbanam

app/models/dr_rai/bp_fudging_indicator.rb

@@ -0,0 +1,43 @@
+module DrRai
+  class BpFudgingIndicator < Indicator
+    attr_reader :region
+
+    def datasource(region)
+      @region = region
+      @source ||= DrRai::Data::BpFudging.chartable
+      @source[region.name]
+    end
+
+    def display_name
+      "BP Fudging"
+    end
+
+    def target_type_frontend
+      "percent"
+    end
+
+    def numerator_key all: nil
+      :numerator
+    end
+
+    def denominator_key all: nil
+      :denominator
+    end
+
+    def action_passive
+      "fudged"
+    end
+
+    def action_active
+      "Fudge"
+    end
+
+    def unit
+      "bps"
+    end
+
+    def is_supported?(region)
+      true
+    end
+  end
+end

app/models/dr_rai/data/bp_fudging.rb

@@ -0,0 +1,15 @@
+class DrRai::Data::BpFudging < ApplicationRecord
+  include DrRai::Chartable
+
+  QUARTERS = ->(timeline = 1.year.ago..Date.today) {
+    Period.quarters_between(timeline.begin, timeline.end)
+      .map(&:to_s)
+  }
+
+  default_scope { where(quarter: QUARTERS.call(10.months.ago..2.months.from_now)) }
+  scope :insert_window, ->(timeline) { where(quarter: QUARTERS.call(timeline)) }
+
+  chartable_internal_keys :numerator, :denominator, :ratio
+  chartable_period_key :quarter
+  chartable_outer_grouping :slug
+end

app/models/dr_rai/data/statin.rb

@@ -2,6 +2,7 @@ class DrRai::Data::Statin < ApplicationRecord
   include DrRai::Chartable
 
   default_scope { where(month_date: 1.year.ago..Date.today) }
+  scope :insert_window, ->(timeline) { where(month_date: timeline) }
 
   chartable_internal_keys :eligible_patients, :patients_prescribed_statins
   chartable_period_key :month_date

app/models/dr_rai/data/titration.rb

@@ -2,6 +2,7 @@ class DrRai::Data::Titration < ApplicationRecord
   include DrRai::Chartable
 
   default_scope { where(month_date: 1.year.ago..Date.today) }
+  scope :insert_window, ->(timeline) { where(month_date: timeline) }
 
   chartable_internal_keys :follow_up_count, :titrated_count
   chartable_period_key :month_date

app/queries/dr_rai/bp_fudging_query_factory.rb

@@ -0,0 +1,53 @@
+module DrRai
+  class BpFudgingQueryFactory < QueryFactory
+    INSERTER_SQL = "insert into #{DrRai::Data::BpFudging.table_name} (state, district, slug, quarter, numerator, denominator, ratio)".freeze
+
+    CONFLICT_HANDLER_SQL = <<~SQL
+      on conflict (state, district, slug, quarter) do
+        update set
+          numerator = excluded.numerator,
+          denominator = excluded.denominator,
+          ratio = excluded.ratio,
+          updated_at = now(); -- ...for good bookkeeping
+    SQL
+
+    def inserter
+      base_query(INSERTER_SQL, "") { |enhancement| enhancement }
+    end
+
+    def updater
+      base_query(INSERTER_SQL, CONFLICT_HANDLER_SQL) { |enhancement| enhancement }
+    end
+
+    private
+
+    # This query is a modified version of what we use in Metabase; linked in Quick Links as well.
+    # The modifications are thus
+    # 1. Wide to Tall query on Quarter
+    # 2. Added facility name to the mix, as "slug"
+    # 3. Remove the filters on state and org
+    def base_query inserter, conflict_handler
+      <<~SQL
+        #{yield inserter}
+        (
+          select
+            reporting_facilities.state_name as "state",
+            reporting_facilities.district_name "district",
+            reporting_facilities.facility_name as "slug",
+            to_char(bp.created_at, '"Q"q-yyyy') as "quarter",
+            count(*) filter (where bp.systolic between 130 and 139) as "numerator",
+            count(*) filter (where bp.systolic between 140 and 149) as "denominator",
+            count(*) filter (where bp.systolic between 130 and 139) * 1.0 /
+            nullif(count(*) filter (where bp.systolic between 140 and 149), 0) as "ratio"
+          from blood_pressures bp
+          join reporting_facilities on bp.facility_id = reporting_facilities.facility_id
+          where 1 = 1
+            and bp.created_at >= date_trunc('quarter', current_date - interval '12 months')
+          group by
+            1, 2, 3, 4
+        )
+        #{yield conflict_handler};
+      SQL
+    end
+  end
+end

app/queries/dr_rai/query_factory.rb

@@ -19,6 +19,8 @@ def for klazz, from: nil, to: nil
           instance = DrRai::TitrationQueryFactory.new(from, to)
         elsif klazz <= Data::Statin
           instance = DrRai::StatinsQueryFactory.new(from, to)
+        elsif klazz <= Data::BpFudging
+          instance = DrRai::BpFudgingQueryFactory.new(from, to)
         else
           raise "Unsupported"
         end

app/services/dr_rai/data_service.rb

@@ -30,7 +30,7 @@ def populate!
     private
 
     def inserting?
-      @klazz.where(month_date: @timeline).count == 0
+      @klazz.insert_window(@timeline).count == 0
     end
   end
 end

config/schedule.rb

@@ -91,7 +91,13 @@ def local(time)
 every :day, at: local("03:00 am"), roles: [:cron] do
   from = 1.month.ago.to_date.to_s
   to = Date.today.to_s
-  rake "dr_rai:populate_titration_data[#{from}, #{to}]"
+  %w[
+    titration
+    statins
+    bp_fudging
+  ].each do |indicator|
+    rake "dr_rai:populate_#{indicator}_data[#{from}, #{to}]"
+  end
 end
 
 every :day, at: local("01:00 am"), roles: [:cron] do

db/migrate/20251125090819_create_dr_rai_data_bp_fudging.rb

@@ -0,0 +1,18 @@
+class CreateDrRaiDataBpFudging < ActiveRecord::Migration[6.1]
+  def change
+    create_table :dr_rai_data_bp_fudgings do |t|
+      t.string :state
+      t.string :district
+      t.string :slug
+      t.string :quarter
+      t.integer :numerator
+      t.integer :denominator
+      t.decimal :ratio, precision: 5, scale: 2
+      t.datetime :deleted_at
+
+      t.timestamps default: -> { "CURRENT_TIMESTAMP" }, null: false
+    end
+
+    add_index :dr_rai_data_bp_fudgings, [:state, :district, :slug, :quarter], unique: true, name: "index_dr_rai_data_bp_fudgings_on_state_district_slug_quarter"
+  end
+end

db/structure.sql

@@ -1099,6 +1099,44 @@ CREATE SEQUENCE public.dr_rai_actions_id_seq
 ALTER SEQUENCE public.dr_rai_actions_id_seq OWNED BY public.dr_rai_actions.id;
 
 
+--
+-- Name: dr_rai_data_bp_fudgings; Type: TABLE; Schema: public; Owner: -
+--
+
+CREATE TABLE public.dr_rai_data_bp_fudgings (
+    id bigint NOT NULL,
+    state character varying,
+    district character varying,
+    slug character varying,
+    quarter character varying,
+    numerator integer,
+    denominator integer,
+    ratio numeric(5,2),
+    deleted_at timestamp without time zone,
+    created_at timestamp(6) without time zone DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at timestamp(6) without time zone DEFAULT CURRENT_TIMESTAMP NOT NULL
+);
+
+
+--
+-- Name: dr_rai_data_bp_fudgings_id_seq; Type: SEQUENCE; Schema: public; Owner: -
+--
+
+CREATE SEQUENCE public.dr_rai_data_bp_fudgings_id_seq
+    START WITH 1
+    INCREMENT BY 1
+    NO MINVALUE
+    NO MAXVALUE
+    CACHE 1;
+
+
+--
+-- Name: dr_rai_data_bp_fudgings_id_seq; Type: SEQUENCE OWNED BY; Schema: public; Owner: -
+--
+
+ALTER SEQUENCE public.dr_rai_data_bp_fudgings_id_seq OWNED BY public.dr_rai_data_bp_fudgings.id;
+
+
 --
 -- Name: dr_rai_data_statins; Type: TABLE; Schema: public; Owner: -
 --
@@ -8557,5 +8595,7 @@ INSERT INTO "schema_migrations" (version) VALUES
 ('20250923223358'),
 ('20250924101441'),
 ('20250924102156'),
-('20250925094123');
+('20250925094123'),
+('20251125090819');
+