o g?f @sddlmZddlmZmZmZddlmZddlm Z m Z ddl Z ddl m ZddlmZmZddlmZdd lmZdd lmZe d Zd d deejeejeejeejeejeejd Z d?dedeedeefddZ!d?dededeedeefddZ"d?dededeedefddZ#d?dededeede$fddZ%d?dededeede&fddZ' d?dedede deedef dd Z(deddfd!d"Z)ded#ed$edeefd%d&Z*dedeefd'd(Z+ded)e&d*edefd+d,Z,ded-e&deeeffd.d/Z-d@ded1e&d2e&deefd3d4Z.ded5e&d6edeeeffd7d8Z/ded9eeefdeeeffd:d;Z0dedZ1dS)A)Session)ListOptionalDict) AdminSetting)AdminSettingCreateAdminSettingUpdateN)settings) HTTPExceptionstatus)Any)Order)Product adimsayarz0.01Z7000z2.0) ZSTEP_BASE_RATEZSTEP_THRESHOLDZSTEP_MULTIPLIERACHIEVEMENT_STEP_GOALACHIEVEMENT_BONUSZREFERRAL_BONUS REFERRAL_DIRECT_BONUS_PERCENTAGEREFERRAL_CHAIN_DECAYREFERRAL_MAX_LEVELdb country_codereturncCs&|t}|r|tj|k}|S)u{ 모든 관리자 설정을 조회합니다. country_code가 제공되면 해당 국가 설정만 반환합니다. )queryrfilterrall)rrrr"/app/app/services/admin_service.pyget_all_settingss r setting_namecCsP|r|ttj|ktj|k}|r|S|ttj|ktjdkS)u 특정 설정을 조회합니다. country_code가 제공되면 해당 국가 설정을 우선 조회하고, 없는 경우 country_code가 None인 기본 설정을 반환합니다. N)rrrrrfirstrrrsettingrrr get_setting#s  r"cCs,t|||}|r|jdur|jSt|dS)uk 설정 값을 문자열로 반환합니다. 설정이 없는 경우 기본값을 반환합니다. N)r" setting_valueDEFAULT_SETTINGSgetr rrrget_setting_value7s  r'c Cstt|||}zt|WSttfy9td|d|dz tt|dWYSttfy8YYdSww)u\ 설정 값을 실수로 반환합니다. 변환 실패 시 0.0을 반환합니다. Failed to convert setting with value 'z ' to floatz0.0g)r'float ValueError TypeErrorloggererrorr%r&rrrvaluerrrget_setting_floatBs  r1c Cs|t|||}ztt|WSttfy=td|d|dz ttt|dWYSttfy<YYdSww)uZ 설정 값을 정수로 반환합니다. 변환 실패 시 0을 반환합니다. r(r)z' to int0r) r'intr*r+r,r-r.r%r&r/rrrget_setting_intQs r4 update_datacCs|ttj|ktj|k}|r!|j|_|jdur |j|_nt||j|dur+|n|jd}|||| ||S)uO 설정을 업데이트하거나 없는 경우 새로 생성합니다. Nrr$r) rrrrrrr$addcommitrefresh)rrr5rr!rrrupdate_setting`s(    r:cCs\tD]#\}}|ttj|ktjdk}|s't||dd}||q| dS)uu 애플리케이션 시작 시 기본 설정이 존재하는지 확인하고, 없는 경우 생성합니다. Nr6) r%itemsrrrrrrr7r8)rnamer0r!rrrensure_default_settingss    r=emailpasswordc Cszddlm}ddlm}m}ddlm}ddlm}ddlm }ddl m } t d||| | j|k} | sIt d |Wd S||| js[t d |Wd S| jdkrkt d |Wd S| jsyt d |Wd S|| _|| ||| || jd} || jd} | | d| j| j| j| j| j| jdd} | WSty}z t jdt |ddd }~ww)z Admin authentication function. Authenticates user credentials and verifies that the user has admin privileges. Returns admin user data with tokens if authentication is successful, None otherwise. r) UserService)create_access_tokencreate_refresh_token)NotificationService)now) pwd_contextUserz*Attempting admin authentication for user: zUser not found with email: NzInvalid password for admin: z#Inactive admin attempted to login: z&Non-admin user attempted admin login: )subjectbearer)idr> first_name last_namer is_admin) access_token refresh_token token_typeuserzAdmin authentication error: Texc_info)!app.services.user_servicer@app.core.securityrArB!app.services.notification_servicerC app.core.timerDrEapp.models.userrGr-inforrr>rwarningverifyr?r rM last_loginr7r8r9rJrKrL Exceptionr.str)rr>r?r@rArBrCrDrErGrQrNrOresponseerrrauthenticate_adminsX          rac Csddlm}ddlm}||j|j|j|j|j |j  ||j|j k }g}|D]}||j|j|j |j |j|jdq*|S)u 모든 사용자의 포인트 정보를 조회합니다. Args: db (Session): 데이터베이스 세션 Returns: List[Dict]: 모든 사용자의 포인트 정보 목록 r) UserPointsrF)user_idr>rKrL total_points updated_at)app.models.user_pointsrbrXrGrrcrdrer>rKrLjoinrJrappend)rrbrGresultsZuser_points_listresultrrrget_all_user_pointss6     rkrc user_datac Csddlm}|||j|k}|s ttjd|ddz9| D] \}}t |||q%| || | ||j|j|j|j|j|j|j|j|j|j|jd }|WStyu}z|ttjdt|dd}~ww) u 관리자 권한으로 사용자 정보를 업데이트합니다. Args: db (Session): 데이터베이스 세션 user_id (int): 업데이트할 사용자의 ID user_data (Dict): 업데이트할 사용자 정보 Returns: Dict: 업데이트된 사용자 정보 Raises: HTTPException: 사용자를 찾을 수 없거나 업데이트 중 오류가 발생한 경우 rrFz User with id not found status_codedetail) rJr>rKrL phone_codephonegender birth_datedaily_step_goalr rezFailed to update user: N)rXrGrrrJrr r HTTP_404_NOT_FOUNDr;setattrr7r8r9r>rKrLrqrrrsrtrurer]rollbackHTTP_500_INTERNAL_SERVER_ERRORr^) rrcrlrGrQkeyr0Z user_infor`rrrupdate_user_by_adminsD     r{ category_idc CsBddlm}ddlm}ddlm}z|||j|k }|s-t t j d|dd|j }|j}|ttj|k}|dkrRt t jd|d |d d|j|j |jd } ||||||j|k } | d urtd |t t jdd||||j |k|j|k } | d urtd| jd| j d| jd| | j| j | jd ddWStd|d| dd| dWS|y} z|tdt| t t jdt| dd } ~ wt yty } z|tdt| t t jdt| dd } ~ ww)u 관리자 권한으로 상품 카테고리를 삭제합니다. Args: db (Session): 데이터베이스 세션 category_id (int): 삭제할 상품 카테고리의 ID Returns: Dict: 삭제 성공 메시지와 삭제된 카테고리 ID Raises: HTTPException: 카테고리가 존재하지 않거나 관련 제품이 있어 삭제할 수 없는 경우 r)ProductCategory)IntegrityError)or_zProduct category with id rmrnzCannot delete category with id z because it has z- products. Remove or reassign products first.)rJcoder<Nz)Category still exists after deletion: ID=zTFailed to delete product category. The category still exists after deletion attempt.z,Found duplicate category after deletion: ID=z, Code=z, Name=zOCategory with ID {category_id} was deleted, but a similar category still existsu자동 복제 방지 시스템이 감지되었습니다. 데이터베이스 트리거나 외부 프로세스가 삭제된 카테고리를 다시 생성했을 수 있습니다.)messagedeleted_categoryZsimilar_categoryrZz*Successfully deleted product category: ID=r<z%Product category deleted successfully)rrz*IntegrityError deleting product category: z9Cannot delete this category due to database constraints: z!Error deleting product category: zBAn unexpected error occurred while deleting the product category: )Zapp.models.product_categoryr}sqlalchemy.excr~ sqlalchemyrrrrJrr r rvrr<rr|countHTTP_400_BAD_REQUESTdeleter8r-r.ryrZrYrxr^r]) rr|r}r~rcategoryZ category_codeZ category_nameZproducts_countZ category_infoZ deleted_checkZduplicate_checkr`rrrdelete_product_category8s      "    rdskiplimitcCsnz|ttj||}|st dgWSg}|D]c}g}|j D]:}|t  t j |jk}|r>|jnd} |rE|jnd} |j|j|j |j|j|j|j| | |jd } || q)|j |j|j|j|j|j|jdd||j|jd } || q"t dt|d|WSty} ztj dt!| d d t"d d t!| d d} ~ ww)u# 모든 사용자의 주문정보를 조회합니다. Args: db (Session): 데이터베이스 세션 skip (int): 건너뛸 레코드 수 limit (int): 조회할 최대 레코드 수 Returns: List[Dict]: 모든 주문 정보 목록 zNo orders found in the databaseN product_idquantityrJorder_idpoints_per_itemrd created_at product_name product_imageZ product_priceF rJrc order_numberrdr address_idshipping_detailsZ save_addressZ address_titler;rrez Retrieved z orders from the databasezError retrieving orders: TrRiInternal server error: rn)#rr order_byrdescoffsetrrr-rYr;rrrJrrr< thumbnailrrrrd isoformatrhrcrr rrrelenr]r.r^r )rrrordersrjorder order_itemsitemproductrr order_item order_infor`rrrget_all_orderssZ &    rr new_statusc Cszgd}|}||vrttjdd|d|ttj|k }|s4ttj d|dd|j}||_| | |t d|d|d |g}|jD]:}|ttj|jk }|rk|jnd } |rr|jnd } |j|j|j|j|j|j|j| | |jd } || qV|j|j|j|j|j|j|jd d ||j|jd } | WStyt y} zt j!dt"| ddttj#dt"| dd } ~ ww)u 주문 상태를 업데이트합니다. Args: db (Session): 데이터베이스 세션 order_id (int): 업데이트할 주문 ID new_status (str): 새로운 주문 상태 (DELIVERED, PROCESSING, PENDING, CANCELLED) Returns: Dict[str, Any]: 업데이트된 주문 정보 Raises: HTTPException: 주문이 존재하지 않거나 잘못된 상태 값이 제공된 경우 )Z DELIVERED PROCESSINGPENDING CANCELLEDz&Invalid status value. Must be one of: z, rnzOrder with ID rmz!Order status updated - Order ID: z, Old status: z, New status: NrFrzError updating order status: TrRr)$upperr r rrgrr rrJrrvr8r9r-rYr;rrr<rrrrrdrrrhrcrrrrer]r.r^ry)rrrZvalid_statusesrZ old_statusrrrrrrrr`rrrupdate_order_statussx      rad_datac Cs8ddlm}zm|d}|||j|k|j}|r<|D]}|jd7_||q"t dt |d||d||dd }||| | ||j|j|j|j|jd }t d |jd |j|WSty}z|t jd t|ddttjdt|dd}~ww)u\ 새로운 광고를 생성합니다. 중복된 video_list_order 값이 있으면 자동으로 조정합니다. Args: db (Session): 데이터베이스 세션 ad_data (Dict[str, Any]): 광고 데이터 (ad_url, video_list_order, ad_video_points) Returns: Dict[str, Any]: 생성된 광고 정보 r Advertisementvideo_list_orderzAdjusted order for z existing advertisementsad_urlad_video_points)rrr)rJrrrrz)Advertisement created successfully - ID: z , Order: zError creating advertisement: TrRz Failed to create advertisement: rnN)app.models.advertisementrrrrrrrr7r-rYrr8r9rJrrrrr]rxr.r^r r ry) rrrZrequested_orderZ&existing_ads_with_same_or_higher_orderZ existing_adZnew_adad_infor`rrrcreate_advertisementGsL       rad_idc Csddlm}z<|||j|k}|s!ttjd|dd|j|j |j |j d}| || td|d|d WStyJtyq}z|tjd t|d d ttjd t|dd}~ww)u 광고를 삭제합니다. Args: db (Session): 데이터베이스 세션 ad_id (int): 삭제할 광고 ID Returns: Dict[str, Any]: 삭제 결과 메시지 rrzAdvertisement with ID rmrn)rJrrrz)Advertisement deleted successfully - ID: z"Advertisement deleted successfully)rZdeleted_advertisementzError deleting advertisement: TrRz Failed to delete advertisement: N)rrrrrJrr r rvrrrrr8r-rYr]rxr.r^ry)rrradrr`rrrdelete_advertisements<     r)N)rr)2sqlalchemy.ormrtypingrrrZapp.models.admin_settingrZapp.schemas.admin_settingrrloggingapp.core.configr Z app_settingsfastapir r r Zapp.models.orderr Zapp.models.productr getLoggerr-r^rrREFERRAL_SIGNUP_BONUSrrrr%rr"r'r*r1r3r4r:r=rarkr{rrrrrrrrrs^        $   !A(: m"F&\"@