当前位置： 首页 > news >正文

中英文网站制作西安市工程建设信息网

news 2025/11/7 13:41:55
中英文网站制作,西安市工程建设信息网,如何搭建平台运营体系,十大搜索引擎排行榜1. 读取配置文件及创建变量信息（点位名称，地址，数据类型（bool/short/int/float/long/double）） 2. 读任务&写任务,数据有变化时事件广播通知 using HslCommunication; using HslCommunication.Core; usi…

1. 读取配置文件及创建变量信息（点位名称，地址，数据类型（bool/short/int/float/long/double））

2. 读任务&写任务,数据有变化时事件广播通知

复制代码

using HslCommunication;
using HslCommunication.Core;
using HslCommunication.ModBus;
using PLCEvent.Util;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading.Tasks;
using UtilHelper;namespace PLCEvent.Service
{public class PLCService{ public static Action<string> OnDataChange;public static ConcurrentDictionary<string, bool> DicBoolData = new ConcurrentDictionary<string, bool>();public static ConcurrentDictionary<string, Word> DicAllData = new ConcurrentDictionary<string, Word>();public static ConcurrentDictionary<string, Word> DicChangeData = new ConcurrentDictionary<string, Word>();static ModbusTcpNet client = null;static IByteTransform byteTransform;static ConcurrentQueue<PLCModel> queueWrite = new ConcurrentQueue<PLCModel>();public static void DataChange(string address){OnDataChange?.Invoke(address);}/// <summary>/// 自定义控件内接收到数据变化事件，根据传入address，以及DataType查询监听地址所需要的监听范围（40120_int 监听两个word：40120 40121；40130_long 监听四个word：40130 40131 40132 40133），判断是否属于本控件监听/// </summary>public static List<string> RangeAddress(string address, int length){List<string> lstaddress = new List<string>();if (0 == length){lstaddress.Add(address);}else{for (int i = 0; i < length; i++){lstaddress.Add(FillAddress((DataHelper.Obj2Short(address) + i).ToString()));}}return lstaddress;}/// <summary>/// 读取时，按位补充0/// </summary>public static string FillAddress(string val, int length = 5){return val.PadLeft(length, '0');}/// <summary>/// 写入时，格式化地址，如：40101 -> 101/// </summary> public static string FormatAddress(string val){if (val.Length < 5) return val;return val.Substring(1, val.Length - 1);}public static void Init(){client = new ModbusTcpNet(CommonMethods.PLCConfig.HostAddress, CommonMethods.PLCConfig.PortNumber);client.AddressStartWithZero = false;client.DataFormat = DataFormat.CDAB;byteTransform = client.ByteTransform;TskPlcRead();TskPlcWrite();}public static bool GetBool(string address){ try{bool exist = DicBoolData.TryGetValue(address, out var value);// 字典存储if (!exist){Logger.Info($"[Error] PLCService,GetBool,errmsg:查无点位数据({address})");}return value;}catch (Exception ex){Logger.Info("[Error] PLCService,GetBool,errmsg:" + ex.Message);}return false;}/// <summary>/// 获取字节（1个word，2个字节）/// </summary> static Word GetAddressWord(string address, int add){address = FillAddress((Convert.ToInt32(address) + add).ToString());bool exist = DicAllData.TryGetValue(address, out var value);if (!exist){Logger.Info($"[Error] PLCService,GetAddressWord,errmsg:查无点位数据({address})");}return value;}/// <summary>/// 拼接字节（多个word）/// </summary> static byte[] JoinAddressWord(string address, DataType datatype){byte[] ret = null;switch (datatype){ case DataType.Short:{ var buff = GetAddressWord(address, 0);ret = new byte[2] { buff.Byte1, buff.Byte2 };}break;case DataType.Int:case DataType.Float:{var buff1 = GetAddressWord(address, 0);var buff2 = GetAddressWord(address, 1);ret = new byte[4] { buff1.Byte1, buff1.Byte2, buff2.Byte1, buff2.Byte2 };} break;case DataType.Long: case DataType.Double:{var buff1 = GetAddressWord(address, 0);var buff2 = GetAddressWord(address, 1);var buff3 = GetAddressWord(address, 2);var buff4 = GetAddressWord(address, 3);ret = new byte[8] { buff1.Byte1, buff1.Byte2, buff2.Byte1, buff2.Byte2, buff3.Byte1, buff3.Byte2, buff4.Byte1, buff4.Byte2 };} break;}return ret;}public static ushort GetShort(string address){try{ var buff = JoinAddressWord(address, DataType.Short);return byteTransform.TransUInt16(buff, 0); }catch (Exception ex){Logger.Info("[Error] PLCService,GetShort,errmsg:" + ex.Message);}return 0;}public static uint GetInt(string address){try{var buff = JoinAddressWord(address, DataType.Int);return byteTransform.TransUInt32(buff, 0);}catch (Exception ex){Logger.Info("[Error] PLCService,GetInt,errmsg:" + ex.Message);}return 0;}public static float GetFloat(string address){try{var buff = JoinAddressWord(address, DataType.Float);return byteTransform.TransSingle(buff, 0);}catch (Exception ex){Logger.Info("[Error] PLCService,GetFloat,errmsg:" + ex.Message);}return 0;}public static ulong GetLong(string address){try{var buff = JoinAddressWord(address, DataType.Long);return byteTransform.TransUInt64(buff, 0);}catch (Exception ex){Logger.Info("[Error] PLCService,GetLong,errmsg:" + ex.Message);}return 0;}public static double GetDouble(string address){try{var buff = JoinAddressWord(address, DataType.Double);return byteTransform.TransDouble(buff, 0);}catch (Exception ex){Logger.Info("[Error] PLCService,GetDouble,errmsg:" + ex.Message);}return 0;}/// <summary>/// 定时读取/// </summary>static void TskPlcRead(){Task.Factory.StartNew(async () =>{var start_c = CommonMethods.PLCConfig.ReadStart_Coil;var start_h = CommonMethods.PLCConfig.ReadStart_Holding;bool[] temp_c = null; byte[] temp_h = null;while (!CommonMethods.CTS.IsCancellationRequested){try{DicChangeData.Clear();var array_c = (await client.ReadBoolAsync(start_c, (ushort)CommonMethods.PLCConfig.ReadCount_Coil)).Content;var array_h = (await client.ReadAsync(start_h, (ushort)(CommonMethods.PLCConfig.ReadCount_Holding * 2))).Content;// ushort占两个字节if (null != array_c){// bool类型只占1位，数据有变化直接通知if (null == temp_c) temp_c = new bool[array_c.Length];CheckBoolChange("0", start_c, temp_c, array_c);Array.Copy(array_c, temp_c, array_c.Length);}if (null != array_h){// word类型数据位(2,4,8)，所以要先读取全部的数据，再通知变化if (null == temp_h) temp_h = new byte[array_h.Length];CheckWordChange("4", start_h, temp_h, array_h);Array.Copy(array_h, temp_h, array_h.Length);if (DicChangeData.Count > 0){foreach (var item in DicChangeData){DataChange(item.Key);}}} }catch (Exception ex){ Logger.Info("[Error] PLCMgr,TskPlcRead,errmsg" + ex.Message);} await Task.Delay(1000);}}, TaskCreationOptions.LongRunning);}/// <summary>/// 检查数据是否有变化（bool类型）/// </summary> public static void CheckBoolChange(string flg, string start, bool[] oldbuffer, bool[] newbuffer){for (int i = 0; i < newbuffer.Length; i++){string address = flg + FillAddress((i + Convert.ToInt32(start)).ToString(), 4);// 00101bool value = newbuffer[i];DicBoolData.AddOrUpdate1(address, value); if (oldbuffer[i] != value){ OnDataChange(address);}}}/// <summary>/// 检查数据是否有变化（word类型）/// </summary> public static void CheckWordChange(string flg, string start, byte[] oldbuffer, byte[] newbuffer){int index = 0;for (int i = 0; i < newbuffer.Length; i = i + 2){string address = flg + FillAddress((index + Convert.ToInt32(start)).ToString(), 4);// 40101if (address == "40130"){}index++;byte byte1 = newbuffer[i];byte byte2 = newbuffer[i + 1];Word buff = new Word() { Byte1 = byte1, Byte2 = byte2 };DicAllData.AddOrUpdate1(address, buff);if (oldbuffer[i] != byte1 || oldbuffer[i + 1] != byte2){DicChangeData.AddOrUpdate1(address, buff);}}}/// <summary>/// 添加写入值/// </summary> public static void AddWriteVariable(string address, object value, DataType datatype){queueWrite.Enqueue(new PLCModel() { Address = address, Value = value, PLCDataType = datatype });//加载值进队列} /// <summary>/// 定时写入/// </summary>static void TskPlcWrite(){ Task.Factory.StartNew(async () =>{while (!CommonMethods.CTS.IsCancellationRequested){try{if (!queueWrite.IsEmpty){PLCModel model = null; OperateResult result = null;queueWrite.TryDequeue(out model);var dataype = model.PLCDataType;switch (dataype){case DataType.Bool:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToBoolean(model.Value));break;case DataType.Short:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToUInt16(model.Value)); break;case DataType.Int:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToUInt32(model.Value));break;case DataType.Float:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToSingle(model.Value));break;case DataType.Long:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToUInt64(model.Value));break;case DataType.Double:result = await client.WriteAsync(FormatAddress(model.Address), Convert.ToDouble(model.Value));break;}if (!result.IsSuccess){Logger.Info("[Error] PLCMgr,TskPlcWrite,errmsg:写入失败," + result.Message);}}}catch (Exception ex){ Logger.Info("[Error] PLCMgr,TskPlcWrite,errmsg:" + ex.Message);} await Task.Delay(500);}}, TaskCreationOptions.LongRunning);}}
}

复制代码

3. 自定义控件绑定参数,监听数据变化事件

注意点：
1. bool类型只占1位，数据有变化直接通知
2. word类型数据位(short:2,int/float:4,long/double:8)，所以要先读取全部的数据，再通知变化
3. 自定义控件内接收到数据变化事件，根据传入address，以及DataType查询监听地址所需要的监听范围（40120_int 监听两个word：40120 40121；40130_long 监听四个word：40130 40131 40132 40133），判断是否属于本控件监听
4. 自定义控件继承BaseParams类， PLCValue get:通过不同的数据类型，获取字典中的word数据，并拼接合成相应的数据类型;set:传入地址(写入时格式化地址，如:40101->101)及类型

实现效果：

开启Modbus Server工具

 双击数字，编辑值，点击更新后，写入modbus

数据有变化时，自动更新

http://www.yayakq.cn/news/475930/

相关文章：

  • php做企业网站管理系统网站建设从零到精通.pdf
  • 网站建设公司的前端免费模板网站都有什么
  • 怎样编辑网站标题新都网站建设
  • 做图片网站编辑标题怎么写能吸引wordpress 如何修改网页标题字体
  • 做邀请函用哪个网站好呢搜索引擎优化的例子
  • 阿里云网站备案查询网站需要哪些证件
  • 怎样维护网站建设pacdora 设计网
  • 深圳营销网站制作义乌网络公司排名
  • 简述网站建设的基本过程上海优化公司排行榜
  • 在微信上做彩票网站吗教育 wordpress模板下载地址
  • 个人网站怎么做代码wordpress模板设置
  • 广州建立网站的公司对建设网站未来发展的建议
  • 中环互联网网站建设套餐整套网站建设视频教程
  • 太原网站建设列表网wordpress 后台添加菜单
  • 网站开发与软件开发区别培训机构倒闭
  • 彩票娱乐网站建设开发高端移动网站开发
  • 合肥做企业网站的网络公司网站规划的步
  • 网站后端做留言板功能html学校官网代码制作
  • 做网站泰安网站制作教程ppt
  • 设计一个网站的首页步骤陕西购物商城网站建设
  • 网站cms系统哪个好用吗互联网金融p2p网站建设模板
  • 手机网站cms系统企业建设网站的比例
  • dedecms怎么关闭网站南阳美容网站建设
  • 上海网站建设-中国互联珠海网站建设公
  • 做明星简介网站侵权吗如何规划一个外贸网站
  • 百度个人网站申请校园二手交易网站建设方案
  • 网站建设项目可行性个人网站有前途吗
  • html5网站开发技术网站设计公司多少钱
  • 门户网站舆情怎么做上海建设网站制
  • 花茶网站设计网站模板下载后怎么用