88 lines
3.0 KiB
C#
88 lines
3.0 KiB
C#
using AutoMapper;
|
|
using DigitalData.Core.Abstraction.Application.Repository;
|
|
using EnvelopeGenerator.Application.Dto.EnvelopeReceiver;
|
|
using EnvelopeGenerator.Domain.Entities;
|
|
using MediatR;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace EnvelopeGenerator.Application.EnvelopeReceivers.Queries;
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public class ReadEnvelopeReceiverQueryHandler : IRequestHandler<ReadEnvelopeReceiverQuery, IEnumerable<EnvelopeReceiverDto>>
|
|
{
|
|
private readonly IRepository<EnvelopeReceiver> _repo;
|
|
|
|
private readonly IMapper _mapper;
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="envelopeReceiver"></param>
|
|
/// <param name="mapper"></param>
|
|
public ReadEnvelopeReceiverQueryHandler(IRepository<EnvelopeReceiver> envelopeReceiver, IMapper mapper)
|
|
{
|
|
_repo = envelopeReceiver;
|
|
_mapper = mapper;
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <param name="cancel"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="NotImplementedException"></exception>
|
|
public async Task<IEnumerable<EnvelopeReceiverDto>> Handle(ReadEnvelopeReceiverQuery request, CancellationToken cancel)
|
|
{
|
|
var q = _repo.Read();
|
|
|
|
if(request.Envelope is not null)
|
|
{
|
|
var env = request.Envelope;
|
|
if (env.Id is not null)
|
|
q = q.Where(er => er.EnvelopeId == env.Id);
|
|
|
|
if (env.Status is not null)
|
|
{
|
|
if(env.Status.Min is not null)
|
|
q = q.Where(er => er.Envelope.Status >= env.Status.Min);
|
|
|
|
if(env.Status.Max is not null)
|
|
q = q.Where(er => er.Envelope.Status <= env.Status.Max);
|
|
|
|
if(env.Status .Include?.Length > 0)
|
|
q = q.Where(er => env.Status.Include.Contains(er.Envelope.Status));
|
|
|
|
if(env.Status.Ignore is not null)
|
|
q = q.Where(er => !env.Status.Ignore.Contains(er.Envelope.Status));
|
|
}
|
|
|
|
if (env.Uuid is not null)
|
|
q = q.Where(er => er.Envelope.Uuid == env.Uuid);
|
|
}
|
|
|
|
if (request.Receiver is not null)
|
|
{
|
|
var rcv = request.Receiver;
|
|
if (rcv.Id is not null)
|
|
q = q.Where(r => r.ReceiverId == rcv.Id);
|
|
|
|
if (rcv.EmailAddress is not null)
|
|
q = q.Where(r => r.Receiver.EmailAddress == rcv.EmailAddress);
|
|
|
|
if (rcv.Signature is not null)
|
|
q = q.Where(er => er.Receiver.Signature == rcv.Signature);
|
|
}
|
|
|
|
var envRcvs = await q.Include(er => er.Envelope).ThenInclude(e => e.Documents).ThenInclude(d => d.Elements)
|
|
.Include(er => er.Envelope).ThenInclude(e => e.History)
|
|
.Include(er => er.Envelope).ThenInclude(e => e.User)
|
|
.Include(er => er.Receiver)
|
|
.ToListAsync(cancel);
|
|
|
|
return _mapper.Map<IEnumerable<EnvelopeReceiverDto>>(envRcvs);
|
|
}
|
|
}
|