TempAreaPanel2.xaml.cs

using FLY.DownBlowing.Client;
using FLY.DownBlowing.Common;
using FLY.DownBlowing.IService;
using FLY.OBJComponents.Client;
using FLY.OBJComponents.IService;
using MultiLayout.UiModule;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Threading;
using Unity;

namespace FLY.DownBlowing.UI.Client.UiModule
{
    /// <summary>
    /// TempAreaPanel.xaml 的交互逻辑
    /// </summary>
    public partial class TempAreaPanel2 : UserControl
    {
        IDownBlowingSystemService downBlowingSystemService;
        IUnityContainer container;
        List<SetPLCUpdatePlan> setPlan_items = new List<SetPLCUpdatePlan>();

        static string[] update_propertynames;
        static TempAreaPanel2()
        {
            string[] propertynames = new string[] {
                nameof(Common.TempArea.TempPV1),
                nameof(Common.TempArea.TempSV1),
                nameof(Common.TempArea.IsHeating1),
                nameof(Common.TempArea.IsHeatingSet1),
                nameof(Common.TempArea.IsCooling1),
                nameof(Common.TempArea.IsSelfAdjusting1)
            };
            List<string> update_propertynames = new List<string>();
            for (int i = 0; i < 6; i++)
            {
                for (int j = 0; j < propertynames.Count(); j++)
                {
                    update_propertynames.Add(propertynames[j].Replace("1", (i + 1).ToString()));
                }
            }
            update_propertynames.Add(nameof(Common.TempArea.MeltingTemp));

            TempAreaPanel2.update_propertynames = update_propertynames.ToArray();
        }
        public TempAreaPanel2()
        {
            InitializeComponent();
        }


        [InjectionMethod]
        public void Init(
            IUnityContainer container,
            IDownBlowingSystemService downBlowingSystemService)
        {
            this.downBlowingSystemService = downBlowingSystemService;
            this.container = container;
            this.DataContext = this.downBlowingSystemService;

            if (this.downBlowingSystemService is DownBlowingSystemServiceClient)
            {
                (this.downBlowingSystemService as DownBlowingSystemServiceClient).ResetTAreasEvent += MWeighterCsService_ResetItemsEvent;
            }
        }

        private void MWeighterCsService_ResetItemsEvent()
        {
            if (setPlan_items.Count() == 0)
                return;//从来没注册

            //把多出来的删除
            int remove_cnt = setPlan_items.Count() - this.downBlowingSystemService.TAreas.Count();
            if (remove_cnt > 0)
            {
                for (int i = 0; i < remove_cnt; i++)
                {
                    SetPLCUpdatePlan plan = setPlan_items[setPlan_items.Count() - 1 - i];
                    plan.Dispose();
                }
                setPlan_items.RemoveRange(setPlan_items.Count() - remove_cnt, remove_cnt);
            }
            else
            {
                int start_idx = setPlan_items.Count();
                int add_cnt = -remove_cnt;
                for (int i = 0; i < add_cnt; i++)
                {
                    string objname = $"{nameof(IDownBlowingSystemService.TAreas)}[{start_idx + i}]";

                    SetPLCUpdatePlan plan = new SetPLCUpdatePlan(
                        this.downBlowingSystemService.PLCos,
                        objname,
                        update_propertynames);
                    setPlan_items.Add(plan);
                }
            }
        }

        private void btnTAreaClick(object sender, RoutedEventArgs e)
        {
            var button = sender as Button;
            var tempArea = button.Tag as TempArea;
            WdTempAreaSet w = new WdTempAreaSet();
            w.Init(this.downBlowingSystemService, tempArea);
            w.Owner = FLY.ControlLibrary.COMMON.GetWindow(this);
            w.ShowDialog();
        }

        private void UserControl_Loaded(object sender, RoutedEventArgs e)
        {
            if (setPlan_items.Count() == 0) {
                for (int i = 0; i < this.downBlowingSystemService.TAreas.Count(); i++)
                {
                    string objname = $"{nameof(IDownBlowingSystemService.TAreas)}[{i}]";
                    SetPLCUpdatePlan plan = new SetPLCUpdatePlan(
                        this.downBlowingSystemService.PLCos,
                        objname,
                        update_propertynames); ;
                    setPlan_items.Add(plan);
                }
            }
        }

        private void UserControl_Unloaded(object sender, RoutedEventArgs e)
        {
            for (int i = 0; i < setPlan_items.Count(); i++)
            {
                setPlan_items[i].Dispose();
            }
            setPlan_items.Clear();
        }

    }

    public class SetPLCUpdatePlan : IDisposable
    {
        IPLCProxySystemService PLCos;
        long planid = 0;
        DispatcherTimer timer;//可能被销毁了
        string objname;
        IEnumerable<string> propertynames;

        public SetPLCUpdatePlan(IPLCProxySystemService plsos, string objname, IEnumerable<string> propertynames)
        {
            PLCos = plsos;

            this.propertynames = propertynames;
            this.objname = objname;// PLCos.ObjNames.First((kv) => kv.Value == obj).Key;



            timer = new DispatcherTimer()//120s 内必须再次注册
            {
                Interval = TimeSpan.FromSeconds(60)
            };
            timer.Tick += (s, e) =>
            {
                if (planid != 0)
                {
                    PLCos.FeedPlan(planid);
                }
            };

            if (IsTimeToSetPlan())
            {
                PLCos.SetPlan(this.objname, this.propertynames, (asyncContext, retData) =>
                {
                    long planid = (long)retData;
                    this.planid = planid;
                    timer.Start();
                }, null);
            }
            if (PLCos is PLCProxySystemServiceClient)
                PLCos.PropertyChanged += PLCos_PropertyChanged;

        }
        bool IsTimeToSetPlan()
        {
            if (PLCos is PLCProxySystemServiceClient)
            {
                var _PLCos = PLCos as PLCProxySystemServiceClient;
                if (_PLCos.IsConnected)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }
            else
            {
                return true;
            }
        }
        private void PLCos_PropertyChanged(object sender, PropertyChangedEventArgs e)
        {
            if (e.PropertyName == nameof(PLCProxySystemServiceClient.IsConnected))
            {
                var _PLCos = PLCos as PLCProxySystemServiceClient;
                if (_PLCos.IsConnected)
                {
                    PLCos.SetPlan(objname, propertynames, (asyncContext, retData) =>
                    {
                        long planid = (long)retData;
                        this.planid = planid;
                        timer.Start();
                    }, null);
                }
                else
                {
                    this.planid = 0;
                    timer.Stop();
                }
            }
        }

        public void Dispose()
        {
            timer.Stop();

            if (planid != 0)
                PLCos.RemovePlan(planid);
        }
    }
}