From ba6a9c246898ecf04f40c827db27a1729f1b0f87 Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期四, 14 八月 2025 11:27:24 +0800
Subject: [PATCH] feat:开发

---
 FlexJobApi.FlexJobServer.Application/TaskUsers/Queries/TaskUserQueryHandler.cs |   61 +++++++++++++++---------------
 1 files changed, 30 insertions(+), 31 deletions(-)

diff --git a/FlexJobApi.FlexJobServer.Application/TaskUsers/Queries/TaskUserQueryHandler.cs b/FlexJobApi.FlexJobServer.Application/TaskUsers/Queries/TaskUserQueryHandler.cs
index ad8c7e6..bb14f0f 100644
--- a/FlexJobApi.FlexJobServer.Application/TaskUsers/Queries/TaskUserQueryHandler.cs
+++ b/FlexJobApi.FlexJobServer.Application/TaskUsers/Queries/TaskUserQueryHandler.cs
@@ -1,5 +1,6 @@
 锘縰sing FlexJobApi.Core;
 using Furion.DatabaseAccessor;
+using Furion.FriendlyException;
 using MediatR;
 using Microsoft.EntityFrameworkCore;
 using System;
@@ -17,7 +18,7 @@
         IRepository<TaskInfoUser> rep) :
         IRequestHandler<GetTaskUsersQuery, GetTaskUsersQueryResult>,
         IRequestHandler<GetArrangeTaskUsersQuery, GetArrangeTaskUsersQueryResult>,
-        IRequestHandler<GetCheckReceiveTaskUserInfosQuery, GetCheckReceiveTaskUserInfosQueryResult>
+        IRequestHandler<GetTaskUserHireStatusQuery, GetTaskUserHireStatusQueryResult>
     {
         private readonly IRepository<TaskInfoUser> rep = rep;
 
@@ -33,10 +34,22 @@
             var q = rep.AsQueryable().AsNoTracking()
                 .OrderBy(it => it.CreatedTime)
                 .Where(it => it.TaskInfo.EnterpriseId == logier.EnterpriseId && it.TaskInfoId == request.Id);
+            if (request.Keywords.IsNotNull())
+            {
+                q = q.Where(it =>
+                    it.EnterpriseEmployee.User.Name.Contains(request.Keywords)
+                    || it.EnterpriseEmployee.User.Identity.Contains(request.Keywords)
+                    || it.EnterpriseEmployee.User.PhoneNumber.Contains(request.Keywords));
+            }
+            if (request.HireStatus.HasValue)
+            {
+                q = q.Where(it => it.EnterpriseEmployee.HireStatus == request.HireStatus);
+            }
             var s = q
                 .Select(it => new GetTaskUsersQueryResultItem
                 {
                     Id = it.Id,
+                    EnterpriseEmployeeId = it.EnterpriseEmployeeId,
                     Avatar = it.EnterpriseEmployee.User.Avatar,
                     Name = it.EnterpriseEmployee.User.Name,
                     Identity = it.EnterpriseEmployee.User.Identity,
@@ -110,50 +123,36 @@
         }
 
         /// <summary>
-        /// 鏌ヨ楠屾敹鍒嗛〉鍒楄〃
+        /// 鏌ヨ搴旇仒鎶ュ悕浜哄憳褰曠敤鐘舵��
         /// </summary>
         /// <param name="request"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public async Task<GetCheckReceiveTaskUserInfosQueryResult> Handle(GetCheckReceiveTaskUserInfosQuery request, CancellationToken cancellationToken)
+        public async Task<GetTaskUserHireStatusQueryResult> Handle(GetTaskUserHireStatusQuery request, CancellationToken cancellationToken)
         {
             var logier = JwtUtils.GetCurrentLogier();
             var q = rep.AsQueryable().AsNoTracking()
-                .OrderBy(it => it.CreatedTime)
-                .AsQueryable();
-
+                .Where(it => it.TaskInfoId == request.TaskInfoId);
             if (logier.Type == EnumUserType.Personal)
             {
-                q = q.Where(it => it.EnterpriseEmployee.UserId == logier.Id);
+                q = q.Where(it => it.EnterpriseEmployee.UserId == request.UserId);
             }
-            else if (logier.Type == EnumUserType.Enterprise)
+            else if (request.UserId == null)
             {
-                q = q.Where(it => it.TaskInfo.EnterpriseId == logier.EnterpriseId);
+                throw Oops.Oh(EnumErrorCodeType.s400, "璇烽�夋嫨鐢ㄦ埛");
             }
-            if (request.TaskInfoId.HasValue)
+            else
             {
-                q = q.Where(it => it.TaskInfoId == request.TaskInfoId);
+                q = q.Where(it => it.EnterpriseEmployee.UserId == request.UserId);
             }
-            if (request.Keywords.IsNotNull())
-            {
-                q = q.Where(it =>
-                    it.EnterpriseEmployee.User.Name.Contains(request.Keywords)
-                    || it.EnterpriseEmployee.User.ContactPhoneNumber.Contains(request.Keywords)
-                    || it.EnterpriseEmployee.User.Identity.Contains(request.Keywords));
-            }
-            if (request.SubmitTimeBegin.HasValue && request.SubmitTimeEnd.HasValue)
-            {
-                q = q.Where(it => it.Submits.Any(s => request.SubmitTimeBegin <= s.CreatedTime && s.CreatedTime <= request.SubmitTimeEnd));
-            }
-            if (request.CheckReceiveStatus.HasValue)
-            {
-                q = q.Where(it => it.CheckReceiveStatus == request.CheckReceiveStatus);
-            }
-            var s = q.Select(it => new GetCheckReceiveTaskUserInfosQueryResultItem
-            {
-
-            });
-            return await request.PageModel.GetPagedListAsync<GetCheckReceiveTaskUserInfosQueryResult, GetCheckReceiveTaskUserInfosQueryResultItem>(s, cancellationToken);
+                var model = await q
+                    .Select(it => new GetTaskUserHireStatusQueryResult
+                    {
+                        HireStatus = it.EnterpriseEmployee.HireStatus
+                    })
+                    .FirstOrDefaultAsync(cancellationToken);
+            if (model == null) throw Oops.Oh(EnumErrorCodeType.s404, "璇ユ姤鍚嶄俊鎭�");
+            return model;
         }
     }
 }

--
Gitblit v1.9.1