Skip to content

[25.01.16 / TASK-271] Hotfix - SVG Badge API 통계값 오류 해결 및 캐싱 적용 #50

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Jihyun3478 merged 7 commits into from
Jan 18, 2026
Merged

[25.01.16 / TASK-271] Hotfix - SVG Badge API 통계값 오류 해결 및 캐싱 적용 #50

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
3e2f958
fix: 배지 API 데이터 정합성 오류 수정
Jihyun3478 Jan 15, 2026
31a6024
feat: 배지 API 캐싱 및 쿼리 최적화
Jihyun3478 Jan 16, 2026
edcd83b
refactor: 사용하지 않는 import 제거
Jihyun3478 Jan 16, 2026
e5e594a
style: 프레티어 적용
Jihyun3478 Jan 16, 2026
1891c05
refactor: TTL 관련 주석 추가
Jihyun3478 Jan 16, 2026
c290171
refactor: badge 쿼리 빌더 함수 분리 및 COALESCE 표현 통일
Jihyun3478 Jan 16, 2026
44a9998
fix: 배지 API 레디스 풀백 패턴 적용
Jihyun3478 Jan 16, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
165 changes: 86 additions & 79 deletions src/repositories/totalStats.repository.ts
View file
Open in desktop
Comment thread
Jihyun3478 marked this conversation as resolved.
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import { Pool } from 'pg';
import logger from '@/configs/logger.config';
import { DBError } from '@/exception';
import { TotalStatsType } from '@/types';
import { getCurrentKSTDateString, getKSTDateStringWithOffset } from '@/utils/date.util';
import { getKSTDateStringWithOffset } from '@/utils/date.util';

