From 1b07d3f0191424cbf06dad186f5eb622ac9144e0 Mon Sep 17 00:00:00 2001 From: sunpengfei <i@angelzzz.com> Date: 星期四, 14 八月 2025 10:51:37 +0800 Subject: [PATCH] feat:开发 --- FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs | 69 +++++++++++++++++++++++++++------- 1 files changed, 55 insertions(+), 14 deletions(-) diff --git a/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs b/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs index 92d1f94..0ad41a4 100644 --- a/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs +++ b/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs @@ -16,7 +16,8 @@ /// 鐢ㄦ埛绠�鍘嗘煡璇㈠鐞嗗櫒 /// </summary> public class UserResumeQueryHandler( - IRepository<User> rep + IRepository<User> rep, + IRepository<TaskInfoUser> repTaskInfoUser ) : IRequestHandler<GetUserResumesQuery, GetUserResumesQueryResult>, IRequestHandler<GetUserResumeQuery, GetUserResumeQueryResult>, @@ -28,6 +29,7 @@ IRequestHandler<GetUserResumeDetailQuery, GetUserResumeDetailQueryResult> { private readonly IRepository<User> rep = rep; + private readonly IRepository<TaskInfoUser> repTaskInfoUser = repTaskInfoUser; /// <summary> /// 鏌ヨ绠�鍘嗗垎椤靛垪琛ㄦ暟鎹� @@ -115,20 +117,59 @@ { request.UserId = logier.Id; } - if (request.UserId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇烽�夋嫨鐢ㄦ埛"); - var model = await rep.AsQueryable().AsNoTracking() - .Where(it => it.Id == request.UserId) - .GetDetail<User, GetUserResumeQueryResult>(cancellationToken); - model.TaskInfoUsers = model.TaskInfoUsers.Where(it => it.SignContractTime.HasValue).ToList(); - model.TaskCount = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking() - .Where(it => it.EnterpriseEmployee.UserId == model.Id && it.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Pass) - .CountAsync(); - if (logier.Type == EnumUserType.Enterprise) + EnterpriseEmployee? enterpriseEmployee = null; + if (logier.Type == EnumUserType.Enterprise && request.UserId == null && request.EnterpriseEmployeeId.HasValue) { - model.IsCollected = await rep.Change<EnterpriseUserCollect>().AsQueryable().AsNoTracking() - .Where(it => it.EnterpriseId == logier.EnterpriseId && it.UserId == model.Id) - .Select(it => it.IsCollected) - .FirstOrDefaultAsync(); + enterpriseEmployee = await rep.Change<EnterpriseEmployee>().AsQueryable().AsNoTracking() + .Where(it => it.EnterpriseId == logier.EnterpriseId && it.Id == request.EnterpriseEmployeeId) + .FirstOrDefaultAsync(cancellationToken); + if (enterpriseEmployee == null) throw Oops.Oh(EnumErrorCodeType.s404, "璇ョ伒宸�"); + request.UserId = enterpriseEmployee.UserId; + } + else if (request.UserId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇烽�夋嫨鐢ㄦ埛"); + + GetUserResumeQueryResult? model = null; + if (request.UserId.HasValue) + { + model = await rep.AsQueryable().AsNoTracking() + .Where(it => it.Id == request.UserId) + .GetDetail<User, GetUserResumeQueryResult>(cancellationToken); + } + else if (enterpriseEmployee != null) + { + model = new GetUserResumeQueryResult + { + Name = enterpriseEmployee.Name, + ContactPhoneNumber = enterpriseEmployee.ContactPhoneNumber, + Identity = enterpriseEmployee.Identity, + Gender = enterpriseEmployee.Gender, + Age = enterpriseEmployee.Age, + }; + } + if (model == null) throw Oops.Oh(EnumErrorCodeType.s404, "璇ヤ俊鎭�"); + + model.TaskInfoUsers = model.TaskInfoUsers.Where(it => it.SignContractTime.HasValue).ToList(); + if (model.Id.HasValue) + { + model.TaskInfoUsers = repTaskInfoUser.AsQueryable().AsNoTracking() + .Where(it => it.EnterpriseEmployee.UserId == model.Id && it.EnterpriseEmployee.EnterpriseSignContractTime.HasValue) + .Select(it => new GetUserResumeQueryResultExperience + { + SignContractTime = it.EnterpriseEmployee.EnterpriseSignContractTime, + EnterpriseName = it.TaskInfo.Enterprise.EnterpriseName, + Name = it.TaskInfo.Name + }) + .ToList(); + model.TaskCount = await repTaskInfoUser.AsQueryable().AsNoTracking() + .Where(it => it.EnterpriseEmployee.UserId == model.Id && it.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Pass) + .CountAsync(); + if (logier.Type == EnumUserType.Enterprise) + { + model.IsCollected = await rep.Change<EnterpriseUserCollect>().AsQueryable().AsNoTracking() + .Where(it => it.EnterpriseId == logier.EnterpriseId && it.UserId == model.Id) + .Select(it => it.IsCollected) + .FirstOrDefaultAsync(); + } } if (model.CityCode.IsNotNull()) { -- Gitblit v1.9.1