[NL-75] : 로또 결과 확인 API (#21)

* feat: 로또 결과 확인 API

* fix: black 적용 및 is_finished 변수 반환

---------

Co-authored-by: Gukhee Jo <[email protected]>

Author: swa07016

migrations/versions/578233fccdf8_add_is_read_read_at_field_to_lotto_.py

@@ -0,0 +1,34 @@
+"""add is_read, read_at field to lotto recommendation table
+
+Revision ID: 578233fccdf8
+Revises: 926bb28822d1
+Create Date: 2025-08-18 00:37:25.201315
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '578233fccdf8'
+down_revision: Union[str, Sequence[str], None] = '926bb28822d1'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('lotto_recommendations', sa.Column('is_read', sa.Boolean(), nullable=False))
+    op.add_column('lotto_recommendations', sa.Column('read_at', sa.DateTime(), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('lotto_recommendations', 'read_at')
+    op.drop_column('lotto_recommendations', 'is_read')
+    # ### end Alembic commands ###

src/lotto/entities/models.py

@@ -1,6 +1,7 @@
 from sqlalchemy import (
     Column,
     Integer,
+    Boolean,
     Date,
     CheckConstraint,
     BigInteger,
@@ -55,5 +56,8 @@ class LottoRecommendations(Base):
     user_id = Column(String(255), ForeignKey("users.id"), nullable=False)
     round = Column(Integer, nullable=False)
     content = Column(JSON, nullable=False)
+    is_read = Column(Boolean, nullable=False, default=False)
+    read_at = Column(DateTime, nullable=True)
 
     user = relationship("User", back_populates="lotto_recommendations")
+

src/lotto/entities/schemas.py

@@ -84,21 +84,38 @@ def normalize_element(cls, v):
                 "금(金)": FiveElements.METAL,
                 "수(水)": FiveElements.WATER,
             }
-            
+
             normalized = element_mapping.get(v)
             if normalized is not None:
                 return normalized
-        
+
         return v
 
 
 class LottoRecommendation(CommonBase):
     user_id: str
     round: int
     content: Optional[LottoRecommendationContent] = None
+    is_finished: bool = False
 
 
 class LottoRecommendationCreate(CommonBase):
     user_id: str
     round: int
     content: LottoRecommendationContent
+
+
+class LottoResultCheckResponse(CommonBase):
+    user_id: str
+    round: int
+
+    # 추가된 필드들
+    draw_numbers: List[int]  # 해당 회차 당첨 메인 번호 6개 (원본 순서)
+    bonus_number: int  # 해당 회차 보너스 번호
+    recommended_numbers: List[int]  # 추천받은 번호 6개 (원본 순서)
+
+    matched_count: int
+    matched_numbers: List[int]  # 교집합(오름차순)
+    has_bonus: bool
+    rank: Optional[int]  # 1~5, 낙첨이면 None
+    prize_amount: Optional[int]  # 원 단위, 알 수 없으면 None

src/lotto/repository.py

@@ -2,7 +2,7 @@
 from typing import List, Optional, Tuple
 
 from fastapi import Depends
-from sqlalchemy import select, desc, asc
+from sqlalchemy import select, update, desc, asc
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from src.common.dependencies import get_db_session
@@ -194,3 +194,26 @@ async def get_excluded_numbers(self, limit: int = 2) -> List[int]:
         )
         result = await self.session.execute(query)
         return [row[0] for row in result.fetchall()]
+
+    async def get_recommendation_by_user_and_round(
+            self, user_id: str, round: int
+    ) -> Optional[LottoRecommendations]:
+        query = (
+            select(LottoRecommendations)
+            .where(
+                LottoRecommendations.user_id == user_id,
+                LottoRecommendations.round == round,
+            )
+            .limit(1)
+        )
+        result = await self.session.execute(query)
+        return result.scalar_one_or_none()
+
+    async def mark_recommendation_read(self, recommendation_id: int, read_at: datetime) -> None:
+        """추천 레코드를 읽음 처리합니다."""
+        stmt = (
+            update(LottoRecommendations)
+            .where(LottoRecommendations.id == recommendation_id)
+            .values(is_read=True, read_at=read_at)
+        )
+        await self.session.execute(stmt)