feat(ad): 记录不发金币的原因(closed_early / too_short)

让广告收益报表能呈现「有展示、没发金币」的原因:
- grant_feed_reward 改整场结算:aborted→closed_early、整场总时长<10s→too_short(均 coin=0)
- 新增 record_reward_noshow + POST /api/v1/ad/reward-noshow(激励视频提前关留痕;
  同 ad_session_id 已 granted 则跳过,防与 S2S 发奖重复)
- feed-reward 加 aborted 入参
- 文档:feed-reward / 两张表 status 取值、新增 ad-reward-noshow、README 索引
- alembic: 合并 ad_revenue_report_cols 与 store_mapping_tb_dl_invalid 双 head(空迁移)

报表复算无需改(非 granted 状态走 else 分支 expected=0 自动归类)。

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

app/api/v1/ad.py

@@ -32,6 +32,8 @@ from app.schemas.ad import (
     FeedRewardIn,
     FeedRewardOut,
     PangleCallbackOut,
+    RewardNoShowIn,
+    RewardNoShowOut,
     TestGrantIn,
     TestGrantOut,
     WatchReportIn,
@@ -363,6 +365,7 @@ def feed_reward(payload: FeedRewardIn, user: CurrentUser, db: DbSession) -> Feed
         slot_id=payload.slot_id,
         app_env=payload.app_env,
         our_code_id=payload.our_code_id,
+        aborted=payload.aborted,
     )
     logger.info(
         "feed ad reward user_id=%d event=%s status=%s units=%d coin=%d",
@@ -375,3 +378,30 @@ def feed_reward(payload: FeedRewardIn, user: CurrentUser, db: DbSession) -> Feed
         unit_count=rec.unit_count,
         daily_limit=rewards.get_ad_daily_limit(db),
     )
+
+
+@router.post(
+    "/reward-noshow",
+    response_model=RewardNoShowOut,
+    summary="激励视频提前关闭/未发奖留痕",
+    dependencies=[Depends(rate_limit(120, 60, "ad-reward-noshow"))],
+)
+def reward_noshow(payload: RewardNoShowIn, user: CurrentUser, db: DbSession) -> RewardNoShowOut:
+    """激励视频展示了但用户提前关/跳过、未触发 S2S 发奖时,客户端 best-effort 上报一条留痕,
+    让广告收益报表能呈现「有展示、没发金币」的原因。不发金币;同一 session 已发奖则跳过。
+    """
+    rec = crud_ad.record_reward_noshow(
+        db,
+        user.id,
+        ad_session_id=payload.ad_session_id,
+        ecpm=payload.ecpm,
+        adn=payload.adn,
+        slot_id=payload.slot_id,
+        app_env=payload.app_env,
+        our_code_id=payload.our_code_id,
+    )
+    logger.info(
+        "ad reward noshow user_id=%d session=%s watched=%ds -> status=%s",
+        user.id, payload.ad_session_id, payload.watched_seconds, rec.status,
+    )
+    return RewardNoShowOut(ok=True, status=rec.status)

app/repositories/ad_feed_reward.py

@@ -71,12 +71,17 @@ def grant_feed_reward(
     slot_id: str | None = None,
     app_env: str | None = None,
     our_code_id: str | None = None,
+    aborted: bool = False,
 ) -> AdFeedRewardRecord:
-    """完成一条信息流广告后结算奖励。client_event_id 幂等,同号重试不重复发。
+    """比价/领券一整场信息流(轮播多条)结束后结算奖励。client_event_id 幂等,同号重试不重复发。
 
