diff --git a/ecs/jskult-batch/src/batch/mst_inst_all.py b/ecs/jskult-batch/src/batch/mst_inst_all.py index c5b99021..33e47faa 100644 --- a/ecs/jskult-batch/src/batch/mst_inst_all.py +++ b/ecs/jskult-batch/src/batch/mst_inst_all.py @@ -44,6 +44,8 @@ class MstInstAll(JskultBatchEntrypoint): '日次バッチ処理中またはdump取得が正常終了していないため、メルク施設マスタ作成処理を終了します。') # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_ERROR) return # 業務日付を取得 @@ -58,6 +60,9 @@ class MstInstAll(JskultBatchEntrypoint): logger.exception(f'転送ファイル一覧の取得に失敗しました。 {e}') # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_ERROR) + return with open(transfer_list_file_path) as f: transfer_list = json.load(f) @@ -68,8 +73,7 @@ class MstInstAll(JskultBatchEntrypoint): jskult_batch_status_manager = JskultBatchStatusManager( environment.PROCESS_NAME, - # TODO チケットNEWDWH2021-1847の実装で作成した定数に置き換え - 'post_process', + constants.PROCESS_TYPE_POST_PROCESS, environment.MAX_RUN_COUNT, receive_file_count ) @@ -86,6 +90,7 @@ class MstInstAll(JskultBatchEntrypoint): # バッチ実行管理テーブルに「retry」で登録 jskult_batch_run_manager.batch_retry() + logger.info('起動条件を満たしていないため、メルク施設マスタ作成処理を終了します') return except MaxRunCountReachedException: @@ -284,7 +289,7 @@ class MstInstAll(JskultBatchEntrypoint): return - def _insert_mst_inst_all_from_mst_inst_merck(self, db:Database): + def _insert_mst_inst_all_from_mst_inst_merck(self, db: Database): # mst_inst_merckから、mst_inst_allへInsert try: sql = """ @@ -338,10 +343,10 @@ class MstInstAll(JskultBatchEntrypoint): null, null, null, - mim.ins_user, - mim.ins_date, - mim.upd_user, - mim.upd_date + mim.create_id, + mim.create_dtt, + mim.last_upd_id, + mim.last_upd_dtt FROM src07.mst_inst_merck AS mim INNER JOIN ( @@ -364,4 +369,4 @@ class MstInstAll(JskultBatchEntrypoint): logger.info("メルク独自施設マスタからメルク施設マスタに登録失敗") raise e - return \ No newline at end of file + return