DW5S/DW5S.Controller/DetectCgController.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using DW5S.KxcApi;
using DW5S.DTO;
using DW5S.Repostory;
using DW5S.WebApi;
using Microsoft.AspNetCore.Mvc;
using DW5S.Service;
using Serilog;

namespace DW5S.Controllers
{
    /// <summary>
    /// 检测参估变采样识别相关接口
    /// </summary>
    public class DetectCgController : BaseController
    {
        ILogger logger { get; set; }

        IUnitOfWork unitOfWork { get; set; }

        /// <summary>
        /// CPU参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">CPU参估参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<CpuCgResDto>> CpuCgCalc(CpuCgDto dto)
        {
            try
            {
                var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CpuCgSvr);
                dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr);
                dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr);
                var res = await HttpHelper.PostRequestAsync<CpuCgResDto>(svr.BaseHttpAddr + "CpuCg/Calc", dto);
                return res;
            }
            catch (TaskCanceledException)
            {
                return Error<CpuCgResDto>($"CPU参估超时");
            }
        }

        /// <summary>
        /// CPU参估多个时隙的参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">CPU多时隙参估参数模型</param>
        /// <returns>返回结果个数始终和传入的时隙个数相同</returns>
        [HttpPost]
        public async Task<AjaxResult<List<CpuCgResDto>>> CpuCgMultiCalc(CpuCgMultiDto dto)
        {
            try
            {
                var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CpuCgSvr);
                dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr);
                dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr);
                var res = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(svr.BaseHttpAddr + "CpuCg/MultiCalc", dto);
                if (res.code != 200)
                {
                    return Error<List<CpuCgResDto>>(res.msg);
                }
                else
                {
                    return Success(res.data);
                }
            }
            catch (TaskCanceledException)
            {
                return Error<List<CpuCgResDto>>($"CPU参估超时({dto.smpPositions.Count}个突发)");
            }
        }

        /// <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);
            dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr);
            var res = await HttpHelper.PostRequestAsync<List<ImageResultDto>>(svr.BaseHttpAddr + "CpuCg/DrawImage", dto);
            return res;
        }
        /// <summary>
        /// GPU参估计算(需要先上传文件)
        /// </summary>
        /// <param name="dto">GPU参估参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<GpuCgResponseDto>>> GpuCgCalc(GpuCgRequestDto dto)
        {
            try
            {
                var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.GpuCgSvr);
                dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr);
                dto.file2 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file2), svr.BaseHttpAddr);
                var res = await HttpHelper.PostRequestAsync<List<GpuCgResponseDto>>(svr.BaseHttpAddr + "GpuCg/Calc", dto);
                return res;
            }
            catch (TaskCanceledException)
            {
                return Error<List<GpuCgResponseDto>>($"GPU参估超时");
            }
        }

        /// <summary>
        /// 信号检测(支持DAMA、IBS、能量检测)(需要先上传文件,会根据信号带宽自动对文件进行滤波)
        /// </summary>
        /// <param name="dto">信号检测参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<DetectResDto>>> DetectCalc(DetectDto dto)
        {
            try
            {
                var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CheckSvr);
                dto.file1 = await HttpHelper.UploadFileAsync(GetLocalFile(dto.file1), svr.BaseHttpAddr);
                var res = await HttpHelper.PostRequestAsync<List<DetectResDto>>(svr.BaseHttpAddr + "Check/Calc", dto);
                if (res.code != 200)
                {
                    return Error<List<DetectResDto>>(res.msg);
                }
                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;
            }
            catch (TaskCanceledException)
            {
                return Error<List<DetectResDto>>($"信号检测超时");
            }

        }

        /// <summary>
        /// 信号识别(调制类型、调制速率、频偏)
        /// </summary>
        /// <param name="dto">信号检测参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<List<SignalProcResDto>>> SignalProc(SignalProcDto dto)
        {

            try
            {
                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;
            }
            catch (TaskCanceledException)
            {
                return Error<List<SignalProcResDto>>($"信号识别超时");
            }
        }


        /// <summary>
        /// 滤波处理(滤波处理文件)
        /// </summary>
        /// <param name="dto">滤波处理参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<AjaxResult<SigFilterResponseDto>> SigFilterProc(SigFilterDto dto)
        {
            try
            {
                if (dto.BandHz <= 0 || dto.BandHz > dto.FsHz)
                {
                    dto.BandHz = 25000;
                    //return new AjaxResult<SigFilterResponseDto>() { code = 200, data = new SigFilterResponseDto() { File = dto.File } };
                }
                var svr = ServerContext.Instance.GetRandomOne(EnumSvrType.CheckSvr);
                dto.File = await HttpHelper.UploadFileAsync(GetLocalFile(dto.File), svr.BaseHttpAddr);
                var res = await HttpHelper.PostRequestAsync<SigFilterResponseDto>(svr.BaseHttpAddr + "Check/SigFilterProc", dto);
                await HttpHelper.DownloadFileAsync(svr.BaseHttpAddr, res.data.File, GetLocalFile(res.data.File));
                return res;
            }
            catch (TaskCanceledException)
            {
                return Error<SigFilterResponseDto>($"信号滤波超时");
            }
        }

        /// <summary>
        /// 文件变采样(需要先上传文件)
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        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);
            var res = await HttpHelper.PostRequestAsync<ResampleResponseDto>(svr.BaseHttpAddr + "Check/Resample", dto);
            await HttpHelper.DownloadFileAsync(svr.BaseHttpAddr, res.data.File, GetLocalFile(res.data.File));
            return res;
        }
    }
}