功能：支持动态配置每日比价次数上限

## 问题

业务收益详情的平均 Draw eCPM 仅平均成功发奖记录，会排除未发奖的真实展示，导致数值系统性偏高，且与广告收益页口径不一致。

## 修复

- `feed_avg_ecpm` 改为从 `ad_ecpm_record` 的全部 `draw/feed` 实际展示计算
- 成功发奖、未发奖展示均纳入，每次展示等权
- 日期、正式/测试环境、业务代码位、领券/比价场景支持与广告收益页对齐
- 奖励份数仍基于成功发奖表，不混用展示数据源
- 复用广告收益报表的业务代码位集合

## 线上数据复算

2026-07-25、正式业务、用户 #33：

- 旧口径（只看成功发奖）：`29.9117 元/千次`
- 新口径（333 次真实展示）：`19.9926 元/千次`
- 新值与广告收益报表一致

## 验证

- 新增成功/未发奖、场景、环境、业务代码位回归用例
- `tests/test_admin_read.py` + `tests/test_admin_ad_revenue_scope.py`：29 项全通过
- Ruff 改动文件检查通过

## 上线顺序

本 PR 需先于管理后台配套 PR 上线。

---------

Co-authored-by: guke <guke@wonderable.ai>
Co-authored-by: unknown <798648091@qq.com>
Reviewed-on: #190
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>

app/admin/schemas/risk_monitor.py

@@ -23,7 +23,7 @@ class RiskMonitorSummary(BaseModel):
 class RiskRuleConfig(BaseModel):
     sms_hourly_threshold: int = Field(ge=1, le=5)
     oneclick_daily_threshold: int = Field(ge=1, le=100_000)
-    compare_daily_threshold: int = Field(ge=1, le=100)
+    compare_daily_threshold: int = Field(ge=1, le=100_000)
 
 
 class RiskIncidentItem(BaseModel):

app/api/v1/compare_record.py

@@ -38,13 +38,14 @@ router = APIRouter(prefix="/api/v1/compare", tags=["compare-record"])
 @router.post(
     "/start",
     response_model=CompareStartReserveOut,
-    summary="预占一次当日比价发起次数（每人每天最多100次）",
+    summary="预占一次当日比价发起次数（上限由风控监控配置）",
 )
 def reserve_compare_start(
     payload: CompareStartReserveIn,
     user: CurrentUser,
     db: DbSession,
 ) -> CompareStartReserveOut:
+    daily_limit = risk_repo.get_rule_threshold(db, risk_repo.RULE_COMPARE_DAILY)
     if risk_repo.is_restricted(
         db,
         subject_type="user",
@@ -57,25 +58,26 @@ def reserve_compare_start(
             db,
             user_id=user.id,
             trace_id=payload.trace_id,
+            daily_limit=daily_limit,
             business_type=payload.business_type,
             device_id=payload.device_id,
         )
     except crud_compare.DailyCompareStartLimitExceeded:
         raise HTTPException(
             status_code=status.HTTP_429_TOO_MANY_REQUESTS,
-            detail="今日已比价超过100次，请明天再试",
+            detail=f"今日已比价超过{daily_limit}次，请明天再试",
         ) from None
     except crud_compare.ComparisonTraceOwnershipError:
         raise HTTPException(
             status_code=status.HTTP_409_CONFLICT,
             detail="比价任务标识冲突，请重新发起",
         ) from None
-    # 风控阈值由后台动态配置，不能再只在固定的 100 次业务上限处同步。
+    # 告警和业务限流共用同一动态阈值，避免后台已修改但用户侧仍固定为 100 次。
     risk_repo.sync_compare_incident(db, user_id=user.id, at=rec.created_at)
     return CompareStartReserveOut(
-        limit=crud_compare.DAILY_COMPARE_START_LIMIT,
+        limit=daily_limit,
         used=used,
-        remaining=max(crud_compare.DAILY_COMPARE_START_LIMIT - used, 0),
+        remaining=max(daily_limit - used, 0),
     )
 
 

app/core/config_schema.py

@@ -134,12 +134,12 @@ CONFIG_DEFS: dict[str, dict[str, Any]] = {
     },
     RISK_COMPARE_DAILY_THRESHOLD_KEY: {
         "default": 100,
-        "label": "比价账户每日告警阈值",
+        "label": "比价账户每日上限与告警阈值",
         "group": "风控",
         "type": "int",
         "min": 1,
-        "max": 100,
+        "max": 100_000,
         "hidden": True,
-        "help": "同一账户在北京时间同一自然日内发起比价达到该次数时告警。",
+        "help": "同一账户按北京时间自然日最多可发起的比价次数；达到该次数时同步告警。",
     },
 }

