From fed0f0b4f2abeca2ee641ee3f95416f68a06fe09 Mon Sep 17 00:00:00 2001 From: sunpengfei <i@angelzzz.com> Date: 星期三, 13 八月 2025 19:06:44 +0800 Subject: [PATCH] feat:开发 --- FlexJobApi.FlexJobServer.Application/TaskUsers/Commands/TaskUserCommandHandler.cs | 12 ++++++------ 1 files changed, 6 insertions(+), 6 deletions(-) diff --git a/FlexJobApi.FlexJobServer.Application/TaskUsers/Commands/TaskUserCommandHandler.cs b/FlexJobApi.FlexJobServer.Application/TaskUsers/Commands/TaskUserCommandHandler.cs index ad9edce..76760be 100644 --- a/FlexJobApi.FlexJobServer.Application/TaskUsers/Commands/TaskUserCommandHandler.cs +++ b/FlexJobApi.FlexJobServer.Application/TaskUsers/Commands/TaskUserCommandHandler.cs @@ -16,14 +16,14 @@ /// </summary> public class TaskUserCommandHandler( IRepository<TaskInfoUser> rep, - IRepository<UserTaskCollect> repUserTaskCollect + IRepository<TaskUserCollect> repTaskUserCollect ) : IRequestHandler<CollectTaskCommand, int>, IRequestHandler<SetTaskUserHireCommand, Guid>, IRequestHandler<SetTaskUserArrangeCommand, Guid> { private readonly IRepository<TaskInfoUser> rep = rep; - private readonly IRepository<UserTaskCollect> repUserTaskCollect = repUserTaskCollect; + private readonly IRepository<TaskUserCollect> repTaskUserCollect = repTaskUserCollect; /// <summary> /// 鏀惰棌浠诲姟 @@ -34,7 +34,7 @@ public async Task<int> Handle(CollectTaskCommand request, CancellationToken cancellationToken) { var logier = JwtUtils.GetCurrentLogier(); - var collects = await repUserTaskCollect.AsQueryable().AsNoTracking() + var collects = await repTaskUserCollect.AsQueryable().AsNoTracking() .Where(it => request.Ids.Contains(it.TaskInfoId) && it.UserId == logier.Id) .ToListAsync(cancellationToken); if (request.IsCollect) @@ -42,18 +42,18 @@ var addIds = request.Ids.Where(it => !collects.Any(c => c.TaskInfoId == it)).ToList(); foreach (var addId in addIds) { - var entity = new UserTaskCollect + var entity = new TaskUserCollect { TaskInfoId = addId, UserId = logier.Id }; - await repUserTaskCollect.InsertAsync(entity); + await repTaskUserCollect.InsertAsync(entity); } return addIds.Count; } else { - await repUserTaskCollect.DeleteAsync(collects); + await repTaskUserCollect.DeleteAsync(collects); return collects.Count; } } -- Gitblit v1.9.1