指摘事項修正
This commit is contained in:
野間
parent
8db0509eb7
commit
afd5db75e5
@ -1,4 +1,4 @@
|
||||
"""アルトマークデータ処理"""
|
||||
"""output_vjsk_inst_pharm_data"""
|
||||
|
||||
from src.aws.s3 import VjskBucket
|
||||
from src.batch.common.batch_context import BatchContext
|
||||
@ -9,7 +9,7 @@ import tempfile
|
||||
import os.path as path
|
||||
import csv
|
||||
|
||||
logger = get_logger('V実用消化施設データ作成処理')
|
||||
logger = get_logger('V実消化用施設データ作成処理')
|
||||
|
||||
sql_err_msg = "SQL実行エラーです。"
|
||||
|
||||
@ -17,15 +17,20 @@ sql_err_msg = "SQL実行エラーです。"
|
||||
def exec():
|
||||
vjsk_csv_file_name = 'ComInst.csv'
|
||||
|
||||
# バッチ共通設定を取得
|
||||
batch_context = BatchContext.get_instance()
|
||||
|
||||
if not batch_context.is_ultmarc_imported:
|
||||
logger.info('アルトマーク取込が行われていないため、V実消化用施設データ作成処理をスキップします。')
|
||||
return
|
||||
|
||||
db = Database.get_instance()
|
||||
try:
|
||||
logger.info('バッチ処理を開始しました。')
|
||||
logger.info('処理開始')
|
||||
|
||||
try:
|
||||
# DB接続
|
||||
db.connect()
|
||||
# ファイル単位でトランザクションを行う
|
||||
db.begin()
|
||||
except Exception as e:
|
||||
logger.info('DB接続エラーです。')
|
||||
raise e
|
||||
@ -42,7 +47,7 @@ def exec():
|
||||
# s3へデータ移動
|
||||
vjsk_bucket.upload_dat_file(vjsk_csv_file_name, csv_file_path)
|
||||
except Exception as e:
|
||||
logger.info('S3バケットDWHへCSVデータを作成できませんでした。')
|
||||
logger.info('S3バケットにCSVデータを作成できませんでした。')
|
||||
raise e
|
||||
|
||||
try:
|
||||
@ -54,13 +59,11 @@ def exec():
|
||||
raise e
|
||||
|
||||
csv_count = len(record_inst) + len(record_pharm)
|
||||
logger.info(f'CSV出力件数: {csv_count}。')
|
||||
logger.info('バッチ処理を正常に終了しました。')
|
||||
logger.info(f'CSV出力件数: {csv_count}')
|
||||
logger.info('正常終了')
|
||||
except Exception as e:
|
||||
raise e
|
||||
finally:
|
||||
# 終了時に必ずコミットする
|
||||
db.commit()
|
||||
db.disconnect()
|
||||
return
|
||||
|
||||
@ -155,14 +158,14 @@ def select_pharm_record(db):
|
||||
inst_name_kana,
|
||||
form_inst_name_kanji,
|
||||
inst_name_kanji,
|
||||
'',
|
||||
'',
|
||||
'' AS rltd_univ_prnt_cd,
|
||||
'' AS bed_num,
|
||||
close_flg,
|
||||
estab_sche_flg,
|
||||
close_start_ym,
|
||||
estab_sche_ym,
|
||||
'',
|
||||
'',
|
||||
'' AS ward_abolish_flg,
|
||||
'' AS inst_repre_cd,
|
||||
inst_repre_kana,
|
||||
inst_repre,
|
||||
phone_number_non_flg,
|
||||
@ -179,24 +182,24 @@ def select_pharm_record(db):
|
||||
addr_cnt,
|
||||
manage_cd,
|
||||
delete_sche_reason_cd,
|
||||
'',
|
||||
'' AS hp_assrt_cd,
|
||||
dup_opp_cd,
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'',
|
||||
'' AS insp_item_micrb,
|
||||
'' AS insp_item_serum,
|
||||
'' AS insp_item_blood,
|
||||
'' AS insp_item_patho,
|
||||
'' AS insp_item_paras,
|
||||
'' AS insp_item_biochem,
|
||||
'' AS insp_item_ri,
|
||||
'' AS re_exam_cd,
|
||||
'' AS prmit_bed_num_other,
|
||||
'' AS prmit_bed_num_mental,
|
||||
'' AS prmit_bed_num_tuber,
|
||||
'' AS prmit_bed_num_infection,
|
||||
'' AS prmit_bed_num_sum,
|
||||
'' AS prmit_bed_num_gen,
|
||||
'' AS prmit_bed_num_rcup,
|
||||
'' AS prmit_bed_maint_ymd,
|
||||
inst_pharm_div,
|
||||
abolish_ymd,
|
||||
delete_flg,
|
||||
@ -240,7 +243,7 @@ def make_csv_data(record_inst: list, record_pharm: list, vjsk_csv_file_name: str
|
||||
'FILLER_3', 'FILLER_4', 'FILLER_5', 'REGIST_DATE', 'CREATE_USER', 'UPDATE_DATE', 'UPDATE_USER', 'SYS_REGIST_DATE',
|
||||
'REGIST_PRGM_ID', 'SYS_UPDATE_DATE', 'UPDATE_PRGM_ID']
|
||||
|
||||
with open(csv_file_path, mode='w', encoding='cp932') as csv_file:
|
||||
with open(csv_file_path, mode='w', encoding='UTF-8') as csv_file:
|
||||
# ヘッダ行書き込み（くくり文字をつけない為にwriterowではなく、writeを使用しています）
|
||||
csv_file.write(f"{','.join(head_str)}\n")
|
||||
|
||||
@ -264,7 +267,7 @@ def make_csv_data(record_inst: list, record_pharm: list, vjsk_csv_file_name: str
|
||||
|
||||
except Exception as e:
|
||||
logger.info('ワークデータの作成に失敗しました。')
|
||||
logger.info('バッチ処理を異常終了しました。')
|
||||
logger.info('CSVデータの作成に失敗しました。')
|
||||
raise e
|
||||
|
||||
return csv_file_path
|
||||
@ -13,7 +13,7 @@ from src.batch.ultmarc import ultmarc_process
|
||||
from src.error.exceptions import BatchOperationException
|
||||
from src.logging.get_logger import get_logger
|
||||
from src.system_var import constants
|
||||
from src.batch.ultmarc import vjsk_process
|
||||
from src.batch.ultmarc import output_vjsk_inst_pharm_data
|
||||
|
||||
logger = get_logger('日次処理コントロール')
|
||||
|
||||
@ -76,11 +76,8 @@ def exec():
|
||||
logger.debug(f'{"アルトマーク取込が行われました。" if batch_context.is_ultmarc_imported else "アルトマーク取込が行われませんでした。"}')
|
||||
|
||||
try:
|
||||
if not batch_context.is_ultmarc_imported:
|
||||
logger.info('アルトマーク取込が行われていないため、V実消化用施設データ作成処理をスキップします。')
|
||||
return
|
||||
logger.info('V実消化用施設データ作成処理：起動')
|
||||
vjsk_process.exec()
|
||||
output_vjsk_inst_pharm_data.exec()
|
||||
logger.info('V実消化用施設データ作成処理：終了')
|
||||
except BatchOperationException as e:
|
||||
logger.exception(f'V実消化用施設データ作成処理エラー（異常終了）{e}')
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user