using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DW5S.DTO;
using DW5S.Entity;
using DW5S.Repostory;
using DW5S.Service;
using DW5S.WebApi;
using Microsoft.AspNetCore.Mvc;
using Serilog;
namespace DW5S.Controllers
{
///
/// 取参考相关接口
///
public class FindRefController : BaseController
{
ILogger logger { get; set; }
IUnitOfWork unitOfWork { get; set; }
///
/// 添加两星一地参考信号缓存
///
/// 返回请求结果
[HttpPost]
public async Task AddX2D1RefCacheAsync(List dtos)
{
var id = dtos.First().TaskID.Value;
try
{
var repsTask = unitOfWork.Of();
var runTask = await repsTask.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
if (runTask == null)
{
string msg = $"接收到两星一地无参参考信号参数,由于找不到执行中的任务忽略本次定位";
logger.Error(msg);
return Error(msg);
}
else
{
runTask = await repsTask.FirstOrDefaultAsync(p => p.Id == id);
if (runTask == null)
{
string msg = $"找不到任务,ID={id}";
logger.Error(msg);
return Error(msg);
}
}
TaskRefCache.Instance.AddRange(id, dtos);
return Success();
}
catch (Exception ex)
{
string msg = $"添加两星一地参考信号异常.ID={id}";
logger.Error(ex, msg);
return Error(msg);
}
}
///
/// 添加两星一地目标信号缓存
///
/// 返回请求结果
[HttpPost]
public async Task AddX2D1TarCacheAsync(List dtos)
{
var id = dtos.First().TaskID;
try
{
var repsTask = unitOfWork.Of();
var runTask = await repsTask.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
if (runTask == null)
{
string msg = $"接收到两星一地无参目标信号参数,由于找不到执行中的任务忽略本次定位";
logger.Error(msg);
return Error(msg);
}
else
{
runTask = await repsTask.FirstOrDefaultAsync(p => p.Id == id);
if (runTask == null)
{
string msg = $"找不到任务,ID={id}";
logger.Error(msg);
return Error(msg);
}
}
TaskTarCache.Instance.AddRange(id, dtos);
return Success();
}
catch (Exception ex)
{
string msg = $"添加两星一地目标信号异常.ID={id}";
logger.Error(ex, msg);
return Error(msg);
}
}
}
}