o ̤gQ@sddlmZddlmZmZmZddlmZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZmZmZmZmZmZdd lZdd lZdd lZdd lZdd lmZmZm Z m!Z!dd l"m#Z#m$Z$dd l%m&Z&ddl'm(Z(ddlm)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9m:Z:e;dZGddde#Z?Gddde#Z@e>Adee fd e@d!efd"d#ZBGd$d%d%e#ZCe>Ad&ee fd eCd!efd'd(ZDd S)))datetime)OptionalListDict)Session)SQLAlchemyError)text)get_db)User)user) pwd_contextcreate_access_tokenget_password_hashcreate_refresh_tokenverify_refresh_tokengenerate_verification_codeN) APIRouterDepends HTTPExceptionstatus) BaseModelEmailStr)send_verification_email) PasswordReset) timedelta)now) UserReferral)PointTransaction) UserPoints)settings)NotificationService)create_friendship)get_setting_floatget_setting_int adimsayarc @sreZdZedededeefddZedede deefddZ e d(ded ed ede e fd dZ ede fddZededejdefddZedededejdeefddZedededeefddZedede de fddZedede de dee fddZed)dedededd fd!d"Zededed#edd fd$d%Zedede e fd&d'Zd S)* UserServicedbuser_idreturnc Csz-td||ttj|k}|r#td||WStd||WStyG}zt d|dt |d}~ww)NzFetching user with id: zFound user with id: zNo user found with id: z#Database error while fetching user : ) loggerinfoqueryr filteridfirstwarningrerrorstr)r&r'r er4!/app/app/services/user_service.pyget_user szUserService.get_useremailc Csz1td||ttj|ktjdk}|r'td||WStd||WSt yK}zt d|dt |d}~ww)NzFetching user with email: zFound user with email: z!No active user found with email: z,Database error while fetching user by email r)) r*r+r,r r-r7rr/r0rr1r2)r&r7r r3r4r4r5get_user_by_email.s"zUserService.get_user_by_emailrdskiplimitc Cs:z|td}td|td}||}td|td}||||d}g}|D]@} t| j} d| vrKd| vrK| d| d<td | d d | d d D]} | | vrp| | rp| |  | | <q^| | q6tdt ||WSt y} z tj dt| ddd} ~ ww)NzSELECT DATABASE()zConnected to database: zSELECT COUNT(*) FROM userszTotal records in users table: z SELECT * FROM users WHERE status = 1 ORDER BY id ASC LIMIT :skip, :limit )r;r< birth_dateZbirthdayzFound user: ID=r.z, Email=r7) created_at updated_at last_loginzTotal users found: zError in get_users: Texc_info)executerscalarr*r+dict_mappingdebugget isoformatappendlen Exceptionr1r2) r&r;r<Zdb_checkZ count_queryZ total_countr,resultusersrowZ user_dictfieldr3r4r4r5 get_users<s4  " zUserService.get_userscCs tjtj}dtj|ddS)z,Generate a unique 8-character reference code)k)stringascii_uppercasedigitsjoinrandomchoices)charsr4r4r5generate_reference_codems z#UserService.generate_reference_coder c Cs,zz t}|ttj|k}|snqt|jt|j |j |j |j |j |j|j|j||jd|jd }||||||jrx|ttj|jk}|rxt|j|jd}|||ddlm}|j||j|jdd|WSty}ztd t||d}~ww) NTi') r7password first_name last_name phone_codephonegenderr= profile_imagereference_codereference_code_useddaily_step_goal country_code)referrer_user_idreferred_user_idr)friendship_servicepending)r' friend_idrzError creating user: ) r%r\r,r r-rdr/r7rr]r^r_r`rarbr=rcrergaddcommitrefreshrr. app.servicesrjr!rLr*r1r2rollback) r&r rdexistsdb_userZreferrerreferralrjr3r4r4r5 create_userss`    zUserService.create_userc CszO|ttj|k}|sWdS|jr#|j\}}||_||_|j r*|j |_ |j r1|j |_ |j r8|j |_ |j r?|j |_ t |_||||WStyj}ztdt||d}~ww)NzError updating user: )r,r r-r.r/ full_namesplitr^r_r7rarfrcrutcnowr?rnrorLr*r1r2rq)r&r'r rsr^r_r3r4r4r5 update_users4  zUserService.update_userc Csz3td|t||}|std|dWdSd|_t|_| td||WSt yQ}zt d|dt || d}~ww)NzDeleting user with id: zNo active user found with id: z for deletionrz#Successfully deleted user with id: z#Database error while deleting user r))r*r+r%r6r0rrrxr?rnrr1r2rq)r&r'rsr3r4r4r5 delete_users"  zUserService.delete_user new_passwordcCsbt||}|sddlm}m}||jddt|}||_|| |t d||S)zG Reset the password for the user with the given email. r)rrUser not found status_codedetailz(Password updated successfully for user: ) r%r9fastapirrHTTP_404_NOT_FOUNDrr]rnror*r+)r&r7r{r rrZhashed_passwordr4r4r5reset_passwords  zUserService.reset_passwordr]c Csdztd||ttj|k}|s#td|WdSt ||j s5td|WdS|j dkrEtd|WdS|j du}t |_ |||||t|jd}t|jd}||d|j|j|j|j|j dd }d }|r||d <td tj||jd |dtd|WSty} z tjdt| ddd} ~ ww)Nz$Attempting authentication for user: zUser not found with email: zInvalid password for user: rz"Inactive user attempted to login: )subjectbearer)r.r7r^r_r) access_token refresh_token token_typer uPTebrikler, adimsayar ile birlikte sağlıklı bir yaşamın tadını çıkarın!welcome_messageu)New Client Login – Welcome Message SentuHoş Geldiniz!)r&r'titlemessageu3NotificationService.send_notification 호출 완료zAuthentication error: TrA)r*r+r,r r-r7r/r0r verifyr]rr@rrmrnror r.rr^r_rGr Zsend_notificationrLr1r2) r&r7r]r Z is_new_userrrresponserr3r4r4r5authenticate_users\        zUserService.authenticate_userri bonus_pointsNc Cs|ttj|ktjdk}|r|j}t|d|dd}|||t t j |k}|r:|j |7_ n t ||d}||t|d|dd}|||t t j |k}|ri|j |7_ n t ||d}||d|_t j ||dd d |d d |d Sd S)u 신규 사용자의 첫 걸음 기록 시, 추천인에게 referral_bonus 지급 및 알림 생성하고, 추천받은 사용자에게도 signup bonus 지급합니다. Freferral_bonusz0Referral bonus awarded upon first step recordingr'transaction_typeamount descriptionr' total_pointszBReferral bonus awarded upon first step recording for referred userTZaward_referral_pointu(Tebrikler! Referans Bonusu Kazandınız!u-Arkadaşınızın ilk adım kaydı sayesinde u puan bonus kazandınız.)r'Z notif_typerrN)r,rr-riawardedr/rhrrmrr'rr Zcreate_notificationrn) r&rirrt referrer_idpoint_txuser_points_recordZpoint_tx_referredZreferred_points_recordr4r4r5award_referral_bonus8sT         z UserService.award_referral_bonus earned_pointsc Cs2|ttj|k}|r|jnd}t|d|}t|d|}t|d|}d}|} ||kr|ttj | k} | s>nU| j } t ||d||d} | dkrt | d| d |d |d d } | | |ttj| k}|r~|j| 7_n t| | d }| || } |d7}||ks.|dS)u Referred user'ın kazandığı adım puanlarının belirli yüzdesini, referral chain boyunca (0.5% ve sonrasında decay uygulanarak) her seviye için dağıtır. N REFERRAL_DIRECT_BONUS_PERCENTAGEREFERRAL_MAX_LEVELREFERRAL_CHAIN_DECAYr8r:rreferral_chainzReferral bonus (level z ) from user z daily points.rr)r,r r-r.r/rgr"r#rrirhintrrmrr'rrn)r&rirr rgZbonus_percentageZ max_levelZdecaylevelcurrent_user_idrtrrrrr4r4r5award_referral_chain_bonusqsD        z&UserService.award_referral_chain_bonusc Cshz|tjtjtjdk}dd|D}|WSty3}z tj dt |ddd}~ww)Nr8cSsg|] }|j|jdqS)r.rdr).0rOr4r4r5 sz6UserService.get_all_referral_codes..zError fetching referral codes: TrA) r,r r.rdr-rallrLr*r1r2)r&Zreferral_codesrMr3r4r4r5get_all_referral_codess z"UserService.get_all_referral_codes)rr:)r:)__name__ __module__ __qualname__ staticmethodrrrr r6r2r9rrrQr\ user_schemasZ UserCreateruZ UserUpdateryrzrrrrrr4r4r4r5r%sT   0;" A84r%c@eZdZUeed<dS)RefreshTokenRequestrN)rrrr2__annotations__r4r4r4r5r rc@r)ForgotPasswordRequestr7N)rrrrrr4r4r4r5rrrz/forgot-passwordreqr&cCsht||j}|sttjddt}t|j|d}| || t |j|s0ttj ddddiS)Nz"User with provided email not foundr})r' reset_codez!Failed to send verification emailrz/Reset code has been sent to your email address.) r%r9r7rrrrrr.rmrnrHTTP_500_INTERNAL_SERVER_ERROR)rr&r r reset_recordr4r4r5forgot_passwords   rc@seZdZUeed<eed<dS)VerifyResetCodeRequestr7rN)rrrrrr2r4r4r4r5rs  rz/verify-reset-codecCst||j}|sttjdd|ttj |j ktj |j k tj }|s2ttjdd|j tdd}t}td|j d|d|||kr^d |_|ttjd d|jd krjttjd dd |_|d diS)a$ Verifies the provided reset code for the given email. If verification succeeds: - Checks if the reset record is still valid and not expired. - If expired, marks it as used (is_valid = 0) and raises an error. - If valid, marks it as used to prevent re-use. r|r}zInvalid reset code )minuteszReset record created_at: z, expiry_time: z, current_time: rzReset code expiredr8z Reset code has already been usedrz Reset code verified successfully)r%r9r7rrrr,rr-r'r.rorder_byr>descr/HTTP_400_BAD_REQUESTrrr*r+is_validrn)rr&r rZ expiry_time current_timer4r4r5verify_reset_codesJ      r)Ertypingrrrsqlalchemy.ormrZsqlalchemy.excr sqlalchemyrapp.db.sessionr app.models.userr Z app.schemasr rZapp.core.securityr r rrrruuidloggingrYrUrrrrrpydanticrrZapp.services.email_servicerapp.models.password_resetrr app.core.timerZapp.models.user_referralrZapp.models.point_transactionrZapp.models.user_pointsrapp.core.configrZ!app.services.notification_servicer Zapp.services.friendship_servicer!Zapp.services.admin_servicer"r# getLoggerr*r%routerrrpostrrrr4r4r4r5sb