AgileWebs/Core.Inventory.DAL
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add TagType CRUD

Browse Source
This commit is contained in:
Oscar Morales
2025-07-31 19:07:22 -06:00
parent e191851982
commit 54dd38cfd6
6 changed files with 410 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
Core.Inventory.Provider/Contracts/ITagTypeProvider.cs Normal file
View File

@@ -0,0 +1,59 @@
using Core.Adapters.Lib;
using Core.Blueprint.Mongo;
using Core.Inventory.Domain.Contexts.Inventory.Request;
namespace Core.Inventory.Provider.Contracts
{
public interface ITagTypeProvider
{
/// <summary>
/// Creates a new TagType.
/// </summary>
/// <param name="entity">The TagType to be created.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<TagTypeAdapter> CreateTagType(TagTypeRequest newTagType, CancellationToken cancellationToken);
/// <summary>
/// Gets an TagType by identifier.
/// </summary>
/// <param name="id">The TagType identifier.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<TagTypeAdapter> GetTagTypeById(string _id, CancellationToken cancellationToken);
/// <summary>
/// Gets all the tagTypes.
/// </summary>
/// <returns>A <see cref="{Task{IEnumerbale{TagTypeAdapter}}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypes(CancellationToken cancellationToken);
/// <summary>
/// Gets all the tagTypes by tagTypes identifier list.
/// </summary>
/// <param name="tagTypes">The list of tagTypes identifiers.</param>
/// <returns>A <see cref="Task{IEnumerable{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypesByList(string[] TagTypes, CancellationToken cancellationToken);
/// <summary>
/// Changes the status of the tagType.
/// </summary>
/// <param name="id">The tagType identifier.</param>
/// <param name="newStatus">The new status of the tagType.</param>
/// <returns>The <see cref="TagTypeAdapter"/> updated entity.</returns>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<TagTypeAdapter> ChangeTagTypeStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken);
/// <summary>
/// Updates a TagType by id.
/// </summary>
/// <param name="entity">The TagType to be updated.</param>
/// <param name="id">The TagType identifier.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<TagTypeAdapter> UpdateTagType(TagTypeAdapter entity, CancellationToken cancellationToken);
}
}

2
Core.Inventory.Provider/Core.Inventory.Provider.csproj
View File

@@ -7,7 +7,7 @@
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Adapters.Lib" Version="1.0.8" />
<PackageReference Include="Adapters.Lib" Version="1.0.9" />
<PackageReference Include="Core.Blueprint.Mongo" Version="1.0.0" />
<PackageReference Include="Core.Blueprint.Redis" Version="1.0.2" />
<PackageReference Include="Mapster" Version="7.4.0" />

149
Core.Inventory.Provider/Providers/Inventory/TagTypeProvider.cs Normal file
View File

@@ -0,0 +1,149 @@
using Core.Adapters.Lib;
using Core.Blueprint.Mongo;
using Core.Blueprint.Redis;
using Core.Blueprint.Redis.Helpers;
using Core.Inventory.Domain.Contexts.Inventory.Request;
using Core.Inventory.Provider.Contracts;
using Mapster;
using Microsoft.Extensions.Options;
using MongoDB.Driver;
namespace Core.Inventory.Provider.Providers.Inventory
{
/// <summary>
/// Handles all services and business rules related to <see cref="TagTypeAdapter"/>.
/// </summary>
public class TagTypeProvider : ITagTypeProvider
{
private readonly CollectionRepository<TagTypeAdapter> repository;
private readonly CacheSettings cacheSettings;
private readonly IRedisCacheProvider cacheProvider;
public TagTypeProvider(CollectionRepository<TagTypeAdapter> repository,
IRedisCacheProvider cacheProvider,
IOptions<CacheSettings> cacheSettings)
{
this.repository = repository;
this.repository.CollectionInitialization();
this.cacheSettings = cacheSettings.Value;
this.cacheProvider = cacheProvider;
}
/// <summary>
/// Creates a new TagType.
/// </summary>
/// <param name="entity">The TagType to be created.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<TagTypeAdapter> CreateTagType(TagTypeRequest newTagType, CancellationToken cancellationToken)
{
var tagTypeCollection = newTagType.Adapt<TagTypeAdapter>();
await repository.InsertOneAsync(tagTypeCollection);
return tagTypeCollection;
}
/// <summary>
/// Gets an TagType by identifier.
/// </summary>
/// <param name="id">The TagType identifier.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>0
public async ValueTask<TagTypeAdapter> GetTagTypeById(string _id, CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagTypeById", _id);
var cachedData = await cacheProvider.GetAsync<TagTypeAdapter>(cacheKey);
if (cachedData is not null) { return cachedData; }
var tagType = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, tagType);
return tagType;
}
/// <summary>
/// Gets all the TagTypes.
/// </summary>
/// <returns>A <see cref="{Task{IEnumerbale{TagTypeAdapter}}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypes(CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagTypes");
var cachedData = await cacheProvider.GetAsync<IEnumerable<TagTypeAdapter>>(cacheKey) ?? [];
if (cachedData.Any()) return cachedData;
var tagTypes = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, tagTypes);
return tagTypes;
}
/// <summary>
/// Gets all the TagTypes by TagTypes identifier list.
/// </summary>
/// <param name="TagTypes">The list of TagTypes identifiers.</param>
/// <returns>A <see cref="Task{IEnumerable{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypesByList(string[] tagTypes, CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllTagTypesByList", tagTypes);
var cachedData = await cacheProvider.GetAsync<IEnumerable<TagTypeAdapter>>(cacheKey) ?? [];
if (cachedData.Any()) return cachedData;
var builder = Builders<TagTypeAdapter>.Filter;
var filters = new List<FilterDefinition<TagTypeAdapter>>();
if (tagTypes != null || !tagTypes.Any())
{
filters.Add(builder.In(x => x._Id, tagTypes));
}
var finalFilter = filters.Any() ? builder.And(filters) : builder.Empty;
var tagTypesList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, tagTypesList);
return tagTypesList;
}
/// <summary>
/// Changes the status of the TagType.
/// </summary>
/// <param name="id">The TagType identifier.</param>
/// <param name="newStatus">The new status of the TagType.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<TagTypeAdapter> ChangeTagTypeStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken)
{
var entity = await repository.FindByIdAsync(id);
entity.Status = newStatus;
await repository.ReplaceOneAsync(entity);
return entity;
}
/// <summary>
/// Updates a TagType by id.
/// </summary>
/// <param name="entity">The TagType to be updated.</param>
/// <param name="id">The TagType identifier.</param>
/// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<TagTypeAdapter> UpdateTagType(TagTypeAdapter entity, CancellationToken cancellationToken)
{
await repository.ReplaceOneAsync(entity);
return entity;
}
}
}

3
Core.Inventory.Provider/ServiceCollectionExtensions.cs
View File

@@ -17,6 +17,9 @@ namespace Core.Inventory.Provider
services.AddScoped<IFurnitureVariantProvider, FurnitureVariantProvider>();
services.AddScoped<CollectionRepository<FurnitureVariant>>();
services.AddScoped<ITagTypeProvider, TagTypeProvider>();
services.AddScoped<CollectionRepository<TagTypeAdapter>>();
return services;
}