WCS_Pedestal/WCS.Service/Worker.cs

using Newtonsoft.Json;
using SqlSugar;
using System.Text;
using WCS.Core;
using WCS.Core.DataTrans;
using WCS.Core.DbHelper;
using WCS.Core.Helpers;
using WCS.Core.Log;
using WCS.Core.Redis;
using WCS.Core.Virtual_PLC;
using WCS.Entity;
using WCS.Entity.Protocol;
using WCS.Entity.Protocol.BCR;
using WCS.Entity.Protocol.Station;
using WCS.WebApi.WMS;

namespace WCS.Service
{
    public class Worker : BackgroundService
    {
        private readonly ILogger<Worker> _logger;

        public Worker(ILogger<Worker> logger)
        {
            _logger = logger;
        }

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

        protected override async System.Threading.Tasks.Task ExecuteAsync(CancellationToken stoppingToken)
        {
            if (stoppingToken.IsCancellationRequested)
                return;

            #region 启用日志

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

            #endregion 启用日志

            _logger.LogInformation("WCS开始启动");
            Configs.ProtocolProxyBaseType = typeof(ProtocolProxy);
            Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
            Configs.StringEncoding = Encoding.UTF8;

            #region 初始化数据库连接

            var dbConnectionStrings = RedisHelper.Default.Check("DbConnectionStrings") ?? throw new Exception("请在Redis中配置数据库连接相关内容");
            Configs.DbConnectionStrings = JsonConvert.DeserializeObject<List<DataBaseConnectionString>>(dbConnectionStrings);
            if (Configs.DbConnectionStrings != null)
            {
                if (Configs.DbConnectionStrings.All(v => v.Key != Wcsdb)) throw new Exception("请在DbConnectionStrings中配置WCS基础数据库连接字符串");
                if (Configs.DbConnectionStrings.All(v => v.Key == Wcsdb && !v.IsDefault)) throw new Exception("请在DbConnectionStrings中配置WCS基础数据库为默认数据库");
                if (Configs.DbConnectionStrings.All(v => v.Key != WcsDlog)) throw new Exception("请在DbConnectionStrings中配置WCS日志数据库连接字符串");
            }

            foreach (var connectionString in Configs.DbConnectionStrings!)
            {
                Db.CreateContext(new ConnectionConfig()
                {
                    ConnectionString = connectionString.ConnectionString,
                    DbType = connectionString.DbType
                }, connectionString.Key);
                if (connectionString.IsDefault) Db.SetDefaultDbContextType(connectionString.Key);

                switch (connectionString.Key)
                {
                    case "WCSDB"://WCS基本数据库
                        Db.Do(db =>
                        {
                            //TODO:DbMaintenance.CreateDatabase()并没起到作用，如果没有对应的数据库的话任然需要手动新建一个
                            db.Default.DbMaintenance.CreateDatabase();
                            db.Default.CodeFirst.InitTables(typeof(WCS_CMD));
                            db.Default.CodeFirst.InitTables(typeof(WCS_PLC));
                            db.Default.CodeFirst.InitTables(typeof(WCS_DATABLOCK));
                            db.Default.CodeFirst.InitTables(typeof(WCS_DEVICE));
                            db.Default.CodeFirst.InitTables(typeof(WCS_PATH));
                            db.Default.CodeFirst.InitTables(typeof(WCS_PATHPOINT));
                            db.Default.CodeFirst.InitTables(typeof(WCS_ROUTE));
                            db.Default.CodeFirst.InitTables(typeof(WCS_TASK));
                            db.Default.CodeFirst.InitTables(typeof(WCS_TASK_OLD));
                            db.Default.CodeFirst.InitTables(typeof(WCS_EXCEPTION));
                            db.Default.CodeFirst.InitTables(typeof(WCS_SystemConfig));
                            db.Default.CodeFirst.InitTables(typeof(WCS_AGVTask));
                            db.Default.CodeFirst.InitTables(typeof(WCS_DEVICEPROTOCOL));
                            db.Default.CodeFirst.InitTables(typeof(WCS_GROUPMEMBER));
                            db.Default.CodeFirst.InitTables(typeof(WCS_MAPPINGENTRY));
                            db.Default.CodeFirst.InitTables(typeof(WCS_USERS));
                            db.Default.CodeFirst.InitTables(typeof(WCS_StatusLog));
                            db.Default.CodeFirst.InitTables(typeof(WCS.Entity.PlcRawData));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_BCR80));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_RGV520));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_RGV521));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_RGV523));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_SRM520));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_SRM521));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_SRM537));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_Station520));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_Station521));
                            //db.Default.CodeFirst.InitTables(typeof(WCS_Station523));
                        });
                        break;

                    case "WCSDlog"://WCS日志数据库
                        Db.Do(db =>
                        {
                            //TODO:DbMaintenance.CreateDatabase()并没起到作用，如果没有对应的数据库的话任然需要手动新建一个
                            db.Context(WcsDlog).DbMaintenance.CreateDatabase();
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_BCR80));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_RGV520));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_RGV521));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_RGV523));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_SRM520));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_SRM521));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_SRM537));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_Station520));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_Station521));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS_Station523));
                            db.Context(WcsDlog).CodeFirst.InitTables(typeof(WCS.Entity.PlcRawData));
                        });
                        break;

                    default: //其他库
                        break;
                }
            }

            #endregion 初始化数据库连接

            #region 创建虚拟PLC

            var isOpenVirtualPlc = RedisHelper.Default.Check("isOpenVirtualPLC");
            if (isOpenVirtualPlc == "1")
            {
                var plcDataConnectionString = RedisHelper.Default.Check("plcDataConnectionString") ?? throw new Exception("请在Redsi中配置虚拟PLC使用的Redis连接字符串");

                //从现有结构解析出需要的结构
                var list = new List<PLCData>();
                Db.Do(db =>
                {
                    var dataBlocks = db.Default.Queryable<WCS_DATABLOCK>().Includes(v => v.PLC).ToList();
                    list.AddRange(dataBlocks.Select(dataBlock => new PLCData()
                    {
                        IP = dataBlock.PLC.IP,
                        DB = dataBlock.NO,
                        Length = dataBlock.LENGTH,
                        DataLength = dataBlock.DATALENGTH,
                    }));
                });
                PlcData.Init(plcDataConnectionString).InitPlcData(list);
            }

            #endregion 创建虚拟PLC

            //是否启用虚拟PLC
            Configs.AddSystemMode(SystemMode.虚拟plc);
            //日志发布事件s
            Configs.PublishEvent += () =>
            {
                WMS.UploadDevInfo();
                ProtocolProxy.Do();
            };
            //异常上抛
            Configs.UploadException = (d, s) =>
            {
                if (s == "接口调用中") return;
                if (ProtocolProxy.AllDatas.ContainsKey(d))
                {
                    ProtocolProxy.AllDatas[d].Info = s;
                    ProtocolProxy.AllDatas[d].Frame = LogicHandler.Frame;
                }
                WMS.TaskException(d, s);
            };

            PlcAccessor.Creater = new PLCAccessors.PlcAccessorsCreater();
            try
            {
                Db.Do(db =>
                {
                    var items = db.Default.Queryable<WCS_DEVICEPROTOCOL>()
                    .Includes(d => d.DEVICE, r => r.ROUTES)
                    .Includes(d => d.DEVICE, p => p.PATHS)
                    .Includes(d => d.DB, p => p.PLC).ToArray();
                    var objects = items.Select(v => v.Data()).ToArray();
                    LogicHandler.AllObjects.AddRange(objects);

                    var devices = db.Default.Queryable<WCS_DEVICE>()
                                            .Includes(v => v.ROUTES)
                                            .Includes(v => v.PATHS)
                                            .Includes(v => v.DEVICEGROUP, g => g.GROUP)
                                            .AsNavQueryable()
                                            .Includes(v => v.DEVICEGROUP, g => g.MEMBER, d => d.DEVICEPROTOCOLS, p => p.DB, c => c.PLC)
                                            .Includes(v => v.DEVICEGROUP, g => g.MEMBER, d => d.DEVICEPROTOCOLS, p => p.DEVICE)
                                            .Includes(v => v.DEVICEPROTOCOLS, p => p.DB, c => c.PLC)
                                            .Includes(v => v.DEVICEPROTOCOLS, p => p.DEVICE)
                                            .ToList();
                    LogicHandler.AllObjects.AddRange(devices);
                });

                #region 设备扩展数据配置

                //WCS_DEVICEExtension.AddFlag(DF.一楼RGV放货, "G1035", "G1044", "G1053", "G1062");
                //WCS_DEVICEExtension.AddFlag(DF.SRM, "SRM1", "SRM2", "SRM3", "SRM4", "SRM5", "SRM6", "SRM7", "SRM8");
                //WCS_DEVICEExtension.AddFlag(DF.月台, "G1469", "G1561", "G1538", "G1574", "G1509");
                //WCS_DEVICEExtension.AddFlag(DF.SRM二级品取货, "1040", "1041", "1042", "1043", "1049", "1050", "1051", "1052");
                //WCS_DEVICEExtension.AddFlag(DF.SRM二级品取货, "1058", "1059", "1060", "1061", "1067", "1068");
                //WCS_DEVICEExtension.AddFlag(DF.SRMBOPP取货, "1195", "1194", "1193", "1192", "1204", "1203", "1202", "1201");
                //WCS_DEVICEExtension.AddFlag(DF.SRMBOPP取货, "1213", "1212", "1210", "1211", "1220", "1219", "1230", "1228");
                //WCS_DEVICEExtension.AddFlag(DF.SRM月台放货, "1473", "1476", "1474", "1475", "1491", "1492", "1493", "1494");
                //WCS_DEVICEExtension.AddFlag(DF.SRM月台放货, "1520", "1521", "1522", "1523", "1545", "1546", "1451", "1453");
                //WCS_DEVICEExtension.AddFlag(DF.SRM涂布取货, "1431", "1432", "1422", "1423", "1424", "1425", "1415", "1416");
                //WCS_DEVICEExtension.AddFlag(DF.SRM涂布取货, "1605", "1606", "1406", "1407", "1408", "1409");
                //WCS_DEVICEExtension.AddFlag(DF.SRM涂布放货, "1283", "1284", "1290", "1291", "1292", "1293", "1299", "1300");
                //WCS_DEVICEExtension.AddFlag(DF.SRM涂布放货, "1301", "1302", "1308", "1309", "1310", "1311");
                //WCS_DEVICEExtension.AddFlag(DF.涂布RGV, "RGV9", "RGV10", "RGV11", "RGV12", "RGV13", "RGV14");
                //WCS_DEVICEExtension.AddFlag(DF.涂布RGV取货设备组, "G2", "G3", "G5", "G7", "G9", "G11");
                //WCS_DEVICEExtension.AddFlag(DF.涂布RGV放货设备组, "G1", "G4", "G6", "G8", "G10");
                //WCS_DEVICEExtension.AddFlag(DF.涂布出库RGV取货站台, "1285", "1286", "1294", "1295", "1303", "1304", "1312", "1313");
                //WCS_DEVICEExtension.AddFlag(DF.涂布入库RGV取货站台, "1391", "1392", "1399", "1400");
                //WCS_DEVICEExtension.AddFlag(DF.涂布RGV取货站台, "1285", "1286", "1294", "1295", "1303", "1304", "1312", "1313");
                //WCS_DEVICEExtension.AddFlag(DF.涂布RGV取货站台, "1391", "1392", "1399", "1400");
                //WCS_DEVICEExtension.AddFlag(DF.BOPPRGV, "RGV1", "RGV2", "RGV3", "RGV4", "RGV5", "RGV6", "RGV7");
                //WCS_DEVICEExtension.AddFlag(DF.BOPPRGV取货设备组, "G19", "G23");
                //WCS_DEVICEExtension.AddFlag(DF.BOPPRGV放货设备组, "G12", "G13", "G14", "G15", "G16");

                #endregion 设备扩展数据配置

                #region 启用所有的逻辑处理器

                var managerTypes = ReflectionHelper.GetTypesByImplementInterface<LogicHandler>().ToArray();
                foreach (var type in managerTypes)
                {
                    var m = Activator.CreateInstance(type);
                    LogicHandler.AddManager((m as LogicHandler)!);
                }

                LogicHandler.StartAll();

                #endregion 启用所有的逻辑处理器

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

        public override System.Threading.Tasks.Task StopAsync(CancellationToken cancellationToken)
        {
            _logger.LogError("WCS关闭");
            LogicHandler.StopAll();
            return base.StopAsync(cancellationToken);
        }
    }
}