✨ Feat: 대기등록, 운영 종료 문자 추가

manager/views.py

@@ -222,8 +222,9 @@ def update_status(self, request, *args, **kwargs):
                 for waiting in Waiting.objects.filter(booth=booth, waiting_status='waiting'):
                     waiting.set_canceled()
                     waiting.save()
-                    # 취소 처리 Sms 전송 구현 예정
-
+                    # 취소 처리 문자 메시지 발송
+                    phone_number = waiting.user.phone_number
+                    sendsms(phone_number, f"[라인나우] 대기 등록한 부스의 운영이 종료되어, 대기가 취소되었어요")
                     # 대기 중인 팀들을 모두 삭제 처리
                     waiting.delete()
 

utils/sendmessages.py

@@ -33,15 +33,13 @@ def sendsms(dest_phone, msg_body):
         "send_phone": SEND_PHONE,
         "msg_body": msg_body,
     }
-    print(data)
-    return custom_response(data=data, message="perfect", code=status.HTTP_200_OK)
-    """
+
     try:
         url = f"{SSODAA_BASE_URL}/sms/send/sms"
         response = requests.post(url, json=data, headers=headers)
         response = response.json()
         status_code = int(response.get('code'))
-
+        print(response)
         if status_code == 200:
             content = response.get('content')
             data = {
@@ -56,4 +54,3 @@ def sendsms(dest_phone, msg_body):
 
     except requests.exceptions.RequestException:
         return custom_response(message="Failed to send messages.", code=status.HTTP_400_BAD_REQUEST, success=False)
-    """

waiting/tasks.py

@@ -19,7 +19,7 @@ def check_ready_to_confirm(waiting_id):
         pass
 
 @shared_task
-def check_confirmed(waiting_id):
+def check_confirmed(waiting_id, phone_number):
     print("기다림은 끝")
     """10분 후 입장 확정 상태에서 도착하지 않으면 time_over_canceled 상태로 변경"""
     from .models import Waiting
@@ -30,7 +30,6 @@ def check_confirmed(waiting_id):
         if waiting.is_confirmed_expired() and waiting.waiting_status == 'confirmed':
             waiting.set_time_over_canceled()  # 시간 초과로 취소 처리
             # 문자 메시지 발송
-            phone_number = waiting.user.phone_number
             print(phone_number)
             sendsms(phone_number, f"[라인나우] 10분 내에 부스에 입장하지 않아, 대기가 취소되었어요")
     except Waiting.DoesNotExist:

waiting/views.py

@@ -11,6 +11,7 @@
 from django.db.models import Q
 from utils.permissions import IsUser
 from .tasks import check_confirmed
+from utils.sendmessages import sendsms
 
 
 class WaitingViewSet(viewsets.GenericViewSet):
@@ -71,6 +72,9 @@ def register_waiting(self, request, pk=None):
                     raise CustomException("User not found.")
 
             serializer.save(booth=booth, user=user)
+            # 문자 메시지 발송
+            phone_number = user.phone_number
+            sendsms(phone_number, f"[라인나우] 대기가 등록되었어요 추후 입장 확정 문자를 확인해 주세요!")
             return custom_response(data=serializer.data, message="Waiting registered successfully !", code=status.HTTP_201_CREATED)
 
         return custom_response(data=serializer.errors, message="Failed to register waiting.", code=status.HTTP_400_BAD_REQUEST, success=False)
@@ -90,10 +94,9 @@ def confirm_waiting(self, request, pk=None):
         waiting = get_object_or_404(Waiting, pk=pk, user=user)
 
         if waiting.waiting_status == 'ready_to_confirm':
-            waiting.set_confirmed()
-
+            waiting.set_confirmed()       
             # 10분 후 check_confirmed task 호출
-            check_confirmed.apply_async((waiting.id,), countdown=600)  # 10분 (600초) 후 실행
+            check_confirmed.apply_async((waiting.id, waiting.user.phone_number), countdown=600)  # 10분 (600초) 후 실행
 
             return custom_response(message="Waiting confirmed successfully.", code=status.HTTP_200_OK)
         return custom_response(message="Unable to confirm waiting in current status.", code=status.HTTP_400_BAD_REQUEST, success=False)