iotgateway/Plugins/Plugin/DeviceThread.cs

using Microsoft.EntityFrameworkCore;
using PluginInterface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;
using IoTGateway.DataAccess;
using IoTGateway.Model;
using WalkingTec.Mvvm.Core;

namespace Plugin
{
    public class DeviceThread : IDisposable
    {
        public Device Device { get; set; }
        public IDriver Driver { get; set; }
        public Dictionary<Guid, DriverReturnValueModel> DeviceValues { get; set; } = new();
        internal List<MethodInfo> Methods { get; set; }
        private Task task { get; set; } = null;
        private DateTime TsStartDt = new DateTime(1970, 1, 1);
        private CancellationTokenSource tokenSource = new CancellationTokenSource();

        public DeviceThread(Device device, IDriver driver, string ProjectId, MyMqttClient myMqttClient)
        {
            Device = device;
            Driver = driver;
            Methods = Driver.GetType().GetMethods().Where(x => x.GetCustomAttribute(typeof(MethodAttribute)) != null).ToList();
            if (Device.AutoStart)
            {
                Console.WriteLine($"采集线程已启动:{Device.DeviceName}");

                using (var DC = new DataContext(IoTBackgroundService.connnectSetting, IoTBackgroundService.DBType))
                {
                    if (Device.DeviceVariables != null)
                    {
                        foreach (var item in Device.DeviceVariables)
                        {
                            DeviceValues[item.ID] = new();
                        }
                    }
                }
                task = Task.Run(() =>
                {
                    while (true)
                    {
                        if (tokenSource.IsCancellationRequested)
                        {
                            Console.WriteLine($"{Device.DeviceName}，停止线程");
                            return;
                        }

                        try
                        {
                            Dictionary<string, List<PayLoad>> sendModel = new() { { Device.DeviceName, new() } };

                            var payLoad = new PayLoad() { Values = new() };
                            if (false)//Device.DeviceConfigs != null  配置数据先不上传
                                foreach (var DeviceConfig in Device.DeviceConfigs)
                                    payLoad.Values[DeviceConfig.DeviceConfigName] = DeviceConfig.Value;

                            if (driver.IsConnected)
                            {
                                if (Device.DeviceVariables != null)
                                {
                                    foreach (var item in Device.DeviceVariables)
                                    {
                                        var ret = new DriverReturnValueModel();
                                        var ioarg = new DriverAddressIoArgModel
                                        {
                                            ID = item.ID,
                                            Address = item.DeviceAddress,
                                            ValueType = item.DataType
                                        };
                                        var method = Methods.Where(x => x.Name == item.Method).FirstOrDefault();
                                        if (method == null)
                                            ret.StatusType = VaribaleStatusTypeEnum.MethodError;
                                        else
                                            ret = (DriverReturnValueModel)method.Invoke(Driver, new object[1] { ioarg });

                                        DeviceValues[item.ID] = ret;
                                        if (!(item.ValueFactor == 1 || item.ValueFactor == 0))
                                            ret.Value = ret.Value == null ? null : double.Parse(ret.Value?.ToString()) * item.ValueFactor;

                                        if (ret.StatusType == VaribaleStatusTypeEnum.Bad)
                                            Console.WriteLine(Driver.Connect());

                                        payLoad.Values[item.Name] = ret.Value;
                                    }
                                    payLoad.TS = (long)(DateTime.Now- TsStartDt).TotalMilliseconds;

                                    if (DeviceValues.Any(x => x.Value.StatusType != VaribaleStatusTypeEnum.Good))
                                    {
                                        payLoad.Values = null;
                                        payLoad.DeviceStatus = DeviceStatusTypeEnum.Bad;
                                    }
                                    else
                                    {
                                        payLoad.DeviceStatus = DeviceStatusTypeEnum.Good;
                                        sendModel[Device.DeviceName] = new List<PayLoad> { payLoad };
                                        myMqttClient.Publish("v1/gateway/telemetry", sendModel);
                                    }
                                }

                            }
                            else
                            {
                                driver.Connect();
                            }
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine($"线程循环异常,{Device.DeviceName},{ex}");
                        }

                        Thread.Sleep((int)Driver.MinPeriod);
                    }
                });
            }

        }

        public void StopThread()
        {
            if (task != null)
            {
                Driver.Close();
                tokenSource.Cancel();
            }
        }

        public void Dispose()
        {
            Driver.Dispose();
            Console.WriteLine($"{Device.DeviceName},释放");
        }
    }

}