using IStation.Untity;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.DataProvider
|
{
|
/// <summary>
|
/// json仓库
|
/// </summary>
|
public class JsonStore
|
{
|
private static DateTime _debugDay=DateTime.MinValue;
|
private static List<List<DebugRecord>> _dayRecordList = null;//数据日缓存
|
|
//获取缓存
|
private static List<DebugRecord> GetDebugCache(DateTime dt)
|
{
|
var debugDay = dt.Date;
|
if (debugDay != _debugDay)
|
{
|
_debugDay = debugDay;
|
_dayRecordList = new List<List<DebugRecord>>();
|
var testDataFolder = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, ConfigHelper.TestDataFolder, _debugDay.Day.ToString());
|
if (!Directory.Exists(testDataFolder))
|
return default;
|
var directInfo = new DirectoryInfo(testDataFolder);
|
var files = directInfo.GetFiles();
|
if (files == null || files.Count() < 1)
|
return default;
|
foreach (var filePath in files)
|
{
|
var str = File.ReadAllText(filePath.FullName);
|
if (string.IsNullOrEmpty(str))
|
return default;
|
var data = JsonHelper.Json2Object<List<DebugRecord>>(str);
|
if (data == null || data.Count < 1)
|
continue;
|
_dayRecordList.Add(data);
|
}
|
}
|
|
var list = new List<DebugRecord>();
|
foreach (var records in _dayRecordList)
|
{
|
var record = records.FindLast(x =>
|
{
|
var dt1 = Convert.ToDateTime(x.DataTime);
|
var dt2 = new DateTime(dt.Year, dt.Month, dt.Day, dt1.Hour, dt1.Minute, dt1.Second);
|
return dt2 < dt;
|
});
|
list.Add(record);
|
}
|
return list.Where(x => x != null).ToList();
|
}
|
|
/// <summary>
|
/// 获取当前记录
|
/// </summary>
|
public static List<SrcRecord> GetCurrentRecord(DateTime dt)
|
{
|
var debugList = GetDebugCache(dt);
|
if (debugList == null || debugList.Count < 1)
|
return default;
|
|
|
var srcList = new List<SrcRecord>();
|
foreach (var debugRecord in debugList)
|
{
|
if (!string.IsNullOrEmpty(debugRecord.ObjectId))
|
{
|
var srcRecord = new SrcRecord();
|
srcRecord.TagName = debugRecord.ObjectId;
|
srcRecord.DataTime = debugRecord.DataTime;
|
srcRecord.DataValue = debugRecord.DataValue;
|
srcList.Add(srcRecord);
|
}
|
}
|
return srcList;
|
}
|
|
|
|
|
|
}
|
}
|
