This commit is contained in:
jxxghp
2025-08-11 16:41:29 +08:00
parent 6230f55116
commit e505b5c85f
+5 -1
View File
@@ -78,10 +78,14 @@ async def create_subscribe(
title = None title = None
# 订阅用户 # 订阅用户
subscribe_in.username = current_user.name subscribe_in.username = current_user.name
# 转化为字典
subscribe_dict = subscribe_in.dict()
if subscribe_in.id:
subscribe_dict.pop("id", None)
sid, message = await SubscribeChain().async_add(mtype=mtype, sid, message = await SubscribeChain().async_add(mtype=mtype,
title=title, title=title,
exist_ok=True, exist_ok=True,
**subscribe_in.dict()) **subscribe_dict)
return schemas.Response( return schemas.Response(
success=bool(sid), message=message, data={"id": sid} success=bool(sid), message=message, data={"id": sid}
) )