erpnext_custom/nexterp_custom/api.py

import frappe
import requests
from frappe import _

@frappe.whitelist()
def sync_custom_fields_to_woocommerce(item_code):
    """Sync Custom Fields vom Item nach WooCommerce ACF
       Liest die Zuordnungen dynamisch aus dem DocType 'WooCommerce ACF Mapping'"""
    
    if not item_code:
        frappe.throw(_("Kein Item Code angegeben"))
    
    try:
        doc = frappe.get_doc("Item", item_code)
    except Exception:
        frappe.throw(_("Item {0} nicht gefunden").format(item_code))
    
    if not doc.get("woocommerce_servers"):
        frappe.msgprint(_("Item hat keine verknüpften WooCommerce Server"), indicator="orange")
        return False
    
    # Dynamisches Mapping aus dem DocType laden
    field_mapping = {}
    mappings = frappe.get_all("WooCommerce ACF Mapping",
                              filters={"enabled": 1},
                              fields=["erp_field", "acf_field"])
    
    for m in mappings:
        if m.erp_field and m.acf_field:
            field_mapping[m.erp_field] = m.acf_field
    
    if not field_mapping:
        frappe.msgprint(_("Keine aktivierten Mappings im DocType 'WooCommerce ACF Mapping' gefunden"), 
                       indicator="orange")
        return False
    
    success_count = 0
    errors = []
    
    for wc_link in doc.woocommerce_servers:
        if not wc_link.enable_sync or not wc_link.woocommerce_id:
            continue
            
        try:
            wc_server = frappe.get_doc("WooCommerce Server", wc_link.woocommerce_server)
            
            if not wc_server.api_key or not wc_server.api_secret:
                errors.append("WooCommerce Server {} hat keine Zugangsdaten".format(wc_link.woocommerce_server))
                continue
            
            # Basis URL vorbereiten
            base_url = wc_server.woocommerce_server_url.rstrip("/")
            if not base_url.endswith("/wp-json/wc/v3"):
                base_url += "/wp-json/wc/v3"
            
            url = "{}/products/{}".format(base_url, wc_link.woocommerce_id)
            auth = (wc_server.api_key, wc_server.api_secret)
            
            # Produkt holen
            resp = requests.get(url, auth=auth, timeout=15)
            resp.raise_for_status()
            product = resp.json()
            
            # ACF Daten mergen
            acf_data = product.get("acf", {})
            
            updated_fields = 0
            for erp_field, acf_field in field_mapping.items():
                value = doc.get(erp_field)
                if value is not None:
                    acf_data[acf_field] = value
                    updated_fields += 1
            
            if updated_fields == 0:
                continue
                
            payload = {"acf": acf_data}
            
            # Update durchführen
            update_resp = requests.put(url, json=payload, auth=auth, timeout=15)
            update_resp.raise_for_status()
            
            success_count += 1
            
        except requests.exceptions.RequestException as e:
            error_msg = "API-Fehler für Produkt {}: {}".format(wc_link.woocommerce_id, str(e))
            errors.append(error_msg)
            frappe.log_error(error_msg, "WooCommerce ACF Sync")
            
        except Exception as e:
            error_msg = "Unerwarteter Fehler für Item {} / WC-ID {}: {}".format(item_code, wc_link.woocommerce_id, str(e))
            errors.append(error_msg)
            frappe.log_error(error_msg, "WooCommerce ACF Sync")
    
    # Zusammenfassung
    if success_count > 0:
        msg = "Custom Fields für {} WooCommerce-Produkt(e) erfolgreich synchronisiert".format(success_count)
        if errors:
            msg += " ({} Fehler aufgetreten)".format(len(errors))
        frappe.msgprint(msg, alert=True, indicator="green")
        return True
    else:
        if errors:
            frappe.msgprint("Fehler beim Sync:\n" + "\n".join(errors[:3]), indicator="red")
        else:
            frappe.msgprint("Keine Felder wurden synchronisiert.", indicator="orange")
        return False