Лаб. 2 полностью

ProjectAtelier/ProjectAtelier/Forms/FormModel.cs

@@ -1,4 +1,5 @@
 using ProjectAtelier.Entities;
+using ProjectAtelier.Entities.Enums;
 using ProjectAtelier.Repositories;
 
 namespace ProjectAtelier.Forms
@@ -10,10 +11,8 @@ namespace ProjectAtelier.Forms
         {
             InitializeComponent();
             _modelRepository = modelRepository ?? throw new ArgumentNullException(nameof(orderRepository));
-            
+
-            comboBoxModelType.DataSource = modelRepository.ReadModels();
+            comboBoxModelType.DataSource = Enum.GetValues(typeof(ModelType));
-            comboBoxModelType.DisplayMember = "ModelType";
-            comboBoxModelType.ValueMember = "Id";
 
             ColumnClothType.DataSource = clothRepository.ReadCloths();
             ColumnClothType.DisplayMember = "ClothType";

ProjectAtelier/ProjectAtelier/Program.cs

@@ -2,6 +2,10 @@ using Unity.Lifetime;
 using Unity;
 using ProjectAtelier.Repositories;
 using ProjectAtelier.Repositories.Implementations;
+using Unity.Microsoft.Logging;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Serilog;
 
 namespace ProjectAtelier
 {
@@ -22,12 +26,27 @@ namespace ProjectAtelier
         private static IUnityContainer CreateContainer()
         {
             var container = new UnityContainer();
+
+            container.AddExtension(new LoggingExtension(CreateLoggerFactory()));
+
             container.RegisterType<IClientRepository, ClientRepository>(new TransientLifetimeManager());
             container.RegisterType<IClothRepository, ClothRepository>(new TransientLifetimeManager());
             container.RegisterType<IEntranceRepository, EntranceRepository>(new TransientLifetimeManager());
             container.RegisterType<IModelRepository, ModelRepository>(new TransientLifetimeManager());
             container.RegisterType<IOrderRepository, OrderRepository>(new TransientLifetimeManager());
+            container.RegisterType<IConnectionString, ConnectionString>(new TransientLifetimeManager());
             return container;
         }
+        private static LoggerFactory CreateLoggerFactory()
+        {
+            var loggerFactory = new LoggerFactory();
+            loggerFactory.AddSerilog(new LoggerConfiguration()
+                .ReadFrom.Configuration(new ConfigurationBuilder()
+                    .SetBasePath(Directory.GetCurrentDirectory())
+                    .AddJsonFile("appsettings.json")
+                    .Build())
+                .CreateLogger());
+            return loggerFactory;
+        }
     }
 }

ProjectAtelier/ProjectAtelier/ProjectAtelier.csproj

@@ -9,7 +9,18 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Dapper" Version="2.1.35" />
+    <PackageReference Include="Microsoft.Extensions.Configuration" Version="9.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="9.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Logging" Version="9.0.0" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
+    <PackageReference Include="Npgsql" Version="9.0.1" />
+    <PackageReference Include="Serilog" Version="4.2.0" />
+    <PackageReference Include="Serilog.Extensions.Logging" Version="8.0.0" />
+    <PackageReference Include="Serilog.Settings.Configuration" Version="8.0.4" />
+    <PackageReference Include="Serilog.Sinks.File" Version="6.0.0" />
     <PackageReference Include="Unity" Version="5.11.10" />
+    <PackageReference Include="Unity.Microsoft.Logging" Version="5.11.1" />
   </ItemGroup>
 
   <ItemGroup>
@@ -27,4 +38,10 @@
     </EmbeddedResource>
   </ItemGroup>
 
+  <ItemGroup>
+    <None Update="appsettings.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </None>
+  </ItemGroup>
+
 </Project>

ProjectAtelier/ProjectAtelier/Repositories/IConnectionString.cs

@@ -0,0 +1,6 @@
+namespace ProjectAtelier.Repositories;
+
+public interface IConnectionString
+{
+    string ConnectionString { get; }
+}

ProjectAtelier/ProjectAtelier/Repositories/IModelRepository.cs

@@ -7,6 +7,5 @@ public interface IModelRepository
     IEnumerable<Model> ReadModels();
     Model ReadModelById(int id);
     void CreateModel(Model model);
-    void UpdateModel(Model model);
     void DeleteModel(int id);
 }

ProjectAtelier/ProjectAtelier/Repositories/Implementations/ClientRepository.cs

