SuncodeSoftware.SuperSDK.Core 5.1.1

SuperSDK.Core

SuperSDK 核心基础库，提供零 UI 依赖的通用工具类和消息系统。

安装

dotnet add 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.Pub(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.Pub(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.Pub(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.RegisterReqHandler<GetConfigRequest, ConfigResponse>(
            this, 
            async req => {
                // 模拟数据库查询
                await Task.Delay(100);
                return new ConfigResponse { Value = "TestValue" };
            }
        );
    }

    ~ConfigService()
    {
        // 方式1：注销特定类型的处理器
        MessageBus.UnregisterReqHandler<GetConfigRequest>(this);
        // 方式2：注销该对象注册的所有处理器和订阅
        // MessageBus.UnsubscribeAll(this);
    }
}

// 发送请求并等待响应（默认超时 5000ms）
var response = await MessageBus.Req<GetConfigRequest, ConfigResponse>(
    new GetConfigRequest { ConfigName = "DataPath" }
);
Console.WriteLine($"Config Value: {response.Value}");

// 指定自定义超时（毫秒）
var response2 = await MessageBus.Req<GetConfigRequest, ConfigResponse>(
    new GetConfigRequest { ConfigName = "DataPath" },
    timeout: 3000
);

// 检查是否已注册处理器
bool hasHandler = MessageBus.HasReqHandler<GetConfigRequest>();

// 查询处理器的所有者
object? owner = MessageBus.GetReqHandlerOwner<GetConfigRequest>();

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;

// 跨平台打开文件夹（Windows/macOS/Linux 自动判断）
bool opened = SystemHelper.OpenFolder("/Users/demo/Documents/MyFolder");

// 跨平台打开 URL（在默认浏览器中打开）
bool opened2 = SystemHelper.OpenUrl("https://scsoftware.cloud");

7. 文件工具类

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 类

SystemHelper 类

FileTools 类

🏗️ 完整 SuperSDK 系列

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

📝 注意事项

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

📄 License

MIT License - 详见 LICENSE 文件

🤝 贡献

欢迎提交 Issue 和 Pull Request！

Made with ❤️ by Goes Team