Update app.py

app.py

@@ -448,6 +448,49 @@ def _log_catalog_variants(logs: List[str], product_info: Dict[str, Any], limit:
             break
 
 
+def _find_existing_product_by_fp(
+    logs: List[str],
+    shop_id: str,
+    fp: str,
+) -> Optional[Dict[str, Any]]:
+    page = 1
+    while True:
+        resp = _req(
+            "GET",
+            f"/v1/shops/{shop_id}/products.json?page={page}&limit=50",
+            logs=logs,
+        )
+        if isinstance(resp, dict):
+            items = resp.get("data") or resp.get("products") or resp.get("items")
+            if isinstance(items, list):
+                products = items
+            else:
+                products = []
+        elif isinstance(resp, list):
+            products = resp
+        else:
+            products = []
+
+        if not products:
+            break
+
+        for p in products:
+            if not isinstance(p, dict):
+                continue
+            desc = p.get("description") or ""
+            if isinstance(desc, str) and f"BATCH_FP={fp}" in desc:
+                _log(
+                    logs,
+                    f"FOUND_EXISTING_PRODUCT_FOR_FP shop_id={shop_id} product_id={p.get('id')} batch_fp={fp}",
+                )
+                return p
+
+        page += 1
+
+    _log(logs, f"NO_EXISTING_PRODUCT_FOR_FP shop_id={shop_id} batch_fp={fp}")
+    return None
+
+
 def _create_product_all_variants_with_grid(
     logs: List[str],
     shop_id: str,
@@ -487,6 +530,15 @@ def _create_product_all_variants_with_grid(
 
     fp = _batch_fingerprint(str(shop_id), int(bp_id), int(provider_id), sorted(list(enabled_ids)))
 
+    existing = _find_existing_product_by_fp(logs, shop_id, fp)
+    if isinstance(existing, dict) and existing.get("id"):
+        _log(
+            logs,
+            f"PHASE_B_REUSE_EXISTING_PRODUCT shop_id={shop_id} blueprint_id={bp_id} "
+            f"provider_id={provider_id} existing_product_id={existing.get('id')} batch_fp={fp}",
+        )
+        return existing
+
     img_id = upload.get("id")
     img_w = float(upload.get("width") or 0)
     img_h = float(upload.get("height") or 0)
@@ -595,7 +647,6 @@ def _create_product_all_variants_with_grid(
         f"/v1/shops/{shop_id}/products.json",
         json_body=payload,
         logs=logs,
-        extra_headers={"Idempotency-Key": fp},
     )
     if not isinstance(created, Dict):
         raise RuntimeError(f"Unexpected create response: {str(created)[:500]}")