BPASmartClient/BPASmartClient.Business/Plugin/ConfigMgr.cs

using BPA.ApolloClient;
using BPA.Message;
using BPASmartClient.Message;
using BPASmartClient.Model;
using Microsoft.Extensions.Configuration;
using System.Xml.Linq;
using System.Xml.XPath;


namespace BPASmartClient.Business
{
    /// <summary>
    /// 配置管理器
    /// </summary>
    public class ConfigMgr : IPlugin
    {
        /// <summary>
        /// 门店ID
        /// </summary>
        public int ClientId { get; set; }
        /// <summary>
        /// MQTT Broker
        /// </summary>
        public MQTT_Entity MQTT_Config { get; set; }

        //Apollo地址
        private string apolloUri;
        private string apoid;
        private string namespa;
        //设备集合
        private List<DeviceConfig> deviceConfigs;
        public void Dispose()
        {
        }

        public void Initialize()
        {
            ClientId = int.Parse(System.Configuration.ConfigurationManager.AppSettings["ClientId"]);
            apolloUri = System.Configuration.ConfigurationManager.AppSettings["ApolloUri"].ToString();
            apoid = System.Configuration.ConfigurationManager.AppSettings["AppId"].ToString();
            namespa = System.Configuration.ConfigurationManager.AppSettings["Namespaces"].ToString();
            InternetInfo.OrderServer = System.Configuration.ConfigurationManager.AppSettings["OrderServiceUri"].ToString();
            InternetInfo.StockServer = System.Configuration.ConfigurationManager.AppSettings["StockServiceUri"].ToString();
            InitDeviceModel();
            InitMQTT();
        }

        public List<DeviceConfig> GetDeviceConfigs()
        {
            if (null == deviceConfigs)
                InitDeviceModel();
            return deviceConfigs;
        }

        /// <summary>
        /// 加载设备模型
        /// </summary>
        private void InitDeviceModel()
        {
            deviceConfigs = new List<DeviceConfig>();
            var devicePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DeviceInfo.xml");
            var xdoc = XDocument.Load(devicePath);
            var devices = xdoc.XPathSelectElements("//Device");
            foreach (var device in devices)
            {
                DeviceConfig deviceConfig = new DeviceConfig();
                deviceConfig.Name = device.Attribute("Name").Value;
                deviceConfig.Module = device.Attribute("Module").Value;
                deviceConfig.DeviceId = int.Parse(device.Attribute("DeviceId").Value);

                var Peripherals = device.XPathSelectElements("Peripherals/Peripheral");
                if (Peripherals != null)
                {
                    foreach (var Per in Peripherals)
                    {
                        BPASmartClient.Model.Peripheral peripheral = new BPASmartClient.Model.Peripheral();
                        peripheral.Module = Per.Attribute("Module").Value;

                        var Parameters = Per.Element("Parameters").Elements();
                        if (Parameters != null)
                        {
                            foreach (var item in Parameters)
                            {
                                peripheral.Parameters.Add(item.Name.LocalName, item.Value);
                            }
                        }
                        deviceConfig.Peripherals.Add(peripheral);
                    }
                }
                deviceConfigs.Add(deviceConfig);
            }
        }

        /// <summary>
        /// 加载MQTT配置
        /// </summary>
        private void InitMQTT()
        {
            IConfigurationBuilder configurationBuilder = new ConfigurationBuilder().SetBasePath(Directory.GetCurrentDirectory());

            //测试版本
            //configurationBuilder.AddApolloConfiguration(p =>
            //    {
            //        p.AppId = "dev1_order";
            //        p.MetaServer = apolloUri;
            //        p.Namespaces = new List<string>() { "DEV.Config" };
            //    });

            //正式版本
            configurationBuilder.AddApolloConfiguration(p =>
            {
                p.AppId = apoid;
                p.MetaServer = apolloUri;
                p.Namespaces = new List<string>() { namespa };
            });

            IConfiguration config = configurationBuilder.Build();
            var mqttBroker = config.GetSection("BrokerHostSettings");
            MQTT_Config = mqttBroker.Value.FromJSON<MQTT_Entity>();
            if (MQTT_Config == null) MessageLog.GetInstance.Show("获取配置数据为空！");
        }

        public void Start()
        {
        }

        public class MQTT_Entity
        {
            public string Host { get; set; }
            public int Port { get; set; }
        }
    }
}