prs/prs.mobile.new/PRS.Mobile/Main/DataModel.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Comal.Classes;
using InABox.Clients;
using InABox.Configuration;
using InABox.Core;
using InABox.Mobile;
using InABox.Rpc;

namespace PRS.Mobile
{
    
    public class GPSEventArgs : EventArgs
    {
        
    }
    
    public delegate void GPSLocationUpdatedEvent(GPSEventArgs args);

    public class BluetoothEventArgs : EventArgs
    {
        
    }

    public delegate void BluetoothScanFinishedEvent(BluetoothEventArgs args);



    
    public class DataModel : IModelHost
    {

        public event GPSLocationUpdatedEvent GPSLocationUpdated;

        public event BluetoothScanFinishedEvent BluetoothScanFinished;
        
        
        /// <summary>
        /// All Active Employees of the Company
        /// </summary>
        public EmployeeDetailModel CurrentEmployee { get; private set; }

        private readonly object _employeelock = new object(); 
        private EmployeeDetailShell _me;
        /// <summary>
        /// EmployeeDetails for Currently Logged in User
        /// </summary>
        public EmployeeDetailShell Me
        {
            get
            {
                lock (_employeelock)
                {
                    if (_me == null)
                    {
                        CurrentEmployee.Refresh(false);
                        _me = CurrentEmployee.FirstOrDefault(x => x.UserID == ClientFactory.UserGuid);
                    }
                }
                return _me;
            }
        }
        
        /// <summary>
        /// All Active Employees of the Company
        /// </summary>
        public EmployeeModel Employees { get; private set; }
        
        /// <summary>
        /// All Employee Teams for the Company
        /// Should this be just teams I am a part of, or all available teams
        /// Need to implement a Security Token to differentiate
        /// </summary>
        public EmployeeTeamModel EmployeeTeams { get; private set; }
        
        /// <summary>
        /// Current Employee Form Instances for this employee
        /// </summary>
        public EmployeeFormModel EmployeeForms { get; private set; }
        
        
        public EmployeeQualificationModel EmployeeQualifications { get; private set; }
        
        /// <summary>
        /// Available Activity Codes for this Employee
        /// </summary>
        public ActivityModel Activities { get; private set; }
        
        /// <summary>
        /// All Available Contacts - used in Deliveries
        /// </summary>
        public ContactModel Contacts { get; private set; }
        
        /// <summary>
        /// All Defined Bluetooth-enabled Gates
        /// </summary>
        public BluetoothGateModel BluetoothGates { get; private set; }
        
        /// <summary>
        /// Unprocessed Timesheets for Currently Logged in User
        /// </summary>
        public TimeSheetModel TimeSheets { get; private set; }
        
        /// <summary>
        /// List of Jobs that Currently Logged in User has access To
        /// </summary>
        public JobModel Jobs { get; private set; }

        /// <summary>
        /// List of Assignments for ??? need to specify this.
        /// Can I see other people's assignments?  (Security Token)
        /// How far back / forward can I look.
        /// This smells Transient, or maybe split into lookups (for all)
        /// and shells (for mine)
        /// Possibly need a back/forward window as well?
        /// </summary>
        public AssignmentModel Assignments { get; private set; }
        
        /// <summary>
        /// Master Product Catalogue for the company
        /// This should be split into Lookups and Shells
        /// </summary>
        public ProductModel Products { get; private set; }
        
        /// <summary>
        ///  Master Supplier List for Lookups, etc
        /// </summary>
        public SupplierModel Suppliers { get; private set; }
        
        public ConsignmentTypeModel ConsignmentTypes { get; private set; }
        
        /// <summary>
        /// Master List of Dimension Units for the company
        /// </summary>
        public ProductDimensionUnitModel ProductDimensionUnits { get; private set; }
        
        /// <summary>
        /// Master Product Groups List (Lookup?)
        /// </summary>
        public ProductGroupModel ProductGroups { get; private set; }
        
                
        /// <summary>
        /// Master Product Styles List (Lookup?)
        /// </summary>
        public ProductStyleModel ProductStyles { get; private set; }

        /// <summary>
        /// All GPS Tracker Devices registered by the company
        /// </summary>
        public GPSTrackerModel GPSTrackers { get; private set; }
        
        /// <summary>
        /// Master Equipment Register
        /// </summary>
        public EquipmentModel Equipment { get; private set; }
        
