using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.BLL
|
{
|
/// <summary>
|
/// 监测数据集
|
/// </summary>
|
public class MonitorDataSet
|
{
|
private readonly DAL.MonitorDataSet _dal = new DAL.MonitorDataSet();
|
|
#region Query
|
|
#region MonitorDataSet
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public List<Model.MonitorDataSet> GetMonitorDataSet()
|
{
|
return _dal.GetMonitorDataSet();
|
}
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public List<Model.MonitorDataSet> GetMonitorDataSet(long monitorPointId)
|
{
|
if (monitorPointId < 1)
|
return default;
|
return _dal.GetMonitorDataSet(monitorPointId);
|
}
|
|
/// <summary>
|
/// 查询监测数据集
|
/// </summary>
|
public Model.MonitorDataSet GetMonitorDataSet(long monitorPointId, int year, int month)
|
{
|
if (monitorPointId < 1)
|
return default;
|
return _dal.GetMonitorDataSet(monitorPointId, year, month);
|
}
|
|
#endregion
|
|
#region SignalRecordPacket
|
|
/// <summary>
|
/// 查询信号记录包
|
/// </summary>
|
public List<Model.SignalRecordPacket> GetSignalRecordPacket(List<long> signalIds, int year, int month)
|
{
|
if (signalIds == null || !signalIds.Any())
|
return default;
|
return _dal.GetSignalRecordPacket(signalIds, year, month);
|
}
|
|
/// <summary>
|
/// 查询信号记录包
|
/// </summary>
|
public Model.SignalRecordPacket GetSignalRecordPacket(long monitorPointId, long signalId)
|
{
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
return _dal.GetSignalRecordPacket(monitorPointId, signalId);
|
}
|
|
/// <summary>
|
/// 查询信号记录包
|
/// </summary>
|
public Model.SignalRecordPacket GetSignalRecordPacket(long monitorPointId, long signalId, int year, int month)
|
{
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
return _dal.GetSignalRecordPacket(monitorPointId, signalId, year, month);
|
}
|
|
#endregion
|
|
#region SignalRecord
|
|
/// <summary>
|
/// 查询信号记录
|
/// </summary>
|
public List<Model.SignalRecord> GetSignalRecord(long monitorPointId, long signalId, int year, int month)
|
{
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
|
return _dal.GetSignalRecord(monitorPointId, signalId, year, month);
|
}
|
|
#endregion
|
|
#endregion
|
|
#region Save
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(IEnumerable<Model.MonitorDataSet> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
return _dal.Save(list);
|
}
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(Model.MonitorDataSet rhs)
|
{
|
if (rhs == null)
|
return default;
|
if (rhs.PacketList == null || rhs.PacketList.Count < 1)
|
return default;
|
return _dal.Save(rhs);
|
}
|
|
/// <summary>
|
/// 保存
|
/// </summary>
|
public bool Save(long monitorPointId, long signalId, List<Model.SignalRecord> signalRecords, int year, int month)
|
{
|
if (monitorPointId < 1)
|
return default;
|
if (signalId < 1)
|
return default;
|
if (signalRecords == null || signalRecords.Count < 1)
|
return default;
|
|
return _dal.Save(monitorPointId, signalId, signalRecords, year, month);
|
}
|
#endregion
|
|
/// <summary>
|
/// 删除(临时)
|
/// </summary>
|
public bool SetAbnormal(long monitorPointId, long signalId, IEnumerable<DateTime> dataTimeList, double err)
|
{
|
if (dataTimeList == null || dataTimeList.Count() < 1)
|
return false;
|
var dataSet = _dal.GetMonitorDataSet(monitorPointId);
|
if (dataSet == null || dataSet.Count < 1)
|
return false;
|
foreach (var data in dataSet)
|
{
|
var packet = data.PacketList?.Find(x => x.SignalID == signalId);
|
if (packet != null && packet.RecordList != null)
|
for (int i = 0; i < packet.RecordList.Count; i++)
|
{
|
var record = packet.RecordList[i];
|
if (dataTimeList.Contains(record.Time))
|
{
|
packet.RecordList[i] = new Model.SignalRecord(record.Time, err);
|
}
|
}
|
}
|
return _dal.Save(dataSet);
|
}
|
|
}
|
}
|
