Domovská stránka Prehľadávať Pomoc
Registrovať Prihlásiť sa
lishun
/
YS-SCADA-LiShun-New
1
0
Fork 0
Súbory Issues 0 Pull requesty 0 Wiki
Branch: master
Branche Tagy
YS-SCADA-LiS...
/
README.md

README.md 18 KB
Permanentný odkaz História Raw

阐述

  1. 所有协议公共函数支持同步异步
  2. 所有协议读取写入协议参数统一
  3. 全部都是统一入参出参
  4. 支持多点转发，多点解析
  5. 支持快速对接，与配置
  6. 支持虚拟点位
  7. 所有采集协议支持订阅模式
  8. 采集与转发协议接口统一
  9. 事件结果统一

核心与扩展组件

  1. [ YSAI.Log ]Verbose(详细信息)、Debug(调试)、Info(信息)、Warning(警告)、Error(异常或错误)、Fatal(致命错误或异常)
  2. [ YSAI.Unility ]公共快捷方便方法集合 (字节、枚举、文件、字符串、验证、比对、转换、反射、扩展、Json、Xml、Ftp、System ...)
  3. [ YSAI.Model ]特性、数据结构、接口、枚举、模型工具
  4. [ YSAI.Core ]处理、反射、转发、脚本、订阅、虚拟地址、TCP、UDP、HTTP、WS、串口
  5. [ YSAI.Rpc ]基于DotNetty实现的RPC(远程过程调用) 支持一对多，支持身份验证
  6. [ YSAI.Redis ]非关系型数据库，用于数据快速出站入站存储

采集协议

  1. Opc(工业标准通信协议) [UA、DA、DAHttp]
  2. Can(工业标准通信协议)
  3. DB(数据库) [SqlServer、MySql、Oracle、SQLite]
  4. Modbus(工业标准通信协议) [Rtu、Ascii、Tcp、Udp]
  5. Siemens(西门子) [S7200、S7200Smart、S7300、S7400、S71200、S71500]
  6. Beckhoff(倍福) [ADS]
  7. Mitsubishi(三菱) [A1E、QNA3E]
  8. Omron(欧姆龙) [FINS]
  9. AllenBradley(罗克韦尔)
  10. Mewtocol(松下) [Tcp、Serial]
  11. GE(通用电气) [SRTP]
namespace YSAI.Model.@interface
{
    /// <summary>
    /// 数采接口
    /// </summary>
    public interface IDaq : IOn, IOff, IRead, IWrite, ISubscribe, IGetStatus, IEvent, IGetParam, ICreateInstance, IDisposable
    { }
}

转发协议

  1. Kafka [AdminClient、Producer、Consumer]
  2. Mqtt [Client [ Publish、Subscribe ]、Service、WSService]
  3. RabbitMQ [Publish、Subscribe]
  4. Netty [Client [ Publish、Subscribe ]、Service]
  5. NetMQ [Publish、Subscribe]
namespace YSAI.Model.@interface
{
    /// <summary>
    /// 转发接口
    /// </summary>
    public interface IRelay : IOn, IOff, IProducer, IConsumer, IGetStatus, IEvent, IGetParam, ICreateInstance, IDisposable
    { }
}

协议服务端(用于数据模拟)

  1. Mqtt服务端
  2. MqttWebSocket服务端
  3. OpcUa服务端
  4. Socket服务端
  5. WebSocket服务端

创建实例合集

//实例创建的几种方式
//以OPCUA 采集协议为例
using YSAI.Model.@interface;
using YSAI.Opc.ua.client;

OpcUaClientOperate? operate = null;
IDaq? daq = null;

