Готовая 3 лаба

PlumbingRepair/PlumbingRepair/FormStore.cs

@@ -56,7 +56,7 @@ namespace PlumbingRepairView
                     Id = _id ?? 0,
                     StoreName = NameTextBox.Text,
                     StoreAdress = AdressTextBox.Text,
-                    OpeningDate = OpeningDatePicker.Value.Date,
+                    OpeningDate = DateTime.SpecifyKind(OpeningDatePicker.Value.Date, DateTimeKind.Utc),
                     WorkMaxCount = (int)VolumeNumericUpDown.Value,
                     StoreWorks = _listStores
                 };

PlumbingRepair/PlumbingRepairBusinessLogic/BusinessLogics/OrderLogic.cs

@@ -93,7 +93,7 @@ namespace PlumbingRepairBusinessLogic.BusinessLogics
 
             if (model.Status == OrderStatus.Готов)
             {
-                model.DateImplement = DateTime.Now;
+                model.DateImplement = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Utc);
                 var work = _workStorage.GetElement(new() { Id = viewModel.WorkId });
 
                 if (work == null)

PlumbingRepair/PlumbingRepairBusinessLogic/BusinessLogics/StoreLogic.cs

@@ -54,7 +54,7 @@ namespace PlumbingRepairBusinessLogic.BusinessLogics
             else
             {
                 element.StoreWorks[work.Id] = (work, quantity);
-                _logger.LogInformation("AddWork. Added {quantity} new package {package} to '{StoreName}' store", quantity, work.WorkName, element.StoreName);
+                _logger.LogInformation("AddWork. Added {quantity} new work  {work} to '{StoreName}' store", quantity, work.WorkName, element.StoreName);
             }
 
             _storeStorage.Update(new()

PlumbingRepair/PlumbingRepairContracts/BindingModels/StoreBindingModel.cs

@@ -12,7 +12,7 @@ namespace PlumbingRepairContracts.BindingModels
         public int Id { get; set; }
         public string StoreName { get; set; } = string.Empty;
         public string StoreAdress { get; set; } = string.Empty;
-        public DateTime OpeningDate { get; set; } = DateTime.Now;
+        public DateTime OpeningDate { get; set; }
         public Dictionary<int, (IWorkModel, int)> StoreWorks { get; set; } = new();
         public int WorkMaxCount { get; set; }
     }

PlumbingRepair/PlumbingRepairContracts/ViewModels/StoreViewModel.cs

@@ -17,7 +17,7 @@ namespace PlumbingRepairContracts.ViewModels
         [DisplayName("Адрес магазина")]
         public string StoreAdress { get; set; } = string.Empty;
         [DisplayName("Дата открытия")]
-        public DateTime OpeningDate { get; set; } = DateTime.Now;
+        public DateTime OpeningDate { get; set; }
         [DisplayName("Вместимость магазина")]
         public int WorkMaxCount { get; set; }
     }

PlumbingRepair/PlumbingRepairDataBaseImplement/Implements/StoreStorage.cs

