ek-data 0.1.0

Trading data contracts for the enkeep ek ecosystem: venue enums, zero-dep epoch-nanosecond time, vt-symbol convention, bus event dictionary, tick/bar/ord/trade/position/account/contract objects and request objects (Python enkeep_trade trader/object.py + constant.py, faithfully ported).
Documentation
//! 零依赖时间面:纪元纳秒 ↔ civil(年月日时分秒)双向换算。
//!
//! Python 版 `TickData.datetime` 等字段用本地 naive `datetime`;
//! Rust 版统一为 **UTC 纪元纳秒**([`DtNs`]),本地化/展示层由使用方处理
//! (DESIGN.md 决定 8-A)。换算采用 Howard Hinnant 的 civil_from_days /
//! days_from_civil 算法(公历 1582-10-15 起全域正确),均以单测钉死。

use std::time::{SystemTime, UNIX_EPOCH};

/// 一秒的纳秒数。
pub const NANOS_PER_SEC: i64 = 1_000_000_000;
/// 一天的纳秒数(86400 s,不涉闰秒)。
pub const NANOS_PER_DAY: i64 = 86_400 * NANOS_PER_SEC;

/// 时间戳:Unix 纪元(The Epoch, 1970-01-01T00:00:00Z)起的纳秒。
pub type DtNs = i64;

/// 交易日序数:Unix 纪元起的天数(向下取整,含负数)。
pub type Day = i32;

/// civil 纪元日天数 → 纪元日序数(Hinnant days_from_civil)。
///
/// 公历,"March through February" 换年修正。
pub fn days_from_civil(y: i32, m: u32, d: u32) -> Day {
    let y = if m <= 2 { y - 1 } else { y } as i64;
    let era = if y >= 0 { y } else { y - 399 } / 400;
    let yoe = y - era * 400; // [0, 399]
    let mp: i64 = ((m as i64) + 9) % 12; // [0, 11]: Mar = 0
    let doy = (153 * mp + 2) / 5 + (d as i64) - 1; // [0, 365]
    let doe = yoe * 365 + yoe / 4 - yoe / 100 + doy; // [0, 146096]
    (era * 146097 + doe - 719468) as Day
}

/// 纪元日序数 → civil (年, 月, 日)(Hinnant civil_from_days)。
pub fn civil_from_days(z: Day) -> (i32, u32, u32) {
    let z = z as i64 + 719468;
    let era = if z >= 0 { z } else { z - 146096 } / 146097;
    let doe = z - era * 146097; // [0, 146096]
    let yoe = (doe - doe / 1460 + doe / 36524 - doe / 146096) / 365; // [0, 399]
    let y = yoe + era * 400;
    let doy = doe - (365 * yoe + yoe / 4 - yoe / 100); // [0, 365]
    let mp = (5 * doy + 2) / 153; // [0, 11]
    let d = (doy - (153 * mp + 2) / 5 + 1) as u32; // [1, 31]
    let m = (if mp < 10 { mp + 3 } else { mp - 9 }) as u32; // [1, 12]
    ((y + if m <= 2 { 1 } else { 0 }) as i32, m, d)
}

/// civil 六元组 + 毫微段(一日内)。
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct Civil {
    /// 年(可为负)
    pub year: i32,
    /// 月 [1, 12]
    pub month: u32,
    /// 日 [1, 31]
    pub day: u32,
    /// 时 [0, 23]
    pub hour: u32,
    /// 分 [0, 59]
    pub minute: u32,
    /// 秒 [0, 59]
    pub second: u32,
    /// 纳秒段 [0, 999999999]
    pub nanos: u32,
}

/// civil → 纪元纳秒(以 civil 视作 UTC,无时区移位)。
pub fn civil_to_nanos(c: Civil) -> DtNs {
    let days = days_from_civil(c.year, c.month, c.day) as i64;
    days * NANOS_PER_DAY
        + (c.hour as i64) * 3600 * NANOS_PER_SEC
        + (c.minute as i64) * 60 * NANOS_PER_SEC
        + (c.second as i64) * NANOS_PER_SEC
        + c.nanos as i64
}

/// 纪元纳秒 → civil(UTC 视角;除法对负纳秒采用 floor 保证越日正确)。
pub fn civil_from_nanos(t: DtNs) -> Civil {
    let days = t.div_euclid(NANOS_PER_DAY);
    let secs_of_day = t.rem_euclid(NANOS_PER_DAY);
    let (year, month, day) = civil_from_days(days as Day);
    let total_sec = secs_of_day / NANOS_PER_SEC;
    let nanos = (secs_of_day % NANOS_PER_SEC) as u32;
    Civil {
        year,
        month,
        day,
        hour: (total_sec / 3600) as u32,
        minute: (total_sec % 3600 / 60) as u32,
        second: (total_sec % 60) as u32,
        nanos,
    }
}

/// 当前时刻的纪元纳秒(SystemTime 视角)。
pub fn now_nanos() -> DtNs {
    from_system_time(SystemTime::now())
}

/// 纪元纳秒所在交易日序数(向下取整,负纳秒同样正确)。
pub fn trading_day(t: DtNs) -> Day {
    t.div_euclid(NANOS_PER_DAY) as Day
}

/// `SystemTime` → 纪元纳秒(epoch 之前取负;独立函数,避免为基本类型
/// `i64` 实现外部 trait——orphan 规则)。
pub fn from_system_time(t: SystemTime) -> DtNs {
    match t.duration_since(UNIX_EPOCH) {
        Ok(d) => d.as_nanos() as DtNs,
        Err(e) => -(e.duration().as_nanos() as DtNs),
    }
}

/// `yyyy-mm-dd hh:mm:ss(.fffffffff 有 nanos 才显示)` 文本(UTC 视角)。
///
/// 仅供日志/调试;持久层自行格式化。
pub fn format_civil(t: DtNs) -> String {
    let c = civil_from_nanos(t);
    let base = format!(
        "{:04}-{:02}-{:02} {:02}:{:02}:{:02}",
        c.year, c.month, c.day, c.hour, c.minute, c.second
    );
    if c.nanos == 0 {
        base
    } else {
        format!("{base}.{:09}", c.nanos)
    }
}