# 获取审批流参数配置
async def get_apv_flow(ns={}):
    orgid = ns.get("orgid")
    business_id = ns.get("business_id")
    if not orgid or not business_id:
        return {"status": False, "msg": "orgid or business_id is None"}
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        data = await sor.R("apv_flow", {"orgid": orgid, "del_flg": 0, "business_id": business_id})
    if not data:
        return {"status": True, "data":{}}
    flow = {}
    flow["orgid"] = data[0]["orgid"]
    flow["user_id"] = data[0]["user_id"]
    flow["dd_template_id"] = data[0]["dd_template_id"]
    flow["del_flg"] = data[0]["del_flg"]
    flow["levels"] = {}
    for i in data:
        l_id = str(i["level"])
        now_level = flow["levels"].get(l_id, None)
        if now_level:
            now_level["apv_dd_user_phone"][i["apv_dd_user_id_index"]] = i["apv_dd_user_phone"]
            now_level["mode"] = i["mode"]
        else:
            user_data = {
                "apv_dd_user_phone": {
                    i["apv_dd_user_id_index"]: i["apv_dd_user_phone"]
                },
                "mode": i["mode"]
            }
            flow["levels"][l_id] = user_data
    data = flow
    return {"status": True, "data": data}

ret = await get_apv_flow(params_kw)
return ret