|
@@ -77,25 +77,14 @@ namespace GxPress.Service.Implement
|
|
|
return (GetFlowName(user, process), new List<string>());
|
|
|
}
|
|
|
|
|
|
- public async Task<FlowResult> GetFlowResult(int todoId, int userId = 0)
|
|
|
+ public async Task<FlowResult> GetFlowResult(int flowId, int userId = 0)
|
|
|
{
|
|
|
- var flowId = 0;
|
|
|
- var query = Q.NewQuery();
|
|
|
- query.Where(nameof(Entity.WorkFlow.FlowTodo.Id), todoId);
|
|
|
- //query.Where(nameof(Entity.WorkFlow.FlowTodo.UserId), userId);
|
|
|
- var flowTodeDto = await _flowTodoRepository.GetAsync(query);
|
|
|
var flowToDos = new List<Entity.WorkFlow.FlowTodo>();
|
|
|
- if (flowTodeDto != null)
|
|
|
- {
|
|
|
- flowId = flowTodeDto.FlowId;
|
|
|
- query = Q.NewQuery();
|
|
|
- query.Where(nameof(Entity.WorkFlow.FlowTodo.FlowId), flowId);
|
|
|
- query.Where(nameof(Entity.WorkFlow.FlowTodo.IsOperate), true);
|
|
|
- flowToDos.AddRange(await _flowTodoRepository.GetAllAsync(query));
|
|
|
- flowTodeDto = flowToDos.FirstOrDefault(n => n.UserId == userId);
|
|
|
- }
|
|
|
- else
|
|
|
- flowId = todoId;
|
|
|
+ var query = Q.NewQuery();
|
|
|
+ query.Where(nameof(Entity.WorkFlow.FlowTodo.FlowId), flowId);
|
|
|
+ query.Where(nameof(Entity.WorkFlow.FlowTodo.IsOperate), true);
|
|
|
+ flowToDos.AddRange(await _flowTodoRepository.GetAllAsync(query));
|
|
|
+ var flowTodeDto = flowToDos.FirstOrDefault(n => n.UserId == userId);
|
|
|
var flowDto = await GetAsync(flowId);
|
|
|
var user = await _userRepository.GetAsync(flowDto.UserId);
|
|
|
var avatarUrl = await _userRepository.GetAvatarUrlAsync(flowDto.UserId);
|