insurance/20 Ověření proti Medicus/10 FinalSaveInsuranceStatusScript(R).py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# this script can be run several times on the same day, in such case it works incrementally

import sys
from pathlib import Path

# ==========================================
# PROJECT ROOT (import fix)
# ==========================================
PROJECT_ROOT = Path(__file__).resolve().parent.parent
sys.path.insert(0, str(PROJECT_ROOT))

import time
import logging
from knihovny.medicus_db import MedicusDB
from knihovny.vzpb2b_client import VZPB2BClient
import pymysql
from datetime import date

# ==========================================
# LOGGING SETUP
# ==========================================
logging.basicConfig(
    filename="insurance_check.log",
    level=logging.INFO,
    format="%(asctime)s [%(levelname)s] %(message)s",
    encoding="utf-8"
)

console = logging.getLogger("console")
console.setLevel(logging.INFO)
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter("%(message)s"))
console.addHandler(handler)

def log_info(msg):
    logging.info(msg)
    console.info(msg)

def log_error(msg):
    logging.error(msg)
    console.error(msg)

# ==========================================
# MYSQL CONNECTION
# ==========================================
mysql = pymysql.connect(
    host="192.168.1.76",
    port=3307,
    user="root",
    password="Vlado9674+",
    database="medevio",
    charset="utf8mb4",
    autocommit=True
)

# ==========================================
# SAVE RESULT
# ==========================================
def save_insurance_status(mysql_conn, rc, prijmeni, jmeno, k_datu, result, xml_text):
    """
    Uloží čistou odpověď VZP + identifikační údaje pacienta.
    Pojišťovna je VÝHRADNĚ z odpovědi VZP.
    """
    sql = """
    INSERT INTO vzp_stav_pojisteni
        (rc, prijmeni, jmeno, k_datu,
         stav, kod_pojistovny, nazev_pojistovny,
         pojisteni_kod, stav_vyrizeni, response_xml)
    VALUES (%s, %s, %s, %s,
            %s, %s, %s,
            %s, %s, %s)
    """

    with mysql_conn.cursor() as cur:
        cur.execute(sql, (
            rc,
            prijmeni,
            jmeno,
            k_datu,
            result["stav"],
            result["kodPojistovny"],      # ← VZP
            result["nazevPojistovny"],    # ← VZP
            result["pojisteniKod"],       # ← VZP
            result["stavVyrizeni"],       # ← VZP
            xml_text
        ))


# ==========================================
# CONFIGURATION
# ==========================================
# con = fdb.connect(
#     host='192.168.1.10', database=r'm:\MEDICUS\data\medicus.FDB',
#     user='sysdba', password='masterkey',charset='WIN1250')
HOST = "192.168.1.4"
DB_PATH = r"z:\Medicus 3\data\MEDICUS.FDB"

PFX_PATH = PROJECT_ROOT / "certificates" / "picka.pfx"
# PFX_PATH = PROJECT_ROOT / "certificates" / "MBcert.pfx"
PFX_PASSWORD = "Vlado7309208104+"

ENV = "prod"
ICZ = "00000000"
DIC = "00000000"

# sanity check
if not PFX_PATH.exists():
    raise FileNotFoundError(f"PFX certificate not found: {PFX_PATH}")

# ==========================================
# INIT CONNECTIONS
# ==========================================
db = MedicusDB(HOST, DB_PATH)
vzp = VZPB2BClient(
    ENV,
    str(PFX_PATH),   # <-- important: pass as string
    PFX_PASSWORD,
    icz=ICZ,
    dic=DIC
)

# ==========================================
# FETCH REGISTERED PATIENTS
# ==========================================
patients = db.get_active_registered_patients()
log_info(f"Loaded {len(patients)} registered patients")

today = date.today()

# ==========================================
# FILTER: ONLY PATIENTS NOT CHECKED TODAY
# ==========================================
patients_to_check = []

with mysql.cursor(pymysql.cursors.DictCursor) as cur:
    for rc, prijmeni, jmeno, poj in patients:
        cur.execute(
            "SELECT MAX(k_datu) AS last_check FROM vzp_stav_pojisteni WHERE rc = %s",
            (rc,)
        )
        row = cur.fetchone()
        last_check = row["last_check"]

        if last_check is None or last_check < today:
            patients_to_check.append((rc, prijmeni, jmeno))

log_info(f"Incremental run: {len(patients_to_check)} patients to check today\n")

# ==========================================
# MAIN LOOP (1 of N)
# ==========================================
total = len(patients_to_check)

for idx, (rodcis, prijmeni, jmeno) in enumerate(patients_to_check, 1):

    log_info(f"[{idx}/{total}] Checking {prijmeni} {jmeno} ({rodcis})")

    try:
        xml = vzp.stav_pojisteni(rc=rodcis, k_datu=today.isoformat())
    except Exception as e:
        log_error(f"❌ VZP REQUEST FAILED for {rodcis}: {e}")
        time.sleep(2)
        continue

    if not xml.strip().startswith("<"):
        log_error(f"❌ INVALID XML for RC {rodcis}")
        time.sleep(2)
        continue

    try:
        result = vzp.parse_stav_pojisteni(xml)
    except Exception as e:
        log_error(f"❌ XML PARSE ERROR for RC {rodcis}: {e}")
        time.sleep(2)
        continue

    try:
        save_insurance_status(
            mysql,
            rodcis,
            prijmeni,
            jmeno,
            today,
            result,
            xml
        )
    except Exception as e:
        log_error(f"❌ MYSQL INSERT ERROR for RC {rodcis}: {e}")
        time.sleep(2)
        continue

    log_info(f"   ✔ OK ({result['nazevPojistovny']})")
    time.sleep(2)

db.close()
mysql.close()
log_info("\nDONE – incremental insurance check finished.")