        /// <summary>
        /// Master List of Equipment Groups
        /// </summary>
        public EquipmentGroupModel EquipmentGroups { get; private set; }
        
        /// <summary>
        /// Master List of Available Delivery Types
        /// </summary>
        public DeliveryTypeModel DeliveryTypes { get; private set; }
        
        /// <summary>
        /// List of all Deliveries
        /// hmmm.. should be configurable?
        /// </summary>
        public DeliveryModel Deliveries { get; private set; }
        
        /// <summary>
        /// List of all available Delivery Barcodes
        /// hmmm.. should be configurable?
        /// </summary>
        public DeliveryItemModel DeliveryItems { get; private set; }
        
        public RequisitionDestinationModel RequisitionDestinations { get; private set; }
        
        /// <summary>
        /// My Notifications (open only?)
        /// </summary>
        public NotificationModel Notifications { get; private set; }
        
        /// <summary>
        /// All Tasks I am subscribed to
        /// </summary>
        public KanbanModel Kanbans { get; private set; }
        
        /// <summary>
        /// All Kanban Types
        /// </summary>
        public KanbanTypeModel KanbanTypes { get; private set; }
        
        /// <summary>
        /// Available Form Library - this includes all "Applies To" values
        /// You can filter to a specific type by using the "Search" function
        /// </summary>
        public DigitalFormModel DigitalForms { get; private set; }
        
        // The list of open task-kased forms for the current user
        // Specifically for us in the "Forms" module
        // This overlaps the "Task" module a fair amount, but it provides
        // an alternative paradigm for tasks
        public KanbanFormModel KanbanForms { get; private set; }
        
        /// <summary>
        /// List of Employees, along with Clock on / off status
        /// </summary>
        public InOutModel InOut { get; private set; }
        
        /// <summary>
        /// List of Open Purchase Orders
        /// </summary>
        public PurchaseOrderModel PurchaseOrders { get; private set; }
        
        public ManufacturingFactoryModel ManufacturingFactories { get; private set; }
        
        
        public StockLocationModel StockLocations { get; set; }

        public StockAreaModel StockAreas { get; set; }

        public StockWarehouseModel StockWarehouses { get; set; }

        public DataModel()
        {
            Reset();
        }

