ns = params_kw.copy() for k,v in ns.items(): if v == "NaN" or v == "null": ns[k] = None if "page" not in ns: ns["page"] = 1 ns["sort"] = "created_at" ns["order"] = "desc" env = request._run_ns async with get_sor_context(env, "tenant") as sor: sql = """SELECT a.*, b.orgname as sub_distributor_id_text FROM tenant_domain a LEFT JOIN sage.organization b ON a.resellerid = b.id ORDER BY a.created_at DESC""" recs = await sor.sqlPaging(sql, ns) rows = [] for r in recs["rows"]: status_text = '启用' if r.status == 'active' else ('停用' if r.status == 'inactive' else r.status) rows.append({ "id": r.id, "domain": r.domain, "resellerid": r.resellerid, "sub_distributor_id": r.resellerid, "sub_distributor_id_text": r.sub_distributor_id_text or r.resellerid, "orgid": r.orgid, "status": status_text, "created_at": str(r.created_at), "updated_at": str(r.updated_at) }) return {"total": recs["total"], "rows": rows}