.net6中, 用數(shù)據(jù)屬性事件觸發(fā) 用httpclient向服務(wù)器提交Mes工單

這篇具有很好參考價值的文章主要介紹了.net6中, 用數(shù)據(jù)屬性事件觸發(fā) 用httpclient向服務(wù)器提交Mes工單。希望對大家有所幫助。如果存在錯誤或未考慮完全的地方，請大家不吝賜教，您也可以點擊"舉報違法"按鈕提交疑問。

MES開發(fā)中, 客戶往往會要求工單開始時記錄工藝數(shù)據(jù), 工單結(jié)束時將這些工藝數(shù)據(jù)回傳到更上一級的WES系統(tǒng)中. 因為MES系統(tǒng)和PLC 是多線程讀取, 所以加鎖, 事件觸發(fā)是常用手段.文章來源地址http://www.zghlxwxcb.cn/news/detail-690020.html

using MyWebApiTest.PLC;
using MyWebApiTest.Service;
using MyWebApiTest.Service.Entry;
using MyWebApiTest.Service.Entry.Imp;
using MyWebApiTest.Service.Factory;
using MyWebApiTest.Service.Factory.Impl;
using MyWebApiTest.Utils;
using Serilog;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.


//日志
builder.Host.UseSerilog((context, logger) =>
{
    logger.ReadFrom.Configuration(context.Configuration);
    logger.Enrich.FromLogContext();
});

// Add services to the container.
builder.Configuration.AddJsonFile("appsettings.json", false, true);
var cfg = builder.Configuration;
builder.Services.AddSingleton<IConfiguration>(cfg);


//ORM
builder.Services.AddSingleton<ISqlSugarService ,SqlSugarServiceImpl>();
builder.Services.AddSingleton<SqlSugarHelper>();

builder.Services.AddSingleton<IAbsFactoryService, AbsFactoryServiceImpl>();

builder.Services.AddSingleton<IConnFactoryService, ConnFactoryServiceImpl2>();
builder.Services.AddSingleton<IConnFactoryService, ConnFactoryServiceImpl1>();

//PLC數(shù)據(jù)
builder.Services.AddSingleton<MyS7Entry>();
builder.Services.AddSingleton<IS7ConnService, S7ConnServiceImpl>();

//運行初始化任務(wù)  測試client
//builder.Services.AddSingleton<IHostedService, StartupInitializationService>();

//client
builder.Services.AddHttpClient();

//AutoMapper
builder.Services.AddAutoMapper(AppDomain.CurrentDomain.GetAssemblies());

builder.Services.AddControllers();
builder.Services.AddCors(c => c.AddPolicy("any", p => p.AllowAnyHeader().AllowAnyMethod().AllowAnyOrigin()));
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();

//日志
builder.Host.UseSerilog((context, logger) =>
{
    logger.ReadFrom.Configuration(context.Configuration);
    logger.Enrich.FromLogContext();
});

var app = builder.Build();

// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
    app.UseSwagger();
    app.UseSwaggerUI();
}
app.UseCors("any");

app.UseAuthorization();

app.MapControllers();

app.Run();

using S7.Net;

namespace MyWebApiTest.Service.Entry
{
    public interface IS7ConnService
    {
        void ConnPlc();


        bool MyIsConnected
        {
            get;
        }

        Plc MyS7Master { get; }
    }
}

using MyWebApiTest.PLC;
using MyWebApiTest.Service.Entry;
using S7.Net;

namespace MyWebApiTest.Service.Entry.Imp
{
    public class S7ConnServiceImpl : IS7ConnService
    {
        public S7ConnServiceImpl(IConfiguration configuration,
            HttpClient httpClient,
            ILogger<S7ConnServiceImpl> logger,
            MyS7Entry myS7Entry)
        {
            this.configuration = configuration;
            this.httpClient = httpClient;
            this.logger = logger;
            this.myS7Entry = myS7Entry;
            myIp = configuration.GetSection("PlcIp").Value;
        }

