using DepartmentBusinessLogic.BindingModels; using DepartmentBusinessLogic.Enums; using DepartmentBusinessLogic.HelperModels; using DepartmentBusinessLogic.Interfaces; using DepartmentBusinessLogic.ViewModels; using ModuleTools.BusinessLogics; using ModuleTools.Enums; using ModuleTools.Extensions; using SecurityBusinessLogic.BindingModels; using SecurityBusinessLogic.BusinessLogics; using System; using System.Collections.Generic; using System.Linq; using System.Net.Http; using System.Net.Http.Headers; using System.Text; using System.Text.Json; using System.Threading.Tasks; namespace DepartmentBusinessLogic.BusinessLogics { /// /// Логика работы с историями синхронизации приказов /// public class OrderSyncHistoryBusinessLogic : GenericBusinessLogic { private OrderSyncHistoryRecordBusinessLogic _recordLogic; private EnviromentSettingBusinessLogic _enviromentSettingLogic; private StudentGroupBusinessLogic _groupsLogic; private StudentBusinessLogic _studentLogic; private UserBusinessLogic _userLogic; private OrderBusinessLogic _orderLogic; private OrderStudentRecordBusinessLogic _orderStudentRecordLogic; public OrderSyncHistoryBusinessLogic(IOrderSyncHistoryService service) : base(service, "Синхронизация Приказов", AccessOperation.СинхронизацияПриказов) { } public async Task SyncOrders() { var history = await CreateAsync(new OrderSyncHistorySetBindingModel { SyncDate = DateTime.Now }); if (history == null) { Errors.Add(("Ошибка создание истории", "Не удалось создать историю")); return false; } _recordLogic = DependencyManager.Instance.Resolve(); _enviromentSettingLogic = DependencyManager.Instance.Resolve(); _groupsLogic = DependencyManager.Instance.Resolve(); _studentLogic = DependencyManager.Instance.Resolve(); _orderLogic = DependencyManager.Instance.Resolve(); _orderStudentRecordLogic = DependencyManager.Instance.Resolve(); _userLogic = DependencyManager.Instance.Resolve(); var address = (await _enviromentSettingLogic.GetListAsync(new EnviromentSettingGetBindingModel { Key = "SyncStudentOrderIpAddress" }))?.List?.FirstOrDefault(); if (address == null || address.Value.IsEmpty()) { Errors = _enviromentSettingLogic.Errors; Errors.Add(("Ошибка получения данных", "Не удалось получить адрес серверая для получения приказов по студентам")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } var username = (await _enviromentSettingLogic.GetListAsync(new EnviromentSettingGetBindingModel { Key = "SyncStudentOrderUserName" }))?.List?.FirstOrDefault(); if (username == null || username.Value.IsEmpty()) { Errors = _enviromentSettingLogic.Errors; Errors.Add(("Ошибка получения данных", "Не удалось получить имя пользователя для получения приказов по студентам")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } var password = (await _enviromentSettingLogic.GetListAsync(new EnviromentSettingGetBindingModel { Key = "SyncStudentOrderPassword" }))?.List?.FirstOrDefault(); if (password == null || password.Value.IsEmpty()) { Errors = _enviromentSettingLogic.Errors; Errors.Add(("Ошибка получения данных", "Не удалось получить пароль для получения приказов по студентам")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } var client = new HttpClient { BaseAddress = new Uri(address.Value) }; client.DefaultRequestHeaders.Accept.Clear(); client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json")); client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Basic", Convert.ToBase64String(Encoding.UTF8.GetBytes($"{username.Value}:{password.Value}"))); // авторизация // получение списка студентов HttpResponseMessage response = await client.GetAsync($"{address.Value}/univer_Testing/hs/Ulstu_StudentsInfo/v1/GetCurrentStudentsOfDepartment"); if (!response.IsSuccessStatusCode) { Errors.Add(("Ошибка получения данных", "Не удалось получить список студентов с сервера")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } var studentFromServer = JsonSerializer.Deserialize(response.Content.ReadAsStringAsync().Result); if (studentFromServer.CurrentStudentsList.Count == 0) { await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = "Полученный список студентов пустой" }); return true; } var groups = await _groupsLogic.GetListAsync(new StudentGroupGetBindingModel()); if (groups == null || groups.List == null) { Errors = _groupsLogic.Errors; Errors.Add(("Ошибка получения данных", "Не удалось получить список групп")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } var students = await _studentLogic.GetListAsync(new StudentGetBindingModel()); if (students == null || students.List == null) { Errors = _studentLogic.Errors; Errors.Add(("Ошибка получения данных", "Не удалось получить список студентов")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return false; } foreach (var student in students.List) { var studentSync = studentFromServer.CurrentStudentsList.FirstOrDefault(x => x.recordBookName == student.NumberOfBook); // студент не найден, значит он ушел с кафедры, выясняем почему if (studentSync == null) { await SyncStudentOrders(history, student, groups.List, client, address.Value, studentSync.iduniv); } // не совпадение групп else if (student.StudentGroupName != studentSync.groupName) { await SyncStudentOrders(history, student, groups.List, client, address.Value, studentSync.iduniv); } studentFromServer.CurrentStudentsList.Remove(studentSync); } // новые студенты foreach (var student in studentFromServer.CurrentStudentsList) { var userName = $"{student.lastName}{(student.firstName.IsNotEmpty() ? $" {student.firstName[0]}." : string.Empty)}{(student.patronymicName.IsNotEmpty() ? $"{student.patronymicName[0]}." : string.Empty)}"; var result = await _userLogic.GetListAsync(new UserGetBindingModel { UserNameForSearch = userName }); var newuser = await _userLogic.CreateAsync(new UserSetBindingModel { Login = userName, Password = student.recordBookName }); if (newuser == null) { var errors = _userLogic.Errors; errors.Add(("Ошибка создания пользователя под студента", $"Не удалось создать пользователя под студента {student.lastName} {student.firstName} {student.patronymicName}")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, errors.Select(x => x.Message)) }); continue; } var newStudent = await _studentLogic.CreateAsync(new StudentSetBindingModel { UserId = newuser.Id, FirstName = student.firstName, LastName = student.lastName, Patronymic = student.patronymicName, NumberOfBook = student.recordBookName, StudentState = GetStudentState(student.stateName), Description = student.presenatationOfRecordBook }); if (newStudent == null) { var errors = _studentLogic.Errors; errors.Add(("Ошибка добавления студента", $"Не удалось добавить студента {student.lastName} {student.firstName} {student.patronymicName}")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, errors.Select(x => x.Message)) }); continue; } await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = $"Добавлен студент {newStudent}" }); await SyncStudentOrders(history, newStudent, groups.List, client, address.Value, student.iduniv); studentFromServer.CurrentStudentsList.Remove(student); } return true; } private static StudentState GetStudentState(string state) => state switch { "Является студентом" => StudentState.Учится, "Находится в академическом отпуске" => StudentState.Академ, _ => StudentState.Неопределен, }; /// /// Синхронизация приказов по студенту /// /// /// /// /// /// /// /// private async Task SyncStudentOrders(OrderSyncHistoryViewModel history, StudentViewModel student, List groups, HttpClient client, string address, string iduniv) { HttpResponseMessage response = await client.GetAsync($"{address}/univer_Testing/hs/Ulstu_StudentsInfo/v1/GetStudentOrdersByIdAndRecordBook?iduniv={iduniv}&recordBookName={student.NumberOfBook}&allOrders=sppd"); if (!response.IsSuccessStatusCode) { Errors.Add(("Ошибка получения данных", "Не удалось получить список приказов по студенту")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, Errors.Select(x => x.Message)) }); return; } var syncOrders = JsonSerializer.Deserialize(response.Content.ReadAsStringAsync().Result); foreach (var syncOrder in syncOrders.StudentOrders) { var orderType = GetOrderType(syncOrder.orderSubTypeName); // отбираем только приказы, которые нас интересуют if (orderType != OrderType.Неопределено) { // пытаемся найти приказ var order = await _orderLogic.GetElementAsync(new OrderGetBindingModel { OrderNumber = syncOrder.clericNumber, OrderDate = Convert.ToDateTime(syncOrder.clericDate) }); if (order == null) { // если не нашли - пытаемся создать order = await _orderLogic.CreateAsync(new OrderSetBindingModel { OrderNumber = syncOrder.clericNumber, OrderDate = Convert.ToDateTime(syncOrder.clericDate), OrderType = orderType }); if (order == null) { var errors = _orderLogic.Errors; errors.Add(("Ошибка добавления приказа", $"Не удалось добавить приказ {syncOrder.clericNumber} {syncOrder.clericDate}")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, errors.Select(x => x.Message)) }); continue; } } // ищем в приказе запись по студенту var studentOrder = await _orderStudentRecordLogic.GetElementAsync(new OrderStudentRecordGetBindingModel { OrderId = order.Id, StudentId = student.Id }); if (studentOrder == null) { Guid? studentGroupFromId = null; Guid? studentGroupToId = null; string info = string.Empty; if (syncOrder.groupNameBefore.IsNotEmpty()) { studentGroupFromId = groups.FirstOrDefault(x => x.ToString() == syncOrder.groupNameBefore)?.Id; } if (syncOrder.groupNameAfter.IsNotEmpty()) { studentGroupToId = groups.FirstOrDefault(x => x.ToString() == syncOrder.groupNameAfter)?.Id; } OrderStudentMoveType orderStudentMoveType = OrderStudentMoveType.Неопределено; switch (syncOrder.orderSubTypeName) { case "Перевод": // внутренний перевод if (studentGroupFromId.HasValue && studentGroupToId.HasValue) { orderStudentMoveType = OrderStudentMoveType.ПереводВГруппу; info = $"Перевод студента {student} из группы {groups.First(x => x.Id == studentGroupFromId)} в группу {groups.First(x => x.Id == studentGroupToId)}"; } else if (!studentGroupFromId.HasValue && studentGroupToId.HasValue) { orderStudentMoveType = OrderStudentMoveType.ЗачислитьПоПереводу; info = $"Зачисление переовдом студента {student} в группу {groups.First(x => x.Id == studentGroupToId)}"; } else if (studentGroupFromId.HasValue && !studentGroupToId.HasValue) { orderStudentMoveType = OrderStudentMoveType.ОтчислитьВСвязиСПереводом; info = $"Отчисление студента {student} из группы {groups.First(x => x.Id == studentGroupFromId)} в связи с переводом"; } break; case "Зачисление в вуз": orderStudentMoveType = OrderStudentMoveType.Зачисление; info = $"Зачисление студента {student}"; break; case "Распределение по группам": orderStudentMoveType = OrderStudentMoveType.Распределение; info = $"Распределение студента {student} в группу {groups.First(x => x.Id == studentGroupToId)}"; break; case "Перевод на следующий курс": orderStudentMoveType = OrderStudentMoveType.ПереводНаКурс; info = $"Перевод студента {student} на следующий курс"; break; } if (orderStudentMoveType == OrderStudentMoveType.Неопределено) { continue; } // создаем, если не нашли studentOrder = await _orderStudentRecordLogic.CreateAsync(new OrderStudentRecordSetBindingModel { OrderId = order.Id, StudentId = student.Id, Info = info, OrderStudentMoveType = orderStudentMoveType, StudentGroupFromId = studentGroupFromId, StudentGroupToId = studentGroupToId }); if (studentOrder == null) { var errors = _orderStudentRecordLogic.Errors; errors.Add(("Ошибка добавления записи приказа по студенту", $"Не удалось добавить запись приказа {syncOrder.orderSubTypeName} по студенту {student}")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, errors.Select(x => x.Message)) }); continue; } if (student.StudentGroupId != studentGroupToId) { var st = Mapper.MapToClass(student, true); st.StudentGroupId = studentGroupToId; var studentName = student.ToString(); student = await _studentLogic.UpdateAsync(st); if (student == null) { var errors = _studentLogic.Errors; errors.Add(("Ошибка изменения по студенту", $"Не удалось изменить группу у студента {studentName}")); await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = string.Join(Environment.NewLine, errors.Select(x => x.Message)) }); continue; } await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = $"У студента {student} сменилась группа на {student.StudentGroupName}" }); } await _recordLogic.CreateAsync(new OrderSyncHistoryRecordSetBindingModel { OrderSyncHistoryId = history.Id, Information = $"Добавили запись к приказу {order.OrderNumber} по студенту {student} с формулировкой {info}" }); if (orderStudentMoveType == OrderStudentMoveType.ОтчислитьВСвязиСПереводом || orderStudentMoveType == OrderStudentMoveType.ОтчислитьЗаНевыходСАкадема || orderStudentMoveType == OrderStudentMoveType.ОтчислитьЗаНеуспевамость || orderStudentMoveType == OrderStudentMoveType.ОтчислитьПоЗавершению || orderStudentMoveType == OrderStudentMoveType.ОтчислитьПоСобственному) { return; } } } } } private static OrderType GetOrderType(string orderTitle) => orderTitle switch { "Зачисление в вуз" => OrderType.ЗачислениеСтудентов, "Распределение по группам" => OrderType.РаспределениеСтудентов, "Перевод на следующий курс" => OrderType.ДвижениеСтудентов, _ => OrderType.Неопределено, }; } }