using Aop.Api.Domain;
|
using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Furion.DistributedIDGenerator;
|
using Furion.FriendlyException;
|
using Mapster;
|
using MediatR;
|
using Microsoft.AspNetCore.Components.Forms;
|
using Microsoft.EntityFrameworkCore;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Security.Principal;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.UserServer.Application
|
{
|
/// <summary>
|
/// 灵工查询处理器
|
/// </summary>
|
public class EnterpriseEmployeeQueryHandler(
|
IRepository<EnterpriseEmployee> rep,
|
IRepository<ContractTemplate> repContractTemplate,
|
IRepository<EnterpriseEmployeeContract> repEnterpriseEmployeeContract,
|
IRepository<Enterprise> repEnterprise,
|
IRepository<User> repUser,
|
IMediator mediator
|
) :
|
IRequestHandler<GetEnterpriseEmployeesQuery, GetEnterpriseEmployeesQueryResult>,
|
IRequestHandler<GetEnterpriseEmployeeQuery, GetEnterpriseEmployeeQueryResult>,
|
IRequestHandler<GetPersonalUserElectronSignsQuery, GetPersonalUserElectronSignsQueryResult>,
|
IRequestHandler<GetPersonalUserElectronSignQuery, GetPersonalUserElectronSignQueryResult>
|
{
|
private readonly IRepository<EnterpriseEmployee> rep = rep;
|
private readonly IRepository<ContractTemplate> repContractTemplate = repContractTemplate;
|
private readonly IRepository<EnterpriseEmployeeContract> repEnterpriseEmployeeContract = repEnterpriseEmployeeContract;
|
private readonly IRepository<Enterprise> repEnterprise = repEnterprise;
|
private readonly IRepository<User> repUser = repUser;
|
private readonly IMediator mediator = mediator;
|
|
/// <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.SignContractStatus.HasValue)
|
{
|
switch (request.SignContractStatus.Value)
|
{
|
case EnumGetEnterpriseEmployeesQuerySignContractStatus.UserWait:
|
q = q.Where(it => it.UserSignContractStatus == null || it.UserSignContractStatus == EnumTaskUserSignContractStatus.Wait);
|
break;
|
case EnumGetEnterpriseEmployeesQuerySignContractStatus.EnterpriseWait:
|
q = q.Where(it => it.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Wait);
|
break;
|
case EnumGetEnterpriseEmployeesQuerySignContractStatus.Pass:
|
q = q.Where(it =>
|
it.UserSignContractStatus == EnumTaskUserSignContractStatus.Pass
|
&& it.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Pass);
|
break;
|
default:
|
break;
|
}
|
}
|
else
|
{
|
if (request.UserSignContractStatus.HasValue)
|
{
|
if (logier.ClientType == EnumClientType.Wxmp)
|
{
|
switch (request.UserSignContractStatus.Value)
|
{
|
case EnumTaskUserSignContractStatus.Wait:
|
q = q.Where(it => it.UserSignContractStatus == null || it.UserSignContractStatus == request.UserSignContractStatus);
|
break;
|
case EnumTaskUserSignContractStatus.Pass:
|
q = q.Where(it => it.UserSignContractStatus == request.UserSignContractStatus && it.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Pass);
|
break;
|
case EnumTaskUserSignContractStatus.Stop:
|
q = q.Where(it => it.UserSignContractStatus == request.UserSignContractStatus);
|
break;
|
default:
|
q = q.Where(it => it.UserSignContractStatus == request.UserSignContractStatus);
|
break;
|
}
|
}
|
else
|
{
|
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.HireTime.HasValue)
|
.Select(tu => tu.HireTime)
|
.FirstOrDefault(),
|
UserRealTime = it.User.RealTime,
|
UserSignContractTime = it.UserSignContractTime,
|
EnterpriseSignContractStatus = it.EnterpriseSignContractStatus,
|
EnterpriseSignContractTime = it.EnterpriseSignContractTime,
|
ContractUrl = it.ContractUrl,
|
});
|
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;
|
}
|
|
/// <summary>
|
/// 查询个人用户签约列表
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<GetPersonalUserElectronSignsQueryResult> Handle(GetPersonalUserElectronSignsQuery request, CancellationToken cancellationToken)
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
var q = rep.AsQueryable().AsNoTracking()
|
.Where(it => it.UserId == logier.Id);
|
if (request.UserSignContractStatus.HasValue)
|
{
|
if (request.UserSignContractStatus == EnumTaskUserSignContractStatus.Pass)
|
{
|
q = q.Where(it => it.UserSignContractStatus == EnumTaskUserSignContractStatus.Pass && it.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Pass);
|
}
|
else
|
{
|
q = q.Where(it => it.UserSignContractStatus == request.UserSignContractStatus.Value);
|
}
|
}
|
else
|
{
|
q = q.Where(it =>
|
it.UserSignContractStatus == EnumTaskUserSignContractStatus.Wait
|
|| it.UserSignContractStatus == EnumTaskUserSignContractStatus.Pass && it.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Pass
|
|| it.UserSignContractStatus == EnumTaskUserSignContractStatus.Stop);
|
}
|
var s = q.Select(it => new GetPersonalUserElectronSignsQueryResultItem
|
{
|
Id = it.Id,
|
EnterpriseName = it.Enterprise.EnterpriseName,
|
UserSignContractStatus = it.UserSignContractStatus,
|
});
|
return await request.PageModel.GetPagedListAsync<GetPersonalUserElectronSignsQueryResult, GetPersonalUserElectronSignsQueryResultItem>(s, cancellationToken);
|
}
|
|
/// <summary>
|
/// 查询个人用户签约详情
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<GetPersonalUserElectronSignQueryResult> Handle(GetPersonalUserElectronSignQuery request, CancellationToken cancellationToken)
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
if (request.Id.HasValue)
|
{
|
var model = await rep.AsQueryable().AsNoTracking()
|
.Where(it => it.UserId == logier.Id && it.Id == request.Id)
|
.GetDetail<EnterpriseEmployee, GetPersonalUserElectronSignQueryResult>();
|
return model;
|
}
|
else if (request.Code.IsNotNull())
|
{
|
var contractTemplate = await repContractTemplate.AsQueryable().AsNoTracking()
|
.Where(it => it.Code == request.Code)
|
.FirstOrDefaultAsync();
|
if (contractTemplate == null) throw Oops.Oh(EnumErrorCodeType.s404, "合同");
|
|
await mediator.Send(new CheckContractTemplateCommand
|
{
|
Id = contractTemplate.Id
|
}, cancellationToken);
|
|
var entity = await rep.AsQueryable()
|
.Where(it =>
|
it.UserId == logier.Id
|
&& it.ContractTemplateId == contractTemplate.Id)
|
.FirstOrDefaultAsync();
|
var enterprise = await repEnterprise.AsQueryable()
|
.Where(it => it.Id == contractTemplate.EnterpriseId)
|
.Select(it => new
|
{
|
it.EnterpriseName
|
})
|
.FirstOrDefaultAsync();
|
if (enterprise == null) throw Oops.Oh(EnumErrorCodeType.s404, "企业");
|
var add = false;
|
if (entity == null)
|
{
|
var user = await repUser.AsQueryable().AsNoTracking()
|
.Include(it => it.UserAuth)
|
.Where(it => it.Id == logier.Id)
|
.Select(it => new
|
{
|
it.Name,
|
it.Identity,
|
it.ContactPhoneNumber,
|
it.Gender,
|
it.Age,
|
it.UserAuth.IdentityImg,
|
it.UserAuth.IdentityBackImg
|
})
|
.FirstOrDefaultAsync(cancellationToken);
|
if (user == null) throw Oops.Oh(EnumErrorCodeType.s404, "账号");
|
entity = new EnterpriseEmployee
|
{
|
Id = IDGen.NextID(),
|
EnterpriseId = contractTemplate.EnterpriseId,
|
UserId = logier.Id,
|
Name = user.Name,
|
Identity = user.Identity,
|
ContactPhoneNumber = user.ContactPhoneNumber,
|
Gender = user.Gender,
|
Age = user.Age,
|
IdentityImg = user.IdentityImg,
|
IdentityBackImg = user.IdentityBackImg,
|
};
|
add = true;
|
}
|
if (entity.UserSignContractStatus == null)
|
{
|
entity.ContractTemplateId = contractTemplate.Id;
|
entity.UserSignContractStatus = EnumTaskUserSignContractStatus.Wait;
|
entity.UserSignContractTime = null;
|
entity.EnterpriseSignContractStatus = null;
|
entity.EnterpriseSignContractTime = null;
|
entity.ContractCode = $"{DateTime.Now:yyyyMMddHHmmss}{new Random(IDGen.NextID().GetHashCode()).Next(1000, 9999)}";
|
entity.ContractUrl = null;
|
var contract = new EnterpriseEmployeeContract
|
{
|
EnterpriseEmployeeId = entity.Id,
|
ContractTemplateId = entity.ContractTemplateId,
|
ContractCode = entity.ContractCode,
|
UserSignContractStatus = entity.UserSignContractStatus,
|
};
|
await repEnterpriseEmployeeContract.InsertAsync(contract);
|
}
|
if (add)
|
{
|
await rep.InsertAsync(entity);
|
}
|
else
|
{
|
await rep.UpdateAsync(entity);
|
}
|
return new GetPersonalUserElectronSignQueryResult
|
{
|
Id = entity.Id,
|
ContractCode = entity.ContractCode,
|
ContractTemplateAccess = contractTemplate.Access,
|
UserSignContractStatus = entity.UserSignContractStatus,
|
Name = entity.Name,
|
Identity = entity.Identity,
|
ContactPhoneNumber = entity.ContactPhoneNumber,
|
UserSignContractTime = entity.UserSignContractTime,
|
EnterpriseEnterpriseName = enterprise.EnterpriseName,
|
EnterpriseSignContractTime = entity.EnterpriseSignContractTime,
|
ContractUrl = entity.ContractUrl,
|
};
|
}
|
else
|
{
|
throw Oops.Oh(EnumErrorCodeType.s400, "请填写灵工Id或合同模板编号");
|
}
|
}
|
}
|
}
|
