Update app.py

app.py

@@ -3,7 +3,7 @@ import pandas as pd
 import numpy as np
 from datetime import datetime
 import os
-import zipfile
+import io
 
 def process_files(thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file):
     if not all([thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file]):
@@ -130,6 +130,8 @@ def process_files(thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file):
     final_analysis['Nguy_Hiem_Baseline'] = final_analysis['PLT_baseline'].apply(get_nguy_hiem)
     final_analysis['Nguy_Hiem_Nadir'] = final_analysis['PLT_nadir'].apply(get_nguy_hiem)
 
+    num_drop_30 = len(final_analysis[(final_analysis['Percent_Drop'] >= 30) & (final_analysis['Signal'] != "Không rõ rệt")]['makcb'].unique())
+
     # Xuất các file check
     file1 = "1_Check_Thuoc_Nghi_Ngo.xlsx"
     check_thuoc.to_excel(file1, sheet_name='Sheet1', index=False)
@@ -140,16 +142,16 @@ def process_files(thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file):
     file3 = "3_Check_PLT_Duoi_100.xlsx"
     check_plt_low.to_excel(file3, sheet_name='Sheet1', index=False)
 
-    file4 = "4_Check_Giao_Thoa_Thuoc_PLT.xlsx"
     inter_df = df_plt[df_plt['Mã KCB'].isin(inter_ids)].copy()
     inter_df['CTCAE_Grade'] = inter_df['Kết quả XN'].apply(get_ctcae_plt)
     inter_df['Nguy_Hiem'] = inter_df['Kết quả XN'].apply(get_nguy_hiem)
+    file4 = "4_Check_Giao_Thoa_Thuoc_PLT.xlsx"
     inter_df.to_excel(file4, sheet_name='Sheet1', index=False)
 
     file5 = "5_Check_Baseline_Nadir_Full.xlsx"
     final_analysis.to_excel(file5, sheet_name='Sheet1', index=False)
 
-    # Function export_realtime_reports
+    # Function export_realtime_reports, trả về thêm num_need_plt
     def export_realtime_reports(final_report, df_xetnghiem):
         today = datetime.now()
         filerealtime = f"Danh_Sach_Can_Thiep_DLS_{today.year}.xlsx"
@@ -167,41 +169,44 @@ def process_files(thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file):
         include_priority = True
         include_recommendations = True
 
+        if not current_patients.empty:
+            current_patients['So_Ngay_Nam_Vien'] = ((today - current_patients['Ngày vào']).dt.days).fillna(0).astype(int)
+
+            if include_priority:
+                def assess_urgency(row):
+                    days = row['So_Ngay_Nam_Vien']
+                    if days >= 7: return "🔴 Rất cao (>= 7 ngày chưa XN lại)"
+                    if days >= 3: return "🟠 Cao (3-6 ngày chưa XN lại)"
+                    return "🟡 Trung bình"
+                current_patients['Muc_Do_Cap_Bach'] = current_patients.apply(assess_urgency, axis=1)
+                current_patients = current_patients.sort_values('So_Ngay_Nam_Vien', ascending=False)
+
+            if include_recommendations:
+                def compose_message(row):
+                    thuoc = row['tenhh'] if pd.notna(row['tenhh']) else row['hoatchat']
+                    plt_nen = row['PLT_baseline'] if pd.notna(row['PLT_baseline']) else 'N/A (thiếu baseline)'
+                    ngay = row['So_Ngay_Nam_Vien']
+                    nadir = row.get('PLT_nadir', 'N/A')
+                    ctcae_nadir = row['CTCAE_Nadir']
+                    nguy_hiem_nadir = row['Nguy_Hiem_Nadir']
+                    if "Nghi ngờ (thiếu baseline)" in row['Signal']:
+                        return (f"CẢNH BÁO ADR: Tiểu cầu bệnh nhân thấp ({nadir} G/L - {ctcae_nadir} - {nguy_hiem_nadir}) khi dùng {thuoc}, thiếu baseline. "
+                                f"Đề xuất theo dõi và làm thêm XN Công thức máu (PLT) trong ngày hôm nay để xác nhận xu hướng.")
+                    elif "sụt giảm" in row['Signal'] or "Trầm trọng" in row['Signal'] or "Nghi ngờ" in row['Signal']:
+                        return (f"CẢNH BÁO ADR: Tiểu cầu bệnh nhân sụt giảm rõ rệt từ {plt_nen} G/L xuống còn {nadir} G/L "
+                                f"({ctcae_nadir} - {nguy_hiem_nadir}) sau khi dùng {thuoc}. Đề xuất bác sĩ xem xét tạm ngưng hoặc đổi thuốc nếu không có nguyên nhân khác.")
+                    else:
+                        return (f"Bệnh nhân đã điều trị {ngay} ngày và đang sử dụng {thuoc} (có nguy cơ giảm PLT). "
+                                f"Kết quả PLT nền thấp ({plt_nen} G/L) và chưa có xét nghiệm kiểm tra lại. "
+                                f"Dược lâm sàng đề xuất làm thêm XN Công thức máu (PLT) trong ngày hôm nay.")
+                current_patients['Mau_Cau_Khuyen_Cao'] = current_patients.apply(compose_message, axis=1)
+
+        num_need_plt = len(current_patients[current_patients['Mau_Cau_Khuyen_Cao'].str.contains("làm thêm XN")])
+
         with pd.ExcelWriter(filerealtime) as writer:
             sheet_written = False
 
             if not current_patients.empty:
