HawkEyesAI
/

Voice-AI-Agent

Model card Files Files and versions

xet

Community

rakib72642 commited on 2 days ago

Commit

a6fa796

1 Parent(s): 42c497a

updated mail

Browse files

Files changed (2) hide show

core/backend.py +304 -19
services/tts.py +1 -1

core/backend.py CHANGED Viewed

@@ -305,8 +305,16 @@ async def send_mail(to_mail: str, subject: str, body: str):
     email["From"] = smtp_user
     email["To"] = to_mail
     email["Subject"] = subject
     email.set_content(body)
     await aiosmtplib.send(
         email,
         hostname="smtp.gmail.com",
@@ -316,6 +324,73 @@ async def send_mail(to_mail: str, subject: str, body: str):
         use_tls=True,
     )
 # ═══════════════════════════════════════════════════════════════════════════════
 #  TOOLS
 # ═══════════════════════════════════════════════════════════════════════════════
@@ -735,14 +810,198 @@ async def book_appointment(
 @tool
-async def delete_appointment(patient_num: str, doctor_name: str = "", doctor_id: int = 0) -> str:
-    """Delete an appointment using the patient's phone number and doctor name or ID."""
     db_path     = get_db_path()
     patient_num = format_bd_number(patient_num)
     doctor_name = _clean_text(doctor_name)
     async with aiosqlite.connect(db_path) as db:
         db.row_factory = aiosqlite.Row
         if not doctor_name and doctor_id:
             cursor = await db.execute("SELECT doctor_name FROM doctors WHERE id = ?", (doctor_id,))
@@ -756,16 +1015,9 @@ async def delete_appointment(patient_num: str, doctor_name: str = "", doctor_id:
                    WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
                 (patient_num, doctor_name),
             )
-            row = await cursor.fetchone()
-            if not row:
                 return json.dumps({"success": False, "message": "No matching appointment found."})
-            await db.execute(
-                """DELETE FROM patients
-                   WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
-                (patient_num, doctor_name),
-            )
-            await db.commit()
         else:
             cursor = await db.execute(
                 """SELECT * FROM patients
@@ -784,17 +1036,46 @@ async def delete_appointment(patient_num: str, doctor_name: str = "", doctor_id:
                     "data": [dict(row) for row in rows],
                 }, ensure_ascii=False)
-            await db.execute(
-                """DELETE FROM patients
-                   WHERE id = ?""",
-                (rows[0]["id"],),
-            )
-            await db.commit()
-            doctor_name = rows[0]["doctor_name"] or doctor_name
     return json.dumps({
         "success": True,
-        "message": f"Appointment with Dr. {doctor_name} deleted successfully.",
     }, ensure_ascii=False)
 # ═══════════════════════════════════════════════════════════════════════════════
@@ -844,6 +1125,7 @@ TOOL RULES:
 - Use `find_doctors` first for doctor search, specialty search, and availability search.
 - Use `get_doctors_by_day` or `get_categories_by_day` when the user asks about a day directly.
 - Use `book_appointment` only after identifying the doctor and required patient details.
 - Never invent `doctor_id`. Get it from tool results or resolve by doctor_name/category.
 - If the user gives a Bangla date like "আগামীকাল" or "পরশু", convert it to a real date before booking.
 - Email is REQUIRED for booking and must be used to send a confirmation mail.
@@ -882,6 +1164,7 @@ You must now choose the correct tool instead of answering in prose:
 - Use `find_doctors` or `search_doctor` for doctor/specialty/availability questions.
 - Use `get_doctors_by_day` or `get_categories_by_day` for day-based availability.
 - Use `book_appointment` when the user is confirming a booking.
 - Use `delete_appointment` when the user is cancelling a booking.
 Important booking rules:
@@ -893,6 +1176,7 @@ Important booking rules:
 Important cancellation rules:
 - If the user gave only a phone number and there is exactly one matching appointment, cancel it directly.
 - If multiple appointments match, ask only for the doctor name.
 Do not give a normal conversational answer before the tool call.
 """
@@ -927,6 +1211,7 @@ class AIBackend:
             book_appointment,
             get_bd_time,
             search_appointment_by_phone,
             delete_appointment,
             get_categories_by_day,
             get_doctors_by_day

     email["From"] = smtp_user
     email["To"] = to_mail
     email["Subject"] = subject
+    # Plain-text fallback
     email.set_content(body)
+    # Professional HTML version
+    try:
+        html = _format_email_html(subject=subject, body_text=body)
+        email.add_alternative(html, subtype="html")
+    except Exception:
+        pass
     await aiosmtplib.send(
         email,
         hostname="smtp.gmail.com",
         use_tls=True,
     )
+def _format_email_html(subject: str, body_text: str) -> str:
+    """
+    Render a simple, professional HTML email.
+    Input body_text should be plain text with newlines.
+    """
+    safe = (
+        (body_text or "")
+        .replace("&", "&amp;")
+        .replace("<", "&lt;")
+        .replace(">", "&gt;")
+    )
+    safe = safe.replace("\n", "<br>")
+    return f"""\
+<!doctype html>
+<html>
+  <body style="margin:0;padding:0;background:#f6f7fb;font-family:Arial,Helvetica,sans-serif;">
+    <div style="max-width:640px;margin:0 auto;padding:24px;">
+      <div style="background:#ffffff;border-radius:14px;border:1px solid #e6e8f0;overflow:hidden;">
+        <div style="padding:18px 20px;background:linear-gradient(135deg,#0ea5e9,#8b5cf6);color:#fff;">
+          <div style="font-size:16px;font-weight:700;">{subject}</div>
+          <div style="font-size:12px;opacity:.9;margin-top:4px;">Aasha • Hospital Assistant</div>
+        </div>
+        <div style="padding:18px 20px;color:#0f172a;font-size:14px;line-height:1.55;">
+          {safe}
+          <div style="margin-top:18px;color:#64748b;font-size:12px;">
+            This is an automated message. If you did not request this, please ignore it.
+          </div>
+        </div>
+      </div>
+    </div>
+  </body>
+</html>
+"""
+def _format_appt_email_text(
+    action: str,
+    doctor_name: str,
+    patient_name: str,
+    patient_num: str,
+    visiting_date: str,
+    visiting_day: str,
+    visiting_time: str,
+    extra: str = "",
+) -> str:
+    action_line = {
+        "booked": "✅ Appointment Confirmed",
+        "updated": "✅ Appointment Updated",
+        "cancelled": "✅ Appointment Cancelled",
+    }.get(action, "✅ Appointment Update")
+    lines = [
+        action_line,
+        "",
+        f"Doctor       : {doctor_name}",
+        f"Patient      : {patient_name}",
+        f"Contact      : {patient_num}",
+        f"Visit Date   : {visiting_date}",
+        f"Visit Day    : {visiting_day}",
+        f"Visit Time   : {visiting_time}",
+    ]
+    if extra:
+        lines.extend(["", extra.strip()])
+    lines.extend(["", "Thank you.", "Aasha • Hospital Assistant"])
+    return "\n".join(lines)
 # ═══════════════════════════════════════════════════════════════════════════════
 #  TOOLS
 # ═══════════════════════════════════════════════════════════════════════════════
 @tool
+async def update_appointment(
+    patient_num: str,
+    doctor_name: str = "",
+    doctor_id: int = 0,
+    new_visiting_date: str = "",
+    new_doctor_name: str = "",
+    new_patient_num: str = "",
+    new_patient_mail: str = "",
+) -> str:
+    """
+    Update an existing appointment found by phone number.
+    You can update:
+      - visit date/day
+      - doctor (by name or id)
+      - phone number
+      - email
+    Rules:
+      - patient_num is required for lookup.
+      - If multiple appointments exist for the phone number, provide doctor_name
+        (or doctor_id) to select which one to update.
+      - A confirmation email is REQUIRED for updates: either the existing
+        appointment has an email, or provide new_patient_mail.
+    """
+    db_path = get_db_path()
+    patient_num_norm = format_bd_number(patient_num)
+    selector_name = _clean_text(doctor_name)
+    new_doctor_name = _clean_text(new_doctor_name)
+    new_patient_num = format_bd_number(new_patient_num) if new_patient_num else ""
+    new_patient_mail = _clean_text(new_patient_mail)
+    new_visiting_date = _clean_text(new_visiting_date)
+    parsed_date = _parse_visit_date(new_visiting_date) if new_visiting_date else None
+    if parsed_date:
+        new_visiting_date = parsed_date
+    if not patient_num_norm:
+        return "Missing details. Need patient phone number."
+    if not any([new_visiting_date, new_doctor_name, new_patient_num, new_patient_mail, doctor_id]):
+        return "Nothing to update. Provide new date, doctor, phone, or email."
+    async with aiosqlite.connect(db_path) as db:
+        db.row_factory = aiosqlite.Row
+        # Find matching appointments
+        params = [patient_num_norm]
+        q = "SELECT * FROM patients WHERE patient_num = ?"
+        if selector_name:
+            q += " AND LOWER(doctor_name) = LOWER(?)"
+            params.append(selector_name)
+        rows = await (await db.execute(q, params)).fetchall()
+        if not rows:
+            return "No appointment found for this phone number."
+        if len(rows) > 1 and not selector_name:
+            return (
+                "Multiple appointments found for this phone number. "
+                "Please specify the doctor name to update."
+            )
+        appt = dict(rows[0])
+        # Resolve new doctor if requested
+        resolved_doctor = None
+        if doctor_id:
+            d = await (await db.execute("SELECT * FROM doctors WHERE id = ?", (doctor_id,))).fetchone()
+            if d:
+                resolved_doctor = dict(d)
+        if resolved_doctor is None and new_doctor_name:
+            d = await (await db.execute(
+                "SELECT * FROM doctors WHERE LOWER(doctor_name) = LOWER(?)",
+                (new_doctor_name,),
+            )).fetchone()
+            if d:
+                resolved_doctor = dict(d)
+            else:
+                return f"No doctor found with name '{new_doctor_name}'."
+        # Build updated fields
+        updated_doctor_name = appt.get("doctor_name", "")
+        updated_doctor_category = appt.get("doctor_category", "")
+        updated_visiting_time = appt.get("visiting_time", "")
+        updated_visiting_day = appt.get("visiting_day", "")
+        updated_visiting_date = appt.get("visiting_date", "")
+        updated_patient_num = appt.get("patient_num", "")
+        updated_patient_mail = appt.get("patient_mail", "")
+        if resolved_doctor:
+            updated_doctor_name = resolved_doctor.get("doctor_name", updated_doctor_name)
+            updated_doctor_category = resolved_doctor.get("category", updated_doctor_category)
+            updated_visiting_time = (resolved_doctor.get("visiting_time") or updated_visiting_time).strip()
+            updated_visiting_day = (resolved_doctor.get("visiting_days") or updated_visiting_day).strip()
+        if new_visiting_date:
+            updated_visiting_date = new_visiting_date
+            # Derive English day name from date for consistency
+            try:
+                import datetime as _dt
+                y, m, d = [int(x) for x in updated_visiting_date.split("-")]
+                updated_visiting_day = _dt.date(y, m, d).strftime("%A")
+            except Exception:
+                pass
+        if new_patient_num:
+            updated_patient_num = new_patient_num
+        if new_patient_mail:
+            updated_patient_mail = new_patient_mail
+        if not updated_patient_mail:
+            return "Email is required to update an appointment. Please provide an email address."
+        await db.execute(
+            """UPDATE patients
+               SET doctor_name = ?,
+                   doctor_category = ?,
+                   patient_num = ?,
+                   visiting_date = ?,
+                   visiting_day = ?,
+                   visiting_time = ?,
+                   patient_mail = ?
+               WHERE id = ?""",
+            (
+                updated_doctor_name,
+                updated_doctor_category,
+                updated_patient_num,
+                updated_visiting_date,
+                updated_visiting_day,
+                updated_visiting_time,
+                updated_patient_mail,
+                appt["id"],
+            ),
+        )
+        await db.commit()
+    # Send confirmation email
+    patient_name = appt.get("patient_name", "Patient")
+    email_text = _format_appt_email_text(
+        action="updated",
+        doctor_name=updated_doctor_name,
+        patient_name=patient_name,
+        patient_num=updated_patient_num,
+        visiting_date=updated_visiting_date,
+        visiting_day=updated_visiting_day,
+        visiting_time=updated_visiting_time,
+        extra="Your appointment details have been updated successfully.",
+    )
+    try:
+        await send_mail(
+            to_mail=updated_patient_mail,
+            subject="Appointment Updated",
+            body=email_text,
+        )
+        mail_status = "📧 Confirmation mail sent."
+    except Exception as e:
+        mail_status = f"⚠️ Mail failed: {str(e)}"
+    return (
+        "✅ Appointment Updated!\n"
+        "━━━━━━━━━━━━━━━━━━━━━━\n"
+        f"Doctor       : {updated_doctor_name}\n"
+        f"Patient      : {patient_name}\n"
+        f"Date         : {updated_visiting_date}\n"
+        f"Day          : {updated_visiting_day}\n"
+        f"Time         : {updated_visiting_time}\n"
+        f"Contact      : {updated_patient_num}\n"
+        f"Email        : {updated_patient_mail}\n"
+        "━━━━━━━━━━━━━━━━━━━━━━\n"
+        f"{mail_status}"
+    )
+@tool
+async def delete_appointment(
+    patient_num: str,
+    doctor_name: str = "",
+    doctor_id: int = 0,
+    patient_mail: str = "",
+) -> str:
+    """
+    Cancel (delete) an appointment.
+    Sends a confirmation email to the patient (required).
+    """
     db_path     = get_db_path()
     patient_num = format_bd_number(patient_num)
     doctor_name = _clean_text(doctor_name)
+    patient_mail = _clean_text(patient_mail)
     async with aiosqlite.connect(db_path) as db:
         db.row_factory = aiosqlite.Row
+        appt_row = None
         if not doctor_name and doctor_id:
             cursor = await db.execute("SELECT doctor_name FROM doctors WHERE id = ?", (doctor_id,))
                    WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
                 (patient_num, doctor_name),
             )
+            appt_row = await cursor.fetchone()
+            if not appt_row:
                 return json.dumps({"success": False, "message": "No matching appointment found."})
         else:
             cursor = await db.execute(
                 """SELECT * FROM patients
                     "data": [dict(row) for row in rows],
                 }, ensure_ascii=False)
