OHV/Dev/OHV/VehicleControlSystem/ControlLayer/Serial/BatteryTabos/BMUManager.cs

using GSG.NET.Concurrent;
using GSG.NET.Extensions;
using GSG.NET.Logging;
using GSG.NET.Quartz;
using GSG.NET.Utils;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using VehicleControlSystem.ControlLayer.Serial.DataModel;

namespace VehicleControlSystem.ControlLayer.Serial.BatteryTabos
{
    public class BMUManager
    {
        static Logger logger = Logger.GetLogger();

        Peak com = null;
        public Config BMUConfig { get; set; }
        public bool IsConnected { get; set; }

        internal Dictionary<string, ReceivedData> ReceivedDataDic = new Dictionary<string, DataModel.ReceivedData>();
        protected TsQueue<QueObject> qq = new TsQueue<QueObject>( 512 );

        public ThreadCancel cancel = new ThreadCancel();

        CbTimer polling = new CbTimer();
        long collectNo = 0;
        long collectElasped = 0;

        protected object LockObject = new object();

        #region Event
        public event Action<string> OnConnect;
        public event Action<string> OnDisconnect;
        public event Action<ReceivedData> OnChangedReceivedData;
        public event Action<List<ReceivedData>> OnFirstColtd;
        #endregion

        public BMUManager()
        {
            this.BMUConfig = new Config();
            this.Init();
        }

        private void Init()
        {
            EnumExtensions.GetValues<eDataKind>().ToList().ForEach( x => { this.ReceivedDataDic.Add( x.ToString(), new ReceivedData(x) ); } );
        }

        protected void EnqueueToNet( object o )
        {
            this.com.Enqueue( o );
        }


        protected void _ThPullQueue()
        {
            while ( !cancel.Canceled )
            {
                try
                {
                    var qo = this.qq.Dequeue();

                    if ( qo is QoConnect )
                        DelegateUtils.Invoke( OnConnect, qo.Arg0 );
                    else if ( qo is QoDisconnected )
                        DelegateUtils.Invoke( OnDisconnect, qo.Arg0 );
                    else if ( qo is QoReceivedDataChanged )
                        DelegateUtils.Invoke( OnChangedReceivedData, qo.Arg0 );
                    //else if ( qo is QoSendMessageSuccess )
                    //    DelegateUtils.Invoke( OnSendSetDataSuccess, qo.Arg0 );
                    else
                        Assert.Fail( "Unk Object {0}", qo );
                }
                catch ( ThreadAbortException )
                {
                    break;
                }
                catch ( Exception e )
                {
                    logger.E( e );
                }
            }
        }


        #region Net Invoke Method
        internal void _OnConnected()
        {
            if ( 0 != collectNo )
                this.qq.Enqueue( new QoConnect { Arg0 = this.BMUConfig.ID } );

            _OnTimePoll();
        }

        internal void _OnDisconnected()
        {
            this.qq.Enqueue( new QoDisconnected { Arg0 = this.BMUConfig.ID } );
        }

        internal void _InvokeChgdWordsAndBits()
        {
            //Todo: 변경 된 내용 처리.
            if ( 0 == collectNo )
            {
                //this.qq.Enqueue( new QoConnect { Arg0 = this.BMUConfig.ID } );
                var ll = this.ReceivedDataDic.Values.ToList();
                DelegateUtils.Invoke( OnFirstColtd, ll );
            }

            //var v = new MapScan
            //{
            //    CollectTime = (int)SwUtils.Elapsed( collectElasped )
            //};
            //DlgUtils.Invoke( OnCollected, v );
            if ( long.MaxValue <= this.collectNo )
                this.collectNo = 1;

            this.collectNo++;

            var rlist = this.ReceivedDataDic.ToList();
            rlist.ForEach( r =>
            {
                if ( r.Value.IsChanged )
                {
                    r.Value.IsChanged = false;
                    var clone = ObjectCopyUtils.DeepClone( r );
                    this.qq.Enqueue( new QoReceivedDataChanged { Arg0 = clone } );
                }
            } );

            //다음 timer 기동 시 까지 잠시 대기
            polling.Once( _OnTimePoll, 100 );
        }

        void _OnTimePoll()
        {
            //Todo: Scan 으로 읽어 오는 영역의 명령을 Net 쪽으로 보내야함. 

            lock ( this.LockObject )
            {
                collectElasped = SwUtils.T;

                this.EnqueueToNet( new PollingObject() );
                this.EnqueueToNet( new DoInvokeChangedReceivedData() );//Invoke Changed
            }
        }

        //internal void _OnSendDataSuccess( ISetData data )
        //{
        //    this.qq.Enqueue( new QoSendMessageSuccess { Arg0 = data } );
        //}
        #endregion


        #region Public Method
        public void Connect()
        {
            //외부 전달 시작
            this.cancel.AddGo( _ThPullQueue );

            //읽기 시작.
            this.com = new Peak(this);
            this.cancel.AddGo( this.com._ThreadPoolingReceiveData );
        }

        public void Disconnect()
        {
            collectNo = 0;
            //Thread Stop
            this.cancel.Cancel();
            this.cancel.StopWaitAll();
        }

        public void test()
        {
            var clone = this.ReceivedDataDic.Values.FirstOrDefault(); 
            this.qq.Enqueue( new QoReceivedDataChanged { Arg0 = clone } );
        }
        #endregion
    }
}