Commit 78ec16ba authored by liguangyu06's avatar liguangyu06
Browse files

增加响应时间

parent 6a379d79
...@@ -26,7 +26,10 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url2") ...@@ -26,7 +26,10 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url2")
request_body1 = commonFuc().get_business_data(module, "payload300") request_body1 = commonFuc().get_business_data(module, "payload300")
# 发送请求 # 发送请求
result1 = requests.post(url, json=request_body1, headers=headers) result1 = requests.post(url, json=request_body1, headers=headers)
# 获取接口响应时间
api_time = result1.elapsed.total_seconds()
result1 = json.loads(result1.content) result1 = json.loads(result1.content)
result1["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict1 = commonFuc().get_business_data(module, "checkDict300") check_dict1 = commonFuc().get_business_data(module, "checkDict300")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
...@@ -42,10 +45,9 @@ request_body = commonFuc().get_business_data(module, "payload301") ...@@ -42,10 +45,9 @@ request_body = commonFuc().get_business_data(module, "payload301")
""" """
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = result.elapsed.total_seconds()
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict300") check_dict = commonFuc().get_business_data(module, "checkDict300")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
__author__ = "liguangyu" __author__ = "liguangyu"
""" """
case_tag:cmdc_api,cmdc用户购物车商品移除,2252,2252-9,sit,bs case_tag:cmdc_api,cmdc购物车商品移除,2252,2252-9,sit,bs
主数据平台:多采商城购物车列表商品删除接口 主数据平台:多采商城购物车列表商品删除接口
""" """
...@@ -77,4 +77,4 @@ if result_product_id == product_id: ...@@ -77,4 +77,4 @@ if result_product_id == product_id:
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict2") check_dict = commonFuc().get_business_data(module, "checkDict2")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
commonFuc().check_result(check_dict, result) commonFuc().check_result(check_dict, result)
\ No newline at end of file
...@@ -46,6 +46,7 @@ if invalid_sign == 0: ...@@ -46,6 +46,7 @@ if invalid_sign == 0:
# 获取接口响应时间 # 获取接口响应时间
api_time = result1.elapsed.total_seconds() api_time = result1.elapsed.total_seconds()
result1 = json.loads(result1.content) result1 = json.loads(result1.content)
result1["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict1 = commonFuc().get_business_data(module, "checkDict80") check_dict1 = commonFuc().get_business_data(module, "checkDict80")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
...@@ -59,7 +60,6 @@ if invalid_sign == 0: ...@@ -59,7 +60,6 @@ if invalid_sign == 0:
for i in result2["data"]["list"][0]["list"]: for i in result2["data"]["list"][0]["list"]:
if i["buyerCartId"] == buyercart_id: if i["buyerCartId"] == buyercart_id:
result3 = i["quantity"] result3 = i["quantity"]
result["api_time"] = api_time
check_dict3 = commonFuc().get_business_data(module, "checkDict81", result3) check_dict3 = commonFuc().get_business_data(module, "checkDict81", result3)
check_dict4 = commonFuc().get_business_data(module, "checkDict82", modify_quantity) check_dict4 = commonFuc().get_business_data(module, "checkDict82", modify_quantity)
commonFuc().check_result(check_dict3, check_dict4) commonFuc().check_result(check_dict3, check_dict4)
......
...@@ -65,6 +65,7 @@ for i in result["data"]["couponList"]: ...@@ -65,6 +65,7 @@ for i in result["data"]["couponList"]:
if i["couponId"] == coupon_id: if i["couponId"] == coupon_id:
# 获取商品对应优惠券id # 获取商品对应优惠券id
result = {"couponId": i["couponId"]} result = {"couponId": i["couponId"]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict10", coupon_id) check_dict = commonFuc().get_business_data(module, "checkDict10", coupon_id)
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -29,6 +29,7 @@ request_body = commonFuc().get_business_data(module, "payload70") ...@@ -29,6 +29,7 @@ request_body = commonFuc().get_business_data(module, "payload70")
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
result = json.loads(result.content) result = json.loads(result.content)
# 获取商品信息并进行参数化处理 # 获取商品信息并进行参数化处理
product_id = result["data"]["list"][0]["productId"] product_id = result["data"]["list"][0]["productId"]
price = result["data"]["list"][0]["referencePrice"] price = result["data"]["list"][0]["referencePrice"]
......
...@@ -47,7 +47,7 @@ result = requests.post(url, json=request_body, headers=headers) ...@@ -47,7 +47,7 @@ result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间 # 获取接口响应时间
api_time = float(result.elapsed.total_seconds()) api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict9") check_dict = commonFuc().get_business_data(module, "checkDict9")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
...@@ -63,7 +63,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -63,7 +63,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = '%s'" % group_id sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = '%s'" % group_id
status = mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0] status = mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]
result = {"status": status} result = {"status": status}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict90") check_dict = commonFuc().get_business_data(module, "checkDict90")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -47,6 +47,7 @@ result = requests.post(url, json=request_body, headers=headers) ...@@ -47,6 +47,7 @@ result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间 # 获取接口响应时间
api_time = float(result.elapsed.total_seconds()) api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
# print(result)
result["api_time"] = api_time result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
......
...@@ -26,7 +26,7 @@ request_body = commonFuc().get_business_data(module, "payload47_1") ...@@ -26,7 +26,7 @@ request_body = commonFuc().get_business_data(module, "payload47_1")
# 发送请求 # 发送请求
result = requests.get(url, params=request_body, headers=headers) result = requests.get(url, params=request_body, headers=headers)
result = json.loads(result.content) result = json.loads(result.content)
# print(result)
# 获取商品限购信息 # 获取商品限购信息
id = result["data"]["list"][0]["id"] id = result["data"]["list"][0]["id"]
......
...@@ -75,7 +75,7 @@ result = requests.post(url, headers=headers, json=request_body) ...@@ -75,7 +75,7 @@ result = requests.post(url, headers=headers, json=request_body)
# 获取接口响应时间 # 获取接口响应时间
api_time = float(result.elapsed.total_seconds()) api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# 数据库操作 # 数据库操作
mysql_handle = mySql() mysql_handle = mySql()
# 获取conf.ini文件中配置的数据库信息 # 获取conf.ini文件中配置的数据库信息
......
...@@ -180,16 +180,18 @@ class CustomAirTestCase(AirtestCase): ...@@ -180,16 +180,18 @@ class CustomAirTestCase(AirtestCase):
txt_log = os.path.join(log, 'log.txt') txt_log = os.path.join(log, 'log.txt')
f = open(txt_log, 'r', encoding='utf-8') f = open(txt_log, 'r', encoding='utf-8')
lines = f.readlines() lines = f.readlines()
f.close() f.close()
start_time = float(re.findall('.*"start_time": (.*), "ret".*', lines[0])[0])
start_time = int(start_time * 1000)
api_time = re.findall('"api_time":(.*)}, "second"', lines[0])[0]
try: try:
start_time = float(re.findall('.*"start_time": (.*), "ret".*', lines[0])[0])
end_time = float(re.findall('.*"end_time": (.*)}}.*', lines[-1])[0]) end_time = float(re.findall('.*"end_time": (.*)}}.*', lines[-1])[0])
# 用于获取接口响应时间,供电商项目使用
api_time = re.findall('"api_time":(.*)}, "second"', lines[0])[0]
except: except:
# case执行失败的话没打end_time # case执行失败的话没打end_time
end_time = float(re.findall('.*"time": (.*), "data".*', lines[-2])[0]) start_time = end_time = api_time = 0
# end_time = float(re.findall('.*"time": (.*), "data".*', lines[-2])[0])
start_time = int(start_time * 1000)
end_time = int(end_time * 1000) end_time = int(end_time * 1000)
return start_time, end_time, api_time return start_time, end_time, api_time
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment