Kepler-Release/Venus/Framework/Common/IOCore/InterlockManager.cs

using System;
using System.Collections.Generic;
using System.Xml;
using Aitex.Core.RT.Event;
using Aitex.Core.Util;
using Aitex.Core.RT.Log;

namespace Aitex.Core.RT.IOCore
{
    public class InterlockManager : Singleton<InterlockManager>
    {
        private List<InterlockAction> _actions = new List<InterlockAction>();
        private Dictionary<InterlockLimit, List<InterlockAction>> _dicLimit = new Dictionary<InterlockLimit, List<InterlockAction>>();
 
        public bool Initialize(string interlockFile, Dictionary<string, DOAccessor> doMap, Dictionary<string, DIAccessor> diMap, out string reason)
        {
            reason = string.Empty;

            try
            {
                XmlDocument xmlConfig = new XmlDocument();
                xmlConfig.Load(interlockFile);


                XmlNode nodeInterlock = xmlConfig.SelectSingleNode("Interlock");


                foreach (XmlNode item in nodeInterlock.ChildNodes)
                {
                    if (item.NodeType == XmlNodeType.Comment)
                        continue;

                    XmlElement actionNode = item as XmlElement;
                    if (actionNode == null) continue;

                    if (actionNode.Name != "Action")
                    {
                        if (actionNode.NodeType != XmlNodeType.Comment)
                        {
                            //LOG.Write("interlock config file contains no comments content, " + actionNode.InnerXml);
                        }
                        continue;
                    }
                    if (!actionNode.HasAttribute("do") || !actionNode.HasAttribute("value"))
                    {
                        reason += "action node has no [do] or [value] attribute \r\n";
                        continue;
                    }

                    string doName = actionNode.GetAttribute("do");
                    bool value = Convert.ToBoolean(actionNode.GetAttribute("value"));
                    string tip = string.Empty;
                    Dictionary<string, string> cultureTip  = new Dictionary<string, string>();
                    List<InterlockLimit> limits = new List<InterlockLimit>();

                    if (!doMap.ContainsKey(doName))
                    {
                        reason += "action node " + doName + " no such DO defined \r\n";
                        continue;
                    }

                    DOAccessor doItem = doMap[doName] as DOAccessor;
                    if (doItem == null)
                    {
                        reason += "action node " + doName + " no such DO defined \r\n";
                        continue;
                    }

                    if (actionNode.HasAttribute("tip"))
                        tip = actionNode.GetAttribute("tip");

                    if (actionNode.HasAttribute("tip.zh-CN"))
                        cultureTip["zh-CN"] = actionNode.GetAttribute("tip.zh-CN");

                    if (actionNode.HasAttribute("tip.en-US"))
                        cultureTip["en-US"] = actionNode.GetAttribute("tip.en-US");

                    foreach (XmlElement limitNode in actionNode.ChildNodes)
                    {
                        if (limitNode.Name != "Limit")
                        {
                            if (limitNode.NodeType != XmlNodeType.Comment)
                            {
                                //LOG.Write("interlock config file contains no comments content, " + limitNode.InnerXml);
                            }
                            continue;
                        }
                        if (!(limitNode.HasAttribute("di") || limitNode.HasAttribute("do")) || !limitNode.HasAttribute("value"))
                        {
                            reason += "limit node lack of di/do or value attribute \r\n";
                            continue;
                        }

                        string stringValue = limitNode.GetAttribute("value");
                        if (stringValue.Contains("*"))
                        {
                            continue;                        
                        }
                        bool limitValue = Convert.ToBoolean(limitNode.GetAttribute("value"));
                        string limitTip = string.Empty;
                        Dictionary<string, string> limitCultureTip = new Dictionary<string, string>();

                        if (limitNode.HasAttribute("tip"))
                            limitTip = limitNode.GetAttribute("tip");

                        if (limitNode.HasAttribute("tip.zh-CN"))
                            limitCultureTip["zh-CN"] = limitNode.GetAttribute("tip.zh-CN");

                        if (limitNode.HasAttribute("tip.en-US"))
                            limitCultureTip["en-US"] = limitNode.GetAttribute("tip.en-US");

                        if (limitNode.HasAttribute("di"))
                        {
                            string diName = limitNode.GetAttribute("di");

                            if (!diMap.ContainsKey(diName))
                            {
                                reason += "limit node " + diName + " no such DI defined \r\n";
                                continue;
                            }

                            DIAccessor diItem = diMap[diName] as DIAccessor;
                            if (diItem == null)
                            {
                                reason += "limit node " + diName + " no such DI defined \r\n";
                                continue;
                            }

                            limits.Add(new DiLimit(diItem, limitValue, limitTip, limitCultureTip));
                        }
                        else if (limitNode.HasAttribute("do"))
                        {
                            string ioName = limitNode.GetAttribute("do");

                            if (!doMap.ContainsKey(ioName))
                            {
                                reason += "limit node " + ioName + " no such DO defined \r\n";
                                continue;
                            }

                            DOAccessor ioItem = doMap[ioName];
                            if (ioItem == null)
                            {
                                reason += "limit node " + ioName + " no such DO defined \r\n";
                                continue;
                            }

                            limits.Add(new DoLimit(ioItem, limitValue, limitTip, limitCultureTip));
                        }

                    }
                    
                    InterlockAction action = new InterlockAction(doItem, value, tip, cultureTip, limits);
                    _actions.Add(action);

                    foreach (var interlockLimit in limits)
                    {
                        bool isExist = false;
                        foreach (var limit in _dicLimit.Keys)
                        {
                            if (interlockLimit.IsSame(limit))
                            {
                                _dicLimit[limit].Add(action);
                                isExist = true;
                                break;
                            }
                        }

                        if (!isExist)
                        {
                            _dicLimit[interlockLimit] = new List<InterlockAction>();
                            _dicLimit[interlockLimit].Add(action);
                        }
                        
                    }
                }

            }
            catch (Exception ex)
            {
                reason += ex.Message;
            }

            if (!string.IsNullOrEmpty(reason))
                return false;

            return true;
        }

