VpwMainEntity.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343
  1. using Aitex.Core.RT.DataCenter;
  2. using Aitex.Core.RT.Device;
  3. using Aitex.Core.RT.Fsm;
  4. using Aitex.Core.RT.Log;
  5. using Aitex.Core.RT.OperationCenter;
  6. using Aitex.Core.Util;
  7. using Aitex.Core.Utilities;
  8. using MECF.Framework.Common.Equipment;
  9. using MECF.Framework.Common.Persistent.Reservoirs;
  10. using MECF.Framework.Common.Persistent.VpwMain;
  11. using MECF.Framework.Common.ToolLayout;
  12. using PunkHPX8_Core;
  13. using PunkHPX8_RT.Devices.VpwCell;
  14. using PunkHPX8_RT.Modules.VpwCelMain;
  15. using System;
  16. using System.Collections.Generic;
  17. using System.Linq;
  18. using System.Text;
  19. using System.Threading;
  20. using System.Threading.Tasks;
  21. namespace PunkHPX8_RT.Modules.VpwMain
  22. {
  23. public class VpwMainEntity : Entity, IEntity, IModuleEntity
  24. {
  25. public enum MSG
  26. {
  27. Home
  28. }
  29. #region 常量
  30. private const string STRATUS = "Stratus";
  31. private const string AUTO = "Auto";
  32. private const string MANUAL = "Manual";
  33. private const string DISABLED = "Disabled";
  34. private const string ENGINEERING = "Engineering";
  35. private const string PRODUCTION = "Production";
  36. #endregion
  37. #region 内部变量
  38. /// <summary>
  39. /// 持久化数值
  40. /// </summary>
  41. private VpwMainPersistentValue _persistentValue;
  42. /// <summary>
  43. /// VPW cell集合
  44. /// </summary>
  45. private List<VpwCellDevice> _vpwCellDevices = new List<VpwCellDevice>();
  46. /// <summary>
  47. /// Home Routine
  48. /// </summary>
  49. private VPWHomeRoutine _homeRoutine;
  50. /// <summary>
  51. /// purge Routine
  52. /// </summary>
  53. private VpwPurgeRoutine _vpwPurgeRoutine;
  54. #endregion
  55. #region 属性
  56. public ModuleName Module { get; private set; }
  57. /// <summary>
  58. /// 是否Init
  59. /// </summary>
  60. public bool IsInit
  61. {
  62. get { return fsm.State == (int)VPWMainState.Init; }
  63. }
  64. /// <summary>
  65. /// 是否Idle
  66. /// </summary>
  67. public bool IsIdle
  68. {
  69. get
  70. {
  71. return fsm.State == (int)VPWMainState.Idle;
  72. }
  73. }
  74. /// <summary>
  75. /// 是否错误
  76. /// </summary>
  77. public bool IsError
  78. {
  79. get { return fsm.State == (int)VPWMainState.Error; }
  80. }
  81. /// <summary>
  82. /// 正在忙碌
  83. /// </summary>
  84. public bool IsBusy
  85. {
  86. get { return fsm.State > (int)VPWMainState.Idle; }
  87. }
  88. /// <summary>
  89. /// 状态
  90. /// </summary>
  91. public VPWMainState State
  92. {
  93. get { return (VPWMainState)fsm.State; }
  94. }
  95. /// <summary>
  96. /// 是否禁用
  97. /// </summary>
  98. public bool IsDisable { get { return _persistentValue == null || _persistentValue.OperatingMode == DISABLED; } }
  99. /// <summary>
  100. /// 自动模式
  101. /// </summary>
  102. public bool IsAuto { get { return _persistentValue != null && _persistentValue.OperatingMode == AUTO; } }
  103. /// <summary>
  104. /// 自动模式
  105. /// </summary>
  106. public bool IsManual { get { return _persistentValue != null && _persistentValue.OperatingMode == MANUAL; } }
  107. /// <summary>
  108. /// 是否为工程模式
  109. /// </summary>
  110. public bool IsEngineering { get { return _persistentValue != null && _persistentValue.RecipeOperatingMode == ENGINEERING; } }
  111. /// <summary>
  112. /// 是否为产品模式
  113. /// </summary>
  114. public bool IsProduction { get { return _persistentValue != null && _persistentValue.RecipeOperatingMode == PRODUCTION; } }
  115. #endregion
  116. /// <summary>
  117. /// 构造函数
  118. /// </summary>
  119. /// <param name="module"></param>
  120. public VpwMainEntity(ModuleName module)
  121. {
  122. this.Module = module;
  123. }
  124. /// <summary>
  125. /// 初始化
  126. /// </summary>
  127. /// <returns></returns>
  128. protected override bool Init()
  129. {
  130. InitialFsm();
  131. InitializeParameter();
  132. InitializeRoutine();
  133. InitializeDATA();
  134. InitializeOperation();
  135. return true;
  136. }
  137. /// 初始化状态机
  138. /// </summary>
  139. private void InitialFsm()
  140. {
  141. fsm = new StateMachine<VpwMainEntity>(Module.ToString(), (int)VPWMainState.Init, 100);
  142. fsm.EnableRepeatedMsg(true);
  143. AnyStateTransition(VPWMainMsg.Error, NullFunc, VPWMainState.Error);
  144. //Initialized
  145. Transition(VPWMainState.Error, VPWMainMsg.Initialize, InitializeAll, VPWMainState.Initializing);
  146. Transition(VPWMainState.Init, VPWMainMsg.Initialize, InitializeAll, VPWMainState.Initializing);
  147. Transition(VPWMainState.Idle, VPWMainMsg.Initialize, InitializeAll, VPWMainState.Initializing);
  148. Transition(VPWMainState.Initializing, FSM_MSG.TIMER, InitializeAllMonitor, VPWMainState.Idle);
  149. Transition(VPWMainState.Error, VPWMainMsg.EnterIdle, NullFunc, VPWMainState.Idle);
  150. Transition(VPWMainState.Init, VPWMainMsg.EnterIdle, NullFunc, VPWMainState.Idle);
  151. Transition(VPWMainState.Idle, VPWMainMsg.EnterIdle, NullFunc, VPWMainState.Idle);
  152. //Enter Init
  153. Transition(VPWMainState.Idle, VPWMainMsg.Init, NullFunc, VPWMainState.Init);
  154. //Purge
  155. Transition(VPWMainState.Idle, VPWMainMsg.Purge, Purge, VPWMainState.Purgeing);
  156. Transition(VPWMainState.Purgeing, VPWMainMsg.Purge, NullFunc, VPWMainState.Purgeing);
  157. Transition(VPWMainState.Purgeing, FSM_MSG.TIMER, PurgeMonitor, VPWMainState.Idle);
  158. EnumLoop<VPWMainState>.ForEach((item) => { fsm.MapState((int)item, item.ToString()); });
  159. EnumLoop<VPWMainMsg>.ForEach((item) => { fsm.MapMessage((int)item, item.ToString()); });
  160. }
  161. /// <summary>
  162. /// 初始化参数
  163. /// </summary>
  164. private void InitializeParameter()
  165. {
  166. _persistentValue = VpwMainPersistentManager.Instance.GetPersistentValue(Module.ToString());
  167. if (_persistentValue == null)
  168. {
  169. LOG.WriteLog(eEvent.ERR_VPWMAIN, Module.ToString(), "Persistent Value Object is not exist");
  170. }
  171. _vpwCellDevices.Clear();
  172. VpwMainItem vpwMainItem = VpwMainItemManager.Instance.GetItem(Module.ToString());
  173. if (vpwMainItem == null || vpwMainItem.VpwCells == null)
  174. {
  175. return;
  176. }
  177. foreach(var item in vpwMainItem.VpwCells)
  178. {
  179. VpwCellDevice cellDevice = DEVICE.GetDevice<VpwCellDevice>(item.ModuleName);
  180. _vpwCellDevices.Add(cellDevice);
  181. }
  182. }
  183. /// <summary>
  184. /// 初始化数据
  185. /// </summary>
  186. private void InitializeDATA()
  187. {
  188. InitializeSVID();
  189. DATA.Subscribe($"{Module}.FsmState", () => ((VPWMainState)fsm.State).ToString(), SubscriptionAttribute.FLAG.IgnoreSaveDB);
  190. DATA.Subscribe($"{Module}.IsIdle", () => IsIdle, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  191. DATA.Subscribe($"{Module}.IsInit", () => IsInit, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  192. DATA.Subscribe($"{Module}.IsDisable", () => IsDisable, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  193. DATA.Subscribe($"{Module}.IsBusy", () => IsBusy, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  194. DATA.Subscribe($"{Module}.IsError", () => IsError, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  195. }
  196. /// <summary>
  197. /// 初始化SVID
  198. /// </summary>
  199. private void InitializeSVID()
  200. {
  201. DATA.Subscribe($"{Module}.State", () => ((VPWMainState)fsm.State).ToString(), SubscriptionAttribute.FLAG.IgnoreSaveDB);
  202. DATA.Subscribe($"{Module}.OperatingMode", () => _persistentValue != null ? _persistentValue.OperatingMode : "None", SubscriptionAttribute.FLAG.IgnoreSaveDB);
  203. }
  204. /// <summary>
  205. /// 初始化Routine
  206. /// </summary>
  207. private void InitializeRoutine()
  208. {
  209. _homeRoutine = new VPWHomeRoutine(Module.ToString());
  210. _vpwPurgeRoutine = new VpwPurgeRoutine(Module.ToString());
  211. }
  212. /// <summary>
  213. /// 初始化操作
  214. /// </summary>
  215. private void InitializeOperation()
  216. {
  217. OP.Subscribe($"{Module}.InitializeAll", (cmd, args) => { return CheckToPostMessage<VPWMainState, VPWMainMsg>(eEvent.ERR_VPWMAIN, Module.ToString(), (int)VPWMainMsg.Initialize); });
  218. OP.Subscribe($"{Module}.Purge", (cmd, args) => { return CheckToPostMessage<VPWMainState, VPWMainMsg>(eEvent.ERR_VPWMAIN, Module.ToString(), (int)VPWMainMsg.Purge); });
  219. }
  220. #region Purge
  221. private bool Purge(object[] param)
  222. {
  223. if (_vpwCellDevices == null || _vpwCellDevices.Count == 0)
  224. {
  225. LOG.WriteLog(eEvent.ERR_VPWMAIN, Module.ToString(), "cell device is empty");
  226. return false;
  227. }
  228. foreach (var device in _vpwCellDevices)
  229. {
  230. VpwCellEntity vpwCellEntity = Singleton<RouteManager>.Instance.GetModule<VpwCellEntity>(device.Module);
  231. if (vpwCellEntity.IsBusy)
  232. {
  233. LOG.WriteLog(eEvent.ERR_VPWMAIN, Module.ToString(), $"cell device {device.Module} is busy,cannot purge");
  234. return false;
  235. }
  236. }
  237. return _vpwPurgeRoutine.Start(_vpwCellDevices) == RState.Running;
  238. }
  239. private bool PurgeMonitor(object[] param)
  240. {
  241. RState ret = _vpwPurgeRoutine.Monitor();
  242. if (ret == RState.Failed || ret == RState.Timeout)
  243. {
  244. PostMsg(VPWMainMsg.Error);
  245. return false;
  246. }
  247. return ret == RState.End;
  248. }
  249. #endregion
  250. #region InitializeAll
  251. /// <summary>
  252. /// Initialize
  253. /// </summary>
  254. /// <param name="param"></param>
  255. /// <returns></returns>
  256. private bool InitializeAll(object[] param)
  257. {
  258. if (_vpwCellDevices == null || _vpwCellDevices.Count == 0)
  259. {
  260. LOG.WriteLog(eEvent.ERR_VPWMAIN, Module.ToString(), "cell device is empty");
  261. return false;
  262. }
  263. foreach(var device in _vpwCellDevices)
  264. {
  265. VpwCellEntity vpwCellEntity = Singleton<RouteManager>.Instance.GetModule<VpwCellEntity>(device.Module);
  266. if (vpwCellEntity.IsBusy)
  267. {
  268. LOG.WriteLog(eEvent.ERR_VPWMAIN, Module.ToString(), $"cell device {device.Module} is busy,cannot initialize");
  269. return false;
  270. }
  271. }
  272. return _homeRoutine.Start(_vpwCellDevices) == RState.Running;
  273. }
  274. /// <summary>
  275. /// Initialize 监控
  276. /// </summary>
  277. /// <param name="param"></param>
  278. /// <returns></returns>
  279. private bool InitializeAllMonitor(object[] param)
  280. {
  281. RState ret = _homeRoutine.Monitor();
  282. if (ret == RState.Failed || ret == RState.Timeout)
  283. {
  284. PostMsg(VPWMainMsg.Error);
  285. return false;
  286. }
  287. return ret == RState.End;
  288. }
  289. #endregion
  290. public bool Check(int msg, out string reason, params object[] args)
  291. {
  292. reason = "";
  293. return false;
  294. }
  295. public bool CheckAcked(int msg)
  296. {
  297. return false;
  298. }
  299. /// <summary>
  300. /// EnterInit
  301. /// </summary>
  302. public void EnterInit()
  303. {
  304. }
  305. public int Invoke(string function, params object[] args)
  306. {
  307. switch (function)
  308. {
  309. case "HomeAll":
  310. return (int)MSG.Home;
  311. }
  312. return (int)FSM_MSG.NONE;
  313. }
  314. }
  315. }