+            appt_row = rows[0]
+            doctor_name = appt_row["doctor_name"] or doctor_name
+        # Resolve email (required)
+        appt = dict(appt_row) if appt_row is not None else {}
+        appt_email = _clean_text(appt.get("patient_mail", "")) or patient_mail
+        if not appt_email:
+            return json.dumps({
+                "success": False,
+                "message": "Email is required to cancel an appointment. Please provide the email address.",
+            }, ensure_ascii=False)
+        # Delete after we have all details for mail
+        await db.execute("DELETE FROM patients WHERE id = ?", (appt["id"],))
+        await db.commit()
+    # Send cancellation email
+    email_text = _format_appt_email_text(
+        action="cancelled",
+        doctor_name=appt.get("doctor_name", doctor_name),
+        patient_name=appt.get("patient_name", "Patient"),
+        patient_num=appt.get("patient_num", patient_num),
+        visiting_date=appt.get("visiting_date", ""),
+        visiting_day=appt.get("visiting_day", ""),
+        visiting_time=appt.get("visiting_time", ""),
+        extra="Your appointment has been cancelled successfully.",
+    )
+    try:
+        await send_mail(
+            to_mail=appt_email,
+            subject="Appointment Cancelled",
+            body=email_text,
+        )
+        mail_status = "Confirmation mail sent."
+    except Exception as e:
+        mail_status = f"Mail failed: {str(e)}"
     return json.dumps({
         "success": True,
+        "message": f"Appointment with Dr. {doctor_name} cancelled successfully. {mail_status}",
     }, ensure_ascii=False)
 # ═══════════════════════════════════════════════════════════════════════════════
 - Use `find_doctors` first for doctor search, specialty search, and availability search.
 - Use `get_doctors_by_day` or `get_categories_by_day` when the user asks about a day directly.
 - Use `book_appointment` only after identifying the doctor and required patient details.
