notebookvb
This commit is contained in:
@@ -0,0 +1,135 @@
|
||||
#!/usr/bin/env python3
|
||||
# -*- coding: utf-8 -*-
|
||||
import sys as _sys
|
||||
_sys.stdout.reconfigure(encoding="utf-8", errors="replace")
|
||||
_sys.stderr.reconfigure(encoding="utf-8", errors="replace")
|
||||
"""
|
||||
07_doplnit_zahajeni.py
|
||||
======================
|
||||
Pro nové pacienty (první dávka po 31.12.2024) kteří jsou již ukončeni
|
||||
a nemají záznam v vzp_registrace_lekari pro naše ICP=09305001,
|
||||
dotáže se VZP k datu jejich první dávky — tehdy tam ještě byli
|
||||
a odpověď obsahuje datumZahajeni registrace u nás.
|
||||
|
||||
Výsledek uloží do vzp_registrace_lekari (stejná tabulka jako kdojelekar).
|
||||
"""
|
||||
|
||||
import sys
|
||||
import time
|
||||
from datetime import date
|
||||
from pathlib import Path
|
||||
|
||||
sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "Knihovny"))
|
||||
from mysql_db import connect_mysql
|
||||
from vzpb2b_client import VZPB2BClient
|
||||
|
||||
PFX_PATH = str(Path(__file__).resolve().parents[1] / "Certificates" / "picka.pfx")
|
||||
PFX_PASSWORD = "Vlado7309208104+"
|
||||
ICZ = "09305000"
|
||||
NASA_ICP = "09305001"
|
||||
API_PAUSE = 2
|
||||
|
||||
PRVNI_DAVKA = date(2024, 12, 1)
|
||||
|
||||
# ── Načtení kandidátů ─────────────────────────────────────────────────────────
|
||||
conn = connect_mysql()
|
||||
cur = conn.cursor()
|
||||
|
||||
# Noví pacienti (prvni_davka > 31.12.2024) bez záznamu v registrace pro naše ICP
|
||||
cur.execute("""
|
||||
SELECT
|
||||
s.cip,
|
||||
MIN(s.prijmeni) AS prijmeni,
|
||||
MIN(s.jmeno) AS jmeno,
|
||||
MIN(DATE(CONCAT(s.davka_rok,'-',LPAD(s.davka_mesic,2,'0'),'-',LPAD(s.davka_den,2,'0')))) AS prvni_davka
|
||||
FROM seznam_pojistencu_davky s
|
||||
WHERE s.pojistovna = '111'
|
||||
GROUP BY s.cip
|
||||
HAVING prvni_davka > %s
|
||||
""", (PRVNI_DAVKA,))
|
||||
vsichni_novi = {r[0]: (r[1], r[2], r[3]) for r in cur.fetchall()}
|
||||
|
||||
# Kteří z nich už mají záznam v registrace pro naše ICP
|
||||
cur.execute("""
|
||||
SELECT DISTINCT rc FROM vzp_registrace_lekari
|
||||
WHERE ICP = %s AND kod_odbornosti = '001' AND ma_lekare = 1
|
||||
""", (NASA_ICP,))
|
||||
uz_maji = {r[0] for r in cur.fetchall()}
|
||||
|
||||
kandidati = {
|
||||
cip: info
|
||||
for cip, info in vsichni_novi.items()
|
||||
if cip not in uz_maji
|
||||
}
|
||||
|
||||
print(f"Noví pacienti celkem: {len(vsichni_novi)}")
|
||||
print(f"Již mají datum zahájení: {len(uz_maji & vsichni_novi.keys())}")
|
||||
print(f"Ke doplnění: {len(kandidati)}")
|
||||
|
||||
if not kandidati:
|
||||
print("Vše je kompletní.")
|
||||
cur.close(); conn.close(); sys.exit(0)
|
||||
|
||||
vzp = VZPB2BClient("prod", PFX_PATH, PFX_PASSWORD, icz=ICZ)
|
||||
|
||||
print()
|
||||
sirka = max(len(f"{p} {j}") for p, j, _ in kandidati.values()) + 2
|
||||
|
||||
for i, (cip, (prijmeni, jmeno, prvni_davka)) in enumerate(kandidati.items(), 1):
|
||||
print(f"[{i:>2}/{len(kandidati)}] {prijmeni+' '+jmeno:<{sirka}} ({cip}) k {prvni_davka}", end=" ", flush=True)
|
||||
|
||||
try:
|
||||
xml = vzp.registrace_lekare(cip, prvni_davka.isoformat(), odbornosti=["001"])
|
||||
time.sleep(API_PAUSE)
|
||||
zaznamy = vzp.parse_registrace_lekare(xml)
|
||||
except Exception as e:
|
||||
print(f"CHYBA: {e}")
|
||||
continue
|
||||
|
||||
nas_zaznam = next(
|
||||
(z for z in zaznamy
|
||||
if z.get("ma_lekare") and z.get("ICP") == NASA_ICP and z.get("kod_odbornosti") == "001"),
|
||||
None
|
||||
)
|
||||
|
||||
if not nas_zaznam:
|
||||
print("→ nenalezen k tomuto datu")
|
||||
continue
|
||||
|
||||
def to_date(s):
|
||||
try:
|
||||
return date.fromisoformat(s) if s else None
|
||||
except ValueError:
|
||||
return None
|
||||
|
||||
poj_el = nas_zaznam
|
||||
cur.execute("""
|
||||
INSERT INTO vzp_registrace_lekari
|
||||
(rc, prijmeni, jmeno, k_datu, kod_odbornosti, ma_lekare,
|
||||
ICZ, ICP, nazev_lekare, nazev_zzz,
|
||||
poj_kod, poj_zkratka,
|
||||
datum_registrace, datum_zahajeni, datum_ukonceni, stav_vyrizeni)
|
||||
VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)
|
||||
ON DUPLICATE KEY UPDATE
|
||||
datum_zahajeni = VALUES(datum_zahajeni),
|
||||
datum_ukonceni = VALUES(datum_ukonceni),
|
||||
nazev_lekare = VALUES(nazev_lekare),
|
||||
nazev_zzz = VALUES(nazev_zzz)
|
||||
""", (
|
||||
cip, prijmeni, jmeno, prvni_davka, "001", 1,
|
||||
nas_zaznam.get("ICZ"), nas_zaznam.get("ICP"),
|
||||
nas_zaznam.get("nazev_lekare"), nas_zaznam.get("nazev_zzz"),
|
||||
nas_zaznam.get("poj_kod"), nas_zaznam.get("poj_zkratka"),
|
||||
to_date(nas_zaznam.get("datum_registrace")),
|
||||
to_date(nas_zaznam.get("datum_zahajeni")),
|
||||
to_date(nas_zaznam.get("datum_ukonceni")),
|
||||
nas_zaznam.get("stav_vyrizeni"),
|
||||
))
|
||||
|
||||
dz = nas_zaznam.get("datum_zahajeni") or "?"
|
||||
du = nas_zaznam.get("datum_ukonceni") or "?"
|
||||
print(f"→ zahájení: {dz} ukončení: {du}")
|
||||
|
||||
cur.close()
|
||||
conn.close()
|
||||
print(f"\nHotovo.")
|
||||
Reference in New Issue
Block a user