diff --git a/app/api/endpoints/merchant_product.py b/app/api/endpoints/merchant_product.py index 3af4927..7ae1500 100644 --- a/app/api/endpoints/merchant_product.py +++ b/app/api/endpoints/merchant_product.py @@ -11,16 +11,26 @@ from app.models.database import get_db from app.api.deps import get_admin_user from app.models.user import UserDB from app.core.response import success_response, error_response, ResponseModel +from app.models.merchant import MerchantDB router = APIRouter() @router.post("", response_model=ResponseModel) -async def create_product( +async def create_merchant_product( product: MerchantProductCreate, db: Session = Depends(get_db), 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.add(db_product)