6 Commits

Author SHA1 Message Date
d922768c85 Merge pull request 'Add TagType CRUD' (#1) from feature/add-tag-type-crud into development
Reviewed-on: #1
Reviewed-by: Sergio Matías <sergio.matias@agilewebs.com>
2025-08-01 14:46:34 +00:00
Oscar Morales
e6d68f4fd3 Add TagType CRUD 2025-07-31 19:07:40 -06:00
542df8a203 Final fixes for demo 2025-06-27 23:11:01 -06:00
0038169f5a Added new endpoint for variants GetAll 2025-06-27 18:02:24 -06:00
24f647f90e Fix in method 2025-06-26 19:15:19 -06:00
f76e318f92 Re-factor on service 2025-06-22 23:16:10 -06:00
46 changed files with 956 additions and 118 deletions

View File

@@ -7,19 +7,19 @@
using Core.Blueprint.Mongo;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Base
{
/// <summary>
/// Command to change the status of a furniture base model.
/// </summary>
public class ChangeFurnitureBaseStatusRequest : Notificator, ICommand
{
public string Id { get; set; } = null!;
public string MongoId { get; set; } = null!;
public StatusEnum Status { get; set; }
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id);
return !string.IsNullOrWhiteSpace(MongoId);
}
}
}

View File

@@ -6,7 +6,7 @@
using Core.Inventory.Application.UseCases.Inventory.Input.Common;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Base
{
/// <summary>
/// Command for creating a new furniture base entity.

View File

@@ -5,7 +5,7 @@
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Base
{
public class GetAllFurnitureBaseRequest : ICommand
{

View File

@@ -5,18 +5,18 @@
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Base
{
/// <summary>
/// Query to retrieve a furniture base by its identifier.
/// </summary>
public class GetFurnitureBaseByIdRequest : Notificator, ICommand
{
public string Id { get; set; } = null!;
public string MongoId { get; set; } = null!;
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id);
return !string.IsNullOrWhiteSpace(MongoId);
}
}
}

View File

@@ -6,13 +6,14 @@
using Core.Inventory.Application.UseCases.Inventory.Input.Common;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Base
{
/// <summary>
/// Command for updating an existing furniture base entity.
/// </summary>
public class UpdateFurnitureBaseRequest : Notificator, ICommand
{
public string _Id { get; set; } = null!;
public string Id { get; set; } = null!;
public string ModelName { get; set; } = null!;
public string Material { get; set; } = null!;
@@ -26,7 +27,8 @@ namespace Core.Inventory.Application.UseCases.Inventory.Input
public List<string>? VariantIds { get; set; }
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id)
return !string.IsNullOrWhiteSpace(_Id)
&& !string.IsNullOrWhiteSpace(Id)
&& !string.IsNullOrWhiteSpace(ModelName)
&& !string.IsNullOrWhiteSpace(Material)
&& !string.IsNullOrWhiteSpace(Condition);

View File

@@ -6,19 +6,19 @@
using Core.Blueprint.Mongo;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
/// <summary>
/// Command to change the status of a furniture variant.
/// </summary>
public class ChangeFurnitureVariantStatusRequest : Notificator, ICommand
{
public string Id { get; set; } = null!;
public string MongoId { get; set; } = null!;
public StatusEnum Status { get; set; }
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id);
return !string.IsNullOrWhiteSpace(MongoId);
}
}
}

View File

@@ -5,7 +5,7 @@
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
public class CreateFurnitureVariantRequest : Notificator, ICommand
{
@@ -18,10 +18,10 @@ namespace Core.Inventory.Application.UseCases.Inventory.Input
public string Currency { get; set; } = "USD";
public int Stock { get; set; }
public Guid CategoryId { get; set; }
public Guid ProviderId { get; set; }
public string CategoryId { get; set; } = string.Empty;
public string ProviderId { get; set; } = string.Empty;
public Dictionary<string, object> Attributes { get; set; } = [];
public Dictionary<string, string> Attributes { get; set; } = [];
public bool Validate()
{
@@ -29,9 +29,7 @@ namespace Core.Inventory.Application.UseCases.Inventory.Input
&& !string.IsNullOrWhiteSpace(Name)
&& !string.IsNullOrWhiteSpace(Color)
&& Price >= 0
&& Stock >= 0
&& CategoryId != Guid.Empty
&& ProviderId != Guid.Empty;
&& Stock >= 0;
}
}
}

View File

@@ -0,0 +1,14 @@
// ***********************************************************************
// <copyright file="GetAllFurnitureVariantRequest.cs">
// Core.Inventory
// </copyright>
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
public class GetAllFurnitureVariantRequest : ICommand
{
public bool Validate() => true;
}
}

View File

@@ -5,7 +5,7 @@
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
public class GetAllFurnitureVariantsByModelIdRequest : Notificator, ICommand
{

View File

@@ -5,15 +5,15 @@
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
public class GetFurnitureVariantByIdRequest : Notificator, ICommand
{
public string Id { get; set; } = null!;
public string MongoId { get; set; } = null!;
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id);
return !string.IsNullOrWhiteSpace(MongoId);
}
}
}

View File

@@ -0,0 +1,22 @@
// ***********************************************************************
// <copyright file="GetVariantsByIdsRequest.cs">
// Core.Inventory
// </copyright>
// ***********************************************************************
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
/// <summary>
/// Request to retrieve multiple furniture variants by their identifiers.
/// </summary>
public class GetFurnitureVariantsByIdsRequest : Notificator, ICommand
{
public string[] Ids { get; set; } = [];
public bool Validate()
{
return Ids is not null && Ids.Length > 0 && Ids.All(id => !string.IsNullOrWhiteSpace(id));
}
}
}

View File

