SuncodeSoftware.SuperSDK.Core 1.1.8

SuperSDK.Core

SuperSDK.Core 是 Goes 应用程序的核心基础库，提供零 UI 依赖的通用工具类和消息系统。

✨ 核心特性

📡 消息总线系统

• ✅ 纯 C# 实现 - 无 ReactiveUI、Avalonia 等 UI 框架依赖
• ✅ 多级通道 - 支持全局、Fixture级、Slot级消息隔离
• ✅ 请求-响应模式 - 支持异步请求处理，带超时控制
• ✅ 性能优化 - 内置数字缓存、通道名优化
• ✅ 线程安全 - 完全线程安全的消息分发

🛠️ 工具类库

• DataPathHelper - 测试数据路径生成（支持 SlotSync、FixtureSync 等模式）
• FileTools - 文件路径验证、文件操作工具
• Utils - 性能测量、随机数生成、文件名解析等

📦 安装

dotnet add package SuperSDK.Core

或通过 NuGet 包管理器：

Install-Package SuperSDK.Core

🚀 快速开始

1. 消息总线 - 基础用法

using SuperSDK.Core.Messaging;

// 定义消息类型
public class TestResultMessage
{
    public string TestName { get; set; }
    public bool Passed { get; set; }
}

// 订阅消息（全局通道）
public class TestObserver
{
    public TestObserver()
    {
        MessageBus.Subscribe<TestResultMessage>(this, OnTestResult);
    }
    
    private void OnTestResult(TestResultMessage msg)
    {
        Console.WriteLine($"Test: {msg.TestName}, Result: {msg.Passed}");
    }
    
    ~TestObserver()
    {
        MessageBus.UnsubscribeAll(this); // 清理订阅
    }
}

// 发送消息
MessageBus.Send(new TestResultMessage 
{ 
    TestName = "Voltage Test", 
    Passed = true 
});

2. Fixture/Slot 级通道隔离

适用于多工位测试场景：

// Fixture 级通道（例如：Fixture 0）
MessageBus.Subscribe<TestResultMessage>(this, msg => {
    Console.WriteLine($"[Fixture 0] {msg.TestName}");
}, fixtureId: 0);

MessageBus.Send(new TestResultMessage { TestName = "Test1", Passed = true }, fixtureId: 0);

// Slot 级通道（例如：Fixture 0, Slot 1）
MessageBus.Subscribe<TestResultMessage>(this, msg => {
    Console.WriteLine($"[F0S1] {msg.TestName}");
}, fixtureId: 0, slotId: 1);

MessageBus.Send(new TestResultMessage { TestName = "Test2", Passed = false }, 
    fixtureId: 0, slotId: 1);

3. 请求-响应模式

// 定义请求和响应类型
public class GetConfigRequest
{
    public string ConfigName { get; set; }
}

public class ConfigResponse
{
    public string Value { get; set; }
}

// 注册请求处理器
public class ConfigService
{
    public ConfigService()
    {
        MessageBus.RegisterRequestHandler<GetConfigRequest, ConfigResponse>(
            this, 
            async req => {
                // 模拟数据库查询
                await Task.Delay(100);
                return new ConfigResponse { Value = "TestValue" };
            }
        );
    }
}

// 发送请求并等待响应
var response = await MessageBus.SendRequest<GetConfigRequest, ConfigResponse>(
    new GetConfigRequest { ConfigName = "DataPath" },
    timeout: 5000 // 5秒超时
);

Console.WriteLine($"Config Value: {response.Value}");

4. 数据路径生成工具

using SuperSDK.Core.Tools;

// SlotSync 模式路径生成
DateTime now = DateTime.Now;
string dataRoot = "D:\\GoesData";

// 1. 创建 Fixture 批次文件夹
string fixturePath = DataPathHelper.GetFixtureBatchFolderPath(
    fixtureId: 0, 
    startTime: now, 
    dataRootPath: dataRoot
);
// 返回: D:\GoesData\2025-12-15\F1_20251215_143052

// 2. 创建 Slot 数据文件夹
string slotPath = DataPathHelper.GetSlotDataFolderPath(
    fixtureId: 0,
    slotId: 0,
    startTime: now,
    workMode: "SlotSync",
    dataRootPath: dataRoot,
    sn: "SN12345",
    fixtureBatchFolderPath: fixturePath
);
// 返回: D:\GoesData\2025-12-15\F1_20251215_143052\S1_SN12345_20251215_143055

// 3. 获取 CSV 文件路径
string csvPath = DataPathHelper.GetDetailedCsvFilePath(
    fixtureId: 0,
    slotId: 0,
    startTime: now,
    workMode: "SlotSync",
    dataRootPath: dataRoot,
    sn: "SN12345",
    fixtureBatchFolderPath: fixturePath
);
// 返回: D:\GoesData\2025-12-15\F1_20251215_143052\S1_SN12345_20251215_143055\ItemResult.csv

// 确保文件夹存在
DataPathHelper.EnsureFolderExists(slotPath);

5. 性能测量工具

using SuperSDK.Core.Tools;

// 方式 1：自动打印耗时
var result = Utils.MeasureTime(() => {
    // 执行耗时操作
    Thread.Sleep(100);
    return "完成";
}, "数据库查询");
// 输出: 数据库查询耗时: 100 ms

// 方式 2：获取耗时数据
var result2 = Utils.MeasureTime(() => {
    Thread.Sleep(50);
    return 42;
}, out TimeSpan elapsed);

Console.WriteLine($"操作耗时: {elapsed.TotalMilliseconds:F2} ms");

6. 文件工具类

using SuperSDK.Core.Tools;

// 验证路径
bool isValid = FileTools.IsValidPath("C:\\Data\\test.csv"); // true
bool isInvalid = FileTools.IsValidPath("C:\\Data\\test?.csv"); // false (? 是非法字符)

// 检查路径是否存在
if (FileTools.PathExists("D:\\Data"))
{
    Console.WriteLine("路径存在");
}

// 确保目录存在
FileTools.EnsureDirectoryExists("D:\\Logs\\2025-12-15");

// 安全删除文件
bool deleted = FileTools.SafeDeleteFile("D:\\temp.txt");

// 获取文件大小
long fileSize = FileTools.GetFileSize("D:\\data.csv");
Console.WriteLine($"文件大小: {fileSize} 字节");

📖 API 文档

MessageBus 类

发送消息

订阅消息

取消订阅

请求-响应

DataPathHelper 类

Utils 类

FileTools 类

🏗️ 完整 SuperSDK 系列

SuperSDK 采用分层架构，按需引用：

📝 注意事项

• ✅ 线程安全：所有 API 都是线程安全的
• ✅ 内存管理：记得在对象销毁时调用 MessageBus.UnsubscribeAll(this)
• ✅ 性能优化：使用 Fixture/Slot 级通道避免全局消息泛滥
• ⚠️ 订阅管理：避免重复订阅同一消息类型

📄 License

MIT License - 详见 LICENSE 文件

🤝 贡献

欢迎提交 Issue 和 Pull Request！

Made with ❤️ by Goes Team