#!/usr/bin/env python # -*- coding: utf-8 -*- """ وحدة متتبع حالة المشروع المتحرك مع تصور التقدم """ import os import sys import json import time import datetime import streamlit as st import pandas as pd import numpy as np import plotly.express as px import plotly.graph_objects as go from datetime import datetime, timedelta import random import math # إضافة مسار النظام للوصول للملفات المشتركة sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "../.."))) # استيراد المكونات المساعدة from utils.helpers import format_time, get_user_info, create_directory_if_not_exists class ProjectStatusTracker: """فئة متتبع حالة المشروع المتحرك""" def __init__(self, project_id=None, user_id=None): """تهيئة متتبع حالة المشروع""" self.project_id = project_id or 1 # استخدام المشروع الافتراضي إذا لم يتم توفير معرف self.user_id = user_id or 1 # استخدام المستخدم الافتراضي إذا لم يتم توفير معرف self.tracker_path = os.path.join(os.path.dirname(__file__), '..', '..', 'data', 'project_tracker') create_directory_if_not_exists(self.tracker_path) self.project_data_file = os.path.join(self.tracker_path, f'project_{self.project_id}_status.json') # تعريف المراحل الافتراضية للمشروع self.default_project_phases = [ { "id": "planning", "name": "التخطيط", "description": "مرحلة التخطيط وإعداد الجدول الزمني", "order": 1, "progress": 100, "status": "completed", "start_date": (datetime.now() - timedelta(days=30)).strftime('%Y-%m-%d'), "end_date": (datetime.now() - timedelta(days=20)).strftime('%Y-%m-%d'), "actual_end_date": (datetime.now() - timedelta(days=18)).strftime('%Y-%m-%d'), "deliverables": ["خطة المشروع", "الجدول الزمني", "خطة الموارد"], "responsible": "فريق التخطيط", "notes": "تم الانتهاء من مرحلة التخطيط بنجاح قبل الموعد المحدد", "critical": True }, { "id": "pricing", "name": "التسعير", "description": "تسعير المشروع وتحليل التكاليف", "order": 2, "progress": 100, "status": "completed", "start_date": (datetime.now() - timedelta(days=20)).strftime('%Y-%m-%d'), "end_date": (datetime.now() - timedelta(days=10)).strftime('%Y-%m-%d'), "actual_end_date": (datetime.now() - timedelta(days=8)).strftime('%Y-%m-%d'), "deliverables": ["جدول الكميات المسعر", "تحليل التكاليف", "خطة التدفق النقدي"], "responsible": "قسم التسعير", "notes": "تم تحقيق وفر في تكاليف المشروع بنسبة 5%", "critical": True }, { "id": "bidding", "name": "تقديم العطاء", "description": "إعداد وتقديم وثائق العطاء", "order": 3, "progress": 100, "status": "completed", "start_date": (datetime.now() - timedelta(days=10)).strftime('%Y-%m-%d'), "end_date": (datetime.now() - timedelta(days=5)).strftime('%Y-%m-%d'), "actual_end_date": (datetime.now() - timedelta(days=5)).strftime('%Y-%m-%d'), "deliverables": ["وثائق العطاء", "خطاب التقديم", "الضمان البنكي الابتدائي"], "responsible": "مدير المشروع", "notes": "تم تقديم العطاء في الموعد المحدد", "critical": True }, { "id": "evaluation", "name": "تقييم العطاء", "description": "مرحلة تقييم العطاء من قبل العميل", "order": 4, "progress": 75, "status": "in_progress", "start_date": (datetime.now() - timedelta(days=5)).strftime('%Y-%m-%d'), "end_date": (datetime.now() + timedelta(days=5)).strftime('%Y-%m-%d'), "actual_end_date": None, "deliverables": ["الرد على استفسارات العميل", "العرض التقديمي", "تقديم المستندات الإضافية"], "responsible": "العميل / مدير المشروع", "notes": "مرحلة التقييم جارية، تم الرد على جميع استفسارات العميل", "critical": True }, { "id": "awarding", "name": "ترسية العطاء", "description": "مرحلة ترسية العطاء وتوقيع العقد", "order": 5, "progress": 0, "status": "not_started", "start_date": (datetime.now() + timedelta(days=5)).strftime('%Y-%m-%d'), "end_date": (datetime.now() + timedelta(days=15)).strftime('%Y-%m-%d'), "actual_end_date": None, "deliverables": ["خطاب الترسية", "العقد الموقع", "الضمان البنكي النهائي"], "responsible": "الإدارة القانونية / مدير المشروع", "notes": "ننتظر نتيجة الترسية", "critical": True }, { "id": "mobilization", "name": "التجهيز", "description": "تجهيز الموقع وتوفير الموارد", "order": 6, "progress": 0, "status": "not_started", "start_date": (datetime.now() + timedelta(days=15)).strftime('%Y-%m-%d'), "end_date": (datetime.now() + timedelta(days=30)).strftime('%Y-%m-%d'), "actual_end_date": None, "deliverables": ["تقرير التجهيز", "قائمة الموارد", "خطة التنفيذ التفصيلية"], "responsible": "قسم العمليات", "notes": "التجهيز سيبدأ بعد توقيع العقد", "critical": False }, { "id": "execution", "name": "التنفيذ", "description": "تنفيذ أعمال المشروع", "order": 7, "progress": 0, "status": "not_started", "start_date": (datetime.now() + timedelta(days=30)).strftime('%Y-%m-%d'), "end_date": (datetime.now() + timedelta(days=180)).strftime('%Y-%m-%d'), "actual_end_date": None, "deliverables": ["تقارير التقدم الدورية", "محاضر الاجتماعات", "الفواتير"], "responsible": "فريق التنفيذ", "notes": "التنفيذ سيستمر لمدة 6 أشهر", "critical": True }, { "id": "handover", "name": "التسليم", "description": "تسليم المشروع للعميل", "order": 8, "progress": 0, "status": "not_started", "start_date": (datetime.now() + timedelta(days=180)).strftime('%Y-%m-%d'), "end_date": (datetime.now() + timedelta(days=195)).strftime('%Y-%m-%d'), "actual_end_date": None, "deliverables": ["محضر الاستلام", "وثائق الضمان", "دليل التشغيل والصيانة"], "responsible": "مدير المشروع / العميل", "notes": "التسليم يشمل فترة الاختبار والتدريب", "critical": True }, ] # تحميل بيانات المشروع self.load_project_data() # تحميل البيانات لمؤشرات الأداء الرئيسية self.kpi_data_file = os.path.join(self.tracker_path, f'project_{self.project_id}_kpis.json') self.load_kpi_data() def load_project_data(self): """تحميل بيانات حالة المشروع""" try: if os.path.exists(self.project_data_file): with open(self.project_data_file, 'r', encoding='utf-8') as f: self.project_data = json.load(f) else: # بيانات افتراضية عند عدم وجود ملف self.project_data = { 'project_id': self.project_id, 'project_name': "مشروع إنشاء مبنى إداري", 'project_code': "PC-2025-001", 'client': "وزارة الإسكان", 'location': "الرياض، المملكة العربية السعودية", 'start_date': (datetime.now() - timedelta(days=30)).strftime('%Y-%m-%d'), 'end_date': (datetime.now() + timedelta(days=200)).strftime('%Y-%m-%d'), 'budget': 10000000, 'duration': 230, 'elapsed_days': 30, 'overall_progress': 25, 'status': "في التقدم", 'phases': self.default_project_phases, 'last_updated': datetime.now().strftime('%Y-%m-%d %H:%M:%S') } self.save_project_data() except Exception as e: st.error(f"خطأ في تحميل بيانات المشروع: {e}") self.project_data = { 'project_id': self.project_id, 'project_name': "مشروع إنشاء مبنى إداري", 'project_code': "PC-2025-001", 'client': "وزارة الإسكان", 'location': "الرياض، المملكة العربية السعودية", 'start_date': (datetime.now() - timedelta(days=30)).strftime('%Y-%m-%d'), 'end_date': (datetime.now() + timedelta(days=200)).strftime('%Y-%m-%d'), 'budget': 10000000, 'duration': 230, 'elapsed_days': 30, 'overall_progress': 25, 'status': "في التقدم", 'phases': self.default_project_phases, 'last_updated': datetime.now().strftime('%Y-%m-%d %H:%M:%S') } def save_project_data(self): """حفظ بيانات حالة المشروع""" try: with open(self.project_data_file, 'w', encoding='utf-8') as f: json.dump(self.project_data, f, ensure_ascii=False, indent=2) except Exception as e: st.error(f"خطأ في حفظ بيانات المشروع: {e}") def load_kpi_data(self): """تحميل بيانات مؤشرات الأداء الرئيسية""" try: if os.path.exists(self.kpi_data_file): with open(self.kpi_data_file, 'r', encoding='utf-8') as f: self.kpi_data = json.load(f) else: # بيانات افتراضية عند عدم وجود ملف self.kpi_data = { 'spi': 1.05, # مؤشر أداء الجدول الزمني (SPI) 'cpi': 0.98, # مؤشر أداء التكلفة (CPI) 'quality_score': 92, # درجة جودة المشروع 'safety_incidents': 0, # عدد حوادث السلامة 'resource_utilization': 85, # نسبة استغلال الموارد 'risk_score': 15, # درجة المخاطر (كلما قلت كان أفضل) 'customer_satisfaction': 90, # درجة رضا العميل 'environmental_compliance': 95, # نسبة الامتثال البيئي 'trends': { 'spi': [0.95, 0.98, 1.02, 1.05], 'cpi': [1.02, 1.00, 0.99, 0.98], 'quality_score': [85, 88, 90, 92], 'risk_score': [25, 22, 18, 15], 'dates': [ (datetime.now() - timedelta(days=21)).strftime('%Y-%m-%d'), (datetime.now() - timedelta(days=14)).strftime('%Y-%m-%d'), (datetime.now() - timedelta(days=7)).strftime('%Y-%m-%d'), datetime.now().strftime('%Y-%m-%d') ] }, 'issues': [ { 'id': 1, 'description': "تأخر في توريد المواد", 'severity': "متوسط", 'status': "قيد المعالجة", 'created_date': (datetime.now() - timedelta(days=10)).strftime('%Y-%m-%d'), 'responsible': "قسم المشتريات", 'resolution': "التنسيق مع المورد البديل" }, { 'id': 2, 'description': "نقص في فريق العمل", 'severity': "منخفض", 'status': "تم الحل", 'created_date': (datetime.now() - timedelta(days=15)).strftime('%Y-%m-%d'), 'responsible': "قسم الموارد البشرية", 'resolution': "تم توظيف فريق إضافي" } ], 'last_updated': datetime.now().strftime('%Y-%m-%d %H:%M:%S') } self.save_kpi_data() except Exception as e: st.error(f"خطأ في تحميل بيانات مؤشرات الأداء: {e}") self.kpi_data = { 'spi': 1.05, 'cpi': 0.98, 'quality_score': 92, 'safety_incidents': 0, 'resource_utilization': 85, 'risk_score': 15, 'customer_satisfaction': 90, 'environmental_compliance': 95, 'trends': { 'spi': [0.95, 0.98, 1.02, 1.05], 'cpi': [1.02, 1.00, 0.99, 0.98], 'quality_score': [85, 88, 90, 92], 'risk_score': [25, 22, 18, 15], 'dates': [ (datetime.now() - timedelta(days=21)).strftime('%Y-%m-%d'), (datetime.now() - timedelta(days=14)).strftime('%Y-%m-%d'), (datetime.now() - timedelta(days=7)).strftime('%Y-%m-%d'), datetime.now().strftime('%Y-%m-%d') ] }, 'issues': [ { 'id': 1, 'description': "تأخر في توريد المواد", 'severity': "متوسط", 'status': "قيد المعالجة", 'created_date': (datetime.now() - timedelta(days=10)).strftime('%Y-%m-%d'), 'responsible': "قسم المشتريات", 'resolution': "التنسيق مع المورد البديل" }, { 'id': 2, 'description': "نقص في فريق العمل", 'severity': "منخفض", 'status': "تم الحل", 'created_date': (datetime.now() - timedelta(days=15)).strftime('%Y-%m-%d'), 'responsible': "قسم الموارد البشرية", 'resolution': "تم توظيف فريق إضافي" } ], 'last_updated': datetime.now().strftime('%Y-%m-%d %H:%M:%S') } def save_kpi_data(self): """حفظ بيانات مؤشرات الأداء الرئيسية""" try: with open(self.kpi_data_file, 'w', encoding='utf-8') as f: json.dump(self.kpi_data, f, ensure_ascii=False, indent=2) except Exception as e: st.error(f"خطأ في حفظ بيانات مؤشرات الأداء: {e}") def update_project_status(self, phase_id, progress, status, actual_end_date=None, notes=None): """تحديث حالة مرحلة في المشروع""" # البحث عن المرحلة phase = next((p for p in self.project_data['phases'] if p['id'] == phase_id), None) if not phase: return False # تحديث البيانات phase['progress'] = progress phase['status'] = status if actual_end_date: phase['actual_end_date'] = actual_end_date if notes: phase['notes'] = notes # تحديث التقدم الكلي للمشروع self._update_overall_progress() # حفظ البيانات self.project_data['last_updated'] = datetime.now().strftime('%Y-%m-%d %H:%M:%S') self.save_project_data() return True def _update_overall_progress(self): """تحديث نسبة التقدم الكلية للمشروع""" total_weight = len(self.project_data['phases']) total_progress = sum(phase['progress'] for phase in self.project_data['phases']) self.project_data['overall_progress'] = round(total_progress / total_weight) # تحديث عدد الأيام المنقضية start_date = datetime.strptime(self.project_data['start_date'], '%Y-%m-%d') self.project_data['elapsed_days'] = (datetime.now() - start_date).days def add_project_issue(self, description, severity, responsible, resolution=None): """إضافة مشكلة جديدة للمشروع""" # إنشاء معرف جديد new_id = max([issue['id'] for issue in self.kpi_data['issues']], default=0) + 1 # إضافة المشكلة new_issue = { 'id': new_id, 'description': description, 'severity': severity, 'status': "قيد المعالجة", 'created_date': datetime.now().strftime('%Y-%m-%d'), 'responsible': responsible, 'resolution': resolution or "" } self.kpi_data['issues'].append(new_issue) self.kpi_data['last_updated'] = datetime.now().strftime('%Y-%m-%d %H:%M:%S') self.save_kpi_data() return new_issue def update_issue_status(self, issue_id, status, resolution=None): """تحديث حالة مشكلة في المشروع""" # البحث عن المشكلة issue = next((i for i in self.kpi_data['issues'] if i['id'] == issue_id), None) if not issue: return False # تحديث البيانات issue['status'] = status if resolution: issue['resolution'] = resolution # حفظ البيانات self.kpi_data['last_updated'] = datetime.now().strftime('%Y-%m-%d %H:%M:%S') self.save_kpi_data() return True def update_kpi_values(self, kpi_updates): """تحديث قيم مؤشرات الأداء الرئيسية""" # تحديث القيم for key, value in kpi_updates.items(): if key in self.kpi_data and key != 'trends' and key != 'issues': self.kpi_data[key] = value # تحديث الاتجاهات for key, value in kpi_updates.items(): if key in self.kpi_data and key != 'trends' and key != 'issues' and key in self.kpi_data['trends']: # إضافة القيمة الجديدة للاتجاه وحذف أقدم قيمة إذا تجاوز العدد 5 self.kpi_data['trends'][key].append(value) if len(self.kpi_data['trends'][key]) > 5: self.kpi_data['trends'][key].pop(0) # تحديث تاريخ الاتجاه today = datetime.now().strftime('%Y-%m-%d') if today not in self.kpi_data['trends']['dates']: self.kpi_data['trends']['dates'].append(today) if len(self.kpi_data['trends']['dates']) > 5: self.kpi_data['trends']['dates'].pop(0) # حفظ البيانات self.kpi_data['last_updated'] = datetime.now().strftime('%Y-%m-%d %H:%M:%S') self.save_kpi_data() return True def render_project_status_dashboard(self): """عرض لوحة تحكم حالة المشروع""" st.markdown("

