fix: 修复db本地连接

This commit is contained in:
hackrobot
2024-03-20 21:31:43 +08:00
parent 8968cc7c87
commit e4ddd6d277
9 changed files with 28 additions and 10 deletions

13
main.py
View File

@@ -48,6 +48,9 @@ async def root():
@app.post("/users/")
# schemas.UserCreate决定了swagger文档
def create_user(user: schemas.User, db: Session = Depends(get_db)):
print('user',user)
print('typeuser',type(user))
db_user = crud.create_user(db, user)
if db_user:
raise HTTPException(status_code=400,
@@ -212,8 +215,9 @@ def kp(event_data):
# 将好友信息=>保存到数据库
newFriendDict=WXBotService.get_friend_info(account_wxid, wxid)
print('newFriendDict[data]---',newFriendDict['data'])
# print(type(newFriendDict['data']))
crud.create_user(db=get_db(),user=json.dumps(newFriendDict['data']))
userClass=models.User(**(newFriendDict['data']))
print('userClass====',type(userClass))
crud.create_user(db=SessionLocal(),user=userClass)
elif msg_type == 3: # 3 图片消息
@@ -237,8 +241,9 @@ def kp(event_data):
xml_msg.get('scene'))
newFriendWxid=xml_msg.get('alias')
# 将好友信息=>保存到数据库
newFriendDict=WXBotService.get_friend_info(account_wxid, newFriendWxid)
crud.create_user(db=get_db(),user=newFriendDict)
# newFriendDict=WXBotService.get_friend_info(account_wxid, newFriendWxid)
# userClass=models.User(**(newFriendDict['data']))
# crud.create_user(db= SessionLocal(),user=userClass)
elif msg_type == 42: # 42 名片消息
xml_msg = ET.fromstring(msg)