aiordervisit

src/Hotline.Application/Visit/AiOrderVisitService.cs

@@ -44,15 +44,16 @@ namespace Hotline.Application.Visit
                                     if(res!=null  && res.Status == 4)
                                     {
                                         aivisitDetail.AiOrderVisitState = Share.Enums.Ai.EAiOrderVisitState.LoseEfficacy;
-                                        await _aiVisitDetailRepository.UpdateAsync(aivisitDetail);
+                                        await _aiVisitDetailRepository.UpdateAsync(aivisitDetail,stoppingToken);
                                         aivisitDetail.OrderVisit.VisitState = Share.Enums.Order.EVisitState.WaitForVisit;
                                         aivisitDetail.OrderVisit.IsCanAiVisit = true;
-                                        await _orderVisitRepository.UpdateAsync(aivisitDetail.OrderVisit);
-                                        if (aivisit.AiOrderVisitDetails.Any(x=>x.AiOrderVisitState != Share.Enums.Ai.EAiOrderVisitState.InProgress && x.AiOrderVisitState != Share.Enums.Ai.EAiOrderVisitState.Stop))
+                                        await _orderVisitRepository.UpdateAsync(aivisitDetail.OrderVisit,stoppingToken);
+                                        aivisit.VisitedFailCount++;
+                                        if ((aivisit.VisitedFailCount + aivisit.VisitedCount) == aivisit.HasVisitCount)
                                         {
                                             aivisit.TaskState = Share.Enums.Ai.EAiOrderVisitTaskState.Ended;
-                                            await _aivisitRepository.UpdateAsync(aivisit);
                                         }
+                                        await _aivisitRepository.UpdateAsync(aivisit,stoppingToken);
                                     }
                                 }