DownBlowingSystem.cs

using FLY.DownBlowing.Common;
using FLY.DownBlowing.IService;
using FLY.DownBlowing.Server.Model;
using FLY.Modbus;
using FLY.OBJComponents.Common;
using FLY.OBJComponents.IService;
using FLY.OBJComponents.Server;
using FObjBase;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;

namespace FLY.DownBlowing.Server
{

    public class DownBlowingSystem : IDownBlowingSystemService, IPropertyOpt
    {
        #region IDownBlowingSystemService


        /// <summary>
        /// 收卷综合
        /// </summary>
        public WinderAccessory WinderAccessory { get; } = new WinderAccessory();

        /// <summary>
        /// 内收卷 外收卷
        /// </summary>
        public List<WinderInsideOutside> WIOs { get; private set; } = new List<WinderInsideOutside>() { new WinderInsideOutside(), new WinderInsideOutside() };

        /// <summary>
        /// 外冷 
        /// </summary>
        public IbcData IbcData { get; } = new IbcData();


        #region 挤出温控
        /// <summary>
        /// 层数
        /// </summary>
        public int TAreasCnt { get; private set; } = 10;
        /// <summary>
        /// 挤出温控
        /// </summary>
        public ObservableCollection<TempArea> TAreas { get; } = new ObservableCollection<TempArea>();
        #endregion


        public PLCProxySystem plcos = new PLCProxySystem();
        /// <summary>
        /// PLC代理系统
        /// </summary>
        public IPLCProxySystemService PLCos { get { return plcos; } }

        /// <summary>
        /// 版本
        /// </summary>
        public string Version { get; set; } = "3";

        #endregion


        /// <summary>
        /// 报警系统
        /// </summary>
        WarningSystem2 warning;
        /// <summary>
        /// 记录到数据库
        /// </summary>
        HistoryDb historyDb;
        /// <summary>
        /// 报警配置
        /// </summary>
        ErrorConf errorConf;

        PLCGroup plcgroup;
        public DownBlowingSystem()
        {

        }
        public void Init(HistoryDb historyDb ,WarningSystem2 warning)
        {

            this.historyDb = historyDb;
            this.warning = warning;

            //--------------------------------------------------------------------------------
            //step 1 加载PLC寄存器 文件
            AddConfigFile();

            //--------------------------------------------------------------------------------
            //step 2 报警配置
            errorConf = new ErrorConf(plcos, this.warning, plcgroup.Devices.Select(d=>d.PlcName).ToArray());

            errorConf.AddErrorAction(WinderAccessory);
            errorConf.AddErrorAction(IbcData);

            WIOs[0].Init("外");
            WIOs[1].Init("内");

            foreach (var wio in WIOs) 
            {
                errorConf.AddErrorAction(wio,
                    (ref string description, object state) => {
                        var w = state as WinderInsideOutside;
                        description = w.Number + description;
                    }, wio);
            }

            foreach (var tarea in TAreas)
            {
                errorConf.AddErrorAction(tarea,
                        (ref string description, object state) => {
                            var ta = state as TempArea;
                            description = ta.Number + "区 " + description;
                        },
                        tarea);
            }

            errorConf.InitError();

            Misc.BindingOperations.SetBinding(this.warning, nameof(this.warning.IsRinging), () =>
            {
                if (!this.warning.IsRinging)
                {
                    WinderAccessory.ErrorReset = true;
                    WinderAccessory.ErrorReset = false;

                    //把全部报警都复位, 当复位无效，该属性还是true，下次查寄存器时，还是能触发报警
                    errorConf.ResetError();
                }
            });


            //--------------------------------------------------------------------------------
            //step 3 历史数据记录

            //添加任务
            PLCos.SetPlan(nameof(WinderAccessory), new string[] {
                        nameof(WinderAccessory.IsRotaryOn),
                        nameof(WinderAccessory.T1Velocity),
                        nameof(WinderAccessory.RotaryFreqSet),
                        nameof(WinderAccessory.RotaryFreq),
                        nameof(WinderAccessory.IsRotaryForw),
                        nameof(WinderAccessory.IsRotaryBackw),
                        nameof(WinderAccessory.IsRotaryBackwTurn),
                        nameof(WinderAccessory.IsRotaryForwTurn),
                        nameof(WinderAccessory.IsRotaryOrgSign)
                    }, 0);

            //--------------------------------------------------------------------------------
            //last step  PLC 更新计划服务初始化
            plcos.Init();


        }
        string TAreaIndex2Number(int index) 
        {
            string number;
            if (index == 0)
            {
                number = "M";
            }
            else
            {
                number = ((char)('A' + (index - 1))).ToString();
            }
            return number;
        }
        void AddConfigFile()
        {
            plcos.AddConfigFile("plcgroup.json", (plcgroup) =>
            {
                this.plcgroup = plcgroup;

                Version = plcgroup.Version;

                //从plcgroup 分析出 有多少层，每层的仓数
                //温控
                Regex r = new Regex($@"{nameof(TAreas)}\[([0-9])\]");
                int tAreasCnt = 0;
                foreach (PLCGroup.PLCVariable var in plcgroup.Variables)
                {
                    Match m = r.Match(var.OwnerName);
                    if (m.Success)
                    {
                        int tArea_idx = int.Parse(m.Groups[1].Value);
                        if (tAreasCnt <= tArea_idx)
                            tAreasCnt = tArea_idx + 1;
                    }
                }
                TAreasCnt = tAreasCnt;



                for (int i = 0; i < TAreasCnt; i++)
                {
                    string number = TAreaIndex2Number(i);
                    TempArea ta = new TempArea();
                    ta.Init(number);
                    TAreas.Add(ta);
                }

                //objname 转 obj
                Dictionary<string, INotifyPropertyChanged> objnames = new Dictionary<string, INotifyPropertyChanged>();

                objnames.Add(nameof(WinderAccessory), WinderAccessory);
                objnames.Add(nameof(IbcData), IbcData);

                for(int i=0;i<WIOs.Count();i++)
                    objnames.Add($"{nameof(WIOs)}[{i}]", WIOs[i]);

                if (TAreas != null)
                {
                    for (int i = 0; i < TAreas.Count(); i++)
                        objnames.Add($"{nameof(TAreas)}[{i}]", TAreas[i]);
                }

                return objnames;
            });

        }

        public event PropertyChangedEventHandler PropertyChanged;

        public string[] GetSyncPropNames()
        {
            return new string[]{
                nameof(TAreasCnt),
                nameof(Version)
                };
        }

        public string[] GetNoSyncPropNames()
        {
            return null;
        }
    
        
    }
}