OHV/Dev/OHV/VehicleControlSystem/Managers/HostManager.cs

using System;
using GSG.NET.Logging;
using OHV.Common.Events;
using OHV.Common.Shareds;
using OHV.SqliteDAL;
using OHVConnector;
using Prism.Events;
using VehicleControlSystem.ControlLayer;
using GSG.NET.Extensions;
using OHV.Common.Model;
using GSG.NET.Quartz;
using System.Linq;
using System.Collections.Generic;

namespace VehicleControlSystem.Managers
{
    /// <summary>
    /// OCS 와 통신 관리
    /// </summary>
    public class HostManager : IDisposable
    {
        static Logger loggerHost = Logger.GetLogger( "Host" );
        static Logger logger = Logger.GetLogger();

        OHVConnector.Manager manager = new OHVConnector.Manager();
        IEventAggregator eventAggregator = null;
        Vehicle vehicle = null;
        SqliteManager sql = null;

        public HostManager( IEventAggregator ea, Vehicle vehicle, SqliteManager sqlite, AutoManager autoManager, Scheduler scheduler )
        {
            this.eventAggregator = ea;
            this.vehicle = vehicle;
            this.vehicle.PropertyChanged += Vehicle_PropertyChanged;
            this.sql = sqlite;
            autoManager.OnOccurAlarm += AutoManager_OnOccurAlarm;
            autoManager.OnClearAlarm += AutoManager_OnClearAlarm;
            scheduler.OnMaualAddedCommand += Scheduler_OnMaualAddedCommand;
        }

        private void Scheduler_OnMaualAddedCommand( Command obj )
        {
            var tID = Convert.ToInt32( obj.TargetID );

            var msg = new OCSMessage()
            {
                Kind = eKind.P,
                Tag = tID.ToString("0000"),
            };

            switch ( obj.Type )
            {
                case eCommandType.Move:
                    msg.SubCode = "001";
                    break;
                case eCommandType.MoveNLoad:
                    msg.SubCode = "010";
                    break;
                case eCommandType.MoveNUnload:
                    msg.SubCode = "100";
                    break;
                case eCommandType.Charging:
                    msg.SubCode = "111";
                    break;
                default:
                    break;
            }

            this.manager.Send( msg );

        }

        private void AutoManager_OnClearAlarm( int obj )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.E;
            msg.Tag = obj.ToString("0000");
            msg.IsSubCode1 = vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = false;
            this.manager.Send( msg );
        }

