数据库验证流程十一脚本编写

air_case/b6_spd3_core_business_flow_database_check/a_b4流程十一请领业务流_二级库向直送_数据库验证.air/a_b4流程十一请领业务流_二级库向直送_数据库验证.py

@@ -343,8 +343,7 @@ def check_mcms_dept_buy_approval_after(type=16):
         "select last_audit_time from  mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc  LIMIT 1;" % (
             branch_id, type))
     target_stock_name = get_branch_name() + "中心库房"
-    # import pdb
-    # pdb.set_trace()
+
     rec_addr = deptname2
     if type == 16:
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
@@ -494,8 +493,7 @@ def check_mcms_mcms_pur_plan(type=16):
     sql = "select order_no from mcms_pur_plan where branch_id='%s' and source_id='%s' order by  create_time desc LIMIT 1;" % (
         branch_id, id1)
     PLAN_order_no = process_tuple(get_dept_buy_id(sql))  # 采购计划主表order_no
-    #验证子表数据
-    check_mcms_mcms_pur_plan_detail(id2)
+
     # 要验证的数据sql
     sql1 = "select * from mcms_pur_plan where branch_id='%s' and source_id='%s' order by  create_time desc LIMIT 1;" % (
         branch_id, id1)
@@ -531,6 +529,8 @@ def check_mcms_mcms_pur_plan(type=16):
     last_modified_user = create_user
     planOrderNo=PLAN_order_no
     if type == 16:
+        # 验证子表数据
+        check_mcms_mcms_pur_plan_detail(id2,type,source_id,planOrderNo)
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
                                                  'mcms_pur_plan', id2, PLAN_order_no, hos_id,
                                                  get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
@@ -538,6 +538,7 @@ def check_mcms_mcms_pur_plan(type=16):
                                                  rec_addr, bill_expdt_date, buyBillId, planBillId, planOrderNo,buyOrderNo,
                                                  create_user,create_time, last_modified, last_modified_user)
     elif type == 20:
+        check_mcms_mcms_pur_plan_detail(id2,type,source_id,planOrderNo)
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
                                                  'mcms_pur_plan2', id2, PLAN_order_no, hos_id,
                                                  get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
@@ -546,6 +547,7 @@ def check_mcms_mcms_pur_plan(type=16):
                                                  buyOrderNo,
                                                  create_user, create_time, last_modified, last_modified_user)
     elif type == 66:
+        check_mcms_mcms_pur_plan_detail(id2,type,source_id,planOrderNo)
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
                                                  'mcms_pur_plan3', id2, PLAN_order_no, hos_id,
                                                  get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
@@ -573,7 +575,7 @@ def check_mcms_mcms_pur_plan(type=16):
         commonFuc().check_text_exist_result_text('error', 'succees')
 
 
