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();

        ICanConnecter can = null;

        public Config BMUConfig { get; set; }
        public bool IsConnected { get { return this.can.IsConnected; } }

        internal Dictionary<eDataKind, ReceivedData> ReceivedDataDic = new Dictionary<eDataKind , 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();

        public enum eCANSelect
        {
            Advantech = 0,
            Peak
        }

    #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 => 
            {
                var data = new ReceivedData( x );
                switch ( x )
                {
                    case eDataKind.Voltage:
                        data.Scale = 0.01;
                        break;
                    case eDataKind.Current:
                        data.Scale = 0.01;
                        break;
                    case eDataKind.BatteryState:
                        data.Scale = 1;
                        break;
                    case eDataKind.ChargeCompleteTime:
                        data.Scale = 60;
                        break;
                    case eDataKind.DisChargeCompleteTime:
                        data.Scale = 60;
                        break;
                    case eDataKind.SOC:
                        data.Scale = 1;
                        break;
                    case eDataKind.SOH:
                        data.Scale = 1;
                        break;
                    case eDataKind.ResidualCapacity:
                        data.Scale = 0.01;
                        break;
                    case eDataKind.ResidualEnergy:
                        data.Scale = 0.1;
                        break;
                    case eDataKind.Temperature:
                        data.Scale = 0.1;
                        break;
                    default:
                        break;
                }
                this.ReceivedDataDic.Add( x, data); 
            } );
        }

        protected void EnqueueToNet( object o )
        {
            this.can.Enqueue( o );
            
            //this.peakCom.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 if ( qo is QoDispose )
                        break;
                    else
                        Assert.Fail( "Unk Object {0}", qo );
                }
                catch ( ThreadAbortException )
                {
                    break;
                }
                catch ( Exception e )
                {
                    logger.E( e );
                }
            }

            logger.D( "[BMU] - Pull Queue Thread End" );
        }


    #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 } );
                this.qq.Enqueue( new QoConnect { Arg0 = this.BMUConfig.ID , Arg1 = true } );
                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.Values.ToList();
            rlist.ForEach( r =>
            {
                if ( r.IsChanged )
                {
                    r.IsChanged = false;
                     //clone test 
                    //var clone = ObjectCopyUtils.DeepClone( r );
                    this.qq.Enqueue( new QoReceivedDataChanged { Arg0 = r } );
                }
            } );

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

        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(eCANSelect select)
        {
#if SIMULATION
            return;
#else
            //외부 전달 시작
            this.cancel.AddGo( _ThPullQueue );

            //읽기 시작.

            switch ( select )
            {
                case eCANSelect.Advantech:
                    this.can = new Advantech( this, "can1" );
                    this.cancel.AddGo( this.can._ThreadPoolingReceiveData );
                    break;
                case eCANSelect.Peak:
                    this.can = new Peak( this );
                    this.cancel.AddGo( this.can._ThreadPoolingReceiveData );
                    break;
            }
#endif
        }

        public void Disconnect()
        {
#if SIMULATION
            return;
#else
            collectNo = 0;
            //Thread Stop
            this.cancel.Cancel();
            this.qq.Enqueue( new QoDispose() );
            this.cancel.StopWaitAll();
#endif
        }

#endregion
    }
}