某个在线实例出错超过阈值时，停止向该实例分配任务

Author: nnhy

AntJob.Server/Services/AppService.cs

@@ -195,11 +195,14 @@ public void UpdateOnline(App app, JobTask ji, AppOnline online)
         //var online = GetOnline(app, sessionId, ip);
         online.Total += ji.Total;
         online.Success += ji.Success;
-        online.Error += ji.Error;
+        //online.Error += ji.Error;
         online.Cost += ji.Cost;
         online.Speed = ji.Speed;
         online.LastKey = ji.Key;
-        online.SaveAsync();
+
+        if (ji.Status == JobStatus.错误) online.Error++;
+
+        online.Update();
     }
     #endregion
 

AntJob.Server/Services/JobService.cs

@@ -470,7 +470,7 @@ public Boolean Report(App app, TaskResult result, AppOnline online)
             SetJobError(job, task, online.UpdateIP);
 
             // 出错时判断如果超过最大错误数，则停止作业
-            CheckMaxError(app, job);
+            CheckMaxError(app, job, online);
 
             // 记录状态
             _appService.UpdateOnline(app, task, online);
@@ -565,7 +565,7 @@ private JobError SetJobError(Job job, JobTask task, String ip)
         return err;
     }
 
-    private void CheckMaxError(App app, Job job)
+    private void CheckMaxError(App app, Job job, AppOnline online)
     {
         // 出错时判断如果超过最大错误数，则停止作业
         var maxError = job.MaxError <= 0 ? 100 : job.MaxError;
@@ -575,7 +575,13 @@ private void CheckMaxError(App app, Job job)
             job.Enable = false;
 
             //job.SaveAsync();
-            (job as IEntity).Update();
+            job.Update();
+        }
+
+        if (online.Enable && online.Error > maxError)
+        {
+            online.Enable = false;
+            online.Update();
         }
     }
     #endregion