// Copyright (C) Stichting Deltares 2016. All rights reserved.
//
// This file is part of Ringtoets.
//
// Ringtoets is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see .
//
// All names, logos, and references to "Deltares" are registered trademarks of
// Stichting Deltares and remain full property of Stichting Deltares at all times.
// All rights reserved.
using System;
using System.Collections.Generic;
using System.Linq;
using Application.Ringtoets.Storage.Create;
using Application.Ringtoets.Storage.DbContext;
using Application.Ringtoets.Storage.Exceptions;
using Application.Ringtoets.Storage.Properties;
using Core.Common.Base.Geometry;
using Ringtoets.Common.Data.FailureMechanism;
namespace Application.Ringtoets.Storage.Update
{
internal static class FailureMechanismSectionUpdateExtensions
{
///
/// Updates a in the database based on the information of the
/// .
///
/// The section to update the database entity for.
/// The object keeping track of update operations.
/// The context to obtain the existing entity from.
/// Thrown when either:
///
/// - is null
/// - is null
///
internal static void Update(this FailureMechanismSection section, PersistenceRegistry registry, IRingtoetsEntities context)
{
if (context == null)
{
throw new ArgumentNullException("context");
}
if (registry == null)
{
throw new ArgumentNullException("registry");
}
FailureMechanismSectionEntity entity = GetCorrespondingFailureMechanismSectionEntity(section, context);
entity.Name = section.Name;
UpdateGeometry(section, entity, context);
registry.Register(entity, section);
}
private static FailureMechanismSectionEntity GetCorrespondingFailureMechanismSectionEntity(FailureMechanismSection section, IRingtoetsEntities context)
{
try
{
return context.FailureMechanismSectionEntities.Single(ase => ase.FailureMechanismSectionEntityId == section.StorageId);
}
catch (InvalidOperationException exception)
{
throw new EntityNotFoundException(string.Format(Resources.Error_Entity_Not_Found_0_1, typeof(FailureMechanismSectionEntity).Name, section.StorageId), exception);
}
}
private static void UpdateGeometry(FailureMechanismSection section, FailureMechanismSectionEntity entity, IRingtoetsEntities context)
{
if (HasChanges(entity.FailureMechanismSectionPointEntities, section.Points))
{
context.FailureMechanismSectionPointEntities.RemoveRange(entity.FailureMechanismSectionPointEntities);
UpdateGeometryPoints(section, entity);
}
}
private static void UpdateGeometryPoints(FailureMechanismSection section, FailureMechanismSectionEntity entity)
{
var i = 0;
foreach (var point2D in section.Points)
{
entity.FailureMechanismSectionPointEntities.Add(point2D.CreateFailureMechanismSectionPointEntity(i++));
}
}
private static bool HasChanges(ICollection existingLine, IEnumerable otherLine)
{
if (!existingLine.Any())
{
return otherLine != null;
}
if (otherLine == null)
{
return true;
}
var existingPointEntities = existingLine.OrderBy(rlpe => rlpe.Order).ToArray();
var otherPointsArray = otherLine.ToArray();
if (existingPointEntities.Length != otherPointsArray.Length)
{
return true;
}
for (int i = 0; i < existingPointEntities.Length; i++)
{
var isXAlmostEqual = Math.Abs(Convert.ToDouble(existingPointEntities[i].X) - otherPointsArray[i].X) < 1e-6;
var isYAlmostEqual = Math.Abs(Convert.ToDouble(existingPointEntities[i].Y) - otherPointsArray[i].Y) < 1e-6;
if (!isXAlmostEqual || !isYAlmostEqual)
{
return true;
}
}
return false;
}
}
}