An error occurred while loading the file. Please try again.
An error occurred while loading the file. Please try again.
An error occurred while loading the file. Please try again.
-
liguangyu06 authored6a17afd1
# -*- encoding=utf8 -*-
__author__ = "liguangyu"
"""
case_tag:cmdc_api,cmdc特价单品新增功能验证,2264,2264-60,sit,bs
主数据平台:后台运营系统客户列表查询、商品列表查询、特价单品新增等接口
"""
from common.common_func import commonFuc
from air_case.cmdc_login.后台管理系统登录.后台管理系统登录 import CmdcDoLogin
from datetime import timedelta, date
from common.db.db import mySql
import random
import requests
import json
import uuid
module = "cmdc_special_fresenius_group"
# 第一步登录后台运营平台获取cmdc_access_token
# 获取登录所需账号密码
username = commonFuc().get_business_data(module, "username2")
password = commonFuc().get_business_data(module, "password2")
# 获取登录后Cmdc_access_token
cmdc_access_token = CmdcDoLogin(username, password).get_token()
headers = commonFuc().get_business_data(module, "json_headers", cmdc_access_token)
# 第二步客户列表获取
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "customer_list_url")
request_body = commonFuc().get_business_data(module, "customer_payload")
# 发送请求
result = requests.post(url, json=request_body, headers=headers)
result = json.loads(result.content)
# 生成随机数
customer_quantity = random.randint(1, len(result["data"]["list"])-1)
# 随机生成唯一字符串用于ref
ref_random = str(uuid.uuid4())
# 客户信息获取
customer_code = result["data"]["list"][customer_quantity]["customerCode"]
customer_name = result["data"]["list"][customer_quantity]["customerName"]
user_name = result["data"]["list"][customer_quantity]["userName"]
# 第三步商品信息获取
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "product_list")
request_body = commonFuc().get_business_data(module, "product_payload")
# 发送请求
result = requests.post(url, json=request_body, headers=headers)
result = json.loads(result.content)
# 获取商品信息
product_detail = result["data"]["list"][random.randint(1, len(result["data"]["list"]))-1]
product_detail["activityUnitAmount"] = customer_quantity
# 随机生成日期
start_date = date(2000, 1, 1)
end_date = date.today()
def random_date(start, end):
delta = end - start
random_days = random.randint(0, delta.days)
return start + timedelta(days=random_days)
random_date = random_date(start_date, end_date)
# 第四步特价单品新增
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "url17")
request_body = {"manufacturerGroupName": "", "manufacturerGroupCode": "", "groupName": "", "limitPurchase": "",
"isLimit": 0, "products": [product_detail], "customerCode": customer_code, "userName": user_name,
7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
"customerName": customer_name, "times": [str(start_date), str(random_date)],
"documentNo": ref_random,
"supplementNo": customer_quantity, "salesProvince": customer_quantity, "salesArea": customer_quantity,
"applicationType": customer_quantity, "effectiveTime": str(start_date),
"expirationTime": str(random_date),
"freseniusProduct": product_detail}
"""
场景: 特价单品新增功能验证
用例名称:特价单品新增功能验证
输出:{"total": 1}
"""
# 发送请求
result = requests.post(url, json=request_body, headers=headers)
# 获取接口响应时间
api_time = float(result.elapsed.total_seconds())
result = json.loads(result.content)
result["api_time"] = api_time
# print(result)
if result["success"]:
# 数据库操作
mysql_handle = mySql()
# 获取conf.ini文件中配置的数据库信息
host, port, user, pwd = mysql_handle.getConf(db="cmdc_db")
# 数据库查询新增特价单品
sql = "SELECT t.groupId FROM `cmdc-order`.tc_fresenius_agreement_price t " \
"WHERE customerCode = {} and documentNo = '{}';".format(customer_code, ref_random)
# print(sql)
total = len(mysql_handle.selectSql(host, port, user, pwd, "cmdc-order", sql))
result = {"total": total}
result["api_time"] = api_time
# 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict17")
# 断言实际结果中是否包含预期结果的内容
commonFuc().check_result(check_dict, result)
else:
# 获取预期结果
check_dict = commonFuc().get_business_data(module, "checkDict17_1")
# 断言实际结果中是否包含预期结果的内容
commonFuc().check_result(check_dict, result)