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

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

@@ -291,6 +291,12 @@ def check_mcms_dept_buy(type=16):
     else:
         print('error')
         commonFuc().check_text_exist_result_text('error', 'succees')
+def check_mcms_psi_dept_batch(type,DR_ID):
+    sql = " select * from  mcms_psi_dept_batch where pid='%s';" % (
+    DR_ID)
+    actual = check_mcms_dept_buy_sql(sql)
+    print(actual)
+
 def check_mcms_psi_dept(type=16):
     branch_id=get_branch_id()
     sql=" select * from  mcms_psi_dept where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_SL' order by   CREATE_TIME desc LIMIT 1;"%(branch_id,type)
@@ -333,6 +339,8 @@ def check_mcms_psi_dept(type=16):
     last_modified=get_create_time("select last_modified from  mcms_psi_dept where id='%s';" % DR_ID)
     last_modified_user=create_user
     if type == 16:
+        #子表检查
+        check_mcms_psi_dept_batch(type,DR_ID)
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
                                                  'mcms_psi_dept1',DR_ID,order_no,target_corp_id,target_branch_id,target_dept_id,target_dept_name,target_stock_id
                                                     ,target_area_code,source_id,source_corp_id,source_branch_id,