TurboPumpMockPMA.cs 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. using System;
  2. using MECF.Framework.Simulator.Core.Driver;
  3. using System.Linq;
  4. namespace Venus_Simulator.Devices
  5. {
  6. class TurboPumpMockPMA : SerialPortDeviceSimulator
  7. {
  8. public enum TurboPumpStatus
  9. {
  10. Unknown,
  11. OFF,
  12. ON,
  13. ERROR
  14. }
  15. private readonly byte PUMP_ON_FLAG = 0x02;
  16. private readonly byte RESERVE_FLAG = 0x80;
  17. private readonly byte ISO_VALVE_OPEN_FLAG = 0x01;
  18. private readonly byte WATER_VALVE_OEPN_FLAG = 0x08;
  19. private readonly byte VALVE_AT_SPEED_FLAG = 0x40;
  20. private byte pumpStatus
  21. {
  22. get
  23. {
  24. return (byte)((_simTurboPumpStatus == TurboPumpStatus.ON ? PUMP_ON_FLAG : 0) + RESERVE_FLAG);
  25. }
  26. }
  27. private byte valveStatus
  28. {
  29. get
  30. {
  31. return (byte)(ISO_VALVE_OPEN_FLAG + WATER_VALVE_OEPN_FLAG + VALVE_AT_SPEED_FLAG + RESERVE_FLAG);
  32. }
  33. }
  34. private const string EOF = "\r";
  35. private const char MSG_DELIMITER = '_';
  36. private const string MOCKUP_PORT = "COM61";
  37. private int _speed = 200;
  38. private int _temperature = 80;
  39. private Random _rd = new Random();
  40. TurboPumpStatus _simTurboPumpStatus;
  41. public TurboPumpMockPMA() : base(MOCKUP_PORT, -1, EOF, MSG_DELIMITER)
  42. {
  43. _simTurboPumpStatus = TurboPumpStatus.Unknown;
  44. }
  45. protected override void ProcessUnsplitMessage(string message)
  46. {
  47. if (string.IsNullOrEmpty(message))
  48. throw new ArgumentException("Hardware command message is invalid");
  49. string sRes = string.Empty;
  50. string str = message.Trim();
  51. if (str.Contains("STA"))
  52. {
  53. if(_simTurboPumpStatus == TurboPumpStatus.ON)
  54. {
  55. _speed = 200;
  56. }
  57. else
  58. {
  59. _speed = 0;
  60. }
  61. string strData = string.Format("#000,000,{0:D5},000,000,000,000,000,00,00000,{1:D3},099,0123456789012345678901234\r", _speed + _rd.Next(0, 5), _temperature + _rd.Next(-5, 5));
  62. byte[] byteArray = System.Text.Encoding.Default.GetBytes(strData);
  63. byteArray[6] = pumpStatus;
  64. byteArray[7] = valveStatus;
  65. OnWriteMessage(byteArray);
  66. return;
  67. }
  68. else if (str.Contains("TMPON"))
  69. {
  70. sRes = "#000,OK\r";
  71. _simTurboPumpStatus = TurboPumpStatus.ON;
  72. }
  73. else if (str.Contains("TMPOFF"))
  74. {
  75. sRes = "#000,OK\r";
  76. _simTurboPumpStatus = TurboPumpStatus.OFF;
  77. }
  78. else
  79. return;
  80. OnWriteMessage(sRes);
  81. }
  82. }
  83. }