using Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming; using Edge.Core.Parser.BinaryParser; using Edge.Core.Parser.BinaryParser.MessageEntity; using System; using System.Collections.Generic; using System.Linq; using System.Text; namespace Dfs.WayneChina.HengshanPayTerminal { public class MessageTemplateLookup : IMessageTemplateLookup { /// /// Gets the default singleton instance of type MessageTemplateLookup. /// public static MessageTemplateLookup Default { get; } = new MessageTemplateLookup(); /// /// Dictionary that holds the commands and types /// private static readonly Dictionary messageCodeToTypeStrDict = new Dictionary(); static MessageTemplateLookup() { messageCodeToTypeStrDict.Add("0x10", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.CheckCmdRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x13", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.RegisterRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x15", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.ValidateCardRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x17", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.AuthRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x19", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.CancelAuthRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x1C", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.FuelingDataRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x20", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.ChangeAuthModeAck,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x21", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.QueryGrayRecordRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x2D", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.TransactionDataRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x30", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.PaymentRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x45", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.LockOrUnlockPumpAck,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x24", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.VolumeTotal,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x25", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.DataDownloadRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x27", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.DataContentRequest,Dfs.WayneChina.HengshanPayTerminal"); messageCodeToTypeStrDict.Add("0x49", "Dfs.WayneChina.HengshanPayTerminal.MessageEntity.Incoming.Totalizer,Dfs.WayneChina.HengshanPayTerminal"); } public MessageTemplateBase GetMessageTemplateByRawBytes(byte[] bytes) { var msgHandleCode = bytes.Skip(6).First(); var key = "0x" + msgHandleCode.ToString("X").PadLeft(2, '0'); if (messageCodeToTypeStrDict.ContainsKey(key)) { var found = messageCodeToTypeStrDict[key]; var targetType = Type.GetType(found); var targetInstance = (MessageTemplateBase)Activator.CreateInstance(targetType); return targetInstance; } else { throw new ArgumentException("Can't find correlated message entity type for incoming raw message bytes: " + bytes.Select(s => s.ToString("X").PadLeft(2, '0')).Aggregate((n, acc) => n + " " + acc)); } } } }