.net6中, 用数据属性事件触发 用httpclient向服务器提交Mes工单

MES开发中, 客户往往会要求 工单开始时记录工艺数据, 工单结束时将这些工艺数据回传到更上一级的WES系统中. 因为MES系统和PLC 是多线程读取, 所以加锁, 事件触发是常用手段.

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数据
builder.Services.AddSingleton<MyS7Entry>();
builder.Services.AddSingleton<IS7ConnService, S7ConnServiceImpl>();//运行初始化任务  测试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(); // 创建一个对象作为锁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"; // 目标 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($"读取时发生错误:{ex.Message}");logger.LogError($"读取时发生错误次数:{errorTimes}");myS7Master.Close();MyIsConnected = false;myS7Master = null;}}}}, cts.Token);}}
}/*使用了 lock 来保护 myS7Entry.MyShort1 和 myS7Entry.MyShort2 的同时修改，
以确保在同一时间只有一个线程可以修改这两个属性。这是一种常见的使用锁的方式，
目的是避免竞态条件和数据不一致性。死锁通常发生在两个或多个线程之间存在循环依赖锁的情况下，
导致它们互相等待对方释放锁。在你的代码中，只有一个 lock，并且在修改属性时使用，
不会导致循环依赖锁，因此不会发生死锁。但要注意，死锁可能在其他情况下发生，比如在涉及多个锁的复杂情况下，
或者在锁嵌套的情况下。确保你的代码中不会出现多个锁之间的循环依赖，
以及在锁内部避免阻塞线程，以保证代码的正常执行。*/

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($"网络错误:{ex.Message}");return Task.CompletedTask;}logger.LogWarning("初始化函数成功");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){// 在应用程序停止时执行清理逻辑（如果有必要）return Task.CompletedTask;}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/107175.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

AUTOSAR规范与ECU软件开发(实践篇）6.6 BSW模块代码生成

AUTOSAR规范与ECU软件开发(实践篇）6.6 BSW模块代码生成

在BCT界面中配置完所需要的BSW模块后&#xff0c; 可以进行BSW模块相关代码与描述文件的生成&#xff0c; 点击ISOLAR-A主菜单中“ ”右边箭头&#xff0c; 选择Run Configuraions&#xff0c; 如图6.57所示。 将弹出如图6.58所示的界面。 图6.57 Run Configuraions配置&#x…
阅读更多...
Cpp学习——编译链接

Cpp学习——编译链接

目录 ​编辑 一&#xff0c;两种环境 二&#xff0c;编译环境下四个部分的 1.预处理 2.编译 3.汇编 4.链接 三&#xff0c;执行环境 一&#xff0c;两种环境 在程序运行时会有两种环境。第一种便是编译环境&#xff0c;第二种则是执行环境。如下图&#xff1a; 在程序运…
阅读更多...
UI位置与布局

UI位置与布局

UI位置与布局 引言 发现UGUI的RectTransform定位还是很复杂的&#xff0c;感觉有必要详细了解一下 RectTransform 继承自Transform。他的local position由其他几个变量控制。建议不要直接设置position 目的是为了实现UI自动布局。这套方法将绝对定位&#xff0c;相对定位&a…
阅读更多...
mysql sql 执行流程

mysql sql 执行流程

监控查询缓存的命中率 show status like ‘%qcache%’; mysql 缓存机制&#xff0c;以及 8.0 为啥取消 select sql_NO_Cache * from 表 where xxx; # 不使用缓存
阅读更多...
K8s学习笔记3

K8s学习笔记3

Kubernetes功能&#xff1a; Kubernetes是一个轻便的可扩展的开源平台&#xff0c;用于管理容器化应用和服务。通过Kubernetes能够进行应用的自动化部署和扩缩容。在Kubernetes中&#xff0c;会将组成应用的容器组合成一个逻辑单元以更易管理和发现。Kubernetes积累了作为Goog…
阅读更多...
origin导出pdf曲线超出边框

origin导出pdf曲线超出边框

软件版本 软件版本Word2021Origin2021Adobe Acrobat Pro2023 问题描述 Origin导出的emf格式矢量图片&#xff0c;插入到Word中&#xff0c;显示正常&#xff0c;但是在使用Word导出→创建Adobe PDF→创建Adobe PDF导出PDF文件后&#xff0c;图片曲线就会超出边框&#xff0c…
阅读更多...
cuda编程day001

cuda编程day001

一、环境&#xff1a; ①、linux cuda-11.3 opecv4.8.0 不知道头文件和库文件路径&#xff0c;用命令查找&#xff1a; # find /usr/local -name cuda.h 2>/dev/null # 查询cuda头文件路径 /usr/local/cuda-11.3/targets/x86_64-linux/include/cuda.h # find /usr/…
阅读更多...
文旅景区vr体验馆游乐场vr项目是什么

文旅景区vr体验馆游乐场vr项目是什么

我们知道现在很多的景区或者游玩的地方&#xff0c;以及学校、科技馆、科普馆、商场或公园或街镇&#xff0c;都会建一些关于游玩以及科普学习的项目。从而增加学习氛围或者带动人流量等等。这样的形式&#xff0c;还是有很好的效果呈现。 普乐蛙VR体验馆案例 下面是普乐蛙做的…
阅读更多...
【MySQL系列】表的内连接和外连接学习

【MySQL系列】表的内连接和外连接学习

「前言」文章内容大致是对MySQL表的内连接和外连接。 「归属专栏」MySQL 「主页链接」个人主页 「笔者」枫叶先生(fy) 目录 一、内连接二、外连接2.1 左外连接2.2 右外连接 一、内连接 内连接实际上就是利用where子句对两种表形成的笛卡儿积进行筛选&#xff0c;前面篇章学习的…
阅读更多...
bug复刻，解决方案---在改变div层级关系时，导致传参失败

bug复刻，解决方案---在改变div层级关系时，导致传参失败

问题描述&#xff1a; 在优化页面时&#xff0c;为了实现网页顶部遮挡效果&#xff08;内容滚动&#xff0c;顶部导航栏不随着一起滚动&#xff0c;并且覆盖&#xff09;&#xff0c;做法是将内容都放在一个div里面&#xff0c;为这个新的div设置样式&#xff0c;margin-top w…
阅读更多...
word 调整列表缩进

word 调整列表缩进

word 调整列表缩进的一种方法&#xff0c;在试了其他方法无效后&#xff0c;按下图所示顺序处理&#xff0c;编号和文字之间的空白就没那么大了。 即右键word上方样式->点击修改格式->定义新编号格式->字体->取消勾选 “……对齐到网格”->确定
阅读更多...
枚举的使用优化if-else

枚举的使用优化if-else

文章目录 目录 文章目录 前言 一、用来替代大量请求路径的判断 二、使用枚举来优化if-else结构 总结 前言 枚举是一种常用于替代复杂的if-else结构的优化工具。通过使用枚举&#xff0c;可以将多个条件判断语句转化为简单的case语句&#xff0c;提高代码的可读性和可维护性 一…
阅读更多...
使用Python写入数据到Excel：实战指南

使用Python写入数据到Excel：实战指南

在数据科学领域&#xff0c;Excel是一种广泛使用的电子表格工具&#xff0c;可以方便地进行数据管理和分析。然而&#xff0c;当数据规模较大或需要自动化处理时&#xff0c;手动操作Excel可能会变得繁琐。此时&#xff0c;使用Python编写程序将数据写入Excel文件是一个高效且便…
阅读更多...
Gateway简述

Gateway简述

前言 ​ 在微服务架构中&#xff0c;一个系统会被拆分为很多个微服务。那么作为客户端调用多个微服务接口的地址。另外微服务架构的请求中&#xff0c;90%的都携带认证信息/用户登录信息&#xff0c;都需要做相关的限制管理&#xff0c;API网关由此应允而生。 这样的架构会存…
阅读更多...
如何通过人工智能和自动化提高供应链弹性？

如何通过人工智能和自动化提高供应链弹性？

全球供应链中的数字化转型已经引起了广泛关注&#xff0c;尽管在过去的十年中&#xff0c;这一话题被广泛讨论&#xff0c;但许多公司仍然对如何实现这一不明确的目标感到困惑。人们普遍认识到这种转变的重要性&#xff0c;而新冠疫情及其带来的巨大影响也为行业向数字化转型方…
阅读更多...
nginx生成自定义证书

nginx生成自定义证书

1、创建key文件夹 [rootlocalhost centos]# mkdir key 进入key文件夹 [rootlocalhost centos]# cd key/ 2、生成私钥文件 [rootlocalhost key]# openssl genrsa -des3 -out ssl.key 4096 输入这个key文件的密码。不推荐输入&#xff0c;因为以后要给nginx使用。每次reload ngin…
阅读更多...
磁盘阵列/视频集中存储/安防监控视频智能分析平台新功能：人员聚集

磁盘阵列/视频集中存储/安防监控视频智能分析平台新功能：人员聚集

人工智能技术已经越来越多地融入到视频监控领域中&#xff0c;近期我们也发布了基于AI智能视频云存储/安防监控视频AI智能分析平台的众多新功能&#xff0c;该平台内置多种AI算法&#xff0c;可对实时视频中的人脸、人体、车辆、物体等进行检测、跟踪与抓拍&#xff0c;支持口罩…
阅读更多...
几种在JavaScript中创建对象的方式！

几种在JavaScript中创建对象的方式！

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ 字面量方式⭐ 构造函数方式⭐ Object.create()方式⭐ 工厂函数方式⭐ ES6类方式⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门…
阅读更多...
Java—实现多线程程序 | 入门

Java—实现多线程程序 | 入门

目录 一、前言 二、基本概念 进程 线程 三、Java多线程实现 java.lang.Thread类 获取线程名字及对象 获取main进程名 Thread currentThread() 四、线程优先级 设置优先级 一、前言 前期入门学习的代码中&#xff0c;全部都是单线的程序&#xff0c;也就是从头到尾…
阅读更多...
[halcon] 局部图片保存 gen_circle 和 gen_rectangle2 对比 这怕不是bug吧

[halcon] 局部图片保存 gen_circle 和 gen_rectangle2 对比 这怕不是bug吧

背景 我想实现一个功能&#xff0c;获取图片中瑕疵的位置&#xff0c;将瑕疵周边的一块区域抠图并保存。 上代码 一开始我代码这么写的&#xff1a; gen_circle (Rectangle, Row[i], Column[i], 256) reduce_domain(Image,Rectangle,GrayEllipse) crop_domain(GrayEllipse,…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023