def check_args(ns={}): if not ns: return {"status": False, "msg": "api args is None"} check_key = [ "name", "bandwidth_price", "stored_price", "ip_price", "user_id", ] for k in check_key: if not ns.get(k, None): return f"the key is null, please check key:{k}" else: if len(ns[k]) == 0: return f"the len is 0, please check key:{k}" return "" async def create_store(ns={}): """ 保存合同 :param ns: :return: """ error = check_args(ns) if error: return {"status": False, "msg": error} db = DBPools() async with db.sqlorContext('kboss') as sor: tablename = "lease_store_data" data = { "id": uuid(), "name": ns.get("name"), "location": ns.get("location",None), "address": ns.get("address",None), "bandwidth_price": ns.get("bandwidth_price"), "stored_price": ns.get("stored_price"), "ip_price": ns.get("ip_price"), "user_id": ns.get("user_id"), } await sor.C(tablename, data) return {"status": True, "msg": "save ok","id":data["id"]} ret = await create_store(params_kw) return ret