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;
|
|
namespace IStation.DAL.LocalFile
|
{
|
/// <summary>
|
/// 监测月数据集
|
/// </summary>
|
public partial class MonitorDataSet
|
{
|
/// <summary>
|
/// 日期文件夹信息类
|
/// </summary>
|
private class DateFolderInfo
|
{
|
public string FullName { get; set; }
|
public int Year { get; set; }
|
public int Month { get; set; }
|
}
|
|
#region DateFolderInfo
|
/// <summary>
|
/// 查询年月
|
/// </summary>
|
private bool GetYearMonth(string folderPath, out int year, out int month)
|
{
|
year = month = 0;
|
if (!Directory.Exists(folderPath))
|
return false;
|
|
var name = Path.GetFileName(folderPath);
|
var strList = name.Split(MonitorDataSetConfig.Separator);
|
if (strList.Length != 2)
|
return false;
|
if (!int.TryParse(strList[0], out year))
|
{
|
return false;
|
}
|
if (!int.TryParse(strList[1], out month))
|
{
|
return false;
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 查询日期文件夹信息列表
|
/// </summary>
|
private List<DateFolderInfo> GetDateFolderInfos(string monitorDataFolderPath)
|
{
|
if (!Directory.Exists(monitorDataFolderPath))
|
return default;
|
var directories = Directory.GetDirectories(monitorDataFolderPath);
|
if (directories == null || directories.Count() < 1)
|
return default;
|
|
var list = new List<DateFolderInfo>(directories.Count());
|
foreach (var directory in directories)
|
{
|
if (!GetYearMonth(directory, out int year, out int month))
|
continue;
|
var info = new DateFolderInfo();
|
info.FullName = directory;
|
info.Year = year;
|
info.Month = month;
|
list.Add(info);
|
}
|
if (list.Count > 0)
|
{
|
list = list.OrderBy(x => x.Year).ThenBy(x => x.Month).ToList();
|
}
|
return list;
|
}
|
|
#endregion
|
|
|
/// <summary>
|
/// 监测月数据集文件夹信息类
|
/// </summary>
|
private class MonitorDataSetFolderInfo
|
{
|
public string FullName { get; set; }
|
public long MonitorPointId { get; set; }
|
public int Year { get; set; }
|
public int Month { get; set; }
|
}
|
|
#region MonitorDataSetFolderInfo
|
/// <summary>
|
/// 查询监测记录文件夹信息
|
/// </summary>
|
private List<MonitorDataSetFolderInfo> GetMonitorDataSetFolderInfos(string dateFolderPath)
|
{
|
if (!Directory.Exists(dateFolderPath))
|
return default;
|
if (!GetYearMonth(dateFolderPath, out int year, out int month))
|
return default;
|
var directories = Directory.GetDirectories(dateFolderPath);
|
if (directories == null || directories.Count() < 1)
|
return default;
|
|
var infos = new List<MonitorDataSetFolderInfo>(directories.Count());
|
foreach (var directory in directories)
|
{
|
var name = Path.GetFileName(directory);
|
if (long.TryParse(name, out long Id))
|
{
|
var info = new MonitorDataSetFolderInfo();
|
info.FullName = directory;
|
info.Year = year;
|
info.Month = month;
|
info.MonitorPointId = Id;
|
infos.Add(info);
|
}
|
}
|
return infos;
|
}
|
|
/// <summary>
|
/// 查询监测记录文件夹信息
|
/// </summary>
|
private List<MonitorDataSetFolderInfo> GetMonitorDataSetFolderInfos(DateFolderInfo dateFolderInfo)
|
{
|
if (dateFolderInfo == null)
|
return default;
|
var directories = Directory.GetDirectories(dateFolderInfo.FullName);
|
if (directories == null || directories.Count() < 1)
|
return default;
|
|
var infos = new List<MonitorDataSetFolderInfo>();
|
foreach (var directory in directories)
|
{
|
var name = Path.GetFileName(directory);
|
if (long.TryParse(name, out long Id))
|
{
|
var info = new MonitorDataSetFolderInfo();
|
info.FullName = directory;
|
info.Year = dateFolderInfo.Year;
|
info.Month = dateFolderInfo.Month;
|
info.MonitorPointId = Id;
|
infos.Add(info);
|
}
|
}
|
return infos;
|
}
|
|
#endregion
|
|
|
/// <summary>
|
/// 信号记录包文件信息类
|
/// </summary>
|
public class SignalRecordPackFileInfo
|
{
|
public string FullName { get; set; }
|
public long MonitorPointId { get; set; }
|
public long SignalId { get; set; }
|
public int Year { get; set; }
|
public int Month { get; set; }
|
}
|
|
#region SignalRecordPackFileInfo
|
/// <summary>
|
/// 查询信号记录包文件信息
|
/// </summary>
|
private List<SignalRecordPackFileInfo> GetSignalRecordPackFileInfos(string montiorDataSetFolder, int year, int month)
|
{
|
if (!Directory.Exists(montiorDataSetFolder))
|
return default;
|
var folderName = Path.GetFileName(montiorDataSetFolder);
|
if (!long.TryParse(folderName, out long montiorPointId))
|
return default;
|
|
var files = Directory.GetFiles(montiorDataSetFolder);
|
if (files == null || files.Count() < 1)
|
return default;
|
|
var infos = new List<SignalRecordPackFileInfo>(files.Count());
|
foreach (var filePath in files)
|
{
|
var name = Path.GetFileNameWithoutExtension(filePath);
|
if (long.TryParse(name, out long Id))
|
{
|
var info = new SignalRecordPackFileInfo();
|
info.FullName = filePath;
|
info.MonitorPointId = montiorPointId;
|
info.SignalId = Id;
|
info.Year = year;
|
info.Month = month;
|
infos.Add(info);
|
}
|
}
|
return infos;
|
}
|
|
/// <summary>
|
/// 查询信号记录包文件信息
|
/// </summary>
|
private List<SignalRecordPackFileInfo> GetSignalRecordPackFileInfos(MonitorDataSetFolderInfo montiorDataSetFolderInfo)
|
{
|
if (montiorDataSetFolderInfo == null)
|
return default;
|
var files = Directory.GetFiles(montiorDataSetFolderInfo.FullName);
|
if (files == null || files.Count() < 1)
|
return default;
|
|
var infos = new List<SignalRecordPackFileInfo>(files.Count());
|
foreach (var filePath in files)
|
{
|
var name = Path.GetFileNameWithoutExtension(filePath);
|
if (long.TryParse(name, out long Id))
|
{
|
var info = new SignalRecordPackFileInfo();
|
info.FullName = filePath;
|
info.MonitorPointId = montiorDataSetFolderInfo.MonitorPointId;
|
info.SignalId = Id;
|
info.Year = montiorDataSetFolderInfo.Year;
|
info.Month = montiorDataSetFolderInfo.Month;
|
infos.Add(info);
|
}
|
}
|
return infos;
|
}
|
|
#endregion
|
|
|
#region CsvConvert
|
//To
|
private string ToDsString(Model.SignalRecord record)
|
{
|
return $"{record.Time:yyyy-MM-dd HH:mm:ss},{record.Value}";
|
}
|
|
//from
|
public Model.SignalRecord FromDsString(string dsString)
|
{
|
var strList = dsString.Split(',');
|
if (strList.Length < 2)
|
return default;
|
var model = new Model.SignalRecord();
|
model.Time = DateTime.Parse(strList[0]);
|
model.Value = double.Parse(strList[1]);
|
return model;
|
}
|
#endregion
|
}
|
}
|
