111

Service/X2D1TaskServer54/Service/HistoryTaskService.cs

@@ -54,12 +54,12 @@ namespace X3TaskServer54.Service
                         #region 第1步,读取需要的配置信息
                         if (!Directory.Exists(DetectDir))
                         {
-                            StopTask(dto.ID, $"检测结果目录[{DetectDir}]不存在");
+                            StopTask(dto.ID, EnumTaskStopType.Error, $"检测结果目录[{DetectDir}]不存在");
                             return;
                         }
                         if (!Directory.Exists(CapDir))
                         {
-                            StopTask(dto.ID, $"AD采集目录[{CapDir}]不存在");
+                            StopTask(dto.ID, EnumTaskStopType.Error, $"AD采集目录[{CapDir}]不存在");
                             return;
                         }
                         Directory.CreateDirectory(DdcDir);
@@ -84,7 +84,7 @@ namespace X3TaskServer54.Service
                         }
                         catch
                         {
-                            StopTask(dto.ID, $"任务处理服务配置文件卫星信息解析出错");
+                            StopTask(dto.ID, EnumTaskStopType.Error, $"任务处理服务配置文件卫星信息解析出错");
                             return;
                         }
                         #endregion
@@ -327,19 +327,22 @@ namespace X3TaskServer54.Service
         {
             cts?.Cancel();
         }
-        void StopTask(int taskID, string stopReason)
+        private void StopTask(int taskID, EnumTaskStopType type, string stopReason)
         {
-            TaskStopHandleDto stopDto = new TaskStopHandleDto() { ID = taskID, StopReason = stopReason };
-            if (string.IsNullOrWhiteSpace(stopReason))
-                LogHelper.Info($"【任务{taskID}】正常结束");
+            Thread.Sleep(2000);
+            if (type == EnumTaskStopType.Properly)
+            {
+                LogHelper.Info($"【任务{taskID}】{stopReason}");
+            }
             else
+            {
                 LogHelper.Error($"【任务{taskID}】{stopReason}");
-
+            }
+            TaskStopHandleDto stopDto = new TaskStopHandleDto() { ID = taskID, StopType = type, StopReason = stopReason };
             var stopResp = HttpHelper.PostRequestAsync(baseUrl + "Task/StopTask", stopDto).Result;
             if (stopResp.code != 200)
             {
                 LogHelper.Error($"【任务{taskID}】停止异常.{stopResp.msg}");
-                return;
             }
         }