interface RawStatsResult {
date: string;
Expand Down Expand Up @@ -110,46 +110,9 @@ export class TotalStatsRepository {
async getUserBadgeStats(username: string, dateRange: number = 30) {
try {
const pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
const nowDateKST =
new Date().getUTCHours() === 15 ? getKSTDateStringWithOffset(-24 * 60) : getCurrentKSTDateString();
const query = buildBadgeStatsQuery();

const query = `
WITH
today_stats AS (
Comment thread
Jihyun3478 marked this conversation as resolved.
SELECT DISTINCT ON (post_id)
post_id,
daily_view_count AS today_view,
daily_like_count AS today_like
FROM posts_postdailystatistics
WHERE date = $2
ORDER BY post_id, date DESC
),
start_stats AS (
SELECT DISTINCT ON (post_id)
post_id,
daily_view_count AS start_view,
daily_like_count AS start_like
FROM posts_postdailystatistics
WHERE date = $3
ORDER BY post_id, date DESC
)
SELECT
u.username,
COALESCE(SUM(ts.today_view), 0) AS total_views,
COALESCE(SUM(ts.today_like), 0) AS total_likes,
COUNT(DISTINCT CASE WHEN p.is_active = true THEN p.id END) AS total_posts,
SUM(COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, 0)) AS view_diff,
SUM(COALESCE(ts.today_like, 0) - COALESCE(ss.start_like, 0)) AS like_diff,
COUNT(DISTINCT CASE WHEN p.released_at >= $3 AND p.is_active = true THEN p.id END) AS post_diff
FROM users_user u
LEFT JOIN posts_post p ON p.user_id = u.id
LEFT JOIN today_stats ts ON ts.post_id = p.id
LEFT JOIN start_stats ss ON ss.post_id = p.id
WHERE u.username = $1
GROUP BY u.username
`;

const result = await this.pool.query(query, [username, nowDateKST, pastDateKST]);
const result = await this.pool.query(query, [username, pastDateKST]);
return result.rows[0] || null;
} catch (error) {
logger.error('TotalStatsRepository getUserBadgeStats error:', error);
Expand All @@ -160,46 +123,9 @@ export class TotalStatsRepository {
async getUserRecentPosts(username: string, dateRange: number = 30, limit: number = 4) {
try {
const pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
const nowDateKST =
new Date().getUTCHours() === 15 ? getKSTDateStringWithOffset(-24 * 60) : getCurrentKSTDateString();
const query = buildRecentPostsQuery();

const query = `
WITH
today_stats AS (
SELECT DISTINCT ON (post_id)
post_id,
daily_view_count AS today_view,
daily_like_count AS today_like
FROM posts_postdailystatistics
WHERE date = $3
ORDER BY post_id, date DESC
),
start_stats AS (
SELECT DISTINCT ON (post_id)
post_id,
daily_view_count AS start_view,
daily_like_count AS start_like
FROM posts_postdailystatistics
WHERE date = $4
ORDER BY post_id, date DESC
)
SELECT
p.title,
p.released_at,
COALESCE(ts.today_view, 0) AS today_view,
COALESCE(ts.today_like, 0) AS today_like,
(COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, 0)) AS view_diff
FROM posts_post p
JOIN users_user u ON u.id = p.user_id
LEFT JOIN today_stats ts ON ts.post_id = p.id
LEFT JOIN start_stats ss ON ss.post_id = p.id
WHERE u.username = $1
AND p.is_active = true
ORDER BY p.released_at DESC
LIMIT $2
`;

const result = await this.pool.query(query, [username, limit, nowDateKST, pastDateKST]);
const result = await this.pool.query(query, [username, limit, pastDateKST]);
return result.rows;
} catch (error) {
logger.error('TotalStatsRepository getUserRecentPosts error:', error);
Expand Down Expand Up @@ -231,3 +157,84 @@ export class TotalStatsRepository {
}
}
}

function buildUserPostsCTE(includeTitle: boolean = false, includeLimit: boolean = false): string {
const titleColumn = includeTitle ? ', p.title' : '';
const limitClause = includeLimit ? 'ORDER BY p.released_at DESC\n LIMIT $2' : '';

return `
user_posts AS (
SELECT p.id${titleColumn}, p.released_at
FROM posts_post p
INNER JOIN users_user u ON u.id = p.user_id
WHERE u.username = $1 AND p.is_active = true
${limitClause}
)`;
}

function buildLatestStatsCTE(): string {
return `
latest_stats AS (
SELECT DISTINCT ON (pds.post_id)
pds.post_id,
pds.daily_view_count AS total_view,
pds.daily_like_count AS total_like
FROM posts_postdailystatistics pds
INNER JOIN user_posts up ON up.id = pds.post_id
ORDER BY pds.post_id, pds.date DESC
)`;
}

function buildStartStatsCTE(includeLike: boolean = true, paramIndex: number = 2): string {
const likeColumn = includeLike ? ',\n pds.daily_like_count AS start_like' : '';

return `
start_stats AS (
SELECT DISTINCT ON (pds.post_id)
pds.post_id,
pds.daily_view_count AS start_view${likeColumn}
FROM posts_postdailystatistics pds
INNER JOIN user_posts up ON up.id = pds.post_id
WHERE pds.date <= $${paramIndex}
ORDER BY pds.post_id, pds.date DESC
)`;
}

function buildBadgeStatsQuery(): string {
return `
WITH
${buildUserPostsCTE(false, false)},
${buildLatestStatsCTE()},
${buildStartStatsCTE(true, 2)}
SELECT
$1 AS username,
COALESCE(SUM(ls.total_view), 0) AS total_views,
COALESCE(SUM(ls.total_like), 0) AS total_likes,
COUNT(up.id) AS total_posts,
COALESCE(SUM(ls.total_view - COALESCE(ss.start_view, 0)), 0) AS view_diff,
COALESCE(SUM(ls.total_like - COALESCE(ss.start_like, 0)), 0) AS like_diff,
COUNT(CASE WHEN up.released_at >= $2 THEN 1 END) AS post_diff
FROM user_posts up
LEFT JOIN latest_stats ls ON ls.post_id = up.id
LEFT JOIN start_stats ss ON ss.post_id = up.id
`;
}

function buildRecentPostsQuery(): string {
return `
WITH
${buildUserPostsCTE(true, true)},
${buildLatestStatsCTE()},
${buildStartStatsCTE(false, 3)}
SELECT
up.title,
up.released_at,
COALESCE(ls.total_view, 0) AS today_view,
COALESCE(ls.total_like, 0) AS today_like,
ls.total_view - COALESCE(ss.start_view, 0) AS view_diff
FROM user_posts up
LEFT JOIN latest_stats ls ON ls.post_id = up.id
LEFT JOIN start_stats ss ON ss.post_id = up.id
ORDER BY up.released_at DESC
`;
}
25 changes: 24 additions & 1 deletion src/services/totalStats.service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@ const safeNumber = (value: string | number | null | undefined, defaultValue: num

const BADGE_DATE_RANGE = 30;

export const BADGE_CACHE_TTL = 60 * 10; // 뱃지 캐시 TTL 10분

export class TotalStatsService {
private readonly STATS_REFRESH_INTERVAL = 15 * 60 * 1000; // 15분 (밀리초)
private readonly MAIN_QUEUE_KEY = 'stats-refresh';
Expand Down Expand Up @@ -47,6 +49,19 @@ export class TotalStatsService {
}

async getBadgeData(username: string, type: 'default' | 'simple' = 'default'): Promise<BadgeData> {
Comment thread
Jihyun3478 marked this conversation as resolved.
const cacheKey = `badge:${username}:${type}`;

try {
const cached = await cache.get<BadgeData>(cacheKey);
if (cached) {
logger.info(`[Cache HIT] ${cacheKey}`);
return cached;
}
logger.info(`[Cache MISS] ${cacheKey}`);
} catch (cacheError) {
logger.warn(`[Cache Error] Failed to get cache for ${cacheKey}:`, cacheError);
}

try {
const userStats = await this.totalStatsRepo.getUserBadgeStats(username, BADGE_DATE_RANGE);

Expand All @@ -57,7 +72,7 @@ export class TotalStatsService {
const recentPosts =
type === 'default' ? await this.totalStatsRepo.getUserRecentPosts(username, BADGE_DATE_RANGE, 4) : [];

return {
const result: BadgeData = {
user: {
username: userStats.username,
totalViews: safeNumber(userStats.total_views),
Expand All @@ -75,6 +90,14 @@ export class TotalStatsService {
viewDiff: safeNumber(post.view_diff),
})),
};

try {
await cache.set(cacheKey, result, BADGE_CACHE_TTL);
} catch (cacheSetError) {
logger.warn(`[Cache Error] Failed to set cache for ${cacheKey}:`, cacheSetError);
}

return result;
} catch (error) {
logger.error('TotalStatsService getBadgeData error: ', error);
throw error;
Expand Down