        private readonly IConfiguration configuration;
        private readonly HttpClient httpClient;
        private readonly ILogger<S7ConnServiceImpl> logger;
        private MyS7Entry myS7Entry;
        private string myIp;
        private Plc myS7Master = null;
        private MyS7EntityRecive? myS7test = new MyS7EntityRecive();
        private MyS7Entry myS7Data = new MyS7Entry();
        private bool myIsConnected = false;
        private CancellationTokenSource cts = new();
        private int errorTimes = 0;
        private static readonly object lockObj = new object(); // 創(chuàng)建一個對象作為鎖

        public Plc MyS7Master
        {
            get => myS7Master;
        }

        public MyS7Entry MyS7Data
        {
            get => myS7Data;
            set => myS7Data = value;
        }

        public bool MyIsConnected
        {
            get => myIsConnected;
            set
            {
                if (myIsConnected == false && value == true)
                {
                    logger.LogInformation("PLC連接成功!");
                }
                myIsConnected = value;
            }
        }

        public void ConnPlc()
        {
            Task.Run(async () =>
            {
                while (!cts.IsCancellationRequested)
                {
                    if (myS7Master == null || !MyIsConnected)
                    {
                        try
                        {
                            myS7Master = new Plc(CpuType.S71500, myIp, 0, 0);
                            myS7Master.Open();
                            MyIsConnected = myS7Master.IsConnected;
                        }
                        catch (Exception ex)
                        {
                            myS7Master?.Close();
                            myS7Master = null;
                            MyIsConnected = false;
                            logger.LogError(ex.Message);
                            await Task.Delay(2000);
                        }
                    }
                    else if (MyIsConnected)
                    {
                        //注入Client

                        //var url = "http://localhost:5190/api/private/v1/My/MyGet"; // 目標(biāo) Web API 的地址

                        //var response = await httpClient.GetAsync(url);

                        //if (response.IsSuccessStatusCode)
                        //{
                        //    var content = await response.Content.ReadAsStringAsync();
                        //    logger.LogError(content);

                        //}

                        try
                        {
                            MyIsConnected = myS7Master.IsConnected;
                            await Task.Delay(1000);
                            myS7test = await myS7Master.ReadClassAsync<MyS7EntityRecive>(31, 416);
                            lock (lockObj)
                            {
                                myS7Entry.MyShort1 = myS7test.MyShort1;
                                myS7Entry.MyShort2 = myS7test.MyShort2;
                            }
                            logger.LogInformation(myS7Entry.MyShort1.ToString() + "====");
                        }
                        catch (Exception ex)
                        {
                            errorTimes++;
                            await Task.Delay(1000);

                            logger.LogError($"讀取時發(fā)生錯誤:{ex.Message}");
                            logger.LogError($"讀取時發(fā)生錯誤次數(shù):{errorTimes}");
                            myS7Master.Close();
                            MyIsConnected = false;
                            myS7Master = null;
                        }
                    }
                }
            }, cts.Token);
        }
    }
}

/*
 使用了 lock 來保護 myS7Entry.MyShort1 和 myS7Entry.MyShort2 的同時修改，
以確保在同一時間只有一個線程可以修改這兩個屬性。這是一種常見的使用鎖的方式，
目的是避免競態(tài)條件和數(shù)據(jù)不一致性。

死鎖通常發(fā)生在兩個或多個線程之間存在循環(huán)依賴鎖的情況下，
導(dǎo)致它們互相等待對方釋放鎖。在你的代碼中，只有一個 lock，并且在修改屬性時使用，
不會導(dǎo)致循環(huán)依賴鎖，因此不會發(fā)生死鎖。

但要注意，死鎖可能在其他情況下發(fā)生，比如在涉及多個鎖的復(fù)雜情況下，
或者在鎖嵌套的情況下。確保你的代碼中不會出現(xiàn)多個鎖之間的循環(huán)依賴，
以及在鎖內(nèi)部避免阻塞線程，以保證代碼的正常執(zhí)行。
 
 */

