using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Mapster;
|
using MediatR;
|
using Microsoft.EntityFrameworkCore;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.UserServer.Application
|
{
|
/// <summary>
|
/// 灵工查询处理器
|
/// </summary>
|
public class EnterpriseEmployeeQueryHandler(
|
IRepository<EnterpriseEmployee> rep
|
) :
|
IRequestHandler<GetEnterpriseEmployeesQuery, GetEnterpriseEmployeesQueryResult>,
|
IRequestHandler<GetEnterpriseEmployeeQuery, GetEnterpriseEmployeeQueryResult>
|
{
|
private readonly IRepository<EnterpriseEmployee> rep = rep;
|
|
/// <summary>
|
/// 查询灵工分页列表数据
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<GetEnterpriseEmployeesQueryResult> Handle(GetEnterpriseEmployeesQuery request, CancellationToken cancellationToken)
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
var q = rep.AsQueryable().AsNoTracking()
|
.OrderBy(it => it.CreatedTime)
|
.Where(it => it.EnterpriseId == logier.EnterpriseId);
|
if (request.Keywords.IsNotNull())
|
{
|
q = q.Where(it =>
|
it.Name.Contains(request.Keywords)
|
|| it.ContactPhoneNumber.Contains(request.Keywords)
|
|| it.Identity.Contains(request.Keywords));
|
}
|
if (request.CreatedTimeStart.HasValue && request.CreatedTimeEnd.HasValue)
|
{
|
q = q.Where(it =>
|
it.CreatedTime >= request.CreatedTimeStart.Value
|
&& it.CreatedTime <= request.CreatedTimeEnd.Value);
|
}
|
if (request.SignContractTimeStart.HasValue && request.SignContractTimeEnd.HasValue)
|
{
|
q = q.Where(it =>
|
it.UserSignContractTime >= request.SignContractTimeStart.Value
|
&& it.UserSignContractTime <= request.SignContractTimeEnd.Value
|
|| it.EnterpriseSignContractTime >= request.SignContractTimeStart.Value
|
&& it.EnterpriseSignContractTime <= request.SignContractTimeEnd.Value);
|
}
|
if (request.HireStatus.HasValue)
|
{
|
q = q.Where(it => it.TaskInfoUsers.Any(tu => tu.HireStatus == request.HireStatus));
|
}
|
if (request.IsReal.HasValue)
|
{
|
q = q.Where(it => (it.UserId.HasValue && it.User.IsReal) == request.IsReal.Value);
|
}
|
if (request.UserSignContractStatus.HasValue)
|
{
|
q = q.Where(it => it.UserSignContractStatus == request.UserSignContractStatus);
|
}
|
if (request.EnterpriseSignContractStatus.HasValue)
|
{
|
q = q.Where(it => it.EnterpriseSignContractStatus == request.EnterpriseSignContractStatus);
|
}
|
var s = q.Select(it => new GetEnterpriseEmployeesQueryResultItem
|
{
|
Id = it.Id,
|
Avatar = it.User.Avatar,
|
Name = it.Name,
|
Identity = it.Identity,
|
Gender = it.Gender,
|
Age = it.Age,
|
ContactPhoneNumber = it.ContactPhoneNumber,
|
UserIsReal = it.User.IsReal == true,
|
RealMethod = it.User.RealMethod,
|
PersonalIdentityCode = it.User.PersonalIdentityCode,
|
PersonalIdentityContent = it.User.PersonalIdentity.Content,
|
EducationalBackgroundCode = it.User.EducationalBackgroundCode,
|
EducationalBackgroundContent = it.User.EducationalBackground.Content,
|
TaskCount = it.User.EnterpriseEmployees.SelectMany(ee => ee.TaskInfoUsers).Count(tu => tu.HireStatus == EnumTaskUserHireStatus.Pass),
|
WorkSeniority = it.User.WorkSeniority,
|
WorkExperience = it.User.WorkExperience,
|
HireStatus = it.TaskInfoUsers.Any(tu => tu.HireStatus == EnumTaskUserHireStatus.Pass)
|
? EnumTaskUserHireStatus.Pass
|
: it.TaskInfoUsers.Any(tu => tu.HireStatus == EnumTaskUserHireStatus.Refuse)
|
? EnumTaskUserHireStatus.Refuse
|
: EnumTaskUserHireStatus.Wait,
|
UserSignContractStatus = it.UserSignContractStatus,
|
HireTime = it.TaskInfoUsers
|
.OrderBy(tu => tu.HireTime)
|
.Where(tu => tu.HireStatus == EnumTaskUserHireStatus.Pass && tu.HireTime.HasValue)
|
.Select(tu => tu.HireTime)
|
.FirstOrDefault(),
|
UserRealTime = it.User.RealTime,
|
UserSignContractTime = it.UserSignContractTime,
|
EnterpriseSignContractStatus = it.EnterpriseSignContractStatus,
|
EnterpriseSignContractTime = it.EnterpriseSignContractTime
|
});
|
return await request.PageModel.GetPagedListAsync<GetEnterpriseEmployeesQueryResult, GetEnterpriseEmployeesQueryResultItem>(s, cancellationToken);
|
}
|
|
/// <summary>
|
/// 查询灵工详情
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<GetEnterpriseEmployeeQueryResult> Handle(GetEnterpriseEmployeeQuery request, CancellationToken cancellationToken)
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
var model = await rep.AsQueryable().AsNoTracking()
|
.Where(it => it.Id == request.Id)
|
.GetDetail<EnterpriseEmployee, GetEnterpriseEmployeeQueryResult>(cancellationToken);
|
if (request.TaskInfoId.HasValue)
|
{
|
model.ApplyTime = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking()
|
.Where(it => it.TaskInfoId == request.TaskInfoId && it.EnterpriseEmployeeId == request.Id)
|
.Select(it => it.CreatedTime as DateTimeOffset?)
|
.FirstOrDefaultAsync(cancellationToken);
|
}
|
else if (logier.Type == EnumUserType.Enterprise)
|
{
|
model.ApplyTime = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking()
|
.OrderBy(it => it.CreatedTime)
|
.Where(it => it.TaskInfo.EnterpriseId == logier.EnterpriseId && it.EnterpriseEmployeeId == request.Id)
|
.Select(it => it.CreatedTime as DateTimeOffset?)
|
.FirstOrDefaultAsync(cancellationToken);
|
}
|
|
return model;
|
}
|
}
|
}
|
