feat(admin): add bulk reward review APIs

tests/test_admin_write.py

@@ -14,6 +14,7 @@ from app.core.security import hash_password
 from app.db.session import SessionLocal
 from app.models.admin import AdminAuditLog
 from app.models.feedback import Feedback
+from app.models.price_report import PriceReport
 from app.models.user import User
 from app.models.wallet import CoinAccount, CoinTransaction, WithdrawOrder
 from app.repositories import user as user_repo
@@ -82,6 +83,26 @@ def _seed_feedback(phone: str) -> int:
         db.close()
 
 
+def _seed_price_report(phone: str) -> int:
+    uid = _seed_user(phone)
+    db = SessionLocal()
+    try:
+        report = PriceReport(
+            user_id=uid,
+            store_name="测试门店",
+            reported_platform_id="eleme",
+            reported_platform_name="饿了么",
+            reported_price_cents=2990,
+            images=[],
+            status="pending",
+        )
+        db.add(report)
+        db.commit()
+        return report.id
+    finally:
+        db.close()
+
+
 # ===== 调金币 =====
 
 def test_grant_coins_writes_txn_and_audit(admin_client: TestClient, finance_token: str) -> None:
@@ -397,6 +418,100 @@ def test_feedback_review_stores_admin_reply(
     assert r.json()["admin_reply"] == "已收到,后续跟进"
 
 
+def test_bulk_approve_feedbacks_returns_per_item_results(
+    admin_client: TestClient, operator_token: str
+) -> None:
+    first_id = _seed_feedback("13900000031")
+    second_id = _seed_feedback("13900000032")
+    r = admin_client.post(
+        "/admin/api/feedbacks/bulk/approve",
+        json={"ids": [first_id, second_id, 999999], "reward_coins": 600, "note": "批量采纳"},
+        headers=_auth(operator_token),
+    )
+    assert r.status_code == 200, r.text
+    payload = r.json()
+    assert payload["total"] == 3 and payload["success"] == 2 and payload["failed"] == 1
+    assert payload["items"][-1] == {"id": 999999, "ok": False, "status": None, "error": "反馈不存在"}
+    db = SessionLocal()
+    try:
+        for feedback_id in (first_id, second_id):
+            feedback = db.get(Feedback, feedback_id)
+            assert feedback is not None and feedback.status == "adopted"
+            assert db.get(CoinAccount, feedback.user_id).coin_balance == 600
+            log = db.execute(
+                select(AdminAuditLog).where(
+                    AdminAuditLog.action == "feedback.approve",
+                    AdminAuditLog.target_id == str(feedback_id),
+                )
+            ).scalar_one()
+            assert log.detail["bulk"] is True
+    finally:
+        db.close()
+
+
+def test_bulk_approve_price_reports_returns_per_item_results(
+    admin_client: TestClient, operator_token: str
+) -> None:
+    first_id = _seed_price_report("13900000041")
+    second_id = _seed_price_report("13900000042")
+    r = admin_client.post(
+        "/admin/api/price-reports/bulk/approve",
+        json={"ids": [first_id, second_id, 999999]},
+        headers=_auth(operator_token),
+    )
+    assert r.status_code == 200, r.text
+    payload = r.json()
+    assert payload["total"] == 3 and payload["success"] == 2 and payload["failed"] == 1
+    assert payload["items"][-1] == {"id": 999999, "ok": False, "status": None, "error": "上报记录不存在"}
+    db = SessionLocal()
+    try:
+        for report_id in (first_id, second_id):
+            report = db.get(PriceReport, report_id)
+            assert report is not None and report.status == "approved"
+            assert report.reward_coins == 1000
+            assert db.get(CoinAccount, report.user_id).coin_balance == 1000
+            log = db.execute(
+                select(AdminAuditLog).where(
+                    AdminAuditLog.action == "price_report.approve",
+                    AdminAuditLog.target_id == str(report_id),
+                )
+            ).scalar_one()
+            assert log.detail["bulk"] is True
+    finally:
+        db.close()
+
+
+def test_bulk_reject_review_requests_apply_shared_reason(
+    admin_client: TestClient, operator_token: str
+) -> None:
+    feedback_id = _seed_feedback("13900000051")
+    report_id = _seed_price_report("13900000052")
+    feedback_response = admin_client.post(
+        "/admin/api/feedbacks/bulk/reject",
+        json={"ids": [feedback_id], "reason": "信息不足", "reply": "请补充完整截图"},
+        headers=_auth(operator_token),
+    )
+    report_response = admin_client.post(
+        "/admin/api/price-reports/bulk/reject",
+        json={"ids": [report_id], "reason": "截图无法核实"},
+        headers=_auth(operator_token),
+    )
+    assert feedback_response.status_code == 200, feedback_response.text
+    assert report_response.status_code == 200, report_response.text
+    assert feedback_response.json()["success"] == 1
+    assert report_response.json()["success"] == 1
+    db = SessionLocal()
+    try:
+        feedback = db.get(Feedback, feedback_id)
+        report = db.get(PriceReport, report_id)
+        assert feedback is not None and feedback.status == "rejected"
+        assert feedback.reject_reason == "信息不足" and feedback.admin_reply == "请补充完整截图"
+        assert report is not None and report.status == "rejected"
+        assert report.reject_reason == "截图无法核实"
+    finally:
+        db.close()
+
+
 # ===== admin 账号管理(super_admin) =====
 
 def test_create_and_update_admin(admin_client: TestClient, super_token: str) -> None: