Registry

import pandas as pd
import hashlib
import requests

def compute_row_hash(row):
    """Genera una fingerprint SHA1 per i dati stringa della row"""
    row_string = "|".join(str(val) for val in row.values)
    return hashlib.sha1(row_string.encode('utf-8')).hexdigest()

def sync_legacy_erp_to_salesforce(erp_data, sf_data):
    # 1. Indicizzazione per chiave primaria (Partita IVA / TaxID)
    df_erp = pd.DataFrame(erp_data).set_index('tax_id')
    df_sf = pd.DataFrame(sf_data).set_index('tax_id')
    
    # 2. Addizione impronte digitali crittografiche per row-state detection
    df_erp['hash'] = df_erp.apply(compute_row_hash, axis=1)
    df_sf['hash'] = df_sf.apply(compute_row_hash, axis=1)
    
    # 3. Logica Insiemistica Differenziale (Delta detection)
    # Record presenti in ERP ma non in Salesforce (Nuovi Clienti)
    new_tax_ids = set(df_erp.index) - set(df_sf.index)
    records_to_insert = df_erp.loc[list(new_tax_ids)]
    
    # Record presenti in entrambi ma con Hash Differenti (Clienti che hanno cambiato Via/Nome)
    common_tax_ids = set(df_erp.index).intersection(set(df_sf.index))
    df_common_erp = df_erp.loc[list(common_tax_ids)]
    df_common_sf = df_sf.loc[list(common_tax_ids)]
    
    changed_mask = df_common_erp['hash'] != df_common_sf['hash']
    records_to_update = df_common_erp[changed_mask]
    
    # 4. Cloud Push 
    total_api_calls = 0
    if not records_to_insert.empty:
        # POST API to Salesforce
        total_api_calls += len(records_to_insert)
    if not records_to_update.empty:
        # PATCH API to Salesforce 
        total_api_calls += len(records_to_update)
        
    return {
        'status': 'Synced',
        'inserted': len(records_to_insert),
        'updated': len(records_to_update),
        'api_quota_saved': len(df_erp) - total_api_calls
    }