wpanda/WPanda
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

neue struktur

Browse Source
This commit is contained in:
wpanda
2026-02-11 10:16:40 +01:00
parent 42531d6e9c
commit 23a60c6250
10 changed files with 0 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

156
Scripts/python/pdf_import/import_pdf_from_o365.py Normal file
View File

@@ -0,0 +1,156 @@
import os
import requests
import msal
import base64
# ==============================================================================
# KONFIGURÁCIÓ
# ==============================================================================
# Az Azure App Registration-ból kapott adatok
TENANT_ID = "TENANT_ID_MASOLD_BE_IDE"
CLIENT_ID = "CLIENT_ID_MASOLD_BE_IDE"
CLIENT_SECRET = "CLIENT_SECRET_MASOLD_BE_IDE" # A "Value", nem a "Secret ID"
# A postafiók, amit figyelni kell
USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
# Hova mentsük a letöltött PDF-eket
DOWNLOAD_DIR = r"\\aps-nb090\test"
# A mappa neve, ahova a feldolgozott leveleket helyezzük
PROCESSED_FOLDER_NAME = "erledigt"
# ==============================================================================
# Microsoft Graph API végpontok
GRAPH_API_ENDPOINT = "https://graph.microsoft.com/v1.0"
AUTHORITY_URL = f"https://login.microsoftonline.com/{TENANT_ID}"
SCOPES = ["https://graph.microsoft.com/.default"]
def get_graph_api_token():
"""Beszerzi a hozzáférési tokent a Microsoft Graph API-hoz."""
app = msal.ConfidentialClientApplication(
client_id=CLIENT_ID,
authority=AUTHORITY_URL,
client_credential=CLIENT_SECRET
)
result = app.acquire_token_silent(scopes=SCOPES, account=None)
if not result:
result = app.acquire_token_for_client(scopes=SCOPES)
if "access_token" in result:
return result["access_token"]
else:
print("Hiba a token beszerzése során!")
print(result.get("error"))
print(result.get("error_description"))
return None
def get_folder_id(access_token, folder_name):
"""Megkeresi egy mappa ID-ját a neve alapján."""
headers = {"Authorization": f"Bearer {access_token}"}
url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders"
response = requests.get(url, headers=headers)
response.raise_for_status()
folders = response.json().get("value", [])
for folder in folders:
if folder["displayName"].lower() == folder_name.lower():
return folder["id"]
# Kezelhetnénk azt az esetet is, ha a mappa nem létezik, és létrehoznánk.
# Most egyszerűen hibát dobunk.
raise ValueError(f"A '{folder_name}' mappa nem található.")
def main():
"""Fő feldolgozó funkció."""
print("Graph API token beszerzése...")
access_token = get_graph_api_token()
if not access_token:
return
headers = {"Authorization": f"Bearer {access_token}"}
try:
print(f"'{PROCESSED_FOLDER_NAME}' mappa ID-jának keresése...")
processed_folder_id = get_folder_id(access_token, PROCESSED_FOLDER_NAME)
print("Mappa ID sikeresen lekérve.")
except (requests.HTTPError, ValueError) as e:
print(f"Hiba a mappa ID lekérése közben: {e}")
return
# Csak az olvasatlan, csatolmánnyal rendelkező levelek lekérdezése
# $select=id,subject -> Csak a szükséges mezőket kérjük le a hatékonyságért
messages_url = (
f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders/inbox/messages?"
"$filter=isRead eq false and hasAttachments eq true&"
"$select=id,subject"
)
response = requests.get(messages_url, headers=headers)
response.raise_for_status()
messages = response.json().get("value", [])
if not messages:
print("Nincsenek új, feldolgozandó e-mailek.")
return
print(f"{len(messages)} új e-mail található csatolmánnyal.")
for message in messages:
msg_id = message["id"]
subject = message.get("subject", "N/A")
print(f"\n--- Feldolgozás alatt: '{subject}' (ID: {msg_id}) ---")
attachments_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/attachments"
response = requests.get(attachments_url, headers=headers)
if response.status_code != 200:
print(f" Hiba a csatolmányok lekérésekor: {response.json()}")
continue
attachments = response.json().get("value", [])
pdf_found = False
for att in attachments:
filename = att.get("name", "unknown")
content_type = att.get("contentType", "")
if filename.lower().endswith(".pdf") or content_type == "application/pdf":
print(f" PDF csatolmány található: {filename}")
# A csatolmány tartalma a 'contentBytes' mezőben van, Base64 kódolással
file_content = base64.b64decode(att["contentBytes"])
# Fájlnév "tisztítása"
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in filename)
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
try:
with open(filepath, "wb") as f:
f.write(file_content)
print(f" PDF sikeresen mentve: {filepath}")
pdf_found = True
except Exception as e:
print(f" Hiba a fájl mentése közben: {e}")
if pdf_found:
print(f" E-mail áthelyezése a '{PROCESSED_FOLDER_NAME}' mappába...")
move_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/move"
move_payload = {"destinationId": processed_folder_id}
response = requests.post(move_url, headers=headers, json=move_payload)
if response.status_code == 201:
print(" E-mail sikeresen áthelyezve.")
else:
# Az áthelyezéshez Mail.ReadWrite jogosultság kell!
print(f" Hiba az e-mail áthelyezésekor: {response.status_code} - {response.text}")
print("\nFeldolgozás befejezve.")
if __name__ == "__main__":
if not os.path.exists(DOWNLOAD_DIR):
print(f"Hiba: A letöltési mappa nem létezik: {DOWNLOAD_DIR}")
else:
main()

210
Scripts/python/pdf_import/import_pdf_from_o365_de.py Normal file
View File

