diff --git a/FishFactory/FishFactory.sln b/FishFactory/FishFactory.sln
index 802abb8..1d146e7 100644
--- a/FishFactory/FishFactory.sln
+++ b/FishFactory/FishFactory.sln
@@ -15,6 +15,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FishFactoryListImplement",
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FishFactoryFileImplement", "FishFactoryFileImplement\FishFactoryFileImplement.csproj", "{6C503B98-AEB3-4322-B8DF-1C0E3E294041}"
EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FishFactoryDatabaseImplement", "FishFactoryDatabaseImplement\FishFactoryDatabaseImplement.csproj", "{CFFEEB1E-413D-4624-8C30-E6D8860A9819}"
+EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@@ -45,6 +47,10 @@ Global
{6C503B98-AEB3-4322-B8DF-1C0E3E294041}.Debug|Any CPU.Build.0 = Debug|Any CPU
{6C503B98-AEB3-4322-B8DF-1C0E3E294041}.Release|Any CPU.ActiveCfg = Release|Any CPU
{6C503B98-AEB3-4322-B8DF-1C0E3E294041}.Release|Any CPU.Build.0 = Release|Any CPU
+ {CFFEEB1E-413D-4624-8C30-E6D8860A9819}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {CFFEEB1E-413D-4624-8C30-E6D8860A9819}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {CFFEEB1E-413D-4624-8C30-E6D8860A9819}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {CFFEEB1E-413D-4624-8C30-E6D8860A9819}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
diff --git a/FishFactory/FishFactory/FishFactoryView.csproj b/FishFactory/FishFactory/FishFactoryView.csproj
index 81b3f1e..3125cd1 100644
--- a/FishFactory/FishFactory/FishFactoryView.csproj
+++ b/FishFactory/FishFactory/FishFactoryView.csproj
@@ -16,6 +16,7 @@
+
diff --git a/FishFactory/FishFactory/Program.cs b/FishFactory/FishFactory/Program.cs
index 37f9e55..d9edc45 100644
--- a/FishFactory/FishFactory/Program.cs
+++ b/FishFactory/FishFactory/Program.cs
@@ -4,7 +4,7 @@ using FishFactoryContracts.StoragesContracts;
using FishFactoryView;
using Microsoft.Extensions.DependencyInjection;
using System;
-using FishFactoryFileImplement.Implements;
+using FishFactoryDatabaseImplement.Implements;
using Microsoft.Extensions.Logging;
using NLog.Extensions.Logging;
diff --git a/FishFactory/FishFactoryBusinessLogic/OrderLogic.cs b/FishFactory/FishFactoryBusinessLogic/OrderLogic.cs
index e53b151..d2834fa 100644
--- a/FishFactory/FishFactoryBusinessLogic/OrderLogic.cs
+++ b/FishFactory/FishFactoryBusinessLogic/OrderLogic.cs
@@ -60,7 +60,7 @@ namespace FishFactoryBusinessLogic.BusinessLogics
{
model.Status = newStatus;
if (model.Status == OrderStatus.Выдан)
- model.DateImplement = DateTime.Now;
+ model.DateImplement = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Utc);
if (_orderStorage.Update(model) == null)
{
_logger.LogWarning("Update operation failed");
diff --git a/FishFactory/FishFactoryContracts/BindingModels/OrderBindingModel.cs b/FishFactory/FishFactoryContracts/BindingModels/OrderBindingModel.cs
index 0fb0eed..58def85 100644
--- a/FishFactory/FishFactoryContracts/BindingModels/OrderBindingModel.cs
+++ b/FishFactory/FishFactoryContracts/BindingModels/OrderBindingModel.cs
@@ -15,7 +15,7 @@ namespace FishFactoryContracts.BindingModels
public int Count { get; set; }
public double Sum { get; set; }
public OrderStatus Status { get; set; } = OrderStatus.Неизвестен;
- public DateTime DateCreate { get; set; } = DateTime.Now;
+ public DateTime DateCreate { get; set; } = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Utc);
public DateTime? DateImplement { get; set; }
}
}
diff --git a/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabase.cs b/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabase.cs
new file mode 100644
index 0000000..31b8fd9
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabase.cs
@@ -0,0 +1,27 @@
+using FishFactoryDatabaseImplement.Models;
+using Microsoft.EntityFrameworkCore;
+using Npgsql.EntityFrameworkCore.PostgreSQL;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement
+{
+ public class FishFactoryDatabase : DbContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ {
+ if (optionsBuilder.IsConfigured == false)
+ {
+ optionsBuilder.UseNpgsql("Host=localhost;Port=5432;Database=FishFactory;Username=postgres;Password=postgres");
+ }
+ base.OnConfiguring(optionsBuilder);
+ }
+ public virtual DbSet Components { set; get; }
+ public virtual DbSet Canneds { set; get; }
+ public virtual DbSet CannedComponents { set; get; }
+ public virtual DbSet Orders { set; get; }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabaseImplement.csproj b/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabaseImplement.csproj
new file mode 100644
index 0000000..b53e457
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/FishFactoryDatabaseImplement.csproj
@@ -0,0 +1,19 @@
+
+
+
+ net6.0
+ enable
+ enable
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/FishFactory/FishFactoryDatabaseImplement/Implements/CannedStorage.cs b/FishFactory/FishFactoryDatabaseImplement/Implements/CannedStorage.cs
new file mode 100644
index 0000000..911edf1
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Implements/CannedStorage.cs
@@ -0,0 +1,111 @@
+using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.SearchModels;
+using FishFactoryContracts.StoragesContracts;
+using FishFactoryContracts.ViewModels;
+using FishFactoryDatabaseImplement.Models;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement.Implements
+{
+ public class CannedStorage : ICannedStorage
+ {
+ public List GetFullList()
+ {
+ using var context = new FishFactoryDatabase();
+ return context.Canneds
+ .Include(x => x.Components)
+ .ThenInclude(x => x.Component)
+ .ToList()
+ .Select(x => x.GetViewModel)
+ .ToList();
+ }
+ public List GetFilteredList(CannedSearchModel model)
+ {
+ if (string.IsNullOrEmpty(model.CannedName))
+ {
+ return new();
+ }
+ using var context = new FishFactoryDatabase();
+ return context.Canneds
+ .Include(x => x.Components)
+ .ThenInclude(x => x.Component)
+ .Where(x => x.CannedName.Contains(model.CannedName))
+ .ToList()
+ .Select(x => x.GetViewModel)
+ .ToList();
+ }
+ public CannedViewModel? GetElement(CannedSearchModel model)
+ {
+ if (string.IsNullOrEmpty(model.CannedName) &&
+ !model.Id.HasValue)
+ {
+ return null;
+ }
+ using var context = new FishFactoryDatabase();
+ return context.Canneds
+ .Include(x => x.Components)
+ .ThenInclude(x => x.Component)
+ .FirstOrDefault(x => (!string.IsNullOrEmpty(model.CannedName) &&
+ x.CannedName == model.CannedName) ||
+ (model.Id.HasValue && x.Id ==
+ model.Id))
+ ?.GetViewModel;
+ }
+ public CannedViewModel? Insert(CannedBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+ var newCanned = Canned.Create(context, model);
+ if (newCanned == null)
+ {
+ return null;
+ }
+ context.Canneds.Add(newCanned);
+ context.SaveChanges();
+ return newCanned.GetViewModel;
+ }
+ public CannedViewModel? Update(CannedBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+ using var transaction = context.Database.BeginTransaction();
+ try
+ {
+ var product = context.Canneds.FirstOrDefault(rec =>
+ rec.Id == model.Id);
+ if (product == null)
+ {
+ return null;
+ }
+ product.Update(model);
+ context.SaveChanges();
+ product.UpdateComponents(context, model);
+ transaction.Commit();
+ return product.GetViewModel;
+ }
+ catch
+ {
+ transaction.Rollback();
+ throw;
+ }
+ }
+ public CannedViewModel? Delete(CannedBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+ var element = context.Canneds
+ .Include(x => x.Components)
+ .FirstOrDefault(rec => rec.Id == model.Id);
+ if (element != null)
+ {
+ context.Canneds.Remove(element);
+ context.SaveChanges();
+ return element.GetViewModel;
+ }
+ return null;
+ }
+
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Implements/ComponentStorage.cs b/FishFactory/FishFactoryDatabaseImplement/Implements/ComponentStorage.cs
new file mode 100644
index 0000000..6676df5
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Implements/ComponentStorage.cs
@@ -0,0 +1,87 @@
+ using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.SearchModels;
+using FishFactoryContracts.StoragesContracts;
+using FishFactoryContracts.ViewModels;
+using FishFactoryDatabaseImplement.Models;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement.Implements
+{
+ public class ComponentStorage : IComponentStorage
+ {
+ public List GetFullList()
+ {
+ using var context = new FishFactoryDatabase();
+ return context.Components.Select(x => x.GetViewModel).ToList();
+ }
+ public List GetFilteredList(ComponentSearchModel
+ model)
+ {
+ if (string.IsNullOrEmpty(model.ComponentName))
+ {
+ return new();
+ }
+ using var context = new FishFactoryDatabase();
+ return context.Components
+ .Where(x => x.ComponentName.Contains(model.ComponentName))
+ .Select(x => x.GetViewModel)
+ .ToList();
+ }
+ public ComponentViewModel? GetElement(ComponentSearchModel model)
+ {
+ if (string.IsNullOrEmpty(model.ComponentName) && !model.Id.HasValue)
+ {
+ return null;
+ }
+ using var context = new FishFactoryDatabase();
+ return context.Components
+ .FirstOrDefault(x =>
+ (!string.IsNullOrEmpty(model.ComponentName) && x.ComponentName ==
+ model.ComponentName) ||
+ (model.Id.HasValue && x.Id == model.Id))
+ ?.GetViewModel;
+ }
+ public ComponentViewModel? Insert(ComponentBindingModel model)
+ {
+ var newComponent = Component.Create(model);
+ if (newComponent == null)
+ {
+ return null;
+ }
+ using var context = new FishFactoryDatabase();
+ context.Components.Add(newComponent);
+ context.SaveChanges();
+ return newComponent.GetViewModel;
+ }
+ public ComponentViewModel? Update(ComponentBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+ var component = context.Components.FirstOrDefault(x => x.Id ==
+ model.Id);
+ if (component == null)
+ {
+ return null;
+ }
+ component.Update(model);
+ context.SaveChanges();
+ return component.GetViewModel;
+ }
+ public ComponentViewModel? Delete(ComponentBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+ var element = context.Components.FirstOrDefault(rec => rec.Id ==
+ model.Id);
+ if (element != null)
+ {
+ context.Components.Remove(element);
+ context.SaveChanges();
+ return element.GetViewModel;
+ }
+ return null;
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Implements/OrderStorage.cs b/FishFactory/FishFactoryDatabaseImplement/Implements/OrderStorage.cs
new file mode 100644
index 0000000..97ae408
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Implements/OrderStorage.cs
@@ -0,0 +1,105 @@
+using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.SearchModels;
+using FishFactoryContracts.StoragesContracts;
+using FishFactoryContracts.ViewModels;
+using FishFactoryDatabaseImplement.Models;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement.Implements
+{
+ public class OrderStorage : IOrderStorage
+ {
+ public OrderViewModel? Delete(OrderBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+
+ var element = context.Orders.FirstOrDefault(rec => rec.Id == model.Id);
+
+ if (element != null)
+ {
+ context.Orders.Remove(element);
+ context.SaveChanges();
+
+ return GetViewModel(element);
+ }
+
+ return null;
+ }
+
+ public OrderViewModel? GetElement(OrderSearchModel model)
+ {
+ if (!model.Id.HasValue)
+ {
+ return null;
+ }
+
+ using var context = new FishFactoryDatabase();
+
+ return GetViewModel(context.Orders.FirstOrDefault(x => (model.Id.HasValue && x.Id == model.Id)));
+ }
+
+ public List GetFilteredList(OrderSearchModel model)
+ {
+ if (!model.Id.HasValue)
+ {
+ return new();
+ }
+
+ using var context = new FishFactoryDatabase();
+
+ return context.Orders.Where(x => x.Id == model.Id).Select(x => GetViewModel(x)).ToList();
+ }
+
+ public List GetFullList()
+ {
+ using var context = new FishFactoryDatabase();
+
+ return context.Orders.Select(x => GetViewModel(x)).ToList();
+ }
+
+ public OrderViewModel? Insert(OrderBindingModel model)
+ {
+ var newOrder = Order.Create(model);
+ if (newOrder == null)
+ {
+ return null;
+ }
+
+ using var context = new FishFactoryDatabase();
+
+ context.Orders.Add(newOrder);
+ context.SaveChanges();
+ return GetViewModel(newOrder);
+ }
+
+ public OrderViewModel? Update(OrderBindingModel model)
+ {
+ using var context = new FishFactoryDatabase();
+
+ var order = context.Orders.FirstOrDefault(x => x.Id == model.Id);
+
+ if (order == null)
+ {
+ return null;
+ }
+
+ order.Update(model);
+ context.SaveChanges();
+
+ return GetViewModel(order);
+ }
+
+ private static OrderViewModel GetViewModel(Order order)
+ {
+ var viewModel = order.GetViewModel;
+ using var context = new FishFactoryDatabase();
+ var element = context.Canneds.FirstOrDefault(x => x.Id == order.CannedId);
+ viewModel.CannedName = element.CannedName;
+ return viewModel;
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.Designer.cs b/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.Designer.cs
new file mode 100644
index 0000000..0be7f32
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.Designer.cs
@@ -0,0 +1,169 @@
+//
+using System;
+using FishFactoryDatabaseImplement;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace FishFactoryDatabaseImplement.Migrations
+{
+ [DbContext(typeof(FishFactoryDatabase))]
+ [Migration("20230227185524_MigrateInit")]
+ partial class MigrateInit
+ {
+ ///
+ protected override void BuildTargetModel(ModelBuilder modelBuilder)
+ {
+#pragma warning disable 612, 618
+ modelBuilder
+ .HasAnnotation("ProductVersion", "7.0.3")
+ .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+ NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Canned", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedName")
+ .IsRequired()
+ .HasColumnType("text");
+
+ b.Property("Price")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.ToTable("Canneds");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.CannedComponent", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedId")
+ .HasColumnType("integer");
+
+ b.Property("ComponentId")
+ .HasColumnType("integer");
+
+ b.Property("Count")
+ .HasColumnType("integer");
+
+ b.HasKey("Id");
+
+ b.HasIndex("CannedId");
+
+ b.HasIndex("ComponentId");
+
+ b.ToTable("CannedComponents");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Component", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("ComponentName")
+ .IsRequired()
+ .HasColumnType("text");
+
+ b.Property("Cost")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.ToTable("Components");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Order", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedId")
+ .HasColumnType("integer");
+
+ b.Property("Count")
+ .HasColumnType("integer");
+
+ b.Property("DateCreate")
+ .HasColumnType("timestamp with time zone");
+
+ b.Property("DateImplement")
+ .HasColumnType("timestamp with time zone");
+
+ b.Property("Status")
+ .HasColumnType("integer");
+
+ b.Property("Sum")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.HasIndex("CannedId");
+
+ b.ToTable("Orders");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.CannedComponent", b =>
+ {
+ b.HasOne("FishFactoryDatabaseImplement.Models.Canned", "Canned")
+ .WithMany("Components")
+ .HasForeignKey("CannedId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+
+ b.HasOne("FishFactoryDatabaseImplement.Models.Component", "Component")
+ .WithMany("CannedComponents")
+ .HasForeignKey("ComponentId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+
+ b.Navigation("Canned");
+
+ b.Navigation("Component");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Order", b =>
+ {
+ b.HasOne("FishFactoryDatabaseImplement.Models.Canned", null)
+ .WithMany("Orders")
+ .HasForeignKey("CannedId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Canned", b =>
+ {
+ b.Navigation("Components");
+
+ b.Navigation("Orders");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Component", b =>
+ {
+ b.Navigation("CannedComponents");
+ });
+#pragma warning restore 612, 618
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.cs b/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.cs
new file mode 100644
index 0000000..f2e96df
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Migrations/20230227185524_MigrateInit.cs
@@ -0,0 +1,126 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace FishFactoryDatabaseImplement.Migrations
+{
+ ///
+ public partial class MigrateInit : Migration
+ {
+ ///
+ protected override void Up(MigrationBuilder migrationBuilder)
+ {
+ migrationBuilder.CreateTable(
+ name: "Canneds",
+ columns: table => new
+ {
+ Id = table.Column(type: "integer", nullable: false)
+ .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+ CannedName = table.Column(type: "text", nullable: false),
+ Price = table.Column(type: "double precision", nullable: false)
+ },
+ constraints: table =>
+ {
+ table.PrimaryKey("PK_Canneds", x => x.Id);
+ });
+
+ migrationBuilder.CreateTable(
+ name: "Components",
+ columns: table => new
+ {
+ Id = table.Column(type: "integer", nullable: false)
+ .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+ ComponentName = table.Column(type: "text", nullable: false),
+ Cost = table.Column(type: "double precision", nullable: false)
+ },
+ constraints: table =>
+ {
+ table.PrimaryKey("PK_Components", x => x.Id);
+ });
+
+ migrationBuilder.CreateTable(
+ name: "Orders",
+ columns: table => new
+ {
+ Id = table.Column(type: "integer", nullable: false)
+ .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+ CannedId = table.Column(type: "integer", nullable: false),
+ Count = table.Column(type: "integer", nullable: false),
+ Sum = table.Column(type: "double precision", nullable: false),
+ Status = table.Column(type: "integer", nullable: false),
+ DateCreate = table.Column(type: "timestamp with time zone", nullable: false),
+ DateImplement = table.Column(type: "timestamp with time zone", nullable: true)
+ },
+ constraints: table =>
+ {
+ table.PrimaryKey("PK_Orders", x => x.Id);
+ table.ForeignKey(
+ name: "FK_Orders_Canneds_CannedId",
+ column: x => x.CannedId,
+ principalTable: "Canneds",
+ principalColumn: "Id",
+ onDelete: ReferentialAction.Cascade);
+ });
+
+ migrationBuilder.CreateTable(
+ name: "CannedComponents",
+ columns: table => new
+ {
+ Id = table.Column(type: "integer", nullable: false)
+ .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+ CannedId = table.Column(type: "integer", nullable: false),
+ ComponentId = table.Column(type: "integer", nullable: false),
+ Count = table.Column(type: "integer", nullable: false)
+ },
+ constraints: table =>
+ {
+ table.PrimaryKey("PK_CannedComponents", x => x.Id);
+ table.ForeignKey(
+ name: "FK_CannedComponents_Canneds_CannedId",
+ column: x => x.CannedId,
+ principalTable: "Canneds",
+ principalColumn: "Id",
+ onDelete: ReferentialAction.Cascade);
+ table.ForeignKey(
+ name: "FK_CannedComponents_Components_ComponentId",
+ column: x => x.ComponentId,
+ principalTable: "Components",
+ principalColumn: "Id",
+ onDelete: ReferentialAction.Cascade);
+ });
+
+ migrationBuilder.CreateIndex(
+ name: "IX_CannedComponents_CannedId",
+ table: "CannedComponents",
+ column: "CannedId");
+
+ migrationBuilder.CreateIndex(
+ name: "IX_CannedComponents_ComponentId",
+ table: "CannedComponents",
+ column: "ComponentId");
+
+ migrationBuilder.CreateIndex(
+ name: "IX_Orders_CannedId",
+ table: "Orders",
+ column: "CannedId");
+ }
+
+ ///
+ protected override void Down(MigrationBuilder migrationBuilder)
+ {
+ migrationBuilder.DropTable(
+ name: "CannedComponents");
+
+ migrationBuilder.DropTable(
+ name: "Orders");
+
+ migrationBuilder.DropTable(
+ name: "Components");
+
+ migrationBuilder.DropTable(
+ name: "Canneds");
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Migrations/FishFactoryDatabaseModelSnapshot.cs b/FishFactory/FishFactoryDatabaseImplement/Migrations/FishFactoryDatabaseModelSnapshot.cs
new file mode 100644
index 0000000..69adfec
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Migrations/FishFactoryDatabaseModelSnapshot.cs
@@ -0,0 +1,166 @@
+//
+using System;
+using FishFactoryDatabaseImplement;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace FishFactoryDatabaseImplement.Migrations
+{
+ [DbContext(typeof(FishFactoryDatabase))]
+ partial class FishFactoryDatabaseModelSnapshot : ModelSnapshot
+ {
+ protected override void BuildModel(ModelBuilder modelBuilder)
+ {
+#pragma warning disable 612, 618
+ modelBuilder
+ .HasAnnotation("ProductVersion", "7.0.3")
+ .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+ NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Canned", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedName")
+ .IsRequired()
+ .HasColumnType("text");
+
+ b.Property("Price")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.ToTable("Canneds");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.CannedComponent", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedId")
+ .HasColumnType("integer");
+
+ b.Property("ComponentId")
+ .HasColumnType("integer");
+
+ b.Property("Count")
+ .HasColumnType("integer");
+
+ b.HasKey("Id");
+
+ b.HasIndex("CannedId");
+
+ b.HasIndex("ComponentId");
+
+ b.ToTable("CannedComponents");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Component", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("ComponentName")
+ .IsRequired()
+ .HasColumnType("text");
+
+ b.Property("Cost")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.ToTable("Components");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Order", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("integer");
+
+ NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property("Id"));
+
+ b.Property("CannedId")
+ .HasColumnType("integer");
+
+ b.Property("Count")
+ .HasColumnType("integer");
+
+ b.Property("DateCreate")
+ .HasColumnType("timestamp with time zone");
+
+ b.Property("DateImplement")
+ .HasColumnType("timestamp with time zone");
+
+ b.Property("Status")
+ .HasColumnType("integer");
+
+ b.Property("Sum")
+ .HasColumnType("double precision");
+
+ b.HasKey("Id");
+
+ b.HasIndex("CannedId");
+
+ b.ToTable("Orders");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.CannedComponent", b =>
+ {
+ b.HasOne("FishFactoryDatabaseImplement.Models.Canned", "Canned")
+ .WithMany("Components")
+ .HasForeignKey("CannedId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+
+ b.HasOne("FishFactoryDatabaseImplement.Models.Component", "Component")
+ .WithMany("CannedComponents")
+ .HasForeignKey("ComponentId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+
+ b.Navigation("Canned");
+
+ b.Navigation("Component");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Order", b =>
+ {
+ b.HasOne("FishFactoryDatabaseImplement.Models.Canned", null)
+ .WithMany("Orders")
+ .HasForeignKey("CannedId")
+ .OnDelete(DeleteBehavior.Cascade)
+ .IsRequired();
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Canned", b =>
+ {
+ b.Navigation("Components");
+
+ b.Navigation("Orders");
+ });
+
+ modelBuilder.Entity("FishFactoryDatabaseImplement.Models.Component", b =>
+ {
+ b.Navigation("CannedComponents");
+ });
+#pragma warning restore 612, 618
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Models/Canned.cs b/FishFactory/FishFactoryDatabaseImplement/Models/Canned.cs
new file mode 100644
index 0000000..5cf70bf
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Models/Canned.cs
@@ -0,0 +1,93 @@
+using FishFactoryDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.ViewModels;
+
+namespace FishFactoryDatabaseImplement.Models
+{
+ public class Canned : ICannedModel
+ {
+ public int Id { get; set; }
+ [Required]
+ public string CannedName { get; set; } = string.Empty;
+ [Required]
+ public double Price { get; set; }
+ private Dictionary? _cannedComponents = null;
+ [NotMapped]
+ public Dictionary CannedComponents
+ {
+ get
+ {
+ if (_cannedComponents == null)
+ {
+ _cannedComponents = Components.ToDictionary(recPC => recPC.ComponentId, recPC => (recPC.Component as IComponentModel, recPC.Count));
+ }
+ return _cannedComponents;
+ }
+ }
+ [ForeignKey("CannedId")]
+ public virtual List Components { get; set; } = new();
+ [ForeignKey("CannedId")]
+ public virtual List Orders { get; set; } = new();
+ public static Canned Create(FishFactoryDatabase context, CannedBindingModel model)
+ {
+ return new Canned()
+ {
+ Id = model.Id,
+ CannedName = model.CannedName,
+ Price = model.Price,
+ Components = model.CannedComponents.Select(x => new CannedComponent
+ {
+ Component = context.Components.First(y => y.Id == x.Key),
+ Count = x.Value.Item2
+ }).ToList()
+ };
+ }
+ public void Update(CannedBindingModel model)
+ {
+ CannedName = model.CannedName;
+ Price = model.Price;
+ }
+ public CannedViewModel GetViewModel => new()
+ {
+ Id = Id,
+ CannedName = CannedName,
+ Price = Price,
+ CannedComponents = CannedComponents
+ };
+ public void UpdateComponents(FishFactoryDatabase context, CannedBindingModel model)
+ {
+ var cannedComponents = context.CannedComponents.Where(rec => rec.CannedId == model.Id).ToList();
+ if (cannedComponents != null && cannedComponents.Count > 0)
+ { // удалили те, которых нет в модели
+ context.CannedComponents.RemoveRange(cannedComponents.Where(rec => !model.CannedComponents.ContainsKey(rec.ComponentId)));
+ context.SaveChanges();
+ // обновили количество у существующих записей
+ foreach (var updateComponent in cannedComponents)
+ {
+ updateComponent.Count = model.CannedComponents[updateComponent.ComponentId].Item2;
+ model.CannedComponents.Remove(updateComponent.ComponentId);
+ }
+ context.SaveChanges();
+ }
+ var canned = context.Canneds.First(x => x.Id == Id);
+ foreach (var pc in model.CannedComponents)
+ {
+ context.CannedComponents.Add(new CannedComponent
+ {
+ Canned = canned,
+ Component = context.Components.First(x => x.Id == pc.Key),
+ Count = pc.Value.Item2
+ });
+ context.SaveChanges();
+ }
+ _cannedComponents = null;
+ }
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Models/CannedComponent.cs b/FishFactory/FishFactoryDatabaseImplement/Models/CannedComponent.cs
new file mode 100644
index 0000000..904054f
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Models/CannedComponent.cs
@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement.Models
+{
+ public class CannedComponent
+ {
+ public int Id { get; set; }
+ [Required]
+ public int CannedId { get; set; }
+ [Required]
+ public int ComponentId { get; set; }
+ [Required]
+ public int Count { get; set; }
+ public virtual Component Component { get; set; } = new();
+ public virtual Canned Canned { get; set; } = new();
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Models/Component.cs b/FishFactory/FishFactoryDatabaseImplement/Models/Component.cs
new file mode 100644
index 0000000..2b46641
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Models/Component.cs
@@ -0,0 +1,61 @@
+using FishFactoryDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.ViewModels;
+
+namespace FishFactoryDatabaseImplement.Models
+{
+ public class Component : IComponentModel
+ {
+ public int Id { get; private set; }
+ [Required]
+ public string ComponentName { get; private set; } = string.Empty;
+ [Required]
+ public double Cost { get; set; }
+ [ForeignKey("ComponentId")]
+ public virtual List CannedComponents { get; set; } = new();
+ public static Component? Create(ComponentBindingModel model)
+ {
+ if (model == null)
+ {
+ return null;
+ }
+ return new Component()
+ {
+ Id = model.Id,
+ ComponentName = model.ComponentName,
+ Cost = model.Cost
+ };
+ }
+ public static Component Create(ComponentViewModel model)
+ {
+ return new Component
+ {
+ Id = model.Id,
+ ComponentName = model.ComponentName,
+ Cost = model.Cost
+ };
+ }
+ public void Update(ComponentBindingModel model)
+ {
+ if (model == null)
+ {
+ return;
+ }
+ ComponentName = model.ComponentName;
+ Cost = model.Cost;
+ }
+ public ComponentViewModel GetViewModel => new()
+ {
+ Id = Id,
+ ComponentName = ComponentName,
+ Cost = Cost
+ };
+ }
+}
diff --git a/FishFactory/FishFactoryDatabaseImplement/Models/Order.cs b/FishFactory/FishFactoryDatabaseImplement/Models/Order.cs
new file mode 100644
index 0000000..57b8c01
--- /dev/null
+++ b/FishFactory/FishFactoryDatabaseImplement/Models/Order.cs
@@ -0,0 +1,90 @@
+using FishFactoryContracts.BindingModels;
+using FishFactoryContracts.ViewModels;
+using FishFactoryDataModels.Enums;
+using FishFactoryDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FishFactoryDatabaseImplement.Models
+{
+ public class Order : IOrderModel
+ {
+ public int Id { get; set; }
+ [Required]
+ public int CannedId { get; set; }
+
+ [Required]
+ public int Count { get; set; }
+ [Required]
+
+ public double Sum { get; set; }
+ [Required]
+
+ public OrderStatus Status { get; set; }
+ [Required]
+
+ public DateTime DateCreate { get; set; }
+
+ public DateTime? DateImplement { get; set; }
+
+ public static Order? Create(OrderBindingModel model)
+ {
+ if (model == null)
+ {
+ return null;
+ }
+ return new Order()
+ {
+ Id = model.Id,
+ CannedId = model.CannedId,
+ Count = model.Count,
+ Sum = model.Sum,
+ Status = model.Status,
+ DateCreate = model.DateCreate,
+ DateImplement = model.DateImplement
+ };
+ }
+ public static Order Create(OrderViewModel model)
+ {
+ return new Order
+ {
+ Id = model.Id,
+ CannedId = model.CannedId,
+ Count = model.Count,
+ Sum = model.Sum,
+ Status = model.Status,
+ DateCreate = model.DateCreate,
+ DateImplement = model.DateImplement
+ };
+ }
+
+ public void Update(OrderBindingModel model)
+ {
+ if (model == null)
+ {
+ return;
+ }
+ Id = model.Id;
+ CannedId = model.CannedId;
+ Count = model.Count;
+ Sum = model.Sum;
+ Status = model.Status;
+ DateCreate = model.DateCreate;
+ DateImplement = model.DateImplement;
+ }
+ public OrderViewModel GetViewModel => new()
+ {
+ Id = Id,
+ CannedId = CannedId,
+ Count = Count,
+ Sum = Sum,
+ Status = Status,
+ DateCreate = DateCreate,
+ DateImplement = DateImplement
+ };
+ }
+}