Floke/Brancheneinstufung2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sync_manager.py aktualisiert

Browse Source
This commit is contained in:
Floke
2025-08-27 14:38:08 +00:00
parent bb2be835e9
commit 5558478ac2
1 changed files with 28 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
sync_manager.py
View File

@@ -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.")