async def update_product(ns={}):
    """
    更新租赁产品(续期)
    :param ns:
    :return:
    """
    db = DBPools()
    data = ns.get("product")
    if not data:
        return {"status": False, "msg": "product is None"}
    async with db.sqlorContext('kboss') as sor:
        data["update_at"] = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
        await sor.U("lease_product_data", data)

        # 机器是否续期
        if data['lease_end_time'] > datetime.datetime.now().strftime("%Y-%m-%d"):
            sql = "UPDATE lease_server_data SET `status` = '0' ,update_at=${update_at}$ WHERE `status` = '2'"
            await sor.sqlExe(sql, {"update_at": data["update_at"]})

    return {"status": True}


ret = await update_product(params_kw)
return ret