@@ -0,0 +1,210 @@
import os
import requests
import msal
import base64
# ==============================================================================
# KONFIGURATION
# ==============================================================================
# Daten aus der Azure App-Registrierung
# Tennant ID : caee3499-03f8-4175-9fa8-a935248d0ece
TENANT_ID = "caee3499-03f8-4175-9fa8-a935248d0ece"
# Client Id : 3a08b279-1fc3-419f-a77e-31f12a0f65f7
CLIENT_ID = "3a08b279-1fc3-419f-a77e-31f12a0f65f7"
# Key : 3cd0be8b-e58f-4e0c-9856-5c9788183b2c
CLIENT_SECRET = "Rk-8Q~nJ.sZ-xUiNxtEDdzVgoFFosODLVHX~jdrh" # Der "Wert", nicht die "Secret ID"
# Das zu überwachende Postfach
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
USER_EMAIL = "i.meszely@aps-hh.de"
# Speicherort für heruntergeladene PDFs
# DOWNLOAD_DIR = r"\\aps-nb090\test"
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
DOWNLOAD_DIR = "C:/Tools/PDF"
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
PROCESSED_FOLDER_NAME = "erledigt"
# ==============================================================================
# Microsoft Graph API Endpunkte
GRAPH_API_ENDPOINT = "https://graph.microsoft.com/v1.0"
AUTHORITY_URL = f"https://login.microsoftonline.com/{TENANT_ID}"
SCOPES = ["https://graph.microsoft.com/.default"]
def get_graph_api_token():
"""Ruft das Zugriffstoken für die Microsoft Graph API ab."""
app = msal.ConfidentialClientApplication(
client_id=CLIENT_ID,
authority=AUTHORITY_URL,
client_credential=CLIENT_SECRET
)
result = app.acquire_token_silent(scopes=SCOPES, account=None)
if not result:
result = app.acquire_token_for_client(scopes=SCOPES)
if "access_token" in result:
print("Graph API-Token erfolgreich abgerufen.")
return result["access_token"]
else:
print("Fehler beim Abrufen des Tokens!")
print(result.get("error"))
print(result.get("error_description"))
return None
def get_folder_id(access_token, folder_name):
"""Sucht die ID eines Ordners anhand seines Namens."""
headers = {"Authorization": f"Bearer {access_token}"}
url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders"
response = requests.get(url, headers=headers)
response.raise_for_status()
folders = response.json().get("value", [])
for folder in folders:
if folder["displayName"].lower() == folder_name.lower():
return folder["id"]
# Man könnte auch den Fall behandeln, dass der Ordner nicht existiert, und ihn erstellen.
# Vorerst wird einfach ein Fehler ausgelöst.
raise ValueError(f"Der Ordner '{folder_name}' wurde nicht gefunden.")
def main():
"""Hauptverarbeitungsfunktion."""
print("Graph API-Token wird abgerufen...")
access_token = get_graph_api_token()
if not access_token:
return
headers = {"Authorization": f"Bearer {access_token}"}
try:
print(f"Suche nach der ID für den Ordner '{PROCESSED_FOLDER_NAME}'...")
processed_folder_id = get_folder_id(access_token, PROCESSED_FOLDER_NAME)
print("Ordner-ID erfolgreich abgerufen.")
except requests.exceptions.HTTPError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
if e.response.status_code == 403:
print("Mögliche Ursache: Fehlende oder unzureichende Graph API-Berechtigungen. Bitte stellen Sie sicher, dass die Anwendung die erforderlichen 'Application Permissions' (z.B. Mail.Read, Mail.ReadWrite) in Azure AD hat und dass der Administrator die Zustimmung erteilt hat.")
return
except ValueError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
return
# Nur ungelesene E-Mails mit Anhängen abfragen
# $select=id,subject -> Nur die notwendigen Felder für mehr Effizienz abfragen
messages_url = (
f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders/inbox/messages?"
f"$filter=isRead eq false and hasAttachments eq true&"
f"$select=id,subject"
)
response = requests.get(messages_url, headers=headers)
response.raise_for_status()
messages = response.json().get("value", [])
if not messages:
print("Keine neuen E-Mails zur Verarbeitung gefunden.")
return
print(f"{len(messages)} neue E-Mail(s) mit Anhängen gefunden.")
for message in messages:
msg_id = message["id"]
subject = message.get("subject", "N/A")
print(f"\n--- In Verarbeitung: '{subject}' (ID: {msg_id}) ---")
attachments_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/attachments"
response = requests.get(attachments_url, headers=headers)
if response.status_code != 200:
print(f" Fehler beim Abrufen der Anhänge: {response.json()}")
continue
attachments = response.json().get("value", [])
pdf_found = False
for att in attachments:
filename = att.get("name", "unknown")
content_type = att.get("contentType", "")
# --- DEBUGGING SORTS START ---
print(f" DEBUG: Melléklet neve: '{filename}', Content-Type: '{content_type}'")
print(f" DEBUG: filename endswith .pdf: {filename.lower().endswith('.pdf')}")
print(f" DEBUG: content_type is application/pdf: {content_type == 'application/pdf'}")
# --- DEBUGGING SORTS END ---
if filename == "Safe Attachments Scan In Progress" and content_type is None:
print(f" Placeholder melléklet kihagyása: '{filename}'")
continue
if filename.lower().endswith(".pdf") or content_type == "application/pdf":
print(f" PDF-Anhang gefunden: {filename}")
# Der Inhalt des Anhangs befindet sich im Feld 'contentBytes' und ist Base64-kodiert
file_content = base64.b64decode(att["contentBytes"])
# Dateinamen bereinigen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in filename)
# Ellenőrizze, hogy a fájl létezik-e, és szükség esetén adjon hozzá sorszámot
base_name, extension = os.path.splitext(safe_filename)
counter = 0
while True:
if counter == 0:
final_filename = safe_filename
else:
final_filename = f"{base_name} ({counter}){extension}"
filepath = os.path.join(DOWNLOAD_DIR, final_filename)
if not os.path.exists(filepath):
break
counter += 1
try:
with open(filepath, "wb") as f:
f.write(file_content)
print(f" PDF erfolgreich gespeichert: {filepath}")
pdf_found = True
except Exception as e:
print(f" Fehler beim Speichern der Datei: {e}")
if pdf_found:
print(f" E-Mail wird in den Ordner '{PROCESSED_FOLDER_NAME}' verschoben...")
move_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/move"
move_payload = {"destinationId": processed_folder_id}
response = requests.post(move_url, headers=headers, json=move_payload)
if response.status_code == 201:
print(" E-Mail erfolgreich verschoben.")
# Az áthelyezett e-mail új ID-jának lekérése a válaszból
moved_message_id = response.json().get("id")
if moved_message_id:
print(f" E-Mail új ID-ja: {moved_message_id}")
# E-Mail mint olvasottként való megjelölés az új ID-val
print(f" Markiere E-Mail '{subject}' (ID: {moved_message_id}) als gelesen...")
mark_as_read_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{moved_message_id}"
mark_as_read_payload = {"isRead": True}
mark_response = requests.patch(mark_as_read_url, headers=headers, json=mark_as_read_payload)
if mark_response.status_code == 200:
print(" E-Mail erfolgreich als gelesen markiert.")
else:
print(f" Fehler beim Markieren der E-Mail als gelesen: {mark_response.status_code} - {mark_response.text}")
else:
print(" Hiba: Nem sikerült lekérni az áthelyezett e-mail új ID-ját a válaszból.")
else:
# Für das Verschieben ist die Berechtigung Mail.ReadWrite erforderlich!
print(f" Fehler beim Verschieben der E-Mail: {response.status_code} - {response.text}")
# Az eredeti olvasottként jelölési kód eltávolítva, mivel feljebb már megcsináljuk
print("\nVerarbeitung abgeschlossen.")
if __name__ == "__main__":
if not os.path.exists(DOWNLOAD_DIR):
print(f"Fehler: Der Download-Ordner existiert nicht: {DOWNLOAD_DIR}")
else:
main()

