feat(esppOrderLoader): доделал логику синхронизации

PARR.DAL/Migrations/20231024002524_TblOrdersAndAgentHistory.cs

@@ -0,0 +1,70 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace PARR.DAL.Migrations
+{
+    /// <inheritdoc />
+    public partial class TblOrdersAndAgentHistory : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<DateTimeOffset>(
+                name: "DateModified",
+                table: "Orders",
+                type: "timestamp with time zone",
+                nullable: true);
+
+            migrationBuilder.AddColumn<string>(
+                name: "ShortName",
+                table: "Orders",
+                type: "text",
+                nullable: false,
+                defaultValue: "");
+
+            migrationBuilder.AddColumn<Guid>(
+                name: "OrderId",
+                table: "AgentHistories",
+                type: "uuid",
+                nullable: true);
+
+            migrationBuilder.CreateIndex(
+                name: "IX_AgentHistories_OrderId",
+                table: "AgentHistories",
+                column: "OrderId");
+
+            migrationBuilder.AddForeignKey(
+                name: "FK_AgentHistories_Orders_OrderId",
+                table: "AgentHistories",
+                column: "OrderId",
+                principalTable: "Orders",
+                principalColumn: "Id");
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropForeignKey(
+                name: "FK_AgentHistories_Orders_OrderId",
+                table: "AgentHistories");
+
+            migrationBuilder.DropIndex(
+                name: "IX_AgentHistories_OrderId",
+                table: "AgentHistories");
+
+            migrationBuilder.DropColumn(
+                name: "DateModified",
+                table: "Orders");
+
+            migrationBuilder.DropColumn(
+                name: "ShortName",
+                table: "Orders");
+
+            migrationBuilder.DropColumn(
+                name: "OrderId",
+                table: "AgentHistories");
+        }
+    }
+}

PARR.DAL/Migrations/DataContextModelSnapshot.cs

@@ -384,6 +384,9 @@ namespace PARR.DAL.Migrations
                     b.Property<string>("Message")
                         .HasColumnType("text");
 
+                    b.Property<Guid?>("OrderId")
+                        .HasColumnType("uuid");
+
                     b.Property<Guid>("TemplateId")
                         .HasColumnType("uuid");
 
@@ -391,6 +394,8 @@ namespace PARR.DAL.Migrations
 
                     b.HasIndex("HistoryLevelId");
 
+                    b.HasIndex("OrderId");
+
                     b.HasIndex("TemplateId");
 
                     b.ToTable("AgentHistories");
@@ -1556,6 +1561,9 @@ namespace PARR.DAL.Migrations
                     b.Property<DateTimeOffset>("DateCreated")
                         .HasColumnType("timestamp with time zone");
 
+                    b.Property<DateTimeOffset?>("DateModified")
+                        .HasColumnType("timestamp with time zone");
+
                     b.Property<string>("Number")
                         .IsRequired()
                         .HasColumnType("text");
@@ -1563,6 +1571,10 @@ namespace PARR.DAL.Migrations
                     b.Property<int>("OrderStatusCode")
                         .HasColumnType("integer");
 
+                    b.Property<string>("ShortName")
+                        .IsRequired()
+                        .HasColumnType("text");
+
                     b.Property<Guid?>("TemplateId")
                         .HasColumnType("uuid");
 
@@ -2226,6 +2238,10 @@ namespace PARR.DAL.Migrations
                         .OnDelete(DeleteBehavior.Cascade)
                         .IsRequired();
 
+                    b.HasOne("PARR.DAL.Models.Order", "Order")
+                        .WithMany("AgentHistories")
+                        .HasForeignKey("OrderId");
+
                     b.HasOne("PARR.DAL.Models.Template", "Template")
                         .WithMany("AgentHistories")
                         .HasForeignKey("TemplateId")
@@ -2234,6 +2250,8 @@ namespace PARR.DAL.Migrations
 
                     b.Navigation("AgentHistoryLevel");
 
+                    b.Navigation("Order");
+
                     b.Navigation("Template");
                 });
 
