using Edge.Core.Parser.BinaryParser; using Edge.Core.Parser.BinaryParser.MessageEntity; using Edge.Core.Parser.BinaryParser.Util; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace HengShan_Pump_NonIC { public class Parser : ParserBase { protected static NLog.Logger logger = NLog.LogManager.LoadConfiguration("nlog.config").GetLogger("Communicator"); public Parser() : base(new MessageTemplateLookup()) { } public override byte[] Serialize(MessageTemplateBase message) { List bytesWithXRL = null; try { bytesWithXRL = base.Serialize(message).ToList(); if (message.GetType().GetProperty("XRL") != null) { ProcessXRLInMsgBody(ref bytesWithXRL); } return bytesWithXRL.ToArray(); } catch (Exception exxx) { string logStr = message?.GetType().Name ?? ""; if (message != null) try { logStr += System.Environment.NewLine + message.ToLogString(); } catch { } if (bytesWithXRL != null && bytesWithXRL.Any()) try { logStr += System.Environment.NewLine + bytesWithXRL.ToHexLogString(); } catch { } logger.Info("Serialize HengShanNonIC message: " + logStr + System.Environment.NewLine + " exceptioned, detail: " + exxx); throw; } } private void ProcessXRLInMsgBody(ref List bytesWithXRL) { var bytesUsedToComputeXRL = bytesWithXRL.GetRange(2, bytesWithXRL.Count - 3).ToArray(); byte XRL = 0; foreach (var b in bytesUsedToComputeXRL) { XRL = (byte)(XRL ^ b); } if (XRL == 0xFF) XRL = 0xEE; bytesWithXRL[bytesWithXRL.Count - 1] = XRL; } } }