IRONN-225 EMPRO month 12 expired vs. not available

portal/migrations/versions/66368e673005_.py

@@ -0,0 +1,63 @@
+"""IRONN-225 update adherence data for expired EMPRO users
+
+Revision ID: 66368e673005
+Revises: d1f3ed8d16ef
+Create Date: 2023-12-11 16:56:10.427854
+
+"""
+from alembic import op
+from datetime import datetime
+import sqlalchemy as sa
+from sqlalchemy.orm import sessionmaker
+
+
+# revision identifiers, used by Alembic.
+revision = '66368e673005'
+down_revision = 'd1f3ed8d16ef'
+
+Session = sessionmaker()
+
+
+def upgrade():
+    # IRONN-225 noted expired EMPRO users adherence data showed
+    # `not yet available`.  Code corrected, need to force renewal
+    # for those affected.
+
+    bind = op.get_bind()
+    session = Session(bind=bind)
+
+    now = datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S")
+    patient_ids = []
+    # get list of non-deleted users with a 12th month expiration
+    # that has already passed.  (12 = baseline + zero-index 10)
+    for patient_id in session.execute(
+            "SELECT DISTINCT(user_id) FROM qb_timeline JOIN users"
+            " ON users.id = user_id WHERE deleted_id IS NULL"
+            " AND research_study_id = 1 AND qb_iteration = 10"
+            f" AND status = 'expired' AND at < '{now}'"):
+        patient_ids.append(patient_id[0])
+
+    # purge their respective rows from adherence cache, IFF status
+    # shows IRONN-225 symptom.
+    rs_visit = "1:Month 12"
+    for patient_id in patient_ids:
+        status = session.execute(
+            "SELECT data->>'status' FROM adherence_data WHERE"
+            f" patient_id = {patient_id} AND"
+            f" rs_id_visit = '{rs_visit}'"
+        ).first()
+        if status and status[0] != "Not Yet Available":
+            continue
+
+        # purge the user's EMPRO adherence rows to force refresh
+        session.execute(
+            "DELETE FROM adherence_data WHERE"
+            f" patient_id = {patient_id} AND"
+            f" rs_id_visit like '1:%'"
+        )
+
+
+def downgrade():
+    # No reasonable downgrade
+    pass
+

portal/models/reporting.py

@@ -152,10 +152,14 @@ def empro_row_detail(row, ts_reporting):
     # build up data until we find valid cache for patient's history
     status = str(qb_stats.overall_status)
     row = patient_data(patient)
+    row["status"] = status
     if status == "Expired" and research_study_id == EMPRO_RS_ID:
-        row["status"] = "Not Yet Available"
-    else:
-        row["status"] = status
+        # Expired status ambiguous for EMPRO - either not available
+        # due to complex business rules around start or walked off
+        # the end.  Assume if consent + 1year > now, it's the former.
+        consent = datetime.strptime(row["consent"], "%d-%b-%Y %H:%M:%S")
+        if consent + timedelta(days=365) > as_of_date:
+            row["status"] = "Not Yet Available"
 
     if last_viable:
         general_row_detail(row, patient, last_viable)