|
|
|
@ -9,13 +9,15 @@ namespace SmartAquaViewer.DataAnalisys
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
internal class AquarDataControl
|
|
|
|
internal class AquarDataControl
|
|
|
|
{
|
|
|
|
{
|
|
|
|
private AQUA_DATA_CONTROL_STATE state = AQUA_DATA_CONTROL_STATE.IDLE;
|
|
|
|
private AQUA_DATA_CONTROL_STATE state = AQUA_DATA_CONTROL_STATE.IDLE;
|
|
|
|
private readonly IWaterQuality iwaterQuality;
|
|
|
|
private readonly IWaterQuality iwaterQuality;
|
|
|
|
private CancellationTokenSource? cts;
|
|
|
|
private CancellationTokenSource? cts;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
AppDbContext db = new AppDbContext();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public AquarDataControl(IWaterQuality iwaterQuality)
|
|
|
|
public AquarDataControl(IWaterQuality iwaterQuality)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
this.iwaterQuality = iwaterQuality;
|
|
|
|
this.iwaterQuality = iwaterQuality;
|
|
|
|
@ -65,6 +67,7 @@ namespace SmartAquaViewer.DataAnalisys
|
|
|
|
vo.Timestamp = DateTime.Now;
|
|
|
|
vo.Timestamp = DateTime.Now;
|
|
|
|
iwaterQuality.OnParsed(vo);
|
|
|
|
iwaterQuality.OnParsed(vo);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
db.Add(vo);
|
|
|
|
|
|
|
|
|
|
|
|
iwaterQuality.OnProgress(percent);
|
|
|
|
iwaterQuality.OnProgress(percent);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|