IntegratedSystem.cs

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

namespace FLY.Integrated.Server
{
    [JsonObject(MemberSerialization.OptIn)]
    public class IntegratedSystem : IIntegratedSystemService
    {
        #region IIntegratedSystemService
        /// <summary>
        /// 数据
        /// </summary>
        public IbcData Ibc { get; } = new IbcData();

        /// <summary>
        ///  收卷
        /// </summary>
        public WinderAccessory Accessory { get; } = new WinderAccessory();
        private int ctrlInterval = 5;
        /// <summary>
        /// 控制记录周期,单位s, 最小值为2
        /// </summary>
        [JsonProperty]
        public int CtrlInterval
        {
            get { return ctrlInterval; }
            set
            {
                if (value < 2)
                    value = 2;
                if (ctrlInterval != value)
                {
                    ctrlInterval = value;
                }
            }
        }


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

        #endregion

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

        /// <summary>
        /// 周期保存Ibc数据
        /// </summary>
        PeriodicallySaveData<Db_Width> psdWidth;

        /// <summary>
        /// 周期保存收卷数据
        /// </summary>
        PeriodicallySaveData<Db_WinderInfo> psdWinderInfo;

        public event PropertyChangedEventHandler PropertyChanged;

        public IntegratedSystem()
        {
            Load();

            //加载PLC寄存器 文件
            AddConfigFile("WS.json");
        }
        public void Init(HistoryDb historyDb, WarningSystem warning) 
        {
            this.historyDb = historyDb;
            this.warning = warning;


            //--------------------------------------------------------------------------------
            //报警配置
            errorConf = new ErrorConf(PLCos, this.warning, "综合IBC");

            byte code = 0;
            errorConf.AddErrorAction(
                Accessory, ref code);

            errorConf.AddErrorAction(
                Ibc, ref code);

            errorConf.InitError();


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

            //添加任务
            PLCos.SetPlan("Ibc", new string[] {
                        "FilmWidth","InletAirFreq","OutletAirFreq","ExCoolFreq"
                    }, 0);

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

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

                    //记录数据
                    return new Db_Width()
                    {
                        Time = DateTime.Now,
                        FilmWidth = Math.Round(Ibc.FilmWidth, 1),
                        InletAirFreq = Math.Round(Ibc.InletAirFreq, 1),
                        OutletAirFreq = Math.Round(Ibc.OutletAirFreq, 1),
                        ExCoolFreq = Math.Round(Ibc.ExCoolFreq, 1)
                    };
                });

            PLCos.SetPlan("Accessory", new string[] {
                        "TractionVelocity","RotaryFreq","IsRotaryForw","IsRotaryBackw"
                    }, 0);

            psdWinderInfo = new PeriodicallySaveData<Db_WinderInfo>();
            psdWinderInfo.Init(
                10,
                this.historyDb.AddWinderInfos,
                () => {
                    if (!PLCos.IsConnectedWithPLC)
                        return null;

                    if (Accessory.TractionVelocity < 1 )//没有工作！！！！
                        return null;

                    //记录数据
                    return new Db_WinderInfo()
                    {
                        Time = DateTime.Now,
                        TractionVelocity = Math.Round(Accessory.TractionVelocity, 1),
                        RotaryFreq = Math.Round(Accessory.RotaryFreq, 1),
                        IsRotaryBackw = Accessory.IsRotaryBackw,
                        IsRotaryForw = Accessory.IsRotaryForw
                    };
                });

            //--------------------------------------------------------------------------------
            //注册通知事件
            plcos.Init();
        }

        void AddConfigFile(string configfile)
        {
            PLCGroup plcgroup = new PLCGroup();
            string json = File.ReadAllText(configfile);
            JsonConvert.PopulateObject(json, plcgroup);

            foreach (PLCGroup.PLCDevice device in plcgroup.Devices)
            {
                var plc = new Modbus.WithThread.ModbusMapper_Client(device.EP);
                plcos.PLCs.Add(plc);
            }

            //objname 转 obj
            PLCos.ObjNames.Add("Ibc", Ibc);
            PLCos.ObjNames.Add("Accessory", Accessory);

            foreach (PLCGroup.PLCVariable var in plcgroup.Variables)
            {
                if (var.DeviceIndex < 0 || var.DeviceIndex >= plcos.PLCs.Count)
                    continue;

                List<Modbus.DataToRegs> drs = plcos.DRMap;
                var plc = plcos.PLCs[var.DeviceIndex];

                Modbus.DataToRegs dr = plc.MapDataToRegs(
                    ModbusMapper.TranslateToPLCAddressArea(var.Mode),
                    var.Addr,
                    ModbusMapper.TranslateToREG_TYPE(var.Type),
                    var.Scale,
                    PLCos.ObjNames[var.OwnerName],
                    var.PropertyName);

                if (dr != null)
                    drs.Add(dr);
            }
            foreach (var plc in plcos.PLCs)
                plc.Build();
        }

        void Save()
        {
            string json = JsonConvert.SerializeObject(this, Formatting.Indented);
            File.WriteAllText("integrated.json", json);
        }
        void Load()
        {

            if (File.Exists("integrated.json"))
            {
                try
                {
                    string json = File.ReadAllText("integrated.json");
                    JsonConvert.PopulateObject(json, this);
                }
                catch
                {

                }
            }

        }
    }



}