169 lines
4.2 KiB
Python
169 lines
4.2 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
|
|
import pymysql
|
|
import requests
|
|
from pathlib import Path
|
|
from datetime import datetime
|
|
|
|
# ================================
|
|
# 🔧 CONFIGURATION
|
|
# ================================
|
|
TOKEN_PATH = Path("token.txt")
|
|
CLINIC_SLUG = "mudr-buzalkova"
|
|
|
|
LIMIT = 300 # download the latest 300 requests
|
|
|
|
DB_CONFIG = {
|
|
"host": "192.168.1.76",
|
|
"port": 3307,
|
|
"user": "root",
|
|
"password": "Vlado9674+",
|
|
"database": "medevio",
|
|
"charset": "utf8mb4",
|
|
"cursorclass": pymysql.cursors.DictCursor,
|
|
}
|
|
|
|
GRAPHQL_QUERY = r"""
|
|
query ClinicRequestGrid_ListPatientRequestsForClinic2(
|
|
$clinicSlug: String!,
|
|
$queueId: String,
|
|
$queueAssignment: QueueAssignmentFilter!,
|
|
$pageInfo: PageInfo!,
|
|
$locale: Locale!,
|
|
$state: PatientRequestState
|
|
) {
|
|
requestsResponse: listPatientRequestsForClinic2(
|
|
clinicSlug: $clinicSlug,
|
|
queueId: $queueId,
|
|
queueAssignment: $queueAssignment,
|
|
pageInfo: $pageInfo,
|
|
state: $state
|
|
) {
|
|
count
|
|
patientRequests {
|
|
id
|
|
displayTitle(locale: $locale)
|
|
createdAt
|
|
updatedAt
|
|
doneAt
|
|
removedAt
|
|
extendedPatient {
|
|
name
|
|
surname
|
|
identificationNumber
|
|
}
|
|
}
|
|
}
|
|
}
|
|
"""
|
|
|
|
# ================================
|
|
# TOKEN
|
|
# ================================
|
|
def read_token(p: Path) -> str:
|
|
tok = p.read_text(encoding="utf-8").strip()
|
|
if tok.startswith("Bearer "):
|
|
return tok.split(" ", 1)[1]
|
|
return tok
|
|
|
|
# ================================
|
|
# DATE PARSER
|
|
# ================================
|
|
def to_mysql_dt(iso_str):
|
|
if not iso_str:
|
|
return None
|
|
try:
|
|
dt = datetime.fromisoformat(iso_str.replace("Z", "+00:00"))
|
|
return dt.strftime("%Y-%m-%d %H:%M:%S")
|
|
except:
|
|
return None
|
|
|
|
# ================================
|
|
# UPSERT
|
|
# ================================
|
|
def upsert(conn, r):
|
|
p = (r.get("extendedPatient") or {})
|
|
sql = """
|
|
INSERT INTO pozadavky (
|
|
id, displayTitle, createdAt, updatedAt, doneAt, removedAt,
|
|
pacient_jmeno, pacient_prijmeni, pacient_rodnecislo
|
|
) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s)
|
|
ON DUPLICATE KEY UPDATE
|
|
displayTitle=VALUES(displayTitle),
|
|
updatedAt=VALUES(updatedAt),
|
|
doneAt=VALUES(doneAt),
|
|
removedAt=VALUES(removedAt),
|
|
pacient_jmeno=VALUES(pacient_jmeno),
|
|
pacient_prijmeni=VALUES(pacient_prijmeni),
|
|
pacient_rodnecislo=VALUES(pacient_rodnecislo)
|
|
"""
|
|
vals = (
|
|
r.get("id"),
|
|
r.get("displayTitle"),
|
|
to_mysql_dt(r.get("createdAt")),
|
|
to_mysql_dt(r.get("updatedAt")),
|
|
to_mysql_dt(r.get("doneAt")),
|
|
to_mysql_dt(r.get("removedAt")),
|
|
p.get("name"),
|
|
p.get("surname"),
|
|
p.get("identificationNumber"),
|
|
)
|
|
with conn.cursor() as cur:
|
|
cur.execute(sql, vals)
|
|
conn.commit()
|
|
|
|
# ================================
|
|
# FETCH LATEST 300 REQUESTS
|
|
# ================================
|
|
def fetch_latest_requests(headers):
|
|
vars = {
|
|
"clinicSlug": CLINIC_SLUG,
|
|
"queueId": None,
|
|
"queueAssignment": "ANY",
|
|
"pageInfo": {"first": LIMIT, "offset": 0},
|
|
"locale": "cs",
|
|
"state": "DONE" # ALL STATES (ACTIVE, DONE, REMOVED)
|
|
}
|
|
|
|
payload = {
|
|
"operationName": "ClinicRequestGrid_ListPatientRequestsForClinic2",
|
|
"query": GRAPHQL_QUERY,
|
|
"variables": vars,
|
|
}
|
|
|
|
r = requests.post("https://api.medevio.cz/graphql", json=payload, headers=headers)
|
|
r.raise_for_status()
|
|
|
|
data = r.json()["data"]["requestsResponse"]
|
|
return data.get("patientRequests", [])
|
|
|
|
# ================================
|
|
# MAIN
|
|
# ================================
|
|
def main():
|
|
token = read_token(TOKEN_PATH)
|
|
headers = {
|
|
"Authorization": f"Bearer {token}",
|
|
"Content-Type": "application/json",
|
|
"Accept": "application/json",
|
|
}
|
|
|
|
conn = pymysql.connect(**DB_CONFIG)
|
|
|
|
print(f"\n=== Downloading last {LIMIT} requests @ {datetime.now():%Y-%m-%d %H:%M:%S} ===")
|
|
|
|
requests_list = fetch_latest_requests(headers)
|
|
|
|
print(f"📌 Requests returned: {len(requests_list)}")
|
|
|
|
for r in requests_list:
|
|
upsert(conn, r)
|
|
|
|
conn.close()
|
|
print("\n✅ Done. Latest requests synced.\n")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|