MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Windows.Input;

using KCOM.KcomService;

using KCOMDataModel.DataModel;

namespace KCOM.Common

{

    public class DataSaveTask : IDisposable

    {

        private KcomService.ServiceDeepViewClient DeepViewTaskClient;

        private Views.MainMenu mainMenu;

        private TimeSpan _Interval;

        public TimeSpan Interval { get => _Interval; set => _Interval = value; }

        private bool _IsEnabled;

        public bool IsEnabled

        {

            get => _IsEnabled;

            set

            {

                if(_IsEnabled != value)

                {

                    _IsEnabled = value;

                    if (_IsEnabled)

                    {

                       Start();

                    }

                }

            }

        }

        public DataSaveTask()

        {

            if (DeepViewTaskClient == null)

            {

                DeepViewTaskClient = new ServiceDeepViewClient(App._binding, App._EndPoint);

            }

            this.Interval = new TimeSpan(0,0,10);

        }

        public DataSaveTask(TimeSpan interval, bool enable)

        {

            if (DeepViewTaskClient == null)

            {

                DeepViewTaskClient = new ServiceDeepViewClient(App._binding, App._EndPoint);

            }

            this.Interval = interval;

            this.IsEnabled = enable;

        }

        /// <summary>

        /// 자동 저장 작업

        /// </summary>

        public async void Start()

        {

            while (IsEnabled)

            {

                if (ViewerDataModel.Instance?.SystemMain?.dzMainMenu != null)

                {

                    mainMenu = ViewerDataModel.Instance.SystemMain.dzMainMenu;

                    if (mainMenu.gridViewMarkup.SelectedItems.Count > 0)

                    {

                        if (mainMenu.currentControl == null)// && mainMenu.SelectLayer.Children.Count == 0)

                        {

                            var result = await AutoSaveTaskAsync(mainMenu);

                            if (result)

                            {

                                // log

                            }

                            else

                            {

                                // log

                            }

                        }

                    }

                }

                await Task.Delay(Interval);

            }

        }

        private async Task<bool> AutoSaveTaskAsync(Views.MainMenu mainMenu)

        {

            bool result = false;

            mainMenu.ConvertInkControlToPolygon();

            //SelectionSet.Instance.UnSelect(mainMenu);

            // update mylist and gridview

            mainMenu.UpdateMyMarkupList();

            /// 현재 사용자의 선택된 마크업(현재 수정중인 마크업)만 저장하도록 한다.

            var saveItems = mainMenu.gridViewMarkup.SelectedItems.Cast<IKCOM.MarkupInfoItem>().Where(x => x.UserID == App.ViewInfo.UserID).ToList();

            result = await SaveProcessTaskAsync(saveItems);

            if (result)

            {

                //Common.ViewerDataModel.Instance.SystemMain.dzMainMenu.gridViewMarkup.Rebind();

                saveItems.ForEach(x =>

                {

                    var item = ViewerDataModel.Instance._markupInfoList.Where(data => data.MarkupInfoID == x.MarkupInfoID);

                    if (item.Count() > 0)

                    {

                        item.First().UpdateTime = DateTime.Now;

                    }

                });

            }

            //ViewerDataModel.Instance.UndoDataList.Clear();

            return result;

        }

        private async Task<bool> SaveProcessTaskAsync(ICollection<IKCOM.MarkupInfoItem> UserStates)

        {

            bool result = false;

            try

            {

                string project_no = App.ViewInfo.ProjectNO;

                string doc_id = App.ViewInfo.DocumentItemID;

                string user_id = App.ViewInfo.UserID;

                int currentPageNo = ViewerDataModel.Instance.PageNumber;

                foreach (var UserState in UserStates)

                {

                    bool IsSuccess = false;

                    List <MARKUP_DATA> markupdata = new List<MARKUP_DATA>();

                    //markupdata = UserState.MarkupList.Select(x=>

                    //    new MARKUP_DATA()

                    //    {

                    //        ID = x.ID,

                    //        PAGENUMBER = x.PageNumber,

                    //        DATA = x.Data,

                    //        MARKUPINFO_VERSION_ID = UserState.MarkupVersionID,

                    //        DATA_TYPE = x.Data_Type

                    //    }

                    //).ToList();

                    var updateItems = ViewerDataModel.Instance.MyMarkupList

                                    .Where(d => d.MarkupInfoID == UserState.MarkupInfoID && d.PageNumber == currentPageNo)

                                    .GroupBy(p => p.ID).Select(g => g.First()).ToList();

                    if (updateItems.Count() > 0)

                    {

                        updateItems.ForEach(value =>

                        {

                            markupdata.Add(new MARKUP_DATA()

                            {

                                ID = value.ID,

                                PAGENUMBER = value.PageNumber,

                                DATA = value.Data,

                                MARKUPINFO_VERSION_ID = UserState.MarkupVersionID,

                                DATA_TYPE = value.Data_Type

                            });

                        });

                        IsSuccess = await DeepViewTaskClient.SavePageMarkupDataAsync(UserState,currentPageNo, project_no, doc_id, user_id, markupdata);

                        System.Diagnostics.Debug.WriteLine($"SaveProcessTaskAsync Project : {project_no} DocID :{doc_id} User ID {user_id} result {IsSuccess}");

                        Logger.sendResLog("SaveProcessTaskAsync", $" Project : {project_no} DocID :{doc_id} User ID {user_id} result {IsSuccess}", 1);

                    }

                    else

                    {

                        IsSuccess = true;

                        System.Diagnostics.Debug.WriteLine($"SaveProcessTaskAsync Project : {project_no} DocID :{doc_id} User ID {user_id} Item = 0");

                    }

                    if (!IsSuccess)

                    {

                        result = false;

                        break;

                    }

                    else

                    {

                        result = true;

                        //Common.ViewerDataModel.Instance.SystemMain.dzMainMenu.MarkupitemViewUpdate(UserState.MarkupInfoID);

                    }

                }

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine($"SaveProcessTaskAsync Error {ex.ToString()}");

                Logger.sendResLog("SaveProcessTaskAsync", ex.Message, 1);

            }

            return result;

        }

        public void Dispose()

        {

            DeepViewTaskClient = null;

        }

    }

}