特提清除数据

src/Hotline.Application/Handlers/FlowEngine/WorkflowRecallHandler.cs

@@ -103,7 +103,7 @@ public class WorkflowRecallHandler : INotificationHandler<RecallNotify>
 					//}
 				}
                 await _orderRepository.UpdateAsync(order, false, cancellationToken);
-                var publish = await _orderPublishRepository.GetAsync(x => x.OrderId == order.Id);
+                var publish = await _orderPublishRepository.GetAsync(x => x.OrderId == order.Id, cancellationToken);
                 if (publish != null)
                 {
 	                var publishHistory = _mapper.Map<OrderPublishHistory>(publish);
@@ -114,15 +114,15 @@ public class WorkflowRecallHandler : INotificationHandler<RecallNotify>
 	                publishHistory.ArrangeContentBefor = publish.ArrangeContent;
 	                publishHistory.ArrangeOpinionAfter = publish.ArrangeOpinion;
 	                publishHistory.ArrangeOpinionBefor = publish.ArrangeOpinion;
-	                await _orderPublishHistoryRepository.AddAsync(publishHistory);
-	                await _orderPublishRepository.RemoveAsync(publish, false);
+	                await _orderPublishHistoryRepository.AddAsync(publishHistory, cancellationToken);
+	                await _orderPublishRepository.RemoveAsync(publish, false, cancellationToken);
                 }
 
-                var visit = await _orderVisitRepository.GetAsync(x => x.OrderId == order.Id && x.VisitState != EVisitState.None);
+                var visit = await _orderVisitRepository.GetAsync(x => x.OrderId == order.Id && x.VisitState != EVisitState.None, cancellationToken);
                 if (visit != null)
                 {
 	                visit.VisitState = EVisitState.None;
-	                await _orderVisitRepository.UpdateAsync(visit);
+	                await _orderVisitRepository.UpdateAsync(visit, cancellationToken);
                 }
 				break;
             case WorkflowModuleConsts.KnowledgeAdd: