TekH
7309b968fe
Removed the State property from ProfileObjState and added ChangedWho and ChangedWhen properties. Updated ProfileObject to reference ProfileObjState instead of State. Modified ProfileObjRepository to include the new State property when querying ProfileObject instances.
40 lines
1.8 KiB
C#
40 lines
1.8 KiB
C#
using Microsoft.EntityFrameworkCore;
|
|
using WorkFlow.Application.Contracts.Repositories;
|
|
using WorkFlow.Domain.Entities;
|
|
|
|
namespace WorkFlow.Infrastructure.Repositories;
|
|
|
|
/// <summary>
|
|
/// Repository implementation for retrieving <see cref="ProfileObject"/> entities from the database.
|
|
/// </summary>
|
|
public class ProfileObjRepository : IProfileObjRepository
|
|
{
|
|
private readonly WFDBContext _context;
|
|
|
|
/// <summary>
|
|
/// Initializes a new instance of the <see cref="ProfileObjRepository"/> class.
|
|
/// </summary>
|
|
/// <param name="context">The database context used for accessing profile data.</param>
|
|
public ProfileObjRepository(WFDBContext context)
|
|
{
|
|
_context = context;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Retrieves the list of <see cref="ProfileObject"/> associated with a given user ID and profile ID by calling a database function.
|
|
/// </summary>
|
|
/// <param name="userId">The unique identifier of the user whose profile is to be retrieved.</param>
|
|
/// <param name="profileId">The unique identifier of the profile whose object is to be retrieved.</param>
|
|
/// <param name="cancel">Propagates notification that operations should be canceled.</param>
|
|
/// <returns>
|
|
/// A task that represents the asynchronous operation. The task result contains the <see cref="ProfileObject"/> object if found; otherwise, <c>null</c>.
|
|
/// </returns>
|
|
/// <remarks>
|
|
/// Logs an error if no profile is found, or if multiple profiles are returned, indicating potential data issues.
|
|
/// </remarks>
|
|
public async Task<IEnumerable<ProfileObject>> ReadAsync(int userId, int profileId, CancellationToken cancel = default)
|
|
=> await _context.Objects
|
|
.FromSqlRaw("SELECT * FROM [FNMWF_GET_PROFILE_OBJECTS] ({0}, {1})", userId, profileId)
|
|
.Include(obj => obj.State)
|
|
.ToListAsync(cancel);
|
|
} |