自動テスト実装 卸マスタ

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/test_vjsk_load.py

@@ -371,3 +371,66 @@ class TestImportFileToDb:
         assert result_src_count[0]['count(*)'] == 6
 
         # teardown
+
+    def test_load_05_whs_mst_ok(self, mapper):
+        table_name_org = mapper.get_org_table(mapper.CONDKEY_WHS_MST)
+        table_name_src = mapper.get_src_table(mapper.CONDKEY_WHS_MST)
+
+        # setup
+        self.batch_context.is_vjsk_stock_import_day = True
+        self.db.execute(f"truncate table {table_name_src}")
+
+        # assertion1 (insert 4row)
+
+        # 処理実行
+        target_dict = {
+            "condkey": mapper.CONDKEY_WHS_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "whs_mst_202304280000.tsv")
+        }
+        VjskDataLoadManager.load(target_dict)
+
+        # 期待値データファイル読み込み
+        assert_list = create_vjsk_assertion_list(target_dict["src_file_path"])
+        # orgテーブル結果を取得
+        result_org = self.db.execute_select(f"select * from {table_name_org}")
+        # 突合から除外する項目
+        ignore_columns = ['dwh_upd_dt']
+        # orgテーブル結果が期待値通りかを突合
+        assert_table_results(result_org, assert_list, ignore_columns)
+        # srcテーブル結果を取得
+        result_src = self.db.execute_select(f"select * from {table_name_src}")
+        # 突合から除外する項目
+        ignore_columns = ['dwh_upd_dt']
+        # srcテーブル結果が期待値通りかを突合
+        assert_table_results(result_src, assert_list, ignore_columns)
+
+        # assertion2 (update 2row +insert 2row)
+
+        # 処理実行
+        target_dict = {
+            "condkey": mapper.CONDKEY_WHS_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "whs_mst_202304290000.tsv")
+        }
+        VjskDataLoadManager.load(target_dict)
+
+        # 期待値データファイル読み込み
+        assert_list = create_vjsk_assertion_list(target_dict["src_file_path"])
+        # orgテーブル結果を取得
+        result_org = self.db.execute_select(f"select * from {table_name_org}")
+        # 突合から除外する項目
+        ignore_columns = ['dwh_upd_dt']
+        # orgテーブル結果が期待値通りかを突合
+        assert_table_results(result_org, assert_list, ignore_columns)
+        # srcテーブル結果(orgテーブル結果のPK値で一致するもの)を取得
+        result_src = self.db.execute_select(
+            f"select * from {table_name_src} s inner join {table_name_org} o on (s.v_whs_cd = o.v_whs_cd and s.sub_num = o.sub_num)")
+        # 突合から除外する項目
+        ignore_columns = ['dwh_upd_dt']
+        # srcテーブル結果が期待値通りかを突合
+        assert_table_results(result_src, assert_list, ignore_columns)
+
+        # srcテーブル結果のレコード件数 (insert 4row + update 2row + insert 2row = 6row)
+        result_src_count = self.db.execute_select(f"select count(*) from {table_name_src} ")
+        assert result_src_count[0]['count(*)'] == 6
+
+        # teardown

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_mst_202304280000.tsv

@@ -0,0 +1,5 @@
+"v_whs_cd"	"sub_no"	"nm"	"kn_nm"	"sht_nm"	"zip_cd"	"addr"	"kn_addr"	"tel_no"	"v_hld_cd"	"start_dt"	"end_dt"	"dsp_odr"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"200000002"	"0"	"株式会社モロオ"	"カナ01"	"モロオ"	"1110001"	"住所01"	"ジュウショ01"	"00-0000-0001"	"0"	"20000101"	"99991231"	"20"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000005"	"0"	"岩渕薬品株式会社"	"カナ02"	"岩渕薬品"	"1110002"	"住所02"	"ジュウショ02"	"00-0000-0002"	"0"	"20000101"	"99991231"	"50"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000009"	"0"	"株式会社マルタケ"	"カナ03"	"マルタケ"	"1110003"	"住所03"	"ジュウショ03"	"00-0000-0003"	"0"	"20000101"	"99991231"	"90"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000010"	"0"	"株式会社ファイネス"	"カナ04"	"ファイネス"	"1110004"	"住所04"	"ジュウショ04"	"00-0000-0004"	"0"	"20000101"	"99991231"	"100"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_mst_202304290000.tsv

@@ -0,0 +1,5 @@
+"v_whs_cd"	"sub_no"	"nm"	"kn_nm"	"sht_nm"	"zip_cd"	"addr"	"kn_addr"	"tel_no"	"v_hld_cd"	"start_dt"	"end_dt"	"dsp_odr"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"200000009"	"0"	"株式会社マルタケ"	""	"マルタケ"	""	""	""	""	"0"	"20000101"	"99991231"	"90"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000010"	"0"	"株式会社ファイネス"	""	"ファイネス"	""	""	""	""	"0"	"20000101"	"99991231"	"100"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000011"	"0"	"鍋林株式会社"	""	"鍋林"	""	""	""	""	"0"	"20000101"	"99991231"	"110"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"
+"200000012"	"0"	"岡野薬品株式会社"	""	"岡野薬品"	""	""	""	""	"0"	"20000101"	"99991231"	"120"	"0"	"16-04-15 16:25:33"	"16-04-15 16:25:33"