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 | 76 +++++++++++++++++++++++++++++++++---- 1 files changed, 67 insertions(+), 9 deletions(-) diff --git a/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs b/FlexJobApi.UserServer.Application/UserResumes/Queries/UserResumeQueryHandler.cs index f4eae59..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> /// 鏌ヨ绠�鍘嗗垎椤靛垪琛ㄦ暟鎹� @@ -73,6 +75,14 @@ it.UserCredentials.Any(c => request.UserCredentials.Contains(c.TypeCode))); } + if (logier.Type == EnumUserType.Enterprise && request.IsCollected == true) + { + q = q.Where(it => it.EnterpriseUserCollects.Any(c => c.EnterpriseId == logier.EnterpriseId && c.IsCollected)); + } + if (logier.Type == EnumUserType.Enterprise && request.IsContacted == true) + { + q = q.Where(it => it.EnterpriseUserCollects.Any(c => c.EnterpriseId == logier.EnterpriseId && c.IsContacted)); + } var s = q.Select(it => new GetUserResumesQueryResultItem { Id = it.Id, @@ -85,9 +95,10 @@ PersonalIdentityContent = it.PersonalIdentity.Content, EducationalBackgroundCode = it.EducationalBackgroundCode, EducationalBackgroundContent = it.EducationalBackground.Content, - TaskCount = it.User.EnterpriseEmployees.Where(ee => ee.HireStatus == EnumTaskUserHireStatus.Pass).Sum(ee => ee.TaskInfoUsers.Count()), + TaskCount = it.EnterpriseEmployees.Where(ee => ee.HireStatus == EnumTaskUserHireStatus.Pass).Sum(ee => ee.TaskInfoUsers.Count()), WorkSeniority = it.WorkSeniority, WorkExperience = it.WorkExperience, + CreatedTime = it.CreatedTime, }); var result = await request.PageModel.GetPagedListAsync<GetUserResumesQueryResult, GetUserResumesQueryResultItem>(s, cancellationToken); return result; @@ -106,14 +117,60 @@ { 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); + EnterpriseEmployee? enterpriseEmployee = null; + if (logier.Type == EnumUserType.Enterprise && request.UserId == null && request.EnterpriseEmployeeId.HasValue) + { + 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(); - model.TaskCount = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking() - .Where(it => it.EnterpriseEmployee.UserId == model.Id && it.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Pass) - .CountAsync(); + 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()) { model.CompleteRate += 20; @@ -134,6 +191,7 @@ { model.CompleteRate += 20; } + return model; } -- Gitblit v1.9.1