o ɣg!@sddlmZmZmZmZddlmZddlmZddl m Z m Z m Z ddl m Z ddlmZddlmZddlmZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z m!Z!eZ"e"j#dedeeeefdedefddZ$e"j#deedeeeefdedefddZ%e"j#deedeefdefddZ&e"j#deedeefdefddZ'e"j#de(deeeefdedefdd Z)e"j*d!e(deeeefdedefd"d#Z+Gd$d%d%e Z,e"j*d&e(deeeefd'e,dedefd(d)Z-d*S)+) APIRouterDepends HTTPExceptionstatus)Session)List)datetime timedeltadate) BaseModel)func) UserPoints)UserPointsResponse)get_dbget_current_user)User)PointTransaction)PointTransactionResponse)AggregatedPointsResponse)calculate_unconverted_pointsconvert_steps_to_points/)response_model current_userdbcsP|ttj|jk}|s&t|jdd}||||||S)u 로그인한 사용자의 포인트를 조회합니다. 만약 사용자에 대한 포인트 레코드가 없으면, 0으로 초기화합니다. ruser_id total_points) queryr filterridfirstaddcommitrefresh)rr user_pointsr&#/app/app/api/v1/endpoints/points.pyget_user_pointss   r(z /transactioncs.|ttj|jktj}|S)u 현재 로그인한 사용자의 포인트 트랜잭션 내역을 반환합니다. 반환되는 항목은 transaction_type, amount, description (그리고 필요시 created_at) 입니다. ) rrrrr order_by created_atdescall)rr transactionsr&r&r'get_point_transactions&s  r.z/weeklycst}t|j|j|jt|d}|tj t t tj ddtj|ktj t t tj ddk}dd|DS)u 모든 유저의 주간 누적 포인트를 조회합니다. 현재 주(월요일부터 시작) 이후에 발생한 포인트 트랜잭션을 집계하여 각 유저별 주간 누적 포인트를 반환합니다. )daysrrcSg|] \}}||dqSrr&.0rrr&r&r' Pz%get_weekly_points..)rutcnowyearmonthdayr weekdayrrrr coalescesumamountlabelrr*group_byhavingr,)rnow_dtZ start_of_weekZ weekly_pointsr&r&r'get_weekly_points7s   rBz/monthlycs~t}t|j|jd}|tjtt tj d d tj |ktjtt tj ddk}dd|DS)u 모든 유저의 월간 누적 포인트를 조회합니다. 이번 달의 초(1일) 이후에 발생한 포인트 트랜잭션을 집계하여 각 유저별 월간 누적 포인트를 반환합니다. rrcSr0r1r&r2r&r&r'r4kr5z&get_monthly_points..)rr6r7r8rrrr r;r<r=r>rr*r?r@r,)rrAZstart_of_monthZmonthly_pointsr&r&r'get_monthly_pointsRs   rDz /unconvertedcst||j|jS)u 아직 포인트로 전환되지 않은 걸음수를 조회합니다. 마지막 포인트 전환 이후의 걸음 기록에서 얻을 수 있는 잠재적 포인트와 100점 단위로 실제 전환 가능한 포인트를 계산합니다. )rr country_code)rrr&r&r'get_unconverted_pointsms rFz/convertcs<t||j|j}|dsd|dvrttj|dd|S)ut 걸음수를 포인트로 전환합니다. - 마지막 포인트 전환 이후의 모든 걸음 기록을 확인합니다. - 전환 가능한 포인트가 1000점 이상인 경우에만 포인트를 적립합니다. - 포인트는 1000점 단위로만 전환됩니다 (예: 1950걸음 → 1000포인트만 전환, 950걸음은 다음 전환까지 유지). - 전환된 포인트는 "step_conversion" 타입의 트랜잭션으로 기록됩니다. - 실시간 걸음 기록은 계속되지만, 자동으로 포인트로 전환되지 않고 반드시 이 엔드포인트를 호출해야 합니다. successzMinimum 1000 points requiredmessage status_codedetail)rr rErrHTTP_400_BAD_REQUEST)rrresultr&r&r' convert_steps_to_points_endpointysrNc@seZdZUeed<dS)PointGameRequest result_pointN)__name__ __module__ __qualname__int__annotations__r&r&r&r'rOs rOz /point-game game_datac s$|jdkr ttjddt}t|tj }t|tj }| t  t j|jkt jdkt j|kt j|k}|rFttjddt |jd|jd|jdd}||| t tj|jk}|rs|j|j7_n t|j|jd }|||d d |jd |j|jd S)uD 포인트 게임을 통해 획득한 포인트를 적립합니다. - 하루에 한 번만 게임 포인트를 적립할 수 있습니다. - 적립된 포인트는 사용자의 총 포인트에 더해집니다. - 포인트 적립 내역은 "point_game" 타입의 트랜잭션으로 기록됩니다. rzPoint value must be positiverI point_gamez,You have already played the point game todayzGet the event z points)rtransaction_typer= descriptionrTzSuccessfully added z points from the point game.)rGrHZ added_pointscurrent_total_points)rPrrrLr todayrcombinemintimemaxrrrrr rXr*r!r"r rr#) rVrrr[Z today_startZ today_endZ existing_gamepoint_txr%r&r&r'point_game_endpointsP       raN).fastapirrrrsqlalchemy.ormrtypingrrr r pydanticr sqlalchemyr Zapp.models.user_pointsr Zapp.schemas.user_pointsrZ app.api.depsrrapp.models.userrZapp.models.point_transactionrZapp.schemas.point_transactionrZapp.schemas.aggregated_pointsrZapp.services.point_servicerrroutergetr(r.rBrDdictrFpostrNrOrar&r&r&r's