脚本优化

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

@@ -10,6 +10,7 @@ from common.fileUtls import FileUtils
 from common.run_cmd_script import execute_command
 from common.timeUtils import timeUtils
 from airtest.core.api import using
+from common.db.sql.sql_tools import *
 
 __author__ = "xiaohesheng"
 
@@ -18,6 +19,26 @@ case_tag:api,b6_spd3_core_business_flow_database_check,a_b3流程十请领业务
 核心业务流:a_b3流程十请领业务流_二级库向边仓
 python runner_test.py tag id2302-13 debug mdm3
 """
+def check_mcms_dept_buy(type):
+    if type==1:#低值
+        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
+        actual_value1 = tools_check_mcms_dept_buy(hos_goods_id)
+        print(actual_value1)
+        # print('actual_value2',actual_value1)
+        actual_value2 = get_process_list2(actual_value1)
+        print('actual_value2', actual_value2, type(actual_value2))
+        prov_hos_goods_id = '8d6273b7bca84dd8aace12b9422d7fd6'
+        expected_value2 = commonFuc().get_business_data('b5_spd3_core_business_flow', 'expected_value2', prov_hos_goods_id)
+        print('expected_value2', expected_value2, type(expected_value2))
+        actual_value2 = actual_value2.replace(" ", "")
+        expected_value2 = expected_value2.replace(" ", "")
+        print(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')
 
 
 
@@ -39,6 +60,7 @@ try:
     updateUserLoginDefaultRange(get_listUserMgrRangePage(2))  # 设置登录账号默认权限是二级库
     # # # 低值
     second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message2')['hosGoodsId'], 1)
+    check_mcms_dept_buy(1)
     # # 高值
     second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId'], 2)
     # # 试剂

air_case/demo/产品检查.air/产品检查.py

@@ -35,22 +35,22 @@ else:
 
 
 # 第二种方式=================================
-# hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
-# actual_value1 = main2(hos_goods_id)
-# print(actual_value1)
-# # print('actual_value2',actual_value1)
-# actual_value2 = get_process_list2(actual_value1)
-# print('actual_value2', actual_value2, type(actual_value2))
-# prov_hos_goods_id = '8d6273b7bca84dd8aace12b9422d7fd6'
-# expected_value2 = commonFuc().get_business_data('b5_spd3_core_business_flow', 'expected_value2', prov_hos_goods_id)
-# print('expected_value2', expected_value2, type(expected_value2))
-# actual_value2 = actual_value2.replace(" ", "")
-# expected_value2 = expected_value2.replace(" ", "")
-# print(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')
+hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
+actual_value1 = main2(hos_goods_id)
+print(actual_value1)
+# print('actual_value2',actual_value1)
+actual_value2 = get_process_list2(actual_value1)
+print('actual_value2', actual_value2, type(actual_value2))
+prov_hos_goods_id = '8d6273b7bca84dd8aace12b9422d7fd6'
+expected_value2 = commonFuc().get_business_data('b5_spd3_core_business_flow', 'expected_value2', prov_hos_goods_id)
+print('expected_value2', expected_value2, type(expected_value2))
+actual_value2 = actual_value2.replace(" ", "")
+expected_value2 = expected_value2.replace(" ", "")
+print(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')
 # 第二种方式=================================
\ No newline at end of file

common/db/sql/sql_tools.py

@@ -104,7 +104,63 @@ def main2(hos_goods_id):
     res_dict = get_dict_data_sql(cursor, sql)
     print('res_dict',res_dict)
     return res_dict
-
+def tools_check_mcms_dept_buy():
+    db, cursor = get_sql_conn()
+    sql = """SELECT hos_goods_code,
+                        hos_id,
+                        prov_id,
+                        prov_hos_goods_id,
+                        srv_id,
+                        mdm_goods_code,
+                        mdm_goods_spec_code,
+                        spd_goods_code,
+                        goods_name,
+                        goods_general_name,
+                        goods_mfrs_id,
+                        goods_mfrs_name,
+                        goods_reg_cert,
+                        goods_agent_mfrs_id,
+                        brand,
+                        short_pinyin,
+                        kind_sixtyeight_code,
+                        unit,
+                        goods_spec,
+                        goods_package,
+                        bar_code_mng,
+                        unique_code_strategy,
+                        pur_mode,
+                        sub_pur_mode,
+                        erp_code,
+                        herp_code,
+                        hrp,
+                        price,
+                        abroad_flag,
+                        made,
+                        property,
+                        mgr_level,
+                        goods_desc,
+                        charge_flag,
+                        focus_control_type,
+                        temp_flag,
+                        official_status,
+                        focus_control,
+                        storage_conditions,
+                        transport_conditions,
+                        into_cost_flag,
+                        rfid_flag,
+                        purchase_flag,
+                        tb_status,
+                        version,
+                        create_user,
+                        create_time,
+                        last_modified_user,
+                        sterilize_flag,
+                        multi_charge_flag,
+                        use_frequency,
+                        charge_unit FROM  	mcms_goods_info WHERE 	id ='%s';""" % hos_goods_id
+    res_dict = get_dict_data_sql(cursor, sql)
+    print('res_dict', res_dict)
+    return res_dict
 
 hos_goods_id = 'h034700004220'
 main2(hos_goods_id)
\ No newline at end of file