vitalitymailg/promote
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

interaction api

Browse Source
This commit is contained in:
William Tso
2025-03-14 22:31:45 +08:00
parent bd1a5ce384
commit d0f2ab0620
4 changed files with 422 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
backend/src/controllers/analyticsController.ts
View File

@@ -825,6 +825,91 @@ export class AnalyticsController {
}, 500);
}
}
/**
* 获取用户互动时间分析数据
* 返回按小时统计的用户互动数量和分布
*
* @param c Hono Context
* @returns Response with interaction time analysis data
*/
async getInteractionTimeAnalysis(c: Context) {
const requestId = `req_${Date.now()}_${Math.random().toString(36).substring(2, 10)}`;
const startTime = Date.now();
try {
// 获取查询参数
const timeRange = c.req.query('timeRange') || '30'; // 默认30天
const projectId = c.req.query('projectId'); // 可选项目过滤
const platform = c.req.query('platform'); // 可选平台过滤
const eventType = c.req.query('eventType') || 'all'; // 可选事件类型过滤
logger.info(`[${requestId}] Interaction time analysis request received`, {
timeRange,
projectId,
platform,
eventType,
userAgent: c.req.header('user-agent'),
ip: c.req.header('x-forwarded-for') || 'unknown'
});
// 验证时间范围
if (!['7', '30', '90'].includes(timeRange)) {
logger.warn(`[${requestId}] Invalid timeRange: ${timeRange}`);
return c.json({
success: false,
error: 'Invalid timeRange. Must be 7, 30, or 90.'
}, 400);
}
// 验证事件类型
const validEventTypes = ['all', 'comment', 'like', 'view', 'share', 'follow'];
if (!validEventTypes.includes(eventType)) {
logger.warn(`[${requestId}] Invalid eventType: ${eventType}`);
return c.json({
success: false,
error: `Invalid eventType. Must be one of: ${validEventTypes.join(', ')}`
}, 400);
}
// 获取互动时间分析数据
const data = await analyticsService.getInteractionTimeAnalysis(
parseInt(timeRange, 10),
projectId,
platform,
eventType
);
// 返回成功响应
const duration = Date.now() - startTime;
logger.info(`[${requestId}] Interaction time analysis response sent successfully`, {
duration,
total: data.total,
peak_hour: data.peak_hour
});
return c.json({
success: true,
data: data.data,
metadata: {
total: data.total,
peak_hour: data.peak_hour,
lowest_hour: data.lowest_hour
}
});
} catch (error) {
// 记录错误
const duration = Date.now() - startTime;
logger.error(`[${requestId}] Error fetching interaction time analysis (${duration}ms)`, error);
// 返回错误响应
return c.json({
success: false,
error: 'Failed to fetch interaction time analysis data',
message: error instanceof Error ? error.message : 'Unknown error'
}, 500);
}
}
}
// Export singleton instance

3
backend/src/routes/analytics.ts
View File

