feat(coin): 金币数值体系二期——看广告按 eCPM 发奖 + ad_session_id 幂等 + 签到膨胀固定金币

- rewards: 激励视频实发改按 calculate_ad_reward_coin(eCPM, 当日第N次) 公式;AD_REWARD_COIN/MAX_AD_REWARD_COIN 降为历史兼容口径;新增 SIGNIN_BOOST_COIN=2000 - 签到膨胀: Day1-13 看完激励视频额外发固定金币、Day14 不允许 (signin.py / signin-boost) - ad_session_id 幂等: ad_ecpm/ad_reward/ad_feed_reward 记录加 ad_session_id 列 + 唯一索引(新迁移 coin_reward_phase2 / ad_feed_reward_session) - ad.py + schemas + repositories: ecpm-report / feed-reward / reward-status / test-grant 改造;config_schema 增 signin_boost_coin;admin stats overview 补充 - 同步 docs/api + docs/database + docs/integrations/pangle 及 tests(test_ad_reward / test_welfare) Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-06-09 00:19:01 +08:00
67 changed files with 115 additions and 3090 deletions
@@ -79,10 +79,6 @@ WXPAY_MCH_PRIVATE_KEY_PATH=./secrets/apiclient_key.pem
 WXPAY_PUBLIC_KEY_ID=PUB_KEY_ID_xxxxxxxx
 WXPAY_PUBLIC_KEY_PATH=./secrets/pub_key.pem
 WXPAY_TRANSFER_SCENE_ID=1000
-WXPAY_AUTH_NOTIFY_URL=
-WITHDRAW_AUTO_RECONCILE_ENABLED=false
-WITHDRAW_AUTO_RECONCILE_INTERVAL_SEC=300
-WITHDRAW_AUTO_RECONCILE_OLDER_THAN_MINUTES=15

 # ===== 穿山甲激励视频(服务端发奖回调)=====
 # 看完激励视频后穿山甲服务器 S2S 回调本服务发金币(客户端不参与发奖)。
