对传入参数merchantid 进行存在检测。
This commit is contained in:
parent
2e278a4025
commit
fe41fcc12b
@ -11,16 +11,26 @@ from app.models.database import get_db
|
|||||||
from app.api.deps import get_admin_user
|
from app.api.deps import get_admin_user
|
||||||
from app.models.user import UserDB
|
from app.models.user import UserDB
|
||||||
from app.core.response import success_response, error_response, ResponseModel
|
from app.core.response import success_response, error_response, ResponseModel
|
||||||
|
from app.models.merchant import MerchantDB
|
||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
@router.post("", response_model=ResponseModel)
|
@router.post("", response_model=ResponseModel)
|
||||||
async def create_product(
|
async def create_merchant_product(
|
||||||
product: MerchantProductCreate,
|
product: MerchantProductCreate,
|
||||||
db: Session = Depends(get_db),
|
db: Session = Depends(get_db),
|
||||||
admin: UserDB = Depends(get_admin_user)
|
admin: UserDB = Depends(get_admin_user)
|
||||||
):
|
):
|
||||||
"""创建商家产品(管理员)"""
|
"""创建商家产品(管理员)"""
|
||||||
|
|
||||||
|
# 检查商家是否存在
|
||||||
|
merchant = db.query(MerchantDB).filter(
|
||||||
|
MerchantDB.id == product.merchant_id
|
||||||
|
).first()
|
||||||
|
|
||||||
|
if not merchant:
|
||||||
|
return error_response(code=404, message="商家不存在")
|
||||||
|
|
||||||
db_product = MerchantProductDB(**product.model_dump())
|
db_product = MerchantProductDB(**product.model_dump())
|
||||||
db.add(db_product)
|
db.add(db_product)
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user