Feat/dashboard

src/Api/Controllers/AuthController.cs

@@ -2,7 +2,9 @@
 using System.Security.Authentication;
 using Api.Controllers.Payload.Requests.Auth;
 using Api.Controllers.Payload.Responses;
+using Application.Common.Extensions.Logging;
 using Application.Common.Interfaces;
+using Application.Common.Logging;
 using Application.Common.Models;
 using Application.Common.Models.Dtos;
 using Application.Users.Queries;
@@ -18,10 +20,14 @@ namespace Api.Controllers;
 public class AuthController : ControllerBase
 {
     private readonly IIdentityService _identityService;
+    private readonly ILogger<AuthController> _logger;
+    private readonly IDateTimeProvider _dateTimeProvider;
 
-    public AuthController(IIdentityService identityService)
+    public AuthController(IIdentityService identityService, ILogger<AuthController> logger, IDateTimeProvider dateTimeProvider)
     {
         _identityService = identityService;
+        _logger = logger;
+        _dateTimeProvider = dateTimeProvider;
     }
 
     /// <summary>
@@ -54,6 +60,11 @@ public async Task<IActionResult> Login([FromBody] LoginModel loginModel)
                     LastName = loginSuccess.UserCredentials.LastName,
                 };
 
+                var dateTimeNow = _dateTimeProvider.DateTimeNow;
+                using (Logging.PushProperties("Login", loginResult.Id, loginResult.Id))
+                {
+                    _logger.LogLogin(loginResult.Username, dateTimeNow.ToString("yyyy-MM-dd HH:mm:ss"));
+                }
                 return Ok(Result<LoginResult>.Succeed(loginResult));
             },
             token =>

src/Api/Controllers/DashboardController.cs

@@ -1,4 +1,8 @@
+using Api.Controllers.Payload.Requests.Dashboard;
+using Application.Common.Interfaces;
 using Application.Common.Models;
+using Application.Common.Models.Dtos.DashBoard;
+using Application.Dashboards.Queries;
 using Application.Identity;
 using Infrastructure.Identity.Authorization;
 using Microsoft.AspNetCore.Mvc;
