Compare commits
10 Commits
abb1ae97c4
...
33cdd2d0e2
| Author | SHA1 | Date | |
|---|---|---|---|
| 33cdd2d0e2 | |||
| 3fa7996580 | |||
| 3758a423eb | |||
|
746963157a | ||
| 70f54d1da5 | |||
| 7fbeba5a1d | |||
| 3d3784ce58 | |||
| a43a06619e | |||
|
|
6324d626be | ||
|
|
37c0ab7d23 |
14
.gitignore
vendored
Normal file
14
.gitignore
vendored
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
# Virtual environment
|
||||||
|
.venv/
|
||||||
|
|
||||||
|
# Python
|
||||||
|
__pycache__/
|
||||||
|
*.pyc
|
||||||
|
*.log
|
||||||
|
|
||||||
|
# IDE
|
||||||
|
.idea/
|
||||||
|
|
||||||
|
# OS
|
||||||
|
.DS_Store
|
||||||
|
Thumbs.db
|
||||||
10
.idea/Insurance.iml
generated
10
.idea/Insurance.iml
generated
@@ -1,10 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<module type="PYTHON_MODULE" version="4">
|
|
||||||
<component name="NewModuleRootManager">
|
|
||||||
<content url="file://$MODULE_DIR$">
|
|
||||||
<excludeFolder url="file://$MODULE_DIR$/.venv" />
|
|
||||||
</content>
|
|
||||||
<orderEntry type="jdk" jdkName="Python 3.12 (Insurance)" jdkType="Python SDK" />
|
|
||||||
<orderEntry type="sourceFolder" forTests="false" />
|
|
||||||
</component>
|
|
||||||
</module>
|
|
||||||
6
.idea/inspectionProfiles/profiles_settings.xml
generated
6
.idea/inspectionProfiles/profiles_settings.xml
generated
@@ -1,6 +0,0 @@
|
|||||||
<component name="InspectionProjectProfileManager">
|
|
||||||
<settings>
|
|
||||||
<option name="USE_PROJECT_PROFILE" value="false" />
|
|
||||||
<version value="1.0" />
|
|
||||||
</settings>
|
|
||||||
</component>
|
|
||||||
10
.idea/misc.xml
generated
10
.idea/misc.xml
generated
@@ -1,10 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="Black">
|
|
||||||
<option name="sdkName" value="Python 3.12 (insurance)" />
|
|
||||||
</component>
|
|
||||||
<component name="ProjectRootManager" version="2" project-jdk-name="Python 3.12 (Insurance)" project-jdk-type="Python SDK" />
|
|
||||||
<component name="PythonCompatibilityInspectionAdvertiser">
|
|
||||||
<option name="version" value="3" />
|
|
||||||
</component>
|
|
||||||
</project>
|
|
||||||
8
.idea/modules.xml
generated
8
.idea/modules.xml
generated
@@ -1,8 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="ProjectModuleManager">
|
|
||||||
<modules>
|
|
||||||
<module fileurl="file://$PROJECT_DIR$/.idea/Insurance.iml" filepath="$PROJECT_DIR$/.idea/Insurance.iml" />
|
|
||||||
</modules>
|
|
||||||
</component>
|
|
||||||
</project>
|
|
||||||
File diff suppressed because one or more lines are too long
@@ -1,4 +0,0 @@
|
|||||||
<changelist name="Uncommitted_changes_before_Update_at_28_09_2025_15_33_[Changes]" date="1759066420299" recycled="false" toDelete="true">
|
|
||||||
<option name="PATH" value="$PROJECT_DIR$/.idea/shelf/Uncommitted_changes_before_Update_at_28_09_2025_15_33_[Changes]/shelved.patch" />
|
|
||||||
<option name="DESCRIPTION" value="Uncommitted changes before Update at 28.09.2025 15:33 [Changes]" />
|
|
||||||
</changelist>
|
|
||||||
6
.idea/vcs.xml
generated
6
.idea/vcs.xml
generated
@@ -1,6 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="VcsDirectoryMappings">
|
|
||||||
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
|
||||||
</component>
|
|
||||||
</project>
|
|
||||||
205
.idea/workspace.xml
generated
205
.idea/workspace.xml
generated
@@ -1,205 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="AutoImportSettings">
|
|
||||||
<option name="autoReloadType" value="SELECTIVE" />
|
|
||||||
</component>
|
|
||||||
<component name="ChangeListManager">
|
|
||||||
<list default="true" id="c323bf66-f6a5-4ac2-b555-4106254af180" name="Changes" comment="notebookVB">
|
|
||||||
<change beforePath="$PROJECT_DIR$/.idea/Insurance.iml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/Insurance.iml" afterDir="false" />
|
|
||||||
<change beforePath="$PROJECT_DIR$/.idea/misc.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/misc.xml" afterDir="false" />
|
|
||||||
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
|
|
||||||
<change beforePath="$PROJECT_DIR$/02 testík.py" beforeDir="false" afterPath="$PROJECT_DIR$/02 testík.py" afterDir="false" />
|
|
||||||
<change beforePath="$PROJECT_DIR$/03 Vyber.py" beforeDir="false" afterPath="$PROJECT_DIR$/03 VyberKontrolaStavuPojisteni.py" afterDir="false" />
|
|
||||||
</list>
|
|
||||||
<option name="SHOW_DIALOG" value="false" />
|
|
||||||
<option name="HIGHLIGHT_CONFLICTS" value="true" />
|
|
||||||
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
|
|
||||||
<option name="LAST_RESOLUTION" value="IGNORE" />
|
|
||||||
</component>
|
|
||||||
<component name="FileTemplateManagerImpl">
|
|
||||||
<option name="RECENT_TEMPLATES">
|
|
||||||
<list>
|
|
||||||
<option value="Python Script" />
|
|
||||||
</list>
|
|
||||||
</option>
|
|
||||||
</component>
|
|
||||||
<component name="Git.Settings">
|
|
||||||
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
|
|
||||||
</component>
|
|
||||||
<component name="GitHubPullRequestSearchHistory">{
|
|
||||||
"lastFilter": {
|
|
||||||
"state": "OPEN",
|
|
||||||
"assignee": "vladobb"
|
|
||||||
}
|
|
||||||
}</component>
|
|
||||||
<component name="GithubPullRequestsUISettings">{
|
|
||||||
"selectedUrlAndAccountId": {
|
|
||||||
"url": "https://github.com/vladobb/insurance",
|
|
||||||
"accountId": "838a92c2-8532-43e8-a61a-667fe50b88ed"
|
|
||||||
}
|
|
||||||
}</component>
|
|
||||||
<component name="ProjectColorInfo">{
|
|
||||||
"associatedIndex": 1
|
|
||||||
}</component>
|
|
||||||
<component name="ProjectId" id="33FcC2tYI91g8V8fLuzrpFNOGkY" />
|
|
||||||
<component name="ProjectLevelVcsManager" settingsEditedManually="true">
|
|
||||||
<ConfirmationsSetting value="2" id="Add" />
|
|
||||||
</component>
|
|
||||||
<component name="ProjectViewState">
|
|
||||||
<option name="hideEmptyMiddlePackages" value="true" />
|
|
||||||
<option name="showLibraryContents" value="true" />
|
|
||||||
</component>
|
|
||||||
<component name="PropertiesComponent">{
|
|
||||||
"keyToString": {
|
|
||||||
"Python.01 testik.executor": "Run",
|
|
||||||
"Python.02 testík.executor": "Run",
|
|
||||||
"Python.03 Vyber.executor": "Run",
|
|
||||||
"Python.05 testik.executor": "Run",
|
|
||||||
"RunOnceActivity.ShowReadmeOnStart": "true",
|
|
||||||
"RunOnceActivity.git.unshallow": "true",
|
|
||||||
"git-widget-placeholder": "master",
|
|
||||||
"ignore.virus.scanning.warn.message": "true",
|
|
||||||
"settings.editor.selected.configurable": "com.jetbrains.python.configuration.PyActiveSdkModuleConfigurable"
|
|
||||||
}
|
|
||||||
}</component>
|
|
||||||
<component name="RunManager" selected="Python.02 testík">
|
|
||||||
<configuration name="01 testik" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
|
|
||||||
<module name="Insurance" />
|
|
||||||
<option name="ENV_FILES" value="" />
|
|
||||||
<option name="INTERPRETER_OPTIONS" value="" />
|
|
||||||
<option name="PARENT_ENVS" value="true" />
|
|
||||||
<envs>
|
|
||||||
<env name="PYTHONUNBUFFERED" value="1" />
|
|
||||||
</envs>
|
|
||||||
<option name="SDK_HOME" value="" />
|
|
||||||
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
|
|
||||||
<option name="IS_MODULE_SDK" value="true" />
|
|
||||||
<option name="ADD_CONTENT_ROOTS" value="true" />
|
|
||||||
<option name="ADD_SOURCE_ROOTS" value="true" />
|
|
||||||
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/01 testik.py" />
|
|
||||||
<option name="PARAMETERS" value="" />
|
|
||||||
<option name="SHOW_COMMAND_LINE" value="false" />
|
|
||||||
<option name="EMULATE_TERMINAL" value="false" />
|
|
||||||
<option name="MODULE_MODE" value="false" />
|
|
||||||
<option name="REDIRECT_INPUT" value="false" />
|
|
||||||
<option name="INPUT_FILE" value="" />
|
|
||||||
<method v="2" />
|
|
||||||
</configuration>
|
|
||||||
<configuration name="02 testík" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
|
|
||||||
<module name="Insurance" />
|
|
||||||
<option name="ENV_FILES" value="" />
|
|
||||||
<option name="INTERPRETER_OPTIONS" value="" />
|
|
||||||
<option name="PARENT_ENVS" value="true" />
|
|
||||||
<envs>
|
|
||||||
<env name="PYTHONUNBUFFERED" value="1" />
|
|
||||||
</envs>
|
|
||||||
<option name="SDK_HOME" value="" />
|
|
||||||
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
|
|
||||||
<option name="IS_MODULE_SDK" value="true" />
|
|
||||||
<option name="ADD_CONTENT_ROOTS" value="true" />
|
|
||||||
<option name="ADD_SOURCE_ROOTS" value="true" />
|
|
||||||
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/02 testík.py" />
|
|
||||||
<option name="PARAMETERS" value="" />
|
|
||||||
<option name="SHOW_COMMAND_LINE" value="false" />
|
|
||||||
<option name="EMULATE_TERMINAL" value="false" />
|
|
||||||
<option name="MODULE_MODE" value="false" />
|
|
||||||
<option name="REDIRECT_INPUT" value="false" />
|
|
||||||
<option name="INPUT_FILE" value="" />
|
|
||||||
<method v="2" />
|
|
||||||
</configuration>
|
|
||||||
<configuration name="03 VyberKontrolaStavuPojisteni" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
|
|
||||||
<module name="Insurance" />
|
|
||||||
<option name="ENV_FILES" value="" />
|
|
||||||
<option name="INTERPRETER_OPTIONS" value="" />
|
|
||||||
<option name="PARENT_ENVS" value="true" />
|
|
||||||
<envs>
|
|
||||||
<env name="PYTHONUNBUFFERED" value="1" />
|
|
||||||
</envs>
|
|
||||||
<option name="SDK_HOME" value="" />
|
|
||||||
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
|
|
||||||
<option name="IS_MODULE_SDK" value="true" />
|
|
||||||
<option name="ADD_CONTENT_ROOTS" value="true" />
|
|
||||||
<option name="ADD_SOURCE_ROOTS" value="true" />
|
|
||||||
<option name="SCRIPT_NAME" value="U:\PycharmProjects\Insurance\03 VyberKontrolaStavuPojisteni.py" />
|
|
||||||
<option name="PARAMETERS" value="" />
|
|
||||||
<option name="SHOW_COMMAND_LINE" value="false" />
|
|
||||||
<option name="EMULATE_TERMINAL" value="false" />
|
|
||||||
<option name="MODULE_MODE" value="false" />
|
|
||||||
<option name="REDIRECT_INPUT" value="false" />
|
|
||||||
<option name="INPUT_FILE" value="" />
|
|
||||||
<method v="2" />
|
|
||||||
</configuration>
|
|
||||||
<configuration name="05 testik" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
|
|
||||||
<module name="Insurance" />
|
|
||||||
<option name="ENV_FILES" value="" />
|
|
||||||
<option name="INTERPRETER_OPTIONS" value="" />
|
|
||||||
<option name="PARENT_ENVS" value="true" />
|
|
||||||
<envs>
|
|
||||||
<env name="PYTHONUNBUFFERED" value="1" />
|
|
||||||
</envs>
|
|
||||||
<option name="SDK_HOME" value="" />
|
|
||||||
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
|
|
||||||
<option name="IS_MODULE_SDK" value="true" />
|
|
||||||
<option name="ADD_CONTENT_ROOTS" value="true" />
|
|
||||||
<option name="ADD_SOURCE_ROOTS" value="true" />
|
|
||||||
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/05 testik.py" />
|
|
||||||
<option name="PARAMETERS" value="" />
|
|
||||||
<option name="SHOW_COMMAND_LINE" value="false" />
|
|
||||||
<option name="EMULATE_TERMINAL" value="false" />
|
|
||||||
<option name="MODULE_MODE" value="false" />
|
|
||||||
<option name="REDIRECT_INPUT" value="false" />
|
|
||||||
<option name="INPUT_FILE" value="" />
|
|
||||||
<method v="2" />
|
|
||||||
</configuration>
|
|
||||||
<recent_temporary>
|
|
||||||
<list>
|
|
||||||
<item itemvalue="Python.02 testík" />
|
|
||||||
<item itemvalue="Python.03 VyberKontrolaStavuPojisteni" />
|
|
||||||
<item itemvalue="Python.05 testik" />
|
|
||||||
<item itemvalue="Python.01 testik" />
|
|
||||||
</list>
|
|
||||||
</recent_temporary>
|
|
||||||
</component>
|
|
||||||
<component name="SharedIndexes">
|
|
||||||
<attachedChunks>
|
|
||||||
<set>
|
|
||||||
<option value="bundled-python-sdk-4f4e415b4190-aa17d162503b-com.jetbrains.pycharm.community.sharedIndexes.bundled-PC-243.26053.29" />
|
|
||||||
</set>
|
|
||||||
</attachedChunks>
|
|
||||||
</component>
|
|
||||||
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
|
|
||||||
<component name="TaskManager">
|
|
||||||
<task active="true" id="Default" summary="Default task">
|
|
||||||
<changelist id="c323bf66-f6a5-4ac2-b555-4106254af180" name="Changes" comment="" />
|
|
||||||
<created>1758916129960</created>
|
|
||||||
<option name="number" value="Default" />
|
|
||||||
<option name="presentableId" value="Default" />
|
|
||||||
<updated>1758916129960</updated>
|
|
||||||
</task>
|
|
||||||
<task id="LOCAL-00001" summary="notebookVB">
|
|
||||||
<option name="closed" value="true" />
|
|
||||||
<created>1759066485966</created>
|
|
||||||
<option name="number" value="00001" />
|
|
||||||
<option name="presentableId" value="LOCAL-00001" />
|
|
||||||
<option name="project" value="LOCAL" />
|
|
||||||
<updated>1759066485966</updated>
|
|
||||||
</task>
|
|
||||||
<option name="localTasksCounter" value="2" />
|
|
||||||
<servers />
|
|
||||||
</component>
|
|
||||||
<component name="VcsManagerConfiguration">
|
|
||||||
<MESSAGE value="notebookVB" />
|
|
||||||
<option name="LAST_COMMIT_MESSAGE" value="notebookVB" />
|
|
||||||
</component>
|
|
||||||
<component name="XDebuggerManager">
|
|
||||||
<breakpoint-manager>
|
|
||||||
<breakpoints>
|
|
||||||
<line-breakpoint enabled="true" suspend="THREAD" type="python-line">
|
|
||||||
<url>file://$PROJECT_DIR$/functions.py</url>
|
|
||||||
<line>62</line>
|
|
||||||
<option name="timeStamp" value="3" />
|
|
||||||
</line-breakpoint>
|
|
||||||
</breakpoints>
|
|
||||||
</breakpoint-manager>
|
|
||||||
</component>
|
|
||||||
</project>
|
|
||||||
22
02 testík.py
22
02 testík.py
@@ -17,7 +17,7 @@ from pymysql.cursors import DictCursor
|
|||||||
from pprint import pprint
|
from pprint import pprint
|
||||||
from functions import get_medicus_connection
|
from functions import get_medicus_connection
|
||||||
from functions import get_mysql_connection
|
from functions import get_mysql_connection
|
||||||
import time, random
|
import time, random,socket
|
||||||
|
|
||||||
# ------------------- CONFIG -------------------
|
# ------------------- CONFIG -------------------
|
||||||
ENDPOINT = "https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/RegistracePojistencePZSB2B" # case-sensitive
|
ENDPOINT = "https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/RegistracePojistencePZSB2B" # case-sensitive
|
||||||
@@ -32,15 +32,27 @@ K_DATU = date.today().isoformat() # YYYY-MM-DD
|
|||||||
ODBORNOSTI = ["001"] # VPL (adult GP)
|
ODBORNOSTI = ["001"] # VPL (adult GP)
|
||||||
|
|
||||||
# MySQL
|
# MySQL
|
||||||
MYSQL_CFG = dict(
|
if socket.gethostname().strip() == "NTBVBHP470G10":
|
||||||
|
MYSQL_CFG = dict(
|
||||||
host="192.168.1.76",
|
host="192.168.1.76",
|
||||||
port=3307,
|
port=3307,
|
||||||
user="root",
|
user="root",
|
||||||
password="Vlado9674+",
|
password="Vlado9674+",
|
||||||
database="medevio",
|
database="medevio",
|
||||||
cursorclass=DictCursor,
|
cursorclass=DictCursor,
|
||||||
autocommit=False,
|
autocommit=True, # or False if you prefer manual commit
|
||||||
)
|
)
|
||||||
|
elif socket.gethostname().strip() == "SESTRA":
|
||||||
|
MYSQL_CFG = dict(
|
||||||
|
host="127.0.0.1",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
cursorclass=DictCursor,
|
||||||
|
autocommit=True, # or False if you prefer manual commit
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
# Namespaces (from your response/WSDL)
|
# Namespaces (from your response/WSDL)
|
||||||
NS = {
|
NS = {
|
||||||
@@ -204,7 +216,7 @@ def main():
|
|||||||
|
|
||||||
con = get_medicus_connection()
|
con = get_medicus_connection()
|
||||||
cur = con.cursor()
|
cur = con.cursor()
|
||||||
cur.execute("select rodcis, prijmeni, jmeno from kar where rodcis starting with '0'")
|
cur.execute("select rodcis, prijmeni, jmeno from kar where rodcis starting with '9'")
|
||||||
# cur.execute("select first 2 rodcis, prijmeni, jmeno from kar where rodcis starting with '0'")
|
# cur.execute("select first 2 rodcis, prijmeni, jmeno from kar where rodcis starting with '0'")
|
||||||
|
|
||||||
# Vytvor seznam rodnych cisel, která už máme
|
# Vytvor seznam rodnych cisel, která už máme
|
||||||
|
|||||||
262
02.1 Test moje rodne cislo.py
Normal file
262
02.1 Test moje rodne cislo.py
Normal file
@@ -0,0 +1,262 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
"""
|
||||||
|
Call VZP RegistracePojistencePZSB2B for one patient (001 = VPL),
|
||||||
|
parse the response, upsert rows into medevio.vzp_registrace,
|
||||||
|
and print what is being saved.
|
||||||
|
"""
|
||||||
|
|
||||||
|
# pip install requests_pkcs12 pymysql
|
||||||
|
|
||||||
|
from requests_pkcs12 import Pkcs12Adapter
|
||||||
|
import requests
|
||||||
|
import xml.etree.ElementTree as ET
|
||||||
|
from datetime import date
|
||||||
|
import pymysql
|
||||||
|
from pymysql.cursors import DictCursor
|
||||||
|
from pprint import pprint
|
||||||
|
from functions import get_medicus_connection
|
||||||
|
from functions import get_mysql_connection
|
||||||
|
import time, random,socket
|
||||||
|
|
||||||
|
# ------------------- CONFIG -------------------
|
||||||
|
ENDPOINT = "https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/RegistracePojistencePZSB2B" # case-sensitive
|
||||||
|
PFX_PATH = r"mbcert.pfx" # <-- your .pfx path
|
||||||
|
PFX_PASS = "Vlado7309208104++" # <-- your export password
|
||||||
|
VERIFY = True # or path to CA PEM, e.g. r"C:\certs\vzp_ca.pem"
|
||||||
|
|
||||||
|
# Patient + query
|
||||||
|
RC = "7309208104" # rodné číslo without slash
|
||||||
|
# RC = "280616/091" # rodné číslo without slash
|
||||||
|
K_DATU = date.today().isoformat() # YYYY-MM-DD
|
||||||
|
ODBORNOSTI = ["001"] # VPL (adult GP)
|
||||||
|
|
||||||
|
# MySQL
|
||||||
|
if socket.gethostname().strip() == "NTBVBHP470G10":
|
||||||
|
MYSQL_CFG = dict(
|
||||||
|
host="192.168.1.76",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
cursorclass=DictCursor,
|
||||||
|
autocommit=True, # or False if you prefer manual commit
|
||||||
|
)
|
||||||
|
elif socket.gethostname().strip() == "SESTRA":
|
||||||
|
MYSQL_CFG = dict(
|
||||||
|
host="127.0.0.1",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
cursorclass=DictCursor,
|
||||||
|
autocommit=True, # or False if you prefer manual commit
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
# Namespaces (from your response/WSDL)
|
||||||
|
NS = {
|
||||||
|
"soap": "http://schemas.xmlsoap.org/soap/envelope/",
|
||||||
|
"rp": "http://xmlns.gemsystem.cz/B2B/RegistracePojistencePZSB2B/1",
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
# ------------------- HELPERS -------------------
|
||||||
|
def normalize_rc(rc: str) -> str:
|
||||||
|
return rc.replace("/", "").strip()
|
||||||
|
|
||||||
|
|
||||||
|
# Ukázka XML – Požadavek:
|
||||||
|
# <registracePojistencePZSB2B xmlns="http://xmlns.gemsystem.cz/B2B/RegistracePojistencePZSB2B/1">
|
||||||
|
# <cisloPojistence>801212855</cisloPojistence>
|
||||||
|
# <seznamOdbornosti>
|
||||||
|
# <kodOdbornosti>002</kodOdbornosti>
|
||||||
|
# </seznamOdbornosti>
|
||||||
|
# </registracePojistencePZSB2B>
|
||||||
|
def build_envelope(rc: str, k_datu: str, odb_list: list[str]) -> str:
|
||||||
|
odb_xml = "".join([f"<ns1:kodOdbornosti>{kod}</ns1:kodOdbornosti>" for kod in odb_list])
|
||||||
|
inner = f"""
|
||||||
|
<ns1:registracePojistencePZSB2B xmlns:ns1="{NS['rp']}">
|
||||||
|
<ns1:cisloPojistence>{rc}</ns1:cisloPojistence>
|
||||||
|
<ns1:kDatu>{k_datu}</ns1:kDatu>
|
||||||
|
<ns1:seznamOdbornosti>
|
||||||
|
{odb_xml}
|
||||||
|
</ns1:seznamOdbornosti>
|
||||||
|
</ns1:registracePojistencePZSB2B>""".strip()
|
||||||
|
|
||||||
|
return f"""<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<soap:Envelope xmlns:soap="{NS['soap']}">
|
||||||
|
<soap:Body>
|
||||||
|
{inner}
|
||||||
|
</soap:Body>
|
||||||
|
</soap:Envelope>"""
|
||||||
|
|
||||||
|
def parse_registrace(xml_text: str):
|
||||||
|
"""
|
||||||
|
Return (rows, stav_vyrizeni) where rows is a list of dicts
|
||||||
|
for each <odbornost> item in the response.
|
||||||
|
"""
|
||||||
|
root = ET.fromstring(xml_text)
|
||||||
|
items = root.findall(".//rp:seznamOdbornosti/rp:odbornost", NS)
|
||||||
|
out = []
|
||||||
|
for it in items:
|
||||||
|
def g(tag, ctx=it):
|
||||||
|
el = ctx.find(f"rp:{tag}", NS)
|
||||||
|
return el.text.strip() if el is not None and el.text else None
|
||||||
|
|
||||||
|
poj = it.find("rp:zdravotniPojistovna", NS)
|
||||||
|
poj_kod = poj.find("rp:kod", NS).text.strip() if (poj is not None and poj.find("rp:kod", NS) is not None) else None
|
||||||
|
poj_zkr = poj.find("rp:zkratka", NS).text.strip() if (poj is not None and poj.find("rp:zkratka", NS) is not None) else None
|
||||||
|
|
||||||
|
spec = it.find("rp:odbornost", NS)
|
||||||
|
odb_kod = spec.find("rp:kod", NS).text.strip() if (spec is not None and spec.find("rp:kod", NS) is not None) else None
|
||||||
|
odb_naz = spec.find("rp:nazev", NS).text.strip() if (spec is not None and spec.find("rp:nazev", NS) is not None) else None
|
||||||
|
|
||||||
|
out.append(dict(
|
||||||
|
icz=g("ICZ"),
|
||||||
|
icp=g("ICP"),
|
||||||
|
nazev_icp=g("nazevICP"),
|
||||||
|
nazev_szz=g("nazevSZZ"),
|
||||||
|
poj_kod=poj_kod,
|
||||||
|
poj_zkratka=poj_zkr,
|
||||||
|
odbornost_kod=odb_kod,
|
||||||
|
odbornost_nazev=odb_naz,
|
||||||
|
datum_registrace=g("datumRegistrace"),
|
||||||
|
datum_zahajeni=g("datumZahajeni"),
|
||||||
|
datum_ukonceni=g("datumUkonceni"),
|
||||||
|
))
|
||||||
|
|
||||||
|
st = root.find(".//rp:stavVyrizeniPozadavku", NS)
|
||||||
|
stav_vyrizeni = st.text.strip() if (st is not None and st.text) else None
|
||||||
|
return out, stav_vyrizeni
|
||||||
|
|
||||||
|
def upsert_rows(rc: str, query_date: str, rows: list[dict], stav_vyrizeni: str, xml_text: str) -> int:
|
||||||
|
"""
|
||||||
|
Insert or update rows into medevio.vzp_registrace and print each payload.
|
||||||
|
Assumes the table already exists (as per your DDL).
|
||||||
|
"""
|
||||||
|
if not rows:
|
||||||
|
print("No <odbornost> rows found; nothing to save.")
|
||||||
|
return 0
|
||||||
|
|
||||||
|
sql = """
|
||||||
|
INSERT INTO vzp_registrace
|
||||||
|
(rc, query_date, odbornost_kod, odbornost_nazev,
|
||||||
|
icz, icp, nazev_icp, nazev_szz,
|
||||||
|
poj_kod, poj_zkratka,
|
||||||
|
datum_registrace, datum_zahajeni, datum_ukonceni,
|
||||||
|
stav_vyrizeni, response_xml)
|
||||||
|
VALUES
|
||||||
|
(%(rc)s, %(query_date)s, %(odbornost_kod)s, %(odbornost_nazev)s,
|
||||||
|
%(icz)s, %(icp)s, %(nazev_icp)s, %(nazev_szz)s,
|
||||||
|
%(poj_kod)s, %(poj_zkratka)s,
|
||||||
|
%(datum_registrace)s, %(datum_zahajeni)s, %(datum_ukonceni)s,
|
||||||
|
%(stav_vyrizeni)s, %(response_xml)s)
|
||||||
|
ON DUPLICATE KEY UPDATE
|
||||||
|
odbornost_nazev = VALUES(odbornost_nazev),
|
||||||
|
nazev_icp = VALUES(nazev_icp),
|
||||||
|
nazev_szz = VALUES(nazev_szz),
|
||||||
|
poj_kod = VALUES(poj_kod),
|
||||||
|
poj_zkratka = VALUES(poj_zkratka),
|
||||||
|
datum_registrace= VALUES(datum_registrace),
|
||||||
|
datum_zahajeni = VALUES(datum_zahajeni),
|
||||||
|
datum_ukonceni = VALUES(datum_ukonceni),
|
||||||
|
stav_vyrizeni = VALUES(stav_vyrizeni),
|
||||||
|
response_xml = VALUES(response_xml),
|
||||||
|
updated_at = CURRENT_TIMESTAMP
|
||||||
|
"""
|
||||||
|
rc_norm = normalize_rc(rc)
|
||||||
|
qd = query_date or date.today().isoformat()
|
||||||
|
payloads = []
|
||||||
|
for r in rows:
|
||||||
|
payload = {
|
||||||
|
"rc": rc_norm,
|
||||||
|
"query_date": qd,
|
||||||
|
**r,
|
||||||
|
"stav_vyrizeni": stav_vyrizeni,
|
||||||
|
"response_xml": xml_text,
|
||||||
|
}
|
||||||
|
payloads.append(payload)
|
||||||
|
|
||||||
|
# Print what we're going to save
|
||||||
|
print("\n=== Will save the following payload(s) to medevio.vzp_registrace ===")
|
||||||
|
for p in payloads:
|
||||||
|
pprint(p)
|
||||||
|
|
||||||
|
conn = pymysql.connect(**MYSQL_CFG)
|
||||||
|
try:
|
||||||
|
with conn.cursor() as cur:
|
||||||
|
cur.executemany(sql, payloads)
|
||||||
|
conn.commit()
|
||||||
|
finally:
|
||||||
|
conn.close()
|
||||||
|
|
||||||
|
print(f"\nUpserted rows: {len(payloads)}")
|
||||||
|
return len(payloads)
|
||||||
|
|
||||||
|
def prepare_processed_rcs():
|
||||||
|
consql=get_mysql_connection()
|
||||||
|
cursql=consql.cursor()
|
||||||
|
|
||||||
|
sql="""
|
||||||
|
WITH ranked AS (
|
||||||
|
SELECT
|
||||||
|
vreg.*,
|
||||||
|
ROW_NUMBER() OVER (
|
||||||
|
PARTITION BY rc
|
||||||
|
ORDER BY query_date DESC
|
||||||
|
) AS rn
|
||||||
|
FROM vzp_registrace AS vreg
|
||||||
|
)
|
||||||
|
SELECT rc
|
||||||
|
FROM ranked
|
||||||
|
WHERE rn = 1
|
||||||
|
"""
|
||||||
|
|
||||||
|
cursql.execute(sql)
|
||||||
|
rows=cursql.fetchall()
|
||||||
|
print(f"Pocet jiz zpracovanych rodnych cisel v MYSQL MEDEVIO je {len(rows)}")
|
||||||
|
rc_set_vzp = {row["rc"] for row in rows}
|
||||||
|
return (rc_set_vzp)
|
||||||
|
|
||||||
|
# ------------------- MAIN FLOW -------------------
|
||||||
|
def main():
|
||||||
|
K_DATU = date.today().isoformat() # YYYY-MM-DD
|
||||||
|
ODBORNOSTI = ["001"]
|
||||||
|
RC='7309208104'
|
||||||
|
|
||||||
|
# Build SOAP envelope
|
||||||
|
envelope = build_envelope(RC, K_DATU, ODBORNOSTI)
|
||||||
|
|
||||||
|
# mTLS session
|
||||||
|
session = requests.Session()
|
||||||
|
session.mount("https://", Pkcs12Adapter(pkcs12_filename=PFX_PATH, pkcs12_password=PFX_PASS))
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
"Content-Type": "text/xml; charset=utf-8",
|
||||||
|
"SOAPAction": "process", # Oracle composite usually expects this
|
||||||
|
}
|
||||||
|
|
||||||
|
# Call service
|
||||||
|
resp = session.post(ENDPOINT, data=envelope.encode("utf-8"),
|
||||||
|
headers=headers, timeout=30, verify=VERIFY)
|
||||||
|
print("HTTP:", resp.status_code)
|
||||||
|
|
||||||
|
# (Optional) Uncomment to see raw XML
|
||||||
|
print(resp.text)
|
||||||
|
|
||||||
|
# Parse and save
|
||||||
|
rows, stav = parse_registrace(resp.text)
|
||||||
|
print(rows,stav)
|
||||||
|
|
||||||
|
time.sleep(random.uniform(1, 5))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
main()
|
||||||
308
02.2 Testík.py
Normal file
308
02.2 Testík.py
Normal file
@@ -0,0 +1,308 @@
|
|||||||
|
#kód bude vkládat i řádky pro pacienty bez registrovaného lékař v oboru 001#!/usr/bin/env python3 -*- coding: utf-8 -*- """ Call VZP RegistracePojistencePZSB2B for one patient (001 = VPL), parse the response, upsert rows into medevio.vzp_registrace, and print what is being saved. """ # pip install requests_pkcs12 pymysql from requests_pkcs12 import Pkcs12Adapter import requests import xml.etree.ElementTree as ET from datetime import date import pymysql from pymysql.cursors import DictCursor from pprint import pprint from functions import get_medicus_connection from functions import get_mysql_connection import time, random,socket # ------------------- CONFIG ------------------- ENDPOINT = "https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/RegistracePojistencePZSB2B" # case-sensitive PFX_PATH = r"mbcert.pfx" # <-- your .pfx path PFX_PASS = "Vlado7309208104++" # <-- your export password VERIFY = True # or path to CA PEM, e.g. r"C:\certs\vzp_ca.pem" Patient + query RC = "7309208104" # rodné číslo without slash RC = "280616/091" # rodné
|
||||||
|
#!/usr/bin/env python3
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
"""
|
||||||
|
Call VZP RegistracePojistencePZSB2B for one patient (001 = VPL),
|
||||||
|
parse the response, upsert rows into medevio.vzp_registrace,
|
||||||
|
and print what is being saved.
|
||||||
|
"""
|
||||||
|
|
||||||
|
# pip install requests_pkcs12 pymysql
|
||||||
|
|
||||||
|
from requests_pkcs12 import Pkcs12Adapter
|
||||||
|
import requests
|
||||||
|
import xml.etree.ElementTree as ET
|
||||||
|
from datetime import date
|
||||||
|
import pymysql
|
||||||
|
from pymysql.cursors import DictCursor
|
||||||
|
from pprint import pprint
|
||||||
|
from functions import get_medicus_connection
|
||||||
|
from functions import get_mysql_connection
|
||||||
|
import time, random,socket
|
||||||
|
|
||||||
|
# ------------------- CONFIG -------------------
|
||||||
|
ENDPOINT = "https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/RegistracePojistencePZSB2B" # case-sensitive
|
||||||
|
PFX_PATH = r"mbcert.pfx" # <-- your .pfx path
|
||||||
|
PFX_PASS = "Vlado7309208104++" # <-- your export password
|
||||||
|
VERIFY = True # or path to CA PEM, e.g. r"C:\certs\vzp_ca.pem"
|
||||||
|
|
||||||
|
# Patient + query
|
||||||
|
RC = "7309208104" # rodné číslo without slash
|
||||||
|
# RC = "280616/091" # rodné číslo without slash
|
||||||
|
K_DATU = date.today().isoformat() # YYYY-MM-DD
|
||||||
|
ODBORNOSTI = ["001"] # VPL (adult GP)
|
||||||
|
|
||||||
|
# MySQL
|
||||||
|
if socket.gethostname().strip() in ("NTBVBHP470G10","Z230"):
|
||||||
|
MYSQL_CFG = dict(
|
||||||
|
host="192.168.1.76",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
cursorclass=DictCursor,
|
||||||
|
autocommit=True, # or False if you prefer manual commit
|
||||||
|
)
|
||||||
|
elif socket.gethostname().strip() == "SESTRA":
|
||||||
|
MYSQL_CFG = dict(
|
||||||
|
host="127.0.0.1",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
cursorclass=DictCursor,
|
||||||
|
autocommit=True, # or False if you prefer manual commit
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
# Namespaces (from your response/WSDL)
|
||||||
|
NS = {
|
||||||
|
"soap": "http://schemas.xmlsoap.org/soap/envelope/",
|
||||||
|
"rp": "http://xmlns.gemsystem.cz/B2B/RegistracePojistencePZSB2B/1",
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
# ------------------- HELPERS -------------------
|
||||||
|
def normalize_rc(rc: str) -> str:
|
||||||
|
return rc.replace("/", "").strip()
|
||||||
|
|
||||||
|
def build_envelope(rc: str, k_datu: str, odb_list: list[str]) -> str:
|
||||||
|
odb_xml = "".join([f"<ns1:kodOdbornosti>{kod}</ns1:kodOdbornosti>" for kod in odb_list])
|
||||||
|
inner = f"""
|
||||||
|
<ns1:registracePojistencePZSB2B xmlns:ns1="{NS['rp']}">
|
||||||
|
<ns1:cisloPojistence>{rc}</ns1:cisloPojistence>
|
||||||
|
<ns1:kDatu>{k_datu}</ns1:kDatu>
|
||||||
|
<ns1:seznamOdbornosti>
|
||||||
|
{odb_xml}
|
||||||
|
</ns1:seznamOdbornosti>
|
||||||
|
</ns1:registracePojistencePZSB2B>""".strip()
|
||||||
|
|
||||||
|
return f"""<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<soap:Envelope xmlns:soap="{NS['soap']}">
|
||||||
|
<soap:Body>
|
||||||
|
{inner}
|
||||||
|
</soap:Body>
|
||||||
|
</soap:Envelope>"""
|
||||||
|
|
||||||
|
def parse_registrace(xml_text: str):
|
||||||
|
"""
|
||||||
|
Return (rows, stav_vyrizeni) where rows is a list of dicts
|
||||||
|
for each <odbornost> item in the response.
|
||||||
|
"""
|
||||||
|
root = ET.fromstring(xml_text)
|
||||||
|
items = root.findall(".//rp:seznamOdbornosti/rp:odbornost", NS)
|
||||||
|
out = []
|
||||||
|
for it in items:
|
||||||
|
def g(tag, ctx=it):
|
||||||
|
el = ctx.find(f"rp:{tag}", NS)
|
||||||
|
return el.text.strip() if el is not None and el.text else None
|
||||||
|
|
||||||
|
poj = it.find("rp:zdravotniPojistovna", NS)
|
||||||
|
poj_kod = poj.find("rp:kod", NS).text.strip() if (poj is not None and poj.find("rp:kod", NS) is not None) else None
|
||||||
|
poj_zkr = poj.find("rp:zkratka", NS).text.strip() if (poj is not None and poj.find("rp:zkratka", NS) is not None) else None
|
||||||
|
|
||||||
|
spec = it.find("rp:odbornost", NS)
|
||||||
|
odb_kod = spec.find("rp:kod", NS).text.strip() if (spec is not None and spec.find("rp:kod", NS) is not None) else None
|
||||||
|
odb_naz = spec.find("rp:nazev", NS).text.strip() if (spec is not None and spec.find("rp:nazev", NS) is not None) else None
|
||||||
|
|
||||||
|
out.append(dict(
|
||||||
|
icz=g("ICZ"),
|
||||||
|
icp=g("ICP"),
|
||||||
|
nazev_icp=g("nazevICP"),
|
||||||
|
nazev_szz=g("nazevSZZ"),
|
||||||
|
poj_kod=poj_kod,
|
||||||
|
poj_zkratka=poj_zkr,
|
||||||
|
odbornost_kod=odb_kod,
|
||||||
|
odbornost_nazev=odb_naz,
|
||||||
|
datum_registrace=g("datumRegistrace"),
|
||||||
|
datum_zahajeni=g("datumZahajeni"),
|
||||||
|
datum_ukonceni=g("datumUkonceni"),
|
||||||
|
))
|
||||||
|
|
||||||
|
st = root.find(".//rp:stavVyrizeniPozadavku", NS)
|
||||||
|
stav_vyrizeni = st.text.strip() if (st is not None and st.text) else None
|
||||||
|
return out, stav_vyrizeni
|
||||||
|
|
||||||
|
def upsert_rows(
|
||||||
|
rc: str,
|
||||||
|
query_date: str,
|
||||||
|
rows: list[dict],
|
||||||
|
stav_vyrizeni: str,
|
||||||
|
xml_text: str,
|
||||||
|
requested_odb_list: list[str] | None = None,
|
||||||
|
) -> int:
|
||||||
|
"""
|
||||||
|
Insert/update medevio.vzp_registrace.
|
||||||
|
If no <odbornost> items are returned, insert placeholder row(s)
|
||||||
|
for each requested specialty (e.g., "001") so the negative result is visible.
|
||||||
|
"""
|
||||||
|
sql = """
|
||||||
|
INSERT INTO vzp_registrace
|
||||||
|
(rc, query_date, odbornost_kod, odbornost_nazev,
|
||||||
|
icz, icp, nazev_icp, nazev_szz,
|
||||||
|
poj_kod, poj_zkratka,
|
||||||
|
datum_registrace, datum_zahajeni, datum_ukonceni,
|
||||||
|
stav_vyrizeni, response_xml)
|
||||||
|
VALUES
|
||||||
|
(%(rc)s, %(query_date)s, %(odbornost_kod)s, %(odbornost_nazev)s,
|
||||||
|
%(icz)s, %(icp)s, %(nazev_icp)s, %(nazev_szz)s,
|
||||||
|
%(poj_kod)s, %(poj_zkratka)s,
|
||||||
|
%(datum_registrace)s, %(datum_zahajeni)s, %(datum_ukonceni)s,
|
||||||
|
%(stav_vyrizeni)s, %(response_xml)s)
|
||||||
|
ON DUPLICATE KEY UPDATE
|
||||||
|
odbornost_nazev = VALUES(odbornost_nazev),
|
||||||
|
nazev_icp = VALUES(nazev_icp),
|
||||||
|
nazev_szz = VALUES(nazev_szz),
|
||||||
|
poj_kod = VALUES(poj_kod),
|
||||||
|
poj_zkratka = VALUES(poj_zkratka),
|
||||||
|
datum_registrace= VALUES(datum_registrace),
|
||||||
|
datum_zahajeni = VALUES(datum_zahajeni),
|
||||||
|
datum_ukonceni = VALUES(datum_ukonceni),
|
||||||
|
stav_vyrizeni = VALUES(stav_vyrizeni),
|
||||||
|
response_xml = VALUES(response_xml),
|
||||||
|
updated_at = CURRENT_TIMESTAMP
|
||||||
|
"""
|
||||||
|
rc_norm = normalize_rc(rc)
|
||||||
|
qd = query_date or date.today().isoformat()
|
||||||
|
|
||||||
|
payloads: list[dict] = []
|
||||||
|
|
||||||
|
if rows:
|
||||||
|
# Positive path: save what came from the API
|
||||||
|
for r in rows:
|
||||||
|
payloads.append({
|
||||||
|
"rc": rc_norm,
|
||||||
|
"query_date": qd,
|
||||||
|
**r,
|
||||||
|
"stav_vyrizeni": stav_vyrizeni,
|
||||||
|
"response_xml": xml_text,
|
||||||
|
})
|
||||||
|
else:
|
||||||
|
# Negative path: no registration items -> create placeholders
|
||||||
|
if not requested_odb_list:
|
||||||
|
requested_odb_list = ["001"]
|
||||||
|
for kod in requested_odb_list:
|
||||||
|
payloads.append({
|
||||||
|
"rc": rc_norm,
|
||||||
|
"query_date": qd,
|
||||||
|
"odbornost_kod": kod,
|
||||||
|
"odbornost_nazev": None,
|
||||||
|
"icz": None,
|
||||||
|
"icp": None,
|
||||||
|
"nazev_icp": None,
|
||||||
|
"nazev_szz": None,
|
||||||
|
"poj_kod": None,
|
||||||
|
"poj_zkratka": None,
|
||||||
|
"datum_registrace": None,
|
||||||
|
"datum_zahajeni": None,
|
||||||
|
"datum_ukonceni": None,
|
||||||
|
# Keep what VZP said (e.g., 'X'), and raw XML for audit
|
||||||
|
"stav_vyrizeni": stav_vyrizeni,
|
||||||
|
"response_xml": xml_text,
|
||||||
|
})
|
||||||
|
|
||||||
|
# Print what we're going to save
|
||||||
|
print("\n=== Will save the following payload(s) to medevio.vzp_registrace ===")
|
||||||
|
for p in payloads:
|
||||||
|
pprint(p)
|
||||||
|
|
||||||
|
if not payloads:
|
||||||
|
print("No payloads prepared (this should not happen).")
|
||||||
|
return 0
|
||||||
|
|
||||||
|
connsql = get_mysql_connection()
|
||||||
|
try:
|
||||||
|
with connsql.cursor() as cur:
|
||||||
|
cur.executemany(sql, payloads)
|
||||||
|
connsql.commit()
|
||||||
|
finally:
|
||||||
|
connsql.close()
|
||||||
|
|
||||||
|
print(f"\nUpserted rows: {len(payloads)}")
|
||||||
|
return len(payloads)
|
||||||
|
|
||||||
|
|
||||||
|
def prepare_processed_rcs():
|
||||||
|
consql=get_mysql_connection()
|
||||||
|
cursql=consql.cursor()
|
||||||
|
|
||||||
|
sql="""
|
||||||
|
WITH ranked AS (
|
||||||
|
SELECT
|
||||||
|
vreg.*,
|
||||||
|
ROW_NUMBER() OVER (
|
||||||
|
PARTITION BY rc
|
||||||
|
ORDER BY query_date DESC
|
||||||
|
) AS rn
|
||||||
|
FROM vzp_registrace AS vreg
|
||||||
|
)
|
||||||
|
SELECT rc
|
||||||
|
FROM ranked
|
||||||
|
WHERE rn = 1
|
||||||
|
"""
|
||||||
|
|
||||||
|
cursql.execute(sql)
|
||||||
|
rows=cursql.fetchall()
|
||||||
|
print(f"Pocet jiz zpracovanych rodnych cisel v MYSQL MEDEVIO je {len(rows)}")
|
||||||
|
rc_set_vzp = {row["rc"] for row in rows}
|
||||||
|
return (rc_set_vzp)
|
||||||
|
|
||||||
|
# ------------------- MAIN FLOW -------------------
|
||||||
|
def main():
|
||||||
|
|
||||||
|
con = get_medicus_connection()
|
||||||
|
cur = con.cursor()
|
||||||
|
cur.execute("select rodcis, prijmeni, jmeno from kar where rodcis starting with '1'")
|
||||||
|
# cur.execute("select first 2 rodcis, prijmeni, jmeno from kar where rodcis starting with '0'")
|
||||||
|
|
||||||
|
# Vytvor seznam rodnych cisel, která už máme
|
||||||
|
rc_set_vzp = prepare_processed_rcs()
|
||||||
|
|
||||||
|
rows = cur.fetchall()
|
||||||
|
print(f"Pocet vybranych radku z tabulky KAR je: {len(rows)}")
|
||||||
|
|
||||||
|
for row in rows:
|
||||||
|
if row[0] in rc_set_vzp:
|
||||||
|
continue
|
||||||
|
else:
|
||||||
|
print(row[0], row[1], row[2])
|
||||||
|
K_DATU = date.today().isoformat() # YYYY-MM-DD
|
||||||
|
ODBORNOSTI = ["001"]
|
||||||
|
RC=row[0]
|
||||||
|
|
||||||
|
# Build SOAP envelope
|
||||||
|
envelope = build_envelope(RC, K_DATU, ODBORNOSTI)
|
||||||
|
|
||||||
|
# mTLS session
|
||||||
|
session = requests.Session()
|
||||||
|
session.mount("https://", Pkcs12Adapter(pkcs12_filename=PFX_PATH, pkcs12_password=PFX_PASS))
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
"Content-Type": "text/xml; charset=utf-8",
|
||||||
|
"SOAPAction": "process", # Oracle composite usually expects this
|
||||||
|
}
|
||||||
|
print(envelope)
|
||||||
|
# Call service
|
||||||
|
resp = session.post(ENDPOINT, data=envelope.encode("utf-8"),
|
||||||
|
headers=headers, timeout=30, verify=VERIFY)
|
||||||
|
print("HTTP:", resp.status_code)
|
||||||
|
|
||||||
|
# (Optional) Uncomment to see raw XML
|
||||||
|
print(resp.text)
|
||||||
|
|
||||||
|
# Parse and save
|
||||||
|
rows, stav = parse_registrace(resp.text)
|
||||||
|
print(rows,stav)
|
||||||
|
upsert_rows(RC, K_DATU, rows, stav, resp.text, requested_odb_list=ODBORNOSTI)
|
||||||
|
|
||||||
|
time.sleep(random.uniform(1, 5))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
main()
|
||||||
BIN
10 Tests/MBcert.pfx
Normal file
BIN
10 Tests/MBcert.pfx
Normal file
Binary file not shown.
67
10 Tests/RozdilnalezenimeziFDBaMySQL.py
Normal file
67
10 Tests/RozdilnalezenimeziFDBaMySQL.py
Normal file
@@ -0,0 +1,67 @@
|
|||||||
|
import pandas as pd
|
||||||
|
import fdb
|
||||||
|
import pymysql
|
||||||
|
|
||||||
|
# ---------------------------------
|
||||||
|
# FIREBIRD CONNECTION
|
||||||
|
# ---------------------------------
|
||||||
|
fb = fdb.connect(
|
||||||
|
host="192.168.1.4",
|
||||||
|
database=r"z:\Medicus 3\data\MEDICUS.FDB",
|
||||||
|
user="SYSDBA",
|
||||||
|
password="masterkey",
|
||||||
|
charset="WIN1250"
|
||||||
|
)
|
||||||
|
cur = fb.cursor()
|
||||||
|
|
||||||
|
sql_fb = """
|
||||||
|
SELECT kar.rodcis
|
||||||
|
FROM registr
|
||||||
|
JOIN kar ON registr.idpac = kar.idpac
|
||||||
|
WHERE registr.datum_zruseni IS NULL
|
||||||
|
AND registr.priznak IN ('A','D','V')
|
||||||
|
"""
|
||||||
|
|
||||||
|
cur.execute(sql_fb)
|
||||||
|
rows_fb = cur.fetchall()
|
||||||
|
|
||||||
|
df_fb = pd.DataFrame(rows_fb, columns=["rc"])
|
||||||
|
print("FB count:", len(df_fb))
|
||||||
|
|
||||||
|
# ---------------------------------
|
||||||
|
# MYSQL CONNECTION
|
||||||
|
# ---------------------------------
|
||||||
|
mysql = pymysql.connect(
|
||||||
|
host="192.168.1.76",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
charset="utf8mb4"
|
||||||
|
)
|
||||||
|
|
||||||
|
sql_mysql = """
|
||||||
|
SELECT rc
|
||||||
|
FROM vzp_stav_pojisteni AS v
|
||||||
|
WHERE v.k_datu = CURDATE()
|
||||||
|
AND v.id = (
|
||||||
|
SELECT MAX(id)
|
||||||
|
FROM vzp_stav_pojisteni
|
||||||
|
WHERE rc = v.rc
|
||||||
|
AND k_datu = CURDATE()
|
||||||
|
);
|
||||||
|
"""
|
||||||
|
|
||||||
|
df_mysql = pd.read_sql(sql_mysql, mysql)
|
||||||
|
print("MySQL count:", len(df_mysql))
|
||||||
|
|
||||||
|
# ---------------------------------
|
||||||
|
# FIND MISSING RC
|
||||||
|
# ---------------------------------
|
||||||
|
df_missing = df_fb[~df_fb["rc"].isin(df_mysql["rc"])]
|
||||||
|
|
||||||
|
print("\nMissing patients:")
|
||||||
|
print(df_missing)
|
||||||
|
|
||||||
|
fb.close()
|
||||||
|
mysql.close()
|
||||||
42
10 Tests/medicus_db.py
Normal file
42
10 Tests/medicus_db.py
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
import fdb
|
||||||
|
|
||||||
|
|
||||||
|
class MedicusDB:
|
||||||
|
|
||||||
|
def __init__(self, host, db_path, user="SYSDBA", password="masterkey", charset="WIN1250"):
|
||||||
|
self.conn = fdb.connect(
|
||||||
|
host=host,
|
||||||
|
database=db_path,
|
||||||
|
user=user,
|
||||||
|
password=password,
|
||||||
|
charset=charset
|
||||||
|
)
|
||||||
|
self.cur = self.conn.cursor()
|
||||||
|
|
||||||
|
def query(self, sql, params=None):
|
||||||
|
self.cur.execute(sql, params or ())
|
||||||
|
return self.cur.fetchall()
|
||||||
|
|
||||||
|
def query_dict(self, sql, params=None):
|
||||||
|
self.cur.execute(sql, params or ())
|
||||||
|
cols = [d[0].strip().lower() for d in self.cur.description]
|
||||||
|
return [dict(zip(cols, row)) for row in self.cur.fetchall()]
|
||||||
|
|
||||||
|
def get_active_registered_patients(self):
|
||||||
|
sql = """
|
||||||
|
SELECT
|
||||||
|
kar.rodcis,
|
||||||
|
kar.prijmeni,
|
||||||
|
kar.jmeno,
|
||||||
|
kar.poj
|
||||||
|
FROM registr
|
||||||
|
JOIN kar ON registr.idpac = kar.idpac
|
||||||
|
WHERE registr.datum_zruseni IS NULL
|
||||||
|
AND registr.priznak IN ('A','D','V')
|
||||||
|
AND kar.rodcis IS NOT NULL
|
||||||
|
AND kar.rodcis <> ''
|
||||||
|
"""
|
||||||
|
return self.query(sql) # or self.query_dict(sql)
|
||||||
|
|
||||||
|
def close(self):
|
||||||
|
self.conn.close()
|
||||||
79
10 Tests/rozdíl.py
Normal file
79
10 Tests/rozdíl.py
Normal file
@@ -0,0 +1,79 @@
|
|||||||
|
import pandas as pd
|
||||||
|
import pymysql
|
||||||
|
from medicus_db import MedicusDB
|
||||||
|
import fdb
|
||||||
|
|
||||||
|
|
||||||
|
# FULL OUTPUT SETTINGS
|
||||||
|
pd.set_option("display.max_rows", None)
|
||||||
|
pd.set_option("display.max_columns", None)
|
||||||
|
pd.set_option("display.width", 0)
|
||||||
|
pd.set_option("display.max_colwidth", None)
|
||||||
|
|
||||||
|
|
||||||
|
# ===========
|
||||||
|
#
|
||||||
|
# ===========================
|
||||||
|
# FIREBIRD → načtení registrovaných pacientů
|
||||||
|
# ======================================
|
||||||
|
db = MedicusDB("192.168.1.4", r"z:\Medicus 3\data\MEDICUS.FDB")
|
||||||
|
rows_fb = db.get_active_registered_patients() # vrací rc, prijmeni, jmeno, poj
|
||||||
|
db.close()
|
||||||
|
|
||||||
|
df_fb = pd.DataFrame(rows_fb, columns=["rc", "prijmeni", "jmeno", "poj_medicus"])
|
||||||
|
df_fb["poj_medicus"] = df_fb["poj_medicus"].astype(str).str.strip()
|
||||||
|
|
||||||
|
print("FB count:", len(df_fb))
|
||||||
|
|
||||||
|
|
||||||
|
# ======================================
|
||||||
|
# MYSQL → načtení dnešních výsledků
|
||||||
|
# ======================================
|
||||||
|
mysql = pymysql.connect(
|
||||||
|
host="192.168.1.76",
|
||||||
|
port=3307,
|
||||||
|
user="root",
|
||||||
|
password="Vlado9674+",
|
||||||
|
database="medevio",
|
||||||
|
charset="utf8mb4"
|
||||||
|
)
|
||||||
|
|
||||||
|
sql_mysql = """
|
||||||
|
SELECT rc,
|
||||||
|
kod_pojistovny AS poj_mysql,
|
||||||
|
nazev_pojistovny,
|
||||||
|
stav,
|
||||||
|
stav_vyrizeni
|
||||||
|
FROM vzp_stav_pojisteni AS v
|
||||||
|
WHERE v.k_datu = CURDATE()
|
||||||
|
AND v.id = (
|
||||||
|
SELECT MAX(id)
|
||||||
|
FROM vzp_stav_pojisteni
|
||||||
|
WHERE rc = v.rc
|
||||||
|
AND k_datu = CURDATE()
|
||||||
|
);
|
||||||
|
"""
|
||||||
|
|
||||||
|
df_mysql = pd.read_sql(sql_mysql, mysql)
|
||||||
|
df_mysql["poj_mysql"] = df_mysql["poj_mysql"].astype(str).str.strip()
|
||||||
|
|
||||||
|
print("MySQL count:", len(df_mysql))
|
||||||
|
|
||||||
|
|
||||||
|
# ======================================
|
||||||
|
# LEFT JOIN: Medicus ↔ MySQL podle RC
|
||||||
|
# ======================================
|
||||||
|
df_merge = df_fb.merge(df_mysql, on="rc", how="left")
|
||||||
|
|
||||||
|
|
||||||
|
# ======================================
|
||||||
|
# Najít rozdíly pojišťovny
|
||||||
|
# ======================================
|
||||||
|
df_diff = df_merge[df_merge["poj_medicus"] != df_merge["poj_mysql"]]
|
||||||
|
|
||||||
|
print("\nPacienti s rozdílnou pojišťovnou:")
|
||||||
|
print(df_diff[["rc", "prijmeni", "jmeno", "poj_medicus", "poj_mysql", "nazev_pojistovny"]])
|
||||||
|
|
||||||
|
# Pokud chceš uložit do Excelu:
|
||||||
|
# df_diff.to_excel("rozdil_pojistoven.xlsx", index=False)
|
||||||
|
|
||||||
137
10 Tests/test kontrola registrovaných.py
Normal file
137
10 Tests/test kontrola registrovaných.py
Normal file
@@ -0,0 +1,137 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
|
import time
|
||||||
|
import logging
|
||||||
|
from medicus_db import MedicusDB
|
||||||
|
from 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
|
||||||
|
)
|
||||||
|
|
||||||
|
def save_insurance_status(mysql_conn, rc, k_datu, result, xml_text):
|
||||||
|
sql = """
|
||||||
|
INSERT INTO vzp_stav_pojisteni
|
||||||
|
(rc, k_datu, stav, kod_pojistovny, nazev_pojistovny,
|
||||||
|
pojisteni_kod, stav_vyrizeni, response_xml)
|
||||||
|
VALUES (%s, %s, %s, %s, %s, %s, %s, %s)
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
with mysql_conn.cursor() as cur:
|
||||||
|
cur.execute(sql, (
|
||||||
|
rc,
|
||||||
|
k_datu,
|
||||||
|
result["stav"],
|
||||||
|
result["kodPojistovny"],
|
||||||
|
result["nazevPojistovny"],
|
||||||
|
result["pojisteniKod"],
|
||||||
|
result["stavVyrizeni"],
|
||||||
|
xml_text
|
||||||
|
))
|
||||||
|
except Exception as e:
|
||||||
|
log_error(f"❌ MYSQL ERROR for RC {rc}: {e}")
|
||||||
|
log_error(f"---- RAW XML ----\n{xml_text}\n-----------------")
|
||||||
|
raise
|
||||||
|
|
||||||
|
|
||||||
|
# ==========================================
|
||||||
|
# CONFIGURATION
|
||||||
|
# ==========================================
|
||||||
|
HOST = "192.168.1.4"
|
||||||
|
DB_PATH = r"z:\Medicus 3\data\MEDICUS.FDB"
|
||||||
|
|
||||||
|
PFX_PATH = r"MBcert.pfx"
|
||||||
|
PFX_PASSWORD = "Vlado7309208104++"
|
||||||
|
|
||||||
|
ENV = "prod"
|
||||||
|
ICZ = "00000000"
|
||||||
|
DIC = "00000000"
|
||||||
|
|
||||||
|
# ==========================================
|
||||||
|
# INIT CONNECTIONS
|
||||||
|
# ==========================================
|
||||||
|
db = MedicusDB(HOST, DB_PATH)
|
||||||
|
vzp = VZPB2BClient(ENV, PFX_PATH, PFX_PASSWORD, icz=ICZ, dic=DIC)
|
||||||
|
|
||||||
|
# ==========================================
|
||||||
|
# FETCH REGISTERED PATIENTS
|
||||||
|
# ==========================================
|
||||||
|
patients = db.get_active_registered_patients()
|
||||||
|
log_info(f"Checking {len(patients)} registered patients...\n")
|
||||||
|
|
||||||
|
k_datu = date.today().isoformat()
|
||||||
|
|
||||||
|
# ==========================================
|
||||||
|
# LOOP ONE PATIENT PER SECOND
|
||||||
|
# ==========================================
|
||||||
|
for rodcis, prijmeni, jmeno, poj in patients:
|
||||||
|
|
||||||
|
log_info(f"=== Checking {prijmeni} {jmeno} ({rodcis}) ===")
|
||||||
|
|
||||||
|
xml = vzp.stav_pojisteni(rc=rodcis, k_datu=k_datu)
|
||||||
|
|
||||||
|
# 1) Check if response looks like XML
|
||||||
|
if not xml.strip().startswith("<"):
|
||||||
|
log_error(f"❌ INVALID XML for RC {rodcis}")
|
||||||
|
log_error(f"---- RAW RESPONSE ----\n{xml}\n----------------------")
|
||||||
|
time.sleep(2)
|
||||||
|
continue
|
||||||
|
|
||||||
|
# 2) Try parsing XML
|
||||||
|
try:
|
||||||
|
result = vzp.parse_stav_pojisteni(xml)
|
||||||
|
except Exception as e:
|
||||||
|
log_error(f"❌ XML PARSE ERROR for RC {rodcis}: {e}")
|
||||||
|
log_error(f"---- RAW RESPONSE ----\n{xml}\n----------------------")
|
||||||
|
time.sleep(2)
|
||||||
|
continue
|
||||||
|
|
||||||
|
log_info(f"Result: {result}")
|
||||||
|
|
||||||
|
# 3) Save into MySQL (with logging)
|
||||||
|
try:
|
||||||
|
save_insurance_status(mysql, rodcis, k_datu, result, xml)
|
||||||
|
except Exception:
|
||||||
|
log_error(f"❌ FAILURE inserting to MySQL for {rodcis}")
|
||||||
|
continue
|
||||||
|
|
||||||
|
time.sleep(2)
|
||||||
|
|
||||||
|
db.close()
|
||||||
|
log_info("\nDONE.")
|
||||||
19
10 Tests/test stavpojisteni.py
Normal file
19
10 Tests/test stavpojisteni.py
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
cur.execute("select rodcis,prijmeni,jmeno from kar where datum_zruseni is null and kar.vyrazen!='A' and kar.rodcis is not null and idicp!=0 order by ockzaz.datum desc")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
from vzpb2b_client import VZPB2BClient
|
||||||
|
|
||||||
|
client = VZPB2BClient(
|
||||||
|
env="production",
|
||||||
|
pfx_path="mbcert.pfx",
|
||||||
|
pfx_password="Vlado7309208104++",
|
||||||
|
icz="00000000",
|
||||||
|
dic="00000000"
|
||||||
|
)
|
||||||
|
|
||||||
|
response = client.stav_pojisteni("0308020152")
|
||||||
|
# print(response)
|
||||||
|
print(client.parse_stav_pojisteni(response))
|
||||||
12
10 Tests/test.py
Normal file
12
10 Tests/test.py
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
from vzpb2b_client import VZPB2BClient
|
||||||
|
|
||||||
|
client = VZPB2BClient(
|
||||||
|
env="simu", # or "prod"
|
||||||
|
pfx_path="mbcert.pfx",
|
||||||
|
pfx_password="Vlado7309208104++",
|
||||||
|
icz="00000000",
|
||||||
|
dic="00000000"
|
||||||
|
)
|
||||||
|
|
||||||
|
result_xml = client.over_prukaz_pojistence("80203111194350000001")
|
||||||
|
print(result_xml)
|
||||||
213
10 Tests/vzpb2b_client.py
Normal file
213
10 Tests/vzpb2b_client.py
Normal file
@@ -0,0 +1,213 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
|
from requests_pkcs12 import Pkcs12Adapter
|
||||||
|
import requests
|
||||||
|
import uuid
|
||||||
|
from datetime import date
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class VZPB2BClient:
|
||||||
|
def __init__(self, env: str, pfx_path: str, pfx_password: str,
|
||||||
|
icz: str = "00000000", dic: str = "00000000"):
|
||||||
|
|
||||||
|
# Normalize environment name
|
||||||
|
env = env.lower().strip()
|
||||||
|
|
||||||
|
if env in ("prod", "production", "live", "real"):
|
||||||
|
self.env = "prod"
|
||||||
|
elif env in ("simu", "simulace", "test", "testing"):
|
||||||
|
self.env = "simu"
|
||||||
|
else:
|
||||||
|
raise ValueError(f"Unknown environment '{env}'. Use 'simu' or 'prod'.")
|
||||||
|
|
||||||
|
self.pfx_path = pfx_path
|
||||||
|
self.pfx_password = pfx_password
|
||||||
|
self.icz = icz
|
||||||
|
self.dic = dic
|
||||||
|
|
||||||
|
# Prepare mTLS session
|
||||||
|
session = requests.Session()
|
||||||
|
session.mount(
|
||||||
|
"https://",
|
||||||
|
Pkcs12Adapter(pkcs12_filename=pfx_path, pkcs12_password=pfx_password)
|
||||||
|
)
|
||||||
|
self.session = session
|
||||||
|
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
# URL BUILDER
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
def _build_endpoint(self, service_name: str) -> str:
|
||||||
|
"""
|
||||||
|
SIMU:
|
||||||
|
https://simu.b2b.vzp.cz/B2BProxy/HttpProxy/SIMU<Service>?sluzba=SIMU<Service>
|
||||||
|
PROD:
|
||||||
|
https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/<Service>
|
||||||
|
"""
|
||||||
|
|
||||||
|
if self.env == "simu":
|
||||||
|
simu_service = f"SIMU{service_name}"
|
||||||
|
return (
|
||||||
|
f"https://simu.b2b.vzp.cz/B2BProxy/HttpProxy/"
|
||||||
|
f"{simu_service}?sluzba={simu_service}"
|
||||||
|
)
|
||||||
|
|
||||||
|
# Production
|
||||||
|
return (
|
||||||
|
f"https://prod.b2b.vzp.cz/B2BProxy/HttpProxy/{service_name}"
|
||||||
|
)
|
||||||
|
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
# SOAP HEADER BUILDER
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
def _header(self) -> str:
|
||||||
|
idZpravy = uuid.uuid4().hex[:12] # must be alphanumeric, max 12 chars
|
||||||
|
return f"""
|
||||||
|
<com:idZpravy>{idZpravy}</com:idZpravy>
|
||||||
|
<com:idSubjektu>
|
||||||
|
<com:icz>{self.icz}</com:icz>
|
||||||
|
<com:dic>{self.dic}</com:dic>
|
||||||
|
</com:idSubjektu>
|
||||||
|
"""
|
||||||
|
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
# OVERPRUKAZ — EHIC CHECK
|
||||||
|
# --------------------------------------------------------------
|
||||||
|
def over_prukaz_pojistence(self, cislo_prukazu: str, k_datu: str = None) -> str:
|
||||||
|
"""
|
||||||
|
Calls OverPrukazPojistenceB2B (SIMU or PROD depending on env).
|
||||||
|
Returns raw XML string.
|
||||||
|
"""
|
||||||
|
|
||||||
|
service = "OverPrukazPojistenceB2B"
|
||||||
|
endpoint = self._build_endpoint(service)
|
||||||
|
|
||||||
|
if not k_datu:
|
||||||
|
k_datu = date.today().isoformat()
|
||||||
|
|
||||||
|
soap = f"""<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<soap:Envelope
|
||||||
|
xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"
|
||||||
|
xmlns:vzp="http://xmlns.gemsystem.cz/OverPrukazPojistenceB2B"
|
||||||
|
xmlns:com="http://xmlns.gemsystem.cz/CommonB2B">
|
||||||
|
|
||||||
|
<soap:Header>
|
||||||
|
{self._header()}
|
||||||
|
</soap:Header>
|
||||||
|
|
||||||
|
<soap:Body>
|
||||||
|
<vzp:OverPrukazPojistenceB2BPozadavek>
|
||||||
|
<vzp:cisloPrukazu>{cislo_prukazu}</vzp:cisloPrukazu>
|
||||||
|
<vzp:kDatu>{k_datu}</vzp:kDatu>
|
||||||
|
</vzp:OverPrukazPojistenceB2BPozadavek>
|
||||||
|
</soap:Body>
|
||||||
|
|
||||||
|
</soap:Envelope>
|
||||||
|
"""
|
||||||
|
|
||||||
|
headers = {"Content-Type": "text/xml; charset=utf-8"}
|
||||||
|
|
||||||
|
print(f"Calling: {endpoint}")
|
||||||
|
response = self.session.post(
|
||||||
|
endpoint,
|
||||||
|
data=soap.encode("utf-8"),
|
||||||
|
headers=headers,
|
||||||
|
timeout=30
|
||||||
|
)
|
||||||
|
print("HTTP:", response.status_code)
|
||||||
|
return response.text
|
||||||
|
|
||||||
|
def stav_pojisteni(self, rc: str, k_datu: str = None, prijmeni: str = None):
|
||||||
|
"""
|
||||||
|
Calls stavPojisteniB2B (SIMU or PROD).
|
||||||
|
"""
|
||||||
|
service = "stavPojisteniB2B"
|
||||||
|
endpoint = self._build_endpoint(service)
|
||||||
|
|
||||||
|
if not k_datu:
|
||||||
|
k_datu = date.today().isoformat()
|
||||||
|
|
||||||
|
prijmeni_xml = f"<vzp:prijmeni>{prijmeni}</vzp:prijmeni>" if prijmeni else ""
|
||||||
|
|
||||||
|
soap = f"""<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<soap:Envelope
|
||||||
|
xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"
|
||||||
|
xmlns:vzp="http://xmlns.gemsystem.cz/stavPojisteniB2B"
|
||||||
|
xmlns:com="http://xmlns.gemsystem.cz/CommonB2B">
|
||||||
|
|
||||||
|
<soap:Header>
|
||||||
|
{self._header()}
|
||||||
|
</soap:Header>
|
||||||
|
|
||||||
|
<soap:Body>
|
||||||
|
<vzp:stavPojisteniB2B>
|
||||||
|
<vzp:cisloPojistence>{rc}</vzp:cisloPojistence>
|
||||||
|
{prijmeni_xml}
|
||||||
|
<vzp:kDatu>{k_datu}</vzp:kDatu>
|
||||||
|
</vzp:stavPojisteniB2B>
|
||||||
|
</soap:Body>
|
||||||
|
|
||||||
|
</soap:Envelope>
|
||||||
|
"""
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
"Content-Type": "text/xml; charset=utf-8",
|
||||||
|
"SOAPAction": "process"
|
||||||
|
}
|
||||||
|
|
||||||
|
print(f"Calling: {endpoint}")
|
||||||
|
resp = self.session.post(endpoint, data=soap.encode("utf-8"),
|
||||||
|
headers=headers, timeout=30)
|
||||||
|
print("HTTP:", resp.status_code)
|
||||||
|
return resp.text
|
||||||
|
|
||||||
|
def parse_stav_pojisteni(self, xml_text: str):
|
||||||
|
"""
|
||||||
|
Parses stavPojisteniB2B SOAP response into a Python dict.
|
||||||
|
|
||||||
|
Returned structure:
|
||||||
|
{
|
||||||
|
"stavVyrizeni": int,
|
||||||
|
"stav": str | None,
|
||||||
|
"kodPojistovny": str | None,
|
||||||
|
"nazevPojistovny": str | None,
|
||||||
|
"pojisteniKod": str | None
|
||||||
|
}
|
||||||
|
"""
|
||||||
|
|
||||||
|
import xml.etree.ElementTree as ET
|
||||||
|
|
||||||
|
NS = {
|
||||||
|
"soap": "http://schemas.xmlsoap.org/soap/envelope/",
|
||||||
|
"vzp": "http://xmlns.gemsystem.cz/stavPojisteniB2B"
|
||||||
|
}
|
||||||
|
|
||||||
|
root = ET.fromstring(xml_text)
|
||||||
|
|
||||||
|
# ---- Extract status ----
|
||||||
|
stav_vyr = root.find(".//vzp:stavVyrizeniPozadavku", NS)
|
||||||
|
stav_vyr = int(stav_vyr.text.strip()) if stav_vyr is not None else None
|
||||||
|
|
||||||
|
# ---- If no stavPojisteni element present (e.g. 0 or some errors) ----
|
||||||
|
node_stav = root.find(".//vzp:stavPojisteni", NS)
|
||||||
|
if node_stav is None:
|
||||||
|
return {
|
||||||
|
"stavVyrizeni": stav_vyr,
|
||||||
|
"stav": None,
|
||||||
|
"kodPojistovny": None,
|
||||||
|
"nazevPojistovny": None,
|
||||||
|
"pojisteniKod": None,
|
||||||
|
}
|
||||||
|
|
||||||
|
def get(tag):
|
||||||
|
el = node_stav.find(f"vzp:{tag}", NS)
|
||||||
|
return el.text.strip() if el is not None and el.text else None
|
||||||
|
|
||||||
|
return {
|
||||||
|
"stavVyrizeni": stav_vyr,
|
||||||
|
"stav": get("stav"),
|
||||||
|
"kodPojistovny": get("kodPojistovny"),
|
||||||
|
"nazevPojistovny": get("nazevPojistovny"),
|
||||||
|
"pojisteniKod": get("pojisteniKod"),
|
||||||
|
}
|
||||||
@@ -22,7 +22,7 @@ def get_medicus_connection():
|
|||||||
fdb.Connection object on success
|
fdb.Connection object on success
|
||||||
None on failure
|
None on failure
|
||||||
"""
|
"""
|
||||||
if socket.gethostname().strip()=="NTBVBHP470G10":
|
if socket.gethostname().strip() in ("NTBVBHP470G10","Z230"):
|
||||||
MEDICUS_CFG = dict(
|
MEDICUS_CFG = dict(
|
||||||
dsn=r"192.168.1.4:z:\medicus 3\data\medicus.fdb",
|
dsn=r"192.168.1.4:z:\medicus 3\data\medicus.fdb",
|
||||||
user="SYSDBA",
|
user="SYSDBA",
|
||||||
@@ -50,7 +50,7 @@ def get_mysql_connection():
|
|||||||
"""
|
"""
|
||||||
Return a PyMySQL connection or None if the connection fails.
|
Return a PyMySQL connection or None if the connection fails.
|
||||||
"""
|
"""
|
||||||
if socket.gethostname().strip() == "NTBVBHP470G10":
|
if socket.gethostname().strip() in ("NTBVBHP470G10","Z230"):
|
||||||
MYSQL_CFG = dict(
|
MYSQL_CFG = dict(
|
||||||
host="192.168.1.76",
|
host="192.168.1.76",
|
||||||
port=3307,
|
port=3307,
|
||||||
|
|||||||
Reference in New Issue
Block a user