210
Scripts/python/pdf_import/import_pdf_from_o365_de.v.2.0.py Normal file
View File

@@ -0,0 +1,210 @@
import os
import requests
import msal
import base64
# ==============================================================================
# KONFIGURATION
# ==============================================================================
# Daten aus der Azure App-Registrierung
# Tennant ID : caee3499-03f8-4175-9fa8-a935248d0ece
TENANT_ID = "caee3499-03f8-4175-9fa8-a935248d0ece"
# Client Id : 3a08b279-1fc3-419f-a77e-31f12a0f65f7
CLIENT_ID = "3a08b279-1fc3-419f-a77e-31f12a0f65f7"
# Key : 3cd0be8b-e58f-4e0c-9856-5c9788183b2c
CLIENT_SECRET = "Rk-8Q~nJ.sZ-xUiNxtEDdzVgoFFosODLVHX~jdrh" # Der "Wert", nicht die "Secret ID"
# Das zu überwachende Postfach
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
USER_EMAIL = "it@aps-hh.de"
# Speicherort für heruntergeladene PDFs
# DOWNLOAD_DIR = r"\\aps-nb090\test"
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
DOWNLOAD_DIR = "C:/Tools/PDF"
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
PROCESSED_FOLDER_NAME = "erledigt"
# ==============================================================================
# Microsoft Graph API Endpunkte
GRAPH_API_ENDPOINT = "https://graph.microsoft.com/v1.0"
AUTHORITY_URL = f"https://login.microsoftonline.com/{TENANT_ID}"
SCOPES = ["https://graph.microsoft.com/.default"]
def get_graph_api_token():
"""Ruft das Zugriffstoken für die Microsoft Graph API ab."""
app = msal.ConfidentialClientApplication(
client_id=CLIENT_ID,
authority=AUTHORITY_URL,
client_credential=CLIENT_SECRET
)
result = app.acquire_token_silent(scopes=SCOPES, account=None)
if not result:
result = app.acquire_token_for_client(scopes=SCOPES)
if "access_token" in result:
print("Graph API-Token erfolgreich abgerufen.")
return result["access_token"]
else:
print("Fehler beim Abrufen des Tokens!")
print(result.get("error"))
print(result.get("error_description"))
return None
def get_folder_id(access_token, folder_name):
"""Sucht die ID eines Ordners anhand seines Namens."""
headers = {"Authorization": f"Bearer {access_token}"}
url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders"
response = requests.get(url, headers=headers)
response.raise_for_status()
folders = response.json().get("value", [])
for folder in folders:
if folder["displayName"].lower() == folder_name.lower():
return folder["id"]
# Man könnte auch den Fall behandeln, dass der Ordner nicht existiert, und ihn erstellen.
# Vorerst wird einfach ein Fehler ausgelöst.
raise ValueError(f"Der Ordner '{folder_name}' wurde nicht gefunden.")
def main():
"""Hauptverarbeitungsfunktion."""
print("Graph API-Token wird abgerufen...")
access_token = get_graph_api_token()
if not access_token:
return
headers = {"Authorization": f"Bearer {access_token}"}
try:
print(f"Suche nach der ID für den Ordner '{PROCESSED_FOLDER_NAME}'...")
processed_folder_id = get_folder_id(access_token, PROCESSED_FOLDER_NAME)
print("Ordner-ID erfolgreich abgerufen.")
except requests.exceptions.HTTPError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
if e.response.status_code == 403:
print("Mögliche Ursache: Fehlende oder unzureichende Graph API-Berechtigungen. Bitte stellen Sie sicher, dass die Anwendung die erforderlichen 'Application Permissions' (z.B. Mail.Read, Mail.ReadWrite) in Azure AD hat und dass der Administrator die Zustimmung erteilt hat.")
return
except ValueError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
return
# Nur ungelesene E-Mails mit Anhängen abfragen
# $select=id,subject -> Nur die notwendigen Felder für mehr Effizienz abfragen
messages_url = (
f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders/inbox/messages?"
f"$filter=isRead eq false and hasAttachments eq true&"
f"$select=id,subject"
)
response = requests.get(messages_url, headers=headers)
response.raise_for_status()
messages = response.json().get("value", [])
if not messages:
print("Keine neuen E-Mails zur Verarbeitung gefunden.")
return
print(f"{len(messages)} neue E-Mail(s) mit Anhängen gefunden.")
for message in messages:
msg_id = message["id"]
subject = message.get("subject", "N/A")
print(f"\n--- In Verarbeitung: '{subject}' (ID: {msg_id}) ---")
attachments_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/attachments"
response = requests.get(attachments_url, headers=headers)
if response.status_code != 200:
print(f" Fehler beim Abrufen der Anhänge: {response.json()}")
continue
attachments = response.json().get("value", [])
pdf_found = False
for att in attachments:
filename = att.get("name", "unknown")
content_type = att.get("contentType", "")
# --- DEBUGGING SORTS START ---
print(f" DEBUG: Melléklet neve: '{filename}', Content-Type: '{content_type}'")
print(f" DEBUG: filename endswith .pdf: {filename.lower().endswith('.pdf')}")
print(f" DEBUG: content_type is application/pdf: {content_type == 'application/pdf'}")
# --- DEBUGGING SORTS END ---
if filename == "Safe Attachments Scan In Progress" and content_type is None:
print(f" Placeholder melléklet kihagyása: '{filename}'")
continue
if filename.lower().endswith(".pdf") or content_type == "application/pdf":
print(f" PDF-Anhang gefunden: {filename}")
# Der Inhalt des Anhangs befindet sich im Feld 'contentBytes' und ist Base64-kodiert
file_content = base64.b64decode(att["contentBytes"])
# Dateinamen bereinigen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in filename)
# Ellenőrizze, hogy a fájl létezik-e, és szükség esetén adjon hozzá sorszámot
base_name, extension = os.path.splitext(safe_filename)
counter = 0
while True:
if counter == 0:
final_filename = safe_filename
else:
final_filename = f"{base_name} ({counter}){extension}"
filepath = os.path.join(DOWNLOAD_DIR, final_filename)
if not os.path.exists(filepath):
break
counter += 1
try:
with open(filepath, "wb") as f:
f.write(file_content)
print(f" PDF erfolgreich gespeichert: {filepath}")
pdf_found = True
except Exception as e:
print(f" Fehler beim Speichern der Datei: {e}")
if pdf_found:
print(f" E-Mail wird in den Ordner '{PROCESSED_FOLDER_NAME}' verschoben...")
move_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/move"
move_payload = {"destinationId": processed_folder_id}
response = requests.post(move_url, headers=headers, json=move_payload)
if response.status_code == 201:
print(" E-Mail erfolgreich verschoben.")
# Az áthelyezett e-mail új ID-jának lekérése a válaszból
moved_message_id = response.json().get("id")
if moved_message_id:
print(f" E-Mail új ID-ja: {moved_message_id}")
# E-Mail mint olvasottként való megjelölés az új ID-val
print(f" Markiere E-Mail '{subject}' (ID: {moved_message_id}) als gelesen...")
mark_as_read_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{moved_message_id}"
mark_as_read_payload = {"isRead": True}
mark_response = requests.patch(mark_as_read_url, headers=headers, json=mark_as_read_payload)
if mark_response.status_code == 200:
print(" E-Mail erfolgreich als gelesen markiert.")
else:
print(f" Fehler beim Markieren der E-Mail als gelesen: {mark_response.status_code} - {mark_response.text}")
else:
print(" Hiba: Nem sikerült lekérni az áthelyezett e-mail új ID-ját a válaszból.")
else:
# Für das Verschieben ist die Berechtigung Mail.ReadWrite erforderlich!
print(f" Fehler beim Verschieben der E-Mail: {response.status_code} - {response.text}")
# Az eredeti olvasottként jelölési kód eltávolítva, mivel feljebb már megcsináljuk
print("\nVerarbeitung abgeschlossen.")
if __name__ == "__main__":
if not os.path.exists(DOWNLOAD_DIR):
print(f"Fehler: Der Download-Ordner existiert nicht: {DOWNLOAD_DIR}")
else:
main()