@@ -53,4 +53,7 @@ analyticsRouter.get('/moderation-status', (c) => analyticsController.getModerati
// Add hot keywords route
analyticsRouter.get('/hot-keywords', (c) => analyticsController.getHotKeywords(c));
// Add interaction time analysis route
analyticsRouter.get('/interaction-time', (c) => analyticsController.getInteractionTimeAnalysis(c));
export default analyticsRouter;

192
backend/src/services/analyticsService.ts
View File

@@ -225,6 +225,25 @@ export interface HotKeywordsResponse {
total: number; // 总数
}
/**
* 用户互动时间分布数据项
*/
export interface InteractionTimeItem {
hour: number; // 小时 (0-23)
count: number; // 互动数量
percentage: number; // 占总数百分比
}
/**
* 用户互动时间分析响应
*/
export interface InteractionTimeResponse {
data: InteractionTimeItem[]; // 按小时统计的互动数据
peak_hour: number; // 峰值时段
lowest_hour: number; // 最低时段
total: number; // 总互动数
}
/**
* Analytics service for KOL performance data
*/
@@ -1911,6 +1930,179 @@ export class AnalyticsService {
};
}
}
/**
* 获取用户互动时间分析数据
* @param timeRange 时间范围（天数）
* @param projectId 可选项目ID
* @param platform 可选平台
* @param eventType 互动事件类型
* @returns 互动时间分析数据
*/
async getInteractionTimeAnalysis(
timeRange: number,
projectId?: string,
platform?: string,
eventType: string = 'all'
): Promise<InteractionTimeResponse> {
const startTime = Date.now();
logger.info('Fetching interaction time analysis data', { timeRange, projectId, platform, eventType });
try {
// 计算时间范围
const startDate = new Date();
startDate.setDate(startDate.getDate() - timeRange);
const formattedStartDate = this.formatDateForClickhouse(startDate);
// 构建查询条件
const filters = [`event_time >= '${formattedStartDate}'`];
if (projectId) {
filters.push(`project_id = '${projectId}'`);
}
if (platform) {
filters.push(`platform = '${platform}'`);
}
// 根据事件类型过滤
if (eventType !== 'all') {
filters.push(`event_type = '${eventType}'`);
}
const whereClause = filters.length > 0 ? `WHERE ${filters.join(' AND ')}` : '';
// 按小时分组查询互动数量
const query = `
SELECT
toHour(event_time) AS hour,
count() AS count
FROM
events
${whereClause}
GROUP BY
hour
ORDER BY
hour ASC
`;
logger.debug('Executing ClickHouse query for interaction time analysis', {
query: query.replace(/\n\s+/g, ' ').trim()
});
// 执行查询
const result = await this.executeClickhouseQuery(query);
// 处理结果，确保所有24小时都有数据
const hourlyData: { [hour: number]: number } = {};
// 初始化所有小时为0
for (let i = 0; i < 24; i++) {
hourlyData[i] = 0;
}
// 填充查询结果
result.forEach(item => {
hourlyData[item.hour] = item.count;
});
// 计算总数和百分比
const total = Object.values(hourlyData).reduce((sum, count) => sum + count, 0);
// 找出峰值和最低时段
let peakHour = 0;
let lowestHour = 0;
let maxCount = 0;
let minCount = Number.MAX_SAFE_INTEGER;
Object.entries(hourlyData).forEach(([hour, count]) => {
const hourNum = parseInt(hour, 10);
if (count > maxCount) {
maxCount = count;
peakHour = hourNum;
}
if (count < minCount) {
minCount = count;
lowestHour = hourNum;
}
});
// 格式化响应数据
const data: InteractionTimeItem[] = Object.entries(hourlyData).map(([hour, count]) => ({
hour: parseInt(hour, 10),
count,
percentage: total > 0 ? parseFloat(((count / total) * 100).toFixed(1)) : 0
}));
const response: InteractionTimeResponse = {
data,
peak_hour: peakHour,
lowest_hour: lowestHour,
total
};
const duration = Date.now() - startTime;
logger.info('Interaction time analysis data fetched successfully', {
duration,
total,
peak_hour: peakHour
});
return response;
} catch (error) {
const duration = Date.now() - startTime;
logger.error(`Error in getInteractionTimeAnalysis (${duration}ms)`, error);
// 发生错误时返回模拟数据
const mockData: InteractionTimeItem[] = Array.from({ length: 24 }, (_, i) => {
// 创建合理的模拟数据分布，早晨和晚上的互动较多
let count = 0;
if (i >= 7 && i <= 10) { // 早晨
count = Math.floor(Math.random() * 100) + 150;
} else if (i >= 17 && i <= 22) { // 晚上
count = Math.floor(Math.random() * 100) + 200;
} else { // 其他时间
count = Math.floor(Math.random() * 100) + 50;
}
return {
hour: i,
count,
percentage: 0 // 暂时设为0，稍后计算
};
});
// 计算总数和百分比
const total = mockData.reduce((sum, item) => sum + item.count, 0);
mockData.forEach(item => {
item.percentage = parseFloat(((item.count / total) * 100).toFixed(1));
});
// 找出峰值和最低时段
let peakHour = 0;
let lowestHour = 0;
let maxCount = 0;
let minCount = Number.MAX_SAFE_INTEGER;
mockData.forEach(item => {
if (item.count > maxCount) {
maxCount = item.count;
peakHour = item.hour;
}
if (item.count < minCount) {
minCount = item.count;
lowestHour = item.hour;
}
});
return {
data: mockData,
peak_hour: peakHour,
lowest_hour: lowestHour,
total
};
}
}
}
// Export singleton instance

142
backend/src/swagger/index.ts
View File

@@ -3320,6 +3320,148 @@ export const openAPISpec = {
}
}
},
'/api/analytics/interaction-time': {
get: {
summary: '获取用户互动时间分析',
description: '返回按小时统计的用户互动数量和分布，帮助了解用户最活跃的时间段',
tags: ['Analytics'],
parameters: [
{
name: 'timeRange',
in: 'query',
description: '时间范围（天）',
schema: {
type: 'integer',
enum: [7, 30, 90],
default: 30
}
},
{
name: 'projectId',
in: 'query',
description: '项目ID（可选）',
schema: {
type: 'string'
}
},
{
name: 'platform',
in: 'query',
description: '平台（可选）',
schema: {
type: 'string',
enum: ['weibo', 'xiaohongshu', 'douyin', 'bilibili']
}
},
{
name: 'eventType',
in: 'query',
description: '互动事件类型',
schema: {
type: 'string',
enum: ['all', 'comment', 'like', 'view', 'share', 'follow'],
default: 'all'
}
}
],
responses: {
'200': {
description: '成功获取互动时间分析数据',
content: {
'application/json': {
schema: {
type: 'object',
properties: {
success: {
type: 'boolean',
example: true
},
data: {
type: 'array',
items: {
type: 'object',
properties: {
hour: {
type: 'integer',
example: 20
},
count: {
type: 'integer',
example: 256
},
percentage: {
type: 'number',
format: 'float',
example: 15.2
}
}
}
},
metadata: {
type: 'object',
properties: {
total: {
type: 'integer',
example: 1680
},
peak_hour: {
type: 'integer',
example: 20
},
lowest_hour: {
type: 'integer',
example: 4
}
}
}
}
}
}
}
},
'400': {
description: '请求参数错误',
content: {
'application/json': {
schema: {
type: 'object',
properties: {
success: {
type: 'boolean',
example: false
},
error: {
type: 'string',
example: 'Invalid timeRange. Must be 7, 30, or 90.'
}
}
}
}
}
},
'500': {
description: '服务器错误',
content: {
'application/json': {
schema: {
type: 'object',
properties: {
success: {
type: 'boolean',
example: false
},
error: {
type: 'string',
example: 'Failed to fetch interaction time analysis data'
}
}
}
}
}
}
}
}
},
},
components: {
schemas: {