diff --git a/ecs/jskult-batch-daily/.vscode/recommended_settings.json b/ecs/jskult-batch-daily/.vscode/recommended_settings.json index 4e6690ce..fd8ebd3c 100644 --- a/ecs/jskult-batch-daily/.vscode/recommended_settings.json +++ b/ecs/jskult-batch-daily/.vscode/recommended_settings.json @@ -16,11 +16,11 @@ "python.formatting.provider": "autopep8", "python.formatting.autopep8Path": "autopep8", "python.formatting.autopep8Args": [ - "--max-line-length", "150", + "--max-line-length", "200", "--ignore=F541" ], "flake8.args": [ - "--max-line-length", "150", + "--max-line-length", "200", "--ignore=F541" ], "python.testing.pytestArgs": [ diff --git a/ecs/jskult-batch-daily/src/batch/ultmarc/dat_insert.py b/ecs/jskult-batch-daily/src/batch/ultmarc/ultmarc_process.py similarity index 99% rename from ecs/jskult-batch-daily/src/batch/ultmarc/dat_insert.py rename to ecs/jskult-batch-daily/src/batch/ultmarc/ultmarc_process.py index 44e53cbc..569b6a09 100644 --- a/ecs/jskult-batch-daily/src/batch/ultmarc/dat_insert.py +++ b/ecs/jskult-batch-daily/src/batch/ultmarc/ultmarc_process.py @@ -14,7 +14,7 @@ logger = get_logger('アルトマークデータ保管') ultmarc_bucket = UltmarcBucket() -def dat_insert_control(): +def batch_process(): try: logger.info('datInsert START') # DBセットアップ diff --git a/ecs/jskult-batch-daily/src/jobctrl_daily.py b/ecs/jskult-batch-daily/src/jobctrl_daily.py index cf374ef5..6ac64fdf 100644 --- a/ecs/jskult-batch-daily/src/jobctrl_daily.py +++ b/ecs/jskult-batch-daily/src/jobctrl_daily.py @@ -1,7 +1,7 @@ from src.batch import jissekiaraigae from src.batch.batch_functions import get_syor_date_as_date_format from src.batch.common.batch_config import BatchConfig -from src.batch.ultmarc.dat_insert import dat_insert_control +from src.batch.ultmarc import ultmarc_process from src.error.exceptions import BatchOperationException from src.logging.get_logger import get_logger @@ -10,6 +10,7 @@ logger = get_logger('日次処理コントロール') # ここを処理IDとか # バッチ共通設定を取得 batch_config = BatchConfig.get_instance() + def batch_process(): try: logger.info('日次ジョブ:開始') @@ -21,17 +22,15 @@ def batch_process(): try: logger.info('処理日取得') syor_date = get_syor_date_as_date_format() - except BatchOperationException as e: + except BatchOperationException as e: logger.error(f'処理日取得エラー(異常終了){e}') logger.info(f'処理日={syor_date}') # バッチ共通設定に処理日を追加 batch_config.syor_date = syor_date - # TODO: 本来のアルトマーク取り込み実施場所に移動させること - dat_insert_control() # 休日判定ファイルを読み込み logger.info('休日判定処理') if True: # 休日判定 - logger.info('非営業日かつ月、火、水以外です。') # 分岐 + logger.info('非営業日かつ月、火、水以外です。') # 分岐 try: # 処理中フラグ判定。ここでdumpのフラグも見る logger.info('処理フラグ更新中') @@ -41,7 +40,7 @@ def batch_process(): logger.info('日次ジョブ:終了(正常終了)') try: logger.info('日次ジョブ処理中判定') - if True: # 処理中判定 + if True: # 処理中判定 logger.error('処理フラグ処理中(異常終了)') logger.info('処理中フラグの更新:起動') logger.info('処理中フラグの更新:終了') @@ -63,21 +62,22 @@ def batch_process(): 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にアップロード + 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: # アルトマークなければ + if True: # アルトマークなければ logger.info('日次処理(アルトマーク)実行対象日でない為未実行') try: logger.info('アルトマーク取込:起動') + ultmarc_process.batch_process() logger.info('アルトマーク取込:終了') except BatchOperationException as e: logger.error(f'アルトマーク取込処理エラー(異常終了){e}') - if True: # 休日判定 + if True: # 休日判定 try: logger.info('メルク施設マスタ作成') logger.info('メルク施設マスタ作成終了') @@ -92,7 +92,7 @@ def batch_process(): logger.info('V実消化連携データ存在確認') if True: logger.error('V実消化連携データ存在確認(異常終了)') - + logger.info('日次処理(V実消化)') try: logger.info('V実消化取込:起動') @@ -120,7 +120,7 @@ def batch_process(): logger.exception(f'処理中フラグ更新エラー(異常終了){e}') logger.info('ワークディレクトリクリーニング') logger.info('日次ジョブ:終了(正常終了)') - + return 0 except Exception as e: raise e