-def check_mcms_mcms_pur_plan_detail(id):
+def check_mcms_mcms_pur_plan_detail(id,type,source_id,planOrderNo):
     branch_id = get_branch_id()
     # 根据采购计划主表的id获取采购计划单子表主键
     sql = "select id from mcms_pur_plan_detail where pid='%s' order by  create_time desc LIMIT 1;" % (
@@ -594,58 +596,106 @@ def check_mcms_mcms_pur_plan_detail(id):
     dept_name2 = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid2']
     rec_org_id = process_tuple(
         get_id("select id from sys_org where branch_id='%s' and ename='%s';" % (branch_id, dept_name2)))
-    rec_org_name = dept_name2
-    info = FileUtils().r_info8("b5_spd3_core_business_flow", "库区信息", 'message22')
-    list_a = info['list_a']
-    area_code = commonFuc().analysis_json('shelfCode', list_a)
-    area_name = '默认库区'
-    # source_id = id1
     rec_user = get_login_user_uxid()
-    rec_addr = '自动化测试'
-    # sql = "select bill_expdt_date from  mcms_pur_plan where branch_id='%s' and source_id='%s' order by create_time desc  LIMIT 1;" % (
-    #     branch_id, id1)
-    print(sql)
-    bill_expdt_date = get_expdt_date(sql)
-    # buyBillId = id1
-    planBillId = id2
-    # buyOrderNo = buyOrderNo1
     create_user = rec_user
-    # create_time = get_create_time(
-    #     "select create_time from mcms_pur_plan where branch_id='%s' and source_id='%s' order by  create_time desc LIMIT 1;" % (
-    #         branch_id, id1))
     # last_modified = create_time
     last_modified_user = create_user
-    planOrderNo=PLAN_order_no
-    source_id=id
     pid=id
     if type == 16:
         hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
+        mdm_goods_code=process_tuple(
+        get_id("select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (hos_goods_id, id2)))
+        # print(mdm_goods_code)
+        goods_code=process_tuple(
+        get_id("select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (hos_goods_id, id2)))
+        pkg_def_id = process_tuple(
+            get_id("select pkg_def_id from mcms_pkg where hos_goods_id='%s' LIMIT 1;" % hos_goods_id))
+        supply_id=process_tuple(
+        get_id("select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (hos_goods_id, id2)))
+        prov_id=FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"]
+        prov_name=FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_username"]
+        sub_prov_id=prov_id
+        create_time = get_create_time(
+        "select create_time from mcms_pur_plan_detail where id='%s';" % (
+            id2))
+        last_modified = create_time
+        sub_prov_name=prov_name
+        source_id = process_tuple(
+            get_id("select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+            hos_goods_id, id2)))
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
-                                                 'mcms_pur_plan', id2, pid, planOrderNo,source_id,hos_goods_id,
-                                                 get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
-                                                 area_code, area_name, source_id, rec_user,
-                                                 rec_addr, bill_expdt_date, buyBillId, planBillId, planOrderNo,buyOrderNo,
-                                                 create_user,create_time, last_modified, last_modified_user)
-    # elif type == 20:
-    #     expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
-    #                                              'mcms_pur_plan', id2, PLAN_order_no, hos_id,
-    #                                              get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
-    #                                              area_code, area_name, source_id, rec_user,
-    #                                              rec_addr, bill_expdt_date, buyBillId, planBillId, planOrderNo,
-    #                                              buyOrderNo,
-    #                                              create_user, create_time, last_modified, last_modified_user)
-    # else:
-    #     import pdb
-    #     pdb.set_trace()
-    #     expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
-    #                                              'mcms_pur_plan',id2, PLAN_order_no, hos_id,
-    #                                              get_branch_id(), dept_id1, dept_name1, rec_org_id, rec_org_name,
-    #                                              area_code, area_name, source_id, rec_user,
-    #                                              rec_addr, bill_expdt_date, buyBillId, planBillId, planOrderNo,
-    #                                              buyOrderNo,
-    #                                              create_user, create_time, last_modified, last_modified_user)
-    #
-    # actual_value1 = get_process_list2(actual)
+                                                 'mcms_pur_plan_detail', id2, pid, planOrderNo,source_id,hos_goods_id,
+                                                 mdm_goods_code,goods_code, pkg_def_id, supply_id, prov_id, prov_name,sub_prov_id,sub_prov_name,
+                                                 create_user, create_time, last_modified, last_modified_user
+                                                 )
+    elif type == 20:
+        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message1')["hosGoodsId"]
+        mdm_goods_code = process_tuple(
+            get_id("select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+            hos_goods_id, id2)))
+        # print(mdm_goods_code)
+        goods_code = process_tuple(
+            get_id("select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+            hos_goods_id, id2)))
+        pkg_def_id = process_tuple(
+            get_id("select pkg_def_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+            hos_goods_id, id2)))
+        supply_id = process_tuple(
+            get_id("select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+            hos_goods_id, id2)))
+        prov_id = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"]
+        prov_name = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_username"]
+        sub_prov_id = prov_id
+        create_time = get_create_time(
+            "select create_time from mcms_pur_plan_detail where id='%s';" % (
+                id2))
+        last_modified = create_time
+        sub_prov_name = prov_name
+        source_id = process_tuple(
+            get_id("select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_pur_plan_detail2', id2, pid, planOrderNo, source_id, hos_goods_id,
+                                                 mdm_goods_code, goods_code, supply_id, prov_id, prov_name,
+                                                 sub_prov_id,sub_prov_name,
+                                                 create_user, create_time, last_modified, last_modified_user
+                                                 )
+
+    else:
+
+        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message3')["hosGoodsId"]
+        mdm_goods_code = process_tuple(
+            get_id("select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        # print(mdm_goods_code)
+        goods_code = process_tuple(
+            get_id("select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        pkg_def_id = process_tuple(
+            get_id("select pkg_def_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        supply_id = process_tuple(
+            get_id("select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        prov_id = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"]
+        prov_name = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_username"]
+        sub_prov_id = prov_id
+        create_time = get_create_time(
+            "select create_time from mcms_pur_plan_detail where id='%s';" % (
+                id2))
+        last_modified = create_time
+        sub_prov_name = prov_name
+        source_id = process_tuple(
+            get_id("select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and  id='%s';" % (
+                hos_goods_id, id2)))
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_pur_plan_detail', id2, pid, planOrderNo, source_id, hos_goods_id,
+                                                 mdm_goods_code, goods_code, pkg_def_id, supply_id, prov_id, prov_name,
+                                                 sub_prov_id,sub_prov_name,
+                                                 create_user, create_time, last_modified, last_modified_user
+                                                 )
+
+    actual_value1 = get_process_list2(actual)
     expected_value1 = get_process_list2(expected)
     actual_value2 = actual_value1.replace(" ", "")
     expected_value2 = expected_value1.replace(" ", "")

data/b6_spd3_core_business_flow_database_check/data

@@ -31,4 +31,5 @@
 "mcms_pur_plan3": '{"id": "%s", "order_no": "%s", "hos_id": "%s", "branch_id": "%s", "dept_id": "%s", "dept_name": "%s", "rec_org_id": "%s", "rec_org_name": "%s", "area_code": "%s", "area_name": "%s", "create_type": "SG", "source_id": "%s", "source_type": "QLD", "rec_user": "%s", "rec_phone": "None", "rec_addr": "%s", "priority": 0, "bill_expdt_date": %s, "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s"}", "remark": "", "close_status": 0, "tb_status": 0, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "last_auditor": None, "last_audit_time": None, "rec_type": "HDI", "audit_remark": None}'
 
 
-"mcms_pur_plan_detail": '{'id': '%s', 'pid': '%s', 'order_no': '%s', 'source_id': '%s', 'hos_goods_id': '%s', 'mdm_goods_code': '11661562', 'goods_code': '00004600', 'pur_mode': 20, 'pkg_def_id': None, 'pkg_def_name': None, 'pkg_def_qty': Decimal('1.00'), 'plan_pkg_qty': Decimal('1.00'), 'plan_qty': Decimal('1.00'), 'pkg_qty': Decimal('1.00'), 'price': Decimal('99.999900'), 'qty': Decimal('1.00'), 'in_settlement': None, 'supply_id': 'c9236fdca0c442feb44314027c78ebcb', 'prov_id': 'p1e35e', 'prov_name': '国药集团公司S57ui', 'sub_send_flag': 10, 'sub_prov_id': 'p1e35e', 'sub_prov_name': '国药集团公司S57ui', 'contract_id': None, 'remark': None, 'close_status': 0, 'tb_status': 10, 'pur_task_id': None, 'create_user': 'h0347_UID-051420', 'create_time': datetime.datetime(2024, 7, 16, 10, 27, 19), 'last_modified': datetime.datetime(2024, 7, 16, 10, 27, 19), 'last_modified_user': 'h0347_UID-051420', 'version': 0, 'coding_type': 0}'
+"mcms_pur_plan_detail": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 10, "pkg_def_id": "%s", "pkg_def_name": "100", "pkg_def_qty": Decimal("100.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("100.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("100.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
\ No newline at end of file
+"mcms_pur_plan_detail2": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 20, "pkg_def_id": None, "pkg_def_name": None, "pkg_def_qty": Decimal("1.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("1.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("1.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
\ No newline at end of file