222
Scripts/python/pdf_import/import_pdf_from_o365_de.v.2.1.py Normal file
View File

@@ -0,0 +1,222 @@
import os
import requests
import msal
import base64
import logging
# ==============================================================================
# LOGGING KONFIGURATION
# ==============================================================================
LOG_FILE = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'import_pdf_from_o365_de.v.2.1.log')
logging.basicConfig(
level=logging.INFO,
format='%(asctime)s - %(levelname)s - %(message)s',
handlers=[
logging.FileHandler(LOG_FILE),
logging.StreamHandler()
]
)
# ==============================================================================
# ==============================================================================
# KONFIGURATION
# ==============================================================================
# Daten aus der Azure App-Registrierung
# Tennant ID : caee3499-03f8-4175-9fa8-a935248d0ece
TENANT_ID = "caee3499-03f8-4175-9fa8-a935248d0ece"
# Client Id : 3a08b279-1fc3-419f-a77e-31f12a0f65f7
CLIENT_ID = "3a08b279-1fc3-419f-a77e-31f12a0f65f7"
# Key : 3cd0be8b-e58f-4e0c-9856-5c9788183b2c
CLIENT_SECRET = "Rk-8Q~nJ.sZ-xUiNxtEDdzVgoFFosODLVHX~jdrh" # Der "Wert", nicht die "Secret ID"
# Das zu überwachende Postfach
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
USER_EMAIL = "i.meszely@aps-hh.de"
# Speicherort für heruntergeladene PDFs
# DOWNLOAD_DIR = r"\\aps-nb090\test"
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
DOWNLOAD_DIR = "C:/Tools/PDF"
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
PROCESSED_FOLDER_NAME = "erledigt"
# ==============================================================================
# Microsoft Graph API Endpunkte
GRAPH_API_ENDPOINT = "https://graph.microsoft.com/v1.0"
AUTHORITY_URL = f"https://login.microsoftonline.com/{TENANT_ID}"
SCOPES = ["https://graph.microsoft.com/.default"]
def get_graph_api_token():
"""Ruft das Zugriffstoken für die Microsoft Graph API ab."""
app = msal.ConfidentialClientApplication(
client_id=CLIENT_ID,
authority=AUTHORITY_URL,
client_credential=CLIENT_SECRET
)
result = app.acquire_token_silent(scopes=SCOPES, account=None)
if not result:
result = app.acquire_token_for_client(scopes=SCOPES)
if "access_token" in result:
logging.info("Graph API-Token erfolgreich abgerufen.")
return result["access_token"]
else:
logging.error("Fehler beim Abrufen des Tokens!")
logging.error(result.get("error"))
logging.error(result.get("error_description"))
return None
def get_folder_id(access_token, folder_name):
"""Sucht die ID eines Ordners anhand seines Namens."""
headers = {"Authorization": f"Bearer {access_token}"}
url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders"
response = requests.get(url, headers=headers)
response.raise_for_status()
folders = response.json().get("value", [])
for folder in folders:
if folder["displayName"].lower() == folder_name.lower():
return folder["id"]
# Man könnte auch den Fall behandeln, dass der Ordner nicht existiert, und ihn erstellen.
# Vorerst wird einfach ein Fehler ausgelöst.
raise ValueError(f"Der Ordner '{folder_name}' wurde nicht gefunden.")
def main():
"""Hauptverarbeitungsfunktion."""
logging.info("Graph API-Token wird abgerufen...")
access_token = get_graph_api_token()
if not access_token:
logging.error("Kein Zugriffstoken erhalten. Beende das Skript.")
return
headers = {"Authorization": f"Bearer {access_token}"}
try:
logging.info(f"Suche nach der ID für den Ordner '{PROCESSED_FOLDER_NAME}'...")
processed_folder_id = get_folder_id(access_token, PROCESSED_FOLDER_NAME)
logging.info("Ordner-ID erfolgreich abgerufen.")
except requests.exceptions.HTTPError as e:
logging.error(f"Fehler beim Abrufen der Ordner-ID: {e}")
if e.response.status_code == 403:
logging.error("Mögliche Ursache: Fehlende oder unzureichende Graph API-Berechtigungen. Bitte stellen Sie sicher, dass die Anwendung die erforderlichen 'Application Permissions' (z.B. Mail.Read, Mail.ReadWrite) in Azure AD hat und dass der Administrator die Zustimmung erteilt hat.")
return
except ValueError as e:
logging.error(f"Fehler beim Abrufen der Ordner-ID: {e}")
return
# Nur ungelesene E-Mails mit Anhängen abfragen
# $select=id,subject -> Nur die notwendigen Felder für mehr Effizienz abfragen
messages_url = (
f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders/inbox/messages?"
f"$filter=isRead eq false and hasAttachments eq true&"
f"$select=id,subject"
)
response = requests.get(messages_url, headers=headers)
response.raise_for_status()
messages = response.json().get("value", [])
if not messages:
logging.info("Keine neuen E-Mails zur Verarbeitung gefunden.")
return
logging.info(f"{len(messages)} neue E-Mail(s) mit Anhängen gefunden.")
for message in messages:
msg_id = message["id"]
subject = message.get("subject", "N/A")
logging.info(f"\n--- In Verarbeitung: '{subject}' (ID: {msg_id}) ---")
attachments_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/attachments"
response = requests.get(attachments_url, headers=headers)
if response.status_code != 200:
logging.error(f" Fehler beim Abrufen der Anhänge: {response.json()}")
continue
attachments = response.json().get("value", [])
pdf_found = False
for att in attachments:
filename = att.get("name", "unknown")
content_type = att.get("contentType", "")
if filename == "Safe Attachments Scan In Progress" and content_type is None:
logging.info(f" Placeholder melléklet kihagyása: '{filename}'")
continue
if filename.lower().endswith(".pdf") or content_type == "application/pdf":
logging.info(f" PDF-Anhang gefunden: {filename}")
# Der Inhalt des Anhangs befindet sich im Feld 'contentBytes' und ist Base64-kodiert
file_content = base64.b64decode(att["contentBytes"])
# Dateinamen bereinigen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in filename)
# Ellenőrizze, hogy a fájl létezik-e, és szükség esetén adjon hozzá sorszámot
base_name, extension = os.path.splitext(safe_filename)
counter = 0
while True:
if counter == 0:
final_filename = safe_filename
else:
final_filename = f"{base_name} ({counter}){extension}"
filepath = os.path.join(DOWNLOAD_DIR, final_filename)
if not os.path.exists(filepath):
break
counter += 1
try:
with open(filepath, "wb") as f:
f.write(file_content)
logging.info(f" PDF erfolgreich gespeichert: {filepath}")
pdf_found = True
except Exception as e:
logging.error(f" Fehler beim Speichern der Datei: {e}")
if pdf_found:
logging.info(f" E-Mail wird in den Ordner '{PROCESSED_FOLDER_NAME}' verschoben...")
move_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/move"
move_payload = {"destinationId": processed_folder_id}
response = requests.post(move_url, headers=headers, json=move_payload)
if response.status_code == 201:
logging.info(" E-Mail erfolgreich verschoben.")
# Az áthelyezett e-mail új ID-jának lekérése a válaszból
moved_message_id = response.json().get("id")
if moved_message_id:
logging.info(f" E-Mail új ID-ja: {moved_message_id}")
# E-Mail mint olvasottként való megjelölés az új ID-val
logging.info(f" Markiere E-Mail '{subject}' (ID: {moved_message_id}) als gelesen...")
mark_as_read_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{moved_message_id}"
mark_as_read_payload = {"isRead": True}
mark_response = requests.patch(mark_as_read_url, headers=headers, json=mark_as_read_payload)
if mark_response.status_code == 200:
logging.info(" E-Mail erfolgreich als gelesen markiert.")
else:
logging.error(f" Fehler beim Markieren der E-Mail als gelesen: {mark_response.status_code} - {mark_response.text}")
else:
logging.error(" Hiba: Nem sikerült lekérni az áthelyezett e-mail új ID-ját a válaszból.")
else:
# Für das Verschieben ist die Berechtigung Mail.ReadWrite erforderlich!
logging.error(f" Fehler beim Verschieben der E-Mail: {response.status_code} - {response.text}")
# Az eredeti olvasottként jelölési kód eltávolítva, mivel feljebb már megcsináljuk
logging.info("\nVerarbeitung abgeschlossen.")
if __name__ == "__main__":
logging.info("Skript gestartet.")
if not os.path.exists(DOWNLOAD_DIR):
logging.error(f"Fehler: Der Download-Ordner existiert nicht: {DOWNLOAD_DIR}")
else:
main()
logging.info("Skript beendet.")

