| | |
| | | IRepository<TaskUserCollect> repTaskUserCollect |
| | | ) : |
| | | IRequestHandler<CollectTaskCommand, int>, |
| | | IRequestHandler<ClearTaskCollectCommand, int>, |
| | | IRequestHandler<SetTaskUserHireCommand, Guid>, |
| | | IRequestHandler<SetTaskUserArrangeCommand, Guid> |
| | | { |
| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 清空已停止的任务收藏 |
| | | /// </summary> |
| | | /// <param name="request"></param> |
| | | /// <param name="cancellationToken"></param> |
| | | /// <returns></returns> |
| | | public async Task<int> Handle(ClearTaskCollectCommand request, CancellationToken cancellationToken) |
| | | { |
| | | var logier = JwtUtils.GetCurrentLogier(); |
| | | var entities = await repTaskUserCollect.AsQueryable() |
| | | .Where(it => it.TaskInfo.ReleaseStatus == EnumTaskReleaseStatus.Stopped && it.UserId == logier.Id) |
| | | .ToListAsync(cancellationToken); |
| | | if (entities.IsNotNull()) |
| | | { |
| | | foreach (var entity in entities) |
| | | { |
| | | await repTaskUserCollect.DeleteAsync(entity); |
| | | } |
| | | } |
| | | return entities.Count; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 任务录用 |
| | | /// </summary> |
| | | /// <param name="request"></param> |
| | |
| | | it.TaskInfo.EnterpriseId == logier.EnterpriseId |
| | | && it.Id == request.Id) |
| | | .FirstOrDefaultAsync(cancellationToken); |
| | | if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "该报名信息"); |
| | | if (entity.HireStatus == EnumTaskUserHireStatus.Pass) throw Oops.Oh(EnumErrorCodeType.s510, "该灵工已录用"); |
| | | if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "报名信息"); |
| | | if (entity.HireStatus == EnumTaskUserHireStatus.Pass) throw Oops.Oh(EnumErrorCodeType.s510, "灵工已录用"); |
| | | entity.HireStatus = request.HireStatus; |
| | | if (entity.HireStatus == EnumTaskUserHireStatus.Pass) |
| | | { |
| | |
| | | it.TaskInfo.EnterpriseId == logier.EnterpriseId |
| | | && it.Id == request.Id) |
| | | .FirstOrDefaultAsync(cancellationToken); |
| | | if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "该报名信息"); |
| | | if (entity.ArrangeStatus == EnumTaskUserArrangeStatus.Complete) throw Oops.Oh(EnumErrorCodeType.s510, "该灵工已安排"); |
| | | if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "报名信息"); |
| | | if (entity.ArrangeStatus == EnumTaskUserArrangeStatus.Complete) throw Oops.Oh(EnumErrorCodeType.s510, "灵工已安排"); |
| | | entity.ArrangeStatus = request.ArrangeStatus; |
| | | if (entity.ArrangeStatus == EnumTaskUserArrangeStatus.Complete) |
| | | { |