@@ -1,24 +1,119 @@
-using ProjectAtelier.Entities;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using Npgsql;
+using Dapper;
+using ProjectAtelier.Entities;
 
 namespace ProjectAtelier.Repositories.Implementations;
 
 internal class ClientRepository : IClientRepository
 {
+    private readonly IConnectionString _connectionString;
+
+    private readonly ILogger<ClientRepository> _logger;
+    public ClientRepository(IConnectionString connectionString, ILogger<ClientRepository> logger)
+    {
+        _connectionString = connectionString;
+        _logger = logger;
+    }
+
     public void CreateClient(Client client)
     {
-    }
+        _logger.LogInformation("Добавление объекта");
-    public void DeleteClient(int id)
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(client));
-    {
+        try
-    }
+        {
-    public Client ReadClientById(int id)
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
-    {
+            var queryInsert = @"
-        return Client.CreateEntity(0, string.Empty, string.Empty);
+INSERT INTO Clients (Name, Phone)
-    }
+VALUES (@Name, @Phone)";
-    public IEnumerable<Client> ReadClients()
+            connection.Execute(queryInsert, client);
-    {
+        }
-        return [];
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при добавлении объекта");
+            throw;
+        }
     }
     public void UpdateClient(Client client)
     {
+        _logger.LogInformation("Редактирование объекта");
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(client));
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryUpdate = @"
+UPDATE Clients
+SET
+    Name=@Name,
+    Phone=@Phone
+WHERE Id=@Id";
+            connection.Execute(queryUpdate, client);
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при редактировании объекта");
+            throw;
+        }
+    }
+    public void DeleteClient(int id)
+    {
+        _logger.LogInformation("Удаление объекта");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryDelete = @"
+DELETE FROM Clients
+WHERE Id=@id";
+            connection.Execute(queryDelete, new { id });
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при удалении объекта");
+            throw;
+        }
+    }
+    public Client ReadClientById(int id)
+    {
+        _logger.LogInformation("Получение объекта по идентификатору");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = @"
+SELECT * FROM Clients
+WHERE Id=@id";
+            var client = connection.QueryFirst<Client>(querySelect, new
+            {
+                id
+            });
+            _logger.LogDebug("Найденный объект: {json}",
+            JsonConvert.SerializeObject(client));
+            return client;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при поиске объекта");
+            throw;
+        }
+    }
+    public IEnumerable<Client> ReadClients()
+    {
+        _logger.LogInformation("Получение всех объектов");
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = "SELECT * FROM Clients";
+            var clients = connection.Query<Client>(querySelect);
+            _logger.LogDebug("Полученные объекты: {json}",
+            JsonConvert.SerializeObject(clients));
+            return clients;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при чтении объектов");
+            throw;
+        }
     }
 }

ProjectAtelier/ProjectAtelier/Repositories/Implementations/ClothRepository.cs

@@ -1,25 +1,118 @@
-using ProjectAtelier.Entities;
+using Dapper;
-using ProjectAtelier.Entities.Enums;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using Npgsql;
+using ProjectAtelier.Entities;
 
 namespace ProjectAtelier.Repositories.Implementations;
 
 internal class ClothRepository : IClothRepository
 {
+    private readonly IConnectionString _connectionString;
+
+    private readonly ILogger<ClothRepository> _logger;
+    public ClothRepository(IConnectionString connectionString, ILogger<ClothRepository> logger)
+    {
+        _connectionString = connectionString;
+        _logger = logger;
+    }
     public void CreateCloth(Cloth cloth)
     {
-    }
+        _logger.LogInformation("Добавление объекта");
-    public void DeleteCloth(int id)
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(cloth));
-    {
+        try
-    }
+        {
-    public Cloth ReadClothById(int id)
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
-    {
+            var queryInsert = @"
-        return Cloth.CreateEntity(0, ClothType.None, 0);
+INSERT INTO Cloths (ClothType, Length)
-    }
+VALUES (@ClothType, @Length)";
-    public IEnumerable<Cloth> ReadCloths()
+            connection.Execute(queryInsert, cloth);
-    {
+        }
-        return [];
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при добавлении объекта");
+            throw;
+        }
     }
     public void UpdateCloth(Cloth cloth)
     {
+        _logger.LogInformation("Редактирование объекта");
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(cloth));
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryUpdate = @"
+UPDATE Cloths
+SET
+    ClothType=@ClothType,
+    Length=@Length
+WHERE Id=@Id";
+            connection.Execute(queryUpdate, cloth);
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при редактировании объекта");
+            throw;
+        }
     }
