using IStation.BLL;
using System.Collections.Generic;
using System.Linq;

namespace IStation.DataProvider
{
    /// <summary>
    /// 泵站 数据生成器
    /// </summary>
    public class StationGenerator
    {

        public Dictionary<long, string> MapperDict = new Dictionary<long, string>();


        /// <summary>
        /// 生成
        /// </summary>
        public static bool Creater()
        {

            var monitorPointGroups = new List<Model.MonitorPointGroup>();
            var monitorPointExSignals = new List<Model.MonitorPointExSignal>();

            var stations = new Station().GetAll();
            var station陈行二取 = stations?.Find(x => x.Name == "陈行二取");
            var station陈行一输 = stations?.Find(x => x.Name == "陈行一输");
            var station陈行二输 = stations?.Find(x => x.Name == "陈行二输");

            if (station陈行二取 != null)
            {
                var belongId = station陈行二取.ID;
                var g泵站 = BuildGroup("泵站", belongId, 1);
                var m长江水位 = BuildMonitorPoint(g泵站, "长江水位", belongId, IStation.SignalType.水位, 1, IStation.Flags.进口);
                var m二取水前池液位 = BuildMonitorPoint(g泵站, "二取水前池液位", belongId, IStation.SignalType.水位, 2, IStation.Flags.进口);
                var m陈行水库水位 = BuildMonitorPoint(g泵站, "陈行水库水位", belongId, IStation.SignalType.水位, 3, IStation.Flags.出口);


                monitorPointGroups.Add(g泵站);
                monitorPointExSignals.Add(m长江水位);
                monitorPointExSignals.Add(m二取水前池液位);
                monitorPointExSignals.Add(m陈行水库水位);
                for (int i = 1; i <= 5; i++)
                {
                    var group = BuildGroup($"{i}#机组", belongId, i);
                    var m运行状态 = BuildMonitorPoint(group, "运行状态", belongId, IStation.SignalType.运行状态, 1);
                    var m出水压力 = BuildMonitorPoint(group, "出水压力", belongId, IStation.SignalType.压力, 2, IStation.Flags.出口);
                    var m出水流量 = BuildMonitorPoint(group, "瞬时流量", belongId, IStation.SignalType.瞬时流量, 3, IStation.Flags.出口);
                    var m累积流量 = BuildMonitorPoint(group, "累积流量", belongId, IStation.SignalType.累积流量, 4);
                    var m有功功率 = BuildMonitorPoint(group, "有功功率", belongId, IStation.SignalType.有功功率, 5);
                    var m有功电度 = BuildMonitorPoint(group, "有功电度", belongId, IStation.SignalType.有功电度, 6);

                    monitorPointGroups.Add(group);
                    monitorPointExSignals.Add(m运行状态);
                    monitorPointExSignals.Add(m出水压力);
                    monitorPointExSignals.Add(m出水流量);
                    monitorPointExSignals.Add(m累积流量);
                    monitorPointExSignals.Add(m有功功率);
                    monitorPointExSignals.Add(m有功电度);
                }
            }

            if (station陈行一输 != null)
            {
                var belongId = station陈行一输.ID;
                var g泵站 = BuildGroup("泵站", belongId, 1);

                var m老前池南侧液位 = BuildMonitorPoint(g泵站, "老前池南侧液位", belongId, IStation.SignalType.水位, 1, IStation.Flags.进口);
                var m老前池北侧液位 = BuildMonitorPoint(g泵站, "老前池北侧液位", belongId, IStation.SignalType.水位, 2, IStation.Flags.进口);
                var m新前池液位 = BuildMonitorPoint(g泵站, "新前池液位", belongId, IStation.SignalType.水位, 3, IStation.Flags.进口);

                var m输水嘉定1线出口压力 = BuildMonitorPoint(g泵站, "嘉定1线出口压力", belongId, IStation.SignalType.压力, 4, IStation.Flags.出口);
                var m输水嘉定2线出口压力 = BuildMonitorPoint(g泵站, "嘉定2线出口压力", belongId, IStation.SignalType.压力, 5, IStation.Flags.出口);
                var m输水嘉定3线出口压力 = BuildMonitorPoint(g泵站, "嘉定3线出口压力", belongId, IStation.SignalType.压力, 6, IStation.Flags.出口);

                var m输水嘉定1线瞬时流量 = BuildMonitorPoint(g泵站, "嘉定1线瞬时流量", belongId, IStation.SignalType.瞬时流量, 7, IStation.Flags.出口);
                var m输水嘉定2线瞬时流量 = BuildMonitorPoint(g泵站, "嘉定2线瞬时流量", belongId, IStation.SignalType.瞬时流量, 8, IStation.Flags.出口);
                var m输水嘉定3线瞬时流量 = BuildMonitorPoint(g泵站, "嘉定3线瞬时流量", belongId, IStation.SignalType.瞬时流量, 9, IStation.Flags.出口);

                var m输水嘉定1线累计流量 = BuildMonitorPoint(g泵站, "嘉定1线累计流量", belongId, IStation.SignalType.累积流量, 10);
                var m输水嘉定2线累计流量 = BuildMonitorPoint(g泵站, "嘉定2线累计流量", belongId, IStation.SignalType.累积流量, 11);
                var m输水嘉定3线累计流量 = BuildMonitorPoint(g泵站, "嘉定3线累计流量", belongId, IStation.SignalType.累积流量, 12);

                monitorPointGroups.Add(g泵站);
                monitorPointExSignals.Add(m老前池南侧液位);
                monitorPointExSignals.Add(m老前池北侧液位);
                monitorPointExSignals.Add(m新前池液位);
                monitorPointExSignals.Add(m输水嘉定1线出口压力);
                monitorPointExSignals.Add(m输水嘉定2线出口压力);
                monitorPointExSignals.Add(m输水嘉定3线出口压力);
                monitorPointExSignals.Add(m输水嘉定1线瞬时流量);
                monitorPointExSignals.Add(m输水嘉定2线瞬时流量);
                monitorPointExSignals.Add(m输水嘉定3线瞬时流量);
                monitorPointExSignals.Add(m输水嘉定1线累计流量);
                monitorPointExSignals.Add(m输水嘉定2线累计流量);
                monitorPointExSignals.Add(m输水嘉定3线累计流量);

                var index = 2;
                for (int i = 11; i <= 18; i++)
                {
                    var index2 = 1;
                    var group = BuildGroup($"{i}#机组", belongId, index++);
                    var m运行状态 = BuildMonitorPoint(group, "运行状态", belongId, IStation.SignalType.运行状态, index2++);
                    var m出水压力 = BuildMonitorPoint(group, "出水压力", belongId, IStation.SignalType.压力, index2++, IStation.Flags.出口);
                    if (i != 15 && i != 16)
                    {
                        var m转速 = BuildMonitorPoint(group, "转速", belongId, IStation.SignalType.转速, index2++);
                        monitorPointExSignals.Add(m转速);
                    }
                    var m有功功率 = BuildMonitorPoint(group, "有功功率", belongId, IStation.SignalType.有功功率, index2++);
                    var m有功电度 = BuildMonitorPoint(group, "有功电度", belongId, IStation.SignalType.有功电度, index2++);


                    monitorPointGroups.Add(group);
                    monitorPointExSignals.Add(m运行状态);
                    monitorPointExSignals.Add(m出水压力);
                    monitorPointExSignals.Add(m有功功率);
                    monitorPointExSignals.Add(m有功电度);

                }
            }

            if (station陈行二输 != null)
            {
                var belongId = station陈行二输.ID;
                var g泵站 = BuildGroup("泵站", belongId, 1);

                var m2400总管出口压力 = BuildMonitorPoint(g泵站, "2400总管出口压力", belongId, IStation.SignalType.压力, 1, IStation.Flags.出口);
                var m2700总管出口压力 = BuildMonitorPoint(g泵站, "2700总管出口压力", belongId, IStation.SignalType.压力, 2, IStation.Flags.出口);

                var m2400总管瞬时流量 = BuildMonitorPoint(g泵站, "2400总管瞬时流量", belongId, IStation.SignalType.瞬时流量, 3, IStation.Flags.出口);
                var m2700总管瞬时流量 = BuildMonitorPoint(g泵站, "2700总管瞬时流量", belongId, IStation.SignalType.瞬时流量, 4, IStation.Flags.出口);

                var m2400总管累计流量 = BuildMonitorPoint(g泵站, "2400总管累计流量", belongId, IStation.SignalType.累积流量, 5);
                var m2700总管累计流量 = BuildMonitorPoint(g泵站, "2700总管累计流量", belongId, IStation.SignalType.累积流量, 6);

                monitorPointExSignals.Add(m2400总管出口压力);
                monitorPointExSignals.Add(m2700总管出口压力);
                monitorPointExSignals.Add(m2400总管瞬时流量);
                monitorPointExSignals.Add(m2700总管瞬时流量);
                monitorPointExSignals.Add(m2400总管累计流量);
                monitorPointExSignals.Add(m2700总管累计流量);

                monitorPointGroups.Add(g泵站);
                var index = 2;
                for (int i = 21; i <= 27; i++)
                {
                    var index2 = 1;
                    var group = BuildGroup($"{i}#机组", belongId, index++);
                    var m泵井液位 = BuildMonitorPoint(group, "泵井液位", belongId, IStation.SignalType.水位, index2++, IStation.Flags.进口);
                    var m运行状态 = BuildMonitorPoint(group, "运行状态", belongId, IStation.SignalType.运行状态, index2++);
                    var m出水压力 = BuildMonitorPoint(group, "出水压力", belongId, IStation.SignalType.压力, index2++, IStation.Flags.出口);
                    var m出水流量 = BuildMonitorPoint(group, "瞬时流量", belongId, IStation.SignalType.瞬时流量, index2++, IStation.Flags.出口);
                    var m累积流量 = BuildMonitorPoint(group, "累积流量", belongId, IStation.SignalType.累积流量, index2++);
                    var m转速 = BuildMonitorPoint(group, "转速", belongId, IStation.SignalType.转速, index2++);
                    var m有功功率 = BuildMonitorPoint(group, "有功功率", belongId, IStation.SignalType.有功功率, index2++);
                    var m有功电度 = BuildMonitorPoint(group, "有功电度", belongId, IStation.SignalType.有功电度, index2++);

                    monitorPointGroups.Add(group);
                    monitorPointExSignals.Add(m泵井液位);
                    monitorPointExSignals.Add(m运行状态);
                    monitorPointExSignals.Add(m出水压力);
                    monitorPointExSignals.Add(m出水流量);
                    monitorPointExSignals.Add(m累积流量);
                    monitorPointExSignals.Add(m转速);
                    monitorPointExSignals.Add(m有功功率);
                    monitorPointExSignals.Add(m有功电度);
                }
            }

            if (monitorPointGroups.Any())
            {
                if (!new BLL.MonitorPointGroup().Covers(monitorPointGroups))
                {
                    return false;
                };
            }

            if (monitorPointExSignals.Any())
            {
                if (!new BLL.MonitorPoint().CoverExs(monitorPointExSignals))
                {
                    return false;
                };
            }

            return true;
        }


        private static Model.MonitorPointGroup BuildGroup(string name, long belongId, int sortCode)
        {
            var model = new Model.MonitorPointGroup();
            model.ID = SnowflakeIdHelper.NextId();
            model.BelongType = IStation.ObjectType.Station;
            model.BelongID = belongId;
            model.Name = name;
            model.SortCode = sortCode;
            return model;
        }

        private static Model.MonitorPointExSignal BuildMonitorPoint(Model.MonitorPointGroup group, string name, long belongId, string signalType, int sortCode, string flag = null)
        {
            var model = new Model.MonitorPointExSignal();
            model.MonitorPointID = SnowflakeIdHelper.NextId();
            model.SignalID = SnowflakeIdHelper.NextId();
            model.Name = name;

            model.BelongType = IStation.ObjectType.Station;
            model.BelongID = belongId;
            model.GroupID = group.ID;
            model.SourceType = Model.eSourceType.Docking;
            model.SerialNO = 1;
            model.SortCode = sortCode;
            model.Importance = 1;
            if (flag != null)
            {
                model.Flags = new List<string>() { flag };
            }
            model.UseStatus = Model.eUseStatus.Enable;
            model.SignalType = signalType;
            return model;
        }



    }
}