using JewelryStoreContracts.BindingModels; using JewelryStoreContracts.BusinessLogicsContracts; using JewelryStoreContracts.StoragesContracts; using JewelryStoreDataModels; using Microsoft.Extensions.Logging; using System; using System.Collections.Generic; using System.IO.Compression; using System.Linq; using System.Reflection; using System.Runtime.Serialization.Json; using System.Text; using System.Threading.Tasks; namespace JewelryStoreBusinessLogic.BusinessLogics { public class BackUpLogic : IBackUpLogic { private readonly ILogger _logger; private readonly IBackUpInfo _backUpInfo; public BackUpLogic(ILogger logger, IBackUpInfo backUpInfo) { _logger = logger; _backUpInfo = backUpInfo; } public void CreateBackUp(BackUpSaveBinidngModel model) { if (_backUpInfo == null) { return; } try { _logger.LogDebug("Clear folder"); // зачистка папки и удаление старого архива var dirInfo = new DirectoryInfo(model.FolderName); if (dirInfo.Exists) { foreach (var file in dirInfo.GetFiles()) { file.Delete(); } } _logger.LogDebug("Delete archive"); string fileName = $"{model.FolderName}.zip"; if (File.Exists(fileName)) { File.Delete(fileName); } // берем метод для сохранения _logger.LogDebug("Get assembly"); var typeIId = typeof(IId); var assembly = typeIId.Assembly; if (assembly == null) { throw new ArgumentNullException("Сборка не найдена", nameof(assembly)); } var types = assembly.GetTypes(); var method = GetType().GetMethod("SaveToFile", BindingFlags.NonPublic | BindingFlags.Instance); _logger.LogDebug("Find {count} types", types.Length); foreach (var type in types) { if (type.IsInterface && type.GetInterface(typeIId.Name) != null) { var modelType = _backUpInfo.GetTypeByModelInterface(type.Name); if (modelType == null) { throw new InvalidOperationException($"Не найден класс-модель для {type.Name}"); } _logger.LogDebug("Call SaveToFile method for {name} type", type.Name); // вызываем метод на выполнение method?.MakeGenericMethod(modelType).Invoke(this, new object[] { model.FolderName }); } } _logger.LogDebug("Create zip and remove folder"); // архивируем ZipFile.CreateFromDirectory(model.FolderName, fileName); // удаляем папку dirInfo.Delete(true); } catch (Exception) { throw; } } private void SaveToFile(string folderName) where T : class, new() { var records = _backUpInfo.GetList(); if (records == null) { _logger.LogWarning("{type} type get null list", typeof(T).Name); return; } var jsonFormatter = new DataContractJsonSerializer(typeof(List)); using var fs = new FileStream(string.Format("{0}/{1}.json", folderName, typeof(T).Name), FileMode.OpenOrCreate); jsonFormatter.WriteObject(fs, records); } } }