        public void Reset()
        {
            
            _me = null;
            
            CurrentEmployee = new EmployeeDetailModel(this,
                () => new Filter<Employee>(x => x.UserLink.ID).IsEqualTo(ClientFactory.UserGuid)
            );
            
            Employees = new EmployeeModel(this,
                LookupFactory.DefineFilter<Employee>
            );

            EmployeeTeams = new EmployeeTeamModel(this,
                () => new Filter<EmployeeTeam>(x => x.EmployeeLink.ID)
                    .InQuery(LookupFactory.DefineFilter<Employee>(), x => x.ID)
            );

            EmployeeForms = new EmployeeFormModel(this,
                () => new Filter<EmployeeForm>(x => x.Parent.ID).IsEqualTo(App.Data.Me.ID)
            );
            
            EmployeeQualifications = new EmployeeQualificationModel(this,
                () => new Filter<EmployeeQualification>(x => x.Employee.ID).IsEqualTo(App.Data.Me.ID)
            );
            
            Activities = new ActivityModel(this,
                () => new Filter<EmployeeActivity>(x => x.Employee.ID).IsEqualTo(App.Data.Me.ID)
            );
            
            InOut = new InOutModel(this,
                () => new Filters<Employee>()
                    .Add(LookupFactory.DefineFilter<Employee>())
                    .Add(new Filter<Employee>(x=>x.ID).IsNotEqualTo(App.Data.Me.ID).And(x=>x.ShowOnInOutBoard).IsEqualTo(true))
                    .Combine()!
            );

            Jobs = new JobModel(this, 
                MyJobsFilter,
                CoreRepository.CacheFileName<Job>
            );

            Products = new ProductModel(this,
                LookupFactory.DefineFilter<Product>, 
                CoreRepository.CacheFileName<Product>
            );
            
            Suppliers = new SupplierModel(this,
                LookupFactory.DefineFilter<Supplier>, 
                CoreRepository.CacheFileName<Supplier>
            );
            
            ConsignmentTypes = new ConsignmentTypeModel(this,
                LookupFactory.DefineFilter<ConsignmentType>, 
                CoreRepository.CacheFileName<ConsignmentType>
            );
            
            ProductDimensionUnits = new ProductDimensionUnitModel(this,
                LookupFactory.DefineFilter<ProductDimensionUnit>,
                () => null);

            ProductGroups = new ProductGroupModel(this,
                LookupFactory.DefineFilter<ProductGroup>, 
                CoreRepository.CacheFileName<ProductGroup>
            );
            
            ProductStyles = new ProductStyleModel(this,
                LookupFactory.DefineFilter<ProductStyle>
            );

            GPSTrackers = new GPSTrackerModel(this,
                LookupFactory.DefineFilter<GPSTracker>
            );

            Equipment = new EquipmentModel(this,
                () =>
                {
                    var filters = new Filters<Equipment>();
                    filters.Add(LookupFactory.DefineFilter<Equipment>());
                    if (!Security.IsAllowed<CanViewPrivateEquipment>())
                        filters.Add(new Filter<Equipment>(x => x.Private).IsEqualTo(false));
                    return filters!.Combine();
                },
                CoreRepository.CacheFileName<Equipment>
            );

            EquipmentGroups = new EquipmentGroupModel(this,
                LookupFactory.DefineFilter<EquipmentGroup>
            );

            DeliveryTypes= new DeliveryTypeModel(this, 
                null, 
                CoreRepository.CacheFileName<DeliveryType>);
            
            Deliveries = new DeliveryModel(this);

            DeliveryItems = new DeliveryItemModel(this,
                LookupFactory.DefineFilter<DeliveryItem>
            );
            
            RequisitionDestinations = new RequisitionDestinationModel(this,
                null, 
                CoreRepository.CacheFileName<RequisitionDestination>
            );
            
            Notifications = new NotificationModel(this, 
                () => new Filter<Notification>(x=>x.Employee.ID).IsEqualTo(App.Data.Me.ID)
                    .And(new Filter<Notification>(x=>x.Closed).IsEqualTo(DateTime.MinValue)
                        .Or(x=>x.Created).IsGreaterThanOrEqualTo(DateTime.Today.AddDays(-90)))
            );
            
            TimeSheets = new TimeSheetModel(this,
                () => new Filter<TimeSheet>(x=>x.Processed).IsEqualTo(DateTime.MinValue)
                    .And(x=>x.EmployeeLink.ID).IsEqualTo(App.Data.Me.ID)
            );

            Assignments = new AssignmentModel(this,
                () => new Filter<Assignment>(x => x.Date).IsGreaterThanOrEqualTo(DateTime.Today.AddDays(-90))
                    .And(x => x.Date).IsLessThanOrEqualTo(DateTime.Today.AddDays(90))
            );
            
            Contacts = new ContactModel(this, 
                () => LookupFactory.DefineFilter<Contact>()
            );

            Kanbans = new KanbanModel(this,
                () => new Filter<Kanban>(x => x.ID)
                    .InQuery(new Filter<KanbanSubscriber>(x=>x.Employee.ID).IsEqualTo(App.Data.Me.ID), x=>x.Kanban.ID)
                    .And(
                        new Filter<Kanban>(x=>x.Status).IsNotEqualTo(KanbanStatus.Complete)
                            .Or(x=>x.Completed).IsGreaterThanOrEqualTo(DateTime.Today.AddDays(-7)
                        )
                    ),
                    CoreRepository.CacheFileName<Kanban>
                );
            
            KanbanTypes = new KanbanTypeModel(this);

            BluetoothGates = new BluetoothGateModel(this,
                () => new Filter<JobTracker>(x => x.Active).IsEqualTo(true)
            );

            DigitalForms = new DigitalFormModel(this,
                () => new Filter<EmployeeDigitalForm>(x => x.Employee.ID).IsEqualTo(App.Data.Me.ID)
                    .And(x => x.Form.Active).IsEqualTo(true)
            );

            KanbanForms = new KanbanFormModel(this,
                () => new Filter<KanbanForm>(x=>x.Parent.EmployeeLink.ID).IsEqualTo(App.Data.Me.ID)
                    .And(new Filter<KanbanForm>(x=>x.FormCompleted).IsEqualTo(DateTime.MinValue)
                        .Or(x=>x.FormCompleted).IsGreaterThanOrEqualTo(DateTime.Today.AddDays(-7)))
            );
            
            PurchaseOrders = new PurchaseOrderModel(this,
                () => new Filter<PurchaseOrder>(x => x.ClosedDate).IsEqualTo(DateTime.MinValue)
            );
            
            ManufacturingFactories = new ManufacturingFactoryModel(this);

            StockLocations = new StockLocationModel(this,
                null,
                CoreRepository.CacheFileName<StockLocation>
            );
            
            StockAreas = new StockAreaModel(this,
                null,
                CoreRepository.CacheFileName<StockArea>
            );
            
            StockWarehouses = new StockWarehouseModel(this,
                null,
                CoreRepository.CacheFileName<StockWarehouse>
            );
        }

