diff --git a/ecs/jskult-batch/src/batch/update_business_day.py b/ecs/jskult-batch/src/batch/update_business_day.py index 298eb7c9..20b99f5d 100644 --- a/ecs/jskult-batch/src/batch/update_business_day.py +++ b/ecs/jskult-batch/src/batch/update_business_day.py @@ -77,7 +77,6 @@ class UpdateBusinessDay(JskultBatchEntrypoint): except MaxRunCountReachedException: logger.error('後続処理の実行が完了していないため、日付テーブル更新処理を異常終了します。') - # 何らかのエラーが発生した際に、バッチ実行管理テーブルに「failed」で登録 jskult_batch_run_manager.batch_failed() jskult_batch_status_manager.set_process_status( constants.PROCESS_STATUS_ERROR) @@ -116,6 +115,10 @@ class UpdateBusinessDay(JskultBatchEntrypoint): logger.exception(f'転送ファイル一覧の取得に失敗しました。 {e}') # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_ERROR) + logger.error(f'E-1 異常終了:実消化&アルトマーク_日付テーブル更新。{e}') + return with open(transfer_list_file_path) as f: transfer_data_list = json.load(f) @@ -130,6 +133,11 @@ class UpdateBusinessDay(JskultBatchEntrypoint): logger.exception(f'転送ファイル一覧の取得に失敗しました。 {e}') # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_ERROR) + logger.error(f'E-1 異常終了:実消化&アルトマーク_日付テーブル更新。{e}') + return + with open(jsk_expected_data_path) as f: jsk_expected_data_list = json.load(f) @@ -149,6 +157,7 @@ class UpdateBusinessDay(JskultBatchEntrypoint): jskult_batch_status_manager.set_process_status( constants.PROCESS_STATUS_DONE) + # 日付テーブルに対しバッチ処理中ステータスとダンプ取得状態区分を0に、処理日を+1日に更新 jskult_batch_run_manager.batch_success() logger.info('I-4 [NOTICE]処理終了: 実消化&アルトマーク_日付テーブル更新') @@ -160,7 +169,12 @@ class UpdateBusinessDay(JskultBatchEntrypoint): logger.error(f'E-1 異常終了:実消化&アルトマーク_日付テーブル更新。{e}') def _is_archive_run_day(self, syor_date: str): - # アーカイブ取得日カレンダーを取得する + """アーカイブ取得日カレンダーを取得し、処理日がアーカイブ起動日かを確認 + + Returns: + bool + + """ archive_calendar_file_path = ConfigBucket().download_jsk_archive_run_day_list() # 設定ファイル「実消化データアーカイブ起動日カレンダーファイル」の定義内容を取得する @@ -185,6 +199,7 @@ class UpdateBusinessDay(JskultBatchEntrypoint): f'I-5 [NOTICE]日次連携受領ファイルに不足がありました。ファイル名:{missing_files}') def _check_extra_received_files(self, jsk_transfer_expected_data_list: list, jsk_transfer_data_list: list): + # jsk_transfer_data_listと比較し、受領予定にないファイルがあった場合ログ出力 unexpected_data = [ jsk_transfer_data for jsk_transfer_data in jsk_transfer_data_list diff --git a/s3/config/jsk_archive_run_day.txt b/s3/config/jsk_archive_run_day.txt new file mode 100644 index 00000000..0af50d99 --- /dev/null +++ b/s3/config/jsk_archive_run_day.txt @@ -0,0 +1,12 @@ +2025/01/01 +2025/02/01 +2025/03/01 +2025/04/01 +2025/05/01 +2025/06/01 +2025/07/01 +2025/08/01 +2025/09/01 +2025/10/01 +2025/11/01 +2025/12/01 \ No newline at end of file diff --git a/s3/config/jsk_expected_data_list.json b/s3/config/jsk_expected_data_list.json new file mode 100644 index 00000000..0b8183c0 --- /dev/null +++ b/s3/config/jsk_expected_data_list.json @@ -0,0 +1,37 @@ +{ + "jsk_transfer_list":[ + "TRN_RESULT_DATA", + "TRN_RESULT_DATA_BIO", + "TRN_Recive_Inventry", + "INST_IM_PLN", + "MR_YR_PLN_INST_KY", + "MST_WHLSLR", + "MST_SALES_PLACE", + "WHLSLR_LVL4", + "WHLSLR_LVL3", + "WHLSLR_LVL2", + "WHLSLR_LVL1", + "MST_COMPANY", + "MST_COMPANY_GRP", + "MST_DEAL_DIV", + "MST_PROD_PKG", + "PROD_PRICE", + "IM_PLN_PROD", + "MST_ASSN_PROD_GRP", + "PROD_ASSN_TEAM", + "MST_ATC_PHARM_PROD_GRP", + "CUSTOMER_LOTNO_ALL", + "MST_INST", + "ATC_PHARM", + "MST_WAREHOUSE", + "EMP", + "ORG_LVL4", + "ORG_LVL3", + "ORG_LVL2", + "ORG_LVL1", + "MST_JIS_PREF", + "MST_JIS_CITY", + "MST_INST_ASSN", + "MST_GENERAL" + ] +} \ No newline at end of file