automapper_validation/generated/fv2604/mscons_conditions_fv2604.rs
1// <auto-generated>
2// Generated by automapper-generator generate-conditions
3// AHB: xml-migs-and-ahbs/FV2604/MSCONS_AHB_3_1g_20251001.xml
4// Generated: 2026-03-12T11:36:06Z
5// </auto-generated>
6
7// LLM-produced bodies aren't idiomatic Rust — silence stylistic lints at
8// file scope so `cargo clippy -D warnings` stays green. Correctness,
9// suspicious, and perf categories stay on so real bugs still surface.
10#![allow(clippy::style, clippy::complexity)]
11
12#[allow(unused_imports)]
13use crate::eval::format_validators::*;
14use crate::eval::{ConditionEvaluator, ConditionResult, EvaluationContext};
15
16/// Generated condition evaluator for MSCONS FV2604.
17pub struct MsconsConditionEvaluatorFV2604 {
18 // External condition IDs that require runtime context.
19 external_conditions: std::collections::HashSet<u32>,
20}
21
22impl Default for MsconsConditionEvaluatorFV2604 {
23 fn default() -> Self {
24 let mut external_conditions = std::collections::HashSet::new();
25 external_conditions.insert(1);
26 external_conditions.insert(22);
27 external_conditions.insert(32);
28 external_conditions.insert(33);
29 external_conditions.insert(35);
30 external_conditions.insert(36);
31 external_conditions.insert(42);
32 external_conditions.insert(67);
33 external_conditions.insert(77);
34 external_conditions.insert(80);
35 external_conditions.insert(81);
36 external_conditions.insert(97);
37 external_conditions.insert(117);
38 external_conditions.insert(118);
39 external_conditions.insert(126);
40 external_conditions.insert(127);
41 external_conditions.insert(138);
42 external_conditions.insert(141);
43 external_conditions.insert(492);
44 external_conditions.insert(493);
45 Self {
46 external_conditions,
47 }
48 }
49}
50
51impl ConditionEvaluator for MsconsConditionEvaluatorFV2604 {
52 fn message_type(&self) -> &str {
53 "MSCONS"
54 }
55
56 fn format_version(&self) -> &str {
57 "FV2604"
58 }
59
60 fn evaluate(&self, condition: u32, ctx: &EvaluationContext) -> ConditionResult {
61 match condition {
62 1 => self.evaluate_1(ctx),
63 2 => self.evaluate_2(ctx),
64 11 => self.evaluate_11(ctx),
65 12 => self.evaluate_12(ctx),
66 17 => self.evaluate_17(ctx),
67 18 => self.evaluate_18(ctx),
68 22 => self.evaluate_22(ctx),
69 23 => self.evaluate_23(ctx),
70 24 => self.evaluate_24(ctx),
71 27 => self.evaluate_27(ctx),
72 28 => self.evaluate_28(ctx),
73 32 => self.evaluate_32(ctx),
74 33 => self.evaluate_33(ctx),
75 35 => self.evaluate_35(ctx),
76 36 => self.evaluate_36(ctx),
77 38 => self.evaluate_38(ctx),
78 42 => self.evaluate_42(ctx),
79 45 => self.evaluate_45(ctx),
80 46 => self.evaluate_46(ctx),
81 48 => self.evaluate_48(ctx),
82 49 => self.evaluate_49(ctx),
83 50 => self.evaluate_50(ctx),
84 51 => self.evaluate_51(ctx),
85 62 => self.evaluate_62(ctx),
86 67 => self.evaluate_67(ctx),
87 68 => self.evaluate_68(ctx),
88 69 => self.evaluate_69(ctx),
89 70 => self.evaluate_70(ctx),
90 71 => self.evaluate_71(ctx),
91 72 => self.evaluate_72(ctx),
92 73 => self.evaluate_73(ctx),
93 77 => self.evaluate_77(ctx),
94 78 => self.evaluate_78(ctx),
95 79 => self.evaluate_79(ctx),
96 80 => self.evaluate_80(ctx),
97 81 => self.evaluate_81(ctx),
98 83 => self.evaluate_83(ctx),
99 84 => self.evaluate_84(ctx),
100 85 => self.evaluate_85(ctx),
101 86 => self.evaluate_86(ctx),
102 87 => self.evaluate_87(ctx),
103 88 => self.evaluate_88(ctx),
104 90 => self.evaluate_90(ctx),
105 91 => self.evaluate_91(ctx),
106 92 => self.evaluate_92(ctx),
107 93 => self.evaluate_93(ctx),
108 94 => self.evaluate_94(ctx),
109 95 => self.evaluate_95(ctx),
110 96 => self.evaluate_96(ctx),
111 97 => self.evaluate_97(ctx),
112 98 => self.evaluate_98(ctx),
113 99 => self.evaluate_99(ctx),
114 100 => self.evaluate_100(ctx),
115 101 => self.evaluate_101(ctx),
116 108 => self.evaluate_108(ctx),
117 111 => self.evaluate_111(ctx),
118 113 => self.evaluate_113(ctx),
119 117 => self.evaluate_117(ctx),
120 118 => self.evaluate_118(ctx),
121 119 => self.evaluate_119(ctx),
122 121 => self.evaluate_121(ctx),
123 125 => self.evaluate_125(ctx),
124 126 => self.evaluate_126(ctx),
125 127 => self.evaluate_127(ctx),
126 128 => self.evaluate_128(ctx),
127 129 => self.evaluate_129(ctx),
128 130 => self.evaluate_130(ctx),
129 131 => self.evaluate_131(ctx),
130 132 => self.evaluate_132(ctx),
131 133 => self.evaluate_133(ctx),
132 134 => self.evaluate_134(ctx),
133 135 => self.evaluate_135(ctx),
134 138 => self.evaluate_138(ctx),
135 141 => self.evaluate_141(ctx),
136 142 => self.evaluate_142(ctx),
137 143 => self.evaluate_143(ctx),
138 144 => self.evaluate_144(ctx),
139 145 => self.evaluate_145(ctx),
140 146 => self.evaluate_146(ctx),
141 147 => self.evaluate_147(ctx),
142 148 => self.evaluate_148(ctx),
143 149 => self.evaluate_149(ctx),
144 150 => self.evaluate_150(ctx),
145 151 => self.evaluate_151(ctx),
146 152 => self.evaluate_152(ctx),
147 153 => self.evaluate_153(ctx),
148 154 => self.evaluate_154(ctx),
149 490 => self.evaluate_490(ctx),
150 491 => self.evaluate_491(ctx),
151 492 => self.evaluate_492(ctx),
152 493 => self.evaluate_493(ctx),
153 494 => self.evaluate_494(ctx),
154 495 => self.evaluate_495(ctx),
155 501 => self.evaluate_501(ctx),
156 502 => self.evaluate_502(ctx),
157 506 => self.evaluate_506(ctx),
158 509 => self.evaluate_509(ctx),
159 510 => self.evaluate_510(ctx),
160 511 => self.evaluate_511(ctx),
161 512 => self.evaluate_512(ctx),
162 513 => self.evaluate_513(ctx),
163 514 => self.evaluate_514(ctx),
164 515 => self.evaluate_515(ctx),
165 516 => self.evaluate_516(ctx),
166 518 => self.evaluate_518(ctx),
167 519 => self.evaluate_519(ctx),
168 520 => self.evaluate_520(ctx),
169 522 => self.evaluate_522(ctx),
170 523 => self.evaluate_523(ctx),
171 524 => self.evaluate_524(ctx),
172 525 => self.evaluate_525(ctx),
173 526 => self.evaluate_526(ctx),
174 528 => self.evaluate_528(ctx),
175 529 => self.evaluate_529(ctx),
176 530 => self.evaluate_530(ctx),
177 531 => self.evaluate_531(ctx),
178 532 => self.evaluate_532(ctx),
179 535 => self.evaluate_535(ctx),
180 538 => self.evaluate_538(ctx),
181 541 => self.evaluate_541(ctx),
182 543 => self.evaluate_543(ctx),
183 544 => self.evaluate_544(ctx),
184 545 => self.evaluate_545(ctx),
185 546 => self.evaluate_546(ctx),
186 547 => self.evaluate_547(ctx),
187 551 => self.evaluate_551(ctx),
188 553 => self.evaluate_553(ctx),
189 554 => self.evaluate_554(ctx),
190 556 => self.evaluate_556(ctx),
191 557 => self.evaluate_557(ctx),
192 558 => self.evaluate_558(ctx),
193 559 => self.evaluate_559(ctx),
194 560 => self.evaluate_560(ctx),
195 566 => self.evaluate_566(ctx),
196 567 => self.evaluate_567(ctx),
197 568 => self.evaluate_568(ctx),
198 569 => self.evaluate_569(ctx),
199 570 => self.evaluate_570(ctx),
200 571 => self.evaluate_571(ctx),
201 572 => self.evaluate_572(ctx),
202 573 => self.evaluate_573(ctx),
203 574 => self.evaluate_574(ctx),
204 575 => self.evaluate_575(ctx),
205 576 => self.evaluate_576(ctx),
206 577 => self.evaluate_577(ctx),
207 578 => self.evaluate_578(ctx),
208 579 => self.evaluate_579(ctx),
209 580 => self.evaluate_580(ctx),
210 581 => self.evaluate_581(ctx),
211 902 => self.evaluate_902(ctx),
212 904 => self.evaluate_904(ctx),
213 905 => self.evaluate_905(ctx),
214 906 => self.evaluate_906(ctx),
215 907 => self.evaluate_907(ctx),
216 908 => self.evaluate_908(ctx),
217 909 => self.evaluate_909(ctx),
218 910 => self.evaluate_910(ctx),
219 917 => self.evaluate_917(ctx),
220 918 => self.evaluate_918(ctx),
221 922 => self.evaluate_922(ctx),
222 925 => self.evaluate_925(ctx),
223 931 => self.evaluate_931(ctx),
224 932 => self.evaluate_932(ctx),
225 933 => self.evaluate_933(ctx),
226 934 => self.evaluate_934(ctx),
227 935 => self.evaluate_935(ctx),
228 937 => self.evaluate_937(ctx),
229 939 => self.evaluate_939(ctx),
230 940 => self.evaluate_940(ctx),
231 950 => self.evaluate_950(ctx),
232 951 => self.evaluate_951(ctx),
233 960 => self.evaluate_960(ctx),
234 2001 => self.evaluate_2001(ctx),
235 2002 => self.evaluate_2002(ctx),
236 2003 => self.evaluate_2003(ctx),
237 _ => ConditionResult::Unknown,
238 }
239 }
240
241 fn is_external(&self, condition: u32) -> bool {
242 self.external_conditions.contains(&condition)
243 }
244 fn is_known(&self, condition: u32) -> bool {
245 matches!(
246 condition,
247 1 | 2
248 | 11
249 | 12
250 | 17
251 | 18
252 | 22
253 | 23
254 | 24
255 | 27
256 | 28
257 | 32
258 | 33
259 | 35
260 | 36
261 | 38
262 | 42
263 | 45
264 | 46
265 | 48
266 | 49
267 | 50
268 | 51
269 | 62
270 | 67
271 | 68
272 | 69
273 | 70
274 | 71
275 | 72
276 | 73
277 | 77
278 | 78
279 | 79
280 | 80
281 | 81
282 | 83
283 | 84
284 | 85
285 | 86
286 | 87
287 | 88
288 | 90
289 | 91
290 | 92
291 | 93
292 | 94
293 | 95
294 | 96
295 | 97
296 | 98
297 | 99
298 | 100
299 | 101
300 | 108
301 | 111
302 | 113
303 | 117
304 | 118
305 | 119
306 | 121
307 | 125
308 | 126
309 | 127
310 | 128
311 | 129
312 | 130
313 | 131
314 | 132
315 | 133
316 | 134
317 | 135
318 | 138
319 | 141
320 | 142
321 | 143
322 | 144
323 | 145
324 | 146
325 | 147
326 | 148
327 | 149
328 | 150
329 | 151
330 | 152
331 | 153
332 | 154
333 | 490
334 | 491
335 | 492
336 | 493
337 | 494
338 | 495
339 | 501
340 | 502
341 | 506
342 | 509
343 | 510
344 | 511
345 | 512
346 | 513
347 | 514
348 | 515
349 | 516
350 | 518
351 | 519
352 | 520
353 | 522
354 | 523
355 | 524
356 | 525
357 | 526
358 | 528
359 | 529
360 | 530
361 | 531
362 | 532
363 | 535
364 | 538
365 | 541
366 | 543
367 | 544
368 | 545
369 | 546
370 | 547
371 | 551
372 | 553
373 | 554
374 | 556
375 | 557
376 | 558
377 | 559
378 | 560
379 | 566
380 | 567
381 | 568
382 | 569
383 | 570
384 | 571
385 | 572
386 | 573
387 | 574
388 | 575
389 | 576
390 | 577
391 | 578
392 | 579
393 | 580
394 | 581
395 | 902
396 | 904
397 | 905
398 | 906
399 | 907
400 | 908
401 | 909
402 | 910
403 | 917
404 | 918
405 | 922
406 | 925
407 | 931
408 | 932
409 | 933
410 | 934
411 | 935
412 | 937
413 | 939
414 | 940
415 | 950
416 | 951
417 | 960
418 | 2001
419 | 2002
420 | 2003
421 )
422 }
423}
424
425impl MsconsConditionEvaluatorFV2604 {
426 /// [23] Wenn UNH DE0070 mit 1 vorhanden
427 fn evaluate_23(&self, ctx: &EvaluationContext) -> ConditionResult {
428 let segs = ctx.find_segments("UNH");
429 match segs.first() {
430 Some(unh) => match unh.elements.get(3).and_then(|e| e.first()) {
431 Some(val) => ConditionResult::from(val == "1"),
432 None => ConditionResult::False,
433 },
434 None => ConditionResult::False, // segment absent → condition not applicable
435 }
436 }
437
438 /// [24] Bei Aufteilung, in der Nachricht mit der höchsten Übermittlungsnummer
439 // REVIEW: "Bei Aufteilung" = UNH S010 is present (splitting indicator exists). "höchste Übermittlungsnummer" = the last message in the sequence, identified by DE0073 (elements[3][1]) == "F" (final). For non-split messages S010 is absent → False. Confidence medium because EDIFACT S010 usage in MSCONS may vary. (medium confidence)
440 fn evaluate_24(&self, ctx: &EvaluationContext) -> ConditionResult {
441 let unh_segs = ctx.find_segments("UNH");
442 match unh_segs.first() {
443 Some(unh) => {
444 match unh.elements.get(3) {
445 Some(s010) => {
446 // S010 present = splitting in use.
447 // DE0073 (components[1]) == "F" = final/last message in split sequence
448 let is_final = s010.get(1).is_some_and(|v| v == "F");
449 ConditionResult::from(is_final)
450 }
451 None => ConditionResult::False, // No S010 = no splitting
452 }
453 }
454 None => ConditionResult::False, // segment absent → condition not applicable
455 }
456 }
457
458 /// [130] Wenn innerhalb desselben LIN-Segments neben diesem Segment (SG10 DTM+7 Nutzungszeitpunkt) noch das SG10 DTM+60 (Ausführungs- / Änderungszeitpunkt) oder das SG10 DTM+9 (Ablesedatum) vorhanden, dar...
459 // REVIEW: Iterates each SG10 instance (child of SG6 in SG5). For each SG10 containing DTM+7, checks co-located DTM+60 or DTM+9. Parses CCYYMMDDHHMM via Julian Day Number to total minutes, computes absolute difference, then selects threshold based on DST transition: MEZ→MESZ (winter→summer) = 23h, MESZ→MEZ (summer→winter) = 25h, no transition = 24h. Uses is_mesz_utc on the earlier and later timestamps to detect the transition direction. Group path SG5→SG6→SG10 assumed from MSCONS structure; medium confidence because SG path and S010 semantics need verification. (medium confidence)
460 fn evaluate_130(&self, ctx: &EvaluationContext) -> ConditionResult {
461 fn parse_to_minutes(s: &str) -> Option<i64> {
462 let s = if s.len() >= 12 {
463 &s[..12]
464 } else {
465 return None;
466 };
467 if !s.bytes().all(|b| b.is_ascii_digit()) {
468 return None;
469 }
470 let year: i64 = s[0..4].parse().ok()?;
471 let month: i64 = s[4..6].parse().ok()?;
472 let day: i64 = s[6..8].parse().ok()?;
473 let hour: i64 = s[8..10].parse().ok()?;
474 let minute: i64 = s[10..12].parse().ok()?;
475 let a = (14 - month) / 12;
476 let y = year + 4800 - a;
477 let m_adj = month + 12 * a - 3;
478 let jdn = day + (153 * m_adj + 2) / 5 + 365 * y + y / 4 - y / 100 + y / 400 - 32045;
479 Some(jdn * 1440 + hour * 60 + minute)
480 }
481 let nav = match ctx.navigator() {
482 Some(n) => n,
483 None => return ConditionResult::Unknown,
484 };
485 // HAND-EDITED: SG10 is nested under SG9 (LIN) in MSCONS — path is
486 // SG5.SG6.SG9.SG10, not SG5.SG6.SG10. Flattened iteration for clarity.
487 let sg10_count = nav.group_instance_count(&["SG5", "SG6", "SG9", "SG10"]);
488 for si in 0..sg10_count {
489 let dtms = nav.find_segments_in_group("DTM", &["SG5", "SG6", "SG9", "SG10"], si);
490 let t7 = dtms
491 .iter()
492 .find(|d| {
493 d.elements
494 .first()
495 .and_then(|e| e.first())
496 .is_some_and(|v| v == "7")
497 })
498 .and_then(|d| d.elements.first().and_then(|e| e.get(1)))
499 .cloned();
500 if let Some(t7_val) = t7 {
501 let t7_mins = match parse_to_minutes(&t7_val) {
502 Some(v) => v,
503 None => continue,
504 };
505 for &other_qual in &["60", "9"] {
506 let t_other = dtms
507 .iter()
508 .find(|d| {
509 d.elements
510 .first()
511 .and_then(|e| e.first())
512 .is_some_and(|v| v == other_qual)
513 })
514 .and_then(|d| d.elements.first().and_then(|e| e.get(1)))
515 .cloned();
516 if let Some(t_other_val) = t_other {
517 let t_other_mins = match parse_to_minutes(&t_other_val) {
518 Some(v) => v,
519 None => continue,
520 };
521 let diff = (t7_mins - t_other_mins).abs();
522 let (min_str, max_str) = if t7_mins <= t_other_mins {
523 (t7_val.as_str(), t_other_val.as_str())
524 } else {
525 (t_other_val.as_str(), t7_val.as_str())
526 };
527 let min_in_mesz = matches!(is_mesz_utc(min_str), ConditionResult::True);
528 let max_in_mesz = matches!(is_mesz_utc(max_str), ConditionResult::True);
529 // MEZ→MESZ (winter→summer, March): threshold < 23h
530 // MESZ→MEZ (summer→winter, October): threshold < 25h
531 // Same timezone: threshold < 24h
532 let threshold = if !min_in_mesz && max_in_mesz {
533 23 * 60
534 } else if min_in_mesz && !max_in_mesz {
535 25 * 60
536 } else {
537 24 * 60
538 };
539 if diff >= threshold {
540 return ConditionResult::False;
541 }
542 }
543 }
544 }
545 }
546 ConditionResult::True
547 }
548
549 /// [151] Wenn BGM+Z27 (Bewegungsdaten im Kalenderjahr vor Lieferbeginn) vorhanden.
550 fn evaluate_151(&self, ctx: &EvaluationContext) -> ConditionResult {
551 ctx.has_qualifier("BGM", 0, "Z27")
552 }
553
554 /// [152] Wenn BGM+7 (Prozessdatenbericht) vorhanden.
555 fn evaluate_152(&self, ctx: &EvaluationContext) -> ConditionResult {
556 ctx.has_qualifier("BGM", 0, "7")
557 }
558
559 /// [153] Wenn SG9 PIA+5+7-0?:33.86.0 vorhanden
560 fn evaluate_153(&self, ctx: &EvaluationContext) -> ConditionResult {
561 // PIA+5+7-0?:33.86.0 — elements[0][0]="5", elements[1][0]="7-0:33.86.0" (EDIFACT ?-escape for colon)
562 ctx.has_segment_matching_in_group(
563 "PIA",
564 &[(0, 0, "5"), (1, 0, "7-0:33.86.0")],
565 &["SG5", "SG9"],
566 )
567 }
568
569 /// [154] Wenn SG9 PIA+5+7-0?:33.47.0 vorhanden
570 fn evaluate_154(&self, ctx: &EvaluationContext) -> ConditionResult {
571 // PIA+5+7-0?:33.47.0 — elements[0][0]="5", elements[1][0]="7-0:33.47.0" (EDIFACT ?-escape for colon)
572 ctx.has_segment_matching_in_group(
573 "PIA",
574 &[(0, 0, "5"), (1, 0, "7-0:33.47.0")],
575 &["SG5", "SG9"],
576 )
577 }
578
579 /// [578] Hinweis: Wenn es sich um die Übermittlung des Leistungswertes für die Netzentgelte mit Jahresleistungspreissystem handelt.
580 fn evaluate_578(&self, _ctx: &EvaluationContext) -> ConditionResult {
581 // Hinweis: Übermittlung des Leistungswertes für Netzentgelte mit Jahresleistungspreissystem — informational note, always applies
582 ConditionResult::True
583 }
584
585 /// [579] Hinweis: Wenn es sich um die Übermittlung des Leistungswertes für die Netzentgelte mit Monatsleistungspreissystem handelt.
586 fn evaluate_579(&self, _ctx: &EvaluationContext) -> ConditionResult {
587 // Hinweis: Übermittlung des Leistungswertes für Netzentgelte mit Monatsleistungspreissystem — informational note, always applies
588 ConditionResult::True
589 }
590
591 /// [580] Hinweis: Wenn es sich um die Übermittlung des Leistungswertes für die Netzentgelte mit Tagesleistungspreissystem handelt.
592 fn evaluate_580(&self, _ctx: &EvaluationContext) -> ConditionResult {
593 // Hinweis: Übermittlung des Leistungswertes für Netzentgelte mit Tagesleistungspreissystem — informational note, always applies
594 ConditionResult::True
595 }
596
597 /// [581] Hinweis: Wenn es sich um die Übermittlung des Monatsmaximum gemäß WiM handelt.
598 fn evaluate_581(&self, _ctx: &EvaluationContext) -> ConditionResult {
599 // Hinweis: Wenn es sich um die Übermittlung des Monatsmaximum gemäß WiM handelt.
600 // Informational note, always applies
601 ConditionResult::True
602 }
603
604 /// [1] Sofern per ORDERS angefordert
605 /// EXTERNAL: Requires context from outside the message.
606 fn evaluate_1(&self, ctx: &EvaluationContext) -> ConditionResult {
607 ctx.external.evaluate("requested_via_orders")
608 }
609
610 /// [2] Wenn das Zeitintervall zwischen ersten SG10 DTM+163 und letzten SG10 DTM+164 mindestens einen Monat umfasst
611 // REVIEW: Parses year+month from DTM+163 (first) and DTM+164 (last) in format 303 (YYYYMMDDHHmm). Computes calendar-month difference. 'Mindestens einen Monat' interpreted as end month > start month (calendar boundary). Medium confidence due to ambiguity between calendar-month vs. 30-day interpretation. (medium confidence)
612 fn evaluate_2(&self, ctx: &EvaluationContext) -> ConditionResult {
613 let dtm_163 = ctx.find_segments_with_qualifier("DTM", 0, "163");
614 let dtm_164 = ctx.find_segments_with_qualifier("DTM", 0, "164");
615 let first_start = dtm_163
616 .first()
617 .and_then(|s| s.elements.first())
618 .and_then(|e| e.get(1))
619 .map(|s| s.as_str());
620 let last_end = dtm_164
621 .last()
622 .and_then(|s| s.elements.first())
623 .and_then(|e| e.get(1))
624 .map(|s| s.as_str());
625 match (first_start, last_end) {
626 (Some(start), Some(end)) if start.len() >= 6 && end.len() >= 6 => {
627 let start_year: u32 = start[0..4].parse().unwrap_or(0);
628 let start_month: u32 = start[4..6].parse().unwrap_or(0);
629 let end_year: u32 = end[0..4].parse().unwrap_or(0);
630 let end_month: u32 = end[4..6].parse().unwrap_or(0);
631 let start_total = start_year * 12 + start_month;
632 let end_total = end_year * 12 + end_month;
633 ConditionResult::from(end_total >= start_total + 1)
634 }
635 _ => ConditionResult::Unknown,
636 }
637 }
638
639 /// [11] Wenn SG9 PIA+5+7-0?:52.0.22/7-0?:54.0.16/7-0?:54.0.20/7-0?:54.0.22
640 fn evaluate_11(&self, ctx: &EvaluationContext) -> ConditionResult {
641 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
642 let obis_values = ["7-0:52.0.22", "7-0:54.0.16", "7-0:54.0.20", "7-0:54.0.22"];
643 ConditionResult::from(pia_segments.iter().any(|s| {
644 s.elements
645 .get(1)
646 .and_then(|e| e.first())
647 .is_some_and(|v| obis_values.contains(&v.as_str()))
648 }))
649 }
650
651 /// [12] Wenn nicht SG9 PIA+5+7-0?:52.0.22/7-0?:54.0.16/7-0?:54.0.20/7-0?:54.0.22
652 fn evaluate_12(&self, ctx: &EvaluationContext) -> ConditionResult {
653 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
654 let obis_values = ["7-0:52.0.22", "7-0:54.0.16", "7-0:54.0.20", "7-0:54.0.22"];
655 ConditionResult::from(!pia_segments.iter().any(|s| {
656 s.elements
657 .get(1)
658 .and_then(|e| e.first())
659 .is_some_and(|v| obis_values.contains(&v.as_str()))
660 }))
661 }
662
663 /// [17] Wenn nicht SG9 PIA+5+1-b?:9.99.0 (b= Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien)
664 // REVIEW: Checks absence of PIA+5 with OBIS matching pattern '1-{channel}:9.99.0'. The 'b' is a variable channel, so pattern-matching on prefix '1-' and suffix ':9.99.0' is used. Negated because condition is 'Wenn NICHT'. Medium confidence due to pattern-based matching of OBIS code. (medium confidence)
665 fn evaluate_17(&self, ctx: &EvaluationContext) -> ConditionResult {
666 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
667 let has_match = pia_segments.iter().any(|s| {
668 s.elements
669 .get(1)
670 .and_then(|e| e.first())
671 .is_some_and(|v| v.starts_with("1-") && v.ends_with(":9.99.0"))
672 });
673 ConditionResult::from(!has_match)
674 }
675
676 /// [18] Wenn SG9 PIA+5+1-b?:9.99.0 (b= Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien)
677 // REVIEW: Affirmative version of condition 17. True when any PIA+5 has OBIS code matching the '1-{channel}:9.99.0' pattern (combined heat/power or special metering). Medium confidence due to pattern matching. (medium confidence)
678 fn evaluate_18(&self, ctx: &EvaluationContext) -> ConditionResult {
679 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
680 ConditionResult::from(pia_segments.iter().any(|s| {
681 s.elements
682 .get(1)
683 .and_then(|e| e.first())
684 .is_some_and(|v| v.starts_with("1-") && v.ends_with(":9.99.0"))
685 }))
686 }
687
688 /// [22] Wenn Aufteilung vorhanden
689 /// EXTERNAL: Requires context from outside the message.
690 fn evaluate_22(&self, ctx: &EvaluationContext) -> ConditionResult {
691 ctx.external.evaluate("message_splitting")
692 }
693
694 /// [27] Wenn SG9 PIA+5+1-1?:1.9.0 vorhanden
695 fn evaluate_27(&self, ctx: &EvaluationContext) -> ConditionResult {
696 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
697 ConditionResult::from(pia_segments.iter().any(|s| {
698 s.elements
699 .get(1)
700 .and_then(|e| e.first())
701 .is_some_and(|v| v == "1-1:1.9.0")
702 }))
703 }
704
705 /// [28] Wenn SG9 PIA+5+1-1?:1.9.0 nicht vorhanden
706 fn evaluate_28(&self, ctx: &EvaluationContext) -> ConditionResult {
707 let pia_segments = ctx.find_segments_with_qualifier("PIA", 0, "5");
708 ConditionResult::from(!pia_segments.iter().any(|s| {
709 s.elements
710 .get(1)
711 .and_then(|e| e.first())
712 .is_some_and(|v| v == "1-1:1.9.0")
713 }))
714 }
715
716 /// [32] wenn MP-ID in SG2 NAD+MS in der Rolle NB
717 /// EXTERNAL: Requires context from outside the message.
718 fn evaluate_32(&self, ctx: &EvaluationContext) -> ConditionResult {
719 ctx.external.evaluate("sender_is_nb")
720 }
721
722 /// [33] wenn MP-ID in SG2 NAD+MR in der Rolle LF
723 /// EXTERNAL: Requires context from outside the message.
724 fn evaluate_33(&self, ctx: &EvaluationContext) -> ConditionResult {
725 ctx.external.evaluate("recipient_is_lf")
726 }
727
728 /// [35] wenn MP-ID in SG2 NAD+MS in der Rolle MSB
729 /// EXTERNAL: Requires context from outside the message.
730 fn evaluate_35(&self, ctx: &EvaluationContext) -> ConditionResult {
731 ctx.external.evaluate("sender_is_msb")
732 }
733
734 /// [36] wenn MP-ID in SG2 NAD+MR in der Rolle NB
735 /// EXTERNAL: Requires context from outside the message.
736 fn evaluate_36(&self, ctx: &EvaluationContext) -> ConditionResult {
737 ctx.external.evaluate("recipient_is_nb")
738 }
739
740 /// [38] wenn in SG6 LOC+172 DE3225 die ID der Messlokation angegeben ist
741 fn evaluate_38(&self, ctx: &EvaluationContext) -> ConditionResult {
742 // Messlokation = 33-char alphanumeric Zählpunktbezeichnung. A non-empty
743 // value that doesn't match (e.g. an 11-digit MaLo-ID) must be False so
744 // the AHB's XOR branches against condition [119] stay mutually exclusive.
745 let loc_segments = ctx.find_segments_with_qualifier("LOC", 0, "172");
746 match loc_segments.first() {
747 Some(loc) => match loc.elements.get(1).and_then(|e| e.first()) {
748 Some(v) if !v.is_empty() => validate_zahlpunkt(v),
749 _ => ConditionResult::False,
750 },
751 None => ConditionResult::False,
752 }
753 }
754
755 /// [42] Wenn MP-ID in SG2 NAD+MR in der Rolle MSB
756 /// EXTERNAL: Requires context from outside the message.
757 fn evaluate_42(&self, ctx: &EvaluationContext) -> ConditionResult {
758 ctx.external.evaluate("recipient_is_msb")
759 }
760
761 /// [45] Wenn SG9 PIA+5+7-b:99.41.16 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
762 fn evaluate_45(&self, ctx: &EvaluationContext) -> ConditionResult {
763 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
764 ConditionResult::from(pias.iter().any(|s| {
765 s.elements
766 .get(1)
767 .and_then(|e| e.first())
768 .is_some_and(|v| v.starts_with("7-") && v.ends_with(":99.41.16"))
769 }))
770 }
771
772 /// [46] Wenn Wert in SG6 LOC+172 DE3225 genau 11 Stellen
773 fn evaluate_46(&self, ctx: &EvaluationContext) -> ConditionResult {
774 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
775 if locs.is_empty() {
776 return ConditionResult::Unknown;
777 }
778 ConditionResult::from(locs.iter().any(|s| {
779 s.elements
780 .get(1)
781 .and_then(|e| e.first())
782 .is_some_and(|v| v.len() == 11)
783 }))
784 }
785
786 /// [48] Wenn SG9 PIA+5+7-0?:52.0.22
787 fn evaluate_48(&self, ctx: &EvaluationContext) -> ConditionResult {
788 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
789 ConditionResult::from(pias.iter().any(|s| {
790 s.elements
791 .get(1)
792 .and_then(|e| e.first())
793 .is_some_and(|v| v == "7-0:52.0.22")
794 }))
795 }
796
797 /// [49] Wenn SG9 PIA+5+7-b?:70.16.16/7-b?:70.16.20/7-b?:70.16.22 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
798 fn evaluate_49(&self, ctx: &EvaluationContext) -> ConditionResult {
799 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
800 ConditionResult::from(pias.iter().any(|s| {
801 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
802 v.starts_with("7-")
803 && (v.ends_with(":70.16.16")
804 || v.ends_with(":70.16.20")
805 || v.ends_with(":70.16.22"))
806 })
807 }))
808 }
809
810 /// [50] Wenn SG9 PIA+5+7-b?:70.18.16/7-b?:70.18.20/7-b?:70.18.22 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
811 fn evaluate_50(&self, ctx: &EvaluationContext) -> ConditionResult {
812 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
813 ConditionResult::from(pias.iter().any(|s| {
814 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
815 v.starts_with("7-")
816 && (v.ends_with(":70.18.16")
817 || v.ends_with(":70.18.20")
818 || v.ends_with(":70.18.22"))
819 })
820 }))
821 }
822
823 /// [51] Wenn SG9 PIA+5+7-0?:33.86.0 vorhanden ist, darf mittels Wiederholung SG9 LIN in derselben Nachricht das SG9 PIA+5+7-0?:52.0.22/7-0?:54.0.16/7-0?:54.0.20/7-0?:54.0.22 nicht mehr angegeben werden
824 // REVIEW: Mutual-exclusion constraint: if 7-0:33.86.0 is present, none of the listed 52/54.x codes may appear. Returns True when constraint is satisfied (i.e. 33.86.0 absent, or 33.86.0 present but excluded codes absent). Returns True when 33.86.0 is not present because the constraint simply does not apply. (medium confidence)
825 fn evaluate_51(&self, ctx: &EvaluationContext) -> ConditionResult {
826 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
827 let has_3386 = pias.iter().any(|s| {
828 s.elements
829 .get(1)
830 .and_then(|e| e.first())
831 .is_some_and(|v| v == "7-0:33.86.0")
832 });
833 if !has_3386 {
834 return ConditionResult::True;
835 }
836 let excluded = ["7-0:52.0.22", "7-0:54.0.16", "7-0:54.0.20", "7-0:54.0.22"];
837 ConditionResult::from(!pias.iter().any(|s| {
838 s.elements
839 .get(1)
840 .and_then(|e| e.first())
841 .is_some_and(|v| excluded.contains(&v.as_str()))
842 }))
843 }
844
845 /// [62] Wenn Wert in SG6 LOC+172 DE3225 genau 33 Stellen
846 fn evaluate_62(&self, ctx: &EvaluationContext) -> ConditionResult {
847 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
848 if locs.is_empty() {
849 return ConditionResult::Unknown;
850 }
851 ConditionResult::from(locs.iter().any(|s| {
852 s.elements
853 .get(1)
854 .and_then(|e| e.first())
855 .is_some_and(|v| v.len() == 33)
856 }))
857 }
858
859 /// [67] Wenn es sich um die Referenz auf eine ORDERS handelt
860 /// EXTERNAL: Requires context from outside the message.
861 // REVIEW: Checks whether the current MSCONS transaction references an ORDERS message. While RFF segments can carry cross-message references, the specific qualifier that marks an ORDERS reference is not provided in the segment structure reference, and determining whether a reference points to an ORDERS vs. another message type typically requires external business context about the originating transaction. (medium confidence)
862 fn evaluate_67(&self, ctx: &EvaluationContext) -> ConditionResult {
863 ctx.external.evaluate("is_orders_reference")
864 }
865
866 /// [68] Wenn BGM+7 vorhanden
867 fn evaluate_68(&self, ctx: &EvaluationContext) -> ConditionResult {
868 ctx.has_qualifier("BGM", 0, "7")
869 }
870
871 /// [69] Wenn BGM+Z28 vorhanden
872 fn evaluate_69(&self, ctx: &EvaluationContext) -> ConditionResult {
873 ctx.has_qualifier("BGM", 0, "Z28")
874 }
875
876 /// [70] Wenn BGM+BK vorhanden
877 fn evaluate_70(&self, ctx: &EvaluationContext) -> ConditionResult {
878 ctx.has_qualifier("BGM", 0, "BK")
879 }
880
881 /// [71] Wenn BGM+Z39 vorhanden
882 fn evaluate_71(&self, ctx: &EvaluationContext) -> ConditionResult {
883 ctx.has_qualifier("BGM", 0, "Z39")
884 }
885
886 /// [72] Wenn SG9 PIA+5+1-b?:1.6.0/1-b?:3.6.0/1-b?:4.6.0/1-66?:13.6.0/1-66?:14.6.0 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
887 fn evaluate_72(&self, ctx: &EvaluationContext) -> ConditionResult {
888 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
889 ConditionResult::from(pias.iter().any(|s| {
890 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
891 (v.starts_with("1-")
892 && (v.ends_with(":1.6.0") || v.ends_with(":3.6.0") || v.ends_with(":4.6.0")))
893 || v == "1-66:13.6.0"
894 || v == "1-66:14.6.0"
895 })
896 }))
897 }
898
899 /// [73] Wenn SG9 PIA+5+1-b?:1.9.e/1-b?:3.9.0/1-b?:4.9.0/1-66?:13.9.0/1-66?:14.9.0 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien, e=Tarif: Wert gemäß Codeliste der OBIS-Kennzahlen und Me...
900 fn evaluate_73(&self, ctx: &EvaluationContext) -> ConditionResult {
901 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
902 ConditionResult::from(pias.iter().any(|s| {
903 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
904 (v.starts_with("1-") && v.contains(":1.9."))
905 || (v.starts_with("1-") && v.ends_with(":3.9.0"))
906 || (v.starts_with("1-") && v.ends_with(":4.9.0"))
907 || v == "1-66:13.9.0"
908 || v == "1-66:14.9.0"
909 })
910 }))
911 }
912
913 /// [77] Wenn MP-ID in SG2 NAD+MR der RB HKN-R
914 /// EXTERNAL: Requires context from outside the message.
915 fn evaluate_77(&self, ctx: &EvaluationContext) -> ConditionResult {
916 ctx.external
917 .evaluate("recipient_is_hkn_registration_authority")
918 }
919
920 /// [78] Wenn SG9 PIA+5+1-66?:13.6.0/1-66?:14.6.0/1-66?:13.9.0/1-66?:14.9.0 vorhanden
921 // REVIEW: PIA+5 means elements[0][0]='5'. DE7140 (OBIS code) is elements[1][0]. EDIFACT '?:' escape sequences are resolved by the parser to literal ':', so '1-66?:13.6.0' becomes '1-66:13.6.0'. Checks any SG9 group instance for PIA+5 with one of the four OBIS codes. Group path SG6->SG9 is approximate based on MSCONS structure. (medium confidence)
922 fn evaluate_78(&self, ctx: &EvaluationContext) -> ConditionResult {
923 ctx.any_group_has_qualified_value(
924 "PIA",
925 0,
926 "5",
927 1,
928 0,
929 &["1-66:13.6.0", "1-66:14.6.0", "1-66:13.9.0", "1-66:14.9.0"],
930 &["SG6", "SG9"],
931 )
932 }
933
934 /// [79] Wenn SG9 PIA+5+1-66?:13.6.0/1-66?:14.6.0/1-66?:13.9.0/1-66?:14.9.0 nicht vorhanden
935 // REVIEW: Logical negation of condition 78. True when none of the specified OBIS codes appears in any SG9 PIA+5 segment. (medium confidence)
936 fn evaluate_79(&self, ctx: &EvaluationContext) -> ConditionResult {
937 match ctx.any_group_has_qualified_value(
938 "PIA",
939 0,
940 "5",
941 1,
942 0,
943 &["1-66:13.6.0", "1-66:14.6.0", "1-66:13.9.0", "1-66:14.9.0"],
944 &["SG6", "SG9"],
945 ) {
946 ConditionResult::True => ConditionResult::False,
947 ConditionResult::False => ConditionResult::True,
948 ConditionResult::Unknown => ConditionResult::Unknown,
949 }
950 }
951
952 /// [80] Wenn MP-ID in SG2 NAD+MR in der Rolle ÜNB
953 /// EXTERNAL: Requires context from outside the message.
954 fn evaluate_80(&self, ctx: &EvaluationContext) -> ConditionResult {
955 ctx.external.evaluate("recipient_is_uenb")
956 }
957
958 /// [81] Wenn MP-ID in SG2 NAD+MS in der Rolle ÜNB
959 /// EXTERNAL: Requires context from outside the message.
960 fn evaluate_81(&self, ctx: &EvaluationContext) -> ConditionResult {
961 ctx.external.evaluate("sender_is_uenb")
962 }
963
964 /// [83] Wenn in derselben SG9 LIN die Angabe STS+10+Z38 nicht vorhanden
965 // REVIEW: STS 'Grundlage der Energiemenge' has elements[0][0]='10' (Statuskategorie) and elements[1][0]=status code. STS lives in SG10 (child of SG9). Condition is True when NO STS with category 10 and status Z38 exists within SG9/SG10 scope. Using any_group_has_qualified_value on SG9->SG10 path then negating. Group scope is approximate — a precise check would traverse SG9 instances and their SG10 children. (medium confidence)
966 fn evaluate_83(&self, ctx: &EvaluationContext) -> ConditionResult {
967 match ctx.any_group_has_qualified_value("STS", 0, "10", 1, 0, &["Z38"], &["SG9", "SG10"]) {
968 ConditionResult::True => ConditionResult::False,
969 ConditionResult::False => ConditionResult::True,
970 ConditionResult::Unknown => ConditionResult::Unknown,
971 }
972 }
973
974 /// [84] Wenn in derselben SG9 LIN die Angabe STS+10+Z39 nicht vorhanden
975 // REVIEW: Same pattern as condition 83 but for status code Z39. True when no STS+10+Z39 is present in any SG10 within the SG9 scope. (medium confidence)
976 fn evaluate_84(&self, ctx: &EvaluationContext) -> ConditionResult {
977 match ctx.any_group_has_qualified_value("STS", 0, "10", 1, 0, &["Z39"], &["SG9", "SG10"]) {
978 ConditionResult::True => ConditionResult::False,
979 ConditionResult::False => ConditionResult::True,
980 ConditionResult::Unknown => ConditionResult::Unknown,
981 }
982 }
983
984 /// [85] Wenn in derselben SG9 LIN die Angabe STS+10+Z36 nicht vorhanden
985 // REVIEW: Same pattern as condition 83 but for status code Z36. True when no STS+10+Z36 is present in any SG10 within the SG9 scope. (medium confidence)
986 fn evaluate_85(&self, ctx: &EvaluationContext) -> ConditionResult {
987 match ctx.any_group_has_qualified_value("STS", 0, "10", 1, 0, &["Z36"], &["SG9", "SG10"]) {
988 ConditionResult::True => ConditionResult::False,
989 ConditionResult::False => ConditionResult::True,
990 ConditionResult::Unknown => ConditionResult::Unknown,
991 }
992 }
993
994 /// [86] Wenn in derselben SG9 LIN die Angabe STS+10+Z37 nicht vorhanden
995 // REVIEW: Same pattern as condition 83 but for status code Z37. True when no STS+10+Z37 is present in any SG10 within the SG9 scope. (medium confidence)
996 fn evaluate_86(&self, ctx: &EvaluationContext) -> ConditionResult {
997 match ctx.any_group_has_qualified_value("STS", 0, "10", 1, 0, &["Z37"], &["SG9", "SG10"]) {
998 ConditionResult::True => ConditionResult::False,
999 ConditionResult::False => ConditionResult::True,
1000 ConditionResult::Unknown => ConditionResult::Unknown,
1001 }
1002 }
1003
1004 /// [87] Wenn der Wert in DTM+163 DE2380 derselben SG6 LOC+172 mit demselben Wert in SG9 PIA+5 DE7140 der früheste angegebene Zeitpunkt ist
1005 // REVIEW: Checks that DTM+163 in SG6 (with LOC+172) equals the minimum DTM+163 across all SG10 instances beneath that SG6's SG9 children. Medium confidence because the SG9→SG10 child navigation uses a local child instance index (si) passed to the grandchild API, which may behave differently depending on navigator implementation details for two-level child traversal. (medium confidence)
1006 fn evaluate_87(&self, ctx: &EvaluationContext) -> ConditionResult {
1007 let nav = match ctx.navigator() {
1008 Some(n) => n,
1009 None => return ConditionResult::Unknown,
1010 };
1011 let sg6_count = nav.group_instance_count(&["SG5", "SG6"]);
1012 for gi in 0..sg6_count {
1013 let locs = nav.find_segments_in_group("LOC", &["SG5", "SG6"], gi);
1014 let has_loc_172 = locs.iter().any(|s| {
1015 s.elements
1016 .first()
1017 .and_then(|e| e.first())
1018 .is_some_and(|v| v == "172")
1019 });
1020 if !has_loc_172 {
1021 continue;
1022 }
1023 let sg6_dtms = nav.find_segments_in_group("DTM", &["SG5", "SG6"], gi);
1024 let sg6_val = match sg6_dtms
1025 .iter()
1026 .find(|s| {
1027 s.elements
1028 .first()
1029 .and_then(|e| e.first())
1030 .is_some_and(|v| v == "163")
1031 })
1032 .and_then(|s| s.elements.first().and_then(|e| e.get(1)))
1033 .filter(|v| !v.is_empty())
1034 .cloned()
1035 {
1036 Some(v) => v,
1037 None => continue,
1038 };
1039 let sg9_count = nav.child_group_instance_count(&["SG5", "SG6"], gi, "SG9");
1040 let mut sg10_values: Vec<String> = Vec::new();
1041 for si in 0..sg9_count {
1042 let sg10_count = nav.child_group_instance_count(&["SG5", "SG6", "SG9"], si, "SG10");
1043 for ti in 0..sg10_count {
1044 let dtms = nav.find_segments_in_child_group(
1045 "DTM",
1046 &["SG5", "SG6", "SG9"],
1047 si,
1048 "SG10",
1049 ti,
1050 );
1051 for dtm in &dtms {
1052 if dtm
1053 .elements
1054 .first()
1055 .and_then(|e| e.first())
1056 .is_some_and(|v| v == "163")
1057 {
1058 if let Some(val) = dtm.elements.first().and_then(|e| e.get(1)) {
1059 if !val.is_empty() {
1060 sg10_values.push(val.clone());
1061 }
1062 }
1063 }
1064 }
1065 }
1066 }
1067 if let Some(min_val) = sg10_values.iter().min() {
1068 if &sg6_val != min_val {
1069 return ConditionResult::False;
1070 }
1071 }
1072 }
1073 ConditionResult::True
1074 }
1075
1076 /// [88] Wenn der Wert in DTM+164 DE2380 derselben SG6 LOC+172 mit demselben Wert in SG9 PIA+5 DE7140 der späteste angegebene Zeitpunkt ist
1077 // REVIEW: Mirror of condition 87 but for DTM+164 (Ende Messperiode) — checks that the SG6 transmission period end equals the maximum DTM+164 across all SG10 measurement instances under that SG6. Same navigation caveat applies for two-level SG9→SG10 child traversal. (medium confidence)
1078 fn evaluate_88(&self, ctx: &EvaluationContext) -> ConditionResult {
1079 let nav = match ctx.navigator() {
1080 Some(n) => n,
1081 None => return ConditionResult::Unknown,
1082 };
1083 let sg6_count = nav.group_instance_count(&["SG5", "SG6"]);
1084 for gi in 0..sg6_count {
1085 let locs = nav.find_segments_in_group("LOC", &["SG5", "SG6"], gi);
1086 let has_loc_172 = locs.iter().any(|s| {
1087 s.elements
1088 .first()
1089 .and_then(|e| e.first())
1090 .is_some_and(|v| v == "172")
1091 });
1092 if !has_loc_172 {
1093 continue;
1094 }
1095 let sg6_dtms = nav.find_segments_in_group("DTM", &["SG5", "SG6"], gi);
1096 let sg6_val = match sg6_dtms
1097 .iter()
1098 .find(|s| {
1099 s.elements
1100 .first()
1101 .and_then(|e| e.first())
1102 .is_some_and(|v| v == "164")
1103 })
1104 .and_then(|s| s.elements.first().and_then(|e| e.get(1)))
1105 .filter(|v| !v.is_empty())
1106 .cloned()
1107 {
1108 Some(v) => v,
1109 None => continue,
1110 };
1111 let sg9_count = nav.child_group_instance_count(&["SG5", "SG6"], gi, "SG9");
1112 let mut sg10_values: Vec<String> = Vec::new();
1113 for si in 0..sg9_count {
1114 let sg10_count = nav.child_group_instance_count(&["SG5", "SG6", "SG9"], si, "SG10");
1115 for ti in 0..sg10_count {
1116 let dtms = nav.find_segments_in_child_group(
1117 "DTM",
1118 &["SG5", "SG6", "SG9"],
1119 si,
1120 "SG10",
1121 ti,
1122 );
1123 for dtm in &dtms {
1124 if dtm
1125 .elements
1126 .first()
1127 .and_then(|e| e.first())
1128 .is_some_and(|v| v == "164")
1129 {
1130 if let Some(val) = dtm.elements.first().and_then(|e| e.get(1)) {
1131 if !val.is_empty() {
1132 sg10_values.push(val.clone());
1133 }
1134 }
1135 }
1136 }
1137 }
1138 }
1139 if let Some(max_val) = sg10_values.iter().max() {
1140 if &sg6_val != max_val {
1141 return ConditionResult::False;
1142 }
1143 }
1144 }
1145 ConditionResult::True
1146 }
1147
1148 /// [90] Wenn BGM+Z41 vorhanden
1149 fn evaluate_90(&self, ctx: &EvaluationContext) -> ConditionResult {
1150 ctx.has_qualifier("BGM", 0, "Z41")
1151 }
1152
1153 /// [91] Wenn BGM+Z42 vorhanden
1154 fn evaluate_91(&self, ctx: &EvaluationContext) -> ConditionResult {
1155 ctx.has_qualifier("BGM", 0, "Z42")
1156 }
1157
1158 /// [92] Wenn SG10 QTY DE6063 mit Wert 67 vorhanden
1159 fn evaluate_92(&self, ctx: &EvaluationContext) -> ConditionResult {
1160 ctx.any_group_has_qualifier("QTY", 0, "67", &["SG9", "SG10"])
1161 }
1162
1163 /// [93] Wenn SG10 QTY DE6063 mit Wert 220 vorhanden
1164 fn evaluate_93(&self, ctx: &EvaluationContext) -> ConditionResult {
1165 ctx.any_group_has_qualifier("QTY", 0, "220", &["SG9", "SG10"])
1166 }
1167
1168 /// [94] Wenn SG10 QTY DE6063 mit Wert 201 vorhanden
1169 fn evaluate_94(&self, ctx: &EvaluationContext) -> ConditionResult {
1170 ctx.any_group_has_qualifier("QTY", 0, "201", &["SG9", "SG10"])
1171 }
1172
1173 /// [95] Wenn SG10 QTY DE6063 mit Wert 20 vorhanden
1174 fn evaluate_95(&self, ctx: &EvaluationContext) -> ConditionResult {
1175 ctx.any_group_has_qualifier("QTY", 0, "20", &["SG5", "SG10"])
1176 }
1177
1178 /// [96] Wenn SG10 QTY DE6063 mit Wert Z18 vorhanden
1179 fn evaluate_96(&self, ctx: &EvaluationContext) -> ConditionResult {
1180 ctx.any_group_has_qualifier("QTY", 0, "Z18", &["SG5", "SG10"])
1181 }
1182
1183 /// [97] Wenn es sich um die Übermittlung eines Wertes aufgrund der Umstellung der Gasqualität handelt
1184 /// EXTERNAL: Requires context from outside the message.
1185 // REVIEW: Whether this transmission is caused by a gas quality changeover (H-Gas/L-Gas conversion) cannot be determined from EDIFACT message content alone — it is a business context condition. (medium confidence)
1186 fn evaluate_97(&self, ctx: &EvaluationContext) -> ConditionResult {
1187 ctx.external.evaluate("gas_quality_change_transmission")
1188 }
1189
1190 /// [98] Wenn SG9 PIA+5+SOL:Z08 vorhanden
1191 fn evaluate_98(&self, ctx: &EvaluationContext) -> ConditionResult {
1192 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1193 ConditionResult::from(pias.iter().any(|s| {
1194 s.elements
1195 .get(1)
1196 .and_then(|e| e.first())
1197 .is_some_and(|v| v == "SOL")
1198 && s.elements
1199 .get(1)
1200 .and_then(|e| e.get(1))
1201 .is_some_and(|v| v == "Z08")
1202 }))
1203 }
1204
1205 /// [99] Wenn SG9 PIA+5+WID:Z08 vorhanden
1206 fn evaluate_99(&self, ctx: &EvaluationContext) -> ConditionResult {
1207 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1208 ConditionResult::from(pias.iter().any(|s| {
1209 s.elements
1210 .get(1)
1211 .and_then(|e| e.first())
1212 .is_some_and(|v| v == "WID")
1213 && s.elements
1214 .get(1)
1215 .and_then(|e| e.get(1))
1216 .is_some_and(|v| v == "Z08")
1217 }))
1218 }
1219
1220 /// [100] Wenn in derselben SG9 LIN das PIA+5+AUA:Z08 vorhanden
1221 fn evaluate_100(&self, ctx: &EvaluationContext) -> ConditionResult {
1222 ctx.any_group_has_qualified_value("PIA", 0, "5", 1, 0, &["AUA"], &["SG5", "SG9"])
1223 }
1224
1225 /// [101] Wenn in derselben SG9 LIN das PIA+5+FPA:Z08 vorhanden
1226 fn evaluate_101(&self, ctx: &EvaluationContext) -> ConditionResult {
1227 ctx.any_group_has_qualified_value("PIA", 0, "5", 1, 0, &["FPA"], &["SG5", "SG9"])
1228 }
1229
1230 /// [108] wenn SG9 PIA+5+7-b?:99.41.16/7-b?:99.42.16 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
1231 // REVIEW: Checks PIA+5 for OBIS codes matching pattern '7-{channel}:99.41.16' or '7-{channel}:99.42.16' (Wirkenergie-Kennzahlen). The '?' in AHB notation is the EDIFACT release character escaping the colon; parsed segments will contain literal colon. Channel variable 'b' matched via starts_with("7-"). (medium confidence)
1232 fn evaluate_108(&self, ctx: &EvaluationContext) -> ConditionResult {
1233 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1234 ConditionResult::from(pias.iter().any(|s| {
1235 let obis = match s.elements.get(1).and_then(|e| e.first()) {
1236 Some(v) => v.as_str(),
1237 None => return false,
1238 };
1239 let code_list = s
1240 .elements
1241 .get(1)
1242 .and_then(|e| e.get(1))
1243 .map(|v| v.as_str())
1244 .unwrap_or("");
1245 code_list == "Z08"
1246 && obis.starts_with("7-")
1247 && (obis.contains(":99.41.16") || obis.contains(":99.42.16"))
1248 }))
1249 }
1250
1251 /// [111] Wenn SG10 DTM+9 DE2379 in demselben Segment mit Wert 303 vorhanden
1252 fn evaluate_111(&self, ctx: &EvaluationContext) -> ConditionResult {
1253 ConditionResult::from(ctx.self_segment_value_equals("DTM", 0, 2, "303"))
1254 }
1255
1256 /// [113] wenn SG7 RFF+AGK (Konfigurations-ID) vorhanden
1257 fn evaluate_113(&self, ctx: &EvaluationContext) -> ConditionResult {
1258 ctx.has_qualifier("RFF", 0, "AGK")
1259 }
1260
1261 /// [117] Nur MP-ID aus Sparte Strom
1262 /// EXTERNAL: Requires context from outside the message.
1263 fn evaluate_117(&self, ctx: &EvaluationContext) -> ConditionResult {
1264 ctx.external.evaluate("marktpartner_is_strom")
1265 }
1266
1267 /// [118] Nur MP-ID aus Sparte Gas
1268 /// EXTERNAL: Requires context from outside the message.
1269 fn evaluate_118(&self, ctx: &EvaluationContext) -> ConditionResult {
1270 ctx.external.evaluate("marktpartner_is_gas")
1271 }
1272
1273 /// [119] wenn in SG6 LOC+172 DE3225 die ID der Marktlokation angegeben ist
1274 fn evaluate_119(&self, ctx: &EvaluationContext) -> ConditionResult {
1275 // Marktlokation = 11-digit MaLo-ID with BDEW check digit. A non-empty
1276 // value that doesn't match (e.g. a 33-char Zählpunkt) must be False so
1277 // the AHB's XOR branches against condition [38] stay mutually exclusive.
1278 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
1279 match locs.first() {
1280 Some(loc) => match loc.elements.get(1).and_then(|e| e.first()) {
1281 Some(v) if !v.is_empty() => validate_malo_id(v),
1282 _ => ConditionResult::False,
1283 },
1284 None => ConditionResult::False,
1285 }
1286 }
1287
1288 /// [121] wenn BGM+Z43 (Redispatch Ausfallarbeitüberführungszeitreihe) vorhanden
1289 fn evaluate_121(&self, ctx: &EvaluationContext) -> ConditionResult {
1290 ctx.has_qualifier("BGM", 0, "Z43")
1291 }
1292
1293 /// [125] wenn SG9 PIA+5+7-0?:52.0.22/7-b?:53.0.16/7-b?:55.0.16/7-b?:55.0.20/7-b?:55.0.22 (b=Kanal: Wert gemäß Codeliste der OBIS-Kennzahlen und Medien) vorhanden
1294 // REVIEW: Checks PIA+5 for specific OBIS code patterns: '7-0:52.0.22' (fixed channel 0), '7-{b}:53.0.16', '7-{b}:55.0.16', '7-{b}:55.0.20', '7-{b}:55.0.22' (variable channel). These are Blindenergie/Leistungsmessungs-Kennzahlen. Uses contains() to match the OBIS suffix after the channel variable. (medium confidence)
1295 fn evaluate_125(&self, ctx: &EvaluationContext) -> ConditionResult {
1296 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1297 ConditionResult::from(pias.iter().any(|s| {
1298 let obis = match s.elements.get(1).and_then(|e| e.first()) {
1299 Some(v) => v.as_str(),
1300 None => return false,
1301 };
1302 let code_list = s
1303 .elements
1304 .get(1)
1305 .and_then(|e| e.get(1))
1306 .map(|v| v.as_str())
1307 .unwrap_or("");
1308 code_list == "Z08"
1309 && obis.starts_with("7-")
1310 && (obis.contains(":52.0.22")
1311 || obis.contains(":53.0.16")
1312 || obis.contains(":55.0.16")
1313 || obis.contains(":55.0.20")
1314 || obis.contains(":55.0.22"))
1315 }))
1316 }
1317
1318 /// [126] wenn Plausibilisierungshinweise vorliegen
1319 /// EXTERNAL: Requires context from outside the message.
1320 fn evaluate_126(&self, ctx: &EvaluationContext) -> ConditionResult {
1321 ctx.external.evaluate("plausibility_notes_present")
1322 }
1323
1324 /// [127] wenn ein Korrekturgrund anzugeben ist
1325 /// EXTERNAL: Requires context from outside the message.
1326 fn evaluate_127(&self, ctx: &EvaluationContext) -> ConditionResult {
1327 ctx.external.evaluate("correction_reason_required")
1328 }
1329
1330 /// [128] Wenn es sich um eine Ablesung handelt, welche keine Ablesung aufgrund der Änderung an der Messtechnik oder deren Konfiguration ist (z.B. Kundenablesung).
1331 // REVIEW: A regular reading (e.g. Kundenablesung) is distinguished from a meter-change reading by the absence of DTM+60 (Ausführungs-/Änderungszeitpunkt) in the same SG10. DTM+9 presence confirms it is a reading at all; DTM+60 absence confirms it is not due to a meter/config change. Group path SG9→SG10 matches MSCONS LIN-group context; fallback to message-wide if no navigator. (medium confidence)
1332 fn evaluate_128(&self, ctx: &EvaluationContext) -> ConditionResult {
1333 // True when SG10 has a reading date (DTM+9, Ablesedatum) but no device change timestamp (DTM+60),
1334 // indicating a regular reading not caused by meter change or configuration change
1335 ctx.any_group_has_qualifier_without("DTM", 0, "9", "DTM", 0, "60", &["SG9", "SG10"])
1336 }
1337
1338 /// [129] Wenn es sich um eine Ablesung aufgrund der Änderung an der Messtechnik oder deren Konfiguration handelt (z.B. Gerätewechsel).
1339 // REVIEW: A meter-change reading is identified by the co-occurrence of DTM+9 (Ablesedatum) and DTM+60 (Ausführungs-/Änderungszeitpunkt) within the same SG10 instance. Uses direct navigator iteration to check co-occurrence within a single group instance (any_group_has_co_occurrence would have ambiguity for same-tag different qualifiers). Falls back to message-wide check without navigator. (medium confidence)
1340 fn evaluate_129(&self, ctx: &EvaluationContext) -> ConditionResult {
1341 // True when SG10 contains both DTM+9 (Ablesedatum) and DTM+60 (Ausführungs-/Änderungszeitpunkt),
1342 // indicating a reading caused by a meter change or configuration change (e.g. Gerätewechsel)
1343 let nav = match ctx.navigator() {
1344 Some(n) => n,
1345 None => {
1346 let has9 = ctx.has_qualifier("DTM", 0, "9");
1347 let has60 = ctx.has_qualifier("DTM", 0, "60");
1348 return match (has9, has60) {
1349 (ConditionResult::True, ConditionResult::True) => ConditionResult::True,
1350 (ConditionResult::Unknown, _) | (_, ConditionResult::Unknown) => {
1351 ConditionResult::Unknown
1352 }
1353 _ => ConditionResult::False,
1354 };
1355 }
1356 };
1357 let sg10_count = nav.group_instance_count(&["SG9", "SG10"]);
1358 for i in 0..sg10_count {
1359 let dtms = nav.find_segments_in_group("DTM", &["SG9", "SG10"], i);
1360 let has9 = dtms.iter().any(|s| {
1361 s.elements
1362 .first()
1363 .and_then(|e| e.first())
1364 .is_some_and(|v| v == "9")
1365 });
1366 let has60 = dtms.iter().any(|s| {
1367 s.elements
1368 .first()
1369 .and_then(|e| e.first())
1370 .is_some_and(|v| v == "60")
1371 });
1372 if has9 && has60 {
1373 return ConditionResult::True;
1374 }
1375 }
1376 ConditionResult::False
1377 }
1378
1379 /// [131] wenn RFF+AGK (Konfigurations-ID) nicht vorhanden
1380 fn evaluate_131(&self, ctx: &EvaluationContext) -> ConditionResult {
1381 ctx.lacks_qualifier("RFF", 0, "AGK")
1382 }
1383
1384 /// [132] wenn LOC+172 (Identifikationsangabe) DE3225 nicht vorhanden
1385 // REVIEW: Checks if LOC+172 is absent entirely, or if DE3225 (elements[1][0], the Bezeichnung) is empty/missing within the LOC+172 segment. Returns True in either case as the condition is 'DE3225 nicht vorhanden'. (medium confidence)
1386 fn evaluate_132(&self, ctx: &EvaluationContext) -> ConditionResult {
1387 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
1388 match locs.first() {
1389 None => ConditionResult::True,
1390 Some(loc) => {
1391 let de3225_absent = loc
1392 .elements
1393 .get(1)
1394 .and_then(|e| e.first())
1395 .map(|v| v.is_empty())
1396 .unwrap_or(true);
1397 ConditionResult::from(de3225_absent)
1398 }
1399 }
1400 }
1401
1402 /// [133] Wenn innerhalb desselben LIN-Segments neben diesem Segment (SG10 DTM+7 Nutzungszeitpunkt) noch das SG10 DTM+9 (Ablesedatum) mit dem Code 102 im DE2379 vorhanden ist, darf der Wert der Differenz zwi...
1403 // REVIEW: Checks that when DTM+7 (Nutzungszeitpunkt, format 303 CCYYMMDDHHMM) and DTM+9 (Ablesedatum, format 102 CCYYMMDD) co-exist in the same SG10 instance, the CCYYMMDD date part of DTM+7 must equal or be at most 1 calendar day different from DTM+9. Uses a Julian Day Number formula for correct cross-month/year date arithmetic. MSCONS SG10 path assumed as SG5.SG6.SG10 based on the tx_group=SG5 and SG6 being the measurement period container; medium confidence due to path uncertainty. (medium confidence)
1404 fn evaluate_133(&self, ctx: &EvaluationContext) -> ConditionResult {
1405 let nav = match ctx.navigator() {
1406 Some(n) => n,
1407 None => return ConditionResult::Unknown,
1408 };
1409 fn date_to_days(s: &str) -> Option<i64> {
1410 if s.len() < 8 {
1411 return None;
1412 }
1413 let y: i64 = s[..4].parse().ok()?;
1414 let m: i64 = s[4..6].parse().ok()?;
1415 let d: i64 = s[6..8].parse().ok()?;
1416 if m < 1 || m > 12 || d < 1 || d > 31 {
1417 return None;
1418 }
1419 let a = (14 - m) / 12;
1420 let yy = y + 4800 - a;
1421 let mm = m + 12 * a - 3;
1422 Some(d + (153 * mm + 2) / 5 + 365 * yy + yy / 4 - yy / 100 + yy / 400 - 32045)
1423 }
1424 let sg10_count = nav.group_instance_count(&["SG5", "SG6", "SG9", "SG10"]);
1425 if sg10_count == 0 {
1426 return ConditionResult::Unknown;
1427 }
1428 for i in 0..sg10_count {
1429 let dtms = nav.find_segments_in_group("DTM", &["SG5", "SG6", "SG9", "SG10"], i);
1430 let dtm7_val = dtms
1431 .iter()
1432 .find(|s| {
1433 s.elements
1434 .first()
1435 .and_then(|e| e.first())
1436 .is_some_and(|v| v == "7")
1437 })
1438 .and_then(|s| s.elements.first())
1439 .and_then(|e| e.get(1))
1440 .cloned();
1441 let dtm9_val = dtms
1442 .iter()
1443 .find(|s| {
1444 s.elements
1445 .first()
1446 .and_then(|e| e.first())
1447 .is_some_and(|v| v == "9")
1448 && s.elements
1449 .first()
1450 .and_then(|e| e.get(2))
1451 .is_some_and(|v| v == "102")
1452 })
1453 .and_then(|s| s.elements.first())
1454 .and_then(|e| e.get(1))
1455 .cloned();
1456 let (v7, v9) = match (dtm7_val, dtm9_val) {
1457 (Some(v7), Some(v9)) if !v7.is_empty() && !v9.is_empty() => (v7, v9),
1458 _ => continue,
1459 };
1460 let date7 = if v7.len() >= 8 { &v7[..8] } else { continue };
1461 let date9 = if v9.len() >= 8 { &v9[..8] } else { v9.as_str() };
1462 let days7 = match date_to_days(date7) {
1463 Some(d) => d,
1464 None => return ConditionResult::Unknown,
1465 };
1466 let days9 = match date_to_days(date9) {
1467 Some(d) => d,
1468 None => return ConditionResult::Unknown,
1469 };
1470 let diff = (days7 - days9).abs();
1471 if diff > 1 {
1472 return ConditionResult::False;
1473 }
1474 }
1475 ConditionResult::True
1476 }
1477
1478 /// [134] Wenn SG10 DTM+9 DE2379 in demselben Segment mit Wert 102 vorhanden
1479 fn evaluate_134(&self, ctx: &EvaluationContext) -> ConditionResult {
1480 ConditionResult::from(ctx.self_segment_value_equals("DTM", 0, 2, "102"))
1481 }
1482
1483 /// [135] Der Wert an der Stelle CCYYMMDD muss ≤ dem Wert an der Stelle CCYYMMDD im DE2380 des DTM+137 sein
1484 // HAND-EDITED: subject is the current DTM's DE2380 (via ctx.resolved_value), not a
1485 // guessed DTM+9. Compares the CCYYMMDD prefix (first 8 chars) lexicographically,
1486 // which matches both format 303 (CCYYMMDDhhmm+ZZ) and 102 (CCYYMMDD) prefixes.
1487 fn evaluate_135(&self, ctx: &EvaluationContext) -> ConditionResult {
1488 let current = match ctx.resolved_value {
1489 Some(v) if v.len() >= 8 => &v[..8],
1490 _ => return ConditionResult::Unknown,
1491 };
1492 let threshold: String = match ctx
1493 .find_segments_with_qualifier("DTM", 0, "137")
1494 .first()
1495 .and_then(|s| s.elements.first())
1496 .and_then(|e| e.get(1))
1497 .filter(|v| v.len() >= 8)
1498 {
1499 Some(v) => v.chars().take(8).collect(),
1500 None => return ConditionResult::Unknown,
1501 };
1502 ConditionResult::from(current <= threshold.as_str())
1503 }
1504
1505 /// [138] Wenn es sich um eine Korrekturenergiemenge auf einen Wert aus einem iMS handelt
1506 /// EXTERNAL: Requires context from outside the message.
1507 fn evaluate_138(&self, ctx: &EvaluationContext) -> ConditionResult {
1508 ctx.external.evaluate("is_correction_energy_from_ims")
1509 }
1510
1511 /// [141] Wenn MP-ID in SG2 NAD+MR in der Rolle MGV
1512 /// EXTERNAL: Requires context from outside the message.
1513 fn evaluate_141(&self, ctx: &EvaluationContext) -> ConditionResult {
1514 ctx.external.evaluate("recipient_is_mgv")
1515 }
1516
1517 /// [142] wenn im DE3155 in demselben COM der Code EM vorhanden ist
1518 fn evaluate_142(&self, ctx: &EvaluationContext) -> ConditionResult {
1519 let coms = ctx.find_segments("COM");
1520 ConditionResult::from(coms.iter().any(|s| {
1521 s.elements
1522 .first()
1523 .and_then(|e| e.get(1))
1524 .is_some_and(|v| v == "EM")
1525 }))
1526 }
1527
1528 /// [143] wenn im DE3155 in demselben COM der Code TE / FX / AJ / AL vorhanden ist
1529 fn evaluate_143(&self, ctx: &EvaluationContext) -> ConditionResult {
1530 let coms = ctx.find_segments("COM");
1531 ConditionResult::from(coms.iter().any(|s| {
1532 s.elements
1533 .first()
1534 .and_then(|e| e.get(1))
1535 .is_some_and(|v| matches!(v.as_str(), "TE" | "FX" | "AJ" | "AL"))
1536 }))
1537 }
1538
1539 /// [144] Wenn Wert in SG7 RFF+AGK DE1154 (Konfigurations-ID) vorhanden
1540 fn evaluate_144(&self, ctx: &EvaluationContext) -> ConditionResult {
1541 let rffs = ctx.find_segments_with_qualifier("RFF", 0, "AGK");
1542 match rffs.first() {
1543 None => ConditionResult::False,
1544 Some(rff) => {
1545 let has_value = rff
1546 .elements
1547 .first()
1548 .and_then(|e| e.get(1))
1549 .map(|v| !v.is_empty())
1550 .unwrap_or(false);
1551 ConditionResult::from(has_value)
1552 }
1553 }
1554 }
1555
1556 /// [145] Wenn in derselben S9 LIN das SG10 DTM+163 (Beginn Messperiode) nicht vorhanden ist.
1557 // REVIEW: Checks absence of DTM+163 (Beginn Messperiode) in the message. The condition references the same SG10 context within the enclosing LIN group; without the exact MSCONS group path this is a message-wide approximation. Note: DTM+163 also appears in SG6 (Übertragungszeitraum), so this may yield false-negatives for the SG10-scoped intent. (medium confidence)
1558 fn evaluate_145(&self, ctx: &EvaluationContext) -> ConditionResult {
1559 ctx.lacks_qualifier("DTM", 0, "163")
1560 }
1561
1562 /// [146] Wenn es bei dem zu übermittelnden Wert um einen Wert zu einem Zeitpunkt handelt.
1563 // REVIEW: A point-in-time value (Wert zu einem Zeitpunkt) is signalled by the presence of DTM+7 (Nutzungszeitpunkt) in SG10. If this DTM qualifier is present, the transmitted value represents a single point in time rather than an interval. (medium confidence)
1564 fn evaluate_146(&self, ctx: &EvaluationContext) -> ConditionResult {
1565 ctx.has_qualifier("DTM", 0, "7")
1566 }
1567
1568 /// [147] Wenn in derselben S9 LIN das SG10 DTM+7 (Nutzungszeitpunkt) nicht vorhanden ist.
1569 // REVIEW: Checks absence of DTM+7 (Nutzungszeitpunkt) in the message, approximating the SG10-scoped check within the enclosing LIN group. Absence means the value is not a point-in-time value. (medium confidence)
1570 fn evaluate_147(&self, ctx: &EvaluationContext) -> ConditionResult {
1571 ctx.lacks_qualifier("DTM", 0, "7")
1572 }
1573
1574 /// [148] Wenn es bei dem zu übermittelnden Wert um einen Wert in einem Zeitintervall handelt.
1575 // REVIEW: An interval value (Wert in einem Zeitintervall) is signalled by the presence of DTM+163 (Beginn Messperiode) in SG10. If Beginn Messperiode is present, the value spans a time interval rather than being a single point. (medium confidence)
1576 fn evaluate_148(&self, ctx: &EvaluationContext) -> ConditionResult {
1577 ctx.has_qualifier("DTM", 0, "163")
1578 }
1579
1580 /// [149] Wenn in derselben S9 LIN das SG10 DTM+163 (Beginn Messperiode) vorhanden ist.
1581 // REVIEW: Checks presence of DTM+163 (Beginn Messperiode) — the direct inverse of condition 145. Message-wide approximation of the SG10-scoped intent within the enclosing LIN group. (medium confidence)
1582 fn evaluate_149(&self, ctx: &EvaluationContext) -> ConditionResult {
1583 ctx.has_qualifier("DTM", 0, "163")
1584 }
1585
1586 /// [150] Wenn BGM+Z69 (Redispatch tägliche Ausfallarbeitsüberführungszeitreihe) vorhanden.
1587 fn evaluate_150(&self, ctx: &EvaluationContext) -> ConditionResult {
1588 ctx.has_qualifier("BGM", 0, "Z69")
1589 }
1590
1591 /// [490] wenn Wert in diesem DE, an der Stelle CCYYMMDDHHMM ein Zeitpunkt aus dem angegeben Zeitraum der Tabelle Kapitel 3.5 „Übersicht gesetzliche deutsche Sommerzeit (MESZ)“ der Spalten: „Sommerzei...
1592 fn evaluate_490(&self, ctx: &EvaluationContext) -> ConditionResult {
1593 match ctx.resolved_value {
1594 Some(val) => is_mesz_utc(val),
1595 None => ConditionResult::False,
1596 }
1597 }
1598
1599 /// [491] wenn Wert in diesem DE, an der Stelle CCYYMMDDHHMM ein Zeitpunkt aus dem angegeben Zeitraum der Tabelle Kapitel 3.6 „Übersicht gesetzliche deutsche Zeit (MEZ)“ der Spalten: „Winterzeit (MEZ)...
1600 // REVIEW: Checks whether the datetime value falls within German winter time (MEZ, UTC+1) using the is_mez_utc helper. Medium confidence because 'diesem DE' is context-dependent — without knowing the exact field the condition is applied to in the AHB table, we check the first DTM value available. The is_mez_utc helper applies the EU DST rule to determine MEZ vs MESZ. (medium confidence)
1601 fn evaluate_491(&self, ctx: &EvaluationContext) -> ConditionResult {
1602 match ctx.resolved_value {
1603 Some(val) => is_mez_utc(val),
1604 None => ConditionResult::False,
1605 }
1606 }
1607
1608 /// [492] wenn MP-ID in NAD+MR aus Sparte Strom
1609 /// EXTERNAL: Requires context from outside the message.
1610 fn evaluate_492(&self, ctx: &EvaluationContext) -> ConditionResult {
1611 ctx.external.evaluate("recipient_is_electricity_sector")
1612 }
1613
1614 /// [493] wenn MP-ID in NAD+MR aus Sparte Gas
1615 /// EXTERNAL: Requires context from outside the message.
1616 fn evaluate_493(&self, ctx: &EvaluationContext) -> ConditionResult {
1617 ctx.external.evaluate("recipient_is_gas_sector")
1618 }
1619
1620 /// [494] Das hier genannte Datum muss der Zeitpunkt sein, zu dem das Dokument erstellt wurde, oder ein Zeitpunkt, der davor liegt.
1621 // HAND-EDITED: subject is the current DTM's DE2380 (via ctx.resolved_value), not a
1622 // guessed other qualifier. Lexicographic compare is valid for fixed-width
1623 // CCYYMMDDHHMM+ZZ (format 303) and CCYYMMDD (format 102) when compared prefix-wise.
1624 fn evaluate_494(&self, ctx: &EvaluationContext) -> ConditionResult {
1625 let current = match ctx.resolved_value {
1626 Some(v) if !v.is_empty() => v,
1627 _ => return ConditionResult::Unknown,
1628 };
1629 let threshold = match ctx
1630 .find_segments_with_qualifier("DTM", 0, "137")
1631 .first()
1632 .and_then(|s| s.elements.first())
1633 .and_then(|e| e.get(1))
1634 {
1635 Some(v) if !v.is_empty() => v.clone(),
1636 _ => return ConditionResult::Unknown,
1637 };
1638 ConditionResult::from(current <= threshold.as_str())
1639 }
1640
1641 /// [495] Der Zeitpunkt muss ≤ dem Wert im DE2380 des DTM+137 sein
1642 // HAND-EDITED: subject is the current DTM's DE2380 (via ctx.resolved_value), not a
1643 // guessed other qualifier. Matches the invoic_conditions pattern.
1644 fn evaluate_495(&self, ctx: &EvaluationContext) -> ConditionResult {
1645 let current = match ctx.resolved_value {
1646 Some(v) if !v.is_empty() => v,
1647 _ => return ConditionResult::Unknown,
1648 };
1649 let threshold = match ctx
1650 .find_segments_with_qualifier("DTM", 0, "137")
1651 .first()
1652 .and_then(|s| s.elements.first())
1653 .and_then(|e| e.get(1))
1654 {
1655 Some(v) if !v.is_empty() => v.clone(),
1656 _ => return ConditionResult::Unknown,
1657 };
1658 ConditionResult::from(current <= threshold.as_str())
1659 }
1660
1661 /// [501] Hinweis: Es sind nur die Werte erlaubt, die in der EDI@Energy Codeliste der OBIS-Kennzahlen und Medien mit dem entsprechenden Prüfidentifikator versehen sind.
1662 fn evaluate_501(&self, _ctx: &EvaluationContext) -> ConditionResult {
1663 // Hinweis: Informational note about allowed OBIS codes — always applies unconditionally
1664 ConditionResult::True
1665 }
1666
1667 /// [502] Hinweis: Einmal für die Energiemenge von Beginn des Kalenderjahres bis zum Lieferbeginn und bis zu zweimal für die zwei höchsten Monatsleistungswerte (wegen KAV) von Beginn des Kalenderjahres bi...
1668 fn evaluate_502(&self, _ctx: &EvaluationContext) -> ConditionResult {
1669 // Hinweis: Informational note about cardinality (once for energy from start of calendar year,
1670 // up to twice for two highest monthly peak values due to KAV) — always applies unconditionally
1671 ConditionResult::True
1672 }
1673
1674 /// [506] Hinweis: Nur bei Einspeisemengen und bei Gas zur stündlichen Energiedatenübermittlung
1675 fn evaluate_506(&self, _ctx: &EvaluationContext) -> ConditionResult {
1676 // Hinweis: Informational note — only for feed-in quantities and gas hourly energy data transmission
1677 // This is an informational annotation, not a boolean predicate — always applies
1678 ConditionResult::True
1679 }
1680
1681 /// [509] Hinweis: Falls es sich um eine Korrekturenergiemenge handelt, ist hier die Referenz auf die MSCONS anzugeben, in der der Zählerstand vorab übermittelt wurde.
1682 fn evaluate_509(&self, _ctx: &EvaluationContext) -> ConditionResult {
1683 // Hinweis: Informational note — for correction energy amounts, reference the prior MSCONS
1684 // in which the meter reading was transmitted. Informational annotation, always applies.
1685 ConditionResult::True
1686 }
1687
1688 /// [510] Hinweis: Verwendung der ID der Messlokation
1689 fn evaluate_510(&self, _ctx: &EvaluationContext) -> ConditionResult {
1690 // Hinweis: Verwendung der ID der Messlokation — informational note, always applies
1691 ConditionResult::True
1692 }
1693
1694 /// [511] Hinweis: Verwendung der ID des MaBiS-ZP
1695 fn evaluate_511(&self, _ctx: &EvaluationContext) -> ConditionResult {
1696 // Hinweis: Verwendung der ID des MaBiS-ZP — informational note, always applies
1697 ConditionResult::True
1698 }
1699
1700 /// [512] Hinweis: Verwendung der Bilanzkreisbezeichnung
1701 fn evaluate_512(&self, _ctx: &EvaluationContext) -> ConditionResult {
1702 // Hinweis: Verwendung der Bilanzkreisbezeichnung — informational note, always applies
1703 ConditionResult::True
1704 }
1705
1706 /// [513] Hinweis: Verwendung der Bezeichnung des Bilanzierungsgebietes
1707 fn evaluate_513(&self, _ctx: &EvaluationContext) -> ConditionResult {
1708 // Hinweis: Verwendung der Bezeichnung des Bilanzierungsgebietes — informational note, always applies
1709 ConditionResult::True
1710 }
1711
1712 /// [514] Hinweis: Verwendung der ID der Marktlokation
1713 fn evaluate_514(&self, _ctx: &EvaluationContext) -> ConditionResult {
1714 // Hinweis: Verwendung der ID der Marktlokation — informational note, always applies
1715 ConditionResult::True
1716 }
1717
1718 /// [515] Hinweis: Verwendung der Profilbezeichnung
1719 fn evaluate_515(&self, _ctx: &EvaluationContext) -> ConditionResult {
1720 // Hinweis: Verwendung der Profilbezeichnung — informational note, always applies
1721 ConditionResult::True
1722 }
1723
1724 /// [516] Hinweis: Verwendung der Bezeichnung der Profilschar
1725 fn evaluate_516(&self, _ctx: &EvaluationContext) -> ConditionResult {
1726 // Hinweis: Verwendung der Bezeichnung der Profilschar — informational note, always applies
1727 ConditionResult::True
1728 }
1729
1730 /// [518] Hinweis: Verwendung der ID der Tranche
1731 fn evaluate_518(&self, _ctx: &EvaluationContext) -> ConditionResult {
1732 // Hinweis: Verwendung der ID der Tranche — informational note, always applies
1733 ConditionResult::True
1734 }
1735
1736 /// [519] Hinweis: Nur wenn der gemessene Lastgang der Messlokation nicht dem Lastgang der Marktlokation 1:1 entspricht.
1737 fn evaluate_519(&self, _ctx: &EvaluationContext) -> ConditionResult {
1738 // Hinweis: Nur wenn der gemessene Lastgang der Messlokation nicht dem Lastgang der Marktlokation 1:1 entspricht — informational note, always applies
1739 ConditionResult::True
1740 }
1741
1742 /// [520] Hinweis: Wenn es sich um eine 1:1 Beziehung zwischen Messlokation und Marktlokation handelt und der gemessene Lastgang der Messlokation dem Lastgang der Marktlokation 1:1 entspricht, oder wenn der ...
1743 fn evaluate_520(&self, _ctx: &EvaluationContext) -> ConditionResult {
1744 // Hinweis: Wenn es sich um eine 1:1 Beziehung zwischen Messlokation und Marktlokation handelt... — informational note, always applies
1745 ConditionResult::True
1746 }
1747
1748 /// [522] Hinweis: Nur für die Übermittlung der Korrekturenergiemengen im Zeitintervall zwischen zwei Messwerten.
1749 fn evaluate_522(&self, _ctx: &EvaluationContext) -> ConditionResult {
1750 // Hinweis: Nur für die Übermittlung der Korrekturenergiemengen im Zeitintervall zwischen zwei Messwerten.
1751 ConditionResult::True
1752 }
1753
1754 /// [523] Hinweis: Nur für die Übermittlung der Energiemenge im Zeitintervall zwischen zwei Messwerten vor der Netznutzungsabrechnung.
1755 fn evaluate_523(&self, _ctx: &EvaluationContext) -> ConditionResult {
1756 // Hinweis: Nur für die Übermittlung der Energiemenge im Zeitintervall zwischen zwei Messwerten vor der Netznutzungsabrechnung.
1757 ConditionResult::True
1758 }
1759
1760 /// [524] Hinweis: Nur, wenn es sich um die Übermittlung von Abrechnungsbrennwert und Z-Zahl für den vom Lieferanten über eine Geschäftsdatenanfrage angeforderten Zeitraum handelt.
1761 fn evaluate_524(&self, _ctx: &EvaluationContext) -> ConditionResult {
1762 // Hinweis: Nur, wenn es sich um die Übermittlung von Abrechnungsbrennwert und Z-Zahl für den vom Lieferanten über eine Geschäftsdatenanfrage angeforderten Zeitraum handelt.
1763 ConditionResult::True
1764 }
1765
1766 /// [525] Hinweis: Nur für die Übermittlung der Energiemenge im Zeitintervall für eine Marktlokation ohne Messlokation (Pauschalanlage) wenn eines der Ereignisse aus Kapitel 4.2 eingetreten ist.
1767 fn evaluate_525(&self, _ctx: &EvaluationContext) -> ConditionResult {
1768 // Hinweis: Nur für die Übermittlung der Energiemenge im Zeitintervall für eine Marktlokation ohne Messlokation (Pauschalanlage) wenn eines der Ereignisse aus Kapitel 4.2 eingetreten ist.
1769 ConditionResult::True
1770 }
1771
1772 /// [526] Hinweis: Wert aus BGM+Z24 DE1004 der ORDERS mit der die Allokationsliste bestellt wurde.
1773 fn evaluate_526(&self, _ctx: &EvaluationContext) -> ConditionResult {
1774 // Hinweis: Wert aus BGM+Z24 DE1004 der ORDERS mit der die Allokationsliste bestellt wurde.
1775 ConditionResult::True
1776 }
1777
1778 /// [528] Hinweis: Wert aus BGM+Z28 DE1004 der ORDERS mit der die Anforderung von Messwerten erfolgt ist.
1779 fn evaluate_528(&self, _ctx: &EvaluationContext) -> ConditionResult {
1780 // Hinweis: Wert aus BGM+Z28 DE1004 der ORDERS mit der die Anforderung von Messwerten erfolgt ist.
1781 // Informational note, always applies
1782 ConditionResult::True
1783 }
1784
1785 /// [529] Hinweis: Wert aus BGM+7 DE1004 der ORDERS mit der die Anforderung von Messwerten erfolgt ist.
1786 fn evaluate_529(&self, _ctx: &EvaluationContext) -> ConditionResult {
1787 // Hinweis: Wert aus BGM+7 DE1004 der ORDERS mit der die Anforderung von Messwerten erfolgt ist.
1788 // Informational note, always applies
1789 ConditionResult::True
1790 }
1791
1792 /// [530] Hinweis: Wert aus SG4 IDE+24 DE7402 der UTILMD mit dem der Sender der MSCONS die vorherigen Stammdaten mittels UTILMD übermittelt hat.
1793 fn evaluate_530(&self, _ctx: &EvaluationContext) -> ConditionResult {
1794 // Hinweis: Wert aus SG4 IDE+24 DE7402 der UTILMD mit dem der Sender der MSCONS die vorherigen Stammdaten mittels UTILMD übermittelt hat.
1795 // Informational note, always applies
1796 ConditionResult::True
1797 }
1798
1799 /// [531] Hinweis: Wert aus BGM+7 DE1004 der MSCONS mit der der Zählerstand übermittelt wurde.
1800 fn evaluate_531(&self, _ctx: &EvaluationContext) -> ConditionResult {
1801 // Hinweis: Wert aus BGM+7 DE1004 der MSCONS mit der der Zählerstand übermittelt wurde.
1802 // Informational note, always applies
1803 ConditionResult::True
1804 }
1805
1806 /// [532] Hinweis: Wert aus BGM+7/Z27/Z28/270/Z41/Z42/Z85 DE1004 der MSCONS Nachricht, die storniert wird
1807 fn evaluate_532(&self, _ctx: &EvaluationContext) -> ConditionResult {
1808 // Hinweis: Wert aus BGM+7/Z27/Z28/270/Z41/Z42/Z85 DE1004 der MSCONS Nachricht, die storniert wird
1809 // Informational note, always applies
1810 ConditionResult::True
1811 }
1812
1813 /// [535] Hinweis: Verwendung der ID des Netzkoppelpunktes Strom/Gas
1814 fn evaluate_535(&self, _ctx: &EvaluationContext) -> ConditionResult {
1815 // Hinweis: Verwendung der ID des Netzkoppelpunktes Strom/Gas — informational note, always applies
1816 ConditionResult::True
1817 }
1818
1819 /// [538] Hinweis: Die Referenz auf die ORDERS ist nur dann anzugeben, wenn diese Werte vom Empfänger auch ursprünglich mittels ORDERS angefragt wurden.
1820 fn evaluate_538(&self, _ctx: &EvaluationContext) -> ConditionResult {
1821 // Hinweis: Die Referenz auf die ORDERS ist nur dann anzugeben, wenn diese Werte vom Empfänger auch ursprünglich mittels ORDERS angefragt wurden — informational note, always applies
1822 ConditionResult::True
1823 }
1824
1825 /// [541] Hinweis: Ein Korrekturgrund ist anzugeben, wenn: 1. ein bereits an den MP übermittelter vorläufiger Wert nach Stornierung durch einen Ersatzwert ersetzt wird, oder 2. ein bereits an den MP über...
1826 fn evaluate_541(&self, _ctx: &EvaluationContext) -> ConditionResult {
1827 // Hinweis: Ein Korrekturgrund ist anzugeben in bestimmten Ersatzwert/Stornierung-Szenarien — informational note, always applies
1828 ConditionResult::True
1829 }
1830
1831 /// [543] Hinweis: Wert aus BGM+Z23 DE1004 der ORDERS mit der die bilanzierte Menge bestellt wurde.
1832 fn evaluate_543(&self, _ctx: &EvaluationContext) -> ConditionResult {
1833 // Hinweis: Wert aus BGM+Z23 DE1004 der ORDERS mit der die bilanzierte Menge bestellt wurde — informational note, always applies
1834 ConditionResult::True
1835 }
1836
1837 /// [544] Hinweis: Bei einer Mengenaufteilung (z. B. Aufgrund einer Abgrenzung) für SG6 LOC+172 muss für den frühesten angegebenen Zeitpunkt zum Beginn des Zeitintervalls (über alle Wiederholungen der L...
1838 fn evaluate_544(&self, _ctx: &EvaluationContext) -> ConditionResult {
1839 // Hinweis: Bei einer Mengenaufteilung für SG6 LOC+172 muss für den frühesten Zeitpunkt zu jeder OBIS-Kennziffer ein Zählerstand vorhanden sein — informational note, always applies
1840 ConditionResult::True
1841 }
1842
1843 /// [545] Hinweis: Bei einer Mengenaufteilung (z. B. Aufgrund einer Abgrenzung) für SG6 LOC+172 muss für den spätesten angegebenen Zeitpunkt zum Ende des Zeitintervalls (über alle Wiederholungen der LIN-...
1844 fn evaluate_545(&self, _ctx: &EvaluationContext) -> ConditionResult {
1845 // Hinweis: informational note about Mengenaufteilung and Zählerstand requirement — always applies
1846 ConditionResult::True
1847 }
1848
1849 /// [546] Hinweis: Eine Referenz auf die Stammdatenänderung des Gerätewechsels ist immer anzugeben, wenn diese dem Sender vorliegt.
1850 fn evaluate_546(&self, _ctx: &EvaluationContext) -> ConditionResult {
1851 // Hinweis: informational note about referencing master data changes for device replacements — always applies
1852 ConditionResult::True
1853 }
1854
1855 /// [547] Hinweis: Der Code 270 ist nur zu nutzen, wenn ein Lieferschein, der vor dem 1.4.2021 erstellt wurde, storniert wird.
1856 fn evaluate_547(&self, _ctx: &EvaluationContext) -> ConditionResult {
1857 // Hinweis: informational note — code 270 only for cancelling delivery notes created before 1.4.2021 — always applies
1858 ConditionResult::True
1859 }
1860
1861 /// [551] Hinweis: Ein Korrekturgrund ist anzugeben, wenn: 1. ein bereits an den MP übermittelter vorläufiger Wert durch einen Ersatzwert ersetzt wird, oder 2. ein bereits an den MP übermittelter Ersatzw...
1862 fn evaluate_551(&self, _ctx: &EvaluationContext) -> ConditionResult {
1863 // Hinweis: informational note describing when a Korrekturgrund must be provided — always applies
1864 ConditionResult::True
1865 }
1866
1867 /// [553] Hinweis: Wert aus BGM+Z34 DE1004 der ORDERS mit der die Reklamation von Werten erfolgt ist
1868 fn evaluate_553(&self, _ctx: &EvaluationContext) -> ConditionResult {
1869 // Hinweis: informational note — value from BGM+Z34 DE1004 of the ORDERS used for value complaint — always applies
1870 ConditionResult::True
1871 }
1872
1873 /// [554] Hinweis: Verwendung der ID der Technischen Ressource
1874 fn evaluate_554(&self, _ctx: &EvaluationContext) -> ConditionResult {
1875 // Hinweis: Verwendung der ID der Technischen Ressource — informational note, always applies
1876 ConditionResult::True
1877 }
1878
1879 /// [556] Hinweis: Wert aus BGM+Z45 DE1004 der ORDERS mit der die Anforderung der Ausfallarbeit durch den anfNB erfolgt ist.
1880 fn evaluate_556(&self, _ctx: &EvaluationContext) -> ConditionResult {
1881 // Hinweis: Wert aus BGM+Z45 DE1004 der ORDERS — informational note, always applies
1882 ConditionResult::True
1883 }
1884
1885 /// [557] Hinweis: Die Referenz auf die ursprüngliche MSCONS ist anzugeben, wenn es sich um die Übermittlung eines Gegenvorschlags durch den BTR handelt.
1886 fn evaluate_557(&self, _ctx: &EvaluationContext) -> ConditionResult {
1887 // Hinweis: Referenz auf ursprüngliche MSCONS bei Gegenvorschlag — informational note, always applies
1888 ConditionResult::True
1889 }
1890
1891 /// [558] Hinweis: Wert aus BGM+Z45 DE1004 der MSCONS auf die sich die Übermittlung des Gegenvorschlags durch den BTR bezieht.
1892 fn evaluate_558(&self, _ctx: &EvaluationContext) -> ConditionResult {
1893 // Hinweis: Wert aus BGM+Z45 DE1004 der MSCONS bei Gegenvorschlag — informational note, always applies
1894 ConditionResult::True
1895 }
1896
1897 /// [559] Hinweis: Ein Korrekturgrund ist anzugeben, wenn: 1. ein bereits an den MP übermittelter vorläufiger Wert nach Stornierung durch einen Ersatzwert ersetzt wird, oder 2. ein bereits an den MP über...
1898 fn evaluate_559(&self, _ctx: &EvaluationContext) -> ConditionResult {
1899 // Hinweis: Korrekturgrund bei Ersatz/Stornierung von Werten — informational note, always applies
1900 ConditionResult::True
1901 }
1902
1903 /// [560] Hinweis: Ein Korrekturgrund ist anzugeben, wenn: 1. ein bereits an den MP übermittelter vorläufiger Wert durch einen Ersatzwert ersetzt wird, oder 2. ein bereits an den MP übermittelter Ersatzw...
1904 fn evaluate_560(&self, _ctx: &EvaluationContext) -> ConditionResult {
1905 // Hinweis: Ein Korrekturgrund ist anzugeben, wenn ein vorläufiger/Ersatz/wahrer Wert ersetzt wird — informational note, always applies
1906 ConditionResult::True
1907 }
1908
1909 /// [566] Hinweis: Es sind nur die Werte erlaubt, die im vorherigen Stammdatenaustausch zu diesem Meldepunkt vom MSB zum Zeitpunkt übermittelt wurden.
1910 fn evaluate_566(&self, _ctx: &EvaluationContext) -> ConditionResult {
1911 // Hinweis: Es sind nur die Werte erlaubt, die im vorherigen Stammdatenaustausch übermittelt wurden — informational note, always applies
1912 ConditionResult::True
1913 }
1914
1915 /// [567] Hinweis: Es ist die Konfigurations-ID anzugeben, die im vorherigen Stammdatenaustausch kommuniziert wurde.
1916 fn evaluate_567(&self, _ctx: &EvaluationContext) -> ConditionResult {
1917 // Hinweis: Es ist die Konfigurations-ID anzugeben, die im vorherigen Stammdatenaustausch kommuniziert wurde — informational note, always applies
1918 ConditionResult::True
1919 }
1920
1921 /// [568] Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung zwischen Markt- und Messlokation handelt und auf Ebene der Messlokation unterschiedliche Ersatzwertbildungsverfahren verwendet u...
1922 fn evaluate_568(&self, _ctx: &EvaluationContext) -> ConditionResult {
1923 // Hinweis: Verwendung nur zulässig bei 1:n Beziehung zwischen Markt- und Messlokation mit unterschiedlichen Ersatzwertbildungsverfahren — informational note, always applies
1924 ConditionResult::True
1925 }
1926
1927 /// [569] Hinweis: Bei mehreren Zählerständen einer Messlokation (z. B. HT/NT) ist diese Zeitangabe zu nutzen und eine Wiederholung das SG9 LIN durchzuführen.
1928 fn evaluate_569(&self, _ctx: &EvaluationContext) -> ConditionResult {
1929 // Hinweis: Bei mehreren Zählerständen einer Messlokation (z. B. HT/NT) ist diese Zeitangabe zu nutzen und SG9 LIN zu wiederholen — informational note, always applies
1930 ConditionResult::True
1931 }
1932
1933 /// [570] Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung zwischen Markt- und Messlokation handelt und auf Ebene der Messlokation unterschiedliche Gründe für die Ersatzwertbildung vorl...
1934 fn evaluate_570(&self, _ctx: &EvaluationContext) -> ConditionResult {
1935 // Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung zwischen Markt- und Messlokation handelt und auf Ebene der Messlokation unterschiedliche Gründe für die Ersatzwertbildung vorliegen und kommuniziert wurden.
1936 ConditionResult::True
1937 }
1938
1939 /// [571] Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung handelt und auf Ebene der Netzkopplungspunkte unterschiedliche Gründe für die Ersatzwertbildung vorliegen und kommuniziert wur...
1940 fn evaluate_571(&self, _ctx: &EvaluationContext) -> ConditionResult {
1941 // Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung handelt und auf Ebene der Netzkopplungspunkte unterschiedliche Gründe für die Ersatzwertbildung vorliegen und kommuniziert wurden.
1942 ConditionResult::True
1943 }
1944
1945 /// [572] Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung handelt und auf Ebene der Netzkopplungspunkte unterschiedliche Ersatzwertbildungsverfahren vorliegen und kommuniziert wurden.
1946 fn evaluate_572(&self, _ctx: &EvaluationContext) -> ConditionResult {
1947 // Hinweis: Verwendung ist nur zulässig, wenn es sich um 1:n Beziehung handelt und auf Ebene der Netzkopplungspunkte unterschiedliche Ersatzwertbildungsverfahren vorliegen und kommuniziert wurden.
1948 ConditionResult::True
1949 }
1950
1951 /// [573] Hinweis: Eine Energiemenge in der Sparte Gas ist gemäß DVGW G685 Arbeitsblatt 4 Kapitel 5.3 auf ganze Kilowattstunden zu runden.
1952 fn evaluate_573(&self, _ctx: &EvaluationContext) -> ConditionResult {
1953 // Hinweis: Eine Energiemenge in der Sparte Gas ist gemäß DVGW G685 Arbeitsblatt 4 Kapitel 5.3 auf ganze Kilowattstunden zu runden.
1954 ConditionResult::True
1955 }
1956
1957 /// [574] Hinweis: Wert aus BGM DE1004 der ORDERS mit der die Bestellung der Werte nach Typ 2 erfolg ist
1958 fn evaluate_574(&self, _ctx: &EvaluationContext) -> ConditionResult {
1959 // Hinweis: Wert aus BGM DE1004 der ORDERS mit der die Bestellung der Werte nach Typ 2 erfolg ist
1960 ConditionResult::True
1961 }
1962
1963 /// [575] Hinweis: Verwendung der ID der Netzlokation
1964 fn evaluate_575(&self, _ctx: &EvaluationContext) -> ConditionResult {
1965 // Hinweis: Verwendung der ID der Netzlokation — informational note, always applies
1966 ConditionResult::True
1967 }
1968
1969 /// [576] Hinweis: Es darf nur eine Information im DE3148 übermittelt werden
1970 fn evaluate_576(&self, _ctx: &EvaluationContext) -> ConditionResult {
1971 // Hinweis: Es darf nur eine Information im DE3148 übermittelt werden — informational note, always applies
1972 ConditionResult::True
1973 }
1974
1975 /// [577] Hinweis: Dieser Code ist auch zu verwenden, wenn aufgrund der Beendigung einer Messlokation (Stilllegung) die Beendigung der Marktlokation (Stilllegung) zu unterschiedlichen Zeitpunkten erfolgt, da...
1976 fn evaluate_577(&self, _ctx: &EvaluationContext) -> ConditionResult {
1977 // Hinweis: Informational note about Messlokation/Marktlokation termination timing — always applies
1978 ConditionResult::True
1979 }
1980
1981 /// [902] Format: Möglicher Wert: ≥ 0
1982 fn evaluate_902(&self, ctx: &EvaluationContext) -> ConditionResult {
1983 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, ">=", 0.0))
1984 }
1985
1986 /// [904] Format: genau 16 Stellen
1987 // REVIEW: Format condition requiring exactly 16 characters. Applied to QTY value (most common numeric format condition target in MSCONS). Confidence is medium because the exact target segment/element is not specified in the condition text — QTY is the most likely candidate in MSCONS context. (medium confidence)
1988 fn evaluate_904(&self, ctx: &EvaluationContext) -> ConditionResult {
1989 ctx.format_check("QTY", 0, 1, |val| validate_exact_length(val, 16))
1990 }
1991
1992 /// [905] Format: max. 3 Stellen
1993 fn evaluate_905(&self, ctx: &EvaluationContext) -> ConditionResult {
1994 ctx.format_check("QTY", 0, 1, |val| validate_max_integer_digits(val, 3))
1995 }
1996
1997 /// [906] Format: max. 3 Nachkommastellen
1998 fn evaluate_906(&self, ctx: &EvaluationContext) -> ConditionResult {
1999 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 3))
2000 }
2001
2002 /// [907] Format: max. 4 Nachkommastellen
2003 fn evaluate_907(&self, ctx: &EvaluationContext) -> ConditionResult {
2004 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 4))
2005 }
2006
2007 /// [908] Format: Mögliche Werte: 1 bis n
2008 fn evaluate_908(&self, ctx: &EvaluationContext) -> ConditionResult {
2009 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, ">=", 1.0))
2010 }
2011
2012 /// [909] Format: Mögliche Werte: 0 bis n
2013 fn evaluate_909(&self, ctx: &EvaluationContext) -> ConditionResult {
2014 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, ">=", 0.0))
2015 }
2016
2017 /// [910] Format: Möglicher Wert: < 0 oder ≥ 0
2018 fn evaluate_910(&self, ctx: &EvaluationContext) -> ConditionResult {
2019 let qty_segments = ctx.find_segments("QTY");
2020 let val = qty_segments
2021 .first()
2022 .and_then(|s| s.elements.first())
2023 .and_then(|e| e.get(1))
2024 .map(|s| s.as_str())
2025 .unwrap_or("");
2026 if val.is_empty() {
2027 return ConditionResult::Unknown;
2028 }
2029 match val.parse::<f64>() {
2030 Ok(_) => ConditionResult::True,
2031 Err(_) => ConditionResult::False,
2032 }
2033 }
2034
2035 /// [917] Format: max. 4 Vorkommastellen
2036 fn evaluate_917(&self, ctx: &EvaluationContext) -> ConditionResult {
2037 ctx.format_check("QTY", 0, 1, |val| validate_max_integer_digits(val, 4))
2038 }
2039
2040 /// [918] Format: Zeichen aus dem über UNOC definierten Zeichensatz, wobei von den Buchstaben nur Großbuchstaben erlaubt sind.
2041 // REVIEW: UNOC charset requires uppercase-only alphabetics. Checks all alphabetic characters in FTX text fields (C108, elements[3], components 0..4) are uppercase. Non-alphabetic characters (digits, punctuation) are permitted. Medium confidence — UNOC validation approximated as uppercase-only alphabetic check without full ISO 8859-1 codepoint enumeration. (medium confidence)
2042 fn evaluate_918(&self, ctx: &EvaluationContext) -> ConditionResult {
2043 let ftx_segments = ctx.find_segments("FTX");
2044 for seg in &ftx_segments {
2045 if let Some(c108) = seg.elements.get(3) {
2046 for component in c108 {
2047 let s = component.as_str();
2048 if s.is_empty() {
2049 continue;
2050 }
2051 if !s.chars().all(|c| !c.is_alphabetic() || c.is_uppercase()) {
2052 return ConditionResult::False;
2053 }
2054 }
2055 }
2056 }
2057 ConditionResult::True
2058 }
2059
2060 /// [922] Format: TR-ID
2061 // REVIEW: Format: TR-ID — validates that the value is a valid Transaktionsreferenz-ID (1–35 alphanumeric characters) using validate_tr_id. In MSCONS, the document/transaction ID is typically found in BGM elements[1][0] (the document number composite). Medium confidence because the exact DE this format condition is applied to depends on the AHB field context, which could alternatively be RFF or another reference segment. (medium confidence)
2062 fn evaluate_922(&self, ctx: &EvaluationContext) -> ConditionResult {
2063 ctx.format_check("BGM", 1, 0, validate_tr_id)
2064 }
2065
2066 /// [925] Format: max. 5 Nachkommastellen
2067 fn evaluate_925(&self, ctx: &EvaluationContext) -> ConditionResult {
2068 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 5))
2069 }
2070
2071 /// [931] Format: ZZZ = +00
2072 fn evaluate_931(&self, ctx: &EvaluationContext) -> ConditionResult {
2073 ctx.format_check("DTM", 0, 1, validate_timezone_utc)
2074 }
2075
2076 /// [932] Format: HHMM = 2200
2077 fn evaluate_932(&self, ctx: &EvaluationContext) -> ConditionResult {
2078 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "2200"))
2079 }
2080
2081 /// [933] Format: HHMM = 2300
2082 fn evaluate_933(&self, ctx: &EvaluationContext) -> ConditionResult {
2083 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "2300"))
2084 }
2085
2086 /// [934] Format: HHMM = 0400
2087 fn evaluate_934(&self, ctx: &EvaluationContext) -> ConditionResult {
2088 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0400"))
2089 }
2090
2091 /// [935] Format: HHMM = 0500
2092 fn evaluate_935(&self, ctx: &EvaluationContext) -> ConditionResult {
2093 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0500"))
2094 }
2095
2096 /// [937] Format: keine Nachkommastelle
2097 fn evaluate_937(&self, ctx: &EvaluationContext) -> ConditionResult {
2098 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 0))
2099 }
2100
2101 /// [939] Format: Die Zeichenkette muss die Zeichen @ und . enthalten
2102 fn evaluate_939(&self, ctx: &EvaluationContext) -> ConditionResult {
2103 ctx.format_check("COM", 0, 0, validate_email)
2104 }
2105
2106 /// [940] Format: Die Zeichenkette muss mit dem Zeichen + beginnen und danach dürfen nur noch Ziffern folgen
2107 fn evaluate_940(&self, ctx: &EvaluationContext) -> ConditionResult {
2108 ctx.format_check("COM", 0, 0, validate_phone)
2109 }
2110
2111 /// [950] Format: Marktlokations-ID
2112 fn evaluate_950(&self, ctx: &EvaluationContext) -> ConditionResult {
2113 ctx.format_check_qualified("LOC", 0, "Z16", 1, 0, validate_malo_id)
2114 }
2115
2116 /// [951] Format: Zählpunktbezeichnung
2117 // REVIEW: Format: Zählpunktbezeichnung — 33 alphanumeric characters. In MSCONS, Zählpunktbezeichnung typically appears in LOC+Z19. Using validate_zahlpunkt helper. (medium confidence)
2118 fn evaluate_951(&self, ctx: &EvaluationContext) -> ConditionResult {
2119 ctx.format_check_qualified("LOC", 0, "Z19", 1, 0, validate_zahlpunkt)
2120 }
2121
2122 /// [960] Format: Netzlokations-ID
2123 // HAND-EDITED: a Netzlokations-ID is "E" + ten alphanumerics (`E1688117482`),
2124 // not MaLo-shaped; `validate_malo_id` rejected every real one (#173).
2125 fn evaluate_960(&self, ctx: &EvaluationContext) -> ConditionResult {
2126 ctx.format_check_qualified("LOC", 0, "Z17", 1, 0, validate_nelo_id)
2127 }
2128
2129 /// [2001] Segmentgruppe ist nur einmal je UNH anzugeben
2130 fn evaluate_2001(&self, _ctx: &EvaluationContext) -> ConditionResult {
2131 // Hinweis: Segmentgruppe ist nur einmal je UNH anzugeben — cardinality annotation, always applies
2132 ConditionResult::True
2133 }
2134
2135 /// [2002] Segmentgruppe ist bis zu drei Mal je SG5 NAD+DP anzugeben
2136 fn evaluate_2002(&self, _ctx: &EvaluationContext) -> ConditionResult {
2137 // Hinweis: Segmentgruppe ist bis zu drei Mal je SG5 NAD+DP anzugeben — cardinality annotation, always applies
2138 ConditionResult::True
2139 }
2140
2141 /// [2003] Segmentgruppe ist genau zwei Mal je SG9 LIN anzugeben
2142 fn evaluate_2003(&self, _ctx: &EvaluationContext) -> ConditionResult {
2143 // Hinweis: Segmentgruppe ist genau zwei Mal je SG9 LIN anzugeben — cardinality annotation, always applies
2144 ConditionResult::True
2145 }
2146}