using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using MediatR;
|
using Microsoft.EntityFrameworkCore;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.CommonServer.Application
|
{
|
/// <summary>
|
/// 查询编号地址
|
/// </summary>
|
/// <param name="rep"></param>
|
public class CodeUrlQueryHandler(
|
IRepository<CodeUrl> rep
|
) :
|
IRequestHandler<GetCodeUrlQuery, string?>
|
{
|
private readonly IRepository<CodeUrl> rep = rep;
|
|
/// <summary>
|
/// 查询编号地址
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<string?> Handle(GetCodeUrlQuery request, CancellationToken cancellationToken)
|
{
|
var now = DateTime.Now;
|
return await rep.AsQueryable().AsNoTracking()
|
.Where(it =>
|
it.Scene == request.Scene
|
&& it.Code == request.Code
|
&& (it.ExpiredTime == null
|
|| it.ExpiredTime > now))
|
.Select(it => it.Url)
|
.FirstOrDefaultAsync();
|
}
|
}
|
}
|