168
Scripts/python/pdf_import/import_pdf_from_o365_de_v.1.0.py Normal file
View File

@@ -0,0 +1,168 @@
import os
import requests
import msal
import base64
# ==============================================================================
# KONFIGURATION
# ==============================================================================
# Daten aus der Azure App-Registrierung
# Tennant ID : caee3499-03f8-4175-9fa8-a935248d0ece
TENANT_ID = "caee3499-03f8-4175-9fa8-a935248d0ece"
# Client Id : 3a08b279-1fc3-419f-a77e-31f12a0f65f7
CLIENT_ID = "3a08b279-1fc3-419f-a77e-31f12a0f65f7"
# Key : 3cd0be8b-e58f-4e0c-9856-5c9788183b2c
CLIENT_SECRET = "Rk-8Q~nJ.sZ-xUiNxtEDdzVgoFFosODLVHX~jdrh" # Der "Wert", nicht die "Secret ID"
# Das zu überwachende Postfach
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
USER_EMAIL = "i.meszely@aps-hh.de"
# Speicherort für heruntergeladene PDFs
# DOWNLOAD_DIR = r"\\aps-nb090\test"
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
DOWNLOAD_DIR = "C:/Tools/PDF"
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
PROCESSED_FOLDER_NAME = "something"
# ==============================================================================
# Microsoft Graph API Endpunkte
GRAPH_API_ENDPOINT = "https://graph.microsoft.com/v1.0"
AUTHORITY_URL = f"https://login.microsoftonline.com/{TENANT_ID}"
SCOPES = ["https://graph.microsoft.com/.default"]
def get_graph_api_token():
"""Ruft das Zugriffstoken für die Microsoft Graph API ab."""
app = msal.ConfidentialClientApplication(
client_id=CLIENT_ID,
authority=AUTHORITY_URL,
client_credential=CLIENT_SECRET
)
result = app.acquire_token_silent(scopes=SCOPES, account=None)
if not result:
result = app.acquire_token_for_client(scopes=SCOPES)
if "access_token" in result:
print("Graph API-Token erfolgreich abgerufen.")
return result["access_token"]
else:
print("Fehler beim Abrufen des Tokens!")
print(result.get("error"))
print(result.get("error_description"))
return None
def get_folder_id(access_token, folder_name):
"""Sucht die ID eines Ordners anhand seines Namens."""
headers = {"Authorization": f"Bearer {access_token}"}
url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders"
response = requests.get(url, headers=headers)
response.raise_for_status()
folders = response.json().get("value", [])
for folder in folders:
if folder["displayName"].lower() == folder_name.lower():
return folder["id"]
# Man könnte auch den Fall behandeln, dass der Ordner nicht existiert, und ihn erstellen.
# Vorerst wird einfach ein Fehler ausgelöst.
raise ValueError(f"Der Ordner '{folder_name}' wurde nicht gefunden.")
def main():
"""Hauptverarbeitungsfunktion."""
print("Graph API-Token wird abgerufen...")
access_token = get_graph_api_token()
if not access_token:
return
headers = {"Authorization": f"Bearer {access_token}"}
try:
print(f"Suche nach der ID für den Ordner '{PROCESSED_FOLDER_NAME}'...")
processed_folder_id = get_folder_id(access_token, PROCESSED_FOLDER_NAME)
print("Ordner-ID erfolgreich abgerufen.")
except requests.exceptions.HTTPError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
if e.response.status_code == 403:
print("Mögliche Ursache: Fehlende oder unzureichende Graph API-Berechtigungen. Bitte stellen Sie sicher, dass die Anwendung die erforderlichen 'Application Permissions' (z.B. Mail.Read, Mail.ReadWrite) in Azure AD hat und dass der Administrator die Zustimmung erteilt hat.")
return
except ValueError as e:
print(f"Fehler beim Abrufen der Ordner-ID: {e}")
return
# Nur ungelesene E-Mails mit Anhängen abfragen
# $select=id,subject -> Nur die notwendigen Felder für mehr Effizienz abfragen
messages_url = (
f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/mailFolders/inbox/messages?"
f"$filter=isRead eq false and hasAttachments eq true&"
f"$select=id,subject"
)
response = requests.get(messages_url, headers=headers)
response.raise_for_status()
messages = response.json().get("value", [])
if not messages:
print("Keine neuen E-Mails zur Verarbeitung gefunden.")
return
print(f"{len(messages)} neue E-Mail(s) mit Anhängen gefunden.")
for message in messages:
msg_id = message["id"]
subject = message.get("subject", "N/A")
print(f"\n--- In Verarbeitung: '{subject}' (ID: {msg_id}) ---")
attachments_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/attachments"
response = requests.get(attachments_url, headers=headers)
if response.status_code != 200:
print(f" Fehler beim Abrufen der Anhänge: {response.json()}")
continue
attachments = response.json().get("value", [])
pdf_found = False
for att in attachments:
filename = att.get("name", "unknown")
content_type = att.get("contentType", "")
if filename.lower().endswith(".pdf") or content_type == "application/pdf":
print(f" PDF-Anhang gefunden: {filename}")
# Der Inhalt des Anhangs befindet sich im Feld 'contentBytes' und ist Base64-kodiert
file_content = base64.b64decode(att["contentBytes"])
# Dateinamen bereinigen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in filename)
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
try:
with open(filepath, "wb") as f:
f.write(file_content)
print(f" PDF erfolgreich gespeichert: {filepath}")
pdf_found = True
except Exception as e:
print(f" Fehler beim Speichern der Datei: {e}")
if pdf_found:
print(f" E-Mail wird in den Ordner '{PROCESSED_FOLDER_NAME}' verschoben...")
move_url = f"{GRAPH_API_ENDPOINT}/users/{USER_EMAIL}/messages/{msg_id}/move"
move_payload = {"destinationId": processed_folder_id}
response = requests.post(move_url, headers=headers, json=move_payload)
if response.status_code == 201:
print(" E-Mail erfolgreich verschoben.")
else:
# Für das Verschieben ist die Berechtigung Mail.ReadWrite erforderlich!
print(f" Fehler beim Verschieben der E-Mail: {response.status_code} - {response.text}")
print("\nVerarbeitung abgeschlossen.")
if __name__ == "__main__":
if not os.path.exists(DOWNLOAD_DIR):
print(f"Fehler: Der Download-Ordner existiert nicht: {DOWNLOAD_DIR}")
else:
main()

