FCC/Devices/Terminals/WayneChina_IcCardReader_SinoChem/Handler.cs

using Edge.Core.Processor;using Edge.Core.IndustryStandardInterface.Pump;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using WayneChina_IcCardReader_SinoChem.MessageEntity;
using WayneChina_IcCardReader_SinoChem.MessageEntity.Incoming;

namespace WayneChina_IcCardReader_SinoChem
{
    public class Handler : IDeviceHandler<byte[], IcCardReaderMessageBase>, IFdcCommunicableController
    {
        static NLog.Logger logger = NLog.LogManager.LoadConfiguration("nlog.config").GetLogger("PumpHandler");

        #region Fields

        private int nozzleIdA;
        private int nozzleIdB;
        private object syncObj = new object();

        private readonly int addressA;
        private readonly int addressB;

        #endregion

        #region Interface implementation, UNUSED for now

        public Guid Id => Guid.NewGuid();
        public Func<string, bool> BroadcastMessageViaFdc { get; set; }
        public Func<string, Tuple<string, global::Wayne.FDCPOSLibrary.OverallResult>> OnMessageReceivedViaFdc { get; set; }
        public Func<string, string, string, bool> SendMessageViaFdc { get; set; }

        #endregion

        #region Event Handler

        public event EventHandler<CardReaderMessageEventArgs> OnCardReaderMessageReceived;

        #endregion

        #region Constructor

        public Handler(int bindingNozzleIdA, int bindingNozzleIdB, int addressA, int addressB, int numberOfPumpsPerSide, string hasBigScreen)
        {
            nozzleIdA = bindingNozzleIdA;
            nozzleIdB = bindingNozzleIdB;
            this.addressA = addressA;
            this.addressB = addressB;

            NumberOfNozzlesPerSide = numberOfPumpsPerSide;
            HasBigScreen = Convert.ToBoolean(hasBigScreen);
        }

        #endregion

        #region Methods

        public void Init(IContext<byte[], IcCardReaderMessageBase> context)
        {
            CardReaderContext = context;
        }

        public void Write(IcCardReaderMessageBase readerMessage)
        {
            if (CardReaderContext != null)
            {
                lock (syncObj)
                {
                    CardReaderContext.Outgoing.Write(readerMessage);
                }
            }
        }

        public Task Process(IContext<byte[], IcCardReaderMessageBase> context)
        {
            int targetNozzleId = -1;

            if (context.Incoming.Message.SourceAddress == addressA)
            {
                targetNozzleId = nozzleIdA;
            }
            else if (context.Incoming.Message.SourceAddress == addressB)
            {
                targetNozzleId = nozzleIdB;
            }

            OnCardReaderMessageReceived?.Invoke(this, new CardReaderMessageEventArgs(targetNozzleId, context.Incoming.Message));
            return Task.CompletedTask;
        }

        public byte GetAddressForNozzleId(int id)
        {
            if (SupportedNozzles.Contains(id))
            {
                if (id == nozzleIdA)
                    return (byte)addressA;
                if (id == nozzleIdB)
                    return (byte)addressB;
            }

            return 0xFF;
        }

        #endregion

        #region Properties

        public int HandlerId
        {
            get { return Math.Max(nozzleIdA, nozzleIdB) / 2; }
        }

        public int AddressA
        {
            get { return addressA; }
        }

        public int AddressB
        {
            get { return addressB; }
        }

        public List<int> SupportedNozzles
        {
            get
            {
                return new List<int> { nozzleIdA, nozzleIdB };
            }
        }

        public IContext<byte[], IcCardReaderMessageBase> CardReaderContext { get; set; }

        #endregion

        public int NumberOfNozzlesPerSide { get; }

        public bool HasBigScreen { get; }
    }
}