@@ -2551,6 +2569,11 @@ namespace PARR.DAL.Migrations
                     b.Navigation("Templates");
                 });
 
+            modelBuilder.Entity("PARR.DAL.Models.Order", b =>
+                {
+                    b.Navigation("AgentHistories");
+                });
+
             modelBuilder.Entity("PARR.DAL.Models.OrderStatus", b =>
                 {
                     b.Navigation("Orders");

PARR.DAL/Models/AgentHistory.cs

@@ -24,10 +24,14 @@ namespace PARR.DAL.Models
 
         public Guid TemplateId { get; set; }
 
+        public Guid? OrderId { get; set; }
+
         [ForeignKey(nameof(TemplateId))]
         public Template? Template { get; set; }
 
         [ForeignKey(nameof(HistoryLevelId))]
         public AgentHistoryLevel? AgentHistoryLevel { get; set; }
+
+        public Order? Order { get; set; }
     }
 }

PARR.DAL/Models/Order.cs

@@ -15,11 +15,12 @@ namespace PARR.DAL.Models
 
         public DateTimeOffset DateCreated { get; set; }
 
-        [NotMapped]
         public DateTimeOffset? DateModified { get; set; }
 
         public required string Number { get; set; }
 
+        public required string ShortName { get; set; }
+
         public string? WorkGroup { get; set; }
 
         public Guid? TemplateId { get; set; }
@@ -31,5 +32,7 @@ namespace PARR.DAL.Models
 
         [ForeignKey(nameof(OrderStatusCode))]
         public OrderStatus? OrderStatus { get; set; }
+
+        public ICollection<AgentHistory> AgentHistories { get; set; } = new HashSet<AgentHistory>();
     }
 }

PARR.DAL/Services/Implementations/OrderStatusService.cs

@@ -1,4 +1,6 @@
-using PARR.DAL.Context;
+using Microsoft.Extensions.Logging;
+using PARR.DAL.Context;
+using PARR.DAL.Contracts;
 using PARR.DAL.Models;
 using PARR.DAL.Services.Interfaces;
 
@@ -7,15 +9,38 @@ namespace PARR.DAL.Services.Implementations
     internal class OrderStatusService : IOrderStatusService
     {
         private readonly DataContext dataContext;
+        private readonly ILogger<OrderStatusService> logger;
 
-        public OrderStatusService(DataContext dataContext)
+        public OrderStatusService(DataContext dataContext, ILogger<OrderStatusService> logger)
         {
             this.dataContext = dataContext;
+            this.logger = logger;
         }
 
         public IQueryable<OrderStatus> Get()
         {
             return dataContext.OrderStatuses;
         }
+
+
+        public OrderStatusEnum GetOrderStatusByName(string statusName)
+        {
+            switch (statusName.ToLower().Trim())
+            {
+                case "1-Направлен в группу":
+                    return OrderStatusEnum.New;
+                case "2-В работе":
+                    return OrderStatusEnum.InWork;
+                case "3-Приостановлен":
+                    return OrderStatusEnum.Stop;
+                case "4-Выполнен":
+                    return OrderStatusEnum.Complete;
+                case "5-Закрыт":
+                    return OrderStatusEnum.Closed;
+                default:
+                    logger.LogWarning($"Не смог распознать статус наряда, вернул значение по умполчанию: {OrderStatusEnum.New.ToString()}, входящее значение: {statusName}");
+                    return OrderStatusEnum.New;
+            }
+        }
     }
 }

PARR.DAL/Services/Interfaces/IOrderStatusService.cs

@@ -1,9 +1,11 @@
-using PARR.DAL.Models;
+using PARR.DAL.Contracts;
+using PARR.DAL.Models;
 
 namespace PARR.DAL.Services.Interfaces
 {
     public interface IOrderStatusService
     {
         IQueryable<OrderStatus> Get();
+        OrderStatusEnum GetOrderStatusByName(string statusName);
     }
 }

PARR.EsppApi/Models/EsppOrder.cs

@@ -12,5 +12,7 @@
         public string Status { get; set; } = string.Empty;
 
         public string ShortName { get; set; } = string.Empty;
