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