feat: add worker stream timestamp

[muverystrong]

No description provided.

[szl97]

@claude 检查提交的代码，使用中文回复

[szl97]

Claude finished @szl97's task —— View job

---

代码审查结果

任务清单:

• 分析修改的文件
• 检查 TaskWrapper.java 中的时间戳功能实现
• 检查 pom.xml 版本变更
• 提供详细的代码审查反馈

📋 变更摘要

本次提交包含以下变更：

1. 版本升级：所有模块从 1.2.73 升级到 1.2.74
2. 时间戳功能：在 TaskWrapper.Event 类中添加了时间戳字段和相关处理逻辑

🔍 详细审查反馈

✅ 优点

1. 功能完整性：时间戳字段的添加覆盖了完整的生命周期（字段定义、构造器传参、序列化输出）
2. 一致性：版本号在所有 pom.xml 文件中保持一致
3. 向后兼容：新增的时间戳字段不会破坏现有的 API

⚠️ 需要关注的问题

1. 时间精度和时区问题

// api/spi/src/main/java/com/ke/bella/queue/TaskWrapper.java:77
System.currentTimeMillis()

• 使用 System.currentTimeMillis() 返回 UTC 毫秒时间戳
• 建议考虑是否需要更明确的时区处理或时间格式规范
• 如果需要在分布式环境中使用，考虑时间同步问题

2. 序列化一致性

// api/spi/src/main/java/com/ke/bella/queue/TaskWrapper.java:86
map.put("timestamp", String.valueOf(getTimestamp()));

• 将 long 类型转换为 String 存储在 Map 中
• 建议确认下游系统是否能正确处理字符串格式的时间戳
• 考虑是否需要统一的时间戳格式规范

3. 构造器重载

• Event 类现在有5个参数，构造器相对较长
• 建议考虑使用 Builder 模式或提供更多便捷的构造方法

💡 改进建议

1. 添加时间戳格式化方法

public String getFormattedTimestamp() {
    return Instant.ofEpochMilli(timestamp).toString(); // ISO-8601格式
}

2. 考虑添加字段验证

public static <T> Event<T> of(String name, T payload) {
    long currentTime = System.currentTimeMillis();
    if (currentTime <= 0) {
        throw new IllegalStateException("Invalid system time");
    }
    return new Event<>(name, StringUtils.EMPTY, payload, StringUtils.EMPTY, currentTime);
}

3. 文档补充
   建议在代码中添加 JavaDoc 说明时间戳的格式和时区信息：

/**
 * Event timestamp in milliseconds since Unix epoch (UTC)
 */
long timestamp;

🎯 总体评价

这是一个简洁且实用的功能增强，代码实现合理，遵循了现有的代码风格。时间戳功能对于监控和调试分布式任务处理系统很有价值。版本号升级也很规范。

推荐状态：✅ 建议合并（可选择性地考虑上述改进建议）

---