From d00bf2699eb02d33ecbbc721c3f3ca221cf34aaa Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Fri, 14 Apr 2023 13:08:49 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20=E3=83=90=E3=82=B0=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/batch/batch_functions.py | 4 ++-- ecs/jskult-batch-daily/src/jobctrl_daily.py | 16 ++++++++++++---- .../src/system_var/constants.py | 3 +++ 3 files changed, 17 insertions(+), 6 deletions(-) diff --git a/ecs/jskult-batch-daily/src/batch/batch_functions.py b/ecs/jskult-batch-daily/src/batch/batch_functions.py index be2bd565..255d7729 100644 --- a/ecs/jskult-batch-daily/src/batch/batch_functions.py +++ b/ecs/jskult-batch-daily/src/batch/batch_functions.py @@ -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() diff --git a/ecs/jskult-batch-daily/src/jobctrl_daily.py b/ecs/jskult-batch-daily/src/jobctrl_daily.py index 3cd862c8..385586f4 100644 --- a/ecs/jskult-batch-daily/src/jobctrl_daily.py +++ b/ecs/jskult-batch-daily/src/jobctrl_daily.py @@ -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 diff --git a/ecs/jskult-batch-daily/src/system_var/constants.py b/ecs/jskult-batch-daily/src/system_var/constants.py index 5eafaedd..d5538a80 100644 --- a/ecs/jskult-batch-daily/src/system_var/constants.py +++ b/ecs/jskult-batch-daily/src/system_var/constants.py @@ -1,3 +1,6 @@ +# バッチ正常終了コード +BATCH_EXIT_CODE_SUCCESS = 0 + # バッチ処理中フラグ：未処理 BATCH_ACTF_BATCH_UNPROCESSED = '0' # バッチ処理中フラグ：処理中