|
| 1 | +from django.core.management.base import BaseCommand |
| 2 | +from django.core.exceptions import ObjectDoesNotExist |
| 3 | +import time |
| 4 | + |
| 5 | +from account.models import User |
| 6 | +from chat.models import SmallChat, Message |
| 7 | + |
| 8 | + |
| 9 | +class Command(BaseCommand): |
| 10 | + help = "Создание тестовых сообщений для существующих чатов" |
| 11 | + |
| 12 | + def handle(self, *args, **kwargs): |
| 13 | + try: |
| 14 | + user1 = User.objects.get(username="user1") # Ирина |
| 15 | + user2 = User.objects.get(username="user2") # Мария |
| 16 | + user3 = User.objects.get(username="user3") # Алексей |
| 17 | + user4 = User.objects.get(username="user4") # Елена |
| 18 | + except ObjectDoesNotExist as e: |
| 19 | + self.stdout.write(self.style.ERROR(f"Ошибка: {e}")) |
| 20 | + return |
| 21 | + |
| 22 | + message_data = [ |
| 23 | + { |
| 24 | + "users": (user1, user2), |
| 25 | + "messages": [ |
| 26 | + (user1, "Здравствуйте, Мария! Нам посоветовали вас как логопеда."), |
| 27 | + (user2, "Здравствуйте! Да, я занимаюсь с детьми 4-7 лет."), |
| 28 | + (user1, "У дочки сложности с произношением 'р' и 'л'."), |
| 29 | + (user2, "Понимаю, можем начать со следующей недели."), |
| 30 | + ], |
| 31 | + }, |
| 32 | + { |
| 33 | + "users": (user1, user3), |
| 34 | + "messages": [ |
| 35 | + (user1, "Добрый день, Алексей! Слышали о вас хорошие отзывы."), |
| 36 | + (user3, "Спасибо, приятно слышать. Чем могу помочь?"), |
| 37 | + (user1, "Нужна помощь с развитием речи у сына 5 лет."), |
| 38 | + (user3, "Конечно. Давайте созвонимся для обсуждения."), |
| 39 | + ], |
| 40 | + }, |
| 41 | + { |
| 42 | + "users": (user4, user2), |
| 43 | + "messages": [ |
| 44 | + (user4, "Здравствуйте, Мария! Мы ищем дефектолога."), |
| 45 | + (user2, "Здравствуйте! Я как раз специализируюсь на этом."), |
| 46 | + (user4, "Ребёнок не разговаривает полными предложениями."), |
| 47 | + (user2, "Давайте организуем первый видеозвонок."), |
| 48 | + ], |
| 49 | + }, |
| 50 | + { |
| 51 | + "users": (user4, user3), |
| 52 | + "messages": [ |
| 53 | + (user4, "Алексей, добрый день! Вы работаете с детьми 3 лет?"), |
| 54 | + (user3, "Здравствуйте! Да, с такими детьми я работаю."), |
| 55 | + (user4, "Очень хорошо. Можем ли созвониться на следующей неделе?"), |
| 56 | + (user3, "Конечно, я свободен во вторник и пятницу."), |
| 57 | + ], |
| 58 | + }, |
| 59 | + ] |
| 60 | + |
| 61 | + for entry in message_data: |
| 62 | + u1, u2 = entry["users"] |
| 63 | + |
| 64 | + try: |
| 65 | + chat = SmallChat.objects.get(user1=u1, user2=u2) |
| 66 | + except SmallChat.DoesNotExist: |
| 67 | + try: |
| 68 | + chat = SmallChat.objects.get(user1=u2, user2=u1) |
| 69 | + except SmallChat.DoesNotExist: |
| 70 | + self.stdout.write( |
| 71 | + self.style.ERROR( |
| 72 | + f"Чат между {u1.username} и {u2.username} не найден" |
| 73 | + ) |
| 74 | + ) |
| 75 | + continue |
| 76 | + |
| 77 | + for sender, text in entry["messages"]: |
| 78 | + time.sleep(0.2) |
| 79 | + Message.objects.create(chat=chat, sender=sender, content=text) |
| 80 | + |
| 81 | + self.stdout.write( |
| 82 | + self.style.SUCCESS( |
| 83 | + f"Добавлены сообщения в чат {u1.username} <-> {u2.username}" |
| 84 | + ) |
| 85 | + ) |
0 commit comments