MARKUS



using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Markus.Service.Extensions;

using Markus.Message;

using Markus.Service.StationController.Extensions;

using Markus.Service.Interface;

namespace Markus.Service.StationController.ViewModel

{

    public class DataBaseByStatusViewModel : Mvvm.ToolKit.ViewModelBase

    {

        BackgroundWorker backgroundWorker;

        private System.Collections.ObjectModel.ObservableCollection<ConvertItem> items;

        private ConvertItem selectItem;

        private IEnumerable<StatusCodeType> statusType;

        private bool isLoading;

        public System.Collections.ObjectModel.ObservableCollection<ConvertItem> Items

        {

            get => items; set

            {

                items = value;

                OnPropertyChanged(() => Items);

            }

        }

        public ConvertItem SelectItem

        {

            get => selectItem; set

            {

                selectItem = value;

                OnPropertyChanged(() => SelectItem);

            }

        }

        public IEnumerable<StatusCodeType> StatusType

        {

            get => statusType; set

            {

                statusType = value;

                OnPropertyChanged(() => StatusType);

            }

        }

        public bool IsLoading

        {

            get => isLoading; set

            {

                if (isLoading != value)

                {

                    isLoading = value;

                    OnPropertyChanged(() => IsLoading);

                }

            }

        }

        public DataBaseByStatusViewModel()

        {

        }

        // 진행률에 변화가 있을때 이벤트가 발생

        private void backgroundWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)

        {

        }

        // 일이 모두 마쳤을때 수행되어야할 코드

        private void backgroundWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)

        {

        }

        // BackgroundWorker에서 수행할 일을 정의.

        private void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)

        {

            while (IsAcitve)

            {

                System.Threading.Thread.Sleep(1000);

                try

                {

                    IsLoading = true;

                    List<ConvertItem> newitems = new List<ConvertItem>();

                    using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(App.MarkusDataBaseConnecitonString))

                    {

                        foreach (var status in statusType)

                        {

                            newitems.AddRange(database.GetConvertItems(status, x => x.TOTAL_PAGE > 100, 10));

                        }

                    }

                    if (Items == null)

                    {

                        Items = new System.Collections.ObjectModel.ObservableCollection<ConvertItem>();

                        foreach (var item in newitems)

                        {

                            Items.Add(item);

                        }

                    }

                    else

                    {

                        /// 데이터 업데이트

                        newitems.ForEach(newitem =>

                        {

                            Items.UpdateWhere(changeitem => ConvertItemEx.ChangeValues(changeitem, newitem), x => x.ProjectNumber == newitem.ProjectNumber && x.ConvertID == newitem.ConvertID);

                        });

                        // 추가

                        foreach (var item in newitems)

                        {

                            if (Items.Count(x => x.ConvertID == item.ConvertID && x.ProjectNumber == item.ProjectNumber) == 0)

                            {

                                Items.Add(item);

                            }

                        }

                        /// 삭제

                        for (int i = Items.Count() - 1; i > -1; --i)

                        {

                            var item = Items[i];

                            if (newitems.Count(x => x.ConvertID == item.ConvertID && x.ProjectNumber == item.ProjectNumber) == 0)

                            {

                                Items.RemoveAt(i);

                            }

                        }

                    }

                }

                catch (Exception ex)

                {

                }

            }

        }

        public override void Loaded()

        {

            base.Loaded();

            if (!App.IsDesignMode)

            {

                backgroundWorker = new BackgroundWorker();

                backgroundWorker.DoWork += backgroundWorker_DoWork;

                backgroundWorker.RunWorkerCompleted += backgroundWorker_RunWorkerCompleted;

                backgroundWorker.WorkerReportsProgress = false;

                backgroundWorker.ProgressChanged += new ProgressChangedEventHandler(backgroundWorker_ProgressChanged);

                backgroundWorker.RunWorkerAsync();

            }

        }

        public override void Closed()

        {

            if (!App.IsDesignMode)

            {

                backgroundWorker.DoWork -= backgroundWorker_DoWork;

                backgroundWorker.RunWorkerCompleted -= backgroundWorker_RunWorkerCompleted;

                backgroundWorker.WorkerReportsProgress = false;

                backgroundWorker.ProgressChanged -= new ProgressChangedEventHandler(backgroundWorker_ProgressChanged);

                backgroundWorker.Dispose();

            }

            base.Closed();

        }

    }

}