先進医療機器　追加

2023-04-20 14:28:56 +09:00 · 2023-04-20 14:28:56 +09:00 · 5047c9c02a
commit 5047c9c02a
parent b0fbacc2eb
1 changed files with 93 additions and 0 deletions
--- 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
@ -0,0 +1,93 @@
+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