//无参实例
operate = new OpcUaClientOperate();
//无参实例调函数创建实例，与无参实例配合使用
operate = new OpcUaClientOperate().CreateInstance(new OpcUaClientData.Basics()).GetRData<OpcUaClientOperate>();
//有参实例
operate = new OpcUaClientOperate(new OpcUaClientData.Basics());
//有参单例
operate = OpcUaClientOperate.Instance(new OpcUaClientData.Basics());
//接口 - 无参实例
daq = new OpcUaClientOperate();
//接口 - 无参实例调函数创建实例，与无参实例配合使用
daq = new OpcUaClientOperate().CreateInstance(new OpcUaClientData.Basics()).GetRData<OpcUaClientOperate>();
//接口 - 有参实例
daq = new OpcUaClientOperate(new OpcUaClientData.Basics());
//接口 - 有参单例
daq = OpcUaClientOperate.Instance(new OpcUaClientData.Basics());

using (operate)
{
    //使用完直接释放
}

using (daq)
{
    //使用完直接释放
}

采集应用

  1. 上 “NUGET” 搜索
  2. 安装对应的协议包
  3. 应用代码如下
  4. 协议包内还有内部公共方法，请自行研究使用
//采集协议
//以OPCUA 采集协议为例
using System.Collections.Concurrent;
using YSAI.Core.script;
using YSAI.Log;
using YSAI.Model.data;
using YSAI.Model.@enum;
using YSAI.Opc.ua.client;
using YSAI.Unility;

