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

fix: バグ修正

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-04-14 13:08:49 +09:00
parent 2b57687697
commit d00bf2699e
3 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ecs/jskult-batch-daily/src/batch/batch_functions.py
View File

@ -36,7 +36,7 @@ def get_batch_statuses() -> tuple[str, str, str]:
hdke_tbl_record = hdke_tbl_result[0]
batch_processing_flag = hdke_tbl_record['bch_actf']
dump_status_kbn = hdke_tbl_record['dump_sts_kbn']
syor_date = hdke_tbl_record['dump_sts_kbn']
syor_date = hdke_tbl_record['syor_date']
# 処理日を文字列に変換する
syor_date_str = datetime.strftime(syor_date, '%Y/%m/%d')
@ -73,7 +73,7 @@ def update_batch_process_complete() -> None:
SET
bch_actf = :batch_complete,
dump_sts_kbn = :dump_unprocessed,
syor_date = DATE_FORMAT((src05.get_syor_date() + interval 1 day), '%Y%m%d) -- +1日
syor_date = DATE_FORMAT((src05.get_syor_date() + interval 1 day), '%Y%m%d') -- +1日
"""
try:
db.connect()

16
ecs/jskult-batch-daily/src/jobctrl_daily.py
View File

@ -22,17 +22,17 @@ def batch_process():
batch_processing_flag, dump_status_kbn, syor_date = get_batch_statuses()
except BatchOperationException as e:
logger.exception(f'日付テーブル取得（異常終了）{e}')
raise e
return constants.BATCH_EXIT_CODE_SUCCESS
# 日次バッチ処理中の場合、後続の処理は行わない
if batch_processing_flag == constants.BATCH_ACTF_BATCH_IN_PROCESSING:
logger.error('日次バッチ処理中のため、日次バッチ処理を終了します。')
return 0
return constants.BATCH_EXIT_CODE_SUCCESS
# dump取得が正常終了していない場合、後続の処理は行わない
if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE:
logger.error('dump取得が正常終了していないため、日次バッチ処理を終了します。')
return 0 # エラーで返せば、StepFunctionsでリトライしてくれるので、どう返すかは要検討
return constants.BATCH_EXIT_CODE_SUCCESS # TODO: エラーで返せば、StepFunctionsでリトライしてくれるので、どう返すかは要検討
logger.info(f'処理日＝{syor_date}')
# バッチ共通設定に処理日を追加
@ -43,6 +43,7 @@ def batch_process():
update_batch_processing_flag_in_processing()
except BatchOperationException as e:
logger.exception(f'処理フラグ更新(未処理→処理中) エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
# 休日判定ファイルを読み込み(ここは、各処理内に押し込むつもり)
logger.info('休日判定処理')
@ -89,17 +90,20 @@ def batch_process():
logger.info('アルトマーク取込：終了')
except BatchOperationException as e:
logger.error(f'アルトマーク取込処理エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
if True: # 休日判定、メルク施設マスタ作成内で行いたい
try:
logger.info('メルク施設マスタ作成')
logger.info('メルク施設マスタ作成終了')
except BatchOperationException as e:
logger.error(f'メルク施設マスタ作成エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
try:
logger.info('DCF施設統合マスタ作成')
logger.info('DCF施設統合マスタ作成終了')
except BatchOperationException as e:
logger.error(f'DCF施設統合マスタ作成エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
# if False: # ($holiday === FALSE) # DCF施設統合マスタを作成する日は必ず休日なので、V実消化の取り込みは行わない。
# TODO: データ存在確認は実消化取り込み内で行う
# logger.info('V実消化連携データ存在確認')
@ -112,6 +116,7 @@ def batch_process():
logger.info('V実消化取込：終了')
except BatchOperationException as e:
logger.exception(f'V実消化取込処理エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
logger.info('日次処理（実績更新）')
# ここも、休日判定を内側で行う
@ -124,14 +129,17 @@ def batch_process():
logger.info('生物由来ロット分解：終了')
except BatchOperationException as e:
logger.exception(f'実績更新処理エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
# バッチ処理完了とし、処理日、バッチ処置中フラグ、dump取得状態区分を更新
try:
update_batch_process_complete()
except BatchOperationException as e:
logger.exception(f'日次バッチ完了処理 エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
logger.info('日次ジョブ：終了（正常終了）')
return 0
return constants.BATCH_EXIT_CODE_SUCCESS
except Exception as e:
logger.exception(f'日次バッチ処理中に想定外のエラーが発生しました {e}')
raise e

3
ecs/jskult-batch-daily/src/system_var/constants.py
View File

@ -1,3 +1,6 @@
# バッチ正常終了コード
BATCH_EXIT_CODE_SUCCESS = 0
# バッチ処理中フラグ：未処理
BATCH_ACTF_BATCH_UNPROCESSED = '0'
# バッチ処理中フラグ：処理中