-                current_patients['So_Ngay_Nam_Vien'] = ((today - current_patients['Ngày vào']).dt.days).fillna(0).astype(int)
-
-                if include_priority:
-                    def assess_urgency(row):
-                        days = row['So_Ngay_Nam_Vien']
-                        if days >= 7: return "🔴 Rất cao (>= 7 ngày chưa XN lại)"
-                        if days >= 3: return "🟠 Cao (3-6 ngày chưa XN lại)"
-                        return "🟡 Trung bình"
-                    current_patients['Muc_Do_Cap_Bach'] = current_patients.apply(assess_urgency, axis=1)
-                    current_patients = current_patients.sort_values('So_Ngay_Nam_Vien', ascending=False)
-
-                if include_recommendations:
-                    def compose_message(row):
-                        thuoc = row['tenhh'] if pd.notna(row['tenhh']) else row['hoatchat']
-                        plt_nen = row['PLT_baseline'] if pd.notna(row['PLT_baseline']) else 'N/A (thiếu baseline)'
-                        ngay = row['So_Ngay_Nam_Vien']
-                        nadir = row.get('PLT_nadir', 'N/A')
-                        ctcae_nadir = row['CTCAE_Nadir']
-                        nguy_hiem_nadir = row['Nguy_Hiem_Nadir']
-                        if "Nghi ngờ (thiếu baseline)" in row['Signal']:
-                            return (f"CẢNH BÁO ADR: Tiểu cầu bệnh nhân thấp ({nadir} G/L - {ctcae_nadir} - {nguy_hiem_nadir}) khi dùng {thuoc}, thiếu baseline. "
-                                    f"Đề xuất theo dõi và làm thêm XN Công thức máu (PLT) trong ngày hôm nay để xác nhận xu hướng.")
-                        elif "sụt giảm" in row['Signal'] or "Trầm trọng" in row['Signal'] or "Nghi ngờ" in row['Signal']:
-                            return (f"CẢNH BÁO ADR: Tiểu cầu bệnh nhân sụt giảm rõ rệt từ {plt_nen} G/L xuống còn {nadir} G/L "
-                                    f"({ctcae_nadir} - {nguy_hiem_nadir}) sau khi dùng {thuoc}. Đề xuất bác sĩ xem xét tạm ngưng hoặc đổi thuốc nếu không có nguyên nhân khác.")
-                        else:
-                            return (f"Bệnh nhân đã điều trị {ngay} ngày và đang sử dụng {thuoc} (có nguy cơ giảm PLT). "
-                                    f"Kết quả PLT nền thấp ({plt_nen} G/L) và chưa có xét nghiệm kiểm tra lại. "
-                                    f"Dược lâm sàng đề xuất làm thêm XN Công thức máu (PLT) trong ngày hôm nay.")
-                    current_patients['Mau_Cau_Khuyen_Cao'] = current_patients.apply(compose_message, axis=1)
-
                 current_patients[cols + ['So_Ngay_Nam_Vien', 'Muc_Do_Cap_Bach', 'Mau_Cau_Khuyen_Cao']].to_excel(writer, sheet_name='CAN_THIEP_TRUC_TIEP', index=False)
                 sheet_written = True
 
@@ -214,13 +219,17 @@ def process_files(thuoc_file, xetnghiem_file, thuoc_plt_file, icd_plt_file):
 
         num_current = len(current_patients)
         num_hoicuu = len(hoi_cuu)
-        return filerealtime, num_current, num_hoicuu
+        return filerealtime, num_current, num_hoicuu, num_need_plt
 
-    filerealtime, num_current, num_hoicuu = export_realtime_reports(final_analysis, df_xetnghiem)
+    filerealtime, num_current, num_hoicuu, num_need_plt = export_realtime_reports(final_analysis, df_xetnghiem)
 
-    output_text = f"✅ Đã xuất file '{os.path.basename(filerealtime)}'.\n"
-    output_text += f"📍 Số ca đang nằm viện cần can thiệp ngay: {num_current}\n"
-    output_text += f"📍 Số ca đã ra viện (Lưu hồ sơ hồi cứu): {num_hoicuu}\n"
+    output_text = f"✅ Số bệnh nhân có PLT dưới 100: {num_plt_low}\n"
+    output_text += f"✅ Số bệnh nhân sử dụng thuốc nghi ngờ và có PLT dưới 100: {num_inter}\n"
+    output_text += f"✅ Số bệnh nhân sử dụng thuốc nghi ngờ và có PLT giảm >=30%: {num_drop_30}\n"
+    output_text += f"✅ Số bệnh nhân cần làm thêm xét nghiệm PLT: {num_need_plt}\n"
+    output_text += f"✅ Số bệnh nhân cần can thiệp: {num_current}\n"
+    output_text += f"✅ Số bệnh nhân cần hồi cứu báo cáo ADR: {num_hoicuu}\n"
+    output_text += f"✅ Đã xuất file '{os.path.basename(filerealtime)}'.\n"
 
     return output_text, file1, file2, file3, file4, file5, filerealtime