def check_args(ns={}): if not ns: return {"status": False, "msg": "api args is None"} check_key = [ "id", "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 update_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" ns["update_at"] = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") try: await sor.U(tablename, ns) return {"status": True, "msg": "save ok"} except Exception as e: if " for key " in str(e): return {"status": False, "msg": f"更新失败,仓库名重复"} return {"status": False, "msg": f"更新失败,{e}"} ret = await update_store(params_kw) return ret