@@ -6,13 +6,14 @@
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.Inventory.Input
namespace Core.Inventory.Application.UseCases.Inventory.Input.Variant
{
/// <summary>
/// Command for updating an existing furniture variant.
/// </summary>
public class UpdateFurnitureVariantRequest : Notificator, ICommand
{
public string _Id { get; set; } = null!;
public string Id { get; set; } = null!;
public string ModelId { get; set; } = null!;
public string Name { get; set; } = null!;
@@ -23,14 +24,15 @@ namespace Core.Inventory.Application.UseCases.Inventory.Input
public decimal Price { get; set; }
public string Currency { get; set; } = "USD";
public Guid CategoryId { get; set; }
public Guid ProviderId { get; set; }
public string CategoryId { get; set; } = string.Empty!;
public string ProviderId { get; set; } = string.Empty!;
public Dictionary<string, object> Attributes { get; set; } = [];
public Dictionary<string, string> Attributes { get; set; } = [];
public bool Validate()
{
return !string.IsNullOrWhiteSpace(Id) &&
return !string.IsNullOrWhiteSpace(_Id) &&
!string.IsNullOrWhiteSpace(Id) &&
!string.IsNullOrWhiteSpace(ModelId) &&
!string.IsNullOrWhiteSpace(Name) &&
!string.IsNullOrWhiteSpace(Color) &&

View File

@@ -1,6 +1,9 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using Core.Inventory.Application.UseCases.Inventory.Ports;
using Core.Inventory.Application.UseCases.Inventory.Validator.Variant;
using Core.Inventory.External.Clients;
using Core.Inventory.External.Clients.Adapters;
using Core.Inventory.External.Clients.Requests;
using FluentValidation;
using Lib.Architecture.BuildingBlocks;
@@ -20,7 +23,9 @@ namespace Core.Inventory.Application.UseCases.Inventory
IComponentHandler<UpdateFurnitureVariantRequest>,
IComponentHandler<GetFurnitureVariantByIdRequest>,
IComponentHandler<GetAllFurnitureVariantsByModelIdRequest>,
IComponentHandler<ChangeFurnitureVariantStatusRequest>
IComponentHandler<ChangeFurnitureVariantStatusRequest>,
IComponentHandler<GetFurnitureVariantsByIdsRequest>,
IComponentHandler<GetAllFurnitureVariantRequest>
{
// FurnitureBase
private readonly IFurnitureBasePort _basePort;
@@ -112,8 +117,10 @@ namespace Core.Inventory.Application.UseCases.Inventory
return;
}
var request = new FurnitureBaseRequest
var request = new FurnitureBaseAdapter
{
_Id = command._Id,
Id = command.Id,
BaseDescription = command.BaseDescription,
Condition = command.Condition,
MaintenanceNotes = command.MaintenanceNotes,
@@ -129,7 +136,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
}
};
var result = await _inventoryDALService.UpdateFurnitureBaseAsync(request, command.Id, cancellationToken);
var result = await _inventoryDALService.UpdateFurnitureBaseAsync(command.Id, request, cancellationToken);
_basePort.Success(result);
}
catch (Exception ex)
@@ -161,7 +168,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
try
{
ArgumentNullException.ThrowIfNull(command);
var result = await _inventoryDALService.GetFurnitureBaseByIdAsync(command.Id, cancellationToken);
var result = await _inventoryDALService.GetFurnitureBaseByIdAsync(command.MongoId, cancellationToken);
if (result is null)
{
_basePort.NoContentSuccess();
@@ -186,7 +193,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
return;
}
var result = await _inventoryDALService.ChangeFurnitureBaseStatusAsync(command.Id, command.Status, cancellationToken);
var result = await _inventoryDALService.ChangeFurnitureBaseStatusAsync(command.MongoId, command.Status, cancellationToken);
_basePort.Success(result);
}
catch (Exception ex)
@@ -240,8 +247,10 @@ namespace Core.Inventory.Application.UseCases.Inventory
_variantPort.ValidationErrors(command.Notifications);
return;
}
var request = new FurnitureVariantRequest
var request = new FurnitureVariantAdapter
{
_Id = command._Id,
Id = command.Id,
Stock = command.Stock,
Attributes= command.Attributes,
CategoryId = command.CategoryId,
@@ -253,7 +262,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
Price = command.Price,
ProviderId = command.ProviderId
};
var result = await _inventoryDALService.UpdateFurnitureVariantAsync(request, command.Id, cancellationToken);
var result = await _inventoryDALService.UpdateFurnitureVariantAsync(command.Id, request, cancellationToken);
_variantPort.Success(result);
}
catch (Exception ex)
@@ -267,7 +276,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
try
{
ArgumentNullException.ThrowIfNull(command);
var result = await _inventoryDALService.GetFurnitureVariantByIdAsync(command.Id, cancellationToken);
var result = await _inventoryDALService.GetFurnitureVariantByIdAsync(command.MongoId, cancellationToken);
if (result is null)
{
_variantPort.NoContentSuccess();
@@ -300,6 +309,34 @@ namespace Core.Inventory.Application.UseCases.Inventory
}
}
public async ValueTask ExecuteAsync(GetFurnitureVariantsByIdsRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(new GetFurnitureVariantsByIdsValidator()))
{
_variantPort.ValidationErrors(command.Notifications);
return;
}
var result = await _inventoryDALService.GetFurnitureVariantsByIdsAsync([.. command.Ids], cancellationToken);
if (result is null || !result.Any())
{
_variantPort.NoContentSuccess();
return;
}
_variantPort.Success([.. result]);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _variantPort);
}
}
public async ValueTask ExecuteAsync(ChangeFurnitureVariantStatusRequest command, CancellationToken cancellationToken = default)
{
try
@@ -310,7 +347,7 @@ namespace Core.Inventory.Application.UseCases.Inventory
_variantPort.ValidationErrors(command.Notifications);
return;
}
var result = await _inventoryDALService.ChangeFurnitureVariantStatusAsync(command.Id, command.Status, cancellationToken);
var result = await _inventoryDALService.ChangeFurnitureVariantStatusAsync(command.MongoId, command.Status, cancellationToken);
_variantPort.Success(result);
}
catch (Exception ex)
@@ -319,6 +356,24 @@ namespace Core.Inventory.Application.UseCases.Inventory
}
}
public async ValueTask ExecuteAsync(GetAllFurnitureVariantRequest command, CancellationToken cancellationToken = default)
{
try
{
var result = await _inventoryDALService.GetAllFurnitureVariantAsync(cancellationToken);
if (!result.Any())
{
_variantPort.NoContentSuccess();
return;
}
_variantPort.Success([.. result]);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _basePort);
}
}
#endregion
}
}

View File

