XdCxRhDW54/XdCxRhDW.App/Controllers/DetectCgController.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using System.Web.Http;
using DevExpress.Data.Svg;
using XdCxRhDW.Api;
using XdCxRhDW.Dto;
using XdCxRhDW.Entity;
using XdCxRhDW.Repostory;
using XdCxRhDW.WebApi;

namespace XdCxRhDW.App.Controllers
{
    /// <summary>
    /// 检测参估变采样识别相关接口
    /// </summary>
    public class DetectCgController : BaseController
    {
        /// <summary>
        /// CPU参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">CPU参估参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<CpuCgResDto>> CpuCgCalc(CpuCgDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CpuCgSvr);
            dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<CpuCgResDto>(svr.BaseHttpAddr + "CpuCg/Calc", dto, dto.TimeoutSeconds);
            return res;
        }

        /// <summary>
        /// CPU参估多个时隙的参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">CPU多时隙参估参数模型</param>
        /// <returns>返回结果个数始终和传入的时隙个数相同</returns>
        [HttpPost]
        public async Task<AjaxResult<List<CpuCgResDto>>> CpuCgMultiCalc(CpuCgMultiDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CpuCgSvr);
            dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(svr.BaseHttpAddr + "CpuCg/MultiCalc", dto, dto.TimeoutSeconds);
            return res;
        }

        /// <summary>
        /// 参估画图
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<ImageResultDto>>> DrawImage(CpuCgDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CpuCgSvr);
            dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<List<ImageResultDto>>(svr.BaseHttpAddr + "CpuCg/DrawImage", dto, dto.TimeoutSeconds);
            return res;
        }
        /// <summary>
        /// GPU参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">GPU参估参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<GpuCgResponseDto>>> GpuCgCalc(GpuCgRequestDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.GpuCgSvr);
            dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<List<GpuCgResponseDto>>(svr.BaseHttpAddr + "GpuCg/Calc", dto, dto.TimeoutSeconds);
            return res;
        }

        /// <summary>
        /// 信号检测(支持DAMA、IBS、能量检测)(需要先上传文件)
        /// </summary>
        /// <param name="dto">信号检测参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<DetectResDto>>> DetectCalc(DetectDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CheckSvr);
            dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<List<DetectResDto>>(svr.BaseHttpAddr + "Check/Calc", dto, dto.TimeoutSeconds);
            if (dto.SigProc && res.data.Any())
            {
                SignalProcDto procDto = new SignalProcDto()
                {
                    File = dto.file1,
                    Fs = (long)dto.fsHz,
                    Smps = res.data.Select(p => new SmpPosition() { smpStart = p.Start, smpCount = p.Length }).ToList(),
                };
                var procRes = await HttpHelper.PostRequestAsync<List<SignalProcResDto>>(svr.BaseHttpAddr + "Check/SignalProc", procDto);
                if (procRes.data == null || res.data.Count != procRes.data.Count)
                {
                    throw new Exception("信号识别结果个数和检测结果个数不一致");
                }
                for (int i = 0; i < res.data.Count; i++)
                {
                    res.data[i].ModRate = procRes.data[i].Rate;
                    res.data[i].ModType = procRes.data[i].ModType.GetEnumDisplayName();
                    res.data[i].FfcHz = procRes.data[i].Ffc;
                    res.data[i].Snr = procRes.data[i].Snr;
                }
            }
            return res;
        }

        /// <summary>
        /// 信号识别(调制类型、调制速率、频偏)
        /// </summary>
        /// <param name="dto">信号检测参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<SignalProcResDto>>> SignalProc(SignalProcDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CheckSvr);
            dto.File = await HttpHelper.UploadFileAsync(GetLocalFile(dto.File), svr.BaseHttpAddr);
            var res = await HttpHelper.PostRequestAsync<List<SignalProcResDto>>(svr.BaseHttpAddr + "Check/SignalProc", dto);
            return res;
        }

        /// <summary>
        /// 文件变采样(需要先上传文件)
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ResampleResponseDto>> Resample(ResampleRequestDto dto)
        {
            var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CheckSvr);
            dto.File = await HttpHelper.UploadFileAsync(GetLocalFile(dto.File), svr.BaseHttpAddr, timeoutSeconds: dto.TimeoutSeconds);
            var res = await HttpHelper.PostRequestAsync<ResampleResponseDto>(svr.BaseHttpAddr + "Check/Resample", dto, dto.TimeoutSeconds);
            await HttpHelper.DownloadFileAsync(svr.BaseHttpAddr, res.data.File, GetLocalFile(res.data.File), dto.TimeoutSeconds);
            return res;
        }


        /// <summary>
        /// 两星一地误差椭圆(带参)
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ErrEllipseResDto>> ErrorEllipse2X1D(ErrEllipseX2D1Dto dto)
        {
            return await Task.Run(() =>
            {
                double[] mainEcef = new double[3] { dto.MainX, dto.MainY, dto.MainZ };
                double[] adjaEcef = new double[3] { dto.AdjaX, dto.AdjaY, dto.AdjaZ };
                double[] cdbLoc = new double[3] { dto.CdbLon, dto.CdbLat, 0 };
                double[] refLoc = new double[3] { dto.RefLon, dto.RefLat, 0 };
                var res = ErrEllipseHepler.ErrorEllipse2X1D(dto.PosLon, dto.PosLat, mainEcef, adjaEcef, cdbLoc, refLoc, dto.DtoErrus, dto.EphErr, dto.OutputErrPoint);
                return Success(res);
            });
        }
        /// <summary>
        /// 两星一地误差椭圆(无参)
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ErrEllipseResDto>> ErrorEllipse2X1DNoRef(ErrEllipseX2D1NoRefDto dto)
        {
            return await Task.Run(() =>
            {
                double[] mainEcef = new double[3] { dto.MainX, dto.MainY, dto.MainZ };
                double[] adjaEcef = new double[3] { dto.AdjaX, dto.AdjaY, dto.AdjaZ };
                double[] cdbLoc = new double[3] { dto.CdbLon, dto.CdbLat, 0 };
                var res = ErrEllipseHepler.ErrorEllipse2X1DNoRef(dto.PosLon, dto.PosLat, mainEcef, adjaEcef, cdbLoc, dto.DtoErrus, dto.EphErr, dto.OutputErrPoint);
                return Success(res);
            });
        }

        /// <summary>
        /// 低轨单星带参误差椭圆
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ErrEllipseResDto>> ErrorEllipseX1Leo(ErrorEllipseLeoX1Dto dto)
        {
            return await Task.Run(() =>
            {
                ErrorEllipseX1Option option = new ErrorEllipseX1Option();
                option.MsEph = dto.MsEph;
                option.NsEph1 = dto.NsEph1;
                option.NsEph2 = dto.NsEph2;
                option.SelectPoint = dto.SelectPoint;
                option.DfoErr = dto.DfoErr;
                option.EphPosErr = dto.EphPosErr;
                option.EphVelErr = dto.EphVelErr;
                option.fu = dto.fu;
                option.Pe = dto.Pe;
                var res = LeoErrorEllipseHelper.ErrorEllipseLeoX1(option,dto.OutputErrPoint);
                return Success(res);
            });
        }

        /// <summary>
        /// 低轨双星带参误差椭圆
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ErrEllipseResDto>> ErrorEllipseX2Leo(ErrorEllipseLeoX2Dto dto)
        {
            return await Task.Run(() =>
            {
                ErrorEllipseX2Option option = new ErrorEllipseX2Option();
                option.MsEph = dto.MsEph;
                option.NsEph = dto.NsEph;
                option.RefGeod = dto.RefGeod;
                option.SelectPoint = dto.SelectPoint;
                option.DtoErr = dto.DtoErr;
                option.DfoErr = dto.DfoErr;
                option.EphPosErr = dto.EphPosErr;
                option.EphVelErr = dto.EphVelErr;
                option.fu1 = dto.fu1;
                option.fu2 = dto.fu2;
                option.Pe = dto.Pe;
                var res = LeoErrorEllipseHelper.ErrorEllipseLeoX2(option, dto.OutputErrPoint);
                return Success(res);
            });
        }


        /// <summary>
        /// 低轨三星带参误差椭圆
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<AjaxResult<ErrEllipseResDto>> ErrorEllipseX3Leo(ErrorEllipseLeoX3Dto dto)
        {
            return await Task.Run(() =>
            {
                ErrorEllipseX3Option option = new ErrorEllipseX3Option();
                option.MsEph = dto.MsEph;
                option.NsEph1 = dto.NsEph1;
                option.NsEph2 = dto.NsEph2;
                option.RefGeod = dto.RefGeod;
                option.SelectPoint = dto.SelectPoint;
                option.DtoErr = dto.DtoErr;
                option.DfoErr = dto.DfoErr;
                option.EphPosErr = dto.EphPosErr;
                option.EphVelErr = dto.EphVelErr;
                option.fu1 = dto.fu1;
                option.fu2 = dto.fu2;
                option.Pe = dto.Pe;
                var res = LeoErrorEllipseHelper.ErrorEllipseLeoX3(option, dto.OutputErrPoint);
                return Success(res);
            });
        }
    }
}