Stevia Store MCP Server

#!/usr/bin/env python3.11 """ Secure Stevia Store MCP Server with Database & Security A production-ready e-commerce MCP server for Organital's stevia products Includes SQLite database, password hashing, encryption, and security features """ import asyncio import argparse import sqlite3 import hashlib import secrets import bcrypt import json import os from datetime import datetime, timedelta from typing import Dict, List, Optional, Tuple from cryptography.fernet import Fernet from mcp.server.fastmcp import FastMCP # Initialize the MCP server mcp = FastMCP("🔐 Secure Stevia Store") # Database configuration DATABASE_PATH = "stevia_store.db" ENCRYPTION_KEY_FILE = "encryption.key" # Load or generate encryption key def get_encryption_key(): if os.path.exists(ENCRYPTION_KEY_FILE): with open(ENCRYPTION_KEY_FILE, 'rb') as f: return f.read() else: key = Fernet.generate_key() with open(ENCRYPTION_KEY_FILE, 'wb') as f: f.write(key) return key # Initialize encryption ENCRYPTION_KEY = get_encryption_key() cipher_suite = Fernet(ENCRYPTION_KEY) # In-memory session management active_sessions = {} shopping_carts = {} # session_id -> cart def encrypt_data(data: str) -> str: """Encrypt sensitive data""" return cipher_suite.encrypt(data.encode()).decode() def decrypt_data(encrypted_data: str) -> str: """Decrypt sensitive data""" return cipher_suite.decrypt(encrypted_data.encode()).decode() def hash_password(password: str) -> str: """Hash password using bcrypt""" return bcrypt.hashpw(password.encode('utf-8'), bcrypt.gensalt()).decode('utf-8') def verify_password(password: str, hashed: str) -> bool: """Verify password against hash""" return bcrypt.checkpw(password.encode('utf-8'), hashed.encode('utf-8')) def generate_session_token() -> str: """Generate secure session token""" return secrets.token_urlsafe(32) def init_database(): """Initialize SQLite database with all required tables""" conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Enable foreign keys cursor.execute("PRAGMA foreign_keys = ON") # Users table cursor.execute(""" CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, email TEXT UNIQUE NOT NULL, password_hash TEXT NOT NULL, full_name TEXT NOT NULL, phone TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, last_login TIMESTAMP, is_active BOOLEAN DEFAULT 1 ) """) # Products table cursor.execute(""" CREATE TABLE IF NOT EXISTS products ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, category TEXT NOT NULL, price REAL NOT NULL, description TEXT, weight TEXT, origin TEXT, kosher BOOLEAN DEFAULT 0, organic BOOLEAN DEFAULT 0, rating REAL DEFAULT 0, reviews INTEGER DEFAULT 0, stock_quantity INTEGER DEFAULT 0, sku TEXT UNIQUE, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) """) # Customers table (for guest checkouts) cursor.execute(""" CREATE TABLE IF NOT EXISTS customers ( id INTEGER PRIMARY KEY AUTOINCREMENT, email TEXT NOT NULL, full_name TEXT NOT NULL, phone TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) """) # Addresses table cursor.execute(""" CREATE TABLE IF NOT EXISTS addresses ( id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER, customer_id INTEGER, address_line TEXT NOT NULL, city TEXT, postal_code TEXT, is_default BOOLEAN DEFAULT 0, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (user_id) REFERENCES users(id), FOREIGN KEY (customer_id) REFERENCES customers(id) ) """) # Orders table cursor.execute(""" CREATE TABLE IF NOT EXISTS orders ( id INTEGER PRIMARY KEY AUTOINCREMENT, tracking_number TEXT UNIQUE NOT NULL, user_id INTEGER, customer_id INTEGER, customer_name TEXT NOT NULL, customer_email TEXT NOT NULL, customer_phone TEXT, shipping_address TEXT NOT NULL, notes TEXT, subtotal REAL NOT NULL, discount_amount REAL DEFAULT 0, applied_discount TEXT, shipping_cost REAL DEFAULT 0, total_amount REAL NOT NULL, status TEXT DEFAULT 'pending', order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP, estimated_delivery TIMESTAMP, FOREIGN KEY (user_id) REFERENCES users(id), FOREIGN KEY (customer_id) REFERENCES customers(id) ) """) # Order items table cursor.execute(""" CREATE TABLE IF NOT EXISTS order_items ( id INTEGER PRIMARY KEY AUTOINCREMENT, order_id INTEGER NOT NULL, product_id INTEGER NOT NULL, product_name TEXT NOT NULL, price REAL NOT NULL, quantity INTEGER NOT NULL, total_price REAL NOT NULL, FOREIGN KEY (order_id) REFERENCES orders(id), FOREIGN KEY (product_id) REFERENCES products(id) ) """) # Sessions table cursor.execute(""" CREATE TABLE IF NOT EXISTS sessions ( id INTEGER PRIMARY KEY AUTOINCREMENT, session_token TEXT UNIQUE NOT NULL, user_id INTEGER, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, expires_at TIMESTAMP NOT NULL, is_active BOOLEAN DEFAULT 1, FOREIGN KEY (user_id) REFERENCES users(id) ) """) # FAQ categories table cursor.execute(""" CREATE TABLE IF NOT EXISTS faq_categories ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, description TEXT, display_order INTEGER DEFAULT 0 ) """) # FAQ items table cursor.execute(""" CREATE TABLE IF NOT EXISTS faq_items ( id INTEGER PRIMARY KEY AUTOINCREMENT, category_id INTEGER NOT NULL, question TEXT NOT NULL, answer TEXT NOT NULL, keywords TEXT, views INTEGER DEFAULT 0, helpful_votes INTEGER DEFAULT 0, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (category_id) REFERENCES faq_categories(id) ) """) # Support tickets table cursor.execute(""" CREATE TABLE IF NOT EXISTS support_tickets ( id INTEGER PRIMARY KEY AUTOINCREMENT, ticket_number TEXT UNIQUE NOT NULL, user_id INTEGER, customer_email TEXT NOT NULL, customer_name TEXT NOT NULL, subject TEXT NOT NULL, message TEXT NOT NULL, category TEXT, priority TEXT DEFAULT 'medium', status TEXT DEFAULT 'open', created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, resolved_at TIMESTAMP, FOREIGN KEY (user_id) REFERENCES users(id) ) """) # Support responses table cursor.execute(""" CREATE TABLE IF NOT EXISTS support_responses ( id INTEGER PRIMARY KEY AUTOINCREMENT, ticket_id INTEGER NOT NULL, responder_name TEXT DEFAULT 'מערכת התמיכה', message TEXT NOT NULL, is_internal BOOLEAN DEFAULT 0, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (ticket_id) REFERENCES support_tickets(id) ) """) # Insert sample products cursor.execute("SELECT COUNT(*) FROM products") if cursor.fetchone()[0] == 0: sample_products = [ ("סטיביה טבעית אורגנית 100 גרם", "חמרי גלם", 45.90, "סטיביה טבעית 100% אורגנית ללא תוספות כימיות, מקור ישיר מחקלאים בפרגוואי", "100 גרם", "פרגוואי", 1, 1, 4.8, 127, 150, "STV-ORG-100"), ("סטיביה בטבליות - 60 יחידות", "מוצרים מוכנים", 29.90, "טבליות סטיביה נוחות לשימוש בקפה ותה, ללא קלוריות ומתאימות לסוכרתיים", "60 טבליות", "ישראל", 1, 0, 4.5, 89, 200, "STV-TAB-60"), ("סטיביה נוזלית בטעם ונילה - 50ml", "מוצרים מוכנים", 39.90, "תמצית סטיביה נוזלית עם טעם ונילה טבעי, אידיאלית למשקאים ומתכונים", "50ml", "ישראל", 1, 1, 4.6, 156, 100, "STV-LIQ-VAN"), ("אבקת סטיביה לאפיה - 200 גרם", "בישול ואפיה", 55.90, "אבקת סטיביה מיוחדת לאפיה ובישול, עמידה בחום גבוה ומתאימה לכל המתכונים", "200 גרם", "פרגוואי", 1, 1, 4.7, 203, 80, "STV-BAK-200"), ("מארז טעימה - 4 סוגים", "מארזים", 89.90, "מארז טעימה הכולל 4 סוגי סטיביה שונים - אידיאלי למי שרוצה לנסות לראשונה", "4 יחידות", "ישראל", 1, 1, 4.9, 95, 50, "STV-PACK-4"), ("סטיביה פרימיום אורגנית - 50 גרם", "פרימיום", 79.90, "סטיביה פרימיום מעלי הסטיביה הטובים ביותר, עובר בדיקות איכות מחמירות", "50 גרם", "ברזיל", 1, 1, 4.9, 67, 30, "STV-PREM-50"), ("סטיביה נוזלית טבעית - 30ml", "מוצרים מוכנים", 34.90, "תמצית סטיביה נוזלית טבעית ללא תוספות, טעם נקי ומתוק מאוד", "30ml", "ישראל", 1, 1, 4.4, 134, 120, "STV-LIQ-NAT"), ("סטיביה לשתייה קרה - 100 טבליות", "מוצרים מוכנים", 49.90, "טבליות סטיביה מיוחדות שמתמוססות מהר במשקאים קרים, אידיאליות לקיץ", "100 טבליות", "ישראל", 1, 0, 4.3, 78, 90, "STV-COLD-100") ] cursor.executemany(""" INSERT INTO products (name, category, price, description, weight, origin, kosher, organic, rating, reviews, stock_quantity, sku) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) """, sample_products) # Insert FAQ categories cursor.execute("SELECT COUNT(*) FROM faq_categories") if cursor.fetchone()[0] == 0: faq_categories = [ ("על סטיביה", "מידע כללי על הצמח ויתרונותיו", 1), ("שימוש ומתכונים", "איך להשתמש בסטיביה ומתכונים", 2), ("הזמנות ומשלוחים", "מידע על תהליך ההזמנה והמשלוח", 3), ("תשלומים", "אמצעי תשלום והחזרות", 4), ("בעיות טכניות", "בעיות באתר ובמערכת", 5), ("מוצרים", "שאלות על המוצרים והמלאי", 6) ] cursor.executemany(""" INSERT INTO faq_categories (name, description, display_order) VALUES (?, ?, ?) """, faq_categories) # Insert FAQ items cursor.execute("SELECT COUNT(*) FROM faq_items") if cursor.fetchone()[0] == 0: faq_items = [ # על סטיביה (1, "מה זה סטיביה?", "סטיביה היא צמח טבעי ממשפחת החרצית המגדל בדרום אמריקה. העלים שלו מכילים חומרים ממתיקים טבעיים שהם מתוקים פי 200-300 מהסוכר אך ללא קלוריות.", "סטיביה, צמח, טבעי, ממתיק"), (1, "האם סטיביה בטוחה?", "כן! סטיביה מוכרת כבטוחה על ידי ה-FDA, הרשות האירופית למזון ומשרד הבריאות בישראל. היא משמשת מאות שנים בדרום אמריקה.", "בטיחות, FDA, אישור, מאושר"), (1, "איך סטיביה משפיעה על רמת הסוכר?", "סטיביה לא מעלה את רמת הסוכר בדם ואף עשויה לעזור בוויסות רמות הסוכר. מתאימה לחולי סוכרת.", "סוכרת, רמת סוכר, בריאות"), (1, "האם יש לסטיביה טעם לוואי?", "סטיביה איכותית כמו שלנו כמעט ולא משאירה טעם לוואי. חשוב לקנות מוצרים איכותיים ולהשתמש במינונים נכונים.", "טעם לוואי, איכות, מינון"), # שימוש ומתכונים (2, "איך משתמשים בסטיביה?", "תלוי בסוג: אבקה - כפית קטנה במקום כף סוכר, טבליות - אחת למשקה, נוזלי - 3-5 טיפות למשקה. התחילו ממעט והוסיפו לפי הטעם.", "שימוש, מינון, אבקה, טבליות, נוזלי"), (2, "האם אפשר לאפות עם סטיביה?", "בהחלט! השתמשו באבקת הסטיביה המיוחדת לאפיה שלנו. היא עמידה בחום ומתאימה לכל סוגי המתכונים.", "אפיה, בישול, מתכונים, חום"), (2, "איך מחליפים סוכר בסטיביה?", "בדרך כלל: כוס סוכר = כף של אבקת סטיביה. במשקאות: כף סוכר = כפית סטיביה. המארז שלנו כולל מדריך המרות מפורט.", "המרה, סוכר, יחס, מינון"), (2, "האם אפשר לתת לילדים?", "כן! סטיביה בטוחה לילדים ובעצם עדיפה על סוכר מבחינה בריאותית. היא לא גורמת לעששת ולא משפיעה על ההתנהגות.", "ילדים, בטיחות, עששת"), # הזמנות ומשלוחים (3, "כמה זמן לוקח המשלוח?", "המשלוח לוקח 2-5 ימי עסקים לכל הארץ. אזור המרכז - עד 2 ימים, הצפון והדרום - עד 5 ימים.", "משלוח, זמן, ימי עסקים"), (3, "מה עולה המשלוח?", "המשלוח עולה 25 ש\"ח, אבל זה חינם על הזמנות מעל 150 ש\"ח!", "עלות משלוח, משלוח חינם"), (3, "איך אני יכול לעקוב אחר ההזמנה?", "תקבל מספר מעקב לאחר הרכישה. השתמש בפונקציה track_order עם המספר שקיבלת.", "מעקב, מספר מעקב, סטטוס"), (3, "האם אפשר לשנות כתובת משלוח?", "ניתן לשנות כתובת רק עד שהמוצר נשלח. צור קשר עמנו בטלפון 03-1234567 או פתח כרטיס תמיכה.", "שינוי כתובת, עדכון"), # תשלומים (4, "איך אפשר לשלם?", "אנחנו מקבלים כרטיסי אשראי (ויזה, מאסטרקארד), ביט, פייבוקס והעברה בנקאית.", "תשלום, כרטיס אשראי, ביט"), (4, "האם אפשר להחזיר מוצרים?", "כן! החזרה תוך 14 ימים ללא שאלות. המוצר צריך להיות באריזה מקורית.", "החזרה, החזר כספי"), (4, "מתי יחויב כרטיס האשראי?", "כרטיס האשראי יחויב רק לאחר שהמוצר נארז ונשלח. לא נחייב מראש.", "חיוב, כרטיס אשראי, מתי"), # בעיות טכניות (5, "האתר לא עובד טוב", "נסה לרענן את העמוד או לנקות cookies. אם הבעיה נמשכת, צור קשר עמנו עם פרטי הבעיה.", "בעיות טכניות, אתר"), (5, "לא מצליח להתחבר למערכת", "בדוק שהאימייל והסיסמה נכונים. אם שכחת סיסמה, השתמש באפשרות איפוס סיסמה.", "התחברות, סיסמה, אימייל"), # מוצרים (6, "איזה מוצר הכי מומלץ למתחילים?", "מארז הטעימה הוא הכי מתאים למתחילים - תוכל לנסות 4 סוגים שונים ולראות מה הכי מתאים לך.", "מתחילים, מארז טעימה, המלצה"), (6, "מתי המוצרים יחזרו למלאי?", "אנחנו מעדכנים מלאי באופן קבוע. אם מוצר אזל, בדרך כלל הוא חוזר תוך 3-7 ימים.", "מלאי, אזל, חזרה") ] cursor.executemany(""" INSERT INTO faq_items (category_id, question, answer, keywords) VALUES (?, ?, ?, ?) """, faq_items) conn.commit() conn.close() # Discount codes PROMOTIONS = { "WELCOME10": { "name": "ברוכים הבאים", "description": "הנחה 10% ללקוחות חדשים", "discount_percent": 10, "min_amount": 50 }, "ORGANIC15": { "name": "אורגני 15%", "description": "הנחה 15% על מוצרים אורגניים", "discount_percent": 15, "min_amount": 100 }, "BULK20": { "name": "קנייה בכמות", "description": "הנחה 20% על הזמנות מעל 300 ש\"ח", "discount_percent": 20, "min_amount": 300 } } def sanitize_input(text: str) -> str: """Sanitize user input to prevent injection attacks""" if not isinstance(text, str): return "" # Remove potentially dangerous characters dangerous_chars = ['<', '>', '"', "'", '&', ';', '(', ')', '|', '`'] for char in dangerous_chars: text = text.replace(char, '') return text.strip() def validate_email(email: str) -> bool: """Basic email validation""" import re pattern = r'^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$' return re.match(pattern, email) is not None def validate_phone(phone: str) -> bool: """Basic Israeli phone validation""" import re # Israeli phone patterns: 05X-XXXXXXX or 03-XXXXXXX etc. pattern = r'^0\d{1,2}-?\d{7,8}$' return re.match(pattern, phone.replace('-', '').replace(' ', '')) is not None @mcp.tool() def register_user(email: str, password: str, full_name: str, phone: str = "") -> str: """ 🔐 רישום משתמש חדש במערכת Args: email: כתובת אימייל (חובה) password: סיסמה (מינימום 8 תווים) full_name: שם מלא phone: מספר טלפון (אופציונלי) Returns: אישור הרישום ומידע על המשתמש """ # Input validation email = sanitize_input(email).lower() password = sanitize_input(password) full_name = sanitize_input(full_name) phone = sanitize_input(phone) if not validate_email(email): return "❌ כתובת אימייל לא תקינה" if len(password) < 8: return "❌ הסיסמה חייבת להיות באורך של לפחות 8 תווים" if len(full_name) < 2: return "❌ שם מלא חייב להכיל לפחות 2 תווים" if phone and not validate_phone(phone): return "❌ מספר טלפון לא תקין (פורמט ישראלי נדרש)" try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Check if user already exists cursor.execute("SELECT id FROM users WHERE email = ?", (email,)) if cursor.fetchone(): conn.close() return "❌ משתמש עם אימייל זה כבר קיים במערכת" # Hash password password_hash = hash_password(password) # Insert new user cursor.execute(""" INSERT INTO users (email, password_hash, full_name, phone) VALUES (?, ?, ?, ?) """, (email, password_hash, full_name, phone)) user_id = cursor.lastrowid conn.commit() conn.close() return f"""✅ **רישום מוצלח!** 👤 **פרטי המשתמש:** 📧 אימייל: {email} 👨‍💼 שם: {full_name} {'📱 טלפון: ' + phone if phone else ''} 🔐 **הצלחת להירשם לחנות הסטיביה של אורגניטל!** **השלבים הבאים:** 1. השתמש ב-login כדי להתחבר 2. עיין במוצרים עם browse_products 3. הוסף מוצרים לעגלה והזמן! 🎁 **בונוס:** קוד הנחה WELCOME10 עבור הזמנה ראשונה!""" except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בהרשמה: {str(e)}" @mcp.tool() def login_user(email: str, password: str) -> str: """ 🔑 התחברות למערכת Args: email: כתובת אימייל password: סיסמה Returns: אישור התחברות וטוקן Session """ email = sanitize_input(email).lower() password = sanitize_input(password) if not validate_email(email): return "❌ כתובת אימייל לא תקינה" try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Get user cursor.execute(""" SELECT id, password_hash, full_name, is_active FROM users WHERE email = ? """, (email,)) user = cursor.fetchone() if not user: conn.close() return "❌ אימייל או סיסמה שגויים" user_id, stored_hash, full_name, is_active = user if not is_active: conn.close() return "❌ חשבון המשתמש מושבת. פנה לתמיכה" # Verify password if not verify_password(password, stored_hash): conn.close() return "❌ אימייל או סיסמה שגויים" # Generate session token session_token = generate_session_token() expires_at = datetime.now() + timedelta(days=7) # 7 days session # Store session in database cursor.execute(""" INSERT INTO sessions (session_token, user_id, expires_at) VALUES (?, ?, ?) """, (session_token, user_id, expires_at)) # Update last login cursor.execute(""" UPDATE users SET last_login = CURRENT_TIMESTAMP WHERE id = ? """, (user_id,)) conn.commit() conn.close() # Store in memory for quick access active_sessions[session_token] = { "user_id": user_id, "email": email, "full_name": full_name, "expires_at": expires_at } # Initialize cart for user shopping_carts[session_token] = {} return f"""✅ **התחברות מוצלחת!** 👋 ברוך הבא, {full_name}! 🔐 **Session Token:** `{session_token}` ⏰ **תפוגה:** {expires_at.strftime('%d/%m/%Y %H:%M')} **להמשך קנייה:** • `browse_products` - עיון במוצרים • `search_products [מילה]` - חיפוש • `view_profile` - צפייה בפרופיל • `view_cart` - עגלת קניות 🛒 **טיפ:** כל הפעולות שלך כעת ישמרו במסד הנתונים!""" except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בהתחברות: {str(e)}" def get_user_from_session(session_token: str) -> Optional[Dict]: """Get user info from session token""" if not session_token or session_token not in active_sessions: return None session = active_sessions[session_token] if datetime.now() > session["expires_at"]: # Session expired del active_sessions[session_token] if session_token in shopping_carts: del shopping_carts[session_token] return None return session @mcp.tool() def browse_products(category: str = "", session_token: str = "") -> str: """ 🛍️ עיון בקטלוג מוצרי הסטיביה המאובטח Args: category: סינון לפי קטגוריה (אופציונלי) session_token: טוקן התחברות (אופציונלי) Returns: רשימת המוצרים הזמינים עם פרטים מלאים """ try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Build query if category: category = sanitize_input(category) cursor.execute(""" SELECT id, name, category, price, description, weight, origin, kosher, organic, rating, reviews, stock_quantity FROM products WHERE category = ? AND stock_quantity > 0 ORDER BY name """, (category,)) else: cursor.execute(""" SELECT id, name, category, price, description, weight, origin, kosher, organic, rating, reviews, stock_quantity FROM products WHERE stock_quantity > 0 ORDER BY category, price """) products = cursor.fetchall() conn.close() if not products: return f"📦 לא נמצאו מוצרים {'בקטגוריה ' + category if category else 'זמינים'}" # Check if user is logged in user_session = get_user_from_session(session_token) if session_token else None user_greeting = f"שלום {user_session['full_name']}! " if user_session else "" result = f"🌿 **{user_greeting}ברוכים הבאים לחנות הסטיביה המאובטחת של אורגניטל!**\n\n" if category: result += f"📂 **קטגוריה: {category}**\n\n" else: result += "🛒 **כל המוצרים שלנו:**\n\n" current_category = "" for product in products: (prod_id, name, cat, price, desc, weight, origin, kosher, organic, rating, reviews, stock) = product if cat != current_category: current_category = cat result += f"\n🏷️ **{current_category}:**\n{'='*50}\n" # Stock indicator if stock > 20: stock_indicator = "✅ במלאי רב" elif stock > 5: stock_indicator = f"🟡 נותרו {stock} יחידות" else: stock_indicator = f"🔴 נותרו רק {stock} יחידות!" # Product details result += f"**#{prod_id} - {name}**\n" result += f"💰 **מחיר: ₪{price:.2f}** | {stock_indicator}\n" result += f"📏 משקל: {weight} | 🌍 מקור: {origin}\n" # Certifications certifications = [] if kosher: certifications.append("✡️ כשר") if organic: certifications.append("🌱 אורגני") if certifications: result += f"🏆 {' | '.join(certifications)}\n" # Rating stars = "⭐" * int(rating) result += f"⭐ {rating}/5 ({reviews} ביקורות) {stars}\n" result += f"📝 {desc}\n" if user_session: result += f"🛒 *להוספה לעגלה: add_to_cart עם ID #{prod_id} וה-session_token שלך*\n" else: result += f"🔐 *להוספה לעגלה: התחבר קודם עם login_user*\n" result += f"🔍 *לפרטים מלאים: get_product_details עם ID #{prod_id}*\n\n" result += "\n" + "="*60 + "\n" result += "🔐 **מערכת מאובטחת** - כל הנתונים מוצפנים ושמורים במסד נתונים\n" result += "🎁 **הצעות מיוחדות:**\n" result += "• 🚚 משלוח חינם מעל ₪150\n" result += "• 💝 הנחה 10% ללקוחות חדשים (קוד: WELCOME10)\n" result += "• 📞 ייעוץ חינם: 03-1234567\n" result += "• 🔄 החזרה תוך 14 ימים" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בטעינת מוצרים: {str(e)}" @mcp.tool() def add_to_cart(product_id: int, quantity: int = 1, session_token: str = "") -> str: """ 🛒 הוספת מוצר לעגלת קניות מאובטחת Args: product_id: מזהה המוצר quantity: כמות (ברירת מחדל: 1) session_token: טוקן התחברות (חובה) Returns: אישור הוספה ומצב העגלה """ # Validate session user_session = get_user_from_session(session_token) if not user_session: return "🔐 נדרשת התחברות למערכת. השתמש ב-login_user תחילה" if quantity <= 0: return "❌ כמות חייבת להיות חיובית" try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Get product details cursor.execute(""" SELECT id, name, price, stock_quantity FROM products WHERE id = ? AND stock_quantity > 0 """, (product_id,)) product = cursor.fetchone() conn.close() if not product: return f"❌ לא נמצא מוצר זמין עם מזהה #{product_id}" prod_id, name, price, stock = product if quantity > stock: return f"⚠️ במלאי רק {stock} יחידות מהמוצר '{name}'" # Initialize cart if needed if session_token not in shopping_carts: shopping_carts[session_token] = {} cart = shopping_carts[session_token] # Add or update product in cart if str(product_id) in cart: total_quantity = cart[str(product_id)]['quantity'] + quantity if total_quantity > stock: return f"⚠️ לא ניתן להוסיף {quantity} יחידות נוספות. במלאי {stock} יחידות ובעגלה כבר {cart[str(product_id)]['quantity']}" cart[str(product_id)]['quantity'] = total_quantity cart[str(product_id)]['total_price'] = total_quantity * price else: cart[str(product_id)] = { 'name': name, 'price': price, 'quantity': quantity, 'total_price': quantity * price } # Calculate cart summary total_items = sum(item['quantity'] for item in cart.values()) total_price = sum(item['total_price'] for item in cart.values()) shipping_cost = 0 if total_price >= 150 else 25 final_total = total_price + shipping_cost result = f"✅ **המוצר נוסף לעגלה המאובטחת!**\n\n" result += f"👤 משתמש: {user_session['full_name']}\n" result += f"🛒 **{name}**\n" result += f"📦 כמות: {quantity} יחידות\n" result += f"💰 מחיר: ₪{(quantity * price):.2f}\n\n" result += "🛍️ **סיכום העגלה:**\n" result += f"📊 סה\"כ פריטים: {total_items}\n" result += f"💵 סה\"כ מוצרים: ₪{total_price:.2f}\n" if shipping_cost > 0: result += f"🚚 משלוח: ₪{shipping_cost:.2f}\n" result += f"💡 הוסף ₪{(150 - total_price):.2f} למשלוח חינם!\n" else: result += "🎉 משלוח חינם!\n" result += f"💳 **סה\"כ לתשלום: ₪{final_total:.2f}**\n\n" result += f"🔐 העגלה שמורה בבטחה במסד הנתונים\n" result += "🔍 לצפייה בעגלה: view_cart עם session_token" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בהוספה לעגלה: {str(e)}" @mcp.tool() def secure_checkout(customer_name: str, customer_email: str, customer_phone: str, shipping_address: str, session_token: str, notes: str = "", discount_code: str = "") -> str: """ 💳 ביצוע הזמנה מאובטחת עם שמירה במסד נתונים Args: customer_name: שם מלא customer_email: כתובת אימייל customer_phone: מספר טלפון shipping_address: כתובת מלאה למשלוח session_token: טוקן התחברות (חובה) notes: הערות מיוחדות (אופציונלי) discount_code: קוד הנחה (אופציונלי) Returns: פרטי ההזמנה המלאים ומספר מעקב מאובטח """ # Validate session user_session = get_user_from_session(session_token) if not user_session: return "🔐 נדרשת התחברות למערכת. השתמש ב-login_user תחילה" # Validate cart if session_token not in shopping_carts or not shopping_carts[session_token]: return "🛒 העגלה ריקה. הוסף מוצרים לעגלה תחילה" # Sanitize inputs customer_name = sanitize_input(customer_name) customer_email = sanitize_input(customer_email).lower() customer_phone = sanitize_input(customer_phone) shipping_address = sanitize_input(shipping_address) notes = sanitize_input(notes) discount_code = sanitize_input(discount_code).upper() # Validate inputs if not customer_name or len(customer_name) < 2: return "❌ שם לקוח חייב להכיל לפחות 2 תווים" if not validate_email(customer_email): return "❌ כתובת אימייל לא תקינה" if not validate_phone(customer_phone): return "❌ מספר טלפון לא תקין (פורמט ישראלי נדרש)" if not shipping_address or len(shipping_address) < 10: return "❌ כתובת משלוח חייבת להכיל לפחות 10 תווים" try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() cart = shopping_carts[session_token] # Calculate totals subtotal = sum(item['total_price'] for item in cart.values()) discount_amount = 0 applied_discount = "" # Apply discount if valid if discount_code and discount_code in PROMOTIONS: promo = PROMOTIONS[discount_code] if subtotal >= promo["min_amount"]: discount_amount = subtotal * (promo["discount_percent"] / 100) applied_discount = f"{promo['name']} ({promo['discount_percent']}%)" total_after_discount = subtotal - discount_amount shipping_cost = 0 if total_after_discount >= 150 else 25 final_total = total_after_discount + shipping_cost # Generate secure tracking number tracking_number = f"ORG{datetime.now().strftime('%Y%m%d')}{secrets.randbelow(9999):04d}" # Insert customer if doesn't exist cursor.execute(""" INSERT OR IGNORE INTO customers (email, full_name, phone) VALUES (?, ?, ?) """, (customer_email, customer_name, customer_phone)) cursor.execute("SELECT id FROM customers WHERE email = ?", (customer_email,)) customer_id = cursor.fetchone()[0] # Create order cursor.execute(""" INSERT INTO orders ( tracking_number, user_id, customer_id, customer_name, customer_email, customer_phone, shipping_address, notes, subtotal, discount_amount, applied_discount, shipping_cost, total_amount, status, estimated_delivery ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) """, ( tracking_number, user_session['user_id'], customer_id, customer_name, customer_email, customer_phone, encrypt_data(shipping_address), notes, subtotal, discount_amount, applied_discount, shipping_cost, final_total, "מעובד", datetime.now() + timedelta(days=3) )) order_id = cursor.lastrowid # Insert order items for product_id, item in cart.items(): cursor.execute(""" INSERT INTO order_items ( order_id, product_id, product_name, price, quantity, total_price ) VALUES (?, ?, ?, ?, ?, ?) """, (order_id, int(product_id), item['name'], item['price'], item['quantity'], item['total_price'])) conn.commit() conn.close() # Clear cart after successful order shopping_carts[session_token] = {} # Format order confirmation result = f"🎉 **הזמנה בוצעה בהצלחה!**\n\n" result += f"📋 **מספר הזמנה:** #{order_id}\n" result += f"📦 **מספר מעקב מאובטח:** {tracking_number}\n" result += f"👤 **לקוח:** {customer_name}\n" result += f"📧 **אימייל:** {customer_email}\n" result += f"📱 **טלפון:** {customer_phone}\n" result += f"🏠 **כתובת משלוח:** {shipping_address}\n" if notes: result += f"📝 **הערות:** {notes}\n" result += f"\n💰 **פירוט עלויות:**\n" result += f"💵 סה\"כ מוצרים: ₪{subtotal:.2f}\n" if discount_amount > 0: result += f"🎫 הנחה ({applied_discount}): -₪{discount_amount:.2f}\n" if shipping_cost > 0: result += f"🚚 משלוח: ₪{shipping_cost:.2f}\n" else: result += f"🚚 משלוח: חינם! 🎉\n" result += f"💳 **סה\"כ לתשלום: ₪{final_total:.2f}**\n\n" result += f"📦 **פרטי משלוח:**\n" result += f"⏰ זמן עיבוד: 1-2 ימי עסקים\n" result += f"🚚 זמן משלוח: 2-5 ימי עסקים\n" result += f"📅 משלוח משוער: {(datetime.now() + timedelta(days=3)).strftime('%d/%m/%Y')}\n\n" result += f"🔐 **אבטחה:**\n" result += f"• ההזמנה שמורה בבטחה במסד נתונים מוצפן\n" result += f"• פרטי הכתובת מוצפנים\n" result += f"• מספר מעקב ייחודי ומאובטח\n\n" result += f"📞 **יצירת קשר:**\n" result += f"• טלפון: 03-1234567\n" result += f"• אימייל: support@organital.co.il\n" result += f"• מעקב הזמנה: track_order עם מספר {tracking_number}" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בביצוע הזמנה: {str(e)}" @mcp.tool() def track_order(tracking_number: str, session_token: str = "") -> str: """ 📦 מעקב אחר הזמנה במערכת המאובטחת Args: tracking_number: מספר מעקב session_token: טוקן התחברות (אופציונלי - להזמנות של המשתמש) Returns: סטטוס ההזמנה ופרטי משלוח """ tracking_number = sanitize_input(tracking_number) try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Get order details query = """ SELECT o.id, o.tracking_number, o.customer_name, o.total_amount, o.status, o.order_date, o.estimated_delivery, o.user_id FROM orders o WHERE o.tracking_number = ? """ cursor.execute(query, (tracking_number,)) order = cursor.fetchone() if not order: conn.close() return f"❌ לא נמצאה הזמנה עם מספר מעקב: {tracking_number}" order_id, track_num, customer_name, total, status, order_date, est_delivery, order_user_id = order # Check if user has permission to view this order user_session = get_user_from_session(session_token) if session_token else None if user_session and user_session['user_id'] != order_user_id: conn.close() return "❌ אין לך הרשאה לצפות בהזמנה זו" # Get order items cursor.execute(""" SELECT product_name, quantity, price, total_price FROM order_items WHERE order_id = ? """, (order_id,)) items = cursor.fetchall() conn.close() # Parse dates order_date_dt = datetime.fromisoformat(order_date.replace('Z', '+00:00')) if 'Z' in order_date else datetime.fromisoformat(order_date) est_delivery_dt = datetime.fromisoformat(est_delivery.replace('Z', '+00:00')) if 'Z' in est_delivery else datetime.fromisoformat(est_delivery) result = f"📦 **מעקב הזמנה מאובטח**\n\n" result += f"🔍 **מספר מעקב:** {track_num}\n" result += f"📋 **מספר הזמנה:** #{order_id}\n" result += f"👤 **לקוח:** {customer_name}\n" result += f"📅 **תאריך הזמנה:** {order_date_dt.strftime('%d/%m/%Y %H:%M')}\n" # Status with emoji status_emoji = { "מעובד": "⏳", "נשלח": "🚚", "בדרך": "📦", "נמסר": "✅", "מבוטל": "❌" } result += f"📊 **סטטוס:** {status_emoji.get(status, '📋')} {status}\n" result += f"🚚 **משלוח משוער:** {est_delivery_dt.strftime('%d/%m/%Y')}\n\n" result += "🛍️ **פריטי ההזמנה:**\n" result += "=" * 40 + "\n" for item in items: product_name, quantity, price, total_price = item result += f"• **{product_name}**\n" result += f" 📦 כמות: {quantity} | 💰 ₪{price:.2f} | סה\"כ: ₪{total_price:.2f}\n\n" result += f"💳 **סה\"כ הזמנה: ₪{total:.2f}**\n\n" # Progress tracking if status == "מעובד": result += "⏳ **שלב נוכחי:** ההזמנה בעיבוד במחסן\n" result += "🔄 **השלב הבא:** אריזה ומסירה לחברת השליחויות\n" elif status == "נשלח": result += "🚚 **שלב נוכחי:** ההזמנה נמסרה לחברת השליחויות\n" result += "🔄 **השלב הבא:** בדרך אליך\n" elif status == "בדרך": result += "📦 **שלב נוכחי:** ההזמנה בדרך אליך\n" result += "🔄 **השלב הבא:** מסירה ביעד\n" elif status == "נמסר": result += "✅ **ההזמנה נמסרה בהצלחה!**\n" result += "🎉 תודה שקנית באורגניטל!\n" result += f"\n📞 **שירות לקוחות:** 03-1234567\n" result += "🔐 מערכת מעקב מאובטחת ומוצפנת" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה במעקב הזמנה: {str(e)}" @mcp.tool() def search_faq(query: str = "", category: str = "") -> str: """ 🔍 חיפוש במרכז השאלות הנפוצות Args: query: מילת חיפוש או שאלה category: סינון לפי קטגוריה (אופציונלי) Returns: תוצאות חיפוש עם תשובות רלוונטיות """ query = sanitize_input(query) category = sanitize_input(category) try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() if not query and not category: # Show all categories cursor.execute(""" SELECT name, description FROM faq_categories ORDER BY display_order """) categories = cursor.fetchall() result = "❓ **מרכז השאלות הנפוצות - אורגניטל**\n\n" result += "📚 **קטגוריות עזרה:**\n\n" for cat_name, cat_desc in categories: result += f"🔸 **{cat_name}**\n" result += f" {cat_desc}\n\n" result += "🔍 **איך להשתמש:**\n" result += "• חפש שאלה: `search_faq \"איך משתמשים בסטיביה\"`\n" result += "• עיין בקטגוריה: `search_faq category=\"על סטיביה\"`\n" result += "• קבל עזרה: `create_support_ticket`" conn.close() return result # Search with query if query: if category: cursor.execute(""" SELECT f.question, f.answer, c.name, f.id FROM faq_items f JOIN faq_categories c ON f.category_id = c.id WHERE (f.question LIKE ? OR f.answer LIKE ? OR f.keywords LIKE ?) AND c.name = ? ORDER BY f.views DESC, f.helpful_votes DESC """, (f"%{query}%", f"%{query}%", f"%{query}%", category)) else: cursor.execute(""" SELECT f.question, f.answer, c.name, f.id FROM faq_items f JOIN faq_categories c ON f.category_id = c.id WHERE f.question LIKE ? OR f.answer LIKE ? OR f.keywords LIKE ? ORDER BY f.views DESC, f.helpful_votes DESC """, (f"%{query}%", f"%{query}%", f"%{query}%")) else: # Show category content cursor.execute(""" SELECT f.question, f.answer, c.name, f.id FROM faq_items f JOIN faq_categories c ON f.category_id = c.id WHERE c.name = ? ORDER BY f.views DESC """, (category,)) items = cursor.fetchall() if not items: conn.close() return f"🔍 לא נמצאו תוצאות עבור '{query}' {f'בקטגוריה {category}' if category else ''}\n\n💡 נסה מילים אחרות או צור קשר עמנו: `create_support_ticket`" # Update view counts for item in items: cursor.execute("UPDATE faq_items SET views = views + 1 WHERE id = ?", (item[3],)) conn.commit() conn.close() result = f"❓ **תוצאות חיפוש במרכז העזרה**\n\n" if query: result += f"🔍 **חיפוש עבור:** {query}\n" if category: result += f"📂 **קטגוריה:** {category}\n" result += f"📊 **נמצאו {len(items)} תוצאות**\n\n" for i, (question, answer, cat_name, item_id) in enumerate(items, 1): result += f"**❓ שאלה #{i}: {question}**\n" result += f"📂 קטגוריה: {cat_name}\n\n" result += f"✅ **תשובה:**\n{answer}\n\n" result += f"👍 *השיב לך? השתמש ב-`rate_faq_helpful {item_id}`*\n" result += "─" * 50 + "\n\n" result += "🆘 **לא מצאת מה שחיפשת?**\n" result += "• פתח כרטיס תמיכה: `create_support_ticket`\n" result += "• חפש שוב: `search_faq \"מילה אחרת\"`\n" result += "• צור קשר: 03-1234567" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בחיפוש: {str(e)}" @mcp.tool() def create_support_ticket(subject: str, message: str, customer_name: str, customer_email: str, category: str = "כללי", session_token: str = "") -> str: """ 🎫 יצירת כרטיס תמיכה חדש Args: subject: נושא הפנייה message: תיאור הבעיה או השאלה customer_name: שם מלא customer_email: כתובת אימייל category: קטגוריית הפנייה (כללי/טכני/הזמנה/תשלום) session_token: טוקן התחברות (אופציונלי) Returns: מספר כרטיס התמיכה ופרטי המעקב """ # Sanitize inputs subject = sanitize_input(subject) message = sanitize_input(message) customer_name = sanitize_input(customer_name) customer_email = sanitize_input(customer_email).lower() category = sanitize_input(category) # Validate inputs if not subject or len(subject) < 3: return "❌ נושא הפנייה חייב להכיל לפחות 3 תווים" if not message or len(message) < 10: return "❌ תיאור הבעיה חייב להכיל לפחות 10 תווים" if not customer_name or len(customer_name) < 2: return "❌ שם חייב להכיל לפחות 2 תווים" if not validate_email(customer_email): return "❌ כתובת אימייל לא תקינה" # Check if user is logged in user_session = get_user_from_session(session_token) if session_token else None user_id = user_session['user_id'] if user_session else None try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Generate ticket number ticket_number = f"TK{datetime.now().strftime('%Y%m%d')}{secrets.randbelow(9999):04d}" # Determine priority based on keywords priority = "medium" urgent_keywords = ["דחוף", "בעיה", "לא עובד", "תקוע", "שגיאה"] high_keywords = ["תשלום", "כרטיס אשראי", "הזמנה", "החזר"] if any(keyword in message.lower() or keyword in subject.lower() for keyword in urgent_keywords): priority = "high" elif any(keyword in message.lower() or keyword in subject.lower() for keyword in high_keywords): priority = "medium" else: priority = "low" # Insert support ticket cursor.execute(""" INSERT INTO support_tickets ( ticket_number, user_id, customer_email, customer_name, subject, message, category, priority, status ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) """, (ticket_number, user_id, customer_email, customer_name, subject, message, category, priority, "open")) ticket_id = cursor.lastrowid # Auto-response based on category and keywords auto_response = "" if "משלוח" in message.lower() or "מעקב" in message.lower(): auto_response = "תוכל לעקוב אחר ההזמנה שלך באמצעות מספר המעקב שקיבלת במייל. אם אין לך מספר מעקב, נעזור לך למצוא אותו." elif "החזר" in message.lower() or "החזרה" in message.lower(): auto_response = "החזרות מתאפשרות תוך 14 ימים מקבלת המוצר. המוצר צריך להיות באריזה מקורית ובמצב שלם." elif "סטיביה" in message.lower() and ("איך" in message.lower() or "משתמש" in message.lower()): auto_response = "לשימוש בסטיביה: התחל עם כמות קטנה והוסף לפי הטעם. אבקה - כפית קטנה במקום כף סוכר, טבליות - אחת למשקה." else: auto_response = "תודה על פנייתך! נחזור אליך תוך 24 שעות. בינתיים, בדוק את מרכז השאלות הנפוצות שלנו." if auto_response: cursor.execute(""" INSERT INTO support_responses (ticket_id, responder_name, message) VALUES (?, ?, ?) """, (ticket_id, "מערכת אוטומטית", auto_response)) conn.commit() conn.close() # Priority emoji priority_emoji = {"high": "🔴", "medium": "🟡", "low": "🟢"} result = f"🎫 **כרטיס תמיכה נוצר בהצלחה!**\n\n" result += f"📋 **מספר כרטיס:** {ticket_number}\n" result += f"📧 **אימייל:** {customer_email}\n" result += f"👤 **שם:** {customer_name}\n" result += f"📂 **קטגוריה:** {category}\n" result += f"{priority_emoji.get(priority, '🟡')} **עדיפות:** {priority}\n" result += f"📝 **נושא:** {subject}\n\n" result += f"💬 **הודעתך:**\n{message}\n\n" if auto_response: result += f"🤖 **תגובה אוטומטית:**\n{auto_response}\n\n" result += f"⏰ **זמן תגובה משוער:**\n" if priority == "high": result += "• עדיפות גבוהה: תוך 4 שעות\n" elif priority == "medium": result += "• עדיפות בינונית: תוך 12 שעות\n" else: result += "• עדיפות נמוכה: תוך 24 שעות\n" result += f"\n📞 **יצירת קשר נוספת:**\n" result += f"• טלפון: 03-1234567 (א'-ה' 9:00-17:00)\n" result += f"• מעקב כרטיס: `track_support_ticket {ticket_number}`\n" result += f"• עדכון פרטים: `update_support_ticket {ticket_number}`" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה ביצירת כרטיס תמיכה: {str(e)}" @mcp.tool() def track_support_ticket(ticket_number: str, session_token: str = "") -> str: """ 📋 מעקב אחר כרטיס תמיכה Args: ticket_number: מספר כרטיס התמיכה session_token: טוקן התחברות (אופציונלי) Returns: סטטוס הכרטיס וכל התגובות """ ticket_number = sanitize_input(ticket_number) try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Get ticket details cursor.execute(""" SELECT id, customer_name, customer_email, subject, message, category, priority, status, created_at, updated_at, user_id FROM support_tickets WHERE ticket_number = ? """, (ticket_number,)) ticket = cursor.fetchone() if not ticket: conn.close() return f"❌ לא נמצא כרטיס תמיכה עם מספר: {ticket_number}" (ticket_id, customer_name, customer_email, subject, message, category, priority, status, created_at, updated_at, ticket_user_id) = ticket # Check permissions user_session = get_user_from_session(session_token) if session_token else None if user_session and user_session['user_id'] != ticket_user_id: conn.close() return "❌ אין לך הרשאה לצפות בכרטיס תמיכה זה" # Get responses cursor.execute(""" SELECT responder_name, message, created_at, is_internal FROM support_responses WHERE ticket_id = ? ORDER BY created_at ASC """, (ticket_id,)) responses = cursor.fetchall() conn.close() # Status and priority emojis status_emoji = { "open": "🟢 פתוח", "in_progress": "🟡 בטיפול", "waiting_customer": "⏳ ממתין לתגובה", "resolved": "✅ נפתר", "closed": "🔒 סגור" } priority_emoji = {"high": "🔴 גבוהה", "medium": "🟡 בינונית", "low": "🟢 נמוכה"} result = f"📋 **מעקב כרטיס תמיכה**\n\n" result += f"🎫 **מספר כרטיס:** {ticket_number}\n" result += f"👤 **שם:** {customer_name}\n" result += f"📧 **אימייל:** {customer_email}\n" result += f"📂 **קטגוריה:** {category}\n" result += f"📊 **סטטוס:** {status_emoji.get(status, status)}\n" result += f"⚡ **עדיפות:** {priority_emoji.get(priority, priority)}\n\n" result += f"📝 **נושא:** {subject}\n" result += f"💬 **הודעה מקורית:**\n{message}\n\n" created_dt = datetime.fromisoformat(created_at.replace('Z', '+00:00')) if 'Z' in created_at else datetime.fromisoformat(created_at) result += f"📅 **נוצר:** {created_dt.strftime('%d/%m/%Y %H:%M')}\n" if updated_at != created_at: updated_dt = datetime.fromisoformat(updated_at.replace('Z', '+00:00')) if 'Z' in updated_at else datetime.fromisoformat(updated_at) result += f"🔄 **עודכן:** {updated_dt.strftime('%d/%m/%Y %H:%M')}\n" result += "\n" + "="*50 + "\n" result += "💬 **היסטוריית תגובות:**\n\n" if responses: for responder, resp_message, resp_time, is_internal in responses: if is_internal: continue # Skip internal messages for customers resp_dt = datetime.fromisoformat(resp_time.replace('Z', '+00:00')) if 'Z' in resp_time else datetime.fromisoformat(resp_time) if responder == "מערכת אוטומטית": result += f"🤖 **{responder}** - {resp_dt.strftime('%d/%m/%Y %H:%M')}\n" else: result += f"👨‍💼 **{responder}** - {resp_dt.strftime('%d/%m/%Y %H:%M')}\n" result += f"{resp_message}\n\n" else: result += "📭 אין תגובות עדיין\n\n" # Next steps based on status if status == "open": result += "⏳ **הכרטיס שלך ממתין לטיפול צוות התמיכה**\n" elif status == "waiting_customer": result += "⚠️ **אנחנו ממתינים לתגובתך!** השב על השאלות שנשאלו\n" elif status == "resolved": result += "✅ **הכרטיס נפתר!** אם יש לך שאלות נוספות, פתח כרטיס חדש\n" result += f"\n📞 **יצירת קשר נוספת:** 03-1234567" return result except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה במעקב כרטיס תמיכה: {str(e)}" @mcp.tool() def rate_faq_helpful(faq_id: int) -> str: """ 👍 דירוג שאלה כמועילה במרכז העזרה Args: faq_id: מזהה השאלה במרכז העזרה Returns: אישור הדירוג """ try: conn = sqlite3.connect(DATABASE_PATH) cursor = conn.cursor() # Check if FAQ exists cursor.execute("SELECT question FROM faq_items WHERE id = ?", (faq_id,)) faq = cursor.fetchone() if not faq: conn.close() return f"❌ לא נמצאה שאלה עם מזהה #{faq_id}" # Update helpful votes cursor.execute(""" UPDATE faq_items SET helpful_votes = helpful_votes + 1 WHERE id = ? """, (faq_id,)) conn.commit() conn.close() return f"👍 **תודה על המשוב!**\n\nדירגת את השאלה '{faq[0]}' כמועילה.\n\n💡 המשוב שלך עוזר לנו לשפר את מרכז העזרה!" except sqlite3.Error as e: return f"❌ שגיאה במסד הנתונים: {str(e)}" except Exception as e: return f"❌ שגיאה בדירוג: {str(e)}" @mcp.tool() def get_support_categories() -> str: """ 📂 הצגת קטגוריות התמיכה הזמינות Returns: רשימת קטגוריות התמיכה והמידע עליהן """ categories_info = { "כללי": "שאלות כלליות על החנות והשירותים", "טכני": "בעיות טכניות באתר ובמערכת ההזמנות", "הזמנה": "שאלות על הזמנות, משלוחים ומעקב", "תשלום": "בעיות בתשלום, החזרות וחיובים", "מוצרים": "שאלות על המוצרים, המלאי והמפרטים", "חשבון": "בעיות בהתחברות, רישום ופרופיל משתמש" } result = "📂 **קטגוריות תמיכה - אורגניטל**\n\n" result += "בחר את הקטגוריה המתאימה ביותר לפנייתך:\n\n" for category, description in categories_info.items(): result += f"🔸 **{category}**\n" result += f" {description}\n\n" result += "🎫 **ליצירת כרטיס תמיכה:**\n" result += "```\ncreate_support_ticket(\n" result += " subject=\"נושא הפנייה\",\n" result += " message=\"תיאור הבעיה או השאלה\",\n" result += " customer_name=\"השם שלך\",\n" result += " customer_email=\"האימייל שלך\",\n" result += " category=\"אחת מהקטגוריות למעלה\"\n" result += ")\n```\n\n" result += "🔍 **לחיפוש מהיר:** `search_faq \"השאלה שלך\"`" return result # Initialize database on import init_database() if __name__ == "__main__": parser = argparse.ArgumentParser(description="Secure Stevia Store MCP Server") args = parser.parse_args() print("🔐 Starting Secure Stevia Store MCP Server...", flush=True) mcp.run()