+- Use `update_appointment` when the user wants to change an existing appointment.
 - Never invent `doctor_id`. Get it from tool results or resolve by doctor_name/category.
 - If the user gives a Bangla date like "আগামীকাল" or "পরশু", convert it to a real date before booking.
 - Email is REQUIRED for booking and must be used to send a confirmation mail.
 - Use `find_doctors` or `search_doctor` for doctor/specialty/availability questions.
 - Use `get_doctors_by_day` or `get_categories_by_day` for day-based availability.
 - Use `book_appointment` when the user is confirming a booking.
+- Use `update_appointment` when the user wants to update an appointment.
 - Use `delete_appointment` when the user is cancelling a booking.
 Important booking rules:
 Important cancellation rules:
 - If the user gave only a phone number and there is exactly one matching appointment, cancel it directly.
 - If multiple appointments match, ask only for the doctor name.
+- Email is REQUIRED to cancel or update. If missing, ask for email.
 Do not give a normal conversational answer before the tool call.
 """
             book_appointment,
             get_bd_time,
             search_appointment_by_phone,
+            update_appointment,
             delete_appointment,
             get_categories_by_day,
             get_doctors_by_day

services/tts.py CHANGED Viewed

@@ -44,7 +44,7 @@ def _parse_pct(text: str) -> float:
 # - `ELEVENLABS_SPEED_PCT` is an optional relative adjustment like "+10%" or "-5%".
 #   This is applied on top of the base: effective = base * (1 + pct).
 # - The final value is clamped to a safe range to avoid invalid API values.
-_ELEVEN_BASE_SPEED = float(os.getenv("ELEVENLABS_SPEED", "3"))
 _ELEVEN_SPEED_PCT  = _parse_pct(os.getenv("ELEVENLABS_SPEED_PCT", "0%"))
 ELEVENLABS_SPEED   = _clamp(_ELEVEN_BASE_SPEED * (1.0 + _ELEVEN_SPEED_PCT), 0.5, 2.5)
 ELEVENLABS_OUTPUT_FORMAT = "mp3_22050_32"

 # - `ELEVENLABS_SPEED_PCT` is an optional relative adjustment like "+10%" or "-5%".
 #   This is applied on top of the base: effective = base * (1 + pct).
 # - The final value is clamped to a safe range to avoid invalid API values.
+_ELEVEN_BASE_SPEED = float(os.getenv("ELEVENLABS_SPEED", "5"))
 _ELEVEN_SPEED_PCT  = _parse_pct(os.getenv("ELEVENLABS_SPEED_PCT", "0%"))
 ELEVENLABS_SPEED   = _clamp(_ELEVEN_BASE_SPEED * (1.0 + _ELEVEN_SPEED_PCT), 0.5, 2.5)
 ELEVENLABS_OUTPUT_FORMAT = "mp3_22050_32"