space

README.md

@@ -1,4 +1,124 @@
+# 🏥 Eczane Sipariş & Prospektüs Asistanı
+
+Tool-calling destekli, gerçek veritabanı okuma/yazma yapan, halüsinasyon üretmeyen bir eczane asistanı.
+
+## 🎯 Senaryo Özeti
+
+Kullanıcı bir ilaç hakkında bilgi ister (stok durumu, prospektüs özeti), sipariş oluşturur ve sipariş durumunu sorgular. Model hiçbir zaman ilaç bilgisini kendi hafızasından **uydurmaz** — her yanıt bir tool çağrısının döndürdüğü gerçek veriye dayanır.
+
+## 🏗️ Mimari
+
+```
+Kullanıcı
+   │
+   ▼
+[Gradio Arayüzü]
+   │
+   ▼
+[Turn 1] Model → sistem promptuna göre JSON tool-call üretir
+   │
+   ▼
+[Tool Router] → hangi fonksiyon çağrılacak, argümanları parse eder
+   │
+   ├─► get_drug_info(drug_name)      ─┐
+   ├─► create_order(drug_name, qty)   ├─► SQLite DB (drugs, orders tabloları)
+   └─► check_order_status(order_id)  ─┘
+   │
+   ▼ (get_drug_info: DB'de ilaç yoksa)
+[Web Arama API: Tavily / SerpApi] → prospektüs özeti çeker → DB'ye yazar
+   │
+   ▼
+[Turn 2] Model, tool sonucunu alır, kullanıcıya doğal dilde özetler
+```
+
+### Kullanılan Model
+
+**`menesnas/gemma_4_pharmacy_merged`** — Gemma 4 tabanlı, Türkçe eczacılık QA verisiyle LoRA fine-tune edilmiş, merge edilmiş model.
+
+## 📂 Dosya Yapısı
+
+```
+OrderDrug/
+├── app.py                # Gradio arayüzü + model yükleme + tool router
+├── db.py                 # SQLite bağlantı, şema oluşturma, CRUD fonksiyonları
+├── tools.py              # get_drug_info, create_order, check_order_status
+├── search_provider.py    # Tavily/SerpApi soyutlaması
+├── seed_db.py            # İlk çalıştırmada örnek 10 ilaç ekler
+├── requirements.txt      # Bağımlılıklar
+├── pharmacy.db           # SQLite veritabanı (seed_db.py ile üretilir)
+├── PROJECT_SPEC.md       # Detaylı proje spesifikasyonu
+└── README.md             # Bu dosya
+```
+
+## 🚀 Yerelde Çalıştırma
+
+```bash
+# 1. Bağımlılıkları kur
+pip install -r requirements.txt
+
+# 2. Veritabanını başlat (opsiyonel — app.py otomatik çağırır)
+python seed_db.py
+
+# 3. Uygulamayı başlat
+python app.py
+```
+
+### Ortam Değişkenleri
+
+Web arama özelliği için (DB'de olmayan ilaçları aramak):
+
+| Değişken | Açıklama |
+|---|---|
+| `TAVILY_API_KEY` | Tavily API anahtarı (önerilen) |
+| `SERPAPI_API_KEY` | SerpApi API anahtarı (alternatif) |
+
+> Her iki anahtar da yoksa, DB'de bulunmayan ilaçlar için "bulunamadı" hatası döner.
+
+## 🧪 Örnek Kullanım Senaryoları
+
+| # | Kullanıcı Girdisi | Tetiklenen Tool | Beklenen Davranış |
+|---|---|---|---|
+| 1 | "Parol stokta var mı?" | `get_drug_info` | DB'den stok/prospektüs döner |
+| 2 | "Aspirin hakkında bilgi ver" | `get_drug_info` | Web araması → DB'ye kayıt → sonuç |
+| 3 | "3 kutu Aferin sipariş et" | `create_order` | Stok azalır, sipariş oluşur |
+| 4 | "500 kutu Parol sipariş et" | `create_order` | "Yetersiz stok" hatası |
+| 5 | "5 numaralı sipariş ne durumda?" | `check_order_status` | Sipariş durumu döner |
+| 6 | "Hava nasıl?" | — | Normal yanıt (tool çağrılmaz) |
+
+
+## 📸 Örnek Çalıştırma Ekran Görüntüleri
+
+Aşağıda, sistemin farklı senaryolarda tool-call mekanizmasını nasıl tetiklediğini gösteren örnek girdi/çıktılar yer almaktadır.
+
+### 1. Semptoma Göre İlaç Sorgulama (Asistan Yanıtı)
+
+**Kullanıcı girdisi:** `"Başım dönüyor. Hangi ilaç işe yarar? Prospektüsünü verebilir misin"`
+
+Model `get_drug_info` fonksiyonunu çağırır, veritabanından gerçek stok ve prospektüs bilgisini çeker.
+
+![DB'de kayıtlı ilaç sorgusu](screenshots/ornekCikti.jpg)
+
+![](screenshots/ornekcikti2.jpg)
+
+### 2. Sipariş Oluşturma
+
+**Kullanıcı girdisi:** `"3 kutu Aferin sipariş et"`
+
+`create_order` fonksiyonu çağrılır, stok düşürülür ve yeni bir sipariş kaydı oluşturulur.
+
+![Sipariş oluşturma](screenshots/siparis.jpg)
+
+![](screenshots/siparisLog.jpg)
+
+
+
+## ⚠️ Disclaimer
+
+Bu sistem akademik bir projedir; stok/fiyat verileri simülasyondur, prospektüs özetleri gerçek tıbbi tavsiye yerine geçmez.
+
+
 ---
+
 title: PharmacyWebsite
 emoji: ⚡
 colorFrom: purple

app.py

@@ -0,0 +1,400 @@
+"""
+Eczane Sipariş & Prospektüs Asistanı — Ana Uygulama
+Gradio arayüzü + model yükleme + tool-calling loop.
+
+Kullanılan model: menesnas/gemma_4_pharmacy_merged
+(Gemma 4 tabanlı, Türkçe eczacılık QA verisiyle LoRA fine-tune, merge edilmiş)
+"""
+
+import json
+import re
+import os
+import time
+
+import gradio as gr
+import torch
+from transformers import AutoTokenizer, AutoModelForCausalLM
+
+from db import init_db, list_drugs
+from seed_db import seed
+from tools import TOOL_DEFINITIONS, route_tool_call
+
+# ---------------------------------------------------------------------------
+# Veritabanı başlat
+# ---------------------------------------------------------------------------
+init_db()
+seed()
+
+# ---------------------------------------------------------------------------
+# Model Yükleme
+# ---------------------------------------------------------------------------
+MODEL_ID = "menesnas/gemma_4_pharmacy_merged"
+
+print(f"[INFO] Model yukleniyor: {MODEL_ID}")
+print(f"[INFO] CUDA mevcut mu: {torch.cuda.is_available()}")
+if torch.cuda.is_available():
+    print(f"[INFO] GPU: {torch.cuda.get_device_name(0)}")
+    free_bytes, total_bytes = torch.cuda.mem_get_info(0)
+    print(f"[INFO] GPU bellek: {free_bytes / 1e9:.1f} GB bos / {total_bytes / 1e9:.1f} GB toplam")
+else:
+    print("[UYARI] GPU bulunamadi — model CPU'da calisacak, bu COK YAVAS olur "
+          "(bir soru icin dakikalar surebilir). Colab'da Runtime > Change runtime "
+          "type > T4 GPU secili oldugundan emin olun.")
+
+tokenizer = AutoTokenizer.from_pretrained(MODEL_ID)
+
+# NOT: device_map="auto" bazen (ozellikle Colab'da runtime yeniden baslatilmadan
+# hucreler tekrar calistirildiginda GPU bellegi onceki yuklemelerle dolu gorunurse)
+# modelin TAMAMINI CPU'ya atiyor — bu da uretimi ~100x yavaslatir. GPU varsa
+# dogrudan tek GPU'ya zorluyoruz, "auto"nun yanlis offload karari vermesini onluyoruz.
+model = AutoModelForCausalLM.from_pretrained(
+    MODEL_ID,
+    dtype=torch.float16 if torch.cuda.is_available() else torch.float32,
+    device_map={"": 0} if torch.cuda.is_available() else "cpu",
+)
+print(f"[INFO] Model cihazi: {model.device}")
+
+
+def _resolve_eos_token_ids() -> list[int] | None:
+    """
+    generate() icin durma token'larini belirler.
+    Gemma sohbet formati <end_of_turn> ile biter; modelin generation_config'i
+    bunu eos olarak tanimiyorsa, model her seferinde max_new_tokens'a kadar
+    (gereksiz yere COK yavas) uretim yapar. Bu yuzden hem <eos> hem
+    <end_of_turn> id'lerini elle topluyoruz.
+    """
+    ids = set()
+    if tokenizer.eos_token_id is not None:
+        ids.add(tokenizer.eos_token_id)
+    end_of_turn_id = tokenizer.convert_tokens_to_ids("<end_of_turn>")
+    if end_of_turn_id is not None and end_of_turn_id != tokenizer.unk_token_id:
+        ids.add(end_of_turn_id)
+    return list(ids) if ids else None
+
+
+EOS_TOKEN_IDS = _resolve_eos_token_ids()
+PAD_TOKEN_ID = tokenizer.pad_token_id
+if PAD_TOKEN_ID is None and EOS_TOKEN_IDS:
+    PAD_TOKEN_ID = EOS_TOKEN_IDS[0]
+
+print(f"[INFO] EOS token id'leri: {EOS_TOKEN_IDS}")
+print(f"[INFO] Tum ozel token'lar: {tokenizer.all_special_tokens}")
+print(f"[INFO] '<end_of_turn>' -> id: {tokenizer.convert_tokens_to_ids('<end_of_turn>')} "
+      f"(unk_token_id: {tokenizer.unk_token_id})")
+print("[OK] Model hazir!")
+
+# ---------------------------------------------------------------------------
+# System Prompt
+# ---------------------------------------------------------------------------
+SYSTEM_PROMPT = """Sen bir eczane sipariş asistanısın. Sana verilen 3 araçtan başka hiçbir bilgi kaynağın yok.
+Kullanıcı ilaç bilgisi sorarsa, sipariş vermek isterse veya sipariş durumu sorarsa, SADECE aşağıdaki JSON formatlarından birini üret. Başka hiçbir şey yazma.
+
+Araçların:
+1. get_drug_info: İlacın stok ve prospektüs bilgisini getirir.
+2. create_order: Sipariş oluşturur.
+3. check_order_status: Sipariş durumunu sorgular.
+
+Örnek 1:
+Kullanıcı: "Parol var mı, stokta mı?"
+Sen: {"name": "get_drug_info", "arguments": {"drug_name": "Parol"}}
+
+Örnek 2:
+Kullanıcı: "3 kutu Aferin sipariş etmek istiyorum"
+Sen: {"name": "create_order", "arguments": {"drug_name": "Aferin", "quantity": 3}}
+
+Örnek 3:
+Kullanıcı: "12 numaralı siparişim nerede kaldı?"
+Sen: {"name": "check_order_status", "arguments": {"order_id": 12}}
+
+Örnek 4:
+Kullanıcı: "Başım ağrıyor ne ilaç önerirsin?"
+Sen: {"name": "get_drug_info", "arguments": {"drug_name": "baş ağrısı"}}
+
+KURALLAR:
+- İlaç/stok/sipariş ile ilgili her soruda SADECE yukarıdaki formatta JSON yaz, başka hiçbir şey yazma.
+- İlaç bilgisi, stok, fiyat veya prospektüs bilgisini KENDİ BİLGİNDEN UYDURMA. Sadece tool sonucunda dönen veriyi kullan.
+- Tool sonucu hata içeriyorsa, alternatif bilgi uydurma, sadece hatayı ilet.
+- İlaç/eczane ile ilgili olmayan sorularda normal Türkçe yanıt verebilirsin.
+"""
+
+RESULT_PROMPT_TEMPLATE = """Aşağıda bir araç çağrısının sonucu var. Bu sonucu kullanıcıya doğal, kibar Türkçe ile özetle.
+SADECE aşağıdaki verileri kullan, kendi bilginden ek bilgi EKLEME.
+Eğer sonuçta hata varsa, hatayı kullanıcıya nazikçe ilet.
+
+Araç sonucu:
+{tool_result}
+
+Kullanıcının sorusu: {user_message}
+"""
+
+# ---------------------------------------------------------------------------
+# Model çıkarım yardımcıları
+# ---------------------------------------------------------------------------
+
+def generate_response(prompt: str, max_new_tokens: int = 512) -> str:
+    """Model'den yanıt üretir."""
+    inputs = tokenizer(prompt, return_tensors="pt").to(model.device)
+    start = time.time()
+    with torch.no_grad():
+        outputs = model.generate(
+            **inputs,
+            max_new_tokens=max_new_tokens,
+            do_sample=True,
+            temperature=0.3,
+            top_p=0.9,
+            repetition_penalty=1.15,
+            eos_token_id=EOS_TOKEN_IDS,
+            pad_token_id=PAD_TOKEN_ID,
+        )
+    elapsed = time.time() - start
+    generated = outputs[0][inputs["input_ids"].shape[1]:]
+    n_new = generated.shape[0]
+    print(f"[TIMING] generate(): {n_new} token, {elapsed:.1f}s ({n_new / elapsed:.2f} tok/s)")
+    # Sadece üretilen kısmı çöz
+    return tokenizer.decode(generated, skip_special_tokens=True).strip()
+
+
+def parse_tool_call(text: str) -> dict | None:
+    """
+    Model çıktısından JSON tool call parse eder.
+    Başarısızsa None döner.
+    """
+    # İlk olarak temiz JSON deniyoruz
+    cleaned = text.strip()
+
+    # Markdown code block kaldır
+    cleaned = re.sub(r"```(?:json)?\s*", "", cleaned)
+    cleaned = re.sub(r"```\s*$", "", cleaned)
+    cleaned = cleaned.strip()
+
+    # JSON objesini bul
+    match = re.search(r'\{[^{}]*"name"\s*:\s*"[^"]+"\s*,\s*"arguments"\s*:\s*\{[^}]*\}[^}]*\}', cleaned, re.DOTALL)
+    if match:
+        try:
+            parsed = json.loads(match.group())
+            if "name" in parsed and "arguments" in parsed:
+                return parsed
+        except json.JSONDecodeError:
+            pass
+
+    # Daha geniş JSON arama
+    for m in re.finditer(r'\{.*?\}', cleaned, re.DOTALL):
+        try:
+            parsed = json.loads(m.group())
+            if "name" in parsed and "arguments" in parsed:
+                return parsed
+        except (json.JSONDecodeError, KeyError):
+            continue
+
+    # Nested JSON için son deneme
+    try:
+        brace_start = cleaned.find("{")
+        brace_end = cleaned.rfind("}") + 1
+        if brace_start >= 0 and brace_end > brace_start:
+            candidate = cleaned[brace_start:brace_end]
+            parsed = json.loads(candidate)
+            if "name" in parsed and "arguments" in parsed:
+                return parsed
+    except (json.JSONDecodeError, KeyError):
+        pass
+
+    return None
+
+
+# ---------------------------------------------------------------------------
+# Ana işlem döngüsü (3-turn tool-calling)
+# ---------------------------------------------------------------------------
+
+def process_message(user_message: str) -> tuple[str, str]:
+    """
+    Kullanıcı mesajını işler, tool-calling döngüsünü yürütür.
+    (final_response, log_text) döner.
+    """
+    log_lines = []
+
+    # --- Turn 1: Model'e kullanıcı sorusunu ver, tool call üretmesini bekle ---
+    turn1_prompt = f"<start_of_turn>system\n{SYSTEM_PROMPT}<end_of_turn>\n<start_of_turn>user\n{user_message}<end_of_turn>\n<start_of_turn>model\n"
+
+    log_lines.append("=" * 60)
+    log_lines.append("📝 TURN 1 — Model'e gönderilen kullanıcı mesajı:")
+    log_lines.append(f"   \"{user_message}\"")
+    log_lines.append("")
+
+    raw_output = generate_response(turn1_prompt, max_new_tokens=256)
+    log_lines.append("🤖 Model çıktısı (Turn 1 — ham):")
+    log_lines.append(f"   {raw_output}")
+    log_lines.append("")
+
+    # --- Tool call parse ---
+    tool_call = parse_tool_call(raw_output)
+
+    if tool_call is None:
+        # Tool call yok → model doğrudan yanıt veriyor (ilaçla ilgisi olmayan soru)
+        log_lines.append("ℹ️  Tool call tespit edilmedi — model doğrudan yanıt veriyor.")
+        return raw_output, "\n".join(log_lines)
+
+    tool_name = tool_call["name"]
+    tool_args = tool_call["arguments"]
+
+    # Tamsayı argümanları düzelt (model bazen string verebilir)
+    if "quantity" in tool_args and isinstance(tool_args["quantity"], str):
+        try:
+            tool_args["quantity"] = int(tool_args["quantity"])
+        except ValueError:
+            pass
+    if "order_id" in tool_args and isinstance(tool_args["order_id"], str):
+        try:
+            tool_args["order_id"] = int(tool_args["order_id"])
+        except ValueError:
+            pass
+
+    log_lines.append(f"🔧 Tool call tespit edildi:")
+    log_lines.append(f"   Araç: {tool_name}")
+    log_lines.append(f"   Argümanlar: {json.dumps(tool_args, ensure_ascii=False)}")
+    log_lines.append("")
+
+    # --- Tool çalıştır ---
+    tool_result = route_tool_call(tool_name, tool_args)
+    tool_result_json = json.dumps(tool_result, ensure_ascii=False, indent=2)
+
+    log_lines.append("📦 Tool sonucu:")
+    log_lines.append(f"   {tool_result_json}")
+    log_lines.append("")
+
+    # --- Turn 2: Tool sonucunu modele ver, doğal dilde özetlemesini iste ---
+    result_prompt = RESULT_PROMPT_TEMPLATE.format(
+        tool_result=tool_result_json,
+        user_message=user_message,
+    )
+    turn2_prompt = (
+        f"<start_of_turn>system\n{SYSTEM_PROMPT}<end_of_turn>\n"
+        f"<start_of_turn>user\n{user_message}<end_of_turn>\n"
+        f"<start_of_turn>model\n{json.dumps(tool_call, ensure_ascii=False)}<end_of_turn>\n"
+        f"<start_of_turn>user\n{result_prompt}<end_of_turn>\n"
+        f"<start_of_turn>model\n"
+    )
+
+    final_response = generate_response(turn2_prompt, max_new_tokens=512)
+
+    log_lines.append("💬 TURN 2 — Model'in nihai yanıtı:")
+    log_lines.append(f"   {final_response}")
+    log_lines.append("=" * 60)
+
+    return final_response, "\n".join(log_lines)
+
+
+# ---------------------------------------------------------------------------
+# Gradio Arayüzü
+# ---------------------------------------------------------------------------
+
+def get_drugs_table():
+    """Mevcut ilaçlar tablosunu DataFrame için döner."""
+    drugs = list_drugs()
+    if not drugs:
+        return [["Veri yok", "", ""]]
+    return [
+        [
+            d["display_name"],
+            str(d["stock"]),
+            f"{d['price']:.2f} ₺" if d["price"] else "—",
+        ]
+        for d in drugs
+    ]
+
+
+def chat_handler(user_message: str):
+    """Gradio event handler."""
+    if not user_message.strip():
+        return "Lütfen bir mesaj yazın.", "", get_drugs_table()
+
+    final_response, log_text = process_message(user_message.strip())
+    drugs_table = get_drugs_table()
+    return final_response, log_text, drugs_table
+
+
+# --- Arayüz ---
+DISCLAIMER = (
+    "⚠️ **Disclaimer:** Bu sistem akademik bir projedir; stok/fiyat verileri simülasyondur, "
+    "prospektüs özetleri gerçek tıbbi tavsiye yerine geçmez."
+)
+
+CUSTOM_CSS = """
+    .disclaimer { 
+        background: #fff3cd; 
+        border: 1px solid #ffc107; 
+        border-radius: 8px; 
+        padding: 12px; 
+        margin-top: 16px;
+        font-size: 14px;
+    }
+    .header-title {
+        text-align: center;
+        margin-bottom: 8px;
+    }
+"""
+
+CUSTOM_THEME = gr.themes.Soft(
+    primary_hue="teal",
+    secondary_hue="blue",
+)
+
+with gr.Blocks(title="Eczane Siparis Asistani") as demo:
+
+    gr.Markdown(
+        """
+        # 🏥 Eczane Sipariş & Prospektüs Asistanı
+        **Model:** `menesnas/gemma_4_pharmacy_merged` (Gemma 4 — Türkçe Eczacılık Fine-Tune)
+        
+        İlaç bilgisi sorgulayabilir, sipariş oluşturabilir ve sipariş durumunu takip edebilirsiniz.
+        """,
+        elem_classes=["header-title"],
+    )
+
+    with gr.Row():
+        with gr.Column(scale=2):
+            user_input = gr.Textbox(
+                label="💬 Mesajınız",
+                placeholder='Örn: "Parol stokta var mı?", "3 kutu Aferin sipariş et", "5 numaralı sipariş ne durumda?"',
+                lines=2,
+            )
+            send_btn = gr.Button("📤 Gönder", variant="primary", size="lg")
+
+            response_output = gr.Textbox(
+                label="🤖 Asistan Yanıtı",
+                lines=6,
+                interactive=False,
+            )
+
+        with gr.Column(scale=1):
+            drugs_table = gr.Dataframe(
+                headers=["İlaç Adı", "Stok", "Fiyat"],
+                label="📋 Mevcut İlaçlar",
+                value=get_drugs_table(),
+                interactive=False,
+                wrap=True,
+            )
+
+    with gr.Accordion("🔍 Tool Call İşlem Adımları (Log)", open=False):
+        log_output = gr.Textbox(
+            label="İşlem Günlüğü",
+            lines=15,
+            interactive=False,
+        )
+
+    gr.Markdown(DISCLAIMER, elem_classes=["disclaimer"])
+
+    # Event binding
+    send_btn.click(
+        fn=chat_handler,
+        inputs=[user_input],
+        outputs=[response_output, log_output, drugs_table],
+    )
+    user_input.submit(
+        fn=chat_handler,
+        inputs=[user_input],
+        outputs=[response_output, log_output, drugs_table],
+    )
+
+
+if __name__ == "__main__":
+    demo.launch(share=True, theme=CUSTOM_THEME, css=CUSTOM_CSS)

db.py

@@ -0,0 +1,191 @@
+"""
+Eczane Sipariş Asistanı — Veritabanı Katmanı
+SQLite bağlantı yönetimi, şema oluşturma ve CRUD fonksiyonları.
+"""
+
+import sqlite3
+import os
+from contextlib import contextmanager
+
+DB_PATH = os.path.join(os.path.dirname(os.path.abspath(__file__)), "pharmacy.db")
+
+
+def get_connection() -> sqlite3.Connection:
+    """Yeni bir SQLite bağlantısı oluşturur (row_factory aktif)."""
+    conn = sqlite3.connect(DB_PATH)
+    conn.row_factory = sqlite3.Row
+    conn.execute("PRAGMA journal_mode=WAL")
+    conn.execute("PRAGMA foreign_keys=ON")
+    return conn
+
+
+@contextmanager
+def get_db():
+    """Context manager: bağlantı açar, işlem bitince kapatır."""
+    conn = get_connection()
+    try:
+        yield conn
+        conn.commit()
+    except Exception:
+        conn.rollback()
+        raise
+    finally:
+        conn.close()
+
+
+def init_db():
+    """Veritabanı tablolarını oluşturur (yoksa)."""
+    with get_db() as conn:
+        conn.executescript("""
+            CREATE TABLE IF NOT EXISTS drugs (
+                id                  INTEGER PRIMARY KEY AUTOINCREMENT,
+                name                TEXT    UNIQUE NOT NULL,
+                display_name        TEXT,
+                stock               INTEGER NOT NULL DEFAULT 0,
+                price               REAL,
+                prospektus_summary  TEXT,
+                source              TEXT,
+                created_at          TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            );
+
+            CREATE TABLE IF NOT EXISTS orders (
+                id          INTEGER PRIMARY KEY AUTOINCREMENT,
+                drug_id     INTEGER REFERENCES drugs(id),
+                drug_name   TEXT,
+                quantity    INTEGER NOT NULL,
+                status      TEXT    DEFAULT 'Hazırlanıyor',
+                created_at  TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            );
+        """)
+
+
+# ---------------------------------------------------------------------------
+# CRUD — drugs
+# ---------------------------------------------------------------------------
+
+def find_drug(name: str) -> dict | None:
+    """
+    İlaç adına göre arama yapar (case-insensitive, boşluk normalize edilmiş).
+    Bulursa dict döner, bulamazsa None.
+    """
+    normalized = " ".join(name.strip().lower().split())
+    with get_db() as conn:
+        row = conn.execute(
+            "SELECT * FROM drugs WHERE LOWER(REPLACE(name, ' ', '')) = LOWER(REPLACE(?, ' ', ''))",
+            (normalized,),
+        ).fetchone()
+        if row:
+            return dict(row)
+    return None
+
+
+def insert_drug(
+    name: str,
+    display_name: str,
+    stock: int = 0,
+    price: float | None = None,
+    prospektus_summary: str | None = None,
+    source: str = "seed",
+) -> int:
+    """Yeni ilaç kaydı ekler ve id döner."""
+    normalized = " ".join(name.strip().lower().split())
+    with get_db() as conn:
+        cur = conn.execute(
+            """INSERT INTO drugs (name, display_name, stock, price, prospektus_summary, source)
+               VALUES (?, ?, ?, ?, ?, ?)""",
+            (normalized, display_name, stock, price, prospektus_summary, source),
+        )
+        return cur.lastrowid
+
+
+def update_drug_prospektus(drug_id: int, summary: str, source: str = "fetched"):
+    """Mevcut ilacın prospektüs özetini günceller."""
+    with get_db() as conn:
+        conn.execute(
+            "UPDATE drugs SET prospektus_summary = ?, source = ? WHERE id = ?",
+            (summary, source, drug_id),
+        )
+
+
+def search_drugs_by_keyword(keyword: str) -> list[dict]:
+    """
+    Semptom, şikayet veya kelimeye göre prospektüs özetinde ve ilaç adında arama yapar.
+    """
+    term = keyword.strip().lower()
+    # Yaygın kelimeleri temizle (örn. 'ilacı', 'önerisi', 'için')
+    stop_words = {"ilaci", "ilaç", "ilacı", "onerisi", "önerisi", "icin", "için", "ne", "var", "mi", "mı", "tavsiye"}
+    words = [w for w in term.split() if w not in stop_words and len(w) > 2]
+    
+    if not words:
+        words = [term]
+
+    with get_db() as conn:
+        results = []
+        seen_ids = set()
+        for word in words:
+            pattern = f"%{word}%"
+            rows = conn.execute(
+                """SELECT id, name, display_name, stock, price, prospektus_summary, source 
+                   FROM drugs 
+                   WHERE LOWER(prospektus_summary) LIKE ? OR LOWER(display_name) LIKE ? OR LOWER(name) LIKE ?""",
+                (pattern, pattern, pattern),
+            ).fetchall()
+            for r in rows:
+                d = dict(r)
+                if d["id"] not in seen_ids:
+                    seen_ids.add(d["id"])
+                    results.append(d)
+        return results
+
+
+def list_drugs() -> list[dict]:
+    """Tüm ilaçları döner (arayüz tablosu için)."""
+    with get_db() as conn:
+        rows = conn.execute(
+            "SELECT display_name, stock, price FROM drugs ORDER BY display_name"
+        ).fetchall()
+        return [dict(r) for r in rows]
+
+
+# ---------------------------------------------------------------------------
+# CRUD — orders
+# ---------------------------------------------------------------------------
+
+def create_order_record(drug_id: int, drug_name: str, quantity: int) -> dict | None:
+    """
+    Sipariş oluşturur. Atomik stok güncellemesi yapar (race condition önlemi).
+    Başarılıysa sipariş dict, değilse None döner.
+    """
+    with get_db() as conn:
+        # Atomik stok azaltma — tek sorguda kontrol + güncelleme
+        cur = conn.execute(
+            "UPDATE drugs SET stock = stock - ? WHERE id = ? AND stock >= ?",
+            (quantity, drug_id, quantity),
+        )
+        if cur.rowcount == 0:
+            return None  # Stok yetersiz veya ilaç bulunamadı
+
+        cur = conn.execute(
+            """INSERT INTO orders (drug_id, drug_name, quantity, status)
+               VALUES (?, ?, ?, 'Hazırlanıyor')""",
+            (drug_id, drug_name, quantity),
+        )
+        order_id = cur.lastrowid
+        return {
+            "order_id": order_id,
+            "drug_name": drug_name,
+            "quantity": quantity,
+            "status": "Hazırlanıyor",
+        }
+
+
+def find_order(order_id: int) -> dict | None:
+    """Sipariş ID'ye göre arama yapar."""
+    with get_db() as conn:
+        row = conn.execute(
+            "SELECT id AS order_id, drug_name, quantity, status, created_at FROM orders WHERE id = ?",
+            (order_id,),
+        ).fetchone()
+        if row:
+            return dict(row)
+    return None

requirements.txt

@@ -0,0 +1,6 @@
+transformers>=4.45.0
+torch>=2.1.0
+gradio>=4.0.0
+requests>=2.31.0
+tavily-python>=0.3.0
+accelerate>=0.25.0

search_provider.py

@@ -0,0 +1,125 @@
+"""
+Eczane Sipariş Asistanı — Harici Arama Sağlayıcı Soyutlaması
+Tavily (varsayılan) veya SerpApi ile web araması yapar.
+Ortam değişkenlerine göre otomatik seçim yapar.
+"""
+
+import os
+import json
+
+
+def _tavily_search(query: str) -> str | None:
+    """Tavily API ile arama yapar. Özetlenmiş sonuç döner."""
+    api_key = os.environ.get("TAVILY_API_KEY")
+    if not api_key:
+        return None
+
+    try:
+        from tavily import TavilyClient
+
+        client = TavilyClient(api_key=api_key)
+        response = client.search(
+            query=query,
+            search_depth="basic",
+            max_results=3,
+            include_answer=True,
+        )
+
+        # Tavily'nin kendi özetini önce dene
+        if response.get("answer"):
+            return response["answer"]
+
+        # Yoksa sonuçlardan birleştir
+        snippets = []
+        for result in response.get("results", [])[:3]:
+            content = result.get("content", "")
+            if content:
+                snippets.append(content[:300])
+
+        if snippets:
+            return " ".join(snippets)[:800]
+
+        return None
+
+    except Exception as e:
+        print(f"[Tavily Arama Hatası] {e}")
+        return None
+
+
+def _serpapi_search(query: str) -> str | None:
+    """SerpApi ile arama yapar (yedek sağlayıcı)."""
+    api_key = os.environ.get("SERPAPI_API_KEY")
+    if not api_key:
+        return None
+
+    try:
+        import requests
+
+        params = {
+            "q": query,
+            "api_key": api_key,
+            "engine": "google",
+            "hl": "tr",
+            "gl": "tr",
+            "num": 3,
+        }
+        resp = requests.get(
+            "https://serpapi.com/search",
+            params=params,
+            timeout=10,
+        )
+        resp.raise_for_status()
+        data = resp.json()
+
+        # Featured snippet veya answer box
+        if "answer_box" in data:
+            ab = data["answer_box"]
+            snippet = ab.get("snippet") or ab.get("answer") or ""
+            if snippet:
+                return snippet[:800]
+
+        # Organik sonuçlar
+        snippets = []
+        for result in data.get("organic_results", [])[:3]:
+            s = result.get("snippet", "")
+            if s:
+                snippets.append(s)
+
+        if snippets:
+            return " ".join(snippets)[:800]
+
+        return None
+
+    except Exception as e:
+        print(f"[SerpApi Arama Hatası] {e}")
+        return None
+
+
+def search_drug_info(drug_name: str) -> str | None:
+    """
+    İlaç bilgisi araması yapar. Önce Tavily, yoksa SerpApi dener.
+    Sonuç bulunamazsa None döner.
+    """
+    query = f"{drug_name} prospektüs kullanma talimatı doz yan etki"
+
+    # Önce Tavily dene
+    result = _tavily_search(query)
+    if result:
+        return result
+
+    # Tavily yoksa SerpApi dene
+    result = _serpapi_search(query)
+    if result:
+        return result
+
+    return None
+
+
+def get_active_provider() -> str:
+    """Aktif arama sağlayıcısını döner (bilgi amaçlı)."""
+    if os.environ.get("TAVILY_API_KEY"):
+        return "Tavily"
+    elif os.environ.get("SERPAPI_API_KEY"):
+        return "SerpApi"
+    else:
+        return "Yok (API anahtarı tanımlı değil)"

seed_db.py

@@ -0,0 +1,151 @@
+"""
+Eczane Sipariş Asistanı — Veritabanı Başlangıç Verileri
+İlk çalıştırmada 10 örnek ilaç ekler (source='seed').
+"""
+
+from db import init_db, insert_drug, find_drug
+
+
+SEED_DRUGS = [
+    {
+        "name": "parol",
+        "display_name": "Parol",
+        "stock": 120,
+        "price": 32.50,
+        "prospektus_summary": (
+            "Parol (Parasetamol 500 mg): Hafif-orta şiddetli ağrı ve ateşte kullanılır. "
+            "Yetişkinler günde en fazla 4 g (8 tablet) alabilir. Karaciğer hastalığı "
+            "olanlarda dikkatli kullanılmalıdır. Yaygın yan etki nadirdir."
+        ),
+    },
+    {
+        "name": "majezik",
+        "display_name": "Majezik",
+        "stock": 85,
+        "price": 48.00,
+        "prospektus_summary": (
+            "Majezik (Flurbiprofen 100 mg): Non-steroid antiinflamatuar ilaçtır. "
+            "Diş ağrısı, kas-iskelet ağrıları ve eklem iltihabında kullanılır. "
+            "Tok karnına alınmalıdır. Mide hassasiyeti olanlarda dikkat edilmelidir."
+        ),
+    },
+    {
+        "name": "augmentin",
+        "display_name": "Augmentin",
+        "stock": 40,
+        "price": 95.00,
+        "prospektus_summary": (
+            "Augmentin (Amoksisilin/Klavulanat): Geniş spektrumlu antibiyotiktir. "
+            "Üst ve alt solunum yolu, idrar yolu, deri enfeksiyonlarında kullanılır. "
+            "Reçetesiz kullanılmamalıdır. Tedavi süresi doktor tarafından belirlenir."
+        ),
+    },
+    {
+        "name": "aferin",
+        "display_name": "Aferin",
+        "stock": 200,
+        "price": 28.00,
+        "prospektus_summary": (
+            "Aferin Fort: Parasetamol, klorfeniramin ve pseudoefedrin içerir. "
+            "Grip ve soğuk algınlığı belirtilerini (ateş, burun akıntısı, tıkanıklık) "
+            "hafifletir. Uyku yapabilir; araç kullanırken dikkatli olunmalıdır."
+        ),
+    },
+    {
+        "name": "ventolin",
+        "display_name": "Ventolin",
+        "stock": 60,
+        "price": 42.50,
+        "prospektus_summary": (
+            "Ventolin (Salbutamol) İnhaler: Bronş genişleticidir. Astım ve KOAH'ta "
+            "nefes darlığı ataklarında kullanılır. Günde en fazla 8 puf önerilir. "
+            "Çarpıntı ve titreme yan etkisi görülebilir."
+        ),
+    },
+    {
+        "name": "nurofen",
+        "display_name": "Nurofen",
+        "stock": 150,
+        "price": 55.00,
+        "prospektus_summary": (
+            "Nurofen (İbuprofen 400 mg): Ağrı kesici ve ateş düşürücüdür. "
+            "Baş ağrısı, diş ağrısı, adet sancısı ve kas ağrılarında kullanılır. "
+            "Tok karnına alınmalıdır. Mide ülseri olanlarda kontrendikedir."
+        ),
+    },
+    {
+        "name": "calpol",
+        "display_name": "Calpol",
+        "stock": 90,
+        "price": 38.00,
+        "prospektus_summary": (
+            "Calpol (Parasetamol 120 mg/5 ml şurup): Çocuklarda ateş ve ağrıda "
+            "kullanılır. Doz çocuğun kilosuna göre ayarlanır. 2 ayın altındaki "
+            "bebeklerde doktor kontrolünde kullanılmalıdır."
+        ),
+    },
+    {
+        "name": "cipro",
+        "display_name": "Cipro",
+        "stock": 30,
+        "price": 72.00,
+        "prospektus_summary": (
+            "Cipro (Siprofloksasin 500 mg): Florokinolon grubu antibiyotiktir. "
+            "İdrar yolu, solunum yolu ve gastrointestinal enfeksiyonlarda kullanılır. "
+            "Tendon rüptürü riski nedeniyle yaşlılarda dikkatli kullanılmalıdır."
+        ),
+    },
+    {
+        "name": "voltaren",
+        "display_name": "Voltaren",
+        "stock": 110,
+        "price": 65.00,
+        "prospektus_summary": (
+            "Voltaren (Diklofenak 75 mg): Non-steroid antiinflamatuar ilaçtır. "
+            "Romatizmal ağrılar, bel ağrısı, travma sonrası şişlik ve ağrıda "
+            "kullanılır. Uzun süreli kullanımda mide koruyucu ile birlikte alınmalıdır."
+        ),
+    },
+    {
+        "name": "a-ferin",
+        "display_name": "A-Ferin",
+        "stock": 75,
+        "price": 35.00,
+        "prospektus_summary": (
+            "A-Ferin Plus: Parasetamol ve kafein kombinasyonudur. Baş ağrısı ve "
+            "grip belirtilerinde kullanılır. Kafein hassasiyeti olanlarda dikkatli "
+            "olunmalıdır. Günde 3-4 tabletten fazla alınmamalıdır."
+        ),
+    },
+]
+
+
+def seed():
+    """Veritabanını oluşturur ve örnek ilaçları ekler (zaten varsa atlar)."""
+    init_db()
+    added = 0
+    skipped = 0
+    for drug in SEED_DRUGS:
+        existing = find_drug(drug["name"])
+        if existing:
+            skipped += 1
+            print(f"  [SKIP] '{drug['display_name']}' zaten mevcut, atlaniyor.")
+            continue
+        insert_drug(
+            name=drug["name"],
+            display_name=drug["display_name"],
+            stock=drug["stock"],
+            price=drug["price"],
+            prospektus_summary=drug["prospektus_summary"],
+            source="seed",
+        )
+        added += 1
+        print(f"  [OK] '{drug['display_name']}' eklendi.")
+
+    print(f"\nToplam: {added} eklendi, {skipped} atlandi.")
+
+
+if __name__ == "__main__":
+    print("Eczane veritabani baslangic verileri yukleniyor...\n")
+    seed()
+    print("\n[OK] Tamamlandi!")

tools.py

@@ -0,0 +1,233 @@
+"""
+Eczane Sipariş Asistanı — Tool Fonksiyonları
+get_drug_info, create_order, check_order_status
+"""
+
+import json
+from db import find_drug, insert_drug, create_order_record, find_order, search_drugs_by_keyword
+from search_provider import search_drug_info
+
+
+# ---------------------------------------------------------------------------
+# Tool tanımları (model'e gösterilecek JSON şeması)
+# ---------------------------------------------------------------------------
+
+TOOL_DEFINITIONS = [
+    {
+        "type": "function",
+        "function": {
+            "name": "get_drug_info",
+            "description": "Bir ilacın veya semptomun/şikayetin (örn. baş ağrısı, ateş) stok durumunu ve prospektüs özetini getirir.",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "drug_name": {"type": "string", "description": "İlacın adı veya şikayet/semptom (örn. Parol, baş ağrısı)"}
+                },
+                "required": ["drug_name"],
+            },
+        },
+    },
+    {
+        "type": "function",
+        "function": {
+            "name": "create_order",
+            "description": "Belirtilen ilaçtan belirtilen adette sipariş oluşturur.",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "drug_name": {"type": "string"},
+                    "quantity": {"type": "integer"},
+                },
+                "required": ["drug_name", "quantity"],
+            },
+        },
+    },
+    {
+        "type": "function",
+        "function": {
+            "name": "check_order_status",
+            "description": "Sipariş numarasına göre sipariş durumunu sorgular.",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "order_id": {"type": "integer"}
+                },
+                "required": ["order_id"],
+            },
+        },
+    },
+]
+
+
+# ---------------------------------------------------------------------------
+# Tool uygulamaları
+# ---------------------------------------------------------------------------
+
+def get_drug_info(drug_name: str) -> dict:
+    """
+    Cache-then-fetch mantığı:
+    1. DB'de birebir veya semptom/kelime araması yapar.
+    2. DB'de varsa → stok/fiyat/prospektüs döner (web'e çıkmaz)
+    3. Yoksa → web araması → DB'ye kaydeder → sonucu döner
+    4. Hiçbir şey bulunamazsa → hata
+    """
+    drug = find_drug(drug_name)
+
+    if drug:
+        return {
+            "drug_name": drug["display_name"],
+            "stock": drug["stock"],
+            "price": drug["price"],
+            "prospektus_summary": drug["prospektus_summary"],
+            "source": "db",
+        }
+
+    # DB'de birebir yoksa semptom / kelime araması yap
+    keyword_matches = search_drugs_by_keyword(drug_name)
+    if keyword_matches:
+        results = [
+            {
+                "drug_name": d["display_name"],
+                "stock": d["stock"],
+                "price": d["price"],
+                "prospektus_summary": d["prospektus_summary"],
+            }
+            for d in keyword_matches
+        ]
+        return {
+            "search_query": drug_name,
+            "matching_drugs": results,
+            "source": "db_keyword_search",
+            "note": f"Veritabanında '{drug_name}' ile ilgili {len(results)} ilaç bulundu."
+        }
+
+    # DB'de hiç yok → web araması
+    raw_result = search_drug_info(drug_name)
+
+    if raw_result:
+        # Özetleme kuralı: ham metin doğrudan kopyalanmaz, kısaltılır
+        summary_text = raw_result[:500].strip()
+        if len(raw_result) > 500:
+            # Son cümle sınırında kes
+            last_dot = summary_text.rfind(".")
+            if last_dot > 100:
+                summary_text = summary_text[: last_dot + 1]
+
+        disclaimer = "Bu bilgi web aramasından derlenmiş bir özettir, resmi prospektüs yerine geçmez."
+        full_summary = f"{disclaimer}\n\n{summary_text}"
+
+        # DB'ye kaydet
+        display_name = drug_name.strip().title()
+        drug_id = insert_drug(
+            name=drug_name,
+            display_name=display_name,
+            stock=0,
+            price=None,
+            prospektus_summary=full_summary,
+            source="fetched",
+        )
+
+        return {
+            "drug_name": display_name,
+            "stock": 0,
+            "price": None,
+            "prospektus_summary": full_summary,
+            "source": "fetched_new",
+            "note": "Bu ilaç veritabanına yeni eklendi, stok bilgisi güncel değildir.",
+        }
+
+    # API de sonuç döndürmedi
+    return {"error": f"'{drug_name}' ile ilgili ilaç bulunamadı. Lütfen kontrol edin."}
+
+
+def create_order(drug_name: str, quantity: int | None = None) -> dict:
+    """
+    Sipariş oluşturur. Stok kontrolü yapar.
+    """
+    if quantity is None:
+        return {"error": "Sipariş miktarı belirtilmedi. Lütfen kaç adet sipariş etmek istediğinizi yazın."}
+
+    try:
+        quantity = int(quantity)
+    except (ValueError, TypeError):
+        return {"error": "Geçersiz sipariş miktarı. Lütfen geçerli bir sayı girin."}
+
+    if quantity <= 0:
+        return {"error": "Sipariş miktarı 0'dan büyük olmalıdır."}
+
+    drug = find_drug(drug_name)
+
+    if not drug:
+        return {
+            "error": (
+                f"'{drug_name}' veritabanında kayıtlı değil. "
+                "Önce get_drug_info ile ilacı sorgulayın."
+            )
+        }
+
+    if drug["stock"] < quantity:
+        return {
+            "error": (
+                f"Yetersiz stok. '{drug['display_name']}' için mevcut stok: "
+                f"{drug['stock']}, istenen: {quantity}."
+            )
+        }
+
+    result = create_order_record(
+        drug_id=drug["id"],
+        drug_name=drug["display_name"],
+        quantity=quantity,
+    )
+
+    if result is None:
+        return {"error": "Sipariş oluşturulamadı (stok yetersiz olabilir)."}
+
+    return result
+
+
+def check_order_status(order_id: int | None = None) -> dict:
+    """
+    Sipariş durumunu sorgular.
+    """
+    if order_id is None:
+        return {"error": "Sipariş numarası belirtilmedi."}
+
+    try:
+        order_id = int(order_id)
+    except (ValueError, TypeError):
+        return {"error": "Geçersiz sipariş numarası."}
+
+    order = find_order(order_id)
+
+    if not order:
+        return {"error": f"{order_id} numaralı sipariş bulunamadı."}
+
+    return order
+
+
+# ---------------------------------------------------------------------------
+# Tool Router
+# ---------------------------------------------------------------------------
+
+TOOL_MAP = {
+    "get_drug_info": get_drug_info,
+    "create_order": create_order,
+    "check_order_status": check_order_status,
+}
+
+
+def route_tool_call(tool_name: str, arguments: dict) -> dict:
+    """
+    Tool adına göre ilgili fonksiyonu çağırır.
+    Tanınmayan tool isimlerinde hata döner.
+    """
+    func = TOOL_MAP.get(tool_name)
+    if func is None:
+        return {"error": f"Tanınmayan araç: '{tool_name}'"}
+
+    try:
+        return func(**arguments)
+    except TypeError as e:
+        return {"error": f"Araç argüman hatası: {e}"}
+    except Exception as e:
+        return {"error": f"Araç çalıştırma hatası: {e}"}