123

XdCxRhDW.App/UserControl/CtrlHome.cs

@@ -480,7 +480,7 @@ namespace XdCxRhDW.App.UserControl
                     if (tsk.TaskType == EnumTaskType.History)
                     {
                         //下发任务
-                        var svtItem =ServerContext.Instance.GetOne(EnumSvrType.X2D1HistoryTask);
+                        var svtItem = ServerContext.Instance.GetOne(EnumSvrType.X2D1HistoryTask);
                         if (svtItem == null)
                         {
                             DxHelper.MsgBoxHelper.ShowWarning($"未找到注册的处理服务");
@@ -506,7 +506,8 @@ namespace XdCxRhDW.App.UserControl
                         var res = await HttpHelper.PostRequestAsync<AjaxResult>(svtItem.BaseHttpAddr + "/api/HistoryTaskProcessing/Run", dto);
                         if (res.code != 200)
                         {
-                            DxHelper.MsgBoxHelper.ShowWarning($"下发启动历史任务的服务失败{res.msg}");
+                            Serilog.Log.Error(res.msg);
+                            DxHelper.MsgBoxHelper.ShowError($"{res.msg}");
                             return;
                         }
                     }
@@ -541,7 +542,7 @@ namespace XdCxRhDW.App.UserControl
                         var svtItem = ServerContext.Instance.GetOne(EnumSvrType.X2D1HistoryTask);
                         if (svtItem == null)
                         {
-                            DxHelper.MsgBoxHelper.ShowWarning($"请打开执行历史任务的服务");
+                            DxHelper.MsgBoxHelper.ShowWarning($"未找到注册的处理服务");
                             return;
                         }
                         HistoryTaskStopDto dto = new HistoryTaskStopDto();
@@ -549,7 +550,8 @@ namespace XdCxRhDW.App.UserControl
                         var res = await HttpHelper.PostRequestAsync<AjaxResult>(svtItem.BaseHttpAddr + "/api/HistoryTaskProcessing/Stop", dto);
                         if (res.code != 200)
                         {
-                            DxHelper.MsgBoxHelper.ShowWarning($"停止历史任务的服务失败{res.msg}");
+                            Serilog.Log.Error(res.msg);
+                            DxHelper.MsgBoxHelper.ShowWarning(res.msg);
                         }
                     }
                     using (RHDWContext db = new RHDWContext())

XdCxRhDW.X2D1TaskServer/Controllers/HistoryTaskProcessingController.cs

@@ -8,7 +8,7 @@ using System.Web.Http;
 using XdCxRhDW.Dto;
 using XdCxRhDW.WebApi;
 using XdCxRhDW.X2D1TaskServer.Service;
-using XdCxRhDW.X2D1TaskServer.Task;
+using XdCxRhDW.X2D1TaskServer.Tasks;
 
 namespace XdCxRhDW.X2D1TaskServer.Controllers
 {
@@ -41,18 +41,11 @@ namespace XdCxRhDW.X2D1TaskServer.Controllers
             {
 
                 _service.allTask.RemoveAll(a => a.IsRuning == false);
-                LogHelper.Info($"接收到历史任务编号:{dto.ID}");
-                //dto.ID = 1;
-                //dto.StartTime = new DateTime(2024, 03, 24, 12, 00, 00);
-                //dto.DateDirFormat = "yyyyMMddHH";
-                //dto.CapDir = @"D:\\data";
-                //dto.SigType = EnumSigTypeDto.SX;
-                //dto.PosType = EnumPosTypeDto.X2D1;
-                //dto.TaskCheckType = EnumTaskCheckTypeDto.DAMA;
+                LogHelper.Info($"接收到开始执行任务[{dto.TaskName}],ID={dto.ID}");
                 if (!Directory.Exists(dto.CapDir))
                 {
-                    LogHelper.Error($"采集路径:{dto.CapDir}不存在");
-                    return Error($"采集路径:{dto.CapDir}不存在");
+                    LogHelper.Error($"文件路径[{dto.CapDir}]不存在");
+                    return Error($"文件路径[{dto.CapDir}]不存在");
                 }
 
                 if (dto.PosType == EnumPosTypeDto.X2D1)
@@ -63,15 +56,14 @@ namespace XdCxRhDW.X2D1TaskServer.Controllers
                 }
                 else
                 {
-                    return Error($"历史任务不支持定位模式{dto.PosType.GetEnumDisplayName()}");
+                    return Error($"【任务{dto.ID}】执行异常,暂不支持{dto.PosType.GetEnumDisplayName()}");
                 }
-
                 return Success();
             }
             catch (Exception ex)
             {
-                Serilog.Log.Error(ex, "历史任务处理出错!");
-                return Error("历史任务处理出错");
+                Serilog.Log.Error(ex, $"【任务{dto.ID}】开始执行异常!");
+                return Error($"【任务{dto.ID}】开始执行异常!");
             }
         }
 
@@ -87,7 +79,7 @@ namespace XdCxRhDW.X2D1TaskServer.Controllers
             try
             {
 
-                LogHelper.Info($"接收停止历史任务编号:{dto.ID}");
+                LogHelper.Info($"接收到停止执行任务,ID={dto.ID}");
                 var historys = _service.allTask.Where(t => t.TaskDto.ID == dto.ID);
                 foreach (var item in historys)
                 {
@@ -99,8 +91,8 @@ namespace XdCxRhDW.X2D1TaskServer.Controllers
             }
             catch (Exception ex)
             {
-                Serilog.Log.Error(ex, "停止历史任务处理出错!");
-                return Error("停止历史任务处理出错");
+                Serilog.Log.Error(ex, $"【任务{dto.ID}】停止执行异常!");
+                return Error($"【任务{dto.ID}】停止执行异常!");
             }
         }