XdCxRhDW54/Service/X3TaskServer54/Service/TaskService.cs

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 System.Web.Http.Results;
using XdCxRhDW.Dto;

namespace X3TaskServer54.Service
{
    //业务逻辑处理类
    public class TaskService
    {
        private readonly string baseUrl;
        CancellationTokenSource cts;
        string DetectDir;
        string CapDir;
        string PosResDir;
        string StateDir;
        int MainSatCode, Adja1SatCode, Adja2SatCode;
        double[] MainSatXYZ, Adja1SatXYZ, Adja2SatXYZ;
        int PosDtoFactor;
        double DtoErrus;
        double EphErrm;
        public TaskService()
        {
            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();
            PosResDir = ConfigurationManager.AppSettings["PosResDir"].Trim();
            StateDir = ConfigurationManager.AppSettings["StateRptDir"].Trim();
            var PosDtoFactorstr = ConfigurationManager.AppSettings["PosDtoFactor"].Trim();
            int.TryParse(PosDtoFactorstr, out PosDtoFactor);
            if (PosDtoFactor == 0) PosDtoFactor = 1;
            var DtoErrusstr = ConfigurationManager.AppSettings["DtoErrus"].Trim();
            double.TryParse(DtoErrusstr, out DtoErrus);
            var EphErrmstr = ConfigurationManager.AppSettings["EphErrm"].Trim();
            double.TryParse(EphErrmstr, out EphErrm);
        }
        public void StartAsync(X3NoRefTaskHandleDto dto)
        {
            cts = new CancellationTokenSource();
            Task.Run(async () =>
            {
                await LogHelper.Info($"【任务{dto.ID}】开始执行...");
                await LogHelper.Info($"【任务{dto.ID}】检测结果目录[{DetectDir}]");
                await LogHelper.Info($"【任务{dto.ID}】AD采集目录[{CapDir}]");
                await LogHelper.Info($"【任务{dto.ID}】状态上报输出目录[{StateDir}]");
                //点击定位平台右上角查看接口可以在浏览器中查看平台提供的所有接口详细信息
                while (!cts.IsCancellationRequested)
                {
                    try
                    {
                        #region 第1步,读取需要的配置信息
                        if (!Directory.Exists(DetectDir))
                        {
                            await StopTask(dto.ID, EnumTaskStopType.Error, $"检测结果目录[{DetectDir}]不存在");
                            return;
                        }
                        if (!Directory.Exists(CapDir))
                        {
                            await StopTask(dto.ID, EnumTaskStopType.Error, $"AD采集目录[{CapDir}]不存在");
                            return;
                        }
                        Directory.CreateDirectory("DdcDir");
                        Directory.CreateDirectory(PosResDir);
                        Directory.CreateDirectory(StateDir);
                        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
                        {
                            await StopTask(dto.ID, EnumTaskStopType.Error, $"任务处理服务配置文件卫星信息解析出错");
                            return;
                        }
                        #endregion

                        #region 第2步,扫描检测结果目录
                        //同一个AD文件得到的不同频点的检测文件FlagNo相同
                        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())
                        {
                            await LogHelper.Info($"【任务{dto.ID}】等待扫描文件...");
                            await Task.Delay(10000, cts.Token);
                        }

                        foreach (var groupFile in groupFiles)//每一组文件代表同一个时刻的,gourpFile时相同时刻的不同频点的文件
                        {
                            if (cts.IsCancellationRequested) break;
                            await LogHelper.Info($"【任务{dto.ID}】正在解析序号为{groupFile.First().FlagNo}的检测引导文件");
                            List<SlotsInfo> listSlotsInfo = new List<SlotsInfo>();//多个频点的时隙结果
                            int idx = 0;
                            DateTime adTime = DateTime.MinValue;
                            foreach (var item in groupFile)
                            {
                                if (cts.IsCancellationRequested) break;
                                var slotsInfo = SlotHelper.GetFileSlots(item.File);//某个频点的所有时隙
                                adTime = slotsInfo.AdTime;
                                if (idx == 0)
                                    await LogHelper.Info($"【任务{dto.ID}】序号为{groupFile.First().FlagNo}的检测引导文件对应采集时刻{slotsInfo.AdTime:yyyyMMddHHmmss}");
                                idx++;
                                if (slotsInfo.Slots.Any())
                                    listSlotsInfo.Add(slotsInfo);
                                else
                                    File.Delete(item.File);//删除没有信号的检测引导文件
                            }
                            var adFiles = Directory.EnumerateFiles(CapDir, "*.dat", SearchOption.TopDirectoryOnly).Select(p => StringToAdFile(p))
                                .Where(p => p.AdTime == adTime);
                            if (!listSlotsInfo.Any())
                            {
                                //没有突发信号，删除所有对应时刻的采集文件
                                foreach (var item in adFiles)
                                {
                                    File.Delete(item.File);
                                }
                                continue;
                            }

                            if (adFiles.Count() != 3)
                            {
                                await LogHelper.Warning($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻原始AD文件个数不为3,跳过此组文件");
                                //AD数据不全，删除所有对应时刻的采集文件
                                foreach (var item in adFiles)
                                {
                                    File.Delete(item.File);
                                }
                                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数据
                            await LogHelper.Info($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻3路AD文件开始DDC处理开始,共{sigs.Count()}个频点...");
                            Stopwatch sw = new Stopwatch();
                            sw.Start();
                            var listTask = new List<Task>();
                            foreach (var adFile in adFiles)
                            {
                                var task = Task.Run(() =>
                                {
                                    var ddcRes = DDCHelper.DDC(adFile.File, adFile.AdTime, adFile.ChNo, (long)(first.FsampleM * 1e6), (long)(227 * 1e6), "DdcDir", sigs);
                                    chDDCFiles.AddRange(StringToDDCFile(ddcRes));
                                }, cts.Token);
                                listTask.Add(task);
                            }
                            await Task.WhenAll(listTask);
                            if (cts.IsCancellationRequested) break;
                            sw.Stop();
                            await LogHelper.Info($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻3路AD文件DDC处理完成,耗时{sw.ElapsedMilliseconds}ms");
                            if (!chDDCFiles.Any())
                            {
                                await LogHelper.Error($"【任务{dto.ID}】{listSlotsInfo.First().AdTime:yyyyMMddHHmmss}时刻3路AD文件DDC处理无结果");
                                continue;
                            }
                            var groupDDCFiles = chDDCFiles.GroupBy(p => p.FreqDownMHz);
                            listTask.Clear();
                            foreach (var group in groupDDCFiles)
                            {
                                //group:同一个时刻同一个频点的多个通道数据
                                var task = Task.Run(async () =>
                                {
                                    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)
                                    {
                                        await LogHelper.Warning($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-未找到主星信号ch0文件,跳过此组数据");
                                        return;
                                    }
                                    if (ch1File == null)
                                    {
                                        await LogHelper.Warning($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-未找到邻1星信号ch1文件,跳过此组数据");
                                        return;
                                    }
                                    if (ch2File == null)
                                    {
                                        await LogHelper.Warning($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-未找到邻2星信号ch2文件,跳过此组数据");
                                        return;
                                    }
                                    var sig = sigs.FirstOrDefault(p => p.FreqDownHz == (int)(group.Key * 1e6));
                                    if (cts.IsCancellationRequested) return;
                                    await LogHelper.Info($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-CPU参估开始,共{sig.Slots.Slots.Count}个突发...");
                                    sw.Start();
                                    string mainFile = await HttpHelper.UploadFileAsync(ch0File.File, baseUrl, token: cts.Token);//主星文件
                                    string adja1File = await HttpHelper.UploadFileAsync(ch1File.File, baseUrl, token: cts.Token);//邻1星文件
                                    string adja2File = await HttpHelper.UploadFileAsync(ch2File.File, baseUrl, token: cts.Token);//邻2星文件
                                    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,
                                    };
                                    var result1 = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(baseUrl + "DetectCg/CpuCgMultiCalc", cgDto, token: cts.Token);
                                    if (result1.code != 200)
                                    {
                                        await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-主星邻1星CPU参估出错.{result1.msg}");
                                        return;
                                    }
                                    cgDto = new CpuCgMultiDto()
                                    {
                                        dtCenter = 0,
                                        dtRange = 40000,
                                        file1 = mainFile,
                                        file2 = adja2File,
                                        samplingRate = ch0File.Fs,
                                        smpPositions = sig.Slots.Slots.Select(p => new SmpPosition() { TimeSeconds = p.TimeSeconds, smpStart = p.StartPoint, smpCount = p.Len }).ToList(),
                                        snrThreshold = 15,
                                    };
                                    var result2 = await HttpHelper.PostRequestAsync<List<CpuCgResDto>>(baseUrl + "DetectCg/CpuCgMultiCalc", cgDto, token: cts.Token);
                                    sw.Stop();
                                    if (result2.code != 200)
                                    {
                                        await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-主星邻2星CPU参估出错.{result2.msg}");
                                        return;
                                    }
                                    await LogHelper.Info($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-CPU参估完成,耗时{sw.ElapsedMilliseconds}ms");
                                    var data1 = result1.data;
                                    var data2 = result2.data;
                                    if (data1.Count != data2.Count || data1.Count != cgDto.smpPositions.Count)
                                    {
                                        await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-参估结果个数和检测结果个数不匹配");
                                        return;
                                    }
                                    var signaldto = new SignalProcDto()
                                    {
                                        File = mainFile,
                                        Fs = ch0File.Fs,
                                        Smps = cgDto.smpPositions,
                                    };
                                    var signalResult = await HttpHelper.PostRequestAsync<List<SignalProcResDto>>(baseUrl + "DetectCg/SignalProc", signaldto);
                                    if (signalResult.code != 200)
                                    {
                                        await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-主星信号识别出错.{signalResult.msg}");
                                        return;

                                    }
                                    sw.Start();
                                    for (int i = 0; i < data1.Count; i++)
                                    {
                                        try
                                        {
                                            if (cts.IsCancellationRequested) break;
                                            X3TwoDtoNoParPosDto x3 = new X3TwoDtoNoParPosDto()
                                            {
                                                TaskID = dto.ID,
                                                //SigTime = adTime.AddSeconds(data1[i].Smpstart / (double)ch0File.Fs),
                                                SigTime = adTime.AddSeconds(data1[i].TimeSeconds),
                                                MainCode = MainSatCode,
                                                Adja1Code = Adja1SatCode,
                                                Adja2Code = Adja2SatCode,
                                                MainX = MainSatXYZ[0],
                                                MainY = MainSatXYZ[1],
                                                MainZ = MainSatXYZ[2],
                                                Adja1X = Adja1SatXYZ[0],
                                                Adja1Y = Adja1SatXYZ[1],
                                                Adja1Z = Adja1SatXYZ[2],
                                                Adja2X = Adja2SatXYZ[0],
                                                Adja2Y = Adja2SatXYZ[1],
                                                Adja2Z = Adja2SatXYZ[2],
                                                Dto1 = PosDtoFactor * data1[i].Dt,
                                                Dfo1 = data1[i].Df,
                                                Snr1 = data1[i].Snr,
                                                Dto2 = PosDtoFactor * data2[i].Dt,
                                                Dfo2 = data2[i].Df,
                                                Snr2 = data2[i].Snr,
                                                SatTxLon = dto.CapLon,
                                                SatTxLat = dto.CapLat,
                                                FreqDown = ch0File.FreqDownMHz * 1e6,
                                                FreqUp = (ch0File.FreqDownMHz + 44) * 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/PosX3TwoDtoNoParAsync", x3);
                                            if (result.code != 200)
                                            {
                                                await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-时隙位置{data1[i].Smpstart}定位异常.{result.msg}");
                                            }
                                            else
                                            {
                                                var posRes = result.data;
                                                double posLon = posRes.PosLon;
                                                double posLat = posRes.PosLat;
                                                if (x3.Snr1 == 0 || x3.Snr2 == 0)
                                                {
                                                    posLon = 0;
                                                    posLat = 0;
                                                }
                                                ErrEllipseResDto errRes = new ErrEllipseResDto();
                                                if (posLon != 0 && posLat != 0 && posLon != 999 && posLat != 999)
                                                {
                                                    var errDto = new ErrEllipseX3NoRefDto()
                                                    {
                                                        PosLon = posLon,
                                                        PosLat = posLat,
                                                        MainX = MainSatXYZ[0],
                                                        MainY = MainSatXYZ[1],
                                                        MainZ = MainSatXYZ[2],
                                                        Adja1X = Adja1SatXYZ[0],
                                                        Adja1Y = Adja1SatXYZ[1],
                                                        Adja1Z = Adja1SatXYZ[2],
                                                        Adja2X = Adja2SatXYZ[0],
                                                        Adja2Y = Adja2SatXYZ[1],
                                                        Adja2Z = Adja2SatXYZ[2],
                                                        DtoErrus = DtoErrus,
                                                        EphErr = EphErrm,
                                                        OutputErrPoint = false,
                                                    };
                                                    var errResRsp = await HttpHelper.PostRequestAsync<ErrEllipseResDto>(baseUrl + "Ellipse/X3TwoDtoNoRef", errDto);
                                                    if (errResRsp.code != 200)
                                                    {
                                                        await LogHelper.Error(errResRsp.msg);
                                                    }
                                                    else
                                                    {
                                                        errRes = errResRsp.data;
                                                    }
                                                }
                                                StringBuilder sb = new StringBuilder();
                                                sb.Append($"{x3.SigTime:yyyy}\t");
                                                sb.Append($"{x3.SigTime:MM}\t");
                                                sb.Append($"{x3.SigTime:dd}\t");
                                                sb.Append($"{x3.SigTime:HH}\t");
                                                sb.Append($"{x3.SigTime:mm}\t");
                                                sb.Append($"{x3.SigTime:ss}\t");
                                                sb.Append($"{x3.SigTime:fff}\t");
                                                sb.Append($"{x3.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($"{GetSignalType(signalResult.data[i].ModType)}\t");//信号样式(暂定有这些1:CPM,2:BPSK,4:QPSK,9:其他)，
                                                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(x3.Dto1 * 1e2):D10}\t");
                                                sb.Append($"{Convert.ToInt64(x3.Dfo1 * 1e2):D10}\t");
                                                sb.Append($"{Convert.ToInt64(x3.Snr1 * 1e2):D6}\t");
                                                sb.Append($"{Convert.ToInt64(x3.Dto2 * 1e2):D10}\t");
                                                sb.Append($"{Convert.ToInt64(x3.Dfo2 * 1e2):D10}\t");
                                                sb.Append($"{Convert.ToInt64(x3.Snr2 * 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($"{100:D3}\t");//置信度
                                                sb.Append($"{1}\t");//定位体制（0未知,1高轨多星，2高低轨，3星地,4星座）
                                                sb.Append($"{(long)signalResult.data[i].Rate:D12}");//符号速率bps
                                                sb.Append("\r\n");
                                                string resFile = Path.Combine(PosResDir, $"高轨三星定位结果_{posRes.SigTime:yyyyMMdd}.txt");
                                                lock (this)
                                                {
                                                    File.AppendAllText(resFile, sb.ToString());
                                                }
                                            }
                                        }
                                        catch (Exception ex)
                                        {
                                            await LogHelper.Error($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-时隙位置{data1[i].Smpstart}定位异常", ex);
                                        }
                                    }
                                    sw.Stop();
                                    await LogHelper.Info($"【任务{dto.ID}】{adTime:yyyyMMddHHmmss}时刻-信号{group.Key}MHz-定位完成,耗时{sw.ElapsedMilliseconds}ms");
                                    //删除DDC文件
                                    File.Delete(ch0File.File);
                                    File.Delete(ch1File.File);
                                    File.Delete(ch2File.File);
                                }, cts.Token);
                                listTask.Add(task);
                            }
                            await Task.WhenAll(listTask);
                        }
                        #endregion
                    }
                    catch (TaskCanceledException ex)
                    {
                        await LogHelper.Warning($"【任务{dto.ID}】处理结束,用户手动终止", ex.InnerException);
                    }
                    catch (Exception ex)
                    {
                        if (ex.InnerException != null && ex.InnerException.GetType() == typeof(TaskCanceledException))
                            await LogHelper.Warning($"【任务{dto.ID}】处理结束,用户手动终止", ex.InnerException);
                        else
                            await LogHelper.Error($"【任务{dto.ID}】任务执行出错", ex);
                        continue;
                    }
                }
            }, cts.Token);
        }
        public void Stop()
        {
            cts?.Cancel();
        }
        private int GetSignalType(EnumSignalTypeDto modType)
        {
            //1:CPM,2:BPSK,4:QPSK,9:其他
            int signalType = 9;
            if (modType == EnumSignalTypeDto.BPSK)
            {
                signalType = 2;
            }
            else if (modType == EnumSignalTypeDto.QPSK)
            {
                signalType = 4;
            }
            return signalType;
        }
        private async Task StopTask(int taskID, EnumTaskStopType type, string stopReason)
        {
            cts?.Cancel();
            await Task.Delay(2000);
            if (type == EnumTaskStopType.Properly)
            {
                await LogHelper.Info($"【任务{taskID}】{stopReason}");
            }
            else
            {
                await LogHelper.Error($"【任务{taskID}】{stopReason}");
            }
            TaskStopHandleDto stopDto = new TaskStopHandleDto() { ID = taskID, StopType = type, StopReason = stopReason };
            var stopResp = await HttpHelper.PostRequestAsync(baseUrl + "Task/StopTask", stopDto);
            if (stopResp.code != 200)
            {
                await 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;
        }
    }
}