CompactMembranReservoirDevice.cs 131 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869
  1. using Aitex.Core.RT.DataCenter;
  2. using Aitex.Core.RT.Device;
  3. using Aitex.Core.RT.Log;
  4. using Aitex.Core.RT.OperationCenter;
  5. using Aitex.Core.RT.RecipeCenter;
  6. using Aitex.Core.RT.SCCore;
  7. using Aitex.Core.Util;
  8. using MECF.Framework.Common.Beckhoff.ModuleIO;
  9. using MECF.Framework.Common.CommonData.Reservoir;
  10. using MECF.Framework.Common.Persistent.Reservoirs;
  11. using MECF.Framework.Common.TwinCat;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.Reflection;
  15. using MECF.Framework.Common.RecipeCenter;
  16. using MECF.Framework.Common.ToolLayout;
  17. using System.Collections.ObjectModel;
  18. using MECF.Framework.Common.CommonData;
  19. using MECF.Framework.Common.Beckhoff.IOAxis;
  20. using System.Linq;
  21. using MECF.Framework.Common.Alarm;
  22. using MECF.Framework.Common.ProcessCell;
  23. using CyberX8_Core;
  24. using CyberX8_RT.Devices.Facilities;
  25. using CyberX8_RT.Devices.Metal;
  26. using CyberX8_RT.Devices.Safety;
  27. using CyberX8_RT.Devices.Temperature;
  28. using CyberX8_RT.Modules.Metal;
  29. using CyberX8_RT.Modules.Reservoir;
  30. using CyberX8_RT.Modules;
  31. using MECF.Framework.Common.IOCore;
  32. using static CyberX8_RT.Devices.Reservoir.ReservoirDiReplenHelper;
  33. namespace CyberX8_RT.Devices.Reservoir
  34. {
  35. public class CompactMembranReservoirDevice : BaseDevice, IDevice
  36. {
  37. private enum ReservoirOperation
  38. {
  39. None,
  40. ManualANDiReplen,
  41. ManualCADiReplen,
  42. AutoANDiReplen,
  43. AutoCADiReplen
  44. }
  45. #region 常量
  46. private const string PERSISTENT_VALUE = "PersistentValue";
  47. private const string CA_DI_REPLEN = "CADiReplen";
  48. private const string AN_DI_REPLEN = "ANDiReplen";
  49. private const string CA_WATER_LEVEL = "CAWaterLevel";
  50. private const string AN_WATER_LEVEL = "ANWaterLevel";
  51. private const string AN_PUMP = "ANPump";
  52. private const string CROSS_DOSE_ENABLE = "CrossDoseEnable";
  53. private const string TRANSFER_PUMP_STM_STATUS = "TransferPumpSTMStatus";
  54. private const string TRANSFER_PUMP_POS_STATUS = "TransferPumpPOSStatus";
  55. private const string TRANSFER_ACTUAL_POSITION = "TransferActualPosition";
  56. private const string TRANSFER_PUMP_ENABLE = "TransferPumpEnable";
  57. private const string TRANSFER_PUMP_RESET = "TransferPumpReset";
  58. private const string TRANSFER_PUMP_EXECUTE = "TransferPumpExecute";
  59. private const string TRANSFER_PUMP_TARGET_POSITION = "TransferPumpTargetPosition";
  60. private const string TRANSFER_PUMP_SPEED = "TransferPumpSpeed";
  61. private const string TRANSFER_PUMP_START_TYPE = "TransferPumpStartType";
  62. private const string TRANSFER_PUMP_ACCELERATION = "TransferPumpAcceleration";
  63. private const string TRANSFER_PUMP_DECELERATION = "TransferPumpDeceleration";
  64. private const string AN_BYPASS_FLOW = "ANBypassFlow";
  65. private const string AN_A_DRAIN_PUMP = "ANADrainPump";
  66. private const string AN_B_DRAIN_PUMP = "ANBDrainPump";
  67. private const string AN_BY_PASS = "ANByPass";
  68. //private const string AN_SLIP_STREAM_PUMP = "ANSlipStreamPump";
  69. private const string AN_TRANSFER_FLOW = "ANTransferFlow";
  70. //private const string CA_SLIP_STREAM_PUMP = "CASlipStreamPump";
  71. private const string CA_PUMP_SPEED = "CAPumpSpeed";
  72. private const string CA_PUMP_RUNNING = "CAPumpRunning";
  73. private const string CA_HED_FLOW = "CAHedFlow";
  74. private const string CDA_FLOW_VALVE = "CDAFlowValve";
  75. private const string CA_BY_PASS = "CAByPass";
  76. private const string CA_PUMP_ENABLE = "CAPumpEnable";
  77. private const string EVAPORATORLEVEL = "EvaporatorLevel";
  78. private const string AN_BYPASS_COUNTERFLOW = "ANBypassFlow";
  79. private const string AN_SAMPLE_FLOW = "ANSampleFlow";
  80. private const string CA_SAMPLE_FLOW = "CASampleFlow";
  81. private const string STRATUS = "Stratus";
  82. private const string AUTO = "Auto";
  83. private const string COUNTER_VALUE = "CounterValue";
  84. private const string COUNTER_START = "Start";
  85. private const string COUNTER_STOP = "Stop";
  86. private const string COUNTER_RESET = "Reset";
  87. private const int ENABLE = 5;
  88. private const string CA_FLOW_START_LOW_LIMIT_ERROR = "CaFlowStartLowLimitError";
  89. private const string CA_FLOW_RECIPE_ERROR = "CaFlowRecipeError";
  90. private const string CA_FLOW_RECIPE_WARN = "CaFlowRecipeWarn";
  91. private const string AN_A_FLOW_ZERO_ERROR = "AnAFlowZeroError";
  92. private const string AN_A_FLOW_RECIPE_ERROR = "AnAFlowRecipeError";
  93. private const string AN_A_FLOW_RECIPE_WARN = "AnAFlowRecipeWarn";
  94. private const string AN_B_FLOW_ZERO_ERROR = "AnBFlowZeroError";
  95. private const string AN_B_FLOW_RECIPE_ERROR = "AnBFlowRecipeError";
  96. private const string AN_B_FLOW_RECIPE_WARN = "AnBFlowRecipeWarn";
  97. #endregion
  98. #region 内部变量
  99. /// <summary>
  100. /// AN Level取样平均值
  101. /// </summary>
  102. private double _avgANLevel;
  103. /// <summary>
  104. /// AN Level取样队列
  105. /// </summary>
  106. private Queue<double> _ANLevelSamples;
  107. /// <summary>
  108. /// CA Level取样平均值
  109. /// </summary>
  110. private double _avgCALevel;
  111. /// <summary>
  112. /// CA Level取样队列
  113. /// </summary>
  114. private Queue<double> _CALevelSamples;
  115. /// <summary>
  116. /// AN/CA level计算平均值取样数
  117. /// </summary>
  118. private int levelSampleCount;
  119. /// <summary>
  120. /// Prewet 持久性数值对象
  121. /// </summary>
  122. private ReservoirsPersistentValue _persistentValue;
  123. /// <summary>
  124. /// 变量是否初始化字典
  125. /// </summary>
  126. private Dictionary<string, bool> _variableInitializeDic = new Dictionary<string, bool>();
  127. /// <summary>
  128. /// 错误字典
  129. /// </summary>
  130. private Dictionary<string, bool> _errorDic = new Dictionary<string, bool>();
  131. /// <summary>
  132. /// 数据
  133. /// </summary>
  134. private CompactMembranReservoirData _reservoirData = new CompactMembranReservoirData();
  135. /// <summary>
  136. /// Recipe
  137. /// </summary>
  138. private ResRecipe _resRecipe;
  139. /// <summary>
  140. /// 阳极Pump速度
  141. /// </summary>
  142. private double _anPumpSpeed = 0;
  143. /// <summary>
  144. /// 阴极Pump速度
  145. /// </summary>
  146. private double _caPumpSpeed = 0;
  147. /// <summary>
  148. /// 定时器
  149. /// </summary>
  150. private PeriodicJob _periodicJob;
  151. /// <summary>
  152. /// 注水Helper
  153. /// </summary>
  154. private ReservoirDiReplenHelper _direplenHelper;
  155. /// <summary>
  156. /// 泵速Helper
  157. /// </summary>
  158. private ReservoirPumpSpeedHelper _pumpSpeedHelper;
  159. /// <summary>
  160. /// 当前操作
  161. /// </summary>
  162. private ReservoirOperation _currentOperation;
  163. /// <summary>
  164. /// 手动注水时间(秒)
  165. /// </summary>
  166. private int _manualReplenSecond = 0;
  167. /// <summary>
  168. /// Fast leak Test时间间隔
  169. /// </summary>
  170. private int _aNLeakOperatingUpdateTime;
  171. /// <summary>
  172. /// Fast leak Test Tolerance Value
  173. /// </summary>
  174. private double _aNFastLeakLevelTolerance;
  175. /// <summary>
  176. /// 计时器是否正在运行
  177. /// </summary>
  178. private bool _isTestRunning = false;
  179. /// <summary>
  180. /// 是否检测到漏液
  181. /// </summary>
  182. private bool _isLeakDetected = false;
  183. /// <summary>
  184. /// 漏液的体积
  185. /// </summary>
  186. private double _leakVolume;
  187. /// <summary>
  188. /// 开始检测slow leak test时的ANLevel
  189. /// </summary>
  190. private double _StartSlowLeakTestANLevel;
  191. /// <summary>
  192. /// 配置的metal device集合
  193. /// </summary>
  194. private ObservableCollection<CompactMembranMetalDevice> _metalDevices = new ObservableCollection<CompactMembranMetalDevice>();
  195. /// <summary>
  196. /// 是否存在anflow有流量
  197. /// </summary>
  198. private bool _isHasAnFlow;
  199. /// <summary>
  200. /// 是否存在metal 在auto模式
  201. /// </summary>
  202. private bool _isHasMetalInAuto;
  203. /// <summary>
  204. /// 设备是否进行过初始化
  205. /// </summary>
  206. private bool _isInitialized;
  207. /// <summary>
  208. /// 是否安装CrossDose
  209. /// </summary>
  210. private bool _isCrossDoseInstalled;
  211. /// <summary>
  212. /// fastleaktest的开始时间
  213. /// </summary>
  214. private DateTime _fastLeakStartTime;
  215. /// <summary>
  216. /// slowleaktest的开始时间
  217. /// </summary>
  218. private DateTime _slowLeakStartTime;
  219. /// <summary>
  220. /// fastleak 测试时间间隔
  221. /// </summary>
  222. private TimeSpan _fastLeakTestSpan;
  223. /// <summary>
  224. /// slowleak 测试时间间隔
  225. /// </summary>
  226. private TimeSpan _slowLeakTestSpan;
  227. /// <summary>
  228. /// clearLeakVolumeTime
  229. /// </summary>
  230. private double _clearLeakVolumeTime;
  231. /// <summary>
  232. /// ANTransferFlow(CrossDose Flow)
  233. /// </summary>
  234. private CounterFlowData _anTransferFlow = new CounterFlowData();
  235. /// <summary>
  236. /// ReservoirANByPassCounterFlow
  237. /// </summary>
  238. private CounterFlowData _reservoirCounterByPassFlow = new CounterFlowData();
  239. /// <summary>
  240. /// Counter字典
  241. /// </summary>
  242. private Dictionary<string, CounterFlowData> _nameCounterFlowData = new Dictionary<string, CounterFlowData>();
  243. /// <summary>
  244. /// CrossDoseHelper
  245. /// </summary>
  246. private CrossDoseHelper _crossDoseHelper;
  247. /// <summary>
  248. /// CrossDose是否初始化
  249. /// </summary>
  250. private bool _isCrossDoseInitialized;
  251. private bool _isTCControlWARN = false;
  252. /// <summary>
  253. /// flow fault hold off时长
  254. /// </summary>
  255. private int _flowFaultHoldOffTime = 10;
  256. private DateTime _AnPumpSafeDetectTime;
  257. private double _metalTotalFlow;
  258. /// <summary>
  259. /// ErrorMessage
  260. /// </summary>
  261. private bool _isAnPumpSafeDetectedActivate = false;
  262. private bool _isANAutoDIReplenError = false;
  263. private bool _isCAAutoDIReplenError = false;
  264. private bool _isSystemAutoMode = false;
  265. /// <summary>
  266. /// 用于控制打印错误log
  267. /// </summary>
  268. private HashSet<string> errorLogSet = new HashSet<string>();
  269. /// <summary>
  270. /// 是否有其他DIReplen的警告
  271. /// </summary>
  272. private bool _isOtherDIReplenWarnOn = false;
  273. /// <summary>
  274. /// Facility DIReplen Off Warning
  275. /// </summary>
  276. private bool _isTotalDIReplenWarnOn = false;
  277. /// <summary>
  278. /// 累计补水是否超时
  279. /// </summary>
  280. private bool _isDIReplenMaxTimeOut = false;
  281. /// <summary>
  282. /// 单次补水是否超时
  283. /// </summary>
  284. private bool _isDIReplenPerfillTimeOut = false;
  285. #endregion
  286. #region 属性
  287. /// <summary>
  288. /// 数据
  289. /// </summary>
  290. public CompactMembranReservoirData ReservoirData { get { return _reservoirData; } }
  291. /// <summary>
  292. /// 操作模式
  293. /// </summary>
  294. public string OperationMode { get { return _persistentValue.OperatingMode; } }
  295. /// <summary>
  296. /// 工程模式
  297. /// </summary>
  298. public string EngineerMode { get { return _persistentValue.RecipeOperatingMode; } }
  299. /// <summary>
  300. /// 阳极是否需要补水
  301. /// </summary>
  302. public bool AnNeedDireplen { get { return CheckANNeedDiReplen(); } }
  303. /// <summary>
  304. /// 阴极是否需要补水
  305. /// </summary>
  306. public bool CANeedDiReplen { get { return CheckCANeedDiReplen(); } }
  307. /// <summary>
  308. /// 检验阴极是否highlevel
  309. /// </summary>
  310. public bool IsCAHighLevel { get { return CheckCAHighLevelStatus(); } }
  311. /// <summary>
  312. /// 检验阴极是否lowlevel
  313. /// </summary>
  314. public bool IsCALowLevel { get { return CheckCALowLevelStatus(); } }
  315. /// <summary>
  316. /// 检验阳极是否highlevel
  317. /// </summary>
  318. public bool IsANHighLevel { get { return CheckANHighLevelStatus(); } }
  319. /// <summary>
  320. /// 检验阳极是否lowlevel
  321. /// </summary>
  322. public bool IsANLowLevel { get { return CheckANLowLevelStatus(); } }
  323. /// <summary>
  324. /// 正在补水
  325. /// </summary>
  326. public bool IsDireplenOn { get { return _reservoirData.ANDiReplen || _reservoirData.CADiReplen; } }
  327. /// <summary>
  328. /// 当前Recipe
  329. /// </summary>
  330. public ResRecipe Recipe { get { return _resRecipe; } }
  331. /// <summary>
  332. /// 是否自动模式
  333. /// </summary>
  334. public bool IsAuto { get { return _persistentValue.OperatingMode == AUTO; } }
  335. /// <summary>
  336. /// ANTransferFlow
  337. /// </summary>
  338. public CounterFlowData ANTransferFlow { get { return _anTransferFlow; } }
  339. /// <summary>
  340. /// ReservoirCounterByPassFlow
  341. /// </summary>
  342. public CounterFlowData ReservoirCounterByPassFlow { get { return _reservoirCounterByPassFlow; } }
  343. /// <summary>
  344. /// 累计补水是否超时
  345. /// </summary>
  346. public bool IsDIReplenMaxTimeOut { get { return _isDIReplenMaxTimeOut; } }
  347. /// <summary>
  348. /// 单次补水是否超时
  349. /// </summary>
  350. public bool IsDIReplenPerfillTimeOut { get { return _isDIReplenPerfillTimeOut; } }
  351. /// <summary>
  352. /// Facility DIReplenOn
  353. /// </summary>
  354. public bool TotalDIReplenOn
  355. {
  356. get
  357. {
  358. var facilitiesDevice = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  359. return facilitiesDevice != null ? facilitiesDevice.DIReplenEnable : false;
  360. }
  361. }
  362. #endregion
  363. /// <summary>
  364. /// 初始化成功清除对应的错误log
  365. /// </summary>
  366. /// <param name="module"></param>
  367. public void ClearErrorLogSet(string module)
  368. {
  369. // 使用构造函数复制 HashSet
  370. HashSet<string> newHashSet = new HashSet<string>(errorLogSet);
  371. foreach (var item in newHashSet)
  372. {
  373. if (item.Contains(module))
  374. {
  375. errorLogSet.Remove(item);
  376. }
  377. }
  378. }
  379. /// <summary>
  380. /// 构造函数
  381. /// </summary>
  382. /// <param name="moduleName"></param>
  383. /// <param name="name"></param>
  384. public CompactMembranReservoirDevice(string moduleName) : base(moduleName, moduleName, moduleName, moduleName)
  385. {
  386. _anPumpSpeed = SC.GetValue<double>($"Reservoir.ANDefaultPumpSpeed");
  387. _caPumpSpeed = SC.GetValue<double>("Reservoir.CADefaultPumpSpeed");
  388. _aNLeakOperatingUpdateTime = SC.GetValue<int>($"Reservoir.{Module}.ANLeakOperatingUpdateTime");
  389. _aNFastLeakLevelTolerance = SC.GetValue<double>($"Reservoir.{Module}.ANFastLeakLevelTolerance");
  390. _clearLeakVolumeTime = SC.GetValue<double>($"Reservoir.{Module}.CleraLeakVolumeTime");
  391. _flowFaultHoldOffTime = SC.GetValue<int>($"Reservoir.{Module}.FlowFaultHoldOffTime") / 1000;
  392. levelSampleCount = SC.GetValue<int>("Reservoir.LevelAvgSamples");
  393. levelSampleCount = levelSampleCount == 0 ? 20 : levelSampleCount;
  394. _ANLevelSamples = new Queue<double>(levelSampleCount);
  395. _CALevelSamples = new Queue<double>(levelSampleCount);
  396. _periodicJob = new PeriodicJob(200, OnTimer, $"{Module}.Timer", true, true);
  397. double updateTime = _aNLeakOperatingUpdateTime > 0 ? Convert.ToDouble(_aNLeakOperatingUpdateTime) : 3.00;//配置文件没有则默认3分钟
  398. _fastLeakTestSpan = TimeSpan.FromMinutes(updateTime);
  399. //slow leak test 时间间隔一个小时,因为leak test开始后要等待clearleakvolumeTime重新开始,因此时间间隔就等于两者相加,第一次执行减掉就行。
  400. _slowLeakTestSpan = TimeSpan.FromMinutes(60) + TimeSpan.FromMinutes(_clearLeakVolumeTime);
  401. }
  402. /// <summary>
  403. /// 初始化
  404. /// </summary>
  405. /// <returns></returns>
  406. public bool Initialize()
  407. {
  408. InitializeParameter();
  409. InitializeRoutine();
  410. SubscribeData();
  411. InitializeOperation();
  412. SubscribeValueAction();
  413. return true;
  414. }
  415. /// <summary>
  416. /// 初始化Routine
  417. /// </summary>
  418. private void InitializeRoutine()
  419. {
  420. }
  421. /// <summary>
  422. /// 初始化参数
  423. /// </summary>
  424. private void InitializeParameter()
  425. {
  426. _persistentValue = ReservoirsPersistentManager.Instance.GetReservoirsPersistentValue(Module);
  427. if (_persistentValue == null)
  428. {
  429. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, "Persistent Value Object is not exist");
  430. }
  431. if (!string.IsNullOrEmpty(_persistentValue.Recipe))
  432. {
  433. _resRecipe = RecipeFileManager.Instance.LoadGenericityRecipe<ResRecipe>(_persistentValue.Recipe);
  434. }
  435. _direplenHelper = new ReservoirDiReplenHelper(Module, _persistentValue);
  436. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  437. if (reservoirItem != null)
  438. {
  439. foreach (var item in reservoirItem.MetalCells)
  440. {
  441. if (item.ModuleName != Module)
  442. {
  443. CompactMembranMetalDevice metalDevice = DEVICE.GetDevice<CompactMembranMetalDevice>(item.ModuleName);
  444. if (metalDevice != null)
  445. {
  446. _metalDevices.Add(metalDevice);
  447. _errorDic[$"{metalDevice.Module}_{CA_FLOW_START_LOW_LIMIT_ERROR}"] = false;
  448. _errorDic[$"{metalDevice.Module}_{CA_FLOW_RECIPE_ERROR}"] = false;
  449. _errorDic[$"{metalDevice.Module}_{CA_FLOW_RECIPE_WARN}"] = false;
  450. _errorDic[$"{metalDevice.Module}_{AN_A_FLOW_ZERO_ERROR}"] = false;
  451. _errorDic[$"{metalDevice.Module}_{AN_A_FLOW_RECIPE_ERROR}"] = false;
  452. _errorDic[$"{metalDevice.Module}_{AN_A_FLOW_RECIPE_WARN}"] = false;
  453. _errorDic[$"{metalDevice.Module}_{AN_B_FLOW_RECIPE_ERROR}"] = false;
  454. _errorDic[$"{metalDevice.Module}_{AN_B_FLOW_RECIPE_WARN}"] = false;
  455. _errorDic[$"{metalDevice.Module}_{AN_B_FLOW_ZERO_ERROR}"] = false;
  456. }
  457. }
  458. }
  459. if (reservoirItem.CrossDoseType != "" && reservoirItem.CrossDoseType != "None")
  460. {
  461. _isCrossDoseInstalled = true;
  462. _crossDoseHelper = new CrossDoseHelper(Module);
  463. _isCrossDoseInitialized = false;
  464. }
  465. }
  466. }
  467. /// <summary>
  468. /// 订阅数据
  469. /// </summary>
  470. private void SubscribeData()
  471. {
  472. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  473. DATA.Subscribe($"{Module}.ReservoirData", () => _reservoirData, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  474. DATA.Subscribe($"{Module}.ReservoirAverageANLevel", () => _avgANLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  475. DATA.Subscribe($"{Module}.ReservoirAverageCALevel", () => _avgCALevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  476. DATA.Subscribe($"{Module}.{PERSISTENT_VALUE}", () => _persistentValue, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  477. DATA.Subscribe($"{Module}.ANPumpSpeed", () => _anPumpSpeed, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  478. DATA.Subscribe($"{Module}.CAPumpSpeed", () => _caPumpSpeed, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  479. DATA.Subscribe($"{Module}.RecipeName", () => (_resRecipe != null ? _resRecipe.Ppid : ""), SubscriptionAttribute.FLAG.IgnoreSaveDB);
  480. DATA.Subscribe($"{Module}.ANLevel", () => _reservoirData.ANLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  481. DATA.Subscribe($"{Module}.CALevel", () => _reservoirData.CALevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  482. DATA.Subscribe($"{Module}.ANBypassFlow", () => _reservoirData.ANBypassFlow, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  483. DATA.Subscribe($"{Module}.HedFlow", () => _reservoirData.CAHedFlow, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  484. DATA.Subscribe($"{Module}.CurrentRecipe", () => _resRecipe, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  485. DATA.Subscribe($"{Module}.DIValveMaxOnTime", () => SC.GetValue<double>($"Reservoir.{Module}.DIValveMaxOnTime") * 60, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  486. DATA.Subscribe($"{Module}.IsManualCAReplen", () => { return _currentOperation == ReservoirOperation.ManualCADiReplen; }, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  487. DATA.Subscribe($"{Module}.IsManualANReplen", () => { return _currentOperation == ReservoirOperation.ManualANDiReplen; }, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  488. DATA.Subscribe($"{Module}.IsCAHighLevel", () => IsCAHighLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  489. DATA.Subscribe($"{Module}.IsCALowLevel", () => IsCALowLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  490. DATA.Subscribe($"{Module}.IsANHighLevel", () => IsANHighLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  491. DATA.Subscribe($"{Module}.IsANLowLevel", () => IsANLowLevel, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  492. DATA.Subscribe($"{Module}.EvaporatorType", () => reservoirItem.EvaporatorType, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  493. DATA.Subscribe($"{Module}.CroseDoseType", () => reservoirItem.CrossDoseType, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  494. DATA.Subscribe($"{Module}.IsLeakDetected", () => _isLeakDetected, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  495. DATA.Subscribe($"{Module}.IsCrossDoseInstalled", () => _isCrossDoseInstalled, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  496. DATA.Subscribe($"{Module}.ANBypassCounterFlow", () => ReservoirCounterByPassFlow.CounterValue, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  497. DATA.Subscribe($"{Module}.IsDIReplenPerfillTimeOut", () => _isDIReplenPerfillTimeOut, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  498. DATA.Subscribe($"{Module}.IsDIReplenMaxTimeOut", () => _isDIReplenMaxTimeOut, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  499. if (_isCrossDoseInstalled)
  500. {
  501. DATA.Subscribe($"{Module}.ANTransferFlow", () => ANTransferFlow != null ? ANTransferFlow.CounterValue : 0, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  502. DATA.Subscribe($"{Module}.IsCalibrateEnable", () => (_crossDoseHelper != null && _crossDoseHelper.CrossDoseState == RState.Running) ? false : true, SubscriptionAttribute.FLAG.IgnoreSaveDB);
  503. }
  504. }
  505. /// <summary>
  506. /// 初始化操作
  507. /// </summary>
  508. private void InitializeOperation()
  509. {
  510. OP.Subscribe($"{Module}.DisabledAction", DisabledOperation);
  511. OP.Subscribe($"{Module}.ManualAction", ManualOperation);
  512. OP.Subscribe($"{Module}.AutoAction", AutoOperation);
  513. OP.Subscribe($"{Module}.EngineeringModeAction", EngineeringModeOperation);
  514. OP.Subscribe($"{Module}.ProductionModeAction", ProductionModeOperation);
  515. OP.Subscribe($"{Module}.LoadRecipe", LoadRecipeOperation);
  516. OP.Subscribe($"{Module}.AnPumpOn", AnPumpOnOperation);
  517. OP.Subscribe($"{Module}.ANPumpSpeed", ANPumpSpeed);
  518. OP.Subscribe($"{Module}.AnPumpOff", AnPumpOffOperation);
  519. OP.Subscribe($"{Module}.AnADrainPumpOn", AnADrainPumpOn);
  520. OP.Subscribe($"{Module}.AnADrainPumpOff", AnADrainPumpOff);
  521. OP.Subscribe($"{Module}.AnBDrainPumpOn", AnBDrainPumpOn);
  522. OP.Subscribe($"{Module}.AnBDrainPumpOff", AnBDrainPumpOff);
  523. OP.Subscribe($"{Module}.ANDiReplenOn", ANDiReplenOnOperation);
  524. OP.Subscribe($"{Module}.ANDiReplenOff", ANDiReplenOff);
  525. OP.Subscribe($"{Module}.ANByPassOn", ANByPassOn);
  526. OP.Subscribe($"{Module}.ANByPassOff", ANByPassOff);
  527. OP.Subscribe($"{Module}.CAPumpOn", CAPumpOn);
  528. OP.Subscribe($"{Module}.CAPumpSpeed", CAPumpSpeedOperation);
  529. OP.Subscribe($"{Module}.CAPumpOff", CAPumpOff);
  530. OP.Subscribe($"{Module}.CADiReplenOn", CADiReplenOnOperation);
  531. OP.Subscribe($"{Module}.CADiReplenOff", CADiReplenOff);
  532. OP.Subscribe($"{Module}.CDAFlowOn", CDAFlowOn);
  533. OP.Subscribe($"{Module}.CDAFlowOff", CDAFlowOff);
  534. OP.Subscribe($"{Module}.CAByPassOn", CAByPassOn);
  535. OP.Subscribe($"{Module}.CAByPassOff", CAByPassOff);
  536. OP.Subscribe($"{Module}.ANSampleOn", ANSampleOn);
  537. OP.Subscribe($"{Module}.ANSampleOff", ANSampleOff);
  538. OP.Subscribe($"{Module}.CASampleOn", CASampleOn);
  539. OP.Subscribe($"{Module}.CASampleOff", CASampleOff);
  540. OP.Subscribe($"{Module}.ManualANDiReplen", ManualANDiReplen);
  541. OP.Subscribe($"{Module}.ManualCADiReplen", ManualCADiReplen);
  542. OP.Subscribe($"{Module}.BaseLineKeyDown", BaseLineKeyDownAction);
  543. OP.Subscribe($"{Module}.StartLeakTest", StartLeakTestAction);
  544. OP.Subscribe($"{Module}.ResetTotalTime", ResetTotalTime);
  545. OP.Subscribe($"{Module}.ClearSlowLeak", ClearSlowLeak);
  546. OP.Subscribe($"{Module}.DIReplenClearError", DIReplenClearError);
  547. if (_isCrossDoseInstalled)
  548. {
  549. OP.Subscribe($"{Module}.StartDosing", StartDosing);
  550. OP.Subscribe($"{Module}.HaltDosing", HaltDosing);
  551. OP.Subscribe($"{Module}.SetPumpFactor", SetPumpFactor);
  552. OP.Subscribe($"{Module}.CrossDoseOn", CrossDoseOn);
  553. OP.Subscribe($"{Module}.CrossDoseOff", CrossDoseOff);
  554. OP.Subscribe($"{Module}.ResetCrossDose", ResetCrossDose);
  555. }
  556. }
  557. #region Operation
  558. /// <summary>
  559. /// DIReplen Clear Error
  560. /// </summary>
  561. /// <param name="cmd"></param>
  562. /// <param name="args"></param>
  563. private bool DIReplenClearError(string cmd, object[] args)
  564. {
  565. _isDIReplenPerfillTimeOut = false;
  566. return true;
  567. }
  568. /// <summary>
  569. /// 重置时长
  570. /// </summary>
  571. /// <param name="cmd"></param>
  572. /// <param name="objs"></param>
  573. /// <returns></returns>
  574. private bool ResetTotalTime(string cmd, object[] objs)
  575. {
  576. _isDIReplenMaxTimeOut = false;
  577. _persistentValue.TotalReplen = 0;
  578. _persistentValue.LastTotalReplen = 0;
  579. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  580. return true;
  581. }
  582. /// <summary>
  583. /// DisabledAction
  584. /// </summary>
  585. /// <param name="cmd"></param>
  586. /// <param name="param"></param>
  587. /// <returns></returns>
  588. private bool DisabledOperation(string cmd, object[] args)
  589. {
  590. string currentOperation = "Disabled";
  591. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  592. if (_persistentValue != null && reservoirEntity != null && _persistentValue.OperatingMode != currentOperation)
  593. {
  594. string preOperation = _persistentValue.OperatingMode;
  595. if (reservoirEntity.IsBusy)
  596. {
  597. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} is Busy, can't switch to Disabled mode");
  598. return false;
  599. }
  600. if (_persistentValue.OperatingMode == "Auto" && reservoirEntity.IsMetalBusy)
  601. {
  602. string busymodule = "";
  603. if (_metalDevices != null)
  604. {
  605. foreach (var item in _metalDevices)
  606. {
  607. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(item.Module.ToString());
  608. if (metalEntity != null && metalEntity.IsBusy)
  609. {
  610. busymodule += metalEntity.Module.ToString() + "/";
  611. }
  612. }
  613. }
  614. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{busymodule} is Busy, can't switch to Disabled mode");
  615. return false;
  616. }
  617. foreach (var metalDevice in _metalDevices)
  618. {
  619. metalDevice.DisabledOperation("", null);
  620. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(metalDevice.Module);
  621. metalEntity.AbortRecipe(null);
  622. metalDevice.EnterDisabledOperation();
  623. }
  624. if (_isCrossDoseInstalled)
  625. {
  626. HaltDosing("", null);
  627. InitializeCrossDose(false);
  628. }
  629. EnterDisabledOperation();
  630. reservoirEntity.EnterInit();
  631. _persistentValue.OperatingMode = currentOperation;
  632. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $"Operating mode is switched from {preOperation} to {currentOperation}");
  633. }
  634. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  635. _currentOperation = ReservoirOperation.None;
  636. return true;
  637. }
  638. /// <summary>
  639. /// ManualAction
  640. /// </summary>
  641. /// <param name="cmd"></param>
  642. /// <param name="param"></param>
  643. /// <returns></returns>
  644. private bool ManualOperation(string cmd, object[] args)
  645. {
  646. string currentOperation = "Manual";
  647. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  648. if (_persistentValue != null && reservoirEntity != null && _persistentValue.OperatingMode != currentOperation)
  649. {
  650. string preOperation = _persistentValue.OperatingMode;
  651. if (reservoirEntity.IsBusy)
  652. {
  653. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} is Busy, can't switch to Manual mode");
  654. return false;
  655. }
  656. if (_persistentValue.OperatingMode == "Auto" && reservoirEntity.IsMetalBusy)
  657. {
  658. string busymodule = "";
  659. if (_metalDevices != null)
  660. {
  661. foreach (var item in _metalDevices)
  662. {
  663. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(item.Module.ToString());
  664. if (metalEntity != null && metalEntity.IsBusy)
  665. {
  666. busymodule += metalEntity.Module.ToString() + "/";
  667. }
  668. }
  669. }
  670. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{busymodule} is Busy, can't switch to Manual mode");
  671. return false;
  672. }
  673. foreach (var metalDevice in _metalDevices)
  674. {
  675. metalDevice.ManualOperation("", null);
  676. }
  677. if (_isCrossDoseInstalled) InitializeCrossDose(false);
  678. reservoirEntity.EnterInit();
  679. if (_reservoirData.ANDiReplen) ANDiReplenOff("", null);
  680. if (_reservoirData.CADiReplen) CADiReplenOff("", null);
  681. _persistentValue.OperatingMode = currentOperation;
  682. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $"Operating mode is switched from {preOperation} to {currentOperation}");
  683. }
  684. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  685. _currentOperation = ReservoirOperation.None;
  686. return true;
  687. }
  688. /// <summary>
  689. /// AutoAction
  690. /// </summary>
  691. /// <param name="cmd"></param>
  692. /// <param name="param"></param>
  693. /// <returns></returns>
  694. private bool AutoOperation(string cmd, object[] args)
  695. {
  696. if (IsANLowLevel || IsCALowLevel)
  697. {
  698. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"LowLevel is activated, can't switch to Auto mode");
  699. return false;
  700. }
  701. string currentOperation = "Auto";
  702. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  703. if (_persistentValue != null && reservoirEntity != null && _persistentValue.OperatingMode != currentOperation)
  704. {
  705. string preOperation = _persistentValue.OperatingMode;
  706. if (reservoirEntity.IsBusy)
  707. {
  708. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} is Busy, can't switch to Auto mode");
  709. return false;
  710. }
  711. if (_isCrossDoseInstalled) InitializeCrossDose(false);
  712. reservoirEntity.EnterInit();
  713. if (_reservoirData.ANDiReplen) ANDiReplenOff("", null);
  714. if (_reservoirData.CADiReplen) CADiReplenOff("", null);
  715. _isDIReplenPerfillTimeOut = false;
  716. _persistentValue.OperatingMode = currentOperation;
  717. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $"Operating mode is switched from {preOperation} to {currentOperation}");
  718. }
  719. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  720. return true;
  721. }
  722. /// <summary>
  723. /// EngineeringModeAction
  724. /// </summary>
  725. /// <param name="cmd"></param>
  726. /// <param name="param"></param>
  727. /// <returns></returns>
  728. private bool EngineeringModeOperation(string cmd, object[] args)
  729. {
  730. string currentRecipeOperation = "Engineering";
  731. if (_persistentValue != null)
  732. {
  733. _persistentValue.RecipeOperatingMode = currentRecipeOperation;
  734. }
  735. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  736. return true;
  737. }
  738. /// <summary>
  739. /// ProductionAction
  740. /// </summary>
  741. /// <param name="cmd"></param>
  742. /// <param name="param"></param>
  743. /// <returns></returns>
  744. private bool ProductionModeOperation(string cmd, object[] args)
  745. {
  746. string currentRecipeOperation = "Production";
  747. if (_persistentValue != null)
  748. {
  749. _persistentValue.RecipeOperatingMode = currentRecipeOperation;
  750. }
  751. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  752. return true;
  753. }
  754. /// <summary>
  755. /// 加载Recipe
  756. /// </summary>
  757. /// <param name="cmd"></param>
  758. /// <param name="args"></param>
  759. /// <returns></returns>
  760. private bool LoadRecipeOperation(string cmd, object[] args)
  761. {
  762. _persistentValue.Recipe = args[0].ToString();
  763. string[] fileRoute = _persistentValue.Recipe.Split('\\');
  764. string recipeRoute = "";
  765. if (fileRoute.Length > 2)
  766. {
  767. recipeRoute = fileRoute[fileRoute.Length - 2];
  768. }
  769. _resRecipe = RecipeFileManager.Instance.LoadGenericityRecipe<ResRecipe>(_persistentValue.Recipe);
  770. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module.ToString());
  771. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module.ToString(), $"Load {recipeRoute} Recipe {_resRecipe.Ppid} Success");
  772. return true;
  773. }
  774. /// <summary>
  775. /// Enter Disabled Operation
  776. /// </summary>
  777. /// <returns></returns>
  778. private void EnterDisabledOperation()
  779. {
  780. if (_reservoirData.CAPumpEnable)
  781. {
  782. CAPumpOff("CAPumpOff", null);
  783. }
  784. if (_reservoirData.ANPump > 0)
  785. {
  786. AnPumpOffOperation("", null);
  787. }
  788. if (_reservoirData.ANADrainPump > 0)
  789. {
  790. AnADrainPumpOff("", null);
  791. }
  792. if (_reservoirData.ANBDrainPump > 0)
  793. {
  794. AnBDrainPumpOff("", null);
  795. }
  796. if (_reservoirData.ANByPass)
  797. {
  798. ANByPassOff("", null);
  799. }
  800. if (_reservoirData.ANDiReplen)
  801. {
  802. ANDiReplenOff("", null);
  803. }
  804. if (_reservoirData.CADiReplen)
  805. {
  806. CADiReplenOff("", null);
  807. }
  808. }
  809. #endregion
  810. #region AN DiReplen
  811. /// <summary>
  812. /// 阳极DI Replen On
  813. /// </summary>
  814. /// <param name="cmd"></param>
  815. /// <param name="args"></param>
  816. /// <returns></returns>
  817. private bool ANDiReplenOnOperation(string cmd, object[] args)
  818. {
  819. return ANDiReplenOn();
  820. }
  821. /// <summary>
  822. /// 阳极DI Replen On
  823. /// </summary>
  824. /// <param name="showError"></param>
  825. /// <returns></returns>
  826. public bool ANDiReplenOn()
  827. {
  828. if (IsANHighLevel)
  829. {
  830. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"ANHighLevel is activate, can't do AN_DIReplen");
  831. return false;
  832. }
  833. if (IsANLowLevel)
  834. {
  835. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"ANLowLevel is activate, can't do AN_DIReplen");
  836. return false;
  837. }
  838. bool preCondition = CheckPreDiReplenCondition();
  839. if (!preCondition)
  840. {
  841. return false;
  842. }
  843. if (ReservoirData.CADiReplen)
  844. {
  845. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, "CA_DIReplen is on");
  846. return false;
  847. }
  848. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_DI_REPLEN}");
  849. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  850. }
  851. /// <summary>
  852. /// 阳极DI Replen On
  853. /// </summary>
  854. /// <param name="cmd"></param>
  855. /// <param name="args"></param>
  856. /// <returns></returns>
  857. private bool ANDiReplenOff(string cmd, object[] args)
  858. {
  859. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_DI_REPLEN}");
  860. bool result = BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  861. if (result)
  862. {
  863. _persistentValue.IsDiReplenOn = false;
  864. if (_currentOperation == ReservoirOperation.ManualANDiReplen || _currentOperation == ReservoirOperation.AutoANDiReplen)
  865. {
  866. _currentOperation = ReservoirOperation.None;
  867. _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
  868. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  869. }
  870. }
  871. return result;
  872. }
  873. /// <summary>
  874. /// 检验DiReplen前置条件
  875. /// </summary>
  876. /// <returns></returns>
  877. public bool CheckPreDiReplenCondition()
  878. {
  879. if (!CheckFacilitiesDiReplenStatus())
  880. {
  881. if (!_isTotalDIReplenWarnOn)
  882. {
  883. _isTotalDIReplenWarnOn = true;
  884. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, "Facilities DiReplen is Off, can't start auto diReplen");
  885. }
  886. return false;
  887. }
  888. else
  889. {
  890. _isTotalDIReplenWarnOn = false;
  891. }
  892. SafetyDevice safetyDevice = DEVICE.GetDevice<SafetyDevice>("Safety");
  893. if (safetyDevice != null && safetyDevice.SafetyData.ReservoirHighLevel)
  894. {
  895. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Safety high is Activate, can't start auto diReplen");
  896. return false;
  897. }
  898. if (CheckOtherReservoirDiReplenStatus())
  899. {
  900. return false;
  901. }
  902. return true;
  903. }
  904. /// <summary>
  905. /// 检验总Di有没有开
  906. /// </summary>
  907. /// <returns></returns>
  908. private bool CheckFacilitiesDiReplenStatus()
  909. {
  910. SystemFacilities systemFacilities = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  911. if (systemFacilities != null)
  912. {
  913. return systemFacilities.DIReplenEnable;
  914. }
  915. return false;
  916. }
  917. /// <summary>
  918. /// 检验是否其他Reservoir Direplen已经
  919. /// </summary>
  920. /// <returns></returns>
  921. private bool CheckOtherReservoirDiReplenStatus()
  922. {
  923. List<string> reservoirs = ReservoirItemManager.Instance.InstalledModules;
  924. foreach (string item in reservoirs)
  925. {
  926. if (item != Module)
  927. {
  928. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(item);
  929. if (reservoirItem.SubType == STRATUS)
  930. {
  931. StandardHotReservoirDevice tmpDevice = DEVICE.GetDevice<StandardHotReservoirDevice>(item);
  932. if (tmpDevice.ReservoirData.DiReplen)
  933. {
  934. if (!_isOtherDIReplenWarnOn)
  935. {
  936. _isOtherDIReplenWarnOn = true;
  937. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{item} DiReplen valve is on. {Module} is waiting DiReplen");
  938. }
  939. return true;
  940. }
  941. }
  942. else
  943. {
  944. CompactMembranReservoirDevice tmpDevice = DEVICE.GetDevice<CompactMembranReservoirDevice>(item);
  945. if (tmpDevice.ReservoirData.ANDiReplen)
  946. {
  947. if (!_isOtherDIReplenWarnOn)
  948. {
  949. _isOtherDIReplenWarnOn = true;
  950. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{item} AN DiReplen valve is on. {Module} is waiting DiReplen");
  951. }
  952. return true;
  953. }
  954. if (tmpDevice.ReservoirData.CADiReplen)
  955. {
  956. if (!_isOtherDIReplenWarnOn)
  957. {
  958. _isOtherDIReplenWarnOn = true;
  959. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{item} CA DiReplen valve is on. {Module} is waiting DiReplen");
  960. }
  961. return true;
  962. }
  963. }
  964. }
  965. }
  966. _isOtherDIReplenWarnOn = false;
  967. return false;
  968. }
  969. #endregion
  970. #region AnPump
  971. /// <summary>
  972. /// AN Pump On 操作
  973. /// </summary>
  974. /// <param name="cmd"></param>
  975. /// <param name="args"></param>
  976. /// <returns></returns>
  977. public bool AnPumpOnOperation(string cmd, object[] args)
  978. {
  979. double anPumpSpeed = SC.GetValue<double>($"Reservoir.ANDefaultPumpSpeed");
  980. return AnPump(anPumpSpeed);
  981. }
  982. /// <summary>
  983. /// AN Pump Off操作
  984. /// </summary>
  985. /// <param name="cmd"></param>
  986. /// <param name="args"></param>
  987. /// <returns></returns>
  988. private bool AnPumpOffOperation(string cmd, object[] args)
  989. {
  990. return AnPump(0);
  991. }
  992. /// <summary>
  993. /// AN Pump
  994. /// </summary>
  995. /// <param name="speed"></param>
  996. /// <returns></returns>
  997. public bool AnPump(double speed)
  998. {
  999. if (speed == 0) //关pump时关掉配置的metal的fill valve
  1000. {
  1001. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  1002. if (reservoirItem != null)
  1003. {
  1004. List<MetalItem> metalItems = reservoirItem.MetalCells;
  1005. if (metalItems != null && metalItems.Count > 0)
  1006. {
  1007. foreach (MetalItem metalItem in metalItems)
  1008. {
  1009. if (metalItem.Installed)
  1010. {
  1011. CompactMembranMetalDevice metalDevice = DEVICE.GetDevice<CompactMembranMetalDevice>(metalItem.ModuleName);
  1012. if (metalDevice != null)
  1013. {
  1014. metalDevice.AnSideAFillOff("ANAFillOff", null);
  1015. metalDevice.AnSideBFillOff("ANBFillOff", null);
  1016. }
  1017. }
  1018. }
  1019. }
  1020. }
  1021. }
  1022. SafetyDevice safetyDevice = DEVICE.GetDevice<SafetyDevice>("Safety");
  1023. if (safetyDevice != null && !safetyDevice.SafetyData.PumpEdm)
  1024. {
  1025. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Safety PumpEdm is Activate");
  1026. return false;
  1027. }
  1028. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_PUMP}");
  1029. return BeckhoffIOManager.Instance.WriteIoValue(ioName, speed);
  1030. }
  1031. /// <summary>
  1032. /// AN Pump调整速度
  1033. /// </summary>
  1034. /// <param name="cmd"></param>
  1035. /// <param name="args"></param>
  1036. /// <returns></returns>
  1037. public bool ANPumpSpeed(string cmd, object[] args)
  1038. {
  1039. if (double.TryParse(args[0].ToString(), out double speed))
  1040. {
  1041. _anPumpSpeed = speed;
  1042. if (_anPumpSpeed > 0)
  1043. {
  1044. _reservoirData.ANPump = _anPumpSpeed;
  1045. }
  1046. return AnPump(speed);
  1047. }
  1048. else
  1049. {
  1050. LOG.WriteLog(eEvent.ERR_METAL, Module, $"{args[0]} is nor invalid speed");
  1051. return false;
  1052. }
  1053. }
  1054. #endregion
  1055. #region AN Drain Pump
  1056. /// <summary>
  1057. /// 阳极A面Drain Pump On
  1058. /// </summary>
  1059. /// <param name="cmd"></param>
  1060. /// <param name="args"></param>
  1061. /// <returns></returns>
  1062. public bool AnADrainPumpOn(string cmd, object[] args)
  1063. {
  1064. double speed = SC.GetValue<double>($"Reservoir.DrainSpeed");
  1065. return AnADrainPump(speed);
  1066. }
  1067. /// <summary>
  1068. /// 阳极A面Drain Pump Off
  1069. /// </summary>
  1070. /// <param name="cmd"></param>
  1071. /// <param name="args"></param>
  1072. /// <returns></returns>
  1073. private bool AnADrainPumpOff(string cmd, object[] args)
  1074. {
  1075. return AnADrainPump(0);
  1076. }
  1077. /// <summary>
  1078. /// 阳极B面Drain Pump On
  1079. /// </summary>
  1080. /// <param name="cmd"></param>
  1081. /// <param name="args"></param>
  1082. /// <returns></returns>
  1083. public bool AnBDrainPumpOn(string cmd, object[] args)
  1084. {
  1085. double speed = SC.GetValue<double>($"Reservoir.DrainSpeed");
  1086. return AnBDrainPump(speed);
  1087. }
  1088. /// <summary>
  1089. /// 阳极B面Drain Pump Off
  1090. /// </summary>
  1091. /// <param name="cmd"></param>
  1092. /// <param name="args"></param>
  1093. /// <returns></returns>
  1094. private bool AnBDrainPumpOff(string cmd, object[] args)
  1095. {
  1096. return AnBDrainPump(0);
  1097. }
  1098. /// <summary>
  1099. /// 阳极A Drain Pump
  1100. /// </summary>
  1101. /// <param name="speed"></param>
  1102. /// <returns></returns>
  1103. public bool AnADrainPump(double speed)
  1104. {
  1105. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_A_DRAIN_PUMP}");
  1106. return BeckhoffIOManager.Instance.WriteIoValue(ioName, speed);
  1107. }
  1108. /// <summary>
  1109. /// 阳极B Drain Pump
  1110. /// </summary>
  1111. /// <param name="speed"></param>
  1112. /// <returns></returns>
  1113. public bool AnBDrainPump(double speed)
  1114. {
  1115. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_B_DRAIN_PUMP}");
  1116. return BeckhoffIOManager.Instance.WriteIoValue(ioName, speed);
  1117. }
  1118. #endregion
  1119. #region AN ByPass
  1120. /// <summary>
  1121. /// 阳极ByPass On
  1122. /// </summary>
  1123. /// <param name="cmd"></param>
  1124. /// <param name="args"></param>
  1125. /// <returns></returns>
  1126. private bool ANByPassOn(string cmd, object[] args)
  1127. {
  1128. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_BY_PASS}");
  1129. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1130. }
  1131. /// <summary>
  1132. /// 阳极ByPass Off
  1133. /// </summary>
  1134. /// <param name="cmd"></param>
  1135. /// <param name="args"></param>
  1136. /// <returns></returns>
  1137. private bool ANByPassOff(string cmd, object[] args)
  1138. {
  1139. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_BY_PASS}");
  1140. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1141. }
  1142. #endregion
  1143. #region CA Pump
  1144. /// <summary>
  1145. /// CA Pump调速
  1146. /// </summary>
  1147. /// <param name="cmd"></param>
  1148. /// <param name="args"></param>
  1149. /// <returns></returns>
  1150. private bool CAPumpSpeedOperation(string cmd, object[] args)
  1151. {
  1152. double caMaxPumpSpeed = 0;
  1153. if (SC.ContainsItem("Reservoir.CAMaxPumpSpeed"))
  1154. {
  1155. caMaxPumpSpeed = SC.GetValue<double>("Reservoir.CAMaxPumpSpeed");
  1156. }
  1157. if (double.TryParse(args[0].ToString(), out double speed))
  1158. {
  1159. _caPumpSpeed = speed;
  1160. if (_caPumpSpeed > caMaxPumpSpeed)
  1161. {
  1162. LOG.WriteLog(eEvent.WARN_METAL, Module, $"CA pump speed:{_caPumpSpeed} is over CA max pump speed {caMaxPumpSpeed}!");
  1163. return false;
  1164. }
  1165. return CAPumpSpeed(_caPumpSpeed);
  1166. }
  1167. else
  1168. {
  1169. LOG.WriteLog(eEvent.ERR_METAL, Module, $"{args[0]} is nor invalid speed");
  1170. return false;
  1171. }
  1172. }
  1173. /// <summary>
  1174. /// 设置阴极泵速
  1175. /// </summary>
  1176. /// <param name="caPumpSpeed"></param>
  1177. /// <returns></returns>
  1178. public bool CAPumpSpeed(double caPumpSpeed)
  1179. {
  1180. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_PUMP_SPEED}");
  1181. return BeckhoffIOManager.Instance.WriteIoValue(ioName, caPumpSpeed);
  1182. }
  1183. /// <summary>
  1184. /// 阴极Pump On
  1185. /// </summary>
  1186. /// <param name="cmd"></param>
  1187. /// <param name="args"></param>
  1188. /// <returns></returns>
  1189. private bool CAPumpOn(string cmd, object[] args)
  1190. {
  1191. double caPumpSpeed = SC.GetValue<double>("Reservoir.CADefaultPumpSpeed");
  1192. bool result = CAPumpSpeed(caPumpSpeed);
  1193. if (result)
  1194. {
  1195. string enableIOName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_PUMP_ENABLE}");
  1196. return BeckhoffIOManager.Instance.WriteIoValue(enableIOName, true);
  1197. }
  1198. else
  1199. {
  1200. return false;
  1201. }
  1202. }
  1203. /// <summary>
  1204. /// 阴极Pump Off
  1205. /// </summary>
  1206. /// <param name="cmd"></param>
  1207. /// <param name="args"></param>
  1208. /// <returns></returns>
  1209. private bool CAPumpOff(string cmd, object[] args)
  1210. {
  1211. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_PUMP_ENABLE}");
  1212. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1213. }
  1214. #endregion
  1215. #region CA DiReplen
  1216. /// <summary>
  1217. /// 阴极DI Replen On
  1218. /// </summary>
  1219. /// <param name="cmd"></param>
  1220. /// <param name="args"></param>
  1221. /// <returns></returns>
  1222. private bool CADiReplenOnOperation(string cmd, object[] args)
  1223. {
  1224. return CADiReplenOn();
  1225. }
  1226. /// <summary>
  1227. /// 阴极DI Replen On
  1228. /// </summary>
  1229. /// <param name="showError"></param>
  1230. /// <returns></returns>
  1231. private bool CADiReplenOn()
  1232. {
  1233. bool preCondition = CheckPreDiReplenCondition();
  1234. if (!preCondition)
  1235. {
  1236. return false;
  1237. }
  1238. if (IsCAHighLevel)
  1239. {
  1240. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"CAHighLevel is activate,Can't do CA_DIReple");
  1241. return false;
  1242. }
  1243. if (IsCALowLevel)
  1244. {
  1245. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"CALowLevel is activate,Can't do CA_DIReple");
  1246. return false;
  1247. }
  1248. if (ReservoirData.ANDiReplen)
  1249. {
  1250. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, "ANDiReplen is on");
  1251. return false;
  1252. }
  1253. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_DI_REPLEN}");
  1254. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1255. }
  1256. /// <summary>
  1257. /// 阴极DI Replen Off
  1258. /// </summary>
  1259. /// <param name="cmd"></param>
  1260. /// <param name="args"></param>
  1261. /// <returns></returns>
  1262. private bool CADiReplenOff(string cmd, object[] args)
  1263. {
  1264. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_DI_REPLEN}");
  1265. bool result = BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1266. if (result)
  1267. {
  1268. _persistentValue.IsDiReplenOn = false;
  1269. if (_currentOperation == ReservoirOperation.ManualCADiReplen || _currentOperation == ReservoirOperation.AutoCADiReplen)
  1270. {
  1271. _currentOperation = ReservoirOperation.None;
  1272. _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
  1273. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  1274. }
  1275. }
  1276. return result;
  1277. }
  1278. #endregion
  1279. #region CDA Flow
  1280. /// <summary>
  1281. /// 阴极CDA Flow On
  1282. /// </summary>
  1283. /// <param name="cmd"></param>
  1284. /// <param name="args"></param>
  1285. /// <returns></returns>
  1286. private bool CDAFlowOn(string cmd, object[] args)
  1287. {
  1288. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CDA_FLOW_VALVE}");
  1289. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1290. }
  1291. /// <summary>
  1292. /// 阴极CDA Flow Off
  1293. /// </summary>
  1294. /// <param name="cmd"></param>
  1295. /// <param name="args"></param>
  1296. /// <returns></returns>
  1297. private bool CDAFlowOff(string cmd, object[] args)
  1298. {
  1299. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CDA_FLOW_VALVE}");
  1300. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1301. }
  1302. #endregion
  1303. #region CA ByPass
  1304. /// <summary>
  1305. /// 阴极ByPass On
  1306. /// </summary>
  1307. /// <param name="cmd"></param>
  1308. /// <param name="args"></param>
  1309. /// <returns></returns>
  1310. public bool CAByPassOn(string cmd, object[] args)
  1311. {
  1312. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_BY_PASS}");
  1313. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1314. }
  1315. /// <summary>
  1316. /// 阴极ByPass Off
  1317. /// </summary>
  1318. /// <param name="cmd"></param>
  1319. /// <param name="args"></param>
  1320. /// <returns></returns>
  1321. public bool CAByPassOff(string cmd, object[] args)
  1322. {
  1323. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_BY_PASS}");
  1324. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1325. }
  1326. #endregion
  1327. #region DiReplen Operation
  1328. /// <summary>
  1329. /// 手动阳极注水
  1330. /// </summary>
  1331. /// <param name="cmd"></param>
  1332. /// <param name="args"></param>
  1333. /// <returns></returns>
  1334. private bool ManualANDiReplen(string cmd, object[] args)
  1335. {
  1336. return ManualDiReplen(ANDiReplenOnOperation, ReservoirOperation.ManualANDiReplen, args[0].ToString());
  1337. }
  1338. /// <summary>
  1339. /// 手动阴极注水
  1340. /// </summary>
  1341. /// <param name="cmd"></param>
  1342. /// <param name="args"></param>
  1343. /// <returns></returns>
  1344. private bool ManualCADiReplen(string cmd, object[] args)
  1345. {
  1346. return ManualDiReplen(CADiReplenOnOperation, ReservoirOperation.ManualCADiReplen, args[0].ToString());
  1347. }
  1348. /// <summary>
  1349. /// 将前端输入的baseline更新到持久化文件
  1350. /// </summary>
  1351. /// <param name="cmd"></param>
  1352. /// <param name="args"></param>
  1353. /// <returns></returns>
  1354. private bool BaseLineKeyDownAction(string cmd, object[] args)
  1355. {
  1356. string variableName = args[0].ToString();
  1357. //baseline输入了一个不同的值的话,将新值写入持久化文件
  1358. if (_persistentValue.ANBaseLineLevel.ToString() != args[1].ToString())
  1359. {
  1360. PropertyInfo property = _persistentValue.GetType().GetProperty(variableName);
  1361. if (property != null)
  1362. {
  1363. property.SetValue(_persistentValue, args[1]);
  1364. }
  1365. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  1366. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" New ANBaseline {args[1]} was inputed");
  1367. _isTestRunning = false;
  1368. }
  1369. return true;
  1370. }
  1371. private bool StartLeakTestAction(string cmd, object[] args)
  1372. {
  1373. //前端重复点击start直接返回true;
  1374. if (_isTestRunning)
  1375. {
  1376. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" Fast leak test has already started");
  1377. return true;
  1378. }
  1379. //判断是否启动fast leak test 参数【0】表示是否初始化,参数【1】表示是否有metal有流量
  1380. if ((bool)args[0] && (bool)args[1])
  1381. {
  1382. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" Fast leak test is start");
  1383. _isTestRunning = true;
  1384. //记录fast leak test的开始时间
  1385. _fastLeakStartTime = DateTime.Now;
  1386. //记录slow leak test的开始时间,第一次的开始时间需要加上这个配置时间,正好使第一次执行slow leak test的时间间隔使为1小时。
  1387. _slowLeakStartTime = DateTime.Now + TimeSpan.FromMinutes(_clearLeakVolumeTime);
  1388. //记录slow leak test的开始液位
  1389. _StartSlowLeakTestANLevel = ReservoirData.ANLevel;
  1390. }
  1391. else
  1392. {
  1393. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" Leak test precondition not met, stoped");
  1394. _isTestRunning = false;
  1395. }
  1396. return true;
  1397. }
  1398. /// Fast leak test
  1399. /// </summary>
  1400. /// <param name="sender"></param>
  1401. /// <param name="e"></param>
  1402. private bool FastLeakTestAction()
  1403. {
  1404. bool isHasMetalFlow = false;
  1405. foreach (var metalDevice in _metalDevices)
  1406. {
  1407. if (metalDevice.ANACellFlow.CounterValue > 0 || metalDevice.ANBCellFlow.CounterValue > 0)
  1408. {
  1409. isHasMetalFlow = true;
  1410. }
  1411. }
  1412. if (!isHasMetalFlow)
  1413. {
  1414. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" No ANFLow in {Module}, current fast leak test is skiped");
  1415. //更新_faseLeak的启动时间,使其可以自动周期性检测
  1416. _fastLeakStartTime = DateTime.Now;
  1417. return true;
  1418. }
  1419. double aNBaseLineLevel = ReservoirsPersistentManager.Instance.GetReservoirsPersistentValue(Module).ANBaseLineLevel;
  1420. if (_reservoirData.ANLevel < aNBaseLineLevel - _aNFastLeakLevelTolerance)
  1421. {
  1422. _isLeakDetected = true; //用于前端页面指示灯
  1423. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $" Fast Leak was Detected,Current ANLevel is{_reservoirData.ANLevel},baseline is{aNBaseLineLevel}. Related pump and valve was closed");
  1424. AnPumpOffOperation($"{Module}.AnPumpOff", null);
  1425. //关闭对应的anolyte flow valve
  1426. foreach (var metalDevice in _metalDevices)
  1427. {
  1428. metalDevice.AnSideAFillOff($"{metalDevice.Name}.ANAFillOff", null);
  1429. metalDevice.AnSideBFillOff($"{metalDevice.Name}.ANBFillOff", null);
  1430. metalDevice.AnSideADrainOff($"{metalDevice.Name}.ANADrainOff", null);
  1431. metalDevice.AnSideBDrainOff($"{metalDevice.Name}.ANBDrainOff", null);
  1432. }
  1433. }
  1434. else
  1435. {
  1436. _isLeakDetected = false;
  1437. string variableName = "ANBaseLineLevel";
  1438. PropertyInfo property = _persistentValue.GetType().GetProperty(variableName);
  1439. if (property != null)
  1440. {
  1441. property.SetValue(_persistentValue, _reservoirData.ANLevel);
  1442. }
  1443. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  1444. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $"No fast leak test was Detected, leak test baseLine was updated");
  1445. }
  1446. //更新_faseLeak的启动时间,使其可以自动周期性检测
  1447. _fastLeakStartTime = DateTime.Now;
  1448. return true;
  1449. }
  1450. /// Slow leak test
  1451. /// </summary>
  1452. /// <param name="sender"></param>
  1453. /// <param name="e"></param>
  1454. private bool SlowLeakTestAction()
  1455. {
  1456. ReservoirEntity _reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  1457. if (_reservoirEntity != null && _reservoirEntity.IsInitialized)
  1458. {
  1459. _isInitialized = true;
  1460. }
  1461. else
  1462. {
  1463. _isInitialized = false;
  1464. }
  1465. if (_persistentValue.OperatingMode == AUTO)
  1466. {
  1467. foreach (var metalDevice in _metalDevices)
  1468. {
  1469. if (metalDevice.ANACellFlow.CounterValue > 0 || metalDevice.ANBCellFlow.CounterValue > 0)
  1470. {
  1471. _isHasAnFlow = true;
  1472. }
  1473. if ("Auto".Equals(metalDevice.OperationMode))
  1474. {
  1475. _isHasMetalInAuto = true;
  1476. }
  1477. }
  1478. if (_isHasAnFlow && _isHasMetalInAuto && _isInitialized)
  1479. {
  1480. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" Slow leak test is start");
  1481. _leakVolume = ReservoirData.ANLevel - _StartSlowLeakTestANLevel;
  1482. if (_leakVolume > SC.GetValue<double>($"Reservoir.{Module}.MaxLeakVolume"))
  1483. {
  1484. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, " Slow leak was detected");
  1485. }
  1486. }
  1487. }
  1488. //更新当前液位
  1489. _StartSlowLeakTestANLevel = ReservoirData.ANLevel;
  1490. //更新启动时间
  1491. _slowLeakStartTime = DateTime.Now;
  1492. return true;
  1493. }
  1494. /// <summary>
  1495. /// 重新开始slow leak test
  1496. /// </summary>
  1497. /// <param name="cmd"></param>
  1498. /// <param name="objs"></param>
  1499. /// <returns></returns>
  1500. private bool ClearSlowLeak(string cmd, object[] objs)
  1501. {
  1502. _StartSlowLeakTestANLevel = ReservoirData.ANLevel;
  1503. _slowLeakStartTime = DateTime.Now;
  1504. LOG.WriteLog(eEvent.INFO_RESERVOIR, Module, $" Slow leak test was reset");
  1505. return true;
  1506. }
  1507. /// <summary>
  1508. /// 手动注水
  1509. /// </summary>
  1510. /// <param name="direplenOn"></param>
  1511. /// <param name="direplenOperation"></param>
  1512. /// <returns></returns>
  1513. private bool ManualDiReplen(Func<string, object[], bool> direplenOn, ReservoirOperation direplenOperation, string timeLength)
  1514. {
  1515. if (_currentOperation != ReservoirOperation.None)
  1516. {
  1517. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"current operation is {_currentOperation},cannot execute {direplenOperation}");
  1518. return false;
  1519. }
  1520. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  1521. if (!reservoirEntity.IsInitialized)
  1522. {
  1523. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} is not initialized. Can't start DiReplen");
  1524. return false;
  1525. }
  1526. if (IsDIReplenMaxTimeOut)
  1527. {
  1528. double diValveMaxOnTime = SC.GetValue<double>($"Reservoir.{Module}.DIValveMaxOnTime");
  1529. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"DiReplen time over conifg's DIValveMaxOnTime:{diValveMaxOnTime} min");
  1530. return false;
  1531. }
  1532. if (IsDIReplenPerfillTimeOut)
  1533. {
  1534. double diValveMaxOnTimePerFill = SC.GetValue<double>($"Reservoir.{Module}.DIValveMaxOnTimePerFill");
  1535. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"DiReplen time over conifg's DIValveMaxOnTimePerFill:{diValveMaxOnTimePerFill} min");
  1536. return false;
  1537. }
  1538. bool result = direplenOn("", null);
  1539. if (result)
  1540. {
  1541. _currentOperation = direplenOperation;
  1542. _persistentValue.DiReplenTime = DateTime.Now;
  1543. ReservoirsPersistentManager.Instance.UpdatePersistentValue(Module);
  1544. int.TryParse(timeLength, out _manualReplenSecond);
  1545. }
  1546. return result;
  1547. }
  1548. /// <summary>
  1549. /// 阳极自动注水
  1550. /// </summary>
  1551. /// <returns></returns>
  1552. public bool AutoANDiReplen()
  1553. {
  1554. if (IsANLowLevel)
  1555. {
  1556. if (!_isANAutoDIReplenError)
  1557. {
  1558. _isANAutoDIReplenError = true;
  1559. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"ANLowLevel is activate,Can't AutoANDireplen");
  1560. }
  1561. return false;
  1562. }
  1563. else
  1564. {
  1565. _isANAutoDIReplenError = false;
  1566. }
  1567. return AutoDireplen(ANDiReplenOn, ReservoirOperation.AutoANDiReplen);
  1568. }
  1569. /// <summary>
  1570. /// 阴极自动流水
  1571. /// </summary>
  1572. /// <returns></returns>
  1573. public bool AutoCADiReplen()
  1574. {
  1575. if (IsCALowLevel)
  1576. {
  1577. if (!_isCAAutoDIReplenError)
  1578. {
  1579. _isCAAutoDIReplenError = true;
  1580. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"CALowLevel is activate,Can't AutoANDireplen");
  1581. }
  1582. return false;
  1583. }
  1584. else
  1585. {
  1586. _isCAAutoDIReplenError = false;
  1587. }
  1588. return AutoDireplen(CADiReplenOn, ReservoirOperation.AutoCADiReplen);
  1589. }
  1590. /// <summary>
  1591. /// 自动注水
  1592. /// </summary>
  1593. /// <returns></returns>
  1594. private bool AutoDireplen(Func<bool> direplenOn, ReservoirOperation reservoirOperation)
  1595. {
  1596. if (_currentOperation != ReservoirOperation.None)
  1597. {
  1598. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"current operation is {_currentOperation},cannot execute {reservoirOperation}");
  1599. return false;
  1600. }
  1601. if (_resRecipe == null)
  1602. {
  1603. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"recipe is null");
  1604. return false;
  1605. }
  1606. bool result = direplenOn();
  1607. if (result)
  1608. {
  1609. _currentOperation = reservoirOperation;
  1610. _persistentValue.DiReplenTime = DateTime.Now;
  1611. }
  1612. return result;
  1613. }
  1614. #endregion
  1615. #region CrossDose
  1616. /// <summary>
  1617. /// CrossDose开阀
  1618. /// </summary>
  1619. /// <param name="cmd"></param>
  1620. /// <param name="args"></param>
  1621. /// <returns></returns>
  1622. public bool CrossDoseOn(string cmd, object[] args)
  1623. {
  1624. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CROSS_DOSE_ENABLE}");
  1625. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1626. }
  1627. /// <summary>
  1628. /// CrossDose关阀
  1629. /// </summary>
  1630. /// <param name="cmd"></param>
  1631. /// <param name="args"></param>
  1632. /// <returns></returns>
  1633. public bool CrossDoseOff(string cmd, object[] args)
  1634. {
  1635. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CROSS_DOSE_ENABLE}");
  1636. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1637. }
  1638. /// <summary>
  1639. /// 手动Dosing
  1640. /// </summary>
  1641. /// <param name="cmd"></param>
  1642. /// <param name="args"></param>
  1643. /// <returns></returns>
  1644. private bool StartDosing(string cmd, object[] args)
  1645. {
  1646. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  1647. if (!_isCrossDoseInitialized)
  1648. {
  1649. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, "Please initialize Cross Dose");
  1650. return false;
  1651. }
  1652. double crossDoseVolume = (double)args[0];
  1653. _crossDoseHelper.SetManualDoseOperation();
  1654. return _crossDoseHelper.StartDosing(crossDoseVolume);
  1655. }
  1656. /// <summary>
  1657. /// 停止Dosing
  1658. /// </summary>
  1659. /// <param name="cmd"></param>
  1660. /// <param name="args"></param>
  1661. /// <returns></returns>
  1662. private bool HaltDosing(string cmd, object[] args)
  1663. {
  1664. _crossDoseHelper.ResetDoseOperation();
  1665. _crossDoseHelper.HaltDosing();
  1666. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CROSS_DOSE_ENABLE}");
  1667. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1668. }
  1669. /// <summary>
  1670. /// Set Pump Factor
  1671. /// </summary>
  1672. /// <param name="cmd"></param>
  1673. /// <param name="args"></param>
  1674. /// <returns></returns>
  1675. private bool SetPumpFactor(string cmd, object[] args)
  1676. {
  1677. double targetPumpFactor = (double)args[0];
  1678. _crossDoseHelper.SetPumpfactor(targetPumpFactor);
  1679. return true;
  1680. }
  1681. /// <summary>
  1682. /// CrossDose初始化
  1683. /// </summary>
  1684. /// <param name="isInitialized"></param>
  1685. public void InitializeCrossDose(bool isInitialized)
  1686. {
  1687. _isCrossDoseInitialized = isInitialized;
  1688. }
  1689. /// <summary>
  1690. /// Reset CrossDose
  1691. /// </summary>
  1692. /// <param name="cmd"></param>
  1693. /// <param name="args"></param>
  1694. /// <returns></returns>
  1695. public bool ResetCrossDose(string cmd, object[] args)
  1696. {
  1697. return _crossDoseHelper.ResetCrossDose();
  1698. }
  1699. /// <summary>
  1700. /// Reset Monitor
  1701. /// </summary>
  1702. /// <param name="cmd"></param>
  1703. /// <param name="args"></param>
  1704. /// <returns></returns>
  1705. public bool ResetCrossDoseMonitor()
  1706. {
  1707. return _crossDoseHelper.ResetCrossDoseMonitor();
  1708. }
  1709. #endregion
  1710. #region Sample
  1711. /// <summary>
  1712. /// ANSample开阀
  1713. /// </summary>
  1714. /// <param name="cmd"></param>
  1715. /// <param name="args"></param>
  1716. /// <returns></returns>
  1717. public bool ANSampleOn(string cmd, object[] args)
  1718. {
  1719. SystemFacilities systemFacility = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  1720. if (systemFacility != null && !systemFacility.SampleFluidDetect)
  1721. {
  1722. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, "SampleFluidDetect is Activate. Can't open ANSample");
  1723. return false;
  1724. }
  1725. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_SAMPLE_FLOW}");
  1726. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1727. }
  1728. /// <summary>
  1729. /// ANSample关阀
  1730. /// </summary>
  1731. /// <param name="cmd"></param>
  1732. /// <param name="args"></param>
  1733. /// <returns></returns>
  1734. public bool ANSampleOff(string cmd, object[] args)
  1735. {
  1736. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{AN_SAMPLE_FLOW}");
  1737. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1738. }
  1739. /// <summary>
  1740. /// CASample开阀
  1741. /// </summary>
  1742. /// <param name="cmd"></param>
  1743. /// <param name="args"></param>
  1744. /// <returns></returns>
  1745. public bool CASampleOn(string cmd, object[] args)
  1746. {
  1747. SystemFacilities systemFacility = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  1748. if (systemFacility != null && !systemFacility.SampleFluidDetect)
  1749. {
  1750. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, "SampleFluidDetect is Activate. Can't open CASample");
  1751. return false;
  1752. }
  1753. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_SAMPLE_FLOW}");
  1754. return BeckhoffIOManager.Instance.WriteIoValue(ioName, true);
  1755. }
  1756. /// <summary>
  1757. /// CASample关阀
  1758. /// </summary>
  1759. /// <param name="cmd"></param>
  1760. /// <param name="args"></param>
  1761. /// <returns></returns>
  1762. public bool CASampleOff(string cmd, object[] args)
  1763. {
  1764. string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName($"{Module}.{CA_SAMPLE_FLOW}");
  1765. return BeckhoffIOManager.Instance.WriteIoValue(ioName, false);
  1766. }
  1767. #endregion
  1768. /// <summary>
  1769. /// 订阅变量数值发生变化
  1770. /// </summary>
  1771. private void SubscribeValueAction()
  1772. {
  1773. BeckhoffIoSubscribeUpdateVariable(CA_DI_REPLEN);
  1774. BeckhoffIoSubscribeUpdateVariable(AN_DI_REPLEN);
  1775. BeckhoffIoSubscribeUpdateVariable(CA_WATER_LEVEL);
  1776. BeckhoffIoSubscribeUpdateVariable(AN_WATER_LEVEL);
  1777. BeckhoffIoSubscribeUpdateVariable(AN_PUMP);
  1778. BeckhoffIoSubscribeUpdateVariable(CROSS_DOSE_ENABLE);
  1779. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_STM_STATUS);
  1780. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_POS_STATUS);
  1781. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_TARGET_POSITION);
  1782. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_ENABLE);
  1783. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_EXECUTE);
  1784. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_RESET);
  1785. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_SPEED);
  1786. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_START_TYPE);
  1787. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_ACCELERATION);
  1788. BeckhoffIoSubscribeUpdateVariable(TRANSFER_PUMP_DECELERATION);
  1789. BeckhoffIoSubscribeUpdateVariable(TRANSFER_ACTUAL_POSITION);
  1790. BeckhoffIoSubscribeUpdateVariable(AN_BYPASS_FLOW);
  1791. BeckhoffIoSubscribeUpdateVariable(AN_A_DRAIN_PUMP);
  1792. BeckhoffIoSubscribeUpdateVariable(AN_B_DRAIN_PUMP);
  1793. BeckhoffIoSubscribeUpdateVariable(AN_SAMPLE_FLOW);
  1794. BeckhoffIoSubscribeUpdateVariable(CA_SAMPLE_FLOW);
  1795. BeckhoffIoSubscribeUpdateVariable(CA_PUMP_SPEED);
  1796. BeckhoffIoSubscribeUpdateVariable(CA_PUMP_RUNNING);
  1797. BeckhoffIoSubscribeUpdateVariable(CA_HED_FLOW);
  1798. BeckhoffIoSubscribeUpdateVariable(CDA_FLOW_VALVE);
  1799. BeckhoffIoSubscribeUpdateVariable(AN_BY_PASS);
  1800. BeckhoffIoSubscribeUpdateVariable(CA_BY_PASS);
  1801. BeckhoffIoSubscribeUpdateVariable(CA_PUMP_ENABLE);
  1802. BeckhoffIoSubscribeUpdateVariable(EVAPORATORLEVEL);
  1803. BeckhoffCounterSubscribeUpdateVariable(AN_TRANSFER_FLOW, ANTransferFlow);
  1804. BeckhoffCounter anTransferFlowCounter = BeckhoffCounterManager.Instance.GetBeckhoffCounter($"{Module}.{AN_TRANSFER_FLOW}");
  1805. if (anTransferFlowCounter != null)
  1806. {
  1807. ANTransferFlow.Period = anTransferFlowCounter.Period;
  1808. }
  1809. BeckhoffCounterSubscribeUpdateVariable(AN_BYPASS_COUNTERFLOW, ReservoirCounterByPassFlow);
  1810. BeckhoffCounter reservoirCounterByPassFlow = BeckhoffCounterManager.Instance.GetBeckhoffCounter($"{Module}.{AN_BYPASS_COUNTERFLOW}");
  1811. if (reservoirCounterByPassFlow != null)
  1812. {
  1813. ReservoirCounterByPassFlow.Period = reservoirCounterByPassFlow.Period;
  1814. }
  1815. }
  1816. /// <summary>
  1817. /// 订阅IO变量
  1818. /// </summary>
  1819. /// <param name="variable"></param>
  1820. private void BeckhoffIoSubscribeUpdateVariable(string variable)
  1821. {
  1822. _variableInitializeDic[variable] = false;
  1823. IOModuleManager.Instance.SubscribeModuleVariable(Module, variable, UpdateVariableValue);
  1824. }
  1825. /// <summary>
  1826. /// 订阅Counter变量
  1827. /// </summary>
  1828. /// <param name="variable"></param>
  1829. private void BeckhoffCounterSubscribeUpdateVariable(string variable, CounterFlowData counterFlowData)
  1830. {
  1831. _nameCounterFlowData[$"{Module}.{variable}"] = counterFlowData;
  1832. BeckhoffCounterManager.Instance.SubscribeModuleVariable($"{Module}.{variable}", COUNTER_VALUE, UpdateCounterVariableValue);
  1833. BeckhoffCounterManager.Instance.SubscribeModuleVariable($"{Module}.{variable}", COUNTER_START, UpdateCounterVariableValue);
  1834. BeckhoffCounterManager.Instance.SubscribeModuleVariable($"{Module}.{variable}", COUNTER_STOP, UpdateCounterVariableValue);
  1835. BeckhoffCounterManager.Instance.SubscribeModuleVariable($"{Module}.{variable}", COUNTER_RESET, UpdateCounterVariableValue);
  1836. }
  1837. /// <summary>
  1838. /// 更新变量数值
  1839. /// </summary>
  1840. /// <param name="variable"></param>
  1841. /// <param name="value"></param>
  1842. private void UpdateCounterVariableValue(string variable, object value)
  1843. {
  1844. string[] strAry = variable.Split('.');
  1845. string lastVariable = strAry[strAry.Length - 1];
  1846. PropertyInfo property = null;
  1847. string key = variable.Replace($".{lastVariable}", "");
  1848. if (_nameCounterFlowData.ContainsKey(key))
  1849. {
  1850. CounterFlowData counterFlowData = _nameCounterFlowData[key];
  1851. if (counterFlowData != null)
  1852. {
  1853. property = counterFlowData.GetType().GetProperty(lastVariable);
  1854. if (property != null)
  1855. {
  1856. property.SetValue(counterFlowData, value);
  1857. }
  1858. }
  1859. }
  1860. }
  1861. /// <summary>
  1862. /// 更新变量数值
  1863. /// </summary>
  1864. /// <param name="variable"></param>
  1865. /// <param name="value"></param>
  1866. private void UpdateVariableValue(string variable, object value)
  1867. {
  1868. if (!ReservoirData.IsDataInitialized)
  1869. {
  1870. ReservoirData.IsDataInitialized = true;
  1871. }
  1872. PropertyInfo property = ReservoirData.GetType().GetProperty(variable);
  1873. if (property != null)
  1874. {
  1875. property.SetValue(ReservoirData, value);
  1876. if (variable == AN_WATER_LEVEL)
  1877. {
  1878. string anLevelCurve = SC.GetStringValue($"Reservoir.{Module}.ANLevelCurve");
  1879. ReservoirData.ANLevel = LevelCurveManager.Instance.CalculateLevelByWaterLevel(ReservoirData.ANWaterLevel, anLevelCurve);
  1880. }
  1881. else if (variable == CA_WATER_LEVEL)
  1882. {
  1883. string caLevelCurve = SC.GetStringValue($"Reservoir.{Module}.CALevelCurve");
  1884. ReservoirData.CALevel = LevelCurveManager.Instance.CalculateLevelByWaterLevel(ReservoirData.CAWaterLevel, caLevelCurve);
  1885. }
  1886. }
  1887. if (_variableInitializeDic.ContainsKey(variable) && !_variableInitializeDic[variable])
  1888. {
  1889. _variableInitializeDic[variable] = true;
  1890. }
  1891. }
  1892. /// <summary>
  1893. /// 是否所有IO变量初始化完成
  1894. /// </summary>
  1895. /// <returns></returns>
  1896. private bool AllIoVariableInitialized()
  1897. {
  1898. foreach (string item in _variableInitializeDic.Keys)
  1899. {
  1900. if (!_variableInitializeDic[item])
  1901. {
  1902. LOG.WriteLog(eEvent.ERR_RINSE, Module, $"{item} is not initialized");
  1903. return false;
  1904. }
  1905. }
  1906. return true;
  1907. }
  1908. /// <summary>
  1909. /// 检验阳极是否需要补水
  1910. /// </summary>
  1911. /// <returns></returns>
  1912. private bool CheckANNeedDiReplen()
  1913. {
  1914. if (IsAuto && _resRecipe != null)
  1915. {
  1916. if (_resRecipe.ANDIReplenEnable && _resRecipe.ANDIReplenCurrentRate == 0 && _resRecipe.ANDIReplenTimeRate == 0)
  1917. {
  1918. double levelHysteresis = SC.GetValue<double>("Reservoir.LevelHysteresis");
  1919. return _reservoirData.ANLevel < _resRecipe.ReservoirANLevel - levelHysteresis;
  1920. }
  1921. return false;
  1922. }
  1923. else
  1924. {
  1925. return false;
  1926. }
  1927. }
  1928. /// <summary>
  1929. /// 检验CA是否需要注水
  1930. /// </summary>
  1931. /// <returns></returns>
  1932. public bool CheckCANeedDiReplen()
  1933. {
  1934. if (IsAuto && _resRecipe != null)
  1935. {
  1936. if (_resRecipe.DIReplenEnable && _resRecipe.DIReplenTimeRate == 0 && _resRecipe.DIReplenCurrentRate == 0)
  1937. {
  1938. double levelHysteresis = SC.GetValue<double>("Reservoir.LevelHysteresis");
  1939. return _reservoirData.CALevel < _resRecipe.ReservoirCALevel - levelHysteresis;
  1940. }
  1941. return false;
  1942. }
  1943. else
  1944. {
  1945. return false;
  1946. }
  1947. }
  1948. /// <summary>
  1949. /// 检验阴极是否highlevel
  1950. /// </summary>
  1951. public bool CheckCAHighLevelStatus()
  1952. {
  1953. return ReservoirData.CAWaterLevel > SC.GetValue<double>($"Reservoir.{Module}.CAHighLevel") ? true : false;
  1954. }
  1955. /// <summary>
  1956. /// 检验阴极是否lowlevel
  1957. /// </summary>
  1958. public bool CheckCALowLevelStatus()
  1959. {
  1960. return ReservoirData.CAWaterLevel < SC.GetValue<double>($"Reservoir.{Module}.CALowLevel") ? true : false;
  1961. }
  1962. /// <summary>
  1963. /// 检验阳极是否highlevel
  1964. /// </summary>
  1965. public bool CheckANHighLevelStatus()
  1966. {
  1967. return ReservoirData.ANWaterLevel > SC.GetValue<double>($"Reservoir.{Module}.ANHighLevel") ? true : false;
  1968. }
  1969. /// <summary>
  1970. /// 检验阳极是否lowlevel
  1971. /// </summary>
  1972. public bool CheckANLowLevelStatus()
  1973. {
  1974. return ReservoirData.ANWaterLevel < SC.GetValue<double>($"Reservoir.{Module}.ANLowLevel") ? true : false;
  1975. }
  1976. /// <summary>
  1977. /// CAFlowRate Check
  1978. /// </summary>
  1979. private void CAFlowRateCheck()
  1980. {
  1981. if (_resRecipe == null) return;
  1982. for (int i = 0; i < _metalDevices.Count; i++)
  1983. {
  1984. CompactMembranMetalDevice hotMetalDevice = _metalDevices[i];
  1985. if (hotMetalDevice != null && !hotMetalDevice.IsDisable && hotMetalDevice.IsAuto)
  1986. {
  1987. if (hotMetalDevice.MetalDeviceData == null) continue;
  1988. if (!hotMetalDevice.FlowValveStable) continue;
  1989. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(hotMetalDevice.Name);
  1990. double cellFlow = hotMetalDevice.MetalDeviceData.CellFlow;
  1991. //double cellFlowStartLowLimit = SC.GetValue<double>("Metal.CellFlowStartLowLimit");
  1992. if (cellFlow <= 0)
  1993. {
  1994. if (!_errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_START_LOW_LIMIT_ERROR}"])
  1995. {
  1996. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_START_LOW_LIMIT_ERROR}"] = true;
  1997. string reason = $"{hotMetalDevice.Name} cellflow:{cellFlow} is less or equal 0";
  1998. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, reason);
  1999. metalEntity.PostMsg(MetalMsg.Error);
  2000. metalEntity.WriteErrorReason(reason);
  2001. }
  2002. continue;
  2003. }
  2004. else
  2005. {
  2006. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_START_LOW_LIMIT_ERROR}"] = false;
  2007. }
  2008. if (cellFlow < _resRecipe.CAFlowRateErrorLow)
  2009. {
  2010. if (!_errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_ERROR}"])
  2011. {
  2012. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_ERROR}"] = true;
  2013. string reason = $"{hotMetalDevice.Name} cellflow:{cellFlow} is less than recipe CAFlowRateErrorLow parameter:{_resRecipe.CAFlowRateErrorLow}";
  2014. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, reason);
  2015. metalEntity.SetFlowErrorFlag(reason);
  2016. }
  2017. continue;
  2018. }
  2019. else
  2020. {
  2021. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_ERROR}"] = false;
  2022. }
  2023. if (cellFlow < _resRecipe.CAFlowRateWarningLow)
  2024. {
  2025. if (!_errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_WARN}"])
  2026. {
  2027. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{hotMetalDevice.Name} cellflow:{cellFlow} is less than recipe CAFlowRateWarningLow parameter:{_resRecipe.CAFlowRateWarningLow}");
  2028. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_WARN}"] = true;
  2029. }
  2030. }
  2031. else
  2032. {
  2033. _errorDic[$"{hotMetalDevice.Module}_{CA_FLOW_RECIPE_WARN}"] = false;
  2034. }
  2035. }
  2036. }
  2037. }
  2038. /// <summary>
  2039. /// ANFlowRate Check
  2040. /// </summary>
  2041. private void ANFlowRateCheck()
  2042. {
  2043. if (_resRecipe == null) return;
  2044. for (int i = 0; i < _metalDevices.Count; i++)
  2045. {
  2046. CompactMembranMetalDevice hotMetalDevice = _metalDevices[i];
  2047. if (hotMetalDevice != null && !hotMetalDevice.IsDisable && hotMetalDevice.IsAuto)
  2048. {
  2049. if (hotMetalDevice.MetalDeviceData == null) continue;
  2050. //ANACellFlow
  2051. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(hotMetalDevice.Name);
  2052. if (hotMetalDevice.MetalDeviceData.ANAPinEnable && hotMetalDevice.ANAFlowValveStable)
  2053. {
  2054. double ANAcellFlow = hotMetalDevice.ANACellFlow.CounterValue;
  2055. AnSideFlowCheck(ANAcellFlow, metalEntity, "A", AN_A_FLOW_ZERO_ERROR, AN_A_FLOW_RECIPE_ERROR,
  2056. AN_A_FLOW_RECIPE_WARN, _resRecipe.ANFlowRateErrorLow, _resRecipe.ANFlowRateWarningLow);
  2057. }
  2058. //ANBCellFlow
  2059. if (hotMetalDevice.MetalDeviceData.ANBPinEnable && hotMetalDevice.ANBFlowValveStable)
  2060. {
  2061. double ANBcellFlow = hotMetalDevice.ANBCellFlow.CounterValue;
  2062. AnSideFlowCheck(ANBcellFlow, metalEntity, "B", AN_B_FLOW_ZERO_ERROR, AN_B_FLOW_RECIPE_ERROR,
  2063. AN_B_FLOW_RECIPE_WARN, _resRecipe.ANFlowRateErrorLow, _resRecipe.ANFlowRateWarningLow);
  2064. }
  2065. }
  2066. }
  2067. }
  2068. /// <summary>
  2069. /// 阳极单面Flow检验
  2070. /// </summary>
  2071. /// <param name="anCellFlow"></param>
  2072. /// <param name="metalEntity"></param>
  2073. /// <param name="side"></param>
  2074. /// <param name="flowZeroError"></param>
  2075. /// <param name="anFlowRecipeError"></param>
  2076. /// <param name="anFlowRecipeWarn"></param>
  2077. /// <param name="anFlowRecipeErrorLow"></param>
  2078. /// <param name="anFlowRecipeWarnLow"></param>
  2079. private void AnSideFlowCheck(double anCellFlow, MetalEntity metalEntity, string side, string flowZeroError,
  2080. string anFlowRecipeError, string anFlowRecipeWarn, double anFlowRecipeErrorLow, double anFlowRecipeWarnLow)
  2081. {
  2082. if (anCellFlow <= 0)
  2083. {
  2084. if (!_errorDic[$"{metalEntity.Module}_{flowZeroError}"])
  2085. {
  2086. _errorDic[$"{metalEntity.Module}_{flowZeroError}"] = true;
  2087. string reason = $"{metalEntity.Module} AN{side}Sideflow:{anCellFlow} is less or equal 0";
  2088. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, reason);
  2089. metalEntity.PostMsg(MetalMsg.Error);
  2090. metalEntity.WriteErrorReason(reason);
  2091. }
  2092. return;
  2093. }
  2094. else
  2095. {
  2096. _errorDic[$"{metalEntity.Module}_{flowZeroError}"] = false;
  2097. }
  2098. if (anCellFlow < anFlowRecipeErrorLow)
  2099. {
  2100. if (!_errorDic[$"{metalEntity.Module}_{anFlowRecipeError}"])
  2101. {
  2102. _errorDic[$"{metalEntity.Module}_{anFlowRecipeError}"] = true;
  2103. string reason = $"{metalEntity.Module} AN{side}Sideflow:{anCellFlow} is less than recipe ANFlowRateErrorLow parameter:{anFlowRecipeErrorLow}";
  2104. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, reason);
  2105. metalEntity.SetFlowErrorFlag(reason);
  2106. }
  2107. return;
  2108. }
  2109. else
  2110. {
  2111. _errorDic[$"{metalEntity.Module}_{anFlowRecipeError}"] = false;
  2112. }
  2113. if (anCellFlow < anFlowRecipeWarnLow)
  2114. {
  2115. if (!_errorDic[$"{metalEntity.Module}_{anFlowRecipeWarn}"])
  2116. {
  2117. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{metalEntity.Module} AN{side}Sideflow:{anCellFlow} is less than recipe ANFlowRateWarningLow parameter:{anFlowRecipeWarnLow}");
  2118. _errorDic[$"{metalEntity.Module}_{anFlowRecipeWarn}"] = true;
  2119. }
  2120. }
  2121. else
  2122. {
  2123. _errorDic[$"{metalEntity.Module}_{anFlowRecipeWarn}"] = false;
  2124. }
  2125. }
  2126. /// <summary>
  2127. /// Temperature Check
  2128. /// </summary>
  2129. private void TemperatureCheck()
  2130. {
  2131. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2132. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  2133. TemperatureController temperatureController = DEVICE.GetDevice<TemperatureController>(reservoirItem.TCID);
  2134. if (temperatureController == null || temperatureController.TemperatureData == null || _resRecipe == null
  2135. || temperatureController.TemperatureData.ControlOperationModel != ENABLE) return;
  2136. double tempValue = temperatureController.TemperatureData.ReserviorTemperature;
  2137. if (tempValue > _resRecipe.TemperatureErrorHigh && !reservoirEntity.IsError)
  2138. {
  2139. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{temperatureController.Name} temperature:{tempValue} is over recipe's TemperatureErrorHigh parameter:{_resRecipe.TemperatureErrorHigh}");
  2140. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2141. }
  2142. else if (tempValue < _resRecipe.TemperatureErrorLow && !reservoirEntity.IsError)
  2143. {
  2144. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{temperatureController.Name} temperature:{tempValue} is less than recipe's TemperatureErrorLow parameter:{_resRecipe.TemperatureErrorLow}");
  2145. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2146. }
  2147. else if (tempValue > _resRecipe.TemperatureWarningHigh)
  2148. {
  2149. if (!_isTCControlWARN)
  2150. {
  2151. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{temperatureController.Name} temperature:{tempValue} is over recipe's TemperatureWarningHigh parameter:{_resRecipe.TemperatureWarningHigh}");
  2152. _isTCControlWARN = true;
  2153. }
  2154. }
  2155. else if (tempValue < _resRecipe.TemperatureWarningLow)
  2156. {
  2157. if (!_isTCControlWARN)
  2158. {
  2159. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{temperatureController.Name} temperature;{tempValue} is less than recipe's TemperatureWarningLow parameter:{_resRecipe.TemperatureWarningLow}");
  2160. _isTCControlWARN = true;
  2161. }
  2162. }
  2163. else
  2164. {
  2165. _isTCControlWARN = false;
  2166. }
  2167. }
  2168. /// <summary>
  2169. /// AN LowLevel触发对应操作
  2170. /// </summary>
  2171. private void ANLowLevelOperation()
  2172. {
  2173. if (IsANLowLevel)
  2174. {
  2175. if (_reservoirData.ANPump > 0)
  2176. {
  2177. AnPumpOffOperation("ANPumpOff", null);
  2178. }
  2179. foreach (var metalDevice in _metalDevices)
  2180. {
  2181. if (metalDevice.MetalDeviceData.ANAPinEnable)
  2182. {
  2183. metalDevice.AnSideAFillOff($"{metalDevice.Name}.ANAFillOff", null);
  2184. }
  2185. if (metalDevice.MetalDeviceData.ANBPinEnable)
  2186. {
  2187. metalDevice.AnSideBFillOff($"{metalDevice.Name}.ANBFillOff", null);
  2188. }
  2189. }
  2190. }
  2191. }
  2192. /// <summary>
  2193. /// CA Low Level触发对应操作
  2194. /// </summary>
  2195. private void CALowLevelOperation()
  2196. {
  2197. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  2198. if (IsCALowLevel)
  2199. {
  2200. if (_reservoirData.CAPumpEnable)
  2201. {
  2202. CAPumpOff("CAPumpOff", null);
  2203. }
  2204. foreach (var metalDevice in _metalDevices)
  2205. {
  2206. if (metalDevice.MetalDeviceData.CellFlowValve)
  2207. {
  2208. metalDevice.CellFlowValveOff($"{metalDevice.Name}.FlowOff", null);
  2209. }
  2210. }
  2211. //禁用TC
  2212. if (!String.IsNullOrEmpty(reservoirItem.TCID))
  2213. {
  2214. TemperatureController temperatureController = DEVICE.GetDevice<TemperatureController>(reservoirItem.TCID);
  2215. if (temperatureController != null && temperatureController.TemperatureData.ControlOperationModel == 5)
  2216. {
  2217. temperatureController.DisableOperation("", null);
  2218. }
  2219. }
  2220. }
  2221. }
  2222. /// <summary>
  2223. /// High Level Common Operation
  2224. /// </summary>
  2225. private void HighLevelOperation()
  2226. {
  2227. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2228. SystemFacilities systemFacilities = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  2229. if (systemFacilities != null)
  2230. {
  2231. if (systemFacilities.DIFillEnable) systemFacilities.DiFillDisableOperation("DIFillDisableOpeartion", null);
  2232. if (systemFacilities.DIReplenEnable) systemFacilities.DiReplenDisableOperation("DiReplenDisableOperation", null);
  2233. if (_reservoirData.ANDiReplen)
  2234. {
  2235. _currentOperation = ReservoirOperation.None;
  2236. ANDiReplenOff("", null);
  2237. }
  2238. if (_reservoirData.CADiReplen)
  2239. {
  2240. _currentOperation = ReservoirOperation.None;
  2241. CADiReplenOff("", null);
  2242. }
  2243. }
  2244. if (!reservoirEntity.IsError) reservoirEntity.PostMsg(ReservoirMsg.Error);
  2245. }
  2246. /// <summary>
  2247. /// Low Level common Operation
  2248. /// </summary>
  2249. private void LowLevelOperation()
  2250. {
  2251. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2252. foreach (var metalDevice in _metalDevices)
  2253. {
  2254. MetalEntity metalEntity = Singleton<RouteManager>.Instance.GetModule<MetalEntity>(metalDevice.DeviceID);
  2255. if (metalEntity != null && !metalEntity.IsError)
  2256. {
  2257. metalEntity.PostMsg(MetalMsg.Error);
  2258. }
  2259. }
  2260. if (!reservoirEntity.IsError) reservoirEntity.PostMsg(ReservoirMsg.Error);
  2261. }
  2262. /// <summary>
  2263. /// WaterLevelMonitor
  2264. /// </summary>
  2265. private void WaterLevelMonitor()
  2266. {
  2267. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  2268. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2269. _isSystemAutoMode = reservoirEntity.IsAuto; ;
  2270. //触发low将对应的reservoir和对应metal切成error
  2271. if (IsANLowLevel)
  2272. {
  2273. if (!errorLogSet.Contains($"{Module}.IsANLowLevel"))
  2274. {
  2275. errorLogSet.Add($"{Module}.IsANLowLevel");
  2276. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current ANWaterlevel:{ReservoirData.ANWaterLevel} is lower than ANLowLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.ANLowLevel")}");
  2277. }
  2278. ANLowLevelOperation();
  2279. LowLevelOperation();
  2280. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "ANWaterLevel"))//模块处于Auto模式使将报错信息加入到Alarm
  2281. {
  2282. AlarmListManager.Instance.AddDataError(Module,
  2283. $"ANWaterLevel", $"Current ANWaterlevel:{ReservoirData.ANWaterLevel} is lower than ANLowLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.ANLowLevel")}");
  2284. }
  2285. }
  2286. else if (IsANHighLevel)
  2287. {
  2288. if (!errorLogSet.Contains($"{Module}.IsANHighLevel"))
  2289. {
  2290. errorLogSet.Add($"{Module}.IsANHighLevel");
  2291. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current ANWaterlevel:{ReservoirData.ANWaterLevel} is larger than ANHighLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.ANHighLevel")}");
  2292. }
  2293. HighLevelOperation();
  2294. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "ANWaterLevel"))
  2295. {
  2296. AlarmListManager.Instance.AddDataError(Module,
  2297. $"ANWaterLevel", $"Current ANWaterlevel:{ReservoirData.ANWaterLevel} is larger than ANHighLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.ANHighLevel")}");
  2298. }
  2299. }
  2300. if (IsCALowLevel)
  2301. {
  2302. if (!errorLogSet.Contains($"{Module}.IsCALowLevel"))
  2303. {
  2304. errorLogSet.Add($"{Module}.IsCALowLevel");
  2305. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current CAWaterlevel:{ReservoirData.CAWaterLevel} is lower than CALowLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.CALowLevel")}");
  2306. }
  2307. CALowLevelOperation();
  2308. LowLevelOperation();
  2309. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "CAWaterLevel"))
  2310. {
  2311. AlarmListManager.Instance.AddDataError(Module,
  2312. $"CAWaterLevel", $"Current CAWaterlevel:{ReservoirData.CAWaterLevel} is lower than CALowLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.CALowLevel")}");
  2313. }
  2314. }
  2315. else if (IsCAHighLevel)
  2316. {
  2317. if (!errorLogSet.Contains($"{Module}.IsCAHighLevel"))
  2318. {
  2319. errorLogSet.Add($"{Module}.IsCAHighLevel");
  2320. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current CAWaterlevel:{ReservoirData.CAWaterLevel} is large than CAHighLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.CAHighLevel")}");
  2321. }
  2322. HighLevelOperation();
  2323. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "CAWaterLevel"))
  2324. {
  2325. AlarmListManager.Instance.AddDataError(Module,
  2326. $"CAWaterLevel", $"Current CAWaterlevel:{ReservoirData.CAWaterLevel} is large than CAHighLevel Config:{SC.GetValue<double>($"Reservoir.{Module}.CAHighLevel")}");
  2327. }
  2328. }
  2329. //水位触发recipe里面的high/low参数将对应的reservoir切成error
  2330. if (_resRecipe == null) return;
  2331. //ANLevel监控
  2332. if (ReservoirData.ANLevel < _resRecipe.ANLevelErrorLow)
  2333. {
  2334. if (!errorLogSet.Contains($"{Module}.ANLevel"))
  2335. {
  2336. errorLogSet.Add($"{Module}.ANLevel");
  2337. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current ANlevel:{ReservoirData.ANLevel} is lower than ResRecipe.ANLevelErrorLow:{_resRecipe.ANLevelErrorLow}");
  2338. }
  2339. if (!reservoirEntity.IsError)
  2340. {
  2341. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2342. }
  2343. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "ANLevel"))
  2344. {
  2345. AlarmListManager.Instance.AddDataError(Module,
  2346. $"ANLevel", $"Current ANlevel:{ReservoirData.ANLevel} is lower than ResRecipe.ANLevelErrorLow:{_resRecipe.ANLevelErrorLow}");
  2347. }
  2348. }
  2349. else if (ReservoirData.ANLevel > _resRecipe.ANLevelErrorHigh)
  2350. {
  2351. if (!errorLogSet.Contains($"{Module}.ANLevel"))
  2352. {
  2353. errorLogSet.Add($"{Module}.ANLevel");
  2354. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current ANlevel:{ReservoirData.ANLevel} is larger than ResRecipe.ANLevelErrorHigh:{_resRecipe.ANLevelErrorHigh}");
  2355. }
  2356. if (!reservoirEntity.IsError)
  2357. {
  2358. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2359. }
  2360. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "ANLevel"))
  2361. {
  2362. AlarmListManager.Instance.AddDataError(Module,
  2363. $"ANLevel", $"Current ANlevel:{ReservoirData.ANLevel} is larger than ResRecipe.ANLevelErrorHigh:{_resRecipe.ANLevelErrorHigh}");
  2364. }
  2365. }
  2366. //CALevel监控
  2367. if (ReservoirData.CALevel < _resRecipe.CALevelErrorLow)
  2368. {
  2369. if (!errorLogSet.Contains($"{Module}.CALevel"))
  2370. {
  2371. errorLogSet.Add($"{Module}.CALevel");
  2372. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current CAlevel:{ReservoirData.CALevel} is lower than ResRecipe.CALevelErrorLow:{_resRecipe.CALevelErrorLow}");
  2373. }
  2374. if (!reservoirEntity.IsError)
  2375. {
  2376. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2377. }
  2378. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "CALevel"))
  2379. {
  2380. AlarmListManager.Instance.AddDataError(Module,
  2381. $"CALevel", $"Current CAlevel:{ReservoirData.CALevel} is lower than ResRecipe.CALevelErrorLow:{_resRecipe.CALevelErrorLow}");
  2382. }
  2383. }
  2384. else if (ReservoirData.CALevel > _resRecipe.CALevelErrorHigh)
  2385. {
  2386. if (!errorLogSet.Contains($"{Module}.CALevel"))
  2387. {
  2388. errorLogSet.Add($"{Module}.CALevel");
  2389. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Current CAlevel:{ReservoirData.CALevel} is larger than ResRecipe.CALevelErrorHigh:{_resRecipe.CALevelErrorHigh}");
  2390. }
  2391. if (!reservoirEntity.IsError)
  2392. {
  2393. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2394. }
  2395. if (_isSystemAutoMode && !AlarmListManager.Instance.IsContainDataError(Module, "CALevel"))
  2396. {
  2397. AlarmListManager.Instance.AddDataError(Module,
  2398. $"CALevel", $"Current CAlevel:{ReservoirData.CALevel} is larger than ResRecipe.CALevelErrorHigh:{_resRecipe.CALevelErrorHigh}");
  2399. }
  2400. }
  2401. }
  2402. /// <summary>
  2403. /// 定时器
  2404. /// </summary>
  2405. /// <returns></returns>
  2406. private bool OnTimer()
  2407. {
  2408. //计算AN/CA level的平均值
  2409. if (ReservoirData != null)
  2410. {
  2411. //AN
  2412. if (_ANLevelSamples.Count >= levelSampleCount)
  2413. {
  2414. _ANLevelSamples.Dequeue();
  2415. _ANLevelSamples.Enqueue(ReservoirData.ANLevel);
  2416. }
  2417. else
  2418. {
  2419. _ANLevelSamples.Enqueue(ReservoirData.ANLevel);
  2420. }
  2421. //CA
  2422. if (_CALevelSamples.Count >= levelSampleCount)
  2423. {
  2424. _CALevelSamples.Dequeue();
  2425. _CALevelSamples.Enqueue(ReservoirData.CALevel);
  2426. }
  2427. else
  2428. {
  2429. _CALevelSamples.Enqueue(ReservoirData.CALevel);
  2430. }
  2431. _avgANLevel = _ANLevelSamples.Count > 0 ? _ANLevelSamples.Average() : 0;
  2432. _avgCALevel = _CALevelSamples.Count > 0 ? _CALevelSamples.Average() : 0;
  2433. }
  2434. _metalTotalFlow = 0;
  2435. ReservoirItem reservoirItem = ReservoirItemManager.Instance.GetReservoirItem(Module);
  2436. if (reservoirItem != null)
  2437. {
  2438. List<MetalItem> metalItems = reservoirItem.MetalCells;
  2439. if (metalItems != null && metalItems.Count > 0)
  2440. {
  2441. foreach (MetalItem metalItem in metalItems)
  2442. {
  2443. if (metalItem.Installed)
  2444. {
  2445. CompactMembranMetalDevice metalDevice = DEVICE.GetDevice<CompactMembranMetalDevice>(metalItem.ModuleName);
  2446. if (metalDevice != null)
  2447. {
  2448. _metalTotalFlow += metalDevice.ANACellFlow.CounterValue;
  2449. _metalTotalFlow += metalDevice.ANBCellFlow.CounterValue;
  2450. }
  2451. }
  2452. }
  2453. }
  2454. }
  2455. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2456. //pump安全性检验
  2457. if (_reservoirData.ANPump > 0 && (_reservoirData.ANBypassFlow + ReservoirCounterByPassFlow.CounterValue + _metalTotalFlow) < SC.GetValue<double>($"Reservoir.{Module}.ByPassMetalTotalFlowMinLimit"))
  2458. {
  2459. if (!_isAnPumpSafeDetectedActivate)
  2460. {
  2461. _isAnPumpSafeDetectedActivate = true;
  2462. _AnPumpSafeDetectTime = DateTime.Now;
  2463. }
  2464. if ((DateTime.Now - _AnPumpSafeDetectTime).TotalSeconds > _flowFaultHoldOffTime && _isAnPumpSafeDetectedActivate)
  2465. {
  2466. if (reservoirEntity.IsAuto && !reservoirEntity.IsError)
  2467. {
  2468. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2469. }
  2470. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Total flow is less than configuration item ByPassMetalTotalFlowMinLimit :{SC.GetValue<double>($"Reservoir.{Module}.ByPassMetalTotalFlowMinLimit")}, AN Pump off");
  2471. _isAnPumpSafeDetectedActivate = false;
  2472. AnPump(0);
  2473. }
  2474. }
  2475. else
  2476. {
  2477. _isAnPumpSafeDetectedActivate = false;
  2478. }
  2479. foreach (CompactMembranMetalDevice device in _metalDevices)
  2480. {
  2481. device.OnTimer(_periodicJob.Interval);
  2482. }
  2483. if (reservoirEntity != null && reservoirEntity.IsError && _isCrossDoseInstalled && _reservoirData.TransferPumpEnable && _reservoirData.TransferPumpExecute)
  2484. {
  2485. _crossDoseHelper.HaltDosing();
  2486. }
  2487. // 判断排气是否触发漏液警报
  2488. if (_reservoirData != null && _reservoirData.EvaporatorLevel && "STD".Equals(reservoirItem.EvaporatorType)) //_reservoirData.EvaporatorLevel true表示触发漏液
  2489. {
  2490. if (_reservoirData.CDAFlowValve)
  2491. {
  2492. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"EvaporatorLevel is Activate");
  2493. CDAFlowOff("CDAFlowOff", null);
  2494. }
  2495. if (_reservoirData.CAPumpEnable)
  2496. {
  2497. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"EvaporatorLevel is Activate");
  2498. CAPumpOff("CAPumpOff", null);
  2499. }
  2500. }
  2501. //WaterLevel Monitor
  2502. WaterLevelMonitor();
  2503. //触发Safetyhigh将reservoir切成error
  2504. SafetyDevice safetyDevice = DEVICE.GetDevice<SafetyDevice>("Safety");
  2505. if (safetyDevice != null && safetyDevice.SafetyData.ReservoirHighLevel && !reservoirEntity.IsError)
  2506. {
  2507. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"Safety high is Activate");
  2508. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2509. }
  2510. //Sample检测
  2511. SystemFacilities systemFacility = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
  2512. if (systemFacility != null && !systemFacility.SampleFluidDetect)
  2513. {
  2514. if (ReservoirData.ANSampleFlow) ANSampleOff("", null);
  2515. if (ReservoirData.CASampleFlow) CASampleOff("", null);
  2516. }
  2517. //DIReplen总阀未开关闭槽体DIReplen;未初始化关闭槽体DIReplen
  2518. if (!systemFacility.DIReplenEnable || reservoirEntity == null || !reservoirEntity.IsInitialized)
  2519. {
  2520. if (_reservoirData.ANDiReplen) ANDiReplenOff("", null);
  2521. if (_reservoirData.CADiReplen) CADiReplenOff("", null);
  2522. }
  2523. if (reservoirEntity == null || !reservoirEntity.IsInitialized)
  2524. {
  2525. return true;
  2526. }
  2527. //补水监控
  2528. if (_direplenHelper != null)
  2529. {
  2530. _direplenHelper.MonitorPeriodTime(ref _isDIReplenMaxTimeOut);
  2531. if (!_isDIReplenMaxTimeOut && !_isDIReplenPerfillTimeOut && TotalDIReplenOn)
  2532. {
  2533. if (_currentOperation == ReservoirOperation.ManualANDiReplen)
  2534. {
  2535. bool result = _direplenHelper.MonitorManualDiReplenComplete(_manualReplenSecond, ANDiReplenOff, ref _isDIReplenMaxTimeOut);
  2536. if (result)
  2537. {
  2538. _currentOperation = ReservoirOperation.None;
  2539. }
  2540. }
  2541. if (_currentOperation == ReservoirOperation.ManualCADiReplen)
  2542. {
  2543. bool result = _direplenHelper.MonitorManualDiReplenComplete(_manualReplenSecond, CADiReplenOff, ref _isDIReplenMaxTimeOut);
  2544. if (result)
  2545. {
  2546. _currentOperation = ReservoirOperation.None;
  2547. }
  2548. }
  2549. if (_currentOperation == ReservoirOperation.AutoANDiReplen)
  2550. {
  2551. AutoDiReplenMonitor(ANDiReplenOff, _reservoirData.ANLevel, _resRecipe.ReservoirANLevel, _resRecipe.ANDIReplenEnable,
  2552. _resRecipe.ANDIReplenTimeRate, _resRecipe.ANDIReplenCurrentRate);
  2553. }
  2554. if (_currentOperation == ReservoirOperation.AutoCADiReplen)
  2555. {
  2556. AutoDiReplenMonitor(CADiReplenOff, _reservoirData.CALevel, _resRecipe.ReservoirCALevel, _resRecipe.DIReplenEnable,
  2557. _resRecipe.DIReplenTimeRate, _resRecipe.DIReplenCurrentRate);
  2558. }
  2559. }
  2560. }
  2561. if (_isCrossDoseInstalled)
  2562. {
  2563. if (_crossDoseHelper.CrossDoseState == RState.Running)
  2564. {
  2565. _crossDoseHelper.CrossDoseStatusMonitor();
  2566. }
  2567. if (_crossDoseHelper.ResetState == RState.Running)
  2568. {
  2569. _crossDoseHelper.ResetCrossDoseMonitor();
  2570. }
  2571. if (_persistentValue.OperatingMode == "Auto")
  2572. {
  2573. _crossDoseHelper.AutoCrossDoseMonitor(_isCrossDoseInitialized);
  2574. }
  2575. else
  2576. {
  2577. _crossDoseHelper.CrossDoseOperationMonitor();
  2578. }
  2579. }
  2580. if (_persistentValue.OperatingMode == AUTO)
  2581. {
  2582. //CAFlowRate判断
  2583. CAFlowRateCheck();
  2584. //ANFlowRate判断
  2585. ANFlowRateCheck();
  2586. //Temperature判断
  2587. TemperatureCheck();
  2588. }
  2589. //判断是否到启动fast leak test的时间
  2590. if (DateTime.Now - _fastLeakStartTime >= _fastLeakTestSpan - TimeSpan.FromMilliseconds(200) && DateTime.Now - _fastLeakStartTime <= _fastLeakTestSpan + TimeSpan.FromMilliseconds(200))
  2591. {
  2592. FastLeakTestAction();
  2593. }
  2594. //判断是否到启动slow leak test的时间
  2595. if (DateTime.Now - _slowLeakStartTime >= _slowLeakTestSpan - TimeSpan.FromMilliseconds(200) && DateTime.Now - _slowLeakStartTime <= _slowLeakTestSpan + TimeSpan.FromMilliseconds(200))
  2596. {
  2597. SlowLeakTestAction();
  2598. }
  2599. return true;
  2600. }
  2601. /// <summary>
  2602. /// 自动注水监控
  2603. /// </summary>
  2604. /// <param name="direplenOff"></param>
  2605. /// <param name="level"></param>
  2606. /// <param name="recipeLevel"></param>
  2607. private void AutoDiReplenMonitor(Func<string, object[], bool> direplenOff, double level, double recipeLevel, bool replenEnable,
  2608. int direplenTimeRate, int direplenCurrentRate)
  2609. {
  2610. var result = _direplenHelper.AutoDiReplenMonitorTimeOut(direplenOff, ref _isDIReplenMaxTimeOut, ref _isDIReplenPerfillTimeOut);
  2611. if (result)
  2612. {
  2613. _currentOperation = ReservoirOperation.None;
  2614. }
  2615. else
  2616. {
  2617. //按液位补水
  2618. var result1 = _direplenHelper.AutoDiReplenMonitorComplete(level, recipeLevel, replenEnable, direplenTimeRate, direplenCurrentRate, direplenOff);
  2619. if (result1)
  2620. {
  2621. _currentOperation = ReservoirOperation.None;
  2622. }
  2623. }
  2624. }
  2625. /// <summary>
  2626. /// ReservoirUsage监控
  2627. /// </summary>
  2628. public void ReservoirUsageMonitor()
  2629. {
  2630. ReservoirUsage reservoirUsage = ReservoirUsageManager.Instance.GetReservoirUsage(Module);
  2631. ReservoirEntity reservoirEntity = Singleton<RouteManager>.Instance.GetModule<ReservoirEntity>(Module);
  2632. if (reservoirUsage == null || reservoirEntity == null) return;
  2633. //reservoirTotalAmpHours Check
  2634. double reservoirTotalAmpHoursWarningLimit = 0;
  2635. if (SC.ContainsItem($"Reservoir.{Module}.ReservoirTotalAmpHoursWarningLimit"))
  2636. {
  2637. reservoirTotalAmpHoursWarningLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.ReservoirTotalAmpHoursWarningLimit");
  2638. }
  2639. double reservoirTotalAmpHoursFaultLimit = 0;
  2640. if (SC.ContainsItem($"Reservoir.{Module}.ReservoirTotalAmpHoursFaultLimit"))
  2641. {
  2642. reservoirTotalAmpHoursFaultLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.ReservoirTotalAmpHoursFaultLimit");
  2643. }
  2644. if (reservoirUsage.TotalUsage > reservoirTotalAmpHoursFaultLimit && reservoirTotalAmpHoursFaultLimit != 0)
  2645. {
  2646. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Total Usage(AHr):{reservoirUsage.TotalUsage} is over config item ReservoirTotalAmpHoursFaultLimit:{reservoirTotalAmpHoursFaultLimit}");
  2647. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2648. AlarmListManager.Instance.AddDataError(Module,
  2649. $"TotalUsage", $"{Module} Total Usage(AHr):{reservoirUsage.TotalUsage} is over ReservoirTotalAmpHoursFaultLimit:{reservoirTotalAmpHoursFaultLimit}");
  2650. }
  2651. else if (reservoirUsage.TotalUsage > reservoirTotalAmpHoursWarningLimit && reservoirTotalAmpHoursWarningLimit != 0)
  2652. {
  2653. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Total Usage(AHr):{reservoirUsage.TotalUsage} is over config item ReservoirTotalAmpHoursWarningLimit:{reservoirTotalAmpHoursWarningLimit}");
  2654. AlarmListManager.Instance.AddWarn(Module,
  2655. $"TotalUsage", $"{Module} Total Usage(AHr):{reservoirUsage.TotalUsage} is over ReservoirTotalAmpHoursWarningLimit:{reservoirTotalAmpHoursWarningLimit}");
  2656. }
  2657. //MembraneTotalAmpHoursCheck
  2658. double membraneTotalAmpHoursWarningLimit = 0;
  2659. if (SC.ContainsItem($"Reservoir.{Module}.MembraneTotalAmpHoursWarningLimit"))
  2660. {
  2661. membraneTotalAmpHoursWarningLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.MembraneTotalAmpHoursWarningLimit");
  2662. }
  2663. double membraneTotalAmpHoursFaultLimit = 0;
  2664. if (SC.ContainsItem($"Reservoir.{Module}.MembraneTotalAmpHoursFaultLimit"))
  2665. {
  2666. membraneTotalAmpHoursFaultLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.MembraneTotalAmpHoursFaultLimit");
  2667. }
  2668. if (reservoirUsage.MembranceUsage > membraneTotalAmpHoursFaultLimit && membraneTotalAmpHoursFaultLimit != 0)
  2669. {
  2670. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Membrane Usage(AHr):{reservoirUsage.MembranceUsage} is over config item MembraneTotalAmpHoursFaultLimit:{membraneTotalAmpHoursFaultLimit}");
  2671. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2672. AlarmListManager.Instance.AddDataError(Module,
  2673. $"MembraneUsage", $"{Module} Membrane Usage(AHr):{reservoirUsage.MembranceUsage} is over MembraneTotalAmpHoursFaultLimit:{membraneTotalAmpHoursFaultLimit}");
  2674. }
  2675. else if (reservoirUsage.MembranceUsage > membraneTotalAmpHoursWarningLimit && membraneTotalAmpHoursWarningLimit != 0)
  2676. {
  2677. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Membrane Usage(AHr):{reservoirUsage.MembranceUsage} is over config item MembraneTotalAmpHoursWarningLimit:{membraneTotalAmpHoursWarningLimit}");
  2678. AlarmListManager.Instance.AddWarn(Module,
  2679. $"MembraneUsage", $"{Module} Membrane Usage(AHr):{reservoirUsage.MembranceUsage} is over MembraneTotalAmpHoursWarningLimit:{membraneTotalAmpHoursWarningLimit}");
  2680. }
  2681. //ANBathTotalAmpHoursCheck
  2682. double anBathTotalAmpHoursWarningLimit = 0;
  2683. if (SC.ContainsItem($"Reservoir.{Module}.ANBathTotalAmpHoursWarningLimit"))
  2684. {
  2685. anBathTotalAmpHoursWarningLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.ANBathTotalAmpHoursWarningLimit");
  2686. }
  2687. double anBathTotalAmpHoursFaultLimit = 0;
  2688. if (SC.ContainsItem($"Reservoir.{Module}.ANBathTotalAmpHoursFaultLimit"))
  2689. {
  2690. anBathTotalAmpHoursFaultLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.ANBathTotalAmpHoursFaultLimit");
  2691. }
  2692. if (reservoirUsage.AnodeUsage > anBathTotalAmpHoursFaultLimit && anBathTotalAmpHoursFaultLimit != 0)
  2693. {
  2694. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Anolyte Bath Usage(AHr):{reservoirUsage.AnodeUsage} is over config item ANBathTotalAmpHoursFaultLimit:{anBathTotalAmpHoursFaultLimit}");
  2695. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2696. AlarmListManager.Instance.AddDataError(Module,
  2697. $"AnodeUsage", $"{Module} Anolyte Bath Usage(AHr):{reservoirUsage.AnodeUsage} is over ANBathTotalAmpHoursFaultLimit:{anBathTotalAmpHoursFaultLimit}");
  2698. }
  2699. else if (reservoirUsage.AnodeUsage > anBathTotalAmpHoursWarningLimit && anBathTotalAmpHoursWarningLimit != 0)
  2700. {
  2701. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Anolyte Bath Usage(AHr):{reservoirUsage.AnodeUsage} is over config item ANBathTotalAmpHoursWarningLimit:{anBathTotalAmpHoursWarningLimit}");
  2702. AlarmListManager.Instance.AddWarn(Module,
  2703. $"AnodeUsage", $"{Module} Anolyte Bath Usage(AHr):{reservoirUsage.AnodeUsage} is over ANBathTotalAmpHoursWarningLimit:{anBathTotalAmpHoursWarningLimit}");
  2704. }
  2705. //BathTotalAmpHoursCheck
  2706. double bathTotalAmpHoursWarningLimit = 0;
  2707. if (SC.ContainsItem($"Reservoir.{Module}.BathTotalAmpHoursWarningLimit"))
  2708. {
  2709. bathTotalAmpHoursWarningLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.BathTotalAmpHoursWarningLimit");
  2710. }
  2711. double bathTotalAmpHoursFaultLimit = 0;
  2712. if (SC.ContainsItem($"Reservoir.{Module}.BathTotalAmpHoursFaultLimit"))
  2713. {
  2714. bathTotalAmpHoursFaultLimit = (double)SC.GetValue<double>($"Reservoir.{Module}.BathTotalAmpHoursFaultLimit");
  2715. }
  2716. if (reservoirUsage.BathUsage > bathTotalAmpHoursFaultLimit && bathTotalAmpHoursFaultLimit != 0)
  2717. {
  2718. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Bath Usage(AHr):{reservoirUsage.BathUsage} is over config item BathTotalAmpHoursFaultLimit:{bathTotalAmpHoursFaultLimit}");
  2719. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2720. AlarmListManager.Instance.AddDataError(Module,
  2721. $"BathUsage", $"{Module} Bath Usage(AHr):{reservoirUsage.BathUsage} is over BathTotalAmpHoursFaultLimit:{bathTotalAmpHoursFaultLimit}");
  2722. }
  2723. else if (reservoirUsage.BathUsage > bathTotalAmpHoursWarningLimit && bathTotalAmpHoursWarningLimit != 0)
  2724. {
  2725. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Bath Usage(AHr):{reservoirUsage.BathUsage} is over config item BathTotalAmpHoursWarningLimit:{bathTotalAmpHoursWarningLimit}");
  2726. AlarmListManager.Instance.AddWarn(Module,
  2727. $"BathUsage", $"{Module} Bath Usage(AHr):{reservoirUsage.BathUsage} is over BathTotalAmpHoursWarningLimit:{bathTotalAmpHoursWarningLimit}");
  2728. }
  2729. //BathTotalDaysCheck
  2730. int bathTotalDaysWarningLimit = 0;
  2731. if (SC.ContainsItem($"Reservoir.{Module}.BathTotalDaysWarningLimit"))
  2732. {
  2733. bathTotalDaysWarningLimit = SC.GetValue<int>($"Reservoir.{Module}.BathTotalDaysWarningLimit");
  2734. }
  2735. int bathTotalDaysFaultLimit = 0;
  2736. if (SC.ContainsItem($"Reservoir.{Module}.BathTotalDaysFaultLimit"))
  2737. {
  2738. bathTotalDaysFaultLimit = SC.GetValue<int>($"Reservoir.{Module}.BathTotalDaysFaultLimit");
  2739. }
  2740. if (reservoirUsage.BathUsageDays > bathTotalDaysFaultLimit && bathTotalDaysFaultLimit != 0)
  2741. {
  2742. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Bath Usage(Days):{reservoirUsage.BathUsageDays} is over config item BathTotalDaysFaultLimit:{bathTotalDaysFaultLimit}");
  2743. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2744. AlarmListManager.Instance.AddDataError(Module,
  2745. $"BathUsageDays", $"{Module} Bath Usage(Days):{reservoirUsage.BathUsageDays} is over BathTotalDaysFaultLimit:{bathTotalDaysFaultLimit}");
  2746. }
  2747. else if (reservoirUsage.BathUsageDays > bathTotalDaysWarningLimit && bathTotalDaysWarningLimit != 0)
  2748. {
  2749. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Bath Usage(Days):{reservoirUsage.BathUsage} is over config item BathTotalDaysWarningLimit:{bathTotalDaysWarningLimit}");
  2750. AlarmListManager.Instance.AddWarn(Module,
  2751. $"BathUsageDays", $"{Module} Bath Usage(Days):{reservoirUsage.BathUsageDays} is over BathTotalDaysWarningLimit:{bathTotalDaysWarningLimit}");
  2752. }
  2753. //ReservoirTotalWafersCheck
  2754. int reservoirTotalWafersWarningLimit = 0;
  2755. if (SC.ContainsItem($"Reservoir.{Module}.ReservoirTotalWafersWarningLimit"))
  2756. {
  2757. reservoirTotalWafersWarningLimit = SC.GetValue<int>($"Reservoir.{Module}.ReservoirTotalWafersWarningLimit");
  2758. }
  2759. int reservoirTotalWafersFaultLimit = 0;
  2760. if (SC.ContainsItem($"Reservoir.{Module}.ReservoirTotalWafersFaultLimit"))
  2761. {
  2762. reservoirTotalWafersFaultLimit = SC.GetValue<int>($"Reservoir.{Module}.ReservoirTotalWafersFaultLimit");
  2763. }
  2764. if (reservoirUsage.TotalWafers > reservoirTotalWafersFaultLimit && reservoirTotalWafersFaultLimit != 0)
  2765. {
  2766. LOG.WriteLog(eEvent.ERR_RESERVOIR, Module, $"{Module} Total Wafers:{reservoirUsage.TotalWafers} is over config item ReservoirTotalWafersFaultLimit:{reservoirTotalWafersFaultLimit}");
  2767. reservoirEntity.PostMsg(ReservoirMsg.Error);
  2768. AlarmListManager.Instance.AddDataError(Module,
  2769. $"TotalWafers", $"{Module} Total Wafers:{reservoirUsage.TotalWafers} is over ReservoirTotalWafersFaultLimit:{reservoirTotalWafersFaultLimit}");
  2770. }
  2771. else if (reservoirUsage.TotalWafers > reservoirTotalWafersWarningLimit && reservoirTotalWafersWarningLimit != 0)
  2772. {
  2773. LOG.WriteLog(eEvent.WARN_RESERVOIR, Module, $"{Module} Total Wafers:{reservoirUsage.TotalWafers} is over config item ReservoirTotalWafersWarningLimit:{reservoirTotalWafersWarningLimit}");
  2774. AlarmListManager.Instance.AddWarn(Module,
  2775. $"TotalWafers", $"{Module} Total Wafers:{reservoirUsage.TotalWafers} is over ReservoirTotalWafersWarningLimit:{reservoirTotalWafersWarningLimit}");
  2776. }
  2777. }
  2778. public void Monitor()
  2779. {
  2780. }
  2781. public void Reset()
  2782. {
  2783. }
  2784. public void Terminate()
  2785. {
  2786. }
  2787. }
  2788. }