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

レビュー指摘対応

Browse Source
This commit is contained in:
mori.k 2025-06-05 09:54:34 +09:00
parent 0cb7ac281a
commit 5bde7acbd8
3 changed files with 66 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
ecs/jskult-batch/src/batch/update_business_day.py
View File

@ -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

12
s3/config/jsk_archive_run_day.txt Normal file
View File

@ -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

37
s3/config/jsk_expected_data_list.json Normal file
View File

@ -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"
]
}