app/repositories/comparison.py

@@ -17,8 +17,6 @@ from app.models.savings import SavingsRecord
 from app.models.user import User
 from app.schemas.compare_record import ComparisonRecordIn
 
-DAILY_COMPARE_START_LIMIT = 100
-
 
 class DailyCompareStartLimitExceeded(Exception):
     """The authenticated user has consumed today's comparison-start quota."""
@@ -363,11 +361,12 @@ def reserve_daily_start(
     *,
     user_id: int,
     trace_id: str,
+    daily_limit: int,
     business_type: str = "food",
     device_id: str | None = None,
     now: datetime | None = None,
 ) -> tuple[ComparisonRecord, int]:
-    """Atomically reserve one of a user's 100 Beijing-day comparison starts.
+    """Atomically reserve one of a user's configured Beijing-day comparison starts.
 
     ``trace_id`` makes client retries idempotent. Locking the user row serializes
     concurrent starts for one account, so parallel requests cannot both consume
@@ -413,7 +412,7 @@ def reserve_daily_start(
             ComparisonRecord.created_at < day_end,
         )
     ) or 0
-    if used >= DAILY_COMPARE_START_LIMIT:
+    if used >= daily_limit:
         raise DailyCompareStartLimitExceeded
 
     rec = ComparisonRecord(

tests/test_compare_daily_limit.py

@@ -3,14 +3,32 @@ from __future__ import annotations
 import time
 from datetime import datetime, timedelta
 
+import pytest
 from sqlalchemy import func, select
 
+from app.core.config_schema import RISK_COMPARE_DAILY_THRESHOLD_KEY
 from app.core.rewards import CN_TZ
 from app.core.security import decode_token
 from app.db.session import SessionLocal
+from app.models.app_config import AppConfig
 from app.models.comparison import ComparisonRecord
 
 
+@pytest.fixture(autouse=True)
+def _reset_compare_daily_limit():
+    with SessionLocal() as db:
+        db.query(AppConfig).filter(
+            AppConfig.key == RISK_COMPARE_DAILY_THRESHOLD_KEY
+        ).delete()
+        db.commit()
+    yield
+    with SessionLocal() as db:
+        db.query(AppConfig).filter(
+            AppConfig.key == RISK_COMPARE_DAILY_THRESHOLD_KEY
+        ).delete()
+        db.commit()
+
+
 def _login(client) -> tuple[str, int]:
     phone = f"137{int(time.time() * 1000) % 100000000:08d}"
     sent = client.post("/api/v1/auth/sms/send", json={"phone": phone})
@@ -118,3 +136,33 @@ def test_compare_start_rejects_101st_beijing_day_attempt(client) -> None:
                 ComparisonRecord.trace_id == rejected_trace
             )
         ) == 0
+
+
+def test_compare_start_uses_dynamic_risk_monitor_limit(client) -> None:
+    with SessionLocal() as db:
+        db.add(AppConfig(key=RISK_COMPARE_DAILY_THRESHOLD_KEY, value=2))
+        db.commit()
+
+    token, user_id = _login(client)
+    first = client.post(
+        "/api/v1/compare/start",
+        json={"trace_id": f"quota-dynamic-{user_id}-1"},
+        headers=_headers(token),
+    )
+    second = client.post(
+        "/api/v1/compare/start",
+        json={"trace_id": f"quota-dynamic-{user_id}-2"},
+        headers=_headers(token),
+    )
+    rejected = client.post(
+        "/api/v1/compare/start",
+        json={"trace_id": f"quota-dynamic-{user_id}-3"},
+        headers=_headers(token),
+    )
+
+    assert first.status_code == 200
+    assert first.json() == {"limit": 2, "used": 1, "remaining": 1}
+    assert second.status_code == 200
+    assert second.json() == {"limit": 2, "used": 2, "remaining": 0}
+    assert rejected.status_code == 429
+    assert rejected.json()["detail"] == "今日已比价超过2次，请明天再试"

tests/test_risk_monitor.py

@@ -529,6 +529,18 @@ def test_admin_can_edit_rules_and_current_window_is_reconciled() -> None:
                 now + timedelta(seconds=2)
             ).replace(tzinfo=None)
 
+        compare_limit = client.patch(
+            "/admin/api/risk-monitor/rules",
+            headers=headers,
+            json={
+                "sms_hourly_threshold": 3,
+                "oneclick_daily_threshold": 20,
+                "compare_daily_threshold": 120,
+            },
+        )
+        assert compare_limit.status_code == 200
+        assert compare_limit.json()["compare_daily_threshold"] == 120
+
         invalid = client.patch(
             "/admin/api/risk-monitor/rules",
             headers=headers,