ZT_FJ_SJCL/WCS.WorkEngineering/WorkStart.cs

using ServiceCenter;
using ServiceCenter.SqlSugars;
using WCS.Core;
using WCS.Entity.Protocol;
using WCS.Entity.Protocol.BCR;
using WCS.Entity.Protocol.HUB;
using WCS.Entity.Protocol.RGV;
using WCS.Entity.Protocol.Robot;
using WCS.Entity.Protocol.SRM;
using WCS.Entity.Protocol.Station;
using WCS.Entity.Protocol.Truss;
using WCS.WorkEngineering.Extensions;
using DeviceFlags = WCS.WorkEngineering.Extensions.DeviceFlags;

namespace WCS.WorkEngineering
{
    /// <summary>
    /// 业务工程配置信息
    /// </summary>
    public static class WorkStart
    {
        /// <summary>
        ///  初始化 设备信息
        /// </summary>

        public static void InitializeDeviceInfo()
        {
            var conv = new Device("1");
            conv.AddFlag(DeviceFlags.输送机);
            conv.AddProtocol<IStation520>(0, 520, "1");
        }

        /// <summary>
        ///  初始化数据库连接
        /// </summary>
        /// <param name="datas"></param>
        public static void InitDB(this List<DataBaseConnectionString> datas)
        {
            //初始化数据库
            SqlSugarHelper.Do(db =>
            {
                foreach (var connectionString in datas!)
                {
                    var _db = db.Connect.GetConnectionScope(connectionString.Key);
                    switch (connectionString.Key)
                    {
                        case "WCSDB"://WCS基本数据库
                            //SqlSugarHelper.SetDefault(connectionString.Key);
                            //_db.CodeFirst.InitTables(typeof(WCS_PlcData));
                            //_db.CodeFirst.InitTables(typeof(WCS_TaskInfo));
                            //_db.CodeFirst.InitTables(typeof(WCS_TaskDtl));
                            //_db.CodeFirst.InitTables(typeof(WCS_TaskOld));
                            //_db.CodeFirst.InitTables(typeof(WCS_AgvTaskInfo));
                            //_db.CodeFirst.InitTables(typeof(WCS_Palletizing));
                            //_db.CodeFirst.InitTables(typeof(WCS_PalletizingLayer));
                            //_db.CodeFirst.InitTables(typeof(WCS_PalletizingRow));
                            //_db.CodeFirst.InitTables(typeof(WCS_PalletizingLoc));
                            //_db.CodeFirst.InitTables(typeof(WCS_CacheLine));
                            //_db.CodeFirst.InitTables(typeof(WCS_CacheLineLoc));

                            break;

                        case "WCSDlog"://WCS日志数据库

                            break;

                        case "PLC"://PLC

                            SqlSugarHelper.SetPLC(connectionString.Key);

                            _db.DbMaintenance.CreateDatabase();
                            _db.CodeFirst.InitTables<WCS_Log>();
                            _db.CodeFirst.InitTables<WCS_SRM520>();
                            _db.CodeFirst.InitTables<DevRunInfo>();
                            _db.CodeFirst.InitTables<WCS_SRM521>();
                            _db.CodeFirst.InitTables<WCS_SRM537>();
                            _db.CodeFirst.InitTables<WCS_RGV520>();
                            _db.CodeFirst.InitTables<WCS_RGV521>();
                            _db.CodeFirst.InitTables<WCS_BCR80>();
                            _db.CodeFirst.InitTables<WCS_BCR81>();
                            _db.CodeFirst.InitTables<WCS_BCR83>();
                            _db.CodeFirst.InitTables<WCS_Station520>();
                            _db.CodeFirst.InitTables<WCS_Station521>();
                            _db.CodeFirst.InitTables<WCS_Station523>();
                            _db.CodeFirst.InitTables<WCS_Station524>();
                            _db.CodeFirst.InitTables<WCS_Station525>();
                            _db.CodeFirst.InitTables<WCS_Station90>();
                            _db.CodeFirst.InitTables<WCS_Station91>();
                            _db.CodeFirst.InitTables<WCS_Truss520>();
                            _db.CodeFirst.InitTables<WCS_Truss521>();
                            _db.CodeFirst.InitTables<WCS_Truss523>();
                            _db.CodeFirst.InitTables<WCS_Truss530>();
                            _db.CodeFirst.InitTables<WCS_Truss531>();
                            _db.CodeFirst.InitTables<WCS_Robot520>();
                            _db.CodeFirst.InitTables<WCS_Robot521>();
                            _db.CodeFirst.InitTables<WCS_Robot522>();
                            _db.CodeFirst.InitTables<WCS_Robot530>();
                            _db.CodeFirst.InitTables<WCS_Robot531>();
                            var a = false;
                            break;

                        default: //其他库
                            break;
                    };
                };
            });
        }
    }

    public class DevDbConfig<T>
    {
        public DevDbConfig()
        {
        }

        public DevDbConfig(string ip, T code)
        {
            IP = ip;
            Code = code;
        }

        public DevDbConfig(string ip, List<DevInterval<T>> devIntervalList)
        {
            IP = ip;
            DevIntervalList = devIntervalList;
        }

        public DevDbConfig(string ip, List<T> devCodeList)
        {
            IP = ip;
            DevCodeList = devCodeList;
        }

        public string IP { get; set; }

        public T Code { get; set; }

        public T StartCode { get; set; }

        public T EndCode { get; set; }

        public List<T> DevCodeList { get; set; }

        public List<DevInterval<T>> DevIntervalList { get; set; }
    }

    public class DevInterval<T>
    {
        public DevInterval(T s, T e)
        {
            StartCode = s;
            EndCode = e;
        }

        public T StartCode { get; set; }

        public T EndCode { get; set; }
    }
}