"use client"; import { useState, useEffect } from 'react'; import { format, subDays } from 'date-fns'; import { DateRangePicker } from '@/app/components/ui/DateRangePicker'; import TimeSeriesChart from '@/app/components/charts/TimeSeriesChart'; import GeoAnalytics from '@/app/components/analytics/GeoAnalytics'; import DevicePieCharts from '@/app/components/charts/DevicePieCharts'; import UtmAnalytics from '@/app/components/analytics/UtmAnalytics'; import { EventsSummary, TimeSeriesData, GeoData, DeviceAnalytics as DeviceAnalyticsType } from '@/app/api/types'; import { TeamSelector } from '@/app/components/ui/TeamSelector'; import { ProjectSelector } from '@/app/components/ui/ProjectSelector'; import { TagSelector } from '@/app/components/ui/TagSelector'; import { useSearchParams } from 'next/navigation'; import { useShortUrlStore } from '@/app/utils/store'; import { useRouter } from 'next/navigation'; // 事件类型定义 interface Event { event_id?: string; url_id: string; url: string; event_type: string; visitor_id: string; created_at: string; event_time?: string; referrer?: string; browser?: string; os?: string; device_type?: string; country?: string; city?: string; event_attributes?: string; link_attributes?: string; user_attributes?: string; link_label?: string; link_original_url?: string; team_name?: string; project_name?: string; link_id?: string; link_slug?: string; link_tags?: string; ip_address?: string; } // 格式化日期函数 const formatDate = (dateString: string | undefined) => { if (!dateString) return ''; try { return format(new Date(dateString), 'yyyy-MM-dd HH:mm:ss'); } catch { return dateString; } }; // 解析JSON字符串 const parseJsonSafely = (jsonString: string) => { if (!jsonString) return null; try { return JSON.parse(jsonString); } catch { return null; } }; // 获取用户可读名称 const getUserDisplayName = (user: Record | null) => { if (!user) return '-'; if (typeof user.full_name === 'string') return user.full_name; if (typeof user.name === 'string') return user.name; if (typeof user.email === 'string') return user.email; return '-'; }; // 提取链接和事件的重要信息 const extractEventInfo = (event: Event) => { // 解析事件属性 const eventAttrs = parseJsonSafely(event.event_attributes || '{}'); // 解析链接属性 const linkAttrs = parseJsonSafely(event.link_attributes || '{}'); // 解析用户属性 const userAttrs = parseJsonSafely(event.user_attributes || '{}'); // 解析标签信息 let tags: string[] = []; try { if (event.link_tags) { const parsedTags = JSON.parse(event.link_tags); if (Array.isArray(parsedTags)) { tags = parsedTags; } } } catch { // 解析失败则保持空数组 } return { eventTime: event.created_at || event.event_time, linkName: event.link_label || linkAttrs?.name || eventAttrs?.link_name || event.link_slug || '-', originalUrl: event.link_original_url || eventAttrs?.origin_url || '-', fullUrl: eventAttrs?.full_url || '-', eventType: event.event_type || '-', visitorId: event.visitor_id?.substring(0, 8) || '-', referrer: eventAttrs?.referrer || '-', ipAddress: event.ip_address || '-', location: event.country ? (event.city ? `${event.city}, ${event.country}` : event.country) : '-', device: event.device_type || '-', browser: event.browser || '-', os: event.os || '-', userInfo: getUserDisplayName(userAttrs), teamName: event.team_name || '-', projectName: event.project_name || '-', tags: tags }; }; export default function AnalyticsPage() { // 从 URL 获取查询参数 const searchParams = useSearchParams(); const shorturlParam = searchParams.get('shorturl'); // 使用 Zustand store const { selectedShortUrl, setSelectedShortUrl, clearSelectedShortUrl } = useShortUrlStore(); // 存储 shorturl 参数 const [selectedShortUrlString, setSelectedShortUrlString] = useState(null); // 从 API 加载短链接数据 useEffect(() => { // 处理 URL 参数 if (shorturlParam) { // 保存参数到状态 setSelectedShortUrlString(shorturlParam); // 如果 store 中没有选中的短链接或者 store 中的短链接与 URL 参数不匹配,则从 localStorage 更新 if (!selectedShortUrl || selectedShortUrl.shortUrl !== shorturlParam) { // 首先检查 localStorage 是否已有此数据 const localStorageData = localStorage.getItem('shorturl-storage'); if (localStorageData) { try { const parsedData = JSON.parse(localStorageData); if (parsedData.state?.selectedShortUrl && parsedData.state.selectedShortUrl.shortUrl === shorturlParam) { // 数据已存在于 localStorage 且匹配 URL 参数,无需操作 return; } } catch (e) { console.error('Error parsing localStorage data:', e); } } // 如果 localStorage 中没有匹配的数据,则从 API 获取 const fetchShortUrlData = async () => { try { // 构建带有 URL 参数的查询字符串 const encodedUrl = encodeURIComponent(shorturlParam); const apiUrl = `/api/shortlinks/byUrl?url=${encodedUrl}`; console.log('Fetching shorturl data from:', apiUrl); // 使用 API 端点获取短链接数据 const response = await fetch(apiUrl); if (!response.ok) { console.error('Failed to fetch shorturl data:', response.statusText); return; } const result = await response.json(); // 如果找到匹配的短链接数据 if (result.success && result.data) { console.log('Retrieved shortlink data:', result.data); // 设置到 Zustand store (会自动更新到 localStorage) setSelectedShortUrl(result.data); } } catch (error) { console.error('Error fetching shorturl data:', error); } }; fetchShortUrlData(); } } else { // 如果 URL 没有参数,清除文本状态 setSelectedShortUrlString(null); // 如果 URL 没有参数但 store 中有数据,我们保持 store 中的数据不变 // 这样用户在清除 URL 参数后仍能看到之前选择的短链接数据 } }, [shorturlParam, selectedShortUrl, setSelectedShortUrl]); // 默认日期范围为最近7天 const today = new Date(); const [dateRange, setDateRange] = useState({ from: subDays(today, 7), // 7天前 to: today // 今天 }); // 添加团队选择状态 - 使用数组支持多选 const [selectedTeamIds, setSelectedTeamIds] = useState([]); // 添加项目选择状态 - 使用数组支持多选 const [selectedProjectIds, setSelectedProjectIds] = useState([]); // 添加标签名称状态 - 用于在UI中显示和API请求 const [selectedTagNames, setSelectedTagNames] = useState([]); // 添加分页状态 const [currentPage, setCurrentPage] = useState(1); const [pageSize, setPageSize] = useState(10); const [totalEvents, setTotalEvents] = useState(0); const [loading, setLoading] = useState(true); const [error, setError] = useState(null); const [summary, setSummary] = useState(null); const [timeSeriesData, setTimeSeriesData] = useState([]); const [geoData, setGeoData] = useState([]); const [deviceData, setDeviceData] = useState(null); const [events, setEvents] = useState([]); const router = useRouter(); // 添加 Snackbar 状态 const [isSnackbarOpen, setIsSnackbarOpen] = useState(false); useEffect(() => { const fetchData = async () => { setLoading(true); setError(null); try { const startTime = format(dateRange.from, "yyyy-MM-dd'T'HH:mm:ss'Z'"); const endTime = format(dateRange.to, "yyyy-MM-dd'T'HH:mm:ss'Z'"); // 构建基础URL和查询参数 const baseUrl = '/api/events'; const params = new URLSearchParams({ startTime, endTime, page: currentPage.toString(), pageSize: pageSize.toString() }); // Add linkId parameter if a shorturl is selected if (selectedShortUrl && selectedShortUrl.id) { params.append('linkId', selectedShortUrl.id); console.log('Adding linkId to requests:', selectedShortUrl.id); } // 添加团队ID参数 - 支持多个团队 if (selectedTeamIds.length > 0) { selectedTeamIds.forEach(teamId => { params.append('teamId', teamId); }); } // 添加项目ID参数 - 支持多个项目 if (selectedProjectIds.length > 0) { selectedProjectIds.forEach(projectId => { params.append('projectId', projectId); }); } // 添加标签名称参数 - 支持多个标签 if (selectedTagNames.length > 0) { selectedTagNames.forEach(tagName => { params.append('tagName', tagName); }); } // 并行获取所有数据 const [summaryRes, timeSeriesRes, geoRes, deviceRes, eventsRes] = await Promise.all([ fetch(`${baseUrl}/summary?${params.toString()}`), fetch(`${baseUrl}/time-series?${params.toString()}`), fetch(`${baseUrl}/geo?${params.toString()}`), fetch(`${baseUrl}/devices?${params.toString()}`), fetch(`${baseUrl}?${params.toString()}`) ]); const [summaryData, timeSeriesData, geoData, deviceData, eventsData] = await Promise.all([ summaryRes.json(), timeSeriesRes.json(), geoRes.json(), deviceRes.json(), eventsRes.json() ]); if (!summaryRes.ok) throw new Error(summaryData.error || 'Failed to fetch summary data'); if (!timeSeriesRes.ok) throw new Error(timeSeriesData.error || 'Failed to fetch time series data'); if (!geoRes.ok) throw new Error(geoData.error || 'Failed to fetch geo data'); if (!deviceRes.ok) throw new Error(deviceData.error || 'Failed to fetch device data'); if (!eventsRes.ok) throw new Error(eventsData.error || 'Failed to fetch events data'); setSummary(summaryData.data); setTimeSeriesData(timeSeriesData.data); setGeoData(geoData.data); setDeviceData(deviceData.data); setEvents(eventsData.data || []); // 设置总事件数量用于分页 if (eventsData.meta) { // 确保将total转换为数字,无论它是字符串还是数字 const totalCount = parseInt(String(eventsData.meta.total), 10); if (!isNaN(totalCount)) { setTotalEvents(totalCount); } } } catch (err) { setError(err instanceof Error ? err.message : 'An error occurred while fetching data'); } finally { setLoading(false); } }; fetchData(); }, [dateRange, selectedTeamIds, selectedProjectIds, selectedTagNames, currentPage, pageSize, selectedShortUrl]); // Function to clear the shorturl filter const handleClearShortUrlFilter = () => { // Clear the shorturl from Zustand store clearSelectedShortUrl(); // Create a new URL object to manipulate the current URL const currentUrl = new URL(window.location.href); // Remove the shorturl parameter currentUrl.searchParams.delete('shorturl'); // Get all other parameters and preserve them const newUrl = `/analytics${currentUrl.search}`; // Navigate to the updated URL router.push(newUrl); // Show a message to the user setIsSnackbarOpen(true); }; if (loading) { return (
); } if (error) { return (
{error}
); } return (
{/* Notification Snackbar */} {isSnackbarOpen && (
URL filter cleared
)}

Analytics Dashboard

{/* 如果有选定的 shorturl,可以显示一个提示,显示更多详细信息 */} {selectedShortUrl && (
{selectedShortUrl.title || 'Untitled'} - {selectedShortUrl.shortUrl}
Analytics filtered for this short URL only {selectedShortUrl.id && (ID: {selectedShortUrl.id})}
{selectedShortUrl.tags && selectedShortUrl.tags.length > 0 && (
{selectedShortUrl.tags.map((tag, index) => ( {tag} ))}
)}
)} {/* 如果只有 URL 参数但没有完整数据,则显示简单提示 */} {selectedShortUrlString && !selectedShortUrl && (
Filtered by Short URL: {selectedShortUrlString}
)} {/* 只在没有选中 shorturl 时显示筛选选择器 */} {!selectedShortUrl && ( <> { const newTeamIds = Array.isArray(value) ? value : [value]; // Check if team selection has changed if (JSON.stringify(newTeamIds) !== JSON.stringify(selectedTeamIds)) { // Clear project selection when team changes setSelectedProjectIds([]); // Update team selection setSelectedTeamIds(newTeamIds); } }} className="w-[250px]" multiple={true} /> setSelectedProjectIds(Array.isArray(value) ? value : [value])} className="w-[250px]" multiple={true} teamIds={selectedTeamIds.length > 0 ? selectedTeamIds : undefined} /> { // TagSelector返回的是标签名称 if (Array.isArray(value)) { setSelectedTagNames(value); } else { setSelectedTagNames(value ? [value] : []); } // 我们需要将标签名称映射回ID,但由于TagSelector内部已经做了处理 // 这里不需要额外的映射代码,selectedTagNames存储名称即可 }} className="w-[250px]" multiple={true} teamIds={selectedTeamIds.length > 0 ? selectedTeamIds : undefined} /> )}
{/* 仅在未选中 shorturl 且有选择的筛选条件时显示筛选条件标签 */} {!selectedShortUrl && ( <> {/* 显示团队选择信息 */} {selectedTeamIds.length > 0 && (
{selectedTeamIds.length === 1 ? 'Team filter:' : 'Teams filter:'}
{selectedTeamIds.map(teamId => ( {teamId} ))} {selectedTeamIds.length > 0 && ( )}
)} {/* 显示项目选择信息 */} {selectedProjectIds.length > 0 && (
{selectedProjectIds.length === 1 ? 'Project filter:' : 'Projects filter:'}
{selectedProjectIds.map(projectId => ( {projectId} ))} {selectedProjectIds.length > 0 && ( )}
)} {/* 显示标签选择信息 */} {selectedTagNames.length > 0 && (
{selectedTagNames.length === 1 ? 'Tag filter:' : 'Tags filter:'}
{selectedTagNames.map(tagName => ( {tagName} ))} {selectedTagNames.length > 0 && ( )}
)} )} {/* 仪表板内容 - 现在放在事件列表之后 */} <> {summary && (

Total Events

{typeof summary.totalEvents === 'number' ? summary.totalEvents.toLocaleString() : summary.totalEvents}

Unique Visitors

{typeof summary.uniqueVisitors === 'number' ? summary.uniqueVisitors.toLocaleString() : summary.uniqueVisitors}

Total Conversions

{typeof summary.totalConversions === 'number' ? summary.totalConversions.toLocaleString() : summary.totalConversions}

Avg. Time Spent

{summary.averageTimeSpent?.toFixed(1) || '0'}s

)} {/* 时间序列图表 */} {timeSeriesData && timeSeriesData.length > 0 && (

Traffic Over Time

)} {/* 设备分析图表 */} {deviceData && (

Device Analytics

)} {/* 地理分析 */} {geoData && geoData.length > 0 && (

Geographic Distribution

)} {/* UTM 参数分析 */}

UTM Parameters Analysis

Recent Events

{events.map((event, index) => { const info = extractEventInfo(event); return ( ); })}
Time Link Name Original URL Full URL Event Type Tags User Team/Project IP/Location Device Info
{formatDate(info.eventTime)} {info.linkName}
ID: {event.link_id?.substring(0, 8) || '-'}
{info.originalUrl} {info.fullUrl} {info.eventType}
{info.tags && info.tags.length > 0 ? ( info.tags.map((tag, idx) => ( {tag} )) ) : ( - )}
{info.userInfo}
{info.visitorId}...
{info.teamName}
{info.projectName}
IP: {info.ipAddress} Location: {info.location}
Device: {info.device} Browser: {info.browser} OS: {info.os}
{/* 表格为空状态 */} {!loading && events.length === 0 && (
No events found
)} {/* 分页控件 */} {!loading && events.length > 0 && (

Showing {events.length > 0 ? ((currentPage - 1) * pageSize) + 1 : 0} to {events.length > 0 ? ((currentPage - 1) * pageSize) + events.length : 0} of{' '} {totalEvents} results

{/* 添加直接跳转到指定页的输入框 */}
Go to: { const page = parseInt(e.target.value); if (!isNaN(page) && page >= 1 && page <= Math.ceil(totalEvents / pageSize)) { setCurrentPage(page); } }} onKeyDown={(e) => { if (e.key === 'Enter') { const input = e.target as HTMLInputElement; const page = parseInt(input.value); if (!isNaN(page) && page >= 1 && page <= Math.ceil(totalEvents / pageSize)) { setCurrentPage(page); } } }} className="w-16 px-3 py-1 border border-gray-300 rounded-md text-sm" /> of {Math.max(1, Math.ceil(totalEvents / pageSize))}
)}
); }