+    public void DeleteCloth(int id)
+    {
+        _logger.LogInformation("Удаление объекта");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryDelete = @"
+DELETE FROM Cloths
+WHERE Id=@id";
+            connection.Execute(queryDelete, new { id });
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при удалении объекта");
+            throw;
+        }
+    }
+    public Cloth ReadClothById(int id)
+    {
+        _logger.LogInformation("Получение объекта по идентификатору");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = @"
+SELECT * FROM Cloths
+WHERE Id=@id";
+            var cloth = connection.QueryFirst<Cloth>(querySelect, new
+            {
+                id
+            });
+            _logger.LogDebug("Найденный объект: {json}",
+            JsonConvert.SerializeObject(cloth));
+            return cloth;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при поиске объекта");
+            throw;
+        }
+    }
+    public IEnumerable<Cloth> ReadCloths()
+    {
+        _logger.LogInformation("Получение всех объектов");
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = "SELECT * FROM Cloths";
+            var cloths = connection.Query<Cloth>(querySelect);
+            _logger.LogDebug("Полученные объекты: {json}",
+            JsonConvert.SerializeObject(cloths));
+            return cloths;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при чтении объектов");
+            throw;
+        }
+    }  
 }

ProjectAtelier/ProjectAtelier/Repositories/Implementations/ConnectionString.cs

@@ -0,0 +1,6 @@
+namespace ProjectAtelier.Repositories.Implementations;
+
+internal class ConnectionString : IConnectionString
+{
+    string IConnectionString.ConnectionString => "Host=localhost;Port=5432;Database=atelierotp;Username=postgres;Password=postgres";
+}

ProjectAtelier/ProjectAtelier/Repositories/Implementations/EntranceRepository.cs

@@ -1,14 +1,55 @@
-using ProjectAtelier.Entities;
+using Dapper;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using Npgsql;
+using ProjectAtelier.Entities;
 
 namespace ProjectAtelier.Repositories.Implementations;
 
 internal class EntranceRepository : IEntranceRepository
 {
+    private readonly IConnectionString _connectionString;
+
+    private readonly ILogger<EntranceRepository> _logger;
+    public EntranceRepository(IConnectionString connectionString, ILogger<EntranceRepository> logger)
+    {
+        _connectionString = connectionString;
+        _logger = logger;
+    }
     public void CreateEntrance(Entrance entrance)
     {
+        _logger.LogInformation("Добавление объекта");
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(entrance));
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryInsert = @"
+INSERT INTO Entrances (ClothId, Value, Date)
+VALUES (@ClothId, @Value, @Date)";
+            connection.Execute(queryInsert, entrance);
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при добавлении объекта");
+            throw;
+        }
     }
     public IEnumerable<Entrance> ReadEntrances(DateTime? dateForm = null, DateTime? dateTo = null, int? clothId = null)
     {
-        return [];
+        _logger.LogInformation("Получение всех объектов");
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = "SELECT * FROM Entrances";
+            var entrances = connection.Query<Entrance>(querySelect);
+            _logger.LogDebug("Полученные объекты: {json}",
+            JsonConvert.SerializeObject(entrances));
+            return entrances;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при чтении объектов");
+            throw;
+        }
     }
 }

ProjectAtelier/ProjectAtelier/Repositories/Implementations/ModelRepository.cs

