From b495fa9f03462cf6007e1e035a7ed8abe5382c1c Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期四, 14 八月 2025 13:59:36 +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 463b2d6..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.EnterpriseEmployees.Sum(ee => ee.TaskInfoUsers.Count(tu => tu.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Pass)),
+                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