+
+        public string TemplateName { get; set; } = string.Empty;
     }
 }

PARR.EsppOrderLoader/EsppOrderLoader.cs

@@ -56,10 +56,10 @@ namespace PARR.EsppOrderLoader
             }
         }
 
-        // получаю список из ЕСПП по фильтрам
+
-        // В цикле проверяю каждый наряд, есть ли он в БД + по имени ищу есть ли такой шаблон
+        //Получаю список нарядов из еспп
-        // Если наряда такого нет в БД и есть шаблон, добавляю в БД
+        //проверяю есть ли наряд в бд
-        // если в бд не добавляю, пишу в лог, что нет такого шаблона, в бд не добавляю
+        //если нет, ище шаблон в бд, затем сохраняю наряд в бд с привязанным шаблоном (если шаблон не нашел, тоже сохраняю)
 
         private async Task DownloadOrdersAsync()
         {

PARR.EsppOrderLoader/Services/OrderItemService.cs

@@ -1,5 +1,6 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
+using PARR.DAL.Models;
 using PARR.DAL.Services.Interfaces;
 using PARR.EsppApi.Models;
 
@@ -10,25 +11,24 @@ namespace PARR.EsppOrderLoader.Services
         private readonly ILogger<OrderItemService> logger;
         private readonly IOrderService orderService;
         private readonly ITemplateService templateService;
+        private readonly IOrderStatusService orderStatusService;
 
         public OrderItemService(
             ILogger<OrderItemService> logger,
             IOrderService orderService,
-            ITemplateService templateService
+            ITemplateService templateService,
+            IOrderStatusService orderStatusService
             )
         {
             this.orderService = orderService;
             this.templateService = templateService;
+            this.orderStatusService = orderStatusService;
             this.logger = logger;
         }
 
 
         public async Task WriteOrderAsync(EsppOrder esppOrder)
         {
-            // В цикле проверяю каждый наряд, есть ли он в БД + по имени ищу есть ли такой шаблон
-            // Если наряда такого нет в БД и есть шаблон, добавляю в БД
-            // если в бд не добавляю, пишу в лог, что нет такого шаблона, в бд не добавляю
-
             var existOrder = await orderService.Get().FirstOrDefaultAsync(t => t.Number.ToLower() == esppOrder.Number.ToLower());
             if (existOrder != null)
             {
@@ -36,15 +36,25 @@ namespace PARR.EsppOrderLoader.Services
                 return;
             }
 
-            var template = await templateService.Get().FirstOrDefaultAsync(t => t.Name.ToLower() == esppOrder.ShortName.ToLower());
+            var template = await templateService.Get().FirstOrDefaultAsync(t => t.Name.ToLower() == esppOrder.TemplateName.ToLower());
             if (template == null)
+                logger.LogWarning($"Не найден шаблон для наряда {esppOrder.Number}, краткое описание наряда: {esppOrder.ShortName}. {esppOrder.WorkGroup}");
+
+            var newOrder = new Order
             {
-                logger.LogInformation($"Не найден шаблон для наряда {esppOrder.Number}, краткое описание наряда: {esppOrder.ShortName}. Пропускаю.");
+                Id = Guid.NewGuid(),
-                return;
+                Number = esppOrder.Number,
+                WorkGroup = esppOrder.WorkGroup,
+                ShortName = esppOrder.ShortName,
+                TemplateId = template?.Id,
+                OrderStatusCode = (int)orderStatusService.GetOrderStatusByName(esppOrder.Status)
+            };
+
+            if (!await orderService.CreateAsync(newOrder) || !await orderService.CommitAsync())
+                logger.LogError($"Ошибка при добавлении новой записи наряда в БД. {esppOrder.Number}, {esppOrder.WorkGroup}, {esppOrder.ShortName}");
+            else
+                logger.LogInformation($"Добавлен наряд в БД: {esppOrder.Number}, {esppOrder.ShortName}");
         }
 
-            //todo: добавляю в БД!
-
-        }
     }
 }