| | |
|---|
| | | /// <param name="taskId"></param> |
|---|
| | | /// <param name="newStatus"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public async Task<WebResponseContent> UpdateTaskByStatusAsync(int taskId, int newStatus) |
|---|
| | | public async Task<WebResponseContent> UpdateTaskByStatusAsync(UpdateTaskDto taskDto) |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | var tasks = await BaseDal.QueryFirstAsync(s => s.TaskNum == taskId); |
|---|
| | | if (tasks == null) |
|---|
| | | var taskInfo = await BaseDal.QueryFirstAsync(s => s.TaskNum == taskDto.Id); |
|---|
| | | if (taskInfo == null) |
|---|
| | | return WebResponseContent.Instance.Error("未找到对应的任务"); |
|---|
| | | |
|---|
| | | tasks.TaskStatus = newStatus; |
|---|
| | | await BaseDal.UpdateDataAsync(tasks); |
|---|
| | | taskInfo.TaskStatus = taskDto.NewStatus; |
|---|
| | | taskInfo.NextAddress = taskDto.NextAddress; |
|---|
| | | taskInfo.CurrentAddress = taskDto.CurrentAddress; |
|---|
| | | await BaseDal.UpdateDataAsync(taskInfo); |
|---|
| | | |
|---|
| | | return WebResponseContent.Instance.OK("修改成功", tasks); |
|---|
| | | return WebResponseContent.Instance.OK("修改成功", taskInfo); |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
| | | { |
|---|
| | |
|---|
| | | } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | await _unitOfWorkManage.BeginTranAsync(async () => |
|---|
| | | return await _unitOfWorkManage.BeginTranAsync(async () => |
|---|
| | | { |
|---|
| | | // 4. 保存到数据库 |
|---|
| | | var result = await BaseDal.AddDataAsync(task) > 0; |
|---|
