From 539296a625cdd347161ce4f44b35bf85abafbc50 Mon Sep 17 00:00:00 2001 From: sunpengfei <i@angelzzz.com> Date: 星期一, 11 八月 2025 10:59:30 +0800 Subject: [PATCH] feat:开发 --- FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs | 134 +++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 129 insertions(+), 5 deletions(-) diff --git a/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs b/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs index 4eaf42e..20c861c 100644 --- a/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs +++ b/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs @@ -1,6 +1,9 @@ 锘縰sing FlexJobApi.Core; using Furion.DatabaseAccessor; +using Furion.FriendlyException; +using Mapster; using MediatR; +using Microsoft.EntityFrameworkCore; using System; using System.Collections.Generic; using System.Linq; @@ -13,15 +16,136 @@ /// 鐢ㄦ埛绠�鍘嗘煡璇㈠鐞嗗櫒 /// </summary> public class UserResumeQueryHandler( - IRepository<UserResume> rep + IRepository<User> rep ) : - IRequestHandler<GetUserResumeQuery, GetUserResumeQueryResult> + IRequestHandler<GetUserResumeQuery, GetUserResumeQueryResult>, + IRequestHandler<GetUserResumePersonalQuery, GetUserResumePersonalQueryResult>, + IRequestHandler<GetUserResumeJobSeekingQuery, GetUserResumeJobSeekingQueryResult>, + IRequestHandler<GetUserResumeCredentialsQuery, List<GetUserResumeCredentialsQueryResultItem>>, + IRequestHandler<GetUserResumeCredentialQuery, GetUserResumeCredentialQueryResult>, + IRequestHandler<GetUserResumeWorkExperienceQuery, GetUserResumeWorkExperienceQueryResult>, + IRequestHandler<GetUserResumeDetailQuery, GetUserResumeDetailQueryResult> { - private readonly IRepository<UserResume> rep = rep; + private readonly IRepository<User> rep = rep; - public Task<GetUserResumeQueryResult> Handle(GetUserResumeQuery request, CancellationToken cancellationToken) + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘� + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public async Task<GetUserResumeQueryResult> Handle(GetUserResumeQuery request, CancellationToken cancellationToken) { - throw new NotImplementedException(); + var logier = JwtUtils.GetCurrentLogier(); + if (logier.Type == EnumUserType.Personal) + { + request.UserId = logier.Id; + } + if (request.UserId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇烽�夋嫨鐢ㄦ埛"); + var model = await request.UserId.Value + .GetDetail<User, GetUserResumeQueryResult>(cancellationToken); + model.TaskCount = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking() + .Where(it => it.UserId == model.Id && it.HireStatus == EnumTaskUserHireStatus.Pass) + .CountAsync(); + if (model.CityCode.IsNotNull()) + { + model.CompleteRate += 20; + } + if (model.JobSeekingStatus.HasValue) + { + model.CompleteRate += 20; + } + if (model.UserCredentials.IsNotNull()) + { + model.CompleteRate += 20; + } + if (model.WorkExperience.IsNotNull() || model.WorkSeniority.IsNotNull()) + { + model.CompleteRate += 20; + } + if (model.Weight.HasValue || model.Height.HasValue || model.Photos.IsNotNull()) + { + model.CompleteRate += 20; + } + return model; } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-涓汉淇℃伅 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public Task<GetUserResumePersonalQueryResult> Handle(GetUserResumePersonalQuery request, CancellationToken cancellationToken) + { + return rep.GetPersonalQueryable(false) + .GetDetail<User, GetUserResumePersonalQueryResult>(cancellationToken); + } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-姹傝亴鎰忓悜 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public Task<GetUserResumeJobSeekingQueryResult> Handle(GetUserResumeJobSeekingQuery request, CancellationToken cancellationToken) + { + return rep.GetPersonalQueryable(false) + .GetDetail<User, GetUserResumeJobSeekingQueryResult>(cancellationToken); + } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-璧勬牸璇佷功鍒楄〃 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public async Task<List<GetUserResumeCredentialsQueryResultItem>> Handle(GetUserResumeCredentialsQuery request, CancellationToken cancellationToken) + { + return await rep.GetPersonalQueryable(false) + .SelectMany(it => it.UserCredentials) + .OrderBy(it => it.CreatedTime) + .ProjectToType<GetUserResumeCredentialsQueryResultItem>() + .ToListAsync(cancellationToken); + } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-璧勬牸璇佷功 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public Task<GetUserResumeCredentialQueryResult> Handle(GetUserResumeCredentialQuery request, CancellationToken cancellationToken) + { + return rep.GetPersonalQueryable(false) + .SelectMany(it => it.UserCredentials) + .Where(it => it.Id == request.Id) + .GetDetail<UserCredential, GetUserResumeCredentialQueryResult>(cancellationToken); + } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-宸ヤ綔缁忛獙 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public Task<GetUserResumeWorkExperienceQueryResult> Handle(GetUserResumeWorkExperienceQuery request, CancellationToken cancellationToken) + { + return rep.GetPersonalQueryable(false) + .GetDetail<User, GetUserResumeWorkExperienceQueryResult>(cancellationToken); + } + + /// <summary> + /// 鏌ヨ鐢ㄦ埛绠�鍘�-璇︾粏淇℃伅 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public Task<GetUserResumeDetailQueryResult> Handle(GetUserResumeDetailQuery request, CancellationToken cancellationToken) + { + return rep.GetPersonalQueryable(false) + .GetDetail<User, GetUserResumeDetailQueryResult>(cancellationToken); + } + } } -- Gitblit v1.9.1