diff --git a/app/api/endpoints/mp.py b/app/api/endpoints/mp.py index 7e0981f..fb05693 100644 --- a/app/api/endpoints/mp.py +++ b/app/api/endpoints/mp.py @@ -64,16 +64,23 @@ async def handle_server(request: Request): # 获取用户信息 user_info = await mp_client.get_user_info(from_user) print(f"微信公众号用户信息:{user_info}") - if user_info: - # 查找或创建用户 - user = db.query(UserDB).filter( - UserDB.unionid == user_info.get('unionid') - ).first() - - if user: - # 更新用户信息 - user.mp_openid = from_user - db.commit() + + # 已关注进入聊天界面的事件 + elif event == 'scancode_push': + # 获取用户信息 + user_info = await mp_client.get_user_info(from_user) + print(f"微信公众号用户信息:{user_info}") + + if user_info: + # 查找或创建用户 + 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")