pblbackend/DOAN.ServiceCore/DoanBackgroundService.cs

using System;
using System.Threading;
using System.Threading.Tasks;
using DOAN.Infrastructure.PLC;
using DOAN.Model.PBL;
using DOAN.Model.System;
using Microsoft.Extensions.Hosting;
using SqlSugar;
using SqlSugar.IOC;
namespace DOAN.ServiceCore
{

    public class DoanBackgroundService : IHostedService, IDisposable
    {
        private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();
        private Task _executingTask;

        public Task StartAsync(CancellationToken cancellationToken)
        {
            PLCTool.ConnectPLC();
            // 当服务开始时，启动后台任务
            _executingTask = ExecuteAsync(_cancellationTokenSource.Token);



            return _executingTask.IsCompleted ? _executingTask : Task.CompletedTask;
        }

        public async Task StopAsync(CancellationToken cancellationToken)
        {
            // 请求取消后台任务
            _cancellationTokenSource.Cancel();

            // 等待后台任务完成
            await Task.WhenAny(_executingTask, Task.Delay(Timeout.Infinite, cancellationToken));
        }

        private async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            // 获取所有传感器 地址


            int index = 1;


            while (!stoppingToken.IsCancellationRequested)
            {
                Storagelocation storagelocation = await DbScoped.SugarScope.CopyNew()
                .Queryable<Storagelocation>().Where(it => it.Id == index).FirstAsync();

                string[] address = storagelocation.PlcAddress2.Split(",");
                for (int i = 0; i < address.Length; i++)
                {
                    bool result = PLCTool.ReadBit(address[i]);
                    // 写补料日志
                    Inventorylog inventorylog = new Inventorylog();
                    inventorylog.Id = SnowFlakeSingle.Instance.NextId().ToString();
                    inventorylog.RackCode = storagelocation.RackCode;

                    if (result)
                    {
                        //缺料


                        storagelocation.PackageNum = 2;
                        inventorylog.Operation = 1;
                        inventorylog.PackageNum = 2;
                        inventorylog.CreatedBy = "PLC";
                        inventorylog.CreatedTime = DateTime.Now.ToLocalTime();
                        await DbScoped.SugarScope.CopyNew().Updateable(storagelocation).ExecuteCommandAsync();
                        await DbScoped.SugarScope.CopyNew().Insertable(inventorylog).ExecuteCommandAsync();

                    }
                    else
                    {
                        if (storagelocation.PackageNum <= 2)
                        {
                            //补料成功
                            storagelocation.PackageNum = 4;
                            inventorylog.Operation = 2;
                            inventorylog.PackageNum = 4;
                            inventorylog.CreatedBy = "PLC";
                            inventorylog.CreatedTime = DateTime.Now.ToLocalTime();
                            await DbScoped.SugarScope.CopyNew().Updateable(storagelocation).ExecuteCommandAsync();
                            await DbScoped.SugarScope.CopyNew().Insertable(inventorylog).ExecuteCommandAsync();
                        }

                    }



                }



                await Task.Delay(5000, stoppingToken);
                Console.WriteLine("永驻线程，正在读取plc值  " + result);

                index++;
                if (index > 16)
                {
                    index = 1;
                }

            }
        }

        public void Dispose()
        {
            _cancellationTokenSource.Cancel();
            _executingTask.Wait();
            _cancellationTokenSource.Dispose();
        }
    }
}