92
Scripts/python/pdf_import/import_pfd_de_v.0.2-from-import-pdf-app-src.py Normal file
View File

@@ -0,0 +1,92 @@
import imaplib
import email
import os
from email.header import decode_header
# ===== Einstellungen =====
IMAP_SERVER = "aps-exch01.aps.local" # IMAP-Server-Adresse
IMAP_PORT = 993 # IMAP-SSL-Port
USERNAME = "i.meszely@aps-hh.de" # Benutzername / E-Mail-Adresse
PASSWORD = "virgI6774#Maci" # Passwort
MAILBOX = "INBOX" # Ordnername (z. B. "INBOX" oder "HelpDesk")
PROCESSED_FOLDER = "erledigt" # Zielordner für verarbeitete E-Mails
DOWNLOAD_DIR = r"C:\Downloads" # Speicherort für PDFs
# Verbindung herstellen
mail = imaplib.IMAP4_SSL(IMAP_SERVER, IMAP_PORT)
mail.login(USERNAME, PASSWORD)
# Ordner auswählen
mail.select(MAILBOX)
# Alle Nachrichten suchen (hier: alle E-Mails)
status, messages = mail.search(None, "ALL")
if status != "OK":
print("Fehler beim Abrufen der Nachrichtenliste")
mail.logout()
exit()
# Liste für zu löschende Nachrichten
delete_list = []
# Nachrichten verarbeiten
for num in messages[0].split():
try:
# Nachricht abrufen
status, data = mail.fetch(num, "(RFC822)")
if status != "OK":
print(f"Fehler beim Herunterladen der Nachricht {num}")
continue
msg = email.message_from_bytes(data[0][1])
pdf_found = False
# Betreff dekodieren
subject, encoding = decode_header(msg["Subject"])[0]
if isinstance(subject, bytes):
subject = subject.decode(encoding if encoding else "utf-8", errors="replace")
print(f"Verarbeite E-Mail: {subject}")
# Anhänge prüfen
for part in msg.walk():
if part.get_content_maintype() == "multipart":
continue
if part.get("Content-Disposition") is None:
continue
filename = part.get_filename()
if filename:
decoded_name, enc = decode_header(filename)[0]
if isinstance(decoded_name, bytes):
decoded_name = decoded_name.decode(enc if enc else "utf-8", errors="replace")
# Ungültige Zeichen im Dateinamen ersetzen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in decoded_name)
if safe_filename.lower().endswith(".pdf"):
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
with open(filepath, "wb") as f:
f.write(part.get_payload(decode=True))
print(f"PDF gespeichert: {filepath}")
pdf_found = True
# Falls PDF gefunden → in Zielordner verschieben & später löschen
if pdf_found:
result = mail.copy(num, PROCESSED_FOLDER)
if result[0] == "OK":
delete_list.append(num)
else:
print(f"Fehler beim Verschieben der Nachricht {num}")
except Exception as e:
print(f"Fehler beim Verarbeiten der Nachricht {num}: {e}")
# Nach der Verarbeitung: löschen
for num in delete_list:
mail.store(num, "+FLAGS", "\\Deleted")
mail.expunge()
# Verbindung trennen
mail.logout()
print("Fertig! Alle neuen PDFs wurden heruntergeladen und verarbeitet.")

93
Scripts/python/pdf_import/import_pfd_de_v.0.2.1.py Normal file
View File

