12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using Comal.Classes;
- using InABox.Core;
- namespace Comal.Stores
- {
- internal class GPSTrackerStore : BaseStore<GPSTracker>
- {
- protected override void AfterSave(GPSTracker entity)
- {
- UpdateLinkedEquipment(entity);
- UpdateLinkedJob(entity);
- base.AfterSave(entity);
- }
- private void UpdateLinkedEquipment(GPSTracker entity)
- {
- if (entity.Equipment.HasOriginalValue(x => x.ID))
- {
- var oldID = entity.Equipment.GetOriginalValue(x => x.ID);
- var newID = entity.Equipment.ID;
- var trackers = Provider.Query(
- new Filter<Equipment>(x => x.ID).IsEqualTo(oldID).Or(x => x.ID).IsEqualTo(newID),
- new Columns<Equipment>(x => x.ID, x => x.TrackerLink.ID)
- );
- var updates = new List<Equipment>();
- var prev = trackers.Rows.FirstOrDefault(r => r.Get<Equipment, Guid>(c => c.ID).Equals(oldID));
- if (prev != null)
- {
- var target = prev.ToObject<Equipment>();
- target.TrackerLink.ID = Guid.Empty;
- updates.Add(target);
- }
- var curr = trackers.Rows.FirstOrDefault(r => r.Get<Equipment, Guid>(c => c.ID).Equals(newID));
- if (curr != null)
- {
- var tracker = curr.ToObject<Equipment>();
- tracker.TrackerLink.ID = entity.ID;
- updates.Add(tracker);
- }
- if (updates.Any())
- Provider.Save(updates);
- }
- }
- private void UpdateLinkedJob(GPSTracker entity)
- {
- if (entity.JobTracker.HasOriginalValue(x => x.ID))
- {
- var oldID = entity.JobTracker.GetOriginalValue(x => x.ID);
- var newID = entity.JobTracker.ID;
- var trackers = Provider.Query(
- new Filter<JobTracker>(x => x.ID).IsEqualTo(oldID).Or(x => x.ID).IsEqualTo(newID),
- new Columns<JobTracker>(x => x.ID, x => x.TrackerLink.ID)
- );
- var updates = new List<JobTracker>();
- var prev = trackers.Rows.FirstOrDefault(r => r.Get<JobTracker, Guid>(c => c.ID).Equals(oldID));
- if (prev != null)
- {
- var target = prev.ToObject<JobTracker>();
- target.TrackerLink.ID = Guid.Empty;
- updates.Add(target);
- }
- var curr = trackers.Rows.FirstOrDefault(r => r.Get<JobTracker, Guid>(c => c.ID).Equals(newID));
- if (curr != null)
- {
- var tracker = curr.ToObject<JobTracker>();
- tracker.TrackerLink.ID = entity.ID;
- updates.Add(tracker);
- }
- if (updates.Any())
- Provider.Save(updates);
- }
- }
- }
- }
|