using (OpcUaClientOperate operate = new OpcUaClientOperate(new OpcUaClientData.Basics
{
    ServerUrl = "opc.tcp://127.0.0.1:6688",
    UserName = "user",
    Password = "password",
}))
{
    //点位地址
    Address address = new Address();
    address.SN = Guid.NewGuid().ToString();
    address.CreationTime = DateTime.Now.ToLocalTime();
    address.AddressArray = new List<AddressDetails>
    {
         new AddressDetails()                                        //地址详情参数介绍
        {
            SN=$"",                                                  //可以理解成唯一标识符（可以存机台号、组名、车间、厂）
            AddressAnotherName="",                                   //地址别名
            AddressDataType=DataType.String,                         //数据类型
            AddressDescribe="",                                      //地址描述
            AddressExtendParam=new object(),                         //扩展数据
            AddressName="",                                          //实际地址[ 不能为空 ]
            AddressPropertyName="",                                  //属性名称
            AddressType=AddressType.Reality,                         //地址类型
            IsEnable=true,                                           //是否启用
            AddressRelayParam=new AddressRelay                       //转发参数
            {
                ISns = new List<string> { "ISN1", "ISN2" },          //实例SN
                Topic = $"topic",                                    //主题
                ContentFormat="Value:{0}"                            //内容格式
            },
            AddressParseParam=new AddressParse                       //脚本解析实例
            {
                ScriptParam=new ScriptData.Basics                    //脚本解析基础数据
                {
                    ScriptCode = @"function Convert(addressname,value) { return '【这是调用脚本解析】传入的地址是：'+ addressname + '----传入的参数是：' + value; }",  //脚本代码
                    ScriptFunction = "Convert",                                                                                                                        //脚本入口
                    ScriptType = ScriptData.ScriptType.JavaScript                                                                                                      //脚本类型
                }
            },
            //AddressParseParam = new AddressParse                  //反射解析
            //{                      
            //    ReflectionParam = new object[]                    //反射解析的参数
            //    {
            //        new ReflectionData.Basics                     //反射解析基础数据
            //        {
            //                                                      //反射解析的基础数据
            //        },
            //        "SN"                                          //反射解析的SN
            //    }
            // },
         }
    };

    #region 打开
    OperateResult result = operate.On();
    LogHelper.Info(result.ToJson().JsonFormatting());  //转成JSON.JSON格式化 
    #endregion 打开

    #region 读取
    //读取
    result = operate.Read(address);
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 读取

    #region 订阅
    operate.OnEvent += delegate (object? sender, EventResult e)
	{
    LogHelper.Info(e.ToJson().JsonFormatting());    //转成JSON.JSON格式化
	};
    result = operate.Subscribe(address);
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 订阅

    #region 写入
    ConcurrentDictionary<string, object> value = new ConcurrentDictionary<string, object>
    {
        ["地址"] = "string 值",
        ["地址"] = (float)1.1f,
        ["地址"] = (double)2.2d,
        ["地址"] = (int)3,
        ["地址"] = true
    };
    result = operate.Write(value);
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 写入

    #region 关闭
    result = operate.Off();
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 关闭

    #region 获取状态
    result = operate.GetStatus();
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 获取状态

    #region 获取参数
    result = operate.GetParam();
    LogHelper.Info(result.GetRData<ParamStructure>().ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 获取参数
}

转发应用

  1. 上 “NUGET” 搜索
  2. 安装对应的协议包
  3. 应用代码如下
  4. 协议包内还有内部公共方法，请自行研究使用
//转发协议
//以MQTT为例
using YSAI.Log;
using YSAI.Model.data;
using YSAI.Mqtt.client;
using YSAI.Unility;

using (MqttClientOperate operate = new MqttClientOperate(new MqttClientData.Basics
{
    Ip = "127.0.0.1",
    Port = 11819,
    UserName = "user",
    Password = "password"
}))
{
    #region 打开
    OperateResult result = operate.On();
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化  
    #endregion 打开

    #region 生产
    result = operate.Produce("主题", "内容");
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化  
    #endregion 生产

    #region 消费
    operate.OnEvent += delegate (object? sender, EventResult e)
    {
        LogHelper.Info(e.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    };
    result = operate.Subscribe("主题");
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化  
    #endregion 消费

    #region 关闭
    result = operate.Off();
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化  
    #endregion 关闭

    #region 获取状态
    result = operate.GetStatus();
    LogHelper.Info(result.ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 获取状态

    #region 获取参数
    result = operate.GetParam();
    LogHelper.Info(result.GetRData<ParamStructure>().ToJson().JsonFormatting());   //转成JSON.JSON格式化 
    #endregion 获取参数
}

更新表

2023-02-15

  1. 项目启动
  2. 库框架搭建
  3. 采集订阅流程实现多线程队列形式，处理速度大大提升
//更新，无休眠时间
while(true)
{
	//三大步骤
	1.优化
	2.更新
	3.提交
}

2023-09-20

  1. 采集订阅模式关闭优化
  2. 底层通信库性能提升

2023-09-23

  1. 日志记录优化，更详细的日志记录

2023-09-24

  1. 新增公用库方法
  2. 版本更新
  3. MqttService参数类型修改

2023-09-25

  1. CanLib 文件位置更换
  2. Pack 生成位置更换

2023-09-27

  1. Mqtt 客户端 修改内部公共方法函数名
  2. 转发协议包修改

2023-10-08

  1. 反射新增类库，分为内外使用
  2. 修改转发库获取不到状态问题
  3. 版本更新，提交NUGET
  4. 新增边端 结构参数解析JSON

2023-10-10

  1. 解决OPCUA问题
  2. OPCUA版本更新

2023-10-11 ~ 2023-10-12

  1. 修改 OPCUA 订阅流程逻辑，解决超时问题
  2. 修改 OPCUA 工具显示问题
  3. OPCUA 工具新增 导出 Core 地址对象
  4. 版本更新
  5. 细节更新
  6. 结果类型新增
  7. 单例模式下新增实例数量限制

2023-10-13

  1. 解决RMQ内存增加问题
  2. 新增微秒延时
  3. 版本更新
  4. 新增对象比对方法
  5. 修改 override bool Equals 方法

2023-10-15

  1. 优化细节
  2. 移除 override bool Equals 方法，直接使用对象比对
  3. 版本更新

2023-10-16

  1. 自定义订阅修改
  2. 修改对象比对
  3. 版本更新

2023-10-17

  1. 订阅函数变化更新 新增订阅源数据比对更新，使比对更合理
  2. S7读取修改

2023-10-19

  1. 移除多余脚本代码（只做简单脚本计算）
  2. 优化OPCUA
  3. 版本更新

2023-10-20 ~ 2023-10-23

  1. 新增json字符串判断
  2. 修改opcua当断线重连自动订阅
  3. 修改传输协议的数据格式
  4. 新增新的传输协议 Netty 客户端服务端
  5. 细节优化
  6. 版本更新

2023-10-24 ~ 2023-10-25

  1. 新增数据类型DataTime、Time、Date
  2. 新增倍福客户端
  3. 版本更新，细节优化

2023-10-26

  1. 修改CORE的系统与Unility时间工具
  2. 整体细节优化
  3. 版本更新

2023-10-30

  1. 移除S7非标服务端
  2. 移除Modbus 非标服务端
  3. 底层通信新增字节数从末尾从前移除0x00
  4. 多余代码清理
  5. 版本更新

2023-10-31

  1. OpcUa新增根据设置值自动分配订阅组
  2. OpcDa新增根据设置值自动分配订阅组
  3. 细节优化

2023-11-01

  1. 新增三个特性 单位、验证、展示
  2. 新增获取库参数接口方法【GetParam】
  3. 移除单独生成库配置文件
  4. 细节优化
  5. 新增结构参数类
  6. 版本更新

2023-11-02

  1. 新增创建单例接口方法，为了在反射或获取参数的情况下使用所有功能

2023-11-03

  1. 底层通信读取等待结果新增分批读取
  2. 新增三菱PLC数据采集
  3. 细节优化
  4. 版本更新

2023-11-06

  1. 三菱PLC采集优化
  2. 新增欧姆龙PLC FINS协议采集
  3. 版本更新

2023-11-08

  1. 新增 NETMQ 传输协议（不保证消息质量模式）
  2. 优化函数运行时间，使用 struct 直接操作底层，性能提升
  3. 细节优化，版本更新
  4. 修改所有协议获取参数重复代码，移植至Core

2023-11-09

  1. 新增 AllenBradley PLC采集
  2. 新增S7类型读取流程
  3. 优化CORE内部结构代码
  4. 优化所有采集协议的读取代码
  5. 修改采集协议的OFF方法，新添加订阅OFF
  6. 新增S7、AllenBradley、Mitsubishi、Omron、ModBus 测试服务端（非标准）
  7. 版本更新

2023-11-10

  1. 自定义订阅细节修改，移除不必要的事件
  2. 新增松下PLC
  3. 修改获取参数函数细节
  4. 移除不必要的事件跳转
  5. OpcUa Da 属性BUG修改

2023-11-13

  1. 展示特性中新增详细提示字段，方面展示时了解与指导此属性的详情
  2. Serilog 更新至最新版本
  3. 修改版本规则 ( 年.天.秒 ) ( 23.317.30964 ) -- 23年，第317天，当天的30964秒时生成的版本
  4. 生成nuget包位置更新

2023-11-14

  1. 修改S7库名称，现使用Siemens
  2. 所有库新增详细描述
  3. 等待.net8发布，集成.net8
  4. OPCUA 移除默认XML文件，使用动态创建
  5. 新增版本更新工具，一键更新版本

2023-11-15

  1. 所有库 统一更新，支持 net6.0 、net8.0
  2. mqttwsservice 细节优化

2023-11-16

  1. RPC远程过程调用工具编写
  2. 底层SOCKET WEBSOCKET 修改断线重连规则
  3. 版本更新

2023-11-21

  1. 新增基于DotNetty实现的RPC(远程过程调用) 支持一对多，支持身份验证
  2. RabbitMQ 依赖库更新

2023-11-23

  1. 移除Core中的Redis
  2. 新增 扩展工具 Redis
  3. 修改RPC扩展工具细节
  4. 新增 XML 序列化 反序列化 扩展方法
  5. 新增HEX扩展转换
  6. 版本更新

2023-11-24

  1. 整体框架调整 Core、Model、Extend、Daq、Relay
  2. 实现底层数据转发功能支持热加载热更新
  3. 优化数据解析流程，优化转发流程

2023-11-27

  1. 优化数据结构
  2. 测试底层转发流程（成功）
  3. 测试底层解析流程（成功）
  4. 修改脚本解析默认参数传两个
  5. 修改反射解析默认参数传两个
  6. 新增 动态转发 打开失败重试流程
  7. 版本更新

2023-11-28

  1. 优化数据类型
  2. 优化地址处理函数，严格数据质量
  3. OPCUA 新增当订阅的地址点没有在服务器创建订阅，则重新订阅

2023-11-30

  1. 修改所有协议的函数开始返回的SN
  2. 优化解析，当解析失败异常，则返回空数据，为了更好的判断数据质量
  3. OPCUA新增是否重连，重连间隔参数

2023-12-4

  1. 修改地址处理的细节，让数据质量更准确
  2. 对象比较器更换至[CompareNETObjects]
  3. 新增示例代码
  4. 修改PACK生成代码位置，与主代码不存在引用关系

2023-12-5

  1. 传输协议 netty 更新 ，修复服务端无法群发问题
  2. 修改三菱采集协议包问题
  3. tool 存在遗留问题待解决

2023-12-7

  1. kafka 处理任务优化
  2. 版本更新

2023-12-11

  1. 新增版本自动更新工具
  2. 新增目标框架自动更新工具
  3. 依赖库更新

2023-12-13

  1. 自动更新工具新增自动打包，一键式完整发布流程
  2. 工具主界面修改，性能优化，更友好的交互
  3. 采集协议、传输协议工具开发，正在进行中

2023-12-14

  1. WPF 属性表格研究，为了开发工具时不用手动写入多个属性控件
  2. 所有基础数据新增 Category 特性
  3. 依赖库更新

2023-12-18

  1. 移除关闭时任务等待
  2. 工具界面整体架构更新完成，包含自动加载参数
  3. UDP、TCPSERVICE工具改造完成

2023-12-19

  1. 新增Ws客户端，服务端
  2. 优化Ws Core
  3. 串口、Tcp客户端改造完成
  4. 优化终端展示界面
  5. 新增第一次打开显示默认界面

2023-12-20

  1. 优化工具界面
  2. 改造OPCUA客户端界面

2023-12-22

  1. OPCUA客户端工具改造完成
  2. OPCUA服务端动态库修改
  3. OPCUA服务端工具改造完成

2023-12-25

  1. 修改Mqtt服务端 验证机制
  2. 删除OPCUA服务端 匿名登录机制
  3. OPCDAHTTP 工具改造完成

2023-12-26

  1. mqtt 服务端问题修改
  2. mqtt 客户端新增断开事件
  3. mqtt 客户端服务端工具改造完成
  4. 新增采集、转发工具模版，更快的集成新的驱动
  5. 新增AllenBradley、Beckhoff、Mewtocol、Mitsubishi、Omron、Siemens 工具

2023-12-27 ~ 2023-12-29

  1. MODBUS 底层库读取写入改造完成
  2. 新增 modbus 工具
  3. 工具细节优化
  4. 模版固定值优化

2024-1-2

  1. 新增转发模块工具，kafka、NetMQ、RabbitMQ、Netty

2024-1-3

  1. 修改工具细节
  2. 优化已存在的问题
  3. 新增Windows窗体示例
  4. 新增Windows动画效果示例

2024-1-4

  1. 修改DB采集问题
  2. 优化DB采集的返回数据格式
  3. 工具新增DB数据采集
  4. 采集转发版本更新

2024-1-5

  1. GE 通用电气 PLC 集成，百分之50

2024-1-8

  1. GE 通用电气 PLC 集成完成
  2. OFF接口新增 强制关闭属性
  3. 所有库修改OFF实现与Dispose流程
  4. 依赖库更新

2024-1-9

  1. 修改OPCUA工具节点浏览的节点导出功能
  2. 新增GE工具

2024-1-10

  1. 细节优化
  2. 新增物联网纯配置数采系统（百分之五）