@@ -0,0 +1,93 @@
import imaplib
import email
import os
from email.header import decode_header
# ===== Einstellungen =====
IMAP_SERVER = "aps-exch01.aps.local" # IMAP-Server-Adresse
IMAP_PORT = 993 # IMAP-SSL-Port
USERNAME = "Bestellung-Fax-Eingang@aps-hh.de" # Benutzername / E-Mail-Adresse
PASSWORD = "kX%tTFC~ZR!;S#Q~h!T^22" # Passwort
# MAILBOX = 'HelpDesk/Inbox' # Der zu verwendende Ordner
MAILBOX = "INBOX" # Ordnername (z. B. "INBOX" oder "HelpDesk")
PROCESSED_FOLDER = "erledigt" # Zielordner für verarbeitete E-Mails
DOWNLOAD_DIR = r"\\APS-FILE01\Faxe\Austausch" # Speicherort für PDFs
# Verbindung herstellen
mail = imaplib.IMAP4_SSL(IMAP_SERVER, IMAP_PORT)
mail.login(USERNAME, PASSWORD)
# Ordner auswählen
mail.select(MAILBOX)
# Alle Nachrichten suchen (hier: alle E-Mails)
status, messages = mail.search(None, "ALL")
if status != "OK":
print("Fehler beim Abrufen der Nachrichtenliste")
mail.logout()
exit()
# Liste für zu löschende Nachrichten
delete_list = []
# Nachrichten verarbeiten
for num in messages[0].split():
try:
# Nachricht abrufen
status, data = mail.fetch(num, "(RFC822)")
if status != "OK":
print(f"Fehler beim Herunterladen der Nachricht {num}")
continue
msg = email.message_from_bytes(data[0][1])
pdf_found = False
# Betreff dekodieren
subject, encoding = decode_header(msg["Subject"])[0]
if isinstance(subject, bytes):
subject = subject.decode(encoding if encoding else "utf-8", errors="replace")
print(f"Verarbeite E-Mail: {subject}")
# Anhänge prüfen
for part in msg.walk():
if part.get_content_maintype() == "multipart":
continue
if part.get("Content-Disposition") is None:
continue
filename = part.get_filename()
if filename:
decoded_name, enc = decode_header(filename)[0]
if isinstance(decoded_name, bytes):
decoded_name = decoded_name.decode(enc if enc else "utf-8", errors="replace")
# Ungültige Zeichen im Dateinamen ersetzen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in decoded_name)
if safe_filename.lower().endswith(".pdf"):
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
with open(filepath, "wb") as f:
f.write(part.get_payload(decode=True))
print(f"PDF gespeichert: {filepath}")
pdf_found = True
# Falls PDF gefunden → in Zielordner verschieben & später löschen
if pdf_found:
result = mail.copy(num, PROCESSED_FOLDER)
if result[0] == "OK":
delete_list.append(num)
else:
print(f"Fehler beim Verschieben der Nachricht {num}")
except Exception as e:
print(f"Fehler beim Verarbeiten der Nachricht {num}: {e}")
# Nach der Verarbeitung: löschen
for num in delete_list:
mail.store(num, "+FLAGS", "\\Deleted")
mail.expunge()
# Verbindung trennen
mail.logout()
print("Fertig! Alle neuen PDFs wurden heruntergeladen und verarbeitet.")

93
Scripts/python/pdf_import/import_pfd_de_v.0.2.2-test.py Normal file
View File

@@ -0,0 +1,93 @@
import imaplib
import email
import os
from email.header import decode_header
# ===== Einstellungen =====
IMAP_SERVER = "outlook.office365.com" # IMAP-Server-Adresse
IMAP_PORT = 993 # IMAP-SSL-Port
USERNAME = "i.meszely@aps-hh.de" # Benutzername / E-Mail-Adresse
PASSWORD = "virgI6774#Maci" # Passwort
# MAILBOX = 'HelpDesk/Inbox' # Der zu verwendende Ordner
MAILBOX = "INBOX" # Ordnername (z. B. "INBOX" oder "HelpDesk")
PROCESSED_FOLDER = "erledigt" # Zielordner für verarbeitete E-Mails
DOWNLOAD_DIR = r"C:/Tools/" # Speicherort für PDFs
# Verbindung herstellen
mail = imaplib.IMAP4_SSL(IMAP_SERVER, IMAP_PORT)
mail.login(USERNAME, PASSWORD)
# Ordner auswählen
mail.select(MAILBOX)
# Alle Nachrichten suchen (hier: alle E-Mails)
status, messages = mail.search(None, "ALL")
if status != "OK":
print("Fehler beim Abrufen der Nachrichtenliste")
mail.logout()
exit()
# Liste für zu löschende Nachrichten
delete_list = []
# Nachrichten verarbeiten
for num in messages[0].split():
try:
# Nachricht abrufen
status, data = mail.fetch(num, "(RFC822)")
if status != "OK":
print(f"Fehler beim Herunterladen der Nachricht {num}")
continue
msg = email.message_from_bytes(data[0][1])
pdf_found = False
# Betreff dekodieren
subject, encoding = decode_header(msg["Subject"])[0]
if isinstance(subject, bytes):
subject = subject.decode(encoding if encoding else "utf-8", errors="replace")
print(f"Verarbeite E-Mail: {subject}")
# Anhänge prüfen
for part in msg.walk():
if part.get_content_maintype() == "multipart":
continue
if part.get("Content-Disposition") is None:
continue
filename = part.get_filename()
if filename:
decoded_name, enc = decode_header(filename)[0]
if isinstance(decoded_name, bytes):
decoded_name = decoded_name.decode(enc if enc else "utf-8", errors="replace")
# Ungültige Zeichen im Dateinamen ersetzen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in decoded_name)
if safe_filename.lower().endswith(".pdf"):
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
with open(filepath, "wb") as f:
f.write(part.get_payload(decode=True))
print(f"PDF gespeichert: {filepath}")
pdf_found = True
# Falls PDF gefunden → in Zielordner verschieben & später löschen
if pdf_found:
result = mail.copy(num, PROCESSED_FOLDER)
if result[0] == "OK":
delete_list.append(num)
else:
print(f"Fehler beim Verschieben der Nachricht {num}")
except Exception as e:
print(f"Fehler beim Verarbeiten der Nachricht {num}: {e}")
# Nach der Verarbeitung: löschen
for num in delete_list:
mail.store(num, "+FLAGS", "\\Deleted")
mail.expunge()
# Verbindung trennen
mail.logout()
print("Fertig! Alle neuen PDFs wurden heruntergeladen und verarbeitet.")

93
Scripts/python/pdf_import/import_pfd_de_v.0.2.panda.py Normal file
View File

