| | |
|---|
| | | WebResponseContent response = new WebResponseContent(); |
|---|
| | | try |
|---|
| | | { |
|---|
| | | var czTask = BaseDal.QueryFirst(x => x.TaskTaskID == dto.TaskId); |
|---|
| | | var czTask = BaseDal.QueryFirst(x => x.TaskTaskID == dto.TaskId && x.TaskStatus == TaskInStatusEnum.InNew.ToString()); |
|---|
| | | if (czTask == null) |
|---|
| | | { |
|---|
| | | response.Error("浠诲姟涓嶅瓨鍦紒"); |
|---|
| | |
|---|
| | | { |
|---|
| | | string Saddress = saveModel.MainData["sourceAddress"].ToString(); |
|---|
| | | string Taddress = saveModel.MainData["targetAddress"].ToString(); |
|---|
| | | |
|---|
| | | string Exception = saveModel.MainData["Exception"].ToString(); |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => x.SourceAddress == Saddress && x.TaskState == (int)TaskInStatusEnum.InPending && x.TargetAddress == "WaitBind"); |
|---|
| | | if (task == null) |
|---|
| | | { |
|---|
| | |
|---|
| | | return Task.FromResult(webResponseContent); |
|---|
| | | } |
|---|
| | | task.TargetAddress = Taddress; |
|---|
| | | task.ExceptionMessage = Exception; |
|---|
| | | task.TaskState = (int)TaskInStatusEnum.InNew; |
|---|
| | | var isTrue = _taskRepository.UpdateData(task); |
|---|
| | | if (isTrue) |
|---|
