BPASmartClient/FryPot_DosingSystem/Control/DeviceOperate.cs

using BPASmartClient.Helper;
using BPASmartClient.Message;
using BPASmartClient.Modbus;
using FryPot_DosingSystem.Model;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace FryPot_DosingSystem.Control
{
    internal class DeviceOperate
    {
        private static DeviceOperate _instance;
        public static DeviceOperate GetInstance=>_instance ??= new DeviceOperate();
        ModbusTcp modbus = new ModbusTcp();
        private string Ip { get; set; }
        private string Port { get; set; }
        public bool Connected { get; set; }

        private string DeviceName { get; set; }

        public ConcurrentDictionary<string, object> Data { get; set; } = new ConcurrentDictionary<string, object>();
        public ObservableCollection<PlcVariableModel> Variables { get; set; }=new ObservableCollection<PlcVariableModel>();
        public DeviceOperate()
        {
            Init();
            Connect();
            ReadData();
        }
        public void Init()
        {
            if (Variables.Count > 0)
            {
                Variables.Clear();
            }
            Variables.Add(new PlcVariableModel() { Address = "D2001", Length = 8 });//1号线体滚筒工位号
            Variables.Add(new PlcVariableModel() { Address = "D2011", Length = 8 });//2号线体滚筒工位号
            Variables.Add(new PlcVariableModel() { Address = "D2021", Length = 8 });//3号线体滚筒工位号
            Variables.Add(new PlcVariableModel() { Address = "D2031", Length = 9 });//输送线出料状态
            Variables.Add(new PlcVariableModel() { Address = "D2040", Length = 5 });//炒锅1-5进料滚筒运行
            Variables.Add(new PlcVariableModel() { Address = "D2045", Length = 5 });//炒锅1-5进料到位信号
            Variables.Add(new PlcVariableModel() { Address = "D2050", Length = 5 });//炒锅1-5空桶到位信号
            Variables.Add(new PlcVariableModel() { Address = "D2055", Length = 5 });//炒锅1-5空桶呼叫AGV
            Variables.Add(new PlcVariableModel() { Address = "D2060", Length = 5 });//炒锅1空桶洗桶呼叫AGV
            Variables.Add(new PlcVariableModel() { Address = "D2065", Length = 5 });//炒锅1-5空桶滚筒运行
            Variables.Add(new PlcVariableModel() { Address = "D2070", Length = 5 });//炒锅1-5滚筒故障信号
            Variables.Add(new PlcVariableModel() { Address = "D2075", Length = 1 });//洗桶进桶滚筒运行信号
            Variables.Add(new PlcVariableModel() { Address = "D2076", Length = 1 });//洗桶出桶呼叫AGV
            Variables.Add(new PlcVariableModel() { Address = "D2077", Length = 1 });// 洗桶出桶滚筒运行信号
            Variables.Add(new PlcVariableModel() { Address = "D2078", Length = 3 });//1-3滚筒线体配方完成信号
        }
        public void Connect()
        {
            Json<DeviceManage>.Read();
            DeviceManage devices = Json<DeviceManage>.Data;
            if (devices != null)
            {
                if (devices.Devices.Count > 0)
                {
                    Ip = devices.Devices[0].Ip;
                    Port = devices.Devices[0].Port;
                    DeviceName = devices.Devices[0].DeviceName;
                    Task.Run(() => { modbus.ModbusTcpConnect(Ip, Convert.ToInt32(Port)); });
                }
            }
        }
        public void ReadData()
        {
            ThreadManage.GetInstance().StartLong(new Action(() => 
            {
                Connected = modbus.Connected;
                while (Connected)
                {
                    foreach (var item in Variables)
                    {
                        var res = modbus.Read(item.Address, item.Length);
                        if (Data.ContainsKey(item.Address))
                        {
                            Data[item.Address] = res;
                        }
                        else
                        {
                            Data.TryAdd(item.Address, res);
                        }
                    }
                    Thread.Sleep(500);
                   
                }
                Thread.Sleep(1000);
            }),$"设备【{DeviceName}】PLC实时数据读取线程");
        }
        public void WritePlcData(string address,ushort value)
        {
            lock (this)
            {
                modbus.Write(address, value);  
            }
        }
        public ConcurrentDictionary<string, object> GetAllData()
        {
            return Data;
        }
    }
}