feat(invite): 被邀请人列表接口 + 指纹归因(任务3)

- GET /invitees: 分页 + 名字降级兜底(昵称→微信昵称→脱敏手机号)
- 指纹归因: 落地页采集 + (IP,设备型号)反查撞库 + 时间窗口闸
- test_invite: +5 个列表测试(脱敏/倒序/昵称优先/分页/空), 修指纹测试跨用例串味

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

.env.example

@@ -40,6 +40,9 @@ MT_CPS_APP_KEY=
 MT_CPS_APP_SECRET=
 # 默认渠道追踪标识(sid),用于区分不同 app 的 CPS 数据
 MT_CPS_DEFAULT_SID=sgbjia
+# 美团调用走的代理。⚠️ 本机/内网开发直连美团会 SSL EOF,必须填本地代理(如 http://127.0.0.1:7897);
+# 线上国内服务器留空(=直连)。留空且本机直连失败时 /feed、/coupons、/top-sales 会返回空。
+MT_CPS_PROXY=
 
 # ===== Pricebot 上游 (领券/比价业务透传目标) =====
 # 客户端调本服务的 /api/v1/coupon/step 等,我们透传到 pricebot-backend。

.gitignore

@@ -23,7 +23,13 @@ dist/
 *.db-journal
 *.db-shm
 *.db-wal