        private static Filter<Job> MyJobsFilter()
        {
            return Security.IsAllowed<CanViewAllJobs>()
                ? new Filter<Job>(X => X.Completed).IsEqualTo(DateTime.MinValue)
                    .And(x => x.JobStatus.Active).IsEqualTo(true)
                : new Filter<Job>(X => X.Completed).IsEqualTo(DateTime.MinValue)
                    .And(x => x.JobStatus.Active).IsEqualTo(true)
                    .And(x => x.ID).InQuery(
                        new Filter<JobEmployee>(x => x.EmployeeLink.ID).IsEqualTo(App.Data.Me.ID),
                        x => x.JobLink.ID
                    );
        }

        public void Setup()
        {
            // Clear All Transient Caches
            Reset();

            // Always load the current Employee and Security Tokens
            Task[] init = new Task[]
            {
                Task.Run(() => { CurrentEmployee.Refresh(true); }),
                Task.Run(() => { Security.CheckTokens(); })
            };
            Task.WaitAll(init);
            
            App.Bluetooth.OnScanFinished += OnBluetoothScanFinished;
            
            App.GPS.OnLocationFound += OnGPSLocationFound;
            
            App.Transport.OnOpen += OnTransportConnected;
            App.Transport.OnClose += OnTransportDisconnected;
            
            DigitalFormDocumentFactory.Init(
                new MobileDigitalFormDocumentHandler(
                b =>
                {
                    IsBackgroundUpdateStatusActive = b;
                    BackgroundUpdateStatusChanged?.Invoke(this, EventArgs.Empty);
                })
            );
            DigitalFormDocumentFactory.Run();
            
            StartUpdateQueue();
        }
        

        public bool IsBackgroundUpdateStatusActive { get; private set; }

        public event BackgroundUpdateStatusEvent BackgroundUpdateStatusChanged;

        public bool IsConnected() => App.Transport?.IsConnected() == true;
        
        public event TransportDisconnectedEvent TransportDisconnected;
        
        public event TransportConnectedEvent TransportConnected;
        
