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

fix: 転送処理の起動条件を修正

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2025-05-16 12:39:14 +09:00
parent f099abbd54
commit 2e7c5d7c3f
3 changed files with 17 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
ecs/jskult-transfer-receive-file/src/main.py
View File

@ -18,18 +18,25 @@ def exec():
# 転送データリストを初期化する。 # 転送データリストを初期化する。
transfer_file_lists = {"transfer_list": []} transfer_file_lists = {"transfer_list": []}
hdke_tbl_manager = JskultHdkeTblManager()
# ② 日付テーブルのステータスを確認する # ② 日付テーブルのステータスを確認する
hdke_tbl_manager = JskultHdkeTblManager()
try: try:
if not hdke_tbl_manager.can_run_process(): # 日次バッチ処置中フラグ、dump処理状態区分、処理日を取得
logger.error('日次バッチ処理中またはdump取得が正常終了していないため、データ転送処理を終了します。') batch_processing_flag, dump_status_kbn, syor_date = hdke_tbl_manager.get_batch_statuses()
return constants.BATCH_EXIT_CODE_SUCCESS
# 処理日を取得
_, _, syor_date = hdke_tbl_manager.get_batch_statuses()
except BatchOperationException as e: except BatchOperationException as e:
logger.exception(f'日付テーブル取得（異常終了）{e}') logger.exception(f'日付テーブル取得（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS return constants.BATCH_EXIT_CODE_SUCCESS
# 日次バッチ処理中の場合、後続の処理は行わない
if batch_processing_flag == constants.BATCH_ACTF_BATCH_START:
logger.error('日次バッチ処理中のため、日次バッチ処理を終了します。')
return constants.BATCH_EXIT_CODE_SUCCESS
# dump取得が正常終了していない場合、後続の処理は行わない
if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE:
logger.error('dump取得が正常終了していないため、日次バッチ処理を終了します。')
return constants.BATCH_EXIT_CODE_SUCCESS
logger.info(f'処理日＝{syor_date}') logger.info(f'処理日＝{syor_date}')
logger.info('I-2 日次バッチ処理中フラグ更新') logger.info('I-2 日次バッチ処理中フラグ更新')
# バッチ処理中に更新 # バッチ処理中に更新

6
ecs/jskult-transfer-receive-file/src/manager/jskult_hdke_tbl_manager.py
View File

@ -52,7 +52,7 @@ class JskultHdkeTblManager:
sql = """\ sql = """\
UPDATE src07.hdke_tbl UPDATE src07.hdke_tbl
SET SET
bch_actf = :in_processing, bch_actf = :start,
updater = CURRENT_USER(), updater = CURRENT_USER(),
update_date = NOW() update_date = NOW()
""" """
@ -60,7 +60,7 @@ class JskultHdkeTblManager:
self._db.connect() self._db.connect()
self._db.to_jst() self._db.to_jst()
self._db.execute( self._db.execute(
sql, {'in_processing': constants.BATCH_ACTF_BATCH_IN_PROCESSING}) sql, {'start': constants.BATCH_ACTF_BATCH_START})
except DBException as e: except DBException as e:
raise BatchOperationException(e) raise BatchOperationException(e)
finally: finally:
@ -113,7 +113,7 @@ class JskultHdkeTblManager:
finally: finally:
self._db.disconnect() self._db.disconnect()
# 日次バッチ処理中の場合、後続の処理は行わない # 日次バッチ処理中の場合、後続の処理は行わない
if batch_processing_flag == constants.BATCH_ACTF_BATCH_IN_PROCESSING: if batch_processing_flag == constants.BATCH_ACTF_BATCH_START:
return False return False
# dump取得が正常終了していない場合、後続の処理は行わない # dump取得が正常終了していない場合、後続の処理は行わない
if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE: if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE:

2
ecs/jskult-transfer-receive-file/src/system_var/constants.py
View File

@ -4,7 +4,7 @@ BATCH_EXIT_CODE_SUCCESS = 0
# バッチ処理中フラグ：未処理 # バッチ処理中フラグ：未処理
BATCH_ACTF_BATCH_UNPROCESSED = '0' BATCH_ACTF_BATCH_UNPROCESSED = '0'
# バッチ処理中フラグ：処理中 # バッチ処理中フラグ：処理中
BATCH_ACTF_BATCH_IN_PROCESSING = '1' BATCH_ACTF_BATCH_START = '1'
# dump取得状態区分：未処理 # dump取得状態区分：未処理
DUMP_STATUS_KBN_UNPROCESSED = '0' DUMP_STATUS_KBN_UNPROCESSED = '0'
# dump取得状態区分：dump取得正常終了 # dump取得状態区分：dump取得正常終了