Spaces:

sonuprasad23
/

quantum-bot

Running

App Files Files Community

sonuprasad23 commited on Sep 13, 2025

Commit

0806440

1 Parent(s): 6de3d2d

Trying again

Browse files

Files changed (2) hide show

server.py +27 -92
worker.py +64 -14

server.py CHANGED Viewed

@@ -44,69 +44,10 @@ class GmailApiService:
             print("[Server Log] Gmail API Service initialized successfully")
         except Exception as e: print(f"[Server Log] Gmail API Error: {e}")
-    def create_professional_email_template(self, subject, status_text, stats, custom_name):
         status_color = "#28a745" if "completed" in status_text else "#ffc107" if "terminated" in status_text else "#dc3545"
         current_date = datetime.now().strftime("%B %d, %Y at %I:%M %p")
-        html_template = f"""
-        <!DOCTYPE html>
-        <html lang="en">
-        <head>
-            <meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>{subject}</title>
-            <style>
-                * {{ margin: 0; padding: 0; box-sizing: border-box; }}
-                body {{ font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif; line-height: 1.6; color: #2c2c2c; background-color: #f8f8f8; }}
-                .email-container {{ max-width: 700px; margin: 20px auto; background-color: #ffffff; box-shadow: 0 8px 32px rgba(139, 0, 0, 0.15); border-radius: 12px; overflow: hidden; }}
-                .header {{ background: linear-gradient(135deg, #8A0303 0%, #4c00ff 100%); color: white; padding: 40px 30px; text-align: center; }}
-                .header h1 {{ font-size: 32px; font-weight: 700; margin-bottom: 8px; text-shadow: 2px 2px 4px rgba(0, 0, 0, 0.3); }}
-                .header p {{ font-size: 18px; opacity: 0.95; font-weight: 300; letter-spacing: 1px; }}
-                .status-banner {{ background: {status_color}; color: white; text-align: center; padding: 18px; font-size: 16px; font-weight: 600; text-transform: uppercase; letter-spacing: 1.5px; }}
-                .content {{ padding: 40px 30px; }}
-                .report-info {{ background: #fdfdff; border-left: 6px solid var(--violet); padding: 25px; margin-bottom: 35px; border-radius: 8px; box-shadow: 0 4px 12px rgba(76, 0, 255, 0.1); }}
-                .info-grid {{ display: grid; grid-template-columns: 1fr 1fr; gap: 15px 25px; }}
-                .info-item {{ display: flex; justify-content: space-between; align-items: center; padding: 10px 0; border-bottom: 1px solid #f0f0f0; }}
-                .stats-grid {{ display: grid; grid-template-columns: repeat(auto-fit, minmax(140px, 1fr)); gap: 20px; margin: 35px 0; }}
-                .stat-card {{ background: #f8f9fa; border: 1px solid #e0e0e0; border-radius: 12px; padding: 25px 15px; text-align: center; box-shadow: 0 4px 15px rgba(0, 0, 0, 0.05); }}
-                .stat-number {{ font-size: 36px; font-weight: 700; color: var(--violet); margin-bottom: 10px; }}
-                .attachments-section {{ background: #f8f5ff; border: 1px solid #e0e0e0; border-radius: 12px; padding: 25px; margin: 35px 0; }}
-                .footer {{ background: #2c2c2c; color: white; padding: 35px 30px; text-align: center; }}
-                h3 {{ color: var(--blood-red); margin-bottom: 20px; font-size: 20px; font-weight: 600; }}
-            </style>
-        </head>
-        <body>
-            <div class="email-container">
-                <div class="header"><h1>Hillside's Quantum Automation</h1><p>Patient Processing Report</p></div>
-                <div class="status-banner">Process {status_text}</div>
-                <div class="content">
-                    <div class="report-info">
-                        <h3>Report Summary</h3>
-                        <div class="info-grid">
-                            <div class="info-item"><span><b>Report Name</b></span><span>{custom_name}</span></div>
-                            <div class="info-item"><span><b>Generated</b></span><span>{current_date}</span></div>
-                        </div>
-                    </div>
-                    <h3>Processing Results</h3>
-                    <div class="stats-grid">
-                        <div class="stat-card"> <div class="stat-number">{stats['total']}</div> <div>Total in File</div> </div>
-                        <div class="stat-card"> <div class="stat-number">{stats['processed']}</div> <div>Processed</div> </div>
-                        <div class="stat-card"> <div class="stat-number">{stats['successful']}</div> <div>Done</div> </div>
-                        <div class="stat-card"> <div class="stat-number">{stats['bad']}</div> <div>Bad State</div> </div>
-                        <div class="stat-card"> <div class="stat-number">{stats['skipped']}</div> <div>Skipped (No PRN)</div> </div>
-                    </div>
-                    <div class="attachments-section">
-                        <h3>Attached Reports</h3>
-                        <p>The following files are attached to this email and have been uploaded to Google Drive:</p>
-                        <ul>
-                            <li><b>{custom_name}_Full.csv:</b> The complete report with the final status for every patient.</li>
-                            <li><b>{custom_name}_Bad.csv:</b> A filtered list of patients that resulted in a "Bad" state.</li>
-                            <li><b>{custom_name}_Skipped.csv:</b> A filtered list of patients that were skipped due to having no PRN.</li>
-                        </ul>
-                    </div>
-                </div>
-                <div class="footer"><h4>Hillside Automation</h4><p>This is an automated report. Please do not reply.</p></div>
-            </div>
-        </body></html>
-        """
         return html_template
     def send_report(self, recipients, subject, body, attachments=None):
