From cb8e50cfb334b969e712383de5cba3e969668fe0 Mon Sep 17 00:00:00 2001 From: Floke Date: Thu, 28 Aug 2025 06:43:14 +0000 Subject: [PATCH] sync_manager.py aktualisiert --- sync_manager.py | 38 ++++++++++++++++---------------------- 1 file changed, 16 insertions(+), 22 deletions(-) diff --git a/sync_manager.py b/sync_manager.py index a0cef468..9dd85e16 100644 --- a/sync_manager.py +++ b/sync_manager.py @@ -34,7 +34,7 @@ class SyncManager: "No. Service Technicians": "CRM Anzahl Techniker", "Annual Revenue (Mio. €)": "CRM Umsatz", "Number of Employees": "CRM Anzahl Mitarbeiter", - "GUID": "CRM ID" # Deine korrekte Anpassung + "GUID": "CRM ID" } self.d365_wins_cols = ["CRM Name", "Parent Account Name", "CRM Ort", "CRM Land", @@ -48,17 +48,14 @@ class SyncManager: try: self.d365_df = pd.read_excel(self.d365_export_path, dtype=str).fillna('') - # --- NEUE, ROBUSTERE LOGIK: Spalten direkt umbenennen --- - # Prüfen, ob alle erwarteten Spalten aus D365 vorhanden sind for d365_col in self.d365_to_gsheet_map.keys(): if d365_col not in self.d365_df.columns: raise ValueError(f"Erwartete Spalte '{d365_col}' nicht in der D365-Exportdatei gefunden.") - # Alle Spalten auf einmal umbenennen. self.d365_df.rename(columns=self.d365_to_gsheet_map, inplace=True) - # Bereinige CRM IDs und entferne Zeilen ohne gültige ID - self.d365_df['CRM ID'] = self.d365_df['CRM ID'].str.strip() + # KORREKTUR: GUIDs normalisieren (Kleinschreibung) + self.d365_df['CRM ID'] = self.d365_df['CRM ID'].str.strip().str.lower() self.d365_df.dropna(subset=['CRM ID'], inplace=True) self.d365_df = self.d365_df[self.d365_df['CRM ID'] != ''] @@ -80,11 +77,9 @@ class SyncManager: if temp_df.empty: temp_df = pd.DataFrame(columns=actual_header) else: - # Stelle sicher, dass die Spaltenanzahl übereinstimmt, fülle ggf. auf if temp_df.shape[1] < len(actual_header): missing_cols = len(actual_header) - temp_df.shape[1] - for i in range(missing_cols): - temp_df[f'temp_{i}'] = '' + for i in range(missing_cols): temp_df[f'temp_{i}'] = '' temp_df.columns = actual_header temp_df = temp_df.fillna('') @@ -100,14 +95,14 @@ class SyncManager: self.logger.critical(f"Fehler beim Laden/Umwandeln der GSheet-Daten: {e}", exc_info=True) return False - self.gsheet_df['CRM ID'] = self.gsheet_df['CRM ID'].str.strip() + # KORREKTUR: GUIDs auch hier normalisieren (Kleinschreibung) + self.gsheet_df['CRM ID'] = self.gsheet_df['CRM ID'].str.strip().str.lower() self.logger.info(f"{len(self.d365_df)} gültige Datensätze aus D365 geladen, {len(self.gsheet_df)} im Google Sheet vorhanden.") return True def run_sync(self): """Führt den gesamten Synchronisationsprozess aus.""" - if not self._load_data(): - return + if not self._load_data(): return self.target_sheet_name = self.sheet_handler.get_main_sheet_name() if not self.target_sheet_name: @@ -123,15 +118,12 @@ class SyncManager: self.logger.info(f"Sync-Analyse: {len(new_ids)} neue, {len(deleted_ids)} zu archivierende, {len(existing_ids)} bestehende Accounts.") - updates_to_batch = [] - rows_to_append = [] + updates_to_batch, rows_to_append = [], [] - # --- KORRIGIERTE LOGIK FÜR NEUE ACCOUNTS --- if new_ids: new_accounts_df = self.d365_df[self.d365_df['CRM ID'].isin(new_ids)] for _, row in new_accounts_df.iterrows(): new_row_data = [""] * len(COLUMN_ORDER) - # Iteriere durch die Spaltennamen, die wir aus D365 kennen (jetzt schon umbenannt) for gsheet_col in self.d365_to_gsheet_map.values(): if gsheet_col in row: col_idx = COLUMN_MAP[gsheet_col]['index'] @@ -153,15 +145,16 @@ class SyncManager: d365_row = d365_indexed.loc[crm_id] gsheet_row = gsheet_indexed.loc[crm_id] - row_updates = {} - conflict_messages = [] - needs_reeval = False + row_updates, conflict_messages, needs_reeval = {}, [], False - # Da die Spaltennamen jetzt identisch sind, können wir direkt vergleichen for gsheet_col in self.d365_wins_cols: - if str(d365_row[gsheet_col]) != str(gsheet_row[gsheet_col]): - row_updates[gsheet_col] = str(d365_row[gsheet_col]) + d365_val = str(d365_row[gsheet_col]) + gsheet_val = str(gsheet_row[gsheet_col]) + if d365_val != gsheet_val: + row_updates[gsheet_col] = d365_val needs_reeval = True + # NEUES LOGGING + self.logger.debug(f"ReEval für {crm_id} durch '{gsheet_col}': D365='{d365_val}' | GSheet='{gsheet_val}'") for gsheet_col in self.smart_merge_cols: d365_val = str(d365_row.get(gsheet_col, '')) @@ -170,6 +163,7 @@ class SyncManager: if d365_val and not gsheet_val: row_updates[gsheet_col] = d365_val needs_reeval = True + self.logger.debug(f"ReEval für {crm_id} durch '{gsheet_col}' (GSheet war leer): D365='{d365_val}'") elif d365_val and gsheet_val and d365_val != gsheet_val: conflict_messages.append(f"{gsheet_col}_CONFLICT: D365='{d365_val}' | GSHEET='{gsheet_val}'")