        public bool Initialize(string chamberName,string interlockFile, Dictionary<string, DOAccessor> doMap, Dictionary<string, DIAccessor> diMap, out string reason)
        {
            reason = string.Empty;

            try
            {
                XmlDocument xmlConfig = new XmlDocument();
                xmlConfig.Load(interlockFile);


                XmlNode nodeInterlock = xmlConfig.SelectSingleNode("Interlock");


                foreach (XmlNode item in nodeInterlock.ChildNodes)
                {
                    if (item.NodeType == XmlNodeType.Comment)
                        continue;

                    XmlElement actionNode = item as XmlElement;
                    if (actionNode == null) continue;

                    if (actionNode.Name != "Action")
                    {
                        if (actionNode.NodeType != XmlNodeType.Comment)
                        {
                            //LOG.Write("interlock config file contains no comments content, " + actionNode.InnerXml);
                        }
                        continue;
                    }
                    if (!actionNode.HasAttribute("do") || !actionNode.HasAttribute("value"))
                    {
                        reason += "action node has no [do] or [value] attribute \r\n";
                        continue;
                    }

                    string doName = $"{chamberName}.{actionNode.GetAttribute("do")}" ;
                    bool value = Convert.ToBoolean(actionNode.GetAttribute("value"));
                    string tip = string.Empty;
                    Dictionary<string, string> cultureTip = new Dictionary<string, string>();
                    List<InterlockLimit> limits = new List<InterlockLimit>();

                    if (!doMap.ContainsKey(doName))
                    {
                        reason += "action node " + doName + " no such DO defined \r\n";
                        continue;
                    }

                    DOAccessor doItem = doMap[doName] as DOAccessor;
                    if (doItem == null)
                    {
                        reason += "action node " + doName + " no such DO defined \r\n";
                        continue;
                    }

                    if (actionNode.HasAttribute("tip"))
                        tip = actionNode.GetAttribute("tip");

                    if (actionNode.HasAttribute("tip.zh-CN"))
                        cultureTip["zh-CN"] = actionNode.GetAttribute("tip.zh-CN");

                    if (actionNode.HasAttribute("tip.en-US"))
                        cultureTip["en-US"] = actionNode.GetAttribute("tip.en-US");

                    foreach (XmlElement limitNode in actionNode.ChildNodes)
                    {
                        if (limitNode.Name != "Limit")
                        {
                            if (limitNode.NodeType != XmlNodeType.Comment)
                            {
                                //LOG.Write("interlock config file contains no comments content, " + limitNode.InnerXml);
                            }
                            continue;
                        }
                        if (!(limitNode.HasAttribute("di") || limitNode.HasAttribute("do")) || !limitNode.HasAttribute("value"))
                        {
                            reason += "limit node lack of di/do or value attribute \r\n";
                            continue;
                        }

                        string stringValue = limitNode.GetAttribute("value");
                        if (stringValue.Contains("*"))
                        {
                            continue;
                        }
                        bool limitValue = Convert.ToBoolean(limitNode.GetAttribute("value"));
                        string limitTip = string.Empty;
                        Dictionary<string, string> limitCultureTip = new Dictionary<string, string>();

                        if (limitNode.HasAttribute("tip"))
                            limitTip = limitNode.GetAttribute("tip");

                        if (limitNode.HasAttribute("tip.zh-CN"))
                            limitCultureTip["zh-CN"] = limitNode.GetAttribute("tip.zh-CN");

                        if (limitNode.HasAttribute("tip.en-US"))
                            limitCultureTip["en-US"] = limitNode.GetAttribute("tip.en-US");

                        if (limitNode.HasAttribute("di"))
                        {
                            string diName = $"{chamberName}.{limitNode.GetAttribute("di")}";

                            if (!diMap.ContainsKey(diName))
                            {
                                reason += "limit node " + diName + " no such DI defined \r\n";
                                continue;
                            }

                            DIAccessor diItem = diMap[diName] as DIAccessor;
                            if (diItem == null)
                            {
                                reason += "limit node " + diName + " no such DI defined \r\n";
                                continue;
                            }

                            limits.Add(new DiLimit(diItem, limitValue, limitTip, limitCultureTip));
                        }
                        else if (limitNode.HasAttribute("do"))
                        {
                            string ioName = $"{chamberName}.{limitNode.GetAttribute("do")}";

                            if (!doMap.ContainsKey(ioName))
                            {
                                reason += "limit node " + ioName + " no such DO defined \r\n";
                                continue;
                            }

                            DOAccessor ioItem = doMap[ioName];
                            if (ioItem == null)
                            {
                                reason += "limit node " + ioName + " no such DO defined \r\n";
                                continue;
                            }

                            limits.Add(new DoLimit(ioItem, limitValue, limitTip, limitCultureTip));
                        }

                    }

                    InterlockAction action = new InterlockAction(doItem, value, tip, cultureTip, limits);
                    _actions.Add(action);

                    foreach (var interlockLimit in limits)
                    {
                        bool isExist = false;
                        foreach (var limit in _dicLimit.Keys)
                        {
                            if (interlockLimit.IsSame(limit))
                            {
                                _dicLimit[limit].Add(action);
                                isExist = true;
                                break;
                            }
                        }

                        if (!isExist)
                        {
                            _dicLimit[interlockLimit] = new List<InterlockAction>();
                            _dicLimit[interlockLimit].Add(action);
                        }

                    }
                }

            }
            catch (Exception ex)
            {
                reason += ex.Message;
            }

            if (!string.IsNullOrEmpty(reason))
                return false;

            return true;
        }


        public void Monitor()
        {
            foreach (var limit in _dicLimit)
            {
                if (!limit.Key.IsTriggered())
                    continue;

                string info = string.Empty;
                foreach (var action in limit.Value)
                {
                    string reason;
                    if (!action.Reverse(out reason))
                        continue;

                    if (string.IsNullOrEmpty(info))
                    {    
                        info = string.Format("Due to the {0}, {1}=[{2}]\n", limit.Key.Tip, limit.Key.Name,
                            !limit.Key.LimitValue);
                    }

                    info += reason + "\n";
                }

                if (!string.IsNullOrEmpty(info))
                {
                    LOG.Write(eEvent.ERR_INTERLOCK_FAIL, "System", info.TrimEnd('\n'));
                } 
            }
        }

        public bool CanSetDo(string doName, bool onOff, out string reason)
        {
            reason = string.Empty;

            foreach (var interlockAction in _actions)
            {
                if (interlockAction.IsSame(doName, onOff))
                {
                    return interlockAction.CanDo(out reason);
                }
            }

            return true;
        }
    }
}