@@ -160,10 +101,11 @@ def run_automation_process(session_id):
     global bot_instance
     results = []; is_terminated = False; is_crash = False
     try:
-        data = session_data.get(session_id, {}); patient_data = data.get('patient_data')
         if not patient_data: raise ValueError("No patient data prepared for automation.")
         socketio.emit('initial_stats', {'total': len(patient_data)})
-        results = bot_instance.process_patient_list(patient_data)
         is_terminated = bot_instance.termination_event.is_set()
     except Exception as e:
         print(f"[Server Log] Fatal error in automation thread: {e}"); is_crash = True
@@ -175,30 +117,22 @@ def run_automation_process(session_id):
         if session_id in session_data: del session_data[session_id]
 def generate_and_send_reports(session_id, results, is_crash_report=False, is_terminated=False):
-    print("[Server Log] Preparing final reports...")
-    data = session_data.get(session_id, {})
-    if not data: print("[Server Log] Session data not found, cannot generate report."); return
-    full_df = pd.DataFrame(data.get('patient_data_for_report'))
     if results:
-        result_df = pd.DataFrame(results)
-        if not result_df.empty:
-            result_df.set_index('Name', inplace=True)
-            full_df.set_index('Name', inplace=True)
-            full_df.update(result_df)
-            full_df.reset_index(inplace=True)
     full_df['Status'].fillna('Not Processed', inplace=True)
-    # --- Definitive Reporting Fix: Select ONLY the required columns ---
     final_report_df = full_df[['Name', 'PRN', 'Status']]
     bad_df = final_report_df[final_report_df['Status'] == 'Bad']
     skipped_df = final_report_df[final_report_df['Status'] == 'Skipped - No PRN']
     timestamp = datetime.now().strftime("%d_%b_%Y"); custom_name = data.get('filename') or timestamp
     full_report_name = f"{custom_name}_Full.csv"; bad_report_name = f"{custom_name}_Bad.csv"; skipped_report_name = f"{custom_name}_Skipped.csv"
     full_report_content = final_report_df.to_csv(index=False)
     drive_service.upload_file(full_report_name, full_report_content)
@@ -207,19 +141,17 @@ def generate_and_send_reports(session_id, results, is_crash_report=False, is_ter
         bad_report_name: bad_df.to_csv(index=False),
         skipped_report_name: skipped_df.to_csv(index=False)
     }
