This commit is contained in:
aaron 2025-02-26 18:44:08 +08:00
parent 442d6f0862
commit 05d67751b9

View File

@ -66,12 +66,12 @@ async def wechat_phone_login(
if not phone: if not phone:
return error_response(code=400, message="手机号为空") return error_response(code=400, message="手机号为空")
# 获取企业微信的 userid # # 获取企业微信的 userid
wecom_client = WecomClient() # wecom_client = WecomClient()
wecom_info = await wecom_client.miniprogram_to_userid(openid) # wecom_info = await wecom_client.miniprogram_to_userid(openid)
print(f"获取到的企业微信用户信息: {wecom_info}") # print(f"获取到的企业微信用户信息: {wecom_info}")
if not wecom_info: # if not wecom_info:
return error_response(code=400, message="获取企业微信用户id失败") # return error_response(code=400, message="获取企业微信用户id失败")
# 查找或创建用户 # 查找或创建用户
user = db.query(UserDB).filter(UserDB.phone == phone).first() user = db.query(UserDB).filter(UserDB.phone == phone).first()
@ -87,8 +87,8 @@ async def wechat_phone_login(
password=get_password_hash("123456"), password=get_password_hash("123456"),
openid=openid, # 保存 openid openid=openid, # 保存 openid
unionid=unionid, # 保存 unionid unionid=unionid, # 保存 unionid
wecom_userid=wecom_info.get("userid"), # wecom_userid=wecom_info.get("userid"),
wecom_pending_id=wecom_info.get("pending_id") # wecom_pending_id=wecom_info.get("pending_id")
) )
db.add(user) db.add(user)
db.flush() db.flush()