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.sql = sqlite;

            autoManager.OnOperationModeChanged += AutoManager_OnOperationModeChanged;
        }

        private void AutoManager_OnOperationModeChanged( eOperatationMode obj )
        {
            var mode = CastTo<eOperatationMode>.From<object>( obj );

            var msg = new OCSMessage();
            if ( mode == eOperatationMode.AutoMode )
            {
                msg.Kind = eKind.I;
                msg.Tag = this.vehicle.CurrentTag;
                msg.IsSubCode1 = this.vehicle.IsContain;
                msg.IsSubCode2 = vehicle.IsMoving;
                msg.IsSubCode3 = vehicle.IsError;
            }
            else if ( mode == eOperatationMode.ManualMode )
            {
                msg.Kind = eKind.O;
                msg.Tag = this.vehicle.CurrentTag;
                msg.IsSubCode1 = this.vehicle.IsContain;
                msg.IsSubCode2 = vehicle.IsMoving;
                msg.IsSubCode3 = vehicle.IsError;
            }
            else
                return;

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