Revert "先進医療機器 追加"
This reverts commit 5deec338edfbefa359bf1c04b9dc4b74e5c2481c.
This commit is contained in:
parent
f615f9b6d3
commit
5f7cdc9af6
@ -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
|
||||
Loading…
x
Reference in New Issue
Block a user