bo4e_core/com/
load_curve_data.rs

1//! Load curve data (Lastkurvendaten) component.
2
3use chrono::{DateTime, Utc};
4use serde::{Deserialize, Serialize};
5
6use crate::enums::Unit;
7use crate::traits::{Bo4eMeta, Bo4eObject};
8
9/// Load curve data containing power measurements over time.
10///
11/// German: Lastkurvendaten
12///
13/// # Example
14///
15/// ```rust
16/// use bo4e_core::com::LoadCurveData;
17/// use bo4e_core::enums::Unit;
18/// use chrono::Utc;
19///
20/// let data = LoadCurveData {
21///     timestamp: Some(Utc::now()),
22///     power_value: Some(125.5),
23///     power_unit: Some(Unit::Kilowatt),
24///     interval_minutes: Some(15),
25///     ..Default::default()
26/// };
27/// ```
28#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
29#[cfg_attr(feature = "json-schema", derive(schemars::JsonSchema))]
30#[cfg_attr(feature = "json-schema", schemars(rename = "Lastkurvendaten"))]
31#[serde(rename_all = "camelCase")]
32pub struct LoadCurveData {
33    /// BO4E metadata
34    #[serde(flatten)]
35    pub meta: Bo4eMeta,
36
37    /// Timestamp of the measurement (Zeitpunkt)
38    #[serde(skip_serializing_if = "Option::is_none")]
39    #[cfg_attr(feature = "json-schema", schemars(rename = "zeitpunkt"))]
40    pub timestamp: Option<DateTime<Utc>>,
41
42    /// Power value (Leistungswert)
43    #[serde(skip_serializing_if = "Option::is_none")]
44    #[cfg_attr(feature = "json-schema", schemars(rename = "leistungswert"))]
45    pub power_value: Option<f64>,
46
47    /// Unit of power measurement (Leistungseinheit)
48    #[serde(skip_serializing_if = "Option::is_none")]
49    #[cfg_attr(feature = "json-schema", schemars(rename = "leistungseinheit"))]
50    pub power_unit: Option<Unit>,
51
52    /// Energy value for the interval (Energiewert)
53    #[serde(skip_serializing_if = "Option::is_none")]
54    #[cfg_attr(feature = "json-schema", schemars(rename = "energiewert"))]
55    pub energy_value: Option<f64>,
56
57    /// Unit of energy measurement (Energieeinheit)
58    #[serde(skip_serializing_if = "Option::is_none")]
59    #[cfg_attr(feature = "json-schema", schemars(rename = "energieeinheit"))]
60    pub energy_unit: Option<Unit>,
61
62    /// Interval duration in minutes (Intervalllaenge)
63    #[serde(skip_serializing_if = "Option::is_none")]
64    #[cfg_attr(feature = "json-schema", schemars(rename = "intervalllaenge"))]
65    pub interval_minutes: Option<i32>,
66
67    /// OBIS code (OBIS-Kennzahl)
68    #[serde(skip_serializing_if = "Option::is_none")]
69    #[cfg_attr(feature = "json-schema", schemars(rename = "obisKennzahl"))]
70    pub obis_code: Option<String>,
71
72    /// Measurement location ID (Messlokations-ID)
73    #[serde(skip_serializing_if = "Option::is_none")]
74    #[cfg_attr(feature = "json-schema", schemars(rename = "messlokationsId"))]
75    pub measurement_location_id: Option<String>,
76}
77
78impl Bo4eObject for LoadCurveData {
79    fn type_name_german() -> &'static str {
80        "Lastkurvendaten"
81    }
82
83    fn type_name_english() -> &'static str {
84        "LoadCurveData"
85    }
86
87    fn meta(&self) -> &Bo4eMeta {
88        &self.meta
89    }
90
91    fn meta_mut(&mut self) -> &mut Bo4eMeta {
92        &mut self.meta
93    }
94}
95
96#[cfg(test)]
97mod tests {
98    use super::*;
99    use chrono::TimeZone;
100
101    #[test]
102    fn test_load_curve_data() {
103        let data = LoadCurveData {
104            timestamp: Some(Utc.with_ymd_and_hms(2024, 1, 15, 12, 15, 0).unwrap()),
105            power_value: Some(125.5),
106            power_unit: Some(Unit::Kilowatt),
107            interval_minutes: Some(15),
108            ..Default::default()
109        };
110
111        let json = serde_json::to_string(&data).unwrap();
112        assert!(json.contains("125.5"));
113        assert!(json.contains("15"));
114    }
115
116    #[test]
117    fn test_with_energy() {
118        let data = LoadCurveData {
119            timestamp: Some(Utc::now()),
120            power_value: Some(100.0),
121            power_unit: Some(Unit::Kilowatt),
122            energy_value: Some(25.0),
123            energy_unit: Some(Unit::KilowattHour),
124            interval_minutes: Some(15),
125            ..Default::default()
126        };
127
128        let json = serde_json::to_string(&data).unwrap();
129        assert!(json.contains("100"));
130        assert!(json.contains("25"));
131    }
132
133    #[test]
134    fn test_roundtrip() {
135        let data = LoadCurveData {
136            timestamp: Some(Utc::now()),
137            power_value: Some(999.99),
138            power_unit: Some(Unit::Kilowatt),
139            obis_code: Some("1-0:1.4.0".to_string()),
140            ..Default::default()
141        };
142
143        let json = serde_json::to_string(&data).unwrap();
144        let parsed: LoadCurveData = serde_json::from_str(&json).unwrap();
145        assert_eq!(data.power_value, parsed.power_value);
146        assert_eq!(data.obis_code, parsed.obis_code);
147    }
148
149    #[test]
150    fn test_bo4e_object_impl() {
151        assert_eq!(LoadCurveData::type_name_german(), "Lastkurvendaten");
152        assert_eq!(LoadCurveData::type_name_english(), "LoadCurveData");
153    }
154}
bo4e_core/com/load_curve_data.rs

bo4e_core/com/
load_curve_data.rs
