SX-WCS/WCS.Service/Worker.cs

using FreeRedis;
using MessagePack;
using Newtonsoft.Json;
using ServiceCenter;
using ServiceCenter.Extensions;
using ServiceCenter.Logs;
using ServiceCenter.Redis;
using ServiceCenter.SqlSugars;
using SqlSugar;
using System.Text;
using WCS.Core;
using WCS.Entity.Protocol.DataStructure;
using WCS.Entity.Protocol.Robot;
using WCS.Entity.Protocol.Station;
using WCS.WorkEngineering;

namespace WCS.Service
{
    /// <summary>
    /// 工作服务
    /// </summary>
    public class Worker : BackgroundService
    {
        /// <summary>
        /// 记录器
        /// </summary>
        private readonly ILogger<Worker> _logger;

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="logger">记录器</param>
        public Worker(ILogger<Worker> logger)
        {
            _logger = logger;
        }

        public static readonly string WcsDlog = "WCSDlog";
        public static readonly string Wcsdb = "WCSDB";

        /// <summary>
        ///  执行
        /// </summary>
        /// <param name="stoppingToken">停止令牌</param>
        /// <returns></returns>
        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            if (stoppingToken.IsCancellationRequested)
                return;
             

            #region 初始化Redis连接
              
            Configs.DebugRedisUrl = "";

            #endregion 初始化Redis连接

            #region 启用日志

            //var logConfigText = RedisHub.Default.Check("LogConfigText") ?? throw new Exception("请在Redis中配置log4net相关内容");
            //var logConfig = JsonConvert.DeserializeObject<LogConfig>(logConfigText);
            //LogHub.SetConfigInfo(logConfig!);

            #endregion 启用日志

            _logger.LogInformation("WCS开始启动");
            Configs.ProtocolProxyBaseType = typeof(ProtocolProxy);
            Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
            Configs.StringEncoding = Encoding.UTF8;
            //var warehouseName = RedisHub.Default.Check("WarehouseName") ?? throw new Exception("请在Redis中配置仓库名称");
            //if (string.IsNullOrEmpty(warehouseName)) throw new Exception("请在Redis中配置仓库名称");
            //ServiceHub.SetWarehouseName(warehouseName);

            #region 初始化数据库连接
            /*
           var dbConnectionStrings = RedisHub.Default.Check("DbConnectionStrings") ?? throw new Exception("请在Redis中配置数据库连接相关内容");
           ServiceHub.DbConnectionStrings = JsonConvert.DeserializeObject<List<DataBaseConnectionString>>(dbConnectionStrings);

           if (ServiceHub.DbConnectionStrings != null)
           {
               if (ServiceHub.DbConnectionStrings.All(v => v.Key != Wcsdb)) throw new Exception("请在DbConnectionStrings中配置WCS基础数据库连接字符串");
               if (ServiceHub.DbConnectionStrings.All(v => v.Key == Wcsdb && !v.IsDefault)) throw new Exception("请在DbConnectionStrings中配置WCS基础数据库为默认数据库");
               // if (ServiceHub.DbConnectionStrings.All(v => v.Key != WcsDlog)) throw new Exception("请在DbConnectionStrings中配置WCS日志数据库连接字符串");
           }

           //设置连接信息
           List<ConnectionConfig> connectionConfigs = new List<ConnectionConfig>();
           foreach (var connectionString in ServiceHub.DbConnectionStrings!)
           {
               connectionConfigs.Add(new ConnectionConfig()
               {
                   ConfigId = connectionString.Key,
                   ConnectionString = connectionString.ConnectionString,//连接符字串
                   DbType = connectionString.DbType,//数据库类型
                   IsAutoCloseConnection = true,//不设成true要手动close
               });
           };

           */
            List<ConnectionConfig> connectionConfigs = new List<ConnectionConfig>();
            connectionConfigs.Add(new ConnectionConfig
            {
                ConfigId = "WCSDB",
                ConnectionString = "Data Source=10.30.44.50;User ID=sa;Password=P@ssw0rd;Initial Catalog=WMS_ZT_01SX;Integrated Security=False;",
                DbType = DbType.SqlServer,
                IsAutoCloseConnection = true,
            });
            connectionConfigs.Add(new ConnectionConfig
            {
                ConfigId = "WCSDlog",
                ConnectionString = "Data Source=10.30.39.1;User ID=sa;Password=123456;Initial Catalog=WCS_ZT_SX_LOG;Integrated Security=False;",
                DbType = DbType.SqlServer,
                IsAutoCloseConnection = true,
            });

            SqlSugarHelper.SetDb(new SqlSugarScope(connectionConfigs));

            SqlSugarHelper.SetDefault("WCSDB");
            SqlSugarHelper.SetDlog("WCSDlog");
             
            SqlSugarHelper.Do(db =>
            {
                var dblog = db.Connect.GetConnectionScope("WCSDlog");
                dblog.CodeFirst.InitTables<WCS_Station23>();
            });


            #endregion

            #region 初始化设备信息

            WorkStart.InitializeDeviceInfo();

            #endregion 初始化设备信息

            #region 初始化PLC访问器及PLC读取协议

            //创建PLC访问器
            Configs.PLCAccessorCreater = new PLCAccessors.PLCAccessorsCreater();

            try
            {
                #region 唤醒所有的世界

                World.StartAll();

                #endregion 唤醒所有的世界

                _logger.LogInformation("WCS启动成功");
            }
            catch (Exception ex)
            {
                _logger.LogError("WCS启动失败{0}", ex.Message);
            }

            #endregion 初始化PLC访问器及PLC读取协议

            //LogHub.init();
        }
    }
}