-    status_text = "terminated by user" if is_terminated else "crashed" if is_crash_report else "completed successfully"
     stats = {
-        'total': len(full_df),
-        'processed': len(results),
         'successful': len(full_df[full_df['Status'] == 'Done']),
-        'bad': len(bad_df),
-        'skipped': len(skipped_df)
     }
-    subject = f"Automation Report [{status_text.upper()}]: {custom_name}"
-    professional_body = email_service.create_professional_email_template(subject, status_text, stats, custom_name)
     email_service.send_report(data.get('emails'), subject, professional_body, attachments)
     socketio.emit('process_complete', {'message': f'Process {status_text}. Report sent.'})
@@ -234,10 +166,11 @@ def extract_patient_name(raw_name):
     name_only = raw_name.split('DOB')[0].strip()
     return re.sub(r'[:\d\-\s]+$', '', name_only).strip()
-@app.route('/process_files_for_automation', methods=['POST'])
-def handle_file_processing():
     session_id = 'user_session'
     try:
         if 'app_data' not in request.files or 'quantum_data' not in request.files:
             return jsonify({"error": "Both files are required."}), 400
@@ -255,11 +188,10 @@ def handle_file_processing():
         master_df = df_quantum.copy()
         master_df['Status'] = ''
-        session_data[session_id]['patient_data_for_report'] = master_df
-        session_data[session_id]['patient_data'] = master_df.to_dict('records')
         socketio.emit('data_processed')
-        print(f"[Server Log] Data prepared. Total records: {len(master_df)}")
         return jsonify({"message": "Data processed successfully."})
     except Exception as e:
         print(f"[Server Log] ERROR during file processing: {e}")
@@ -273,7 +205,10 @@ def handle_connect():
 @socketio.on('initialize_session')
 def handle_init(data):
     session_id = 'user_session'
-    session_data[session_id] = {'emails': data['emails'], 'filename': data['filename']}
 @socketio.on('start_login')
 def handle_login(credentials):
@@ -304,7 +239,7 @@ def handle_terminate():
 if __name__ == '__main__':
     print("====================================================================")
-    print("  🤗 Hillside Automation - Definitive Version")
     print(f"  Frontend URL: {FRONTEND_ORIGIN}")
     print(f"  Port: {os.getenv('PORT', 7860)}")
     print("====================================================================")

             print("[Server Log] Gmail API Service initialized successfully")
         except Exception as e: print(f"[Server Log] Gmail API Error: {e}")
+    def create_professional_email_template(self, subject, status_text, stats, custom_name, process_type):
         status_color = "#28a745" if "completed" in status_text else "#ffc107" if "terminated" in status_text else "#dc3545"
         current_date = datetime.now().strftime("%B %d, %Y at %I:%M %p")