-    一期 eCPM/时长均由客户端上报,故服务端两道硬闸防刷:时长钳到 FEED_MAX_DURATION_SECONDS
-    限单事件份数,eCPM 在 rewards.calculate_ad_reward_coin 内钳到 AD_ECPM_MAX_FEN 限单份金额;
-    叠加每日 get_ad_daily_limit 条数上限,把单用户日产出锁进有限区间。
+    发奖规则:**比价全程不关广告才发**,金额按整场**总观看时长**折份(每 10 秒 1 份)。
+    - aborted=True(用户中途 ✕ 关闭):整场不发,记 status='closed_early' 留痕(原因可查)。
+    - 总时长不足 10 秒(unit_count==0):记 status='too_short' 不发。
+    - 命中当日条数上限:记 status='capped' 不发。
+    duration_seconds 是整场累计秒数。一期 eCPM/时长均由客户端上报,故服务端两道硬闸防刷:时长钳到
+    FEED_MAX_DURATION_SECONDS 限单场份数,eCPM 在 rewards.calculate_ad_reward_coin 内钳到
+    AD_ECPM_MAX_FEN 限单份金额;叠加每日 get_ad_daily_limit 条数上限,把单用户日产出锁进有限区间。
     """
     existing = _find_by_event(db, client_event_id)
     if existing is not None:
@@ -87,6 +92,25 @@ def grant_feed_reward(
     safe_duration = max(0, min(duration_seconds, FEED_MAX_DURATION_SECONDS))
     unit_count = safe_duration // FEED_REWARD_UNIT_SECONDS
 
+    # 用户中途关闭广告:整场不发(全程不关才发),留一条 closed_early 记录原因。优先级最高。
+    if aborted:
+        rec = AdFeedRewardRecord(
+            client_event_id=client_event_id,
+            user_id=user_id,
+            reward_date=today,
+            duration_seconds=safe_duration,
+            unit_count=unit_count,
+            ad_session_id=ad_session_id,
+            ecpm_raw=ecpm,
+            adn=adn,
+            slot_id=slot_id,
+            app_env=app_env,
+            our_code_id=our_code_id,
+            coin=0,
+            status="closed_early",
+        )
+        return _commit_record(db, rec, client_event_id)
+
     if _granted_today(db, user_id, today) >= rewards.get_ad_daily_limit(db):
         rec = AdFeedRewardRecord(
             client_event_id=client_event_id,
@@ -105,6 +129,25 @@ def grant_feed_reward(
         )
         return _commit_record(db, rec, client_event_id)
 
+    # 整场总时长不足 10 秒,凑不满一份 → 不发,记 too_short 留痕。
+    if unit_count == 0:
+        rec = AdFeedRewardRecord(
+            client_event_id=client_event_id,
+            user_id=user_id,
+            reward_date=today,
+            duration_seconds=safe_duration,
+            unit_count=0,
+            ad_session_id=ad_session_id,
+            ecpm_raw=ecpm,
+            adn=adn,
+            slot_id=slot_id,
+            app_env=app_env,
+            our_code_id=our_code_id,
+            coin=0,
+            status="too_short",
+        )
+        return _commit_record(db, rec, client_event_id)
+
     coin = _unit_reward_total(db, user_id, ecpm, unit_count)
     if coin > 0:
         crud_wallet.grant_coins(

app/repositories/ad_reward.py

@@ -145,6 +145,54 @@ def grant_ad_reward(
     return _commit_record(db, rec, trans_id)
 
 
+def record_reward_noshow(
+    db: Session,
+    user_id: int,
+    *,
+    ad_session_id: str,
+    ecpm: str | None = None,
+    adn: str | None = None,
+    slot_id: str | None = None,
+    app_env: str | None = None,
+    our_code_id: str | None = None,
+    reward_scene: str = "reward_video",
+) -> AdRewardRecord:
+    """客户端上报「激励视频展示了但用户提前关/跳过、未触发发奖」,落一条 coin=0 status='closed_early'
+    记录,供广告收益报表把「不发金币的原因」也呈现出来(只留痕,不发币)。
+
+    幂等键 trans_id = 'noreward:{ad_session_id}'(每次展示唯一)。若同一 ad_session_id 已有 granted
+    记录(S2S 已发奖,正常路径),说明用户其实看完了 → 跳过不写、原样返回那条,避免与正常发奖重复。
+    app_env/our_code_id 由客户端直接带上(它本就持有);查不到 user 抛 UnknownUserError。
+    """
+    if db.get(User, user_id) is None:
+        raise UnknownUserError
+    # 同一次展示已正常发奖 → 不再记 closed_early(防与 S2S granted 重复)
+    granted = db.execute(
+        select(AdRewardRecord)
+        .where(
+            AdRewardRecord.user_id == user_id,
+            AdRewardRecord.ad_session_id == ad_session_id,
+            AdRewardRecord.status == "granted",
+        )
+        .limit(1)
+    ).scalar_one_or_none()
+    if granted is not None:
+        return granted
+
+    trans_id = f"noreward:{ad_session_id}"
+    existing = _find_by_trans(db, trans_id)
+    if existing is not None:
+        return existing
+
+    rec = AdRewardRecord(
+        trans_id=trans_id, user_id=user_id, coin=0, status="closed_early",
+        reward_date=cn_today().isoformat(), reward_name=None, raw=None,
+        reward_scene=reward_scene, ad_session_id=ad_session_id, ecpm_raw=ecpm,
+        app_env=app_env, our_code_id=our_code_id,
+    )
+    return _commit_record(db, rec, trans_id)
+
+
 def record_external_reward(
     db: Session,
     user_id: int,

app/schemas/ad.py

@@ -121,17 +121,18 @@ class TestGrantOut(BaseModel):
 
 
 class FeedRewardIn(BaseModel):
-    """信息流广告完成后结算奖励。
+    """比价/领券一整场信息流(轮播多条)结束后结算奖励。
 
-    每展示满 10 秒累计一份奖励,视频完成后一次性入账。client_event_id 用于客户端超时重试幂等。
+    规则:全程不关广告才发,金额按整场**总观看时长**折份(每 10 秒 1 份)。client_event_id 用于
+    客户端超时重试幂等。中途被用户关闭时传 aborted=True,整场不发(只记 closed_early)。
     """
 
     client_event_id: str = Field(..., min_length=8, max_length=64, description="客户端生成的幂等事件 id")
     ad_session_id: str | None = Field(
         None, min_length=8, max_length=64, description="客户端生成的一次信息流广告会话 id"
     )
