SkyPump.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Concurrent;
  4. using System.Collections.Generic;
  5. using System.Diagnostics;
  6. using System.Linq;
  7. using System.Reflection;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. using System.Xml;
  11. using Aitex.Core.Common.DeviceData;
  12. using Aitex.Core.RT.DataCenter;
  13. using Aitex.Core.RT.Device;
  14. using Aitex.Core.RT.Event;
  15. using Aitex.Core.RT.IOCore;
  16. using Aitex.Core.RT.Log;
  17. using Aitex.Core.RT.OperationCenter;
  18. using Aitex.Core.RT.SCCore;
  19. using Aitex.Core.RT.Tolerance;
  20. using Aitex.Core.Util;
  21. using MECF.Framework.Common.Communications;
  22. using MECF.Framework.Common.DataCenter;
  23. using MECF.Framework.Common.Device.Bases;
  24. using MECF.Framework.Common.Equipment;
  25. using SecsGem.Core.Variables;
  26. using Venus_Core;
  27. namespace Venus_RT.Devices
  28. {
  29. //interface IPumpControl
  30. //{
  31. // bool IsRunning { get; }
  32. // void TurnON();
  33. // void TurnOFF();
  34. //}
  35. public enum SkyPumpState { ON = 0, OFF, Connected, Disconnected, Unknown, ERROR }
  36. static class SkyPumpMessage
  37. {
  38. public const string EOF = "\r\n";
  39. public const string SET_ON = "@00CON_FDP_ON";
  40. public const string SET_OFF = "@00CON_FDP_OFF";
  41. public const string GET_ON = "@00FDP_ONOK"; // \0\r\n
  42. public const string GET_OFF = "@00FDP_OFFOK"; // \0\r\n
  43. public const string READ_DATA = "@00READ_RUN_PARA";
  44. public const string GET_DATA = "@00RUN_PARA";
  45. }
  46. class SkyPump : PumpBase
  47. {
  48. // ----------------------------Fields--------------------------
  49. //
  50. private const ushort CHK_ST_INTERVAL = 1000;
  51. private const ushort CHK_REC_INTERVAL = 20 * 1000;
  52. private const ushort CHK_PUMP_REC_INTERVAL = 10 * 1000;
  53. private double _total;
  54. private double _fromLast;
  55. private const string EOF = "\r";
  56. private const char MSG_DELIMITER = ' ';
  57. private readonly string _PortNum = "COM91";
  58. private const int _counterMax = 30;
  59. private int _counter = 0;
  60. private string _fdp_Current = null;
  61. private string _roots_Current = null;
  62. private string _fdp_Temp = null;
  63. private string _roots_Temp = null;
  64. private string _n2Flow = null;
  65. private string _pressure = null;
  66. private string _runTime = null;
  67. private readonly AsyncSerialPort _serial;
  68. private readonly DeviceTimer _timerQueryStatus = new DeviceTimer();
  69. private readonly DeviceTimer _timerReceiveStatus = new DeviceTimer();
  70. private readonly DeviceTimer _timerPumpOn = new DeviceTimer();
  71. private readonly DeviceTimer _timerPumpOff = new DeviceTimer();
  72. private readonly DeviceTimer _timerTotal = new DeviceTimer();
  73. private readonly DeviceTimer _timerFromLast = new DeviceTimer();
  74. private readonly R_TRIG _trigPumpOn = new R_TRIG();
  75. private readonly R_TRIG _trigPumpOff = new R_TRIG();
  76. private readonly R_TRIG _trigReceiveStatus = new R_TRIG();
  77. private readonly RD_TRIG _trigOnOff = new RD_TRIG();
  78. private readonly R_TRIG _trigPMNeeded = new R_TRIG();
  79. private StatsDataItemRFAndPump _statPumpOnTime;
  80. private Stopwatch _errorStopWatch = new Stopwatch();
  81. private string _lastError;
  82. private Stopwatch _pumpOnTimeWatch=new Stopwatch();
  83. // --------------------------Properties------------------------
  84. //
  85. public SkyPumpState StatusDry { get; set; }
  86. public SkyPumpState StatusRoose { get; set; }
  87. public string FDP_Current
  88. {
  89. get
  90. {
  91. return _fdp_Current;
  92. }
  93. }
  94. public string ROOTS_Current
  95. {
  96. get
  97. {
  98. return _roots_Current;
  99. }
  100. }
  101. public string FDP_Temp
  102. {
  103. get
  104. {
  105. return _fdp_Temp;
  106. }
  107. }
  108. public string ROOTS_Temp
  109. {
  110. get
  111. {
  112. return _roots_Temp;
  113. }
  114. }
  115. public string N2Flow
  116. {
  117. get
  118. {
  119. return _n2Flow;
  120. }
  121. }
  122. public string Pressure
  123. {
  124. get
  125. {
  126. return _pressure;
  127. }
  128. }
  129. public string RunTime
  130. {
  131. get
  132. {
  133. return _runTime;
  134. }
  135. }
  136. public string LastPMTime
  137. {
  138. get
  139. {
  140. return _statPumpOnTime != null ? _statPumpOnTime.LastPMTime.ToString() : "";
  141. }
  142. }
  143. public float DaysFromLastPM
  144. {
  145. get
  146. {
  147. return _statPumpOnTime == null ? 0 : _statPumpOnTime.fromLastPM;
  148. }
  149. set
  150. {
  151. if (_statPumpOnTime != null)
  152. _statPumpOnTime.fromLastPM = value;
  153. }
  154. }
  155. public float TotalDays
  156. {
  157. get
  158. {
  159. return _statPumpOnTime != null ? _statPumpOnTime.Total : 0;
  160. }
  161. set
  162. {
  163. if (_statPumpOnTime != null)
  164. _statPumpOnTime.Total = value;
  165. }
  166. }
  167. public double PMIntervalDays
  168. {
  169. get
  170. {
  171. return _statPumpOnTime != null ? _statPumpOnTime.PMInterval : 0;
  172. }
  173. }
  174. public bool IsPMNeeded
  175. {
  176. get
  177. {
  178. return StatsDataManager.Instance.GetItemRFAndPump($"{Module}.PumpOnTime").fromLastPM > PMIntervalDays;
  179. }
  180. }
  181. public bool EnableAlarm
  182. {
  183. get
  184. {
  185. return _statPumpOnTime == null || _statPumpOnTime.AlarmEnable;
  186. }
  187. }
  188. [Subscription(AITPumpProperty.IsRunning)]
  189. public override bool IsRunning
  190. {
  191. get
  192. {
  193. return StatusDry == SkyPumpState.ON;
  194. }
  195. }
  196. [Subscription(AITPumpProperty.IsError)]
  197. public override bool IsError
  198. {
  199. get
  200. {
  201. return StatusDry == SkyPumpState.ERROR || StatusDry == SkyPumpState.Disconnected;
  202. }
  203. }
  204. public override AITPumpData DeviceData
  205. {
  206. get
  207. {
  208. AITPumpData deviceData = new AITPumpData
  209. {
  210. DeviceName = Name,
  211. DeviceModule = Module,
  212. DeviceSchematicId = DeviceID,
  213. DisplayName = Display,
  214. IsError = false,
  215. IsWarning = false,
  216. IsOn = IsRunning,
  217. //WaterFlow = WaterFlowValue,
  218. IsDryPumpEnable = true,
  219. IsN2PressureEnable = false,
  220. IsWaterFlowEnable = false,
  221. //WaterFlowWarning = WaterFlowWarning,
  222. //WaterFlowAlarm = WaterFlowAlarm,
  223. //N2PressureAlarm = N2PressureAlarm,
  224. //N2PressureWarning = N2PressureWarning,
  225. };
  226. return deviceData;
  227. }
  228. }
  229. public SkyPump(ModuleName mod) : base(mod.ToString(), VenusDevice.MainPump.ToString(), "SKY pump", "")
  230. {
  231. _PortNum = SC.GetStringValue($"{mod}.DryPump.Port");
  232. StatusDry = SkyPumpState.Unknown;
  233. _serial = new AsyncSerialPort(_PortNum, 9600, 8, System.IO.Ports.Parity.None, System.IO.Ports.StopBits.One, "\r\n", false);
  234. SerachCommandList = new List<string>()
  235. {
  236. SkyPumpMessage.READ_DATA
  237. };
  238. sendDataChangedEvent += SkyPump_sendDataChangedEvent;
  239. baseStopwatch.Start();
  240. baseTimer.Enabled = true;
  241. }
  242. private void SkyPump_sendDataChangedEvent(string obj)
  243. {
  244. try
  245. {
  246. var newstr = obj + "\r";
  247. if (SC.GetValue<bool>("System.EnableDeviceLog"))
  248. {
  249. string str = "";
  250. if (_serial != null)
  251. {
  252. str = _serial.PortName + _serial.IsOpen();
  253. }
  254. LOG.Write(eEvent.EV_DEVICE_INFO, ModuleName.System, $"{Name} send {obj},socket {str}");
  255. }
  256. _serial?.Write(newstr);
  257. }
  258. catch
  259. {
  260. LOG.Write(eEvent.EV_DEVICE_INFO, ModuleName.System, $"{Name} send {obj},socket error");
  261. }
  262. }
  263. public override bool Initialize()
  264. {
  265. base.Initialize();
  266. if (!_serial.Open())
  267. {
  268. StatusDry = SkyPumpState.Disconnected;
  269. LOG.Write(eEvent.ERR_DRY_PUMP, Module, "Sky Pump串口无法打开");
  270. return false;
  271. }
  272. _statPumpOnTime = StatsDataManager.Instance.GetItemRFAndPump($"{Module}.PumpOnTime");
  273. StatusDry = SkyPumpState.Connected;
  274. _trigPumpOn.RST = true;
  275. _trigPumpOff.RST = true;
  276. _trigReceiveStatus.RST = true;
  277. _serial.OnDataChanged += OnPortDataChanged;
  278. _serial.OnBinaryDataChanged += OnPortBinaryDataChanged;
  279. _serial.OnErrorHappened += OnErrorOccurred;
  280. _timerQueryStatus.Start(CHK_ST_INTERVAL);
  281. _timerReceiveStatus.Start(CHK_REC_INTERVAL);
  282. return true;
  283. }
  284. List<byte> bytes = new List<byte>();
  285. private void OnPortBinaryDataChanged(byte[] obj)
  286. {
  287. try
  288. {
  289. _timerReceiveStatus.Stop();
  290. _timerReceiveStatus.Start(CHK_REC_INTERVAL);
  291. _trigReceiveStatus.RST = true;
  292. if (obj.Length<2)
  293. {
  294. return;
  295. }
  296. if (obj[0] == 0x40 && obj[1] == 0x30)
  297. {
  298. bytes.Clear();
  299. //bytes.AddRange(new List<byte>(obj));
  300. }
  301. bytes.AddRange(obj);
  302. if (bytes[bytes.Count - 1] == 0x0A && bytes[bytes.Count - 2] == 0x0D)
  303. {
  304. }
  305. else
  306. {
  307. return;
  308. }
  309. obj = bytes.ToArray();
  310. var strData = System.Text.Encoding.ASCII.GetString(obj);
  311. bytes.Clear();
  312. if (strData.Contains(SkyPumpMessage.EOF))
  313. {
  314. string cmd = "";
  315. if (obj.Length == 14 || obj.Length >= 40)
  316. cmd = Encoding.ASCII.GetString(obj, 0, 11);
  317. else if (obj.Length == 15)
  318. cmd = Encoding.ASCII.GetString(obj, 0, 12);
  319. if (cmd == SkyPumpMessage.GET_ON)
  320. {
  321. _trigPumpOn.CLK = true;
  322. _timerPumpOn.Start(CHK_PUMP_REC_INTERVAL);
  323. //LOG.Info($"[{Module}] {SkyPumpMessage.GET_ON}");
  324. LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"[{Module}] {SkyPumpMessage.GET_ON}");
  325. return;
  326. }
  327. if (cmd == SkyPumpMessage.GET_OFF)
  328. {
  329. _trigPumpOff.CLK = true;
  330. _timerPumpOff.Start(CHK_PUMP_REC_INTERVAL);
  331. LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"[{Module}] {SkyPumpMessage.GET_ON}");
  332. //LOG.Info($"[{Module}] {SkyPumpMessage.GET_OFF}");
  333. return;
  334. }
  335. if (cmd == SkyPumpMessage.GET_DATA)
  336. {
  337. _fdp_Current = Encoding.ASCII.GetString(obj, 11, 2);
  338. _roots_Current = Encoding.ASCII.GetString(obj, 13, 2);
  339. _fdp_Temp = Encoding.ASCII.GetString(obj, 15, 3);
  340. _roots_Temp = Encoding.ASCII.GetString(obj, 18, 3);
  341. _n2Flow = Encoding.ASCII.GetString(obj, 21, 2);
  342. _pressure = Encoding.ASCII.GetString(obj, 23, 4);
  343. _runTime = Encoding.ASCII.GetString(obj, 27, 5);
  344. ParaErrSta1(new BitArray(new byte[] { obj[32] }));
  345. ParaErrSta2(new BitArray(new byte[] { obj[33] }));
  346. ParaRunSta(new BitArray(new byte[] { obj[34] }));
  347. //ParaRunSta(new BitArray(new byte[] { obj[35] }));
  348. ParaErrSta3(new BitArray(new byte[] { obj[36] }));
  349. }
  350. }
  351. else
  352. {
  353. if (!SC.GetValue<bool>("System.IsSimulatorMode"))
  354. {
  355. //LOG.Info($"[{Module}] Sky Pump 数据无效:[{strData}]");
  356. LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"[{Module}] Sky Pump 数据无效:[{strData}]");
  357. }
  358. }
  359. }
  360. catch (Exception ex)
  361. {
  362. if (!SC.GetValue<bool>("System.IsSimulatorMode"))
  363. {
  364. LOG.WriteExeption($"[{Module}] sky pump data para error: ", ex);
  365. }
  366. }
  367. }
  368. private void OnErrorOccurred(string obj)
  369. {
  370. if (_lastError != obj || _errorStopWatch.ElapsedMilliseconds > 60 * 1000)
  371. {
  372. _errorStopWatch.Restart();
  373. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}] sky pump error: [{obj}]");
  374. }
  375. _lastError = obj;
  376. StatusDry = SkyPumpState.ERROR;
  377. //LOG.Error($"[{Module}] sky pump error: [{obj}]");
  378. }
  379. private void OnPortDataChanged(string obj)
  380. {
  381. if (string.IsNullOrEmpty(obj))
  382. //LOG.Error($"[{Module}] sky pump message IsNullOrEmpty");
  383. try
  384. {
  385. string cmd = obj.ToString().Split('\n')[0].Split('\r')[0];
  386. if (cmd == SkyPumpMessage.GET_ON)
  387. {
  388. //LOG.Info($"[{Module}] {SkyPumpMessage.GET_ON}");
  389. return;
  390. }
  391. if (cmd == SkyPumpMessage.GET_OFF)
  392. {
  393. //LOG.Info($"[{Module}] {SkyPumpMessage.GET_OFF}");
  394. return;
  395. }
  396. if (cmd.Substring(0, 11) == SkyPumpMessage.GET_DATA)
  397. {
  398. _fdp_Current = cmd.Substring(11, 2);
  399. _roots_Current = cmd.Substring(13, 2);
  400. _fdp_Temp = cmd.Substring(15, 3);
  401. _roots_Temp = cmd.Substring(18, 3);
  402. _n2Flow = cmd.Substring(21, 2);
  403. _pressure = cmd.Substring(23, 4);
  404. _runTime = cmd.Substring(27, 5);
  405. ParaErrSta1(new BitArray(new byte[] { Convert.ToByte(cmd[32]) }));
  406. ParaErrSta2(new BitArray(new byte[] { Convert.ToByte(cmd[33]) }));
  407. ParaRunSta(new BitArray(new byte[] { Convert.ToByte(cmd[34]) }));
  408. //ParaRunSta(new BitArray(new byte[] { Convert.ToByte(cmd[35]) }));
  409. ParaErrSta3(new BitArray(new byte[] { Convert.ToByte(cmd[36]) }));
  410. }
  411. }
  412. catch(Exception ex)
  413. {
  414. LOG.WriteExeption($"[{Module}] sky pump error: ", ex);
  415. }
  416. }
  417. public void ParaErrSta1(BitArray bits)
  418. {
  419. for (int i = 0; i < bits.Count; i++)
  420. {
  421. if (bits[i]) ErrSta1(i);
  422. }
  423. }
  424. public void ParaErrSta2(BitArray bits)
  425. {
  426. for (int i = 0; i < bits.Count; i++)
  427. {
  428. if (bits[i]) ErrSta2(i);
  429. }
  430. }
  431. public void ParaErrSta3(BitArray bits)
  432. {
  433. for (int i = 0; i < bits.Count; i++)
  434. {
  435. if (bits[i]) ErrSta3(i);
  436. }
  437. }
  438. public void ParaRunSta(BitArray bits)
  439. {
  440. string sRes = "sky pump status: ";
  441. for (int i = 0; i < bits.Count; i++)
  442. {
  443. if (bits[i])
  444. sRes += RunStaTure(i);
  445. else
  446. sRes += RunStaFalse(i);
  447. }
  448. _counter++;
  449. if (_counter == _counterMax)
  450. {
  451. _counter = 0;
  452. //LOG.Info($"[{Module}] {sRes}");
  453. //LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"[{Module}] {sRes}");
  454. }
  455. }
  456. public string RunStaTure(int code)
  457. {
  458. switch (code)
  459. {
  460. case 7:
  461. return "远程。";
  462. case 6:
  463. StatusDry = SkyPumpState.ON;
  464. if (_trigPumpOn.Q)
  465. {
  466. LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"Dry Pump打开");
  467. }
  468. if (_trigPumpOff.Q && _timerPumpOff.IsTimeout())
  469. {
  470. _trigPumpOff.RST = true;
  471. LOG.Write(eEvent.WARN_DEVICE_INFO, Module, "Dry Pump 无法关闭");
  472. }
  473. _trigPumpOn.RST = true;
  474. return "干泵开, ";
  475. case 5:
  476. StatusRoose = SkyPumpState.ON;
  477. return "罗茨泵开, ";
  478. case 4:
  479. return "泵冷阀开, ";
  480. case 3:
  481. return "清洗阀开, ";
  482. case 2:
  483. return "有警示, ";
  484. case 1:
  485. return "有故障, ";
  486. case 0:
  487. return "无水, ";
  488. default:
  489. return "";
  490. }
  491. }
  492. public string RunStaFalse(int code)
  493. {
  494. switch (code)
  495. {
  496. case 7:
  497. return "本地。";
  498. case 6:
  499. StatusDry = SkyPumpState.OFF;
  500. if (_trigPumpOn.Q && _timerPumpOn.IsTimeout())
  501. {
  502. _trigPumpOn.RST = true;
  503. LOG.Write(eEvent.WARN_DEFAULT_WARN, ModuleHelper.Converter(Module), "Dry Pump 无法打开");
  504. }
  505. if (_trigPumpOff.Q)
  506. {
  507. LOG.Write(eEvent.EV_DEVICE_INFO, Module, $"Dry Pump关闭");
  508. }
  509. _trigPumpOff.RST = true;
  510. return "干泵关, ";
  511. case 5:
  512. StatusRoose = SkyPumpState.OFF;
  513. return "罗茨泵关, ";
  514. case 4:
  515. return "泵冷阀关, ";
  516. case 3:
  517. return "清洗阀关, ";
  518. case 2:
  519. return "无警示, ";
  520. case 1:
  521. return "无故障, ";
  522. case 0:
  523. return "有水, ";
  524. default:
  525. return "";
  526. }
  527. }
  528. public void ErrSta1(int error)
  529. {
  530. switch (error)
  531. {
  532. case 7:
  533. //LOG.Error($"[{Module}]上泵变频器除通讯外故障");
  534. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵变频器除通讯外故障");
  535. break;
  536. case 6:
  537. //LOG.Error($"[{Module}]下泵变频器除通讯外故障");
  538. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵变频器除通讯外故障");
  539. break;
  540. case 5:
  541. //LOG.Error($"[{Module}]上泵接触器");
  542. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵接触器");
  543. break;
  544. case 4:
  545. //LOG.Error($"[{Module}]下泵接触器");
  546. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵接触器");
  547. break;
  548. case 3:
  549. //LOG.Error($"[{Module}]上泵电机过热");
  550. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵电机过热");
  551. break;
  552. case 2:
  553. //LOG.Error($"[{Module}]下泵电机过热");
  554. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵电机过热");
  555. break;
  556. case 1:
  557. //LOG.Error($"[{Module}]急停");
  558. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]急停");
  559. break;
  560. case 0:
  561. //LOG.Error($"[{Module}]水冷");
  562. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]水冷");
  563. break;
  564. default:
  565. break;
  566. }
  567. }
  568. public void ErrSta2(int error)
  569. {
  570. switch (error)
  571. {
  572. case 7:
  573. //LOG.Error($"[{Module}]下泵变频器通讯故障");
  574. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵变频器通讯故障");
  575. break;
  576. case 6:
  577. //LOG.Error($"[{Module}]上泵变频器通讯故障");
  578. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵变频器通讯故障");
  579. break;
  580. case 5:
  581. //LOG.Error($"[{Module}]排气压力");
  582. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]排气压力");
  583. break;
  584. case 4:
  585. //LOG.Error($"[{Module}]氮气流量");
  586. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]氮气流量");
  587. break;
  588. case 3:
  589. // LOG.Error($"[{Module}]下泵电流");
  590. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵电流");
  591. break;
  592. case 2:
  593. // LOG.Error($"[{Module}]上泵电流");
  594. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵电流");
  595. break;
  596. case 1:
  597. // LOG.Error($"[{Module}]下泵温度");
  598. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵温度");
  599. break;
  600. case 0:
  601. // LOG.Error($"[{Module}]上泵温度");
  602. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵温度");
  603. break;
  604. default:
  605. break;
  606. }
  607. }
  608. public void ErrSta3(int error)
  609. {
  610. switch (error)
  611. {
  612. case 7:
  613. case 6:
  614. case 5:
  615. case 4:
  616. case 3:
  617. case 2:
  618. break;
  619. case 1:
  620. //LOG.Error($"[{Module}]下泵温度传感器未连接");
  621. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]下泵温度传感器未连接");
  622. break;
  623. case 0:
  624. //LOG.Error($"[{Module}]上泵温度传感器未连接");
  625. LOG.Write(eEvent.ERR_DRY_PUMP, Module, $"[{Module}]上泵温度传感器未连接");
  626. break;
  627. default:
  628. break;
  629. }
  630. }
  631. public override void Monitor()
  632. {
  633. try
  634. {
  635. // 状态查询
  636. //if (_timerQueryStatus.IsTimeout() && this.StatusDry != SkyPumpState.ERROR)
  637. //{
  638. // this.SendCmd(SkyPumpMessage.READ_DATA);
  639. // _timerQueryStatus.Start(CHK_ST_INTERVAL);
  640. //}
  641. if (_timerReceiveStatus.IsTimeout() && this.StatusDry != SkyPumpState.ERROR)
  642. {
  643. _trigReceiveStatus.CLK = true;
  644. if(_trigReceiveStatus.Q)
  645. {
  646. LOG.Write(eEvent.WARN_DEVICE_INFO, Module, "Dry Pump 没有回复");
  647. }
  648. }
  649. _trigOnOff.CLK = IsRunning;
  650. //第一次检测到打开了,开始计时
  651. if (_trigOnOff.R)
  652. {
  653. _total = TotalDays;
  654. _fromLast = DaysFromLastPM;
  655. _timerTotal.Start(0);
  656. _timerFromLast.Start(0);
  657. _pumpOnTimeWatch.Start();
  658. }
  659. //第一次检测到从打开到关闭状态
  660. if (_trigOnOff.T)
  661. {
  662. }
  663. //如果开着,就更新SC
  664. if (_trigOnOff.M && _pumpOnTimeWatch.ElapsedMilliseconds>1000)
  665. {
  666. //TotalDays = (float)_timerTotal.GetElapseTime() / 1000 / 60 / 60;
  667. //DaysFromLastPM = (float)_timerFromLast.GetElapseTime() / 1000 / 60 / 60;
  668. TotalDays = (float)1 / 60 / 60;
  669. DaysFromLastPM = (float)1 / 60 / 60;
  670. _pumpOnTimeWatch.Restart();
  671. //_timerTotal.Restart(0);
  672. //_timerFromLast.Restart(0);
  673. if (ModuleHelper.IsPm(Module))
  674. {
  675. StatsDataManager.Instance.Increase($"{Module}.PumpOnTime", $"{Module} PumpOnTime", DaysFromLastPM, TotalDays);
  676. }
  677. }
  678. if (PMIntervalDays > 0)
  679. {
  680. _trigPMNeeded.CLK = IsPMNeeded;
  681. if (_trigPMNeeded.Q)
  682. {
  683. if (EnableAlarm)
  684. {
  685. LOG.Write(eEvent.ERR_DRY_PUMP, Module, "pump on time value larger than setting interval days");
  686. }
  687. }
  688. }
  689. }
  690. catch (Exception ex)
  691. {
  692. throw ex;
  693. }
  694. }
  695. private bool SendCmd(string str)
  696. {
  697. var newstr = str + "\r";
  698. SetPointCommandQueue.Add(newstr);
  699. return true;
  700. }
  701. public override void Reset()
  702. {
  703. _trigPumpOn.RST = true;
  704. _trigPumpOff.RST = true;
  705. _trigReceiveStatus.RST = true;
  706. _trigPMNeeded.RST = true;
  707. //SetPumpOnOff(false);
  708. }
  709. public override void Terminate()
  710. {
  711. //if (StatusDry == SkyPumpState.ON)
  712. // SetPumpOnOff(false);
  713. _serial?.Close();
  714. }
  715. public override void ResetPumpStats()
  716. {
  717. _statPumpOnTime = StatsDataManager.Instance.GetItemRFAndPump($"{Module}.PumpOnTime");
  718. }
  719. public override void SetPumpOnOff(bool on)
  720. {
  721. SendCmd(on ? SkyPumpMessage.SET_ON : SkyPumpMessage.SET_OFF);
  722. }
  723. }
  724. }