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.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";

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

            #region 启用日志

            var logConfig = JsonConvert.DeserializeObject<LogConfig>(await File.ReadAllTextAsync("config.json", Encoding.Default, stoppingToken));
            LogHelper.SetConfigInfo(logConfig!);

            #endregion 启用日志

            InfoLog.INFO_INIT("1111");

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

            #region 需要改成循环遍历，以实现根据配置项完成多个数据库链接创建

            Db.CreateContext(new ConnectionConfig()
            {
                ConnectionString = AppSettings.Config.GetConnectionString("WCSDB"),
                DbType = DbType.SqlServer
            }, "WCSDB");
            Db.SetDefaultDbContextType("WCSDB");
            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));
            });

            Db.CreateContext(new ConnectionConfig()
            {
                ConnectionString = AppSettings.Config.GetConnectionString(WcsDlog),
                DbType = DbType.PostgreSQL
            }, WcsDlog);

            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));
            });

            #endregion 需要改成循环遍历，以实现根据配置项完成多个数据库链接创建

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

            PlcData.Init("127.0.0.1,database=0").InitPlcData(list);
            //日志发布事件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);
            };

            //LogicHandler.DbLog = Helpers.LogHelper.AddWCS_EXCEPTION;

            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();
                    items.Select(v => v.Data()).ToArray();
                    LogicHandler.AllObjects.AddRange(items);

                    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启动成功");
                //InfoLog.INFO_INIT("WCS启动成功");
            }
            catch (Exception ex)
            {
                _logger.LogError("WCS启动失败{0}", ex.Message);
                //InfoLog.INFO_INIT($"WCS启动失败{ex.Message}");
            }
        }

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