-    ecpm: str = Field(..., description="本条信息流广告 eCPM,按分/千次展示处理(SDK getEcpm 原值,非元)")
-    duration_seconds: int = Field(..., ge=0, description="本条广告实际展示/播放秒数")
+    ecpm: str = Field(..., description="本场信息流 eCPM(代表值,按分/千次展示处理;SDK getEcpm 原值,非元)")
+    duration_seconds: int = Field(..., ge=0, description="整场累计观看秒数(轮播各条相加)")
     adn: str | None = Field(None, description="实际投放 ADN")
     slot_id: str | None = Field(None, description="实际展示代码位")
     app_env: str | None = Field(
@@ -140,11 +141,42 @@ class FeedRewardIn(BaseModel):
     our_code_id: str | None = Field(
         None, max_length=64, description="我们后台配置的代码位 ID(AdConfig 的 104xxx,非底层 rit)"
     )
+    aborted: bool = Field(
+        False, description="用户中途 ✕ 关闭广告(未走完比价):整场不发,记 closed_early"
+    )
 
 
 class FeedRewardOut(BaseModel):
     granted: bool = Field(..., description="本次是否入账。达上限时 false")
-    status: str = Field(..., description="granted / capped")
+    status: str = Field(..., description="granted / capped / too_short / closed_early")
     coin: int = Field(..., description="本次发放金币")
     unit_count: int = Field(..., description="按 10 秒折算出的奖励份数")
     daily_limit: int = Field(..., description="每日信息流展示次数上限")
+
+
+class RewardNoShowIn(BaseModel):
+    """激励视频展示了但用户提前关闭/跳过、未触发发奖——上报留痕(不发金币)。
+
+    供广告收益报表把「有展示、没发金币」的原因也记录下来。user_id 由 JWT 取,不在 body。
+    """
+
+    ad_session_id: str = Field(
+        ..., min_length=8, max_length=64, description="本次展示会话 id(与 ecpm 上报、S2S extra 一致)"
+    )
+    watched_seconds: int = Field(0, ge=0, description="关闭前已观看秒数(仅留痕参考,不入库)")
+    ecpm: str | None = Field(None, description="本次展示 eCPM(分/千次,SDK getEcpm 原值);可空")
+    adn: str | None = Field(None, description="实际投放 ADN")
+    slot_id: str | None = Field(None, description="实际展示代码位(底层 mediation rit)")
+    app_env: str | None = Field(
+        None, max_length=16, description="我们的穿山甲应用环境:prod / test"
+    )
+    our_code_id: str | None = Field(
+        None, max_length=64, description="我们后台配置的代码位 ID(104xxx)"
+    )
+
+
+class RewardNoShowOut(BaseModel):
+    ok: bool = Field(..., description="是否处理成功(落库或幂等命中)")
+    status: str = Field(
+        ..., description="closed_early(已留痕) / granted(该次其实已发奖,跳过未写)"
+    )