-data/
+# data/ 整体不入库(运行时数据/上传文件/大二进制)。例外:邀请落地页 dl.html——
+# 它既是生产落地页又是本地测试资产,纳入 git 便于同事一致测试
+# (见 docs/邀请功能-实现原理与本地测试.md)。其余(avatars/ / *.apk / app.db 等)仍忽略。
+data/*
+!data/media/
+data/media/*
+!data/media/dl.html
 
 secrets/*
 !secrets/.gitkeep

alembic/versions/0cf18d590b1d_merge_coupon_state_and_invite_heads.py

@@ -0,0 +1,26 @@
+"""merge coupon_state and invite heads
+
+Revision ID: 0cf18d590b1d
+Revises: coupon_state_tables, invite_code_and_relation
+Create Date: 2026-06-08 05:49:29.604571
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '0cf18d590b1d'
+down_revision: Union[str, Sequence[str], None] = ('coupon_state_tables', 'invite_code_and_relation')
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    pass
+
+
+def downgrade() -> None:
+    pass

alembic/versions/11a1d08c6f55_merge_meituan_coupon_与_ops_price_.py

@@ -0,0 +1,26 @@
+"""merge meituan_coupon 与 ops/price_observation 迁移头
+
+Revision ID: 11a1d08c6f55
+Revises: meituan_coupon_table, opsrename01
+Create Date: 2026-06-08 00:06:01.633796
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '11a1d08c6f55'
+down_revision: Union[str, Sequence[str], None] = ('meituan_coupon_table', 'opsrename01')
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    pass
+
+
+def downgrade() -> None:
+    pass

alembic/versions/coupon_state_tables.py

@@ -0,0 +1,77 @@
+"""coupon state tables (领券今日状态:弹窗频控 engagement + 领券记录 claim)
+
+Revision ID: coupon_state_tables
+Revises: 11a1d08c6f55
+Create Date: 2026-06-08 00:00:00.000000
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'coupon_state_tables'
+down_revision: Union[str, Sequence[str], None] = '11a1d08c6f55'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+# PG 上为 JSONB,其它(SQLite dev)为 JSON——与模型层 with_variant 对齐
+_JSON = sa.JSON().with_variant(postgresql.JSONB(), 'postgresql')
+
+
+def upgrade() -> None:
+    # 领券记录(资产层,当前不参与去重判断)
+    op.create_table(
+        'coupon_claim_record',
+        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('coupon_id', sa.String(length=64), nullable=False),
+        sa.Column('claim_date', sa.Date(), nullable=False),
+        sa.Column('status', sa.String(length=24), nullable=False),
+        sa.Column('vendor', sa.String(length=48), nullable=True),
+        sa.Column('coupon_name', sa.String(length=128), nullable=True),
+        sa.Column('claimed_count', sa.Integer(), nullable=True),
+        sa.Column('trace_id', sa.String(length=64), nullable=True),
+        sa.Column('reason', sa.String(length=255), nullable=True),
+        sa.Column('extra', _JSON, 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', 'coupon_id', 'claim_date', name='uq_coupon_claim_device_coupon_date'),
+    )
+    with op.batch_alter_table('coupon_claim_record', schema=None) as batch_op:
+        batch_op.create_index('ix_coupon_claim_device_date', ['device_id', 'claim_date'], unique=False)
+        batch_op.create_index(batch_op.f('ix_coupon_claim_record_user_id'), ['user_id'], unique=False)
+        batch_op.create_index(batch_op.f('ix_coupon_claim_record_trace_id'), ['trace_id'], unique=False)
+
+    # 弹窗频控(今天 engage 过就不再弹)
+    op.create_table(
+        'coupon_prompt_engagement',
+        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('engage_date', sa.Date(), nullable=False),
+        sa.Column('engage_type', sa.String(length=16), nullable=False),
+        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', 'engage_date', name='uq_coupon_engage_device_date'),
+    )
+    with op.batch_alter_table('coupon_prompt_engagement', schema=None) as batch_op:
+        batch_op.create_index(batch_op.f('ix_coupon_prompt_engagement_user_id'), ['user_id'], unique=False)
+
+
+def downgrade() -> None:
+    with op.batch_alter_table('coupon_prompt_engagement', schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f('ix_coupon_prompt_engagement_user_id'))
+    op.drop_table('coupon_prompt_engagement')
+
+    with op.batch_alter_table('coupon_claim_record', schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f('ix_coupon_claim_record_trace_id'))
+        batch_op.drop_index(batch_op.f('ix_coupon_claim_record_user_id'))
+        batch_op.drop_index('ix_coupon_claim_device_date')
+    op.drop_table('coupon_claim_record')

alembic/versions/invite_code_and_relation.py

@@ -0,0 +1,54 @@
+"""user.invite_code + invite_relation table
+
+Revision ID: invite_code_and_relation
+Revises: 11a1d08c6f55
+Create Date: 2026-06-08 00:00:00.000000
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'invite_code_and_relation'
+down_revision: Union[str, Sequence[str], None] = '11a1d08c6f55'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    # user 加邀请码列(唯一索引;nullable 允许多个 NULL=未生成的用户)
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.add_column(sa.Column('invite_code', sa.String(length=16), nullable=True))
+        batch_op.create_index('ix_user_invite_code', ['invite_code'], unique=True)
+
+    # 邀请关系表
+    op.create_table(
+        'invite_relation',
+        sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column('inviter_user_id', sa.Integer(), nullable=False),
+        sa.Column('invitee_user_id', sa.Integer(), nullable=False),
+        sa.Column('channel', sa.String(length=16), nullable=False, server_default='clipboard'),
+        sa.Column('status', sa.String(length=16), nullable=False, server_default='effective'),
+        sa.Column('inviter_coin', sa.Integer(), nullable=False, server_default='0'),
+        sa.Column('invitee_coin', sa.Integer(), nullable=False, server_default='0'),
+        sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.func.now(), nullable=False),
+        sa.ForeignKeyConstraint(['inviter_user_id'], ['user.id']),
+        sa.ForeignKeyConstraint(['invitee_user_id'], ['user.id']),
+        sa.PrimaryKeyConstraint('id'),
+    )
+    op.create_index('ix_invite_relation_inviter_user_id', 'invite_relation', ['inviter_user_id'])
+    op.create_index('ix_invite_relation_invitee_user_id', 'invite_relation', ['invitee_user_id'], unique=True)
+    op.create_index('ix_invite_relation_created_at', 'invite_relation', ['created_at'])
+
+
+def downgrade() -> None:
+    op.drop_index('ix_invite_relation_created_at', table_name='invite_relation')
+    op.drop_index('ix_invite_relation_invitee_user_id', table_name='invite_relation')
+    op.drop_index('ix_invite_relation_inviter_user_id', table_name='invite_relation')
+    op.drop_table('invite_relation')
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.drop_index('ix_user_invite_code')
+        batch_op.drop_column('invite_code')

alembic/versions/invite_fingerprint_table.py

@@ -0,0 +1,50 @@
+"""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')

alembic/versions/meituan_coupon_table.py

@@ -0,0 +1,62 @@
+"""meituan_coupon table(美团 CPS 券本地缓存,供销量/佣金排序从库里捞、本地排序)
+
+Revision ID: meituan_coupon_table
+Revises: withdraw_review_ad_watch
+Create Date: 2026-06-06 12:00:00.000000
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'meituan_coupon_table'
+down_revision: Union[str, Sequence[str], None] = 'withdraw_review_ad_watch'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    op.create_table(
+        'meituan_coupon',
+        sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column('source', sa.String(length=16), nullable=False),
+        sa.Column('platform', sa.Integer(), nullable=False),
+        sa.Column('biz_line', sa.Integer(), nullable=True),
+        sa.Column('city_id', sa.String(length=32), nullable=False),
+        sa.Column('product_view_sign', sa.String(length=128), nullable=False),
+        sa.Column('sku_view_id', sa.String(length=128), nullable=True),
+        sa.Column('name', sa.String(length=256), nullable=True),
+        sa.Column('brand_name', sa.String(length=128), nullable=True),
+        sa.Column('sell_price_cents', sa.Integer(), nullable=True),
+        sa.Column('original_price_cents', sa.Integer(), nullable=True),
+        sa.Column('head_url', sa.String(length=512), nullable=True),
+        sa.Column('sale_volume', sa.String(length=32), nullable=True),
+        sa.Column('sale_volume_num', sa.Integer(), nullable=True),
+        sa.Column('commission_percent', sa.Float(), nullable=True),
+        sa.Column('commission_amount_cents', sa.Integer(), nullable=True),
+        sa.Column('poi_name', sa.String(length=128), nullable=True),
+        sa.Column('available_poi_num', sa.Integer(), nullable=True),
+        sa.Column('delivery_distance_m', sa.Float(), nullable=True),
+        sa.Column('dedup_key', sa.String(length=64), nullable=False),
+        sa.Column('raw', sa.JSON().with_variant(postgresql.JSONB(), 'postgresql'), nullable=False),
+        sa.Column('first_seen', sa.DateTime(timezone=True), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False),
+        sa.Column('last_seen', 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('source', 'product_view_sign', name='uq_meituan_coupon_source_sign'),
+    )
+    op.create_index('ix_meituan_coupon_source', 'meituan_coupon', ['source'])
+    op.create_index('ix_meituan_coupon_city_id', 'meituan_coupon', ['city_id'])
+    op.create_index('ix_meituan_coupon_brand_name', 'meituan_coupon', ['brand_name'])
+    op.create_index('ix_meituan_coupon_sale_volume_num', 'meituan_coupon', ['sale_volume_num'])
+    op.create_index('ix_meituan_coupon_commission_percent', 'meituan_coupon', ['commission_percent'])
+    op.create_index('ix_meituan_coupon_dedup_key', 'meituan_coupon', ['dedup_key'])
+    op.create_index('ix_meituan_coupon_last_seen', 'meituan_coupon', ['last_seen'])
+
+
+def downgrade() -> None:
+    op.drop_table('meituan_coupon')

app/api/v1/coupon.py

@@ -16,15 +16,66 @@ from typing import Any
 
 import httpx
 from fastapi import APIRouter, HTTPException, Request, status
+from fastapi.concurrency import run_in_threadpool
 
+from app.api.deps import DbSession
 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 CouponPromptDismissIn, CouponPromptShouldShowOut
 
 logger = logging.getLogger("shagua.coupon")
 
 router = APIRouter(prefix="/api/v1/coupon", tags=["coupon"])
 
 
+def _to_int(v: object) -> int | None:
+    """user_id 协议是字符串(登录态才带),转 int 存库;缺失/非法 → None。"""
+    if v is None:
+        return None
+    try:
+        return int(v)  # type: ignore[arg-type]
+    except (TypeError, ValueError):
+        return None
+
+
+def _extract_coupon_results(resp_json: dict) -> list[dict]:
+    """从 pricebot 响应抽本帧券结果,并**按 coupon_id 去重**。
+
+    ⚠️ done/单券帧同时带 last_coupon_result(最后一张)+ action.params.coupon_results
+    (全量含最后一张)→ 最后一张出现两次。必须去重:同批里同 coupon_id 两次,
+    record_claims 在 autoflush=False 下两次 select 都查不到刚 add 的行 → 重复 add →
+    commit 撞唯一约束 IntegrityError 回滚整批(done/单券记录全丢)。
+    coupon_results(全量权威)覆盖 last_coupon_result。"""
+    by_id: dict[str, dict] = {}
+    last = resp_json.get("last_coupon_result")
+    if isinstance(last, dict) and last.get("coupon_id"):
+        by_id[last["coupon_id"]] = last
+    params = (resp_json.get("action") or {}).get("params") or {}
+    cr = params.get("coupon_results")
+    if isinstance(cr, list):
+        for x in cr:
+            if isinstance(x, dict) and x.get("coupon_id"):
+                by_id[x["coupon_id"]] = x
+    return list(by_id.values())
+
+
+def _mark_engagement_blocking(
+    device_id: str, user_id: int | None, engage_type: str
+) -> None:
+    """独立 session 写 engagement(async 端点经 run_in_threadpool 调,不阻塞事件循环)。"""
+    with SessionLocal() as db:
+        coupon_repo.mark_engagement(db, device_id, user_id, engage_type)
+
+
+def _record_claims_blocking(
+    device_id: str, user_id: int | None, trace_id: str | None, results: list[dict]
+) -> None:
+    with SessionLocal() as db:
+        coupon_repo.record_claims(db, device_id, user_id, trace_id, results)
+
+
 @router.post("/step", summary="领券任务步进 (透传到 pricebot)")
 async def coupon_step(
     request: Request,
@@ -45,6 +96,21 @@ async def coupon_step(
     if not isinstance(meta, dict):
         meta = {}
 
+    device_id = meta.get("device_id")
+    user_id = _to_int(meta.get("user_id"))  # 登录态才带;判断不靠它,资产留痕用
+    trace_id = meta.get("trace_id")
+
+    # 领券任务首帧(step=0)= 用户已发起领券 → 记一条今日 engagement(claim_started),
+    # 今天这台设备不再弹引导窗(对齐前台"点一键领取即 markEngaged")。写库失败绝不能
+    # 连累领券主流程,整段吞掉。
+    if device_id and meta.get("step") == 0:
+        try:
+            await run_in_threadpool(
+                _mark_engagement_blocking, device_id, user_id, "claim_started"
+            )
+        except Exception as e:  # noqa: BLE001
+            logger.warning("coupon engagement write failed: %s", e)
+
     # 按 trace_id 一致性 hash 选 pricebot 实例(同一领券任务的所有帧落同一进程)
     base = pick_pricebot(meta.get("trace_id"))
     url = f"{base.rstrip('/')}/api/coupon/step"
@@ -80,4 +146,44 @@ async def coupon_step(
             detail=f"pricebot upstream returned {resp.status_code}",
         )
 
-    return resp.json()
+    resp_json = resp.json()
+
+    # 领券结果沉淀(资产):中间帧 last_coupon_result + done 帧 coupon_results 幂等写库。
+    # 当前只记录、不参与"要不要领"判断(MVP 先不去重)。写库失败不影响返回。
+    if device_id:
+        results = _extract_coupon_results(resp_json)
+        if results:
+            try:
+                await run_in_threadpool(
+                    _record_claims_blocking, device_id, user_id, trace_id, results
+                )
+            except Exception as e:  # noqa: BLE001
+                logger.warning("coupon claim write failed: %s", e)
+
+    return resp_json
+
+
+@router.post("/prompt/dismiss", summary="用户拒绝/关闭领券引导窗(记今日已 engage)")
+def coupon_prompt_dismiss(payload: CouponPromptDismissIn, db: DbSession) -> dict[str, bool]:
+    """客户端点关闭引导窗时调用 → 记一条今日 engagement(dismissed),今天不再弹。
+
+    server 在透传链路里看不到"用户拒绝"(拒绝不发起领券),故必须客户端通知。
+    MVP 不鉴权,按 device_id 记。
+    """
+    coupon_repo.mark_engagement(db, payload.device_id, payload.user_id, "dismissed")
+    return {"ok": True}
+
+
+@router.get(
+    "/prompt/should-show",
+    response_model=CouponPromptShouldShowOut,
+    summary="切到外卖 App 时是否还应弹领券引导窗",
+)
+def coupon_prompt_should_show(
+    device_id: str, db: DbSession
+) -> CouponPromptShouldShowOut:
+    """今天这台设备已 engage(领或拒)过 → should_show=false。客户端据此决定弹不弹
+    (前台 SP 缓存做快速路径,这里是权威)。"""
+    return CouponPromptShouldShowOut(
+        should_show=not coupon_repo.has_engaged_today(db, device_id)
+    )

app/api/v1/invite.py

@@ -0,0 +1,217 @@
+"""好友邀请 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 访问时上报指纹(剪贴板兜底的服务端一端,无需鉴权)
+
+绑定的真正逻辑(邀请码生成/反查、幂等、自邀屏蔽、发金币、指纹反查)在
+repositories/invite.py。
+"""
+from __future__ import annotations
+
+import logging
+import re
+
+from fastapi import APIRouter, Request
+
+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,
+)
+
+logger = logging.getLogger("shagua.invite")
+
+router = APIRouter(prefix="/api/v1/invite", tags=["invite"])
+
+_BIND_MESSAGES = {
+    "success": "邀请绑定成功,金币已到账",
+    "already_bound": "你已绑定过邀请人",
+    "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)
+    invited, coins = invite_repo.get_stats(db, user.id)
+    sep = "&" if "?" in settings.INVITE_LANDING_URL else "?"
+    share_url = f"{settings.INVITE_LANDING_URL}{sep}ref={code}"
+    return InviteInfoOut(
+        invite_code=code,
+        share_url=share_url,
+        invited_count=invited,
+        coins_earned=coins,
+    )
+
+
+@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,
+    )
+    logger.info(
+        "invite landing-track inviter=%d ip=%s screen=%s model=%s",
+        inviter.id, ip, req.screen, device_model,
+    )
+    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"],
+    )

app/api/v1/meituan.py

@@ -7,10 +7,14 @@ from __future__ import annotations
 import logging
 from concurrent.futures import ThreadPoolExecutor, as_completed
 
-from fastapi import APIRouter, HTTPException
+from fastapi import APIRouter, Depends, HTTPException
+from sqlalchemy import select
+from sqlalchemy.orm import Session
 
 from app.core.config import settings
+from app.db.session import get_db
 from app.integrations.meituan import MeituanCpsError, get_referral_link, query_coupon
+from app.models.meituan_coupon import MeituanCoupon
 from app.schemas.meituan import (
     CouponCard,
     CouponListRequest,
@@ -19,6 +23,7 @@ from app.schemas.meituan import (
     FeedResponse,
     ReferralLinkRequest,
     ReferralLinkResponse,
+    TopSalesRequest,
 )
 
 logger = logging.getLogger("shagua.meituan")
@@ -79,13 +84,21 @@ def _interleave(waimai: list[dict], daodian: list[dict]) -> list[CouponCard]:
     return items
 
 
-@router.post("/feed", response_model=FeedResponse, summary="混合feed(外卖+到店交叉, 无限流)")
+def _commission_pct(card: CouponCard) -> float:
+    """'1.4%' → 1.4;解析失败按 0(会被智能推荐过滤掉)。"""
+    try:
+        return float(card.commission_rate.rstrip("%"))
+    except (ValueError, AttributeError):
+        return 0.0
+
+
+@router.post("/feed", response_model=FeedResponse, summary="混合feed(外卖+到店交叉);tab=rec智能推荐/distance距离最近")
 def feed(req: FeedRequest) -> FeedResponse:
     if not settings.mt_cps_configured:
         return FeedResponse(items=[], has_next=False, page=req.page)
-    page_idx = req.page - 1
     lon, lat = req.longitude, req.latitude
-    logger.info("[feed] page=%s lon=%.6f lat=%.6f", req.page, lon, lat)
+    tab = (req.tab or "").strip()
+    logger.info("[feed] tab=%s page=%s lon=%.6f lat=%.6f", tab or "(default)", req.page, lon, lat)
 
     def _fetch_topic(platform: int, biz_line: int | None, topic: int) -> list[dict]:
         try:
@@ -97,6 +110,28 @@ def feed(req: FeedRequest) -> FeedResponse:
         except MeituanCpsError:
             return []
 
+    # 距离最近:拉齐全部榜单轮次,合并去重,后端在【完整池子】上全局按距离由近及远排,一次性返回。
+    # (距离排序必须在完整池上做、不能逐页排——这正是之前放前端不合理的根因。)
+    if tab == "distance":
+        with ThreadPoolExecutor(max_workers=len(_TOPIC_ROUNDS) * 2) as pool:
+            futs = []
+            for wm_topic, dd_topic in _TOPIC_ROUNDS:
+                futs.append(pool.submit(_fetch_topic, 1, None, wm_topic))
+                futs.append(pool.submit(_fetch_topic, 2, 1, dd_topic))
+            raws = [f.result() for f in futs]
+        seen: set[str] = set()
+        cards: list[CouponCard] = []
+        for raw_list in raws:
+            for it in raw_list:
+                card = CouponCard.from_raw(it)
+                if card.product_view_sign and card.product_view_sign not in seen:
+                    seen.add(card.product_view_sign)
+                    cards.append(card)
+        cards.sort(key=lambda c: c.distance_meters if c.distance_meters is not None else float("inf"))
+        return FeedResponse(items=cards, has_next=False, page=1)
+
+    # 智能推荐(rec,默认):沿用逐轮分页的混合 feed,后端过滤掉佣金率 < 3%。
+    page_idx = req.page - 1
     if page_idx >= len(_TOPIC_ROUNDS):
         return FeedResponse(items=[], has_next=False, page=req.page)
 
@@ -107,6 +142,8 @@ def feed(req: FeedRequest) -> FeedResponse:
         waimai, daodian = f_wm.result(), f_dd.result()
 
     items = _interleave(waimai, daodian)
+    if tab == "rec":
+        items = [c for c in items if _commission_pct(c) >= 3.0]
     has_next = page_idx + 1 < len(_TOPIC_ROUNDS)
     return FeedResponse(items=items, has_next=has_next, page=req.page)
 
@@ -130,3 +167,37 @@ def referral_link(req: ReferralLinkRequest) -> ReferralLinkResponse:
     link_map = raw.get("referralLinkMap") or {}
     link = raw.get("data") or link_map.get("1") or link_map.get("3") or next(iter(link_map.values()), "")
     return ReferralLinkResponse(link=link, link_map=link_map)
+
+
+@router.post("/top-sales", response_model=CouponListResponse,
+             summary="销量最高(从离线库 meituan_coupon 按销量降序 + 跨源去重,不实时打美团)")
+def top_sales(req: TopSalesRequest, db: Session = Depends(get_db)) -> CouponListResponse:
+    # 只取有销量档的(美团很多券没销量,排不了);按销量降序、同销量再按佣金降序
+    stmt = select(MeituanCoupon).where(MeituanCoupon.sale_volume_num.isnot(None))
+    if req.platform is not None:
+        stmt = stmt.where(MeituanCoupon.platform == req.platform)
+    stmt = stmt.order_by(
+        MeituanCoupon.sale_volume_num.desc(),
+        MeituanCoupon.commission_percent.desc(),
+    )
+    rows = db.execute(stmt).scalars().all()
+
+    # 跨源去重(dedup_key = 品牌|名|价):按销量降序遍历,每个 dedup_key 只留第一条(=销量最高那条)。
+    # 用 raw(整条原始返回)重建 CouponCard,字段与实时接口完全一致,前端无需改渲染。
+    seen: set[str] = set()
+    cards: list[CouponCard] = []
+    for row in rows:
+        if row.dedup_key in seen:
+            continue
+        seen.add(row.dedup_key)
+        try:
+            card = CouponCard.from_raw(row.raw or {})
+        except Exception:  # noqa: BLE001
+            continue
+        if card.product_view_sign:
+            cards.append(card)
+
+    start = (req.page - 1) * req.page_size
+    page_items = cards[start:start + req.page_size]
+    has_next = start + req.page_size < len(cards)
+    return CouponListResponse(items=page_items, has_next=has_next, search_id=None)

app/core/config.py

@@ -81,6 +81,9 @@ class Settings(BaseSettings):
     MT_CPS_HOST: str = "https://media.meituan.com"
     MT_CPS_TIMEOUT_SEC: int = 15
     MT_CPS_DEFAULT_SID: str = "sgbjia"
+    # 美团调用走的代理。本机开发直连美团会 SSL EOF,需填 http://127.0.0.1:7897;
+    # 线上国内服务器留空(=直连)。见 .env.example 与 integrations/meituan.py。
+    MT_CPS_PROXY: str = ""
 
     @property
     def mt_cps_configured(self) -> bool:
@@ -170,6 +173,11 @@ class Settings(BaseSettings):
     MEDIA_URL_PREFIX: str = "/media"
     AVATAR_MAX_BYTES: int = 5 * 1024 * 1024  # 头像最大 5MB
 
+    # ===== 邀请好友 =====
+    # 分享落地页(二维码 / 分享链接指向这里;扫码 → 落地页 → 引导浏览器下载 APK)。
+    # MVP 落地页就放 app-server 的 /media 静态目录下(dl.html)。
+    INVITE_LANDING_URL: str = "https://app-api.shaguabijia.com/media/dl.html"
+
     # ===== CORS =====
     CORS_ALLOW_ORIGINS: str = ""
 

app/core/rewards.py

@@ -77,6 +77,20 @@ def record_milestone_reward(milestone: int) -> int:
     return RECORD_MILESTONES[milestone - 1]
 
 
+# ===== 邀请好友(注册即生效,邀请人 + 被邀请人各发金币)=====
+# 10000 金币 = 1 元,双方各得 1 元。MVP 先用固定常量(不走 app_config)。
+INVITE_INVITER_COINS: int = 10000
+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 单位按"元/千次展示"处理,单次收入 = eCPM / 1000 元。
 AD_ECPM_FACTOR_TABLE: tuple[tuple[float, int, int | None], ...] = (

app/integrations/meituan.py

@@ -62,8 +62,12 @@ def _call(path: str, body_obj: dict[str, Any]) -> dict[str, Any]:
     }
 
     url = f"{settings.MT_CPS_HOST}{path}"
+    # 美团调用走 MT_CPS_PROXY(本机开发直连会 SSL EOF,必须走代理;线上留空=直连)。
+    # trust_env=False:不读进程环境的 HTTP_PROXY,只认配置,避免被错误/失效代理误导。
+    proxy = settings.MT_CPS_PROXY or None
     try:
-        resp = httpx.post(url, content=body, headers=headers, timeout=settings.MT_CPS_TIMEOUT_SEC)
+        with httpx.Client(proxy=proxy, trust_env=False, timeout=settings.MT_CPS_TIMEOUT_SEC) as client:
+            resp = client.post(url, content=body, headers=headers)
     except httpx.HTTPError as e:
         logger.exception("[MT] http error calling %s", url)
         raise MeituanCpsError(f"meituan http error: {e}") from e

app/main.py

@@ -22,6 +22,7 @@ from app.api.v1.compare_record import router as compare_record_router
 from app.api.v1.coupon import router as coupon_router
 from app.api.internal.price import router as internal_price_router
 from app.api.v1.feedback import router as feedback_router
+from app.api.v1.invite import router as invite_router
 from app.api.v1.meituan import router as meituan_router
 from app.api.v1.order import router as order_router
 from app.api.v1.platform import router as platform_router
@@ -79,6 +80,7 @@ def health() -> dict[str, str]:
 app.include_router(auth_router)
 app.include_router(user_router)
 app.include_router(feedback_router)
+app.include_router(invite_router)
 app.include_router(coupon_router)
 app.include_router(compare_router)
 app.include_router(compare_record_router)

app/models/__init__.py

@@ -7,7 +7,14 @@ from app.models.admin import AdminAuditLog, AdminUser  # noqa: F401
 from app.models.app_config import AppConfig  # noqa: F401
 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,
+    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.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

app/models/coupon_state.py

@@ -0,0 +1,130 @@
+"""领券今日状态(弹窗频控 + 领券记录)两张表。
+
+- `coupon_prompt_engagement`:按 (device, 自然日) 记"今天是否对领券引导窗表达过意向"
+  ——点「一键领取」(claim_started) 或 点拒绝/关闭 (dismissed) 都算。切到外卖 App 时
+  据此决定弹不弹:今天 engage 过就不再弹。判断维度是 **device_id**——券发到的是设备上
+  登录的那个外卖账号,device 比 user 更贴近"哪个登录环境",且 device_id 全链路现成、
+  不依赖领券鉴权。
+
+- `coupon_claim_record`:按 (device, 券, 自然日) 记每张券的领取结果,纯沉淀(资产/画像/
+  排查)。当前**不参与**"要不要领"的判断(MVP 先不去重:今天 engage 过就不弹,A 路径
+  主动领则全跑)。留作以后做按券去重 / CPS 归因 / 用户画像的数据源。
+
+口径:
+- 日期 = Asia/Shanghai 的自然日(claim_date / engage_date)。
+- user_id 领券登录态有就记(资产),可空、不进唯一键、不阻塞判断。
+- device_id 客户端生成存 SP,卸载重装会变 → 重装当新设备重新弹一次(产品预期)。
+"""
+from __future__ import annotations
+
+from datetime import date, datetime
+
+from sqlalchemy import (
+    JSON,
+    Date,
+    DateTime,
+    Index,
+    Integer,
+    String,
+    UniqueConstraint,
+    func,
+)
+from sqlalchemy.dialects.postgresql import JSONB
+from sqlalchemy.orm import Mapped, mapped_column
+
+from app.db.base import Base
+
+# PG 上用 JSONB,SQLite(本地/测试)退化为通用 JSON(同 price_observation / comparison)。
+_JSON = JSON().with_variant(JSONB(), "postgresql")
+
+
+class CouponClaimRecord(Base):
+    """单张券一天一条领取记录(资产层,当前不做去重判断)。"""
+
+    __tablename__ = "coupon_claim_record"
+    __table_args__ = (
+        # 同设备、同券、同一天只一条:领券每帧 last_coupon_result + done 帧 coupon_results
+        # 会重复上报同一张券,靠它幂等 upsert。
+        UniqueConstraint(
+            "device_id", "coupon_id", "claim_date",
+            name="uq_coupon_claim_device_coupon_date",
+        ),
+        # 去重/统计查询按 (device, 日) 取一天所有券。
+        Index("ix_coupon_claim_device_date", "device_id", "claim_date"),
+    )
+
+    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
+
+    # 判断/聚合维度。client getOrCreateDeviceId 生成,重装会变。
+    device_id: Mapped[str] = mapped_column(String(64), nullable=False)
+    # 登录态有就记(资产/画像),可空、不进唯一键。
+    user_id: Mapped[int | None] = mapped_column(Integer, index=True, nullable=True)
+
+    coupon_id: Mapped[str] = mapped_column(String(64), nullable=False)
+    # Asia/Shanghai 自然日。每日可领的券(签到/天天红包)靠这天然每天一条。
+    claim_date: Mapped[date] = mapped_column(Date, nullable=False)
+
+    # success / already_claimed / failed / skipped(原样取 pricebot coupon 结果)
+    status: Mapped[str] = mapped_column(String(24), nullable=False)
+    vendor: Mapped[str | None] = mapped_column(String(48), nullable=True)
+    coupon_name: Mapped[str | None] = mapped_column(String(128), nullable=True)
+    # 这张领到几张(pricebot display_count;给不出时为 None)
+    claimed_count: Mapped[int | None] = mapped_column(Integer, nullable=True)
+    # 哪次任务领的,回指 pricebot work_logs / 排查
+    trace_id: Mapped[str | None] = mapped_column(String(64), index=True, nullable=True)
+    # failed / skipped 原因
+    reason: Mapped[str | None] = mapped_column(String(255), nullable=True)
+    # 杂项兜底:券的结构化信息(面额/入口/关键节点摘要等),免得加字段就迁移。
+    # ⚠️ 别塞原始无障碍树(几十 KB → 行膨胀);原始大树看 trace_id 指过去的 work_logs。
+    extra: Mapped[dict | None] = mapped_column(_JSON, 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"<CouponClaimRecord device={self.device_id} coupon={self.coupon_id} "
+            f"date={self.claim_date} status={self.status}>"
+        )
+
+
+class CouponPromptEngagement(Base):
+    """按 (device, 自然日) 记"今天是否对领券引导窗表达过意向"——弹窗频控源。"""
+
+    __tablename__ = "coupon_prompt_engagement"
+    __table_args__ = (
+        # 一台设备一天一条:今天 engage 过(领或拒)就不再弹。
+        UniqueConstraint(
+            "device_id", "engage_date",
+            name="uq_coupon_engage_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 自然日。
+    engage_date: Mapped[date] = mapped_column(Date, nullable=False)
+    # claim_started(点了一键领取)/ dismissed(点了拒绝/关闭)。仅记录区分,
+    # 判断只看"今天有没有这条",type 不影响弹不弹。
+    engage_type: Mapped[str] = mapped_column(String(16), nullable=False)
+
+    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"<CouponPromptEngagement device={self.device_id} "
+            f"date={self.engage_date} type={self.engage_type}>"
+        )

app/models/invite.py

@@ -0,0 +1,46 @@
+"""好友邀请关系表(注册即生效)。
+
+一行 = 一次成功的邀请绑定。`invitee_user_id` 唯一 = 一个被邀请人只能被归因一次
+(天然幂等键,防重复发奖,仿 ad_reward.trans_id 思路)。`channel` 记归因来源
+(clipboard 自动 / manual 手动填),便于后续分析"剪贴板自动捕获率"。
+
+邀请码本身是 `user.invite_code`(一人一稳定码,懒生成),不在这张表里。
+"""
+from __future__ import annotations
+
+from datetime import datetime
+
+from sqlalchemy import DateTime, ForeignKey, Integer, String, func
+from sqlalchemy.orm import Mapped, mapped_column
+
+from app.db.base import Base
+
+
+class InviteRelation(Base):
+    __tablename__ = "invite_relation"
+
+    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
+    )
+    # 被邀请人唯一:一个人只能被邀一次(幂等键,防重复发奖)
+    invitee_user_id: Mapped[int] = mapped_column(
+        Integer, ForeignKey("user.id"), unique=True, index=True, nullable=False
+    )
+    # 归因来源:clipboard(剪贴板自动) / manual(手动填码)
+    channel: Mapped[str] = mapped_column(String(16), nullable=False, default="clipboard")
+    # 状态:effective(注册即生效)。预留:以后改"完成首单才生效"时用 pending/effective
+    status: Mapped[str] = mapped_column(String(16), nullable=False, default="effective")
+    # 本次给邀请人 / 被邀请人各发的金币(记账留痕,便于对账)
+    inviter_coin: Mapped[int] = mapped_column(Integer, nullable=False, default=0)
+    invitee_coin: Mapped[int] = mapped_column(Integer, nullable=False, default=0)
+
+    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"<InviteRelation inviter={self.inviter_user_id} "
+            f"invitee={self.invitee_user_id} {self.status}>"
+        )

app/models/invite_fingerprint.py

@@ -0,0 +1,46 @@
+"""邀请指纹归因表(剪贴板归因兜底)。
+
+数据流(对应 [[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}>"
+        )

app/models/meituan_coupon.py

@@ -0,0 +1,93 @@
+"""美团 CPS 券本地缓存表(meituan_coupon)。
+
+把美团联盟 CPS 的券定时抓进本地库,供「销量 / 佣金排序」等查询**直接从库里捞、本地排序**,
+不再每次实时打美团接口——美团搜索/供给对销量排序支持差(实测乱序)、且有 402 限流和召回上限。
+
+数据来源(source,北京试点):
+  - search_waimai : 到家/外卖, 搜索关键词「外卖」, 翻到尽头
+  - search_meishi : 到家/外卖, 搜索关键词「美食」, 翻到尽头
+  - store_supply  : 到店, 多业务线供给(到餐+到综+酒店+门票), 翻到尽头
+
+每 5min(本地测试)/ 1h(线上)全量抓一次,按 (source, product_view_sign) upsert 存最新态,
+last_seen 每轮刷新(可据此清理长期未再出现的陈旧券)。
+
+去重说明:`product_view_sign` / `sku_view_id` 都是「按召回渠道生成」的,跨渠道(搜索 vs 供给)
+会变,**不能当商品全局唯一 id**。因此:
+  - 存储:按 (source, product_view_sign) upsert(同源短周期内 sign 稳定)。
+  - 查询:用 `dedup_key = md5(brand|name|price)` 跨源去重,再按 `sale_volume_num` / `commission_percent` 排序。
+
+价格统一存「分」(cents),与 price_report / comparison_record 一致。`raw` 保留整条原始返回
+(字段越详细越好,避免后续漏字段还要重抓)。
+"""
+from __future__ import annotations
+
+from datetime import datetime
+
+from sqlalchemy import JSON, DateTime, Float, Integer, String, UniqueConstraint, func
+from sqlalchemy.dialects.postgresql import JSONB
+from sqlalchemy.orm import Mapped, mapped_column
+
+from app.db.base import Base
+
+
+class MeituanCoupon(Base):
+    __tablename__ = "meituan_coupon"
+    __table_args__ = (
+        UniqueConstraint("source", "product_view_sign", name="uq_meituan_coupon_source_sign"),
+    )
+
+    id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
+
+    # ===== 来源 / 分类 =====
+    # source: search_waimai | search_meishi | store_supply
+    source: Mapped[str] = mapped_column(String(16), index=True, nullable=False)
+    platform: Mapped[int] = mapped_column(Integer, nullable=False)              # 1 到家/外卖, 2 到店
+    biz_line: Mapped[int | None] = mapped_column(Integer, nullable=True)        # 到店: 1到餐 2到综 3酒店 4门票
+    city_id: Mapped[str] = mapped_column(String(32), index=True, nullable=False)
+
+    # ===== 召回 id(按渠道生成,跨渠道会变;product_view_sign 用于换推广链) =====
+    product_view_sign: Mapped[str] = mapped_column(String(128), nullable=False)
+    sku_view_id: Mapped[str | None] = mapped_column(String(128), nullable=True)
+
+    # ===== 商品本体 =====
+    name: Mapped[str | None] = mapped_column(String(256), nullable=True)
+    brand_name: Mapped[str | None] = mapped_column(String(128), index=True, nullable=True)
+    sell_price_cents: Mapped[int | None] = mapped_column(Integer, nullable=True)
+    original_price_cents: Mapped[int | None] = mapped_column(Integer, nullable=True)
+    head_url: Mapped[str | None] = mapped_column(String(512), nullable=True)
+
+    # ===== 销量(美团只给粗档位:热销1w+;num=排序用的下界数值,如 1w+ → 10000) =====
+    sale_volume: Mapped[str | None] = mapped_column(String(32), nullable=True)
+    sale_volume_num: Mapped[int | None] = mapped_column(Integer, index=True, nullable=True)
+
+    # ===== 佣金(percent 如 1.4 表示 1.4%;amount 为分) =====
+    commission_percent: Mapped[float | None] = mapped_column(Float, index=True, nullable=True)
+    commission_amount_cents: Mapped[int | None] = mapped_column(Integer, nullable=True)
+
+    # ===== 门店 / 距离 =====
+    poi_name: Mapped[str | None] = mapped_column(String(128), nullable=True)
+    available_poi_num: Mapped[int | None] = mapped_column(Integer, nullable=True)
+    delivery_distance_m: Mapped[float | None] = mapped_column(Float, nullable=True)
+
+    # ===== 跨源去重键 + 原始返回 =====
+    dedup_key: Mapped[str] = mapped_column(String(64), index=True, nullable=False)
+    raw: Mapped[dict] = mapped_column(
+        JSON().with_variant(JSONB(), "postgresql"), nullable=False, default=dict
+    )
+
+    # ===== 抓取时间窗 =====
+    first_seen: Mapped[datetime] = mapped_column(
+        DateTime(timezone=True), server_default=func.now(), nullable=False
+    )
+    last_seen: Mapped[datetime] = mapped_column(
+        DateTime(timezone=True), server_default=func.now(), index=True, 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"<MeituanCoupon id={self.id} source={self.source} "
+            f"name={self.name!r} sale={self.sale_volume} comm={self.commission_percent}>"
+        )

app/models/user.py

@@ -33,6 +33,12 @@ class User(Base):
     nickname: Mapped[str | None] = mapped_column(String(64), nullable=True)
     avatar_url: Mapped[str | None] = mapped_column(String(512), nullable=True)
 
+    # 邀请码:每个用户一个稳定短码(懒生成,见 repositories/invite.ensure_code),
+    # 分享链接 / 二维码里带它。unique 允许多个 NULL(未生成的用户)。
+    invite_code: Mapped[str | None] = mapped_column(
+        String(16), unique=True, index=True, nullable=True
+    )
+
     # 微信开放平台 openid(微信登录绑定后存,提现转账到零钱用)。同一 appid 下唯一;
     # unique 索引保证一个微信只能绑一个账号(nullable,允许多个 NULL=未绑定)。
     wechat_openid: Mapped[str | None] = mapped_column(

app/repositories/coupon_state.py

@@ -0,0 +1,129 @@
+"""领券今日状态读写:弹窗频控(engagement)+ 领券记录(claim)。
+
+写操作按唯一键幂等 upsert,自带 commit + 并发 IntegrityError 兜底(对齐 price_observation)。
+日期口径 = Asia/Shanghai 的自然日。
+"""
+from __future__ import annotations
+
+import logging
+from datetime import date, datetime
+from zoneinfo import ZoneInfo
+
+from sqlalchemy import select
+from sqlalchemy.exc import IntegrityError
+from sqlalchemy.orm import Session
+
+from app.models.coupon_state import CouponClaimRecord, CouponPromptEngagement
+
+logger = logging.getLogger("shagua.coupon_state")
+
+_CN_TZ = ZoneInfo("Asia/Shanghai")
+
+
+def today_cn() -> date:
+    """Asia/Shanghai 的自然日(领券判断的"今天")。"""
+    return datetime.now(_CN_TZ).date()
+
+
+# ===== 弹窗频控(coupon_prompt_engagement)=====
+
+def has_engaged_today(db: Session, device_id: str) -> bool:
+    """这台设备今天是否已对领券引导窗表达过意向(领或拒)。有 = 不再弹。"""
+    row = db.execute(
+        select(CouponPromptEngagement.id).where(
+            CouponPromptEngagement.device_id == device_id,
+            CouponPromptEngagement.engage_date == today_cn(),
+        )
+    ).first()
+    return row is not None
+
+
+def mark_engagement(
+    db: Session, device_id: str, user_id: int | None, engage_type: str
+) -> None:
+    """记今日意向(claim_started / dismissed)。(device, 今天) 唯一,幂等 upsert。"""
+    today = today_cn()
+    row = db.execute(
+        select(CouponPromptEngagement).where(
+            CouponPromptEngagement.device_id == device_id,
+            CouponPromptEngagement.engage_date == today,
+        )
+    ).scalar_one_or_none()
+    if row is not None:
+        row.engage_type = engage_type
+        if user_id is not None:
+            row.user_id = user_id
+    else:
+        db.add(CouponPromptEngagement(
+            device_id=device_id, user_id=user_id,
+            engage_date=today, engage_type=engage_type,
+        ))
+    try:
+        db.commit()
+    except IntegrityError:
+        # 并发下另一请求刚插了同 (device, 日) → 唯一约束撞,回滚忽略(本就幂等)。
+        db.rollback()
+
+
+# ===== 领券记录(coupon_claim_record)=====
+
+def record_claims(
+    db: Session,
+    device_id: str,
+    user_id: int | None,
+    trace_id: str | None,
+    results: list[dict],
+) -> int:
+    """一批券领取结果幂等写入,返回写入(新增 + 更新)条数。
+
+    results 单项取自 pricebot 的 last_coupon_result / done.coupon_results,识别字段:
+    coupon_id(必需)/ status(必需)/ name / vendor / reason /(display_count)。
+    (device, coupon_id, 今天) 唯一:重复上报同张券走更新(status 以最后一次为准)。
+    """
+    today = today_cn()
+    written = 0
+    seen: set[str] = set()  # 同批去重防御:autoflush=False 下同 coupon_id 重复会两次 add → 撞唯一约束回滚整批
+    for r in results:
+        coupon_id = r.get("coupon_id")
+        status = r.get("status")
+        if not coupon_id or not status or coupon_id in seen:
+            continue  # 脏数据 / 同批重复跳过
+        seen.add(coupon_id)
+        count = r.get("display_count")
+        if count is None:
+            count = r.get("claimed_count")
+        row = db.execute(
+            select(CouponClaimRecord).where(
+                CouponClaimRecord.device_id == device_id,
+                CouponClaimRecord.coupon_id == coupon_id,
+                CouponClaimRecord.claim_date == today,
+            )
+        ).scalar_one_or_none()
+        if row is not None:
+            row.status = status
+            row.reason = r.get("reason")
+            if user_id is not None:
+                row.user_id = user_id
+            if count is not None:
+                row.claimed_count = count
+            row.extra = r
+        else:
+            db.add(CouponClaimRecord(
+                device_id=device_id, user_id=user_id,
+                coupon_id=coupon_id, claim_date=today,
+                status=status, vendor=r.get("vendor"), coupon_name=r.get("name"),
+                claimed_count=count, trace_id=trace_id, reason=r.get("reason"),
+                extra=r,
+            ))
+        written += 1
+    if written == 0:
+        return 0
+    try:
+        db.commit()
+    except IntegrityError:
+        db.rollback()
+        logger.warning(
+            "coupon_claim 并发幂等冲突 device=%s trace=%s,回滚", device_id, trace_id
+        )
+        return 0
+    return written

app/repositories/invite.py

@@ -0,0 +1,285 @@
+"""好友邀请 CRUD(注册即生效,邀请人 + 被邀请人各发金币)。
+
+防重复发奖三道(仿 ad_reward / 提现的资金安全思路):
+  1. invitee_user_id 唯一 → 一个被邀请人只能被绑定一次(幂等键)。
+  2. 自邀屏蔽 → inviter == invitee 直接拒。
+  3. 现成的手机号唯一(每个被邀请人 = 一个真实手机号账号)= 天然限制刷量规模。
+
+发金币复用 wallet.grant_coins(grant 只 flush 不 commit),与建关系记录在**同一事务**
+commit,保证"建关系 + 双方加金币"原子。奖励额 = rewards.INVITE_INVITER_COINS /
+INVITE_INVITEE_COINS。
+"""
+from __future__ import annotations
+
+import secrets
+from dataclasses import dataclass
+from datetime import datetime, timedelta, timezone
+
+from sqlalchemy import func, select
+from sqlalchemy.exc import IntegrityError
+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
+
+# 邀请码字符集:去掉易混字符(0/O/1/I/L/B/8/S/5/Z/2),用户口述/手输不易错
+_CODE_ALPHABET = "ACDEFGHJKMNPQRTUVWXY34679"
+_CODE_LEN = 6
+
+
+def _gen_code() -> str:
+    return "".join(secrets.choice(_CODE_ALPHABET) for _ in range(_CODE_LEN))
+
+
+def ensure_code(db: Session, user: User) -> str:
+    """保证 user 有邀请码(懒生成),返回它。唯一约束碰撞则换码重试。
+
+    ⚠️ 本函数会 db.commit() 整个 session(与 grant_coins"只 flush 不 commit"约定相反)。
+    当前只在 GET /invite/me 里调(该请求此前无其它写,提交范围干净)。若将来在带其它未提交
+    写的请求里复用本函数,会被它提前 commit——届时应改成 flush + 由调用方 commit。
+    """
+    if user.invite_code:
+        return user.invite_code
+    for _ in range(8):
+        user.invite_code = _gen_code()
+        try:
+            db.commit()
+            db.refresh(user)
+            return user.invite_code
+        except IntegrityError:
+            db.rollback()
+            user = db.get(User, user.id)  # 重取(rollback 后实例已过期),继续换码
+    raise RuntimeError("生成邀请码连续碰撞,请重试")
+
+
+def resolve_inviter(db: Session, invite_code: str) -> User | None:
+    """邀请码 → 邀请人(大小写不敏感)。"""
+    code = (invite_code or "").strip().upper()
+    if not code:
+        return None
+    return db.execute(
+        select(User).where(User.invite_code == code)
+    ).scalar_one_or_none()
+
+
+def _relation_of_invitee(db: Session, invitee_id: int) -> InviteRelation | None:
+    return db.execute(
+        select(InviteRelation).where(InviteRelation.invitee_user_id == invitee_id)
+    ).scalar_one_or_none()
+
+
+def _is_new_user(user: User) -> bool:
+    """被邀请人是否为"新注册"(created_at 在 INVITE_NEW_USER_WINDOW_HOURS 窗口内)。
+
+    "新用户闸":只奖刚注册的人,挡存量老用户互相填码薅羊毛。兼容 PG(tz-aware)与
+    SQLite(naive,按 UTC 解释)。
+    """
+    created = user.created_at
+    if created is None:
+        return False
+    if created.tzinfo is None:
+        created = created.replace(tzinfo=timezone.utc)
+    age = datetime.now(timezone.utc) - created
+    return age <= timedelta(hours=rewards.INVITE_NEW_USER_WINDOW_HOURS)
+
+
+@dataclass
+class BindResult:
+    status: str                          # success / already_bound / invalid_code / self_invite / not_eligible
+    relation: InviteRelation | None = None
+    invitee_coin: int = 0                # 本次给被邀请人发的金币(success 时 >0)
+
+
+def bind(
+    db: Session, *, invitee: User, invite_code: str, channel: str = "clipboard"
+) -> BindResult:
+    """把 invitee 绑定到 invite_code 对应的邀请人,注册即生效 + 双方发金币。
+
+    幂等:invitee 已被绑过 → already_bound(不重复发奖)。
+    """
+    # 幂等:已绑过直接返回(不重复发奖)
+    existing = _relation_of_invitee(db, invitee.id)
+    if existing is not None:
+        return BindResult("already_bound", existing)
+
+    inviter = resolve_inviter(db, invite_code)
+    if inviter is None or inviter.status != "active":
+        return BindResult("invalid_code")
+    if inviter.id == invitee.id:
+        return BindResult("self_invite")
+    # 新用户闸:被邀请人必须是"新注册"(窗口内)才发奖,挡存量老用户互相填码薅羊毛
+    if not _is_new_user(invitee):
+        return BindResult("not_eligible")
+
+    inviter_coin = rewards.INVITE_INVITER_COINS
+    invitee_coin = rewards.INVITE_INVITEE_COINS
+
+    rel = InviteRelation(
+        inviter_user_id=inviter.id,
+        invitee_user_id=invitee.id,
+        channel=(channel or "clipboard")[:16],
+        status="effective",
+        inviter_coin=inviter_coin,
+        invitee_coin=invitee_coin,
+    )
+    db.add(rel)
+    # 双方发金币(同事务,与建关系一起 commit)。ref_id 互指对方便于对账。
+    crud_wallet.grant_coins(
+        db, inviter.id, inviter_coin,
+        biz_type="invite_inviter", ref_id=str(invitee.id), remark="邀请好友奖励",
+    )
+    crud_wallet.grant_coins(
+        db, invitee.id, invitee_coin,
+        biz_type="invite_invitee", ref_id=str(inviter.id), remark="新人受邀奖励",
+    )
+    try:
+        db.commit()
+    except IntegrityError:
+        # 并发:同一 invitee 另一个请求先建了关系 → 回滚返回已存在(幂等兜底)
+        db.rollback()
+        existing = _relation_of_invitee(db, invitee.id)
+        if existing is not None:
+            return BindResult("already_bound", existing)
+        raise
+    except Exception:
+        # 其它 commit 失败(DB 故障 / PG 序列化冲突等):显式回滚,保证"建关系 + 双方发币"
+        # 原子(要么全成要么全无),不依赖 get_db 关闭时的隐式回滚,语义更硬。
+        db.rollback()
+        raise
+    db.refresh(rel)
+    return BindResult("success", rel, invitee_coin)
+
+
+def get_stats(db: Session, inviter_id: int) -> tuple[int, int]:
+    """返回 (已成功邀请人数, 累计从邀请获得的金币)。"""
+    count = db.execute(
+        select(func.count())
+        .select_from(InviteRelation)
+        .where(InviteRelation.inviter_user_id == inviter_id)
+    ).scalar_one()
+    coins = db.execute(
+        select(func.coalesce(func.sum(InviteRelation.inviter_coin), 0))
+        .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)

app/schemas/coupon_state.py

@@ -0,0 +1,21 @@
+"""领券今日状态端点的收发模型。"""
+from __future__ import annotations
+
+from pydantic import BaseModel
+
+
+class CouponPromptDismissIn(BaseModel):
+    """客户端拒绝/关闭领券引导窗的通知体。
+
+    server 据此记一条今日 engagement(dismissed)→ 今天这台设备不再弹引导窗。
+    MVP 不鉴权,按 device_id 判断;user_id 登录态带上就一并记(资产),可空。
+    """
+
+    device_id: str
+    user_id: int | None = None
+
+
+class CouponPromptShouldShowOut(BaseModel):
+    """切到外卖 App 时是否还应弹领券引导窗。今天已 engage(领或拒)过 → false。"""
+
+    should_show: bool

app/schemas/invite.py

@@ -0,0 +1,73 @@
+"""邀请相关 API 收发模型。"""
+from __future__ import annotations
+
+from datetime import datetime
+
+from pydantic import BaseModel, Field
+
+
+class InviteInfoOut(BaseModel):
+    invite_code: str                # 我的邀请码
+    share_url: str                  # 落地页链接(含 ?ref=),前端据此生成二维码 + 复制分享
+    invited_count: int              # 已成功邀请人数
+    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="邀请码;走指纹兜底时为空"
+    )
+    channel: str = Field(
+        "clipboard", max_length=16,
+        description="归因来源:clipboard(首启读剪贴板自动) / manual(手动填) / fingerprint(指纹兜底)",
+    )
+    # 当 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
+    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                  # 还有下一页吗(完整列表页滚到底加载更多)

app/schemas/meituan.py

@@ -134,6 +134,12 @@ class FeedRequest(BaseModel):
     latitude: float = Field(..., description="纬度")
     page: int = Field(1, ge=1)
     page_size: int = Field(20, ge=1, le=20)
+    # 筛选/排序口径,后端据此处理后返回(前端不再自己筛/排):
+    #  rec      = 智能推荐:榜单混合 feed 去掉佣金率 < 3%(分页)
+    #  distance = 距离最近:拉齐全部轮次后全局按距离由近及远(一次性返回, has_next=False)
+    #  留空/其它 = 原混合 feed 不筛(老客户端兼容,新 app 会显式传 tab)
+    # (销量最高 sales 走 /coupons 同城热销,不在本接口)
+    tab: str = Field("", description="rec 智能推荐 / distance 距离最近 / 空=不筛(兼容)")
 
 
 class FeedResponse(BaseModel):
@@ -142,6 +148,13 @@ class FeedResponse(BaseModel):
     page: int = 1
 
 
+class TopSalesRequest(BaseModel):
+    """销量最高 tab:从离线库 meituan_coupon 按销量降序取(不实时打美团)。"""
+    page: int = Field(1, ge=1)
+    page_size: int = Field(20, ge=1, le=50)
+    platform: int | None = Field(None, description="可选: 1只外卖 / 2只到店; 不填=全部(全城销量)")
+
+
 # ───────────────── 换链 请求 / 响应 ─────────────────
 
 class ReferralLinkRequest(BaseModel):

data/media/dl.html

@@ -0,0 +1,168 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+<meta charset="utf-8">
+<meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no">
+<meta name="format-detection" content="telephone=no">
+<title>傻瓜比价 · 下载</title>
+<style>
+  * { margin:0; padding:0; box-sizing:border-box; -webkit-tap-highlight-color:transparent; }
+  html,body { height:100%; }
+  body {
+    font-family:-apple-system,BlinkMacSystemFont,"PingFang SC","Microsoft YaHei",sans-serif;
+    background:linear-gradient(165deg,#FF7A3D 0%,#FF3B30 52%,#E0245E 100%);
+    color:#fff; min-height:100%; display:flex; flex-direction:column;
+    align-items:center; justify-content:center; padding:40px 26px; text-align:center;
+    overflow-x:hidden;
+  }
+  .logo {
+    width:104px; height:104px; border-radius:26px; background:#fff;
+    display:flex; align-items:center; justify-content:center; font-size:52px;
+    box-shadow:0 14px 34px rgba(0,0,0,.22); margin-bottom:24px;
+  }
+  h1 { font-size:30px; font-weight:800; letter-spacing:1px; }
+  .slogan { margin-top:12px; font-size:16px; line-height:1.7; opacity:.95; max-width:300px; }
+  .feats { margin-top:26px; display:flex; flex-direction:column; gap:12px; width:100%; max-width:320px; }
+  .feat { background:rgba(255,255,255,.16); border-radius:14px; padding:13px 16px; font-size:15px; display:flex; align-items:center; gap:10px; }
+  .feat b { font-weight:700; }
+  .btn {
+    margin-top:34px; width:100%; max-width:320px; border:none; cursor:pointer;
+    background:#fff; color:#FF3B30; font-size:19px; font-weight:800;
+    padding:17px 0; border-radius:999px; box-shadow:0 10px 26px rgba(0,0,0,.22);
+    display:flex; align-items:center; justify-content:center; gap:9px;
+  }
+  .btn:active { transform:translateY(1px); opacity:.92; }
+  .hint { margin-top:16px; font-size:13px; opacity:.85; }
+  .foot { margin-top:30px; font-size:12px; opacity:.6; line-height:1.6; max-width:320px; }
+
+  /* 微信内"去浏览器打开"引导蒙层 */
+  #wxmask {
+    display:none; position:fixed; inset:0; z-index:9999;
+    background:rgba(0,0,0,.86); padding:18px;
+  }
+  #wxmask.show { display:block; }
+  .arrow { position:absolute; top:8px; right:14px; width:120px; }
+  .wxtip { position:absolute; top:150px; right:18px; left:18px; text-align:right; }
+  .wxtip .big { font-size:21px; font-weight:800; line-height:1.5; }
+  .wxtip .big em { color:#FFD24D; font-style:normal; }
+  .wxtip .sub { margin-top:14px; font-size:15px; line-height:1.8; opacity:.9; }
+  .wxsteps { margin-top:26px; text-align:left; background:rgba(255,255,255,.1); border-radius:14px; padding:18px 18px; font-size:15px; line-height:2; }
+  .wxsteps .n { display:inline-block; width:22px; height:22px; line-height:22px; text-align:center; border-radius:50%; background:#FFD24D; color:#333; font-weight:800; font-size:13px; margin-right:8px; }
+  .closebar { position:absolute; bottom:30px; left:0; right:0; text-align:center; font-size:14px; opacity:.7; }
+</style>
+</head>
+<body>
+  <div class="logo">🛒</div>
+  <h1>傻瓜比价</h1>
+  <div class="slogan">买什么都先比一比<br>自动帮你找全网最低价</div>
+
+  <div class="feats">
+    <div class="feat">🍔 <span>点外卖前一键比价,<b>美团/京东/淘宝</b>到手价一目了然</span></div>
+    <div class="feat">🎟️ <span>自动领遍各平台<b>红包券</b>,能省的一分不漏</span></div>
+    <div class="feat">💰 <span>省下的钱看得见,还能<b>赚金币提现</b></span></div>
+  </div>
+
+  <button class="btn" id="dlbtn">⬇️ 下载安装包</button>
+  <div class="hint" id="hint">Android 安卓版 · 安装包约 24 MB</div>
+
+  <div class="foot">
+    安装时如提示「未知来源」,请允许后继续安装。<br>
+    本页为内部测试页。
+  </div>
+
+  <!-- 微信内引导:跳出微信去浏览器 -->
+  <div id="wxmask">
+    <svg class="arrow" viewBox="0 0 120 130" fill="none" xmlns="http://www.w3.org/2000/svg">
+      <path d="M30 120 C 30 70, 55 40, 95 28" stroke="#FFD24D" stroke-width="6" stroke-linecap="round" fill="none" stroke-dasharray="2 13"/>
+      <path d="M95 28 L 78 30 M95 28 L 92 46" stroke="#FFD24D" stroke-width="6" stroke-linecap="round"/>
+    </svg>
+    <div class="wxtip">
+      <div class="big">点击右上角 <em>···</em><br>选择「<em>在浏览器打开</em>」</div>
+      <div class="sub">微信里无法直接下载安装包<br>需在系统浏览器中完成下载</div>
+      <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>
+    </div>
+    <div class="closebar" id="wxclose">我知道了 ✕</div>
+  </div>
+
+<script>
+  // 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 兜底
+    try {
+      var ta = document.createElement("textarea");
+      ta.value = payload; ta.style.position = "fixed"; ta.style.top = "-1000px"; ta.style.opacity = "0";
+      document.body.appendChild(ta); ta.focus(); ta.select();
+      document.execCommand("copy"); document.body.removeChild(ta);
+    } catch (e) {}
+  }
+  function copyInviteCode() {                   // 返回 Promise(完成后才下载,避免异步写入被打断)
+    if (!ref) return Promise.resolve();
+    var payload = "SGBJ_INVITE:" + ref;
+    legacyCopy(payload);                         // 同步兜底:在用户手势内立刻 execCommand 写一次(最可靠)
+    if (navigator.clipboard && navigator.clipboard.writeText) {
+      return navigator.clipboard.writeText(payload).catch(function () {});  // 现代 API 锦上添花,失败无妨
+    }
+    return Promise.resolve();
+  }
+  // 确保剪贴板写完(或最多等 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");
+  if (isIOS) hint.textContent = "检测到 iPhone · iOS 版请前往 App Store";
+
+  var mask = document.getElementById("wxmask");
+  function showMask(){ mask.classList.add("show"); }
+  function hideMask(){ mask.classList.remove("show"); }
+  document.getElementById("wxclose").addEventListener("click", hideMask);
+
+  // 微信里一进页面就提示去浏览器打开(下载在微信内必被拦)
+  if (isWeChat) showMask();
+
+  document.getElementById("dlbtn").addEventListener("click", function(){
+    if (isWeChat) { showMask(); return; }           // 微信内:引导去浏览器
+    if (isIOS)    { alert("iOS 版即将上线,请前往 App Store 搜索「傻瓜比价」"); return; }
+    // 普通浏览器:先把邀请码写进剪贴板(写完或 400ms 兜底),再下载 APK(首启读回完成归因)
+    startDownload();
+  });
+</script>
+</body>
+</html>

docs/README.md

@@ -10,6 +10,7 @@
 | [数据库迁移.md](./数据库迁移.md) | **Alembic 迁移指南**:clone 后如何建表、日常升级、新增迁移、迁移文件命名约定。想"把数据库跑起来 / 改表结构"看这份。 |
 | [待办与技术债.md](./待办与技术债.md) | **待办与技术债账本**:记"现在先简化、以后要补"的事 + 跨前后端技术债(P1 鉴权/用户绑定、引擎移植待办等),免遗忘。想知道"还欠什么、以后要补什么"看这份。 |
 | [看广告赚金币上线清单.md](./看广告赚金币上线清单.md) | **看广告发奖上线 checklist**:跨前后端,记上线前必做(GroMore 回调配置、清理调试脚手架、端到端验收)。上线"看广告赚金币"前对照这份。 |
+| [邀请功能-实现原理与本地测试.md](./邀请功能-实现原理与本地测试.md) | **好友邀请(invite-mvp)实现原理 + 跨前后端具体实现 + 本地内网测试方法**:剪贴板 deferred-deeplink 归因、双方各发 1 万金币、落地页 dl.html、起本地后端 + 编 debug 包 + 两台真机走全链路 + 上线前还差什么。要本地测 / 接手邀请功能看这份。 |
 
 ## api/ 目录是怎么组织的(传送门式)
 

docs/邀请功能-实现原理与本地测试.md

@@ -0,0 +1,139 @@
+# 好友邀请(invite-mvp)— 实现原理与本地测试
+
+> 跨 **shaguabijia-app-server**(后端)+ **shaguabijia-app-android**(前端)的好友邀请功能。
+> 本文给三件事:**做什么 / 怎么实现 / 怎么在本地内网测**(交接给同事用)。
+> 代码引用一律用文件路径 + 符号名(不写行号,重构后行号会失效)。
+
+---
+
+## 一、功能是什么
+
+**注册即生效**:被邀请人(B)用邀请人(A)的邀请码完成绑定 → **A、B 各得 1 万金币(= 1 元,可提现)**。
+
+---
+
+## 二、实现原理(数据流)
+
+归因(B 装的这次算不算 A 邀的)有**两条通道**:
+
+- **剪贴板自动**(deferred deeplink,生产主路径):落地页把邀请码写进剪贴板,APK 首启读回。
+- **手动填码**(兜底):B 在邀请页直接输入 A 的邀请码。
+
+剪贴板自动这条的完整跨库链路:
+
+```
+A 端(已登录)
+  └─ GET /api/v1/invite/me → 拿到 invite_code + share_url(=落地页?ref=<码>)
+  └─ 分享 share_url(微信/任意渠道)
+        ↓
+B 端(系统浏览器打开 share_url = .../media/dl.html?ref=<码>)
+  └─ 点「下载安装包」
+        ├─ dl.html 把 "SGBJ_INVITE:<码>" 写进剪贴板(execCommand)
+        └─ 跳 APK_URL 下载安装包
+        ↓
+B 安装并首启 App
+  └─ InviteCapture 读剪贴板,识别 "SGBJ_INVITE:" 前缀 → 暂存 pending 邀请码
+  └─ B 登录成功 → AuthRepository 触发 InviteRepository.bindPendingFromClipboard()
+        └─ POST /api/v1/invite/bind { invite_code, channel="clipboard" }
+        ↓
+后端 repositories/invite.py bind()
+  └─ 过四道防线 → 建 invite_relation + 给 A、B 各发金币(同事务原子提交)
+```
+
+手动填码这条:B 在邀请页输码 → `InviteRepository.bindManual()` → `POST /bind { channel="manual" }` → 同一个 `bind()`。
+
+---
+
+## 三、具体实现
+
+### 3.1 后端(shaguabijia-app-server)
+
+| 关注点 | 位置 |
+|---|---|
+| 端点 | `app/api/v1/invite.py`:`GET /api/v1/invite/me`(返回 `invite_code` + `share_url` + 战绩)、`POST /api/v1/invite/bind`(绑定,`channel` = `clipboard` / `manual`)。**均需 Bearer 鉴权**。 |
+| share_url 构造 | `invite.py` 的 `my_invite`:`settings.INVITE_LANDING_URL + "?ref=" + code`。`INVITE_LANDING_URL` 在 `app/core/config.py`(默认 `https://app-api.shaguabijia.com/media/dl.html`)。 |
+| 业务逻辑 | `app/repositories/invite.py`:`ensure_code`(懒生成 6 位邀请码,去混淆字符集,唯一约束碰撞则换码)/ `resolve_inviter`(邀请码→邀请人,大小写不敏感)/ `bind`(下面详述)/ `get_stats`(已邀人数 + 累计金币)。 |
+| 数据模型 | `app/models/invite.py` 的 `InviteRelation`(`inviter_user_id` / `invitee_user_id` / `channel` / `status` / `inviter_coin` / `invitee_coin` / `created_at`)+ `app/models/user.py` 的 `User.invite_code` 列。 |
+| 迁移 | `alembic/versions/invite_code_and_relation.py`:给 `user` 加 `invite_code`(唯一索引)+ 建 `invite_relation` 表。`down_revision = 11a1d08c6f55`。 |
+| 收发模型 | `app/schemas/invite.py`:`InviteInfoOut` / `BindInviteIn` / `BindInviteOut`。 |
+| 奖励常量 | `app/core/rewards.py`:`INVITE_INVITER_COINS` / `INVITE_INVITEE_COINS`(各 10000 = 1 元)、`INVITE_NEW_USER_WINDOW_HOURS`(72)。 |
+
+**`bind()` 的四道防线(防重复 / 防刷,看 `repositories/invite.py`):**
+
+1. **被邀请人唯一**:`invitee_user_id` 唯一约束 → 一个 B 只能被绑一次(幂等键,重复返回 `already_bound`,不重复发奖)。
+2. **自邀屏蔽**:`inviter == invitee` → `self_invite`。
+3. **新人闸**:`_is_new_user`(B 的 `created_at` 在 `INVITE_NEW_USER_WINDOW_HOURS` = 72h 内)才发奖,挡存量老用户互相填码薅羊毛 → 否则 `not_eligible`。
+4. **手机号唯一**(天然限量):每个 B = 一个真实手机号账号。
+
+发金币复用 `repositories/wallet.py` 的 `grant_coins`,与建关系记录在**同一事务**提交,保证"建关系 + 双方加金币"原子。
+
+### 3.2 前端(shaguabijia-app-android)
+
+| 关注点 | 位置 |
+|---|---|
+| 网络层 | `data/api/InviteApi.kt` + `InviteDto.kt`:`me()` / `bind(BindInviteRequest)`。 |
+| 门面 | `data/invite/InviteRepository.kt`:`myInvite()` / `bindManual(code)` / `bindPendingFromClipboard()`。 |
+| 剪贴板捕获 | `util/InviteCapture.kt`:首启读剪贴板找 `SGBJ_INVITE:` 前缀(常量 `CLIP_PREFIX`),命中即暂存到 SP(`pending_invite_code`);**未命中不烧机会**,跨多次启动最多试 `MAX_ATTEMPTS`(5)次,之后靠手动填码兜底。 |
+| 自动绑定触发 | 登录成功后由 `data/auth/AuthRepository.kt` 调 `InviteRepository.bindPendingFromClipboard()`(best-effort,不抛异常)。 |
+| UI | `ui/invite/InviteScreen.kt` + `InviteViewModel.kt`:展示码 / 二维码(`util/QrCodeGen.kt`)/ 战绩 + 手动填码入口。 |
+
+### 3.3 落地页 dl.html(`data/media/dl.html`,由后端 `/media` 静态托管)
+
+- 读 URL 的 `?ref=<邀请码>`。
+- 点「下载安装包」时:`legacyCopy()` 用 `document.execCommand('copy')` **同步**把 `"SGBJ_INVITE:<码>"` 写进剪贴板(execCommand **不要求安全上下文**,内网 HTTP 也能写;`navigator.clipboard` 只是 HTTPS 下锦上添花、失败无妨),再跳 `APK_URL` 下载。
+- `APK_URL = location.origin + "/media/shaguabijia.apk"`:**跟随页面 host**——本地测试时页面由笔记本(LAN:8770)托管 → 下载也走 LAN;生产由 `app-api.shaguabijia.com` 托管 → 走生产域名。**无需按机器改 IP**。
+- 微信内显示「去浏览器打开」引导(微信内 execCommand / apk 下载都受限,必须跳系统浏览器)。
+
+> dl.html 已纳入 git(见本仓 `.gitignore` 对 `data/media/dl.html` 的例外)。`data/media/shaguabijia.apk`(大二进制)、`avatars/` 等仍忽略。
+
+---
+
+## 四、本地内网测试方法(重点)
+
+**拓扑**:同一 WiFi 下,1 台笔记本(起后端 + 托管落地页/APK)+ 2 台安卓真机(A 邀请人 / B 被邀请人)。落地页和 APK 都由笔记本 app-server 的 `/media` 在局域网托管,一处搞定。
+
+### 4.1 起后端
+
+1. 本机 PostgreSQL 起着;`conda activate price`。
+2. `.env` 改两项(**本地测试覆盖,测完改回**):
+   - `SMS_MOCK=true` —— 任意手机号 + 任意 6 位码秒注册,方便建 A/B 两个号(生产是 `false` 走真极光)。
+   - `INVITE_LANDING_URL=http://<笔记本LAN_IP>:8770/media/dl.html` —— 让 `/invite/me` 返回的 share_url 走内网。
+3. `alembic upgrade head` 建表。
+   - ⚠️ **切分支后若报 `Can't locate revision`**(DB 版本指针停在别分支的迁移,例如先测过 coupon-daily-claim-gate,DB 停在 `coupon_state_tables`,而本分支没这个文件):用 `alembic stamp <共同祖先> --purge` 把指针重置到共同祖先(本分支祖先是 `11a1d08c6f55`)→ 再 `alembic upgrade head` 只跑 invite 这一条建表。**别删多余表**。详见 `docs/数据库迁移.md`。
+4. `./run.sh`(监听 `0.0.0.0:8770`)。**笔记本防火墙放行入站 8770**。
+
+### 4.2 落地页 + APK(都由 `/media` 在 LAN 托管)
+
+- **落地页**:`data/media/dl.html` 已在 git、host-agnostic,**无需改**(clone 出来就在)。
+- **APK**:编一个 debug 包放到 `data/media/shaguabijia.apk`:
+  1. 前端 `local.properties` 填 `debug.api.host=<笔记本LAN_IP>` / `debug.api.port=8770`(debug 包的 `BASE_URL` 据此**编译期**烧入,见 `app/build.gradle.kts`;debug 包还放行明文 HTTP)。
+  2. `./gradlew assembleDebug`。
+  3. `cp app/build/outputs/apk/debug/app-debug.apk <app-server>/data/media/shaguabijia.apk`。
+
+### 4.3 跑流程
+
+1. A 真机装 debug 包 → 登录 → 邀请页拿到 6 位码 / share_url(= `http://<LAN>:8770/media/dl.html?ref=<码>`)。
+2. A 把 share_url 发出去 → B 真机**用系统浏览器**打开 → 点「下载」(写剪贴板 + 下 APK)→ 安装。
+3. B 首启 → `InviteCapture` 读剪贴板拿码(Android 12+ 会弹"已粘贴"提示,正常)→ B 用**新手机号**登录 → 自动 `bind(clipboard)` → **A、B 各 +1 万金币,`invite_relation` 入库**。
+4. **手动填码路径**:B 在邀请页直接输 A 的码(`channel=manual`),不依赖剪贴板——剪贴板失败时的兜底,值得单独测。
+
+### 4.4 测试硬约束 / 坑(都是机制,不是 bug)
+
+- **B 必须用新手机号**:`invitee_user_id` 唯一,一个 B 只能绑一次;反复测要换号(或手删 `invite_relation` 那行 + 回滚金币)。
+- **72h 新人闸**:B 注册后 72 小时内绑才发奖(刚注册肯定满足)。
+- **A ≠ B**:自邀被屏蔽。
+- **B 从点下载到首启 App 之间别复制别的东西**:剪贴板会被覆盖 → 归因丢(剪贴板 deferred deeplink 的固有脆弱性)。
+- **笔记本 IP 别变**:debug 包把 `BASE_URL` 的 IP 烧死在编译期,DHCP 一换就连不上 → 给笔记本固定个 LAN IP。
+
+---
+
+## 五、上线前还差什么(本地测通 ≠ 可上线)
+
+本地这一关证明的是"机制能跑通",离生产可上线还差:
+
+1. ⚠️ **alembic 多 head(不修 100% 翻车)**:`coupon_state_tables` 和 `invite_code_and_relation` 都挂在 `11a1d08c6f55` 下、是**兄弟迁移**。invite 一合 main,main 上就有两个 head,prod `alembic upgrade head` 撞 `Multiple head revisions` → 服务起不来。**合 main 前 / 部署前必须建一个 merge 迁移**把两条链并起来(参考 repo 里已有的 `*_merge_*_heads.py`)。本地单分支单 head 测不出。
+2. **release 包 ≠ debug 包**:用户拿到的是 release(签名不同、强制 HTTPS、若开 minify 还有 R8 混淆),本地测的是 debug。上线前用 **release 包真机**验全流程。
+3. **风控 / 薅羊毛**:1 万金币可提现,**邀请人无总数上限**,接码平台批量注册新号绑同一个码即可刷。上线前加 **inviter 上限 + 基础风控**。
+4. **仅验了 happy path**:错误分支文案(`invalid_code` / `already_bound` / `self_invite` / `not_eligible`)、手动填码兜底、stats 展示更新、并发绑定都没真测。
+5. **配置回归**:`SMS_MOCK` / `INVITE_LANDING_URL` 是本地覆盖,生产走真极光 + 默认生产落地页。
+6. **(dl.html 纳入 git 后的部署细节)**:生产机上已有未跟踪的 `data/media/dl.html`(之前手动放的)。若走 git 部署,首次 pull 前需先移走生产那份,否则报 `untracked working tree files would be overwritten`。

pyproject.toml

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

scripts/pull_meituan_coupons.py

@@ -0,0 +1,331 @@
+"""美团 CPS 券定时抓取入库(北京试点)。
+
+把 3 路券抓进 meituan_coupon 表,供「销量/佣金排序」从库里捞、本地排序,不再实时打美团:
+  1. search_waimai : 到家/外卖, 搜「外卖」          翻到尽头
+  2. search_meishi : 到家/外卖, 搜「美食」          翻到尽头
+  3. store_supply  : 到店, 多业务线供给(到餐+到综+酒店+门票) 翻到尽头
+
+按 (source, product_view_sign) upsert 存最新态;last_seen 每轮刷新。带文件锁,防止
+上一轮没跑完下一轮又起(本地 5~10min、跨进程 cron 都安全)。
+
+用法:
+    # 单轮(打通验证 / 给 cron 用,线上每 1h 一次)
+    python -m scripts.pull_meituan_coupons --once
+
+    # 本地循环(默认每 10min 一轮)
+    python -m scripts.pull_meituan_coupons --loop --interval 600
+"""
+from __future__ import annotations
+
+import argparse
+import hashlib
+import os
+import re
+import sys
+import time
+from datetime import datetime, timedelta, timezone
+
+# Windows 控制台按 UTF-8 输出中文/¥
+try:
+    sys.stdout.reconfigure(encoding="utf-8")  # type: ignore[attr-defined]
+except Exception:  # noqa: BLE001
+    pass
+
+from sqlalchemy import delete, func, select
+from sqlalchemy.dialects.postgresql import insert as pg_insert
+
+from app.db.session import SessionLocal
+from app.integrations.meituan import MeituanCpsError, _call
+from app.models.meituan_coupon import MeituanCoupon
+
+CITY_BEIJING = "WKV2HMXUEK634WP64CUCUQGM64"
+QUERY_PATH = "/cps_open/common/api/v1/query_coupon"
+PAGE_SIZE = 20
+MAX_PAGES = 80          # 单路安全上限(搜索 ~52 页、供给 ~70 页)
+PAGE_SLEEP = 0.35       # 页间配速,缓解 402
+RETRY = 7
+LOCK_FILE = "data/.meituan_etl.lock"
+LOCK_STALE_SEC = 30 * 60   # 锁超过 30min 视为陈旧(进程异常退出残留),自动接管
+
+SOURCES = [
+    {"code": "search_waimai", "label": "外卖·搜外卖", "kind": "search", "platform": 1, "keyword": "外卖"},
+    {"code": "search_meishi", "label": "外卖·搜美食", "kind": "search", "platform": 1, "keyword": "美食"},
+    {"code": "store_supply", "label": "到店·多业务线供给", "kind": "supply",
+     "platform": 2, "biz_lines": [1, 2, 3, 4]},
+]
+
+
+# ───────────────────────── 美团调用 ─────────────────────────
+
+def _call_retry(body: dict) -> dict | None:
+    """打美团,402/频繁退避重试;其它错误打印并放弃本页。"""
+    for a in range(RETRY):
+        try:
+            return _call(QUERY_PATH, body)
+        except MeituanCpsError as e:
+            msg = str(e)
+            if "402" in msg or "频繁" in msg:
+                time.sleep(2.5 * (a + 1))
+                continue
+            print(f"   [warn] meituan: {msg[:80]}")
+            return None
+        except Exception as e:  # noqa: BLE001
+            print(f"   [warn] {type(e).__name__}: {str(e)[:60]}")
+            time.sleep(2.0 * (a + 1))
+    return None
+
+
+def _pull_search(platform: int, keyword: str) -> list[dict]:
+    rows: list[dict] = []
+    sid = None
+    pg = 1
+    while pg <= MAX_PAGES:
+        body = {"platform": platform, "searchText": keyword, "cityId": CITY_BEIJING, "pageSize": PAGE_SIZE}
+        if sid:
+            body["searchId"] = sid
+        else:
+            body["pageNo"] = pg
+        r = _call_retry(body)
+        if not r:
+            break
+        sid = r.get("searchId")
+        data = r.get("data") or []
+        rows.extend(data)
+        if not r.get("hasNext") or not data:
+            break
+        pg += 1
+        time.sleep(PAGE_SLEEP)
+    return rows
+
+
+def _pull_supply(platform: int, biz_lines: list[int]) -> list[dict]:
+    rows: list[dict] = []
+    sid = None
+    biz_param = [{"bizLine": b} for b in biz_lines]
+    for _ in range(MAX_PAGES):
+        body = {
+            "multipleSupplyList": [{"platform": platform, "bizLineParamList": biz_param}],
+            "cityId": CITY_BEIJING,
+            "sortField": 2,  # 供给查询 sortField 必填;我们入库后本地再排,这里给个默认
+            "pageSize": PAGE_SIZE,
+        }
+        if sid:
+            body["searchId"] = sid
+        r = _call_retry(body)
+        if not r:
+            break
+        sid = r.get("searchId")
+        data = r.get("data") or []
+        rows.extend(data)
+        if not r.get("hasNext") or not data:
+            break
+        time.sleep(PAGE_SLEEP)
+    return rows
+
+
+# ───────────────────────── 解析 ─────────────────────────
+
+_SV_RE = re.compile(r"(\d+(?:\.\d+)?)\s*(w|万|k)?", re.I)
+
+
+def _sale_volume_num(s: str | None) -> int | None:
+    """'热销1w+' → 10000, '热销500+' → 500(取下界,排序用)。"""
+    if not s:
+        return None
+    m = _SV_RE.search(str(s))
+    if not m:
+        return None
+    v = float(m.group(1))
+    u = (m.group(2) or "").lower()
+    if u in ("w", "万"):
+        v *= 10000
+    elif u == "k":
+        v *= 1000
+    return int(v)
+
+
+def _to_cents(yuan) -> int | None:
+    if yuan in (None, "", "null"):
+        return None
+    try:
+        return round(float(yuan) * 100)
+    except (TypeError, ValueError):
+        return None
+
+
+def _parse_item(item: dict, source: dict) -> dict | None:
+    cpd = item.get("couponPackDetail") or {}
+    br = item.get("brandInfo") or {}
+    ci = item.get("commissionInfo") or {}
+    poi = item.get("availablePoiInfo") or {}
+    dp = item.get("deliverablePoiInfo") or {}
+
+    sign = cpd.get("productViewSign") or cpd.get("skuViewId")
+    if not sign:
+        return None
+
+    name = cpd.get("name") or ""
+    brand = br.get("brandName") or ""
+    price_cents = _to_cents(cpd.get("sellPrice"))
+
+    comm_pct = None
+    if ci.get("commissionPercent") is not None:
+        try:
+            comm_pct = float(ci["commissionPercent"]) / 100.0  # 140 → 1.4(%)
+        except (TypeError, ValueError):
+            comm_pct = None
+
+    dist = dp.get("deliveryDistance")
+    try:
+        dist = float(dist) if dist not in (None, "", "null") else None
+    except (TypeError, ValueError):
+        dist = None
+
+    dedup_raw = f"{brand}|{name}|{price_cents}"
+    return {
+        "source": source["code"],
+        "platform": source["platform"],
+        "biz_line": item.get("bizLine") or cpd.get("bizLine"),
+        "city_id": CITY_BEIJING,
+        "product_view_sign": str(sign)[:128],
+        "sku_view_id": cpd.get("skuViewId"),
+        "name": (name[:256] or None),
+        "brand_name": (brand[:128] or None),
+        "sell_price_cents": price_cents,
+        "original_price_cents": _to_cents(cpd.get("originalPrice")),
+        "head_url": ((cpd.get("headUrl") or "").split("@")[0][:512] or None),
+        "sale_volume": cpd.get("saleVolume"),
+        "sale_volume_num": _sale_volume_num(cpd.get("saleVolume")),
+        "commission_percent": comm_pct,
+        "commission_amount_cents": _to_cents(ci.get("commission")),
+        "poi_name": ((dp.get("poiName") or "")[:128] or None),
+        "available_poi_num": poi.get("availablePoiNum"),
+        "delivery_distance_m": dist,
+        "dedup_key": hashlib.md5(dedup_raw.encode("utf-8")).hexdigest(),
+        "raw": item,
+    }
+
+
+# ───────────────────────── 入库(upsert) ─────────────────────────
+
+def _upsert(db, rows: list[dict], now: datetime) -> tuple[int, int]:
+    """按 (source, product_view_sign) upsert。返回 (入库去重后条数, 本源内重复条数)。"""
+    if not rows:
+        return 0, 0
+    dedup: dict[tuple, dict] = {}
+    for r in rows:
+        dedup[(r["source"], r["product_view_sign"])] = r  # 同轮内同键保留最后一条
+    payload = list(dedup.values())
+    for r in payload:
+        r["last_seen"] = now
+        r["updated_at"] = now
+
+    chunk = 500
+    for i in range(0, len(payload), chunk):
+        part = payload[i:i + chunk]
+        stmt = pg_insert(MeituanCoupon).values(part)
+        update_cols = {
+            c: getattr(stmt.excluded, c)
+            for c in part[0]
+            if c not in ("source", "product_view_sign", "first_seen")
+        }
+        stmt = stmt.on_conflict_do_update(
+            constraint="uq_meituan_coupon_source_sign", set_=update_cols
+        )
+        db.execute(stmt)
+        db.commit()
+    return len(payload), len(rows) - len(payload)
+
+
+# ───────────────────────── 运行锁 ─────────────────────────
+
+def _acquire_lock() -> bool:
+    os.makedirs(os.path.dirname(LOCK_FILE) or ".", exist_ok=True)
+    try:
+        fd = os.open(LOCK_FILE, os.O_CREAT | os.O_EXCL | os.O_WRONLY)
+        os.write(fd, f"{os.getpid()} {time.time()}".encode())
+        os.close(fd)
+        return True
+    except FileExistsError:
+        try:
+            with open(LOCK_FILE) as f:
+                parts = f.read().split()
+            ts = float(parts[1]) if len(parts) > 1 else 0.0
+            if time.time() - ts > LOCK_STALE_SEC:
+                os.remove(LOCK_FILE)
+                return _acquire_lock()
+        except Exception:  # noqa: BLE001
+            pass
+        return False
+
+
+def _release_lock() -> None:
+    try:
+        os.remove(LOCK_FILE)
+    except OSError:
+        pass
+
+
+# ───────────────────────── 主流程 ─────────────────────────
+
+def run_once(prune_hours: int = 24) -> None:
+    if not _acquire_lock():
+        print(f"[{datetime.now():%H:%M:%S}] 上一轮还在跑(锁占用),跳过本轮")
+        return
+    t0 = time.time()
+    now = datetime.now(timezone.utc)
+    db = SessionLocal()
+    try:
+        total = 0
+        for src in SOURCES:
+            ts = time.time()
+            if src["kind"] == "search":
+                items = _pull_search(src["platform"], src["keyword"])
+            else:
+                items = _pull_supply(src["platform"], src["biz_lines"])
+            parsed = [p for p in (_parse_item(it, src) for it in items) if p]
+            up, dup = _upsert(db, parsed, now)
+            total += up
+            print(f"  {src['label']:18} 抓{len(items):5} 解析{len(parsed):5} "
+                  f"入库{up:5} (本源去重{dup:3}) {time.time() - ts:4.0f}s")
+        # 清理长期未再出现的陈旧券(美团 sign 轮换 / 券下架后的残留),默认 24h 宽限
+        if prune_hours and prune_hours > 0:
+            cutoff = now - timedelta(hours=prune_hours)
+            pruned = db.execute(
+                delete(MeituanCoupon).where(MeituanCoupon.last_seen < cutoff)
+            ).rowcount
+            db.commit()
+            if pruned:
+                print(f"  清理陈旧券(>{prune_hours}h 未再出现): {pruned} 条")
+        cnt = db.execute(select(func.count()).select_from(MeituanCoupon)).scalar()
+        print(f"[{datetime.now():%H:%M:%S}] 本轮完成: 入库 {total} 条, 表总计 {cnt} 行, "
+              f"用时 {time.time() - t0:.0f}s")
+    finally:
+        db.close()
+        _release_lock()
+
+
+def main() -> None:
+    ap = argparse.ArgumentParser(description="美团 CPS 券定时抓取入库")
+    ap.add_argument("--once", action="store_true", help="只跑一轮(默认)")
+    ap.add_argument("--loop", action="store_true", help="循环跑")
+    ap.add_argument("--interval", type=int, default=600, help="循环间隔秒(默认 600=10min)")
+    ap.add_argument("--prune-hours", type=int, default=24,
+                    help="清理超过 N 小时未再出现的陈旧券(默认 24;0=不清理)")
+    args = ap.parse_args()
+
+    if args.loop:
+        print(f"循环模式: 每 {args.interval}s 一轮 (Ctrl-C 退出)")
+        while True:
+            try:
+                run_once(args.prune_hours)
+            except Exception as e:  # noqa: BLE001
+                print(f"[{datetime.now():%H:%M:%S}] 本轮异常: {type(e).__name__}: {e}")
+                _release_lock()
+            time.sleep(args.interval)
+    else:
+        run_once(args.prune_hours)
+
+
+if __name__ == "__main__":
+    main()

scripts/seed_invitee_avatar_test.py

@@ -0,0 +1,91 @@
+# -*- 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("  没有带头像的被邀请人?!")

tests/test_invite.py

@@ -0,0 +1,377 @@
+"""好友邀请测试:邀请码、绑定、双方发金币、幂等、自邀/无效码屏蔽、指纹兜底归因。
+
+用 sms mock 登录拿 token(同 test_welfare),再跑邀请闭环。
+"""
+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
+
+
+def _login(client, phone: str) -> str:
+    client.post("/api/v1/auth/sms/send", json={"phone": phone})
+    r = client.post("/api/v1/auth/sms/login", json={"phone": phone, "code": "123456"})
+    assert r.status_code == 200, r.text
+    return r.json()["access_token"]
+
+
+def _auth(token: str) -> dict[str, str]:
+    return {"Authorization": f"Bearer {token}"}
+
+
+def _coin_balance(client, token: str) -> int:
+    r = client.get("/api/v1/wallet/account", headers=_auth(token))
+    assert r.status_code == 200, r.text
+    return r.json()["coin_balance"]
+
+
+def _my_code(client, token: str) -> str:
+    r = client.get("/api/v1/invite/me", headers=_auth(token))
+    assert r.status_code == 200, r.text
+    return r.json()["invite_code"]
+
+
+def test_invite_me_returns_stable_code(client) -> None:
+    """/invite/me 返回邀请码 + 分享链接;同一用户多次取码稳定。"""
+    token = _login(client, "13800002001")
+    r = client.get("/api/v1/invite/me", headers=_auth(token))
+    assert r.status_code == 200, r.text
+    body = r.json()
+    assert body["invite_code"]                      # 非空
+    assert f"ref={body['invite_code']}" in body["share_url"]
+    assert body["invited_count"] == 0
+    assert body["coins_earned"] == 0
+    # 再取一次,码不变(懒生成 + 持久化)
+    assert _my_code(client, token) == body["invite_code"]
+
+
+def test_bind_flow_both_get_coins(client) -> None:
+    """B 用 A 的码绑定 → 双方各得 1 万金币;A 战绩 +1。"""
+    a = _login(client, "13800002002")
+    b = _login(client, "13800002003")
+    a_code = _my_code(client, a)
+
+    assert _coin_balance(client, a) == 0
+    assert _coin_balance(client, b) == 0
+
+    r = client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(b))
+    assert r.status_code == 200, r.text
+    res = r.json()
+    assert res["status"] == "success"
+    assert res["coins_awarded"] == INVITE_INVITEE_COINS
+
+    # 双方金币到账
+    assert _coin_balance(client, b) == INVITE_INVITEE_COINS
+    assert _coin_balance(client, a) == INVITE_INVITER_COINS
+
+    # A 的战绩:已邀 1 人,累计获得 = 邀请人那份
+    r = client.get("/api/v1/invite/me", headers=_auth(a))
+    assert r.json()["invited_count"] == 1
+    assert r.json()["coins_earned"] == INVITE_INVITER_COINS
+
+
+def test_bind_idempotent_no_double_reward(client) -> None:
+    """同一被邀请人二次绑定 → already_bound,不重复发奖。"""
+    a = _login(client, "13800002004")
+    b = _login(client, "13800002005")
+    a_code = _my_code(client, a)
+
+    r1 = client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(b))
+    assert r1.json()["status"] == "success"
+    bal_b = _coin_balance(client, b)
+    bal_a = _coin_balance(client, a)
+
+    # 再绑一次(甚至换个码也不行,已被绑过)
+    c = _login(client, "13800002006")
+    c_code = _my_code(client, c)
+    r2 = client.post("/api/v1/invite/bind", json={"invite_code": c_code}, headers=_auth(b))
+    assert r2.json()["status"] == "already_bound"
+    assert r2.json()["coins_awarded"] == 0
+
+    # 余额没变(没二次发奖),C 也没拿到邀请奖励
+    assert _coin_balance(client, b) == bal_b
+    assert _coin_balance(client, a) == bal_a
+    assert _coin_balance(client, c) == 0
+
+
+def test_self_invite_blocked(client) -> None:
+    """填自己的邀请码 → self_invite,不发奖。"""
+    a = _login(client, "13800002007")
+    a_code = _my_code(client, a)
+    r = client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(a))
+    assert r.status_code == 200, r.text
+    assert r.json()["status"] == "self_invite"
+    assert _coin_balance(client, a) == 0
+
+
+def test_invalid_code(client) -> None:
+    """无效邀请码 → invalid_code,不发奖。"""
+    b = _login(client, "13800002008")
+    r = client.post("/api/v1/invite/bind", json={"invite_code": "ZZZZZZ"}, headers=_auth(b))
+    assert r.status_code == 200, r.text
+    assert r.json()["status"] == "invalid_code"
+    assert _coin_balance(client, b) == 0
+
+
+def test_manual_channel_recorded(client) -> None:
+    """channel=manual 也能绑定(手动填码兜底路径)。"""
+    a = _login(client, "13800002009")
+    b = _login(client, "13800002010")
+    a_code = _my_code(client, a)
+    r = client.post(
+        "/api/v1/invite/bind",
+        json={"invite_code": a_code, "channel": "manual"},
+        headers=_auth(b),
+    )
+    assert r.status_code == 200, r.text
+    assert r.json()["status"] == "success"
+
+
+def test_invite_requires_auth(client) -> None:
+    """不带 token → 401。"""
+    assert client.get("/api/v1/invite/me").status_code == 401
+    assert client.post("/api/v1/invite/bind", json={"invite_code": "ABCDEF"}).status_code == 401
+
+
+def test_old_user_not_eligible(client) -> None:
+    """新用户闸:被邀请人注册超过窗口 → not_eligible,双方都不发奖。"""
+    a = _login(client, "13800002030")
+    a_code = _my_code(client, a)
+    b = _login(client, "13800002031")
+    # 把 b 的注册时间改成超出窗口 → 变"老用户"
+    with SessionLocal() as db:
+        u = get_user_by_phone(db, "13800002031")
+        assert u is not None
+        u.created_at = datetime.now(timezone.utc) - timedelta(hours=INVITE_NEW_USER_WINDOW_HOURS + 1)
+        db.commit()
+
+    r = client.post("/api/v1/invite/bind", json={"invite_code": a_code}, headers=_auth(b))
+    assert r.status_code == 200, r.text
+    assert r.json()["status"] == "not_eligible"
+    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