Compare commits
3 Commits
865449cf9c
...
78a88900d8
| Author | SHA1 | Date | |
|---|---|---|---|
| 78a88900d8 | |||
| e91094e344 | |||
| d7c6577ec1 |
43
Dev/postfix_smtp_relay/etc/postfix/main.cf
Normal file
43
Dev/postfix_smtp_relay/etc/postfix/main.cf
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
alias_database = hash:/etc/aliases
|
||||||
|
alias_maps = hash:/etc/aliases
|
||||||
|
command_directory = /usr/bin
|
||||||
|
compatibility_level = 3.10
|
||||||
|
daemon_directory = /usr/libexec/postfix
|
||||||
|
data_directory = /var/lib/postfix
|
||||||
|
debug_peer_level = 2
|
||||||
|
debugger_command = PATH=/bin:/usr/bin:/usr/local/bin:/usr/X11R6/bin ddd $daemon_directory/$process_name $process_id & sleep 5
|
||||||
|
html_directory = no
|
||||||
|
inet_interfaces = all
|
||||||
|
inet_protocols = all
|
||||||
|
mail_owner = postfix
|
||||||
|
mailq_path = /usr/bin/mailq.postfix
|
||||||
|
manpage_directory = /usr/share/man
|
||||||
|
meta_directory = /etc/postfix
|
||||||
|
mydestination = $myhostname, localhost.$mydomain, localhost
|
||||||
|
mynetworks = 127.0.0.0/8, 10.102.9.0/24, 10.101.0.0/16, 10.102.1.0/24
|
||||||
|
newaliases_path = /usr/bin/newaliases.postfix
|
||||||
|
queue_directory = /var/spool/postfix
|
||||||
|
readme_directory = /usr/share/doc/postfix/README_FILES
|
||||||
|
#relayhost = apshh-de0i.mail.protection.outlook.com
|
||||||
|
#relayhost = [apshh.mail.protection.outlook.com]:25
|
||||||
|
relayhost = [aps-exch01.aps.local]:25
|
||||||
|
#relayhost =
|
||||||
|
sample_directory = /usr/share/doc/postfix/samples
|
||||||
|
sendmail_path = /usr/bin/sendmail.postfix
|
||||||
|
setgid_group = postdrop
|
||||||
|
shlib_directory = /usr/lib64/postfix
|
||||||
|
#smtp_sasl_auth_enable = no
|
||||||
|
smtpd_sasl_auth_enable = yes
|
||||||
|
smtpd_sasl_security_options = noanonymous
|
||||||
|
smtpd_sasl_local_domain = $myhostname
|
||||||
|
broken_sasl_auth_clients = yes
|
||||||
|
smtp_tls_CAfile = /etc/pki/tls/certs/ca-bundle.crt
|
||||||
|
smtp_tls_CApath = /etc/pki/tls/certs
|
||||||
|
smtp_tls_security_level = may
|
||||||
|
smtpd_tls_cert_file = /etc/pki/tls/certs/postfix.pem
|
||||||
|
smtpd_tls_key_file = /etc/pki/tls/private/postfix.key
|
||||||
|
smtpd_tls_security_level = may
|
||||||
|
unknown_local_recipient_reject_code = 550
|
||||||
|
myhostname = antares-apo.local
|
||||||
|
smtpd_recipient_restrictions = permit_mynetworks, permit_sasl_authenticated, reject_unauth_destination
|
||||||
|
|
||||||
37
Dev/postfix_smtp_relay/etc/postfix/main.cf.19.02.2026
Normal file
37
Dev/postfix_smtp_relay/etc/postfix/main.cf.19.02.2026
Normal file
@@ -0,0 +1,37 @@
|
|||||||
|
alias_database = hash:/etc/aliases
|
||||||
|
alias_maps = hash:/etc/aliases
|
||||||
|
command_directory = /usr/bin
|
||||||
|
compatibility_level = 3.10
|
||||||
|
daemon_directory = /usr/libexec/postfix
|
||||||
|
data_directory = /var/lib/postfix
|
||||||
|
debug_peer_level = 2
|
||||||
|
debugger_command = PATH=/bin:/usr/bin:/usr/local/bin:/usr/X11R6/bin ddd $daemon_directory/$process_name $process_id & sleep 5
|
||||||
|
html_directory = no
|
||||||
|
inet_interfaces = all
|
||||||
|
inet_protocols = all
|
||||||
|
mail_owner = postfix
|
||||||
|
mailq_path = /usr/bin/mailq.postfix
|
||||||
|
manpage_directory = /usr/share/man
|
||||||
|
meta_directory = /etc/postfix
|
||||||
|
mydestination = $myhostname, localhost.$mydomain, localhost
|
||||||
|
mynetworks = 127.0.0.0/8, 10.102.9.0/24, 10.101.0.0/16, 10.102.1.0/24
|
||||||
|
newaliases_path = /usr/bin/newaliases.postfix
|
||||||
|
queue_directory = /var/spool/postfix
|
||||||
|
readme_directory = /usr/share/doc/postfix/README_FILES
|
||||||
|
#relayhost = apshh-de0i.mail.protection.outlook.com
|
||||||
|
#relayhost = [apshh.mail.protection.outlook.com]:25
|
||||||
|
relayhost = [aps-exch01.aps.local]:25
|
||||||
|
#relayhost =
|
||||||
|
sample_directory = /usr/share/doc/postfix/samples
|
||||||
|
sendmail_path = /usr/bin/sendmail.postfix
|
||||||
|
setgid_group = postdrop
|
||||||
|
shlib_directory = /usr/lib64/postfix
|
||||||
|
smtp_sasl_auth_enable = no
|
||||||
|
smtp_tls_CAfile = /etc/pki/tls/certs/ca-bundle.crt
|
||||||
|
smtp_tls_CApath = /etc/pki/tls/certs
|
||||||
|
smtp_tls_security_level = may
|
||||||
|
smtpd_tls_cert_file = /etc/pki/tls/certs/postfix.pem
|
||||||
|
smtpd_tls_key_file = /etc/pki/tls/private/postfix.key
|
||||||
|
smtpd_tls_security_level = may
|
||||||
|
unknown_local_recipient_reject_code = 550
|
||||||
|
myhostname = antares-apo.local
|
||||||
151
Dev/postfix_smtp_relay/etc/postfix/master.cf
Normal file
151
Dev/postfix_smtp_relay/etc/postfix/master.cf
Normal file
@@ -0,0 +1,151 @@
|
|||||||
|
#
|
||||||
|
# Postfix master process configuration file. For details on the format
|
||||||
|
# of the file, see the master(5) manual page (command: "man 5 master" or
|
||||||
|
# on-line: https://www.postfix.org/master.5.html).
|
||||||
|
#
|
||||||
|
# Do not forget to execute "postfix reload" after editing this file.
|
||||||
|
#
|
||||||
|
# ==========================================================================
|
||||||
|
# service type private unpriv chroot wakeup maxproc command + args
|
||||||
|
# (yes) (yes) (no) (never) (100)
|
||||||
|
# ==========================================================================
|
||||||
|
smtp inet n - n - - smtpd
|
||||||
|
#smtp inet n - n - 1 postscreen
|
||||||
|
#smtpd pass - - n - - smtpd
|
||||||
|
#dnsblog unix - - n - 0 dnsblog
|
||||||
|
#tlsproxy unix - - n - 0 tlsproxy
|
||||||
|
# Choose one: enable submission for loopback clients only, or for any client.
|
||||||
|
#127.0.0.1:submission inet n - n - - smtpd
|
||||||
|
#submission inet n - n - - smtpd
|
||||||
|
# -o syslog_name=postfix/submission
|
||||||
|
# -o smtpd_forbid_unauth_pipelining=no
|
||||||
|
# -o smtpd_tls_security_level=encrypt
|
||||||
|
# -o smtpd_sasl_auth_enable=yes
|
||||||
|
# -o smtpd_tls_auth_only=yes
|
||||||
|
# -o local_header_rewrite_clients=static:all
|
||||||
|
# -o smtpd_hide_client_session=yes
|
||||||
|
# -o smtpd_reject_unlisted_recipient=no
|
||||||
|
# Instead of specifying complex smtpd_<xxx>_restrictions here,
|
||||||
|
# specify "smtpd_<xxx>_restrictions=$mua_<xxx>_restrictions"
|
||||||
|
# here, and specify mua_<xxx>_restrictions in main.cf (where
|
||||||
|
# "<xxx>" is "client", "helo", "sender", "relay", or "recipient").
|
||||||
|
# -o smtpd_client_restrictions=
|
||||||
|
# -o smtpd_helo_restrictions=
|
||||||
|
# -o smtpd_sender_restrictions=
|
||||||
|
# -o smtpd_relay_restrictions=
|
||||||
|
# -o smtpd_recipient_restrictions=permit_sasl_authenticated,reject
|
||||||
|
# -o milter_macro_daemon_name=ORIGINATING
|
||||||
|
# Choose one: enable submissions for loopback clients only, or for any client.
|
||||||
|
#127.0.0.1:submissions inet n - n - - smtpd
|
||||||
|
#submissions inet n - n - - smtpd
|
||||||
|
# -o syslog_name=postfix/submissions
|
||||||
|
# -o smtpd_forbid_unauth_pipelining=no
|
||||||
|
# -o smtpd_tls_wrappermode=yes
|
||||||
|
# -o smtpd_sasl_auth_enable=yes
|
||||||
|
# -o local_header_rewrite_clients=static:all
|
||||||
|
# -o smtpd_hide_client_session=yes
|
||||||
|
# -o smtpd_reject_unlisted_recipient=no
|
||||||
|
# Instead of specifying complex smtpd_<xxx>_restrictions here,
|
||||||
|
# specify "smtpd_<xxx>_restrictions=$mua_<xxx>_restrictions"
|
||||||
|
# here, and specify mua_<xxx>_restrictions in main.cf (where
|
||||||
|
# "<xxx>" is "client", "helo", "sender", "relay", or "recipient").
|
||||||
|
# -o smtpd_client_restrictions=
|
||||||
|
# -o smtpd_helo_restrictions=
|
||||||
|
# -o smtpd_sender_restrictions=
|
||||||
|
# -o smtpd_relay_restrictions=
|
||||||
|
# -o smtpd_recipient_restrictions=permit_sasl_authenticated,reject
|
||||||
|
# -o milter_macro_daemon_name=ORIGINATING
|
||||||
|
#628 inet n - n - - qmqpd
|
||||||
|
pickup unix n - n 60 1 pickup
|
||||||
|
cleanup unix n - n - 0 cleanup
|
||||||
|
qmgr unix n - n 300 1 qmgr
|
||||||
|
#qmgr unix n - n 300 1 oqmgr
|
||||||
|
tlsmgr unix - - n 1000? 1 tlsmgr
|
||||||
|
rewrite unix - - n - - trivial-rewrite
|
||||||
|
bounce unix - - n - 0 bounce
|
||||||
|
defer unix - - n - 0 bounce
|
||||||
|
trace unix - - n - 0 bounce
|
||||||
|
verify unix - - n - 1 verify
|
||||||
|
flush unix n - n 1000? 0 flush
|
||||||
|
proxymap unix - - n - - proxymap
|
||||||
|
proxywrite unix - - n - 1 proxymap
|
||||||
|
smtp unix - - n - - smtp
|
||||||
|
relay unix - - n - - smtp
|
||||||
|
-o syslog_name=${multi_instance_name?{$multi_instance_name}:{postfix}}/$service_name
|
||||||
|
# -o smtp_helo_timeout=5 -o smtp_connect_timeout=5
|
||||||
|
showq unix n - n - - showq
|
||||||
|
error unix - - n - - error
|
||||||
|
retry unix - - n - - error
|
||||||
|
discard unix - - n - - discard
|
||||||
|
local unix - n n - - local
|
||||||
|
virtual unix - n n - - virtual
|
||||||
|
lmtp unix - - n - - lmtp
|
||||||
|
anvil unix - - n - 1 anvil
|
||||||
|
scache unix - - n - 1 scache
|
||||||
|
postlog unix-dgram n - n - 1 postlogd
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
# Interfaces to non-Postfix software. Be sure to examine the manual
|
||||||
|
# pages of the non-Postfix software to find out what options it wants.
|
||||||
|
#
|
||||||
|
# Many of the following services use the Postfix pipe(8) delivery
|
||||||
|
# agent. See the pipe(8) man page for information about ${recipient}
|
||||||
|
# and other message envelope options.
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# maildrop. See the Postfix MAILDROP_README file for details.
|
||||||
|
# Also specify in main.cf: maildrop_destination_recipient_limit=1
|
||||||
|
#
|
||||||
|
#maildrop unix - n n - - pipe
|
||||||
|
# flags=DRXhu user=vmail argv=/usr/local/bin/maildrop -d ${recipient}
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# Recent Cyrus versions can use the existing "lmtp" master.cf entry.
|
||||||
|
#
|
||||||
|
# Specify in cyrus.conf:
|
||||||
|
# lmtp cmd="lmtpd -a" listen="localhost:lmtp" proto=tcp4
|
||||||
|
#
|
||||||
|
# Specify in main.cf one or more of the following:
|
||||||
|
# mailbox_transport = lmtp:inet:localhost
|
||||||
|
# virtual_transport = lmtp:inet:localhost
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# Cyrus 2.1.5 (Amos Gouaux)
|
||||||
|
# Also specify in main.cf: cyrus_destination_recipient_limit=1
|
||||||
|
#
|
||||||
|
#cyrus unix - n n - - pipe
|
||||||
|
# flags=DRX user=cyrus argv=/usr/lib/cyrus-imapd/deliver -e -r ${sender} -m ${extension} ${user}
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# Old example of delivery via Cyrus.
|
||||||
|
#
|
||||||
|
#old-cyrus unix - n n - - pipe
|
||||||
|
# flags=R user=cyrus argv=/usr/lib/cyrus-imapd/deliver -e -m ${extension} ${user}
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# See the Postfix UUCP_README file for configuration details.
|
||||||
|
#
|
||||||
|
#uucp unix - n n - - pipe
|
||||||
|
# flags=Fqhu user=uucp argv=uux -r -n -z -a$sender - $nexthop!rmail ($recipient)
|
||||||
|
#
|
||||||
|
# ====================================================================
|
||||||
|
#
|
||||||
|
# Other external delivery methods.
|
||||||
|
#
|
||||||
|
#ifmail unix - n n - - pipe
|
||||||
|
# flags=F user=ftn argv=/usr/lib/ifmail/ifmail -r $nexthop ($recipient)
|
||||||
|
#
|
||||||
|
#bsmtp unix - n n - - pipe
|
||||||
|
# flags=Fq. user=bsmtp argv=/usr/local/sbin/bsmtp -f $sender $nexthop $recipient
|
||||||
|
#
|
||||||
|
#scalemail-backend unix - n n - 2 pipe
|
||||||
|
# flags=R user=scalemail argv=/usr/lib/scalemail/bin/scalemail-store
|
||||||
|
# ${nexthop} ${user} ${extension}
|
||||||
|
#
|
||||||
|
#mailman unix - n n - - pipe
|
||||||
|
# flags=FRX user=list argv=/usr/lib/mailman/bin/postfix-to-mailman.py
|
||||||
|
# ${nexthop} ${user}
|
||||||
@@ -87,6 +87,7 @@ services:
|
|||||||
- DB_USER=librenms
|
- DB_USER=librenms
|
||||||
- DB_PASSWORD=${MYSQL_PASSWORD}
|
- DB_PASSWORD=${MYSQL_PASSWORD}
|
||||||
- REDIS_HOST=redis
|
- REDIS_HOST=redis
|
||||||
|
- LIBRENMS_ALLOW_LOGIN_GET=true
|
||||||
- DISPATCHER_NODE_ID=dispatcher1
|
- DISPATCHER_NODE_ID=dispatcher1
|
||||||
- SIDECAR_DISPATCHER=1
|
- SIDECAR_DISPATCHER=1
|
||||||
restart: always
|
restart: always
|
||||||
|
|||||||
297
Scripts/python/pdf_import/import_pdf_from_o365_de.v2.2-orig.py
Normal file
297
Scripts/python/pdf_import/import_pdf_from_o365_de.v2.2-orig.py
Normal file
@@ -0,0 +1,297 @@
|
|||||||
|
import os
|
||||||
|
import requests
|
||||||
|
import msal
|
||||||
|
import base64
|
||||||
|
import logging
|
||||||
|
import mysql.connector
|
||||||
|
import sys
|
||||||
|
|
||||||
|
sys.stdout.reconfigure(encoding='utf-8')
|
||||||
|
|
||||||
|
# ==============================================================================
|
||||||
|
# MySQL KONFIGURATION
|
||||||
|
# ==============================================================================
|
||||||
|
MYSQL_HOST = "10.102.1.65"
|
||||||
|
MYSQL_USER = "svc.emailtopdf"
|
||||||
|
MYSQL_PASSWORD = "zZUHrps62skLKfr9yQwQ"
|
||||||
|
MYSQL_DATABASE = "emailtopdf"
|
||||||
|
MYSQL_TABLE = "emailtopdf"
|
||||||
|
# ==============================================================================
|
||||||
|
|
||||||
|
def create_log_table_if_not_exists():
|
||||||
|
"""Létrehozza a naplótáblát, ha még nem létezik."""
|
||||||
|
try:
|
||||||
|
cnx = mysql.connector.connect(
|
||||||
|
host=MYSQL_HOST,
|
||||||
|
user=MYSQL_USER,
|
||||||
|
password=MYSQL_PASSWORD,
|
||||||
|
database=MYSQL_DATABASE
|
||||||
|
)
|
||||||
|
cursor = cnx.cursor()
|
||||||
|
|
||||||
|
# A tábla struktúrája
|
||||||
|
create_table_query = f"""
|
||||||
|
CREATE TABLE IF NOT EXISTS `{MYSQL_TABLE}` (
|
||||||
|
`id` INT AUTO_INCREMENT PRIMARY KEY,
|
||||||
|
`timestamp` DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
`level` VARCHAR(10),
|
||||||
|
`message` TEXT
|
||||||
|
)
|
||||||
|
"""
|
||||||
|
cursor.execute(create_table_query)
|
||||||
|
cnx.commit()
|
||||||
|
logging.info(f"MySQL naplótábla '{MYSQL_TABLE}' ellenőrizve/létrehozva.")
|
||||||
|
except mysql.connector.Error as err:
|
||||||
|
logging.error(f"Hiba a MySQL naplótábla létrehozásakor/ellenőrzésekor: {err}")
|
||||||
|
finally:
|
||||||
|
if 'cnx' in locals() and cnx.is_connected():
|
||||||
|
cursor.close()
|
||||||
|
cnx.close()
|
||||||
|
|
||||||
|
class MySQLHandler(logging.Handler):
|
||||||
|
"""Egyéni naplózó kezelő, amely MySQL adatbázisba ír."""
|
||||||
|
def emit(self, record):
|
||||||
|
# Szűrjük ki a mysql.connector naplókat, hogy elkerüljük a rekurziót
|
||||||
|
if record.name.startswith('mysql.connector'):
|
||||||
|
return
|
||||||
|
|
||||||
|
try:
|
||||||
|
cnx = mysql.connector.connect(
|
||||||
|
host=MYSQL_HOST,
|
||||||
|
user=MYSQL_USER,
|
||||||
|
password=MYSQL_PASSWORD,
|
||||||
|
database=MYSQL_DATABASE
|
||||||
|
)
|
||||||
|
cursor = cnx.cursor()
|
||||||
|
|
||||||
|
sql = f"INSERT INTO `{MYSQL_TABLE}` (level, message) VALUES (%s, %s)"
|
||||||
|
# A rekord szintjének és üzenetének használata
|
||||||
|
cursor.execute(sql, (record.levelname, self.format(record)))
|
||||||
|
cnx.commit()
|
||||||
|
except mysql.connector.Error as err:
|
||||||
|
# Ne naplózzunk a MySQLHandlerben, hogy elkerüljük a végtelen ciklust
|
||||||
|
# Helyette printeljük ki a hibát, hogy debuggolható legyen.
|
||||||
|
print(f"Hiba a MySQL naplóbejegyzés beszúrásakor: {err}")
|
||||||
|
finally:
|
||||||
|
if 'cnx' in locals() and cnx.is_connected():
|
||||||
|
cursor.close()
|
||||||
|
cnx.close()
|
||||||
|
|
||||||
|
# ==============================================================================
|
||||||
|
# LOGGING KONFIGURATION
|
||||||
|
# ==============================================================================
|
||||||
|
LOG_FILE = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'import_pdf_from_o365_de.v2.1.log')
|
||||||
|
logging.basicConfig(
|
||||||
|
level=logging.INFO,
|
||||||
|
format='%(asctime)s - %(levelname)s - %(message)s',
|
||||||
|
handlers=[
|
||||||
|
logging.FileHandler(LOG_FILE, encoding='utf-8'),
|
||||||
|
logging.StreamHandler(), # Revert to default StreamHandler, encoding is handled by sys.stdout.reconfigure
|
||||||
|
MySQLHandler() # Re-enabled MySQLHandler
|
||||||
|
]
|
||||||
|
)
|
||||||
|
# ==============================================================================
|
||||||
|
|
||||||
|
# ==============================================================================
|
||||||
|
# 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.")
|
||||||
|
create_log_table_if_not_exists() # Call to create table
|
||||||
|
if not os.path.exists(DOWNLOAD_DIR):
|
||||||
|
logging.error(f"Fehler: Der Download-Ordner existiert nicht: {DOWNLOAD_DIR}")
|
||||||
|
else:
|
||||||
|
main()
|
||||||
|
logging.info("Skript beendet.")
|
||||||
@@ -105,12 +105,12 @@ CLIENT_SECRET = "Rk-8Q~nJ.sZ-xUiNxtEDdzVgoFFosODLVHX~jdrh" # Der "Wert", nicht d
|
|||||||
|
|
||||||
# Das zu überwachende Postfach
|
# Das zu überwachende Postfach
|
||||||
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
|
# USER_EMAIL = "Bestellung-Fax-Eingang@aps-hh.de"
|
||||||
USER_EMAIL = "i.meszely@aps-hh.de"
|
USER_EMAIL = "fax-bestellung@antares-apo.de"
|
||||||
|
|
||||||
# Speicherort für heruntergeladene PDFs
|
# Speicherort für heruntergeladene PDFs
|
||||||
# DOWNLOAD_DIR = r"\\aps-nb090\test"
|
# DOWNLOAD_DIR = r"\\aps-nb090\test"
|
||||||
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
|
# DOWNLOAD_DIR = r"C:\Users\YourUsername\Downloads\PDFs"
|
||||||
DOWNLOAD_DIR = "C:/Tools/PDF"
|
DOWNLOAD_DIR = r"\\APS-FILE01\Faxe\Austausch"
|
||||||
|
|
||||||
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
|
# Name des Ordners, in den verarbeitete E-Mails verschoben werden
|
||||||
PROCESSED_FOLDER_NAME = "erledigt"
|
PROCESSED_FOLDER_NAME = "erledigt"
|
||||||
|
|||||||
Reference in New Issue
Block a user