@@ -0,0 +1,93 @@
import imaplib
import email
import os
from email.header import decode_header
# ===== Einstellungen =====
IMAP_SERVER = "aps-exch01.aps.local" # IMAP-Server-Adresse
IMAP_PORT = 993 # IMAP-SSL-Port
USERNAME = "i.meszely@aps-hh.de" # Benutzername / E-Mail-Adresse
PASSWORD = "virgI6774#Maci" # Passwort
# MAILBOX = 'HelpDesk/Inbox' # Der zu verwendende Ordner
MAILBOX = "INBOX" # Ordnername (z. B. "INBOX" oder "HelpDesk")
PROCESSED_FOLDER = "erledigt" # Zielordner für verarbeitete E-Mails
DOWNLOAD_DIR = r"\\aps-nb090\Test" # Speicherort für PDFs
# Verbindung herstellen
mail = imaplib.IMAP4_SSL(IMAP_SERVER, IMAP_PORT)
mail.login(USERNAME, PASSWORD)
# Ordner auswählen
mail.select(MAILBOX)
# Alle Nachrichten suchen (hier: alle E-Mails)
status, messages = mail.search(None, "ALL")
if status != "OK":
print("Fehler beim Abrufen der Nachrichtenliste")
mail.logout()
exit()
# Liste für zu löschende Nachrichten
delete_list = []
# Nachrichten verarbeiten
for num in messages[0].split():
try:
# Nachricht abrufen
status, data = mail.fetch(num, "(RFC822)")
if status != "OK":
print(f"Fehler beim Herunterladen der Nachricht {num}")
continue
msg = email.message_from_bytes(data[0][1])
pdf_found = False
# Betreff dekodieren
subject, encoding = decode_header(msg["Subject"])[0]
if isinstance(subject, bytes):
subject = subject.decode(encoding if encoding else "utf-8", errors="replace")
print(f"Verarbeite E-Mail: {subject}")
# Anhänge prüfen
for part in msg.walk():
if part.get_content_maintype() == "multipart":
continue
if part.get("Content-Disposition") is None:
continue
filename = part.get_filename()
if filename:
decoded_name, enc = decode_header(filename)[0]
if isinstance(decoded_name, bytes):
decoded_name = decoded_name.decode(enc if enc else "utf-8", errors="replace")
# Ungültige Zeichen im Dateinamen ersetzen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in decoded_name)
if safe_filename.lower().endswith(".pdf"):
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
with open(filepath, "wb") as f:
f.write(part.get_payload(decode=True))
print(f"PDF gespeichert: {filepath}")
pdf_found = True
# Falls PDF gefunden → in Zielordner verschieben & später löschen
if pdf_found:
result = mail.copy(num, PROCESSED_FOLDER)
if result[0] == "OK":
delete_list.append(num)
else:
print(f"Fehler beim Verschieben der Nachricht {num}")
except Exception as e:
print(f"Fehler beim Verarbeiten der Nachricht {num}: {e}")
# Nach der Verarbeitung: löschen
for num in delete_list:
mail.store(num, "+FLAGS", "\\Deleted")
mail.expunge()
# Verbindung trennen
mail.logout()
print("Fertig! Alle neuen PDFs wurden heruntergeladen und verarbeitet.")

93
Scripts/python/pdf_import/import_pfd_de_v.0.2.py Normal file
View File

@@ -0,0 +1,93 @@
import imaplib
import email
import os
from email.header import decode_header
# ===== Einstellungen =====
IMAP_SERVER = "aps-exch01.aps.local" # IMAP-Server-Adresse
IMAP_PORT = 993 # IMAP-SSL-Port
USERNAME = "Bestellung-Fax-Eingang@aps-hh.de" # Benutzername / E-Mail-Adresse
PASSWORD = "kX%tTFC~ZR!;S#Q~h!T^22" # Passwort
# MAILBOX = 'HelpDesk/Inbox' # Der zu verwendende Ordner
MAILBOX = "INBOX" # Ordnername (z. B. "INBOX" oder "HelpDesk")
PROCESSED_FOLDER = "erledigt" # Zielordner für verarbeitete E-Mails
DOWNLOAD_DIR = r"\\aps-nb090\test" # Speicherort für PDFs
# Verbindung herstellen
mail = imaplib.IMAP4_SSL(IMAP_SERVER, IMAP_PORT)
mail.login(USERNAME, PASSWORD)
# Ordner auswählen
mail.select(MAILBOX)
# Alle Nachrichten suchen (hier: alle E-Mails)
status, messages = mail.search(None, "ALL")
if status != "OK":
print("Fehler beim Abrufen der Nachrichtenliste")
mail.logout()
exit()
# Liste für zu löschende Nachrichten
delete_list = []
# Nachrichten verarbeiten
for num in messages[0].split():
try:
# Nachricht abrufen
status, data = mail.fetch(num, "(RFC822)")
if status != "OK":
print(f"Fehler beim Herunterladen der Nachricht {num}")
continue
msg = email.message_from_bytes(data[0][1])
pdf_found = False
# Betreff dekodieren
subject, encoding = decode_header(msg["Subject"])[0]
if isinstance(subject, bytes):
subject = subject.decode(encoding if encoding else "utf-8", errors="replace")
print(f"Verarbeite E-Mail: {subject}")
# Anhänge prüfen
for part in msg.walk():
if part.get_content_maintype() == "multipart":
continue
if part.get("Content-Disposition") is None:
continue
filename = part.get_filename()
if filename:
decoded_name, enc = decode_header(filename)[0]
if isinstance(decoded_name, bytes):
decoded_name = decoded_name.decode(enc if enc else "utf-8", errors="replace")
# Ungültige Zeichen im Dateinamen ersetzen
safe_filename = "".join(c if c.isalnum() or c in (" ", ".", "_", "-") else "_" for c in decoded_name)
if safe_filename.lower().endswith(".pdf"):
filepath = os.path.join(DOWNLOAD_DIR, safe_filename)
with open(filepath, "wb") as f:
f.write(part.get_payload(decode=True))
print(f"PDF gespeichert: {filepath}")
pdf_found = True
# Falls PDF gefunden → in Zielordner verschieben & später löschen
if pdf_found:
result = mail.copy(num, PROCESSED_FOLDER)
if result[0] == "OK":
delete_list.append(num)
else:
print(f"Fehler beim Verschieben der Nachricht {num}")
except Exception as e:
print(f"Fehler beim Verarbeiten der Nachricht {num}: {e}")
# Nach der Verarbeitung: löschen
for num in delete_list:
mail.store(num, "+FLAGS", "\\Deleted")
mail.expunge()
# Verbindung trennen
mail.logout()
print("Fertig! Alle neuen PDFs wurden heruntergeladen und verarbeitet.")