Add autofilter to all Excel report sheets

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

.gitignore

@@ -8,6 +8,9 @@ __pycache__/
 # PyCharm / IDE
 .idea/
 
+# Claude worktrees
+.claude/worktrees/
+
 # OS
 .DS_Store
 Thumbs.db

10ReadPozadavky/01 Read pozadavky.py

@@ -8,10 +8,11 @@ Reads Bearer token from token.txt (single line, token only).
 import requests
 import pandas as pd
 import time
+from pathlib import Path
 from typing import List, Dict, Any
 
 # CONFIG ---------------------------------------------------------------------
-TOKEN_FILE = "token.txt"            # file with token (no "Bearer " prefix)
+TOKEN_FILE = str(Path(__file__).resolve().parent.parent / "token.txt")  # centralized token
 GRAPHQL_URL = "https://app.medevio.cz/graphql"
 CLINIC_SLUG = "mudr-buzalkova"      # adjust if needed
 LOCALE = "cs"

10ReadPozadavky/02 Start query creation.py

@@ -6,7 +6,7 @@ from pathlib import Path
 import requests  # 👈 this is new
 
 # --- Settings ----------------------------------------------------
-TOKEN_PATH = Path("token.txt")   # file contains ONLY the token, no "Bearer "
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 SHOW_FULL_TOKEN = False          # set True if you want to print the full token
 # -----------------------------------------------------------------

10ReadPozadavky/03 Read pozadavek simple.py

@@ -6,7 +6,7 @@ from pathlib import Path
 import requests
 
 # --- Settings ----------------------------------------------------
-TOKEN_PATH = Path("token.txt")   # file contains ONLY the token, no "Bearer "
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 # -----------------------------------------------------------------
 

10ReadPozadavky/04 Dalsi.py

@@ -5,7 +5,7 @@ import json
 from pathlib import Path
 import requests
 
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 # --- Try including `updatedAt` field directly ---

10ReadPozadavky/05 Další.py

