From 31a8f79fcac25c5894fa6ad1a174b5b85eae4c04 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Tue, 3 Jun 2025 18:27:32 +0900 Subject: [PATCH 1/8] =?UTF-8?q?format:=20=E3=83=95=E3=82=A9=E3=83=BC?= =?UTF-8?q?=E3=83=9E=E3=83=83=E3=83=88=E9=81=A9=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/batch/trn_result_data_bio_lot.py | 50 +++++++++---------- 1 file changed, 24 insertions(+), 26 deletions(-) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 65e7408a..24a0941f 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -1,25 +1,22 @@ import json + from src.aws.s3 import JskTransferListBucket from src.batch.environment.trn_result_data_bio_lot_environment import \ TrnResultDataBioLotEnvironment from src.batch.jskult_batch_entrypoint import JskultBatchEntrypoint -from src.manager.jskult_batch_run_manager import JskultBatchRunManager -from src.manager.jskult_batch_status_manager import JskultBatchStatusManager -from src.manager.jskult_hdke_tbl_manager import JskultHdkeTblManager from src.db.database import Database from src.error.exceptions import (BatchOperationException, EnvironmentVariableNotSetException, MaxRunCountReachedException) from src.logging.get_logger import get_logger +from src.manager.jskult_batch_run_manager import JskultBatchRunManager +from src.manager.jskult_batch_status_manager import JskultBatchStatusManager +from src.manager.jskult_hdke_tbl_manager import JskultHdkeTblManager from src.system_var import constants - - - - - logger = get_logger('生物由来卸販売ロット分解') + class TrnResultDataBioLot(JskultBatchEntrypoint): def __init__(self): super().__init__() @@ -36,7 +33,6 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): """生物由来卸販売ロット分解""" logger.info('生物由来卸販売ロット分解処理開始') - jskult_hdke_tbl_manager = JskultHdkeTblManager() jskult_batch_run_manager = JskultBatchRunManager( self.environment.BATCH_MANAGE_DYNAMODB_TABLE_NAME, @@ -77,12 +73,14 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): ) try: - jskult_batch_status_manager.set_process_status(constants.BATCH_ACTF_BATCH_START) + jskult_batch_status_manager.set_process_status( + constants.BATCH_ACTF_BATCH_START) try: if not jskult_batch_status_manager.can_run_post_process(): # 後続処理の起動条件を満たしていない場合 # 処理ステータスを「処理待」に設定 - jskult_batch_status_manager.set_process_status(constants.PROCESS_STATUS_WAITING) + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_WAITING) # バッチ実行管理テーブルに「retry」で登録 jskult_batch_run_manager.batch_retry() @@ -91,7 +89,8 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): except MaxRunCountReachedException: logger.info('最大起動回数に到達したため、生物由来卸販売ロット分解処理を実行します。') - jskult_batch_status_manager.set_process_status(constants.PROCESS_STATUS_DOING) + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_DOING) db = Database.get_instance() try: db.connect() @@ -105,15 +104,17 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): # 製造ロット管理番号マスタから有効期限を生物由来ロット分解データにセットする self._set_expr_dt_from_lot_num_mst(db) # 施設情報を生物由来ロット分解データにセットする - self._set_inst_info_from_com_inst_or_com_pharm_or_mst_inst_merck(db) + self._set_inst_info_from_com_inst_or_com_pharm_or_mst_inst_merck( + db) db.commit() logger.info('生物由来卸販売ロット分解処理終了') # 処理が全て正常終了した際に、バッチ実行管理テーブルに「success」で登録 logger.info("生物由来卸販売ロット分解処理を正常終了します。") jskult_batch_run_manager.batch_success() - jskult_batch_status_manager.set_process_status(constants.PROCESS_STATUS_DONE) + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_DONE) return - + except Exception as e: db.rollback() raise BatchOperationException(e) @@ -123,8 +124,8 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): # 何らかのエラーが発生した際に、バッチ実行管理テーブルに「failed」で登録 logger.exception(f'予期せぬエラーが発生したため、生物由来卸販売ロット分解処理を終了します。{e}') jskult_batch_run_manager.batch_failed() - jskult_batch_status_manager.set_process_status(constants.PROCESS_STATUS_ERROR) - + jskult_batch_status_manager.set_process_status( + constants.PROCESS_STATUS_ERROR) def _delete_not_confirm_data_in_trn_result_data_bio_lot(self, db: Database): logger.info('生物由来ロット分解データの未確定データ削除開始') @@ -136,13 +137,12 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): AND bio.seq_no = lot.seq_no AND IFNULL(bio.upd_date, bio.ins_date) >= src07.get_syor_date() """ - res = db.execute(sql) + db.execute(sql) except Exception as e: logger.info('生物由来ロット分解データの未確定データ削除に失敗') raise e logger.info('生物由来ロット分解データの未確定データ削除に成功') - def _insert_trn_result_data_bio_lot(self, db: Database): logger.info('生物由来ロット分解データの作成開始') try: @@ -222,7 +222,6 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): raise e logger.info('生物由来ロット分解データの作成に成功') - def _delete_empty_lot_record(self, db: Database): logger.info('生物由来ロット分解データのロット番号が空のレコードを削除開始') try: @@ -232,13 +231,12 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): -- 空白15桁のデータはロット情報が空とみなして削除する lot.cnvs_lot_no = REPEAT(' ', 15) OR lot.cnvs_lot_no IS NULL """ - res = db.execute(sql) + db.execute(sql) except Exception as e: logger.info('生物由来ロット分解データのロット番号が空のレコードを削除に失敗') raise e logger.info('生物由来ロット分解データのロット番号が空のレコードを削除に成功') - def _set_inst_info_from_com_inst_or_com_pharm_or_mst_inst_merck(self, db: Database): logger.info('COM_施設 or COM_薬局 or メルク独自施設マスタから施設情報を生物由来ロット分解データにセット開始') try: @@ -273,13 +271,13 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): END ) """ - res = db.execute(sql) + db.execute(sql) except Exception as e: - logger.info('COM_施設 or COM_薬局 or メルク独自施設マスタから施設情報を生物由来ロット分解データにセット失敗') + logger.info( + 'COM_施設 or COM_薬局 or メルク独自施設マスタから施設情報を生物由来ロット分解データにセット失敗') raise e logger.info('COM_施設 or COM_薬局 or メルク独自施設マスタから施設情報を生物由来ロット分解データにセット成功') - def _set_ck_last_dt_txt_from_customer_lotno_all(self, db: Database): # ロットマスタから有効期限をセット logger.info('ロットマスタから有効期限をセット開始') @@ -293,7 +291,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): SET bio.ck_last_dt_txt = cla.ck_last_dt_txt """ - res = db.execute(sql) + db.execute(sql) except Exception as e: logger.info('ロットマスタから有効期限をセット失敗') raise e From af6d995e6d6a6d1045c8ff941e53fae7ed48226b Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Tue, 3 Jun 2025 18:38:48 +0900 Subject: [PATCH 2/8] =?UTF-8?q?refactor:=20=E3=83=AA=E3=83=86=E3=83=A9?= =?UTF-8?q?=E3=83=AB=E3=82=92=E5=AE=9A=E6=95=B0=E5=8C=96=E3=80=82=E7=92=B0?= =?UTF-8?q?=E5=A2=83=E5=A4=89=E6=95=B0=E3=83=95=E3=82=A1=E3=82=A4=E3=83=AB?= =?UTF-8?q?=E3=81=AB=E3=83=95=E3=82=A9=E3=83=BC=E3=83=9E=E3=83=83=E3=83=88?= =?UTF-8?q?=E9=81=A9=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../trn_result_data_bio_lot_environment.py | 13 ++++++++----- .../src/batch/trn_result_data_bio_lot.py | 3 +-- 2 files changed, 9 insertions(+), 7 deletions(-) diff --git a/ecs/jskult-batch/src/batch/environment/trn_result_data_bio_lot_environment.py b/ecs/jskult-batch/src/batch/environment/trn_result_data_bio_lot_environment.py index ff0ca12e..4d0bbec1 100644 --- a/ecs/jskult-batch/src/batch/environment/trn_result_data_bio_lot_environment.py +++ b/ecs/jskult-batch/src/batch/environment/trn_result_data_bio_lot_environment.py @@ -23,13 +23,16 @@ class TrnResultDataBioLotEnvironment(JskultBatchEnvironment): Raises: EnvironmentVariableNotSetException: 環境変数の設定ミス """ - super()._assert_variable_not_empty(self.JSKULT_BACKUP_BUCKET, 'JSKULT_BACKUP_BUCKET') - super()._assert_variable_not_empty(self.BATCH_MANAGE_DYNAMODB_TABLE_NAME, 'BATCH_MANAGE_DYNAMODB_TABLE_NAME') + super()._assert_variable_not_empty( + self.JSKULT_BACKUP_BUCKET, 'JSKULT_BACKUP_BUCKET') + super()._assert_variable_not_empty( + self.BATCH_MANAGE_DYNAMODB_TABLE_NAME, 'BATCH_MANAGE_DYNAMODB_TABLE_NAME') super()._assert_variable_not_empty(self.BATCH_EXECUTION_ID, 'BATCH_EXECUTION_ID') super()._assert_variable_is_int(self.MAX_RUN_COUNT, 'MAX_RUN_COUNT') # MAX_RUN_COUNTは数値として扱うため、検査後に変換 self.MAX_RUN_COUNT = int(self.MAX_RUN_COUNT) super()._assert_variable_not_empty(self.PROCESS_NAME, 'PROCESS_NAME') - super()._assert_variable_not_empty(self.TRANSFER_RESULT_FOLDER, 'TRANSFER_RESULT_FOLDER') - super()._assert_variable_not_empty(self.TRANSFER_RESULT_FILE_NAME, 'TRANSFER_RESULT_FILE_NAME') - + super()._assert_variable_not_empty( + self.TRANSFER_RESULT_FOLDER, 'TRANSFER_RESULT_FOLDER') + super()._assert_variable_not_empty( + self.TRANSFER_RESULT_FILE_NAME, 'TRANSFER_RESULT_FILE_NAME') diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 24a0941f..13c1b43e 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -66,8 +66,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): jskult_batch_status_manager = JskultBatchStatusManager( self.environment.PROCESS_NAME, - # TODO チケットNEWDWH2021-1847の実装で作成した定数に置き換え - 'post_process', + constants.PROCESS_TYPE_POST_PROCESS, self.environment.MAX_RUN_COUNT, receive_file_count ) From b7c3b8ca1164fe1944830d9b84b25f43c52812e7 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Wed, 4 Jun 2025 10:08:44 +0900 Subject: [PATCH 3/8] =?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/trn_result_data_bio_lot.py | 34 +++++++++---------- 1 file changed, 17 insertions(+), 17 deletions(-) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 13c1b43e..9501c283 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -14,7 +14,7 @@ from src.manager.jskult_batch_status_manager import JskultBatchStatusManager from src.manager.jskult_hdke_tbl_manager import JskultHdkeTblManager from src.system_var import constants -logger = get_logger('生物由来卸販売ロット分解') +logger = get_logger('生物由来ロット分解') class TrnResultDataBioLot(JskultBatchEntrypoint): @@ -30,8 +30,8 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): return def execute(self): - """生物由来卸販売ロット分解""" - logger.info('生物由来卸販売ロット分解処理開始') + """生物由来ロット分解""" + logger.info('生物由来ロット分解処理開始') jskult_hdke_tbl_manager = JskultHdkeTblManager() jskult_batch_run_manager = JskultBatchRunManager( @@ -39,7 +39,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): self.environment.BATCH_EXECUTION_ID) if not jskult_hdke_tbl_manager.can_run_process(): logger.error( - '日次バッチ処理中またはdump取得が正常終了していないため、生物由来卸販売ロット分解処理を終了します。') + '日次バッチ処理中またはdump取得が正常終了していないため、生物由来ロット分解処理を終了します。') # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() return @@ -86,7 +86,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): return except MaxRunCountReachedException: - logger.info('最大起動回数に到達したため、生物由来卸販売ロット分解処理を実行します。') + logger.info('最大起動回数に到達したため、生物由来ロット分解処理を実行します。') jskult_batch_status_manager.set_process_status( constants.PROCESS_STATUS_DOING) @@ -101,14 +101,14 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): # 生物由来ロット分解データの不要レコードを削除する self._delete_empty_lot_record(db) # 製造ロット管理番号マスタから有効期限を生物由来ロット分解データにセットする - self._set_expr_dt_from_lot_num_mst(db) + self._set_expr_dt_from_customer_lotno_all(db) # 施設情報を生物由来ロット分解データにセットする self._set_inst_info_from_com_inst_or_com_pharm_or_mst_inst_merck( db) db.commit() - logger.info('生物由来卸販売ロット分解処理終了') + logger.info('生物由来ロット分解処理終了') # 処理が全て正常終了した際に、バッチ実行管理テーブルに「success」で登録 - logger.info("生物由来卸販売ロット分解処理を正常終了します。") + logger.info("生物由来ロット分解処理を正常終了します。") jskult_batch_run_manager.batch_success() jskult_batch_status_manager.set_process_status( constants.PROCESS_STATUS_DONE) @@ -121,7 +121,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): db.disconnect() except Exception as e: # 何らかのエラーが発生した際に、バッチ実行管理テーブルに「failed」で登録 - logger.exception(f'予期せぬエラーが発生したため、生物由来卸販売ロット分解処理を終了します。{e}') + logger.exception(f'予期せぬエラーが発生したため、生物由来ロット分解処理を終了します。{e}') jskult_batch_run_manager.batch_failed() jskult_batch_status_manager.set_process_status( constants.PROCESS_STATUS_ERROR) @@ -186,8 +186,8 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): bio.cnvs_inst_cd AS cnvs_inst_cd, bio.cls_inst_nm AS cls_inst_nm, -- COM_施設 or COM_薬局 or メルク独自施設マスタから後ほどセット - NULL AS inst_addr, - NULL AS inst_tel, + NULL AS address, + NULL AS tel_num, bio.result_cd AS result_cd, bio.src_cd AS src_cd, -- 判定結果CDより値を設定する @@ -206,7 +206,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): WHEN 'S' THEN 'SCSK-VAN' END AS if_kind, -- 製品コード、ロット番号でロットマスタより後ほどセット - NULL AS ck_last_dt_txt + NULL AS expr_dt FROM src07.trn_result_data_bio bio -- 生物由来変換マスタ @@ -254,7 +254,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): AND DATE_FORMAT(bio.cnvs_sales_dt, '%Y%m') BETWEEN mim.eff_start_ym AND mim.eff_end_ym -- 施設住所 - SET bio.inst_addr = ( + SET bio.address = ( CASE LEFT(bio.cnvs_inst_cd, 2) WHEN '00' THEN ci.inst_addr WHEN '03' THEN cp.inst_addr @@ -262,10 +262,10 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): END ), -- 施設電話番号 - bio.inst_tel = ( + bio.tel_num = ( CASE LEFT(bio.cnvs_inst_cd, 2) WHEN '00' THEN ci.inst_phone_number - WHEN '03' THEN cm.inst_phone_number + WHEN '03' THEN cp.inst_phone_number ELSE mim.tel_no END ) @@ -277,7 +277,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): raise e logger.info('COM_施設 or COM_薬局 or メルク独自施設マスタから施設情報を生物由来ロット分解データにセット成功') - def _set_ck_last_dt_txt_from_customer_lotno_all(self, db: Database): + def _set_expr_dt_from_customer_lotno_all(self, db: Database): # ロットマスタから有効期限をセット logger.info('ロットマスタから有効期限をセット開始') try: @@ -288,7 +288,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): ON bio.cnvs_prod_cd = cla.material_cd AND bio.cnvs_lot_no = cla.lot_no_txt SET - bio.ck_last_dt_txt = cla.ck_last_dt_txt + bio.expr_dt = cla.ck_last_dt_txt """ db.execute(sql) except Exception as e: From 629482507a185369b0233ee4240ec21513806003 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Wed, 4 Jun 2025 13:44:18 +0900 Subject: [PATCH 4/8] =?UTF-8?q?fix:=20=E5=88=A4=E5=AE=9A=E3=81=99=E3=82=8B?= =?UTF-8?q?=E3=82=AB=E3=83=A9=E3=83=A0=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 9501c283..8e99cb31 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -199,7 +199,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): WHEN 'Z' THEN 'エラー（想定外）' END AS data_kbn, -- SRC_種類より値を設定する - CASE bio.result_cd + CASE bio.src_cd WHEN '1' THEN 'VAN' WHEN '2' THEN '手入力' WHEN '3' THEN 'VAN-Web' From 2f4e2125ef24cac9b204a91f2dbf8283579fe2d1 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Wed, 4 Jun 2025 13:48:21 +0900 Subject: [PATCH 5/8] =?UTF-8?q?fix:=20=E8=BB=A2=E9=80=81=E3=83=87=E3=83=BC?= =?UTF-8?q?=E3=82=BF=E4=B8=80=E8=A6=A7=E5=8F=96=E5=BE=97=E3=81=AB=E5=A4=B1?= =?UTF-8?q?=E6=95=97=E3=81=97=E3=81=9F=E5=A0=B4=E5=90=88return=E3=81=99?= =?UTF-8?q?=E3=82=8B=E3=82=88=E3=81=86=E3=81=AB=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 8e99cb31..b4cdc688 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -57,6 +57,8 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): # バッチ実行管理テーブルをfailedで登録 jskult_batch_run_manager.batch_failed() + return + with open(transfer_list_file_path) as f: transfer_list = json.load(f) From dc18487b17da299f27bf53afd0695d72b2ed95b9 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Thu, 5 Jun 2025 10:06:16 +0900 Subject: [PATCH 6/8] =?UTF-8?q?feat:=20SQL=E3=81=AE=E5=AE=9F=E8=A1=8C?= =?UTF-8?q?=E9=A0=86=E5=BA=8F=E3=82=92=E8=A8=AD=E8=A8=88=E6=9B=B8=E9=80=9A?= =?UTF-8?q?=E3=82=8A=E3=81=AB=E5=A4=89=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index b4cdc688..ba08ea30 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -102,11 +102,11 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): self._insert_trn_result_data_bio_lot(db) # 生物由来ロット分解データの不要レコードを削除する self._delete_empty_lot_record(db) - # 製造ロット管理番号マスタから有効期限を生物由来ロット分解データにセットする - self._set_expr_dt_from_customer_lotno_all(db) # 施設情報を生物由来ロット分解データにセットする self._set_inst_info_from_com_inst_or_com_pharm_or_mst_inst_merck( db) + # 製造ロット管理番号マスタから有効期限を生物由来ロット分解データにセットする + self._set_expr_dt_from_customer_lotno_all(db) db.commit() logger.info('生物由来ロット分解処理終了') # 処理が全て正常終了した際に、バッチ実行管理テーブルに「success」で登録 From 5581fb91417a9048b59e11517f2acd989de18a80 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Thu, 5 Jun 2025 13:42:27 +0900 Subject: [PATCH 7/8] =?UTF-8?q?feat:=20SQL=E3=81=AB=E3=82=B3=E3=83=A1?= =?UTF-8?q?=E3=83=B3=E3=83=88=E8=BF=BD=E5=8A=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index ba08ea30..652d82f1 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -158,7 +158,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): bio.edit_whlslr_org_cd AS edit_whlslr_org_cd, bio.orig_univ_product_cd AS orig_univ_product_cd, bio.edit_deal_div_cd AS edit_deal_div_cd, - bio.cnvs_sales_dt AS cnvs_sales_dt, + bio.cnvs_sales_dt AS cnvs_sales_dt, -- datetime → date bio.orig_slip_no AS orig_slip_no, bio.orig_prod_nm AS orig_prod_nm, bio.edit_endusr_cd AS edit_endusr_cd, @@ -170,7 +170,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): WHEN 2 THEN bio.cnvs_lot_no_2 WHEN 3 THEN bio.cnvs_lot_no_3 END AS cnvs_lot_no, - bio.load_dt AS load_dt, + bio.load_dt AS load_dt, -- datetime → date bio.cnvs_deal_div_cd AS cnvs_deal_div_cd, bio.cls_deal_div_nm AS cls_deal_div_nm, bio.cnvs_depo_cd AS cnvs_depo_cd, @@ -290,7 +290,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): ON bio.cnvs_prod_cd = cla.material_cd AND bio.cnvs_lot_no = cla.lot_no_txt SET - bio.expr_dt = cla.ck_last_dt_txt + bio.expr_dt = STR_TO_DATE(cla.ck_last_dt_txt, '%Y%m%d') """ db.execute(sql) except Exception as e: From 8ae3b91d5c0eef9d62acd44b5f5300d5fe547c36 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Thu, 5 Jun 2025 15:48:42 +0900 Subject: [PATCH 8/8] =?UTF-8?q?fix:=20=E8=B5=B7=E5=8B=95=E6=9D=A1=E4=BB=B6?= =?UTF-8?q?=E3=82=92=E6=BA=80=E3=81=9F=E3=81=97=E3=81=A6=E3=81=84=E3=81=AA?= =?UTF-8?q?=E3=81=84=E5=A0=B4=E5=90=88=E3=81=AE=E3=83=AD=E3=82=B0=E5=87=BA?= =?UTF-8?q?=E5=8A=9B=E3=82=92=E8=BF=BD=E5=8A=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py | 1 + 1 file changed, 1 insertion(+) diff --git a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py index 652d82f1..b8c3329d 100644 --- a/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py +++ b/ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py @@ -85,6 +85,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint): # バッチ実行管理テーブルに「retry」で登録 jskult_batch_run_manager.batch_retry() + logger.info('起動条件を満たしていないため、生物由来ロット分解処理を終了します。') return except MaxRunCountReachedException: