服务端代码：
- 1、创建数据库连接对象
- 2、初始化数据库
- 3、声明一个上下文
- 4、挂载用户相关的路由，这里主要由
- 用户登录接口
- 用户注册注册
- 获取用户列表接口
- 激活指定用户接口
- 5、启动服务
import mcrud
import api
import amauth
import env
import contextlib
env.load("../.env")
db = mcrud.new_env()
amauth.data.init(db, is_init_role=True, is_init_auth=True)
@contextlib.asynccontextmanager
async def lifespan(app):
yield {"db": db}
app = api.Api(
routes=[
api.resp.post("/auth/user/login", amauth.user.login),
api.resp.post("/auth/user/register", amauth.user.register),
api.resp.get("/auth/user", amauth.user.get_users),
api.resp.put("/auth/user/active/{id}", amauth.user.active),
],
lifespan=lifespan,
)
if __name__ == '__main__':
app.run()
测试代码：
- 1、我们注册一个叫做zhangdapeng1的用户
- 2、查询所有的用户
- 3、我们从查询的所有用户中，提取出名字叫做zhangdapeng1的用户的ID。同时，我们要观察，此时这个用户的激活状态是什么？
- 4、我们根据这个ID去调用激活用户的接口，激活指定ID的用户
- 5、再次查询所有的用户。此时，我们再次观察，这个用户的激活状态是什么？
import req
# 注册
target_url = "http://127.0.0.1:8888/auth/user/register"
data = {
"username": "zhangdapeng1",
"password": "zhangdapeng1",
"re_password": "zhangdapeng1",
}
resp = req.post(target_url, json=data)
print(resp.json())
# 查询所有用户
target_url = "http://127.0.0.1:8888/auth/user"
resp = req.get(target_url)
print(resp.json())
# 获取id
data = resp.json()
user_id = None
for u in data.get("data"):
if u.get("username") == "zhangdapeng1":
user_id = u.get("id")
break
# 激活
target_url = "http://127.0.0.1:8888/auth/user/active/" + user_id
resp = req.put(target_url)
print(resp.json())
# 查询所有用户
target_url = "http://127.0.0.1:8888/auth/user"
resp = req.get(target_url)
print(resp.json())
输出结果：
- 1、注册：返回True表明成功
- 2、查询所有的用户：由zhangdapeng1的用户，ID是1788925660358500352，active激活状态是0
- 3、根据ID激活用户：返回True，表明成功
- 4、再次查询所有的用户：由zhangdapeng1的用户，ID是1788925660358500352，active激活状态是1
{'msg': 'success', 'status': True, 'code': 10000}
{'msg': 'success', 'status': True, 'code': 10000, 'data': [{'id': '1788925660358500352', 'username': 'zhangdapeng1', 'real_name': None, 'mobile': None, 'email': None, 'avatar': None, 'active': 0, 'status': 0, 'add_time': '2024-05-10 13:34:47', 'update_time': '2024-05-10 13:34:47', 'login_time': None}, {'id': '1788925643526758400', 'username': 'zhangdapeng', 'real_name': None, 'mobile': None, 'email': None, 'avatar': None, 'active': 1, 'status': 0, 'add_time': '2024-05-10 13:34:43', 'update_time': '2024-05-10 13:34:43', 'login_time': None}]}
{'msg': 'success', 'status': True, 'code': 10000}
{'msg': 'success', 'status': True, 'code': 10000, 'data': [{'id': '1788925660358500352', 'username': 'zhangdapeng1', 'real_name': None, 'mobile': None, 'email': None, 'avatar': None, 'active': 1, 'status': 0, 'add_time': '2024-05-10 13:34:47', 'update_time': '2024-05-10 13:34:47', 'login_time': None}, {'id': '1788925643526758400', 'username': 'zhangdapeng', 'real_name': None, 'mobile': None, 'email': None, 'avatar': None, 'active': 1, 'status': 0, 'add_time': '2024-05-10 13:34:43', 'update_time': '2024-05-10 13:34:43', 'login_time': None}]}
总结：如果我们想要使用zdppy_amauth这个框架去实现一个激活用户的接口，那么我们只需要引入amauth.user.active方法并将其使用zdppy_api这个框架挂载到指定路径的接口即可。这个方法，需要传入一个叫做id的路径参数，比如路径可以设计成/auth/user/active/{id}。这个接口方法，除了路径参数以外，不需要接收任何其他参数。
