CheckController.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258
  1. 
  2. using CheckServer.AddIns;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Configuration;
  6. using System.IO;
  7. using System.Linq;
  8. using System.Threading.Tasks;
  9. using System.Web.Http;
  10. using XdCxRhDW.Dto;
  11. using XdCxRhDW.Framework;
  12. using XdCxRhDW.UI.Lib;
  13. using XdCxRhDW.WebApi;
  14. namespace CheckServer.Controllers
  15. {
  16. /// <summary>
  17. /// 信号检测、识别、变采样接口
  18. /// </summary>
  19. public class CheckController : BaseController
  20. {
  21. /// <summary>
  22. /// 信号检测(支持DAMA、IBS、能量检测)(需要先上传文件、会根据信号带宽自动对文件进行滤波)
  23. /// </summary>
  24. /// <param name="dto">信号检测参数</param>
  25. /// <returns></returns>
  26. [HttpPost]
  27. public async Task<AjaxResult<List<DetectResDto>>> Calc(DetectDto dto)
  28. {
  29. try
  30. {
  31. GC.Collect();
  32. dto.file1 = GetLocalFile(dto.file1);
  33. var bandHz = dto.band * 1e3;
  34. string outFile = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", $"{Path.GetFileNameWithoutExtension(dto.file1)}_filter.dat");
  35. dto.file1 = await SigFilterHelper.SigFilter(new SigFilterDto()
  36. {
  37. BandHz = bandHz,
  38. File = dto.file1,
  39. FsHz = dto.fsHz,
  40. }, outFile);
  41. if (!File.Exists(dto.file1))
  42. {
  43. return Error<List<DetectResDto>>("滤波后的文件未能生成");
  44. }
  45. List<DetectResDto> list = new List<DetectResDto>();
  46. List<DmcResult> listRes = new List<DmcResult>();
  47. List<DmcResult> dmcResults = new List<DmcResult>();
  48. List<DmcResult> ibsResults = new List<DmcResult>();
  49. List<DmcResult> kyResults = new List<DmcResult>();
  50. if (dto.dmcType.HasFlag(EnumSigCheckTypeDto.DAMA))
  51. {
  52. var dmcResult2 = await CheckHelper.DAMACheckAsync(dto.file1, dto.fsHz, EnumSigCheckTypeDto.DAMA, dto.band);
  53. dmcResults.AddRange(dmcResult2);
  54. }
  55. if (dto.dmcType.HasFlag(EnumSigCheckTypeDto.IBS))
  56. {
  57. var dmcResult = await CheckHelper.DmcCheckAsync(dto.file1, dto.fsHz, EnumSigCheckTypeDto.IBS, dto.band);
  58. ibsResults.AddRange(dmcResult);
  59. }
  60. if (dto.dmcType.HasFlag(EnumSigCheckTypeDto.Ky5758))
  61. {
  62. var dmcResult = await CheckHelper.DmcCheckAsync(dto.file1, dto.fsHz, EnumSigCheckTypeDto.Ky5758, dto.band);
  63. kyResults.AddRange(dmcResult);
  64. }
  65. if (dto.mergeRes)
  66. {
  67. listRes.AddRange(dmcResults);
  68. var ibsCopy = ibsResults.Skip(0).ToList();
  69. foreach (var item in ibsResults)
  70. {
  71. if (listRes.Any(p => CalcIntersecLen(p, item) > 500))
  72. ibsCopy.Remove(item);//IBS结果在DAMA中重叠超过500长度,忽略
  73. }
  74. listRes.AddRange(ibsCopy);
  75. var kyCopy = kyResults.Skip(0).ToList();
  76. foreach (var item in kyResults)
  77. {
  78. if (listRes.Any(p => CalcIntersecLen(p, item) > 500))
  79. kyCopy.Remove(item);//KY结果在DAMA或IBS中重叠超过500长度,忽略
  80. }
  81. listRes.AddRange(kyCopy);
  82. foreach (var dmcItem in listRes)
  83. {
  84. DetectResDto detectRes = new DetectResDto(dmcItem.Start, dmcItem.Length, dmcItem.UserName);
  85. detectRes.ModType = dmcItem.ModType;
  86. detectRes.DmcType = dmcItem.DmcType;
  87. detectRes.File1 = dto.file1;
  88. detectRes.TimeMs = dmcItem.Times;
  89. list.Add(detectRes);
  90. }
  91. }
  92. else
  93. {
  94. listRes.AddRange(dmcResults);
  95. listRes.AddRange(ibsResults);
  96. listRes.AddRange(kyResults);
  97. foreach (var dmcItem in listRes)
  98. {
  99. DetectResDto detectRes = new DetectResDto(dmcItem.Start, dmcItem.Length, dmcItem.UserName);
  100. detectRes.ModType = dmcItem.ModType;
  101. detectRes.DmcType = dmcItem.DmcType;
  102. detectRes.File1 = dto.file1;
  103. detectRes.TimeMs = dmcItem.Times;
  104. list.Add(detectRes);
  105. }
  106. }
  107. list = list.OrderBy(l => l.Start).ToList();
  108. await LogUI.Info($"文件{Path.GetFileName(dto.file1)}检测完成");
  109. return Success(list);
  110. }
  111. catch (Exception ex)
  112. {
  113. await LogUI.Error($"文件【{Path.GetFileName(dto.file1)}】{dto.dmcType}检测异常", ex);
  114. return Error<List<DetectResDto>>($"{dto.dmcType}检测异常");
  115. }
  116. }
  117. /// <summary>
  118. /// 文件变采样(需要先上传文件)
  119. /// </summary>
  120. /// <param name="dto"></param>
  121. /// <returns></returns>
  122. public async Task<AjaxResult<ResampleResponseDto>> Resample(ResampleRequestDto dto)
  123. {
  124. var res = await Task.Run(async () =>
  125. {
  126. try
  127. {
  128. string fileIn = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", dto.File);
  129. string fileOut = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", Guid.NewGuid() + ".dat");
  130. var val = Gcd(dto.FsHz, dto.OutFsHz);//最大公约数
  131. var insertFactor = dto.OutFsHz / val;
  132. var extFactor = dto.FsHz / val;
  133. var outFile = ReSampleHelper.Resample(fileIn, fileOut, insertFactor, extFactor);
  134. if (!string.IsNullOrWhiteSpace(outFile))
  135. {
  136. if (!File.Exists(outFile))
  137. return Error<ResampleResponseDto>("变采样后的文件未能生成");
  138. else
  139. return Success(new ResampleResponseDto() { File = Path.GetFileName(outFile), OutFsHz = dto.OutFsHz });
  140. }
  141. else
  142. {
  143. return Error<ResampleResponseDto>("变采样算法返回失败");
  144. }
  145. }
  146. catch (Exception ex)
  147. {
  148. await LogUI.Error($"变采样算法执行异常", ex);
  149. return Error<ResampleResponseDto>("变采样算法执行异常");
  150. }
  151. });
  152. return res;
  153. }
  154. /// <summary>
  155. /// 信号识别(调制类型、调制速率、频偏)
  156. /// </summary>
  157. /// <param name="dto">信号检测参数</param>
  158. /// <returns></returns>
  159. [HttpPost]
  160. public async Task<AjaxResult<List<SignalProcResDto>>> SignalProc(SignalProcDto dto)
  161. {
  162. await LogUI.Info($"正在识别文件{dto.File}");
  163. return await Task.Run(async () =>
  164. {
  165. try
  166. {
  167. dto.File = GetLocalFile(dto.File);
  168. List<SignalProcResDto> list = new List<SignalProcResDto>();
  169. var res = SignalProcHelper.SigalEst(dto.File, dto.Fs
  170. , dto.Smps.Select(p => (int)p.smpStart).ToArray()
  171. , dto.Smps.Select(p => (int)p.smpCount).ToArray());
  172. foreach (var item in res)
  173. {
  174. SignalProcResDto resItem = new SignalProcResDto()
  175. {
  176. Snr = item.Snr,
  177. Ffc = item.Ffc,
  178. Rate = item.Rate,
  179. ModType = (EnumSignalTypeDto)(int)item.SignalType
  180. };
  181. list.Add(resItem);
  182. }
  183. await LogUI.Info($"文件{Path.GetFileName(dto.File)}识别完成");
  184. return Success(list);
  185. }
  186. catch (Exception ex)
  187. {
  188. await LogUI.Error($"文件{Path.GetFileName(dto.File)}识别异常", ex);
  189. return Error<List<SignalProcResDto>>($"信号识别算法执行异常");
  190. }
  191. });
  192. }
  193. /// <summary>
  194. /// 对信号文件进行滤波处理(需要先上传文件)
  195. /// </summary>
  196. /// <param name="dto">信号滤波参数</param>
  197. /// <returns></returns>
  198. [HttpPost]
  199. public async Task<AjaxResult<SigFilterResponseDto>> SigFilterProc(SigFilterDto dto)
  200. {
  201. try
  202. {
  203. await LogUI.Info($"正在滤波处理文件{dto.File}");
  204. dto.File = GetLocalFile(dto.File);
  205. string outFile = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", Guid.NewGuid() + "filter.dat");
  206. outFile = await SigFilterHelper.SigFilter(dto, outFile);
  207. if (!File.Exists(outFile))
  208. {
  209. return Error<SigFilterResponseDto>("滤波后的文件未能生成");
  210. }
  211. else
  212. {
  213. await LogUI.Info($"文件{Path.GetFileName(dto.File)}滤波完成");
  214. return Success(new SigFilterResponseDto() { File = Path.GetFileName(outFile) });
  215. }
  216. }
  217. catch (Exception ex)
  218. {
  219. await LogUI.Error($"文件{Path.GetFileName(dto.File)}滤波异常", ex);
  220. return Error<SigFilterResponseDto>($"信号滤波算法执行异常");
  221. }
  222. }
  223. //求最大公约数
  224. private int Gcd(int M, int N)
  225. {
  226. int Rem;
  227. while (N > 0)
  228. {
  229. Rem = M % N;
  230. M = N;
  231. N = Rem;
  232. }
  233. return M;
  234. }
  235. //计算两个时隙交集的长度,无交集返回0
  236. private int CalcIntersecLen(DmcResult dto1, DmcResult dto2)
  237. {
  238. if (dto2.Start >= dto1.Start + dto1.Length) return 0;
  239. if (dto1.Start >= dto2.Start + dto2.Length) return 0;
  240. int maxStart = Math.Max(dto1.Start, dto2.Start);
  241. int minEnd = Math.Min(dto1.Start + dto1.Length, dto2.Start + dto2.Length);
  242. return minEnd - maxStart + 1;
  243. }
  244. }
  245. }