        private void AutoManager_OnOccurAlarm( int obj )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.E;
            msg.Tag = obj.ToString("0000");
            msg.IsSubCode1 = vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = true;
            this.manager.Send( msg );
        }

        private void Vehicle_PropertyChanged( object sender, System.ComponentModel.PropertyChangedEventArgs e )
        {
            if ( e.PropertyName.Equals( "MachineMode" ) )
            {
                var property = sender.GetType().GetProperty( e.PropertyName );
                var newValue = property.GetValue( sender, null );

                var msg = new OCSMessage();

                var mode = CastTo<eMachineMode>.From<object>( newValue );
                if ( mode == eMachineMode.HostMode )
                {
                    msg.Kind = eKind.I;
                    msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
                    msg.IsSubCode1 = this.vehicle.IsContain;
                    msg.IsSubCode2 = vehicle.IsMoving;
                    msg.IsSubCode3 = vehicle.IsError;
                }
                else
                {
                    msg.Kind = eKind.O;
                    msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
                    msg.IsSubCode1 = this.vehicle.IsContain;
                    msg.IsSubCode2 = vehicle.IsMoving;
                    msg.IsSubCode3 = vehicle.IsError;
                }

                this.manager.Send( msg );
            }

        }

        public void Init()
        {
            this.manager.Config = new OHVConnector.Config
            {
                ID = sql.ConfigDal.GetById( ConstString.VehicleID ).Value,
                IpAddress = sql.ConfigDal.GetById( ConstString.Addr ).Value,
                Port = Convert.ToInt16( sql.ConfigDal.GetById( ConstString.PortNo ).Value ),
                HostID = sql.ConfigDal.GetById( ConstString.OCSID ).Value,
            };

            this.manager.OnContd += Manager_OnContd;
            this.manager.OnDiscontd += Manager_OnDiscontd;
            this.manager.OnLog += Manager_OnLog;
            this.manager.OnT3Timeout += Manager_OnT3Timeout;
            this.manager.OnRecd += Manager_OnRecd;
            this.manager.OnSent += Manager_OnSent;

            //Vehicle Server.
            this.manager.Connect( false );

            //Vehicle Event
            vehicle.OnBatteryVelueChanged += Vehicle_OnBatteryVelueChanged;
            vehicle.OnChargingStart += Vehicle_OnChargingStart;
            vehicle.OnCharging += Vehicle_OnCharging;
            vehicle.OnChargingFull += Vehicle_OnChargingFull;

            vehicle.OnCurrentTagChanged += Vehicle_OnCurrentTagChanged;

            //vehicle.OnManualLoad += Vehicle_OnManualLoad;
            //vehicle.OnManualMove += Vehicle_OnManualMove;
            //vehicle.OnManualUnload += Vehicle_OnManualUnload;
            //vehicle.OnManualCharging += Vehicle_OnManualCharging;

            vehicle.OnPIOStart += Vehicle_OnPIOStart;
            vehicle.OnConveyorStart += Vehicle_OnConveyorStart;
            vehicle.OnConveyorStop += Vehicle_OnConveyorStop;
            vehicle.OnLoadComplete += Vehicle_OnLoadComplete;
            vehicle.OnUnloadComplete += Vehicle_OnUnloadComplete;
            vehicle.OnCarrierDetected += Vehicle_OnCarrierDetected;

            vehicle.OnFailReport += Vehicle_OnFailReport;
        }

        private void Vehicle_OnFailReport( Vehicle.eFailCode obj )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.F;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.SubCode = CastTo<int>.From( obj ).ToString( "000" );

            this.manager.Send( msg );
        }

        private void Vehicle_OnChargingFull()
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.H;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = false;
            msg.IsSubCode2 = false;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        private void Vehicle_OnCharging()
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.H;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = false;
            msg.IsSubCode2 = true;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        private void Vehicle_OnChargingStart()
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.H;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = false;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        private void Vehicle_OnCarrierDetected( bool isLoad )
        {
            var msg = new OCSMessage();

            if ( isLoad )
                msg.Kind = eKind.L;
            else
                msg.Kind = eKind.U;

            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = true;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        private void Vehicle_OnUnloadComplete()
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.U;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = true;
            msg.IsSubCode3 = true;

            this.manager.Send( msg );
        }

        private void Vehicle_OnLoadComplete()
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.L;
            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = true;
            msg.IsSubCode3 = true;

            this.manager.Send( msg );
        }

        private void Vehicle_OnConveyorStop( bool isLoad )
        {
            var msg = new OCSMessage();

            if ( isLoad )
                msg.Kind = eKind.L;
            else
                msg.Kind = eKind.U;

            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = false;
            msg.IsSubCode3 = true;

            this.manager.Send( msg );
        }

        private void Vehicle_OnConveyorStart( bool isLoad )
        {
            var msg = new OCSMessage();

            if ( isLoad )
                msg.Kind = eKind.L;
            else
                msg.Kind = eKind.U;

            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = true;
            msg.IsSubCode2 = false;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        private void Vehicle_OnPIOStart( bool isLoad )
        {
            var msg = new OCSMessage();

            if ( isLoad )
                msg.Kind = eKind.L;
            else
                msg.Kind = eKind.U;

            msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );
            msg.IsSubCode1 = false;
            msg.IsSubCode2 = false;
            msg.IsSubCode3 = false;

            this.manager.Send( msg );
        }

        //private void Vehicle_OnManualCharging()
        //{
        //    this.Send_ManualCharging();
        //}

        //private void Vehicle_OnManualUnload()
        //{
        //    this.Send_ManualUnlaod();
        //}

        //private void Vehicle_OnManualMove()
        //{
        //    this.Send_ManualMove();
        //}

        //private void Vehicle_OnManualLoad()
        //{
        //    this.Send_ManualLoad();
        //}

        private void Vehicle_OnCurrentTagChanged( int point )
        {
            this.Send_Tcmd( point );
        }

        private void Vehicle_OnBatteryVelueChanged( double obj )
        {
            this.Send_Bcmd( obj );
        }

        #region Event Method
        private void Manager_OnSent( OHVConnector.OCSMessage msg )
        {
            loggerHost.I( "[Sent] : " + msg.LogFormat() );
        }

        private void Manager_OnRecd( OHVConnector.OCSMessage msg )
        {
            loggerHost.I( "[Received] : " + msg.LogFormat() );

            switch ( msg.Kind )
            {
                case OHVConnector.eKind.Unknown:
                    break;
                case OHVConnector.eKind.E://Error 보고 요청.
                    break;
                case OHVConnector.eKind.S://마지막으로 읽은 TagNo
                    break;
                case OHVConnector.eKind.B://battery Report
                    break;
                case OHVConnector.eKind.T://위치 응답
                    break;
                case OHVConnector.eKind.C://제어 요청
                    break;
                case OHVConnector.eKind.P://수동명령보고
                    break;
                case OHVConnector.eKind.I:
                    break;
                case OHVConnector.eKind.O:
                    break;
                case OHVConnector.eKind.A://Alive 
                    break;
                case OHVConnector.eKind.L:
                    break;
                case OHVConnector.eKind.U:
                    break;
                case OHVConnector.eKind.F:
                    break;
                case OHVConnector.eKind.M:
                    ReceiveMCommand( msg );
                    break;
                case OHVConnector.eKind.R:
                    ReceiveRCommand( msg );
                    break;
                case OHVConnector.eKind.H:
                    break;
                case OHVConnector.eKind.Z:
                    break;
                case eKind.G:
                    ReceiveGCommand( msg );
                    break;
                default:
                    break;
            }

        }

        private void ReceiveGCommand( OCSMessage msg )
        {
            this.Reply( msg );

            var cmd = new Command();

            var info = sql.VehicleInfoDAL.GetAll().FirstOrDefault();
            if ( info.MachineMode == eMachineMode.LocalMode )
            {
                loggerHost.E( $"[OCS] Cmd - Current Mode Local Mode " );
                return;
            }

            if ( this.sql.CommandDAL.Count > 0 )
            {
                logger.W( $"[{this.GetType().Name}] - Has Command / Target {cmd.TargetID} / Type {cmd.Type}" );
                return;
            }

            cmd.TargetID = msg.Tag;
            cmd.Type = eCommandType.Move;
            cmd.ByWho = eCommandByWho.Host;
            cmd.TargetList = new List<string>( msg.ViaRouteList );

            this.sql.CommandDAL.Insert( cmd );
            logger.I( $"[Command] - Add Host : Target {cmd.TargetID} / Type {cmd.Type}" );
        }

        void Reply( OCSMessage recieve )
        {
            var reply = new OCSMessage();
            reply.Kind = recieve.Kind;
            reply.Tag = recieve.Tag;
            reply.SubCode = recieve.SubCode;
            this.manager.Reply( reply );
        }

        private void ReceiveRCommand( OCSMessage msg )
        {
            this.Reply( msg );

            if ( msg.SubCode.Equals( "100" ) )
            {
                Send_Scmd( );
            }
            if ( msg.SubCode.Equals( "010" ) )
            {
                Send_Bcmd( this.vehicle.BatteryVoltage );
            }
        }

        private void ReceiveMCommand( OCSMessage msg )
        {
            this.Reply( msg );

            var cmd = new Command();

            var info = sql.VehicleInfoDAL.GetAll().FirstOrDefault();
            if ( info.MachineMode == eMachineMode.LocalMode )
            {
                loggerHost.E( $"[OCS] Cmd - Current Mode Local Mode " );
                return;
            }

            var hasCommand = this.sql.CommandDAL.GetAll().FirstOrDefault();
            if ( hasCommand != null )
            {
                if ( !hasCommand.IsSecondCommanded )
                {
                    switch ( msg.SubCode )
                    {
                        case "000": //Move
                            cmd.Type = eCommandType.Move;
                            break;
                        case "001": //Move and Load
                            cmd.Type = eCommandType.MoveNLoad;
                            break;
                        case "002": //Move and Unload
                            cmd.Type = eCommandType.MoveNUnload;
                            break;
                        case "003": //Move and Charge
                            cmd.Type = eCommandType.Charging;
                            break;
                        case "004": //Cancel
                            cmd.Type = eCommandType.Cancel;
                            break;
                        default:
                            return;
                    }

                    cmd.ByWho = eCommandByWho.HostOverWrite;
                    cmd.TargetList = new List<string>( msg.ViaRouteList );

                    cmd.TargetID = msg.Tag;

                    this.sql.CommandDAL.Insert( cmd );
                    logger.I( $"[Command] - Add HostOverWrite : Target {cmd.TargetID} / Type {cmd.Type}" );

                    sql.CommandDAL.Delete( hasCommand.CommandID );
                }
                else
                {
                    loggerHost.E( $"[OCS] Cmd - {msg.Kind} Message Tag [{msg.Tag}] - Already Load/Unload " );
                    return;
                }
            }
            else
            {
                cmd.TargetID = msg.Tag;

                switch ( msg.SubCode )
                {
                    case "000": //Move
                        cmd.Type = eCommandType.Move;
                        break;
                    case "001": //Move and Load
                        cmd.Type = eCommandType.MoveNLoad;
                        break;
                    case "002": //Move and Unload
                        cmd.Type = eCommandType.MoveNUnload;
                        break;
                    case "003": //Cancel
                        cmd.Type = eCommandType.Charging;
                        break;
                    default:
                        return;
                }
                cmd.ByWho = eCommandByWho.Host;
                cmd.TargetList = new List<string>( msg.ViaRouteList );

                this.sql.CommandDAL.Insert( cmd );
                logger.I( $"[Command] - Add Host : Target {cmd.TargetID} / Type {cmd.Type}" );

            }

        }

        private void Manager_OnT3Timeout( OHVConnector.OCSMessage msg )
        {
            loggerHost.E( "[TimeOut] : " + msg.LogFormat() );
        }

        private void Manager_OnLog( string id, string log )
        {
            loggerHost.I( "[Log] : " + log );
        }

        private void Manager_OnDiscontd( string id, Exception e )
        {
            var msg = new HostConnectedEventArgs( HostConnectedEventArgs.eConnectedState.Disconnected );
            this.eventAggregator.GetEvent<HostConnectedPubSubEvent>().Publish( msg );

            QuartzUtils.StopSchedule( "BatteryReport" );
        }

        private void Manager_OnContd( string id )
        {
            var msg = new HostConnectedEventArgs( HostConnectedEventArgs.eConnectedState.Connected );
            this.eventAggregator.GetEvent<HostConnectedPubSubEvent>().Publish( msg );

            QuartzUtils.Invoke( "BatteryReport", QuartzUtils.GetExpnMinute( 1 ), BatteryState_Report );
        }

        #endregion

        #region Pooling Report
        void BatteryState_Report()
        {
            Send_Bcmd( this.vehicle.BatteryVoltage );
        }
        #endregion

        #region Send
        /// <summary>
        /// 현재 위치 보고 
        /// </summary>
        public void Send_Scmd( )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.S;

            if ( this.vehicle.CurrentTag < 0 )
                msg.Tag = 0.ToString( "0000" );
            else
                msg.Tag = this.vehicle.CurrentTag.ToString( "0000" );

            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Bcmd( double volt )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.B;
            var bData = volt;
            msg.Tag = bData.ToString( "00.00" ).Replace( ".", "" );
            msg.SubCode = this.vehicle.BatteryStateOfCharge.ToString( "000" );
            //msg.IsSubCode1 = this.vehicle.IsContain;
            //msg.IsSubCode2 = vehicle.IsMoving;
            //msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Ecmd(int AlarmNo)
        {
            var msg = new OCSMessage();
            msg.Tag = AlarmNo.ToString( "0000" );
            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Tcmd( int point )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.T;
            msg.Tag = point.ToString( "0000" );
            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Ccmd( string crossPointID )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.C;
            msg.Tag = crossPointID;
            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_ManualMove()
        {
            var msg = new OCSMessage()
            {
                Kind = eKind.P,
                Tag = this.vehicle.CurrentTag.ToString( "0000" ),
                IsSubCode1 = false,
                IsSubCode2 = false,
                IsSubCode3 = true,
            };
            this.manager.Send( msg );
        }

        public void Send_ManualLoad()
        {
            var msg = new OCSMessage()
            {
                Kind = eKind.P,
                Tag = this.vehicle.CurrentTag.ToString( "0000" ),
                IsSubCode1 = false,
                IsSubCode2 = true,
                IsSubCode3 = false,
            };
            this.manager.Send( msg );
        }

        public void Send_ManualUnlaod()
        {
            var msg = new OCSMessage()
            {
                Kind = eKind.P,
                Tag = this.vehicle.CurrentTag.ToString( "0000" ),
                IsSubCode1 = true,
                IsSubCode2 = false,
                IsSubCode3 = false,
            };
            this.manager.Send( msg );

        }
        public void Send_ManualCharging()
        {
            var msg = new OCSMessage()
            {
                Kind = eKind.P,
                Tag = this.vehicle.CurrentTag.ToString( "0000" ),
                IsSubCode1 = true,
                IsSubCode2 = true,
                IsSubCode3 = true,
            };
            this.manager.Send( msg );
        }
        #endregion
        public void Dispose()
        {
            this.manager.Disconnect();
        }
    }
}