xinyouhe/fangke
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 访客列表站点归属显示与筛选

Browse Source 
Co-Authored-By: Claude Code <noreply@anthropic.com>
This commit is contained in:
浅念
2026-09-16 14:33:39 +08:00
parent 15ad3fb200
commit 58659b0ec9
4 changed files with 100 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/tracker/api/visitors.py
+17 -6
View File
@@ -1,8 +1,9 @@
"""访客列表/详情/跨天时间线/单会话接口（管理台）。
M1 单组织多站点：访客 API 不做 site 过滤参数（后台看全站访客流，站点维度在 Dashboard）。
M1 单组织多站点：访客列表支持 ?site= 可选过滤（缺省聚合全部站点），行内随带站点归属
（site_id/site_name）——多站点下分辨访客来自哪个站；访客数据本身已按站点隔离。
访客列表查询按 (site,-last_seen_at) 索引逐站扫描或全表 order_by——M1 规模（万级访客）可接受，
量级上来后按站点分片或引入 site 过滤即可（索引已就位）。
量级上来后按站点分片即可（索引已就位）。
"""
from datetime import datetime, time, timedelta
@@ -12,7 +13,7 @@ from rest_framework.response import Response
from rest_framework.views import APIView
from tracker.api.envelope import EnvelopeMixin, ok
from tracker.models import Event, VisitSession, Visitor
from tracker.models import Event, Site, VisitSession, Visitor
PAGE_SIZE = 20
TIMELINE_DEFAULT_DAYS = 30
@@ -36,6 +37,8 @@ def _row(visitor, last_session, online_cutoff):
"""列表/详情共用行字段。last_source 依赖最近会话（由调用方批量取好传入，防 N+1）。"""
return {
"visitor_id": visitor.visitor_id,
# 站点归属：visitor.site 需随行 select_related("site")，否则逐行多一条查询
"site_id": visitor.site.site_id, "site_name": visitor.site.name,
"country": visitor.country, "province": visitor.province, "city": visitor.city,
"device_type": visitor.device_type, "os": visitor.os,
"browser": visitor.browser, "language": visitor.language,
@@ -106,7 +109,7 @@ def _page_visitors(qs, request):
page = 1
page = max(1, page)
page_qs = _annotate(qs).order_by("-last_seen_at", "-pk")
page_qs = _annotate(qs).select_related("site").order_by("-last_seen_at", "-pk")
visitors = list(page_qs[(page - 1) * PAGE_SIZE: page * PAGE_SIZE])
latest = {s.pk: s for s in VisitSession.objects.filter(
pk__in=[v.latest_session_pk for v in visitors if v.latest_session_pk])}
@@ -163,13 +166,21 @@ def _merge_page_stay(events):
class VisitorListView(EnvelopeMixin, APIView):
def get(self, request):
rows, total, page = _page_visitors(Visitor.objects.all(), request)
qs = Visitor.objects.all()
sid = request.query_params.get("site") # 可选站点过滤，缺省聚合全部（与 dashboard 同款）
if sid:
site = Site.objects.filter(site_id=sid).first()
if not site:
return _not_found("site_not_found")
qs = qs.filter(site=site)
rows, total, page = _page_visitors(qs, request)
return ok({"list": rows, "total": total, "page": page})
class VisitorDetailView(EnvelopeMixin, APIView):
def get(self, request, visitor_id):
visitor = _annotate(Visitor.objects.filter(visitor_id=visitor_id)) \
visitor = _annotate(Visitor.objects.filter(visitor_id=visitor_id)
.select_related("site")) \
.order_by("-last_seen_at", "-pk").first()
if not visitor:
return _not_found("visitor_not_found")
server/tracker/tests/test_visitors.py
+33 -4
View File
@@ -74,10 +74,10 @@ def test_list_fields_and_default_bot_excluded(client, member_user):
assert d["total"] == 2 and d["page"] == 1 and len(d["list"]) == 2
assert [x["visitor_id"] for x in d["list"]] == ["v1", "v2"] # last_seen 倒序
row = d["list"][0]
assert set(row) == {"visitor_id", "country", "province", "city", "device_type", "os",
"browser", "language", "first_seen_at", "last_seen_at", "visit_count",
"active_days", "session_count", "total_stay_ms", "first_source",
"last_source", "online"}
assert set(row) == {"visitor_id", "site_id", "site_name", "country", "province", "city",
"device_type", "os", "browser", "language", "first_seen_at",
"last_seen_at", "visit_count", "active_days", "session_count",
"total_stay_ms", "first_source", "last_source", "online"}
assert row["country"] == "中国" and row["os"] == "Windows" and row["browser"] == "Chrome"
assert row["session_count"] == 2
assert row["total_stay_ms"] == 150000 # 120000+30000，有效停留口径
@@ -125,6 +125,34 @@ def test_list_filters_and_search(client, member_user):
assert ids(d) == ["old-visitor"] # last_seen 落在昨天
def test_list_site_fields_and_site_filter(client, member_user):
_auth(client, member_user)
site_a = Site.objects.create(name="站点A", domains=["a.com"])
site_b = Site.objects.create(name="站点B", domains=["b.com"])
_visitor(site_a, "va", last_seen=timezone.now())
_visitor(site_b, "vb", last_seen=timezone.now() - timedelta(hours=1))
d = client.get("/api/admin/visitors").json()["data"] # 缺省聚合全部站点
assert d["total"] == 2 and len(d["list"]) == 2
by_id = {x["visitor_id"]: x for x in d["list"]}
assert by_id["va"]["site_id"] == site_a.site_id and by_id["va"]["site_name"] == "站点A"
assert by_id["vb"]["site_id"] == site_b.site_id and by_id["vb"]["site_name"] == "站点B"
d = client.get("/api/admin/visitors", {"site": site_b.site_id}).json()["data"]
assert d["total"] == 1 and [x["visitor_id"] for x in d["list"]] == ["vb"] # 只剩本站访客
def test_list_site_not_found(client, member_user):
_auth(client, member_user)
site = Site.objects.create(name="s", domains=["a.com"])
_visitor(site, "v1", last_seen=timezone.now())
r = client.get("/api/admin/visitors", {"site": "site_nope"})
assert r.status_code == 404
body = r.json()
assert body["code"] == 404 and body["data"] is None and body["message"] == "site_not_found"
def test_list_pagination_and_order(client, member_user):
_auth(client, member_user)
site = Site.objects.create(name="s", domains=["a.com"])
@@ -153,6 +181,7 @@ def test_detail_shape(client, member_user):
r = client.get("/api/admin/visitors/v1")
assert r.status_code == 200
d = r.json()["data"]
assert d["site_id"] == site.site_id and d["site_name"] == "s" # 详情同样输出站点归属
assert d["screen"] == "1920x1080" and d["timezone_name"] == "Asia/Shanghai"
assert d["last_ip"] == "1.2.3.4" and d["first_utm"] == {"utm_source": "google"}
assert d["first_landing_path"] == "/landing" and d["first_referrer_domain"] == "google.com"