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

feat: ログ出力メッセージを変更

Browse Source
This commit is contained in:
高木要 2023-06-01 15:58:52 +09:00
parent f3e772e0f3
commit 9ae9278967
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
View File

@ -40,7 +40,7 @@ def _set_enabled_dct_inst_merge(db: Database) -> list[dict]:
if _update_dcf_inst_merge(db, 0) > 0:
# DCF施設統合マスタの過去分の洗い替え
for row in enabled_dst_inst_merge_records:
_update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'])
_update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'], 0)
return enabled_dst_inst_merge_records
@ -52,7 +52,7 @@ def _set_disabled_dct_inst_merge(db: Database):
if _update_dcf_inst_merge(db, 1) > 0:
# DCF施設統合マスタの過去分の洗い替え
for row in disabled_dst_inst_merge_records:
_update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'])
_update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'], 1)
def _add_ult_ident_presc(db: Database, enabled_dst_inst_merge_records: list[dict]):
@ -356,15 +356,16 @@ def _update_dcf_inst_merge(db: Database, muko_flg: int) -> int:
logging_sql(logger, sql)
logger.info(f'DCF施設統合マスタの有効データを{log_message} 成功, {res.rowcount} 行更新 ({elapsed_time.of})')
except Exception as e:
logger.debug(f'DCF施設統合マスタの{log_message} 失敗')
logger.debug(f'DCF施設統合マスタの有効データを{log_message} 失敗')
raise e
return res.rowcount
def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str):
def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str, muko_flg: int):
# dcf_inst_mergeをUPDATE
try:
log_message = '' if muko_flg == 0 else '戻し'
elapsed_time = ElapsedTime()
sql = """
UPDATE
@ -384,9 +385,9 @@ def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_c
}
res = db.execute(sql, params)
logging_sql(logger, sql)
logger.info(f'移行先DCF施設コードの更新に成功, {res.rowcount} 行更新 ({elapsed_time.of})')
logger.info(f'移行先DCF施設コードの{log_message}更新に成功, {res.rowcount} 行更新 ({elapsed_time.of})')
except Exception as e:
logger.debug('移行先DCF施設コードの更新に失敗')
logger.debug(f'移行先DCF施設コードの{log_message}更新に失敗')
raise e