feat: 주문 export의 필터 추가

Author: MU-Software

app/admin_api/filtersets/shop/orders.py

@@ -30,6 +30,7 @@ class OrderAdminFilterSet(filters.FilterSet):
     product_id = filters.BaseCSVFilter(method="filter_by_active_opr_product_id")
     category_id = filters.BaseCSVFilter(method="filter_by_active_opr_category_id")
     category_group_id = filters.BaseCSVFilter(method="filter_by_active_opr_category_group_id")
+    event_id = filters.BaseCSVFilter(method="filter_by_active_opr_event_id")
 
     price_min = filters.NumberFilter(field_name="latest_price", lookup_expr="gte")
     price_max = filters.NumberFilter(field_name="latest_price", lookup_expr="lte")
@@ -46,6 +47,9 @@ def filter_by_active_opr_category_id(self, qs: QuerySet[Order], n: str, vs: list
     def filter_by_active_opr_category_group_id(self, qs: QuerySet[Order], n: str, v: list[str]) -> QuerySet[Order]:
         return self._filter_by_active_opr_exists(qs, product__category__group_id__in=v) if v else qs
 
+    def filter_by_active_opr_event_id(self, qs: QuerySet[Order], n: str, vs: list[str]) -> QuerySet[Order]:
+        return self._filter_by_active_opr_exists(qs, product__category__event_id__in=vs) if vs else qs
+
     class Meta:
         model = Order
         fields = [
@@ -65,6 +69,7 @@ class Meta:
             "product_id",
             "category_id",
             "category_group_id",
+            "event_id",
             "price_min",
             "price_max",
         ]

app/admin_api/serializers/shop/orders.py

@@ -121,7 +121,6 @@ def update(self, instance: Order, validated_data: dict) -> Order:
 
 
 class OrderExportRequestSerializer(JsonSchemaSerializer, serializers.Serializer):
-    product_ids = serializers.ListField(child=serializers.UUIDField(), required=True, min_length=1)
     include_refunded = serializers.BooleanField(default=False)
 
 

app/admin_api/test/helpers.py

@@ -1,4 +1,5 @@
 from typing import ClassVar
+from urllib.parse import urlencode
 
 from core.util.testutil import ModelApiFixture
 from django.urls import reverse
@@ -22,8 +23,11 @@ def import_csv(self, *, csv_file=None):
         data = {"csv_file": csv_file} if csv_file is not None else {}
         return self.http_client.post(reverse(f"{self.name}-import-csv"), data, format="multipart")
 
-    def export(self, data=None):
-        return self.http_client.post(reverse(f"{self.name}-export"), data, format="json")
+    def export(self, params=None):
+        url = reverse(f"{self.name}-export")
+        if params:
+            url = f"{url}?{urlencode(params, doseq=True)}"
+        return self.http_client.post(url, format="json")
 
 
 class OrderNotificationsAdminApi(ModelApiFixture):

app/admin_api/test/shop/orders_api_test.py

@@ -7,6 +7,7 @@
 from admin_api.test.helpers import OrdersAdminApi
 from admin_api.views.shop.orders import OrderAdminViewSet
 from freezegun import freeze_time
+from model_bakery import baker
 from rest_framework.fields import DateTimeField
 from rest_framework.status import (
     HTTP_200_OK,
@@ -101,6 +102,21 @@ def test_admin_list_filters_by_active_opr_category_group(api_client, ticket_prod
     assert {row["id"] for row in response.json()["results"]} == {str(completed_order.id)}
 
 
+@pytest.mark.django_db
+def test_admin_list_filters_by_active_opr_event(api_client, ticket_product, non_ticket_product, order_factory):
+    """`?event_id=` 가 해당 이벤트 카테고리의 상품을 가진 주문만 매칭한다."""
+    event = baker.make("event.Event", name="파이콘 한국 2026")
+    ticket_product.category.event = event
+    ticket_product.category.save()
+
+    in_event_order = order_factory(status="completed")  # ticket_product → event 연결됨
+    order_factory(status="completed", is_ticket=False)  # non_ticket_product → event 없음
+
+    response = OrdersAdminApi(http_client=api_client).list({"event_id": str(event.id)})
+    assert response.status_code == HTTP_200_OK
+    assert {row["id"] for row in response.json()["results"]} == {str(in_event_order.id)}
+
+
 @pytest.mark.django_db
 def test_admin_retrieve_returns_nested_payload(api_client, order_factory):
     completed_order = order_factory(status="completed")
@@ -226,7 +242,7 @@ def test_admin_export_returns_xlsx_filtering_refunded_per_include_flag(
 ):
     refunded_order = order_factory(status="refunded")
     response = OrdersAdminApi(http_client=api_client).export(
-        {"product_ids": [str(ticket_product.id)], "include_refunded": include_refunded}
+        {"product_id": str(ticket_product.id), "include_refunded": include_refunded}
     )
     assert response.status_code == HTTP_200_OK
     assert response.headers["Content-Type"] == "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
@@ -281,11 +297,49 @@ def test_admin_export_returns_xlsx_filtering_refunded_per_include_flag(
     ]
 
 
-@pytest.mark.parametrize("payload", [{}, {"product_ids": []}])
+def _export_order_ids(response) -> set[str]:
+    """export XLSX 응답의 '주문' 시트에서 주문 번호 집합을 추출."""
+    df = pandas.read_excel(BytesIO(b"".join(response.streaming_content)), sheet_name="주문", index_col=0, dtype=str)
+    return set(df["주문 번호"].tolist()) if not df.empty else set()
+
+
 @pytest.mark.django_db
-def test_admin_export_rejects_missing_or_empty_product_ids(api_client, payload):
-    response = OrdersAdminApi(http_client=api_client).export(payload)
-    assert response.status_code == HTTP_400_BAD_REQUEST
+def test_admin_export_without_filters_returns_all_purchased_orders(api_client, ticket_product, order_factory):
+    """필터 없이 호출하면 결제 완료 주문 전체를 내보낸다 (기본 include_refunded=false → 환불 제외)."""
+    completed_order = order_factory(status="completed")
+    order_factory(status="refunded")  # include_refunded 기본 false → 제외
+    response = OrdersAdminApi(http_client=api_client).export()
+    assert response.status_code == HTTP_200_OK
+    # streaming_content 는 1회성 iterator — 한 번만 읽어 비교 (== 비교가 환불 주문 제외도 함께 검증).
+    assert _export_order_ids(response) == {str(completed_order.id)}
+
+
+@pytest.mark.django_db
+def test_admin_export_scopes_by_event_id(api_client, ticket_product, non_ticket_product, order_factory):
+    """`?event_id=` 가 해당 이벤트 카테고리의 상품을 가진 주문만 내보낸다."""
+    event = baker.make("event.Event", name="파이콘 한국 2026")
+    ticket_product.category.event = event
+    ticket_product.category.save()
+
+    in_event_order = order_factory(status="completed")  # ticket_product (event 연결됨)
+    order_factory(status="completed", is_ticket=False)  # non_ticket_product (event 없음)
+
+    response = OrdersAdminApi(http_client=api_client).export({"event_id": str(event.id)})
+    assert response.status_code == HTTP_200_OK
+    assert _export_order_ids(response) == {str(in_event_order.id)}
+
+
+@pytest.mark.django_db
+def test_admin_export_scopes_by_category_group_id(api_client, ticket_product, non_ticket_product, order_factory):
+    """`?category_group_id=` 가 해당 그룹 상품을 가진 주문만 내보낸다."""
+    ticket_order = order_factory(status="completed")
+    order_factory(status="completed", is_ticket=False)
+
+    response = OrdersAdminApi(http_client=api_client).export(
+        {"category_group_id": str(ticket_product.category.group_id)}
+    )
+    assert response.status_code == HTTP_200_OK
+    assert _export_order_ids(response) == {str(ticket_order.id)}
 
 
 @pytest.mark.django_db

app/admin_api/test/shop/products_api_test.py

@@ -42,6 +42,18 @@ def test_admin_category_group_create_rejects_duplicate_name(api_client):
     assert response.status_code == HTTP_400_BAD_REQUEST
 
 
+@pytest.mark.django_db
+def test_admin_category_group_selectables_include_priority_meta(api_client):
+    # selectables 의 각 그룹은 CategoryGroup.get_choice_meta() 로 priority 메타를 실어야 한다.
+    group = CategoryGroup.objects.create(name="굿즈", priority=7)
+    url = reverse("v1:admin-shop-category-group-list") + "selectables/"
+    response = api_client.get(url)
+    assert response.status_code == HTTP_200_OK
+    body = response.json()
+    assert {c["const"]: c for c in body["results"]}[str(group.id)]["meta"]["priority"] == 7
+    assert "priority" in body["meta_schema"]
+
+
 def _patch_category(api_client, category: Category, **fields) -> object:
     # 카테고리는 CategoryGroup nested 로만 수정 — 그룹에 카테고리 1개뿐이므로 단건 전송이 전체 목록.
     return CategoryGroupsAdminApi(http_client=api_client).update(

app/admin_api/test/shop/soft_delete_filtering_test.py

@@ -44,7 +44,7 @@ def test_admin_export_excludes_soft_deleted_opr_from_product_sheet(api_client, o
     stale_opr.delete()
 
     response = OrdersAdminApi(http_client=api_client).export(
-        {"product_ids": [str(ticket_product.id)], "include_refunded": False}
+        {"product_id": str(ticket_product.id), "include_refunded": False}
     )
     assert response.status_code == HTTP_200_OK
     df_dict = pandas.read_excel(
@@ -101,7 +101,7 @@ def test_admin_export_excludes_order_with_only_soft_deleted_matching_opr(
     PaymentHistory.objects.create(order=leak_candidate, imp_id="leak", status=PaymentHistoryStatus.completed, price=500)
 
     response = OrdersAdminApi(http_client=api_client).export(
-        {"product_ids": [str(target_product.id)], "include_refunded": True}
+        {"product_id": str(target_product.id), "include_refunded": True}
     )
     assert response.status_code == HTTP_200_OK
     df_dict = pandas.read_excel(

app/admin_api/views/shop/orders.py

@@ -135,9 +135,7 @@ def refund_product(
     @extend_schema(
         summary="주문 CSV 가져오기 템플릿 다운로드",
         tags=[OpenAPITag.ADMIN_SHOP_ORDER],
-        parameters=[
-            OpenApiParameter(name="product_id", type=OpenApiTypes.UUID, location=OpenApiParameter.QUERY, required=True),
-        ],
+        parameters=[OpenApiParameter(name="product_id", type=OpenApiTypes.UUID, required=True)],
         responses={status.HTTP_200_OK: OpenApiTypes.STR},
     )
     @action(detail=False, methods=["get"], url_path="import-template")
@@ -196,32 +194,38 @@ def import_csv(self, request: request.Request) -> response.Response:
     @extend_schema(
         summary="주문 XLSX 내보내기",
         tags=[OpenAPITag.ADMIN_SHOP_ORDER],
-        request=OrderExportRequestSerializer,
+        parameters=[
+            OpenApiParameter(name="event_id", description="이벤트 ID (CSV 다중값)"),
+            OpenApiParameter(name="category_group_id", description="카테고리 그룹 ID (CSV 다중값)"),
+            OpenApiParameter(name="category_id", description="카테고리 ID (CSV 다중값)"),
+            OpenApiParameter(name="product_id", description="상품 ID (CSV 다중값)"),
+            OpenApiParameter(
+                name="include_refunded", type=OpenApiTypes.BOOL, description="환불 주문 포함 여부 (기본 false)"
+            ),
+        ],
+        request=None,
         responses={status.HTTP_200_OK: OpenApiTypes.BINARY},
     )
     @action(detail=False, methods=["post"], url_path="export")
     def export(self, request: request.Request) -> StreamingHttpResponse:
-        req = OrderExportRequestSerializer(data=request.data)
+        req = OrderExportRequestSerializer(data=request.query_params)
         req.is_valid(raise_exception=True)
-        product_ids = req.validated_data["product_ids"]
-        include_refunded = req.validated_data["include_refunded"]
-
-        statuses = PURCHASED_STATUSES if include_refunded else REFUNDABLE_STATUSES
+        statuses = PURCHASED_STATUSES if req.validated_data["include_refunded"] else REFUNDABLE_STATUSES
 
-        order_qs = (
+        base_qs = (
             Order.objects.filter_active()
-            .annotate(current_status=PaymentHistory.objects.latest_per_order_field("status"))
             .select_related("user")
             .with_dto_prefetches()
-            .filter(
-                models.Exists(
-                    OrderProductRelation.objects.filter_active().filter(
-                        order_id=models.OuterRef("pk"), product_id__in=product_ids
-                    )
-                ),
-                current_status__in=statuses,
+            .annotate(
+                current_status=PaymentHistory.objects.latest_per_order_field("status"),
+                latest_imp_id=PaymentHistory.objects.latest_per_order_field("imp_id"),
+                latest_price=PaymentHistory.objects.latest_per_order_field("price"),
+                first_paid_at=_payment_history_created_at_subquery(latest=False),
+                status_changed_at=_payment_history_created_at_subquery(latest=True),
             )
+            .filter(current_status__in=statuses)
         )
+        order_qs = OrderAdminFilterSet(request.query_params, queryset=base_qs, request=request).qs
         order_product_qs = (
             OrderProductRelation.objects.filter_active()
             .filter(order__in=order_qs)