@@ -0,0 +1,168 @@
+using Microsoft.EntityFrameworkCore;
+using PlumbingRepairContracts.BindingModels;
+using PlumbingRepairContracts.SearchModels;
+using PlumbingRepairContracts.StoragesContracts;
+using PlumbingRepairContracts.ViewModels;
+using PlumbingRepairDataBaseImplement.Models;
+using PlumbingRepairDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PlumbingRepairDataBaseImplement.Implements
+{
+    public class StoreStorage : IStoreStorage
+    {
+        public StoreViewModel? Delete(StoreBindingModel model)
+        {
+            using var context = new PlumbingRepairDataBase();
+
+            var element = context.Stores
+                .Include(x => x.Works)
+                .FirstOrDefault(rec => rec.Id == model.Id);
+
+            if (element != null)
+            {
+                context.Stores.Remove(element);
+                context.SaveChanges();
+
+                return element.GetViewModel;
+            }
+
+            return null;
+        }
+
+        public StoreViewModel? GetElement(StoreSearchModel model)
+        {
+            if (string.IsNullOrEmpty(model.StoreName) && !model.Id.HasValue)
+            {
+                return null;
+            }
+
+            using var context = new PlumbingRepairDataBase();
+
+            return context.Stores
+                .Include(x => x.Works)
+                .ThenInclude(x => x.Work)
+                .FirstOrDefault(x => (!string.IsNullOrEmpty(model.StoreName) && x.StoreName == model.StoreName) || (model.Id.HasValue && x.Id == model.Id))
+                ?.GetViewModel;
+        }
+
+        public List<StoreViewModel> GetFilteredList(StoreSearchModel model)
+        {
+            if (string.IsNullOrEmpty(model.StoreName))
+            {
+                return new();
+            }
+
+            using var context = new PlumbingRepairDataBase();
+
+            return context.Stores
+                    .Include(x => x.Works)
+                    .ThenInclude(x => x.Work)
+                    .Where(x => x.StoreName.Contains(model.StoreName))
+                    .ToList()
+                    .Select(x => x.GetViewModel)
+                    .ToList();
+        }
+
+        public List<StoreViewModel> GetFullList()
+        {
+            using var context = new PlumbingRepairDataBase();
+            return context.Stores
+                    .Include(x => x.Works)
+                    .ThenInclude(x => x.Work)
+                    .ToList()
+                    .Select(x => x.GetViewModel)
+                    .ToList();
+        }
+
+        public StoreViewModel? Insert(StoreBindingModel model)
+        {
+            using var context = new PlumbingRepairDataBase();
+            var newStore = Store.Create(context, model);
+            if (newStore == null)
+            {
+                return null;
+            }
+            context.Stores.Add(newStore);
+            context.SaveChanges();
+            return newStore.GetViewModel;
+        }
+
+        public bool SellWork(IWorkModel model, int quantity)
+        {
+            using var context = new PlumbingRepairDataBase();
+            using var transaction = context.Database.BeginTransaction();
+            try
+            {
+                foreach (var store in context.Stores
+                    .Include(x => x.Works)
+                    .ThenInclude(x => x.Work)
+                    .ToList()
+                    .Where(x => x.StoreWorks.ContainsKey(model.Id)))
+                {
+                    int countInCurrentStore = store.StoreWorks[model.Id].Item2;
+                    if (countInCurrentStore <= quantity)
+                    {
+                        var elem = context.StoreWorks
+                            .Where(x => x.WorkId == model.Id)
+                            .FirstOrDefault(x => x.StoreId == store.Id);
+                        context.StoreWorks.Remove(elem);
+                        store.StoreWorks.Remove(model.Id);
+                        quantity -= countInCurrentStore;
+                    }
+                    else
+                    {
+                        store.StoreWorks[model.Id] = (store.StoreWorks[model.Id].Item1, countInCurrentStore - quantity);
+                        quantity = 0;
+                        store.UpdateWorks(context, new()
+                        {
+                            Id = store.Id,
+                            StoreWorks = store.StoreWorks,
+                        });
+                    }
+                    if (quantity == 0)
+                    {
+                        context.SaveChanges();
+                        transaction.Commit();
+                        return true;
+                    }
+                }
+                transaction.Rollback();
+                return false;
+            }
+            catch
+            {
+                transaction.Rollback();
+                throw;
+            }
+        }
+
+        public StoreViewModel? Update(StoreBindingModel model)
+        {
+            using var context = new PlumbingRepairDataBase();
+            using var transaction = context.Database.BeginTransaction();
+            try
+            {
+                var store = context.Stores.FirstOrDefault(rec => rec.Id == model.Id);
+                if (store == null)
+                {
+                    return null;
+                }
+                store.Update(model);
+                context.SaveChanges();
+                store.UpdateWorks(context, model);
+                transaction.Commit();
+                return store.GetViewModel;
+            }
+            catch
+            {
+                transaction.Rollback();
+                throw;
+            }
+        }
+    }
+}