@@ -43,4 +43,3 @@ secrets/*

 # 运行日志(run.sh 输出, 不入库)
 *.log
-logs/
@@ -1,26 +0,0 @@
-"""merge invite_fingerprint and ad_reward heads
-
-Revision ID: a8c47fc4dc39
-Revises: invite_fingerprint_table, 044dce6e9b1f
-Create Date: 2026-06-10 01:03:03.699443
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = 'a8c47fc4dc39'
-down_revision: Union[str, Sequence[str], None] = ('invite_fingerprint_table', '044dce6e9b1f')
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    pass
-
-
-def downgrade() -> None:
-    pass
@@ -1,58 +0,0 @@
-"""coupon daily completion table(今日跑完整轮领券 → 首页置灰源)
-
-Revision ID: coupon_daily_completion
-Revises: f8d3b1e60a27
-Create Date: 2026-06-10 00:00:00.000000
-
-"""
-
-from collections.abc import Sequence
-
-import sqlalchemy as sa
-
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision: str = "coupon_daily_completion"
-down_revision: str | Sequence[str] | None = "f8d3b1e60a27"
-branch_labels: str | Sequence[str] | None = None
-depends_on: str | Sequence[str] | None = None
-
-
-def upgrade() -> None:
-    op.create_table(
-        "coupon_daily_completion",
-        sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
-        sa.Column("device_id", sa.String(length=64), nullable=False),
-        sa.Column("user_id", sa.Integer(), nullable=True),
-        sa.Column("complete_date", sa.Date(), nullable=False),
-        sa.Column("trace_id", sa.String(length=64), nullable=True),
-        sa.Column(
-            "created_at",
-            sa.DateTime(timezone=True),
-            server_default=sa.text("(CURRENT_TIMESTAMP)"),
-            nullable=False,
-        ),
-        sa.Column(
-            "updated_at",
-            sa.DateTime(timezone=True),
-            server_default=sa.text("(CURRENT_TIMESTAMP)"),
-            nullable=False,
-        ),
-        sa.PrimaryKeyConstraint("id"),
-        sa.UniqueConstraint("device_id", "complete_date", name="uq_coupon_completion_device_date"),
-    )
-    with op.batch_alter_table("coupon_daily_completion", schema=None) as batch_op:
-        batch_op.create_index(
-            batch_op.f("ix_coupon_daily_completion_user_id"), ["user_id"], unique=False
-        )
-        batch_op.create_index(
-            batch_op.f("ix_coupon_daily_completion_trace_id"), ["trace_id"], unique=False
-        )
-
-
-def downgrade() -> None:
-    with op.batch_alter_table("coupon_daily_completion", schema=None) as batch_op:
-        batch_op.drop_index(batch_op.f("ix_coupon_daily_completion_trace_id"))
-        batch_op.drop_index(batch_op.f("ix_coupon_daily_completion_user_id"))
-    op.drop_table("coupon_daily_completion")
@@ -1,49 +0,0 @@
-"""add user.debug_trace_enabled + comparison_record.trace_url
-
-调试链接权限功能：
-  - user.debug_trace_enabled：运营后台给指定用户开「复制调试链接」权限
-  - comparison_record.trace_url：比价记录页「复制调试链接」的数据（pricebot done 帧给，
-    dir 名含落盘时分秒、前端/server 拼不出，必须落库）
-
-注：本迁移最初基于旧 main（#31，双 head）写、down_revision 曾指向那对父；但 #33 已用
-a8c47fc4dc39 合并了那对双 head，故改为线性接在 a8c47fc4dc39 之后、只负责加两列
-（避免与 a8c47fc4dc39 平行再造一个双 head）。
-
-Revision ID: f8d3b1e60a27
-Revises: a8c47fc4dc39
-Create Date: 2026-06-10 02:40:00.000000
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = "f8d3b1e60a27"
-down_revision: Union[str, Sequence[str], None] = "a8c47fc4dc39"
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    # sa.false() 渲染成 PG 的 false / SQLite 的 0，两端兼容（避免字符串 "false" 在 SQLite 上存歪）
-    op.add_column(
-        "user",
-        sa.Column(
-            "debug_trace_enabled",
-            sa.Boolean(),
-            nullable=False,
-            server_default=sa.false(),
-        ),
-    )
-    op.add_column(
-        "comparison_record",
-        sa.Column("trace_url", sa.String(length=512), nullable=True),
-    )
-
-
-def downgrade() -> None:
-    op.drop_column("comparison_record", "trace_url")
-    op.drop_column("user", "debug_trace_enabled")
@@ -1,50 +0,0 @@
-"""invite_fingerprint table (任务 3 指纹归因兜底)
-
-Revision ID: invite_fingerprint_table
-Revises: 0cf18d590b1d
-Create Date: 2026-06-08 14:00:00.000000
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = 'invite_fingerprint_table'
-down_revision: Union[str, Sequence[str], None] = '0cf18d590b1d'
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    # 邀请指纹归因表:落地页访问时记一行,登录后剪贴板没拿到邀请码时反查
-    op.create_table(
-        'invite_fingerprint',
-        sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-        sa.Column('inviter_user_id', sa.Integer(), nullable=False),
-        sa.Column('ip', sa.String(length=64), nullable=False),
-        sa.Column('device_model', sa.String(length=64), nullable=False, server_default=''),
-        sa.Column('screen', sa.String(length=32), nullable=False, server_default=''),
-        sa.Column('user_agent', sa.Text(), nullable=False, server_default=''),
-        sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.func.now(), nullable=False),
-        sa.ForeignKeyConstraint(['inviter_user_id'], ['user.id']),
-        sa.PrimaryKeyConstraint('id'),
-    )
-    # 反查主索引:(ip, screen, device_model, created_at)
-    # /bind 兜底分支 WHERE ip=? AND screen=? AND device_model=? AND created_at > now - 7d
-    # ORDER BY created_at DESC LIMIT 1 — SQLite/PG 优化器都能反向扫该索引
-    op.create_index(
-        'ix_invite_fp_match',
-        'invite_fingerprint',
-        ['ip', 'screen', 'device_model', 'created_at'],
-    )
-    # 兜底/统计索引:按 inviter 看"这个邀请人的落地页被谁访问过"
-    op.create_index('ix_invite_fp_inviter', 'invite_fingerprint', ['inviter_user_id'])
-
-
-def downgrade() -> None:
-    op.drop_index('ix_invite_fp_inviter', table_name='invite_fingerprint')
-    op.drop_index('ix_invite_fp_match', table_name='invite_fingerprint')
-    op.drop_table('invite_fingerprint')
@@ -1,26 +0,0 @@
-"""merge ad feed reward session and withdraw safety heads
-
-Revision ID: 044dce6e9b1f
-Revises: ad_feed_reward_session, withdraw_safety_indexes
-Create Date: 2026-06-09 09:52:08.276767
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = '044dce6e9b1f'
-down_revision: Union[str, Sequence[str], None] = ('ad_feed_reward_session', 'withdraw_safety_indexes')
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    pass
-
-
-def downgrade() -> None:
-    pass
@@ -1,39 +0,0 @@
-"""onboarding_completion table (新手引导完成标记,按 user+device 去重)
-
-Revision ID: onboarding_completion
-Revises: coupon_daily_completion
-Create Date: 2026-06-10 00:00:00.000000
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = 'onboarding_completion'
-down_revision: Union[str, Sequence[str], None] = 'coupon_daily_completion'
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    # (账号, 设备) 一条完成标记;device_id = 客户端硬件级 ANDROID_ID(跨卸载重装稳定)。
-    op.create_table(
-        'onboarding_completion',
-        sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-        sa.Column('user_id', sa.Integer(), nullable=False),
-        sa.Column('device_id', sa.String(length=64), nullable=False),
-        sa.Column('completed_at', sa.DateTime(timezone=True), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False),
-        sa.PrimaryKeyConstraint('id'),
-        sa.UniqueConstraint('user_id', 'device_id', name='uq_onboarding_user_device'),
-    )
-    with op.batch_alter_table('onboarding_completion', schema=None) as batch_op:
-        batch_op.create_index(batch_op.f('ix_onboarding_completion_user_id'), ['user_id'], unique=False)
-
-
-def downgrade() -> None:
-    with op.batch_alter_table('onboarding_completion', schema=None) as batch_op:
-        batch_op.drop_index(batch_op.f('ix_onboarding_completion_user_id'))
-    op.drop_table('onboarding_completion')
@@ -1,42 +0,0 @@
-"""add withdraw concurrency safety indexes
-
-Revision ID: withdraw_safety_indexes
-Revises: 0cf18d590b1d
-Create Date: 2026-06-08 16:20:00.000000
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = "withdraw_safety_indexes"
-down_revision: Union[str, Sequence[str], None] = "0cf18d590b1d"
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    op.create_index(
-        "ux_withdraw_order_user_active",
-        "withdraw_order",
-        ["user_id"],
-        unique=True,
-        sqlite_where=sa.text("status IN ('reviewing', 'pending')"),
-        postgresql_where=sa.text("status IN ('reviewing', 'pending')"),
-    )
-    op.create_index(
-        "ux_cash_transaction_withdraw_refund_ref",
-        "cash_transaction",
-        ["ref_id"],
-        unique=True,
-        sqlite_where=sa.text("biz_type = 'withdraw_refund' AND ref_id IS NOT NULL"),
-        postgresql_where=sa.text("biz_type = 'withdraw_refund' AND ref_id IS NOT NULL"),
-    )
-
-
-def downgrade() -> None:
-    op.drop_index("ux_cash_transaction_withdraw_refund_ref", table_name="cash_transaction")
-    op.drop_index("ux_withdraw_order_user_active", table_name="withdraw_order")
@@ -13,7 +13,6 @@ from contextlib import asynccontextmanager
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware

-from app.admin.routers.ad_audit import router as ad_audit_router
 from app.admin.routers.admins import router as admins_router
 from app.admin.routers.audit import router as audit_router
 from app.admin.routers.auth import router as auth_router
@@ -22,7 +21,6 @@ from app.admin.routers.dashboard import router as dashboard_router
 from app.admin.routers.ops_stat_config import router as ops_stat_config_router
 from app.admin.routers.feedback import router as feedback_router
 from app.admin.routers.ops_marquee_seed import router as ops_marquee_seed_router
-from app.admin.routers.price_report import router as price_report_router
 from app.admin.routers.users import router as users_router
 from app.admin.routers.wallet import router as wallet_router
 from app.admin.routers.withdraw import router as withdraw_router
@@ -82,9 +80,7 @@ admin_app.include_router(ops_marquee_seed_router)
 admin_app.include_router(users_router)
 admin_app.include_router(wallet_router)
 admin_app.include_router(withdraw_router)
-admin_app.include_router(price_report_router)
 admin_app.include_router(feedback_router)
 admin_app.include_router(admins_router)
 admin_app.include_router(audit_router)
 admin_app.include_router(config_router)
-admin_app.include_router(ad_audit_router)
@@ -1,168 +0,0 @@
-"""看广告金币审计:复算 expected_coin 并与实发对比。
-
-只读。复用 [app.core.rewards] 的公式函数(不另写公式,避免与正式发奖口径漂移):
- 看视频:每条 granted = 1 份,第 N 份 = 当日该用户 granted 的 reward_video 顺序号
-  (与 ad_reward.grant_ad_reward 里 `_granted_today + 1` 一致)。
- 信息流:每条按 unit_count 份逐份累加,LT 序号 = 当日该用户已 granted 份数累计
-  (与 ad_feed_reward._unit_reward_total 的 existing_units 一致)。
-
-非 granted(capped/ecpm_missing)不占用份序号、应发恒 0,据此校验闸口是否确实没发。
-"""
-from __future__ import annotations
-
-from sqlalchemy import select
-from sqlalchemy.orm import Session
-
-from app.core import rewards
-from app.models.ad_feed_reward import AdFeedRewardRecord
-from app.models.ad_reward import AdRewardRecord
-from app.repositories.ad_feed_reward import FEED_REWARD_UNIT_SECONDS
-
-
-def _reward_video_rows(
-    db: Session, *, date: str, user_id: int | None
-) -> list[dict]:
-    """看视频记录复算。按 (user_id, created_at) 升序还原当日第 N 份。"""
-    stmt = (
-        select(AdRewardRecord)
-        .where(
-            AdRewardRecord.reward_date == date,
-            AdRewardRecord.reward_scene == "reward_video",
-        )
-        .order_by(AdRewardRecord.user_id, AdRewardRecord.created_at)
-    )
-    if user_id is not None:
-        stmt = stmt.where(AdRewardRecord.user_id == user_id)
-
-    granted_n: dict[int, int] = {}  # user_id -> 已 granted 份数
-    rows: list[dict] = []
-    for rec in db.execute(stmt).scalars():
-        if rec.status == "granted":
-            nth = granted_n.get(rec.user_id, 0) + 1
-            granted_n[rec.user_id] = nth
-            expected = rewards.calculate_ad_reward_coin(rec.ecpm_raw, nth)
-            rows.append({
-                "scene": "reward_video",
-                "record_id": rec.id,
-                "user_id": rec.user_id,
-                "created_at": rec.created_at,
-                "status": rec.status,
-                "ecpm": rec.ecpm_raw,
-                "ecpm_factor": rewards.ad_ecpm_factor(rewards.parse_ecpm_yuan(rec.ecpm_raw)),
-                "units": 1,
-                "lt_index_start": nth,
-                "lt_index_end": nth,
-                "lt_factor_start": rewards.ad_lt_factor(nth),
-                "lt_factor_end": rewards.ad_lt_factor(nth),
-                "expected_coin": expected,
-                "actual_coin": rec.coin,
-                "matched": expected == rec.coin,
-            })
-        else:
-            # capped / ecpm_missing:不发金币,校验实发确为 0
-            rows.append({
-                "scene": "reward_video",
-                "record_id": rec.id,
-                "user_id": rec.user_id,
-                "created_at": rec.created_at,
-                "status": rec.status,
-                "ecpm": rec.ecpm_raw,
-                "ecpm_factor": None,
-                "units": 1,
-                "lt_index_start": None,
-                "lt_index_end": None,
-                "lt_factor_start": None,
-                "lt_factor_end": None,
-                "expected_coin": 0,
-                "actual_coin": rec.coin,
-                "matched": rec.coin == 0,
-            })
-    return rows
-
-
-def _feed_rows(db: Session, *, date: str, user_id: int | None) -> list[dict]:
-    """信息流记录复算。granted 记录逐份累加,LT 序号沿用当日累计份数。"""
-    stmt = (
-        select(AdFeedRewardRecord)
-        .where(AdFeedRewardRecord.reward_date == date)
-        .order_by(AdFeedRewardRecord.user_id, AdFeedRewardRecord.created_at)
-    )
-    if user_id is not None:
-        stmt = stmt.where(AdFeedRewardRecord.user_id == user_id)
-
-    granted_units: dict[int, int] = {}  # user_id -> 已 granted 份数累计
-    rows: list[dict] = []
-    for rec in db.execute(stmt).scalars():
-        if rec.status == "granted":
-            existing = granted_units.get(rec.user_id, 0)
-            units = rec.unit_count
-            expected = sum(
-                rewards.calculate_ad_reward_coin(rec.ecpm_raw, existing + offset)
-                for offset in range(1, units + 1)
-            )
-            granted_units[rec.user_id] = existing + units
-            start = existing + 1 if units > 0 else None
-            end = existing + units if units > 0 else None
-            rows.append({
-                "scene": "feed",
-                "record_id": rec.id,
-                "user_id": rec.user_id,
-                "created_at": rec.created_at,
-                "status": rec.status,
-                "ecpm": rec.ecpm_raw,
-                "ecpm_factor": rewards.ad_ecpm_factor(rewards.parse_ecpm_yuan(rec.ecpm_raw)),
-                "units": units,
-                "lt_index_start": start,
-                "lt_index_end": end,
-                "lt_factor_start": rewards.ad_lt_factor(start) if start else None,
-                "lt_factor_end": rewards.ad_lt_factor(end) if end else None,
-                "expected_coin": expected,
-                "actual_coin": rec.coin,
-                "matched": expected == rec.coin,
-            })
-        else:
-            rows.append({
-                "scene": "feed",
-                "record_id": rec.id,
-                "user_id": rec.user_id,
-                "created_at": rec.created_at,
-                "status": rec.status,
-                "ecpm": rec.ecpm_raw,
-                "ecpm_factor": None,
-                "units": rec.unit_count,
-                "lt_index_start": None,
-                "lt_index_end": None,
-                "lt_factor_start": None,
-                "lt_factor_end": None,
-                "expected_coin": 0,
-                "actual_coin": rec.coin,
-                "matched": rec.coin == 0,
-            })
-    return rows
-
-
-def ad_coin_audit(
-    db: Session, *, date: str, user_id: int | None, scene: str | None, limit: int
-) -> list[dict]:
-    """返回当日发奖复算明细,按 created_at 倒序(最新在前)截断到 limit。
-
-    scene: None=两类都要 / "reward_video" / "feed"。
-    份序号在截断前已基于全天数据算好,故 limit 只影响展示条数、不影响 expected 复算正确性。
-    """
-    rows: list[dict] = []
-    if scene in (None, "reward_video"):
-        rows.extend(_reward_video_rows(db, date=date, user_id=user_id))
-    if scene in (None, "feed"):
-        rows.extend(_feed_rows(db, date=date, user_id=user_id))
-    rows.sort(key=lambda r: r["created_at"], reverse=True)
-    return rows[:limit]
-
-
-def formula_snapshot() -> dict:
-    """当前公式参数快照(给前端展示规则参照)。直接读 rewards 常量,与发奖同源。"""
-    return {
-        "coin_per_yuan": rewards.COIN_PER_YUAN,
-        "feed_unit_seconds": FEED_REWARD_UNIT_SECONDS,
-        "ecpm_factor_tiers": [list(t) for t in rewards.AD_ECPM_FACTOR_TABLE],
-        "lt_factor_tiers": [list(t) for t in rewards.AD_LT_FACTOR_TABLE],
-    }
@@ -8,13 +8,9 @@ set_user_status / update_feedback_status 支持 commit=False,让 router 把"业
 """
 from __future__ import annotations

-from datetime import datetime
-
 from sqlalchemy.orm import Session

-from app.core.rewards import CN_TZ
 from app.models.feedback import Feedback
-from app.models.price_report import PriceReport
 from app.models.user import User


@@ -28,20 +24,6 @@ def set_user_status(db: Session, user: User, *, status: str, commit: bool = True
    return user


-def set_user_debug_trace(
-    db: Session, user: User, *, enabled: bool, commit: bool = True
-) -> User:
-    """开关用户「复制调试链接」权限。同 set_user_status：支持 commit=False 让 router 把
-    业务写 + 审计写放进同一事务。"""
-    user.debug_trace_enabled = enabled
-    if commit:
-        db.commit()
-        db.refresh(user)
-    else:
-        db.flush()
-    return user
-
-
 def update_feedback_status(
    db: Session, feedback: Feedback, *, status: str, commit: bool = True
 ) -> Feedback:
@@ -52,30 +34,3 @@ def update_feedback_status(
    else:
        db.flush()
    return feedback
-
-
-def review_price_report(
-    db: Session,
-    report: PriceReport,
-    *,
-    status: str,
-    reward_coins: int | None = None,
-    reject_reason: str | None = None,
-    commit: bool = True,
-) -> PriceReport:
-    """审核上报:置 approved/rejected + 记审核时间;通过填 reward_coins、拒绝填 reject_reason。
-
-    发金币(wallet.grant_coins)不在这里——由 router 在同一事务里调,涉钱逻辑不重写(见模块头注释)。
-    """
-    report.status = status
-    if reward_coins is not None:
-        report.reward_coins = reward_coins
-    if reject_reason is not None:
-        report.reject_reason = reject_reason
-    report.reviewed_at = datetime.now(CN_TZ).replace(tzinfo=None)  # 北京 wall-clock,同 created_at
-    if commit:
-        db.commit()
-        db.refresh(report)
-    else:
-        db.flush()
-    return report
@@ -5,16 +5,11 @@
 """
 from __future__ import annotations

-from datetime import datetime, timedelta, timezone
-from zoneinfo import ZoneInfo
-
-from sqlalchemy import Select, asc, desc, func, or_, select
+from sqlalchemy import Select, func, select
 from sqlalchemy.orm import Session

-from app.models.admin import AdminAuditLog
 from app.models.comparison import ComparisonRecord
 from app.models.feedback import Feedback
-from app.models.price_report import PriceReport
 from app.models.user import User
 from app.models.wallet import CashTransaction, CoinAccount, CoinTransaction, WithdrawOrder

@@ -93,114 +88,15 @@ def list_all_withdraw_orders(
    *,
    user_id: int | None = None,
    status: str | None = None,
-    keyword: str | None = None,
-    date_from: datetime | None = None,
-    date_to: datetime | None = None,
-    date_field: str = "created_at",
-    sort_by: str = "created_at",
-    sort_order: str = "desc",
-    quick_filter: str | None = None,
    limit: int = 20,
    cursor: int | None = None,
 ) -> tuple[list[WithdrawOrder], int | None]:
    stmt = select(WithdrawOrder)
-    needs_user_join = bool(keyword and keyword.strip()) or quick_filter == "high_risk"
-    if needs_user_join:
-        stmt = stmt.outerjoin(User, User.id == WithdrawOrder.user_id)
-
    if user_id is not None:
        stmt = stmt.where(WithdrawOrder.user_id == user_id)
    if status:
        stmt = stmt.where(WithdrawOrder.status == status)
-
-    kw = (keyword or "").strip()
-    if kw:
-        pattern = f"%{kw}%"
-        conditions = [
-            WithdrawOrder.out_bill_no.ilike(pattern),
-            WithdrawOrder.transfer_bill_no.ilike(pattern),
-            WithdrawOrder.user_name.ilike(pattern),
-            WithdrawOrder.wechat_state.ilike(pattern),
-            WithdrawOrder.fail_reason.ilike(pattern),
-            User.phone.ilike(pattern),
-            User.nickname.ilike(pattern),
-            User.wechat_nickname.ilike(pattern),
-        ]
-        if kw.isdigit():
-            conditions.append(WithdrawOrder.user_id == int(kw))
-        stmt = stmt.where(or_(*conditions))
-
-    date_col = WithdrawOrder.updated_at if date_field == "updated_at" else WithdrawOrder.created_at
-    if date_from is not None:
-        stmt = stmt.where(date_col >= _as_utc_naive(date_from))
-    if date_to is not None:
-        stmt = stmt.where(date_col <= _as_utc_naive(date_to))
-
-    now = datetime.now(timezone.utc).replace(tzinfo=None)
-    today_start = (
-        datetime.now(ZoneInfo("Asia/Shanghai"))
-        .replace(hour=0, minute=0, second=0, microsecond=0)
-        .astimezone(timezone.utc)
-        .replace(tzinfo=None)
-    )
-    if quick_filter == "abnormal":
-        stmt = stmt.where(
-            or_(
-                WithdrawOrder.status.in_(("failed", "rejected")),
-                WithdrawOrder.fail_reason.is_not(None),
-                WithdrawOrder.wechat_state.in_(("FAIL", "CANCELLED", "CLOSED")),
-            )
-        )
-    elif quick_filter == "failed":
-        stmt = stmt.where(WithdrawOrder.status == "failed")
-    elif quick_filter == "overdue_reviewing":
-        stmt = stmt.where(
-            WithdrawOrder.status == "reviewing",
-            WithdrawOrder.created_at <= now - timedelta(minutes=30),
-        )
-    elif quick_filter == "pending_overdue":
-        stmt = stmt.where(
-            WithdrawOrder.status == "pending",
-            WithdrawOrder.updated_at <= now - timedelta(minutes=15),
-        )
-    elif quick_filter == "today":
-        stmt = stmt.where(WithdrawOrder.created_at >= today_start)
-    elif quick_filter == "high_risk":
-        stmt = stmt.where(
-            or_(
-                WithdrawOrder.user_name.is_(None),
-                WithdrawOrder.user_name == "",
-                User.status != "active",
-                User.created_at >= now - timedelta(hours=24),
-                WithdrawOrder.status.in_(("failed", "rejected")),
-                WithdrawOrder.fail_reason.is_not(None),
-            )
-        )
-
-    sort_cols = {
-        "id": WithdrawOrder.id,
-        "created_at": WithdrawOrder.created_at,
-        "updated_at": WithdrawOrder.updated_at,
-        "amount_cents": WithdrawOrder.amount_cents,
-    }
-    sort_col = sort_cols.get(sort_by, WithdrawOrder.created_at)
-    order_fn = asc if sort_order == "asc" else desc
-    id_order = asc(WithdrawOrder.id) if sort_order == "asc" else desc(WithdrawOrder.id)
-    stmt = stmt.order_by(order_fn(sort_col), id_order)
-
-    offset = max(cursor or 0, 0)
-    rows = list(db.execute(stmt.offset(offset).limit(limit + 1)).scalars().all())
-    has_more = len(rows) > limit
-    items = rows[:limit]
-    next_cursor = offset + limit if has_more else None
-    return items, next_cursor
-
-
-def _as_utc_naive(value: datetime) -> datetime:
-    """前端传 ISO 时间;DB 当前按 UTC naive 比较最稳(SQLite/本地开发一致)。"""
-    if value.tzinfo is None:
-        return value
-    return value.astimezone(timezone.utc).replace(tzinfo=None)
+    return cursor_paginate(db, stmt, WithdrawOrder.id, limit=limit, cursor=cursor)


 def list_feedbacks(
@@ -226,147 +122,6 @@ def get_withdraw_by_out_bill_no(db: Session, out_bill_no: str) -> WithdrawOrder
    ).scalar_one_or_none()


-def withdraw_summary(db: Session) -> dict:
-    """提现审核台顶部统计。金额单位:分。"""
-    rows = db.execute(
-        select(
-            WithdrawOrder.status,
-            func.count(WithdrawOrder.id),
-            func.coalesce(func.sum(WithdrawOrder.amount_cents), 0),
-        ).group_by(WithdrawOrder.status)
-    ).all()
-    by_status = {
-        status: {"count": int(count), "amount_cents": int(amount_cents)}
-        for status, count, amount_cents in rows
-    }
-
-    today_start = (
-        datetime.now(ZoneInfo("Asia/Shanghai"))
-        .replace(hour=0, minute=0, second=0, microsecond=0)
-        .astimezone(timezone.utc)
-    )
-
-    def _today_count(status: str) -> int:
-        return db.execute(
-            select(func.count(WithdrawOrder.id)).where(
-                WithdrawOrder.status == status,
-                WithdrawOrder.updated_at >= today_start,
-            )
-        ).scalar_one()
-
-    today_success_amount = db.execute(
-        select(func.coalesce(func.sum(WithdrawOrder.amount_cents), 0)).where(
-            WithdrawOrder.status == "success",
-            WithdrawOrder.updated_at >= today_start,
-        )
-    ).scalar_one()
-
-    return {
-        "reviewing_count": by_status.get("reviewing", {}).get("count", 0),
-        "reviewing_amount_cents": by_status.get("reviewing", {}).get("amount_cents", 0),
-        "pending_count": by_status.get("pending", {}).get("count", 0),
-        "failed_count": by_status.get("failed", {}).get("count", 0),
-        "today_success_count": _today_count("success"),
-        "today_success_amount_cents": int(today_success_amount),
-        "today_rejected_count": _today_count("rejected"),
-    }
-
-
-def list_withdraw_audit_logs(
-    db: Session, out_bill_no: str, *, limit: int = 20
-) -> list[AdminAuditLog]:
-    return list(
-        db.execute(
-            select(AdminAuditLog)
-            .where(AdminAuditLog.target_type == "withdraw", AdminAuditLog.target_id == out_bill_no)
-            .order_by(AdminAuditLog.id.desc())
-            .limit(limit)
-        ).scalars().all()
-    )
-
-
-def withdraw_risk_flags(
-    order: WithdrawOrder,
-    user: User | None,
-    recent_withdraws: list[WithdrawOrder],
-    cash_balance_cents: int,
-) -> tuple[list[str], int]:
-    flags: list[str] = []
-    if not order.user_name:
-        flags.append("缺少提现实名")
-    if user and user.status != "active":
-        flags.append(f"账号状态:{user.status}")
-    if user and user.created_at:
-        created_at = user.created_at.replace(tzinfo=timezone.utc) if user.created_at.tzinfo is None else user.created_at
-        if datetime.now(timezone.utc) - created_at < timedelta(hours=24):
-            flags.append("新注册用户")
-    failed_or_rejected = sum(1 for item in recent_withdraws if item.status in {"failed", "rejected"})
-    if failed_or_rejected:
-        flags.append(f"历史异常提现{failed_or_rejected}笔")
-    recent_reviewing = sum(1 for item in recent_withdraws if item.status == "reviewing")
-    if recent_reviewing >= 3:
-        flags.append(f"待审核提现偏多:{recent_reviewing}笔")
-    if cash_balance_cents < 0:
-        flags.append("现金余额为负")
-    score = min(100, len(flags) * 20 + failed_or_rejected * 10)
-    return flags, score
-
-
-def withdraw_ledger_check(db: Session) -> dict:
-    cash_balance_total = int(
-        db.execute(select(func.coalesce(func.sum(CoinAccount.cash_balance_cents), 0))).scalar_one()
-    )
-    cash_txn_total = int(
-        db.execute(select(func.coalesce(func.sum(CashTransaction.amount_cents), 0))).scalar_one()
-    )
-
-    orders = list(db.execute(select(WithdrawOrder)).scalars().all())
-    cash_txns = list(
-        db.execute(
-            select(CashTransaction).where(
-                CashTransaction.biz_type.in_(("withdraw", "withdraw_refund"))
-            )
-        ).scalars().all()
-    )
-    withdraw_refs = {txn.ref_id for txn in cash_txns if txn.biz_type == "withdraw"}
-    refund_counts: dict[str, int] = {}
-    for txn in cash_txns:
-        if txn.biz_type == "withdraw_refund" and txn.ref_id:
-            refund_counts[txn.ref_id] = refund_counts.get(txn.ref_id, 0) + 1
-
-    missing_withdraw = 0
-    missing_refund = 0
-    refund_on_non_terminal = 0
-    for order in orders:
-        if order.out_bill_no not in withdraw_refs:
-            missing_withdraw += 1
-        has_refund = refund_counts.get(order.out_bill_no, 0) > 0
-        if order.status in {"failed", "rejected"} and not has_refund:
-            missing_refund += 1
-        if has_refund and order.status not in {"failed", "rejected"}:
-            refund_on_non_terminal += 1
-
-    duplicate_refund = sum(1 for count in refund_counts.values() if count > 1)
-    diff = cash_balance_total - cash_txn_total
-    ok = (
-        diff == 0
-        and missing_withdraw == 0
-        and missing_refund == 0
-        and duplicate_refund == 0
-        and refund_on_non_terminal == 0
-    )
-    return {
-        "ok": ok,
-        "cash_balance_total_cents": cash_balance_total,
-        "cash_transaction_total_cents": cash_txn_total,
-        "balance_diff_cents": diff,
-        "missing_withdraw_txn_count": missing_withdraw,
-        "missing_refund_txn_count": missing_refund,
-        "duplicate_refund_txn_count": duplicate_refund,
-        "refund_txn_on_non_terminal_count": refund_on_non_terminal,
-    }
-
-
 def get_user_overview(db: Session, user_id: int) -> dict | None:
    """用户 360 概览:基础资料 + 钱包余额 + 各项 count。历史明细走各自分页接口(带 user_id 过滤)。"""
    user = db.get(User, user_id)
@@ -396,34 +151,3 @@ def get_user_overview(db: Session, user_id: int) -> dict | None:
        ).scalar_one(),
        "feedback_total": _count(Feedback, Feedback.user_id == user_id),
    }
-
-
-def list_price_reports(
-    db: Session,
-    *,
-    status: str | None = None,
-    user_id: int | None = None,
-    limit: int = 20,
-    cursor: int | None = None,
-) -> tuple[list[PriceReport], int | None]:
-    """上报更低价列表(admin 全量,可按状态/用户筛)。游标同 feedback:id 倒序。"""
-    stmt = select(PriceReport)
-    if status:
-        stmt = stmt.where(PriceReport.status == status)
-    if user_id is not None:
-        stmt = stmt.where(PriceReport.user_id == user_id)
-    return cursor_paginate(db, stmt, PriceReport.id, limit=limit, cursor=cursor)
-
-
-def price_report_summary(db: Session) -> dict:
-    """上报审核台各状态计数(待审核/已通过/已拒绝/合计)。"""
-    rows = db.execute(
-        select(PriceReport.status, func.count(PriceReport.id)).group_by(PriceReport.status)
-    ).all()
-    by_status = {status: int(count) for status, count in rows}
-    return {
-        "pending": by_status.get("pending", 0),
-        "approved": by_status.get("approved", 0),
-        "rejected": by_status.get("rejected", 0),
-        "total": sum(by_status.values()),
-    }
@@ -1,44 +0,0 @@
-"""admin 看广告金币审计:只读对账,核对发奖金币是否按公式计算。
-
-任意已登录 admin 可看(只读,不涉及资金操作)。复算逻辑在 app/admin/repositories/ad_audit.py。
-"""
-from __future__ import annotations
-
-from typing import Annotated
-
-from fastapi import APIRouter, Depends, Query
-
-from app.admin.deps import AdminDb, get_current_admin
-from app.admin.repositories import ad_audit
-from app.admin.schemas.ad_audit import AdCoinAuditOut, AdCoinAuditRow, AdCoinFormulaOut
-from app.core.rewards import cn_today
-
-router = APIRouter(
-    prefix="/admin/api/ad-coin-audit",
-    tags=["admin-ad-coin-audit"],
-    dependencies=[Depends(get_current_admin)],
-)
-
-
-@router.get("", response_model=AdCoinAuditOut, summary="看广告金币公式审计(复算对比)")
-def get_ad_coin_audit(
-    db: AdminDb,
-    date: Annotated[str | None, Query(description="北京时间 YYYY-MM-DD,默认今天")] = None,
-    user_id: Annotated[int | None, Query(description="只看某用户;不传=全部用户")] = None,
-    scene: Annotated[
-        str | None, Query(description="reward_video / feed;不传=两类都要")
-    ] = None,
-    limit: Annotated[int, Query(ge=1, le=500)] = 100,
-) -> AdCoinAuditOut:
-    audit_date = date or cn_today().isoformat()
-    rows = ad_audit.ad_coin_audit(
-        db, date=audit_date, user_id=user_id, scene=scene, limit=limit,
-    )
-    items = [AdCoinAuditRow(**r) for r in rows]
-    return AdCoinAuditOut(
-        date=audit_date,
-        formula=AdCoinFormulaOut(**ad_audit.formula_snapshot()),
-        total=len(items),
-        mismatch_count=sum(1 for it in items if not it.matched),
-        items=items,
-    )
@@ -1,103 +0,0 @@
-"""admin 上报更低价审核:列表 + 统计(读)+ 通过(发金币)/拒绝(写,带审计)。
-
-数据由客户端 POST /api/v1/report 写入 price_report 表(提交即 pending);本路由是运营后台
-对它的人工审核窗口。**通过** → 给上报用户钱包发固定金币(PRICE_REPORT_REWARD_COINS):
-改状态 + 发金币(wallet.grant_coins)+ 审计同一事务一起 commit(原子,仿 users.grant_user_coins),
-绝不只改状态不发钱或反之。客户端轮询 GET /api/v1/report/records 自动看到结果(无需推送)。
-"""
-from __future__ import annotations
-
-from typing import Annotated
-
-from fastapi import APIRouter, Depends, HTTPException, Query, Request
-
-from app.admin.audit import write_audit
-from app.admin.deps import AdminDb, get_client_ip, get_current_admin, require_role
-from app.admin.repositories import mutations, queries
-from app.admin.schemas.common import CursorPage, OkResponse
-from app.admin.schemas.price_report import (
-    PriceReportOut,
-    PriceReportRejectRequest,
-    PriceReportSummary,
-)
-from app.core.rewards import PRICE_REPORT_REWARD_COINS
-from app.models.admin import AdminUser
-from app.models.price_report import PriceReport
-from app.repositories import wallet as wallet_repo
-
-router = APIRouter(
-    prefix="/admin/api/price-reports",
-    tags=["admin-price-report"],
-    dependencies=[Depends(get_current_admin)],
-)
-
-
-@router.get("", response_model=CursorPage[PriceReportOut], summary="上报更低价列表(筛选+分页)")
-def list_price_reports(
-    db: AdminDb,
-    status: Annotated[str | None, Query()] = None,
-    user_id: Annotated[int | None, Query()] = None,
-    limit: Annotated[int, Query(ge=1, le=100)] = 20,
-    cursor: Annotated[int | None, Query()] = None,
-) -> CursorPage[PriceReportOut]:
-    items, next_cursor = queries.list_price_reports(
-        db, status=status, user_id=user_id, limit=limit, cursor=cursor,
-    )
-    return CursorPage(
-        items=[PriceReportOut.model_validate(r) for r in items], next_cursor=next_cursor,
-    )
-
-
-@router.get("/summary", response_model=PriceReportSummary, summary="上报审核统计(各状态计数)")
-def price_report_summary(db: AdminDb) -> PriceReportSummary:
-    return PriceReportSummary.model_validate(queries.price_report_summary(db))
-
-
-@router.post("/{report_id}/approve", response_model=OkResponse, summary="通过上报(发固定金币)")
-def approve_price_report(
-    report_id: int,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("operator"))],
-    db: AdminDb,
-) -> OkResponse:
-    rep = db.get(PriceReport, report_id)
-    if rep is None:
-        raise HTTPException(status_code=404, detail="上报记录不存在")
-    if rep.status != "pending":
-        raise HTTPException(status_code=400, detail=f"该上报已审核过(当前 {rep.status}),不可重复操作")
-    coins = PRICE_REPORT_REWARD_COINS
-    # 改状态 + 发金币 + 审计同一事务(commit=False),最后一起 commit:改了就有痕、发了就留账
-    mutations.review_price_report(db, rep, status="approved", reward_coins=coins, commit=False)
-    wallet_repo.grant_coins(
-        db, rep.user_id, coins,
-        biz_type="price_report_reward", ref_id=str(rep.id), remark="上报更低价审核通过",
-    )
-    write_audit(
-        db, admin, action="price_report.approve", target_type="price_report", target_id=report_id,
-        detail={"reward_coins": coins, "user_id": rep.user_id}, ip=get_client_ip(request), commit=False,
-    )
-    db.commit()
-    return OkResponse()
-
-
-@router.post("/{report_id}/reject", response_model=OkResponse, summary="拒绝上报")
-def reject_price_report(
-    report_id: int,
-    body: PriceReportRejectRequest,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("operator"))],
-    db: AdminDb,
-) -> OkResponse:
-    rep = db.get(PriceReport, report_id)
-    if rep is None:
-        raise HTTPException(status_code=404, detail="上报记录不存在")
-    if rep.status != "pending":
-        raise HTTPException(status_code=400, detail=f"该上报已审核过(当前 {rep.status}),不可重复操作")
-    reason = body.reason.strip()
-    mutations.review_price_report(db, rep, status="rejected", reject_reason=reason, commit=False)
-    write_audit(
-        db, admin, action="price_report.reject", target_type="price_report", target_id=report_id,
-        detail={"reason": reason, "user_id": rep.user_id}, ip=get_client_ip(request), commit=False,
-    )
-    db.commit()
-    return OkResponse()
@@ -13,7 +13,6 @@ from app.admin.schemas.user import (
    AdminUserListItem,
    AdminUserOverview,
    GrantCoinsRequest,
-    SetDebugTraceRequest,
    SetUserStatusRequest,
 )
 from app.models.admin import AdminUser
@@ -78,28 +77,6 @@ def set_user_status(
    return OkResponse()


-@router.post("/{user_id}/debug-trace", response_model=OkResponse, summary="开关调试链接权限")
-def set_user_debug_trace(
-    user_id: int,
-    body: SetDebugTraceRequest,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("operator"))],
-    db: AdminDb,
-) -> OkResponse:
-    user = user_repo.get_user_by_id(db, user_id)
-    if user is None:
-        raise HTTPException(status_code=404, detail="用户不存在")
-    before = user.debug_trace_enabled
-    # 业务写 + 审计写同一事务(commit=False),最后一起 commit(同 set_user_status)
-    mutations.set_user_debug_trace(db, user, enabled=body.enabled, commit=False)
-    write_audit(
-        db, admin, action="user.debug_trace.set", target_type="user", target_id=user_id,
-        detail={"before": before, "after": body.enabled}, ip=get_client_ip(request), commit=False,
-    )
-    db.commit()
-    return OkResponse()
-
-
@router.post("/{user_id}/coins", response_model=OkResponse, summary="手动增减金币(带审计)")
 def grant_user_coins(
    user_id: int,
@@ -6,7 +6,6 @@
 """
 from __future__ import annotations

-from datetime import datetime
 from typing import Annotated

 from fastapi import APIRouter, Depends, HTTPException, Query, Request
@@ -15,23 +14,7 @@ from app.admin.audit import write_audit
 from app.admin.deps import AdminDb, get_client_ip, get_current_admin, require_role
 from app.admin.repositories import queries
 from app.admin.schemas.common import CursorPage
-from app.admin.schemas.admin import AdminAuditLogOut
-from app.admin.schemas.wallet import (
-    CashTxnOut,
-    ReconcileResult,
-    WithdrawBulkRejectRequest,
-    WithdrawBulkRequest,
-    WithdrawBulkResult,
-    WithdrawBulkItemResult,
-    WithdrawDetailOut,
-    WithdrawLedgerCheckOut,
-    WithdrawOrderOut,
-    WithdrawRejectRequest,
-    WithdrawSummaryOut,
-    WithdrawUserSnapshot,
-    WxpayHealthCheckOut,
-)
-from app.core.config import settings
+from app.admin.schemas.wallet import ReconcileResult, WithdrawOrderOut, WithdrawRejectRequest
 from app.integrations import wxpay
 from app.models.admin import AdminUser
 from app.repositories import wallet as wallet_repo
@@ -48,143 +31,17 @@ def list_withdraws(
    db: AdminDb,
    user_id: Annotated[int | None, Query()] = None,
    status: Annotated[str | None, Query()] = None,
-    keyword: Annotated[str | None, Query(max_length=100)] = None,
-    date_from: Annotated[datetime | None, Query()] = None,
-    date_to: Annotated[datetime | None, Query()] = None,
-    date_field: Annotated[str, Query(pattern="^(created_at|updated_at)$")] = "created_at",
-    sort_by: Annotated[
-        str, Query(pattern="^(id|created_at|updated_at|amount_cents)$")
-    ] = "created_at",
-    sort_order: Annotated[str, Query(pattern="^(asc|desc)$")] = "desc",
-    quick_filter: Annotated[
-        str | None,
-        Query(pattern="^(abnormal|failed|overdue_reviewing|pending_overdue|today|high_risk)$"),
-    ] = None,
    limit: Annotated[int, Query(ge=1, le=100)] = 20,
    cursor: Annotated[int | None, Query()] = None,
 ) -> CursorPage[WithdrawOrderOut]:
    items, next_cursor = queries.list_all_withdraw_orders(
-        db,
-        user_id=user_id,
-        status=status,
-        keyword=keyword,
-        date_from=date_from,
-        date_to=date_to,
-        date_field=date_field,
-        sort_by=sort_by,
-        sort_order=sort_order,
-        quick_filter=quick_filter,
-        limit=limit,
-        cursor=cursor,
+        db, user_id=user_id, status=status, limit=limit, cursor=cursor,
    )
    return CursorPage(
        items=[WithdrawOrderOut.model_validate(o) for o in items], next_cursor=next_cursor,
    )


-@router.get("/summary", response_model=WithdrawSummaryOut, summary="提现审核台统计")
-def withdraws_summary(db: AdminDb) -> WithdrawSummaryOut:
-    return WithdrawSummaryOut(**queries.withdraw_summary(db))
-
-
-@router.get("/health-check", response_model=WxpayHealthCheckOut, summary="提现配置健康检查")
-def withdraw_health_check() -> WxpayHealthCheckOut:
-    private_path = wxpay._resolve_config_path(settings.WXPAY_MCH_PRIVATE_KEY_PATH)  # noqa: SLF001
-    public_path = wxpay._resolve_config_path(settings.WXPAY_PUBLIC_KEY_PATH)  # noqa: SLF001
-    issues: list[str] = []
-
-    private_loadable = False
-    public_loadable = False
-    try:
-        wxpay._load_private_key()  # noqa: SLF001
-        private_loadable = True
-    except Exception as e:  # noqa: BLE001
-        issues.append(f"商户私钥不可用:{e}")
-    try:
-        wxpay._load_public_key()  # noqa: SLF001
-        public_loadable = True
-    except Exception as e:  # noqa: BLE001
-        issues.append(f"微信支付平台公钥不可用:{e}")
-
-    if not settings.wxpay_configured:
-        issues.append("微信支付基础配置不完整")
-    if not settings.WXPAY_AUTH_NOTIFY_URL:
-        issues.append("免确认授权回调地址未配置")
-    if not settings.WITHDRAW_AUTO_RECONCILE_ENABLED:
-        issues.append("自动对账未开启")
-
-    return WxpayHealthCheckOut(
-        ok=not issues,
-        wxpay_configured=settings.wxpay_configured,
-        wxpay_auth_configured=settings.wxpay_auth_configured,
-        private_key_path=str(private_path),
-        private_key_exists=private_path.exists(),
-        private_key_loadable=private_loadable,
-        public_key_path=str(public_path),
-        public_key_exists=public_path.exists(),
-        public_key_loadable=public_loadable,
-        auth_notify_url_configured=bool(settings.WXPAY_AUTH_NOTIFY_URL),
-        auto_reconcile_enabled=settings.WITHDRAW_AUTO_RECONCILE_ENABLED,
-        auto_reconcile_interval_sec=settings.WITHDRAW_AUTO_RECONCILE_INTERVAL_SEC,
-        auto_reconcile_older_than_minutes=settings.WITHDRAW_AUTO_RECONCILE_OLDER_THAN_MINUTES,
-        issues=issues,
-    )
-
-
-@router.get("/ledger-check", response_model=WithdrawLedgerCheckOut, summary="提现资金账本校验")
-def withdraw_ledger_check(db: AdminDb) -> WithdrawLedgerCheckOut:
-    return WithdrawLedgerCheckOut(**queries.withdraw_ledger_check(db))
-
-
-@router.get("/{out_bill_no}", response_model=WithdrawDetailOut, summary="提现单详情")
-def withdraw_detail(out_bill_no: str, db: AdminDb) -> WithdrawDetailOut:
-    order = queries.get_withdraw_by_out_bill_no(db, out_bill_no)
-    if order is None:
-        raise HTTPException(status_code=404, detail="提现单不存在")
-
-    overview = queries.get_user_overview(db, order.user_id)
-    user_snapshot = None
-    if overview is not None:
-        user = overview["user"]
-        user_snapshot = WithdrawUserSnapshot(
-            id=user.id,
-            phone=user.phone,
-            nickname=user.nickname,
-            status=user.status,
-            wechat_nickname=user.wechat_nickname,
-            wechat_avatar_url=user.wechat_avatar_url,
-            created_at=user.created_at,
-            last_login_at=user.last_login_at,
-            cash_balance_cents=overview["cash_balance_cents"],
-            withdraw_total=overview["withdraw_total"],
-            withdraw_success_cents=overview["withdraw_success_cents"],
-        )
-
-    recent_withdraws, _ = queries.list_all_withdraw_orders(
-        db, user_id=order.user_id, limit=5, cursor=None,
-    )
-    recent_cash_transactions, _ = queries.list_all_cash_transactions(
-        db, user_id=order.user_id, limit=8, cursor=None,
-    )
-    audit_logs = queries.list_withdraw_audit_logs(db, out_bill_no, limit=10)
-    risk_flags, risk_score = queries.withdraw_risk_flags(
-        order,
-        overview["user"] if overview else None,
-        recent_withdraws,
-        overview["cash_balance_cents"] if overview else 0,
-    )
-
-    return WithdrawDetailOut(
-        order=WithdrawOrderOut.model_validate(order),
-        user=user_snapshot,
-        risk_flags=risk_flags,
-        risk_score=risk_score,
-        recent_withdraws=[WithdrawOrderOut.model_validate(o) for o in recent_withdraws],
-        recent_cash_transactions=[CashTxnOut.model_validate(t) for t in recent_cash_transactions],
-        audit_logs=[AdminAuditLogOut.model_validate(log) for log in audit_logs],
-    )
-
-
 # 注意:/reconcile 必须在 /{out_bill_no}/refresh 之前声明(静态路径优先于路径参数)
@router.post("/reconcile", response_model=ReconcileResult, summary="批量对账(扫超时 pending 单)")
 def reconcile(
@@ -204,159 +61,6 @@ def reconcile(
    return ReconcileResult(**result)


-def _bulk_result(items: list[WithdrawBulkItemResult]) -> WithdrawBulkResult:
-    success = sum(1 for item in items if item.ok)
-    return WithdrawBulkResult(
-        total=len(items),
-        success=success,
-        failed=len(items) - success,
-        items=items,
-    )
-
-
-@router.post("/bulk/refresh", response_model=WithdrawBulkResult, summary="批量刷新查单")
-def bulk_refresh_withdraws(
-    body: WithdrawBulkRequest,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("finance"))],
-    db: AdminDb,
-) -> WithdrawBulkResult:
-    results: list[WithdrawBulkItemResult] = []
-    ip = get_client_ip(request)
-    for out_bill_no in body.out_bill_nos:
-        try:
-            order = queries.get_withdraw_by_out_bill_no(db, out_bill_no)
-            if order is None:
-                raise wallet_repo.WithdrawOrderNotFound
-            refreshed = wallet_repo.refresh_withdraw_status(
-                db, order.user_id, out_bill_no, cancel_if_unconfirmed=True,
-            )
-            write_audit(
-                db, admin, action="withdraw.refresh", target_type="withdraw",
-                target_id=out_bill_no,
-                detail={
-                    "status": refreshed.status,
-                    "wechat_state": refreshed.wechat_state,
-                    "fail_reason": refreshed.fail_reason,
-                    "bulk": True,
-                },
-                ip=ip, commit=True,
-            )
-            results.append(
-                WithdrawBulkItemResult(
-                    out_bill_no=out_bill_no, ok=True, status=refreshed.status
-                )
-            )
-        except wallet_repo.WithdrawOrderNotFound:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error="提现单不存在")
-            )
-        except wxpay.WxPayNotConfiguredError:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error="微信支付未配置")
-            )
-        except Exception as e:  # noqa: BLE001 - 批量操作单笔失败不打断整批
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error=f"系统异常: {e}")
-            )
-    return _bulk_result(results)
-
-
-@router.post("/bulk/approve", response_model=WithdrawBulkResult, summary="批量审核通过并打款")
-def bulk_approve_withdraws(
-    body: WithdrawBulkRequest,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("finance"))],
-    db: AdminDb,
-) -> WithdrawBulkResult:
-    results: list[WithdrawBulkItemResult] = []
-    ip = get_client_ip(request)
-    for out_bill_no in body.out_bill_nos:
-        try:
-            order = wallet_repo.approve_withdraw(db, out_bill_no)
-            write_audit(
-                db, admin, action="withdraw.approve", target_type="withdraw",
-                target_id=out_bill_no,
-                detail={
-                    "status": order.status,
-                    "wechat_state": order.wechat_state,
-                    "amount_cents": order.amount_cents,
-                    "bulk": True,
-                },
-                ip=ip, commit=True,
-            )
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=True, status=order.status)
-            )
-        except wallet_repo.WithdrawOrderNotFound:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error="提现单不存在")
-            )
-        except wallet_repo.WithdrawNotReviewable as e:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error=str(e))
-            )
-        except wxpay.WxPayNotConfiguredError:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error="微信支付未配置")
-            )
-        except Exception as e:  # noqa: BLE001 - 批量操作单笔失败不打断整批
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error=f"系统异常: {e}")
-            )
-    return _bulk_result(results)
-
-
-@router.post("/bulk/reject", response_model=WithdrawBulkResult, summary="批量审核拒绝并退款")
-def bulk_reject_withdraws(
-    body: WithdrawBulkRejectRequest,
-    request: Request,
-    admin: Annotated[AdminUser, Depends(require_role("finance"))],
-    db: AdminDb,
-) -> WithdrawBulkResult:
-    results: list[WithdrawBulkItemResult] = []
-    ip = get_client_ip(request)
-    for out_bill_no in body.out_bill_nos:
-        try:
-            order = wallet_repo.reject_withdraw(db, out_bill_no, body.reason)
-            write_audit(
-                db, admin, action="withdraw.reject", target_type="withdraw",
-                target_id=out_bill_no,
-                detail={
-                    "reason": body.reason,
-                    "amount_cents": order.amount_cents,
-                    "bulk": True,
-                },
-                ip=ip, commit=True,
-            )
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=True, status=order.status)
-            )
-        except wallet_repo.WithdrawOrderNotFound:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error="提现单不存在")
-            )
-        except wallet_repo.WithdrawNotReviewable as e:
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error=str(e))
-            )
-        except Exception as e:  # noqa: BLE001 - 批量操作单笔失败不打断整批
-            db.rollback()
-            results.append(
-                WithdrawBulkItemResult(out_bill_no=out_bill_no, ok=False, error=f"系统异常: {e}")
-            )
-    return _bulk_result(results)
-
-
@router.post("/{out_bill_no}/refresh", response_model=WithdrawOrderOut, summary="单笔重试查单")
 def refresh_withdraw(
    out_bill_no: str,
@@ -375,11 +79,7 @@ def refresh_withdraw(
        raise HTTPException(status_code=503, detail="微信支付未配置") from e
    write_audit(
        db, admin, action="withdraw.refresh", target_type="withdraw", target_id=out_bill_no,
-        detail={
-            "status": refreshed.status,
-            "wechat_state": refreshed.wechat_state,
-            "fail_reason": refreshed.fail_reason,
-        },
+        detail={"status": refreshed.status, "wechat_state": refreshed.wechat_state},
        ip=get_client_ip(request), commit=True,
    )
    return WithdrawOrderOut.model_validate(refreshed)
@@ -1,57 +0,0 @@
-"""看广告金币审计 schemas。
-
-只读对账视图:把"看视频"(ad_reward_record)和"信息流"(ad_feed_reward_record)两类发奖记录,
-用与正式发奖相同的公式 [app.core.rewards.calculate_ad_reward_coin] 复算一遍 expected_coin,
-和实际入账的 actual_coin 对比,核对金币公式是否生效。字段 snake_case、金额按金币整数。
-"""
-from __future__ import annotations
-
-from datetime import datetime
-
-from pydantic import BaseModel, Field
-
-
-class AdCoinAuditRow(BaseModel):
-    """单条发奖记录的复算明细。"""
-
-    scene: str = Field(..., description="reward_video(看视频) / feed(信息流)")
-    record_id: int = Field(..., description="对应记录表主键")
-    user_id: int
-    created_at: datetime
-    status: str = Field(..., description="granted / capped / ecpm_missing")
-    ecpm: str | None = Field(None, description="本次采用的 eCPM 原始值(分/千次展示,SDK getEcpm 原值)")
-    ecpm_factor: float | None = Field(None, description="因子1(eCPM 档)")
-    units: int = Field(..., description="折算份数:看视频恒为 1;信息流 = 满 10 秒的份数")
-    lt_index_start: int | None = Field(None, description="本条占用的当日第几份(起)")
-    lt_index_end: int | None = Field(None, description="本条占用的当日第几份(止);看视频 = 起")
-    lt_factor_start: float | None = Field(None, description="因子2(LT)起值")
-    lt_factor_end: float | None = Field(None, description="因子2(LT)止值;看视频 = 起值")
-    expected_coin: int = Field(..., description="按公式复算应发金币")
-    actual_coin: int = Field(..., description="实际入账金币")
-    matched: bool = Field(..., description="复算与实发是否一致(capped/ecpm_missing 校验是否确为 0)")
-
-
-class AdCoinFormulaOut(BaseModel):
-    """当前金币公式参数(给前端展示规则参照)。"""
-
-    description: str = Field(
-        "eCPM元 = getEcpm分 ÷ 100;单份金币 = round(eCPM元 ÷ 1000 × 因子1 × 因子2 × coin_per_yuan);"
-        "因子1 按 eCPM元 判档(阈值 100/200/400 元)",
-        description="公式说明",
-    )
-    coin_per_yuan: int = Field(..., description="金币:元 汇率")
-    ecpm_unit: str = Field("分/千次展示(SDK getEcpm 原值)", description="eCPM 口径")
-    feed_unit_seconds: int = Field(..., description="信息流每多少秒折 1 份")
-    # [(因子值, 区间下限, 区间上限或 null)]
-    ecpm_factor_tiers: list[tuple[float, int, int | None]] = Field(..., description="因子1 档位表")
-    lt_factor_tiers: list[tuple[float, int, int | None]] = Field(..., description="因子2 LT 档位表")
-
-
-class AdCoinAuditOut(BaseModel):
-    """审计响应:公式参照 + 命中条数 + 明细。"""
-
-    date: str = Field(..., description="审计日期(北京时间 YYYY-MM-DD)")
-    formula: AdCoinFormulaOut
-    total: int = Field(..., description="返回的明细条数")
-    mismatch_count: int = Field(..., description="其中 matched=false 的条数(=0 说明公式全部生效)")
-    items: list[AdCoinAuditRow]
@@ -1,46 +0,0 @@
-"""admin 上报更低价审核 schemas。"""
-from __future__ import annotations
-
-from datetime import datetime
-
-from pydantic import BaseModel, ConfigDict, Field
-
-
-class PriceReportOut(BaseModel):
-    """admin 列表项:price_report 全字段(审核要看的快照 + 截图 + 状态 + 奖励)。"""
-
-    model_config = ConfigDict(from_attributes=True)
-
-    id: int
-    user_id: int
-    comparison_record_id: int | None = None
-    # 选中比价记录的快照
-    store_name: str | None = None
-    dish_summary: str | None = None
-    original_platform_id: str | None = None
-    original_platform_name: str | None = None
-    original_price_cents: int | None = None
-    # 用户上报的更低价
-    reported_platform_id: str
-    reported_platform_name: str
-    reported_price_cents: int
-    images: list[str] = []
-    # 审核
-    status: str
-    reject_reason: str | None = None
-    reward_coins: int | None = None
-    reviewed_at: datetime | None = None
-    created_at: datetime
-
-
-class PriceReportRejectRequest(BaseModel):
-    reason: str = Field(min_length=1, max_length=256, description="拒绝理由,用户端记录页会看到")
-
-
-class PriceReportSummary(BaseModel):
-    """审核台顶部各状态计数。"""
-
-    pending: int
-    approved: int
-    rejected: int
-    total: int
@@ -15,7 +15,6 @@ class AdminUserListItem(BaseModel):
    nickname: str | None = None
    register_channel: str
    status: str
-    debug_trace_enabled: bool = False
    wechat_openid: str | None = None
    created_at: datetime
    last_login_at: datetime
@@ -46,7 +45,3 @@ class SetUserStatusRequest(BaseModel):
    status: Literal["active", "disabled"] = Field(
        ..., description="active=解封 / disabled=封禁(注销 deleted 不走此接口)"
    )
-
-
-class SetDebugTraceRequest(BaseModel):
-    enabled: bool = Field(..., description="是否给该用户开「复制调试链接」权限")
@@ -5,8 +5,6 @@ from datetime import datetime

 from pydantic import BaseModel, ConfigDict, Field

-from app.admin.schemas.admin import AdminAuditLogOut
-

 class CoinTxnOut(BaseModel):
    model_config = ConfigDict(from_attributes=True)
@@ -50,99 +48,11 @@ class WithdrawOrderOut(BaseModel):
    updated_at: datetime


-class WithdrawSummaryOut(BaseModel):
-    reviewing_count: int
-    reviewing_amount_cents: int
-    pending_count: int
-    failed_count: int
-    today_success_count: int
-    today_success_amount_cents: int
-    today_rejected_count: int
-
-
-class WithdrawUserSnapshot(BaseModel):
-    id: int
-    phone: str
-    nickname: str | None = None
-    status: str
-    wechat_nickname: str | None = None
-    wechat_avatar_url: str | None = None
-    created_at: datetime
-    last_login_at: datetime
-    cash_balance_cents: int
-    withdraw_total: int
-    withdraw_success_cents: int
-
-
-class WithdrawDetailOut(BaseModel):
-    order: WithdrawOrderOut
-    user: WithdrawUserSnapshot | None = None
-    risk_flags: list[str]
-    risk_score: int
-    recent_withdraws: list[WithdrawOrderOut]
-    recent_cash_transactions: list[CashTxnOut]
-    audit_logs: list[AdminAuditLogOut]
-
-
 class ReconcileResult(BaseModel):
    checked: int
    resolved: int


-class WithdrawBulkRequest(BaseModel):
-    out_bill_nos: list[str] = Field(
-        ..., min_length=1, max_length=50, description="提现商户单号列表"
-    )
-
-
-class WithdrawBulkRejectRequest(WithdrawBulkRequest):
-    reason: str = Field(
-        ..., min_length=1, max_length=200, description="批量拒绝理由(用户可见)"
-    )
-
-
-class WithdrawBulkItemResult(BaseModel):
-    out_bill_no: str
-    ok: bool
-    status: str | None = None
-    error: str | None = None
-
-
-class WithdrawBulkResult(BaseModel):
-    total: int
-    success: int
-    failed: int
-    items: list[WithdrawBulkItemResult]
-
-
-class WithdrawLedgerCheckOut(BaseModel):
-    ok: bool
-    cash_balance_total_cents: int
-    cash_transaction_total_cents: int
-    balance_diff_cents: int
-    missing_withdraw_txn_count: int
-    missing_refund_txn_count: int
-    duplicate_refund_txn_count: int
-    refund_txn_on_non_terminal_count: int
-
-
-class WxpayHealthCheckOut(BaseModel):
-    ok: bool
-    wxpay_configured: bool
-    wxpay_auth_configured: bool
-    private_key_path: str
-    private_key_exists: bool
-    private_key_loadable: bool
-    public_key_path: str
-    public_key_exists: bool
-    public_key_loadable: bool
-    auth_notify_url_configured: bool
-    auto_reconcile_enabled: bool
-    auto_reconcile_interval_sec: int
-    auto_reconcile_older_than_minutes: int
-    issues: list[str]
-
-
 class WithdrawRejectRequest(BaseModel):
    reason: str = Field(
        ..., min_length=1, max_length=200, description="拒绝理由(写入 fail_reason,用户可见)"
@@ -304,18 +304,10 @@ def test_grant(user: CurrentUser, db: DbSession, payload: TestGrantIn | None = N
            db.commit()
            db.refresh(rec)
    else:
-        # 优先用客户端按 ad_session_id 上报的真实 eCPM(走与正式发奖相同的公式);
-        # 取不到或 eCPM≤0(测试应用常返 0/假值)时兜底 200,保证本地联调仍能验出非零金币。
-        ad_session_id = payload.ad_session_id if payload is not None else None
-        ecpm_val = "200"
-        if ad_session_id:
-            ecpm_rec = crud_ecpm.find_by_session(db, user_id=user.id, ad_session_id=ad_session_id)
-            if ecpm_rec is not None and rewards.parse_ecpm_fen(ecpm_rec.ecpm_raw) > 0:
-                ecpm_val = ecpm_rec.ecpm_raw
        try:
            rec = crud_ad.grant_ad_reward(
-                db, user.id, trans_id, ecpm=ecpm_val, ad_session_id=ad_session_id,
-                reward_name="测试发奖", raw=f"client debug test-grant ecpm={ecpm_val}",
+                db, user.id, trans_id, ecpm="200", reward_name="测试发奖",
+                raw="client debug test-grant ecpm=200",
            )
        except crud_ad.UnknownUserError as e:
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="user not found") from e
@@ -19,7 +19,6 @@ from app.core.ratelimit import rate_limit
 from app.core.security import TokenError, decode_token, issue_token_pair
 from app.integrations.jiguang import JiguangError, mask_phone, verify_and_get_phone
 from app.integrations.sms import SmsError, send_code, verify_code
-from app.repositories import onboarding as onboarding_repo
 from app.repositories import user as user_repo
 from app.schemas.auth import (
    JverifyLoginRequest,
@@ -38,13 +37,12 @@ logger = logging.getLogger("shagua.auth")
 router = APIRouter(prefix="/api/v1/auth", tags=["auth"])


-def _login_response(user, *, onboarding_completed: bool) -> TokenWithUser:
-    """登录类接口共用的响应组装。onboarding_completed 据登录请求的 device_id 算好后传入。"""
+def _login_response(db, user) -> TokenWithUser:
+    """登录类接口共用的响应组装。"""
    tokens = issue_token_pair(user.id)
    return TokenWithUser(
        **tokens,
        user=UserOut.model_validate(user),
-        onboarding_completed=onboarding_completed,
    )


@@ -68,9 +66,8 @@ def jverify_login(req: JverifyLoginRequest, db: DbSession) -> TokenWithUser:
    if user.status != "active":
        raise HTTPException(status_code=403, detail="account disabled")

-    completed = onboarding_repo.is_completed(db, user_id=user.id, device_id=req.device_id)
-    logger.info("jverify_login ok user_id=%d phone=%s onboarded=%s", user.id, mask_phone(phone), completed)
-    return _login_response(user, onboarding_completed=completed)
+    logger.info("jverify_login ok user_id=%d phone=%s", user.id, mask_phone(phone))
+    return _login_response(db, user)


 # ===================== 短信登录 =====================
@@ -106,9 +103,8 @@ def sms_login(req: SmsLoginRequest, db: DbSession) -> TokenWithUser:
    if user.status != "active":
        raise HTTPException(status_code=403, detail="account disabled")

-    completed = onboarding_repo.is_completed(db, user_id=user.id, device_id=req.device_id)
-    logger.info("sms_login ok user_id=%d phone=%s onboarded=%s", user.id, mask_phone(req.phone), completed)
-    return _login_response(user, onboarding_completed=completed)
+    logger.info("sms_login ok user_id=%d phone=%s", user.id, mask_phone(req.phone))
+    return _login_response(db, user)


 # ===================== Refresh =====================
@@ -77,12 +77,10 @@ def list_records(
    items, next_cursor = crud_compare.list_records(
        db, user.id, limit=limit, cursor=cursor
    )
-    outs = [ComparisonRecordOut.model_validate(it) for it in items]
-    # 权限闸:未开 debug_trace_enabled 的用户不下发 trace_url(列表页「复制调试链接」靠它)
-    if not user.debug_trace_enabled:
-        for o in outs:
-            o.trace_url = None
-    return ComparisonRecordPage(items=outs, next_cursor=next_cursor)
+    return ComparisonRecordPage(
+        items=[ComparisonRecordOut.model_validate(it) for it in items],
+        next_cursor=next_cursor,
+    )


@router.get(
@@ -96,12 +94,4 @@ def get_record(
    rec = crud_compare.get_record(db, user.id, record_id)
    if rec is None:
        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="record not found")
-    out = ComparisonRecordDetailOut.model_validate(rec)
-    # 权限闸:未开 debug_trace_enabled 的用户不下发 trace_url。
-    # ⚠️ raw_payload 是上报体全量(model_dump),里面也藏着一份 trace_url,必须一并抹掉——
-    # 否则无权限用户从详情接口的 raw_payload 绕过权限闸拿到 trace_url。
-    if not user.debug_trace_enabled:
-        out.trace_url = None
-        if isinstance(out.raw_payload, dict):
-            out.raw_payload.pop("trace_url", None)
-    return out
+    return ComparisonRecordDetailOut.model_validate(rec)
@@ -23,11 +23,7 @@ from app.core.config import settings
 from app.core.pricebot_router import pick_pricebot
 from app.db.session import SessionLocal
 from app.repositories import coupon_state as coupon_repo
-from app.schemas.coupon_state import (
-    CouponCompletedTodayOut,
-    CouponPromptDismissIn,
-    CouponPromptShouldShowOut,
-)
+from app.schemas.coupon_state import CouponPromptDismissIn, CouponPromptShouldShowOut

 logger = logging.getLogger("shagua.coupon")

@@ -80,14 +76,6 @@ def _record_claims_blocking(
        coupon_repo.record_claims(db, device_id, user_id, trace_id, results)


-def _mark_completed_blocking(
-    device_id: str, user_id: int | None, trace_id: str | None
-) -> None:
-    """独立 session 写"今日已跑完整轮"(到 done 帧那刻调,best-effort 不阻塞领券)。"""
-    with SessionLocal() as db:
-        coupon_repo.mark_completed_today(db, device_id, user_id, trace_id)
-
-
@router.post("/step", summary="领券任务步进 (透传到 pricebot)")
 async def coupon_step(
    request: Request,
@@ -172,19 +160,6 @@ async def coupon_step(
            except Exception as e:  # noqa: BLE001
                logger.warning("coupon claim write failed: %s", e)

-    # 整轮跑完(done 帧)→ 记一条"今日已完成",首页「去领取」卡据此置灰。
-    # pricebot 把中途单券 done 改写成 wait+continue=true,只有整套全跑完那帧才保留
-    # command=="done"(见 pricebot main.py),故 done 已等价"整轮完成"(用户决策 A 方案:
-    # 到 done 即算,不管单券成败),无需再判 continue。写库失败绝不连累领券返回。
-    action = resp_json.get("action") or {}
-    if device_id and action.get("command") == "done":
-        try:
-            await run_in_threadpool(
-                _mark_completed_blocking, device_id, user_id, trace_id
-            )
-        except Exception as e:  # noqa: BLE001
-            logger.warning("coupon completion write failed: %s", e)
-
    return resp_json


@@ -208,31 +183,7 @@ def coupon_prompt_should_show(
    device_id: str, db: DbSession
 ) -> CouponPromptShouldShowOut:
    """今天这台设备已 engage(领或拒)过 → should_show=false。客户端据此决定弹不弹
-    (纯后台判据,客户端不再做前台 SP 缓存判断)。"""
+    (前台 SP 缓存做快速路径,这里是权威)。"""
    return CouponPromptShouldShowOut(
        should_show=not coupon_repo.has_engaged_today(db, device_id)
    )
-
-
-@router.post("/prompt/reset", summary="重置今日领券引导窗 engagement(开发测频控用)")
-def coupon_prompt_reset(payload: CouponPromptDismissIn, db: DbSession) -> dict[str, bool]:
-    """删这台设备今天的 engagement → has_engaged_today 变 false,今天又能弹。
-    开发设置「重置今日领券弹窗状态」按钮调。MVP 不鉴权,按 device_id。"""
-    coupon_repo.reset_today_engagement(db, payload.device_id)
-    return {"ok": True}
-
-
-@router.get(
-    "/completed-today",
-    response_model=CouponCompletedTodayOut,
-    summary="这台设备今天是否已跑完整轮领券(到 done 帧)",
-)
-def coupon_completed_today(
-    device_id: str, db: DbSession
-) -> CouponCompletedTodayOut:
-    """今天这台设备已跑完整轮(到 done)→ completed=true。客户端据此把首页「去领取」
-    卡置灰、不可点(用户决策 A 方案:到 done 即算,不管单券成败)。判断维度 device_id
-    必须与领券循环上报的一致(客户端两端都用 ANDROID_ID)。"""
-    return CouponCompletedTodayOut(
-        completed=coupon_repo.has_completed_today(db, device_id)
-    )
@@ -1,37 +1,25 @@
 """好友邀请 endpoint。

-路由前缀 /api/v1/invite,需 Bearer 鉴权(用户级数据);唯一例外是 /landing-track
-(落地页 dl.html 浏览器访问、无 token,详见任务 3 [[invite-three-tasks]]):
-  GET  /me                我的邀请码 + 分享链接 + 已邀人数/已得金币(邀请页展示)
-  POST /bind              把当前登录用户(被邀请人)绑定到某邀请码;支持三种归因:
-                          ① clipboard:首启读剪贴板拿邀请码 → 上报码
-                          ② manual:用户在邀请页输入邀请码 → 上报码
-                          ③ fingerprint:剪贴板没拿到时上报指纹,后端反查
-  POST /landing-track     落地页 dl.html 访问时上报指纹(剪贴板兜底的服务端一端,无需鉴权)
+路由前缀 /api/v1/invite,需 Bearer 鉴权(用户级数据):
+  GET  /me     我的邀请码 + 分享链接 + 已邀人数/已得金币(邀请页展示)
+  POST /bind   把当前登录用户(被邀请人)绑定到某邀请码,注册即生效,双方各发金币

-绑定的真正逻辑(邀请码生成/反查、幂等、自邀屏蔽、发金币、指纹反查)在
-repositories/invite.py。
+客户端两种调用 /bind:
+  - 自动:首启读剪贴板拿到邀请码 → 登录后调本接口(channel=clipboard)
+  - 手动:用户在邀请页输入好友邀请码(channel=manual)
+
+绑定的真正逻辑(邀请码生成/反查、幂等、自邀屏蔽、发金币)在 repositories/invite.py。
 """
 from __future__ import annotations

 import logging
-import re

-from fastapi import APIRouter, Request
+from fastapi import APIRouter

 from app.api.deps import CurrentUser, DbSession
-from app.core import rewards
 from app.core.config import settings
 from app.repositories import invite as invite_repo
-from app.schemas.invite import (
-    BindInviteIn,
-    BindInviteOut,
-    InviteeItem,
-    InviteeListOut,
-    InviteInfoOut,
-    LandingTrackIn,
-    LandingTrackOut,
-)
+from app.schemas.invite import BindInviteIn, BindInviteOut, InviteInfoOut

 logger = logging.getLogger("shagua.invite")

@@ -43,43 +31,9 @@ _BIND_MESSAGES = {
    "invalid_code": "邀请码无效",
    "self_invite": "不能填写自己的邀请码",
    "not_eligible": "邀请仅对新注册用户生效",
-    "fp_not_found": "未匹配到邀请关系",
 }


-def _client_ip(request: Request) -> str:
-    """从 HTTP 头拿真实 IP。nginx 反代时走 X-Forwarded-For;裸跑 uvicorn 走 request.client。"""
-    xff = request.headers.get("x-forwarded-for", "")
-    if xff:
-        # X-Forwarded-For 可能是 "client, proxy1, proxy2" 链;取第一个 = 真实客户端
-        return xff.split(",")[0].strip()
-    return request.client.host if request.client else ""
-
-
-# Android UA 形如 '... ; <Model> Build/<id>) AppleWebKit/...';抓 ';' 后到 ' Build/' 前
-# 的 token = Build.MODEL(跨端跟客户端 android.os.Build.MODEL 对齐)。user-agents 库
-# 把 Android 设备归为 'Smartphone' 通用名,抓不到真实型号,只能正则。
-_ANDROID_BUILD_MODEL_RE = re.compile(r";\s*([^;]+?)\s+Build/", re.IGNORECASE)
-
-
-def _parse_device_model(ua: str) -> str:
-    """解析浏览器 UA 拿手机型号(如 '24115RA8EC'、'PJF110')。
-
-    Android:正则抓 UA 里 ';...Build/' 前的 token(== Build.MODEL),跨端可严格匹配。
-    iOS / 解析不到:退到 user-agents 库的通用解析,失败/UA 空 → 返空字符串。
-    """
-    if not ua:
-        return ""
-    m = _ANDROID_BUILD_MODEL_RE.search(ua)
-    if m:
-        return m.group(1).strip()
-    try:
-        from user_agents import parse
-        return (parse(ua).device.model or "").strip()
-    except Exception:  # noqa: BLE001
-        return ""
-
-
@router.get("/me", response_model=InviteInfoOut, summary="我的邀请码 + 分享链接 + 战绩")
 def my_invite(user: CurrentUser, db: DbSession) -> InviteInfoOut:
    code = invite_repo.ensure_code(db, user)
@@ -94,124 +48,17 @@ def my_invite(user: CurrentUser, db: DbSession) -> InviteInfoOut:
    )


-@router.get("/invitees", response_model=InviteeListOut, summary="我邀请的人列表(分页)")
-def my_invitees(
-    user: CurrentUser, db: DbSession, limit: int = 20, offset: int = 0
-) -> InviteeListOut:
-    """邀请页小窗(取前几条) + 完整列表页(分页加载)共用。
-
-    名字/头像的降级兜底在 repositories/invite.get_invitees 算好,这里只组装响应。
-    limit 夹到 [1,50] 防滥用;offset 不小于 0。
-    """
-    limit = max(1, min(limit, 50))
-    offset = max(0, offset)
-    items, total, has_more = invite_repo.get_invitees(
-        db, user.id, limit=limit, offset=offset,
-    )
-    return InviteeListOut(
-        items=[InviteeItem(**it) for it in items],
-        total=total,
-        has_more=has_more,
-    )
-
-
-@router.post(
-    "/landing-track",
-    response_model=LandingTrackOut,
-    summary="落地页指纹采集(无需鉴权)",
-)
-def landing_track(
-    req: LandingTrackIn, request: Request, db: DbSession
-) -> LandingTrackOut:
-    """B 浏览器打开 dl.html?ref=xxx 时上报指纹。
-
-    服务端从 HTTP 头拿 IP/UA、解析 UA 拿 device_model,跟 req.screen 一起入库。
-    无需鉴权(浏览器没 token)。invalid_code / no_ip 走 silent 返回(不抛 5xx 影响下载流程)。
-    """
-    inviter = invite_repo.resolve_inviter(db, req.ref)
-    if inviter is None or inviter.status != "active":
-        return LandingTrackOut(status="invalid_code")
-
-    ip = _client_ip(request)
-    if not ip:
-        return LandingTrackOut(status="no_ip")
-
-    ua_str = request.headers.get("user-agent", "")
-    device_model = _parse_device_model(ua_str)
-
-    invite_repo.record_fingerprint(
-        db,
-        inviter_user_id=inviter.id,
-        ip=ip,
-        screen=req.screen,
-        device_model=device_model,
-        user_agent=ua_str,
+@router.post("/bind", response_model=BindInviteOut, summary="绑定邀请人(注册即生效,双方发金币)")
+def bind_invite(req: BindInviteIn, user: CurrentUser, db: DbSession) -> BindInviteOut:
+    result = invite_repo.bind(
+        db, invitee=user, invite_code=req.invite_code, channel=req.channel,
    )
    logger.info(
-        "invite landing-track inviter=%d ip=%s screen=%s model=%s",
-        inviter.id, ip, req.screen, device_model,
+        "invite bind invitee=%d code=%s channel=%s -> %s",
+        user.id, req.invite_code, req.channel, result.status,
    )
-    return LandingTrackOut(status="ok")
-
-
-@router.post("/bind", response_model=BindInviteOut, summary="绑定邀请人(注册即生效,双方发金币)")
-def bind_invite(
-    req: BindInviteIn, user: CurrentUser, db: DbSession, request: Request
-) -> BindInviteOut:
-    code = (req.invite_code or "").strip()
-
-    # 路径 1:有邀请码 → 走原路径(clipboard / manual)
-    if code:
-        result = invite_repo.bind(
-            db, invitee=user, invite_code=code, channel=req.channel,
-        )
-        logger.info(
-            "invite bind invitee=%d code=%s channel=%s -> %s",
-            user.id, code, req.channel, result.status,
-        )
-        return BindInviteOut(
-            status=result.status,
-            coins_awarded=result.invitee_coin,
-            message=_BIND_MESSAGES.get(result.status, result.status),
-        )
-
-    # 路径 2:无邀请码 + 有指纹 → 指纹兜底反查
-    if req.fingerprint is not None:
-        ip = _client_ip(request)
-        inviter = invite_repo.resolve_inviter_by_fingerprint(
-            db,
-            ip=ip,
-            screen=req.fingerprint.screen,
-            device_model=req.fingerprint.device_model,
-            window_days=rewards.INVITE_FP_WINDOW_DAYS,
-        )
-        if inviter is None:
-            logger.info(
-                "invite bind invitee=%d fingerprint not_found ip=%s screen=%s model=%s",
-                user.id, ip, req.fingerprint.screen, req.fingerprint.device_model,
-            )
-            return BindInviteOut(
-                status="fp_not_found",
-                coins_awarded=0,
-                message=_BIND_MESSAGES["fp_not_found"],
-            )
-        # 用反查到的 inviter.invite_code 走原 bind 流程(走原幂等/自邀/新人闸/发币逻辑)
-        result = invite_repo.bind(
-            db, invitee=user, invite_code=inviter.invite_code, channel="fingerprint",
-        )
-        logger.info(
-            "invite bind invitee=%d fingerprint -> inviter=%d code=%s -> %s",
-            user.id, inviter.id, inviter.invite_code, result.status,
-        )
-        return BindInviteOut(
-            status=result.status,
-            coins_awarded=result.invitee_coin,
-            message=_BIND_MESSAGES.get(result.status, result.status),
-        )
-
-    # 路径 3:啥都没传 → 无效请求
    return BindInviteOut(
-        status="invalid_code",
-        coins_awarded=0,
-        message=_BIND_MESSAGES["invalid_code"],
+        status=result.status,
+        coins_awarded=result.invitee_coin,
+        message=_BIND_MESSAGES.get(result.status, result.status),
    )
@@ -16,10 +16,9 @@ from fastapi import APIRouter, File, HTTPException, UploadFile

 from app.api.deps import CurrentUser, DbSession
 from app.core import media
-from app.repositories import onboarding as onboarding_repo
 from app.repositories import user as user_repo
 from app.schemas.auth import UserOut
-from app.schemas.user import OkResponse, OnboardingCompleteRequest, ProfileUpdateRequest
+from app.schemas.user import OkResponse, ProfileUpdateRequest

 logger = logging.getLogger("shagua.user")

@@ -52,17 +51,6 @@ async def upload_avatar(
    return UserOut.model_validate(updated)


-@router.post("/onboarding/complete", response_model=OkResponse, summary="标记新手引导完成(按 设备+账号)")
-def complete_onboarding(
-    req: OnboardingCompleteRequest, user: CurrentUser, db: DbSession
-) -> OkResponse:
-    """走完新手引导时调一次。按 (当前账号, device_id) 落一条完成标记,跨卸载重装持久。
-    幂等:重复调用不报错。device_id 取客户端硬件级 ANDROID_ID,与登录请求一致。"""
-    onboarding_repo.mark_completed(db, user_id=user.id, device_id=req.device_id)
-    logger.info("onboarding complete user_id=%d device_len=%d", user.id, len(req.device_id))
-    return OkResponse()
-
-
@router.delete("", response_model=OkResponse, summary="注销账号(软删除)")
 def delete_account(user: CurrentUser, db: DbSession) -> OkResponse:
    media.delete_avatar(user.avatar_url)
@@ -176,7 +176,7 @@ def withdraw_info(user: CurrentUser, db: DbSession) -> WithdrawInfoOut:
    "/withdraw",
    response_model=WithdrawResultOut,
    summary="发起提现(扣款建单,待人工审核;审核通过后才打款)",
-    dependencies=[Depends(rate_limit(5, 60, "withdraw"))],  # IP 级粗限流;用户级未完成单限制在仓库层
+    dependencies=[Depends(rate_limit(20, 60, "withdraw"))],  # #6 同 IP 每分钟≤20 次
 )
 def withdraw(req: WithdrawRequest, user: CurrentUser, db: DbSession) -> WithdrawResultOut:
    # 提现发起本身不调微信(打款在审核通过后),但仍要求微信支付已配置——否则审核通过也打不了款,提前拦
@@ -189,17 +189,12 @@ def withdraw(req: WithdrawRequest, user: CurrentUser, db: DbSession) -> Withdraw
    except crud_wallet.InvalidWithdrawAmountError as e:
        raise HTTPException(
            status_code=status.HTTP_400_BAD_REQUEST,
-            detail="提现金额不符合要求",
+            detail=f"amount_cents must be within [{WITHDRAW_MIN_CENTS}, {WITHDRAW_MAX_CENTS}]",
        ) from e
    except crud_wallet.WechatNotBoundError as e:
-        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="请先绑定微信") from e
-    except crud_wallet.WithdrawTooFrequentError as e:
-        raise HTTPException(
-            status_code=status.HTTP_409_CONFLICT,
-            detail="已有提现申请正在审核或打款中,请处理完成后再申请",
-        ) from e
+        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="wechat not bound") from e
    except crud_wallet.InsufficientCashError as e:
-        raise HTTPException(status_code=status.HTTP_409_CONFLICT, detail="现金余额不足") from e
+        raise HTTPException(status_code=status.HTTP_409_CONFLICT, detail="insufficient cash balance") from e

    # 调试直发(非生产):skip_review=true 时跳过人工审核,立即发起微信转账(等价 admin approve)。
    # 双闸保护——客户端仅 debug 包下发此 flag,服务端仅非 prod 才认;任一道闸拦住即恢复正常审核,
@@ -102,9 +102,6 @@ class Settings(BaseSettings):
    WXPAY_PUBLIC_KEY_PATH: str = "./secrets/pub_key.pem"             # 微信支付平台公钥
    WXPAY_TRANSFER_SCENE_ID: str = "1000"  # 转账场景 ID(1000=现金营销)
    WXPAY_REQUEST_TIMEOUT_SEC: int = 10
-    WITHDRAW_AUTO_RECONCILE_ENABLED: bool = False
-    WITHDRAW_AUTO_RECONCILE_INTERVAL_SEC: int = 300
-    WITHDRAW_AUTO_RECONCILE_OLDER_THAN_MINUTES: int = 15
    # 免确认收款授权(用户授权免确认模式)的授权结果回调地址,必须公网可访问 HTTPS、不带参数。
    # 发起授权 / 首单顺带授权时作为 authorization_notify_url 传给微信。一期不处理回调内容
    # (授权状态靠 query 查询兜底),但微信要求该字段非空,故启用免确认前必须配置;留空时免确认相关接口返回未配置。
@@ -77,12 +77,6 @@ def record_milestone_reward(milestone: int) -> int:
    return RECORD_MILESTONES[milestone - 1]


-# ===== 上报更低价(人工审核通过发固定金币)=====
-# 用户上报"某平台比我们算的最低价更便宜"+ 截图,经运营后台人工审核通过后发放的固定金币奖励。
-# 与广告/任务同量级;固定值(产品 2026-06 定),要调直接改这里;客户端记录页按 reward_coins 显示。
-PRICE_REPORT_REWARD_COINS: int = 1000
-
-
 # ===== 邀请好友(注册即生效,邀请人 + 被邀请人各发金币)=====
 # 10000 金币 = 1 元,双方各得 1 元。MVP 先用固定常量(不走 app_config)。
 INVITE_INVITER_COINS: int = 10000
@@ -91,18 +85,9 @@ INVITE_INVITEE_COINS: int = 10000
 # 自动绑(剪贴板)在首次注册登录后几秒内发生;留 72h 给手动填码兜底。
 INVITE_NEW_USER_WINDOW_HOURS: int = 72

-# 指纹归因兜底(剪贴板被覆盖时):落地页 POST /landing-track 存的指纹记录,在此窗口内可被
-# /bind 反查撞库。窗口取舍:太短(24h)覆盖不到"晚上看链接、第二天装"的常见场景;太宽
-# (30d)IP/设备会漂、匹配错率上升。7 天兼顾"看广告→使用"周期与匹配精度。
-INVITE_FP_WINDOW_DAYS: int = 7
-

 # ===== 看激励视频 / 信息流广告发金币 =====
-# eCPM 取自穿山甲 SDK getShowEcpm().getEcpm(),官方口径单位是【分/千次展示】(不是元!
-# csjplatform 文档原文"通过 getEcpm 获取的单位是分")。计算时先 ÷100 转成元;
-# 因子1 档位阈值按【元/千次】定(100/200/400 元 = ¥100/¥200/¥400 CPM,产品口径 2026-06-09)。
-# 注:真实 eCPM 一般 <¥100 CPM,故多落最低档 0.1,高档基本不触发——这是产品有意的取舍。
-# 单次展示收益(元) = eCPM元 ÷ 1000(每千次→单次)。
+# 金币数值体系约定:eCPM 单位按"元/千次展示"处理,单次收入 = eCPM / 1000 元。
 AD_ECPM_FACTOR_TABLE: tuple[tuple[float, int, int | None], ...] = (
    (0.1, 0, 100),
    (0.3, 101, 200),
@@ -118,8 +103,8 @@ AD_LT_FACTOR_TABLE: tuple[tuple[float, int, int | None], ...] = (
 )


-def parse_ecpm_fen(ecpm: str | int | float | None) -> float:
-    """解析 eCPM 原始值(穿山甲 getEcpm 原值,单位=分/千次展示)。非法/缺失→0。"""
+def parse_ecpm_yuan(ecpm: str | int | float | None) -> float:
+    """解析 eCPM 原始值。当前产品口径:SDK 返回值按"元/千次展示"处理。"""
    if ecpm is None:
        return 0.0
    try:
@@ -129,14 +114,8 @@ def parse_ecpm_fen(ecpm: str | int | float | None) -> float:
    return max(0.0, value)


-def parse_ecpm_yuan(ecpm: str | int | float | None) -> float:
-    """eCPM 转成元(getEcpm 原值是分,÷100)。因子档位判定与收益换算都用元。"""
-    return parse_ecpm_fen(ecpm) / 100.0
-
-
 def ad_ecpm_factor(ecpm_yuan: float) -> float:
-    """eCPM 档位因子(阈值单位=元/千次):≤100=0.1,101-200=0.3,201-400=0.4,>400=0.6。
-    产品口径(2026-06-09):阈值按元判档;真实 eCPM(<¥100 CPM)多落最低档 0.1。"""
+    """eCPM 档位因子:0-100=0.1,101-200=0.3,201-400=0.4,>400=0.6。"""
    if ecpm_yuan > 400:
        return 0.6
    if ecpm_yuan > 200:
@@ -158,9 +137,7 @@ def ad_lt_factor(today_count_after_this: int) -> float:
 def calculate_ad_reward_coin(ecpm: str | int | float | None, today_count_after_this: int) -> int:
    """按金币数值体系计算单份广告奖励金币。

-    eCPM 是穿山甲 getEcpm 原值,单位【分/千次展示】;先 ÷100 转成元(因子判档 + 收益换算都用元)。
-    单次收益(元)= eCPM元 ÷ 1000(每千次→单次) × 因子1(eCPM 元档) × 因子2(LT);
-    再按 1 元=10000 金币取整。
+    单次奖励(元)=eCPM/1000 × 因子1(eCPM 档) × 因子2(LT);再按 1 元=10000 金币取整。
    """
    ecpm_yuan = parse_ecpm_yuan(ecpm)
    yuan = (ecpm_yuan / 1000.0) * ad_ecpm_factor(ecpm_yuan) * ad_lt_factor(today_count_after_this)
@@ -1,118 +0,0 @@
-"""提现 pending 单自动对账后台任务。"""
-from __future__ import annotations
-
-import asyncio
-import contextlib
-import logging
-import os
-import time
-from collections.abc import Iterator
-from pathlib import Path
-
-from sqlalchemy.exc import SQLAlchemyError
-
-from app.core.config import settings
-from app.db.session import SessionLocal
-from app.integrations.wxpay import WxPayNotConfiguredError
-from app.repositories import wallet as wallet_repo
-
-logger = logging.getLogger("shagua.withdraw_reconcile")
-_LOCK_PATH = Path(__file__).resolve().parents[2] / "data" / "withdraw_reconcile.lock"
-
-
-def _touch_lock() -> None:
-    with contextlib.suppress(FileNotFoundError):
-        os.utime(_LOCK_PATH, None)
-
-
-@contextlib.contextmanager
-def _single_instance_lock(stale_after_sec: int) -> Iterator[bool]:
-    """同机多进程保护:同一时间只允许一个自动查单 worker 运行。"""
-    _LOCK_PATH.parent.mkdir(parents=True, exist_ok=True)
-    fd: int | None = None
-    try:
-        try:
-            fd = os.open(str(_LOCK_PATH), os.O_CREAT | os.O_EXCL | os.O_WRONLY)
-        except FileExistsError:
-            try:
-                age = time.time() - _LOCK_PATH.stat().st_mtime
-            except FileNotFoundError:
-                age = stale_after_sec + 1
-            if age > stale_after_sec:
-                with contextlib.suppress(FileNotFoundError):
-                    _LOCK_PATH.unlink()
-                try:
-                    fd = os.open(str(_LOCK_PATH), os.O_CREAT | os.O_EXCL | os.O_WRONLY)
-                except FileExistsError:
-                    fd = None
-
-        if fd is None:
-            yield False
-            return
-
-        os.write(fd, f"pid={os.getpid()} started_at={int(time.time())}\n".encode("ascii"))
-        yield True
-    finally:
-        if fd is not None:
-            os.close(fd)
-            with contextlib.suppress(FileNotFoundError):
-                _LOCK_PATH.unlink()
-
-
-def _reconcile_once(older_than_minutes: int) -> dict:
-    with SessionLocal() as db:
-        return wallet_repo.reconcile_pending_withdraws(db, older_than_minutes=older_than_minutes)
-
-
-async def _run_loop() -> None:
-    interval = max(30, int(settings.WITHDRAW_AUTO_RECONCILE_INTERVAL_SEC))
-    older_than = max(1, int(settings.WITHDRAW_AUTO_RECONCILE_OLDER_THAN_MINUTES))
-    lock_stale_after = max(interval * 3, 600)
-    with _single_instance_lock(lock_stale_after) as lock_acquired:
-        if not lock_acquired:
-            logger.warning("withdraw auto reconcile skipped: another worker owns lock")
-            return
-
-        await _run_locked_loop(interval, older_than)
-
-
-async def _run_locked_loop(interval: int, older_than: int) -> None:
-    logger.info(
-        "withdraw auto reconcile started interval=%ss older_than=%sm",
-        interval,
-        older_than,
-    )
-    try:
-        while True:
-            try:
-                _touch_lock()
-                result = await asyncio.to_thread(_reconcile_once, older_than)
-                if result["checked"] or result["resolved"]:
-                    logger.info("withdraw auto reconcile result=%s", result)
-            except WxPayNotConfiguredError:
-                logger.warning("withdraw auto reconcile skipped: wxpay not configured")
-            except SQLAlchemyError:
-                logger.exception("withdraw auto reconcile db error")
-            except Exception:  # noqa: BLE001 - 后台任务不能因单次异常退出
-                logger.exception("withdraw auto reconcile unexpected error")
-            await asyncio.sleep(interval)
-    except asyncio.CancelledError:
-        logger.info("withdraw auto reconcile stopped")
-        raise
-
-
-def start_withdraw_reconcile_worker() -> asyncio.Task | None:
-    if not settings.WITHDRAW_AUTO_RECONCILE_ENABLED:
-        logger.info("withdraw auto reconcile disabled")
-        return None
-    if not settings.wxpay_configured:
-        logger.warning("withdraw auto reconcile enabled but wxpay not configured")
-    return asyncio.create_task(_run_loop(), name="withdraw-auto-reconcile")
-
-
-async def stop_withdraw_reconcile_worker(task: asyncio.Task | None) -> None:
-    if task is None:
-        return
-    task.cancel()
-    with contextlib.suppress(asyncio.CancelledError):
-        await task
@@ -14,9 +14,7 @@ import base64
 import json
 import time
 import uuid
-from pathlib import Path

-import certifi
 import httpx
 from cryptography.hazmat.primitives import hashes, serialization
 from cryptography.hazmat.primitives.asymmetric import padding
@@ -25,7 +23,6 @@ from cryptography.hazmat.primitives.asymmetric.rsa import RSAPrivateKey, RSAPubl
 from app.core.config import settings

 _API_HOST = "https://api.mch.weixin.qq.com"
-_PROJECT_ROOT = Path(__file__).resolve().parents[2]
 _TRANSFER_PATH = "/v3/fund-app/mch-transfer/transfer-bills"
 # 免确认收款授权(用户授权免确认模式)
 _AUTH_PATH = "/v3/fund-app/mch-transfer/user-confirm-authorization"
@@ -41,30 +38,15 @@ class WxPayNotConfiguredError(Exception):
    """微信支付凭证 / 证书缺失,无法调用。"""


-def _http_client() -> httpx.Client:
-    """微信相关 HTTP 客户端。
-
-    显式使用当前 Python 环境的 certifi 证书,避免被外部 SSL_CERT_FILE 指到不存在文件。
-    代理仍允许从环境变量读取,方便本地开发。
-    """
-    return httpx.Client(verify=certifi.where())
-
-
-def _resolve_config_path(value: str) -> Path:
-    path = Path(value)
-    return path if path.is_absolute() else _PROJECT_ROOT / path
-
-
 def _load_private_key() -> RSAPrivateKey:
    global _private_key
    if _private_key is None:
-        key_path = _resolve_config_path(settings.WXPAY_MCH_PRIVATE_KEY_PATH)
        try:
-            with key_path.open("rb") as f:
+            with open(settings.WXPAY_MCH_PRIVATE_KEY_PATH, "rb") as f:
                _private_key = serialization.load_pem_private_key(f.read(), password=None)
        except FileNotFoundError as e:
            raise WxPayNotConfiguredError(
-                f"商户私钥不存在: {key_path}"
+                f"商户私钥不存在: {settings.WXPAY_MCH_PRIVATE_KEY_PATH}"
            ) from e
    return _private_key

@@ -72,13 +54,12 @@ def _load_private_key() -> RSAPrivateKey:
 def _load_public_key() -> RSAPublicKey:
    global _public_key
    if _public_key is None:
-        key_path = _resolve_config_path(settings.WXPAY_PUBLIC_KEY_PATH)
        try:
-            with key_path.open("rb") as f:
+            with open(settings.WXPAY_PUBLIC_KEY_PATH, "rb") as f:
                _public_key = serialization.load_pem_public_key(f.read())
        except FileNotFoundError as e:
            raise WxPayNotConfiguredError(
-                f"微信支付平台公钥不存在: {key_path}"
+                f"微信支付平台公钥不存在: {settings.WXPAY_PUBLIC_KEY_PATH}"
            ) from e
    return _public_key

@@ -145,7 +126,7 @@ def create_transfer(
        "Content-Type": "application/json",
        "Wechatpay-Serial": settings.WXPAY_PUBLIC_KEY_ID,
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{_TRANSFER_PATH}",
            content=body_str,
@@ -162,7 +143,7 @@ def query_transfer(out_bill_no: str) -> dict:
        "Authorization": _build_authorization("GET", path, ""),
        "Accept": "application/json",
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.get(
            f"{_API_HOST}{path}", headers=headers, timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC
        )
@@ -178,7 +159,7 @@ def cancel_transfer(out_bill_no: str) -> dict:
        "Accept": "application/json",
        "Content-Type": "application/json",
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{path}", headers=headers, timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC
        )
@@ -190,17 +171,16 @@ def code_to_userinfo(code: str) -> dict:
    返回 {openid, nickname, avatar_url, raw}。失败抛 ValueError。
    注意:微信隐私新政下,部分 app 的 sns/userinfo 可能返回脱敏值(昵称"微信用户"/灰头像);
    nickname/avatar_url 可能为空,调用方需兜底。"""
-    with _http_client() as client:
-        r1 = client.get(
-            "https://api.weixin.qq.com/sns/oauth2/access_token",
-            params={
-                "appid": settings.WECHAT_APP_ID,
-                "secret": settings.WECHAT_APP_SECRET,
-                "code": code,
-                "grant_type": "authorization_code",
-            },
-            timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC,
-        )
+    r1 = httpx.get(
+        "https://api.weixin.qq.com/sns/oauth2/access_token",
+        params={
+            "appid": settings.WECHAT_APP_ID,
+            "secret": settings.WECHAT_APP_SECRET,
+            "code": code,
+            "grant_type": "authorization_code",
+        },
+        timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC,
+    )
    d1 = r1.json()
    if "openid" not in d1 or "access_token" not in d1:
        raise ValueError(f"微信授权失败: {d1.get('errmsg', d1)}")
@@ -211,12 +191,11 @@ def code_to_userinfo(code: str) -> dict:
    raw: dict = {}
    # userinfo 拉取失败不应让绑定失败(openid 已拿到),吞掉异常只是没昵称头像
    try:
-        with _http_client() as client:
-            r2 = client.get(
-                "https://api.weixin.qq.com/sns/userinfo",
-                params={"access_token": d1["access_token"], "openid": openid, "lang": "zh_CN"},
-                timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC,
-            )
+        r2 = httpx.get(
+            "https://api.weixin.qq.com/sns/userinfo",
+            params={"access_token": d1["access_token"], "openid": openid, "lang": "zh_CN"},
+            timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC,
+        )
        raw = r2.json()
        nickname = raw.get("nickname") or None
        avatar_url = raw.get("headimgurl") or None
@@ -265,7 +244,7 @@ def apply_transfer_authorization(
        "Accept": "application/json",
        "Content-Type": "application/json",
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{_AUTH_PATH}",
            content=body_str,
@@ -283,7 +262,7 @@ def query_transfer_authorization(out_authorization_no: str) -> dict:
        "Authorization": _build_authorization("GET", path, ""),
        "Accept": "application/json",
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.get(
            f"{_API_HOST}{path}", headers=headers, timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC
        )
@@ -298,7 +277,7 @@ def close_transfer_authorization(out_authorization_no: str) -> dict:
        "Accept": "application/json",
        "Content-Type": "application/json",
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{path}", headers=headers, timeout=settings.WXPAY_REQUEST_TIMEOUT_SEC
        )
@@ -340,7 +319,7 @@ def pre_transfer_with_authorization(
        "Content-Type": "application/json",
        "Wechatpay-Serial": settings.WXPAY_PUBLIC_KEY_ID,
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{_PRE_TRANSFER_AUTH_PATH}",
            content=body_str,
@@ -377,7 +356,7 @@ def transfer_with_authorization(
        "Content-Type": "application/json",
        "Wechatpay-Serial": settings.WXPAY_PUBLIC_KEY_ID,
    }
-    with _http_client() as client:
+    with httpx.Client() as client:
        resp = client.post(
            f"{_API_HOST}{_TRANSFER_WITH_AUTH_PATH}",
            content=body_str,
@@ -35,10 +35,6 @@ from app.api.v1.wallet import router as wallet_router
 from app.api.v1.wxpay import router as wxpay_router
 from app.core.config import settings
 from app.core.logging import setup_logging
-from app.core.withdraw_reconcile_worker import (
-    start_withdraw_reconcile_worker,
-    stop_withdraw_reconcile_worker,
-)

 setup_logging(debug=settings.APP_DEBUG)
 logger = logging.getLogger("shagua.main")
@@ -54,12 +50,8 @@ async def lifespan(_: FastAPI) -> AsyncIterator[None]:
        settings.APP_DEBUG,
        settings.DATABASE_URL.split("://", 1)[0],
    )
-    reconcile_task = start_withdraw_reconcile_worker()
-    try:
-        yield
-    finally:
-        await stop_withdraw_reconcile_worker(reconcile_task)
-        logger.info("shutting down")
+    yield
+    logger.info("shutting down")


 app = FastAPI(
@@ -9,14 +9,11 @@ from app.models.comparison import ComparisonRecord  # noqa: F401
 from app.models.comparison_milestone import ComparisonMilestoneClaim  # noqa: F401
 from app.models.coupon_state import (  # noqa: F401
    CouponClaimRecord,
-    CouponDailyCompletion,
    CouponPromptEngagement,
 )
 from app.models.feedback import Feedback  # noqa: F401
 from app.models.invite import InviteRelation  # noqa: F401
-from app.models.invite_fingerprint import InviteFingerprint  # noqa: F401
 from app.models.meituan_coupon import MeituanCoupon  # noqa: F401
-from app.models.onboarding import OnboardingCompletion  # noqa: F401
 from app.models.ops_marquee_seed import OpsMarqueeSeed  # noqa: F401
 from app.models.ops_stat_config import OpsStatConfig  # noqa: F401
 from app.models.price_observation import PriceObservation  # noqa: F401
@@ -35,7 +35,7 @@ class AdEcpmRecord(Base):
    adn: Mapped[str | None] = mapped_column(String(32), nullable=True)
    # 实际展示用的代码位(底层 mediation rit,非客户端配置位)
    slot_id: Mapped[str | None] = mapped_column(String(64), nullable=True)
-    # 客户端上报的 eCPM 原始字符串(单位:分/千次展示,SDK getEcpm 原值,原样存)
+    # 客户端上报的 eCPM 原始字符串(单位:元/千次展示,原样存)
    ecpm_raw: Mapped[str] = mapped_column(String(32), nullable=False)
    # 北京时间日期串 'YYYY-MM-DD',按它等值做"按天聚合"(不在 SQL 里做跨时区 date 比较)
    report_date: Mapped[str] = mapped_column(String(10), index=True, nullable=False)
@@ -53,10 +53,6 @@ class ComparisonRecord(Base):
    )
    # pricebot 侧 trace_id:关联调试落盘 + 幂等去重键
    trace_id: Mapped[str] = mapped_column(String(64), nullable=False)
-    # 本次比价的公网调试链接(price.shaguabijia.com/traces/{dir}/)。pricebot done 帧给、
-    # 客户端上报带上——dir 名含 pricebot 落盘的时分秒,前端/server 都拼不出,必须存。
-    # 查看接口按 user.debug_trace_enabled 决定返不返回。旧记录 / 未开上云为 None。
-    trace_url: Mapped[str | None] = mapped_column(String(512), nullable=True)

    # ===== 源平台(发起比价的那家)=====
    source_platform_id: Mapped[str | None] = mapped_column(String(32), nullable=True)
@@ -93,49 +93,6 @@ class CouponClaimRecord(Base):
        )


-class CouponDailyCompletion(Base):
-    """按 (device, 自然日) 记"今天是否已跑完整轮领券(到 done 帧)"——首页置灰源。
-
-    与 engagement 区别:engagement = 用户表达过意向(点了一键领取/拒绝即记,不管跑没跑完);
-    completion = 这一轮真跑到了 done(整套流程走完)。首页「去领取」卡据此置灰:跑完了
-    今天就不能再领。判断口径(用户决策 2026-06-10 A 方案):**到 done 即算**,不管单券
-    成败(失败/跳过常是无障碍/环境问题,重复点也补不回来)。判断维度 device_id,与
-    engagement/claim 一致。
-    """
-
-    __tablename__ = "coupon_daily_completion"
-    __table_args__ = (
-        # 一台设备一天一条:今天跑完过就置灰。
-        UniqueConstraint(
-            "device_id", "complete_date",
-            name="uq_coupon_completion_device_date",
-        ),
-    )
-
-    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
-
-    device_id: Mapped[str] = mapped_column(String(64), nullable=False)
-    user_id: Mapped[int | None] = mapped_column(Integer, index=True, nullable=True)
-    # Asia/Shanghai 自然日。
-    complete_date: Mapped[date] = mapped_column(Date, nullable=False)
-    # 哪次任务跑到 done,回指 pricebot work_logs / 排查。
-    trace_id: Mapped[str | None] = mapped_column(String(64), index=True, nullable=True)
-
-    created_at: Mapped[datetime] = mapped_column(
-        DateTime(timezone=True), server_default=func.now(), nullable=False
-    )
-    updated_at: Mapped[datetime] = mapped_column(
-        DateTime(timezone=True), server_default=func.now(), onupdate=func.now(),
-        nullable=False,
-    )
-
-    def __repr__(self) -> str:  # pragma: no cover
-        return (
-            f"<CouponDailyCompletion device={self.device_id} "
-            f"date={self.complete_date}>"
-        )
-
-
 class CouponPromptEngagement(Base):
    """按 (device, 自然日) 记"今天是否对领券引导窗表达过意向"——弹窗频控源。"""

@@ -1,46 +0,0 @@
-"""邀请指纹归因表(剪贴板归因兜底)。
-
-数据流(对应 [[invite-three-tasks]] 任务 3):
-  1. B 浏览器打开落地页 dl.html?ref=邀请码 → JS POST /api/v1/invite/landing-track
-  2. 后端从 HTTP 头拿 IP/UA,解析 UA 得 device_model,跟 JS 上报的 screen 一起入库
-  3. B 装包首启 → 登录后,若剪贴板没拿到邀请码(被覆盖),客户端再算一次 screen+Build.MODEL
-     上报 → 后端用 (ip, screen, device_model) 反查本表 7 天内最近匹配 → 拿出 inviter_user_id
-     → 走原 bind 路径(channel=fingerprint)
-
-不要索引(IP, created_at) 单独,组合索引 (ip, screen, device_model, created_at desc) 反查更省。
-"""
-from __future__ import annotations
-
-from datetime import datetime
-
-from sqlalchemy import DateTime, ForeignKey, Integer, String, Text, func
-from sqlalchemy.orm import Mapped, mapped_column
-
-from app.db.base import Base
-
-
-class InviteFingerprint(Base):
-    __tablename__ = "invite_fingerprint"
-
-    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
-    inviter_user_id: Mapped[int] = mapped_column(
-        Integer, ForeignKey("user.id"), index=True, nullable=False
-    )
-    # 落地页访问者 IP(服务端从 HTTP 头拿,X-Forwarded-For 由部署侧 nginx 透传)
-    ip: Mapped[str] = mapped_column(String(64), nullable=False)
-    # 客户端 Build.MODEL / 浏览器 UA 解析出来的型号(如 "PJF110"、"23046PNC9C")
-    device_model: Mapped[str] = mapped_column(String(64), nullable=False, default="")
-    # 屏幕分辨率 "1080x2400"(浏览器 screen.width × height,客户端 DisplayMetrics)
-    screen: Mapped[str] = mapped_column(String(32), nullable=False, default="")
-    # 完整 UA 字符串(留 debug / 排查"匹配不上"用,不直接参与匹配)
-    user_agent: Mapped[str] = mapped_column(Text, nullable=False, default="")
-
-    created_at: Mapped[datetime] = mapped_column(
-        DateTime(timezone=True), server_default=func.now(), index=True, nullable=False
-    )
-
-    def __repr__(self) -> str:  # pragma: no cover
-        return (
-            f"<InviteFingerprint inviter={self.inviter_user_id} "
-            f"ip={self.ip} model={self.device_model} screen={self.screen}>"
-        )
@@ -1,40 +0,0 @@
-"""新手引导完成标记(按 设备 + 账号 去重)。
-
-产品规则:同一台设备 + 同一个账号,新手引导只跑一次;卸载重装(同设备同账号)
-不再触发。本地标记(SharedPreferences)卸载即丢,所以"完成"必须落后端,按
-(user_id, device_id) 唯一一条。
-
-⚠️ device_id 这里用客户端的**硬件级稳定标识**(Android `Settings.Secure.ANDROID_ID`),
-同签名 app 卸载重装不变、仅恢复出厂才重置——区别于领券/比价用的 per-install device_id
-(见 coupon_state,存 SP、重装会变)。换新设备 → 无此行 → 重新走引导。
-"""
-from __future__ import annotations
-
-from datetime import datetime
-
-from sqlalchemy import DateTime, Integer, String, UniqueConstraint, func
-from sqlalchemy.orm import Mapped, mapped_column
-
-from app.db.base import Base
-
-
-class OnboardingCompletion(Base):
-    """一台设备 + 一个账号 一条:走完新手引导即写入,登录时据此跳过引导。"""
-
-    __tablename__ = "onboarding_completion"
-    __table_args__ = (
-        # 同账号、同设备只一条:重复 mark / 并发提交靠它幂等。
-        UniqueConstraint("user_id", "device_id", name="uq_onboarding_user_device"),
-    )
-
-    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
-    # 登录态用户。引导是登录后才走的,故必填(非空)、进唯一键。
-    user_id: Mapped[int] = mapped_column(Integer, index=True, nullable=False)
-    # 硬件级稳定设备标识(ANDROID_ID),卸载重装不变。
-    device_id: Mapped[str] = mapped_column(String(64), nullable=False)
-    completed_at: Mapped[datetime] = mapped_column(
-        DateTime(timezone=True), server_default=func.now(), nullable=False
-    )
-
-    def __repr__(self) -> str:  # pragma: no cover
-        return f"<OnboardingCompletion user={self.user_id} device={self.device_id}>"
@@ -11,7 +11,7 @@ from __future__ import annotations

 from datetime import datetime, timezone

-from sqlalchemy import Boolean, DateTime, Integer, String, false, func
+from sqlalchemy import DateTime, Integer, String, func
 from sqlalchemy.orm import Mapped, mapped_column

 from app.db.base import Base
@@ -51,13 +51,6 @@ class User(Base):
    # 账号状态:active / disabled / deleted
    status: Mapped[str] = mapped_column(String(20), nullable=False, default="active")

-    # 调试链接权限:开了的用户在比价完成弹窗 + 比价记录页能看到「复制调试链接」按钮
-    # (复制 price.shaguabijia.com 的 trace 链接发给开发排障)。运营后台按用户配置;
-    # /me 与登录响应里带出给前端做条件渲染。默认 false。
-    debug_trace_enabled: Mapped[bool] = mapped_column(
-        Boolean, nullable=False, default=False, server_default=false()
-    )
-
    created_at: Mapped[datetime] = mapped_column(
        DateTime(timezone=True), server_default=func.now(), nullable=False
    )
@@ -10,7 +10,7 @@ from __future__ import annotations

 from datetime import datetime

-from sqlalchemy import DateTime, ForeignKey, Index, Integer, String, func, text
+from sqlalchemy import DateTime, ForeignKey, Integer, String, func
 from sqlalchemy.orm import Mapped, mapped_column

 from app.db.base import Base
@@ -76,15 +76,6 @@ class WithdrawOrder(Base):
    """

    __tablename__ = "withdraw_order"
-    __table_args__ = (
-        Index(
-            "ux_withdraw_order_user_active",
-            "user_id",
-            unique=True,
-            sqlite_where=text("status IN ('reviewing', 'pending')"),
-            postgresql_where=text("status IN ('reviewing', 'pending')"),
-        ),
-    )

    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
    user_id: Mapped[int] = mapped_column(
@@ -157,15 +148,6 @@ class CashTransaction(Base):
    """现金流水(单位:分)。金币兑现金、提现都记在这里。"""

    __tablename__ = "cash_transaction"
-    __table_args__ = (
-        Index(
-            "ux_cash_transaction_withdraw_refund_ref",
-            "ref_id",
-            unique=True,
-            sqlite_where=text("biz_type = 'withdraw_refund' AND ref_id IS NOT NULL"),
-            postgresql_where=text("biz_type = 'withdraw_refund' AND ref_id IS NOT NULL"),
-        ),
-    )

    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
    user_id: Mapped[int] = mapped_column(
@@ -84,7 +84,6 @@ def upsert_record(
        source_package=payload.source_package,
        information=payload.information,
        best_deeplink=payload.best_deeplink,
-        trace_url=payload.trace_url,
        total_dish_count=payload.total_dish_count,
        skipped_dish_count=payload.skipped_dish_count,
        items=[it.model_dump(exclude_none=True) for it in payload.items],
@@ -9,15 +9,11 @@ import logging
 from datetime import date, datetime
 from zoneinfo import ZoneInfo

-from sqlalchemy import delete, select
+from sqlalchemy import select
 from sqlalchemy.exc import IntegrityError
 from sqlalchemy.orm import Session

-from app.models.coupon_state import (
-    CouponClaimRecord,
-    CouponDailyCompletion,
-    CouponPromptEngagement,
-)
+from app.models.coupon_state import CouponClaimRecord, CouponPromptEngagement

 logger = logging.getLogger("shagua.coupon_state")

@@ -69,60 +65,6 @@ def mark_engagement(
        db.rollback()


-def reset_today_engagement(db: Session, device_id: str) -> int:
-    """删这台设备今天的 engagement(开发设置「重置今日领券弹窗状态」调,测频控用)。
-    删后 has_engaged_today → false,今天又能弹。返回删除行数。"""
-    result = db.execute(
-        delete(CouponPromptEngagement).where(
-            CouponPromptEngagement.device_id == device_id,
-            CouponPromptEngagement.engage_date == today_cn(),
-        )
-    )
-    db.commit()
-    return result.rowcount or 0
-
-
-# ===== 今日跑完整轮(coupon_daily_completion)=====
-
-def has_completed_today(db: Session, device_id: str) -> bool:
-    """这台设备今天是否已跑完整轮领券(到 done 帧)。有 = 首页置灰、不能再领。"""
-    row = db.execute(
-        select(CouponDailyCompletion.id).where(
-            CouponDailyCompletion.device_id == device_id,
-            CouponDailyCompletion.complete_date == today_cn(),
-        )
-    ).first()
-    return row is not None
-
-
-def mark_completed_today(
-    db: Session, device_id: str, user_id: int | None, trace_id: str | None = None
-) -> None:
-    """记今日已跑完整轮。(device, 今天) 唯一,幂等 upsert。到 done 即记,不管单券成败。"""
-    today = today_cn()
-    row = db.execute(
-        select(CouponDailyCompletion).where(
-            CouponDailyCompletion.device_id == device_id,
-            CouponDailyCompletion.complete_date == today,
-        )
-    ).scalar_one_or_none()
-    if row is not None:
-        if user_id is not None:
-            row.user_id = user_id
-        if trace_id is not None:
-            row.trace_id = trace_id
-    else:
-        db.add(CouponDailyCompletion(
-            device_id=device_id, user_id=user_id,
-            complete_date=today, trace_id=trace_id,
-        ))
-    try:
-        db.commit()
-    except IntegrityError:
-        # 并发下另一请求刚插了同 (device, 日) → 唯一约束撞,回滚忽略(本就幂等)。
-        db.rollback()
-
-
 # ===== 领券记录(coupon_claim_record)=====

 def record_claims(
@@ -21,7 +21,6 @@ from sqlalchemy.orm import Session

 from app.core import rewards
 from app.models.invite import InviteRelation
-from app.models.invite_fingerprint import InviteFingerprint
 from app.models.user import User
 from app.repositories import wallet as crud_wallet

@@ -165,121 +164,3 @@ def get_stats(db: Session, inviter_id: int) -> tuple[int, int]:
        .where(InviteRelation.inviter_user_id == inviter_id)
    ).scalar_one()
    return int(count), int(coins)
-
-
-def _mask_phone(phone: str) -> str:
-    """手机号脱敏:138****8888。前端拿不到完整号,展示被邀请人时在此兜底名字。
-
-    11 位标准手机号 → 前 3 + **** + 后 4;非标准(异常/截断)→ 只露后 4 位;太短 → "新用户"。
-    """
-    p = (phone or "").strip()
-    if len(p) == 11:
-        return f"{p[:3]}****{p[-4:]}"
-    if len(p) >= 4:
-        return f"****{p[-4:]}"
-    return "新用户"
-
-
-def get_invitees(
-    db: Session, inviter_id: int, *, limit: int = 20, offset: int = 0
-) -> tuple[list[dict], int, bool]:
-    """查某邀请人的被邀请人列表(按邀请时间倒序, 分页),返回 (items, total, has_more)。
-
-    每条 item = {display_name, avatar_url, coins, invited_at}。降级兜底:
-      名字 = 昵称 → 微信昵称 → 脱敏手机号(很多被邀请人是刚注册新用户、没设资料);
-      头像 = 用户头像 → 微信头像 → None(前端画默认色块)。
-    邀请关系表 join 用户表;total 单独 count(分页时算 has_more)。
-    """
-    total = db.execute(
-        select(func.count())
-        .select_from(InviteRelation)
-        .where(InviteRelation.inviter_user_id == inviter_id)
-    ).scalar_one()
-
-    rows = db.execute(
-        select(InviteRelation, User)
-        .join(User, User.id == InviteRelation.invitee_user_id)
-        .where(InviteRelation.inviter_user_id == inviter_id)
-        .order_by(InviteRelation.created_at.desc())
-        .limit(limit)
-        .offset(offset)
-    ).all()
-
-    items: list[dict] = []
-    for rel, u in rows:
-        items.append({
-            "display_name": u.nickname or u.wechat_nickname or _mask_phone(u.phone),
-            "avatar_url": u.avatar_url or u.wechat_avatar_url or None,
-            "coins": rel.inviter_coin,
-            "invited_at": rel.created_at,
-        })
-    has_more = offset + len(rows) < int(total)
-    return items, int(total), has_more
-
-
-# ===== 指纹归因(剪贴板兜底,见 [[invite-three-tasks]] 任务 3)=====
-
-def record_fingerprint(
-    db: Session,
-    *,
-    inviter_user_id: int,
-    ip: str,
-    screen: str,
-    device_model: str,
-    user_agent: str,
-) -> InviteFingerprint:
-    """落地页 dl.html 访问时调用,写一行指纹记录。
-
-    后续被邀请人登录、剪贴板没拿到邀请码时,/bind 会按 (ip, screen, device_model) 反查本表
-    7 天内最近一条匹配 → 拿出 inviter_user_id 撞库。
-
-    本函数会 commit;调用方(/landing-track endpoint)在此之前无其它写操作。
-    """
-    fp = InviteFingerprint(
-        inviter_user_id=inviter_user_id,
-        ip=ip[:64],
-        screen=screen[:32],
-        device_model=device_model[:64],
-        user_agent=user_agent[:2000] if user_agent else "",  # 截一下防异常长 UA
-    )
-    db.add(fp)
-    db.commit()
-    db.refresh(fp)
-    return fp
-
-
-def resolve_inviter_by_fingerprint(
-    db: Session,
-    *,
-    ip: str,
-    screen: str,
-    device_model: str,
-    window_days: int,
-) -> User | None:
-    """根据指纹反查邀请人(time window 内最近一条匹配)。
-
-    匹配规则:(ip, device_model) 相等 + created_at > now - window_days。
-
-    screen 字段**只入库不反查**:浏览器算物理像素走 `CSS × devicePixelRatio` 路径、
-    Android 走 `DisplayMetrics.widthPixels` 真实硬件值,两端浮点 round 必然 ±1 像素漂移
-    (DPR 不严格是整数)→ 严格匹配注定撞不上。同 device_model 必同 screen(同型号同硬件)
-    → screen 是冗余字段,删它不损精度。撞错只有"同 IP 下同型号手机同时被邀请"才会
-    发生,中国家庭/公司 WiFi 场景概率极低。
-    """
-    if not ip:
-        return None
-    from datetime import datetime, timedelta, timezone
-    cutoff = datetime.now(timezone.utc) - timedelta(days=window_days)
-    fp = db.execute(
-        select(InviteFingerprint)
-        .where(
-            InviteFingerprint.ip == ip,
-            InviteFingerprint.device_model == device_model,
-            InviteFingerprint.created_at > cutoff,
-        )
-        .order_by(InviteFingerprint.created_at.desc())
-        .limit(1)
-    ).scalar_one_or_none()
-    if fp is None:
-        return None
-    return db.get(User, fp.inviter_user_id)
@@ -1,35 +0,0 @@
-"""新手引导完成标记的读写(按 user_id + device_id 去重)。
-
-登录时 [is_completed] 判断该 (账号, 设备) 是否走过引导;走完引导时 [mark_completed] 写一条。
-device_id 为空(老客户端 / 取不到 ANDROID_ID)一律按"未完成"处理,即照常走引导,不误跳过。
-"""
-from __future__ import annotations
-
-from sqlalchemy import select
-from sqlalchemy.exc import IntegrityError
-from sqlalchemy.orm import Session
-
-from app.models.onboarding import OnboardingCompletion
-
-
-def is_completed(db: Session, *, user_id: int, device_id: str) -> bool:
-    """该 (账号, 设备) 是否已完成新手引导。device_id 为空 → 一律 False。"""
-    if not device_id:
-        return False
-    stmt = select(OnboardingCompletion.id).where(
-        OnboardingCompletion.user_id == user_id,
-        OnboardingCompletion.device_id == device_id,
-    )
-    return db.execute(stmt).first() is not None
-
-
-def mark_completed(db: Session, *, user_id: int, device_id: str) -> None:
-    """走完引导时写入。device_id 为空忽略;同 (账号, 设备) 已存在则幂等(靠唯一约束兜并发)。"""
-    if not device_id:
-        return
-    db.add(OnboardingCompletion(user_id=user_id, device_id=device_id))
-    try:
-        db.commit()
-    except IntegrityError:
-        # 并发 / 重复提交撞唯一约束:已有行即视为成功。
-        db.rollback()
@@ -12,7 +12,6 @@ import uuid
 from datetime import datetime, timedelta, timezone

 from sqlalchemy import select, update
-from sqlalchemy.exc import IntegrityError
 from sqlalchemy.orm import Session

 from app.core import rewards
@@ -32,7 +31,6 @@ from app.models.wallet import (
 _WX_STATE_SUCCESS = "SUCCESS"
 _WX_STATE_FAILED = {"FAIL", "CANCELLED", "CLOSED"}
 _WX_STATE_WAIT_CONFIRM = "WAIT_USER_CONFIRM"  # 用户还没在微信确认页确认
-_WITHDRAW_ACTIVE_STATUSES = {"reviewing", "pending"}
 # 免确认收款授权状态
 _WX_AUTH_ACTIVE = "TAKING_EFFECT"   # 已生效,可免确认转账
 _WX_AUTH_CLOSED = "CLOSED"          # 已关闭(用户/商户/风控),需重新开启
@@ -62,10 +60,6 @@ class InsufficientCashError(Exception):
    """现金余额不足。"""


-class WithdrawTooFrequentError(Exception):
-    """提现申请过于频繁,或已有未完成提现单。"""
-
-
 class WithdrawTransferError(Exception):
    """调用微信转账失败(已退回余额)。"""

@@ -289,18 +283,6 @@ def _refund_withdraw(
    """
    if order.status in ("failed", "rejected"):
        return  # 防重复退款(并发/对账与查单/重复拒绝同时触发)
-    refunded_txn_id = db.execute(
-        select(CashTransaction.id).where(
-            CashTransaction.user_id == order.user_id,
-            CashTransaction.biz_type == "withdraw_refund",
-            CashTransaction.ref_id == order.out_bill_no,
-        ).limit(1)
-    ).scalar_one_or_none()
-    if refunded_txn_id is not None:
-        order.status = final_status
-        order.fail_reason = reason[:256]
-        db.commit()
-        return
    bal = _add_cash(db, order.user_id, order.amount_cents)
    db.add(
        CashTransaction(
@@ -316,30 +298,7 @@ def _refund_withdraw(
    )
    order.status = final_status
    order.fail_reason = reason[:256]
-    out_bill_no = order.out_bill_no
-    user_id = order.user_id
-    try:
-        db.commit()
-    except IntegrityError:
-        # 并发退款兜底:唯一退款流水已被另一事务写入时,回滚本事务的加钱和流水,
-        # 再把订单状态补到终态。这样无论拒绝/查单/对账怎么并发,现金最多退一次。
-        db.rollback()
-        refunded_txn_id = db.execute(
-            select(CashTransaction.id).where(
-                CashTransaction.user_id == user_id,
-                CashTransaction.biz_type == "withdraw_refund",
-                CashTransaction.ref_id == out_bill_no,
-            ).limit(1)
-        ).scalar_one_or_none()
-        if refunded_txn_id is None:
-            raise
-        fresh_order = db.execute(
-            select(WithdrawOrder).where(WithdrawOrder.out_bill_no == out_bill_no)
-        ).scalar_one_or_none()
-        if fresh_order is not None and fresh_order.status not in ("failed", "rejected"):
-            fresh_order.status = final_status
-            fresh_order.fail_reason = reason[:256]
-            db.commit()
+    db.commit()


 def _wx_not_found(result: dict) -> bool:
@@ -426,15 +385,6 @@ def create_withdraw(
    else:
        out_bill_no = uuid.uuid4().hex

-    active_order_id = db.execute(
-        select(WithdrawOrder.id).where(
-            WithdrawOrder.user_id == user_id,
-            WithdrawOrder.status.in_(_WITHDRAW_ACTIVE_STATUSES),
-        ).limit(1)
-    ).scalar_one_or_none()
-    if active_order_id is not None:
-        raise WithdrawTooFrequentError
-
    # 账户须存在(原子扣款的 UPDATE 不会建账户)
    get_or_create_account(db, user_id, commit=True)

@@ -465,26 +415,7 @@ def create_withdraw(
        status="reviewing",
    )
    db.add(order)
-    try:
-        db.commit()
-    except IntegrityError:
-        db.rollback()
-        existing = db.execute(
-            select(WithdrawOrder).where(
-                WithdrawOrder.out_bill_no == out_bill_no, WithdrawOrder.user_id == user_id
-            )
-        ).scalar_one_or_none()
-        if existing is not None:
-            return existing
-        active_order_id = db.execute(
-            select(WithdrawOrder.id).where(
-                WithdrawOrder.user_id == user_id,
-                WithdrawOrder.status.in_(_WITHDRAW_ACTIVE_STATUSES),
-            ).limit(1)
-        ).scalar_one_or_none()
-        if active_order_id is not None:
-            raise WithdrawTooFrequentError from None
-        raise
+    db.commit()
    db.refresh(order)
    return order  # 待管理员审核;**不在此处打款**

@@ -772,15 +703,7 @@ def refresh_withdraw_status(
    if order.status != "pending":
        return order  # 已终态,不再查

-    try:
-        result = wxpay.query_transfer(out_bill_no)
-    except wxpay.WxPayNotConfiguredError:
-        raise
-    except Exception as exc:  # noqa: BLE001 - 查单失败不能把运营后台打成 500
-        order.fail_reason = f"微信查单异常,保持pending: {exc}"[:256]
-        db.commit()
-        db.refresh(order)
-        return order
+    result = wxpay.query_transfer(out_bill_no)
    if result["status_code"] != 200:
        if _wx_not_found(result):
            # 微信明确无此单 → 转账从未创建(如崩溃在扣款后/调用前),退款安全
@@ -46,11 +46,11 @@ class AdRewardStatusOut(BaseModel):
 class EcpmReportIn(BaseModel):
    """客户端上报一次广告展示的 eCPM(内部收益统计/对账)。

-    user_id 不在 body 里——由 JWT 取(Bearer),防伪造。ecpm 原样上报字符串,后端按分/千次展示处理(SDK getEcpm 原值,非元)。
+    user_id 不在 body 里——由 JWT 取(Bearer),防伪造。ecpm 原样上报字符串,后端按元/千次展示处理。
    """

    ad_type: str = Field(..., description="广告类型:reward_video(激励视频) / draw(Draw 信息流) 等")
-    ecpm: str = Field(..., description="穿山甲 getShowEcpm().getEcpm() 原始字符串,按分/千次展示处理(SDK getEcpm 原值,非元)")
+    ecpm: str = Field(..., description="穿山甲 getShowEcpm().getEcpm() 原始字符串,按元/千次展示处理")
    ad_session_id: str | None = Field(
        None, min_length=8, max_length=64,
        description="客户端生成的一次广告会话 id;激励视频 S2S extra 会透传同值",
@@ -89,11 +89,6 @@ class TestGrantIn(BaseModel):
        "reward_video",
        description="模拟发奖场景:reward_video(普通激励视频) / signin_boost(签到膨胀)",
    )
-    ad_session_id: str | None = Field(
-        None, min_length=8, max_length=64,
-        description="本次广告会话 id(与 ecpm-report 同值)。reward_video 场景下据此查回客户端"
-        "已上报的真实 eCPM 来按公式发奖;查不到或 eCPM≤0 时兜底 200,保证本地联调仍出非零金币",
-    )


 class TestGrantOut(BaseModel):
@@ -124,7 +119,7 @@ class FeedRewardIn(BaseModel):
    ad_session_id: str | None = Field(
        None, min_length=8, max_length=64, description="客户端生成的一次信息流广告会话 id"
    )
-    ecpm: str = Field(..., description="本条信息流广告 eCPM,按分/千次展示处理(SDK getEcpm 原值,非元)")
+    ecpm: str = Field(..., description="本条信息流广告 eCPM,按元/千次展示处理")
    duration_seconds: int = Field(..., ge=0, description="本条广告实际展示/播放秒数")
    adn: str | None = Field(None, description="实际投放 ADN")
    slot_id: str | None = Field(None, description="实际展示代码位")
@@ -25,8 +25,6 @@ class UserOut(BaseModel):
    status: str
    created_at: datetime
    last_login_at: datetime
-    # 调试链接权限:前端据此在比价结果弹窗/记录页显示「复制调试链接」按钮。默认 false。
-    debug_trace_enabled: bool = False


 # ===== Token 通用结构 =====
@@ -41,11 +39,6 @@ class TokenPair(BaseModel):

 class TokenWithUser(TokenPair):
    user: UserOut
-    onboarding_completed: bool = Field(
-        False,
-        description="该 设备+账号 是否已走完新手引导(据登录请求里的 device_id 计算)。"
-        "true → 客户端登录后直接进首页,跳过引导。",
-    )


 # ===== 极光一键登录 =====
@@ -53,10 +46,6 @@ class TokenWithUser(TokenPair):
 class JverifyLoginRequest(BaseModel):
    login_token: str = Field(..., description="客户端 loginAuth 拿到的 loginToken", min_length=1)
    operator: str = Field("", description="CM/CU/CT,用于日志,可选")
-    device_id: str = Field(
-        "", max_length=64,
-        description="硬件级设备标识(Android ANDROID_ID),用于新手引导按 设备+账号 去重;空=按未完成处理",
-    )


 # ===== 短信验证码 =====
@@ -74,10 +63,6 @@ class SmsSendResponse(BaseModel):
 class SmsLoginRequest(BaseModel):
    phone: str = Field(..., min_length=11, max_length=11, pattern=r"^1\d{10}$")
    code: str = Field(..., min_length=4, max_length=8)
-    device_id: str = Field(
-        "", max_length=64,
-        description="硬件级设备标识(Android ANDROID_ID),用于新手引导按 设备+账号 去重;空=按未完成处理",
-    )


 # ===== Refresh =====
@@ -67,9 +67,6 @@ class ComparisonRecordIn(BaseModel):
    status: str | None = Field(None, description="success / failed,可不传由服务端派生")
    # 最优平台商家/商品深链(客户端从 collectedLinks[best_index] 取);「再次比价」直达用
    best_deeplink: str | None = Field(None, description="最优平台深链,再次比价直达")
-    # pricebot done.params.trace_url 原样上报,落库供记录页「复制调试链接」(dir 名含落盘
-    # 时分秒前端拼不出,必须由后端透传)。
-    trace_url: str | None = Field(None, description="本次比价公网调试链接")


 # ===== 读取出参 =====
@@ -82,8 +79,6 @@ class ComparisonRecordOut(BaseModel):
    id: int
    business_type: str
    trace_id: str
-    # 公网调试链接;仅当 user.debug_trace_enabled 时由端点填充,否则端点层置 None(权限闸)。
-    trace_url: str | None = None
    source_platform_id: str | None = None
    source_platform_name: str | None = None
    source_package: str | None = None
@@ -19,9 +19,3 @@ class CouponPromptShouldShowOut(BaseModel):
    """切到外卖 App 时是否还应弹领券引导窗。今天已 engage(领或拒)过 → false。"""

    should_show: bool
-
-
-class CouponCompletedTodayOut(BaseModel):
-    """这台设备今天是否已跑完整轮领券(到 done 帧)。完成 → 首页「去领取」卡置灰。"""
-
-    completed: bool
@@ -1,8 +1,6 @@
 """邀请相关 API 收发模型。"""
 from __future__ import annotations

-from datetime import datetime
-
 from pydantic import BaseModel, Field


@@ -13,61 +11,15 @@ class InviteInfoOut(BaseModel):
    coins_earned: int               # 累计从邀请获得的金币


-class LandingTrackIn(BaseModel):
-    """落地页 dl.html 访问时上报的指纹(用于剪贴板归因失败时兜底)。"""
-    ref: str = Field(..., min_length=4, max_length=16, description="邀请码(落地页 ?ref=)")
-    screen: str = Field("", max_length=32, description="屏幕分辨率,如 1080x2400")
-    # IP / UA 服务端从 HTTP 头自动拿,无需 JS 上报
-
-
-class LandingTrackOut(BaseModel):
-    status: str                     # ok / invalid_code / no_ip
-
-
-class FingerprintIn(BaseModel):
-    """客户端登录后剪贴板归因失败时上报的设备指纹。
-
-    跨端匹配字段:浏览器落地页存的同名字段 == 客户端 Build.MODEL / DisplayMetrics 算的值。
-    IP 服务端从 HTTP 头拿,不在这里。
-    """
-    screen: str = Field("", max_length=32)
-    device_model: str = Field("", max_length=64)
-
-
 class BindInviteIn(BaseModel):
-    # invite_code: 可选 — 走指纹兜底时为空(channel=fingerprint)
-    invite_code: str | None = Field(
-        None, max_length=16, description="邀请码;走指纹兜底时为空"
-    )
+    invite_code: str = Field(..., min_length=4, max_length=16, description="邀请人的邀请码")
    channel: str = Field(
        "clipboard", max_length=16,
-        description="归因来源:clipboard(首启读剪贴板自动) / manual(手动填) / fingerprint(指纹兜底)",
+        description="归因来源:clipboard(首启读剪贴板自动) / manual(用户手动填)",
    )
-    # 当 invite_code 为空、channel=fingerprint 时,后端用这组指纹反查
-    fingerprint: FingerprintIn | None = None


 class BindInviteOut(BaseModel):
-    status: str                     # success / already_bound / invalid_code / self_invite / not_eligible / fp_not_found
+    status: str                     # success / already_bound / invalid_code / self_invite / not_eligible
    coins_awarded: int              # 本次给当前用户(被邀请人)发的金币
    message: str                    # 给前端直接展示的文案
-
-
-class InviteeItem(BaseModel):
-    """被邀请人列表的一条(邀请页小窗 / 完整列表页共用)。
-
-    display_name / avatar_url 的"降级兜底"在后端算好(见 repositories/invite.get_invitees):
-    名字 = 昵称 → 微信昵称 → 脱敏手机号(前端拿不到完整号,必须后端脱敏);
-    头像 = 用户头像 → 微信头像 → null(前端拿到 null 画默认色块)。
-    """
-    display_name: str               # 已兜底好的显示名(真名/脱敏号)
-    avatar_url: str | None = None   # 头像 URL;null = 前端画默认色块
-    coins: int                      # 这次邀请给我(邀请人)发的金币
-    invited_at: datetime            # 邀请绑定时间(前端转"今天/3天前")
-
-
-class InviteeListOut(BaseModel):
-    """GET /invite/invitees 响应:被邀请人列表 + 分页。"""
-    items: list[InviteeItem]
-    total: int                      # 我邀请的总人数(用于"共 N 人")
-    has_more: bool                  # 还有下一页吗(完整列表页滚到底加载更多)
@@ -16,12 +16,5 @@ class ProfileUpdateRequest(BaseModel):
        return v


-class OnboardingCompleteRequest(BaseModel):
-    device_id: str = Field(
-        ..., min_length=1, max_length=64,
-        description="硬件级设备标识(Android ANDROID_ID),与登录时一致,用于按 设备+账号 标记引导完成",
-    )
-
-
 class OkResponse(BaseModel):
    ok: bool = True
@@ -62,11 +62,11 @@
    <div class="feat">💰 <span>省下的钱看得见,还能<b>赚金币提现</b></span></div>
  </div>

-  <button class="btn" id="dlbtn">🏪 打开应用商店下载</button>
-  <div class="hint" id="hint">Android 安卓版 · 应用商店安全下载</div>
+  <button class="btn" id="dlbtn">⬇️ 下载安装包</button>
+  <div class="hint" id="hint">Android 安卓版 · 安装包约 24 MB</div>

  <div class="foot">
-    将前往应用商店下载,安全放心。<br>
+    安装时如提示「未知来源」,请允许后继续安装。<br>
    本页为内部测试页。
  </div>

@@ -82,45 +82,22 @@
      <div class="wxsteps">
        <div><span class="n">1</span>点右上角的 ··· 菜单</div>
        <div><span class="n">2</span>选择「在浏览器打开」</div>
-        <div><span class="n">3</span>在浏览器里按提示去应用商店下载</div>
+        <div><span class="n">3</span>在浏览器里点「下载安装包」</div>
      </div>
    </div>
    <div class="closebar" id="wxclose">我知道了 ✕</div>
  </div>

 <script>
-  // 应用商店跳转:用包名(App 唯一标识 = 身份证号)定位到傻瓜比价的商店下载页。
-  // 主:market:// 唤起手机自带应用市场(华为/小米/OV);兜底:应用宝网页(任何浏览器都能开)。
-  var PKG = "com.jishisongfu.shaguabijia";
-  var MARKET_URL = "market://details?id=" + PKG;
-  var YYB_URL = "https://a.app.qq.com/o/simple.jsp?pkgname=" + PKG;
+  // APK 下载地址跟随当前页面 origin:本地测试时页面由笔记本 app-server(LAN:8770)托管 →
+  // 下载也走 LAN;生产由 app-api.shaguabijia.com 托管 → 下载走生产域名。无需按机器改 IP。
+  var APK_URL = location.origin + "/media/shaguabijia.apk";
  var ua = navigator.userAgent || "";
  var isWeChat = /MicroMessenger/i.test(ua);
  var isIOS = /iPhone|iPad|iPod/i.test(ua);
  var isAndroid = /Android/i.test(ua);
  var ref = new URLSearchParams(location.search).get("ref");  // 邀请码(来自二维码 URL ?ref=)

-  // 【任务 3】指纹归因兜底:页面加载即上报访问者指纹,后端存 invite_fingerprint 表。
-  // 当 APK 首启读剪贴板失败(被覆盖)时,客户端会用 (IP+屏幕+UA 解析的手机型号) 反查
-  // 本表 7 天内最近一条匹配 → 撞库出原邀请人 → 走原 bind 流程。
-  // 任何失败都 silent(不影响下载主流程);后端 invalid_code/no_ip 也只返 200。
-  if (ref) {
-    // screen 报【物理像素】= CSS 像素 × devicePixelRatio,跟 Android dm.widthPixels(物理像素)对齐。
-    // 不同设备 DPR 不同(常见 2/2.5/3/3.5),CSS 像素直接报会跟客户端不对齐 → 撞不上库。
-    var _dpr = window.devicePixelRatio || 1;
-    var _sw = Math.round(screen.width * _dpr);
-    var _sh = Math.round(screen.height * _dpr);
-    fetch("/api/v1/invite/landing-track", {
-      method: "POST",
-      headers: { "Content-Type": "application/json" },
-      body: JSON.stringify({
-        ref: ref,
-        screen: _sw + "x" + _sh,
-        // IP / UA 服务端从 HTTP 头自动拿,无需 JS 上报
-      }),
-    }).catch(function () {});  // silent,绝不阻断下载
-  }
-
  // 把邀请码写进剪贴板,APK 首启时读出来完成归因(deferred deeplink 的关键一步)。
  // 浏览器要求:必须在用户点击手势里调用 + HTTPS 下才允许写。
  function legacyCopy(payload) {                // 老 webview / 无 clipboard API 兜底
@@ -140,20 +117,12 @@
    }
    return Promise.resolve();
  }
-  // 跳应用商店:先尝试 market:// 唤起手机自带商店;若 2.5s 内页面没切到后台
-  //(= 没有商店接管 market://),兜底跳应用宝网页下载页,不让用户卡死。
-  function openStore() {
-    var jumped = false;
-    function markJumped() { jumped = true; }           // 页面切到后台 = 商店已唤起
-    document.addEventListener("visibilitychange", function () {
-      if (document.hidden) jumped = true;
-    });
-    window.addEventListener("pagehide", markJumped);
-    window.addEventListener("blur", markJumped);
-    window.location.href = MARKET_URL;                 // 唤起自带应用市场
-    setTimeout(function () {
-      if (!jumped) window.location.href = YYB_URL;     // 没唤起 → 应用宝网页兜底
-    }, 2500);
+  // 确保剪贴板写完(或最多等 400ms 兜底,防写入卡住)再触发下载。
+  function startDownload() {
+    var fired = false;
+    function go() { if (!fired) { fired = true; window.location.href = APK_URL; } }
+    copyInviteCode().then(go);
+    setTimeout(go, 400);
  }

  var hint = document.getElementById("hint");
@@ -170,10 +139,8 @@
  document.getElementById("dlbtn").addEventListener("click", function(){
    if (isWeChat) { showMask(); return; }           // 微信内:引导去浏览器
    if (isIOS)    { alert("iOS 版即将上线,请前往 App Store 搜索「傻瓜比价」"); return; }
-    // 安卓浏览器:先把邀请码写进剪贴板(legacyCopy 同步写、最可靠),再跳应用商店。
-    // 剪贴板供 App 首启归因;链路长易丢时由指纹兜底(已上报 landing-track)接住。
-    copyInviteCode();
-    openStore();
+    // 普通浏览器:先把邀请码写进剪贴板(写完或 400ms 兜底),再下载 APK(首启读回完成归因)
+    startDownload();
  });
 </script>
 </body>
@@ -102,7 +102,6 @@
 | A24 | `DELETE /admin/api/marquee-seeds/{seed_id}` | operator | [详情](./admin-marquee-seeds.md) |
 | A25 | `POST /admin/api/marquee-seeds/bulk` | operator | [详情](./admin-marquee-seeds.md) |
 | A26 | `GET /admin/api/marquee-seeds/preview` | admin | [详情](./admin-marquee-seeds.md) |
-| A27 | `GET /admin/api/ad-coin-audit` | admin | [详情](./admin-ad-coin-audit.md)(看广告金币公式复算对账,只读) |
 | - | `GET /admin/api/health` | 无 | admin 健康检查(无单独文档) |

 > ⚠️ 美团三个接口当前**无鉴权**,且 `referral-link` 的 `sid` 允许客户端传值覆盖默认渠道——见各接口"备注"。
@@ -9,7 +9,7 @@
 |---|---|---|---|
 | `ad_type` | str | 是 | 广告类型:`reward_video`(激励视频) / `draw`(Draw 信息流) 等 |
 | `ad_session_id` | str\|null | 否 | 客户端生成的广告会话 ID;需和穿山甲 `extra.ad_session_id` 一致,用于 S2S 缺 eCPM 时匹配 |
-| `ecpm` | str | 是 | 穿山甲 `getShowEcpm().getEcpm()` 原始字符串,单位是**分/千次展示**(非元),后端 ÷100 转元参与金币公式 |
+| `ecpm` | str | 是 | 穿山甲 `getShowEcpm().getEcpm()` 原始字符串,后端按“元/千次展示”参与金币公式 |
 | `adn` | str\|null | 否 | 实际投放 ADN(`getSdkName`),如 `pangle` |
 | `slot_id` | str\|null | 否 | 实际展示代码位(底层 mediation rit,非客户端配置位) |

@@ -12,7 +12,7 @@
 |---|---|---:|---|
 | `client_event_id` | string | 是 | 客户端生成的幂等事件 id，8-64 字符 |
 | `ad_session_id` | string\|null | 否 | 客户端生成的一次信息流广告会话 id，用于对账/排查 |
-| `ecpm` | string | 是 | 本条信息流广告 eCPM(穿山甲 getEcpm 原值)，按“分/千次展示”处理(非元) |
+| `ecpm` | string | 是 | 本条信息流广告 eCPM，按“元/千次展示”处理 |
 | `duration_seconds` | int | 是 | 实际展示/播放秒数 |
 | `adn` | string\|null | 否 | 实际投放 ADN |
 | `slot_id` | string\|null | 否 | 实际展示代码位 |
@@ -10,7 +10,6 @@
 | 字段 | 类型 | 必填 | 默认 | 说明 |
 |---|---|---|---|---|
 | `reward_scene` | string | 否 | `reward_video` | 模拟发奖场景。`reward_video`=普通激励视频；`signin_boost`=签到膨胀 |
-| `ad_session_id` | string(8~64) \| null | 否 | null | 本次广告会话 id(与 [ecpm-report](./ad-ecpm-report.md) 同值)。**仅 `reward_video` 场景生效**:据此查回客户端已上报的真实 eCPM,走与正式发奖相同的公式发奖;查不到或 eCPM≤0(测试应用常返 0/假值)时兜底 200,保证本地联调仍出非零金币 |

 ## 出参
 响应 `200`:`TestGrantOut`
@@ -31,6 +30,4 @@
 ## 说明
 没公网、穿山甲 S2S 回调打不到本地时,debug 客户端看完广告后调它,直接走与 [ad-pangle-callback](./ad-pangle-callback.md) 相同的发奖逻辑（每次新 `trans_id`,幂等 + 每日上限/今日膨胀一次）。

-`reward_scene=reward_video` 时按上面 `ad_session_id` 查回的真实 eCPM 走金币公式发奖(取不到兜底 200)——便于本地用 [admin 金币审计](./admin-ad-coin-audit.md) 核对「看广告→金币」是否按公式计算。
-
 `reward_scene=signin_boost` 时复用签到膨胀业务规则:必须当天已签到、非第 14 天、当天未膨胀过,成功后写入 `signin_boost` 金币流水。它让已登录客户端能自助发奖 = 绕过反作弊,**严禁在生产开启**。
@@ -1,69 +0,0 @@
-# Admin 看广告金币审计
-
-> 所属:Admin 组(前缀 `/admin/api/ad-coin-audit`) | 鉴权:Admin Bearer(任意已登录 admin,只读) | [← 返回 API 索引](./README.md)
-
-把「看视频赚金币」(`ad_reward_record`)和「比价信息流广告」(`ad_feed_reward_record`)两类发奖记录,用与**正式发奖完全相同**的公式 [`app/core/rewards.py` `calculate_ad_reward_coin`](../../app/core/rewards.py) 复算一遍 `expected_coin`,与实际入账的 `actual_coin` 对比,核对金币公式是否生效。**纯只读对账**,不发币、不改任何数据。
-
-相关表:[ad_reward_record](../database/ad_reward_record.md)、[ad_feed_reward_record](../database/ad_feed_reward_record.md)。
-
-## 金币公式(展示参照)
-
-```
-eCPM元 = getEcpm分 ÷ 100
-单份金币 = round( eCPM元 ÷ 1000 × 因子1 × 因子2 × coin_per_yuan )   # coin_per_yuan=10000
-```
- **eCPM 口径**:`getEcpm()` 原值单位是分/千次展示;先 ÷100 转元,**因子判档与收益换算都用元**。
- **因子1(eCPM 档,阈值单位=元/千次)**:≤100→0.1,101–200→0.3,201–400→0.4,>400→0.6(即 ¥100/¥200/¥400 CPM 分界。**真实 eCPM 多 <¥100 CPM,故常落最低档 0.1,高档基本不触发——产品有意取舍**)。
- **因子2(LT,当日第 N 份)**:第1→2.0,第2→1.5,第3→1.3,第4–10→1.1,≥11→1.0。
- **第 N 份的计数**:看视频每条 granted 记 1 份;信息流每满 10 秒记 1 份。**两个点位各自独立计数**(看视频的份数不影响信息流的份数,反之亦然)。
-
-## GET /admin/api/ad-coin-audit — 复算对比
-
- 入参(均 query,可选):
-  | 参数 | 类型 | 默认 | 说明 |
-  |---|---|---|---|
-  | `date` | string | 今天 | 北京时间 `YYYY-MM-DD`,审计某天 |
-  | `user_id` | int | 全部 | 只看某用户;不传=所有用户 |
-  | `scene` | string | 两类 | `reward_video` / `feed`;不传=两类都返回 |
-  | `limit` | int(1~500) | 100 | 返回明细条数(按时间倒序截断;**份序号在截断前已按全天数据算好**,不影响复算正确性) |
-
- 出参 `200`:`AdCoinAuditOut`
-  | 字段 | 类型 | 说明 |
-  |---|---|---|
-  | `date` | string | 审计日期 |
-  | `formula` | object | 当前公式参数快照(见下) |
-  | `total` | int | 返回明细条数 |
-  | `mismatch_count` | int | 其中 `matched=false` 的条数;**=0 说明全部按公式发放** |
-  | `items` | `AdCoinAuditRow[]` | 明细(见下) |
-
-### AdCoinFormulaOut(`formula`)
-| 字段 | 类型 | 说明 |
-|---|---|---|
-| `description` | string | 公式文字说明 |
-| `coin_per_yuan` | int | 金币:元 汇率(10000) |
-| `ecpm_unit` | string | eCPM 口径(分/千次展示,SDK getEcpm 原值) |
-| `feed_unit_seconds` | int | 信息流每多少秒折 1 份(10) |
-| `ecpm_factor_tiers` | `[因子, 下限, 上限\|null][]` | 因子1 档位表(直接读发奖常量,与发奖同源) |
-| `lt_factor_tiers` | `[因子, 下限, 上限\|null][]` | 因子2 LT 档位表 |
-
-### AdCoinAuditRow(`items[]`)
-| 字段 | 类型 | 说明 |
-|---|---|---|
-| `scene` | string | `reward_video` / `feed` |
-| `record_id` | int | 对应记录表主键 |
-| `user_id` | int | |
-| `created_at` | datetime | |
-| `status` | string | `granted` / `capped`(超每日上限未发) / `ecpm_missing`(缺 eCPM 未发) |
-| `ecpm` | string \| null | 本次采用的 eCPM 原始值 |
-| `ecpm_factor` | float \| null | 因子1;非 granted 为 null |
-| `units` | int | 折算份数:看视频恒 1;信息流 = 满 10 秒份数 |
-| `lt_index_start` / `lt_index_end` | int \| null | 本条占用「当日第几份」的起止(看视频起=止;信息流一条可跨多份) |
-| `lt_factor_start` / `lt_factor_end` | float \| null | 因子2 的起止值(信息流跨份时会衰减,故给区间) |
-| `expected_coin` | int | 按公式复算应发金币(非 granted 恒 0) |
-| `actual_coin` | int | 实际入账金币 |
-| `matched` | bool | 复算与实发是否一致;非 granted 校验实发是否确为 0 |
-
-## 说明
- **非 granted 行**(capped/ecpm_missing)不占用份序号、应发恒 0,`matched` 用于校验「该不发的确实没发」。
- 用法建议:**按 `user_id`+`date` 定位某次具体核对**最直观;不带 `user_id` 是全用户当天概览。
- 本地联调造数:debug 包看完激励视频会调 [`/api/v1/ad/test-grant`](./ad-test-grant.md),它会用客户端按 `ad_session_id` 上报的真实 eCPM 发奖(取不到兜底 200),所以本审计能看到真实 eCPM 对应的金币。
@@ -2,7 +2,7 @@

 > 跨表视角。单表字段级细节看同目录 `<表名>.md`(索引见 [README](./README.md))。
 > 本文专门回答三件「跨表」的事:**① 每块 App 功能用到哪些表 ② 什么操作往哪张表写 ③ 表和表怎么连(join key,含没有外键约束、靠业务字段对齐的语义关联)**。
-> **范围**:业务表全部在 `shaguabijia-app-server`(SQLAlchemy 2.0 + SQLite 开发 / PostgreSQL 生产)。`pricebot-backend`(比价/领券 Agent)是纯内存态、**无任何表**;Android 客户端只有 EncryptedSharedPreferences / SharedPreferences、**无关系库**。共 **23 张业务表** + `alembic_version`(框架的迁移版本指针)。
+> **范围**:业务表全部在 `shaguabijia-app-server`(SQLAlchemy 2.0 + SQLite 开发 / PostgreSQL 生产)。`pricebot-backend`(比价/领券 Agent)是纯内存态、**无任何表**;Android 客户端只有 EncryptedSharedPreferences / SharedPreferences、**无关系库**。共 **22 张业务表** + `alembic_version`(框架的迁移版本指针)。

 ---

@@ -35,7 +35,6 @@
 | App 位置 / 动作 | 表 | 说明 |
 |---|---|---|
 | 登录(极光/短信)/ 改资料 / 注销 | [`user`](./user.md) | 登录主体,注册即登录 |
-| 新手引导是否再展示 | [`onboarding_completion`](./onboarding_completion.md) | 按 设备+账号 去重;登录响应回 `onboarding_completed`,走完引导时标记,跨卸载重装 |
 | 帮助与反馈 | [`feedback`](./feedback.md) | 含截图,后台人工处理 |

 ### 运营后台 admin(独立子应用 `app/admin/`,端口 8771,独立鉴权)
@@ -55,8 +54,7 @@
 ### C 端(App 用户触发)
 | 触发(用户动作 / endpoint / 回调) | 写入 | 操作 |
 |---|---|---|
-| 登录 `POST /auth/jverify-login`、`/auth/sms/login` | `user` | C(首次=注册)/ U(`last_login_at`);并**读** `onboarding_completion` 回 `onboarding_completed` |
-| 走完新手引导 `POST /user/onboarding/complete` | `onboarding_completion`(C) | `(user_id, device_id)` 幂等,撞唯一约束即忽略 |
+| 登录 `POST /auth/jverify-login`、`/auth/sms/login` | `user` | C(首次=注册)/ U(`last_login_at`) |
 | 改昵称 `PATCH /user/profile`、传头像 `POST /user/avatar` | `user` | U |
 | 注销 `DELETE /user` | `user` | U(软删:`phone→deleted_<id>`、`status=deleted`) |
 | 绑/解绑微信 `POST /wallet/bind-wechat`、`/unbind-wechat` | `user`.wechat_* | U |
@@ -122,7 +120,6 @@
 - **`comparison_record.store_name` ≈ `savings_record.shop_name`**:无 id 关联,按**店名字符串相等**给比价记录打「已下单」标记(瞬态,不写库)。两边店名同源 = 比价意图识别阶段的门店 query,语义=**店级**(同店比价多次会一并标已下单)。
 - **广告流会话关联**:`ad_reward_record.ad_session_id` 可与 `ad_ecpm_record.ad_session_id` 对齐;`ad_watch_log` 仍是旧版兼容统计,不逐条参与发奖。
 - **里程碑解锁进度不存库**:`comparison_milestone_claim` 只记「哪几档已领」;进度 = `comparison_record` 里 `status='success'` 的 `count`。
- **`onboarding_completion.(user_id, device_id)`**:`user_id` 语义关联 `user.id`(无硬 FK,同 `coupon_*` 设备表),`device_id` = 客户端硬件级 `ANDROID_ID`(≠ 领券 per-install `device_id`)。登录读、走完引导写,决定是否再展示新手引导。

 ### ER 关系(文字版)
 ```
@@ -132,7 +129,6 @@ user ─1:N─ { coin_transaction, cash_transaction, withdraw_order, signin_reco
            signin_boost_record, user_task, comparison_record, comparison_milestone_claim,
            savings_record, ad_reward_record, ad_watch_log, ad_ecpm_record, ad_feed_reward_record,
            price_report, feedback }
-user ─1:N─ onboarding_completion             (user_id, 无硬 FK; (user_id,device_id) 去重)
 comparison_record ─1:N─ price_report        (comparison_record_id, 可空)
 admin_user ─1:N─ admin_audit_log
 app_config                                   (独立, 无外键, key 为主键)
@@ -3,19 +3,18 @@
 > 数据库:SQLite 起步(`data/app.db`),生产可切 PostgreSQL(改 `DATABASE_URL`)。
 > ORM:SQLAlchemy 2.0(`app/models/`),迁移:Alembic(`alembic/versions/`,`render_as_batch` 兼容 SQLite)。
 > 金额字段一律存**整数**:金币=个数,现金=**分**(`*_cents`)。时间列 `DateTime(timezone=True)`。
-> 最后更新:2026-06-10(新增 `onboarding_completion` 新手引导完成表 → 23 张业务表)
+> 最后更新:2026-06-07(补全 22 张业务表 + 新增 [OVERVIEW 总览](./OVERVIEW.md))

 > 🧭 **先看 [OVERVIEW.md — 表 × 功能 × 关系](./OVERVIEW.md)**:跨表的「每块功能用哪些表 / 什么操作写哪张表 / 表间 join key」都在那;本页只做**单表索引**,点进每张表的详情看字段级说明。

 ---

-## 表总览(23 张业务表 + `alembic_version` 框架表)
+## 表总览(22 张业务表 + `alembic_version` 框架表)

 ### 账号 / 反馈
 | 表 | 用途 | 模型 | 文档 |
 |---|---|---|---|
 | `user` | 用户(登录主体);几乎所有表的外键宿主 | `models/user.py` | [详情](./user.md) |
-| `onboarding_completion` | 新手引导完成标记(按 设备+账号 去重,登录时据此跳过引导) | `models/onboarding.py` | [详情](./onboarding_completion.md) |
 | `feedback` | 用户帮助与反馈(含截图) | `models/feedback.py` | [详情](./feedback.md) |

 ### 钱包 / 福利(看广告赚钱闭环)
@@ -18,7 +18,7 @@
 | `ad_session_id` | String(64) | UNIQUE, index, nullable | 客户端广告会话 ID;用于普通激励视频在 S2S 缺 `ecpm` 时匹配发奖 |
 | `adn` | String(32) | nullable | 实际投放 ADN(`getShowEcpm().getSdkName()`,如 `pangle`/`gdt`) |
 | `slot_id` | String(64) | nullable | 实际展示用代码位(底层 mediation rit,非客户端配置位) |
-| `ecpm_raw` | String(32) | NOT NULL | 客户端上报的 eCPM **原始串**(穿山甲 getEcpm 原值,单位**分/千次展示**);后端 ÷100 转元参与金币公式 |
+| `ecpm_raw` | String(32) | NOT NULL | 客户端上报的 eCPM **原始串**;后端按“元/千次展示”参与金币公式 |
 | `report_date` | String(10) | index, NOT NULL | 北京时间日期串 `YYYY-MM-DD`,按它做按天聚合 |
 | `created_at` | DateTime(tz) | server_default now(), index | 时间 |

@@ -1,44 +0,0 @@
-# onboarding_completion — 新手引导完成标记(按 设备 + 账号 去重)
-
-> 模型 `app/models/onboarding.py` · 仓库 `app/repositories/onboarding.py` · 迁移 `alembic/versions/onboarding_completion_table.py`(revision `onboarding_completion`) · 读 `POST /api/v1/auth/jverify-login`·`/sms/login` · 写 `POST /api/v1/user/onboarding/complete` · 测试 `tests/test_onboarding.py` · [← 索引](./README.md) · [总览](./OVERVIEW.md)
-
-记录「**某账号在某台设备上已走完新手引导**」,一条 `(user_id, device_id)`。用途单一:决定**登录后要不要再展示新手引导教程**——本表有这条 → 跳过引导直接进首页;没有 → 走引导。
-
-**为什么要落后端**:此前「引导只跑一次」只存客户端本地 `OnboardingPrefs`(SharedPreferences),**卸载重装即丢** → 重装会重弹引导。产品需求是「同设备 + 同账号只触发一次,且跨卸载重装」,本地存不住,故把"真相"放到服务端,按 **账号 + 硬件设备号** 去重。
-
-**去重维度 = 设备 + 账号**(产品决议):
-
-| 场景 | 命中本表? | 是否再展示引导 |
-|---|---|---|
-| 新账号(从未走过) | 否 | ✅ 展示 |
-| 同账号 + **同设备**(卸载重装 / 退登重登) | 是 | ❌ 跳过 |
-| 同账号 + **换新设备** | 否 | ✅ 展示(新机需重新授权悬浮窗/无障碍等) |
-
-> ⚠️ `device_id` 用客户端**硬件级稳定标识** `Settings.Secure.ANDROID_ID`(`util/DeviceId.hardwareId()`,同签名 app 卸载重装不变、仅恢复出厂重置),**不是**领券/比价用的 per-install `DeviceId.get()`(存 SP、重装会变)。两套 device_id 不互通,别混用。
-
-## 用在哪 / 增删改查
- **R(读)**:登录 `POST /auth/jverify-login`、`/auth/sms/login` —— 客户端在登录请求体里带 `device_id`,`onboarding_repo.is_completed(user_id, device_id)` 查本表有无行,结果塞进登录响应 `TokenWithUser.onboarding_completed`(true=已完成)。客户端 `AuthRepository.persist` 据此回写本地 `OnboardingPrefs`(只回写 true),既有 gating(`OnboardingHost` / `AppNavHost`)逻辑不变。
- **C(插入)**:走完引导最后一步(后台耗电屏)时,客户端 `POST /api/v1/user/onboarding/complete`(带 Bearer + `device_id`)→ `onboarding_repo.mark_completed` 插一行。**幂等**:同 `(user_id, device_id)` 已存在则撞唯一约束,`IntegrityError` 被 rollback 吞掉、视为成功;`device_id` 为空一律忽略不写。best-effort:客户端上报失败不阻断进首页(本地已先标记)。
- **U / D**:无。一台设备 + 一账号一条,完成即永久;账号注销(软删 `user`)**不清本表**(留着无害——user_id 指向的是已 `deleted` 的行;同手机号重新注册是新 user.id,自然重新走引导)。
-
-## 字段
-| 列 | 类型 | 约束 / 默认 | 说明(取值 / join) |
-|---|---|---|---|
-| `id` | Integer | PK, autoincrement | |
-| `user_id` | Integer | index, NOT NULL | 归属账号 → `user.id`(语义外键,未建 DB 级 FK,同 `coupon_*` 设备表) |
-| `device_id` | String(64) | NOT NULL | 硬件级设备标识 = 客户端 `Settings.Secure.ANDROID_ID`;卸载重装不变 |
-| `completed_at` | DateTime(tz) | server_default now() | 标记完成的时间 |
-
-## 关系 / Join Key
- `user_id` → `user.id`(多对一:一账号在 N 台设备各一条)。**无硬 FK 约束**(同 `coupon_claim_record` / `coupon_prompt_engagement`),靠业务字段对齐。
- 判断维度 = `(user_id, device_id)` 组合等值查。
- `device_id` 与客户端 `DeviceId.hardwareId()`(ANDROID_ID)同源;**不**与领券侧 per-install `device_id` 互通。
-
-## 索引与约束
- PK `id`;index `user_id`(`ix_onboarding_completion_user_id`);UNIQUE(`user_id`, `device_id`) = `uq_onboarding_user_device`(防同账号同设备重复写 + 兜并发 upsert)。
-
-## 注意
- **去重维度是「设备 + 账号」**,不是纯账号:同一个人在新手机上登录会重新看引导(产品预期:新机要重新授权权限)。若日后想改「纯账号、换机也不弹」,把 `is_completed`/`mark_completed` 去掉 `device_id` 维度即可。
- `device_id` 取不到 / 为已知脏值(`9774d56d682e549c`)时客户端退回 per-install id,这类极少数设备重装会重弹一次(尽力而为)。
- 本地 `OnboardingPrefs` 现仅作**同安装快速跳过缓存**;真相以本表为准,每次登录响应同步。
- 客户端实现:`ui/onboarding/OnboardingViewModel.kt`(上报)、`data/auth/AuthRepository.kt`(读 + 同步本地)、`util/DeviceId.kt`(ANDROID_ID)。
@@ -34,9 +34,6 @@ dependencies = [

    # admin 后台账号密码 hash(用户侧是手机号+验证码登录,不需要密码;admin 才用)
    "bcrypt>=4.0.0",
-
-    # 邀请指纹归因:解析浏览器 UA 拿手机型号(Build.MODEL),跨端匹配用
-    "user-agents>=2.2.0",
 ]

 [project.optional-dependencies]
@@ -1,35 +0,0 @@
-@echo off
-REM Local dev startup script (Windows) - mirror of run.sh
-REM
-REM Usage:
-REM   cd shaguabijia-app-server
-REM   run.bat
-REM
-REM Listens on 0.0.0.0:8770 (works for both real device via adb reverse
-REM and LAN). Auto-reload on code change.
-REM
-REM Prerequisite (first time):
-REM   conda activate pricebot ^&^& pip install -e .
-REM   copy .env.example .env  ^&^& fill JWT_SECRET_KEY
-REM
-REM This file is the Windows-native peer of run.sh. Keeping run.sh untouched
-REM avoids CRLF/encoding fights every time someone bash-runs the .sh on Win.
-
-cd /d "%~dp0"
-
-if not exist .env (
-    echo [X] Missing .env. Run: copy .env.example .env  and fill JWT_SECRET_KEY ^(plus MT_CPS_* if you test Meituan^)
-    exit /b 1
-)
-
-if not exist data mkdir data
-
-REM Build/upgrade SQLite schema (idempotent; no-op if already at head)
-call alembic upgrade head
-if errorlevel 1 (
-    echo [X] alembic upgrade head failed
-    exit /b %errorlevel%
-)
-
-REM Long-running foreground process. Ctrl+C to stop.
-uvicorn app.main:app --host 0.0.0.0 --port 8770 --reload
@@ -1,91 +0,0 @@
-# -*- coding: utf-8 -*-
-"""造测试数据验证邀请列表"真实头像能不能连上"。
-
-A 邀请 B1(上传真实头像)/B2(无头像→色块)/B3(设昵称→色块), 然后:
-  ① 打印 A 的邀请码 + /invitees 返回(看 B1 有 avatar_url、B2 空、B3 昵称);
-  ② 直接 HTTP 访问 B1 的头像地址,确认文件能取到(后端静态托管通)。
-前端 AsyncImage 实际显示,装机后真机用 A 登录看。
-
-跑: <app-server py> scripts/seed_invitee_avatar_test.py"""
-import io
-import struct
-import sys
-import zlib
-
-import httpx
-
-sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding="utf-8")
-
-BASE = "http://127.0.0.1:8770"
-
-
-def solid_png(size: int = 96, rgb: tuple = (80, 140, 240)) -> bytes:
-    """生成一张纯色 PNG(蓝色 96x96),够真机看清、魔数是合法 PNG。"""
-    row = b"\x00" + bytes(rgb) * size
-    raw = row * size
-    comp = zlib.compress(raw)
-
-    def chunk(typ: bytes, data: bytes) -> bytes:
-        c = typ + data
-        return struct.pack(">I", len(data)) + c + struct.pack(">I", zlib.crc32(c) & 0xFFFFFFFF)
-
-    sig = b"\x89PNG\r\n\x1a\n"
-    ihdr = struct.pack(">IIBBBBB", size, size, 8, 2, 0, 0, 0)  # 8bit, RGB
-    return sig + chunk(b"IHDR", ihdr) + chunk(b"IDAT", comp) + chunk(b"IEND", b"")
-
-
-def login(c: httpx.Client, phone: str) -> str:
-    c.post(f"{BASE}/api/v1/auth/sms/send", json={"phone": phone})
-    r = c.post(f"{BASE}/api/v1/auth/sms/login", json={"phone": phone, "code": "123456"})
-    r.raise_for_status()
-    return r.json()["access_token"]
-
-
-def auth(tok: str) -> dict:
-    return {"Authorization": f"Bearer {tok}"}
-
-
-with httpx.Client(timeout=15) as c:
-    # A = 邀请人(真机用它登录看)
-    A_PHONE = "13900008001"
-    a_tok = login(c, A_PHONE)
-    a_code = c.get(f"{BASE}/api/v1/invite/me", headers=auth(a_tok)).json()["invite_code"]
-    print(f"邀请人 A: 手机号={A_PHONE} 验证码=123456 邀请码={a_code}")
-
-    # B1: 绑 A 码 + 上传真实头像
-    b1 = login(c, "13900008002")
-    c.post(f"{BASE}/api/v1/invite/bind", json={"invite_code": a_code}, headers=auth(b1))
-    r = c.post(
-        f"{BASE}/api/v1/user/avatar",
-        headers=auth(b1),
-        files={"file": ("avatar.png", io.BytesIO(solid_png()), "image/png")},
-    )
-    print(f"B1 绑定 + 上传头像 -> HTTP {r.status_code}, avatar_url={r.json().get('avatar_url')!r}")
-
-    # B2: 绑 A 码, 不传头像(测色块兜底)
-    b2 = login(c, "13900008003")
-    c.post(f"{BASE}/api/v1/invite/bind", json={"invite_code": a_code}, headers=auth(b2))
-    print("B2 绑定, 无头像(测色块)")
-
-    # B3: 绑 A 码 + 设昵称(测昵称优先 + 色块)
-    b3 = login(c, "13900008004")
-    c.post(f"{BASE}/api/v1/invite/bind", json={"invite_code": a_code}, headers=auth(b3))
-    c.patch(f"{BASE}/api/v1/user/profile", json={"nickname": "测试昵称"}, headers=auth(b3))
-    print("B3 绑定 + 昵称='测试昵称'")
-
-    # A 的邀请列表
-    inv = c.get(f"{BASE}/api/v1/invite/invitees", headers=auth(a_tok)).json()
-    print(f"\n=== A 的 /invitees (共 {inv['total']} 人) ===")
-    for it in inv["items"]:
-        print(f"  name={it['display_name']!r}  avatar={it['avatar_url']!r}  coins={it['coins']}  time={it['invited_at']}")
-
-    # 关键: 直接 HTTP 取 B1 的头像文件, 确认后端静态托管能 serve(= 前端拿这地址也能加载)
-    b1_avatar = next((it["avatar_url"] for it in inv["items"] if it["avatar_url"]), None)
-    print("\n=== 头像文件 HTTP 可访问性(后端静态托管) ===")
-    if b1_avatar:
-        rr = c.get(f"{BASE}{b1_avatar}")
-        ok = rr.status_code == 200 and (rr.headers.get("content-type", "").startswith("image"))
-        print(f"  GET {BASE}{b1_avatar}")
-        print(f"  -> HTTP {rr.status_code}, content-type={rr.headers.get('content-type')}, {len(rr.content)} bytes  {'✅ 能取到' if ok else '✗ 取不到'}")
-    else:
-        print("  没有带头像的被邀请人?!")
@@ -1,4 +1,4 @@
-"""好友邀请测试:邀请码、绑定、双方发金币、幂等、自邀/无效码屏蔽、指纹兜底归因。
+"""好友邀请测试:邀请码、绑定、双方发金币、幂等、自邀/无效码屏蔽。

 用 sms mock 登录拿 token(同 test_welfare),再跑邀请闭环。
 """
@@ -6,16 +6,12 @@ from __future__ import annotations

 from datetime import datetime, timedelta, timezone

-from sqlalchemy import select
-
 from app.core.rewards import (
-    INVITE_FP_WINDOW_DAYS,
    INVITE_INVITEE_COINS,
    INVITE_INVITER_COINS,
    INVITE_NEW_USER_WINDOW_HOURS,
 )
 from app.db.session import SessionLocal
-from app.models.invite_fingerprint import InviteFingerprint
 from app.repositories.user import get_user_by_phone


@@ -162,216 +158,3 @@ def test_old_user_not_eligible(client) -> None:
    assert r.json()["coins_awarded"] == 0
    assert _coin_balance(client, b) == 0
    assert _coin_balance(client, a) == 0
-
-
-# =====================================================================
-# 任务 3:指纹归因(剪贴板兜底,见 brain [[invite-three-tasks]])
-# =====================================================================
-
-def test_landing_track_records_fingerprint(client) -> None:
-    """落地页 POST /landing-track 成功存指纹(无需鉴权)。"""
-    a = _login(client, "13800002040")
-    a_code = _my_code(client, a)
-    # 浏览器无 token 调
-    r = client.post(
-        "/api/v1/invite/landing-track",
-        json={"ref": a_code, "screen": "1080x2400"},
-    )
-    assert r.status_code == 200, r.text
-    assert r.json()["status"] == "ok"
-
-
-def test_landing_track_invalid_code(client) -> None:
-    """无效邀请码 → invalid_code(silent 返,不影响落地页下载流程)。"""
-    r = client.post(
-        "/api/v1/invite/landing-track",
-        json={"ref": "ZZZZZZ", "screen": "1080x2400"},
-    )
-    assert r.status_code == 200, r.text
-    assert r.json()["status"] == "invalid_code"
-
-
-def test_bind_by_fingerprint_success(client) -> None:
-    """B 落地页存指纹 → B 登录后用指纹兜底绑定成功(模拟剪贴板被覆盖丢失)。"""
-    a = _login(client, "13800002041")
-    a_code = _my_code(client, a)
-
-    # 1. B 浏览器(无 token)访问落地页 → 存指纹
-    r1 = client.post(
-        "/api/v1/invite/landing-track",
-        json={"ref": a_code, "screen": "1234x5678"},  # 用独特 screen 避免跟其它测试撞
-    )
-    assert r1.json()["status"] == "ok"
-
-    # 2. B 注册登录(剪贴板被覆盖,没拿到邀请码)
-    b = _login(client, "13800002042")
-
-    # 3. B 不带 invite_code,只带 fingerprint 走兜底
-    r2 = client.post(
-        "/api/v1/invite/bind",
-        json={
-            "channel": "fingerprint",
-            "fingerprint": {"screen": "1234x5678", "device_model": ""},
-        },
-        headers=_auth(b),
-    )
-    assert r2.status_code == 200, r2.text
-    assert r2.json()["status"] == "success"
-    # 双方各发金币
-    assert _coin_balance(client, a) == INVITE_INVITER_COINS
-    assert _coin_balance(client, b) == INVITE_INVITEE_COINS
-
-
-def test_bind_by_fingerprint_not_found(client) -> None:
-    """没有匹配的指纹记录 → fp_not_found,不发奖。"""
-    b = _login(client, "13800002043")
-    r = client.post(
-        "/api/v1/invite/bind",
-        json={
-            "channel": "fingerprint",
-            "fingerprint": {"screen": "0000x9999", "device_model": "no_such_model"},
-        },
-        headers=_auth(b),
-    )
-    assert r.status_code == 200, r.text
-    assert r.json()["status"] == "fp_not_found"
-    assert r.json()["coins_awarded"] == 0
-    assert _coin_balance(client, b) == 0
-
-
-def test_bind_by_fingerprint_outside_window(client) -> None:
-    """指纹记录超出 INVITE_FP_WINDOW_DAYS 窗口 → fp_not_found。
-
-    用独特设备型号隔离:测试环境所有请求 IP 都是 testclient、落地页默认无 UA(解析出的
-    型号="")，而指纹反查按 (IP, 型号) 匹配 → 会串到别的测试残留的、没过期的 model=""
-    指纹上(误判 success)。这里给落地页传一个独特 UA(解析出独特型号 OUTWIN9X),反查只可能
-    命中本测试自己的指纹,"过期就反查不到"才验得准。
-    """
-    a = _login(client, "13800002044")
-    a_code = _my_code(client, a)
-
-    # 落地页存指纹(独特 UA → 独特型号 OUTWIN9X),再手动把 created_at 改到窗口外
-    unique_screen = "2222x3333"
-    unique_ua = "Mozilla/5.0 (Linux; Android 13; OUTWIN9X Build/TQ) AppleWebKit/537.36"
-    r1 = client.post(
-        "/api/v1/invite/landing-track",
-        json={"ref": a_code, "screen": unique_screen},
-        headers={"user-agent": unique_ua},
-    )
-    assert r1.json()["status"] == "ok"
-
-    with SessionLocal() as db:
-        fp = db.execute(
-            select(InviteFingerprint).where(InviteFingerprint.screen == unique_screen)
-        ).scalar_one()
-        fp.created_at = datetime.now(timezone.utc) - timedelta(days=INVITE_FP_WINDOW_DAYS + 1)
-        db.commit()
-
-    b = _login(client, "13800002045")
-    r = client.post(
-        "/api/v1/invite/bind",
-        json={
-            "channel": "fingerprint",
-            "fingerprint": {"screen": unique_screen, "device_model": "OUTWIN9X"},
-        },
-        headers=_auth(b),
-    )
-    assert r.status_code == 200, r.text
-    assert r.json()["status"] == "fp_not_found"
-    assert _coin_balance(client, a) == 0
-    assert _coin_balance(client, b) == 0
-
-
-def test_bind_no_code_no_fingerprint(client) -> None:
-    """既没邀请码也没指纹 → invalid_code(无效请求)。"""
-    b = _login(client, "13800002046")
-    r = client.post(
-        "/api/v1/invite/bind",
-        json={"channel": "fingerprint"},  # 没 invite_code、没 fingerprint
-        headers=_auth(b),
-    )
-    assert r.status_code == 200, r.text
-    assert r.json()["status"] == "invalid_code"
-    assert _coin_balance(client, b) == 0
-
-
-# =====================================================================
-# 被邀请人列表 GET /invitees(邀请页小窗 + 完整列表页共用)
-# =====================================================================
-
-def test_invitees_basic(client) -> None:
-    """A 邀 B、C → 列表返 2 条、total=2、没设资料的名字=脱敏手机号、头像 null、金币对。"""
-    a = _login(client, "13800002050")
-    a_code = _my_code(client, a)
-    for phone in ("13800002051", "13800002052"):
-        u = _login(client, phone)
-        client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(u))
-
-    r = client.get("/api/v1/invite/invitees", headers=_auth(a))
-    assert r.status_code == 200, r.text
-    body = r.json()
-    assert body["total"] == 2
-    assert body["has_more"] is False
-    assert len(body["items"]) == 2
-    # 没设昵称头像 → 名字脱敏手机号、头像 null(不依赖顺序用 set)
-    names = {it["display_name"] for it in body["items"]}
-    assert names == {"138****2051", "138****2052"}
-    assert all(it["avatar_url"] is None for it in body["items"])
-    assert all(it["coins"] == INVITE_INVITER_COINS for it in body["items"])
-
-
-def test_invitees_order_desc(client) -> None:
-    """按邀请时间倒序:最近邀请的在最前(手动拉开时间,避开 SQLite 秒级精度)。"""
-    from app.models.invite import InviteRelation
-    a = _login(client, "13800002060")
-    a_code = _my_code(client, a)
-    b = _login(client, "13800002061")
-    c = _login(client, "13800002062")
-    client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(b))
-    client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(c))
-    with SessionLocal() as db:
-        ub = get_user_by_phone(db, "13800002061")
-        rel_b = db.execute(
-            select(InviteRelation).where(InviteRelation.invitee_user_id == ub.id)
-        ).scalar_one()
-        rel_b.created_at = datetime.now(timezone.utc) - timedelta(hours=2)
-        db.commit()
-    items = client.get("/api/v1/invite/invitees", headers=_auth(a)).json()["items"]
-    assert items[0]["display_name"] == "138****2062"  # C 刚邀,在前
-    assert items[1]["display_name"] == "138****2061"  # B 2 小时前,在后
-
-
-def test_invitees_nickname_priority(client) -> None:
-    """设了昵称的被邀请人 → 名字用昵称(优先于脱敏手机号)。"""
-    a = _login(client, "13800002070")
-    a_code = _my_code(client, a)
-    b = _login(client, "13800002071")
-    client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(b))
-    with SessionLocal() as db:
-        u = get_user_by_phone(db, "13800002071")
-        u.nickname = "小明"
-        db.commit()
-    items = client.get("/api/v1/invite/invitees", headers=_auth(a)).json()["items"]
-    assert items[0]["display_name"] == "小明"
-
-
-def test_invitees_pagination(client) -> None:
-    """分页:limit=1 → 1 条 + has_more=True;offset=1 → 第 2 条 + has_more=False。"""
-    a = _login(client, "13800002080")
-    a_code = _my_code(client, a)
-    for phone in ("13800002081", "13800002082"):
-        u = _login(client, phone)
-        client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(u))
-
-    p1 = client.get("/api/v1/invite/invitees?limit=1&offset=0", headers=_auth(a)).json()
-    assert len(p1["items"]) == 1 and p1["total"] == 2 and p1["has_more"] is True
-    p2 = client.get("/api/v1/invite/invitees?limit=1&offset=1", headers=_auth(a)).json()
-    assert len(p2["items"]) == 1 and p2["has_more"] is False
-
-
-def test_invitees_empty_and_auth(client) -> None:
-    """没邀请人 → 空列表;不带 token → 401。"""
-    a = _login(client, "13800002090")
-    body = client.get("/api/v1/invite/invitees", headers=_auth(a)).json()
-    assert body["total"] == 0 and body["items"] == [] and body["has_more"] is False
-    assert client.get("/api/v1/invite/invitees").status_code == 401
@@ -1,67 +0,0 @@
-"""新手引导"按 设备+账号 只触发一次"的后端闭环测试。
-
-覆盖:
- 全新 (账号, 设备) 登录 → onboarding_completed=False(照常走引导)
- 标记完成后,同 (账号, 设备) 再登录 → True(跳过引导,跨"重装"= 同 device_id 重新登录)
- 同账号换设备(device_id 不同)→ False(新设备重新引导)
- 标记幂等;缺 device_id 时按未完成处理
-"""
-from __future__ import annotations
-
-
-def _login(client, phone: str, device_id: str | None):
-    body = {"phone": phone, "code": "123456"}
-    if device_id is not None:
-        body["device_id"] = device_id
-    r = client.post("/api/v1/auth/sms/login", json=body)
-    assert r.status_code == 200, r.text
-    return r.json()
-
-
-def _mark_complete(client, access: str, device_id: str):
-    return client.post(
-        "/api/v1/user/onboarding/complete",
-        json={"device_id": device_id},
-        headers={"Authorization": f"Bearer {access}"},
-    )
-
-
-def test_onboarding_once_per_device_and_account(client) -> None:
-    phone = "13800138001"
-    dev_a = "android-id-aaaa"
-    dev_b = "android-id-bbbb"
-
-    # ① 全新账号+设备:未完成
-    data = _login(client, phone, dev_a)
-    assert data["onboarding_completed"] is False
-    access = data["access_token"]
-
-    # ② 走完引导 → 标记完成(幂等:再标一次也 200)
-    assert _mark_complete(client, access, dev_a).status_code == 200
-    assert _mark_complete(client, access, dev_a).json()["ok"] is True
-
-    # ③ 同账号 + 同设备(模拟卸载重装后重新登录)→ 已完成,跳过引导
-    assert _login(client, phone, dev_a)["onboarding_completed"] is True
-
-    # ④ 同账号 + 新设备 → 仍未完成,新设备重新走引导
-    assert _login(client, phone, dev_b)["onboarding_completed"] is False
-
-
-def test_onboarding_mark_on_one_device_does_not_leak_to_other(client) -> None:
-    """B 设备标记完成,不影响 A 设备(逐设备独立)。"""
-    phone = "13800138002"
-    data_a = _login(client, phone, "devA")
-    assert data_a["onboarding_completed"] is False
-
-    data_b = _login(client, phone, "devB")
-    assert _mark_complete(client, data_b["access_token"], "devB").status_code == 200
-
-    assert _login(client, phone, "devB")["onboarding_completed"] is True
-    assert _login(client, phone, "devA")["onboarding_completed"] is False
-
-
-def test_onboarding_missing_device_id_treated_as_incomplete(client) -> None:
-    """老客户端不传 device_id:按未完成处理,不报错、不误跳过。"""
-    phone = "13800138003"
-    data = _login(client, phone, device_id=None)
-    assert data["onboarding_completed"] is False