Create supply_chain/suppliers_database.py

supply_chain/suppliers_database.py

@@ -0,0 +1,534 @@
+"""
+قاعدة بيانات الموردين المحليين
+يوفر واجهة للوصول إلى بيانات الموردين والمنتجات المحلية
+"""
+
+import json
+import logging
+import os
+import re
+from typing import Dict, List, Any, Tuple, Optional, Union
+from collections import defaultdict
+
+logger = logging.getLogger(__name__)
+
+class SuppliersDatabase:
+    """
+    قاعدة بيانات الموردين المحليين
+    """
+    
+    def __init__(self, config=None):
+        """
+        تهيئة قاعدة بيانات الموردين
+        
+        المعاملات:
+        ----------
+        config : Dict, optional
+            إعدادات قاعدة البيانات
+        """
+        self.config = config or {}
+        
+        # تحميل بيانات الموردين
+        self.suppliers = self._load_suppliers()
+        
+        # تحميل بيانات المنتجات
+        self.products = self._load_products()
+        
+        # تهيئة فهارس البحث
+        self._initialize_indexes()
+        
+        logger.info(f"تم تهيئة قاعدة بيانات الموردين: {len(self.suppliers)} مورد")
+    
+    def search_suppliers(self, query: str, category: Optional[str] = None) -> List[Dict[str, Any]]:
+        """
+        البحث عن الموردين
+        
+        المعاملات:
+        ----------
+        query : str
+            استعلام البحث
+        category : str, optional
+            فئة المورد
+            
+        المخرجات:
+        --------
+        List[Dict[str, Any]]
+            قائمة الموردين المطابقين
+        """
+        results = []
+        
+        # تنظيف الاستعلام
+        query = query.lower().strip()
+        
+        # البحث عن الموردين المطابقين
+        for supplier in self.suppliers:
+            # التحقق من الفئة إذا تم تحديدها
+            if category and category != "الكل" and supplier.get("category") != category:
+                continue
+            
+            # البحث في اسم المورد
+            if query in supplier.get("name", "").lower():
+                results.append(supplier)
+                continue
+            
+            # البحث في المنطقة
+            if query in supplier.get("region", "").lower():
+                results.append(supplier)
+                continue
+            
+            # البحث في المنتجات
+            if any(query in product.lower() for product in supplier.get("products", [])):
+                results.append(supplier)
+                continue
+        
+        return results
+    
+    def find_matching_suppliers(self, materials: List[Dict[str, Any]]) -> Dict[str, Any]:
+        """
+        البحث عن الموردين المطابقين للمواد المطلوبة
+        
+        المعاملات:
+        ----------
+        materials : List[Dict[str, Any]]
+            قائمة المواد المطلوبة
+            
+        المخرجات:
+        --------
+        Dict[str, Any]
+            نتائج البحث
+        """
+        results = {
+            "local_suppliers": [],
+            "material_coverage": {},
+            "region_distribution": {},
+            "summary": {}
+        }
+        
+        material_suppliers = {}
+        all_matching_suppliers = []
+        
+        # البحث عن الموردين المطابقين لكل مادة
+        for material in materials:
+            material_name = material.get("name", "")
+            if not material_name:
+                continue
+            
+            # البحث عن المنتجات المطابقة
+            matching_products = []
+            for product_id, product in self.products.items():
+                similarity = self._calculate_similarity(material_name, product.get("name", ""))
+                if similarity > 0.7:  # عتبة التشابه
+                    matching_products.append((product_id, similarity))
+            
+            # ترتيب المنتجات حسب التشابه
+            matching_products.sort(key=lambda x: x[1], reverse=True)
+            
+            # البحث عن الموردين لهذه المنتجات
+            suppliers_for_material = []
+            for product_id, similarity in matching_products[:5]:  # أفضل 5 منتجات
+                product_suppliers = self.product_suppliers.get(product_id, [])
+                for supplier_id in product_suppliers:
+                    supplier = next((s for s in self.suppliers if s.get("id") == supplier_id), None)
+                    if supplier:
+                        suppliers_for_material.append(supplier)
+                        all_matching_suppliers.append(supplier)
+            
+            # إزالة التكرارات
+            unique_suppliers = []
+            supplier_ids = set()
+            for supplier in suppliers_for_material:
+                supplier_id = supplier.get("id")
+                if supplier_id not in supplier_ids:
+                    supplier_ids.add(supplier_id)
+                    unique_suppliers.append(supplier)
+            
+            # تخزين الموردين لهذه المادة
+            material_suppliers[material_name] = unique_suppliers
+            
+            # حساب نسبة التغطية
+            coverage = min(100.0, len(unique_suppliers) * 20.0)  # كل مورد يغطي 20% بحد أقصى 100%
+            results["material_coverage"][material_name] = coverage
+        
+        # إزالة التكرارات من قائمة الموردين
+        unique_matching_suppliers = []
+        supplier_ids = set()
+        for supplier in all_matching_suppliers:
+            supplier_id = supplier.get("id")
+            if supplier_id not in supplier_ids:
+                supplier_ids.add(supplier_id)
+                
+                # إضافة معلومات المواد التي يوفرها المورد
+                supplier_materials = []
+                for material_name, suppliers in material_suppliers.items():
+                    if any(s.get("id") == supplier_id for s in suppliers):
+                        supplier_materials.append(material_name)
+                
+                supplier_copy = supplier.copy()
+                supplier_copy["materials"] = supplier_materials
+                
+                unique_matching_suppliers.append(supplier_copy)
+        
+        # ترتيب الموردين حسب عدد المواد وتصنيف الموثوقية
+        unique_matching_suppliers.sort(
+            key=lambda s: (len(s.get("materials", [])), s.get("reliability", 0)),
+            reverse=True
+        )
+        
+        # إضافة الموردين المطابقين
+        results["local_suppliers"] = unique_matching_suppliers
+        
+        # حساب توزيع المناطق
+        region_counts = defaultdict(int)
+        for supplier in unique_matching_suppliers:
+            region = supplier.get("region", "غير محدد")
+            region_counts[region] += 1
+        
+        results["region_distribution"] = dict(region_counts)
+        
+        # إعداد ملخص
+        results["summary"] = {
+            "total_materials": len(materials),
+            "materials_with_suppliers": len(material_suppliers),
+            "total_matching_suppliers": len(unique_matching_suppliers),
+            "average_coverage": sum(results["material_coverage"].values()) / max(1, len(results["material_coverage"]))
+        }
+        
+        return results
+    
+    def get_total_suppliers(self) -> int:
+        """
+        الحصول على إجمالي عدد الموردين
+        
+        المخرجات:
+        --------
+        int
+            إجمالي عدد الموردين
+        """
+        return len(self.suppliers)
+    
+    def get_total_products(self) -> int:
+        """
+        الحصول على إجمالي عدد المنتجات
+        
+        المخرجات:
+        --------
+        int
+            إجمالي عدد المنتجات
+        """
+        return len(self.products)
+    
+    def get_covered_regions(self) -> int:
+        """
+        الحصول على عدد المناطق المغطاة
+        
+        المخرجات:
+        --------
+        int
+            عدد المناطق المغطاة
+        """
+        regions = set(supplier.get("region", "") for supplier in self.suppliers if supplier.get("region"))
+        return len(regions)
+    
+    def get_suppliers_by_region(self) -> Dict[str, int]:
+        """
+        الحصول على توزيع الموردين حسب المنطقة
+        
+        المخرجات:
+        --------
+        Dict[str, int]
+            توزيع الموردين حسب المنطقة
+        """
+        region_counts = defaultdict(int)
+        for supplier in self.suppliers:
+            region = supplier.get("region", "غير محدد")
+            region_counts[region] += 1
+        
+        return dict(region_counts)
+    
+    def get_suppliers_by_category(self) -> Dict[str, int]:
+        """
+        الحصول على توزيع الموردين حسب الفئة
+        
+        المخرجات:
+        --------
+        Dict[str, int]
+            توزيع الموردين حسب الفئة
+        """
+        category_counts = defaultdict(int)
+        for supplier in self.suppliers:
+            category = supplier.get("category", "غير محدد")
+            category_counts[category] += 1
+        
+        return dict(category_counts)
+    
+    def _load_suppliers(self) -> List[Dict[str, Any]]:
+        """
+        تحميل بيانات الموردين
+        
+        المخرجات:
+        --------
+        List[Dict[str, Any]]
+            بيانات الموردين
+        """
+        try:
+            file_path = 'data/templates/local_suppliers.json'
+            if os.path.exists(file_path):
+                with open(file_path, 'r', encoding='utf-8') as f:
+                    suppliers = json.load(f)
+                
+                # إضافة معرف فريد لكل مورد إذا لم يكن موجودًا
+                for i, supplier in enumerate(suppliers):
+                    if "id" not in supplier:
+                        supplier["id"] = f"S{i+1:04d}"
+                
+                return suppliers
+            else:
+                logger.warning(f"ملف بيانات الموردين غير موجود: {file_path}")
+                # إنشاء بيانات افتراضية
+                return self._create_default_suppliers()
+        except Exception as e:
+            logger.error(f"فشل في تحميل بيانات الموردين: {str(e)}")
+            return self._create_default_suppliers()
+    
+    def _load_products(self) -> Dict[str, Dict[str, Any]]:
+        """
+        تحميل بيانات المنتجات
+        
+        المخرجات:
+        --------
+        Dict[str, Dict[str, Any]]
+            بيانات المنتجات
+        """
+        try:
+            file_path = 'data/templates/local_materials.json'
+            if os.path.exists(file_path):
+                with open(file_path, 'r', encoding='utf-8') as f:
+                    materials = json.load(f)
+                
+                products = {}
+                for i, material in enumerate(materials):
+                    product_id = f"P{i+1:04d}"
+                    products[product_id] = {
+                        "id": product_id,
+                        "name": material.get("name", ""),
+                        "category": material.get("category", ""),
+                        "availability_percentage": material.get("availability_percentage", 0)
+                    }
+                
+                return products
+            else:
+                logger.warning(f"ملف بيانات المنتجات غير موجود: {file_path}")
+                # إنشاء بيانات افتراضية
+                return self._create_default_products()
+        except Exception as e:
+            logger.error(f"فشل في تحميل بيانات المنتجات: {str(e)}")
+            return self._create_default_products()
+    
+    def _initialize_indexes(self):
+        """
+        تهيئة فهارس البحث
+        """
+        # إنشاء فهرس للمنتجات حسب المورد
+        self.supplier_products = defaultdict(list)
+        
+        # إنشاء فهرس للموردين حسب المنتج
+        self.product_suppliers = defaultdict(list)
+        
+        # ربط المنتجات بالموردين
+        for supplier in self.suppliers:
+            supplier_id = supplier.get("id")
+            supplier_products = supplier.get("products", [])
+            
+            for product_name in supplier_products:
+                # البحث عن المنتج المطابق
+                matching_product_id = None
+                best_similarity = 0
+                
+                for product_id, product in self.products.items():
+                    similarity = self._calculate_similarity(product_name, product.get("name", ""))
+                    if similarity > 0.7 and similarity > best_similarity:  # عتبة التشابه
+                        best_similarity = similarity
+                        matching_product_id = product_id
+                
+                if matching_product_id:
+                    self.supplier_products[supplier_id].append(matching_product_id)
+                    self.product_suppliers[matching_product_id].append(supplier_id)
+    
+    def _calculate_similarity(self, str1: str, str2: str) -> float:
+        """
+        حساب درجة التشابه بين سلسلتين
+        
+        المعاملات:
+        ----------
+        str1 : str
+            السلسلة الأولى
+        str2 : str
+            السلسلة الثانية
+            
+        المخرجات:
+        --------
+        float
+            درجة التشابه (0 إلى 1)
+        """
+        # تنظيف السلاسل
+        str1 = str1.lower().strip()
+        str2 = str2.lower().strip()
+        
+        # تحويل السلاسل إلى مجموعات من الكلمات
+        words1 = set(str1.split())
+        words2 = set(str2.split())
+        
+        # حساب معامل جاكارد
+        intersection = len(words1.intersection(words2))
+        union = len(words1.union(words2))
+        
+        if union == 0:
+            return 0.0
+        
+        return intersection / union
+    
+    def _create_default_suppliers(self) -> List[Dict[str, Any]]:
+        """
+        إنشاء بيانات افتراضية للموردين
+        
+        المخرجات:
+        --------
+        List[Dict[str, Any]]
+            بيانات افتراضية للموردين
+        """
+        return [
+            {
+                "id": "S0001",
+                "name": "شركة الراجحي للحديد",
+                "region": "الرياض",
+                "category": "مواد بناء",
+                "products": ["حديد تسليح", "حديد مجلفن"],
+                "reliability": 4.5,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر مرتفع"
+            },
+            {
+                "id": "S0004",
+                "name": "شركة الزامل للتكييف",
+                "region": "الدمام",
+                "category": "تكييف",
+                "products": ["وحدات تكييف", "معدات تبريد", "أجهزة تهوية"],
+                "reliability": 4.8,
+                "contact": "[email protected]",
+                "nitaqat_category": "بلاتيني"
+            },
+            {
+                "id": "S0005",
+                "name": "شركة امجاد للسباكة",
+                "region": "الرياض",
+                "category": "سباكة",
+                "products": ["أنابيب مياه", "خزانات مياه", "مواسير صرف"],
+                "reliability": 3.9,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر متوسط"
+            },
+            {
+                "id": "S0006",
+                "name": "مصنع الخليج للزجاج",
+                "region": "جدة",
+                "category": "مواد بناء",
+                "products": ["زجاج", "ألواح زجاجية", "واجهات زجاجية"],
+                "reliability": 4.0,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر مرتفع"
+            },
+            {
+                "id": "S0007",
+                "name": "مؤسسة الديار للدهانات",
+                "region": "الرياض",
+                "category": "مواد بناء",
+                "products": ["دهانات", "طلاء جدران", "عوازل"],
+                "reliability": 3.7,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر منخفض"
+            },
+            {
+                "id": "S0008",
+                "name": "شركة الأثاث المكتبي المتحدة",
+                "region": "الرياض",
+                "category": "أثاث",
+                "products": ["أثاث مكتبي", "كراسي", "طاولات", "خزائن"],
+                "reliability": 4.1,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر مرتفع"
+            },
+            {
+                "id": "S0009",
+                "name": "شركة ابن غنيم للنجارة",
+                "region": "الدمام",
+                "category": "نجارة",
+                "products": ["أبواب خشبية", "نوافذ خشبية", "أثاث منزلي"],
+                "reliability": 4.3,
+                "contact": "[email protected]",
+                "nitaqat_category": "أخضر مرتفع"
+            },
+            {
+                "id": "S0010",
+                "name": "الشركة العربية للألمنيوم",
+                "region": "جدة",
+                "category": "ألمنيوم",
+                "products": ["نوافذ ألمنيوم", "أبواب ألمنيوم", "واجهات ألمنيوم"],
+                "reliability": 4.4,
+                "contact": "[email protected]",
+                "nitaqat_category": "بلاتيني"
+            }
+        ]
+    
+    def _create_default_products(self) -> Dict[str, Dict[str, Any]]:
+        """
+        إنشاء بيانات افتراضية للمنتجات
+        
+        المخرجات:
+        --------
+        Dict[str, Dict[str, Any]]
+            بيانات افتراضية للمنتجات
+        """
+        products = {
+            "P0001": {"id": "P0001", "name": "حديد تسليح", "category": "مواد بناء", "availability_percentage": 90.0},
+            "P0002": {"id": "P0002", "name": "أسمنت", "category": "مواد بناء", "availability_percentage": 95.0},
+            "P0003": {"id": "P0003", "name": "خرسانة جاهزة", "category": "مواد بناء", "availability_percentage": 100.0},
+            "P0004": {"id": "P0004", "name": "بلاط", "category": "مواد بناء", "availability_percentage": 80.0},
+            "P0005": {"id": "P0005", "name": "رخام", "category": "مواد بناء", "availability_percentage": 60.0},
+            "P0006": {"id": "P0006", "name": "دهانات", "category": "مواد بناء", "availability_percentage": 75.0},
+            "P0007": {"id": "P0007", "name": "زجاج", "category": "مواد بناء", "availability_percentage": 50.0},
+            "P0008": {"id": "P0008", "name": "أسلاك كهربائية", "category": "كهرباء", "availability_percentage": 60.0},
+            "P0009": {"id": "P0009", "name": "لوحات كهربائية", "category": "كهرباء", "availability_percentage": 55.0},
+            "P0010": {"id": "P0010", "name": "مفاتيح كهربائية", "category": "كهرباء", "availability_percentage": 45.0},
+            "P0011": {"id": "P0011", "name": "أنابيب مياه", "category": "سباكة", "availability_percentage": 70.0},
+            "P0012": {"id": "P0012", "name": "خزانات مياه", "category": "سباكة", "availability_percentage": 95.0},
+            "P0013": {"id": "P0013", "name": "مواسير صرف", "category": "سباكة", "availability_percentage": 85.0},
+            "P0014": {"id": "P0014", "name": "وحدات تكييف", "category": "تكييف", "availability_percentage": 30.0},
+            "P0015": {"id": "P0015", "name": "معدات تبريد", "category": "تكييف", "availability_percentage": 25.0},
+            "P0016": {"id": "P0016", "name": "أجهزة تهوية", "category": "تكييف", "availability_percentage": 40.0},
+            "P0017": {"id": "P0017", "name": "أثاث مكتبي", "category": "أثاث", "availability_percentage": 70.0},
+            "P0018": {"id": "P0018", "name": "أثاث منزلي", "category": "أثاث", "availability_percentage": 65.0},
+            "P0019": {"id": "P0019", "name": "أبواب خشبية", "category": "نجارة", "availability_percentage": 80.0},
+            "P0020": {"id": "P0020", "name": "نوافذ ألمنيوم", "category": "ألمنيوم", "availability_percentage": 75.0}
+        }
+        
+        return productsrajhi-steel.sa",
+                "nitaqat_category": "بلاتيني"
+            },
+            {
+                "id": "S0002",
+                "name": "اسمنت اليمامة",
+                "region": "الرياض",
+                "category": "مواد بناء",
+                "products": ["أسمنت", "خرسانة جاهزة"],
+                "reliability": 4.7,
+                "contact": "[email protected]",
+                "nitaqat_category": "بلاتيني"
+            },
+            {
+                "id": "S0003",
+                "name": "الشركة السعودية للصناعات الكهربائية",
+                "region": "جدة",
+                "category": "كهرباء",
+                "products": ["أسلاك كهربائية", "لوحات كهربائية", "مفاتيح كهربائية"],
+                "reliability": 4.2,
+                "contact": "info@