+        html_template = f"""<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>{subject}</title><style> * {{ margin: 0; padding: 0; box-sizing: border-box; }} body {{ font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif; line-height: 1.6; color: #2c2c2c; background-color: #f8f8f8; }} .email-container {{ max-width: 700px; margin: 20px auto; background-color: #ffffff; box-shadow: 0 8px 32px rgba(139, 0, 0, 0.15); border-radius: 12px; overflow: hidden; }} .header {{ background: linear-gradient(135deg, #8A0303 0%, #4c00ff 100%); color: white; padding: 40px 30px; text-align: center; }} .header h1 {{ font-size: 32px; font-weight: 700; margin-bottom: 8px; text-shadow: 2px 2px 4px rgba(0, 0, 0, 0.3); }} .header p {{ font-size: 18px; opacity: 0.95; font-weight: 300; letter-spacing: 1px; }} .status-banner {{ background: {status_color}; color: white; text-align: center; padding: 18px; font-size: 16px; font-weight: 600; text-transform: uppercase; letter-spacing: 1.5px; }} .content {{ padding: 40px 30px; }} .report-info {{ background: #fdfdff; border-left: 6px solid #4c00ff; padding: 25px; margin-bottom: 35px; border-radius: 8px; box-shadow: 0 4px 12px rgba(76, 0, 255, 0.1); }} .info-grid {{ display: grid; grid-template-columns: 1fr 1fr; gap: 15px 25px; }} .info-item {{ display: flex; justify-content: space-between; align-items: center; padding: 10px 0; border-bottom: 1px solid #f0f0f0; }} .stats-grid {{ display: grid; grid-template-columns: repeat(auto-fit, minmax(140px, 1fr)); gap: 20px; margin: 35px 0; }} .stat-card {{ background: #f8f9fa; border: 1px solid #e0e0e0; border-radius: 12px; padding: 25px 15px; text-align: center; box-shadow: 0 4px 15px rgba(0, 0, 0, 0.05); }} .stat-number {{ font-size: 36px; font-weight: 700; color: #4c00ff; margin-bottom: 10px; }} .attachments-section {{ background: #f8f5ff; border: 1px solid #e0e0e0; border-radius: 12px; padding: 25px; margin: 35px 0; }} .footer {{ background: #2c2c2c; color: white; padding: 35px 30px; text-align: center; }} h3 {{ color: #8A0303; margin-bottom: 20px; font-size: 20px; font-weight: 600; }} </style></head><body> <div class="email-container"> <div class="header"><h1>Hillside's Quantum Automation</h1><p>Patient Processing Report</p></div> <div class="status-banner">Process {status_text}</div> <div class="content"> <div class="report-info"> <h3>Report Summary</h3> <div class="info-grid"> <div class="info-item"><span><b>Report Name</b></span><span>{custom_name}</span></div> <div class="info-item"><span><b>Process Type</b></span><span>{process_type}</span></div> <div class="info-item"><span><b>Generated</b></span><span>{current_date}</span></div> <div class="info-item"><span><b>Status</b></span><span style="font-weight: bold; color: {status_color};">{status_text}</span></div> </div> </div> <h3>Processing Results</h3> <div class="stats-grid"> <div class="stat-card"><div class="stat-number">{stats['total']}</div><div>Total in File</div></div> <div class="stat-card"><div class="stat-number">{stats['processed']}</div><div>Attempted</div></div> <div class="stat-card"><div class="stat-number">{stats['successful']}</div><div>Done</div></div> <div class="stat-card"><div class="stat-number">{stats['bad']}</div><div>Bad State</div></div> <div class="stat-card"><div class="stat-number">{stats['skipped']}</div><div>Skipped</div></div> </div> <div class="attachments-section"> <h3>Attached Reports</h3> <p style="margin-bottom: 1rem;">The following files are attached and have been uploaded to Google Drive:</p> <ul style="list-style-position: inside; padding-left: 0;"> <li><b>{custom_name}_Full.csv:</b> The complete report with the final status for every patient.</li> <li><b>{custom_name}_Bad.csv:</b> A filtered list of patients that resulted in a "Bad" state.</li> <li><b>{custom_name}_Skipped.csv:</b> A filtered list of patients that were skipped.</li> </ul> </div> </div> <div class="footer"><h4>Hillside Automation</h4><p>This is an automated report. Please do not reply.</p></div> </div> </body></html>"""
         return html_template
     def send_report(self, recipients, subject, body, attachments=None):
     global bot_instance
     results = []; is_terminated = False; is_crash = False
     try:
+        data = session_data.get(session_id, {});
+        patient_data = data.get('patient_data'); mode = data.get('mode')
         if not patient_data: raise ValueError("No patient data prepared for automation.")
         socketio.emit('initial_stats', {'total': len(patient_data)})
+        results = bot_instance.start_processing(mode, patient_data, start_date=data.get('start_date'), end_date=data.get('end_date'))
         is_terminated = bot_instance.termination_event.is_set()
     except Exception as e:
         print(f"[Server Log] Fatal error in automation thread: {e}"); is_crash = True
         if session_id in session_data: del session_data[session_id]
 def generate_and_send_reports(session_id, results, is_crash_report=False, is_terminated=False):
