diff --git a/sync_manager.py b/sync_manager.py index 46317a77..6cdddfd3 100644 --- a/sync_manager.py +++ b/sync_manager.py @@ -32,6 +32,7 @@ class SyncManager: sheet_handler: Eine instanziierte GoogleSheetHandler-Klasse. d365_export_path (str): Der Dateipfad zur D365 Excel-Exportdatei. """ + print("DEBUG: SyncManager wird initialisiert (__init__ wird ausgeführt).") # <<< HINZUGEFÜGT self.sheet_handler = sheet_handler self.d365_export_path = d365_export_path self.logger = logging.getLogger(__name__) @@ -48,7 +49,7 @@ class SyncManager: "No. Service Technicians": "CRM Anzahl Techniker", "Annual Revenue (Mio. €)": "CRM Umsatz", "Number of Employees": "CRM Anzahl Mitarbeiter", - "GUID": "CRM ID" + "GUID": "CRM ID" # <<< KORRIGIERT: Passt jetzt zu deiner Export-Datei } # Definiert die Merge-Strategien für GSheet-Spalten @@ -89,9 +90,12 @@ class SyncManager: def run_sync(self): """Führt den gesamten Synchronisationsprozess aus.""" + print("DEBUG: run_sync() wurde aufgerufen. Versuche jetzt, Daten zu laden.") # <<< HINZUGEFÜGT if not self._load_data(): + print("DEBUG: _load_data() ist fehlgeschlagen oder hat False zurückgegeben. Breche ab.") # <<< HINZUGEFÜGT return + print("DEBUG: _load_data() war erfolgreich. Beginne mit der Analyse der IDs.") # <<< HINZUGEFÜGT d365_ids = set(self.d365_df[self.d365_df['CRM ID'] != '']['CRM ID']) gsheet_ids = set(self.gsheet_df[self.gsheet_df['CRM ID'] != '']['CRM ID']) @@ -100,6 +104,7 @@ class SyncManager: existing_ids = d365_ids.intersection(gsheet_ids) self.logger.info(f"Sync-Analyse: {len(new_ids)} neue, {len(deleted_ids)} archivierte, {len(existing_ids)} bestehende Accounts.") + print(f"DEBUG: Sync-Analyse: {len(new_ids)} neue, {len(deleted_ids)} archivierte, {len(existing_ids)} bestehende Accounts.") # <<< HINZUGEFÜGT updates_to_batch = [] rows_to_append = [] @@ -118,17 +123,22 @@ class SyncManager: # 2. Gelöschte/Archivierte Accounts verarbeiten if deleted_ids: for crm_id in deleted_ids: - row_idx = self.gsheet_df[self.gsheet_df['CRM ID'] == crm_id].index[0] - updates_to_batch.append({ - "range": f"{COLUMN_MAP['Archiviert']['Titel']}{row_idx + 2}", # +2 weil 1-basiert und Header - "values": [["TRUE"]] - }) + row_idx_list = self.gsheet_df[self.gsheet_df['CRM ID'] == crm_id].index.tolist() + if row_idx_list: + row_idx = row_idx_list[0] + updates_to_batch.append({ + "range": f"{COLUMN_MAP['Archiviert']['Titel']}{row_idx + 2}", # +2 weil 1-basiert und Header + "values": [["TRUE"]] + }) # 3. Bestehende Accounts intelligent mergen if existing_ids: # Setze 'CRM ID' als Index für schnellen Zugriff - self.d365_df.set_index('CRM ID', inplace=True) - self.gsheet_df.set_index('CRM ID', inplace=True) + if self.d365_df.index.name != 'CRM ID': + self.d365_df.set_index('CRM ID', inplace=True) + if self.gsheet_df.index.name != 'CRM ID': + self.gsheet_df.set_index('CRM ID', inplace=True) + for crm_id in existing_ids: d365_row = self.d365_df.loc[crm_id] @@ -166,7 +176,10 @@ class SyncManager: # Batch-Update-Objekte erstellen if row_updates: - row_idx = self.gsheet_df.index.get_loc(crm_id) + row_idx_list = self.gsheet_df.index.get_loc(crm_id) + # Sicherstellen, dass row_idx ein Integer ist, kein Slice oder Array + row_idx = row_idx_list if isinstance(row_idx_list, int) else row_idx_list.start + for col_name, value in row_updates.items(): updates_to_batch.append({ "range": f"{COLUMN_MAP[col_name]['Titel']}{row_idx + 2}", @@ -175,11 +188,17 @@ class SyncManager: # 4. Änderungen ins Google Sheet schreiben if rows_to_append: + print(f"DEBUG: {len(rows_to_append)} neue Zeilen werden hinzugefügt.") # <<< HINZUGEFÜGT self.logger.info(f"Füge {len(rows_to_append)} neue Zeilen zum Google Sheet hinzu...") self.sheet_handler.append_rows(rows_to_append) if updates_to_batch: + print(f"DEBUG: {len(updates_to_batch)} Zell-Updates werden gesendet.") # <<< HINZUGEFÜGT self.logger.info(f"Sende {len(updates_to_batch)} Zell-Updates an das Google Sheet...") self.sheet_handler.batch_update_cells(updates_to_batch) + if not rows_to_append and not updates_to_batch: + print("DEBUG: Keine neuen Zeilen oder Updates zum Senden gefunden.") # <<< HINZUGEFÜGT + + print("DEBUG: run_sync() am Ende angelangt.") # <<< HINZUGEFÜGT self.logger.info("Synchronisation erfolgreich abgeschlossen.") \ No newline at end of file