PlumbingRepair/PlumbingRepairDataBaseImplement/Migrations/20240506071751_InitialCreate.Designer.cs

@@ -12,8 +12,8 @@ using PlumbingRepairDataBaseImplement;
 namespace PlumbingRepairDataBaseImplement.Migrations
 {
     [DbContext(typeof(PlumbingRepairDataBase))]
-    [Migration("20240326163755_Migration1")]
-    partial class Migration1
+    [Migration("20240506071751_InitialCreate")]
+    partial class InitialCreate
     {
         /// <inheritdoc />
         protected override void BuildTargetModel(ModelBuilder modelBuilder)
@@ -82,6 +82,59 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.ToTable("Orders");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Store", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<DateTime>("OpeningDate")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("StoreAdress")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("StoreName")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<int>("WorkMaxCount")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Stores");
+                });
+
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.StoreWork", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<int>("Count")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("StoreId")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("WorkId")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("StoreId");
+
+                    b.HasIndex("WorkId");
+
+                    b.ToTable("StoreWorks");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Work", b =>
                 {
                     b.Property<int>("Id")
@@ -139,6 +192,25 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.Navigation("Work");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.StoreWork", b =>
+                {
+                    b.HasOne("PlumbingRepairDataBaseImplement.Models.Store", "Store")
+                        .WithMany("Works")
+                        .HasForeignKey("StoreId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.HasOne("PlumbingRepairDataBaseImplement.Models.Work", "Work")
+                        .WithMany()
+                        .HasForeignKey("WorkId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("Store");
+
+                    b.Navigation("Work");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.WorkComponent", b =>
                 {
                     b.HasOne("PlumbingRepairDataBaseImplement.Models.Component", "Component")
@@ -163,6 +235,11 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.Navigation("WorkComponents");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Store", b =>
+                {
+                    b.Navigation("Works");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Work", b =>
                 {
                     b.Navigation("Components");

PlumbingRepair/PlumbingRepairDataBaseImplement/Migrations/20240506071751_InitialCreate.cs

@@ -7,7 +7,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 namespace PlumbingRepairDataBaseImplement.Migrations
 {
     /// <inheritdoc />
-    public partial class Migration1 : Migration
+    public partial class InitialCreate : Migration
     {
         /// <inheritdoc />
         protected override void Up(MigrationBuilder migrationBuilder)
@@ -26,6 +26,22 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     table.PrimaryKey("PK_Components", x => x.Id);
                 });
 
+            migrationBuilder.CreateTable(
+                name: "Stores",
+                columns: table => new
+                {
+                    Id = table.Column<int>(type: "integer", nullable: false)
+                        .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+                    StoreName = table.Column<string>(type: "text", nullable: false),
+                    StoreAdress = table.Column<string>(type: "text", nullable: false),
+                    OpeningDate = table.Column<DateTime>(type: "timestamp with time zone", nullable: false),
+                    WorkMaxCount = table.Column<int>(type: "integer", nullable: false)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_Stores", x => x.Id);
+                });
+
             migrationBuilder.CreateTable(
                 name: "Works",
                 columns: table => new
@@ -65,6 +81,33 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                         onDelete: ReferentialAction.Cascade);
                 });
 
+            migrationBuilder.CreateTable(
+                name: "StoreWorks",
+                columns: table => new
+                {
+                    Id = table.Column<int>(type: "integer", nullable: false)
+                        .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+                    WorkId = table.Column<int>(type: "integer", nullable: false),
+                    StoreId = table.Column<int>(type: "integer", nullable: false),
+                    Count = table.Column<int>(type: "integer", nullable: false)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_StoreWorks", x => x.Id);
+                    table.ForeignKey(
+                        name: "FK_StoreWorks_Stores_StoreId",
+                        column: x => x.StoreId,
+                        principalTable: "Stores",
+                        principalColumn: "Id",
+                        onDelete: ReferentialAction.Cascade);
+                    table.ForeignKey(
+                        name: "FK_StoreWorks_Works_WorkId",
+                        column: x => x.WorkId,
+                        principalTable: "Works",
+                        principalColumn: "Id",
+                        onDelete: ReferentialAction.Cascade);
+                });
+
             migrationBuilder.CreateTable(
                 name: "WorkComponents",
                 columns: table => new
@@ -97,6 +140,16 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                 table: "Orders",
                 column: "WorkId");
 
+            migrationBuilder.CreateIndex(
+                name: "IX_StoreWorks_StoreId",
+                table: "StoreWorks",
+                column: "StoreId");
+
+            migrationBuilder.CreateIndex(
+                name: "IX_StoreWorks_WorkId",
+                table: "StoreWorks",
+                column: "WorkId");
+
             migrationBuilder.CreateIndex(
                 name: "IX_WorkComponents_ComponentId",
                 table: "WorkComponents",
@@ -114,9 +167,15 @@ namespace PlumbingRepairDataBaseImplement.Migrations
             migrationBuilder.DropTable(
                 name: "Orders");
 
+            migrationBuilder.DropTable(
+                name: "StoreWorks");
+
             migrationBuilder.DropTable(
                 name: "WorkComponents");
 
+            migrationBuilder.DropTable(
+                name: "Stores");
+
             migrationBuilder.DropTable(
                 name: "Components");
 

PlumbingRepair/PlumbingRepairDataBaseImplement/Migrations/PlumbingRepairDataBaseModelSnapshot.cs

@@ -79,6 +79,59 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.ToTable("Orders");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Store", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<DateTime>("OpeningDate")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("StoreAdress")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("StoreName")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<int>("WorkMaxCount")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Stores");
+                });
+
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.StoreWork", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<int>("Count")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("StoreId")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("WorkId")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("StoreId");
+
+                    b.HasIndex("WorkId");
+
+                    b.ToTable("StoreWorks");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Work", b =>
                 {
                     b.Property<int>("Id")
@@ -136,6 +189,25 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.Navigation("Work");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.StoreWork", b =>
+                {
+                    b.HasOne("PlumbingRepairDataBaseImplement.Models.Store", "Store")
+                        .WithMany("Works")
+                        .HasForeignKey("StoreId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.HasOne("PlumbingRepairDataBaseImplement.Models.Work", "Work")
+                        .WithMany()
+                        .HasForeignKey("WorkId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("Store");
+
+                    b.Navigation("Work");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.WorkComponent", b =>
                 {
                     b.HasOne("PlumbingRepairDataBaseImplement.Models.Component", "Component")
@@ -160,6 +232,11 @@ namespace PlumbingRepairDataBaseImplement.Migrations
                     b.Navigation("WorkComponents");
                 });
 
+            modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Store", b =>
+                {
+                    b.Navigation("Works");
+                });
+
             modelBuilder.Entity("PlumbingRepairDataBaseImplement.Models.Work", b =>
                 {
                     b.Navigation("Components");

PlumbingRepair/PlumbingRepairDataBaseImplement/Models/Store.cs

@@ -0,0 +1,110 @@
+using PlumbingRepairContracts.BindingModels;
+using PlumbingRepairContracts.ViewModels;
+using PlumbingRepairDataModels.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;
+
+namespace PlumbingRepairDataBaseImplement.Models
+{
+    public class Store : IStoreModel
+    {
+        [Required]
+        public string StoreName { get; private set; } = string.Empty;
+        [Required]
+        public string StoreAdress { get; private set; } = string.Empty;
+        [Required]
+        public DateTime OpeningDate { get; private set; }
+        [Required]
+        public int WorkMaxCount { get; private set; }
+
+        public int Id { get; private set; }
+
+
+        private Dictionary<int, (IWorkModel, int)> _storeWorks = null;
+        [NotMapped]
+        public Dictionary<int, (IWorkModel, int)> StoreWorks
+        {
+            get
+            {
+                if (_storeWorks == null)
+                {
+                    _storeWorks = Works
+                            .ToDictionary(recPC => recPC.WorkId, recPC => (recPC.Work as IWorkModel, recPC.Count));
+                }
+                return _storeWorks;
+            }
+        }
+
+        [ForeignKey("StoreId")]
+        public virtual List<StoreWork> Works { get; set; } = new();
+
+        public static Store Create(PlumbingRepairDataBase context, StoreBindingModel model)
+        {
+            return new Store()
+            {
+                Id = model.Id,
+                StoreName = model.StoreName,
+                StoreAdress = model.StoreAdress,
+                OpeningDate = model.OpeningDate,
+                WorkMaxCount = model.WorkMaxCount,
+                Works = model.StoreWorks.Select(x => new StoreWork
+                {
+                    Work = context.Works.First(y => y.Id == x.Key),
+                    Count = x.Value.Item2
+                }).ToList()
+            };
+        }
+
+        public void Update(StoreBindingModel model)
+        {
+            StoreName = model.StoreName;
+            StoreAdress = model.StoreAdress;
+            OpeningDate = model.OpeningDate;
+            WorkMaxCount = model.WorkMaxCount;
+        }
+
+        public StoreViewModel GetViewModel => new()
+        {
+            Id = Id,
+            StoreName = StoreName,
+            StoreAdress = StoreAdress,
+            OpeningDate = OpeningDate,
+            WorkMaxCount = WorkMaxCount,
+            StoreWorks = StoreWorks
+        };
+
+        public void UpdateWorks(PlumbingRepairDataBase context, StoreBindingModel model)
+        {
+            var storeWorks = context.StoreWorks.Where(rec => rec.StoreId == model.Id).ToList();
+            if (storeWorks != null && storeWorks.Count > 0)
+            {   // удалили те, которых нет в модели
+                context.StoreWorks.RemoveRange(storeWorks.Where(rec => !model.StoreWorks.ContainsKey(rec.WorkId)));
+                context.SaveChanges();
+                // обновили количество у существующих записей
+                foreach (var updateWork in storeWorks)
+                {
+                    updateWork.Count = model.StoreWorks[updateWork.WorkId].Item2;
+                    model.StoreWorks.Remove(updateWork.WorkId);
+                }
+                context.SaveChanges();
+            }
+            var store = context.Stores.First(x => x.Id == Id);
+            foreach (var sw in model.StoreWorks)
+            {
+                context.StoreWorks.Add(new StoreWork
+                {
+                    Store = store,
+                    Work = context.Works.First(x => x.Id == sw.Key),
+                    Count = sw.Value.Item2
+                });
+                context.SaveChanges();
+            }
+            _storeWorks = null;
+        }
+    }
+}

PlumbingRepair/PlumbingRepairDataBaseImplement/Models/StoreWork.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PlumbingRepairDataBaseImplement.Models
+{
+    public class StoreWork
+    {
+        public int Id { get; set; }
+
+        [Required]
+        public int WorkId { get; set; }
+
+        [Required]
+        public int StoreId { get; set; }
+
+        [Required]
+        public int Count { get; set; }
+
+        public virtual Store Store { get; set; } = new();
+
+        public virtual Work Work { get; set; } = new();
+    }
+}

PlumbingRepair/PlumbingRepairDataBaseImplement/PlumbingRepairDataBase.cs

@@ -23,5 +23,7 @@ namespace PlumbingRepairDataBaseImplement
         public virtual DbSet<Work> Works { set; get; }
         public virtual DbSet<WorkComponent> WorkComponents { set; get; }
         public virtual DbSet<Order> Orders { set; get; }
+        public virtual DbSet<Store> Stores { set; get; }
+        public virtual DbSet<StoreWork> StoreWorks { set; get; }
     }
 }