+    data = session_data.get(session_id, {});
+    if not data: print("[Server Log] Session data not found for reporting."); return
+    full_df = pd.DataFrame(data.get('patient_data_for_report'))
     if results:
+        result_df = pd.DataFrame(results).set_index('Name')
+        full_df.set_index('Name', inplace=True)
+        full_df.update(result_df); full_df.reset_index(inplace=True)
     full_df['Status'].fillna('Not Processed', inplace=True)
     final_report_df = full_df[['Name', 'PRN', 'Status']]
     bad_df = final_report_df[final_report_df['Status'] == 'Bad']
     skipped_df = final_report_df[final_report_df['Status'] == 'Skipped - No PRN']
     timestamp = datetime.now().strftime("%d_%b_%Y"); custom_name = data.get('filename') or timestamp
     full_report_name = f"{custom_name}_Full.csv"; bad_report_name = f"{custom_name}_Bad.csv"; skipped_report_name = f"{custom_name}_Skipped.csv"
     full_report_content = final_report_df.to_csv(index=False)
     drive_service.upload_file(full_report_name, full_report_content)
         bad_report_name: bad_df.to_csv(index=False),
         skipped_report_name: skipped_df.to_csv(index=False)
     }
+    status_text = "Terminated by User" if is_terminated else "Crashed" if is_crash_report else "Completed Successfully"
     stats = {
+        'total': len(full_df), 'processed': len(results),
         'successful': len(full_df[full_df['Status'] == 'Done']),
+        'bad': len(bad_df), 'skipped': len(skipped_df)
     }
+    process_type_str = data.get('mode', 'Unknown').title()
+    subject = f"{process_type_str} Automation Report [{status_text.upper()}]: {custom_name}"
+    professional_body = email_service.create_professional_email_template(subject, status_text, stats, custom_name, process_type_str)
     email_service.send_report(data.get('emails'), subject, professional_body, attachments)
     socketio.emit('process_complete', {'message': f'Process {status_text}. Report sent.'})
     name_only = raw_name.split('DOB')[0].strip()
     return re.sub(r'[:\d\-\s]+$', '', name_only).strip()
+@app.route('/process_and_initialize', methods=['POST'])
+def handle_file_processing_and_init():
     session_id = 'user_session'
     try:
+        data = session_data.get(session_id, {})
         if 'app_data' not in request.files or 'quantum_data' not in request.files:
             return jsonify({"error": "Both files are required."}), 400
         master_df = df_quantum.copy()
         master_df['Status'] = ''
+        data['patient_data_for_report'] = master_df
+        data['patient_data'] = master_df.to_dict('records')
         socketio.emit('data_processed')
         return jsonify({"message": "Data processed successfully."})
     except Exception as e:
         print(f"[Server Log] ERROR during file processing: {e}")
 @socketio.on('initialize_session')
 def handle_init(data):
     session_id = 'user_session'
+    session_data[session_id] = {
+        'emails': data['emails'], 'filename': data['filename'], 'mode': data.get('mode'),
+        'start_date': data.get('start_date'), 'end_date': data.get('end_date')
+    }
 @socketio.on('start_login')
 def handle_login(credentials):
 if __name__ == '__main__':
     print("====================================================================")
+    print("  🤗 Hillside Automation - Definitive Multi-Workflow Platform")
     print(f"  Frontend URL: {FRONTEND_ORIGIN}")
     print(f"  Port: {os.getenv('PORT', 7860)}")
     print("====================================================================")

worker.py CHANGED Viewed

@@ -76,28 +76,51 @@ class QuantumBot:
             error_message = f"Error during OTP submission: {str(e)}"; print(f"[Bot Log] ERROR during OTP submission: {error_message}")
             return False, error_message
