Update supabase_utils.py

supabase_utils.py

@@ -53,33 +53,43 @@ def save_law_to_supabase(law_json: dict):
         raise Exception(f"❌ فشل إدراج/تحديث القانون: {title}")
 
     # -------------------------------
-    # 2) UPSERT الأقسام
+    # 2) إدخال الأقسام (insert عادي مع التحقق)
     # -------------------------------
     for sec in sections:
         sec_title = sec.get("title", "")
         sec_content = sec.get("content", "")
         sec_tables = sec.get("tables", [])
 
-        res_sec = (
-    supabase.table("sections")
-    .insert(
-        {
-            "law_id": law_id,
-            "title": sec_title or "",
-            "content": sec_content or "",
-            "chapter_number": (
-                int(re.search(r"\d+", sec_title or "0").group(0))
-                if re.search(r"\d+", sec_title or "")
-                else 0
-            ),
-            "tables": sec_tables or [],
-        }
-    )
-    .execute()
-)
-
+        # التحقق من وجود القسم مسبقًا
+        existing_section = (
+            supabase.table("sections")
+            .select("id")
+            .eq("law_id", law_id)
+            .eq("title", sec_title)
+            .execute()
+        )
 
-        section_id = res_sec.data[0]["id"]
+        if existing_section.data and len(existing_section.data) > 0:
+            section_id = existing_section.data[0]["id"]
+        else:
+            res_sec = (
+                supabase.table("sections")
+                .insert(
+                    {
+                        "law_id": law_id,
+                        "title": sec_title or "",
+                        "content": sec_content or "",
+                        "chapter_number": (
+                            int(re.search(r"\d+", sec_title or "0").group(0))
+                            if re.search(r"\d+", sec_title or "")
+                            else 0
+                        ),
+                        "tables": sec_tables or [],
+                    }
+                )
+                .execute()
+            )
+            section_id = res_sec.data[0]["id"]
 
         # -------------------------------
         # 3) UPSERT المواد لكل قسم
@@ -94,12 +104,12 @@ def save_law_to_supabase(law_json: dict):
                 .upsert(
                     {
                         "chapter_id": section_id,
-                        "id_law": law_id,                 # ربط المادة بالقانون مباشرة
+                        "id_law": law_id,
                         "article_number": article_number,
                         "content": article_content or "",
                         "tables": article_tables or [],
                     },
-                    on_conflict=["chapter_id", "law_id", "article_number"],  # المفتاح الفريد للمادة
+                    on_conflict=["chapter_id", "id_law", "article_number"],
                 )
                 .execute()
             )