nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

アルトマーク施設マスタのinsertの実装

Browse Source
This commit is contained in:
mori.k 2025-05-30 18:14:43 +09:00
parent ed55a30bf1
commit f5953877fc
1 changed files with 19 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

95
ecs/jskult-batch/src/batch/mst_inst_all.py
View File

@ -19,6 +19,7 @@ from src.system_var import environment
logger = get_logger('メルク施設マスタ作成') logger = get_logger('メルク施設マスタ作成')
class MstInstAll(JskultBatchEntrypoint): class MstInstAll(JskultBatchEntrypoint):
def __init__(self): def __init__(self):
super().__init__() super().__init__()
@ -35,7 +36,8 @@ class MstInstAll(JskultBatchEntrypoint):
logger.info("メルク施設マスタ作成処理を開始します。") logger.info("メルク施設マスタ作成処理を開始します。")
jskult_hdke_tbl_manager = JskultHdkeTblManager() jskult_hdke_tbl_manager = JskultHdkeTblManager()
jskult_batch_run_manager = JskultBatchRunManager( jskult_batch_run_manager = JskultBatchRunManager(
environment.BATCH_EXECUTION_ID) self.environment.BATCH_MANAGE_DYNAMODB_TABLE_NAME,
self.environment.BATCH_BATCH_EXECUTION_ID)
if not jskult_hdke_tbl_manager.can_run_process(): if not jskult_hdke_tbl_manager.can_run_process():
logger.error( logger.error(
'日次バッチ処理中またはdump取得が正常終了していないため、メルク施設マスタ作成処理を終了します。') '日次バッチ処理中またはdump取得が正常終了していないため、メルク施設マスタ作成処理を終了します。')
@ -93,22 +95,21 @@ class MstInstAll(JskultBatchEntrypoint):
self._db = Database.get_instance() self._db = Database.get_instance()
self._db.connect() self._db.connect()
logger.debug('メルク施設マスタ作成処理開始') logger.debug('メルク施設マスタ作成処理開始')
# mst_instをTruncate # mst_inst_allをTruncate
self._truncate_mst_inst(self._db) self._truncate_mst_inst_all(self._db)
# fcl_mst_vから、mst_instへInsert # com_pharmから、mst_inst_allへInsert
self._insert_mst_inst_from_fcl_mst_v(self._db) self._insert_mst_inst_all_from_com_pharm(self._db)
# com_instから、mst_instへInsert # com_instから、mst_inst_allへInsert
self._insert_mst_inst_from_com_inst(self._db) self._insert_mst_inst_all_from_com_inst(self._db)
logger.debug('メルク施設マスタ作成処理終了') logger.debug('メルク施設マスタ作成処理終了')
except Exception as e: except Exception as e:
raise BatchOperationException(e) raise BatchOperationException(e)
finally: finally:
self._db.disconnect() self._db.disconnect()
def _truncate_mst_inst_all(self, db: Database):
def _truncate_mst_inst(db: Database):
try: try:
db.execute("TRUNCATE TABLE src05.mst_inst") db.execute("TRUNCATE TABLE src07.mst_inst_all")
except Exception as e: except Exception as e:
logger.debug("メルク施設マスタの全件削除に失敗") logger.debug("メルク施設マスタの全件削除に失敗")
raise e raise e
@ -116,13 +117,12 @@ class MstInstAll(JskultBatchEntrypoint):
logger.debug("メルク施設マスタの全件削除に成功") logger.debug("メルク施設マスタの全件削除に成功")
return return
def _insert_mst_inst_all_from_com_pharm(self, db: Database):
def _insert_mst_inst_from_fcl_mst_v(db: Database): # com_pharmから、mst_inst_allへInsert
# fcl_mst_vから、mst_instへInsert
try: try:
sql = """ sql = """
INSERT INTO INSERT INTO
src05.mst_inst ( src07.mst_inst_all (
inst_cd, inst_cd,
inst_clas_cd, inst_clas_cd,
inst_name_form, inst_name_form,
@ -191,15 +191,14 @@ class MstInstAll(JskultBatchEntrypoint):
AND fmv1.rec_sts_kbn != '9' AND fmv1.rec_sts_kbn != '9'
""" """
res = db.execute(sql) res = db.execute(sql)
logger.info(f'Ｖ施設マスタからメルク施設マスタに登録成功') logger.info(f'COM_薬局からメルク施設マスタに登録成功')
except Exception as e: except Exception as e:
logger.debug("Ｖ施設マスタからメルク施設マスタに登録失敗") logger.debug("COM_薬局からメルク施設マスタに登録失敗")
raise e raise e
return return
def _insert_mst_inst_all_from_com_inst(self, db: Database):
def _insert_mst_inst_from_com_inst(db: Database):
# オプティマイザのderived_mergeフラグをoffにする # オプティマイザのderived_mergeフラグをoffにする
try: try:
sql = """ sql = """
@ -211,11 +210,11 @@ class MstInstAll(JskultBatchEntrypoint):
logger.debug("オプティマイザのderived_mergeフラグの値変更に失敗") logger.debug("オプティマイザのderived_mergeフラグの値変更に失敗")
raise e raise e
# com_instから、mst_instへInsert # com_instから、mst_inst_allへInsert
try: try:
sql = """ sql = """
INSERT INTO INSERT INTO
src05.mst_inst ( src07.mst_inst_all (
inst_cd, inst_cd,
inst_clas_cd, inst_clas_cd,
inst_name_form, inst_name_form,
@ -233,7 +232,6 @@ class MstInstAll(JskultBatchEntrypoint):
delete_date, delete_date,
inst_div_cd, inst_div_cd,
inst_div_name, inst_div_name,
v_inst_cd,
creater, creater,
create_date, create_date,
updater, updater,
@ -257,7 +255,6 @@ class MstInstAll(JskultBatchEntrypoint):
ci.abolish_ymd, ci.abolish_ymd,
ci.inst_div_cd, ci.inst_div_cd,
LEFT(cid.inst_div_name, 40), LEFT(cid.inst_div_name, 40),
mcmv.hco_vid_v,
ci.create_user, ci.create_user,
ci.regist_date, ci.regist_date,
ci.update_user, ci.update_user,
@ -273,60 +270,6 @@ class MstInstAll(JskultBatchEntrypoint):
ON ci.manage_cd = cm.manage_cd ON ci.manage_cd = cm.manage_cd
LEFT OUTER JOIN src05.com_inst_div AS cid LEFT OUTER JOIN src05.com_inst_div AS cid
ON ci.inst_div_cd = cid.inst_div_cd ON ci.inst_div_cd = cid.inst_div_cd
LEFT OUTER JOIN ( -- MDBコード変換表を使用してV施設コードを取得するためのテーブル結合
SELECT
mcmv4.*
FROM (
SELECT
mcmv1.*
FROM
src05.mdb_cnv_mst_v AS mcmv1
INNER JOIN (
SELECT
mcmv2.hco_vid_v,
MAX(mcmv2.sub_num) AS sno -- MDBコード変換データの枝番MAX
FROM
src05.mdb_cnv_mst_v mcmv2
WHERE
mcmv2.rec_sts_kbn != '9' -- 状態区分9（削除）以外 and 適用開始≦日付テーブル.処理日
AND src05.get_syor_date() >= mcmv2.start_date
GROUP BY
mcmv2.hco_vid_v
) AS mcmv3
ON mcmv1.hco_vid_v = mcmv3.hco_vid_v
AND mcmv1.sub_num = mcmv3.sno
) AS mcmv4
INNER JOIN (
SELECT
MIN(mcmv8.hco_vid_v) AS hvv, -- 1つのMDBコードに対し、複数のV施設コードが割り当てられている場合、最小のV施設コードを選択する
mcmv8.mdb_cd
FROM (
SELECT
mcmv5.*
FROM
src05.mdb_cnv_mst_v AS mcmv5
INNER JOIN (
SELECT
mcmv6.hco_vid_v,
MAX(mcmv6.sub_num) AS sno -- MDBコード変換データの枝番MAX
FROM
src05.mdb_cnv_mst_v AS mcmv6
WHERE
mcmv6.rec_sts_kbn != '9' -- 状態区分9（削除）以外 and 適用開始≦日付テーブル.処理日
AND src05.get_syor_date() >= mcmv6.start_date
GROUP BY
mcmv6.hco_vid_v
) AS mcmv7
ON mcmv5.hco_vid_v = mcmv7.hco_vid_v
AND mcmv5.sub_num = mcmv7.sno
) AS mcmv8
GROUP BY
mcmv8.mdb_cd
) AS mcmv9
ON mcmv4.mdb_cd = mcmv9.mdb_cd
AND mcmv4.hco_vid_v = mcmv9.hvv
) AS mcmv
ON ci.dcf_dsf_inst_cd = mcmv.mdb_cd
""" """
res = db.execute(sql) res = db.execute(sql)
logger.info(f'COM施設からメルク施設マスタに登録成功') logger.info(f'COM施設からメルク施設マスタに登録成功')