Merge branch 'master' of https://twinetfs.visualstudio.com/_git/Tango

1 files changed, 304 insertions, 0 deletions

diff --git a/Software/Visual_Studio/MachineStudio/Modules/Tango.MachineStudio.Statistics/ViewModels/JobRunsViewVM.cs b/Software/Visual_Studio/MachineStudio/Modules/Tango.MachineStudio.Statistics/ViewModels/JobRunsViewVM.cs
new file mode 100644
index 000000000..cf74071c9
--- /dev/null
+++ b/Software/Visual_Studio/MachineStudio/Modules/Tango.MachineStudio.Statistics/ViewModels/JobRunsViewVM.cs
@@ -0,0 +1,304 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Data.Entity;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Tango.BL;
+using Tango.BL.Builders;
+using Tango.BL.Entities;
+using Tango.BL.Enumerations;
+using Tango.Core.Commands;
+using Tango.MachineStudio.Common;
+using Tango.MachineStudio.Common.Notifications;
+using Tango.MachineStudio.Statistics.Models;
+using Tango.SharedUI;
+using Tango.SharedUI.Components;
+using Tango.AutoComplete.Editors;
+
+namespace Tango.MachineStudio.Statistics.ViewModels
+{
+    public class JobRunsViewVM : ViewModel
+    {
+        private INotificationProvider _notification;
+        private List<Machine> _allMachines;
+        private List<User> _allUsers;
+        private List<RmlModel> _rmlsModels;
+        private List<JobRun> _allJobRuns;
+
+        #region Properties
+
+        private ObservableCollection<JobRunModel> _jobRuns;
+        public ObservableCollection<JobRunModel> JobRuns
+        {
+            get { return _jobRuns; }
+            set
+            {
+                _jobRuns = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private JobRunModel _selectedJobRun = null;
+        public JobRunModel SelectedJobRun
+        {
+            get { return _selectedJobRun; }
+            set
+            {
+                _selectedJobRun = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private SelectedObjectCollection<Machine> _selectedMachines;
+        public SelectedObjectCollection<Machine> SelectedMachines
+        {
+            get { return _selectedMachines; }
+            set
+            {
+                _selectedMachines = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private DateTime _startSelectedDate;
+        public DateTime StartSelectedDate
+        {
+            get { return _startSelectedDate; }
+            set { _startSelectedDate = value; RaisePropertyChangedAuto(); }
+        }
+
+        private DateTime _endSelectedDate;
+        public DateTime EndSelectedDate
+        {
+            get { return _endSelectedDate; }
+            set { _endSelectedDate = value; RaisePropertyChangedAuto(); }
+        }
+
+        protected Double _lengthLowerValue;
+        public Double LengthLowerValue
+        {
+            get { return _lengthLowerValue; }
+            set
+            {
+                _lengthLowerValue = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        protected Double _lengthUpperValue;
+        public Double LengthUpperValue
+        {
+            get { return _lengthUpperValue; }
+            set
+            {
+                _lengthUpperValue = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private SelectedObjectCollection<JobSource> _jobRunSelectedSources;
+        public SelectedObjectCollection<JobSource> JobRunSelectedSources
+        {
+            get { return _jobRunSelectedSources; }
+            set { _jobRunSelectedSources = value; RaisePropertyChangedAuto(); }
+        }
+
+        private SelectedObjectCollection<JobRunStatus> _jobRunSelectedStatuses;
+        public SelectedObjectCollection<JobRunStatus> JobRunSelectedStatuses
+        {
+            get { return _jobRunSelectedStatuses; }
+            set { _jobRunSelectedStatuses = value; RaisePropertyChangedAuto(); }
+        }
+
+        public SelectedObjectCollection<bool> _isGradientSelection;
+        public SelectedObjectCollection<bool> IsGradientSelection
+        {
+            get { return _isGradientSelection; }
+            set
+            {
+                _isGradientSelection = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private SelectedObjectCollection<RmlModel> _selectedThreads;
+        public SelectedObjectCollection<RmlModel> SelectedThreads
+        {
+            get { return _selectedThreads; }
+            set
+            {
+                _selectedThreads = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        /// <summary>
+        /// Gets or sets the JobRuns providers.
+        /// </summary>
+        public ISuggestionProvider JobRunsProvider { get; set; }
+
+        private  JobRun _jobRun;
+        public JobRun JobRun
+        {
+            get { return _jobRun; }
+            set {
+                _jobRun = value;
+                if (_jobRun != null)
+                {
+                    SelectedJobName = _jobRun.JobName;
+                }
+                RaisePropertyChangedAuto(); }
+        }
+
+        private string SelectedJobName { get; set; }
+        
+
+        #endregion
+
+        public RelayCommand LoadJobRunsCommand { get; set; }
+
+        public JobRunsViewVM(INotificationProvider notificationProvider)
+        {
+            _notification = notificationProvider;
+            JobRuns = new ObservableCollection<JobRunModel>();
+            LoadJobRunsCommand = new RelayCommand(async () => await LoadJobRuns(), ()=> IsFree);
+            LengthUpperValue = 5000.0;
+            LengthLowerValue = 0.0;
+            DateTime now = DateTime.Now;
+            StartSelectedDate = now.AddMonths(-1);
+            EndSelectedDate = now;
+
+            JobRunSelectedSources = new SelectedObjectCollection<JobSource>(new ObservableCollection<JobSource>()
+            {
+                JobSource.Local,
+                JobSource.Remote
+            }, new ObservableCollection<JobSource>()
+            {
+                JobSource.Local,
+                JobSource.Remote
+            });
+            JobRunSelectedSources.SelectionChanged -= (x, y) => RaisePropertyChanged(nameof(JobRunSelectedSources));
+            JobRunSelectedSources.SelectionChanged += (x, y) => RaisePropertyChanged(nameof(JobRunSelectedSources));
+
+            JobRunSelectedStatuses = new SelectedObjectCollection<JobRunStatus>(new ObservableCollection<JobRunStatus>()
+            {
+                JobRunStatus.Aborted,
+                JobRunStatus.Completed,
+                JobRunStatus.Failed,
+
+            }, new ObservableCollection<JobRunStatus>()
+            {
+                JobRunStatus.Aborted,
+                JobRunStatus.Completed,
+                JobRunStatus.Failed,
+
+            });
+            JobRunSelectedStatuses.SelectionChanged -= (x,y)=> RaisePropertyChanged(nameof(JobRunSelectedStatuses));
+            JobRunSelectedStatuses.SelectionChanged += (x, y) => RaisePropertyChanged(nameof(JobRunSelectedStatuses));
+
+            IsGradientSelection = new SelectedObjectCollection<bool>(new ObservableCollection<bool>
+            {
+                true,
+                false
+            }, new ObservableCollection<bool>
+            {
+                true,
+                false
+            });
+            IsGradientSelection.SelectionChanged -= (x, y) => RaisePropertyChanged(nameof(IsGradientSelection));
+            IsGradientSelection.SelectionChanged += (x, y) => RaisePropertyChanged(nameof(IsGradientSelection));
+            JobRunsProvider = new SuggestionProvider((filter) =>
+            {
+                try
+                {
+                    SelectedJobName = filter;
+                    return _allJobRuns.Where(x => x.JobName != null && x.JobName.ToString().StartsWith(filter, StringComparison.CurrentCultureIgnoreCase)).ToList();
+                }
+                catch
+                {
+                    return null;
+                }
+            });
+           
+        }
+        
+        public async void Init()
+        {
+            using (_notification.PushTaskItem("Loading job runs..."))
+            {
+                try
+                {
+                    IsFree = false;
+
+                    using (var db = ObservablesContext.CreateDefault())
+                    {
+                        _allJobRuns = await db.JobRuns.ToListAsync(); ;
+                        _allMachines = await db.Machines.ToListAsync();
+                        _allUsers = await db.Users.Include(x => x.Contact).ToListAsync();
+                        _rmlsModels  = await db.Rmls.Select(x=> new RmlModel(){ Name = x.Name, Guid = x.Guid}).ToListAsync();
+                        SelectedMachines = new SelectedObjectCollection<Machine>(_allMachines.ToObservableCollection(), new ObservableCollection<Machine>());
+                        SelectedThreads = new SelectedObjectCollection<RmlModel>(_rmlsModels.ToObservableCollection(), new ObservableCollection<RmlModel>());
+                       
+                    }
+                }
+                catch (Exception ex)
+                {
+                    LogManager.Log(ex, "Error loading job runs.");
+                }
+                finally
+                {
+                    IsFree = true;
+                }
+            }
+        }
+        
+        private async Task LoadJobRuns()
+        {
+            using (_notification.PushTaskItem("Loading job runs..."))
+            {
+                try
+                {
+                    IsFree = false;
+
+                    using (var db = ObservablesContext.CreateDefault())
+                    {
+                        DateTime startUtc = StartSelectedDate.ToUniversalTime();
+                        TimeSpan offsetTime = (EndSelectedDate.Date == DateTime.Now.Date) ? DateTime.Now.TimeOfDay : new TimeSpan(23, 59, 59);
+                        DateTime endUtc = EndSelectedDate.ToUniversalTime() + offsetTime;
+
+                        var runs = await new JobRunsCollectionBuilder(db).Set(x => x.ActualStartDate <= DbFunctions.TruncateTime(endUtc) && x.ActualStartDate >= DbFunctions.TruncateTime(startUtc.Date))
+                        .WithMachines(SelectedMachines.SynchedSource.ToList())
+                        .WithJobSource(JobRunSelectedSources.SynchedSource)
+                        .WithJobStatus(JobRunSelectedStatuses.SynchedSource)
+                        .WithGradient(IsGradientSelection.SynchedSource)
+                        .Query(y => y.Where(x => (String.IsNullOrEmpty(SelectedJobName) || x.JobName.ToString().ToLower().StartsWith(SelectedJobName.ToLower()))
+                        && ( x.JobLength < LengthUpperValue && x.JobLength >= LengthLowerValue)
+                        ))
+                        .BuildListAsync();
+
+                        var modelList = runs.Select(x => new JobRunModel()
+                        {
+                            JobRun = x,
+                            Machine = _allMachines.FirstOrDefault(y => y.Guid == x.MachineGuid),
+                            User = _allUsers.SingleOrDefault(y => y.Guid == x.UserGuid),
+                        }).ToList();
+
+                        modelList.ForEach(x => x.Init());
+                        JobRuns = modelList.ToObservableCollection();
+                    }
+                }
+                catch (Exception ex)
+                {
+                    LogManager.Log(ex, "Error loading job runs.");
+                }
+                finally
+                {
+                    IsFree = true;
+                }
+            }
+        }
+
+    }
+}