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<JsonData> _dayRecordList = null;//数据日缓存
|
|
//获取缓存
|
private static List<JsonData> GetDebugCache(DateTime dt)
|
{
|
var debugDay = dt.Date;
|
if (debugDay != _debugDay)
|
{
|
_debugDay = debugDay;
|
_dayRecordList = new List<JsonData>();
|
var fullFileName = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, ConfigHelper.TestDataFolder, _debugDay.Day.ToString() + ".txt");
|
|
System.Text.Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance);
|
var allLines = File.ReadAllLines(fullFileName,Encoding.GetEncoding("GB2312"));
|
foreach (var line in allLines)
|
{
|
if (string.IsNullOrEmpty(line))
|
continue;
|
var timeIndex = line.IndexOf(",");
|
var timeStr = line.Substring(0, timeIndex);
|
var time = DateTime.Parse(timeStr);
|
var jsonIndex = line.IndexOf("|");
|
var jsonStr = line.Substring(jsonIndex + 1);
|
jsonStr = jsonStr.Substring(0, jsonStr.Length - 1);
|
var jsonList = JsonConvert.DeserializeObject<List<DebugRecord>>(jsonStr);
|
_dayRecordList.Add(new JsonData(new DateTime(_debugDay.Year,_debugDay.Month,_debugDay.Day,time.Hour,time.Minute,time.Second), jsonList));
|
}
|
_dayRecordList = _dayRecordList.OrderBy(x => x.DebugTime).ToList();
|
}
|
return _dayRecordList;
|
}
|
|
/// <summary>
|
/// 获取当前记录
|
/// </summary>
|
public static List<SrcRecord> GetCurrentRecord(DateTime dt)
|
{
|
var debugList = GetDebugCache(dt);
|
if (debugList == null || debugList.Count < 1)
|
return default;
|
|
var debugLast = debugList.FindLast(x => x.DebugTime < dt);
|
if (debugLast == null)
|
return default;
|
var srcList = new List<SrcRecord>();
|
foreach (var debugRecord in debugLast.DebugRecords)
|
{
|
if (!string.IsNullOrEmpty(debugRecord.SignId))
|
{
|
var srcRecord = new SrcRecord();
|
srcRecord.TagName = debugRecord.SignId;
|
srcRecord.DataTime = debugRecord.SrcTime;
|
srcRecord.DataValue = debugRecord.SrcValue;
|
srcList.Add(srcRecord);
|
}
|
}
|
return srcList;
|
}
|
|
|
|
|
|
}
|
}
|
