Merge pull request #39 from 9git9git/SCRUM-140-BE-분석-페이지-서비스-API-개발

Scrum 140 be 분석 페이지 서비스 api 개발

Author: GideokKim

app/api/v1/endpoints/character.py

@@ -100,7 +100,7 @@ async def delete_character(
 # 서비스 로직
 
 
-@router.get("/characters", response_model=ResponseBase[List[CharacterResponse]])
+@router.get("/", response_model=ResponseBase[List[CharacterResponse]])
 async def get_user_character_collection(
     user_id: UUID,
     db: AsyncSession = Depends(get_db),

app/api/v1/endpoints/chart.py

@@ -0,0 +1,49 @@
+from fastapi import APIRouter, Depends, HTTPException, Query, status
+from sqlalchemy.ext.asyncio import AsyncSession
+from uuid import UUID
+from typing import List
+
+from app.db.session import get_db
+from app.services.chart import get_daily_achievement, get_monthly_achievement
+from app.schemas.chart import DailyAchievementResponse, MonthlyAchievementResponse
+from app.schemas.base import ResponseBase
+
+router = APIRouter()
+
+
+@router.get("/chart/daily", response_model=ResponseBase[List[DailyAchievementResponse]])
+async def get_daily_chart_data(
+    user_id: UUID,
+    year: int = Query(..., description="연도 기준 필터 (예: 2025)"),
+    db: AsyncSession = Depends(get_db),
+) -> ResponseBase[List[DailyAchievementResponse]]:
+    try:
+        data = await get_daily_achievement(db, user_id=user_id, year=year)
+        return ResponseBase(status_code=status.HTTP_200_OK, data=data)
+    except HTTPException as e:
+        return ResponseBase(status_code=e.status_code, error=e.detail)
+    except Exception as e:
+        return ResponseBase(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            error="일별 차트 데이터를 가져오는 중 오류가 발생했습니다.",
+        )
+
+
+@router.get(
+    "/chart/monthly", response_model=ResponseBase[List[MonthlyAchievementResponse]]
+)
+async def get_monthly_chart_data(
+    user_id: UUID,
+    year: int = Query(..., description="연도 기준 필터 (예: 2025)"),
+    db: AsyncSession = Depends(get_db),
+) -> ResponseBase[List[MonthlyAchievementResponse]]:
+    try:
+        data = await get_monthly_achievement(db, user_id=user_id, year=year)
+        return ResponseBase(status_code=status.HTTP_200_OK, data=data)
+    except HTTPException as e:
+        return ResponseBase(status_code=e.status_code, error=e.detail)
+    except Exception as e:
+        return ResponseBase(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            error="월별 차트 데이터를 가져오는 중 오류가 발생했습니다.",
+        )

app/api/v1/router.py

@@ -16,6 +16,7 @@
     todo,
     main,
     analyze,
+    chart,
 )
 
 router = APIRouter()
@@ -69,17 +70,18 @@
 )
 router.include_router(main.router, prefix="/users/{user_id}", tags=["main"])
 
-# 일반 캐릭터 CRUD
-router.include_router(character.router, prefix="/characters", tags=["characters"])
-
 # 유저 도감 전용 API (GET /users/{user_id}/characters)
 router.include_router(
-    character.router,
-    prefix="/users/{user_id}",
-    tags=["user_characters"],  # or "characters" if you want to group together
+    character.router, prefix="/users/{user_id}/characters", tags=["characters"]
 )
 router.include_router(
     analyze.router,
     prefix="/users/{user_id}/analyze",
     tags=["analyze"],
 )
+
+router.include_router(
+    chart.router,
+    prefix="/users/{user_id}",
+    tags=["Chart"],
+)

app/schemas/chart.py

@@ -0,0 +1,19 @@
+from app.schemas.base import BaseModel
+from typing import Literal
+from datetime import date
+
+
+# 일자별 달성률 응답
+class DailyAchievementResponse(BaseModel):
+    date: date
+    english: float
+    exercise: float
+    coding: float
+
+
+# 월별 달성률 응답 (optional로 구성 가능)
+class MonthlyAchievementResponse(BaseModel):
+    month: str  # "2025-01", "2025-02" 형식
+    english: float
+    exercise: float
+    coding: float

app/services/chart.py

