Commit 5fff38e3 authored by liguangyu06's avatar liguangyu06
Browse files

增加响应时间

parent fb678c50
...@@ -61,11 +61,14 @@ files = {"file": file} ...@@ -61,11 +61,14 @@ files = {"file": file}
# 发送请求 # 发送请求
result = requests.post(url, files=files, headers=headers, data=request_body) result = requests.post(url, files=files, headers=headers, data=request_body)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
file.close() file.close()
# 截取结果中errList信息 # 截取结果中errList信息
result = {"errList": result["data"]["errMsg"]["errList"]} result = {"errList": result["data"]["errMsg"]["errList"]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
err_list = "平台套包编号【{}】 在待启用记录里不存在!".format(group_code) err_list = "平台套包编号【{}】 在待启用记录里不存在!".format(group_code)
check_dict = commonFuc().get_business_data(module, "checkDict11", err_list) check_dict = commonFuc().get_business_data(module, "checkDict11", err_list)
......
...@@ -61,11 +61,14 @@ files = {"file": file} ...@@ -61,11 +61,14 @@ files = {"file": file}
# 发送请求 # 发送请求
result = requests.post(url, files=files, headers=headers, data=request_body) result = requests.post(url, files=files, headers=headers, data=request_body)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
file.close() file.close()
# 截取结果中errList信息 # 截取结果中errList信息
result = {"errList": result["data"]["errMsg"]["errList"]} result = {"errList": result["data"]["errMsg"]["errList"]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
err_list = "平台套包编号【{}】 在待启用记录里不存在!".format(group_code) err_list = "平台套包编号【{}】 在待启用记录里不存在!".format(group_code)
check_dict = commonFuc().get_business_data(module, "checkDict11", err_list) check_dict = commonFuc().get_business_data(module, "checkDict11", err_list)
......
...@@ -72,6 +72,8 @@ request_body = {"groupIds": [group_id], "type": 0, "remarks": ""} ...@@ -72,6 +72,8 @@ request_body = {"groupIds": [group_id], "type": 0, "remarks": ""}
# 发送请求 # 发送请求
result = requests.post(url, headers=headers, json=request_body) result = requests.post(url, headers=headers, json=request_body)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
# 数据库操作 # 数据库操作
...@@ -82,7 +84,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -82,7 +84,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询套包状态 # 数据库查询套包状态
sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id) sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id)
result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]} result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict6") check_dict = commonFuc().get_business_data(module, "checkDict6")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -47,8 +47,13 @@ request_body = {"manufacturerGroupName": "", "manufacturerGroupCode": "", "group ...@@ -47,8 +47,13 @@ request_body = {"manufacturerGroupName": "", "manufacturerGroupCode": "", "group
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
print(result)
result["api_time"] = api_time
# print(result)
if result["success"]: if result["success"]:
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict20") check_dict = commonFuc().get_business_data(module, "checkDict20")
......
...@@ -45,6 +45,9 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, ...@@ -45,6 +45,9 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module,
# 发送请求 # 发送请求
result = requests.get(url, headers=headers) result = requests.get(url, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
# 数据库操作 # 数据库操作
...@@ -55,7 +58,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -55,7 +58,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询套包状态 # 数据库查询套包状态
sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id) sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id)
result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]} result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict21") check_dict = commonFuc().get_business_data(module, "checkDict21")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -33,6 +33,9 @@ request_body = commonFuc().get_business_data(module, "payload46") ...@@ -33,6 +33,9 @@ request_body = commonFuc().get_business_data(module, "payload46")
""" """
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
# 获取创建需求成功后需求单信息 # 获取创建需求成功后需求单信息
demand_parent_code = result["data"]["国药集团上海医疗器械有限公司"]["demandParentCode"] demand_parent_code = result["data"]["国药集团上海医疗器械有限公司"]["demandParentCode"]
...@@ -40,7 +43,7 @@ demand_parent_id = result["data"]["国药集团上海医疗器械有限公司"][ ...@@ -40,7 +43,7 @@ demand_parent_id = result["data"]["国药集团上海医疗器械有限公司"][
# 实际结果 # 实际结果
result = {"demandParentCode": demand_parent_code} result = {"demandParentCode": demand_parent_code}
result["api_time"] = api_time
# 数据库操作 # 数据库操作
mysql_handle = mySql() mysql_handle = mySql()
# 获取conf.ini文件中配置的数据库信息 # 获取conf.ini文件中配置的数据库信息
...@@ -52,6 +55,6 @@ sql = "SELECT t.demandParentCode FROM `cmdc-order`.tc_demand t WHERE demandParen ...@@ -52,6 +55,6 @@ sql = "SELECT t.demandParentCode FROM `cmdc-order`.tc_demand t WHERE demandParen
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict46", check_dict = commonFuc().get_business_data(module, "checkDict46",
mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]) mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0])
print(check_dict) # print(check_dict)
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
commonFuc().check_result(check_dict, result) commonFuc().check_result(check_dict, result)
...@@ -52,8 +52,11 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url_buy ...@@ -52,8 +52,11 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url_buy
request_body = commonFuc().get_business_data(module, "payload_buyercart") request_body = commonFuc().get_business_data(module, "payload_buyercart")
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
print(result) # print(result)
# 过滤查找添加的单品 # 过滤查找添加的单品
for i in result["data"]["list"]: for i in result["data"]["list"]:
...@@ -62,7 +65,8 @@ for i in result["data"]["list"]: ...@@ -62,7 +65,8 @@ for i in result["data"]["list"]:
if j["buyerCartId"] == 19177: if j["buyerCartId"] == 19177:
result = {"groupPrice": j["groupPrice"], "timeStr": j["timeStr"], "documentNo": j["documentNo"], result = {"groupPrice": j["groupPrice"], "timeStr": j["timeStr"], "documentNo": j["documentNo"],
"buyCartNum": 5} "buyCartNum": 5}
print(result) result["api_time"] = api_time
# print(result)
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict_buyercart") check_dict = commonFuc().get_business_data(module, "checkDict_buyercart")
# # 断言实际结果中是否包含预期结果的内容 # # 断言实际结果中是否包含预期结果的内容
......
...@@ -45,8 +45,13 @@ request_body = commonFuc().get_business_data(module, "payload42", fresenius_pric ...@@ -45,8 +45,13 @@ request_body = commonFuc().get_business_data(module, "payload42", fresenius_pric
# 发送请求 # 发送请求
result = requests.get(url, params=request_body, headers=headers) result = requests.get(url, params=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# 进行相应判断,当success为true时,说明超限额,否则未超限额 # 进行相应判断,当success为true时,说明超限额,否则未超限额
if result["success"]: if result["success"]:
# 获取结果中限购数量 # 获取结果中限购数量
......
...@@ -83,7 +83,12 @@ request_body = {"manufacturerGroupName": "", "manufacturerGroupCode": "", "group ...@@ -83,7 +83,12 @@ request_body = {"manufacturerGroupName": "", "manufacturerGroupCode": "", "group
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
if result["success"]: if result["success"]:
# 数据库操作 # 数据库操作
...@@ -94,10 +99,12 @@ if result["success"]: ...@@ -94,10 +99,12 @@ if result["success"]:
# 数据库查询新增特价单品 # 数据库查询新增特价单品
sql = "SELECT t.groupId FROM `cmdc-order`.tc_fresenius_agreement_price t " \ sql = "SELECT t.groupId FROM `cmdc-order`.tc_fresenius_agreement_price t " \
"WHERE customerCode = {} and documentNo = '{}';".format(customer_code, ref_random) "WHERE customerCode = {} and documentNo = '{}';".format(customer_code, ref_random)
print(sql) # print(sql)
total = len(mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)) total = len(mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql))
result = {"total": total} result = {"total": total}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict17") check_dict = commonFuc().get_business_data(module, "checkDict17")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -36,6 +36,9 @@ request_body = commonFuc().get_business_data(module, "payload1") ...@@ -36,6 +36,9 @@ request_body = commonFuc().get_business_data(module, "payload1")
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
# 获取特价单品总数量 # 获取特价单品总数量
...@@ -49,6 +52,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -49,6 +52,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询特价单品数量 # 数据库查询特价单品数量
sql = "SELECT t.groupId FROM `cmdc-order`.tc_fresenius_group t WHERE groupType = 1 and companyCode = 00111;" sql = "SELECT t.groupId FROM `cmdc-order`.tc_fresenius_group t WHERE groupType = 1 and companyCode = 00111;"
total = len(mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)) total = len(mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql))
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict1", total) check_dict = commonFuc().get_business_data(module, "checkDict1", total)
......
...@@ -32,8 +32,12 @@ request_body = commonFuc().get_business_data(module, "customer_payload") ...@@ -32,8 +32,12 @@ request_body = commonFuc().get_business_data(module, "customer_payload")
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
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, "checkDict15") check_dict = commonFuc().get_business_data(module, "checkDict15")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
......
...@@ -39,11 +39,16 @@ request_body = commonFuc().get_business_data(module, "payload38") ...@@ -39,11 +39,16 @@ request_body = commonFuc().get_business_data(module, "payload38")
# 发送请求 # 发送请求
result = requests.get(url, params=request_body, headers=headers) result = requests.get(url, params=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
print(result) # print(result)
result = {"productCode": result["data"][0]["productCode"]} result = {"productCode": result["data"][0]["productCode"]}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict38") check_dict = commonFuc().get_business_data(module, "checkDict38")
# 断言实际结果中是否包含预期结果的内容 # 断言实际结果中是否包含预期结果的内容
commonFuc().check_result(check_dict, result) commonFuc().check_result(check_dict, result)
...@@ -57,6 +57,8 @@ request_body = {"groupIds": [group_id], "type": 1} ...@@ -57,6 +57,8 @@ request_body = {"groupIds": [group_id], "type": 1}
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
# 数据库操作 # 数据库操作
mysql_handle = mySql() mysql_handle = mySql()
# 获取conf.ini文件中配置的数据库信息 # 获取conf.ini文件中配置的数据库信息
...@@ -65,7 +67,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -65,7 +67,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询套包状态 # 数据库查询套包状态
sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id) sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id)
result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]} result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]}
result["api_time"] = api_time
# 获取 # 获取
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict7") check_dict = commonFuc().get_business_data(module, "checkDict7")
......
...@@ -46,6 +46,9 @@ request_body = {"groupIds": [group_id], "type": 0, "remarks": ""} ...@@ -46,6 +46,9 @@ request_body = {"groupIds": [group_id], "type": 0, "remarks": ""}
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
# 数据库操作 # 数据库操作
mysql_handle = mySql() mysql_handle = mySql()
# 获取conf.ini文件中配置的数据库信息 # 获取conf.ini文件中配置的数据库信息
...@@ -54,6 +57,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db") ...@@ -54,6 +57,7 @@ host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询套包状态 # 数据库查询套包状态
sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id) sql = "SELECT t.status FROM `cmdc-order`.tc_fresenius_group t WHERE groupId = {}".format(group_id)
result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]} result = {"status": mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql)[0][0]}
result["api_time"] = api_time
# 获取 # 获取
# 获取预期结果 # 获取预期结果
......
...@@ -42,7 +42,10 @@ files = {"file": file} ...@@ -42,7 +42,10 @@ files = {"file": file}
# 发送请求 # 发送请求
result = requests.post(url, files=files, headers=headers) result = requests.post(url, files=files, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
# 获取预期结果 # 获取预期结果
......
...@@ -48,6 +48,8 @@ request_body = commonFuc().get_business_data(module, "payload10", demand_code) ...@@ -48,6 +48,8 @@ request_body = commonFuc().get_business_data(module, "payload10", demand_code)
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
# result = json.loads(result.content) # result = json.loads(result.content)
# print(result) # print(result)
...@@ -62,7 +64,7 @@ with open(file_path, 'wb') as f: ...@@ -62,7 +64,7 @@ with open(file_path, 'wb') as f:
# 获取文件中订单编号 # 获取文件中订单编号
excel = HandleExcel(file_path, "Sheet1") excel = HandleExcel(file_path, "Sheet1")
result = {"demandCode": excel.read_data()[0].get("订单编号")} result = {"demandCode": excel.read_data()[0].get("订单编号")}
result["api_time"] = api_time
# 获取预期结果 # 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict10", demand_code) check_dict = commonFuc().get_business_data(module, "checkDict10", demand_code)
# print(check_dict) # print(check_dict)
......
...@@ -65,7 +65,10 @@ request_body = commonFuc().get_business_data(module, "payload7", seller_companyC ...@@ -65,7 +65,10 @@ request_body = commonFuc().get_business_data(module, "payload7", seller_companyC
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
# 获取查询结果中订单编号 # 获取查询结果中订单编号
......
...@@ -57,7 +57,10 @@ request_body = commonFuc().get_business_data(module, "payload9", demand_code, ma ...@@ -57,7 +57,10 @@ request_body = commonFuc().get_business_data(module, "payload9", demand_code, ma
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
# 获取商品行信息中商品信息 # 获取商品行信息中商品信息
......
...@@ -34,7 +34,10 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url1") ...@@ -34,7 +34,10 @@ url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url1")
# 发送请求 # 发送请求
result = requests.get(url, headers=headers) result = requests.get(url, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
# 获取公司数量 # 获取公司数量
result = {"total": len(result["data"])} result = {"total": len(result["data"])}
......
...@@ -34,7 +34,10 @@ request_body = commonFuc().get_business_data(module, "payload4") ...@@ -34,7 +34,10 @@ request_body = commonFuc().get_business_data(module, "payload4")
# 发送请求 # 发送请求
result = requests.post(url, json=request_body, headers=headers) result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content) result = json.loads(result.content)
result["api_time"] = api_time
# print(result) # print(result)
# 获取预期结果 # 获取预期结果
......
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