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.ComponentModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FLY.IBC.Server
{
    [JsonObject(MemberSerialization.OptIn)]
    public class IBCSystem : IIBCSystemService
    {
        #region IIBCSystem
        /// <summary>
        /// 数据
        /// </summary>
        public IBCData Item { get; } = new IBCData();

        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;

        public IBCSystem()
        {
            Load();

            //加载PLC寄存器 文件
            AddConfigFile("WS.xml");
        }
        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(
                Item, ref code);

            errorConf.InitError();

            //--------------------------------------------------------------------------------
            //历史数据记录
            
            //添加任务
            PLCos.SetPlan("Item", new string[] {
                        "FilmWidth","InletAirFreq","OutletAirFreq"
                    }, 0);

            psdWidth = new PeriodicallySaveData<Db_Width>();
            psdWidth.Init(
                CtrlInterval,
                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)
                    };
                });
            //--------------------------------------------------------------------------------
            //PLC初始化
            plcos.Init();



        }
        
        void AddConfigFile(string configfile)
        {
            PLCGroup plcgroup = new PLCGroup();
            plcgroup.Load(configfile);

            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("Item", Item);


            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,
                    Item,
                    var.PropertyName);

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


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

}