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

feat: アルトマーク取り込み処理の実行場所を正しい位置に変更

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-04-07 12:26:08 +09:00
parent b2e0582458
commit b1a8cf31cd
3 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ecs/jskult-batch-daily/.vscode/recommended_settings.json vendored
View File

@ -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": [

2
ecs/jskult-batch-daily/src/batch/ultmarc/dat_insert.py → ecs/jskult-batch-daily/src/batch/ultmarc/ultmarc_process.py
View File

@ -14,7 +14,7 @@ logger = get_logger('アルトマークデータ保管')
ultmarc_bucket = UltmarcBucket()
def dat_insert_control():
def batch_process():
try:
logger.info('datInsert START')
# DBセットアップ

22
ecs/jskult-batch-daily/src/jobctrl_daily.py
View File

@ -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