From 8c73f153d6dd9112d6e07968912b00587d8931b8 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Fri, 14 Apr 2023 17:46:13 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=B8=8D=E8=A6=81=E3=81=AA=E3=82=B3?= =?UTF-8?q?=E3=83=A1=E3=83=B3=E3=83=88=E3=81=AA=E3=81=A9=E3=82=92=E6=95=B4?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch-daily/src/jobctrl_daily.py | 83 +-------------------- 1 file changed, 2 insertions(+), 81 deletions(-) diff --git a/ecs/jskult-batch-daily/src/jobctrl_daily.py b/ecs/jskult-batch-daily/src/jobctrl_daily.py index 72395a0c..94e8a835 100644 --- a/ecs/jskult-batch-daily/src/jobctrl_daily.py +++ b/ecs/jskult-batch-daily/src/jobctrl_daily.py @@ -34,7 +34,7 @@ def exec(): return constants.BATCH_EXIT_CODE_SUCCESS # dump取得が正常終了していない場合、後続の処理は行わない - if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE and dump_status_kbn != constants.DUMP_STATUS_KBN_DUMP_SKIP: + if dump_status_kbn not in [constants.DUMP_STATUS_KBN_COMPLETE, constants.DUMP_STATUS_KBN_DUMP_SKIP]: logger.error('dump取得が正常終了していないため、日次バッチ処理を終了します。') return constants.BATCH_EXIT_CODE_SUCCESS # TODO: エラーで返せば、StepFunctionsでリトライしてくれるので、どう返すかは要検討 @@ -42,26 +42,10 @@ def exec(): # バッチ共通設定に処理日を追加 batch_context.syor_date = syor_date - # 稼働日かかどうかを設定 - # 非営業日ファイルをダウンロードして判定 + # 稼働日かかどうかを、非営業日ファイルをダウンロードして判定 holiday_list_file_path = ConfigBucket().download_holiday_list() holiday_calendar = CalendarFile(holiday_list_file_path) - # 非稼働日かどうかを設定 batch_context.is_not_business_day = not holiday_calendar.compare_date(syor_date) - # for row in io.TextIOWrapper(io.BytesIO(non_business_day_response["Body"].read()), encoding='utf-8'): - # if row[INDEX_ROW_COMMENT_SYMBOL] == ROW_COMMENT_SYMBOL: - # continue - # non_date = row.rstrip('\n') - # # 日付妥当性判定 - # try: - # datetime.datetime.strptime(non_date, "%Y/%m/%d") - # except Exception as e: - # raise e - # none_business_day_list.append(non_date) - - # if execute_date in none_business_day_list: - # logger.info('I-02-05 本日は非営業日のため、チェック処理をスキップします') - # return # バッチ処理中に更新 try: @@ -70,46 +54,7 @@ def exec(): logger.exception(f'処理フラグ更新(未処理→処理中) エラー（異常終了）{e}') return constants.BATCH_EXIT_CODE_SUCCESS - # 休日判定ファイルを読み込み(ここは、各処理内に押し込むつもり) - logger.info('休日判定処理') - if True: # 休日判定 - logger.info('非営業日かつ月、火、水以外です。') # 分岐 - # try: - # # 処理中フラグ判定。ここでdumpのフラグも見る - # logger.info('処理フラグ更新中') - # logger.info('処理フラグ更新終了') - # except BatchOperationException as e: - # logger.error(f'処理フラグ更新処理エラー（異常終了）{e}') - logger.info('日次ジョブ：終了（正常終了）') - # try: - # logger.info('日次ジョブ処理中判定') - # if True: # 処理中判定 - # logger.error('処理フラグ処理中（異常終了）') - # logger.info('処理中フラグの更新：起動') - # logger.info('処理中フラグの更新：終了') - # except BatchOperationException as e: - # logger.error(f'日次ジョブ処理中エラー（異常終了）{e}') - # TODO: 以下、卸在庫取り込み処理は、実消化取り込み内で行う - # logger.info('卸在庫データ取込判定') - # if True: # 卸在庫日判定 - # logger.info('卸在庫データ取込日です') - # logger.debug('卸在庫データファイル名： {_PATH_OROSHI_ZAIKO}') - # if True: # 卸在庫ファイル存在確認なければ異常終了 - # logger.error('卸在庫データ存在確認エラー（異常終了）') - # logger.info('卸在庫データ存在確認：取込処理開始') - # logger.debug('卸在庫データファイル名作成： {read_filename}') - # logger.debug('ファイル移動OK：{_MOVE_OROSHI_ZAIKO}') # S3からダウンロード - # logger.debug('ファイル解凍OK：{sprintf(_ZIP_OROSHI_ZAIKO, $read_filename)}') # gunzip -fなので、gzipを使う - # logger.debug('ファイル名変更OK： {sprintf(_RENAME_OROSHI_ZAIKO, $read_filename)}') # S3にアップロード - # try: - # logger.info('卸在庫データ取込：起動') - # logger.info('卸在庫データ取込：終了') - # except BatchOperationException as e: - # logger.error(f'卸在庫データ取込処理エラー（異常終了）{e}') logger.info('日次処理（アルトマーク）') - # if True: # アルトマーク取り込み処理内で実装 - # logger.info('日次処理（アルトマーク）実行対象日でない為未実行') - try: logger.info('アルトマーク取込：起動') ultmarc_process.exec_import() @@ -126,28 +71,6 @@ def exec(): logger.exception(f'V実消化用施設・薬局薬店データ作成処理エラー（異常終了）{e}') return constants.BATCH_EXIT_CODE_SUCCESS - # TODO: 現行では休日も、メルク施設マスタと施設統合マスタの作成を行っている。 - # 実績洗い替えの中でもメルク施設マスタと施設統合マスタの作成は行っているが、他の処理は動かしたくない。 - # つまり、休日だったら、メルク施設マスタと施設統合マスタ以外の作成は行わない、とすれば、シンプルになる？ - # 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) # V実消化非稼働日は、V実消化の取り込みは行わない。 - # TODO: データ存在確認は実消化取り込み内で行う - # logger.info('V実消化連携データ存在確認') - # if True: - # logger.error('V実消化連携データ存在確認（異常終了）') - logger.info('日次処理（V実消化）') try: logger.info('V実消化取込：起動') @@ -166,8 +89,6 @@ def exec(): return constants.BATCH_EXIT_CODE_SUCCESS logger.info('日次処理（実績更新）') - # ここも、休日判定を実績更新内で行う - # 休日であっても、施設統合マスタの作成だけは行う。 try: # ここで、生物由来ロット分解と並行処理 logger.info('実績更新：起動')