-    def process_patient_list(self, patient_data):
         results = []
         for index, record in enumerate(patient_data):
             if self.termination_event.is_set(): print("[Bot Log] Termination detected."); break
             patient_name = record['Name']; patient_prn = record.get('PRN', '')
-            # --- Definitive Conditional Logic ---
-            if not patient_prn or not str(patient_prn).strip():
                 self.micro_status(f"Skipping '{patient_name}' (No PRN).")
-                status = 'Skipped - No PRN'
-                time.sleep(0.5) # A brief pause to make the skip visible on the UI
             else:
-                self.micro_status(f"Processing '{patient_name}' ({index + 1}/{len(patient_data)})...")
-                status = self._process_single_patient(patient_name, patient_prn)
             results.append({'Name': patient_name, 'PRN': patient_prn, 'Status': status})
             with self.app.app_context():
                 self.socketio.emit('log_update', {'name': patient_name, 'prn': patient_prn, 'status': status})
-                self.socketio.emit('stats_update', {'processed': len(results), 'remaining': len(patient_data) - len(results), 'status': status})
         return results
-    def _process_single_patient(self, patient_name, patient_prn):
         try:
             self.micro_status(f"Navigating to Void page for '{patient_name}'")
             self.driver.get("https://gateway.quantumepay.com/credit-card/void")