@@ -1,13 +1,13 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Base
{
public class ChangeFurnitureBaseStatusValidator : AbstractValidator<ChangeFurnitureBaseStatusRequest>
{
public ChangeFurnitureBaseStatusValidator()
{
RuleFor(x => x.Id)
RuleFor(x => x.MongoId)
.NotEmpty().WithMessage("Id is required.");
RuleFor(x => x.Status)

View File

@@ -3,11 +3,11 @@
// Core.Inventory
// </copyright>
// ***********************************************************************
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using Core.Inventory.Application.UseCases.Inventory.Validator.Common;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Base
{
public class CreateFurnitureBaseValidator : AbstractValidator<CreateFurnitureBaseRequest>
{

View File

@@ -1,13 +1,13 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Base
{
public class GetFurnitureBaseByIdValidator : AbstractValidator<GetFurnitureBaseByIdRequest>
{
public GetFurnitureBaseByIdValidator()
{
RuleFor(x => x.Id)
RuleFor(x => x.MongoId)
.NotEmpty().WithMessage("Id is required.");
}
}

View File

@@ -1,13 +1,19 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using Core.Inventory.Application.UseCases.Inventory.Validator.Common;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Base
{
public class UpdateFurnitureBaseValidator : AbstractValidator<UpdateFurnitureBaseRequest>
{
public UpdateFurnitureBaseValidator()
{
RuleFor(x => x._Id)
.NotEmpty().WithMessage("_Id is required.");
RuleFor(x => x.Id)
.NotEmpty().WithMessage("Id is required.");
RuleFor(x => x.ModelName)
.NotEmpty().WithMessage("Model name is required.");

View File

@@ -1,13 +1,13 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
public class ChangeFurnitureVariantStatusValidator : AbstractValidator<ChangeFurnitureVariantStatusRequest>
{
public ChangeFurnitureVariantStatusValidator()
{
RuleFor(x => x.Id)
RuleFor(x => x.MongoId)
.NotEmpty().WithMessage("Id is required.");
RuleFor(x => x.Status)

View File

@@ -1,7 +1,7 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
public class CreateFurnitureVariantValidator : AbstractValidator<CreateFurnitureVariantRequest>
{
@@ -23,10 +23,10 @@ namespace Core.Inventory.Application.UseCases.Inventory.Validator
.GreaterThanOrEqualTo(0).WithMessage("Stock must be a non-negative value.");
RuleFor(x => x.CategoryId)
.NotEqual(Guid.Empty).WithMessage("CategoryId is required.");
.NotEmpty().WithMessage("CategoryId is required.");
RuleFor(x => x.ProviderId)
.NotEqual(Guid.Empty).WithMessage("ProviderId is required.");
.NotEmpty().WithMessage("ProviderId is required.");
RuleFor(x => x.Currency)
.NotEmpty().WithMessage("Currency is required.");

View File

@@ -1,7 +1,7 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
public class GetAllFurnitureVariantsByModelIdValidator : AbstractValidator<GetAllFurnitureVariantsByModelIdRequest>
{

View File

@@ -1,13 +1,13 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
public class GetFurnitureVariantByIdValidator : AbstractValidator<GetFurnitureVariantByIdRequest>
{
public GetFurnitureVariantByIdValidator()
{
RuleFor(x => x.Id)
RuleFor(x => x.MongoId)
.NotEmpty().WithMessage("Id is required.");
}
}

View File

@@ -0,0 +1,27 @@
// ***********************************************************************
// <copyright file="GetVariantsByIdsValidator.cs">
// Core.Inventory
// </copyright>
// ***********************************************************************
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
/// <summary>
/// Validator for <see cref="GetFurnitureVariantsByIdsRequest"/>.
/// </summary>
public class GetFurnitureVariantsByIdsValidator : AbstractValidator<GetFurnitureVariantsByIdsRequest>
{
public GetFurnitureVariantsByIdsValidator()
{
RuleFor(x => x.Ids)
.NotNull()
.WithMessage("The list of IDs must not be null.")
.Must(ids => ids.Length!=0)
.WithMessage("At least one ID must be provided.")
.Must(ids => ids.All(id => !string.IsNullOrWhiteSpace(id)))
.WithMessage("All IDs must be non-empty strings.");
}
}
}

View File

@@ -1,12 +1,15 @@
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.Inventory.Validator
namespace Core.Inventory.Application.UseCases.Inventory.Validator.Variant
{
public class UpdateFurnitureVariantValidator : AbstractValidator<UpdateFurnitureVariantRequest>
{
public UpdateFurnitureVariantValidator()
{
RuleFor(x => x._Id)
.NotEmpty().WithMessage("_Id is required.");
RuleFor(x => x.Id)
.NotEmpty().WithMessage("Id is required.");
@@ -29,10 +32,10 @@ namespace Core.Inventory.Application.UseCases.Inventory.Validator
.NotEmpty().WithMessage("Currency is required.");
RuleFor(x => x.CategoryId)
.NotEqual(Guid.Empty).WithMessage("CategoryId is required.");
.NotEmpty().WithMessage("CategoryId is required.");
RuleFor(x => x.ProviderId)
.NotEqual(Guid.Empty).WithMessage("ProviderId is required.");
.NotEmpty().WithMessage("ProviderId is required.");
}
}
}

View File

@@ -0,0 +1,19 @@
using Core.Adapters.Lib;
using Core.Inventory.Application.UseCases.TagType.Ports;
using Lib.Architecture.BuildingBlocks;
using Microsoft.AspNetCore.Mvc;
namespace Core.Inventory.Application.UseCases.TagType.Adapter
{
public class TagTypePort : BasePresenter, ITagTypePort
{
public void Success(TagTypeAdapter output)
{
ViewModel = new OkObjectResult(output);
}
public void Success(List<TagTypeAdapter> output)
{
ViewModel = new OkObjectResult(output);
}
}
}

View File

@@ -0,0 +1,16 @@
using Core.Blueprint.Mongo;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class ChangeTagTypeStatusRequest : Notificator, ICommand
{
public string Id { get; set; }
public StatusEnum Status { get; set; }
public bool Validate()
{
return Id != null;
}
}
}

View File

@@ -0,0 +1,17 @@
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class CreateTagTypeRequest : Notificator, ICommand
{
public string TenantId { get; set; } = null!;
public string TypeName { get; set; } = null!;
public int Level { get; set; }
public string ParentTypeId { get; set; } = null!;
public bool Validate()
{
return TypeName != null;
}
}
}

View File

@@ -0,0 +1,14 @@
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class GetAllTagTypesByListRequest : Notificator, ICommand
{
public string[] TagTypes { get; set; }
public bool Validate()
{
return TagTypes != null;
}
}
}

View File

@@ -0,0 +1,12 @@
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class GetAllTagTypesRequest : ICommand
{
public bool Validate()
{
return true;
}
}
}

View File

@@ -0,0 +1,13 @@
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class GetTagTypeRequest : Notificator, ICommand
{
public string Id { get; set; }
public bool Validate()
{
return Id != null;
}
}
}

View File

@@ -0,0 +1,22 @@
using Lib.Architecture.BuildingBlocks;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Core.Inventory.Application.UseCases.TagType.Input
{
public class UpdateTagTypeRequest : Notificator, ICommand
{
public string Id { get; set; } = null!;
public string TenantId { get; set; } = null!;
public string TypeName { get; set; } = null!;
public int Level { get; set; }
public string ParentTypeId { get; set; } = null!;
public bool Validate()
{
return Id != null;
}
}
}

View File

@@ -0,0 +1,14 @@
using Core.Adapters.Lib;
using Lib.Architecture.BuildingBlocks;
namespace Core.Inventory.Application.UseCases.TagType.Ports
{
public interface ITagTypePort : IBasePort,
ICommandSuccessPort<TagTypeAdapter>,
ICommandSuccessPort<List<TagTypeAdapter>>,
INoContentPort, IBusinessErrorPort, ITimeoutPort, IValidationErrorPort,
INotFoundPort, IForbiddenPort, IUnauthorizedPort, IInternalServerErrorPort,
IBadRequestPort
{
}
}

View File

@@ -0,0 +1,214 @@
using Core.Adapters.Lib;
using Core.Inventory.Application.UseCases.TagType.Input;
using Core.Inventory.Application.UseCases.TagType.Ports;
using Core.Inventory.External.Clients;
using Core.Inventory.External.Clients.Requests;
using FluentValidation;
using Lib.Architecture.BuildingBlocks;
using Lib.Architecture.BuildingBlocks.Helpers;
namespace Core.Inventory.Application.UseCases.TagType
{
public class TagTypeHandler :
IComponentHandler<ChangeTagTypeStatusRequest>,
IComponentHandler<GetAllTagTypesRequest>,
IComponentHandler<GetAllTagTypesByListRequest>,
IComponentHandler<UpdateTagTypeRequest>,
IComponentHandler<GetTagTypeRequest>,
IComponentHandler<CreateTagTypeRequest>
{
private readonly ITagTypePort _port;
private readonly IValidator<ChangeTagTypeStatusRequest> _changeTagTypeStatusValidator;
private readonly IValidator<CreateTagTypeRequest> _registerTagTypeValidator;
private readonly IValidator<UpdateTagTypeRequest> _updateTagTypeValidator;
private readonly IValidator<GetAllTagTypesByListRequest> _TagTypesByListValidator;
private readonly IInventoryServiceClient _inventoryServiceClient;
public TagTypeHandler(
ITagTypePort port,
IValidator<ChangeTagTypeStatusRequest> changeTagTypeStatusValidator,
IValidator<CreateTagTypeRequest> registerTagTypeValidator,
IValidator<UpdateTagTypeRequest> updateTagTypeValidator,
IValidator<GetAllTagTypesByListRequest> TagTypesByListValidator,
IInventoryServiceClient inventoryDALService)
{
_port = port ?? throw new ArgumentNullException(nameof(port));
_changeTagTypeStatusValidator = changeTagTypeStatusValidator ?? throw new ArgumentNullException(nameof(changeTagTypeStatusValidator));
_registerTagTypeValidator = registerTagTypeValidator ?? throw new ArgumentNullException(nameof(registerTagTypeValidator));
_updateTagTypeValidator = updateTagTypeValidator ?? throw new ArgumentNullException(nameof(updateTagTypeValidator));
_inventoryServiceClient = inventoryDALService ?? throw new ArgumentNullException(nameof(inventoryDALService));
_TagTypesByListValidator = TagTypesByListValidator ?? throw new ArgumentNullException(nameof(TagTypesByListValidator));
}
public async ValueTask ExecuteAsync(GetTagTypeRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
var result = await _inventoryServiceClient.GetTagTypeByIdAsync(command.Id, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(GetAllTagTypesRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
var _result = await _inventoryServiceClient.GetAllTagTypesAsync().ConfigureAwait(false);
if (!_result.Any())
{
_port.NoContentSuccess();
return;
}
_port.Success(_result.ToList());
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(GetAllTagTypesByListRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_TagTypesByListValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var _result = await _inventoryServiceClient.GetAllTagTypesByListAsync(command.TagTypes, cancellationToken).ConfigureAwait(false);
if (!_result.Any())
{
_port.NoContentSuccess();
return;
}
_port.Success(_result.ToList());
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(ChangeTagTypeStatusRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_changeTagTypeStatusValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var result = await _inventoryServiceClient.ChangeStatusTagTypeAsync(command.Id, command.Status, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(CreateTagTypeRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_registerTagTypeValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var request = new TagTypeRequest
{
TenantId = command.TenantId,
TypeName = command.TypeName,
Level = command.Level,
ParentTypeId = command.ParentTypeId,
};
var result = await _inventoryServiceClient.CreateTagTypeAsync(request, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(UpdateTagTypeRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_updateTagTypeValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var request = new TagTypeAdapter
{
Id = command.Id,
TenantId = command.TenantId,
TypeName = command.TypeName,
Level = command.Level,
ParentTypeId = command.ParentTypeId
};
string id = command.Id;
var result = await _inventoryServiceClient.UpdateTagTypeAsync(request, id, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
}
}

View File

@@ -0,0 +1,14 @@
using Core.Inventory.Application.UseCases.TagType.Input;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.TagType.Validator
{
public class ChangeTagTypeStatusValidator : AbstractValidator<ChangeTagTypeStatusRequest>
{
public ChangeTagTypeStatusValidator()
{
RuleFor(i => i.Id).NotEmpty().NotNull().OverridePropertyName(x => x.Id).WithName("TagType ID").WithMessage("TagType ID is Obligatory.");
RuleFor(i => i.Status).NotNull().OverridePropertyName(x => x.Status).WithName("Status").WithMessage("Status is Obligatory.");
}
}
}

View File

@@ -0,0 +1,14 @@
using Core.Inventory.Application.UseCases.TagType.Input;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.TagType.Validator
{
public class CreateTagTypeValidator : AbstractValidator<CreateTagTypeRequest>
{
public CreateTagTypeValidator()
{
RuleFor(i => i.TypeName).NotEmpty().NotNull().OverridePropertyName(x => x.TypeName).WithName("TagType Name").WithMessage("TagType Name is Obligatory.");
RuleFor(i => i.Level).NotEmpty().NotNull().OverridePropertyName(x => x.Level).WithName("TagType Level").WithMessage("TagType Level is Obligatory.");
}
}
}

View File

@@ -0,0 +1,14 @@
using Core.Inventory.Application.UseCases.TagType.Input;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.TagType.Validator
{
public class GetAllTagTypesByListValidator : AbstractValidator<GetAllTagTypesByListRequest>
{
public GetAllTagTypesByListValidator()
{
RuleFor(i => i.TagTypes).NotEmpty().NotNull().OverridePropertyName(x => x.TagTypes).WithName("TagTypes").WithMessage("TagTypes are Obligatory.");
}
}
}

View File

@@ -0,0 +1,14 @@
using Core.Inventory.Application.UseCases.TagType.Input;
using FluentValidation;
namespace Core.Inventory.Application.UseCases.TagType.Validator
{
public class UpdateTagTypeValidator : AbstractValidator<UpdateTagTypeRequest>
{
public UpdateTagTypeValidator()
{
RuleFor(i => i.TypeName).NotEmpty().NotNull().OverridePropertyName(x => x.TypeName).WithName("TagType Name").WithMessage("TagType Name is Obligatory.");
RuleFor(i => i.Level).NotEmpty().NotNull().OverridePropertyName(x => x.Level).WithName("Level").WithMessage("Level is Obligatory.");
}
}
}

View File

@@ -0,0 +1,19 @@
using Core.Adapters.Lib;
namespace Core.Inventory.External.Clients.Adapters
{
public class FurnitureBaseAdapter
{
public string _Id { get; set; } = null!;
public string Id { get; init; } = null!;
public string ModelName { get; set; } = null!;
public string Material { get; set; } = null!;
public string Condition { get; set; } = null!;
public string? BaseDescription { get; set; }
public string? Representation { get; set; }
public string? MaintenanceNotes { get; set; }
public Dimensions Dimensions { get; set; } = new();
public List<string>? VariantIds { get; set; }
}
}

View File

@@ -0,0 +1,21 @@
namespace Core.Inventory.External.Clients.Adapters
{
public class FurnitureVariantAdapter
{
public string _Id { get; set; } = null!;
public string Id { get; init; } = null!;
public string ModelId { get; set; } = null!;
public string Name { get; set; } = null!;
public string Color { get; set; } = null!;
public string? Line { get; set; }
public decimal Price { get; set; }
public string Currency { get; set; } = "USD";
public int Stock { get; set; }
public string CategoryId { get; set; } = string.Empty!;
public string ProviderId { get; set; } = string.Empty!;
public Dictionary<string, string> Attributes { get; set; } = [];
}
}

View File

@@ -1,5 +1,6 @@
using Core.Adapters.Lib;
using Core.Blueprint.Mongo;
using Core.Inventory.External.Clients.Adapters;
using Core.Inventory.External.Clients.Requests;
using Microsoft.AspNetCore.Mvc;
using Refit;
@@ -13,36 +14,63 @@ namespace Core.Inventory.External.Clients
[Get("/api/v1/FurnitureBase")]
Task<IEnumerable<FurnitureBase>> GetAllFurnitureBaseAsync(CancellationToken cancellationToken = default);
[Get("/api/v1/FurnitureBase/{id}")]
Task<FurnitureBase> GetFurnitureBaseByIdAsync([FromRoute] string id, CancellationToken cancellationToken = default);
[Get("/api/v1/FurnitureBase/{mongoId}")]
Task<FurnitureBase> GetFurnitureBaseByIdAsync([FromRoute] string mongoId, CancellationToken cancellationToken = default);
[Post("/api/v1/FurnitureBase")]
Task<FurnitureBase> CreateFurnitureBaseAsync([FromBody] FurnitureBaseRequest request, CancellationToken cancellationToken = default);
[Put("/api/v1/FurnitureBase/{id}")]
Task<FurnitureBase> UpdateFurnitureBaseAsync([FromBody] FurnitureBaseRequest request, [FromRoute] string id, CancellationToken cancellationToken = default);
Task<FurnitureBase> UpdateFurnitureBaseAsync([FromRoute] string id, [FromBody] FurnitureBaseAdapter request, CancellationToken cancellationToken = default);
[Patch("/api/v1/FurnitureBase/{id}/{newStatus}/ChangeStatus")]
Task<FurnitureBase> ChangeFurnitureBaseStatusAsync([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken = default);
[Patch("/api/v1/FurnitureBase/{mongoId}/{newStatus}/ChangeStatus")]
Task<FurnitureBase> ChangeFurnitureBaseStatusAsync([FromRoute] string mongoId, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken = default);
#endregion
#region FurnitureVariant
[Get("/api/v1/FurnitureVariant/{modelId}")]
[Get("/api/v1/FurnitureVariant/ByModel/{modelId}")]
Task<IEnumerable<FurnitureVariant>> GetAllVariantsByModelIdAsync([FromRoute] string modelId, CancellationToken cancellationToken = default);
[Get("/api/v1/FurnitureVariant/{id}/byId")]
Task<FurnitureVariant> GetFurnitureVariantByIdAsync([FromRoute] string id, CancellationToken cancellationToken = default);
[Get("/api/v1/FurnitureVariant/{mongoId}")]
Task<FurnitureVariant> GetFurnitureVariantByIdAsync([FromRoute] string mongoId, CancellationToken cancellationToken = default);
[Post("/api/v1/FurnitureVariant/ByIds")]
Task<IEnumerable<FurnitureVariant>> GetFurnitureVariantsByIdsAsync([Body] string[] ids, CancellationToken cancellationToken = default);
[Post("/api/v1/FurnitureVariant")]
Task<FurnitureVariant> CreateFurnitureVariantAsync([FromBody] FurnitureVariantRequest request, CancellationToken cancellationToken = default);
[Put("/api/v1/FurnitureVariant/{id}")]
Task<FurnitureVariant> UpdateFurnitureVariantAsync([FromBody] FurnitureVariantRequest request, [FromRoute] string id, CancellationToken cancellationToken = default);
Task<FurnitureVariant> UpdateFurnitureVariantAsync([FromRoute] string id, [FromBody] FurnitureVariantAdapter request, CancellationToken cancellationToken = default);
[Patch("/api/v1/FurnitureVariant/{id}/{newStatus}/ChangeStatus")]
Task<FurnitureVariant> ChangeFurnitureVariantStatusAsync([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken = default);
[Patch("/api/v1/FurnitureVariant/{mongoId}/{newStatus}/ChangeStatus")]
Task<FurnitureVariant> ChangeFurnitureVariantStatusAsync([FromRoute] string mongoId, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken = default);
[Get("/api/v1/FurnitureVariant")]
Task<IEnumerable<FurnitureVariant>> GetAllFurnitureVariantAsync(CancellationToken cancellationToken = default);
#endregion
#region TagType
[Get("/api/v1/TagType")]
Task<IEnumerable<TagTypeAdapter>> GetAllTagTypesAsync(CancellationToken cancellationToken = default);
[Post("/api/v1/TagType/GetTagTypeList")]
Task<IEnumerable<TagTypeAdapter>> GetAllTagTypesByListAsync([FromBody] string[] request, CancellationToken cancellationToken = default);
[Get("/api/v1/TagType/{id}")]
Task<TagTypeAdapter> GetTagTypeByIdAsync([FromRoute] string id, CancellationToken cancellationToken = default);
[Post("/api/v1/TagType")]
Task<TagTypeAdapter> CreateTagTypeAsync([FromBody] TagTypeRequest newTagType, CancellationToken cancellationToken = default);
[Put("/api/v1/TagType/{id}")]
Task<TagTypeAdapter> UpdateTagTypeAsync([FromBody] TagTypeAdapter entity, [FromRoute] string id, CancellationToken cancellationToken = default);
[Patch("/api/v1/TagType/{id}/{newStatus}/ChangeStatus")]
Task<TagTypeAdapter> ChangeStatusTagTypeAsync([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken = default);
#endregion
}

View File

@@ -11,9 +11,9 @@
public string Currency { get; set; } = "USD";
public int Stock { get; set; }
public Guid CategoryId { get; set; }
public Guid ProviderId { get; set; }
public string CategoryId { get; set; } = string.Empty!;
public string ProviderId { get; set; } = string.Empty!;
public Dictionary<string, object> Attributes { get; set; } = [];
public Dictionary<string, string> Attributes { get; set; } = [];
}
}

View File

@@ -0,0 +1,10 @@
namespace Core.Inventory.External.Clients.Requests
{
public class TagTypeRequest
{
public string TenantId { get; set; } = null!;
public string TypeName { get; set; } = null!;
public int Level { get; set; }
public string ParentTypeId { get; set; } = null!;
}
}

View File

@@ -7,7 +7,7 @@
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Adapters.Lib" Version="1.0.3" />
<PackageReference Include="Adapters.Lib" Version="1.0.9" />
<PackageReference Include="BuildingBlocks.Library" Version="1.0.0" />
<PackageReference Include="Refit" Version="8.0.0" />
</ItemGroup>

View File

@@ -1,5 +1,5 @@
using Asp.Versioning;
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using Core.Inventory.Application.UseCases.Inventory.Ports;
using Lib.Architecture.BuildingBlocks;
using Microsoft.AspNetCore.Mvc;
@@ -10,30 +10,20 @@ namespace Core.Inventory.Service.API.Controllers
[Route("api/v{api-version:apiVersion}/[controller]")]
[Produces("application/json")]
[ApiController]
public class FurnitureBaseController : ControllerBase
public class FurnitureBaseController(
IComponentHandler<GetFurnitureBaseByIdRequest> getByIdHandler,
IComponentHandler<GetAllFurnitureBaseRequest> getAllHandler,
IComponentHandler<CreateFurnitureBaseRequest> createHandler,
IComponentHandler<UpdateFurnitureBaseRequest> updateHandler,
IComponentHandler<ChangeFurnitureBaseStatusRequest> changeStatusHandler,
IFurnitureBasePort port) : ControllerBase
{
private readonly IComponentHandler<GetFurnitureBaseByIdRequest> _getByIdHandler;
private readonly IComponentHandler<GetAllFurnitureBaseRequest> _getAllHandler;
private readonly IComponentHandler<CreateFurnitureBaseRequest> _createHandler;
private readonly IComponentHandler<UpdateFurnitureBaseRequest> _updateHandler;
private readonly IComponentHandler<ChangeFurnitureBaseStatusRequest> _changeStatusHandler;
private readonly IFurnitureBasePort _port;
public FurnitureBaseController(
IComponentHandler<GetFurnitureBaseByIdRequest> getByIdHandler,
IComponentHandler<GetAllFurnitureBaseRequest> getAllHandler,
IComponentHandler<CreateFurnitureBaseRequest> createHandler,
IComponentHandler<UpdateFurnitureBaseRequest> updateHandler,
IComponentHandler<ChangeFurnitureBaseStatusRequest> changeStatusHandler,
IFurnitureBasePort port)
{
_getByIdHandler= getByIdHandler;
_getAllHandler= getAllHandler;
_createHandler= createHandler;
_updateHandler= updateHandler;
_changeStatusHandler= changeStatusHandler;
_port= port;
}
private readonly IComponentHandler<GetFurnitureBaseByIdRequest> _getByIdHandler = getByIdHandler;
private readonly IComponentHandler<GetAllFurnitureBaseRequest> _getAllHandler = getAllHandler;
private readonly IComponentHandler<CreateFurnitureBaseRequest> _createHandler = createHandler;
private readonly IComponentHandler<UpdateFurnitureBaseRequest> _updateHandler = updateHandler;
private readonly IComponentHandler<ChangeFurnitureBaseStatusRequest> _changeStatusHandler = changeStatusHandler;
private readonly IFurnitureBasePort _port = port;
[HttpGet("GetAll")]
public async Task<IActionResult> GetAllAsync(CancellationToken cancellationToken)
@@ -45,7 +35,7 @@ namespace Core.Inventory.Service.API.Controllers
[HttpPost("GetById")]
public async Task<IActionResult> GetByIdAsync([FromBody] GetFurnitureBaseByIdRequest request, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request?.Id)) return BadRequest("Furniture base identifier is required");
if (string.IsNullOrEmpty(request?.MongoId)) return BadRequest("Furniture base identifier is required");
await _getByIdHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;
@@ -68,7 +58,7 @@ namespace Core.Inventory.Service.API.Controllers
[HttpPatch("ChangeStatus")]
public async Task<IActionResult> ChangeStatusAsync([FromBody] ChangeFurnitureBaseStatusRequest request, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request?.Id)) return BadRequest("Furniture base identifier is required");
if (string.IsNullOrEmpty(request?.MongoId)) return BadRequest("Furniture base identifier is required");
await _changeStatusHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;

View File

@@ -1,5 +1,5 @@
using Asp.Versioning;
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using Core.Inventory.Application.UseCases.Inventory.Ports;
using Lib.Architecture.BuildingBlocks;
using Microsoft.AspNetCore.Mvc;
@@ -12,38 +12,59 @@ namespace Core.Inventory.Service.API.Controllers
[ApiController]
public class FurnitureVariantController(
IComponentHandler<GetFurnitureVariantByIdRequest> getByIdHandler,
IComponentHandler<GetAllFurnitureVariantsByModelIdRequest> getAllHandler,
IComponentHandler<GetAllFurnitureVariantsByModelIdRequest> getAllMyModelIdHandler,
IComponentHandler<CreateFurnitureVariantRequest> createHandler,
IComponentHandler<UpdateFurnitureVariantRequest> updateHandler,
IComponentHandler<ChangeFurnitureVariantStatusRequest> changeStatusHandler,
IComponentHandler<GetFurnitureVariantsByIdsRequest> getByIdsHandler,
IComponentHandler<GetAllFurnitureVariantRequest> getAllHandler,
IFurnitureVariantPort port) : ControllerBase
{
private readonly IComponentHandler<GetFurnitureVariantByIdRequest> _getByIdHandler = getByIdHandler;
private readonly IComponentHandler<GetAllFurnitureVariantsByModelIdRequest> _getAllHandler = getAllHandler;
private readonly IComponentHandler<GetAllFurnitureVariantsByModelIdRequest> _getAllByModelIdHandler = getAllMyModelIdHandler;
private readonly IComponentHandler<CreateFurnitureVariantRequest> _createHandler = createHandler;
private readonly IComponentHandler<UpdateFurnitureVariantRequest> _updateHandler = updateHandler;
private readonly IComponentHandler<ChangeFurnitureVariantStatusRequest> _changeStatusHandler = changeStatusHandler;
private readonly IComponentHandler<GetFurnitureVariantsByIdsRequest> _getByIdsHandler = getByIdsHandler;
private readonly IComponentHandler<GetAllFurnitureVariantRequest> _getAllHandler = getAllHandler;
private readonly IFurnitureVariantPort _port = port;
[HttpGet("GetAllByModelId")]
public async Task<IActionResult> GetAllAsync([FromQuery] string modelId, CancellationToken cancellationToken)
[HttpGet("GetAll")]
public async Task<IActionResult> GetAllAsync(CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(modelId)) return BadRequest("Model ID is required");
await _getAllHandler.ExecuteAsync(new GetAllFurnitureVariantRequest { }, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;
}
var request = new GetAllFurnitureVariantsByModelIdRequest { ModelId = modelId };
await _getAllHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
[HttpPost("GetAllByModelId")]
public async Task<IActionResult> GetAllByModelIdAsync([FromBody] GetAllFurnitureVariantsByModelIdRequest request, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request?.ModelId)) return BadRequest("Model ID is required");
await _getAllByModelIdHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;
}
[HttpPost("GetById")]
public async Task<IActionResult> GetByIdAsync([FromBody] GetFurnitureVariantByIdRequest request, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request?.Id)) return BadRequest("Furniture variant identifier is required");
if (string.IsNullOrEmpty(request?.MongoId)) return BadRequest("Furniture variant identifier is required");
await _getByIdHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;
}
[HttpPost("GetByIds")]
public async Task<IActionResult> GetByIdsAsync([FromBody] GetFurnitureVariantsByIdsRequest request, CancellationToken cancellationToken)
{
if (request?.Ids is null || request.Ids.Length == 0)
return BadRequest("At least one furniture variant ID must be provided.");
await _getByIdsHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;
}
[HttpPost("Create")]
public async Task<IActionResult> CreateAsync([FromBody] CreateFurnitureVariantRequest request, CancellationToken cancellationToken)
{
@@ -61,7 +82,7 @@ namespace Core.Inventory.Service.API.Controllers
[HttpPatch("ChangeStatus")]
public async Task<IActionResult> ChangeStatusAsync([FromBody] ChangeFurnitureVariantStatusRequest request, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request?.Id)) return BadRequest("Furniture variant identifier is required");
if (string.IsNullOrEmpty(request?.MongoId)) return BadRequest("Furniture variant identifier is required");
await _changeStatusHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return _port.ViewModel;

View File

@@ -0,0 +1,187 @@
using Asp.Versioning;
using Core.Adapters.Lib;
using Core.Inventory.Application.UseCases.TagType.Input;
using Core.Inventory.Application.UseCases.TagType.Ports;
using Lib.Architecture.BuildingBlocks;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
namespace Core.Inventory.Service.API.Controllers
{
/// <summary>
/// Handles all services and business rules related to <see cref="TagTypeController"/>.
/// </summary>
[ApiVersion("1.0")]
[Route("api/v{api-version:apiVersion}/[controller]")]
[Produces("application/json")]
[ApiController]
[AllowAnonymous]
public class TagTypeController : ControllerBase
{
private readonly IComponentHandler<GetTagTypeRequest> getTagTypeHandler;
private readonly IComponentHandler<GetAllTagTypesRequest> getAllTagTypesHandler;
private readonly IComponentHandler<GetAllTagTypesByListRequest> getAllTagTypesByListHandler;
private readonly IComponentHandler<CreateTagTypeRequest> createTagTypeHandler;
private readonly IComponentHandler<UpdateTagTypeRequest> updateTagTypeHandler;
private readonly IComponentHandler<ChangeTagTypeStatusRequest> changeTagTypeStatusHandler;
private readonly ITagTypePort port;
/// <summary>
/// Handles all services and business rules related to <see cref="TagTypeController"/>.
/// </summary>
public TagTypeController(
IComponentHandler<GetTagTypeRequest> getTagTypeHandler,
IComponentHandler<GetAllTagTypesRequest> getAllTagTypesHandler,
IComponentHandler<GetAllTagTypesByListRequest> getAllTagTypesByListHandler,
IComponentHandler<CreateTagTypeRequest> createTagTypeHandler,
IComponentHandler<UpdateTagTypeRequest> updateTagTypeHandler,
IComponentHandler<ChangeTagTypeStatusRequest> changeTagTypeStatusHandler,
ITagTypePort port
)
{
this.createTagTypeHandler = createTagTypeHandler;
this.updateTagTypeHandler = updateTagTypeHandler;
this.changeTagTypeStatusHandler = changeTagTypeStatusHandler;
this.getAllTagTypesHandler = getAllTagTypesHandler;
this.getTagTypeHandler = getTagTypeHandler;
this.getAllTagTypesByListHandler = getAllTagTypesByListHandler;
this.port = port;
}
/// <summary>
/// Gets all the TagTypes.
/// </summary>
[HttpGet("GetAll")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
public async Task<IActionResult> GetAllTagTypesAsync(CancellationToken cancellationToken)
{
await getAllTagTypesHandler.ExecuteAsync(new GetAllTagTypesRequest { }, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
/// <summary>
/// Gets all the TagTypes by TagType identifiers.
/// </summary>
/// <param name="request">The request containing the list of TagType identifiers.</param>
/// <param name="cancellationToken">Cancellation token for the asynchronous operation.</param>
/// <returns>The <see cref="IActionResult"/> representing the result of the service call.</returns>
/// <response code="200">The TagTypes found.</response>
/// <response code="204">No content if no TagTypes are found.</response>
/// <response code="400">Bad request if the TagType identifiers are missing or invalid.</response>
/// <response code="401">Unauthorized if the user is not authenticated.</response>
/// <response code="412">Precondition failed if the request does not meet expected conditions.</response>
/// <response code="422">Unprocessable entity if the request cannot be processed.</response>
/// <response code="500">Internal server error if an unexpected error occurs.</response>
[HttpPost]
[Route("GetTagTypeList")]
[ProducesResponseType(typeof(IEnumerable<TagTypeAdapter>), StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<IActionResult> GetAllTagTypesByListAsync([FromBody] GetAllTagTypesByListRequest request, CancellationToken cancellationToken)
{
if (request == null || request.TagTypes == null || !request.TagTypes.Any())
{
return BadRequest("TagType identifiers are required.");
}
await getAllTagTypesByListHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
/// <summary>
/// Gets the TagType by identifier.
/// </summary>
[HttpPost]
[Route("GetById")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<IActionResult> GetTagTypeById([FromBody] GetTagTypeRequest request, CancellationToken cancellationToken)
{
if (request.Id == null || !request.Id.Any())
{
return BadRequest("Invalid TagType Id");
}
await getTagTypeHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
/// <summary>
/// Creates a new TagType.
/// </summary>
[HttpPost("Create")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
public async Task<IActionResult> CreateTagTypeAsync([FromBody] CreateTagTypeRequest newTagType, CancellationToken cancellationToken = default)
{
await createTagTypeHandler.ExecuteAsync(newTagType, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
/// <summary>
/// Updates a full TagType by identifier.
/// </summary>
[HttpPut("Update")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
public async Task<IActionResult> UpdateTagTypeAsync([FromBody] UpdateTagTypeRequest request, CancellationToken cancellationToken = default)
{
await updateTagTypeHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
/// <summary>
/// Changes the status of the TagType.
/// </summary>
[HttpPatch]
[Route("ChangeStatus")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status204NoContent)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)]
[ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<IActionResult> ChangeTagTypeStatusAsync([FromBody] ChangeTagTypeStatusRequest request,
CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(request.Id)) { return BadRequest("Invalid TagType identifier"); }
await changeTagTypeStatusHandler.ExecuteAsync(request, cancellationToken).ConfigureAwait(false);
return port.ViewModel;
}
}
}

View File

@@ -1,8 +1,15 @@
using Core.Inventory.Application.UseCases.Inventory;
using Core.Inventory.Application.UseCases.Inventory.Adapter;
using Core.Inventory.Application.UseCases.Inventory.Input;
using Core.Inventory.Application.UseCases.Inventory.Input.Base;
using Core.Inventory.Application.UseCases.Inventory.Input.Variant;
using Core.Inventory.Application.UseCases.Inventory.Ports;
using Core.Inventory.Application.UseCases.Inventory.Validator;
using Core.Inventory.Application.UseCases.Inventory.Validator.Base;
using Core.Inventory.Application.UseCases.Inventory.Validator.Variant;
using Core.Inventory.Application.UseCases.TagType;
using Core.Inventory.Application.UseCases.TagType.Adapter;
using Core.Inventory.Application.UseCases.TagType.Input;
using Core.Inventory.Application.UseCases.TagType.Ports;
using Core.Inventory.Application.UseCases.TagType.Validator;
using FluentValidation;
using Lib.Architecture.BuildingBlocks;
@@ -42,6 +49,8 @@ namespace Core.Inventory.Service.API.Extensions
services.AddScoped<IComponentHandler<CreateFurnitureVariantRequest>, InventoryHandler>();
services.AddScoped<IComponentHandler<UpdateFurnitureVariantRequest>, InventoryHandler>();
services.AddScoped<IComponentHandler<ChangeFurnitureVariantStatusRequest>, InventoryHandler>();
services.AddScoped<IComponentHandler<GetFurnitureVariantsByIdsRequest>, InventoryHandler>();
services.AddScoped<IComponentHandler<GetAllFurnitureVariantRequest>, InventoryHandler>();
services.AddValidatorsFromAssemblyContaining<CreateFurnitureVariantValidator>();
services.AddScoped<IValidator<CreateFurnitureVariantRequest>, CreateFurnitureVariantValidator>();
@@ -57,6 +66,33 @@ namespace Core.Inventory.Service.API.Extensions
services.AddValidatorsFromAssemblyContaining<GetAllFurnitureVariantsByModelIdValidator>();
services.AddScoped<IValidator<GetAllFurnitureVariantsByModelIdRequest>, GetAllFurnitureVariantsByModelIdValidator>();
services.AddValidatorsFromAssemblyContaining<GetFurnitureVariantsByIdsValidator>();
services.AddScoped<IValidator<GetFurnitureVariantsByIdsRequest>, GetFurnitureVariantsByIdsValidator>();
#endregion
#region TagType Services
services.AddScoped<ITagTypePort, TagTypePort>();
services.AddScoped<IComponentHandler<GetAllTagTypesRequest>, TagTypeHandler>();
services.AddScoped<IComponentHandler<GetTagTypeRequest>, TagTypeHandler>();
services.AddValidatorsFromAssemblyContaining<GetAllTagTypesByListValidator>();
services.AddScoped<IValidator<GetAllTagTypesByListRequest>, GetAllTagTypesByListValidator>();
services.AddScoped<IComponentHandler<GetAllTagTypesByListRequest>, TagTypeHandler>();
services.AddValidatorsFromAssemblyContaining<CreateTagTypeValidator>();
services.AddScoped<IValidator<CreateTagTypeRequest>, CreateTagTypeValidator>();
services.AddScoped<IComponentHandler<CreateTagTypeRequest>, TagTypeHandler>();
services.AddValidatorsFromAssemblyContaining<UpdateTagTypeValidator>();
services.AddScoped<IValidator<UpdateTagTypeRequest>, UpdateTagTypeValidator>();
services.AddScoped<IComponentHandler<UpdateTagTypeRequest>, TagTypeHandler>();
services.AddValidatorsFromAssemblyContaining<ChangeTagTypeStatusValidator>();
services.AddScoped<IValidator<ChangeTagTypeStatusRequest>, ChangeTagTypeStatusValidator>();
services.AddScoped<IComponentHandler<ChangeTagTypeStatusRequest>, TagTypeHandler>();
#endregion
return services;