using System.ComponentModel;

namespace MyWebApiTest.PLC
{
    public class MyS7Entry : INotifyPropertyChanged
    {
        public event PropertyChangedEventHandler? PropertyChanged;

        private short myShort1;

        public short MyShort1
        {
            get => myShort1;
            set
            {
                if (myShort1 != value)
                {
                    if (myShort1 == 1 && value == 0)
                    {
                        OnPropertyChanged(nameof(MyShort1));
                    }
                    myShort1 = value;
                }
            }
        }

        private short myShort2;

        public short MyShort2
        {
            get => myShort2;
            set
            {
                if (myShort2 != value)
                {
                    if (myShort2 == 1 && value == 0)
                    {
                        OnPropertyChanged(nameof(MyShort2));
                    }
                    myShort2 = value;
                }

            }
        }

        private void OnPropertyChanged(string propertyName)
        {
            PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
        }
    }
}

namespace MyWebApiTest.PLC
{
    public class MyS7EntityRecive
    {
        public short MyShort1 { get; set; }
        public short MyShort2 { get; set; }
    }
}

using MyWebApiTest.entities;
using MyWebApiTest.PLC;
using MyWebApiTest.Service.Entry;
using System.Text.Json;

namespace MyWebApiTest.Utils
{
    public class StartupInitializationService : IHostedService
    {
        private readonly MyS7Entry myS7Entry;
        private readonly IS7ConnService s7ConnService;
        private readonly ILogger<StartupInitializationService> logger;
        private readonly HttpClient httpClient;

        public StartupInitializationService(MyS7Entry myS7Entry
            , IS7ConnService s7ConnService
            , ILogger<StartupInitializationService> logger
            , HttpClient httpClient
            )
        {
            this.myS7Entry = myS7Entry;
            this.s7ConnService = s7ConnService;
            this.logger = logger;
            this.httpClient = httpClient;
        }
        public Task StartAsync(CancellationToken cancellationToken)
        {
            try
            {
                s7ConnService.ConnPlc();
            }
            catch (Exception ex)
            {
                logger.LogError($"網(wǎng)絡(luò)錯誤:{ex.Message}");
                return Task.CompletedTask;
            }

            logger.LogWarning("初始化函數(shù)成功");

            myS7Entry.PropertyChanged += async (s, e) =>
            {
                if (e.PropertyName == "MyShort1")
                {
                    string? url = "http://127.0.0.1:8081/endpoint/mes/kx/reportA";
                    Student stu = new()
                    {
                        Id = 1,
                        Name = "MyBool1",
                        Age = 999
                    };
                    var json = JsonSerializer.Serialize(stu);
                    var content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
                    var response = await httpClient.PostAsync(url, content);
                    if (response.IsSuccessStatusCode)
                    {
                        logger.LogInformation("Data sent successfullyS1.");
                    }
                    else
                    {
                        logger.LogInformation("Failed to send dataS1.");
                    }
                }

                else if (e.PropertyName == "MyShort2")
                {
                    string? url = "http://127.0.0.1:8081/endpoint/mes/kx/reportB";
                    Student stu = new()
                    {
                        Id = 2,
                        Name = "MyBool2",
                        Age = 888
                    };

                    var json = JsonSerializer.Serialize(stu);
                    var content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
                    var response = await httpClient.PostAsync(url, content);
                    if (response.IsSuccessStatusCode)
                    {
                        logger.LogInformation("Data sent successfullyS1.");
                    }
                    else
                    {
                        logger.LogInformation("Failed to send dataS1.");
                    }
                }
            };

            return Task.CompletedTask;
        }

        public Task StopAsync(CancellationToken cancellationToken)
        {
            // 在應(yīng)用程序停止時執(zhí)行清理邏輯（如果有必要）
            return Task.CompletedTask;
        }
    }
}

到了這里，關(guān)于.net6中, 用數(shù)據(jù)屬性事件觸發(fā) 用httpclient向服務(wù)器提交Mes工單的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！