12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 |
- using System;
- using System.Configuration;
- using System.IO;
- using System.Web.Http;
- using XdCxRhDW.Dto;
- using XdCxRhDW.TaskServer.Task;
- using XdCxRhDW.WebApi;
- namespace XdCxRhDW.TaskServer.Controllers
- {
- /// <summary>
- ///离线任务处理接口
- /// </summary>
- public class HistoryTaskProcessingController : BaseController
- {
- /// <summary>
- /// 执行离线任务
- /// </summary>
- /// <param name="dto">离线任务信息</param>
- /// <returns></returns>
- [HttpPost]
- public AjaxResult Run(HistoryTaskProcessingDto dto)
- {
- try
- {
- LogHelper.Info($"接收到历史任务:{dto.ID}");
- dto.StartTime = new DateTime(2024, 03, 24, 12, 00, 00);
- dto.DateDirFormat = "yyyyMMddHH";
- dto.CapDir = @"D:\\data";
- if (!Directory.Exists(dto.CapDir))
- {
- LogHelper.Error($"采集路径:{dto.CapDir}不存在");
- return Error($"采集路径:{dto.CapDir}不存在");
- }
-
- switch (dto.PosType)
- {
- case EnumPosTypeDto.X1D1CX:
- X1D1CXTask x1D1 = new X1D1CXTask();
- x1D1.Start(dto, posPlatformAddr);
- break;
- case EnumPosTypeDto.X2D1:
- break;
- case EnumPosTypeDto.RH:
- break;
- case EnumPosTypeDto.X3TwoDto:
- break;
- case EnumPosTypeDto.X3TwoDfo:
- break;
- case EnumPosTypeDto.X2Dfo:
- break;
- default:
- break;
- }
- return Success();
- }
- catch (Exception ex)
- {
- Serilog.Log.Error(ex, "离线任务处理出错!");
- return Error("离线任务处理出错");
- }
- }
- }
- }
|