analytics

.gitea/workflows/pipeline.yml

@@ -1,11 +1,11 @@
 # Name Ihrer Workflow-Pipeline
-name: Build and Push Backend API Docker Image
+name: Branch - test - Build and Push Backend API Docker Image
 
 # Definiert, wann dieser Workflow ausgeführt werden soll
 on:
   push:
     branches:
-      - master # Wird ausgelöst bei jedem Push auf den Master-Branch
+      - test # Wird ausgelöst bei jedem Push auf den Master-Branch
 
 # Definition der Jobs, die in diesem Workflow ausgeführt werden
 jobs:
@@ -39,4 +39,4 @@ jobs:
           # Legt fest, dass das Image nach dem Bauen in die Registry gepusht werden soll
           push: true
           # Definiert die Tags für Ihr Docker-Image in der Registry
-          tags: gitea.tzbre.dev/admin/shopsolution-backend:latest # WICHTIG: Eindeutiger Name für das Backend-Image
+          tags: gitea.tzbre.dev/admin/shopsolution-backend:test # WICHTIG: Eindeutiger Name für das Backend-Image

Webshop.Api/Controllers/Admin/AdminAnalyticsController.cs

@@ -1,9 +1,9 @@
-// src/Webshop.Api/Controllers/Admin/AdminAnalyticsController.cs
+using Microsoft.AspNetCore.Authorization;
-using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using System.Threading.Tasks;
 using Webshop.Application.DTOs.Admin;
 using Webshop.Application.Services.Admin.Interfaces;
+using Webshop.Application; // Hinzugefügt
 
 namespace Webshop.Api.Controllers.Admin
 {
@@ -26,11 +26,24 @@ namespace Webshop.Api.Controllers.Admin
         /// Ruft die aggregierten Analysedaten und KPIs für den Admin-Bereich ab.
         /// </summary>
         /// <param name="period">Der Zeitraum für die Statistiken (Last7Days, Last30Days, AllTime). Standard ist Last30Days.</param>
+        /// <response code="200">Gibt die Analysedaten zurück.</response>
+        /// <response code="500">Tritt auf, wenn ein interner Serverfehler beim Abrufen der Daten auftritt.</response>
         [HttpGet]
-        public async Task<ActionResult<AnalyticsDto>> GetAnalytics([FromQuery] AnalyticsPeriod period = AnalyticsPeriod.Last30Days)
+        [ProducesResponseType(typeof(AnalyticsDto), 200)]
+        [ProducesResponseType(typeof(object), 500)]
+        public async Task<IActionResult> GetAnalytics([FromQuery] AnalyticsPeriod period = AnalyticsPeriod.Last30Days)
         {
-            var stats = await _analyticsService.GetAnalyticsAsync(period);
+            var result = await _analyticsService.GetAnalyticsAsync(period);
-            return Ok(stats);
+
+            return result.Type switch
+            {
+                ServiceResultType.Success => Ok(result.Value),
+
+                ServiceResultType.Failure => StatusCode(500, new { message = result.ErrorMessage }),
+
+                // Fallback für unerwartete Fehlertypen
+                _ => StatusCode(500, new { message = "Ein unerwarteter Fehler ist aufgetreten." })
+            };
         }
     }
 }

Webshop.Application/Services/Admin/AdminAnalyticsService.cs

@@ -1,5 +1,4 @@
-// src/Webshop.Application/Services/Admin/AdminAnalyticsService.cs
+using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -9,6 +8,8 @@ using Webshop.Application.Services.Admin.Interfaces;
 using Webshop.Domain.Enums;
 using Webshop.Domain.Interfaces;
 using Webshop.Infrastructure.Data;
+using Webshop.Application; // Hinzugefügt
+using Microsoft.Extensions.Logging; // Empfohlen für Logging
 
 namespace Webshop.Application.Services.Admin
 {
@@ -16,30 +17,45 @@ namespace Webshop.Application.Services.Admin
     {
         private readonly ApplicationDbContext _context;
         private readonly ISettingService _settingService;
+        private readonly ILogger<AdminAnalyticsService> _logger; // Empfohlen: Logger hinzufügen
 
-        public AdminAnalyticsService(ApplicationDbContext context, ISettingService settingService)
+        // Empfohlen: Logger per Dependency Injection übergeben
+        public AdminAnalyticsService(ApplicationDbContext context, ISettingService settingService, ILogger<AdminAnalyticsService> logger)
         {
             _context = context;
             _settingService = settingService;
+            _logger = logger;
         }
 
-        public async Task<AnalyticsDto> GetAnalyticsAsync(AnalyticsPeriod period)
+        public async Task<ServiceResult<AnalyticsDto>> GetAnalyticsAsync(AnalyticsPeriod period)
         {
-            var startDate = GetStartDateFromPeriod(period);
+            try
-
-            var filteredOrders = await _context.Orders
-                .Where(o => o.OrderDate >= startDate && o.OrderStatus != OrderStatus.Cancelled.ToString())
-                .ToListAsync();
-
-            var analyticsDto = new AnalyticsDto
             {
-                KpiSummary = await GetKpiSummaryAsync(startDate, filteredOrders),
+                var startDate = GetStartDateFromPeriod(period);
-                SalesOverTime = GetSalesOverTime(filteredOrders),
-                TopPerformingProducts = await GetTopPerformingProductsAsync(startDate),
-                InventoryStatus = await GetInventoryStatusAsync()
-            };
 
-            return analyticsDto;
+                // Die Abfragen bleiben gleich, werden aber jetzt innerhalb des Try-Blocks ausgeführt.
+                var filteredOrders = await _context.Orders
+                    .Where(o => o.OrderDate >= startDate && o.OrderStatus != OrderStatus.Cancelled.ToString())
+                    .ToListAsync();
+
+                var analyticsDto = new AnalyticsDto
+                {
+                    KpiSummary = await GetKpiSummaryAsync(startDate, filteredOrders),
+                    SalesOverTime = GetSalesOverTime(filteredOrders),
+                    TopPerformingProducts = await GetTopPerformingProductsAsync(startDate),
+                    InventoryStatus = await GetInventoryStatusAsync()
+                };
+
+                return ServiceResult.Ok(analyticsDto);
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "Fehler beim Abrufen der Analysedaten für den Zeitraum {Period}.", period);
+                return ServiceResult.Fail<AnalyticsDto>(
+                    ServiceResultType.Failure,
+                    "Ein interner Fehler ist beim Abrufen der Analysedaten aufgetreten."
+                );
+            }
         }
 
         private async Task<KpiSummaryDto> GetKpiSummaryAsync(DateTimeOffset startDate, List<Domain.Entities.Order> filteredOrders)

Webshop.Application/Services/Admin/Interfaces/IAdminAnalyticsService.cs

@@ -1,6 +1,6 @@
-// src/Webshop.Application/Services/Admin/Interfaces/IAdminAnalyticsService.cs
+using System.Threading.Tasks;
-using System.Threading.Tasks;
 using Webshop.Application.DTOs.Admin;
+using Webshop.Application; // Hinzugefügt
 
 namespace Webshop.Application.Services.Admin.Interfaces
 {
@@ -8,6 +8,6 @@ namespace Webshop.Application.Services.Admin.Interfaces
 
     public interface IAdminAnalyticsService
     {
-        Task<AnalyticsDto> GetAnalyticsAsync(AnalyticsPeriod period);
+        Task<ServiceResult<AnalyticsDto>> GetAnalyticsAsync(AnalyticsPeriod period);
     }
 }