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