#!/usr/bin/env python # -*- coding: utf-8 -*- """ وحدة المساعد الذكي التفاعلية تتيح للمستخدمين التفاعل مع نماذج الذكاء الاصطناعي المتقدمة للحصول على مساعدة في تحليل العقود والمناقصات """ import os import sys import json import re import time import base64 import tempfile import logging from datetime import datetime import streamlit as st import pandas as pd import numpy as np import requests from io import BytesIO from PIL import Image import openai import plotly.express as px import plotly.graph_objects as go # إضافة مسار النظام للوصول للملفات المشتركة sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "../.."))) # استيراد المكونات المساعدة from utils.helpers import create_directory_if_not_exists, format_time, get_user_info, render_credits, load_css class AIAssistant: """فئة المساعد الذكي التفاعلية""" def __init__(self): """تهيئة المساعد الذكي""" self.conversations_dir = os.path.join(os.path.dirname(__file__), '..', '..', 'data', 'assistant_conversations') create_directory_if_not_exists(self.conversations_dir) # تهيئة مفتاح OpenAI API self.openai_api_key = os.environ.get("OPENAI_API_KEY") if self.openai_api_key: openai.api_key = self.openai_api_key self.is_api_available = True else: self.is_api_available = False # نموذج OpenAI المستخدم self.model = "gpt-4o" # النموذج الأحدث من OpenAI # تهيئة حالة المحادثة في الجلسة if "assistant_messages" not in st.session_state: st.session_state.assistant_messages = [] if "assistant_mode" not in st.session_state: st.session_state.assistant_mode = "general" if "document_context" not in st.session_state: st.session_state.document_context = None # الأنماط المتاحة للمساعد self.assistant_modes = { "general": "مساعد عام", "contract_analysis": "تحليل العقود", "cost_estimation": "تقدير التكاليف", "risk_assessment": "تقييم المخاطر", "project_planning": "تخطيط المشاريع" } # توجيهات النظام للمساعد self.system_prompts = { "general": """ أنت مساعد ذكي متخصص في شركة شبه الجزيرة للمقاولات، وتعمل ضمن نظام WAHBi لتحليل العقود والمناقصات. دورك هو مساعدة المستخدمين في: 1. تحليل المستندات والعقود، وتوضيح بنود العقود وفهم الالتزامات والشروط. 2. المساعدة في تسعير المشاريع وحساب التكاليف والموارد. 3. تقييم مخاطر العقود والمشاريع والمساعدة في اتخاذ القرارات. 4. المساعدة في إدارة المشاريع ومتابعة الإنجاز. استخدم لغة مهنية واضحة ومباشرة. قدم إجابات دقيقة ومختصرة. عند قيام المستخدم بسؤال عن كيفية استخدام النظام، قم بإرشاده إلى الوحدة المناسبة في النظام. معلومات هامة عن وحدات النظام: - وحدة تحليل المستندات: لتحليل العقود والمناقصات باستخدام الذكاء الاصطناعي. - وحدة مقارنة المستندات: لمقارنة نسخ مختلفة من المستندات وتحديد التغييرات. - وحدة التسعير المتكاملة: لحساب تكاليف المشاريع بناءً على الموارد والمواد والعمالة. - وحدة تقييم مخاطر العقود: لتحليل وتقييم المخاطر المحتملة في العقود والمشاريع. - وحدة متتبع حالة المشروع: لمتابعة تقدم المشاريع وعرض مؤشرات الأداء. - وحدة خريطة المشاريع: لعرض مواقع المشاريع على الخريطة بشكل تفاعلي. - وحدة الإشعارات الذكية: لإرسال تنبيهات وإشعارات للمستخدمين حول المشاريع. تذكر أن تكون مفيداً ودقيقاً ومهنياً في جميع إجاباتك. """, "contract_analysis": """ أنت محلل عقود متخصص في تحليل العقود والمناقصات لشركات المقاولات. مهمتك هي تحليل العقود وتحديد: - الالتزامات الرئيسية - المواعيد النهائية والتسليمات - الشروط الجزائية والغرامات - آلية الدفع والمستحقات المالية - الشروط الخاصة والاستثناءات - المخاطر المحتملة وكيفية التخفيف منها عند تحليل عقد، قم بتوضيح البنود غير المواتية التي قد تسبب مشاكل مستقبلية. استخدم لغة قانونية دقيقة مع شرح المصطلحات القانونية بلغة مبسطة. قدم توصيات عملية لكيفية التعامل مع بنود العقد وتجنب المخاطر. """, "cost_estimation": """ أنت خبير في تقدير تكاليف مشاريع البناء والمقاولات. مهمتك هي مساعدة المستخدم في: - تقدير تكاليف المشاريع بناءً على وصف المشروع ومتطلباته - حساب تكاليف المواد والعمالة والمعدات والنفقات العامة - توضيح كيفية تخصيص الميزانية بين مختلف عناصر المشروع - تحديد التكاليف غير المباشرة التي قد يغفل عنها المستخدم - اقتراح طرق لتقليل التكاليف دون التأثير على جودة المشروع استخدم أسلوب منهجي في تقدير التكاليف واشرح افتراضاتك بوضوح. قدم نطاقات تقديرية بدلاً من أرقام دقيقة للتكاليف حيثما كان ذلك مناسباً. عند الإشارة إلى تكاليف، وضح ما إذا كانت التكاليف تشمل ضريبة القيمة المضافة أم لا. """, "risk_assessment": """ أنت خبير في تقييم مخاطر مشاريع البناء والمقاولات. مهمتك هي مساعدة المستخدم في: - تحديد المخاطر المحتملة في المشاريع والعقود - تقييم احتمالية وتأثير كل خطر - اقتراح استراتيجيات للتخفيف من المخاطر - تحليل السيناريوهات المحتملة وخطط الطوارئ - تقديم أفضل الممارسات لإدارة المخاطر في مشاريع المقاولات صنف المخاطر إلى فئات (عالية، متوسطة، منخفضة) بناءً على احتماليتها وتأثيرها. اشرح كيف يمكن للشركة أن تحول بعض المخاطر إلى فرص. قدم أمثلة عملية من مشاريع مماثلة لتوضيح كيفية إدارة المخاطر المحددة. """, "project_planning": """ أنت خبير في تخطيط وإدارة مشاريع البناء والمقاولات. مهمتك هي مساعدة المستخدم في: - تخطيط المشاريع وتقسيمها إلى مراحل ومهام - تحديد الموارد اللازمة والجداول الزمنية - إنشاء مخطط جانت وتحديد المسار الحرج - التخطيط للموارد البشرية والمعدات والمواد - متابعة تقدم المشروع ومؤشرات الأداء قدم نصائح عملية لإدارة المشاريع بكفاءة وتجنب التأخيرات. اشرح كيفية التعامل مع التغييرات والمطالبات خلال تنفيذ المشروع. قدم أفضل الممارسات للتواصل مع أصحاب المصلحة وإدارة التوقعات. """ } def _call_openai_api(self, messages, model=None, max_tokens=2000): """استدعاء OpenAI API للحصول على استجابة""" if not self.is_api_available: return { "choices": [{"message": {"content": "عذراً، مفتاح OpenAI API غير متوفر. يرجى التواصل مع مسؤول النظام."}}] } try: if model is None: model = self.model response = openai.ChatCompletion.create( model=model, messages=messages, max_tokens=max_tokens, temperature=0.7, top_p=0.9, frequency_penalty=0, presence_penalty=0 ) return response except Exception as e: logging.error(f"خطأ في استدعاء OpenAI API: {e}") return { "choices": [{"message": {"content": f"عذراً، حدث خطأ في الاتصال بـ OpenAI API: {str(e)}"}}] } def _call_backend_api(self, endpoint, data): """استدعاء واجهة API الخلفية للنظام""" try: response = requests.post( f"http://localhost:5000/api/{endpoint}", json=data, timeout=60 ) if response.status_code == 200: return response.json() else: logging.error(f"خطأ في استدعاء واجهة API الخلفية: {response.status_code} - {response.text}") return {"error": f"خطأ في استدعاء واجهة API الخلفية: {response.status_code}"} except Exception as e: logging.error(f"خطأ في الاتصال بواجهة API الخلفية: {e}") return {"error": f"خطأ في الاتصال بواجهة API الخلفية: {str(e)}"} def _process_user_message(self, user_message, mode=None): """معالجة رسالة المستخدم والحصول على رد من المساعد الذكي""" if mode is None: mode = st.session_state.assistant_mode # إنشاء قائمة الرسائل للمحادثة messages = [ {"role": "system", "content": self.system_prompts[mode]} ] # إضافة سياق المستند إذا كان متاحاً if st.session_state.document_context: messages.append({ "role": "system", "content": f"معلومات سياقية عن المستند: {st.session_state.document_context}" }) # إضافة المحادثة السابقة for msg in st.session_state.assistant_messages: messages.append({ "role": msg["role"], "content": msg["content"] }) # إضافة رسالة المستخدم الحالية messages.append({ "role": "user", "content": user_message }) # استدعاء API response = self._call_openai_api(messages) # استخراج الرد assistant_response = response["choices"][0]["message"]["content"] # تحديث سجل المحادثة st.session_state.assistant_messages.append({"role": "user", "content": user_message}) st.session_state.assistant_messages.append({"role": "assistant", "content": assistant_response}) return assistant_response def _clear_chat(self): """مسح المحادثة الحالية""" st.session_state.assistant_messages = [] st.session_state.document_context = None def _save_conversation(self): """حفظ المحادثة الحالية""" if not st.session_state.assistant_messages: st.warning("لا توجد محادثة لحفظها.") return False timestamp = datetime.now().strftime("%Y%m%d%H%M%S") user_info = get_user_info() conversation_data = { "timestamp": timestamp, "user": user_info["username"], "mode": st.session_state.assistant_mode, "messages": st.session_state.assistant_messages, "document_context": st.session_state.document_context } filename = f"conversation_{user_info['username']}_{timestamp}.json" file_path = os.path.join(self.conversations_dir, filename) try: with open(file_path, 'w', encoding='utf-8') as f: json.dump(conversation_data, f, ensure_ascii=False, indent=2) return True except Exception as e: logging.error(f"خطأ في حفظ المحادثة: {e}") return False def _load_conversation(self, filename): """تحميل محادثة محفوظة""" file_path = os.path.join(self.conversations_dir, filename) try: with open(file_path, 'r', encoding='utf-8') as f: conversation_data = json.load(f) st.session_state.assistant_messages = conversation_data["messages"] st.session_state.assistant_mode = conversation_data["mode"] st.session_state.document_context = conversation_data.get("document_context") return True except Exception as e: logging.error(f"خطأ في تحميل المحادثة: {e}") return False def _get_saved_conversations(self): """الحصول على قائمة المحادثات المحفوظة""" conversations = [] try: for filename in os.listdir(self.conversations_dir): if filename.endswith(".json") and filename.startswith("conversation_"): file_path = os.path.join(self.conversations_dir, filename) with open(file_path, 'r', encoding='utf-8') as f: data = json.load(f) conversations.append({ "filename": filename, "timestamp": data.get("timestamp", ""), "user": data.get("user", ""), "mode": data.get("mode", "general"), "message_count": len(data.get("messages", [])) }) except Exception as e: logging.error(f"خطأ في قراءة المحادثات المحفوظة: {e}") # ترتيب المحادثات حسب التاريخ (الأحدث أولاً) conversations.sort(key=lambda x: x["timestamp"], reverse=True) return conversations def render_chat_interface(self): """عرض واجهة المحادثة الرئيسية""" st.markdown("
مرحباً بك في المساعد الذكي!
يمكنك البدء بطرح سؤال أو طلب مساعدة.