import os, sys, django sys.path.append("../") os.environ.setdefault("DJANGO_SETTINGS_MODULE", "lms.settings") django.setup() from journals.models import Thread from django.contrib.auth import get_user_model from lms.global_decorators import transaction_decorator @transaction_decorator def main_threads(): print("Инициализация основных тредов") res = {} support_list = [ 'kate.gazukina@skillbox.ru', 'katerina.ragozina@skillbox.ru', ] admin_list = [ 'andrey.korolev@skillbox.ru', 'pavel.matveev@skillbox.ru', 'anton.kopylov@skillbox.ru', ] admin_thread, _is_create = Thread.objects.get_or_create( key='Admin', text='Тред для админов, сюда падают все журналируемые сообщения в системе', is_staff=True, ) for i in get_user_model().objects.filter(email__in=admin_list): admin_thread.subscribers.add(i) management_thread, _is_create = Thread.objects.get_or_create( key='Project_management', text='Тред для проджект-менеджеров, сюда падает статистика разного рода', is_staff=True, ) management_thread.parent.add(admin_thread) support_thread, _is_create = Thread.objects.get_or_create( key='Support', text='Тред сапортов, занимаются поддержкой клиента', is_staff=True, ) for i in get_user_model().objects.filter(email__in=support_list): support_thread.subscribers.add(i) support_thread.parent.add(admin_thread) res['library_thread'], _is_create = Thread.objects.get_or_create( key='Library', text='Тред <<Библиотека>> сюда прилетает вся инфа по статьям', is_staff=True, ) res['library_thread'].parent.add(management_thread) course_thread, _is_create = Thread.objects.get_or_create( key='Course_thread', text='Тред курсов', is_staff=True, ) course_thread.parent.add(management_thread) start_and_end_thread, _is_create = Thread.objects.get_or_create( key='Start_and_end', text='Тред начала и завершения прохождения какого-либо этапа обучения', is_staff=True, ) start_and_end_thread.parent.add(course_thread) res['task_thread'], _is_create = Thread.objects.get_or_create( key='Tasks', text='Сюда пободают все переписки студентов и преподов', is_staff=True, ) res['task_thread'].parent.add(support_thread) return res if __name__ == '__main__': main_threads()