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

BIOの2本追加

Browse Source
This commit is contained in:
x.azuma.m@nds-tyo.co.jp 2023-05-09 19:06:19 +09:00
parent 62ec4ddebb
commit f299cb9379
2 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ecs/jskult-batch-daily/src/batch/vjsk/vjsk_importer.py
View File

@ -92,6 +92,14 @@ def _check_received_files():
if not _check_if_file_exists(received_s3_files, vjsk_mapper.CONDKEY_MDB_CONV_MST):
raise BatchOperationException(f'MDBコード変換マスタファイルがありません ファイル一覧:{received_s3_files}')
# ファイル存在確認 生物由来データ
if not _check_if_file_exists(received_s3_files, vjsk_mapper.CONDKEY_BIO_SLIP_DATA):
raise BatchOperationException(f'生物由来データファイルがありません ファイル一覧:{received_s3_files}')
# ファイル存在確認 製造ロット番号マスタ
if not _check_if_file_exists(received_s3_files, vjsk_mapper.CONDKEY_LOT_NUM_MST):
raise BatchOperationException(f'製造ロット番号マスタファイルがありません ファイル一覧:{received_s3_files}')
logger.debug('_check_received_files end')
return True
@ -158,6 +166,12 @@ def _import_file_to_db():
# DB登録 MDBコード変換マスタ
JjskDataLoadManager.Load(target_dict[vjsk_mapper.CONDKEY_MDB_CONV_MST])
# DB登録 生物由来データ
JjskDataLoadManager.Load(target_dict[vjsk_mapper.CONDKEY_BIO_SLIP_DATA])
# DB登録 製造ロット番号マスタ
JjskDataLoadManager.Load(target_dict[vjsk_mapper.CONDKEY_LOT_NUM_MST])
logger.debug('_import_file_to_db end')

6
ecs/jskult-batch-daily/src/batch/vjsk/vjsk_recv_file_mapper.py
View File

@ -16,7 +16,7 @@ class VjskRecvFileMapper:
CONDKEY_MDB_CONV_MST = "MDB_CONV_MST" # MDBコード変換表
CONDKEY_STOCK_SLIP_DATA = "STOCK_SLIP_DATA" # 卸在庫データ
CONDKEY_BIO_SLIP_DATA = "BIO_SLIP_DATA" # 生物由来データ
CONDKEY_LOT_NUM_MS = "LOT_NUM_MS" # ロットマスタデータ
CONDKEY_LOT_NUM_MST = "LOT_NUM_MST" # ロットマスタデータ
_KEY_FILE_PREFIX = "file_prefix"
_KEY_FILE_SUFFIX = "file_suffix"
@ -1412,8 +1412,8 @@ class VjskRecvFileMapper:
},
# ロットマスタデータ
CONDKEY_LOT_NUM_MS: {
_KEY_FILE_PREFIX: "lot_num_ms_",
CONDKEY_LOT_NUM_MST: {
_KEY_FILE_PREFIX: "lot_num_mst_",
_KEY_FILE_SUFFIX: ".tsv",
_KEY_ORG_TABLE: "org05.lot_num_mst",
_KEY_SRC_TABLE: "src05.lot_num_mst",