متتبع حالة المشروع المتحرك

", unsafe_allow_html=True) st.markdown("""
متتبع حالة المشروع المتحرك يوفر عرضاً تفاعلياً ومرئياً لحالة المشروع ومراحله المختلفة، مع إمكانية متابعة مؤشرات الأداء الرئيسية وتتبع التقدم بشكل مباشر.
""", unsafe_allow_html=True) # عرض معلومات المشروع self._render_project_info() # عرض بطاقات مؤشرات الأداء الرئيسية self._render_kpi_cards() # عرض تقدم المشروع self._render_project_progress() # عرض نظرة عامة على المراحل self._render_phases_timeline() # عرض اتجاهات مؤشرات الأداء self._render_kpi_trends() # عرض قائمة المشكلات self._render_issues_table() # عرض لوحة تحكم تحديث حالة المشروع if st.checkbox("تحديث حالة المشروع"): self._render_update_panel() def _render_project_info(self): """عرض معلومات المشروع""" st.markdown("

معلومات المشروع

", unsafe_allow_html=True) col1, col2, col3 = st.columns([2, 1, 1]) with col1: st.markdown(f"""
{self.project_data['project_name']}
رمز المشروع: {self.project_data['project_code']}
العميل: {self.project_data['client']}
الموقع: {self.project_data['location']}
""", unsafe_allow_html=True) with col2: # حساب الأيام المتبقية end_date = datetime.strptime(self.project_data['end_date'], '%Y-%m-%d') remaining_days = (end_date - datetime.now()).days st.markdown(f"""
تاريخ البدء
{self.project_data['start_date']}
تاريخ الانتهاء
{self.project_data['end_date']}
الأيام المتبقية
{remaining_days} يوم
""", unsafe_allow_html=True) with col3: # عرض معلومات التقدم progress = self.project_data['overall_progress'] progress_color = "green" if progress >= 80 else "orange" if progress >= 50 else "red" st.markdown(f"""
التقدم الكلي
{progress}%
الميزانية
{self.project_data['budget']:,} ريال
آخر تحديث
{self.project_data['last_updated']}
""", unsafe_allow_html=True) def _render_kpi_cards(self): """عرض بطاقات مؤشرات الأداء الرئيسية""" st.markdown("

مؤشرات الأداء الرئيسية

", unsafe_allow_html=True) col1, col2, col3, col4 = st.columns(4) with col1: # مؤشر أداء الجدول الزمني (SPI) spi = self.kpi_data['spi'] spi_color = "green" if spi >= 1.0 else "red" spi_icon = "⬆️" if spi >= 1.0 else "⬇️" spi_trend = round((spi - self.kpi_data['trends']['spi'][0]) * 100, 1) st.markdown(f"""
مؤشر أداء الجدول الزمني
{spi}
{spi_icon} {spi_trend}%
""", unsafe_allow_html=True) # مؤشر درجة الجودة quality = self.kpi_data['quality_score'] quality_color = "green" if quality >= 90 else "orange" if quality >= 80 else "red" quality_icon = "⬆️" if quality >= 90 else "➡️" if quality >= 80 else "⬇️" st.markdown(f"""
درجة الجودة
{quality}%
{quality_icon} ممتاز
""", unsafe_allow_html=True) with col2: # مؤشر أداء التكلفة (CPI) cpi = self.kpi_data['cpi'] cpi_color = "green" if cpi >= 1.0 else "red" cpi_icon = "⬆️" if cpi >= 1.0 else "⬇️" cpi_trend = round((cpi - self.kpi_data['trends']['cpi'][0]) * 100, 1) st.markdown(f"""
مؤشر أداء التكلفة
{cpi}
{cpi_icon} {cpi_trend}%
""", unsafe_allow_html=True) # مؤشر درجة المخاطر risk = self.kpi_data['risk_score'] risk_color = "green" if risk < 20 else "orange" if risk < 40 else "red" risk_icon = "⬇️" if risk < 20 else "➡️" if risk < 40 else "⬆️" st.markdown(f"""
درجة المخاطر
{risk}%
{risk_icon} منخفضة
""", unsafe_allow_html=True) with col3: # مؤشر استغلال الموارد resources = self.kpi_data['resource_utilization'] resources_color = "green" if resources >= 85 else "orange" if resources >= 70 else "red" st.markdown(f"""
استغلال الموارد
{resources}%
استغلال فعال للموارد
""", unsafe_allow_html=True) # عدد حوادث السلامة safety = self.kpi_data['safety_incidents'] safety_color = "green" if safety == 0 else "orange" if safety < 3 else "red" st.markdown(f"""
حوادث السلامة
{safety}
سجل سلامة ممتاز
""", unsafe_allow_html=True) with col4: # مؤشر رضا العميل satisfaction = self.kpi_data['customer_satisfaction'] satisfaction_color = "green" if satisfaction >= 90 else "orange" if satisfaction >= 75 else "red" st.markdown(f"""
رضا العميل
{satisfaction}%
مستوى رضا ممتاز
""", unsafe_allow_html=True) # مؤشر الامتثال البيئي compliance = self.kpi_data['environmental_compliance'] compliance_color = "green" if compliance >= 90 else "orange" if compliance >= 75 else "red" st.markdown(f"""
الامتثال البيئي
{compliance}%
امتثال كامل للمعايير
""", unsafe_allow_html=True) def _render_project_progress(self): """عرض تقدم المشروع""" st.markdown("

تقدم المشروع

", unsafe_allow_html=True) # مؤشر التقدم الكلي st.markdown("
التقدم الكلي للمشروع
", unsafe_allow_html=True) # حساب النسبة المئوية للوقت المنقضي start_date = datetime.strptime(self.project_data['start_date'], '%Y-%m-%d') end_date = datetime.strptime(self.project_data['end_date'], '%Y-%m-%d') total_days = (end_date - start_date).days elapsed_days = self.project_data['elapsed_days'] time_percentage = min(100, max(0, round((elapsed_days / total_days) * 100))) # تقدم المشروع progress_percentage = self.project_data['overall_progress'] # تحديد لون التقدم progress_status = "ahead" if progress_percentage > time_percentage else "behind" if progress_percentage < time_percentage else "on-track" progress_color = "#00b894" if progress_status == "ahead" else "#d63031" if progress_status == "behind" else "#fdcb6e" # إنشاء المخطط fig = go.Figure() # إضافة خط التقدم المخطط fig.add_trace(go.Scatter( x=[start_date, end_date], y=[0, 100], mode='lines', name='التقدم المخطط', line=dict(color='rgba(0, 0, 0, 0.3)', width=2, dash='dash'), hoverinfo='text', hovertext=['بداية المشروع', 'نهاية المشروع'] )) # إضافة نقطة الوقت الحالي current_date = start_date + timedelta(days=elapsed_days) fig.add_trace(go.Scatter( x=[current_date], y=[time_percentage], mode='markers', name='الوقت المنقضي', marker=dict(color='#2d3436', size=12, symbol='diamond'), hoverinfo='text', hovertext=[f'الوقت المنقضي: {time_percentage}%'] )) # إضافة نقطة التقدم الفعلي fig.add_trace(go.Scatter( x=[current_date], y=[progress_percentage], mode='markers', name='التقدم الفعلي', marker=dict(color=progress_color, size=16, symbol='circle'), hoverinfo='text', hovertext=[f'التقدم الفعلي: {progress_percentage}%'] )) # تنسيق المخطط fig.update_layout( title=f"التقدم: {progress_percentage}% - الوقت المنقضي: {time_percentage}%", xaxis_title="التاريخ", yaxis_title="نسبة التقدم (%)", legend=dict( x=0, y=1.1, orientation='h' ), height=300, margin=dict(l=20, r=20, t=50, b=20), xaxis=dict(showgrid=False), yaxis=dict(range=[0, 100]), hovermode='closest', plot_bgcolor='rgba(255, 255, 255, 0.8)' ) st.plotly_chart(fig, use_container_width=True) # حالة التقدم status_message = "المشروع متقدم عن الجدول الزمني" if progress_status == "ahead" else "المشروع متأخر عن الجدول الزمني" if progress_status == "behind" else "المشروع في الموعد المحدد" status_color = "green" if progress_status == "ahead" else "red" if progress_status == "behind" else "orange" st.markdown(f"""
{status_message} (الفرق: {abs(progress_percentage - time_percentage)}%)
""", unsafe_allow_html=True) # تحليل المراحل st.markdown("
تقدم مراحل المشروع
", unsafe_allow_html=True) # ترتيب المراحل sorted_phases = sorted(self.project_data['phases'], key=lambda x: x['order']) # إنشاء بيانات للرسم البياني phase_labels = [phase['name'] for phase in sorted_phases] phase_progress = [phase['progress'] for phase in sorted_phases] phase_colors = [ "#00b894" if phase['status'] == "completed" else "#fdcb6e" if phase['status'] == "in_progress" else "#d63031" if phase['status'] == "delayed" else "#a29bfe" if phase['status'] == "on_hold" else "#dfe6e9" # لحالة not_started for phase in sorted_phases ] # إنشاء الرسم البياني fig = go.Figure() fig.add_trace(go.Bar( y=phase_labels, x=phase_progress, orientation='h', marker=dict( color=phase_colors ), hoverinfo='text', hovertext=[f"{phase['name']}: {phase['progress']}% - {self._get_status_text(phase['status'])}" for phase in sorted_phases] )) fig.update_layout( title="تقدم مراحل المشروع", xaxis_title="نسبة التقدم (%)", yaxis=dict( categoryorder='array', categoryarray=phase_labels ), xaxis=dict(range=[0, 100]), height=400, margin=dict(l=20, r=20, t=50, b=20), plot_bgcolor='rgba(255, 255, 255, 0.8)' ) st.plotly_chart(fig, use_container_width=True) # وضع مفتاح الألوان col1, col2, col3, col4, col5 = st.columns(5) with col1: st.markdown('
مكتمل
', unsafe_allow_html=True) with col2: st.markdown('
قيد التنفيذ
', unsafe_allow_html=True) with col3: st.markdown('
متأخر
', unsafe_allow_html=True) with col4: st.markdown('
متوقف
', unsafe_allow_html=True) with col5: st.markdown('
لم يبدأ
', unsafe_allow_html=True) def _render_phases_timeline(self): """عرض الجدول الزمني للمراحل""" st.markdown("

الجدول الزمني للمراحل

", unsafe_allow_html=True) # ترتيب المراحل sorted_phases = sorted(self.project_data['phases'], key=lambda x: x['order']) # تحويل التواريخ إلى كائنات datetime for phase in sorted_phases: phase['start_date_obj'] = datetime.strptime(phase['start_date'], '%Y-%m-%d') phase['end_date_obj'] = datetime.strptime(phase['end_date'], '%Y-%m-%d') if phase['actual_end_date']: phase['actual_end_date_obj'] = datetime.strptime(phase['actual_end_date'], '%Y-%m-%d') else: phase['actual_end_date_obj'] = None # إيجاد أدنى وأقصى تاريخ min_date = min(phase['start_date_obj'] for phase in sorted_phases) max_date = max(phase['end_date_obj'] for phase in sorted_phases) # إضافة هامش date_range = (max_date - min_date).days min_date = min_date - timedelta(days=date_range * 0.05) max_date = max_date + timedelta(days=date_range * 0.05) # إنشاء الرسم البياني fig = go.Figure() # إضافة خط الوقت الحالي current_date = datetime.now() fig.add_shape( type="line", x0=current_date, y0=-0.5, x1=current_date, y1=len(sorted_phases) - 0.5, line=dict( color="red", width=2, dash="dash", ), name="اليوم" ) # إضافة المراحل for i, phase in enumerate(sorted_phases): # إضافة المرحلة المخططة fig.add_trace(go.Bar( x=[phase['end_date_obj'] - phase['start_date_obj']], y=[phase['name']], orientation='h', base=[phase['start_date_obj']], marker=dict( color='rgba(171, 214, 255, 0.8)', line=dict(color='rgba(50, 136, 229, 1.0)', width=1) ), name=phase['name'] + " (مخطط)", hoverinfo='text', hovertext=[f"{phase['name']} (مخطط)
البداية: {phase['start_date']}
النهاية: {phase['end_date']}
المدة: {(phase['end_date_obj'] - phase['start_date_obj']).days} يوم"] )) # تحديد لون المرحلة الفعلية if phase['status'] == "completed": color = 'rgba(0, 184, 148, 0.8)' line_color = 'rgba(0, 150, 136, 1.0)' elif phase['status'] == "in_progress": color = 'rgba(253, 203, 110, 0.8)' line_color = 'rgba(225, 177, 44, 1.0)' elif phase['status'] == "delayed": color = 'rgba(214, 48, 49, 0.8)' line_color = 'rgba(192, 57, 43, 1.0)' elif phase['status'] == "on_hold": color = 'rgba(162, 155, 254, 0.8)' line_color = 'rgba(108, 92, 231, 1.0)' else: # not_started continue # لا نعرض المراحل التي لم تبدأ بعد # إضافة المرحلة الفعلية if phase['status'] in ["completed", "in_progress", "delayed", "on_hold"]: if phase['status'] == "completed" and phase['actual_end_date_obj']: # للمراحل المكتملة التي لها تاريخ انتهاء فعلي duration = phase['actual_end_date_obj'] - phase['start_date_obj'] fig.add_trace(go.Bar( x=[duration], y=[phase['name']], orientation='h', base=[phase['start_date_obj']], marker=dict( color=color, line=dict(color=line_color, width=1) ), name=phase['name'] + " (فعلي)", hoverinfo='text', hovertext=[f"{phase['name']} (فعلي)
البداية: {phase['start_date']}
النهاية الفعلية: {phase['actual_end_date']}
المدة: {duration.days} يوم
التقدم: {phase['progress']}%"] )) else: # للمراحل الجارية أو المتأخرة أو المعلقة if current_date > phase['start_date_obj']: duration = current_date - phase['start_date_obj'] fig.add_trace(go.Bar( x=[duration], y=[phase['name']], orientation='h', base=[phase['start_date_obj']], marker=dict( color=color, line=dict(color=line_color, width=1) ), name=phase['name'] + " (فعلي)", hoverinfo='text', hovertext=[f"{phase['name']} (فعلي)
البداية: {phase['start_date']}
حتى تاريخه: {current_date.strftime('%Y-%m-%d')}
المدة: {duration.days} يوم
التقدم: {phase['progress']}%"] )) # تنسيق المخطط fig.update_layout( title="الجدول الزمني للمراحل", xaxis=dict(type='date', range=[min_date, max_date], title='التاريخ'), yaxis=dict(title=None, autorange="reversed"), height=400, margin=dict(l=20, r=20, t=50, b=20), barmode='overlay', legend=dict(orientation='h', yanchor='bottom', y=1.02, xanchor='right', x=1), plot_bgcolor='rgba(255, 255, 255, 0.8)' ) st.plotly_chart(fig, use_container_width=True) # عرض تفاصيل المراحل with st.expander("عرض تفاصيل المراحل"): for phase in sorted_phases: status_class = self._get_status_class(phase['status']) status_text = self._get_status_text(phase['status']) critical_badge = 'مسار حرج' if phase.get('critical', False) else '' st.markdown(f"""
{phase['name']} {critical_badge}
{status_text}
{phase['progress']}%
البداية: {phase['start_date']}
النهاية (مخطط): {phase['end_date']}
{f'
النهاية (فعلي): {phase["actual_end_date"]}
' if phase['actual_end_date'] else ''}
المسؤول: {phase['responsible']}
التسليمات: {', '.join(phase['deliverables'])}
{phase['notes']}
""", unsafe_allow_html=True) def _render_kpi_trends(self): """عرض اتجاهات مؤشرات الأداء الرئيسية""" st.markdown("

اتجاهات مؤشرات الأداء

", unsafe_allow_html=True) tabs = st.tabs(["أداء الجدول الزمني والتكلفة", "الجودة والمخاطر"]) with tabs[0]: # تحويل البيانات dates = [datetime.strptime(date, '%Y-%m-%d') for date in self.kpi_data['trends']['dates']] spi_values = self.kpi_data['trends']['spi'] cpi_values = self.kpi_data['trends']['cpi'] # إنشاء رسم بياني لمؤشر أداء الجدول الزمني والتكلفة fig = go.Figure() # مؤشر أداء الجدول الزمني fig.add_trace(go.Scatter( x=dates, y=spi_values, mode='lines+markers', name='مؤشر أداء الجدول الزمني (SPI)', line=dict(color='#00b894', width=2), marker=dict(size=8) )) # مؤشر أداء التكلفة fig.add_trace(go.Scatter( x=dates, y=cpi_values, mode='lines+markers', name='مؤشر أداء التكلفة (CPI)', line=dict(color='#0984e3', width=2), marker=dict(size=8) )) # إضافة خط المرجع (1.0) fig.add_shape( type="line", x0=min(dates), y0=1.0, x1=max(dates), y1=1.0, line=dict( color="#636e72", width=1, dash="dash", ) ) # تنسيق الرسم البياني fig.update_layout( title="اتجاهات مؤشرات أداء الجدول الزمني والتكلفة", xaxis_title="التاريخ", yaxis_title="القيمة", legend=dict(orientation='h', yanchor='bottom', y=1.02, xanchor='right', x=1), height=350, margin=dict(l=20, r=20, t=50, b=20), yaxis=dict(range=[0.8, 1.2], zeroline=False), hovermode='x unified', plot_bgcolor='rgba(255, 255, 255, 0.8)' ) fig.update_yaxes(tickformat=".2f") st.plotly_chart(fig, use_container_width=True) # شرح المؤشرات col1, col2 = st.columns(2) with col1: st.markdown("""

مؤشر أداء الجدول الزمني (SPI)

""", unsafe_allow_html=True) with col2: st.markdown("""

مؤشر أداء التكلفة (CPI)

""", unsafe_allow_html=True) with tabs[1]: # تحويل البيانات dates = [datetime.strptime(date, '%Y-%m-%d') for date in self.kpi_data['trends']['dates']] quality_values = self.kpi_data['trends']['quality_score'] risk_values = self.kpi_data['trends']['risk_score'] # إنشاء رسم بياني للجودة والمخاطر fig = go.Figure() # مؤشر الجودة fig.add_trace(go.Scatter( x=dates, y=quality_values, mode='lines+markers', name='درجة الجودة (%)', line=dict(color='#00b894', width=2), marker=dict(size=8) )) # إنشاء محور Y ثانوي للمخاطر fig.add_trace(go.Scatter( x=dates, y=risk_values, mode='lines+markers', name='درجة المخاطر (%)', line=dict(color='#d63031', width=2), marker=dict(size=8), yaxis="y2" )) # تنسيق الرسم البياني fig.update_layout( title="اتجاهات الجودة والمخاطر", xaxis_title="التاريخ", yaxis=dict( title="درجة الجودة (%)", range=[0, 100], side="left", zeroline=False ), yaxis2=dict( title="درجة المخاطر (%)", range=[0, 100], side="right", overlaying="y", zeroline=False ), legend=dict(orientation='h', yanchor='bottom', y=1.02, xanchor='right', x=1), height=350, margin=dict(l=20, r=20, t=50, b=20), hovermode='x unified', plot_bgcolor='rgba(255, 255, 255, 0.8)' ) st.plotly_chart(fig, use_container_width=True) # شرح المؤشرات col1, col2 = st.columns(2) with col1: st.markdown("""

درجة الجودة

""", unsafe_allow_html=True) with col2: st.markdown("""

درجة المخاطر

""", unsafe_allow_html=True) def _render_issues_table(self): """عرض جدول المشكلات""" st.markdown("

مشكلات المشروع

", unsafe_allow_html=True) if not self.kpi_data['issues']: st.info("لا توجد مشكلات مسجلة للمشروع.") return # تحويل المشكلات إلى DataFrame issues_data = pd.DataFrame(self.kpi_data['issues']) # تنسيق الجدول st.markdown(""" """, unsafe_allow_html=True) # قائمة المشكلات for issue in self.kpi_data['issues']: # تحديد فئة الخطورة severity_class = "" if issue['severity'] == "عالي": severity_class = "high" elif issue['severity'] == "متوسط": severity_class = "medium" else: severity_class = "low" # تحديد فئة الحالة status_class = "" if issue['status'] == "تم الحل": status_class = "resolved" elif issue['status'] == "قيد المعالجة": status_class = "in-progress" elif issue['status'] == "معلق": status_class = "on-hold" else: status_class = "open" st.markdown(f"""
#{issue['id']} - {issue['description']}
{issue['severity']} {issue['status']}
تاريخ الإنشاء: {issue['created_date']}
المسؤول: {issue['responsible']}
خطة المعالجة: {issue['resolution']}
""", unsafe_allow_html=True) if st.checkbox("إضافة مشكلة جديدة"): with st.form("add_issue_form"): description = st.text_input("وصف المشكلة") col1, col2 = st.columns(2) with col1: severity = st.selectbox("الخطورة", ["منخفض", "متوسط", "عالي"]) with col2: responsible = st.text_input("المسؤول") resolution = st.text_area("خطة المعالجة") submitted = st.form_submit_button("إضافة المشكلة") if submitted: if description and responsible: self.add_project_issue(description, severity, responsible, resolution) st.success("تمت إضافة المشكلة بنجاح") st.rerun() else: st.error("يرجى ملء جميع الحقول المطلوبة") def _render_update_panel(self): """عرض لوحة تحديث حالة المشروع""" st.markdown("

تحديث حالة المشروع

", unsafe_allow_html=True) tabs = st.tabs(["تحديث مرحلة", "تحديث مؤشرات الأداء", "تحديث حالة مشكلة"]) with tabs[0]: # تحديث مرحلة sorted_phases = sorted(self.project_data['phases'], key=lambda x: x['order']) phase_names = [phase['name'] for phase in sorted_phases] phase_ids = [phase['id'] for phase in sorted_phases] selected_phase_index = st.selectbox("اختر المرحلة", range(len(phase_names)), format_func=lambda i: phase_names[i]) selected_phase = sorted_phases[selected_phase_index] with st.form("update_phase_form"): st.markdown(f"**تحديث مرحلة: {selected_phase['name']}**") col1, col2 = st.columns(2) with col1: progress = st.slider("نسبة التقدم", 0, 100, selected_phase['progress']) with col2: status = st.selectbox("الحالة", [ "not_started", "in_progress", "completed", "delayed", "on_hold" ], index=["not_started", "in_progress", "completed", "delayed", "on_hold"].index(selected_phase['status']), format_func=lambda s: self._get_status_text(s)) actual_end_date = None if status == "completed": actual_end_date = st.date_input("تاريخ الانتهاء الفعلي", value=datetime.now() if not selected_phase['actual_end_date'] else datetime.strptime(selected_phase['actual_end_date'], '%Y-%m-%d')) actual_end_date = actual_end_date.strftime('%Y-%m-%d') notes = st.text_area("ملاحظات", selected_phase['notes']) submitted = st.form_submit_button("تحديث المرحلة") if submitted: success = self.update_project_status(selected_phase['id'], progress, status, actual_end_date, notes) if success: st.success("تم تحديث حالة المرحلة بنجاح") st.rerun() else: st.error("حدث خطأ أثناء تحديث حالة المرحلة") with tabs[1]: # تحديث مؤشرات الأداء with st.form("update_kpi_form"): st.markdown("**تحديث مؤشرات الأداء**") col1, col2 = st.columns(2) with col1: spi = st.number_input("مؤشر أداء الجدول الزمني (SPI)", 0.1, 2.0, self.kpi_data['spi'], 0.01) cpi = st.number_input("مؤشر أداء التكلفة (CPI)", 0.1, 2.0, self.kpi_data['cpi'], 0.01) quality_score = st.slider("درجة الجودة", 0, 100, self.kpi_data['quality_score']) risk_score = st.slider("درجة المخاطر", 0, 100, self.kpi_data['risk_score']) with col2: resource_utilization = st.slider("استغلال الموارد", 0, 100, self.kpi_data['resource_utilization']) safety_incidents = st.number_input("حوادث السلامة", 0, 100, self.kpi_data['safety_incidents']) customer_satisfaction = st.slider("رضا العميل", 0, 100, self.kpi_data['customer_satisfaction']) environmental_compliance = st.slider("الامتثال البيئي", 0, 100, self.kpi_data['environmental_compliance']) submitted = st.form_submit_button("تحديث مؤشرات الأداء") if submitted: kpi_updates = { 'spi': spi, 'cpi': cpi, 'quality_score': quality_score, 'risk_score': risk_score, 'resource_utilization': resource_utilization, 'safety_incidents': safety_incidents, 'customer_satisfaction': customer_satisfaction, 'environmental_compliance': environmental_compliance } success = self.update_kpi_values(kpi_updates) if success: st.success("تم تحديث مؤشرات الأداء بنجاح") st.rerun() else: st.error("حدث خطأ أثناء تحديث مؤشرات الأداء") with tabs[2]: # تحديث حالة مشكلة if not self.kpi_data['issues']: st.info("لا توجد مشكلات لتحديثها.") else: issue_descriptions = [f"#{issue['id']} - {issue['description']}" for issue in self.kpi_data['issues']] issue_ids = [issue['id'] for issue in self.kpi_data['issues']] selected_issue_index = st.selectbox("اختر المشكلة", range(len(issue_descriptions)), format_func=lambda i: issue_descriptions[i]) selected_issue = self.kpi_data['issues'][selected_issue_index] with st.form("update_issue_form"): st.markdown(f"**تحديث حالة المشكلة: {selected_issue['description']}**") status = st.selectbox("الحالة", [ "مفتوح", "قيد المعالجة", "تم الحل", "معلق" ], index=["مفتوح", "قيد المعالجة", "تم الحل", "معلق"].index(selected_issue['status']) if selected_issue['status'] in ["مفتوح", "قيد المعالجة", "تم الحل", "معلق"] else 0) resolution = st.text_area("خطة المعالجة / الحل", selected_issue['resolution']) submitted = st.form_submit_button("تحديث المشكلة") if submitted: success = self.update_issue_status(selected_issue['id'], status, resolution) if success: st.success("تم تحديث حالة المشكلة بنجاح") st.rerun() else: st.error("حدث خطأ أثناء تحديث حالة المشكلة") def _get_status_text(self, status): """الحصول على النص العربي لحالة المرحلة""" status_map = { "not_started": "لم تبدأ", "in_progress": "قيد التنفيذ", "completed": "مكتملة", "delayed": "متأخرة", "on_hold": "متوقفة" } return status_map.get(status, status) def _get_status_class(self, status): """الحصول على فئة CSS لحالة المرحلة""" status_map = { "not_started": "not-started", "in_progress": "in-progress", "completed": "completed", "delayed": "delayed", "on_hold": "on-hold" } return status_map.get(status, "") def render(self): """عرض واجهة متتبع حالة المشروع""" # إضافة CSS مخصص st.markdown(""" """, unsafe_allow_html=True) # عرض لوحة تحكم حالة المشروع self.render_project_status_dashboard()