DataSimulation/DataSimulation.Repostory/SimulationCache.cs

using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DataSimulation.Repostory.EFContext;
using DataSimulation.Repostory.Model;

namespace DataSimulation.Repostory
{
    public static class SimulationCache
    {
        /// <summary>
        /// 获取数据库所有航迹
        /// </summary>
        /// <returns></returns>
        public static async Task<List<SimulationInfo>> GetAllAsync()
        {
            try
            {
                List<SimulationInfo> list = new List<SimulationInfo>();
                var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
                if (!Directory.Exists(dir)) return list;
                var yearDirs = Directory.EnumerateDirectories(dir).OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name));//年目录,倒叙排列
                foreach (var yearDir in yearDirs)
                {
                    //每一天的db文件,倒序排列
                    var dayFiles = Directory.EnumerateFiles(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, yearDir), "*.db").OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name.Substring(0, 4)));
                    foreach (var dayFile in dayFiles)
                    {
                        using (SimulationPartContext db = SimulationPartContext.GetContext(dayFile))
                        {
                            list.AddRange(await db.SimulationInfos.ToListAsync());
                        }
                    }
                }
                return list;
            }
            catch (Exception ex)
            {
                Serilog.Log.Error(ex, "加载仿真航迹信息异常");
                return null;
            }
        }
        /// <summary>
        /// 根据编号查询航迹点
        /// </summary>
        /// <param name="simulationId">航迹编号</param>
        /// <param name="createTime">航迹创建时间</param>
        /// <returns></returns>
        public static async Task<List<SimulationPonit>> GetAllByIDAsync(long simulationId, DateTime createTime)
        {
            try
            {
                List<SimulationPonit> list = new List<SimulationPonit>();
                var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
                if (!Directory.Exists(dir)) return list;
                using (SimulationPartContext db = SimulationPartContext.GetContext(createTime))
                {
                    var points = await db.SimulationPonits.Where(s => s.SimulationId == simulationId).ToListAsync();
                    list.AddRange(points);
                }
                return list;
            }
            catch (Exception ex)
            {
                Serilog.Log.Error(ex, $"查询仿真航迹{simulationId}信息异常");
                return null;
            }
        }


    }
}