This commit is contained in:
aaron 2025-02-25 21:11:58 +08:00
parent 9317e6776b
commit bb28b7015f

View File

@ -64,16 +64,23 @@ async def handle_server(request: Request):
# 获取用户信息 # 获取用户信息
user_info = await mp_client.get_user_info(from_user) user_info = await mp_client.get_user_info(from_user)
print(f"微信公众号用户信息:{user_info}") print(f"微信公众号用户信息:{user_info}")
if user_info:
# 查找或创建用户 # 已关注进入聊天界面的事件
user = db.query(UserDB).filter( elif event == 'scancode_push':
UserDB.unionid == user_info.get('unionid') # 获取用户信息
).first() user_info = await mp_client.get_user_info(from_user)
print(f"微信公众号用户信息:{user_info}")
if user:
# 更新用户信息 if user_info:
user.mp_openid = from_user # 查找或创建用户
db.commit() user = db.query(UserDB).filter(
UserDB.unionid == user_info.get('unionid')
).first()
if user:
# 更新用户信息
user.mp_openid = from_user
db.commit()
return Response(content="", media_type="text/plain") return Response(content="", media_type="text/plain")