using System;
|
using System.Text;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Runtime.Serialization;
|
using System.Linq;
|
using System.IO;
|
using System.Runtime.InteropServices;
|
using System.Xml.Linq;
|
using System.Net.Sockets;
|
|
namespace IStation.DAL.LocalFile
|
{
|
/// <summary>
|
/// 监测月数据集
|
/// </summary>
|
public partial class MonitorDataSet : IDAL.IMonitorDataSet
|
{
|
//监测数据集概要实例
|
MonitorDataSetSummary _monitorDataSetSummary = new MonitorDataSetSummary();
|
|
#region Path
|
|
/// <summary>
|
/// 查询文件路径
|
/// </summary>
|
private string GetMonitorDataFolder(long projectId, long sceneId)
|
{
|
return MonitorDataSetConfig.GetMonitorDataFolder(projectId, sceneId);
|
}
|
|
/// <summary>
|
/// 查询数据集文件夹路径
|
/// </summary>
|
private string GetMonitorDataSetFolder(long projectId, long sceneId, long monitorPointId, int year, int month)
|
{
|
return MonitorDataSetConfig.GetMonitorDataSetFolder(projectId, sceneId, monitorPointId, year, month);
|
}
|
|
/// <summary>
|
/// 查询信号文件路径
|
/// </summary>
|
private bool GetSignalRecordPacketFile(long projectId, long sceneId, long monitorPointId, long signaId, int year, int month, out string filePath)
|
{
|
filePath = MonitorDataSetConfig.GetSignalRecordFile(projectId, sceneId, monitorPointId, signaId, year, month);
|
if (!File.Exists(filePath))
|
return false;
|
return true;
|
}
|
|
#endregion
|
|
#region Get
|
|
#region MonitorDataSet
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public List<Model.MonitorDataSet> GetMonitorDataSet(long projectId, long sceneId)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
|
var rootFolder = this.GetMonitorDataFolder(projectId, sceneId);
|
var dateFolderInfos = this.GetDateFolderInfos(rootFolder);
|
if (dateFolderInfos == null || dateFolderInfos.Count() < 1)
|
return default;
|
|
var MonitorDataSetCount = _monitorDataSetSummary.GetMonitorDataSetCount(projectId, sceneId);
|
var MonitorDataSetList = new List<Model.MonitorDataSet>(MonitorDataSetCount);
|
foreach (var dateFolderInfo in dateFolderInfos)
|
{
|
var montiorDataSetFolderInfos = this.GetMonitorDataSetFolderInfos(dateFolderInfo);
|
if (montiorDataSetFolderInfos == null || montiorDataSetFolderInfos.Count < 1)
|
continue;
|
|
foreach (var montiorDataSetFolderInfo in montiorDataSetFolderInfos)
|
{
|
var monitorPointId = montiorDataSetFolderInfo.MonitorPointId;
|
var year = montiorDataSetFolderInfo.Year;
|
var month = montiorDataSetFolderInfo.Month;
|
var MonitorDataSet = GetMonitorDataSet(projectId, sceneId, monitorPointId, year, month);
|
if (MonitorDataSet != null)
|
MonitorDataSetList.Add(MonitorDataSet);
|
}
|
}
|
return MonitorDataSetList;
|
}
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public List<Model.MonitorDataSet> GetMonitorDataSet(long projectId, long sceneId, long monitorPointId)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
|
var rootFolder = this.GetMonitorDataFolder(projectId, sceneId);
|
var dateFolderInfos = this.GetDateFolderInfos(rootFolder);
|
if (dateFolderInfos == null || dateFolderInfos.Count() < 1)
|
return default;
|
|
var MonitorDataSetList = new List<Model.MonitorDataSet>(dateFolderInfos.Count());
|
foreach (var dateFolderInfo in dateFolderInfos)
|
{
|
var montiorDataSetFolderInfos = this.GetMonitorDataSetFolderInfos(dateFolderInfo);
|
if (montiorDataSetFolderInfos == null || montiorDataSetFolderInfos.Count < 1)
|
continue;
|
var montiorDataSetFolderInfo = montiorDataSetFolderInfos.Find(x => x.MonitorPointId == monitorPointId);
|
if (montiorDataSetFolderInfo == null)
|
continue;
|
var year = montiorDataSetFolderInfo.Year;
|
var month = montiorDataSetFolderInfo.Month;
|
var MonitorDataSet = GetMonitorDataSet(projectId, sceneId, monitorPointId, year, month);
|
if (MonitorDataSet != null)
|
MonitorDataSetList.Add(MonitorDataSet);
|
}
|
|
return MonitorDataSetList;
|
}
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public Model.MonitorDataSet GetMonitorDataSet(long projectId, long sceneId, long monitorPointId, int year, int month)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
|
var monitorDataSetFolder = this.GetMonitorDataSetFolder(projectId, sceneId, monitorPointId, year, month);
|
var signalRecordPacketFileInfos = this.GetSignalRecordPackFileInfos(monitorDataSetFolder, year, month);
|
if (signalRecordPacketFileInfos == null || signalRecordPacketFileInfos.Count < 1)
|
return default;
|
|
var signalRecordPacketCount = _monitorDataSetSummary.GetSignalRecordPacketCount(projectId, sceneId, monitorPointId, year, month);
|
if (signalRecordPacketCount < 1)
|
return default;
|
|
var MonitorDataSet = new Model.MonitorDataSet();
|
MonitorDataSet.MonitorPointId = monitorPointId;
|
MonitorDataSet.Year = year;
|
MonitorDataSet.Month = month;
|
MonitorDataSet.PacketList = new List<Model.SignalRecordPacket>(signalRecordPacketCount);
|
|
foreach (var signalRecordFile in signalRecordPacketFileInfos)
|
{
|
var signalId = signalRecordFile.SignalId;
|
var signalRecordPacket = GetSignalRecordPacket(projectId, sceneId, monitorPointId, signalId, year, month);
|
if (signalRecordPacket != null)
|
{
|
MonitorDataSet.PacketList.Add(signalRecordPacket);
|
}
|
}
|
|
return MonitorDataSet;
|
}
|
|
#endregion
|
|
#region SignalRecordPacket
|
|
/// <summary>
|
/// 查询信号记录包
|
/// </summary>
|
public Model.SignalRecordPacket GetSignalRecordPacket(long projectId, long sceneId, long monitorPointId, long signalId)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
var rootFolder = this.GetMonitorDataFolder(projectId, sceneId);
|
var dateFolderInfos = this.GetDateFolderInfos(rootFolder);
|
if (dateFolderInfos == null || dateFolderInfos.Count() < 1)
|
return default;
|
|
var signalRecordCount = _monitorDataSetSummary.GetSignalRecordCount(projectId, sceneId, monitorPointId, signalId);
|
if (signalRecordCount < 1)
|
return default;
|
|
var signalRecordPacket = new Model.SignalRecordPacket();
|
signalRecordPacket.SignalId = signalId;
|
signalRecordPacket.RecordList = new List<Model.SignalRecord>(signalRecordCount);
|
|
foreach (var dateFolderInfo in dateFolderInfos)
|
{
|
var year = dateFolderInfo.Year;
|
var month = dateFolderInfo.Month;
|
var valid = this.GetSignalRecordPacketFile(projectId, sceneId, monitorPointId, signalId, year, month, out string filePath);
|
if (!valid)
|
continue;
|
using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
|
using (var sr = new StreamReader(fs, Encoding.UTF8))
|
{
|
var strLine = string.Empty;
|
while (!string.IsNullOrEmpty(strLine = sr.ReadLine()))
|
{
|
var content = FromDsString(strLine);
|
signalRecordPacket.RecordList.Add(content);
|
}
|
}
|
}
|
return signalRecordPacket;
|
}
|
|
/// <summary>
|
/// 查询信号记录包
|
/// </summary>
|
public Model.SignalRecordPacket GetSignalRecordPacket(long projectId, long sceneId, long monitorPointId, long signalId, int year, int month)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
var valid = this.GetSignalRecordPacketFile(projectId, sceneId, monitorPointId, signalId, year, month, out string filePath);
|
if (!valid)
|
return default;
|
var signalRecordCount = _monitorDataSetSummary.GetSignalRecordCount(projectId, sceneId, monitorPointId, signalId, year, month);
|
if (signalRecordCount < 1)
|
return default;
|
|
var signalRecordPacket = new Model.SignalRecordPacket();
|
signalRecordPacket.SignalId = signalId;
|
signalRecordPacket.RecordList = new List<Model.SignalRecord>(signalRecordCount);
|
|
using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
|
using (var sr = new StreamReader(fs, Encoding.UTF8))
|
{
|
var strLine = string.Empty;
|
while (!string.IsNullOrEmpty(strLine = sr.ReadLine()))
|
{
|
var content = FromDsString(strLine);
|
signalRecordPacket.RecordList.Add(content);
|
}
|
}
|
return signalRecordPacket;
|
}
|
|
#endregion
|
|
#region SignalRecord
|
|
/// <summary>
|
/// 查询信号记录
|
/// </summary>
|
public List<Model.SignalRecord> GetSignalRecord(long projectId, long sceneId, long monitorPointId, long signalId, int year, int month)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
var valid = this.GetSignalRecordPacketFile(projectId, sceneId, monitorPointId, signalId, year, month, out string filePath);
|
if (!valid)
|
return default;
|
var signalRecordCount = _monitorDataSetSummary.GetSignalRecordCount(projectId, sceneId, monitorPointId, signalId, year, month);
|
if (signalRecordCount < 1)
|
return default;
|
|
var signalRecordList = new List<Model.SignalRecord>(signalRecordCount);
|
using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
|
using (var sr = new StreamReader(fs, Encoding.UTF8))
|
{
|
var strLine = string.Empty;
|
while (!string.IsNullOrEmpty(strLine = sr.ReadLine()))
|
{
|
var content = FromDsString(strLine);
|
signalRecordList.Add(content);
|
}
|
}
|
return signalRecordList;
|
}
|
|
#endregion
|
|
#endregion
|
|
#region Save
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(long projectId, long sceneId, IEnumerable<Model.MonitorDataSet> list)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (list == null || list.Count() < 1)
|
return default;
|
for (int i = 0; i < list.Count(); i++)
|
{
|
var dataSet = list.ElementAt(i);
|
if (!Save(projectId, sceneId, dataSet))
|
{
|
//未做判断
|
}
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(long projectId, long sceneId, Model.MonitorDataSet rhs)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (rhs == null)
|
return default;
|
if (rhs.PacketList == null || rhs.PacketList.Count < 1)
|
return default;
|
|
var monitorPointId = rhs.MonitorPointId;
|
var year = rhs.Year;
|
var month = rhs.Month;
|
for (int i = 0; i < rhs.PacketList.Count; i++)
|
{
|
var packet = rhs.PacketList[i];
|
if (!Save(projectId, sceneId, monitorPointId, packet.SignalId, packet.RecordList, year, month))
|
{
|
//未做判断
|
}
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(long projectId, long sceneId, long monitorPointId, long signalId, List<Model.SignalRecord> signalRecords, int year, int month)
|
{
|
if (projectId < 1)
|
return default;
|
if (sceneId < 1)
|
return default;
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
if (signalRecords == null || signalRecords.Count < 1)
|
return default;
|
|
var valid = GetSignalRecordPacketFile(projectId, sceneId, monitorPointId, signalId, year, month, out string filePath);
|
using (var fs = new FileStream(filePath, System.IO.FileMode.Create, System.IO.FileAccess.Write, FileShare.ReadWrite))
|
using (var sw = new StreamWriter(fs, System.Text.Encoding.UTF8))
|
{
|
foreach (var record in signalRecords)
|
{
|
var strLine = ToDsString(record);
|
sw.WriteLine(strLine);
|
}
|
}
|
|
var model = new Model.MonitorDataSetSummary();
|
model.MonitorPointId = monitorPointId;
|
model.SignalId = signalId;
|
model.Year = year;
|
model.Month = month;
|
model.MinTime = signalRecords.Min(x => x.Time);
|
model.MaxTime = signalRecords.Max(x => x.Time);
|
model.Count = signalRecords.Count();
|
if (_monitorDataSetSummary.Set(projectId, sceneId, model, year, month))
|
return false;
|
return true;
|
}
|
|
#endregion
|
|
}
|
}
|
