BPASmartClient/DosingSystem/ViewModel/UHardwareStatusViewModel.cs

using BPA.Helper;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Threading;

namespace BPASmartClient.DosingSystem.ViewModel
{
    public class UHardwareStatusViewModel : NotifyBase
    {
        public UHardwareStatusViewModel()
        {

            //TopDeviceCurrentStatuses = new ObservableCollection<DeviceCurrentStatus>();
            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 }) ;
            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });

            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //TopDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });



            //BottomDeviceCurrentStatuses = new ObservableCollection<DeviceCurrentStatus>();
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //BottomDeviceCurrentStatuses.Add(new DeviceCurrentStatus { DeviceNum = 1 });
            //TopDeviceCurrentStatuses = DeviceInquire.GetInstance.TopDeviceCurrentStatuses;
            //BottomDeviceCurrentStatuses = DeviceInquire.GetInstance.BottomDeviceCurrentStatuses;
            //2023/7/3调整
            TopDeviceCurrentStatuses = ConvertToObservableCollention(DeviceInquire.GetInstance.TopDeviceCurrentStatuses.OrderByDescending(p => p.DeviceNum).Reverse());
            BottomDeviceCurrentStatuses = ConvertToObservableCollention(DeviceInquire.GetInstance.BottomDeviceCurrentStatuses.OrderByDescending(p => p.DeviceNum).Reverse());
            UnifordColumNum();

            TaskManage.GetInstance.StartLong(new Action(() =>
                {
                    for (int i = 0; i < Json<DevicePar>.Data.OutletInfoModels.Count; i++)
                    {
                        int count = Json<DevicePar>.Data.OutletInfoModels.ElementAt(i).SiloInfos.Count;
                        if (count >= 1)
                        {
                            for (int m = 0; m < count; m++)
                            {
                                var deviceName = Json<DevicePar>.Data.OutletInfoModels.ElementAt(i).SiloInfos.ElementAt(m);
                                int topIndex = TopDeviceCurrentStatuses.ToList().FindIndex(p => p.DeviceName == deviceName);
                                int bottomIndex = BottomDeviceCurrentStatuses.ToList().FindIndex(p => p.DeviceName == deviceName);
                                if (topIndex >= 0 && topIndex < TopDeviceCurrentStatuses.Count)
                                    TopDeviceCurrentStatuses.ElementAt(i).BucketFlagbit = GlobalDevice.PlcData.StationDetection[i];
                                if (bottomIndex >= 0 && bottomIndex < BottomDeviceCurrentStatuses.Count)
                                    BottomDeviceCurrentStatuses.ElementAt(i).BucketFlagbit = GlobalDevice.PlcData.StationDetection[i];
                            }
                        }
                    }
                    StatusUpdate(TopDeviceCurrentStatuses);
                    StatusUpdate(BottomDeviceCurrentStatuses);
                    OnDetection = GlobalDevice.PlcData.OnDetection;
                    UnderDetection = GlobalDevice.PlcData.UnderDetection;
                    ConveyerBeltStatus = GlobalDevice.MotorControlFeedback > 0 ? 2 : GlobalDevice.MotorControlFeedback;
                    Thread.Sleep(100);
                }), "输送带料仓状态监控", true);

            RecipeControlCommand = new BPARelayCommand<object>((o) =>
            {
                if (o != null && o is DeviceCurrentStatus currentStatus)
                {
                    var res = DeviceInquire.GetInstance.devices.FirstOrDefault(p => p.DeviceName == currentStatus.DeviceName);
                    if (res != null)
                    {
                        DeviceInquire.GetInstance.GetDevice(res.IpAddress).Start(currentStatus.SetWeight);
                    }
                }
            });
        }

        private void StatusUpdate(ObservableCollection<DeviceCurrentStatus> devices)
        {
            if (devices == null) return;
            for (int i = 0; i < devices.Count; i++)
            {
                if (devices.ElementAt(i).BaitingControl)
                {
                    var res = DeviceInquire.GetInstance.devices.FirstOrDefault(p => p.DeviceName == devices.ElementAt(i).DeviceName);
                    if (res != null)
                    {
                        var runStatus = DeviceInquire.GetInstance.GetDevice(res.IpAddress).deviceStatus.RunStatus;
                        if (runStatus == 3)
                        {
                            if (TopDeviceCurrentStatuses.FirstOrDefault(p => p.DeviceName == devices.ElementAt(i).DeviceName) != null)
                            {
                                TopDeviceCurrentStatuses.ElementAt(i).BaitingControl = false;
                            }
                            else if (BottomDeviceCurrentStatuses.FirstOrDefault(p => p.DeviceName == devices.ElementAt(i).DeviceName) != null)
                            {
                                BottomDeviceCurrentStatuses.ElementAt(i).BaitingControl = false;
                            }
                            DeviceInquire.GetInstance.GetDevice(res.IpAddress).StatusReset();
                        }
                    }
                }
            }
        }
        /// <summary>
        /// 根据料仓数来进行uniform列划分
        /// </summary>
        private void UnifordColumNum()
        {
            //StockNum = Json<DevicePar>.Data.BaseParModel.StockCount;

            StockNum = TopDeviceCurrentStatuses.Count >= BottomDeviceCurrentStatuses.Count ? TopDeviceCurrentStatuses.Count : BottomDeviceCurrentStatuses.Count;


        }
        /// <summary>
        /// 数组集合转换
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="array"></param>
        /// <returns></returns>
        public ObservableCollection<T> ConvertToObservableCollention<T>(IEnumerable<T> array)
        {
            ObservableCollection<T> collec = new ObservableCollection<T>();
            foreach (var item in array)
            {
                collec.Add(item);
            }
            return collec;
        }
        public ObservableCollection<DeviceCurrentStatus> TopDeviceCurrentStatuses { get; set; }

        public ObservableCollection<DeviceCurrentStatus> BottomDeviceCurrentStatuses { get; set; }

        public ObservableCollection<ConveyerBeltModel> ConveyerBeltModels { get; set; } = new ObservableCollection<ConveyerBeltModel>();

        public BPARelayCommand<object> ConveyerBeltControlCommand { get; set; }

        public BPARelayCommand<object> RecipeControlCommand { get; set; }
        /// <summary>
        /// Uniford根据料仓数量来划分列数量
        /// </summary>
        private int _stockNum;
        public int StockNum { get { return _stockNum; } set { _stockNum = value; OnPropertyChanged(); } }
        /// <summary>
        /// 输送带状态
        /// </summary>
        public uint ConveyerBeltStatus { get { return _mConveyerBeltStatus; } set { _mConveyerBeltStatus = value; OnPropertyChanged(); } }
        private uint _mConveyerBeltStatus;

        /// <summary>
        /// 上桶工位检测
        /// </summary>
        public bool OnDetection { get { return _mOnDetection; } set { _mOnDetection = value; OnPropertyChanged(); } }
        private bool _mOnDetection;

        /// <summary>
        /// 下桶工位检测
        /// </summary>
        public bool UnderDetection { get { return _mUnderDetection; } set { _mUnderDetection = value; OnPropertyChanged(); } }
        private bool _mUnderDetection;
    }
}