@@ -122,13 +145,11 @@ class QuantumBot:
                 self.micro_status("Verifying success and saving...")
                 company_input = WebDriverWait(self.driver, 10).until(EC.element_to_be_clickable((By.NAME, "company_name")))
                 company_input.clear(); company_input.send_keys(patient_name)
                 contact_input = WebDriverWait(self.driver, 5).until(EC.element_to_be_clickable((By.NAME, "company_contact")))
                 self.micro_status("Clearing Contact Name field...")
                 contact_input.click(); contact_input.send_keys(Keys.CONTROL + "a"); contact_input.send_keys(Keys.BACK_SPACE)
                 self.micro_status(f"Entering PRN: {patient_prn}...")
                 contact_input.send_keys(str(patient_prn))
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button/span[normalize-space()='Save Changes']"))).click()
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button[.//span[normalize-space()='Confirm']]"))).click()
                 time.sleep(5); return 'Done'
@@ -137,7 +158,36 @@ class QuantumBot:
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button[.//span[normalize-space()='Cancel']]"))).click()
                 return 'Bad'
         except Exception as e:
-            print(f"An error occurred while processing {patient_name}: {e}"); return 'Error'
     def shutdown(self):
         try:

             error_message = f"Error during OTP submission: {str(e)}"; print(f"[Bot Log] ERROR during OTP submission: {error_message}")
             return False, error_message
+    def start_processing(self, process_type, patient_data, **kwargs):
+        if process_type == 'void':
+            return self.process_void_list(patient_data)
+        elif process_type == 'refund':
+            return self.process_refund_list(patient_data, kwargs.get('start_date'), kwargs.get('end_date'))
+        else:
+            return []
+    def process_void_list(self, patient_data):
         results = []
         for index, record in enumerate(patient_data):
             if self.termination_event.is_set(): print("[Bot Log] Termination detected."); break
             patient_name = record['Name']; patient_prn = record.get('PRN', '')
+            status = 'Skipped - No PRN'
+            if patient_prn and str(patient_prn).strip():
+                self.micro_status(f"Processing VOID for '{patient_name}' ({index + 1}/{len(patient_data)})...")
+                status = self._process_single_void(patient_name, patient_prn)
+            else:
                 self.micro_status(f"Skipping '{patient_name}' (No PRN).")
+                time.sleep(0.5)
+            results.append({'Name': patient_name, 'PRN': patient_prn, 'Status': status})
+            with self.app.app_context():
+                self.socketio.emit('log_update', {'name': patient_name, 'prn': patient_prn, 'status': status})
+                self.socketio.emit('stats_update', {'processed': index + 1, 'remaining': len(patient_data) - (index + 1), 'status': status})
+        return results
+    def process_refund_list(self, patient_data, start_date, end_date):
+        results = []
+        for index, record in enumerate(patient_data):
+            if self.termination_event.is_set(): print("[Bot Log] Termination detected."); break
+            patient_name = record['Name']; patient_prn = record.get('PRN', '')
+            status = 'Skipped - No PRN'
+            if patient_prn and str(patient_prn).strip():
+                self.micro_status(f"Processing REFUND for '{patient_name}' ({index + 1}/{len(patient_data)})...")
+                status = self._process_single_refund(patient_name, patient_prn, start_date, end_date)
             else:
+                self.micro_status(f"Skipping '{patient_name}' (No PRN).")
+                time.sleep(0.5)
             results.append({'Name': patient_name, 'PRN': patient_prn, 'Status': status})
             with self.app.app_context():
                 self.socketio.emit('log_update', {'name': patient_name, 'prn': patient_prn, 'status': status})
+                self.socketio.emit('stats_update', {'processed': index + 1, 'remaining': len(patient_data) - (index + 1), 'status': status})
         return results
+    def _process_single_void(self, patient_name, patient_prn):
         try:
             self.micro_status(f"Navigating to Void page for '{patient_name}'")
             self.driver.get("https://gateway.quantumepay.com/credit-card/void")
                 self.micro_status("Verifying success and saving...")
                 company_input = WebDriverWait(self.driver, 10).until(EC.element_to_be_clickable((By.NAME, "company_name")))
                 company_input.clear(); company_input.send_keys(patient_name)
                 contact_input = WebDriverWait(self.driver, 5).until(EC.element_to_be_clickable((By.NAME, "company_contact")))
                 self.micro_status("Clearing Contact Name field...")
                 contact_input.click(); contact_input.send_keys(Keys.CONTROL + "a"); contact_input.send_keys(Keys.BACK_SPACE)
                 self.micro_status(f"Entering PRN: {patient_prn}...")
                 contact_input.send_keys(str(patient_prn))
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button/span[normalize-space()='Save Changes']"))).click()
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button[.//span[normalize-space()='Confirm']]"))).click()
                 time.sleep(5); return 'Done'
                 WebDriverWait(self.driver, self.DEFAULT_TIMEOUT).until(EC.element_to_be_clickable((By.XPATH, "//button[.//span[normalize-space()='Cancel']]"))).click()
                 return 'Bad'
         except Exception as e:
+            print(f"An error occurred during VOID for {patient_name}: {e}"); return 'Error'
+    def _process_single_refund(self, patient_name, patient_prn, start_date, end_date):
+        try:
+            self.micro_status(f"Navigating to Refund page for '{patient_name}'")
+            self.driver.get("https://gateway.quantumepay.com/credit-card/refund")
+            # This is a placeholder for your real date selection logic
+            # This needs to be implemented based on the actual calendar widget's HTML
+            self.micro_status(f"Setting date range: {start_date} to {end_date}...")
+            time.sleep(2)
+            search_successful = False
+            for attempt in range(15):
+                try:
+                    self.micro_status(f"Searching... (Attempt {attempt + 1})")
+                    search_box = WebDriverWait(self.driver, 2).until(EC.element_to_be_clickable((By.XPATH, "//input[@placeholder='Search']")))
+                    search_box.click(); time.sleep(0.5); search_box.clear(); time.sleep(0.5)
+                    search_box.send_keys(patient_name); search_successful = True; break
+                except Exception: time.sleep(1)
+            if not search_successful: raise Exception("Failed to search for patient in Refund.")
+            time.sleep(3)
+            # This is a placeholder for clicking the refund button
+            self.micro_status("Refunding transaction...")
+            time.sleep(2)
+            return "Done"
+        except Exception as e:
+            print(f"An error occurred during REFUND for {patient_name}: {e}"); return 'Error'
     def shutdown(self):
         try: