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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
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;

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

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

        public HostManager( IEventAggregator ea, Vehicle vehicle, SqliteManager sqlite, AutoManager autoManager )
        {
            this.eventAggregator = ea;
            this.vehicle = vehicle;
            this.vehicle.PropertyChanged += Vehicle_PropertyChanged;
            this.sql = sqlite;
        }

        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;
                    msg.IsSubCode1 = this.vehicle.IsContain;
                    msg.IsSubCode2 = vehicle.IsMoving;
                    msg.IsSubCode3 = vehicle.IsError;
                }
                else
                {
                    msg.Kind = eKind.O;
                    msg.Tag = this.vehicle.CurrentTag;
                    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.GetK( ConstString.VehicleID ).Value,
                IpAddress = sql.ConfigDal.GetK( ConstString.Addr ).Value,
                Port = Convert.ToInt16( sql.ConfigDal.GetK( ConstString.PortNo ).Value ),
                HostID = sql.ConfigDal.GetK( 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;
            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;
            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;
            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;
            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;
            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;
            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;
            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;
            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;
            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;
            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( string 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 )
        {
            logger.I( "[Sent] : " + msg.LogFormat() );
        }

        private void Manager_OnRecd( OHVConnector.OCSMessage msg )
        {
            logger.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;
                default:
                    break;
            }

        }

        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( (int)this.vehicle.CurrentPosition );
            }
            if ( msg.SubCode.Equals( "010" ) )
            {
                Send_Bcmd( this.vehicle.BatteryVolt );
            }
        }

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

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

            var hasCommand = this.sql.CommandDAL.GetCmd();
            if ( hasCommand != null )
            {
                //Todo: 충전 중에는 어떻게 하지???
                if ( !hasCommand.IsSecondCommanded )
                    sql.CommandDAL.Delete( hasCommand );
                else
                {
                    logger.E( $"[OCS] Cmd - {msg.Kind} Message Tag [{msg.Tag}] - Already Load/Unload " );
                    return;
                }

            }

            var cmd = new Command();

            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;
                default:
                    return;
            }

            //Todo: 등록 되어 있는 경로 가 있는 지 확인 필요.
            var route = this.sql.RouteDal.GetRouteFromOCSMatchID( msg.Tag );
            if ( route == null )
            {
                logger.E( $"[OCS] Message Tag [{msg.Tag}] - not found route" );
                return;
            }

            cmd.TargetID = route.Name;

            this.sql.CommandDAL.Add( cmd );
        }

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

        private void Manager_OnLog( string id, string log )
        {
            logger.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.BatteryVolt );
        }
        #endregion

        #region Send
        /// <summary>
        /// 현재 위치 보고 
        /// </summary>
        public void Send_Scmd( int point )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.S;
            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_Bcmd( double volt )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.B;
            var bData = volt;
            msg.Tag = bData.ToString( "00.00" ).Replace( ".", "" );
            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Ecmd()
        {
            var msg = new OCSMessage();
            msg.Tag = vehicle.CurrentTag;
            msg.IsSubCode1 = this.vehicle.IsContain;
            msg.IsSubCode2 = vehicle.IsMoving;
            msg.IsSubCode3 = vehicle.IsError;

            this.manager.Send( msg );
        }

        public void Send_Tcmd( string point )
        {
            var msg = new OCSMessage();
            msg.Kind = eKind.T;
            msg.Tag = point;
            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,
                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,
                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,
                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,
                IsSubCode1 = true,
                IsSubCode2 = true,
                IsSubCode3 = true,
            };
            this.manager.Send( msg );
        }
        #endregion
        public void Dispose()
        {
            this.manager.Disconnect();
        }
    }
}