        private void OnTransportDisconnected(IRpcTransport transport, RpcTransportCloseArgs e)
        {
            DigitalFormDocumentFactory.Stop();
            TransportDisconnected?.Invoke(new TransportDisconnectedEventArgs());
            Task.Run(() =>
            {
                ValidationStatus status = ValidationStatus.INVALID;
                while (status != ValidationStatus.VALID)
                {
                    try
                    {
                        while (!IsConnected())
                        {
                            
                            try
                            {
                                App.Transport.Connect();
                            }
                            catch (Exception eConnect)
                            {
                                MobileLogging.Log($"Reconnect() {eConnect.Message} \n {eConnect.StackTrace}");
                                Task.Delay(TimeSpan.FromMilliseconds(1000));
                            }
                        }
                        status = ClientFactory.Validate(ClientFactory.SessionID);
                        if (status != ValidationStatus.VALID)
                        {
                            ClientFactory.InvalidateUser();
                            var settings = new LocalConfiguration<MobileDatabaseSettings>().LoadAll().Values
                                .FirstOrDefault(x => x.IsDefault);
                            if (settings != null)
                            {
                                var userid = settings.UserID;
                                var password = settings.Password;
                                status = ClientFactory.Validate(userid, password);
                                if (status != ValidationStatus.VALID)
                                    break;
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        MobileLogging.Log($"Revalidate() {ex.Message} \n {ex.StackTrace}");
                        Task.Delay(TimeSpan.FromMilliseconds(1000));
                    }
                }
                DigitalFormDocumentFactory.Run();
            });
        }

        private void OnTransportConnected(IRpcTransport transport, RpcTransportOpenArgs e)
        {
            TransportConnected?.Invoke(new TransportConnectedEventArgs());
        }
        
        #region QueueUpdaterSupport
        
        private CancellationTokenSource? _cancelQueueUpdate;
        private List<IQueueUpdater> _updateQueues = new();
        
        private void StartUpdateQueue()
        {
            StopUpdateQueue();
            _cancelQueueUpdate = new CancellationTokenSource();
            Task.Run(
                () =>
                {
                    while (_cancelQueueUpdate?.IsCancellationRequested != true)
                    {
                        foreach (var queue in _updateQueues.ToArray())
                            queue.ProcessQueue();
                        Thread.Sleep(100);
                    }
                },
                _cancelQueueUpdate.Token
            );
        }

        private void StopUpdateQueue()
        {
            if (_cancelQueueUpdate != null)
            {
                _cancelQueueUpdate.Cancel();
                _cancelQueueUpdate.Dispose();
                _cancelQueueUpdate = null;
            }
        }
        
        public void AddUpdateQueue<TEntity>(QueueUpdater<TEntity> queue)
            where TEntity : Entity, IPersistent, IRemotable, new()
        {
            _updateQueues.Add(queue);
        }

        public void RemoveUpdateQueue<TEntity>(QueueUpdater<TEntity> queue)
            where TEntity : Entity, IPersistent, IRemotable, new()
        {
            _updateQueues.Remove(queue);
        }
        
        #endregion
        
        
        private Location _lastgpslocation = new Location();

        private GPSTrackerLocation GetGPSTrackerUpdate(string deviceid, Location location,
            TimeSpan threshold, double distance)
        {
            GPSTrackerShell tracker = GPSTrackers.FirstOrDefault(x => x.DeviceID.Equals(deviceid));
            if (tracker != null)
            {
                if ((tracker.Timestamp < location.Timestamp.Subtract(threshold)) || (tracker.Location.DistanceTo(location, UnitOfLength.Kilometers) > distance))
                {
                    GPSTrackerLocation gpsTrackerLocation = new GPSTrackerLocation();
                    gpsTrackerLocation.DeviceID = tracker.DeviceID;
                    gpsTrackerLocation.Tracker.ID = tracker.ID;
                    gpsTrackerLocation.Location = location; 
                    return gpsTrackerLocation;
                }
                
            }
            return null;
        }

        private void OnGPSLocationFound(LocationServices sender)
        {
            if (_lastgpslocation.Timestamp < DateTime.Now.Subtract(TimeSpan.FromMinutes(2)))
            {

                var devicelocation = new InABox.Core.Location()
                {
                    Latitude = App.GPS.Latitude,
                    Longitude = App.GPS.Longitude,
                    Timestamp = App.GPS.TimeStamp,
                    Address = App.GPS.Address
                };

                GPSTrackers.Refresh(false);

                var update = GetGPSTrackerUpdate(MobileUtils.GetDeviceID(), devicelocation, TimeSpan.FromMinutes(2),
                    0.1);
                if (update != null)
                    new Client<GPSTrackerLocation>().Save(update, "Updated via Mobile Device", (o, e) => { });

            }

            GPSLocationUpdated?.Invoke(new GPSEventArgs());
        }

        private void OnBluetoothScanFinished(Bluetooth sender)
        {
            UploadTiles();
            BluetoothScanFinished?.Invoke(new BluetoothEventArgs());
        }

        private void UploadTiles()
        {
            try
            {
                if (App.GPS.Latitude.Equals(0.0F) && App.GPS.Longitude.Equals(0.0F))
                    return;

                if (App.Bluetooth.DetectedBlueToothMACAddresses.Count == 0)
                    return;

                var devicelocation = new InABox.Core.Location()
                {
                    Latitude = App.GPS.Latitude,
                    Longitude = App.GPS.Longitude,
                    Timestamp = App.GPS.TimeStamp,
                    Address = App.GPS.Address
                };

                GPSTrackers.Refresh(true);

                List<GPSTrackerLocation> updates = new List<GPSTrackerLocation>();
                foreach (String deviceid in App.Bluetooth.DetectedBlueToothMACAddresses)
                {
                    var update = GetGPSTrackerUpdate(deviceid, devicelocation, TimeSpan.FromMinutes(2), 0.1);
                    if (update != null)
                        updates.Add(update);
                }

                if (updates.Any())
                    new Client<GPSTrackerLocation>().Save(updates, $"Updated by Mobile {MobileUtils.GetDeviceID()}",
                        (o, e) => { });
            }
            catch (Exception ex)
            {
                MobileLogging.Log($"UploadTiles() {ex.Message} \n {ex.StackTrace}");
            }
        }
        
    }

}