diff --git a/app/api/endpoints/merchant_product.py b/app/api/endpoints/merchant_product.py index 0bea133..76ee101 100644 --- a/app/api/endpoints/merchant_product.py +++ b/app/api/endpoints/merchant_product.py @@ -76,6 +76,7 @@ async def update_product( @router.get("/list", response_model=ResponseModel) async def list_merchant_products( merchant_id: Optional[int] = None, + community_id: Optional[int] = None, skip: int = 0, limit: int = 20, db: Session = Depends(get_db) @@ -89,6 +90,9 @@ async def list_merchant_products( # 如果指定了商家ID,添加筛选条件 if merchant_id: query = query.filter(MerchantProductDB.merchant_id == merchant_id) + + if community_id: + query = query.filter(MerchantProductDB.merchant.has(community_id=community_id)) total = query.count() results = query.order_by( diff --git a/jobs.sqlite b/jobs.sqlite index 557e098..ea46daf 100644 Binary files a/jobs.sqlite and b/jobs.sqlite differ