|
|
@@ -0,0 +1,408 @@
|
|
|
+using System;
|
|
|
+using System.Collections.Generic;
|
|
|
+using System.Configuration;
|
|
|
+using System.Diagnostics;
|
|
|
+using System.IO;
|
|
|
+using System.Linq;
|
|
|
+using System.Text;
|
|
|
+using System.Threading;
|
|
|
+using System.Threading.Tasks;
|
|
|
+using XdCxRhDW.Api;
|
|
|
+using XdCxRhDW.Dto;
|
|
|
+
|
|
|
+namespace X2D1NoRefTaskServer54.Service
|
|
|
+{
|
|
|
+ //业务逻辑处理类
|
|
|
+ public class HistoryTaskService
|
|
|
+ {
|
|
|
+ private readonly string baseUrl;
|
|
|
+ CancellationTokenSource cts;
|
|
|
+
|
|
|
+ string DetectDir;
|
|
|
+ string CapDir;
|
|
|
+ string DdcDir;
|
|
|
+ string PosResDir;
|
|
|
+ int MainSatCode, Adja1SatCode;
|
|
|
+ double[] MainSatXYZ, Adja1SatXYZ;
|
|
|
+ int PosDtoFactor;
|
|
|
+ public HistoryTaskService()
|
|
|
+ {
|
|
|
+ var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();//like http://127.0.0.1:8091 or http://127.0.0.1:8091/
|
|
|
+ if (posPlatformAddr.EndsWith("/"))
|
|
|
+ this.baseUrl = posPlatformAddr + "api/";
|
|
|
+ else
|
|
|
+ this.baseUrl = posPlatformAddr + "/api/";
|
|
|
+
|
|
|
+ DetectDir = ConfigurationManager.AppSettings["DetectDir"].Trim();
|
|
|
+ CapDir = ConfigurationManager.AppSettings["CapDir"].Trim();
|
|
|
+ DdcDir = ConfigurationManager.AppSettings["DdcDir"].Trim();
|
|
|
+ PosResDir = ConfigurationManager.AppSettings["PosResDir"].Trim();
|
|
|
+ var PosDtoFactorstr = ConfigurationManager.AppSettings["PosDtoFactor"].Trim();
|
|
|
+ int.TryParse(PosDtoFactorstr, out PosDtoFactor);
|
|
|
+ if (PosDtoFactor == 0) PosDtoFactor = 1;
|
|
|
+ }
|
|
|
+ public void StartAsync(X2D1NoRefTaskHandleDto dto)
|
|
|
+ {
|
|
|
+ cts = new CancellationTokenSource();
|
|
|
+ Task.Run(async () =>
|
|
|
+ {
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】开始执行...");
|
|
|
+ //点击定位平台右上角查看接口可以在浏览器中查看平台提供的所有接口详细信息
|
|
|
+ while (!cts.IsCancellationRequested)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ #region 第1步,读取需要的配置信息
|
|
|
+ if (!Directory.Exists(DetectDir))
|
|
|
+ {
|
|
|
+ StopTask(dto.ID, EnumTaskStopType.Error, $"检测结果目录[{DetectDir}]不存在");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if (!Directory.Exists(CapDir))
|
|
|
+ {
|
|
|
+ StopTask(dto.ID, EnumTaskStopType.Error, $"AD采集目录[{CapDir}]不存在");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ Directory.CreateDirectory(DdcDir);
|
|
|
+ Directory.CreateDirectory(PosResDir);
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】检测结果目录[{DetectDir}]");
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】AD采集目录[{CapDir}]");
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】DDC输出目录[{DdcDir}]");
|
|
|
+ try
|
|
|
+ {
|
|
|
+ var mainInfo = ConfigurationManager.AppSettings["MainSatInfo"].Replace(",", ",").Trim();
|
|
|
+ var adja1Info = ConfigurationManager.AppSettings["Adja1SatInfo"].Replace(",", ",").Trim();
|
|
|
+ //var adja2Info = ConfigurationManager.AppSettings["Adja2SatInfo"].Replace(",", ",").Trim();
|
|
|
+ var arr1 = mainInfo.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ var arr2 = adja1Info.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ // var arr3 = adja2Info.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ MainSatCode = Convert.ToInt32(arr1[0]);
|
|
|
+ Adja1SatCode = Convert.ToInt32(arr2[0]);
|
|
|
+ //Adja2SatCode = Convert.ToInt32(arr3[0]);
|
|
|
+ MainSatXYZ = new double[3] { Convert.ToDouble(arr1[1]), Convert.ToDouble(arr1[2]), Convert.ToDouble(arr1[3]) };
|
|
|
+ Adja1SatXYZ = new double[3] { Convert.ToDouble(arr2[1]), Convert.ToDouble(arr2[2]), Convert.ToDouble(arr2[3]) };
|
|
|
+ //Adja2SatXYZ = new double[3] { Convert.ToDouble(arr3[1]), Convert.ToDouble(arr3[2]), Convert.ToDouble(arr3[3]) };
|
|
|
+ }
|
|
|
+ catch
|
|
|
+ {
|
|
|
+ StopTask(dto.ID, EnumTaskStopType.Error, $"任务处理服务配置文件卫星信息解析出错");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 第2步,扫描检测结果目录
|
|
|
+ var groupFiles = Directory.EnumerateFiles(DetectDir, "*.dat", SearchOption.TopDirectoryOnly).Select(p => StringToCheckResFile(p))
|
|
|
+ .GroupBy(m => Convert.ToInt64(m.DayTime.ToString("yyyyMMdd") + m.FlagNo)).OrderBy(m => m.Key);
|
|
|
+ if (!groupFiles.Any())
|
|
|
+ {
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】等待扫描文件...");
|
|
|
+ await Task.Delay(10000);
|
|
|
+ }
|
|
|
+ foreach (var groupFile in groupFiles)//每一组文件代表同一个时刻的
|
|
|
+ {
|
|
|
+ if (cts.IsCancellationRequested) break;
|
|
|
+ List<SlotsInfo> listSlotsInfo = new List<SlotsInfo>();//多个频点的时隙结果
|
|
|
+ foreach (var item in groupFile)
|
|
|
+ {
|
|
|
+ var slotsInfo = SlotHelper.GetFileSlots(item.File);//某个频点的所有时隙
|
|
|
+ if (!Debugger.IsAttached)
|
|
|
+ File.Delete(item.File);//检测检测结果文件
|
|
|
+ if (slotsInfo.Slots.Any())
|
|
|
+ listSlotsInfo.Add(slotsInfo);
|
|
|
+ LogHelper.Warning($"【任务{dto.ID}】{slotsInfo.AdTime:yyyyMMddHHmmss}时刻频点{slotsInfo.FreqDownMHz}共{slotsInfo.Slots.Count}个突发");
|
|
|
+ }
|
|
|
+ if (!listSlotsInfo.Any()) continue;
|
|
|
+ var adFiles = Directory.EnumerateFiles(CapDir, "*.dat", SearchOption.TopDirectoryOnly).Select(p => StringToAdFile(p))
|
|
|
+ .Where(p => p.AdTime == listSlotsInfo.First().AdTime);
|
|
|
+ if (!adFiles.Any())
|
|
|
+ {
|
|
|
+ LogHelper.Warning($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻找不到原始AD文件,跳过此组文件");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ var first = listSlotsInfo.First();
|
|
|
+ var sigs = listSlotsInfo.Select(p => new DDCSig() { FreqDownHz = (int)(p.FreqDownMHz * 1e6), Mult = (int)first.Multi, Slots = p });
|
|
|
+ List<DDCFile> chDDCFiles = new List<DDCFile>();//同一个时刻多个频点多个通道的DDC数据
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻DDC处理开始...");
|
|
|
+ Parallel.ForEach(adFiles, adFile =>
|
|
|
+ {
|
|
|
+
|
|
|
+ //227=变频器频点255-(140-112))
|
|
|
+ var ddcRes = DDCHelper.DDC(adFile.File, adFile.AdTime, adFile.ChNo, (long)(first.FsampleM * 1e6), (long)(227 * 1e6), DdcDir, sigs);
|
|
|
+ chDDCFiles.AddRange(StringToDDCFile(ddcRes));
|
|
|
+ if (!Debugger.IsAttached)
|
|
|
+ File.Delete(adFile.File);//删除AD文件
|
|
|
+ });
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻DDC处理完成");
|
|
|
+ if (!chDDCFiles.Any())
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻DDC处理无结果");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ var groupDDCFiles = chDDCFiles.GroupBy(p => p.FreqDownMHz);
|
|
|
+ foreach (var group in groupDDCFiles)
|
|
|
+ {
|
|
|
+ //group:同一个时刻同一个频点的多个通道数据
|
|
|
+ var capTime = group.First().AdTime;
|
|
|
+ var ch0File = group.Where(p => p.ChNo == 0).FirstOrDefault();
|
|
|
+ var ch1File = group.Where(p => p.ChNo == 1).FirstOrDefault();
|
|
|
+ var ch2File = group.Where(p => p.ChNo == 2).FirstOrDefault();
|
|
|
+ if (ch0File == null)
|
|
|
+ {
|
|
|
+ LogHelper.Warning($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻未找到主星信号ch0文件,跳过此组数据");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (ch1File == null)
|
|
|
+ {
|
|
|
+ LogHelper.Warning($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻未找到邻星信号ch1文件,跳过此组数据");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (ch2File == null)
|
|
|
+ {
|
|
|
+ LogHelper.Warning($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻未找到超短信号ch2文件,跳过此组数据");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (cts.IsCancellationRequested) break;
|
|
|
+ string mainFile = await HttpHelper.UploadFileAsync(ch0File.File, baseUrl, token: cts.Token);//主星文件
|
|
|
+ string adja1File = await HttpHelper.UploadFileAsync(ch1File.File, baseUrl, token: cts.Token);//邻1星文件
|
|
|
+ string cdbFile = await HttpHelper.UploadFileAsync(ch2File.File, baseUrl, token: cts.Token);//地面信号文件
|
|
|
+
|
|
|
+
|
|
|
+ var sig = sigs.FirstOrDefault(p => p.FreqDownHz == (int)(group.Key * 1e6));
|
|
|
+ var cgDto = new CpuCgMultiDto()
|
|
|
+ {
|
|
|
+ dtCenter = 0,
|
|
|
+ dtRange = 40000,
|
|
|
+ file1 = mainFile,
|
|
|
+ file2 = adja1File,
|
|
|
+ samplingRate = ch0File.Fs,
|
|
|
+ smpPositions = sig.Slots.Slots.Select(p => new SmpPosition() { TimeSeconds = p.TimeSeconds, smpStart = p.StartPoint, smpCount = p.Len }).ToList(),
|
|
|
+ snrThreshold = 15,
|
|
|
+ };
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星邻星CPU参估开始...");
|
|
|
+ var result1 = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(baseUrl + "DetectCg/CpuCgMultiCalc", cgDto, token: cts.Token);
|
|
|
+ if (result1.code != 200)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星邻星CPU参估出错.{result1.msg}");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星邻星CPU参估完成");
|
|
|
+ cgDto = new CpuCgMultiDto()
|
|
|
+ {
|
|
|
+ dtCenter = 260000,
|
|
|
+ dtRange = 50000,
|
|
|
+ file1 = mainFile,
|
|
|
+ file2 = cdbFile,
|
|
|
+ samplingRate = ch0File.Fs,
|
|
|
+ smpPositions = sig.Slots.Slots.Select(p => new SmpPosition() { TimeSeconds = p.TimeSeconds, smpStart = p.StartPoint, smpCount = p.Len }).ToList(),
|
|
|
+ snrThreshold = 15,
|
|
|
+ };
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星超短CPU参估开始...");
|
|
|
+ var result2 = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(baseUrl + "DetectCg/CpuCgMultiCalc", cgDto, token: cts.Token);
|
|
|
+ if (result2.code != 200)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星超短CPU参估出错.{result2.msg}");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //删除DDC文件
|
|
|
+ File.Delete(ch0File.File);
|
|
|
+ File.Delete(ch1File.File);
|
|
|
+ File.Delete(ch2File.File);
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻主星超短CPU参估完成");
|
|
|
+ var data1 = result1.data;
|
|
|
+ var data2 = result2.data;
|
|
|
+ if (data1.Count != data2.Count || data1.Count != cgDto.smpPositions.Count)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻参估结果个数和检测结果个数不匹配");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ for (int i = 0; i < data1.Count; i++)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ if (cts.IsCancellationRequested) break;
|
|
|
+ X2D1NoParPosDto x21d = new X2D1NoParPosDto()
|
|
|
+ {
|
|
|
+ TaskID = dto.ID,
|
|
|
+ //SigTime = capTime.AddSeconds(data1[i].Smpstart / (double)ch0File.Fs),
|
|
|
+ SigTime = capTime.AddSeconds(data1[i].TimeSeconds),
|
|
|
+ MainCode = MainSatCode,
|
|
|
+ AdjaCode = Adja1SatCode,
|
|
|
+ MainX = MainSatXYZ[0],
|
|
|
+ MainY = MainSatXYZ[1],
|
|
|
+ MainZ = MainSatXYZ[2],
|
|
|
+ AdjaX = Adja1SatXYZ[0],
|
|
|
+ AdjaY = Adja1SatXYZ[1],
|
|
|
+ AdjaZ = Adja1SatXYZ[2],
|
|
|
+ SxDto = PosDtoFactor * data1[i].Dt,
|
|
|
+ SxDfo = data1[i].Df,
|
|
|
+ SxSnr = data1[i].Snr,
|
|
|
+ XdDto = PosDtoFactor * data2[i].Dt,
|
|
|
+ XdDfo = data2[i].Df,
|
|
|
+ XdSnr = data2[i].Snr,
|
|
|
+ SatTxLon = dto.CapLon,
|
|
|
+ SatTxLat = dto.CapLat,
|
|
|
+ FreqDown = ch0File.FreqDownMHz * 1e6,
|
|
|
+ CheckRes = new CheckResDto()
|
|
|
+ {
|
|
|
+ FileName = Path.GetFileName(ch0File.File),
|
|
|
+ SmpStart = sig.Slots.Slots[i].StartPoint,
|
|
|
+ SmpCount = sig.Slots.Slots[i].Len,
|
|
|
+ PosCheckType = EnumPosCheckTypeDto.DAMA,
|
|
|
+ }
|
|
|
+ };
|
|
|
+ var result = await HttpHelper.PostRequestAsync<PosResDto>(baseUrl + "Pos/PosX2D1NoParAsync", x21d);
|
|
|
+ if (result.code != 200)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻时隙位置{data1[i].Smpstart}定位异常.{result.msg}");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ var posRes = result.data;
|
|
|
+ double posLon = posRes.PosLon;
|
|
|
+ double posLat = posRes.PosLat;
|
|
|
+ if (x21d.SxSnr == 0 || x21d.XdSnr == 0)
|
|
|
+ {
|
|
|
+ posLon = 0;
|
|
|
+ posLat = 0;
|
|
|
+ }
|
|
|
+ double[] cdbPos= new double[] { 0, 0, 0 };
|
|
|
+ double[] RefGeod= new double[] { 0, 0, 0 };
|
|
|
+ //GdopHelper.ErrorEllipse2X1D(posLon, posLat, MainSatXYZ, Adja1SatXYZ, cdbPos, RefGeod,);
|
|
|
+
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.Append($"{x21d.SigTime:yyyy}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:MM}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:dd}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:HH}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:mm}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:ss}\t");
|
|
|
+ sb.Append($"{x21d.SigTime:fff}\t");
|
|
|
+ sb.Append($"{x21d.CheckRes.SmpCount * 1000 / ch0File.Fs:D4}\t");//信号持续时间ms
|
|
|
+ sb.Append($"{Convert.ToInt64(group.First().FreqDownMHz * 1e6):D12}\t");//下行频点
|
|
|
+ sb.Append($"{Convert.ToInt64((group.First().FreqDownMHz + 44) * 1e6):D12}\t");//上行频点
|
|
|
+ sb.Append($"{4}\t");//信号样式(暂定有这些1:CPM,2:BPSK,4:QPSK),
|
|
|
+ sb.Append($"{0:D4}\t");//目标序号
|
|
|
+ sb.Append($"res\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(posLon * 1e6):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(posLat * 1e6):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(0 * 1e3):D8}\t");//定位误差km
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.SxDto * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.SxDfo * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.SxSnr * 1e2):D6}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.XdDto * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.XdDfo * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(x21d.XdSnr * 1e2):D6}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(0 * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(0 * 1e2):D10}\t");
|
|
|
+ sb.Append($"{Convert.ToInt64(0 * 1e2):D6}\t");
|
|
|
+ sb.Append($"{0:D8}\t");//长轴
|
|
|
+ sb.Append($"{0:D8}\t");//短轴
|
|
|
+ sb.Append($"{0:D7}\t");//倾角
|
|
|
+ sb.Append($"{data1.Count:D2}\t");//时隙属性
|
|
|
+ sb.Append($"{1}\t");//所属卫星
|
|
|
+ sb.Append($"{950:D3}\t");//置信度
|
|
|
+ sb.Append($"{3}\r\n");//定位体制(星地=3)
|
|
|
+ string resFile = Path.Combine(PosResDir, $"定位结果_{posRes.SigTime:yyyyMMdd}.txt");
|
|
|
+ File.AppendAllText(resFile, sb.ToString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻时隙位置{data1[i].Smpstart}定位异常", ex);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ LogHelper.Info($"【任务{dto.ID}】{capTime:yyyyMMddHHmmss}时刻定位完成");
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ if (!cts.IsCancellationRequested)
|
|
|
+ LogHelper.Error("任务执行出错", ex);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }, cts.Token);
|
|
|
+ }
|
|
|
+ public void Stop()
|
|
|
+ {
|
|
|
+ cts?.Cancel();
|
|
|
+ }
|
|
|
+ private void StopTask(int taskID, EnumTaskStopType type, string stopReason)
|
|
|
+ {
|
|
|
+ Thread.Sleep(2000);
|
|
|
+ if (type == EnumTaskStopType.Properly)
|
|
|
+ {
|
|
|
+ LogHelper.Info($"【任务{taskID}】{stopReason}");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{taskID}】{stopReason}");
|
|
|
+ }
|
|
|
+ TaskStopHandleDto stopDto = new TaskStopHandleDto() { ID = taskID, StopType = type, StopReason = stopReason };
|
|
|
+ var stopResp = HttpHelper.PostRequestAsync(baseUrl + "Task/StopTask", stopDto).Result;
|
|
|
+ if (stopResp.code != 200)
|
|
|
+ {
|
|
|
+ LogHelper.Error($"【任务{taskID}】停止异常.{stopResp.msg}");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private CheckResFile StringToCheckResFile(string file)
|
|
|
+ {
|
|
|
+ //YUFO_252.050MHz_20240409_1398.dat
|
|
|
+ string fileName = Path.GetFileNameWithoutExtension(file).ToUpper();
|
|
|
+ var arr = fileName.Split(new string[] { "_", "MHZ" }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ var dayTime = DateTime.ParseExact(arr[2], "yyyyMMdd", null);
|
|
|
+ CheckResFile res = new CheckResFile()
|
|
|
+ {
|
|
|
+ DayTime = dayTime,
|
|
|
+ File = file,
|
|
|
+ FreqDownMHz = Convert.ToDouble(arr[1]),
|
|
|
+ FlagNo = Convert.ToInt64(arr[3]),
|
|
|
+ };
|
|
|
+ return res;
|
|
|
+ }
|
|
|
+ private AdFile StringToAdFile(string file)
|
|
|
+ {
|
|
|
+ //20240409094240_ADC_ch02.dat
|
|
|
+ var name = Path.GetFileNameWithoutExtension(file).ToUpper();
|
|
|
+ var arr = name.Split(new string[] { "_", "CH" }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ var time = DateTime.ParseExact(arr[0], "yyyyMMddHHmmss", null);
|
|
|
+ AdFile adFile = new AdFile()
|
|
|
+ {
|
|
|
+ File = file,
|
|
|
+ AdTime = time,
|
|
|
+ ChNo = Convert.ToInt32(arr[2]),
|
|
|
+ };
|
|
|
+ return adFile;
|
|
|
+ }
|
|
|
+ public DDCFile StringToDDCFile(string file)
|
|
|
+ {
|
|
|
+ //20240409094240_252.025_C109375_ch0.dat
|
|
|
+ var name = Path.GetFileNameWithoutExtension(file).ToUpper();
|
|
|
+ var arr = name.Split(new string[] { "_", "MHz", "C", "H" }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
+ var time = DateTime.ParseExact(arr[0], "yyyyMMddHHmmss", null);
|
|
|
+ double freqDown = Convert.ToDouble(arr[1]);
|
|
|
+ int fs = Convert.ToInt32(arr[2]);
|
|
|
+ int chNo = Convert.ToInt32(arr[3]);
|
|
|
+ return new DDCFile()
|
|
|
+ {
|
|
|
+ AdTime = time,
|
|
|
+ ChNo = chNo,
|
|
|
+ File = file,
|
|
|
+ FreqDownMHz = freqDown,
|
|
|
+ Fs = fs
|
|
|
+ };
|
|
|
+ }
|
|
|
+ public List<DDCFile> StringToDDCFile(List<string> files)
|
|
|
+ {
|
|
|
+ List<DDCFile> list = new List<DDCFile>();
|
|
|
+ foreach (var item in files)
|
|
|
+ {
|
|
|
+ list.Add(StringToDDCFile(item));
|
|
|
+ }
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|