diff --git a/ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_forfront_med_equip_mapper.py b/ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_forfront_med_equip_mapper.py deleted file mode 100644 index 62496980..00000000 --- a/ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_forfront_med_equip_mapper.py +++ /dev/null @@ -1,93 +0,0 @@ -from src.batch.ultmarc.utmp_tables.table_mapper.ultmarc_table_mapper import \ - UltmarcTableMapper -from src.batch.ultmarc.utmp_tables.tables.com_forfront_med_equip import ComForfrontMedEquip - - -class ComForfrontMedEquipMapper(UltmarcTableMapper): - """レイアウト区分102: COM_薬局 登録処理 """ - - # レコード存在確認SQL - RECORD_EXISTS_QUERY = """\ - SELECT - COUNT(*) AS count_num - FROM - src05.com_forfront_med_equip - WHERE - forfront_med_equip_cd = :hi_medicmach_code - """ - # データ登録用SQL - INSERT_QUERY = """\ - INSERT INTO src05.com_forfront_med_equip - ( - forfront_med_equip_cd, - forfront_med_equip_name, - regist_ymd, - update_ymd, - delete_ymd, - sys_regist_date, - regist_prgm_id, - sys_update_date, - update_prgm_id - ) - VALUES ( - :hi_medicmach_code, - :hi_medicmach_name, - :execute_datetime, - :execute_datetime, - NULL, - :execute_datetime, - :program_name, - :execute_datetime, - :program_name - ) - """ - # 更新用SQL - UPDATE_QUERY = """\ - UPDATE src05.com_forfront_med_equip - SET - forfront_med_equip_name = :hi_medicmach_name, - sys_update_date = :execute_datetime, - update_prgm_id = :program_name - WHERE - forfront_med_equip_cd = :hi_medicmach_code - """ - - # 修正区分が「C(削除)」の場合の更新SQL - # 削除年月日 ← システム日付 - LOGICAL_DELETE_QUERY = """\ - UPDATE - src05.com_forfront_med_equip - SET - delete_ymd = :execute_date_str_ymd, - sys_update_date = :execute_date_str_ymd, - update_prgm_id = :program_name - WHERE - forfront_med_equip_cd = :hi_medicmach_code - """ - record: ComForfrontMedEquip - - def __init__(self, record: list[str], db) -> None: - super().__init__(record, db, ComPharm) - program_name = __name__.split('.')[-1] # 当モジュール名(現行から変わっている) - # モジュール名をクエリパラメータに設定 - self.query_parameter['program_name'] = program_name - # 読み込んだレコード値もクエリパラメータに追加 - self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()} - - def make_query(self): - # 修正区分がC(削除)の場合、論理削除 - if self.record.maint_flag == 'C': - self.queries.append(self.LOGICAL_DELETE_QUERY) - return - - # レコードの存在確認 - record_count = self.db.execute_select(self.RECORD_EXISTS_QUERY, self.query_parameter) - # 存在しない場合はInsert - if record_count[0]['count_num'] == 0: - self.queries.append(self.INSERT_QUERY) - return - - # 更新の場合 - if self.record.hi_medicmach_name != '': - self.queries.append(update_query) - return