DownBlowingSystemServiceClient.cs

using FLY.DownBlowing.Common;
using FLY.DownBlowing.IService;
using FLY.OBJComponents.Client;
using FLY.OBJComponents.IService;
using FObjBase;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FLY.DownBlowing.Client
{
    public class DownBlowingSystemServiceClient : FObjServiceClient, IDownBlowingSystemService, IPropertyOpt
    {
        #region IDownBlowingSystemService
        /// <summary>
        /// 挤出机层数
        /// </summary>
        public int TAreasCnt { get; set; } = 8;

        /// <summary>
        /// 收卷
        /// </summary>
        public WinderData WinderData { get; } = new WinderData();

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

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

        /// <summary>
        /// 挤出温控
        /// </summary>
        public ObservableCollection<TempArea> TAreas { get; } = new ObservableCollection<TempArea>();

        PLCProxySystemServiceClient plcos;
        public IPLCProxySystemService PLCos => plcos;

        #endregion

        SyncPropServiceClient syncPropServiceClient;

        public event Action ResetItemsEvent;

        /// <summary>
        /// 当前 INotifyPropertyChanged 对象 引发了 PropertyChanged,  是由于 接收到数据导致的
        /// </summary>
        public bool IsInPushValue
        {
            get
            {
                return syncPropServiceClient.IsInPushValue;
            }
        }

        public DownBlowingSystemServiceClient(UInt32 serviceId) : base(serviceId)
        {
            Init();
        }
        public DownBlowingSystemServiceClient(UInt32 serviceId, string connName) : base(serviceId)
        {
            Init();
            ConnName = connName;
            FObjServiceClientManager.Instance.Connect_to_Another_OBJSys(connName, this);
        }
        void TAreasAdd(int i)
        {
            string number = Index2Number(i);

            //少了，需要添加
            var tarea = new TempArea();

            tarea.Init(number);

            TAreas.Add(tarea);
        }
        string Index2Number(int index)
        {
            string number;
            if (index == 0)
            {
                number = "M";
            }
            else
            {
                number = ((char)('A' + (index - 1))).ToString();
            }
            return number;
        }

        void FeederDatasAdd(int i) {
            string number = Index2Number(i+1);
            var feederData = new FeederData();

            feederData.Init(number);

            FeederDatas.Add(feederData);
        }
        void Init()
        {
            Load();
            if (TAreasCnt <= 1)
                TAreasCnt = 0;

            for (int i = 0; i < TAreasCnt; i++)
            {
                TAreasAdd(i);
            }
            for (int i = 0; i < TAreasCnt-1; i++)
            {
                FeederDatasAdd(i);
            }

            //--------------------------------------------------------------
            //属性同步
            Dictionary<string, INotifyPropertyChanged> objnames = GetObjNames();
            objnames.Add(".", this);

            syncPropServiceClient = new SyncPropServiceClient(mServerID + 1, objnames);
            //--------------------------------------------------------------
            //PLC代理，用于添加更新任务

            objnames = GetObjNames();
            plcos = new PLCProxySystemServiceClient(mServerID + 2);


            this.PropertyChanged += DownBlowingSystemServiceClient_PropertyChanged;
        }
        Dictionary<string, INotifyPropertyChanged> GetObjNames() 
        {
            Dictionary<string, INotifyPropertyChanged> objnames = new Dictionary<string, INotifyPropertyChanged>();

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

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

            return objnames;
        }
        string filePath = "downBlowingSystemClient.json";
        void Save()
        {
            DownBlowingSystemServiceClientJsonDb.Save(this, filePath);
        }
        void Load()
        {
            DownBlowingSystemServiceClientJsonDb.Load(this, filePath);

        }

        private void DownBlowingSystemServiceClient_PropertyChanged(object sender, PropertyChangedEventArgs e)
        {
            if (e.PropertyName == nameof(TAreasCnt))
            {
                if (IsTAreasCntChanged())
                {
                    ResetTAreas();
                    Save();
                }
            }
        }

        bool IsTAreasCntChanged()
        {
            if (TAreas.Count() != TAreasCnt)
                return true;
            else
                return false;
        }
        /// <summary>
        /// 重新创建 Items
        /// </summary>
        void ResetTAreas()
        {
            if (TAreas.Count() == TAreasCnt)
                return;

            int last_tAreasCnt = TAreas.Count();
            int remove_cnt = TAreas.Count() - TAreasCnt;
            
            if (remove_cnt > 0)
            {
                //多出来的Item 都要删除
                for (int i = 0; i < remove_cnt; i++)
                {
                    int index = TAreas.Count() - 1;
                    TAreas.RemoveAt(index);
                    string objname = $"{nameof(TAreas)}[{index}]";
                    syncPropServiceClient.Remove(objname);
                }

                for (int i = 0; i < remove_cnt; i++)
                {
                    int index = FeederDatas.Count() - 1;
                    FeederDatas.RemoveAt(index);
                    string objname = $"{nameof(FeederDatas)}[{index}]";
                    syncPropServiceClient.Remove(objname);
                }
            }
            else if (remove_cnt < 0)
            {
                //少了，需要添加
                for (int i = 0; i < -remove_cnt; i++)
                {
                    int index = TAreas.Count();
                    TAreasAdd(index);

                    string objname = $"{nameof(TAreas)}[{index}]";
                    syncPropServiceClient.Add(objname, TAreas[index]);
                }


                for (int i = 0; i < -remove_cnt; i++)
                {
                    int index = FeederDatas.Count();
                    FeederDatasAdd(index);

                    string objname = $"{nameof(FeederDatas)}[{index}]";
                    syncPropServiceClient.Add(objname, FeederDatas[index]);
                }
            }

            ResetItemsEvent?.Invoke();
            return;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public override UInt32[] GetIDs()
        {
            List<UInt32> IDs = new List<uint>();
            IDs.Add(ID);
            IDs.Add(syncPropServiceClient.ID);
            IDs.AddRange(((PLCProxySystemServiceClient)PLCos).GetIDs());
            return IDs.ToArray();
        }

        public override void ConnectNotify(IFConn from)
        {
            base.ConnectNotify(from);
            if (from.IsConnected)
            {
                CurrObjSys.SenseConfigEx(mConn, mServerID, ID,
                    0xffffffff, SENSE_CONFIG.ADD);
            }
        }

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

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

    public class DownBlowingSystemServiceClientJsonDb
    {
        public int TAreasCnt;

        public static bool Save(DownBlowingSystemServiceClient src, string filePath)
        {
            try
            {
                DownBlowingSystemServiceClientJsonDb jsonDb = new DownBlowingSystemServiceClientJsonDb()
                {
                    TAreasCnt = src.TAreasCnt
                };
                string json = Newtonsoft.Json.JsonConvert.SerializeObject(jsonDb);
                File.WriteAllText(filePath, json);
                return true;
            }
            catch {
                return false;
            }

        }
        public static bool Load(DownBlowingSystemServiceClient src, string filePath)
        {
            if (!File.Exists(filePath))
                return false;
            try
            {
                string json = File.ReadAllText(filePath);
                var p = Newtonsoft.Json.JsonConvert.DeserializeObject<DownBlowingSystemServiceClientJsonDb>(json);
                src.TAreasCnt = p.TAreasCnt;
                return true;
            }
            catch
            {
                //失败就算了。。。
                return false;
            }

        }
    }
}