@@ -5,7 +5,7 @@ import json
 from pathlib import Path
 import requests
 
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 GRAPHQL_QUERY = r"""

10ReadPozadavky/06 Načti všechny požadavky do mySQL.py

@@ -11,7 +11,7 @@ from datetime import datetime
 # ================================
 # 🔧 CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BATCH_SIZE = 100
 STATES = ["ACTIVE", "DONE"]  # optionally add "REMOVED"

10ReadPozadavky/0601 Plně funkční stáhne všechny požadavky do mySQl.py

@@ -11,7 +11,7 @@ from datetime import datetime
 # ================================
 # 🔧 CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BATCH_SIZE = 1000
 STATES = ["ACTIVE", "DONE"]  # optionally add "REMOVED"

10ReadPozadavky/07 Ulož přílohy požadavku do filesystem.py

@@ -3,7 +3,7 @@ import json
 from pathlib import Path
 
 # === Nastavení ===
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 REQUEST_ID = "092a0c63-28be-4c6b-ab3b-204e1e2641d4"
 OUTPUT_DIR = Path(r"u:\Dropbox\!!!Days\Downloads Z230\Medevio_přílohy")
 

10ReadPozadavky/0701 test.py

@@ -2,7 +2,7 @@ import requests
 import json
 from pathlib import Path
 
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 REQUEST_ID = "092a0c63-28be-4c6b-ab3b-204e1e2641d4"
 CLINIC_SLUG = "mudr-buzalkova"
 

10ReadPozadavky/0702 Plně funkční uložení přílohyfilesystem.py

@@ -13,7 +13,7 @@ import shutil
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BASE_DIR = Path(r"u:\Dropbox\ordinace\Dokumentace_ke_zpracování\Medevio_přílohy")
 BASE_DIR.mkdir(parents=True, exist_ok=True)

10ReadPozadavky/0704 Plne funkční uložení do mysql.py

@@ -20,7 +20,7 @@ import time
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {

10ReadPozadavky/08 Read communication.py

@@ -17,7 +17,7 @@ import time
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 
 DB_CONFIG = {

10ReadPozadavky/09 Read dotaznik.py

@@ -16,7 +16,7 @@ import time
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 

10ReadPozadavky/10 UpdateMessageswithJmeno.py

@@ -10,7 +10,7 @@ import time, socket
 # ===============================
 # ⚙️ CONFIG
 # ===============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {

10ReadPozadavky/10 test2.py

@@ -10,7 +10,7 @@ import time
 # ================================
 # ⚙️ CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BATCH_SIZE = 100
 

10ReadPozadavky/705 Plně funkční uložení do mysql.py

@@ -18,7 +18,7 @@ import time
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {

10ReadPozadavky/PRAVIDELNE_0_READ_ALL_ACTIVE_POZADAVKY.py

@@ -23,7 +23,7 @@ except AttributeError:
 # ================================
 # 🔧 CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BATCH_SIZE = 100
 

10ReadPozadavky/PRAVIDELNE_1_ReadLast300DonePozadavku.py

@@ -6,41 +6,15 @@ import requests
 from pathlib import Path
 from datetime import datetime
 from dateutil import parser
-import sys
-
-# Force UTF-8 output even under Windows Task Scheduler
-import sys
-try:
-    sys.stdout.reconfigure(encoding='utf-8')
-    sys.stderr.reconfigure(encoding='utf-8')
-except AttributeError:
-    # Python < 3.7 fallback (not needed for you, but safe)
-    import io
-    sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding='utf-8')
-    sys.stderr = io.TextIOWrapper(sys.stderr.buffer, encoding='utf-8')
-
-# ================================
-# 🛡 SAFE PRINT FOR CP1250 / Emoji
-# ================================
-def safe_print(text: str):
-    enc = sys.stdout.encoding or ""
-    if not enc.lower().startswith("utf"):
-        # strip emoji + characters outside BMP
-        text = ''.join(ch for ch in text if ord(ch) < 65536)
-    try:
-        print(text)
-    except UnicodeEncodeError:
-        # final fallback to ASCII only
-        text = ''.join(ch for ch in text if ord(ch) < 128)
-        print(text)
-
 
 # ================================
 # 🔧 CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
-LIMIT = 300
+
+LIMIT = 500                   # batch size / number of records
+FULL_DOWNLOAD = False         # 🔥 TOGGLE: False = last X, True = ALL batches
 
 DB_CONFIG = {
     "host": "192.168.1.76",
@@ -52,7 +26,7 @@ DB_CONFIG = {
     "cursorclass": pymysql.cursors.DictCursor,
 }
 
-# ⭐ GraphQL query
+# ⭐ Query with lastMessage
 GRAPHQL_QUERY = r"""
 query ClinicRequestList2(
   $clinicSlug: String!,
@@ -95,27 +69,23 @@ query ClinicRequestList2(
 # ================================
 def read_token(path: Path) -> str:
     tok = path.read_text(encoding="utf-8").strip()
-    if tok.startswith("Bearer "):
+    return tok.split(" ", 1)[1] if tok.startswith("Bearer ") else tok
-        return tok.split(" ", 1)[1]
-    return tok
-
 
 # ================================
-# DATETIME PARSER
+# DATETIME PARSER (UTC → MySQL)
 # ================================
 def to_mysql_dt(iso_str):
     if not iso_str:
         return None
     try:
-        dt = parser.isoparse(iso_str)
+        dt = parser.isoparse(iso_str)   # ISO8601 → aware datetime (UTC)
-        dt = dt.astimezone()
+        dt = dt.astimezone()            # convert to local timezone
         return dt.strftime("%Y-%m-%d %H:%M:%S")
     except:
         return None
 
-
 # ================================
-# UPSERT
+# UPSERT REQUEST
 # ================================
 def upsert(conn, r):
     p = r.get("extendedPatient") or {}
@@ -147,7 +117,7 @@ def upsert(conn, r):
     """
 
     vals = (
-        r.get("id"),
+        r["id"],
         r.get("displayTitle"),
         to_mysql_dt(r.get("createdAt")),
         final_updated,
@@ -163,16 +133,15 @@ def upsert(conn, r):
 
     conn.commit()
 
-
 # ================================
-# FETCH LAST 300 DONE REQUESTS
+# FETCH DONE REQUESTS (one batch)
 # ================================
-def fetch_done(headers):
+def fetch_done(headers, offset):
     vars = {
         "clinicSlug": CLINIC_SLUG,
         "queueId": None,
         "queueAssignment": "ANY",
-        "pageInfo": {"first": LIMIT, "offset": 0},
+        "pageInfo": {"first": LIMIT, "offset": offset},
         "locale": "cs",
         "state": "DONE",
     }
@@ -187,8 +156,7 @@ def fetch_done(headers):
     r.raise_for_status()
 
     data = r.json()["data"]["requestsResponse"]
-    return data.get("patientRequests", [])
+    return data.get("patientRequests", []), data.get("count", 0)
-
 
 # ================================
 # MAIN
@@ -203,18 +171,40 @@ def main():
 
     conn = pymysql.connect(**DB_CONFIG)
 
-    safe_print(f"\n=== Downloading last {LIMIT} DONE requests @ {datetime.now():%Y-%m-%d %H:%M:%S} ===")
+    print(f"\n=== Sync CLOSED requests @ {datetime.now():%Y-%m-%d %H:%M:%S} ===")
 
-    requests_list = fetch_done(headers)
+    offset = 0
-    safe_print(f"📌 Requests returned: {len(requests_list)}")
+    total_count = None
+    total_processed = 0
 
-    for r in requests_list:
+    while True:
+        batch, count = fetch_done(headers, offset)
+
+        if total_count is None:
+            total_count = count
+            print(f"📡 Total DONE in Medevio: {count}")
+
+        if not batch:
+            break
+
+        print(f"   • Processing batch offset={offset}  size={len(batch)}")
+
+        for r in batch:
             upsert(conn, r)
+        total_processed += len(batch)
+
+        if not FULL_DOWNLOAD:
+            # process only last LIMIT records
+            break
+
+        # FULL DOWNLOAD → fetch next batch
+        offset += LIMIT
+        if offset >= count:
+            break
 
     conn.close()
-    safe_print("\n\u2705 DONE - latest closed requests synced.\n")
+    print(f"\n✅ DONE — {total_processed} requests synced.\n")
 
 
-# ================================
 if __name__ == "__main__":
     main()

10ReadPozadavky/PRAVIDELNE_2_ReadPoznamky.py

@@ -45,7 +45,7 @@ def safe_print(text: str):
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 

10ReadPozadavky/PRAVIDELNE_3_StahniKomunikaci.py

@@ -47,7 +47,7 @@ def safe_print(text: str):
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 
 DB_CONFIG = {
     "host": "192.168.1.76",

10ReadPozadavky/PRAVIDELNE_3_StahniKomunikaciDELTA.py

@@ -40,7 +40,7 @@ def safe_print(text: str):
 # ==============================
 # CONFIG
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 
 DB_CONFIG = {
     "host": "192.168.1.76",

10ReadPozadavky/PRAVIDELNE_4_StahniPrilohyUlozDoMySQL.py

@@ -48,7 +48,7 @@ def safe_print(text: str):
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {
@@ -190,9 +190,10 @@ def main():
 
     # Build query for pozadavky
     sql = """
-        SELECT id, pacient_prijmeni, pacient_jmeno, createdAt
+        SELECT id, pacient_prijmeni, pacient_jmeno, createdAt, updatedAt, attachmentsProcessed
         FROM pozadavky
         WHERE attachmentsProcessed IS NULL
+           OR updatedAt > attachmentsProcessed
     """
     params = []
     if CREATED_AFTER:

10ReadPozadavky/PRAVIDELNE_5_SaveToFileSystem incremental1.py

@@ -0,0 +1,224 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import os
+import shutil
+import pymysql
+import re
+from pathlib import Path
+from datetime import datetime
+from collections import defaultdict
+
+# ==============================
+# ⚙️ CONFIGURATION
+# ==============================
+
+DB_CONFIG = {
+    "host": "192.168.1.76",
+    "port": 3307,
+    "user": "root",
+    "password": "Vlado9674+",
+    "database": "medevio",
+    "charset": "utf8mb4",
+}
+
+BASE_DIR = Path(r"u:\Dropbox\Ordinace\Dokumentace_ke_zpracování\MP")
+BASE_DIR.mkdir(parents=True, exist_ok=True)
+
+
+# ==============================
+# 🔧 HELPERS
+# ==============================
+
+def sanitize_name(name: str) -> str:
+    """Replace invalid Windows filename characters."""
+    return re.sub(r'[<>:"/\\|?*\x00-\x1F]', "_", name).strip()
+
+
+def make_abbrev(title: str) -> str:
+    """Create abbreviation from title."""
+    if not title:
+        return ""
+    words = re.findall(r"[A-Za-zÁ-Žá-ž0-9]+", title)
+    abbr = ""
+    for w in words:
+        if w.isdigit():
+            abbr += w
+        else:
+            abbr += w[0]
+    return abbr.upper()
+
+
+def clean_folder(folder: Path, valid_files: set):
+    """Remove unexpected files except ▲ files."""
+    if not folder.exists():
+        return
+
+    for f in folder.iterdir():
+        if f.is_file():
+            if f.name.startswith("▲"):
+                continue
+            sanitized = sanitize_name(f.name)
+            if sanitized not in valid_files:
+                print(f"🗑️ Removing unexpected file: {f.name}")
+                try:
+                    f.unlink()
+                except Exception as e:
+                    print(f"⚠️ Could not delete {f}: {e}")
+
+
+# ==============================
+# 📦 DB CONNECTION
+# ==============================
+
+conn = pymysql.connect(**DB_CONFIG)
+cur_meta = conn.cursor(pymysql.cursors.DictCursor)
+cur_blob = conn.cursor()
+
+print("🔍 Loading only requests with NEW attachments…")
+
+cur_meta.execute("""
+    SELECT
+        p.id AS request_id,
+        p.displayTitle,
+        p.pacient_jmeno,
+        p.pacient_prijmeni,
+        p.updatedAt,
+        p.attachmentsProcessed,
+        d.filename,
+        d.created_at
+    FROM pozadavky p
+    JOIN medevio_downloads d ON d.request_id = p.id
+    LEFT JOIN (
+        SELECT request_id, MAX(created_at) AS last_attachment_ts
+        FROM medevio_downloads
+        GROUP BY request_id
+    ) x ON x.request_id = p.id
+    WHERE p.attachmentsProcessed IS NULL
+       OR p.attachmentsProcessed < x.last_attachment_ts
+    ORDER BY p.updatedAt DESC;
+""")
+
+rows = cur_meta.fetchall()
+print(f"📋 Found {len(rows)} attachment rows belonging to requests needing processing.\n")
+
+# ==============================
+# 🧠 PREPARE REQUEST GROUPING
+# ==============================
+
+grouped = defaultdict(list)
+for r in rows:
+    grouped[r["request_id"]].append(r)
+
+unique_request_ids = list(grouped.keys())
+total_requests = len(unique_request_ids)
+
+print(f"🔄 Processing {total_requests} requests needing updates…\n")
+
+# ==============================
+# 🧠 MAIN LOOP
+# ==============================
+
+index = 0
+
+for req_id in unique_request_ids:
+    index += 1
+    pct = (index / total_requests) * 100
+
+    print(f"\n[ {pct:5.1f}% ] Processing request {index}/{total_requests} → {req_id}")
+
+    req_rows = grouped[req_id]
+    first = req_rows[0]
+
+    # Build folder name
+    updated_at = first["updatedAt"] or datetime.now()
+    date_str = updated_at.strftime("%Y-%m-%d")
+
+    prijmeni = sanitize_name(first["pacient_prijmeni"] or "Unknown")
+    jmeno = sanitize_name(first["pacient_jmeno"] or "")
+    abbr = make_abbrev(first["displayTitle"])
+
+    desired_folder_name = sanitize_name(f"{date_str} {prijmeni}, {jmeno} [{abbr}] {req_id}")
+
+    # Detect existing folder for request
+    main_folder = None
+    for f in BASE_DIR.iterdir():
+        if f.is_dir() and req_id in f.name:
+            main_folder = f
+            break
+
+    if not main_folder:
+        main_folder = BASE_DIR / desired_folder_name
+
+    main_folder.mkdir(parents=True, exist_ok=True)
+
+    # Build valid filename set
+    valid_files = {sanitize_name(r["filename"]) for r in req_rows}
+
+    # Clean unexpected non-▲ files
+    clean_folder(main_folder, valid_files)
+
+    # Track if ANY new files were downloaded
+    added_new_file = False
+
+    # DOWNLOAD MISSING FILES
+    for r in req_rows:
+        filename = sanitize_name(r["filename"])
+        dest_plain = main_folder / filename
+        dest_flag = main_folder / ("▲" + filename)
+
+        # Skip if file already exists (plain or ▲)
+        if dest_plain.exists() or dest_flag.exists():
+            continue
+
+        # Fetch content
+        cur_blob.execute("""
+            SELECT file_content
+            FROM medevio_downloads
+            WHERE request_id=%s AND filename=%s
+        """, (req_id, r["filename"]))
+
+        row = cur_blob.fetchone()
+        if not row or not row[0]:
+            continue
+
+        with open(dest_plain, "wb") as f:
+            f.write(row[0])
+
+        print(f"💾 Wrote: {dest_plain.relative_to(BASE_DIR)}")
+        added_new_file = True
+
+    # ------------------------------------
+    # 🟦 FOLDER ▲ LOGIC (IMPORTANT)
+    # ------------------------------------
+    if added_new_file:
+        # If folder contains ▲ in its name → remove it
+        if "▲" in main_folder.name:
+            new_name = main_folder.name.replace("▲", "").strip()
+            new_path = main_folder.parent / new_name
+
+            try:
+                main_folder.rename(new_path)
+                print(f"🔄 Folder flag ▲ removed → {new_name}")
+                main_folder = new_path
+            except Exception as e:
+                print(f"⚠️ Could not rename folder: {e}")
+    else:
+        # NO new files → NEVER rename folder
+        pass
+
+    # Mark request as processed
+    cur_meta.execute(
+        "UPDATE pozadavky SET attachmentsProcessed = NOW() WHERE id=%s",
+        (req_id,)
+    )
+    conn.commit()
+
+# ==============================
+# 🏁 DONE
+# ==============================
+
+print("\n🎯 Export complete.\n")
+cur_blob.close()
+cur_meta.close()
+conn.close()

10ReadPozadavky/PRAVIDELNE_5_SaveToFileSystem incremental2.py

@@ -0,0 +1,193 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import os
+import shutil
+import pymysql
+import re
+from pathlib import Path
+from datetime import datetime
+
+# ==============================
+# ⚙️ CONFIGURATION
+# ==============================
+DB_CONFIG = {
+    "host": "192.168.1.76",
+    "port": 3307,
+    "user": "root",
+    "password": "Vlado9674+",
+    "database": "medevio",
+    "charset": "utf8mb4",
+}
+
+BASE_DIR = Path(r"u:\Dropbox\Ordinace\Dokumentace_ke_zpracování\MP")
+BASE_DIR.mkdir(parents=True, exist_ok=True)
+
+
+def sanitize_name(name: str) -> str:
+    """Replace invalid filename characters with underscore."""
+    return re.sub(r'[<>:"/\\|?*\x00-\x1F]', "_", name).strip()
+
+
+def make_abbrev(title: str) -> str:
+    """Create abbreviation from displayTitle."""
+    if not title:
+        return ""
+    words = re.findall(r"[A-Za-zÁ-Žá-ž0-9]+", title)
+    abbr = ""
+    for w in words:
+        abbr += w if w.isdigit() else w[0]
+    return abbr.upper()
+
+
+# ==============================
+# 🧹 DELETE UNEXPECTED FILES
+# ==============================
+def clean_folder(folder: Path, valid_files: set):
+    if not folder.exists():
+        return
+
+    for f in folder.iterdir():
+        if f.is_file():
+            if f.name.startswith("▲"):
+                continue
+            sanitized = sanitize_name(f.name)
+            if sanitized not in valid_files:
+                print(f"🗑️ Removing unexpected file: {f.name}")
+                try:
+                    f.unlink()
+                except Exception as e:
+                    print(f"⚠️ Could not delete {f}: {e}")
+
+
+# ==============================
+# 📦 DB CONNECTION
+# ==============================
+conn = pymysql.connect(**DB_CONFIG)
+cur_meta = conn.cursor(pymysql.cursors.DictCursor)
+cur_blob = conn.cursor()
+
+print("🔍 Loading ALL metadata without file_content…")
+
+# ⭐ Load ALL metadata once (NO BLOBs)
+cur_meta.execute("""
+    SELECT 
+        d.request_id,
+        d.filename,
+        d.created_at,
+        p.updatedAt AS req_updated_at,
+        p.pacient_jmeno AS jmeno,
+        p.pacient_prijmeni AS prijmeni,
+        p.displayTitle
+    FROM medevio_downloads d
+    JOIN pozadavky p ON d.request_id = p.id
+    ORDER BY p.updatedAt DESC;
+""")
+
+rows = cur_meta.fetchall()
+print(f"📋 Found {len(rows)} metadata rows.\n")
+
+# ==============================
+# 🧠 PRE-GROUP METADATA
+# ==============================
+
+# Build dictionary: request_id → all metadata rows for that request
+grouped = {}
+for row in rows:
+    grouped.setdefault(row["request_id"], []).append(row)
+
+unique_request_ids = list(grouped.keys())
+total_requests = len(unique_request_ids)
+
+print(f"🔄 Processing {total_requests} unique requests…\n")
+
+# ==============================
+# 🧠 MAIN LOOP
+# ==============================
+
+for idx, req_id in enumerate(unique_request_ids, start=1):
+    pct = (idx / total_requests) * 100
+    req_rows = grouped[req_id]
+    first = req_rows[0]
+
+    print(f"\n[ {pct:5.1f}% ] Processing request {idx}/{total_requests} → {req_id}")
+
+    # ======================
+    # Build folder name
+    # ======================
+    updated_at = first["req_updated_at"] or datetime.now()
+    date_str = updated_at.strftime("%Y-%m-%d")
+    prijmeni = sanitize_name(first["prijmeni"] or "Unknown")
+    jmeno   = sanitize_name(first["jmeno"] or "")
+    abbr    = make_abbrev(first["displayTitle"] or "")
+
+    clean_folder_name = sanitize_name(f"{date_str} {prijmeni}, {jmeno} [{abbr}] {req_id}")
+
+    # Detect existing folder
+    existing_folder = None
+    for f in BASE_DIR.iterdir():
+        if f.is_dir() and req_id in f.name:
+            existing_folder = f
+            break
+
+    main_folder = existing_folder if existing_folder else BASE_DIR / clean_folder_name
+    main_folder.mkdir(parents=True, exist_ok=True)
+
+    # ======================
+    # Valid files for this request
+    # ======================
+    valid_files = {sanitize_name(r["filename"]) for r in req_rows}
+
+    # Clean unexpected files
+    clean_folder(main_folder, valid_files)
+
+    # ======================
+    # DOWNLOAD MISSING FILES → only now load BLOBs
+    # ======================
+    added_new_file = False
+
+    for r in req_rows:
+        filename = sanitize_name(r["filename"])
+        dest_plain = main_folder / filename
+        dest_marked = main_folder / ("▲" + filename)
+
+        if dest_plain.exists() or dest_marked.exists():
+            continue
+
+        added_new_file = True
+
+        # ⭐ Load BLOB only when needed
+        cur_blob.execute("""
+            SELECT file_content
+            FROM medevio_downloads
+            WHERE request_id=%s AND filename=%s
+        """, (req_id, r["filename"]))
+
+        row = cur_blob.fetchone()
+        if not row or not row[0]:
+            continue
+
+        with open(dest_plain, "wb") as f:
+            f.write(row[0])
+
+        print(f"💾 Wrote: {dest_plain.relative_to(BASE_DIR)}")
+
+    # ======================
+    # Folder-level ▲ logic
+    # ======================
+    if added_new_file and "▲" in main_folder.name:
+        new_name = main_folder.name.replace("▲", "").strip()
+        new_path = main_folder.parent / new_name
+
+        try:
+            main_folder.rename(new_path)
+            main_folder = new_path
+            print(f"🔄 Folder flag ▲ removed → {new_name}")
+        except Exception as e:
+            print(f"⚠️ Could not rename folder: {e}")
+
+cur_blob.close()
+cur_meta.close()
+conn.close()
+
+print("\n🎯 Export complete.\n")

10ReadPozadavky/PRAVIDELNE_log.txt

@@ -0,0 +1,29 @@
+[2025-12-01 06:37:41] === START pravidelného běhu ===
+[2025-12-01 06:37:42] ▶ Spouštím: PRAVIDELNE_0_READ_ALL_ACTIVE_POZADAVKY.py
+[2025-12-01 06:37:44] ↳ PRAVIDELNE_0_READ_ALL_ACTIVE_POZADAVKY.py return code: 0
+[2025-12-01 06:37:44] ▶ Spouštím: PRAVIDELNE_1_ReadLast300DonePozadavku.py
+[2025-12-01 06:37:48] ↳ PRAVIDELNE_1_ReadLast300DonePozadavku.py return code: 0
+[2025-12-01 06:37:48] ▶ Spouštím: PRAVIDELNE_2_ReadPoznamky.py
+[2025-12-01 06:37:49] ↳ PRAVIDELNE_2_ReadPoznamky.py return code: 0
+[2025-12-01 06:37:50] ▶ Spouštím: PRAVIDELNE_3_StahniKomunikaci.py
+[2025-12-01 06:37:51] ↳ PRAVIDELNE_3_StahniKomunikaci.py return code: 0
+[2025-12-01 06:37:52] ▶ Spouštím: PRAVIDELNE_4_StahniPrilohyUlozDoMySQL.py
+[2025-12-01 06:37:53] ↳ PRAVIDELNE_4_StahniPrilohyUlozDoMySQL.py return code: 0
+[2025-12-01 06:37:53] ▶ Spouštím: PRAVIDELNE_5_SaveToFileSystem incremental.py
+[2025-12-01 06:38:42] ↳ PRAVIDELNE_5_SaveToFileSystem incremental.py return code: 0
+[2025-12-01 06:38:43] === KONEC pravidelného běhu ===
+[2025-12-02 07:04:34] === START pravidelného běhu ===
+[2025-12-02 07:04:34] ▶ Spouštím: PRAVIDELNE_0_READ_ALL_ACTIVE_POZADAVKY.py
+[2025-12-02 07:04:35]    ↳ return code: 0
+[2025-12-02 07:04:35] ▶ Spouštím: PRAVIDELNE_1_ReadLast300DonePozadavku.py
+[2025-12-02 07:04:39]    ↳ return code: 0
+[2025-12-02 07:04:39] ▶ Spouštím: PRAVIDELNE_2_ReadPoznamky.py
+[2025-12-02 07:04:40]    ↳ return code: 0
+[2025-12-02 07:04:40] ▶ Spouštím: PRAVIDELNE_3_StahniKomunikaci.py
+[2025-12-02 07:04:40]    ↳ return code: 0
+[2025-12-02 07:04:40] ▶ Spouštím: PRAVIDELNE_4_StahniPrilohyUlozDoMySQL.py
+[2025-12-02 07:04:40]    ↳ return code: 0
+[2025-12-02 07:04:40] ▶ Spouštím: PRAVIDELNE_5_SaveToFileSystem incremental.py
+[2025-12-02 07:05:28]    ↳ return code: 0
+[2025-12-02 07:05:28] === KONEC pravidelného běhu ===
+

10ReadPozadavky/token.txt

@@ -1 +0,0 @@
-nYvrvgflIKcDiQg8Hhpud+qG8iGZ8eH8su4nyT/Mgcm7XQp65ygY9s39+O01wIpk/7sKd6fBHkiKvsqH

10ReadPozadavky/x0703 Plne funkční uložení do mysql.py

@@ -20,7 +20,7 @@ import time
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {

12 Readallinbatches/10 Readallpozadavkyinbatches.py

@@ -35,7 +35,7 @@ def safe_print(text: str):
 # ================================
 # 🔧 CONFIG
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 BATCH_SIZE = 500

12 Readallinbatches/PRAVIDELNE_3_StahniKomunikacifull.py

@@ -21,7 +21,7 @@ import argparse
 # ==============================
 # 🔧 CONFIGURATION
 # ==============================
-TOKEN_PATH = Path("../10ReadPozadavky/token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 
 DB_CONFIG = {
     "host": "192.168.1.76",

12 Readallinbatches/token.txt

@@ -1 +0,0 @@
-nYvrvgflIKcDiQg8Hhpud+qG8iGZ8eH8su4nyT/Mgcm7XQp65ygY9s39+O01wIpk/7sKd6fBHkiKvsqH

12 Tower1/10 ReadAllActive.py

@@ -21,7 +21,7 @@ except AttributeError:
 # ================================
 # 🔧 CONFIGURATION
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 BATCH_SIZE = 100
 

12 Tower1/12 ReadAllinBatches.py

@@ -35,7 +35,7 @@ def safe_print(text: str):
 # ================================
 # 🔧 CONFIG
 # ================================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 BATCH_SIZE = 500

12 Tower1/20 ReadPoznamky.py

@@ -41,7 +41,7 @@ def safe_print(text: str):
 # ==============================
 # 🔧 CONFIGURATION (UPDATED TO 192.168.1.50)
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 

12 Tower1/30 ReadConversation.py

@@ -19,7 +19,7 @@ except AttributeError:
 # ==============================
 # CONFIG (.50)
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 
 DB_CONFIG = {
     "host": "192.168.1.50",

12 Tower1/40 DownloadPrilohy.py

@@ -40,7 +40,7 @@ def safe_print(text: str):
 # ==============================
 # 🔧 CONFIGURATION (.50)
 # ==============================
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {

12 Tower1/token.txt

@@ -1 +0,0 @@
-nYvrvgflIKcDiQg8Hhpud+qG8iGZ8eH8su4nyT/Mgcm7XQp65ygY9s39+O01wIpk/7sKd6fBHkiKvsqH

30 ManipulacePoznámek/100 JednoducheCteni1poznamky.py

@@ -13,7 +13,7 @@ except:
 
 # === CONFIG ===
 
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 REQUEST_ID = "e17536c4-ed22-4242-ada5-d03713e0b7ac"   # požadavek který sledujeme
 

30 ManipulacePoznámek/101 JednoducheDoplneniInterniPoznamky.py

@@ -13,7 +13,7 @@ except:
 
 # === CONFIG ===
 
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 
 REQUEST_ID = "e17536c4-ed22-4242-ada5-d03713e0b7ac"   # požadavek

30 ManipulacePoznámek/102 Zapiš ID request do nejnovějšího otevřeného požadavku.py

@@ -16,7 +16,7 @@ except:
 # === KONFIGURACE ===
 
 # --- Medevio API ---
-TOKEN_PATH = Path("token.txt")
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
 GRAPHQL_URL = "https://api.medevio.cz/graphql"
 
 # --- ZPRACOVÁNÍ ---

30 ManipulacePoznámek/token.txt

@@ -1 +0,0 @@
-nYvrvgflIKcDiQg8Hhpud+qG8iGZ8eH8su4nyT/Mgcm7XQp65ygY9s39+O01wIpk/7sKd6fBHkiKvsqH

40 agenda a požadavky/Report_AgendaPozadavky.py

@@ -30,7 +30,7 @@ CLINIC_SLUG = "mudr-buzalkova"
 
 DB_CONFIG = {
     "host": "192.168.1.76",
-    "port": 3307,
+    "port": 3306,
     "user": "root",
     "password": "Vlado9674+",
     "database": "medevio",
@@ -40,26 +40,18 @@ DB_CONFIG = {
 
 EXPORT_DIR = Path(r"u:\Dropbox\Ordinace\Reporty")
 EXPORT_DIR.mkdir(exist_ok=True, parents=True)
-timestamp = datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
+
-xlsx_path = EXPORT_DIR / f"{timestamp} Agenda + Pozadavky (Merged).xlsx"
+# Delete previous reports
+for old in EXPORT_DIR.glob("* Agenda + Požadavky.xlsx"):
+    old.unlink()
+    print(f"🗑️ Deleted old report: {old.name}")
+
+timestamp = datetime.now().strftime("%Y-%m-%d %H-%M-%S")
+xlsx_path = EXPORT_DIR / f"{timestamp} Agenda + Požadavky.xlsx"
 
 # ==================== LOAD TOKEN ====================
-def load_gateway_token(storage_path="medevio_storage.json"):
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
-    path = Path(storage_path)
+gateway_token = TOKEN_PATH.read_text(encoding="utf-8").strip()
-    if not path.exists():
-        raise SystemExit(f"❌ Storage file not found: {path}")
-    with path.open("r", encoding="utf-8") as f:
-        state = json.load(f)
-    token = next(
-        (c["value"] for c in state["cookies"] if c["name"] == "gateway-access-token"),
-        None,
-    )
-    if not token:
-        raise SystemExit("❌ gateway-access-token not found in storage file.")
-    return token
-
-
-gateway_token = load_gateway_token()
 
 headers = {
     "content-type": "application/json",
@@ -80,8 +72,18 @@ thin_border = Border(
 )
 
 
+REQUEST_URL_TEMPLATE = "https://my.medevio.cz/mudr-buzalkova/klinika/pozadavky?pozadavek={}"
+link_font = Font(color="0563C1", underline="single")
+
+
 def format_ws(ws, df):
     """Apply unified formatting to a worksheet."""
+    # Find Request_ID column index (1-based)
+    req_id_col = None
+    columns = list(df.columns)
+    if "Request_ID" in columns:
+        req_id_col = columns.index("Request_ID") + 1
+
     for col_idx in range(1, len(df.columns) + 1):
         col_letter = get_column_letter(col_idx)
         cell = ws.cell(row=1, column=col_idx)
@@ -96,7 +98,12 @@ def format_ws(ws, df):
             cell.border = thin_border
             if r_idx % 2 == 0:
                 cell.fill = alt_fill
+            # Add hyperlink to Request_ID cells
+            if req_id_col and cell.column == req_id_col and cell.value:
+                cell.hyperlink = REQUEST_URL_TEMPLATE.format(cell.value)
+                cell.font = link_font
     ws.freeze_panes = "A2"
+    ws.auto_filter.ref = ws.dimensions
 
 
 # ==================== 1️⃣ LOAD AGENDA (API) ====================
@@ -138,7 +145,12 @@ payload = {
 
 r = requests.post(GRAPHQL_URL, headers=headers, data=json.dumps(payload))
 r.raise_for_status()
-reservations = r.json()["data"]["reservations"]
+resp = r.json()
+if "errors" in resp or "data" not in resp:
+    print("❌ API response:")
+    print(json.dumps(resp, indent=2, ensure_ascii=False))
+    raise SystemExit("API call failed - check token or query.")
+reservations = resp["data"]["reservations"]
 
 rows = []
 for r in reservations:

40 agenda a požadavky/check_mysql.py

@@ -0,0 +1,33 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""Check one request in MySQL."""
+
+import pymysql
+import json
+
+DB_CONFIG = {
+    "host": "192.168.1.76",
+    "port": 3306,
+    "user": "root",
+    "password": "Vlado9674+",
+    "database": "medevio",
+    "charset": "utf8mb4",
+    "cursorclass": pymysql.cursors.DictCursor,
+}
+
+REQUEST_ID = "6b46b5a8-b080-4821-86b0-39adabeec86b"
+
+conn = pymysql.connect(**DB_CONFIG)
+with conn.cursor() as cur:
+    cur.execute("SELECT * FROM pozadavky WHERE id = %s", (REQUEST_ID,))
+    row = cur.fetchone()
+conn.close()
+
+if row:
+    # Convert datetime objects to strings for JSON serialization
+    for k, v in row.items():
+        if hasattr(v, 'isoformat'):
+            row[k] = v.isoformat()
+    print(json.dumps(row, indent=2, ensure_ascii=False, default=str))
+else:
+    print(f"Not found: {REQUEST_ID}")

40 agenda a požadavky/check_request.py

@@ -0,0 +1,63 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""Quick check: fetch one request from Medevio API and print all fields."""
+
+import json
+import requests
+from pathlib import Path
+
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
+GRAPHQL_URL = "https://api.medevio.cz/graphql"
+CLINIC_SLUG = "mudr-buzalkova"
+REQUEST_ID = "6b46b5a8-b080-4821-86b0-39adabeec86b"
+
+token = TOKEN_PATH.read_text(encoding="utf-8").strip()
+headers = {
+    "content-type": "application/json",
+    "authorization": f"Bearer {token}",
+    "origin": "https://my.medevio.cz",
+    "referer": "https://my.medevio.cz/",
+}
+
+# Query with as many fields as possible
+QUERY = """
+query GetPatientRequest2($requestId: UUID!, $clinicSlug: String!, $locale: Locale!) {
+  request: getPatientRequest2(patientRequestId: $requestId, clinicSlug: $clinicSlug) {
+    id
+    displayTitle(locale: $locale)
+    createdAt
+    updatedAt
+    doneAt
+    removedAt
+    userNote
+    eventType
+    extendedPatient(clinicSlug: $clinicSlug) {
+      name
+      surname
+      dob
+      identificationNumber
+      insuranceCompanyObject { shortName }
+    }
+    ecrfFilledData(locale: $locale) {
+      name
+      groups {
+        label
+        fields { name label type value }
+      }
+    }
+  }
+}
+"""
+
+payload = {
+    "operationName": "GetPatientRequest2",
+    "query": QUERY,
+    "variables": {
+        "requestId": REQUEST_ID,
+        "clinicSlug": CLINIC_SLUG,
+        "locale": "cs",
+    },
+}
+
+r = requests.post(GRAPHQL_URL, json=payload, headers=headers, timeout=30)
+print(json.dumps(r.json(), indent=2, ensure_ascii=False))

40 agenda a požadavky/sync_open_requests.py

@@ -0,0 +1,176 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+"""
+Sync open requests: checks each request marked as open in MySQL (doneAt IS NULL
+AND removedAt IS NULL) against the Medevio API. If the API shows the request is
+closed (doneAt) or removed (removedAt), updates MySQL accordingly.
+"""
+
+import json
+import sys
+import time
+import requests
+import pymysql
+from pathlib import Path
+from datetime import datetime
+
+# ==============================
+# UTF-8 output (Windows friendly)
+# ==============================
+try:
+    sys.stdout.reconfigure(encoding="utf-8")
+    sys.stderr.reconfigure(encoding="utf-8")
+except AttributeError:
+    import io
+    sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding="utf-8")
+    sys.stderr = io.TextIOWrapper(sys.stderr.buffer, encoding="utf-8")
+
+# ==============================
+# DRY RUN - set to True to only print what would be updated, False to actually update
+# ==============================
+DRY_RUN = False
+
+# ==============================
+# CONFIG
+# ==============================
+GRAPHQL_URL = "https://api.medevio.cz/graphql"
+CLINIC_SLUG = "mudr-buzalkova"
+
+TOKEN_PATH = Path(__file__).resolve().parent.parent / "token.txt"
+
+gateway_token = TOKEN_PATH.read_text(encoding="utf-8").strip()
+headers = {
+    "content-type": "application/json",
+    "authorization": f"Bearer {gateway_token}",
+    "origin": "https://my.medevio.cz",
+    "referer": "https://my.medevio.cz/",
+}
+
+DB_CONFIG = {
+    "host": "192.168.1.76",
+    "port": 3306,
+    "user": "root",
+    "password": "Vlado9674+",
+    "database": "medevio",
+    "charset": "utf8mb4",
+    "cursorclass": pymysql.cursors.DictCursor,
+}
+
+GRAPHQL_QUERY = """
+query GetPatientRequest2($requestId: UUID!, $clinicSlug: String!) {
+  request: getPatientRequest2(patientRequestId: $requestId, clinicSlug: $clinicSlug) {
+    id
+    doneAt
+    removedAt
+    updatedAt
+  }
+}
+"""
+
+
+def fix_datetime(dt_str):
+    if not dt_str:
+        return None
+    try:
+        return datetime.fromisoformat(dt_str.replace("Z", "+00:00"))
+    except Exception:
+        return None
+
+
+def fetch_request(request_id):
+    payload = {
+        "operationName": "GetPatientRequest2",
+        "query": GRAPHQL_QUERY,
+        "variables": {
+            "requestId": request_id,
+            "clinicSlug": CLINIC_SLUG,
+        },
+    }
+    for attempt in range(3):
+        try:
+            r = requests.post(GRAPHQL_URL, json=payload, headers=headers, timeout=30)
+            break
+        except (requests.ConnectionError, requests.Timeout, requests.exceptions.RequestException) as e:
+            print(f"  ⚠️ Attempt {attempt+1}/3 failed: {e}")
+            time.sleep(2)
+    else:
+        print(f"  ❌ Connection failed after 3 attempts for {request_id}")
+        return None
+    if r.status_code != 200:
+        print(f"  ❌ HTTP {r.status_code} for {request_id}")
+        return None
+    data = r.json()
+    if "errors" in data:
+        print(f"  ❌ API error for {request_id}: {data['errors']}")
+        return None
+    return data.get("data", {}).get("request")
+
+
+# ==============================
+# MAIN
+# ==============================
+conn = pymysql.connect(**DB_CONFIG)
+
+# 1) Read all open requests from MySQL
+with conn.cursor() as cur:
+    cur.execute(
+        "SELECT id, displayTitle, pacient_prijmeni, pacient_jmeno "
+        "FROM pozadavky WHERE doneAt IS NULL AND removedAt IS NULL"
+    )
+    open_requests = cur.fetchall()
+
+mode = "DRY RUN" if DRY_RUN else "LIVE"
+print(f"🔧 Mode: {mode}")
+print(f"📋 Found {len(open_requests)} open requests in MySQL.\n")
+
+updated = 0
+errors = 0
+
+for i, req in enumerate(open_requests, 1):
+    rid = req["id"]
+    name = f"{req.get('pacient_prijmeni', '')} {req.get('pacient_jmeno', '')}".strip()
+    title = req.get("displayTitle", "")
+    print(f"[{i}/{len(open_requests)}] {name} – {title} ({rid})")
+
+    api_data = fetch_request(rid)
+    if api_data is None:
+        errors += 1
+        continue
+
+    api_done = api_data.get("doneAt")
+    api_removed = api_data.get("removedAt")
+    api_updated = api_data.get("updatedAt")
+
+    if api_done or api_removed:
+        done_dt = fix_datetime(api_done)
+        removed_dt = fix_datetime(api_removed)
+        updated_dt = fix_datetime(api_updated)
+
+        status = "DONE" if api_done else "REMOVED"
+
+        if DRY_RUN:
+            print(f"  🔍 Would update → {status} (doneAt={api_done}, removedAt={api_removed})")
+        else:
+            with conn.cursor() as cur:
+                cur.execute(
+                    "UPDATE pozadavky SET doneAt = %s, removedAt = %s, updatedAt = %s WHERE id = %s",
+                    (done_dt, removed_dt, updated_dt, rid),
+                )
+            conn.commit()
+            print(f"  ✅ Updated → {status}")
+
+        updated += 1
+    else:
+        print(f"  ⏳ Still open")
+
+    # Be gentle with the API
+    time.sleep(1)
+
+conn.close()
+
+print(f"\n{'='*50}")
+print(f"📊 Total open in MySQL: {len(open_requests)}")
+print(f"✅ Updated (closed/removed): {updated}")
+print(f"⏳ Still open: {len(open_requests) - updated - errors}")
+print(f"❌ Errors: {errors}")

86 Agenda měsíc dopředu.py

@@ -69,7 +69,7 @@ payload = {
         "calendarIds": [CALENDAR_ID],
         "clinicSlug": CLINIC_SLUG,
         "since": since_iso,
-        "until": "2025-11-30T21:59:59.999Z",
+        "until": until_iso,
         "locale": "cs",
         "emptyCalendarIds": False,
     },

Testy/token.txt

@@ -1 +0,0 @@
-nYvrvgflIKcDiQg8Hhpud+qG8iGZ8eH8su4nyT/Mgcm7XQp65ygY9s39+O01wIpk/7sKd6fBHkiKvsqH