2023-04-13 11:51:03 +08:00
|
|
|
using System;
|
|
|
|
using System.Collections.Generic;
|
|
|
|
using System.IO;
|
|
|
|
using System.Reflection;
|
|
|
|
using System.Xml;
|
|
|
|
using Aitex.Core.RT.Log;
|
|
|
|
using Aitex.Core.RT.SCCore;
|
|
|
|
using Aitex.Core.Util;
|
|
|
|
using MECF.Framework.Common.IOCore;
|
|
|
|
|
|
|
|
namespace MECF.Framework.RT.Core.IoProviders
|
|
|
|
{
|
|
|
|
public class IoProviderManager : Singleton<IoProviderManager>
|
|
|
|
{
|
|
|
|
private List<IIoProvider> _providers = new List<IIoProvider>();
|
|
|
|
|
|
|
|
private Dictionary<string, IIoProvider> _dicProviders = new Dictionary<string, IIoProvider>();
|
|
|
|
|
|
|
|
public List<IIoProvider> Providers => _providers;
|
|
|
|
|
|
|
|
public IIoProvider GetProvider(string name)
|
|
|
|
{
|
|
|
|
if (_dicProviders.ContainsKey(name))
|
|
|
|
{
|
|
|
|
return _dicProviders[name];
|
|
|
|
}
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
|
|
|
|
public void Initialize(string xmlConfigFile, Dictionary<string, Dictionary<int, string>> ioMappingPathFile)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
var xmlDocument = new XmlDocument();
|
2023-04-13 11:51:03 +08:00
|
|
|
try
|
|
|
|
{
|
|
|
|
xmlDocument.Load(xmlConfigFile);
|
2023-04-24 10:42:02 +08:00
|
|
|
var xmlNodeIoProviders = xmlDocument.SelectNodes("IoProviders/IoProvider");
|
|
|
|
foreach (var node in xmlNodeIoProviders)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
if (!(node is XmlElement nodeProvider) || !(nodeProvider.SelectSingleNode("Parameter") is XmlElement nodeParameter))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var attrModule = nodeProvider.GetAttribute("module").Trim();
|
|
|
|
var attrName = nodeProvider.GetAttribute("name").Trim();
|
|
|
|
var attrClass = nodeProvider.GetAttribute("class").Trim();
|
|
|
|
var attrAssembly = nodeProvider.GetAttribute("assembly").Trim();
|
|
|
|
var attrLoadCond = nodeProvider.GetAttribute("load_condition").Trim();
|
|
|
|
var isSim = SC.GetConfigItem("System.IsSimulatorMode").BoolValue;
|
|
|
|
if ((isSim && attrLoadCond != "0" && attrLoadCond != "2") || (!isSim && attrLoadCond != "1" && attrLoadCond != "2"))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var ioProviderName = attrModule + "." + attrName;
|
|
|
|
var type = Assembly.Load(attrAssembly).GetType(attrClass);
|
2023-04-13 11:51:03 +08:00
|
|
|
if (type == null)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
throw new Exception(string.Format("ioProvider config file class and assembly not valid," + ioProviderName));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
IIoProvider ioProvider;
|
|
|
|
try
|
|
|
|
{
|
|
|
|
ioProvider = (IIoProvider)Activator.CreateInstance(type);
|
|
|
|
_providers.Add(ioProvider);
|
2023-04-24 10:42:02 +08:00
|
|
|
_dicProviders[ioProviderName] = ioProvider;
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
LOG.Write(ex);
|
2023-04-24 10:42:02 +08:00
|
|
|
throw new Exception(string.Format("ioProvider can not be created," + ioProviderName));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var list = new List<IoBlockItem>();
|
|
|
|
var xmlNodeBlocks = nodeProvider.SelectNodes("Blocks/Block");
|
|
|
|
foreach (var nodeBlock in xmlNodeBlocks)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
if (!(nodeBlock is XmlElement xmlNodeBlock))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var ioBlockItem = new IoBlockItem();
|
|
|
|
var attrType = xmlNodeBlock.GetAttribute("type");
|
|
|
|
var attrOffset = xmlNodeBlock.GetAttribute("offset");
|
|
|
|
var attrSize = xmlNodeBlock.GetAttribute("size");
|
|
|
|
var attrValueType = xmlNodeBlock.GetAttribute("value_type");
|
|
|
|
if (!int.TryParse(attrOffset, out var result))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
ioBlockItem.Offset = result;
|
2023-04-24 10:42:02 +08:00
|
|
|
if (int.TryParse(attrSize, out result))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
ioBlockItem.Size = result;
|
2023-04-24 10:42:02 +08:00
|
|
|
switch (attrType.ToLower())
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
case "ai":
|
|
|
|
ioBlockItem.Type = IoType.AI;
|
|
|
|
break;
|
|
|
|
case "ao":
|
|
|
|
ioBlockItem.Type = IoType.AO;
|
|
|
|
break;
|
|
|
|
case "di":
|
|
|
|
ioBlockItem.Type = IoType.DI;
|
|
|
|
break;
|
|
|
|
case "do":
|
|
|
|
ioBlockItem.Type = IoType.DO;
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (ioBlockItem.Type == IoType.AI || ioBlockItem.Type == IoType.AO)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
ioBlockItem.AIOType = ((string.IsNullOrEmpty(attrValueType) || attrValueType.ToLower() != "float") ? typeof(short) : typeof(float));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
list.Add(ioBlockItem);
|
|
|
|
}
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
if (ioMappingPathFile.ContainsKey(ioProviderName))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
ioProvider.Initialize(attrModule, attrName, list, Singleton<IoManager>.Instance, nodeParameter, ioMappingPathFile[ioProviderName]);
|
2023-04-13 11:51:03 +08:00
|
|
|
ioProvider.Start();
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
throw new Exception(string.Format("can not find io map config files," + ioProviderName));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex2)
|
|
|
|
{
|
|
|
|
throw new ApplicationException("IoProvider configuration not valid," + ex2.Message);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public void Initialize(string xmlConfigFile)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
var xmlDoc = new XmlDocument();
|
2023-04-13 11:51:03 +08:00
|
|
|
try
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
xmlDoc.Load(xmlConfigFile);
|
|
|
|
var xmlNodeList = xmlDoc.SelectNodes("IoProviders/IoProvider");
|
|
|
|
foreach (var item in xmlNodeList)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
if (!(item is XmlElement xmlElement) || !(xmlElement.SelectSingleNode("Parameter") is XmlElement nodeParameter))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var moduleName = xmlElement.GetAttribute("module").Trim();
|
|
|
|
var providerName = xmlElement.GetAttribute("name").Trim();
|
|
|
|
var typeName = xmlElement.GetAttribute("class").Trim();
|
|
|
|
var assemblyString = xmlElement.GetAttribute("assembly").Trim();
|
|
|
|
var loadCond = xmlElement.GetAttribute("load_condition").Trim();
|
2023-04-13 11:51:03 +08:00
|
|
|
var isSim = SC.GetConfigItem("System.IsSimulatorMode").BoolValue;
|
|
|
|
if ((isSim && loadCond != "0" && loadCond != "2") || (!isSim && loadCond != "1" && loadCond != "2"))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var ioProviderName = moduleName + "." + providerName;
|
|
|
|
var type = Assembly.Load(assemblyString).GetType(typeName);
|
2023-04-13 11:51:03 +08:00
|
|
|
if (type == null)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
throw new Exception(string.Format("ioProvider config file class and assembly not valid," + ioProviderName));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
IIoProvider ioProvider;
|
|
|
|
try
|
|
|
|
{
|
|
|
|
ioProvider = (IIoProvider)Activator.CreateInstance(type);
|
|
|
|
_providers.Add(ioProvider);
|
2023-04-24 10:42:02 +08:00
|
|
|
_dicProviders[ioProviderName] = ioProvider;
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
LOG.Write(ex);
|
2023-04-24 10:42:02 +08:00
|
|
|
throw new Exception(string.Format("ioProvider can not be created," + ioProviderName));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var list = new List<IoBlockItem>();
|
|
|
|
var nodeBlocks = xmlElement.SelectNodes("Blocks/Block");
|
|
|
|
foreach (var nodeBlock in nodeBlocks)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
if (!(nodeBlock is XmlElement xmlBlock))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var ioBlockItem = new IoBlockItem();
|
|
|
|
var attrType = xmlBlock.GetAttribute("type");
|
|
|
|
var attrOffset = xmlBlock.GetAttribute("offset");
|
|
|
|
var attrSize = xmlBlock.GetAttribute("size");
|
|
|
|
var attrValueType = xmlBlock.GetAttribute("value_type");
|
|
|
|
if (!int.TryParse(attrOffset, out var result))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
ioBlockItem.Offset = result;
|
2023-04-24 10:42:02 +08:00
|
|
|
if (int.TryParse(attrSize, out result))
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
ioBlockItem.Size = result;
|
2023-04-24 10:42:02 +08:00
|
|
|
switch (attrType.ToLower())
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
case "ai":
|
|
|
|
ioBlockItem.Type = IoType.AI;
|
|
|
|
break;
|
|
|
|
case "ao":
|
|
|
|
ioBlockItem.Type = IoType.AO;
|
|
|
|
break;
|
|
|
|
case "di":
|
|
|
|
ioBlockItem.Type = IoType.DI;
|
|
|
|
break;
|
|
|
|
case "do":
|
|
|
|
ioBlockItem.Type = IoType.DO;
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (ioBlockItem.Type == IoType.AI || ioBlockItem.Type == IoType.AO)
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
ioBlockItem.AIOType = ((string.IsNullOrEmpty(attrValueType) || attrValueType.ToLower() != "float") ? typeof(short) : typeof(float));
|
2023-04-13 11:51:03 +08:00
|
|
|
}
|
|
|
|
list.Add(ioBlockItem);
|
|
|
|
}
|
|
|
|
}
|
2023-04-24 10:42:02 +08:00
|
|
|
var ioModule = xmlElement.GetAttribute("map_module").Trim();
|
|
|
|
var ioMapFileName = xmlElement.GetAttribute("map_file").Trim();
|
|
|
|
var fileInfo = new FileInfo(xmlConfigFile);
|
|
|
|
var ioMappingPathFile = fileInfo.Directory.FullName + "\\" + ioMapFileName;
|
2023-04-13 11:51:03 +08:00
|
|
|
ioProvider.Initialize(moduleName, providerName, list, Singleton<IoManager>.Instance, nodeParameter, ioMappingPathFile, ioModule);
|
|
|
|
ioProvider.Start();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex2)
|
|
|
|
{
|
|
|
|
throw new ApplicationException("IoProvider configuration not valid," + ex2.Message);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public void Terminate()
|
|
|
|
{
|
|
|
|
try
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
foreach (var provider in _providers)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
provider.Stop();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
LOG.Write(ex);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public void Reset()
|
|
|
|
{
|
|
|
|
try
|
|
|
|
{
|
2023-04-24 10:42:02 +08:00
|
|
|
foreach (var provider in _providers)
|
2023-04-13 11:51:03 +08:00
|
|
|
{
|
|
|
|
provider.Reset();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
LOG.Write(ex);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|