流程十四脚本编写

air_case/b6_spd3_core_business_flow_database_check/a_b8流程十五退库业务_三级库向二级库退库_数据库验证.air/a_b8流程十五退库业务_三级库向二级库退库_数据库验证.py

@@ -86,9 +86,9 @@ def check_mcms_psi_dept_out(type1=16):
                                                  , create_user, create_time, last_modified, last_modified_user)
     else:
         # 子表检查
-        check_mcms_psi_dept_batch(DR_ID,type1,order_no)
         check_mcms_psi_dept_batch(DR_ID, type1, order_no)
         target_area_code = None
+        accounter = None
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
                                                  'mcms_psi_dept_tkck3', DR_ID, order_no, target_corp_id, target_branch_id,
                                                  target_dept_id, target_dept_name, target_stock_id
@@ -203,6 +203,102 @@ def check_mcms_psi_dept_batch(DR_ID,type,order_no):
         print('error')
         commonFuc().check_text_exist_result_text('error', 'succees')
 
+def check_mcms_psi_dept_in(type1=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_LYTK' order by   CREATE_TIME desc LIMIT 1;" % (
+    branch_id, type1)
+    actual = check_mcms_dept_buy_sql(sql)
+    print(actual)
+    DR_ID=get_id(" select id from  mcms_psi_dept where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_LYTK' order by   CREATE_TIME desc LIMIT 1;" % (
+    branch_id, type1))
+    sql = "select order_no from mcms_psi_dept where id='%s';" % DR_ID
+    order_no = get_id(sql)
+    target_corp_id = get_hosid()
+    target_branch_id = get_branch_id()
+    target_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid2']
+    target_dept_name = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid2']
+    target_stock_id = get_stockId_fromdb(target_dept_name + '库房')
+    target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 2)
+    PICK_id = get_PICK_id(branch_id, type1)
+    source_id = PICK_id
+    source_corp_id = get_hosid()
+    source_branch_id = get_branch_id()
+    source_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid3']
+    source_dept_name = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid3']
+    source_stock_id = get_stockId_fromdb(source_dept_name + '库房')
+    source_area_code = get_stockAreaId_new_fromDb(source_dept_name, 2)
+    buyBillId = get_buyBillId(branch_id, type1)
+    pickOrderNo = get_PICK_order_no(branch_id, type1)
+    buyOrderNo = get_buyOrderNo(branch_id, type1)
+    pickBillId = get_PICK_id(branch_id, type1)
+    psiDeptOutBillId = DR_ID
+    psiDeptOutOrderNo = order_no
+    create_user = get_login_user_uxid_bydb(FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')['username1'])
+    create_time = get_create_time("select create_time from  mcms_psi_dept where id='%s';" % DR_ID)
+    last_modified = get_create_time("select last_modified from  mcms_psi_dept where id='%s';" % DR_ID)
+    last_modified_user = create_user
+    accounter=create_user
+    account_date = process_tuple(get_create_time("select account_date from  mcms_psi_dept where id='%s';" % DR_ID))
+    if type1 == 16:
+        # 子表检查
+        check_mcms_psi_dept_batch(DR_ID,type1,order_no)
+        target_area_code = None
+        accounter = None
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_dept_tkck1', 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,
+                                                 source_dept_id, source_dept_name, source_stock_id, source_area_code,accounter,account_date,
+                                                 pickOrderNo, pickBillId, psiDeptOutBillId, psiDeptOutOrderNo
+                                                 , create_user, create_time, last_modified, last_modified_user
+
+                                                 )
+    elif type1 == 20:
+        # 子表检查
+        check_mcms_psi_dept_batch(DR_ID,type1,order_no)
+        target_area_code=None
+        accounter=None
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_dept_tkck2', 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,
+                                                 source_dept_id, source_dept_name, source_stock_id, source_area_code,accounter,account_date,
+                                                 pickOrderNo, pickBillId, psiDeptOutBillId, psiDeptOutOrderNo
+                                                 , create_user, create_time, last_modified, last_modified_user)
+    else:
+        # 子表检查
+        check_mcms_psi_dept_batch(DR_ID, type1, order_no)
+        target_area_code = None
+        accounter = None
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_dept_tkck3', 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,
+                                                 source_dept_id, source_dept_name, source_stock_id, source_area_code,accounter,account_date,
+                                                 pickOrderNo, pickBillId, psiDeptOutBillId, psiDeptOutOrderNo
+                                                 , create_user, create_time, last_modified, last_modified_user
+
+                                                 )
+    print('expected', expected)
+    print('aaaaaaaaaaaaaaaaa')
+    actual_value1 = get_process_list2(actual)
+    expected_value1 = get_process_list2(expected)
+    actual_value2 = actual_value1.replace(" ", "")
+    expected_value2 = expected_value1.replace(" ", "")
+    # print('actual_value2',actual_value2)
+    print('expected_value2')
+    print(expected_value2)
+    print('actual_value2')
+    print(actual_value2)
+    print(compare_text_index(actual_value2, expected_value2))
+    if actual_value2 == expected_value2:
+        print('ok')
+        commonFuc().check_text_exist_result_text('succees', 'succees')
+    else:
+        print('error')
+        commonFuc().check_text_exist_result_text('error', 'succees')
+
 pro_path = commonFuc().get_pro_path2()
 print('pro_path', pro_path)
 sys.path.append(pro_path + r'/air_case/b5_spd3_core_business_flow/a_b8流程十五退库业务_三级库向二级库退库.air')
@@ -211,13 +307,20 @@ from a_b8流程十五退库业务_三级库向二级库退库 import second_dept
 try:
     # updateUserLoginDefaultRange(get_listUserMgrRangePage1(3))  # 设置登录账号默认权限是三级库
     # second_dept_return_Out_Stock(2)  # 高值耗材退货出库
-    check_mcms_psi_dept_out(20)#检查出库单（包括主表和子表）
-    second_dept_return_Out_Stock(1)  # 低值耗材退货出库
-    check_mcms_psi_dept_out(16)  # 检查出库单（包括主表和子表）
-    second_dept_return_Out_Stock(3)  # 试剂耗材退货出库
+    # time.sleep(6)
+    # check_mcms_psi_dept_out(20)#检查出库单（包括主表和子表）
+    # time.sleep(6)
+    # second_dept_return_Out_Stock(1)  # 低值耗材退货出库
+    # time.sleep(6)
+    # check_mcms_psi_dept_out(16)  # 检查出库单（包括主表和子表）
+    # second_dept_return_Out_Stock(3)  # 试剂耗材退货出库
+    check_mcms_psi_dept_out(66)  # 检查出库单（包括主表和子表）
     second_dept_one_key_in(2)
     second_dept_one_key_in(2)
     second_dept_one_key_in(2)
+    check_mcms_psi_dept_in(16)  # 检查出库单（包括主表和子表）
+    check_mcms_psi_dept_in(20)  # 检查出库单（包括主表和子表）
+    check_mcms_psi_dept_in(66)  # 检查出库单（包括主表和子表）
     commonFuc().check_text_exist_result_text('succees', 'succees')
 except Exception as e:
     # 打印错误信息