@@ -0,0 +1,148 @@
+from uuid import UUID
+from sqlalchemy.ext.asyncio import AsyncSession
+from sqlalchemy import select, extract, func
+from sqlalchemy.orm import selectinload
+from app.models.category import Todo, Category
+from app.schemas.chart import DailyAchievementResponse
+from collections import defaultdict
+from typing import List
+
+
+async def get_daily_achievement(
+    db: AsyncSession, user_id: UUID, year: int
+) -> List[DailyAchievementResponse]:
+    # 해당 연도의 투두 불러오기
+    result = await db.execute(
+        select(Todo)
+        .join(Category)
+        .options(selectinload(Todo.category))
+        .where(Todo.user_id == user_id, extract("year", Todo.start_date) == year)
+    )
+    todos = result.scalars().all()
+
+    # 일자별 → 카테고리별 → [완료된 수, 전체 수] 누적
+    data = defaultdict(
+        lambda: {"english": [0, 0], "exercise": [0, 0], "coding": [0, 0]}
+    )
+
+    for todo in todos:
+        key_date = todo.start_date
+        category = todo.category.category_name.value  # "영어", "운동", "코딩"
+
+        if category == "영어":
+            key = "english"
+        elif category == "운동":
+            key = "exercise"
+        elif category == "코딩":
+            key = "coding"
+        else:
+            continue  # 혹시 모를 예외
+
+        data[key_date][key][1] += 1  # 전체 수
+        if todo.is_completed:
+            data[key_date][key][0] += 1  # 완료 수
+
+    # 응답 데이터 구성
+    responses: List[DailyAchievementResponse] = []
+
+    for date_key in sorted(data.keys()):
+        entry = data[date_key]
+        responses.append(
+            DailyAchievementResponse(
+                date=date_key,
+                english=(
+                    round((entry["english"][0] / entry["english"][1] * 100), 2)
+                    if entry["english"][1]
+                    else 0
+                ),
+                exercise=(
+                    round((entry["exercise"][0] / entry["exercise"][1] * 100), 2)
+                    if entry["exercise"][1]
+                    else 0
+                ),
+                coding=(
+                    round((entry["coding"][0] / entry["coding"][1] * 100), 2)
+                    if entry["coding"][1]
+                    else 0
+                ),
+            )
+        )
+
+    return responses
+
+
+from app.models.category import Todo, Category
+from app.schemas.chart import MonthlyAchievementResponse
+from sqlalchemy import extract, select
+from sqlalchemy.ext.asyncio import AsyncSession
+from sqlalchemy.orm import selectinload
+from uuid import UUID
+from collections import defaultdict
+from typing import List
+
+
+async def get_monthly_achievement(
+    db: AsyncSession, user_id: UUID, year: int
+) -> List[MonthlyAchievementResponse]:
+    # 1. 연도에 해당하는 Todo 불러오기 (Category 조인 포함)
+    result = await db.execute(
+        select(Todo)
+        .join(Category)
+        .options(selectinload(Todo.category))
+        .where(Todo.user_id == user_id, extract("year", Todo.start_date) == year)
+    )
+    todos = result.scalars().all()
+
+    # 2. 월별 데이터 누적용 딕셔너리 초기화
+    data = defaultdict(
+        lambda: {
+            "english": [0, 0],
+            "exercise": [0, 0],
+            "coding": [0, 0],
+        }
+    )
+
+    # 3. 데이터 누적
+    for todo in todos:
+        month_str = todo.start_date.strftime("%Y-%m")  # 예: "2025-01"
+        category = todo.category.category_name.value  # "코딩", "영어", "운동"
+
+        if category == "영어":
+            key = "english"
+        elif category == "운동":
+            key = "exercise"
+        elif category == "코딩":
+            key = "coding"
+        else:
+            continue
+
+        data[month_str][key][1] += 1  # 전체 수 증가
+        if todo.is_completed:
+            data[month_str][key][0] += 1  # 완료 수 증가
+
+    # 4. 응답 스키마에 맞게 가공
+    responses: List[MonthlyAchievementResponse] = []
+    for month_key in sorted(data.keys()):
+        entry = data[month_key]
+        responses.append(
+            MonthlyAchievementResponse(
+                month=month_key,
+                english=(
+                    round((entry["english"][0] / entry["english"][1] * 100), 2)
+                    if entry["english"][1]
+                    else 0
+                ),
+                exercise=(
+                    round((entry["exercise"][0] / entry["exercise"][1] * 100), 2)
+                    if entry["exercise"][1]
+                    else 0
+                ),
+                coding=(
+                    round((entry["coding"][0] / entry["coding"][1] * 100), 2)
+                    if entry["coding"][1]
+                    else 0
+                ),
+            )
+        )
+
+    return responses