测试之路 pytest接口自动化框架扩展-创建用例文件

# 创建用例文件
def create_case_file(filename):
    # 获取接口字段参数
    apis = get_ms_data(filename)
    # 获取当前已经存在的接口
    case_list = check_case_list("testcase/sp_meeting")
    # 创建test.py用例代码
    create_case_clasee()
    # 遍历参数，并按照模板将参数写入
    for key, value in apis.items():
         # 初始化模板
        caseinfo = CASETEMPLATE
        if value["api_name"] + ".yaml" not in case_list:
            create_case(value["api_name"])
            caseinfo["api_name"] = value.pop("api_name")
            caseinfo["request"]["method"] = value.pop("method")
            caseinfo["request"]["url"] = key
            caseinfo["request"]["base_url"] = GetConfig().read_base_url("base_url_224")
            request_type = value.pop("content_type")
            if caseinfo["request"]["method"].lower() in ["get", "put", "delete"]:
                par_datas = join_dict(value)
                # 调用生成par参数方法
                parameterize = create_case_value(par_datas)
                caseinfo["request"]["params"] = {}
                for i in range(1, len(parameterize[0])):
                    if "_" in parameterize[0][i]:
                        spli_list = parameterize[0][i].split("_")
                        data_key = spli_list[0]
                        data_value = spli_list[1]
                        caseinfo["request"]["params"].update({data_key: {
                            data_value: "$ddt{" + str(parameterize[0][i]) + "}"
                        }})
                    else:
                        caseinfo["request"]["params"].update({
                            parameterize[0][i]: "$ddt{" + str(parameterize[0][i]) + "}"
                        })
                caseinfo["content_type"] = request_type
                caseinfo["parameterize"] = parameterize
            elif caseinfo["request"]["method"].lower() == "post":
                params_type = "json"
                if 'params' in caseinfo["request"]:
                    del caseinfo["request"]["params"]
                if request_type == "application/text":
                    params_type = "params"
                if NODE:
                    caseinfo["request"][params_type] = {"root": {}}
                else:
                    caseinfo["request"][params_type] = {}
                datas = join_dict(value)
                 # 调用生成json参数方法
                parameterize = create_case_value(datas)
                for i in range(1, len(parameterize[0])):
                    if NODE:
                        if "_" in parameterize[0][i]:
                            spli_list = parameterize[0][i].split("_")
                            data_key = spli_list[0]
                            data_value = spli_list[1]
                            caseinfo["request"][params_type]["root"].update({data_key: {
                                data_value: "$ddt{" + str(parameterize[0][i]) + "}"
                            }})
                        else:
                            caseinfo["request"][params_type]["root"].update({
                                parameterize[0][i]: "$ddt{" + str(parameterize[0][i]) + "}"
                            })
                    else:
                        if "_" in parameterize[0][i]:
                            spli_list = parameterize[0][i].split("_")
                            data_key = spli_list[0]
                            data_value = spli_list[1]
                            caseinfo["request"][params_type].update({data_key: {
                                data_value: "$ddt{" + str(parameterize[0][i]) + "}"
                            }})
                        else:
                            caseinfo["request"][params_type].update({
                                parameterize[0][i]: "$ddt{" + str(parameterize[0][i]) + "}"
                            })
                caseinfo["content_type"] = "application/json"
                caseinfo["parameterize"] = parameterize
            # 最后将参数写入yaml文件中
            write_yaml("testcase/sp_meeting/" + caseinfo["api_name"] + ".yaml", [caseinfo])
            return 200
        else:
            print_log("接口已存在")
            return 500