From 4cd848afdec46a5a40c75eafad039e4b8d3ed1b1 Mon Sep 17 00:00:00 2001 From: "shimoda.m@nds-tyo.co.jp" Date: Fri, 7 Apr 2023 15:13:20 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20COM=5F=E9=AB=98=E5=BA=A6=E5=85=88?= =?UTF-8?q?=E9=80=B2=E5=8C=BB=E7=99=82=E3=81=AE=E3=83=86=E3=82=B9=E3=83=88?= =?UTF-8?q?=E3=82=B3=E3=83=BC=E3=83=89=E4=BD=9C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../table_mapper/test_com_hamtec_mapper.py | 305 ++++++++++++++++++ 1 file changed, 305 insertions(+) create mode 100644 ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/test_com_hamtec_mapper.py diff --git a/ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/test_com_hamtec_mapper.py b/ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/test_com_hamtec_mapper.py new file mode 100644 index 00000000..ac16b47c --- /dev/null +++ b/ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/test_com_hamtec_mapper.py @@ -0,0 +1,305 @@ +from datetime import datetime + +import pytest + +from src.batch.common.batch_config import BatchConfig +from src.batch.ultmarc.utmp_tables.table_mapper.concrete import \ + com_hamtec_mapper +from src.db.database import Database +from tests.testing_utility import (assert_table_results, + create_delete_sql_with_parameter, + create_insert_sql_with_parameter, + create_ultmarc_common_column_names, + create_ultmarc_common_column_values, + create_ultmarc_table_mapper_sut, + create_ultmarc_test_csv, get_module_name) + + +class TestComHamtecMapper: + """COM_高度先進医療""" + + db: Database + batch_config: BatchConfig + table_columns = ["hamtec_cd", "hamtec_div", "hamtec_name"] + create_ultmarc_common_column_names() + + @pytest.fixture(autouse=True, scope='function') + def pre_test(self, database: Database): + """テスト実行前後処理""" + self.batch_config = BatchConfig.get_instance() + # setup + self.db = database + self.db.connect() + self.db.begin() + + # testing + yield + + # teardown + self.db.rollback() + self.db.disconnect() + + def test_insert_record(self, expect_datetime: datetime, expect_date_str: str): + """ + Cases: + COM_高度先進医療テーブルにレコードを登録する + Arranges: + - CSVデータを用意する + - 追加対象となるレコードを削除する + Expects: + - 登録内容が期待値と一致すること + """ + + # Arrange + # 処理日設定 + self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d') + # テストデータ作成 + csv_floating_data_lst = [ + ['001', '2', '直流電流による骨電気治療法', 'A'], + ['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'A'], + ['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'A'], + ['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'A'], + ['005', '1', '造血器腫瘍のＤＮＡ診断', 'A'], + ['006', '1', '培養細胞による先天性代謝異常診断（胎児又は新生児に係るものに限る）', 'A'] + ] + test_data_list = [ + f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"' + for data in csv_floating_data_lst + ] + test_dat_file = create_ultmarc_test_csv(test_data_list) + # 一旦全データをDBから削除 + delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'}) + self.db.execute(delete_sql, delete_parameter) + + # sut(system under test)作成 + for i, line in enumerate(test_dat_file, start=1): + sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db) + assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目:マッパークラスが期通りか' + + # Act + sut.make_query() + sut.execute_queries() + + # Assert + # 期待値作成 + # 期待値となるモジュール名 + module_name = get_module_name(com_hamtec_mapper) + expect_data = csv_floating_data_lst[i - 1] + expect_row = [expect_data[0], expect_data[1], expect_data[2]] + create_ultmarc_common_column_values( + regist_ymd=expect_date_str, + sys_regist_date=expect_datetime, + regist_prgm_id=module_name, + sys_update_date=expect_datetime, + update_prgm_id=module_name + ) + expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}] + actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'") + + # 期待値検査 + assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date']) + + # 動的日付項目の個別確認 + for actual_row, expect_row in zip(actual_rows, expect_rows): + for actual_col_name, expect_col_name in zip(actual_row, expect_row): + if actual_col_name in ['sys_regist_date', 'sys_update_date']: + assert actual_row[actual_col_name] <= expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること' + + def test_update_record(self, expect_datetime: datetime, expect_date_str: str): + """ + Cases: + COM_高度先進医療テーブルのレコードを更新する + Arranges: + - CSVデータを用意する + - 追加対象となるレコードを登録する + Expects: + - 登録内容が期待値と一致すること + """ + + # Arrange + # 処理日設定 + self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d') + # テストデータ作成 + csv_floating_data_lst = [ + ['001', '', '', 'A'], + ['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'B'], + ['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'B'], + ['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'B'], + ['005', '', '造血器腫瘍のＤＮＡ診断', 'B'], + ['006', '1', '', 'B'] + ] + test_data_list = [ + f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"' + for data in csv_floating_data_lst + ] + test_dat_file = create_ultmarc_test_csv(test_data_list) + + # 一旦全データをDBから削除 + delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'}) + self.db.execute(delete_sql, delete_parameter) + + db_floating_data_list = [ + ['001', '2', '直流電流による骨電気治療法'], + ['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）'], + ['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療'], + ['004', '1', '顔面骨、頭蓋骨の観血的移動術'], + ['005', '1', '造血器腫瘍のＤＮＡ診断'], + ['006', '1', '培養細胞による先天性代謝異常診断（胎児又は新生児に係るものに限る）'] + ] + # モジュール名 + module_name = get_module_name(com_hamtec_mapper) + # テスト対象のデータをDBに登録 + for row in db_floating_data_list: + code, div, name = row + # DBに登録するテストデータ + test_sql_data = [code, div, name] + create_ultmarc_common_column_values( + regist_ymd=expect_date_str, + sys_regist_date=expect_datetime, + regist_prgm_id=module_name, + sys_update_date=expect_datetime, + update_prgm_id=module_name + ) + insert_sql, insert_parameter = create_insert_sql_with_parameter( + 'src05.com_hamtec', + self.table_columns, + test_sql_data + ) + self.db.execute(insert_sql, insert_parameter) + + # sut(system under test)作成 + for i, line in enumerate(test_dat_file, start=1): + sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db) + assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目: マッパークラスが期待通りか' + + # Act + sut.make_query() + sut.execute_queries() + + # Assert + # 期待値作成 + + expect_data = csv_floating_data_lst[i - 1] + hamtec_div = expect_data[1] if expect_data[3] == 'B' else db_floating_data_list[i - 1][1] + hamtec_name = expect_data[2] if expect_data[3] == 'B' else db_floating_data_list[i - 1][2] + expect_row = [expect_data[0], hamtec_div, hamtec_name] + create_ultmarc_common_column_values( + regist_ymd=expect_date_str, + update_ymd=expect_date_str if expect_data[3] == 'B' else None, # レコードがあり、項目が設定されている場合、更新日が登録される + sys_regist_date=expect_datetime, + regist_prgm_id=module_name, + sys_update_date=datetime.now() if expect_data[3] == 'B' else expect_datetime, # レコードがあり、項目が設定されている場合、更新日が登録される + update_prgm_id=module_name + ) + expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}] + actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'") + + # 期待値検査 + assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date']) + # 動的日付項目の個別確認 + for actual_row, expect_row in zip(actual_rows, expect_rows): + for actual_col_name, expect_col_name in zip(actual_row, expect_row): + if actual_col_name == 'sys_regist_date': + assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること' + if actual_col_name == 'sys_update_date': + # 更新されている場合 + if expect_data[3] == 'B': + assert actual_row[actual_col_name] < expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること' + else: + assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること' + + def test_logical_delete_record_one(self, expect_datetime: datetime, expect_date_str: str): + """ + Cases: + COM_高度先進医療テーブルのレコードを論理削除する + Arranges: + - CSVデータを用意する + - 追加対象となるレコードを登録する + Expects: + - 登録内容が期待値と一致すること + """ + + # Arrange + # 処理日設定 + self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d') + # テストデータ作成 + # 3カラム目、論理削除されるかどうか + csv_floating_data_lst = [ + ['001', '', '', 'A'], + ['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'B'], + ['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'B'], + ['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'C'], + ['005', '', '造血器腫瘍のＤＮＡ診断', 'B'], + ['006', '1', '', 'B'] + ] + test_data_list = [ + f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"' + for data in csv_floating_data_lst + ] + test_dat_file = create_ultmarc_test_csv(test_data_list) + # 一旦全データをDBから削除 + delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'}) + self.db.execute(delete_sql, delete_parameter) + + # テスト対象のデータをDBに登録 + db_floating_data_list = [ + ['001', '', ''], + ['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）'], + ['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療'], + ['004', '1', '顔面骨、頭蓋骨の観血的移動術'], + ['005', '', '造血器腫瘍のＤＮＡ診断'], + ['006', '1', ''] + ] + # モジュール名 + module_name = get_module_name(com_hamtec_mapper) + for row in db_floating_data_list: + code, div, name = row + # DBに登録するテストデータ + test_sql_data = [code, div, name] + create_ultmarc_common_column_values( + regist_ymd=expect_date_str, + sys_regist_date=expect_datetime, + regist_prgm_id=module_name, + sys_update_date=expect_datetime, + update_prgm_id=module_name + ) + insert_sql, insert_parameter = create_insert_sql_with_parameter( + 'src05.com_hamtec', + self.table_columns, + test_sql_data + ) + self.db.execute(insert_sql, insert_parameter) + + # sut(system under test)作成 + for i, line in enumerate(test_dat_file, start=1): + sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db) + assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目: マッパークラスが期待通りか' + + # Act + sut.make_query() + sut.execute_queries() + + # Assert + # 期待値作成 + expect_data = csv_floating_data_lst[i - 1] + hamtec_div = expect_data[1] if expect_data[3] == 'B' else db_floating_data_list[i - 1][1] + hamtec_name = expect_data[2] if expect_data[3] == 'B' else db_floating_data_list[i - 1][2] + expect_row = [expect_data[0], hamtec_div, hamtec_name] + create_ultmarc_common_column_values( + regist_ymd=expect_date_str, + update_ymd=expect_date_str if expect_data[3] == 'B' else None, # メンテナンス区分!=C 更新日が登録される + delete_ymd=expect_date_str if expect_data[3] == 'C' else None, # メンテナンス区分==C 削除日が登録される + sys_regist_date=expect_datetime, + regist_prgm_id=module_name, + sys_update_date=datetime.now() if expect_data[3] != 'A' else expect_datetime, + update_prgm_id=module_name + ) + expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}] + actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'") + + # 期待値検査 + assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date']) + # 動的日付項目の個別確認 + for actual_row, expect_row in zip(actual_rows, expect_rows): + for actual_col_name, expect_col_name in zip(actual_row, expect_row): + if actual_col_name == 'sys_regist_date': + assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること' + if actual_col_name == 'sys_update_date': + if expect_data[3] != 'A': + assert actual_row[actual_col_name] <= expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること' + else: + assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること'