feat:开发

sunpengfei

2025-08-13 fc35150cfe2401b93fa9f4d536b5e151b904bdf7

 FlexJobApi.FlexJobServer.Application/Tasks/Queries/TaskInfoQueryHandler.cs

@@ -20,6 +20,7 @@
            IRepository<DictionaryData> repDictionaryData
        ) :
        IRequestHandler<GetTaskInfoQuery, GetTaskInfoQueryResult>,
        IRequestHandler<GetOpenTaskInfosQuery, GetTaskInfosQueryResult>,
        IRequestHandler<GetTaskInfosQuery, GetTaskInfosQueryResult>,
        IRequestHandler<GetPersonalApplyTaskInfosQuery, GetPersonalApplyTaskInfosQueryResult>,
        IRequestHandler<GetPersonalHireTaskInfosQuery, GetPersonalHireTaskInfosQueryResult>,
@@ -73,17 +74,28 @@
                    if (model.HireButton == GetTaskInfoQueryResultHireButton.InProcess && model.BeginTime <= now)
                    {
                        var submit = await rep.Change<TaskInfoUserSubmit>().AsQueryable().AsNoTracking()
                            .AnyAsync(it => it.TaskInfoUserId == taskUser.Id && it.CheckReceiveStatus >= EnumTaskUserSubmitCheckReceiveStatus.Wait);
                            .AnyAsync(it => it.TaskInfoUserId == taskUser.Id && it.CheckReceiveStatus >= EnumTaskUserSubmitCheckReceiveStatus.WaitCheckReceive);
                        if (!submit)
                        {
                            model.HireButton = GetTaskInfoQueryResultHireButton.ApplyCheckReceive;
                        }
                    }
                }
                model.IsCollected = await rep.Change<UserTaskCollect>().AsQueryable().AsNoTracking()
                model.IsCollected = await rep.Change<TaskUserCollect>().AsQueryable().AsNoTracking()
                    .AnyAsync(it => it.TaskInfoId == request.Id && it.UserId == logier.Id);
            }
            return model;
        }

        /// <summary>
        /// 查询开放任务分页列表
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<GetTaskInfosQueryResult> Handle(GetOpenTaskInfosQuery request, CancellationToken cancellationToken)
        {
            return Handle(request.Adapt<GetTaskInfosQuery>(), cancellationToken);
        }

        /// <summary>
@@ -106,7 +118,7 @@
            }
            if (request.BeginTime.HasValue && request.EndTime.HasValue)
            {
                q = q.Where(it => request.BeginTime <= it.BeginTime && it.BeginTime <= request.EndTime);
                q = q.Where(it => request.BeginTime <= it.CreatedTime && it.CreatedTime <= request.EndTime);
            }
            if (request.CityCode.IsNotNull())
            {
@@ -338,5 +350,6 @@
            });
            return await request.PageModel.GetPagedListAsync<GetPersonalCancelTaskInfosQueryResult, GetPersonalCancelTaskInfosQueryResultItem>(s, cancellationToken);
        }

    }
}