| | |
| | | IRepository<TaskInfoUserSubmit> repTaskInfoUserSubmit |
| | | ) : |
| | | IRequestHandler<SubmitCheckReceiveTaskCommand, Guid>, |
| | | IRequestHandler<CheckReceiveTaskCommand, Guid> |
| | | IRequestHandler<CheckReceiveTaskCommand, Guid>, |
| | | IRequestHandler<ExportTaskCheckReceiveTaskUsersCommand, string> |
| | | { |
| | | private readonly IRepository<TaskInfo> repTaskInfo = repTaskInfo; |
| | | private readonly IRepository<TaskInfoUser> repTaskInfoUser = repTaskInfoUser; |
| | |
| | | await repTaskInfoUserSubmit.UpdateAsync(submit); |
| | | return submit.Id; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 导出验收记录 |
| | | /// </summary> |
| | | /// <param name="request"></param> |
| | | /// <param name="cancellationToken"></param> |
| | | /// <returns></returns> |
| | | public async Task<string> Handle(ExportTaskCheckReceiveTaskUsersCommand request, CancellationToken cancellationToken) |
| | | { |
| | | var models = await repTaskInfoUserSubmit.AsQueryable().AsNoTracking() |
| | | .Where(it => it.TaskInfoUser.TaskInfoId == request.Id) |
| | | .Select(it => new ExportTaskCheckReceiveTaskUsersCommandModel |
| | | { |
| | | Name = it.TaskInfoUser.EnterpriseEmployee.User.Name, |
| | | Identity = it.TaskInfoUser.EnterpriseEmployee.User.Identity, |
| | | ContactPhoneNumber = it.TaskInfoUser.EnterpriseEmployee.User.ContactPhoneNumber, |
| | | CheckReceiveStatus = it.CheckReceiveStatus, |
| | | CheckReceiveTime = it.CheckReceiveTime, |
| | | Bank = "123", |
| | | Code = "456" |
| | | }) |
| | | .ToListAsync(cancellationToken); |
| | | var url = await models.ExportExcelToOSS("TaskCheckReceive/Export", "验收记录.xlsx"); |
| | | url = AliyunOSSUtils.GetUrl(url); |
| | | return url; |
| | | } |
| | | } |
| | | } |