IBCSystem.cs

using FLY.IBC.Common;
using FLY.IBC.IService;
using FLY.IBC.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.IBC.Server
{
    [JsonObject(MemberSerialization.OptIn)]
    public class IBCSystem : IIbcSystemService, IPropertyOpt
    {
        #region IIBCSystem

        #region IBC
        public bool HasIbc { get; private set; } = true;

        /// <summary>
        /// 数据
        /// </summary>
        public IBCData Item { get; } = new IBCData();

        #endregion

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

        #region 吸料
        /// <summary>
        /// 吸料机层数
        /// </summary>
        public int FeederCnt { get; private set; } = 0;

        /// <summary>
        /// 吸料
        /// </summary>
        public ObservableCollection<FeederData> FeederDatas { get; } = new ObservableCollection<FeederData>();

        /// <summary>
        /// 吸料报警
        /// </summary>
        public FeederWarningData FeederWarningData { get; } = new FeederWarningData();

        #endregion

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

        #endregion


        /// <summary>
        /// 报警系统
        /// </summary>
        WarningSystem2 warning;
        /// <summary>
        /// 记录到数据库
        /// </summary>
        HistoryDb historyDb;
        /// <summary>
        /// 报警配置
        /// </summary>
        ErrorConf errorConf;
        /// <summary>
        /// 周期保存Ibc数据
        /// </summary>
        PeriodicallySaveData<Db_Width> psdWidth;

        PLCGroup plcgroup;

        public IBCSystem()
        {
            Load();

            //--------------------------------------------------------------------------------
            //step 1 加载PLC寄存器 文件
            AddConfigFile();
        }
        public void Init(HistoryDb historyDb ,WarningSystem2 warning)
        {
            this.historyDb = historyDb;
            this.warning = warning;

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

            if (TAreasCnt > 0)
            {
                for (int i = 0; i < TAreas.Count(); i++)
                {
                    errorConf.AddErrorAction(
                        TAreas[i],
                            (ref string description, object state) =>
                            {
                                int idx = (int)state;
                                description = TAreas[idx].Number + "层 " + description;
                            },
                            i);
                }
            }

            if (FeederCnt > 0) {
                errorConf.AddErrorAction(FeederWarningData);

                for (int i = 0; i < FeederDatas.Count(); i++)
                {
                    errorConf.AddErrorAction(
                        FeederDatas[i],
                            (ref string description, object state) =>
                            {
                                int idx = (int)state;
                                description = FeederDatas[idx].Number + "层 " + description;
                            },
                            i);
                }
            }
            
            errorConf.InitError();

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

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


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

            //添加任务
            if (HasIbc)
            {
                PLCos.SetPlan(nameof(Item), new string[] {
                        nameof(IBCData.FilmWidth),
                        nameof(IBCData.InletAirFreq),
                        nameof(IBCData.OutletAirFreq),
                        //nameof(IBCData.ExAirFreq)
                    }, 0);

                psdWidth = new PeriodicallySaveData<Db_Width>();
                psdWidth.Init(
                    10,
                    this.historyDb.AddWidthRange,
                    () =>
                    {
                        if (!PLCos.IsConnectedWithPLC)
                            return null;

                        if (Item.InletAirFreq < 2 && Item.OutletAirFreq < 2)//没有工作！！！！
                        return null;

                    //记录数据
                    return new Db_Width()
                        {
                            Time = DateTime.Now,
                            FilmWidth = Math.Round(Item.FilmWidth, 1),
                            InletAirFreq = Math.Round(Item.InletAirFreq, 1),
                            OutletAirFreq = Math.Round(Item.OutletAirFreq, 1)
                        };
                    });
            }
            //--------------------------------------------------------------------------------
            //last step  PLC 更新计划服务初始化
            plcos.Init();

        }


        void AddConfigFile()
        {
            plcos.AddConfigFile("plcgroup.json", (plcgroup) =>
            {
                this.plcgroup = plcgroup;

                //从plcgroup 分析出 是否有IBC
                HasIbc = plcgroup.Variables.Any(var => var.OwnerName == nameof(Item));


                //从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 = Index2Number_tArea(i);
                    TempArea ta = new TempArea();
                    ta.Init(number);
                    TAreas.Add(ta);
                }

                //从plcgroup 分析出 有多少层吸料
                r = new Regex($@"{nameof(FeederDatas)}\[([0-9])\]");
                int feederCnt = 0;
                foreach (PLCGroup.PLCVariable var in plcgroup.Variables)
                {
                    Match m = r.Match(var.OwnerName);
                    if (m.Success)
                    {
                        int feeder_idx = int.Parse(m.Groups[1].Value);
                        if (feederCnt <= feeder_idx)
                            feederCnt = feeder_idx + 1;
                    }
                }
                FeederCnt = feederCnt;

                for (int i = 0; i < FeederCnt; i++)
                {
                    string number = Index2Number_feeder(i);
                    FeederData fd = new FeederData();
                    fd.Init(number);
                    FeederDatas.Add(fd);
                }


                if (HasIbc == false && TAreasCnt == 0 && FeederCnt == 0) {
                    //异常，什么都没有，加载文件有问题！！！！！！
                    throw new Exception("加载配置文件有问题, 没有IBC,没有温控,没有吸料");
                }

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

                objnames.Add(nameof(Item), Item);

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

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

                objnames.Add(nameof(FeederWarningData), FeederWarningData);
                
                return objnames;
            });

        }

        string Index2Number_tArea(int index)
        {
            string number;
            if (index == 0)
            {
                number = "M";
            }
            else
            {
                number = ((char)('A' + (index - 1))).ToString();
            }

            return number;
        }

        string Index2Number_feeder(int index)
        {
            string number;
            number = ((char)('A' + (index))).ToString();
            
            return number;
        }

        public event PropertyChangedEventHandler PropertyChanged;

        string filePath = "ibc.json";
        void Save()
        {
            string json = JsonConvert.SerializeObject(this, Formatting.Indented);
            File.WriteAllText(filePath, json);
        }
        void Load()
        {
            if (!File.Exists(filePath))
                return;
            string json = File.ReadAllText(filePath);
            try
            {
                JsonConvert.PopulateObject(json, this);
            }
            catch 
            {
            
            }
        }

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

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

}