o ag@sddlmZmZmZmZddlmZddlmZddl m Z ddl Z ddl m Z ddl mZddlmZdd lmZddlZe d ZGd d d ZdS) )ListOptionalDictAny)Session) Notification)NotificationResponseN)datetime)ZoneInfo) HTTPException)text adimsayarc@seZdZedededeefddZedededede e fddZ eddeded e d e d e d e e efde fddZeddeded e d e d e d e e efdefddZededefddZedededede e fddZd S)NotificationServicedbuser_idreturncCsl|ttj|ktd}tdt|d||D]}t d|j d|j qdd|DS)u_ 사용자의 알림을 조회합니다 (소프트 삭제된 알림은 제외) zf(data IS NULL OR JSON_EXTRACT(data, '$.deleted') IS NULL OR JSON_EXTRACT(data, '$.deleted') = 'false')zget_notifications: found z notifications for user_id zNotification id: z, data: cSsg|]}t|qS)rfrom_orm).0 notificationrr)/app/app/services/notification_service.py !sz9NotificationService.get_notifications..) queryrfilterrr allloggerinfolendebugiddata)rr notificationsnrrrget_notificationss z%NotificationService.get_notificationsnotification_idcCs|ttj|ktj|k}|dur"td|d|dSt t d|_ | | |td|d||S)NNotification with id ) not found or not authorized for user_id zEurope/IstanbulzNotification id z marked as read for user_id )rrrrrfirstrwarningr nowr read_atcommitrefreshr)rr$rrrrrmark_notification_as_read#s  z-NotificationService.mark_notification_as_readN notif_typetitlemessager cCs t|||||d}|||S)uZ 알림을 생성하고 데이터베이스에 추가합니다. 주의: 이 메서드는 db.commit()을 호출하지 않으므로, 호출하는 쪽에서 처리해야 합니다. 푸시 알림 기능을 위해 호출하는 쪽에서 선택적으로 커밋을 제어할 수 있도록 설계되었습니다. rtyper/r0r )radd)rrr.r/r0r new_notificationrrrcreate_notification3s z'NotificationService.create_notificationgeneralT send_pushc Csrt|||||d}|||||td|d|j|r7ddlm}|j ||||||dd|S)u~ 알림을 생성하고 데이터베이스에 저장하며, 선택적으로 푸시 알림을 발송합니다. r1z/New notification saved to database for user_id z with ID r)ExpoPushNotificationServiceF)rrr/r0r notification_typeZ save_to_db) rr3r+r,rrrZ+app.services.expo_push_notification_servicer8Zsend_push_to_user) rrr/r0r.r r7r4r8rrrsend_notificationEs.    z%NotificationService.send_notificationcCstdtj||ddddS)u/사용자 로그인 시 환영 메시지 전송u)New Client Login – Welcome Message SentuHoş geldiniz!u;Adimsayar'a hoş geldiniz. İyi vakit geçirmenizi dileriz!u hoş_geliş)rrr/r0r.)rrrr:)rrrrrsend_welcome_notificationgs z-NotificationService.send_welcome_notificationc Cs<td|d||ttj|ktj|k}|dur-td|d|dS|j p1i}td|t }d|d<||d <t |}z3|td |||d }|td |jd |ttj|k}td|j |WSty} z|tjdt| ddd} ~ ww)u] 알림을 소프트 삭제합니다 (MySQL JSON 필드 직접 업데이트) z'Attempting to soft delete notification z for user Nr%r&zCurrent data before update: Tdeleted deleted_atz UPDATE notifications SET data = :json_data WHERE id = :notification_id AND user_id = :user_id ) json_datar$rzUpdate result: z rows affectedzUpdated notification data: z"Error updating notification data: )exc_info)rrrrrrrr'r(r r r) isoformatjsondumpsexecuter r+rowcount Exceptionrollbackerrorstr) rr$rrZ current_datar=r>resultZupdated_notificationerrrsoft_delete_notificationssN     z,NotificationService.soft_delete_notification)N)r6NT)__name__ __module__ __qualname__ staticmethodrintrrr#rrr-rHrrr5boolr:r;rKrrrrrs 22! $r)typingrrrrsqlalchemy.ormrZapp.models.notificationrapp.schemas.notificationrloggingr zoneinfor fastapir sqlalchemyr rA getLoggerrrrrrrs