@@ -1,24 +1,113 @@
-using ProjectAtelier.Entities;
+using Dapper;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using Npgsql;
+using ProjectAtelier.Entities;
 
 namespace ProjectAtelier.Repositories.Implementations;
 
 internal class ModelRepository : IModelRepository
 {
+    private readonly IConnectionString _connectionString;
+
+    private readonly ILogger<ModelRepository> _logger;
+    public ModelRepository(IConnectionString connectionString, ILogger<ModelRepository> logger)
+    {
+        _connectionString = connectionString;
+        _logger = logger;
+    }
     public void CreateModel(Model model)
     {
+        _logger.LogInformation("Добавление объекта");
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(model));
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            connection.Open();
+            using var transaction = connection.BeginTransaction();
+            var queryInsert = @"
+INSERT INTO Models (ModelType)
+VALUES (@ModelType);
+SELECT MAX(Id) FROM Models";
+            var modelId = connection.QueryFirst<int>(queryInsert, model, transaction);
+            var querySubInsert = @"
+INSERT INTO Expenditures (modelId, ClothId, Value)
+VALUES (@modelId,@ClothId, @Value)";
+            foreach (var elem in model.Expenditures)
+            {
+                connection.Execute(querySubInsert, new
+                {
+                    modelId,
+                    elem.ClothId,
+                    elem.Value
+                }, transaction);
+            }
+            transaction.Commit();
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при добавлении объекта");
+            throw;
+        }
     }
     public void DeleteModel(int id)
     {
+        _logger.LogInformation("Удаление объекта");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryDelete = @"
+DELETE FROM Models
+WHERE Id=@id";
+            connection.Execute(queryDelete, new { id });
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при удалении объекта");
+            throw;
+        }
     }
     public Model ReadModelById(int id)
     {
-        return null;
+        _logger.LogInformation("Получение объекта по идентификатору");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = @"
+SELECT * FROM Models
+WHERE Id=@id";
+            var model = connection.QueryFirst<Model>(querySelect, new
+            {
+                id
+            });
+            _logger.LogDebug("Найденный объект: {json}",
+            JsonConvert.SerializeObject(model));
+            return model;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при поиске объекта");
+            throw;
+        }
     }
     public IEnumerable<Model> ReadModels()
     {
-        return [];
+        _logger.LogInformation("Получение всех объектов");
-    }
+        try
-    public void UpdateModel(Model model)
+        {
-    {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = "SELECT * FROM Models";
+            var models = connection.Query<Model>(querySelect);
+            _logger.LogDebug("Полученные объекты: {json}",
+            JsonConvert.SerializeObject(models));
+            return models;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при чтении объектов");
+            throw;
+        }
     }
 }

ProjectAtelier/ProjectAtelier/Repositories/Implementations/OrderRepository.cs

@@ -1,17 +1,90 @@
-using ProjectAtelier.Entities;
+using Dapper;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using Npgsql;
+using ProjectAtelier.Entities;
 
 namespace ProjectAtelier.Repositories.Implementations;
 
 internal class OrderRepository : IOrderRepository
 {
+    private readonly IConnectionString _connectionString;
+
+    private readonly ILogger<OrderRepository> _logger;
+    public OrderRepository(IConnectionString connectionString, ILogger<OrderRepository> logger)
+    {
+        _connectionString = connectionString;
+        _logger = logger;
+    }
     public void CreateOrder(Order order)
     {
+        _logger.LogInformation("Добавление объекта");
+        _logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(order));
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            connection.Open();
+            using var transaction = connection.BeginTransaction();
+            var queryInsert = @"
+INSERT INTO Orders (ClientId, Prise, Date, Prints)
+VALUES (@ClientId, @Prise, @Date, @Prints);
+SELECT MAX(Id) FROM Orders";
+            var orderId = connection.QueryFirst<int>(queryInsert, order, transaction);
+            var querySubInsert = @"
+INSERT INTO ModelLists (orderId, ModelId, Count)
+VALUES (@orderId,@ModelId, @Count)";
+            foreach (var elem in order.ModelLists)
+            {
+                connection.Execute(querySubInsert, new
+                {
+                    orderId,
+                    elem.ModelId,
+                    elem.Count
+                }, transaction);
+            }
+            transaction.Commit();
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при добавлении объекта");
+            throw;
+        }
     }
     public void DeleteOrder(int id)
     {
+        _logger.LogInformation("Удаление объекта");
+        _logger.LogDebug("Объект: {id}", id);
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var queryDelete = @"
+DELETE FROM Orders
+WHERE Id=@id";
+            connection.Execute(queryDelete, new { id });
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при удалении объекта");
+            throw;
+        }
+
     }
     public IEnumerable<Order> ReadOrders(DateTime? dateForm = null, DateTime? dateTo = null, int? clientId = null, int? modelId = null)
     {
-        return [];
+        _logger.LogInformation("Получение всех объектов");
+        try
+        {
+            using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
+            var querySelect = @"SELECT * FROM Orders";
+            var orders = connection.Query<Order>(querySelect);
+            _logger.LogDebug("Полученные объекты: {json}",
+            JsonConvert.SerializeObject(orders));
+            return orders;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при чтении объектов");
+            throw;
+        }
     }
 }

ProjectAtelier/ProjectAtelier/appsettings.json

@@ -0,0 +1,15 @@
+{
+  "Serilog": {
+    "Using": [ "Serilog.Sinks.File" ],
+    "MinimumLevel": "Debug",
+    "WriteTo": [
+      {
+        "Name": "File",
+        "Args": {
+          "path": "Logs/atelier_log.txt",
+          "rollingInterval": "Day"
+        }
+      }
+    ]
+  }
+}