using DevExpress.Utils.About; using MySql.Data.MySqlClient; using System; using System.Collections.Generic; using System.Globalization; using System.IO; using System.Linq; using System.Security.Policy; using System.Text; using System.Threading; using System.Threading.Tasks; using XdCxRhDw; using XdCxRhDW.Dto; using ZstdSharp.Unsafe; namespace XdCxRhDW.TaskServer.Task { public class X2D1Task : HistoryTaskI { public override void Start(HistoryTaskProcessingDto dto) { IsRuning = true; TaskDto = dto; System.Threading.Tasks.Task.Run(async () => { DateTime preTime = dto.StartTime; while (IsRuning || dto.EndTime.HasValue && dto.EndTime <= DateTime.Now) { string capfile = Path.Combine(dto.CapDir, $"{preTime.ToString(dto.DateDirFormat)}"); var files = Directory.EnumerateFiles(capfile, "*.dat"); var groups = files.Select(f => FileToHistoryFile(f)).GroupBy(m => m.CapTime).OrderBy(m => m.Key); foreach (var item in groups) { if (!IsRuning) { break; } var finfos = item.ToList(); if (finfos.Count < 3) { LogHelper.Info($"历史任务:{dto.ID}采集时刻:{finfos.First().CapTime:yyyy-MM-dd HH:mm:ss}文件数量只有{finfos.Count}个,不满足"); continue; } //超短波信号 var dinfo = finfos.FirstOrDefault(m => m.Ch == 1); if (dinfo == null) { LogHelper.Info($"历史任务:{dto.ID}采集时刻:{finfos.First().CapTime:yyyy-MM-dd HH:mm:ss}未找到超短波信号ch1文件,不满足"); continue; } //主星 var minfo = finfos.FirstOrDefault(m => m.Ch == 2); if (minfo == null) { LogHelper.Info($"历史任务:{dto.ID}采集时刻:{finfos.First().CapTime:yyyy-MM-dd HH:mm:ss}未找到主星信号ch2文件,不满足"); continue; } //邻1 var ninfo = finfos.FirstOrDefault(m => m.Ch == 3); if (ninfo == null) { LogHelper.Info($"历史任务:{dto.ID}采集时刻:{finfos.First().CapTime:yyyy-MM-dd HH:mm:ss}未找到邻星信号ch3文件,不满足"); continue; } try { var txInfos = await GetTxInfoAsync(); var satTx = txInfos.First(t => t.TxType == EnumTxType.Rec); var cdbTx = txInfos.First(t => t.TxType == EnumTxType.Cdb); var refTx = txInfos.First(t => t.TxType == EnumTxType.Ref); //根据信号类型执行检测或参数估计 if (dto.SigType == EnumSigTypeDto.Normal) { var xd = await GPUCalcAsync(minfo.FilePath, dinfo.FilePath, minfo.FsHz, 260000, 40000); var sx = await GPUCalcAsync(minfo.FilePath, ninfo.FilePath, minfo.FsHz, 0, 40000); X2D1NoXlPosDto x2D1 = new X2D1NoXlPosDto() { SigTime = minfo.CapTime, MainCode = minfo.SatId, AdjaCode = ninfo.SatId, SxDto = sx.Dt, XdDto = xd.Dt, SatTxLon = satTx.Lon, SatTxLat = satTx.Lat, CdbTxLon = cdbTx.Lon, CdbTxLat = cdbTx.Lat, RefLon = refTx.Lon, RefLat = refTx.Lat, FreqDown = minfo.FreqHz * 1e-6, FreqUp = dinfo.FreqHz * 1e-6, XdDfo = xd.Df, XdSnr = xd.Snr, SxDfo = sx.Df, SxSnr = sx.Snr, }; await X2D1NoXlAsync(x2D1); } else { var mDetect = await DAMAAsync(dto.DmcType.Value, minfo.FsHz, minfo.FilePath); var dfile = await ToResampleAsync((int)dinfo.FsHz, dinfo.FilePath); var nfile = await ToResampleAsync((int)ninfo.FsHz, ninfo.FilePath); foreach (var deitem in mDetect) { if (!IsRuning) { break; } try { var xd = await CPUCalcAsync(deitem.File1, dfile.File, dfile.OutFsHz, deitem, 260000, 40000); var sx = await CPUCalcAsync(deitem.File1, nfile.File, nfile.OutFsHz, deitem, 0, 40000); X2D1NoXlPosDto x2D1 = new X2D1NoXlPosDto() { SigTime = minfo.CapTime.AddSeconds(deitem.Start / nfile.OutFsHz), MainCode = minfo.SatId, AdjaCode = ninfo.SatId, SxDto = sx.Dt, XdDto = xd.Dt, SatTxLon = satTx.Lon, SatTxLat = satTx.Lat, CdbTxLon = cdbTx.Lon, CdbTxLat = cdbTx.Lat, RefLon = refTx.Lon, RefLat = refTx.Lat, FreqDown = minfo.FreqHz * 1e-6, FreqUp = dinfo.FreqHz * 1e-6, XdDfo = xd.Df, XdSnr = xd.Snr, SxDfo = sx.Df, SxSnr = sx.Snr, }; await X2D1NoXlAsync(x2D1); } catch (Exception ex) { LogHelper.Info($"历史任务:{dto.ID}异常:{ex.Message}"); continue; } } } } catch (Exception ex) { LogHelper.Info($"执行历史任务:{dto.ID}异常:{ex.Message}"); continue; } } preTime = preTime.AddHours(1); } IsRuning = false; LogHelper.Info($"历史任务:{dto.ID}已结束!"); }); } private async Task X2D1NoXlAsync(X2D1NoXlPosDto x2D1) { var result = await HttpHelper.PostRequestAsync(baseUrl + "Pos/PosX2D1NoXlAsync", x2D1); if (result.code != 200) { return false; } return true; } private async Task> GetTxInfoAsync() { List infos = new List(); var result = await HttpHelper.GetRequestAsync<(TxInfo recTx, TxInfo cdbTx, TxInfo cxTx, TxInfo refLoc)>(baseUrl + "Tx/GetTxInfoAsync"); if (result.code != 200) { infos.Add(new TxInfo() { TxType = EnumTxType.Rec }); infos.Add(new TxInfo() { TxType = EnumTxType.Cdb }); infos.Add(new TxInfo() { TxType = EnumTxType.Cx }); infos.Add(new TxInfo() { TxType = EnumTxType.Ref }); LogHelper.Error($"历史任务获取天线信息失败"); return infos; } infos.Add(result.data.recTx==null? new TxInfo() { TxType = EnumTxType.Rec }: result.data.recTx); infos.Add(result.data.cdbTx == null ? new TxInfo() { TxType = EnumTxType.Cdb } : result.data.cdbTx); infos.Add(result.data.cxTx == null ? new TxInfo() { TxType = EnumTxType.Cx } : result.data.cxTx); infos.Add(result.data.refLoc == null ? new TxInfo() { TxType = EnumTxType.Ref } : result.data.refLoc); return infos; } /// /// 获取采集文件信息 /// /// /// private HistoryFile FileToHistoryFile(string filePath) { //读取采集文件 //2024_01_31_10_01_51_000000000_ch11_-1_＿Nxx.xxxxxx_Exx.xxxxxx_xxxxx.xxxHz_xxx.xxxMHz_ch1_xd1.dat HistoryFile historyFile = new HistoryFile(); historyFile.FilePath = filePath; var fileName = Path.GetFileNameWithoutExtension(filePath); var strs = fileName.Split(new string[] { "_", "MHz", "Hz", "ch" }, StringSplitOptions.RemoveEmptyEntries); //采集时间 var datestr = string.Join("_", strs.Take(6)); DateTime dateTime; bool istime = DateTime.TryParseExact(datestr, "yyyy_MM_dd_HH_mm_ss", null, DateTimeStyles.None, out dateTime); if (!istime) return historyFile; historyFile.CapTime = dateTime; //采集通道 var chstr = strs.Skip(strs.Length - 2).Take(1).First(); int ch; int.TryParse(chstr, out ch); //采集频点 var freqstr = strs.Skip(strs.Length - 3).Take(1).First(); double freqMHz; double.TryParse(freqstr, out freqMHz); //采样率 var fsstr = strs.Skip(strs.Length - 4).Take(1).First(); double fsHz; double.TryParse(fsstr, out fsHz); historyFile.FreqHz = freqMHz * 1e6; historyFile.Ch = ch; historyFile.FsHz = fsHz; if (ch > 1) { historyFile.SatId = GetSatId(historyFile.FreqHz); } return historyFile; } } }