@@ -7,6 +11,62 @@ namespace Api.Controllers;
 
 public class DashboardController : ApiControllerBase
 {
+    private readonly ICurrentUserService _currentUserService;
+
+    public DashboardController(ICurrentUserService currentUserService)
+    {
+        _currentUserService = currentUserService;
+    }
+
+    [RequiresRole(IdentityData.Roles.Admin)]
+    [HttpPost("import-documents")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
+    public async Task<ActionResult<Result<List<MetricResultDto>>>> GetImportDocuments(
+        [FromBody] GetImportedDocumentsMetricsRequest request)
+    {
+        var query = new GetImportDocuments.Query()
+        {
+            StartDate = request.StartDate,
+            EndDate = request.EndDate
+        };
+
+        var result = await Mediator.Send(query);
+        return Ok(Result<List<MetricResultDto>>.Succeed(result));
+    }
+
+    [RequiresRole(IdentityData.Roles.Admin)]
+    [HttpPost("logins")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
+    public async Task<ActionResult<Result<MetricResultDto>>> GetLoggedInUsers(
+        [FromBody] DateTime date)
+    {
+        var query = new GetLoggedInUser.Query()
+        {
+            Date = date
+        };
+
+        var result = await Mediator.Send(query);
+        return Ok(Result<MetricResultDto>.Succeed(result));
+    }
+
+    [RequiresRole(IdentityData.Roles.Admin)]
+    [HttpPost("largest-drive")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
+    public async Task<ActionResult<Result<LargestDriveDto>>> GetUserWithLargestDrive(
+        [FromBody] DateTime date)
+    {
+        var query = new GetUserWithLargestDriveData.Query()
+        {
+            Date = date
+        };
+
+        var result = await Mediator.Send(query);
+        return Ok(Result<LargestDriveDto>.Succeed(result));
+    }
+
     [RequiresRole(IdentityData.Roles.Admin)]
     [HttpGet("online-users")]
     [ProducesResponseType(StatusCodes.Status200OK)]

src/Api/Controllers/Payload/Requests/Dashboard/GetImportedDocumentsMetricsRequest.cs

@@ -0,0 +1,9 @@
+namespace Api.Controllers.Payload.Requests.Dashboard;
+
+public class GetImportedDocumentsMetricsRequest
+{
+
+    public DateTime StartDate { get; set; }
+
+    public DateTime EndDate { get; set; }
+}

src/Application/Borrows/Commands/ApproveOrRejectBorrowRequest.cs

@@ -120,7 +120,7 @@ is BorrowRequestStatus.Approved
 
                 using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentUserId))
                 {
-                    _logger.LogApproveBorrowRequest(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                    Common.Extensions.Logging.BorrowLogExtensions.LogApproveBorrowRequest(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
                 }
             }
 
@@ -130,7 +130,7 @@ is BorrowRequestStatus.Approved
 
                 using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentUserId))
                 {
-                    _logger.LogRejectBorrowRequest(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                    Common.Extensions.Logging.BorrowLogExtensions.LogRejectBorrowRequest(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
                 }
             }
 

src/Application/Borrows/Commands/BorrowDocument.cs

@@ -164,7 +164,7 @@ is BorrowRequestStatus.Approved
             await _context.SaveChangesAsync(cancellationToken);
             using (Logging.PushProperties("Request", document.Id, user.Id))
             {
-                _logger.LogBorrowDocument(document.Id.ToString(), result.Entity.Id.ToString());
+                Common.Extensions.Logging.BorrowLogExtensions.LogBorrowDocument(_logger, document.Id.ToString(), result.Entity.Id.ToString());
             }
             return _mapper.Map<BorrowDto>(result.Entity);
         }

src/Application/Borrows/Commands/CancelBorrowRequest.cs

@@ -65,7 +65,7 @@ public async Task<BorrowDto> Handle(Command request, CancellationToken cancellat
             await _context.SaveChangesAsync(cancellationToken);
             using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentUserId))
             {
-                _logger.LogCancelBorrowRequest(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                Common.Extensions.Logging.BorrowLogExtensions.LogCancelBorrowRequest(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
             }
             return _mapper.Map<BorrowDto>(result.Entity);
         }

src/Application/Borrows/Commands/CheckoutDocument.cs

@@ -90,7 +90,7 @@ public async Task<BorrowDto> Handle(Command request, CancellationToken cancellat
             await _context.SaveChangesAsync(cancellationToken);
             using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentStaff.Id))
             {
-                _logger.LogCheckoutDocument(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                Common.Extensions.Logging.BorrowLogExtensions.LogCheckoutDocument(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
             }
             return _mapper.Map<BorrowDto>(result.Entity);
         }

src/Application/Borrows/Commands/ReturnDocument.cs

@@ -91,7 +91,7 @@ public async Task<BorrowDto> Handle(Command request, CancellationToken cancellat
             await _context.SaveChangesAsync(cancellationToken);
             using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentUser.Id))
             {
-                _logger.LogReturnDocument(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                Common.Extensions.Logging.BorrowLogExtensions.LogReturnDocument(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
             }
             return _mapper.Map<BorrowDto>(result.Entity);
         }

src/Application/Borrows/Commands/UpdateBorrow.cs

@@ -115,7 +115,7 @@ is BorrowRequestStatus.Approved
 
             using (Logging.PushProperties("BorrowRequest", borrowRequest.Id, request.CurrentUser.Id))
             {
-                _logger.LogUpdateBorrow(borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
+                Common.Extensions.Logging.BorrowLogExtensions.LogUpdateBorrow(_logger, borrowRequest.Document.Id.ToString(), borrowRequest.Id.ToString());
             }
 
             return _mapper.Map<BorrowDto>(result.Entity);

src/Application/Borrows/BorrowLogExtensions.cs → src/Application/Common/Extensions/Logging/BorrowLogExtensions.cs

@@ -1,7 +1,7 @@
 using Application.Common.Messages;
 using Microsoft.Extensions.Logging;
 
-namespace Application.Borrows;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class BorrowLogExtensions
 {

src/Application/Documents/DocumentLogExtensions.cs → src/Application/Common/Extensions/Logging/DocumentLogExtensions.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Documents;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class DocumentLogExtensions
 {

src/Application/Entries/EntryLogExtension.cs → src/Application/Common/Extensions/Logging/EntryLogExtension.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Entries;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class EntryLogExtension
 {

src/Application/Folders/FolderLogExtension.cs → src/Application/Common/Extensions/Logging/FolderLogExtension.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Folders;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class FolderLogExtension {
 

src/Application/ImportRequests/ImportRequestLogExtensions.cs → src/Application/Common/Extensions/Logging/ImportRequestLogExtensions.cs

@@ -1,9 +1,8 @@
 using Application.Common.Messages;
-using Domain.Entities.Physical;
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.ImportRequests;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class ImportRequestLogExtensions {
     // Approve or reject document

src/Application/Lockers/LockerLogExtension.cs → src/Application/Common/Extensions/Logging/LockerLogExtension.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Lockers;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class LockerLogExtension {
 

src/Application/Common/Extensions/Logging/LoginLogExtension.cs

@@ -0,0 +1,11 @@
+using Application.Common.Messages;
+using Microsoft.Extensions.Logging;
+using EventId = Application.Common.Logging.EventId;
+
+namespace Application.Common.Extensions.Logging;
+
+public static partial class LoginLogExtension
+{
+    [LoggerMessage(Level = LogLevel.Information, Message = LoginLogMessages.Login, EventId = EventId.Approve)]
+    public static partial void LogLogin(this ILogger logger, string username, string time);
+}

src/Application/Rooms/RoomLogExtension.cs → src/Application/Common/Extensions/Logging/RoomLogExtension.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Rooms;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class RoomLogExtension {
     [LoggerMessage(Level = LogLevel.Information, Message = RoomLogMessage.Add, EventId = EventId.Add)]

src/Application/Staffs/StaffLogExtensions.cs → src/Application/Common/Extensions/Logging/StaffLogExtensions.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using EventId = Application.Common.Logging.EventId;
 
-namespace Application.Staffs;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class StaffLogExtensions {
     [LoggerMessage(Level = LogLevel.Information, Message = UserLogMessages.Staff.AssignStaff, EventId = EventId.Add)]

src/Application/Users/UserLogExtensions.cs → src/Application/Common/Extensions/Logging/UserLogExtensions.cs

@@ -1,7 +1,7 @@
 using Application.Common.Messages;
 using Microsoft.Extensions.Logging;
 
-namespace Application.Users;
+namespace Application.Common.Extensions.Logging;
 
 public static partial class UserLogExtensions
 {

src/Application/Common/Messages/LoginLogMessages.cs

@@ -0,0 +1,6 @@
+namespace Application.Common.Messages;
+
+public class LoginLogMessages
+{
+    public const string Login = "User with username {Username} Log in at {Time}";
+}

src/Application/Common/Models/Dtos/DashBoard/LargestDriveDto.cs

@@ -0,0 +1,10 @@
+using Application.Users.Queries;
+
+namespace Application.Common.Models.Dtos.DashBoard;
+
+public class LargestDriveDto
+{
+    public string Label { get; set; }
+    public long Value { get; set; }
+    public UserDto User { get; set; }
+}

src/Application/Common/Models/Dtos/DashBoard/MetricResultDto.cs

@@ -0,0 +1,7 @@
+namespace Application.Common.Models.Dtos.DashBoard;
+
+public class MetricResultDto
+{
+    public string Label { get; set; }
+    public int Value { get; set; }
+}

src/Application/Dashboards/Queries/GetImportDocuments.cs

@@ -0,0 +1,74 @@
+using Application.Common.Interfaces;
+using Application.Common.Models.Dtos.DashBoard;
+using Domain.Statuses;
+using FluentValidation;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using NodaTime;
+
+namespace Application.Dashboards.Queries;
+
+public class GetImportDocuments
+{
+    public class Validator : AbstractValidator<Query>
+    {
+        public Validator()
+        {
+            RuleLevelCascadeMode = CascadeMode.Stop;
+
+            RuleFor(x => x.StartDate)
+                .NotEmpty().WithMessage("Start date can not be empty.");
+
+            RuleFor(x => x.EndDate)
+                .NotEmpty().WithMessage("End date can not be empty.");
+        }
+    }
+    public record Query : IRequest<List<MetricResultDto>>
+    {
+        public DateTime StartDate { get; init; }
+        public DateTime EndDate { get; init; }
+
+    }
+
+    public class QueryHandler : IRequestHandler<Query, List<MetricResultDto>>
+    {
+        private readonly IApplicationDbContext _context;
+
+        public QueryHandler(IApplicationDbContext context)
+        {
+            _context = context;
+        }
+
+        public async Task<List<MetricResultDto>> Handle(Query request, CancellationToken cancellationToken)
+        {
+            var result = new List<MetricResultDto>();
+
+            var currentDate = request.StartDate.Date;
+            var endDate = request.EndDate.Date;
+
+            while (currentDate <= endDate)
+            {
+                var nextDate = currentDate.AddDays(1);
+                var label = $"{currentDate:dd-MM} to {nextDate:dd-MM}";
+                if (nextDate <= endDate)
+                {
+                    var date = currentDate;
+                    var importedDocumentsCount = await _context.Documents
+                        .Where(x => x.Created >= LocalDateTime.FromDateTime(date)
+                                    && x.Created <= LocalDateTime.FromDateTime(nextDate)
+                                    && x.Status != DocumentStatus.Issued)
+                        .CountAsync(cancellationToken);
+
+                    result.Add(new MetricResultDto()
+                    {
+                        Label = label,
+                        Value = importedDocumentsCount
+                    });
+                }
+                currentDate = nextDate;
+            }
+
+            return result;
+        }
+    }
+}