automapper_validation/generated/fv2604/utilmd_gas_conditions_fv2604.rs
1// <auto-generated>
2// Generated by automapper-generator generate-conditions
3// AHB: xml-migs-and-ahbs/FV2604/UTILMD_AHB_Gas_1_1_außerordentliche_20251211.xml
4// Generated: 2026-03-12T11:40:25Z
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 UTILMD_Gas FV2604.
17pub struct UtilmdGasConditionEvaluatorFV2604 {
18 // External condition IDs that require runtime context.
19 external_conditions: std::collections::HashSet<u32>,
20}
21
22impl Default for UtilmdGasConditionEvaluatorFV2604 {
23 fn default() -> Self {
24 let mut external_conditions = std::collections::HashSet::new();
25 external_conditions.insert(1);
26 external_conditions.insert(3);
27 external_conditions.insert(4);
28 external_conditions.insert(5);
29 external_conditions.insert(14);
30 external_conditions.insert(17);
31 external_conditions.insert(29);
32 external_conditions.insert(39);
33 external_conditions.insert(51);
34 external_conditions.insert(65);
35 external_conditions.insert(92);
36 external_conditions.insert(98);
37 external_conditions.insert(108);
38 external_conditions.insert(127);
39 external_conditions.insert(129);
40 external_conditions.insert(133);
41 external_conditions.insert(147);
42 external_conditions.insert(165);
43 external_conditions.insert(166);
44 external_conditions.insert(219);
45 external_conditions.insert(241);
46 external_conditions.insert(268);
47 external_conditions.insert(283);
48 external_conditions.insert(315);
49 external_conditions.insert(324);
50 external_conditions.insert(336);
51 external_conditions.insert(427);
52 Self {
53 external_conditions,
54 }
55 }
56}
57
58impl ConditionEvaluator for UtilmdGasConditionEvaluatorFV2604 {
59 fn message_type(&self) -> &str {
60 "UTILMD_Gas"
61 }
62
63 fn format_version(&self) -> &str {
64 "FV2604"
65 }
66
67 fn evaluate(&self, condition: u32, ctx: &EvaluationContext) -> ConditionResult {
68 match condition {
69 1 => self.evaluate_1(ctx),
70 2 => self.evaluate_2(ctx),
71 3 => self.evaluate_3(ctx),
72 4 => self.evaluate_4(ctx),
73 5 => self.evaluate_5(ctx),
74 7 => self.evaluate_7(ctx),
75 9 => self.evaluate_9(ctx),
76 10 => self.evaluate_10(ctx),
77 11 => self.evaluate_11(ctx),
78 12 => self.evaluate_12(ctx),
79 13 => self.evaluate_13(ctx),
80 14 => self.evaluate_14(ctx),
81 15 => self.evaluate_15(ctx),
82 16 => self.evaluate_16(ctx),
83 17 => self.evaluate_17(ctx),
84 18 => self.evaluate_18(ctx),
85 19 => self.evaluate_19(ctx),
86 24 => self.evaluate_24(ctx),
87 25 => self.evaluate_25(ctx),
88 26 => self.evaluate_26(ctx),
89 28 => self.evaluate_28(ctx),
90 29 => self.evaluate_29(ctx),
91 32 => self.evaluate_32(ctx),
92 33 => self.evaluate_33(ctx),
93 35 => self.evaluate_35(ctx),
94 36 => self.evaluate_36(ctx),
95 37 => self.evaluate_37(ctx),
96 39 => self.evaluate_39(ctx),
97 46 => self.evaluate_46(ctx),
98 47 => self.evaluate_47(ctx),
99 48 => self.evaluate_48(ctx),
100 51 => self.evaluate_51(ctx),
101 58 => self.evaluate_58(ctx),
102 64 => self.evaluate_64(ctx),
103 65 => self.evaluate_65(ctx),
104 66 => self.evaluate_66(ctx),
105 68 => self.evaluate_68(ctx),
106 69 => self.evaluate_69(ctx),
107 70 => self.evaluate_70(ctx),
108 77 => self.evaluate_77(ctx),
109 78 => self.evaluate_78(ctx),
110 81 => self.evaluate_81(ctx),
111 84 => self.evaluate_84(ctx),
112 92 => self.evaluate_92(ctx),
113 98 => self.evaluate_98(ctx),
114 106 => self.evaluate_106(ctx),
115 108 => self.evaluate_108(ctx),
116 123 => self.evaluate_123(ctx),
117 127 => self.evaluate_127(ctx),
118 128 => self.evaluate_128(ctx),
119 129 => self.evaluate_129(ctx),
120 130 => self.evaluate_130(ctx),
121 133 => self.evaluate_133(ctx),
122 137 => self.evaluate_137(ctx),
123 138 => self.evaluate_138(ctx),
124 147 => self.evaluate_147(ctx),
125 165 => self.evaluate_165(ctx),
126 166 => self.evaluate_166(ctx),
127 200 => self.evaluate_200(ctx),
128 202 => self.evaluate_202(ctx),
129 203 => self.evaluate_203(ctx),
130 205 => self.evaluate_205(ctx),
131 209 => self.evaluate_209(ctx),
132 212 => self.evaluate_212(ctx),
133 213 => self.evaluate_213(ctx),
134 216 => self.evaluate_216(ctx),
135 219 => self.evaluate_219(ctx),
136 230 => self.evaluate_230(ctx),
137 241 => self.evaluate_241(ctx),
138 249 => self.evaluate_249(ctx),
139 252 => self.evaluate_252(ctx),
140 257 => self.evaluate_257(ctx),
141 268 => self.evaluate_268(ctx),
142 274 => self.evaluate_274(ctx),
143 276 => self.evaluate_276(ctx),
144 277 => self.evaluate_277(ctx),
145 283 => self.evaluate_283(ctx),
146 315 => self.evaluate_315(ctx),
147 324 => self.evaluate_324(ctx),
148 328 => self.evaluate_328(ctx),
149 333 => self.evaluate_333(ctx),
150 336 => self.evaluate_336(ctx),
151 345 => self.evaluate_345(ctx),
152 361 => self.evaluate_361(ctx),
153 362 => self.evaluate_362(ctx),
154 367 => self.evaluate_367(ctx),
155 368 => self.evaluate_368(ctx),
156 427 => self.evaluate_427(ctx),
157 442 => self.evaluate_442(ctx),
158 490 => self.evaluate_490(ctx),
159 491 => self.evaluate_491(ctx),
160 494 => self.evaluate_494(ctx),
161 500 => self.evaluate_500(ctx),
162 501 => self.evaluate_501(ctx),
163 502 => self.evaluate_502(ctx),
164 504 => self.evaluate_504(ctx),
165 505 => self.evaluate_505(ctx),
166 507 => self.evaluate_507(ctx),
167 508 => self.evaluate_508(ctx),
168 510 => self.evaluate_510(ctx),
169 511 => self.evaluate_511(ctx),
170 513 => self.evaluate_513(ctx),
171 527 => self.evaluate_527(ctx),
172 528 => self.evaluate_528(ctx),
173 530 => self.evaluate_530(ctx),
174 556 => self.evaluate_556(ctx),
175 558 => self.evaluate_558(ctx),
176 559 => self.evaluate_559(ctx),
177 560 => self.evaluate_560(ctx),
178 566 => self.evaluate_566(ctx),
179 567 => self.evaluate_567(ctx),
180 570 => self.evaluate_570(ctx),
181 571 => self.evaluate_571(ctx),
182 572 => self.evaluate_572(ctx),
183 581 => self.evaluate_581(ctx),
184 583 => self.evaluate_583(ctx),
185 584 => self.evaluate_584(ctx),
186 590 => self.evaluate_590(ctx),
187 601 => self.evaluate_601(ctx),
188 621 => self.evaluate_621(ctx),
189 622 => self.evaluate_622(ctx),
190 636 => self.evaluate_636(ctx),
191 637 => self.evaluate_637(ctx),
192 638 => self.evaluate_638(ctx),
193 643 => self.evaluate_643(ctx),
194 644 => self.evaluate_644(ctx),
195 651 => self.evaluate_651(ctx),
196 654 => self.evaluate_654(ctx),
197 655 => self.evaluate_655(ctx),
198 902 => self.evaluate_902(ctx),
199 907 => self.evaluate_907(ctx),
200 912 => self.evaluate_912(ctx),
201 930 => self.evaluate_930(ctx),
202 931 => self.evaluate_931(ctx),
203 934 => self.evaluate_934(ctx),
204 935 => self.evaluate_935(ctx),
205 937 => self.evaluate_937(ctx),
206 938 => self.evaluate_938(ctx),
207 950 => self.evaluate_950(ctx),
208 951 => self.evaluate_951(ctx),
209 952 => self.evaluate_952(ctx),
210 953 => self.evaluate_953(ctx),
211 2061 => self.evaluate_2061(ctx),
212 2119 => self.evaluate_2119(ctx),
213 2284 => self.evaluate_2284(ctx),
214 2286 => self.evaluate_2286(ctx),
215 2287 => self.evaluate_2287(ctx),
216 2335 => self.evaluate_2335(ctx),
217 2353 => self.evaluate_2353(ctx),
218 _ => ConditionResult::Unknown,
219 }
220 }
221
222 fn is_external(&self, condition: u32) -> bool {
223 self.external_conditions.contains(&condition)
224 }
225 fn is_known(&self, condition: u32) -> bool {
226 matches!(
227 condition,
228 1 | 2
229 | 3
230 | 4
231 | 5
232 | 7
233 | 9
234 | 10
235 | 11
236 | 12
237 | 13
238 | 14
239 | 15
240 | 16
241 | 17
242 | 18
243 | 19
244 | 24
245 | 25
246 | 26
247 | 28
248 | 29
249 | 32
250 | 33
251 | 35
252 | 36
253 | 37
254 | 39
255 | 46
256 | 47
257 | 48
258 | 51
259 | 58
260 | 64
261 | 65
262 | 66
263 | 68
264 | 69
265 | 70
266 | 77
267 | 78
268 | 81
269 | 84
270 | 92
271 | 98
272 | 106
273 | 108
274 | 123
275 | 127
276 | 128
277 | 129
278 | 130
279 | 133
280 | 137
281 | 138
282 | 147
283 | 165
284 | 166
285 | 200
286 | 202
287 | 203
288 | 205
289 | 209
290 | 212
291 | 213
292 | 216
293 | 219
294 | 230
295 | 241
296 | 249
297 | 252
298 | 257
299 | 268
300 | 274
301 | 276
302 | 277
303 | 283
304 | 315
305 | 324
306 | 328
307 | 333
308 | 336
309 | 345
310 | 361
311 | 362
312 | 367
313 | 368
314 | 427
315 | 442
316 | 490
317 | 491
318 | 494
319 | 500
320 | 501
321 | 502
322 | 504
323 | 505
324 | 507
325 | 508
326 | 510
327 | 511
328 | 513
329 | 527
330 | 528
331 | 530
332 | 556
333 | 558
334 | 559
335 | 560
336 | 566
337 | 567
338 | 570
339 | 571
340 | 572
341 | 581
342 | 583
343 | 584
344 | 590
345 | 601
346 | 621
347 | 622
348 | 636
349 | 637
350 | 638
351 | 643
352 | 644
353 | 651
354 | 654
355 | 655
356 | 902
357 | 907
358 | 912
359 | 930
360 | 931
361 | 934
362 | 935
363 | 937
364 | 938
365 | 950
366 | 951
367 | 952
368 | 953
369 | 2061
370 | 2119
371 | 2284
372 | 2286
373 | 2287
374 | 2335
375 | 2353
376 )
377 }
378}
379
380impl UtilmdGasConditionEvaluatorFV2604 {
381 /// [2] Wenn UNH DE0070 (Übermittlungsfolgenummer) mit 1 vorhanden
382 fn evaluate_2(&self, ctx: &EvaluationContext) -> ConditionResult {
383 let unh_segs = ctx.find_segments("UNH");
384 match unh_segs.first() {
385 Some(unh) => match unh.elements.get(3).and_then(|e| e.first()) {
386 Some(val) => ConditionResult::from(val == "1"),
387 None => ConditionResult::False,
388 },
389 None => ConditionResult::False, // segment absent → condition not applicable
390 }
391 }
392
393 /// [3] Bei Aufteilung, in der Nachricht mit der höchsten Übermittlungsfolgenummer
394 /// EXTERNAL: Requires context from outside the message.
395 fn evaluate_3(&self, ctx: &EvaluationContext) -> ConditionResult {
396 ctx.external.evaluate("is_highest_sequence_number_in_split")
397 }
398
399 /// [203] Wenn STS+7++E06 / Z39 / ZC6 / ZC7 / ZT6 / ZT7
400 fn evaluate_203(&self, ctx: &EvaluationContext) -> ConditionResult {
401 ctx.has_qualified_value(
402 "STS",
403 0,
404 "7",
405 2,
406 0,
407 &["E06", "Z39", "ZC6", "ZC7", "ZT6", "ZT7"],
408 )
409 }
410
411 /// [315] Es sind alle OBISKennzahlen gem. EDI@Energy Codeliste der OBIS-Kennzahlen und Medien für den deutschen Energiemarkt Kap. 4 anzugeben welche an der Marktlokation erforderlich sind, dabei muss der M...
412 /// EXTERNAL: Requires context from outside the message.
413 fn evaluate_315(&self, ctx: &EvaluationContext) -> ConditionResult {
414 ctx.external.evaluate("obis_kennzahlen_mindestumfang_valid")
415 }
416
417 /// [324] Es sind alle OBIS-Kennzahlen gem. EDI@Energy Codeliste der OBIS Kennzahlen Kap. 4. anzugeben welche an der Zähleinrichtung genutzt werden. Der Mindestumfang der OBIS-Kennzahlen ergibt sich aus den...
418 /// EXTERNAL: Requires context from outside the message.
419 fn evaluate_324(&self, ctx: &EvaluationContext) -> ConditionResult {
420 ctx.external
421 .evaluate("zaehler_obis_kennzahlen_mindestumfang_valid")
422 }
423
424 /// [328] Wenn IMD++Z36+Z12 (Identifikationslogik: Marktlokations-ID) vorhanden
425 fn evaluate_328(&self, ctx: &EvaluationContext) -> ConditionResult {
426 ctx.has_segment_matching("IMD", &[(1, 0, "Z36"), (2, 0, "Z12")])
427 }
428
429 /// [333] Wenn IMD+Z36+Z13 (Identifikationslogik: Alle Identifikationsdaten) vorhanden
430 fn evaluate_333(&self, ctx: &EvaluationContext) -> ConditionResult {
431 ctx.has_segment_matching("IMD", &[(1, 0, "Z36"), (2, 0, "Z13")])
432 }
433
434 /// [502] Hinweis: Ersatzbelieferung gibt es nur bei - Marktlokationen in der Niederdruckebene, die kein Haushaltskunde gem. EnWG sind und die nicht mehr der gesetzlichen Ersatzversorgung (drei Monate) un...
435 fn evaluate_502(&self, _ctx: &EvaluationContext) -> ConditionResult {
436 // Hinweis: Ersatzbelieferung gibt es nur bei Marktlokationen in der Niederdruckebene, die kein Haushaltskunde gem. EnWG sind und die nicht mehr der gesetzlichen Ersatzversorgung unterliegen, und für Marktlokationen in Mitteldruck. Grundlage ist die bilaterale Vereinbarung — informational note, always applies
437 ConditionResult::True
438 }
439
440 /// [504] Hinweis: Der Code Z22 wird auch in der Sparte Strom genutzt. Der Verweis auf den Einspeisevergütungsintervall ist in der Sparte Gas nicht relevant
441 fn evaluate_504(&self, _ctx: &EvaluationContext) -> ConditionResult {
442 // Hinweis: Code Z22 wird auch in der Sparte Strom genutzt. Der Verweis auf den Einspeisevergütungsintervall ist in der Sparte Gas nicht relevant — informational note, always applies
443 ConditionResult::True
444 }
445
446 /// [505] Hinweis: Übergangsversorgung gibt es nur bei Marktlokationen, die unter § 38a EnWG fallen. Grundlage ist eine bilaterale Vereinbarung
447 fn evaluate_505(&self, _ctx: &EvaluationContext) -> ConditionResult {
448 // Hinweis: Übergangsversorgung gibt es nur bei Marktlokationen, die unter § 38a EnWG fallen. Grundlage ist eine bilaterale Vereinbarung — informational note, always applies
449 ConditionResult::True
450 }
451
452 /// [511] Hinweis: Zu verwenden bei der Abmeldung der Übergangsversorgung
453 fn evaluate_511(&self, _ctx: &EvaluationContext) -> ConditionResult {
454 // Hinweis: Zu verwenden bei der Abmeldung der Übergangsversorgung — informational note, always applies
455 ConditionResult::True
456 }
457
458 /// [1] Wenn Aufteilung vorhanden
459 /// EXTERNAL: Requires context from outside the message.
460 fn evaluate_1(&self, ctx: &EvaluationContext) -> ConditionResult {
461 ctx.external.evaluate("message_splitting")
462 }
463
464 /// [4] Wenn MP-ID in SG2 NAD+MR (Nachrichtenempfänger) in der Rolle LF
465 /// EXTERNAL: Requires context from outside the message.
466 fn evaluate_4(&self, ctx: &EvaluationContext) -> ConditionResult {
467 ctx.external.evaluate("recipient_is_lf")
468 }
469
470 /// [5] Wenn MP-ID in SG2 NAD+MS (Nachrichtenabsender) in der Rolle LF
471 /// EXTERNAL: Requires context from outside the message.
472 fn evaluate_5(&self, ctx: &EvaluationContext) -> ConditionResult {
473 ctx.external.evaluate("sender_is_lf")
474 }
475
476 /// [7] Wenn SG4 STS+7++ZG9/ZH1/ZH2 (Transaktionsgrund: Aufhebung einer zukünftigen Zuordnung wegen Auszug des Kunden / -wegen Stilllegung / -wegen aufgehobenem Vertragsverhältnis) vorhanden
477 fn evaluate_7(&self, ctx: &EvaluationContext) -> ConditionResult {
478 ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZG9", "ZH1", "ZH2"])
479 }
480
481 /// [9] Wenn SG4 STS+7++ZE4 (Transaktionsgrund: Weggefallene Markt- bzw. Messlokation) nicht vorhanden
482 fn evaluate_9(&self, ctx: &EvaluationContext) -> ConditionResult {
483 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZE4"]) {
484 ConditionResult::True => ConditionResult::False,
485 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
486 }
487 }
488
489 /// [10] Wenn SG4 STS+Z17 (Transaktionsgrund für befristete Anmeldung) vorhanden
490 fn evaluate_10(&self, ctx: &EvaluationContext) -> ConditionResult {
491 ctx.has_qualifier("STS", 0, "Z17")
492 }
493
494 /// [11] Wenn SG4 STS+7++ZG9/ZH1/ZH2 (Transaktionsgrund: Aufhebung einer zukünftigen Zuordnung wegen Auszug des Kunden / -wegen Stilllegung / -wegen aufgehobenem Vertragsverhältnis) nicht vorhanden
495 fn evaluate_11(&self, ctx: &EvaluationContext) -> ConditionResult {
496 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZG9", "ZH1", "ZH2"]) {
497 ConditionResult::True => ConditionResult::False,
498 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
499 }
500 }
501
502 /// [12] Wenn SG4 DTM+471 (Ende zum nächstmöglichem Termin) nicht vorhanden
503 fn evaluate_12(&self, ctx: &EvaluationContext) -> ConditionResult {
504 ctx.lacks_qualifier("DTM", 0, "471")
505 }
506
507 /// [13] Wenn SG4 STS+E01++Z01 (Status der Antwort: Zustimmung mit Terminänderung) nicht vorhanden
508 fn evaluate_13(&self, ctx: &EvaluationContext) -> ConditionResult {
509 match ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z01"]) {
510 ConditionResult::True => ConditionResult::False,
511 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
512 }
513 }
514
515 /// [14] Wenn Datum bekannt
516 /// EXTERNAL: Requires context from outside the message.
517 fn evaluate_14(&self, ctx: &EvaluationContext) -> ConditionResult {
518 ctx.external.evaluate("date_known")
519 }
520
521 /// [15] Wenn SG4 STS+E01++Z34 (Status der Antwort: Ablehnung Mehrfachkündigung) vorhanden
522 fn evaluate_15(&self, ctx: &EvaluationContext) -> ConditionResult {
523 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z34"])
524 }
525
526 /// [16] Wenn SG4 STS+E01++Z12 (Status der Antwort: Ablehnung Vertragsbindung) vorhanden
527 fn evaluate_16(&self, ctx: &EvaluationContext) -> ConditionResult {
528 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z12"])
529 }
530
531 /// [17] Wenn bereits eine bestätigte Kündigung durch Kunde oder MP vorhanden
532 /// EXTERNAL: Requires context from outside the message.
533 fn evaluate_17(&self, ctx: &EvaluationContext) -> ConditionResult {
534 ctx.external.evaluate("confirmed_cancellation_present")
535 }
536
537 /// [18] Wenn SG4 DTM+93 (Ende zum) nicht vorhanden
538 fn evaluate_18(&self, ctx: &EvaluationContext) -> ConditionResult {
539 ctx.lacks_qualifier("DTM", 0, "93")
540 }
541
542 /// [19] Wenn SG8 SEQ+Z01 (Daten der Marktlokation) SG10 CCI+++ZC0 (Prognose auf Basis von Werten) vorhanden
543 fn evaluate_19(&self, ctx: &EvaluationContext) -> ConditionResult {
544 ctx.filtered_parent_child_has_qualifier(
545 &["SG4", "SG8"],
546 "SEQ",
547 0,
548 "Z01",
549 "SG10",
550 "CCI",
551 2,
552 "ZC0",
553 )
554 }
555
556 /// [24] Wenn SG6 DTM+Z21 (Termin der Netznutzungsabrechnung) vorhanden
557 fn evaluate_24(&self, ctx: &EvaluationContext) -> ConditionResult {
558 ctx.has_qualifier("DTM", 0, "Z21")
559 }
560
561 /// [25] Wenn der Meldepunkt im SG5 LOC+172 (Meldepunkt) DE3225 das Format der Marktlokations-ID hat
562 // REVIEW: Marktlokations-ID in German gas market is a numeric (all-digit) identifier. LOC+172 has elements[0][0]='172', elements[1][0]=DE3225. Checks if value consists entirely of ASCII digits. Returns Unknown if no LOC+172 exists. (medium confidence)
563 fn evaluate_25(&self, ctx: &EvaluationContext) -> ConditionResult {
564 let segs = ctx.find_segments_with_qualifier("LOC", 0, "172");
565 if segs.is_empty() {
566 return ConditionResult::Unknown;
567 }
568 for seg in &segs {
569 if let Some(val) = seg.elements.get(1).and_then(|e| e.first()) {
570 if !val.is_empty() && val.chars().all(|c| c.is_ascii_digit()) {
571 return ConditionResult::True;
572 }
573 }
574 }
575 ConditionResult::False
576 }
577
578 /// [26] Wenn der Meldepunkt im SG5 LOC+172 (Meldepunkt) DE3225 das Format der Zählpunktbezeichnung hat
579 // REVIEW: Zählpunktbezeichnung format contains non-digit characters (typically alphanumeric string). Negates condition 25's all-digit check. Returns True if DE3225 of LOC+172 is non-empty and contains at least one non-digit character. (medium confidence)
580 fn evaluate_26(&self, ctx: &EvaluationContext) -> ConditionResult {
581 let segs = ctx.find_segments_with_qualifier("LOC", 0, "172");
582 if segs.is_empty() {
583 return ConditionResult::Unknown;
584 }
585 for seg in &segs {
586 if let Some(val) = seg.elements.get(1).and_then(|e| e.first()) {
587 if !val.is_empty() && !val.chars().all(|c| c.is_ascii_digit()) {
588 return ConditionResult::True;
589 }
590 }
591 }
592 ConditionResult::False
593 }
594
595 /// [28] Wenn SG4 DTM+93 (Ende zum) vorhanden
596 fn evaluate_28(&self, ctx: &EvaluationContext) -> ConditionResult {
597 ctx.has_qualifier("DTM", 0, "93")
598 }
599
600 /// [29] Wenn eine Bilanzierung stattfindet
601 /// EXTERNAL: Requires context from outside the message.
602 fn evaluate_29(&self, ctx: &EvaluationContext) -> ConditionResult {
603 ctx.external.evaluate("balancing_takes_place")
604 }
605
606 /// [32] Wenn BGM+E03 (Änderungsmeldungen) vorhanden
607 fn evaluate_32(&self, ctx: &EvaluationContext) -> ConditionResult {
608 ctx.has_qualifier("BGM", 0, "E03")
609 }
610
611 /// [33] Wenn in Abmeldung ein Bilanzierungsende vorhanden
612 // REVIEW: Wenn in Abmeldung ein Bilanzierungsende vorhanden: BGM+E02 identifies the message as Abmeldung (de-registration), DTM+159 is Bilanzierungsende. Both must coexist. (medium confidence)
613 fn evaluate_33(&self, ctx: &EvaluationContext) -> ConditionResult {
614 let has_abmeldung = !ctx.find_segments_with_qualifier("BGM", 0, "E02").is_empty();
615 let has_bilanzierungsende = !ctx.find_segments_with_qualifier("DTM", 0, "159").is_empty();
616 ConditionResult::from(has_abmeldung && has_bilanzierungsende)
617 }
618
619 /// [35] Wenn das DE2380 von SG4 DTM+Z01 (Kündigungsfrist des Vertrags) an vierter Stelle T (Termin) enthält
620 fn evaluate_35(&self, ctx: &EvaluationContext) -> ConditionResult {
621 let segs = ctx.find_segments_with_qualifier("DTM", 0, "Z01");
622 match segs.first() {
623 Some(dtm) => {
624 match dtm
625 .elements
626 .first()
627 .and_then(|e| e.get(1))
628 .map(|s| s.as_str())
629 {
630 Some(value) => match value.chars().nth(3) {
631 Some('T') => ConditionResult::True,
632 Some(_) => ConditionResult::False,
633 None => ConditionResult::False, // segment absent → condition not applicable
634 },
635 None => ConditionResult::False, // segment absent → condition not applicable
636 }
637 }
638 None => ConditionResult::False, // segment absent → condition not applicable
639 }
640 }
641
642 /// [36] Wenn SG4 STS+E01++ZC5 (Status der Antwort: Ablehnung andere Anmeldung in Bearbeitung) vorhanden
643 fn evaluate_36(&self, ctx: &EvaluationContext) -> ConditionResult {
644 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["ZC5"])
645 }
646
647 /// [37] Wenn Anmeldung/ Änderung befristet
648 fn evaluate_37(&self, ctx: &EvaluationContext) -> ConditionResult {
649 // Same check as [10]: STS+Z17 indicates befristete Anmeldung in Gas
650 ctx.has_qualifier("STS", 0, "Z17")
651 }
652
653 /// [39] Wenn LF beabsichtigt Zählerstand zu übermitteln
654 /// EXTERNAL: Requires context from outside the message.
655 fn evaluate_39(&self, ctx: &EvaluationContext) -> ConditionResult {
656 ctx.external
657 .evaluate("lf_intends_to_transmit_meter_reading")
658 }
659
660 /// [46] Wenn in SG8 SEQ+Z35 ein SG10 CCI+Z12 (Lastprofil) CAV (Lastprofil) DE3055 der Wert 293 enthalten ist
661 // REVIEW: In SG8 with SEQ+Z35 (Lastprofildaten), check SG10 children for CCI+Z12 (Lastprofil, elements[0][0]='Z12') AND a Klimazone CCI with DE3055=293 at elements[2][2] (responsible agency code = BDEW/GS1-DE). Uses collect_group_values to find Z35 SG8 instances by index, then navigator for SG10 child traversal. (medium confidence)
662 fn evaluate_46(&self, ctx: &EvaluationContext) -> ConditionResult {
663 let seq_values = ctx.collect_group_values("SEQ", 0, 0, &["SG4", "SG8"]);
664 let z35_instances: Vec<usize> = seq_values
665 .iter()
666 .filter(|(_, v)| v == "Z35")
667 .map(|(i, _)| *i)
668 .collect();
669 if z35_instances.is_empty() {
670 return ConditionResult::False;
671 }
672 let nav = match ctx.navigator() {
673 Some(n) => n,
674 None => return ConditionResult::Unknown,
675 };
676 for i in z35_instances {
677 let sg10_count = nav.child_group_instance_count(&["SG4", "SG8"], i, "SG10");
678 for j in 0..sg10_count {
679 let ccis = nav.find_segments_in_child_group("CCI", &["SG4", "SG8"], i, "SG10", j);
680 let has_z12 = ccis.iter().any(|s| {
681 s.elements
682 .first()
683 .and_then(|e| e.first())
684 .is_some_and(|v| v == "Z12")
685 });
686 if !has_z12 {
687 continue;
688 }
689 // Check Klimazone CCI (Z99/ZA0) for DE3055=293 at elements[2][2]
690 let has_293 = ccis.iter().any(|s| {
691 s.elements
692 .get(2)
693 .and_then(|e| e.get(2))
694 .is_some_and(|v| v == "293")
695 });
696 if has_293 {
697 return ConditionResult::True;
698 }
699 }
700 }
701 ConditionResult::False
702 }
703
704 /// [47] Wenn in SG8 SEQ+Z35 ein SG10 CCI+Z12 (Lastprofil) CAV (Lastprofil) DE3055 der Wert 293 nicht enthalten ist
705 // REVIEW: Logical negation of condition 46: CCI+Z12 Klimazone DE3055=293 NOT present in SG10 under SG8+Z35. Propagates Unknown to maintain three-valued semantics. (medium confidence)
706 fn evaluate_47(&self, ctx: &EvaluationContext) -> ConditionResult {
707 match self.evaluate_46(ctx) {
708 ConditionResult::True => ConditionResult::False,
709 ConditionResult::False => ConditionResult::True,
710 ConditionResult::Unknown => ConditionResult::Unknown,
711 }
712 }
713
714 /// [48] Wenn in dieser SG4 das STS+E01++E14 (Status der Antwort: Ablehnung Sonstiges) vorhanden
715 fn evaluate_48(&self, ctx: &EvaluationContext) -> ConditionResult {
716 // HAND-EDITED: "in dieser SG4" — the enclosing SG4 only, when the scope
717 // reaches one; the message as before otherwise. As
718 // `has_qualified_value`: Unknown without any STS+E01.
719 if let Some(scope) = ctx.enclosing_scope("SG4") {
720 let e01: Vec<_> = ctx
721 .find_segments_at(scope, "STS")
722 .into_iter()
723 .filter(|s| s.get_element(0) == "E01")
724 .collect();
725 if e01.is_empty() {
726 return ConditionResult::Unknown;
727 }
728 return ConditionResult::from(e01.iter().any(|s| s.get_component(2, 0) == "E14"));
729 }
730 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["E14"])
731 }
732
733 /// [51] Bei rückwirkendem Lieferende/Lieferbeginn
734 /// EXTERNAL: Requires context from outside the message.
735 fn evaluate_51(&self, ctx: &EvaluationContext) -> ConditionResult {
736 ctx.external.evaluate("retroactive_delivery_change")
737 }
738
739 /// [58] Wenn in diesem CCI das DE3055 mit dem Code 293 vorhanden
740 // REVIEW: DE3055 (Verantwortliche Stelle für die Codepflege) appears at CCI elements[2][2] in CCI — Klimazone/Temperaturmessstelle. Checks any CCI in the message has that code. 'In diesem CCI' implies context-local check; falls back to message-wide. (medium confidence)
741 fn evaluate_58(&self, ctx: &EvaluationContext) -> ConditionResult {
742 // HAND-EDITED (#379): "in diesem CCI" — the CCI whose field is judged
743 // (C240 DE3055 is component 2 of element 2); any CCI of the message only
744 // where none is resolved.
745 let codepflege =
746 |e: &[Vec<String>]| e.get(2).and_then(|c| c.get(2)).is_some_and(|v| v == "293");
747 match ctx.resolved_segment {
748 Some(elements) => ConditionResult::from(codepflege(elements)),
749 None => ConditionResult::from(
750 ctx.find_segments("CCI")
751 .iter()
752 .any(|s| codepflege(&s.elements)),
753 ),
754 }
755 }
756
757 /// [64] Wenn SG4 DTM+158 (Bilanzierungsbeginn) vorhanden
758 fn evaluate_64(&self, ctx: &EvaluationContext) -> ConditionResult {
759 ctx.has_qualifier("DTM", 0, "158")
760 }
761
762 /// [65] Wenn Marktgebietsüber-lappung besteht, sind alle Bilanzkreise des LF zu melden in denen freie Kapazitäten beim NB bestehen
763 /// EXTERNAL: Requires context from outside the message.
764 fn evaluate_65(&self, ctx: &EvaluationContext) -> ConditionResult {
765 ctx.external.evaluate("market_area_overlap_exists")
766 }
767
768 /// [66] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als einmal vorhanden
769 fn evaluate_66(&self, ctx: &EvaluationContext) -> ConditionResult {
770 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
771 ConditionResult::from(count > 1)
772 }
773
774 /// [68] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als zweimal vorhanden
775 fn evaluate_68(&self, ctx: &EvaluationContext) -> ConditionResult {
776 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
777 ConditionResult::from(count > 2)
778 }
779
780 /// [69] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als dreimal vorhanden
781 fn evaluate_69(&self, ctx: &EvaluationContext) -> ConditionResult {
782 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
783 ConditionResult::from(count > 3)
784 }
785
786 /// [70] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang fünfmal vorhanden
787 fn evaluate_70(&self, ctx: &EvaluationContext) -> ConditionResult {
788 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
789 ConditionResult::from(count == 5)
790 }
791
792 /// [77] Wenn SG8 SEQ+Z03 (Zähleinrichtungsdaten) CAV+Z30 (Identifikation/Nummer des Gerätes) nicht vorhanden
793 fn evaluate_77(&self, ctx: &EvaluationContext) -> ConditionResult {
794 ctx.any_group_has_qualifier_without("SEQ", 0, "Z03", "CAV", 0, "Z30", &["SG4", "SG8"])
795 }
796
797 /// [78] Wenn SG4 STS+7++E02 (Transaktionsgrund: Einzug in Neuanlage) nicht vorhanden
798 fn evaluate_78(&self, ctx: &EvaluationContext) -> ConditionResult {
799 let result = ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]);
800 match result {
801 ConditionResult::True => ConditionResult::False,
802 ConditionResult::False => ConditionResult::True,
803 ConditionResult::Unknown => ConditionResult::Unknown,
804 }
805 }
806
807 /// [81] Wenn SG4 FTX+ABO+Z05 (Beschreibung der Abweichung zur übermittelten Liste: Änderung vorhanden) vorhanden
808 fn evaluate_81(&self, ctx: &EvaluationContext) -> ConditionResult {
809 ctx.has_qualified_value("FTX", 0, "ABO", 2, 0, &["Z05"])
810 }
811
812 /// [84] Wenn SG4 STS+E01++Z35 (Status der Antwort: Ablehnung der Abmeldeanfrage) vorhanden
813 fn evaluate_84(&self, ctx: &EvaluationContext) -> ConditionResult {
814 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z35"])
815 }
816
817 /// [92] Wenn Wert innerhalb SG bzw. Segment geändert wird
818 /// EXTERNAL: Requires context from outside the message.
819 // REVIEW: 'Wenn Wert innerhalb SG bzw. Segment geändert wird' — whether a value was changed compared to a prior state cannot be determined from the EDIFACT message alone; requires external business context comparing current vs previous transmission. (medium confidence)
820 fn evaluate_92(&self, ctx: &EvaluationContext) -> ConditionResult {
821 ctx.external.evaluate("value_changed_in_segment")
822 }
823
824 /// [98] Wenn MP-ID in SG2 NAD+MS (Nachrichtenabsender) in der Rolle NB
825 /// EXTERNAL: Requires context from outside the message.
826 // REVIEW: 'Wenn MP-ID in SG2 NAD+MS in der Rolle NB' — while we can confirm NAD+MS exists in the message, determining whether that market participant ID is registered in the role of Netzbetreiber (NB) requires an external role/master-data lookup. Cannot be derived from the EDIFACT message content alone. (medium confidence)
827 fn evaluate_98(&self, ctx: &EvaluationContext) -> ConditionResult {
828 ctx.external.evaluate("sender_is_nb")
829 }
830
831 /// [106] Wenn in dieser SG8 SEQ+Z01 SG10 CCI+++ZA6 (Prognosegrundlage der Marktlokation: Prognose auf Basis von Profilen) vorhanden
832 fn evaluate_106(&self, ctx: &EvaluationContext) -> ConditionResult {
833 // HAND-EDITED: "in dieser/derselben SG8" — the enclosing SG8 only, when the
834 // scope reaches one; the message as before otherwise.
835 if let Some(scope) = ctx.enclosing_scope("SG8") {
836 return ConditionResult::from(
837 ctx.find_segments_at(scope, "SEQ")
838 .iter()
839 .any(|s| matches!(s.get_element(0), "Z01"))
840 && ctx
841 .find_segments_at(scope, "CCI")
842 .iter()
843 .any(|s| s.get_component(2, 0) == "ZA6"),
844 );
845 }
846 ctx.filtered_parent_child_has_qualifier(
847 &["SG4", "SG8"],
848 "SEQ",
849 0,
850 "Z01",
851 "SG10",
852 "CCI",
853 2,
854 "ZA6",
855 )
856 }
857
858 /// [108] Wenn Kundenwertverfahren (z. B. TU München)
859 /// EXTERNAL: Requires context from outside the message.
860 // REVIEW: Kundenwertverfahren (e.g., TU München) is a specific billing methodology determined by contract terms, not derivable from the EDIFACT message content itself. (medium confidence)
861 fn evaluate_108(&self, ctx: &EvaluationContext) -> ConditionResult {
862 ctx.external.evaluate("kundenwertverfahren")
863 }
864
865 /// [123] Wenn noch mindestens eine weitere SG8 SEQ+Z20 (OBIS-Daten der Zähleinrichtung / Mengenumwerter) mit dem SG8 RFF+MG / Z11 (Gerätenummer des Zählers / Mengenumwerters) auf die gleiche Identifikati...
866 // REVIEW: Collects device IDs (via RFF+MG or RFF+Z11) from all SG8 instances that have SEQ+Z20. Returns True if any device ID appears in at least two such instances, indicating at least one further SG8 references the same device. Requires navigator for proper group-scoped traversal. (medium confidence)
867 fn evaluate_123(&self, ctx: &EvaluationContext) -> ConditionResult {
868 let nav = match ctx.navigator() {
869 Some(n) => n,
870 None => {
871 let seqs = ctx.find_segments_with_qualifier("SEQ", 0, "Z20");
872 if seqs.len() < 2 {
873 return ConditionResult::False;
874 }
875 return ConditionResult::Unknown;
876 }
877 };
878 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
879 let mut device_ids: Vec<String> = Vec::new();
880 for i in 0..sg8_count {
881 let seqs = nav.find_segments_in_group("SEQ", &["SG4", "SG8"], i);
882 let has_z20 = seqs.iter().any(|s| {
883 s.elements
884 .first()
885 .and_then(|e| e.first())
886 .is_some_and(|v| v == "Z20")
887 });
888 if !has_z20 {
889 continue;
890 }
891 let rffs = nav.find_segments_in_group("RFF", &["SG4", "SG8"], i);
892 for rff in &rffs {
893 let qual = rff
894 .elements
895 .first()
896 .and_then(|e| e.first())
897 .map(|s| s.as_str());
898 if matches!(qual, Some("MG") | Some("Z11")) {
899 if let Some(id) = rff.elements.first().and_then(|e| e.get(1)) {
900 if !id.is_empty() {
901 device_ids.push(id.clone());
902 }
903 }
904 }
905 }
906 }
907 for i in 0..device_ids.len() {
908 for j in (i + 1)..device_ids.len() {
909 if device_ids[i] == device_ids[j] {
910 return ConditionResult::True;
911 }
912 }
913 }
914 ConditionResult::False
915 }
916
917 /// [127] Hat der Lieferant auf Grund seines Vertrags Kenntnis, dass der Kunde keine hohe KA hat so muss er dies dem NB mitteilen
918 /// EXTERNAL: Requires context from outside the message.
919 // REVIEW: Whether the supplier knows from their contract that the customer has no high KA (Kapazitätsanteil) is contract-based knowledge external to the EDIFACT message. Cannot be determined from segment data alone. (medium confidence)
920 fn evaluate_127(&self, ctx: &EvaluationContext) -> ConditionResult {
921 ctx.external.evaluate("supplier_knows_no_high_ka")
922 }
923
924 /// [128] Wenn SG10 CAV+TAS/ TKS/ SAS/ KAS vorhanden
925 fn evaluate_128(&self, ctx: &EvaluationContext) -> ConditionResult {
926 ctx.any_group_has_any_qualifier(
927 "CAV",
928 0,
929 &["TAS", "TKS", "SAS", "KAS"],
930 &["SG4", "SG8", "SG10"],
931 )
932 }
933
934 /// [129] Hat der Lieferant auf Grund seines Vertrags Kenntnis über die Höhe der Sonder-KA, so muss er diesen dem NB mitteilen
935 /// EXTERNAL: Requires context from outside the message.
936 // REVIEW: Whether the supplier has contract knowledge about the amount of a special KA (Sonder-Kapazitätsanteil) is contract-based knowledge. Cannot be derived from the EDIFACT message. (medium confidence)
937 fn evaluate_129(&self, ctx: &EvaluationContext) -> ConditionResult {
938 ctx.external.evaluate("supplier_knows_special_ka_amount")
939 }
940
941 /// [130] Wenn an Messlokation vorhanden
942 // REVIEW: 'Wenn an Messlokation vorhanden' is interpreted as: a Messlokation section exists in the message, indicated by SEQ+Z18 (Daten der Messlokation) in SG8. Returns True when such a section is present. (medium confidence)
943 fn evaluate_130(&self, ctx: &EvaluationContext) -> ConditionResult {
944 ctx.has_qualifier("SEQ", 0, "Z18")
945 }
946
947 /// [133] Wenn an der übermittelten Marktlokation / Messlokation vorhanden
948 /// EXTERNAL: Requires context from outside the message.
949 // REVIEW: 'Wenn an der übermittelten Marktlokation / Messlokation vorhanden' — whether a specific data element exists at the transmitted market or metering location is a business/registry lookup that cannot be determined from the EDIFACT message content alone. Marked external. (medium confidence)
950 fn evaluate_133(&self, ctx: &EvaluationContext) -> ConditionResult {
951 ctx.external.evaluate("at_marktlokation_or_messlokation")
952 }
953
954 /// [137] Nicht bei Neuanlage
955 // REVIEW: 'Nicht bei Neuanlage' — the condition is True when the transaction reason is NOT E02 (Neubau / new installation). Finds STS with elements[0][0]="7" (Transaktionsgrund), checks elements[2][0] for E02, and negates the result. (medium confidence)
956 fn evaluate_137(&self, ctx: &EvaluationContext) -> ConditionResult {
957 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]) {
958 ConditionResult::True => ConditionResult::False,
959 ConditionResult::False => ConditionResult::True,
960 ConditionResult::Unknown => ConditionResult::Unknown,
961 }
962 }
963
964 /// [138] Wenn SG5 LOC+172 (Meldepunkt) nicht vorhanden
965 fn evaluate_138(&self, ctx: &EvaluationContext) -> ConditionResult {
966 ctx.lacks_qualifier("LOC", 0, "172")
967 }
968
969 /// [147] Wenn in Anfrage vorhanden
970 /// EXTERNAL: Requires context from outside the message.
971 // REVIEW: 'Wenn in Anfrage vorhanden' — whether something is present in the original inquiry/request message is a cross-message business context that cannot be determined from the current EDIFACT message alone. Marked external. (medium confidence)
972 fn evaluate_147(&self, ctx: &EvaluationContext) -> ConditionResult {
973 ctx.external.evaluate("present_in_request")
974 }
975
976 /// [165] Wenn bekannt
977 /// EXTERNAL: Requires context from outside the message.
978 fn evaluate_165(&self, ctx: &EvaluationContext) -> ConditionResult {
979 ctx.external.evaluate("date_known")
980 }
981
982 /// [166] Wenn vorhanden
983 /// EXTERNAL: Requires context from outside the message.
984 // REVIEW: 'Wenn vorhanden' — generic 'if present/available' without a specific segment reference. When used as a standalone condition this refers to business data availability that cannot be determined from the EDIFACT message structure alone. Marked external. (medium confidence)
985 fn evaluate_166(&self, ctx: &EvaluationContext) -> ConditionResult {
986 ctx.external.evaluate("data_available")
987 }
988
989 /// [200] Wenn BGM+Z26 (Vorläufige Meldung zur Marktraumumstellung) vorhanden
990 fn evaluate_200(&self, ctx: &EvaluationContext) -> ConditionResult {
991 ctx.has_qualifier("BGM", 0, "Z26")
992 }
993
994 /// [202] Wenn SG4 STS+E01+ZG2 (Status der Antwort: Gültiges Ergebnis nach der Datenprüfung) vorhanden
995 fn evaluate_202(&self, ctx: &EvaluationContext) -> ConditionResult {
996 ctx.has_qualified_value("STS", 0, "E01", 1, 0, &["ZG2"])
997 }
998
999 /// [205] Wenn SG9 QTY+Y02 (TUM Kundenwert) nicht vorhanden
1000 fn evaluate_205(&self, ctx: &EvaluationContext) -> ConditionResult {
1001 ctx.lacks_qualifier("QTY", 0, "Y02")
1002 }
1003
1004 /// [209] Wenn im selben Segment im DE2379 der Code 303 vorhanden ist
1005 fn evaluate_209(&self, ctx: &EvaluationContext) -> ConditionResult {
1006 ConditionResult::from(ctx.self_segment_value_equals("DTM", 0, 2, "303"))
1007 }
1008
1009 /// [212] Wenn im selben SG12 NAD DE3124 nicht vorhanden
1010 // REVIEW: Checks if any NAD in SG12 has DE3124 (C058 first component, elements[2][0]) absent or empty. Without group-scoped navigation, falls back to message-wide NAD check. (medium confidence)
1011 fn evaluate_212(&self, ctx: &EvaluationContext) -> ConditionResult {
1012 let nads = ctx.find_segments("NAD");
1013 ConditionResult::from(nads.iter().any(|s| {
1014 s.elements
1015 .get(2)
1016 .map(|e| e.first().map(|v| v.is_empty()).unwrap_or(true))
1017 .unwrap_or(true)
1018 }))
1019 }
1020
1021 /// [213] Wenn SG12 NAD+Z09 (Kunde des Lieferanten) vorhanden
1022 fn evaluate_213(&self, ctx: &EvaluationContext) -> ConditionResult {
1023 ctx.has_qualifier("NAD", 0, "Z09")
1024 }
1025
1026 /// [216] Wenn CCI+++Z88 (Netznutzung) CAV+Z74:::Z08 (Netznutzungsvertrag: Direkter Vertrag zwischen Kunden und NB) vorhanden
1027 // REVIEW: CCI+++Z88 means elements[2][0]=='Z88' (Netznutzung). CAV+Z74:::Z08 means elements[0][0]=='Z74' and elements[0][3]=='Z08' (Direkter Vertrag). Uses parent-child group navigation to check co-occurrence within the same SG10 instance. (medium confidence)
1028 fn evaluate_216(&self, ctx: &EvaluationContext) -> ConditionResult {
1029 let nav = match ctx.navigator() {
1030 Some(n) => n,
1031 None => {
1032 let cavs = ctx.find_segments("CAV");
1033 return ConditionResult::from(cavs.iter().any(|s| {
1034 let e0 = s.elements.first();
1035 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1036 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1037 }));
1038 }
1039 };
1040 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
1041 for i in 0..sg8_count {
1042 let sg10_count = nav.child_group_instance_count(&["SG4", "SG8"], i, "SG10");
1043 for j in 0..sg10_count {
1044 let ccis = nav.find_segments_in_child_group("CCI", &["SG4", "SG8"], i, "SG10", j);
1045 let has_cci_z88 = ccis.iter().any(|s| {
1046 s.elements
1047 .get(2)
1048 .and_then(|e| e.first())
1049 .is_some_and(|v| v == "Z88")
1050 });
1051 if has_cci_z88 {
1052 let cavs =
1053 nav.find_segments_in_child_group("CAV", &["SG4", "SG8"], i, "SG10", j);
1054 if cavs.iter().any(|s| {
1055 let e0 = s.elements.first();
1056 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1057 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1058 }) {
1059 return ConditionResult::True;
1060 }
1061 }
1062 }
1063 }
1064 ConditionResult::False
1065 }
1066
1067 /// [219] Wenn an Marktlokation vorhanden
1068 /// EXTERNAL: Requires context from outside the message.
1069 // REVIEW: 'Wenn an Marktlokation vorhanden' — whether specific data exists at the market location is a registry/master-data lookup that cannot be derived from the EDIFACT message content. Marked external. (medium confidence)
1070 fn evaluate_219(&self, ctx: &EvaluationContext) -> ConditionResult {
1071 ctx.external.evaluate("at_marktlokation")
1072 }
1073
1074 /// [230] Sich ergebendes Datum/ bzw. Endedatum des Turnuszeitraums aus DTM+Z21 (Termin der Netznutzungsabrechnung) und DTM+Z09 (Nächste Netznutzungsabrechnung) muss >= DTM+92 (Beginn zum) sein
1075 // REVIEW: Compares the later of DTM+Z21 and DTM+Z09 (end of Turnuszeitraum) against DTM+92 (start date). Date formats differ across the three DTM qualifiers (Z21=CCYYMM/format 106, Z09=format 602, DTM+92=CCYYMMDDHHMM/format 303), so comparison is normalized to the CCYYMM prefix (first 6 chars). The exact definition of 'sich ergebendes Datum' from Z21+Z09 introduces some ambiguity — using max(Z21,Z09) as the best approximation. (medium confidence)
1076 fn evaluate_230(&self, ctx: &EvaluationContext) -> ConditionResult {
1077 {
1078 // DTM+Z21 (Termin der Netznutzungsabrechnung): elements[0][1], format 106/104
1079 let z21_val = ctx
1080 .find_segments_with_qualifier("DTM", 0, "Z21")
1081 .into_iter()
1082 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1083 .unwrap_or_default();
1084 // DTM+Z09 (Nächste Netznutzungsabrechnung): elements[0][1], format 602
1085 let z09_val = ctx
1086 .find_segments_with_qualifier("DTM", 0, "Z09")
1087 .into_iter()
1088 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1089 .unwrap_or_default();
1090 // DTM+92 (Beginn zum): elements[0][1], format 303 (CCYYMMDDHHMM)
1091 let dtm92_val = match ctx
1092 .find_segments_with_qualifier("DTM", 0, "92")
1093 .into_iter()
1094 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1095 {
1096 Some(v) if !v.is_empty() => v,
1097 _ => return ConditionResult::Unknown,
1098 };
1099 // Use the later of Z21 and Z09 as the end date of the Turnuszeitraum
1100 // Note: formats differ (Z21=106/104, Z09=602, DTM+92=303) — use first 6 chars (CCYYMM) for comparison
1101 let end_date = match (z21_val.is_empty(), z09_val.is_empty()) {
1102 (false, false) => {
1103 if z21_val >= z09_val {
1104 z21_val
1105 } else {
1106 z09_val
1107 }
1108 }
1109 (false, true) => z21_val,
1110 (true, false) => z09_val,
1111 (true, true) => return ConditionResult::Unknown,
1112 };
1113 // Compare first 6 chars (CCYYMM) — both reference dates have at least CCYYMM
1114 let end_ym = &end_date[..end_date.len().min(6)];
1115 let begin_ym = &dtm92_val[..dtm92_val.len().min(6)];
1116 if end_ym.len() < 6 || begin_ym.len() < 6 {
1117 return ConditionResult::Unknown;
1118 }
1119 ConditionResult::from(end_ym >= begin_ym)
1120 }
1121 }
1122
1123 /// [241] Wenn MP-ID in SG2 NAD+MR (Nachrichtenempfänger) in der Rolle MSB
1124 /// EXTERNAL: Requires context from outside the message.
1125 fn evaluate_241(&self, ctx: &EvaluationContext) -> ConditionResult {
1126 ctx.external.evaluate("recipient_is_msb")
1127 }
1128
1129 /// [249] Innerhalb eines SG4 IDE müssen alle DE1131 der SG4 STS+E01 den identischen Wert enthalten
1130 // REVIEW: Checks that all STS+E01 segments have identical DE1131 values (elements[2][1] — Codeliste, Code within C556). Returns True when all values match the first occurrence. Message-wide fallback without per-SG4 grouping. (medium confidence)
1131 fn evaluate_249(&self, ctx: &EvaluationContext) -> ConditionResult {
1132 let sts_segs = ctx.find_segments("STS");
1133 let sts_e01: Vec<_> = sts_segs
1134 .iter()
1135 .filter(|s| {
1136 s.elements
1137 .first()
1138 .and_then(|e| e.first())
1139 .is_some_and(|v| v == "E01")
1140 })
1141 .collect();
1142 if sts_e01.is_empty() {
1143 return ConditionResult::Unknown;
1144 }
1145 let first_val = sts_e01
1146 .first()
1147 .and_then(|s| s.elements.get(2))
1148 .and_then(|e| e.get(1))
1149 .map(|v| v.as_str())
1150 .unwrap_or("");
1151 ConditionResult::from(sts_e01.iter().all(|s| {
1152 s.elements
1153 .get(2)
1154 .and_then(|e| e.get(1))
1155 .map(|v| v.as_str())
1156 .unwrap_or("")
1157 == first_val
1158 }))
1159 }
1160
1161 /// [252] Wenn DE0068 vorhanden
1162 // REVIEW: DE0068 is the Common Access Reference in UNH (elements[2][0]). Checks if it is present and non-empty in any UNH segment. (medium confidence)
1163 fn evaluate_252(&self, ctx: &EvaluationContext) -> ConditionResult {
1164 let unh_segs = ctx.find_segments("UNH");
1165 ConditionResult::from(unh_segs.iter().any(|s| {
1166 s.elements
1167 .get(2)
1168 .and_then(|e| e.first())
1169 .is_some_and(|v| !v.is_empty())
1170 }))
1171 }
1172
1173 /// [257] Wenn in derselben SG8 SEQ+Z02 (OBIS-Daten der Marktlokation) das PIA+5+7-0?:33.86.0 vorhanden
1174 fn evaluate_257(&self, ctx: &EvaluationContext) -> ConditionResult {
1175 // HAND-EDITED: "in dieser/derselben SG8" — the enclosing SG8 only, when the
1176 // scope reaches one; the message as before otherwise.
1177 if let Some(scope) = ctx.enclosing_scope("SG8") {
1178 return ConditionResult::from(
1179 ctx.find_segments_at(scope, "SEQ")
1180 .iter()
1181 .any(|s| matches!(s.get_element(0), "Z02"))
1182 && ctx
1183 .find_segments_at(scope, "PIA")
1184 .iter()
1185 .any(|s| s.get_component(1, 0) == "7-0:33.86.0"),
1186 );
1187 }
1188 ctx.any_group_has_co_occurrence(
1189 "SEQ",
1190 0,
1191 &["Z02"],
1192 "PIA",
1193 1,
1194 0,
1195 &["7-0:33.86.0"],
1196 &["SG4", "SG8"],
1197 )
1198 }
1199
1200 /// [268] Wenn der Code im DE3207 in der "EDI@Energy Codeliste der europäischen Ländercodes" in der Spalte "PLZ vorhanden" ein "X" aufgeführt ist
1201 /// EXTERNAL: Requires context from outside the message.
1202 fn evaluate_268(&self, ctx: &EvaluationContext) -> ConditionResult {
1203 ctx.external.evaluate("country_has_postal_code_requirement")
1204 }
1205
1206 /// [274] Wenn in derselben SG8 SEQ+Z20 (OBIS-Daten der Zähleinrichtung / Mengenumwerter) das PIA+5+7-b?:3.0.0 / 7-b?:6.0.0 / 7-b?:3.1.0 / 7-b?:6.1.0 / 7-b?:3.2.0 / 7-b?:6.2.0 / 7-b?:13.2.0 / 7-b?:16.2.0 / ...
1207 // REVIEW: Checks co-occurrence of SEQ+Z20 and PIA+5 in same SG8, then verifies the OBIS code (elements[1][0]) matches pattern '7-b:X.X.X' where b is variable (any subgroup) and suffix is one of the 16 listed measurement quantities. EDIFACT ?. decoded as literal colon. OBIS suffix match is message-wide as a secondary filter. (medium confidence)
1208 fn evaluate_274(&self, ctx: &EvaluationContext) -> ConditionResult {
1209 let obis_suffixes = [
1210 ":3.0.0", ":6.0.0", ":3.1.0", ":6.1.0", ":3.2.0", ":6.2.0", ":13.2.0", ":16.2.0",
1211 ":1.0.0", ":2.0.0", ":4.0.0", ":5.0.0", ":11.2.0", ":12.2.0", ":14.2.0", ":15.2.0",
1212 ];
1213 // HAND-EDITED: "in dieser/derselben SG8" — the enclosing SG8 only, when the
1214 // scope reaches one; the message as before otherwise.
1215 if let Some(scope) = ctx.enclosing_scope("SG8") {
1216 return ConditionResult::from(
1217 ctx.find_segments_at(scope, "SEQ")
1218 .iter()
1219 .any(|s| matches!(s.get_element(0), "Z20"))
1220 && ctx.find_segments_at(scope, "PIA").iter().any(|s| {
1221 let v = s.get_component(1, 0);
1222 s.get_element(0) == "5"
1223 && v.starts_with("7-")
1224 && obis_suffixes.iter().any(|suf| v.ends_with(suf))
1225 }),
1226 );
1227 }
1228 let has_seq_pia_co = ctx.any_group_has_co_occurrence(
1229 "SEQ",
1230 0,
1231 &["Z20"],
1232 "PIA",
1233 0,
1234 0,
1235 &["5"],
1236 &["SG4", "SG8"],
1237 );
1238 if !matches!(has_seq_pia_co, ConditionResult::True) {
1239 return has_seq_pia_co;
1240 }
1241 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1242 ConditionResult::from(pias.iter().any(|s| {
1243 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
1244 v.starts_with("7-") && obis_suffixes.iter().any(|suf| v.ends_with(suf))
1245 })
1246 }))
1247 }
1248
1249 /// [276] Wenn SG4 DTM+92 (Beginn zum) vorhanden
1250 fn evaluate_276(&self, ctx: &EvaluationContext) -> ConditionResult {
1251 ctx.has_qualifier("DTM", 0, "92")
1252 }
1253
1254 /// [277] Wenn Zuordnung vorhanden
1255 // REVIEW: 'Wenn Zuordnung vorhanden' most likely refers to Bilanzkreiszuordnung zur Marktlokation, indicated by STS+Z18 per the MIG segment reference. Medium confidence as 'Zuordnung' could refer to other assignments in different PID contexts. (medium confidence)
1256 fn evaluate_277(&self, ctx: &EvaluationContext) -> ConditionResult {
1257 ctx.has_qualifier("STS", 0, "Z18")
1258 }
1259
1260 /// [283] Wenn Empfänger der Nachricht der zum Nachrichtendatum aktuell zugeordnete Lieferant ist
1261 /// EXTERNAL: Requires context from outside the message.
1262 fn evaluate_283(&self, ctx: &EvaluationContext) -> ConditionResult {
1263 ctx.external.evaluate("recipient_is_current_supplier")
1264 }
1265
1266 /// [336] Wenn in Änderungsmeldung gefüllt
1267 /// EXTERNAL: Requires context from outside the message.
1268 // REVIEW: "Wenn in Änderungsmeldung gefüllt" means the condition applies when this field is populated in the context of an amendment message (Änderungsmeldung). Whether a given transmission constitutes an amendment depends on business context (the PID / Vorgang type) that cannot be reliably determined from the raw EDIFACT segments alone. Delegated to external provider. (medium confidence)
1269 fn evaluate_336(&self, ctx: &EvaluationContext) -> ConditionResult {
1270 ctx.external.evaluate("field_filled_in_amendment_message")
1271 }
1272
1273 /// [345] Wenn 33-stelliger Meldepunkt im SG5 LOC+172 (Meldepunkt) vorhanden
1274 fn evaluate_345(&self, ctx: &EvaluationContext) -> ConditionResult {
1275 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
1276 ConditionResult::from(locs.iter().any(|s| {
1277 s.elements
1278 .get(1)
1279 .and_then(|e| e.first())
1280 .map(|id| id.len() == 33)
1281 .unwrap_or(false)
1282 }))
1283 }
1284
1285 /// [361] Wenn STS+E01++A03/ A04 nicht vorhanden
1286 fn evaluate_361(&self, ctx: &EvaluationContext) -> ConditionResult {
1287 let found = ctx
1288 .find_segments_with_qualifier("STS", 0, "E01")
1289 .iter()
1290 .any(|s| {
1291 s.elements
1292 .get(2)
1293 .and_then(|e| e.first())
1294 .map(|v| v == "A03" || v == "A04")
1295 .unwrap_or(false)
1296 });
1297 ConditionResult::from(!found)
1298 }
1299
1300 /// [362] Wenn STS+E01++A03/ A17 nicht vorhanden
1301 fn evaluate_362(&self, ctx: &EvaluationContext) -> ConditionResult {
1302 let found = ctx
1303 .find_segments_with_qualifier("STS", 0, "E01")
1304 .iter()
1305 .any(|s| {
1306 s.elements
1307 .get(2)
1308 .and_then(|e| e.first())
1309 .map(|v| v == "A03" || v == "A17")
1310 .unwrap_or(false)
1311 });
1312 ConditionResult::from(!found)
1313 }
1314
1315 /// [367] Wenn SG4 STS+E01++A04 vorhanden
1316 fn evaluate_367(&self, ctx: &EvaluationContext) -> ConditionResult {
1317 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["A04"])
1318 }
1319
1320 /// [368] Es sind alle Codes aus der Codeliste G_0009 erlaubt
1321 fn evaluate_368(&self, _ctx: &EvaluationContext) -> ConditionResult {
1322 ConditionResult::True
1323 }
1324
1325 /// [427] Messprodukt-Code aus Kapitel 3 "Codeliste der Standard-Messprodukte Gas" der Codeliste der Konfigurationen
1326 /// EXTERNAL: Requires context from outside the message.
1327 fn evaluate_427(&self, ctx: &EvaluationContext) -> ConditionResult {
1328 ctx.external.evaluate("messprodukt_code_gas_valid")
1329 }
1330
1331 /// [442] Wenn in keinem SG8+SEQ+Z09 Mengenumwerterdaten das RFF+MG (Referenz auf die Gerätenummer) der in diesem RFF DE1154 genannte Gerätenummer des Zählers vorhanden ist
1332 fn evaluate_442(&self, ctx: &EvaluationContext) -> ConditionResult {
1333 // HAND-EDITED (#379): the device number this RFF names (DE1154) in an
1334 // RFF+MG of a SEQ+Z09 SG8 — not any RFF+MG there. A Zähler whose own
1335 // number no Mengenumwerter references may carry its RFF+MG.
1336 let Some(number) = ctx
1337 .resolved_segment
1338 .and_then(|e| e.first())
1339 .and_then(|c| c.get(1))
1340 .filter(|v| !v.is_empty())
1341 else {
1342 return ConditionResult::Unknown;
1343 };
1344 let sg8 = ["SG4", "SG8"];
1345 let referenced = (0..ctx.group_instance_count(&sg8)).any(|i| {
1346 ctx.find_segments_in_group("SEQ", &sg8, i)
1347 .iter()
1348 .any(|s| s.get_element(0) == "Z09")
1349 && ctx
1350 .find_segments_in_group("RFF", &sg8, i)
1351 .iter()
1352 .any(|s| s.get_component(0, 0) == "MG" && s.get_component(0, 1) == number)
1353 });
1354 ConditionResult::from(!referenced)
1355 }
1356
1357 /// [490] Wenn Wert in diesem DE, an der Stelle CCYYMMDD ein Datum aus dem angegeben Zeitraum der Tabelle Kapitel 3.5 „Prozesszeitpunkt bei MESZ mit UTC“ ist
1358 fn evaluate_490(&self, ctx: &EvaluationContext) -> ConditionResult {
1359 match ctx.resolved_value {
1360 Some(val) => is_mesz_utc(val),
1361 None => ConditionResult::False,
1362 }
1363 }
1364
1365 /// [491] Wenn Wert in diesem DE, an der Stelle CCYYMMDD ein Datum aus dem angegeben Zeitraum der Tabelle Kapitel 3.6 „Prozesszeitpunkt bei MEZ mit UTC““ ist
1366 fn evaluate_491(&self, ctx: &EvaluationContext) -> ConditionResult {
1367 match ctx.resolved_value {
1368 Some(val) => is_mez_utc(val),
1369 None => ConditionResult::False,
1370 }
1371 }
1372
1373 /// [494] Das hier genannte Datum muss der Zeitpunkt sein, zu dem das Dokument erstellt wurde, oder ein Zeitpunkt, der davor liegt
1374 fn evaluate_494(&self, _ctx: &EvaluationContext) -> ConditionResult {
1375 // Hinweis: Das genannte Datum muss dem Dokumenterstellungszeitpunkt oder einem früheren Zeitpunkt entsprechen — informational annotation
1376 ConditionResult::True
1377 }
1378
1379 /// [500] Hinweis: Code ist gemäß der Kategorie der zu stornierenden Meldung zu wählen
1380 fn evaluate_500(&self, _ctx: &EvaluationContext) -> ConditionResult {
1381 // Hinweis: Code ist gemäß der Kategorie der zu stornierenden Meldung zu wählen — informational note, always applies
1382 ConditionResult::True
1383 }
1384
1385 /// [501] Hinweis: Die Angabe wird aus dem DTM+157 (Änderung zum) der Zuordnungsliste übernommen
1386 fn evaluate_501(&self, _ctx: &EvaluationContext) -> ConditionResult {
1387 // Hinweis: Die Angabe wird aus dem DTM+157 (Änderung zum) der Zuordnungsliste übernommen — informational note, always applies
1388 ConditionResult::True
1389 }
1390
1391 /// [507] Hinweis: Ursprünglich vom NB bestätigtes Beginndatum
1392 fn evaluate_507(&self, _ctx: &EvaluationContext) -> ConditionResult {
1393 // Hinweis: Informational note — 'ursprünglich vom NB bestätigtes Beginndatum'.
1394 // Documents the semantic meaning of the date field; no boolean logic.
1395 ConditionResult::Unknown
1396 }
1397
1398 /// [508] Hinweis: Beginndatum beim neuen NB
1399 fn evaluate_508(&self, _ctx: &EvaluationContext) -> ConditionResult {
1400 // Hinweis: Informational note — 'Beginndatum beim neuen NB'.
1401 // Documents the semantic meaning of the date field; no boolean logic.
1402 ConditionResult::Unknown
1403 }
1404
1405 /// [510] Hinweis: Zu verwenden bei der Abmeldung der ESV
1406 fn evaluate_510(&self, _ctx: &EvaluationContext) -> ConditionResult {
1407 // Hinweis: Informational note — to be used for deregistration of ESV (Ersatzversorgung).
1408 // Documents usage context; no boolean logic.
1409 ConditionResult::Unknown
1410 }
1411
1412 /// [513] Hinweis: Ist SG9 QTY+Y02 (TUM Kundenwert) vorhanden, dann ist ausschließlich SG9 QTY+Y02, unabhängig von SG9 QTY+31 (Veranschlagte Jahresmenge gesamt), für die Bilanzierung und MMM-Abrechnung zu...
1413 // REVIEW: Hinweis describing precedence rule between QTY+Y02 and QTY+31. Partial implementation checks whether QTY+Y02 is present (i.e. the rule is active). Full semantic enforcement (exclusive use) cannot be expressed as a simple ConditionResult. (medium confidence)
1414 fn evaluate_513(&self, ctx: &EvaluationContext) -> ConditionResult {
1415 // Hinweis: If QTY+Y02 (TUM Kundenwert) is present, only QTY+Y02 (not QTY+31) is
1416 // to be used for billing and MMM settlement. This is a documentation note about
1417 // precedence, not a simple presence/absence condition.
1418 // Best approximation: True if QTY+Y02 is present (signalling the rule applies).
1419 ctx.has_qualifier("QTY", 0, "Y02")
1420 }
1421
1422 /// [527] Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben
1423 fn evaluate_527(&self, _ctx: &EvaluationContext) -> ConditionResult {
1424 // Hinweis: Informational note — ID of Marktlokation AND all Messlokation
1425 // identifiers must be provided. No evaluatable boolean logic.
1426 ConditionResult::Unknown
1427 }
1428
1429 /// [528] Hinweis: Es ist das Datum/ Daten aus der Anfrage zu verwenden
1430 fn evaluate_528(&self, _ctx: &EvaluationContext) -> ConditionResult {
1431 // Hinweis: Informational note — the date(s) from the original request must be used.
1432 // No evaluatable boolean logic.
1433 ConditionResult::Unknown
1434 }
1435
1436 /// [530] Hinweis: Es sind alle an dem Meldepunkt vorhandenen Daten, die mit dieser Segmentgruppe übermittelt werden und zum Datum „Änderung zum“ Gültigkeit haben, anzugeben. Dies kann zur Folge haben...
1437 fn evaluate_530(&self, _ctx: &EvaluationContext) -> ConditionResult {
1438 // Hinweis: Informational note — all data valid at 'Änderung zum' date for the
1439 // reporting point must be provided, possibly requiring repeated segment groups.
1440 // No evaluatable boolean logic.
1441 ConditionResult::Unknown
1442 }
1443
1444 /// [556] Hinweis: Wenn keine Korrespondenzanschrift des Endverbrauchers/ Kunden vorliegt, ist die Anschrift der Marktlokation zu übermitteln
1445 fn evaluate_556(&self, _ctx: &EvaluationContext) -> ConditionResult {
1446 // Hinweis: Wenn keine Korrespondenzanschrift des Endverbrauchers/Kunden vorliegt, ist die Anschrift der Marktlokation zu übermitteln — informational note, always applies
1447 ConditionResult::True
1448 }
1449
1450 /// [558] Hinweis: Diese Information kann freiwillig ausgetauscht werden
1451 fn evaluate_558(&self, _ctx: &EvaluationContext) -> ConditionResult {
1452 // Hinweis: This information can be exchanged voluntarily.
1453 // No evaluatable boolean logic — purely documentary.
1454 ConditionResult::Unknown
1455 }
1456
1457 /// [559] Hinweis: Die Korrespondenzanschrift des Endverbrauchers/Kunden wird nicht zur Identifikation genutzt
1458 fn evaluate_559(&self, _ctx: &EvaluationContext) -> ConditionResult {
1459 // Hinweis: Correspondence address of end consumer/customer is not used for identification.
1460 // No evaluatable boolean logic — purely documentary.
1461 ConditionResult::Unknown
1462 }
1463
1464 /// [560] Hinweis: Die Angabe Name und Adresse für die Ablesekarte wird nicht zur Identifikation genutzt
1465 fn evaluate_560(&self, _ctx: &EvaluationContext) -> ConditionResult {
1466 // Hinweis: Name and address for Ablesekarte (meter reading card) is not used
1467 // for identification purposes. No evaluatable boolean logic — purely documentary.
1468 ConditionResult::Unknown
1469 }
1470
1471 /// [566] Hinweis: Altlieferant
1472 fn evaluate_566(&self, _ctx: &EvaluationContext) -> ConditionResult {
1473 // Hinweis: 'Altlieferant' (previous supplier). Informational label for the
1474 // market participant role context; no evaluatable boolean logic.
1475 ConditionResult::Unknown
1476 }
1477
1478 /// [567] Hinweis: Neulieferant
1479 fn evaluate_567(&self, _ctx: &EvaluationContext) -> ConditionResult {
1480 // Hinweis: 'Neulieferant' (new supplier). Informational label for the
1481 // market participant role context; no evaluatable boolean logic.
1482 ConditionResult::Unknown
1483 }
1484
1485 /// [570] Hinweis: Netzbetreiber Alt
1486 fn evaluate_570(&self, _ctx: &EvaluationContext) -> ConditionResult {
1487 // Hinweis: Netzbetreiber Alt — informational note, always applies
1488 ConditionResult::True
1489 }
1490
1491 /// [571] Hinweis: Auslösender Marktpartner (LFA bei STS+7++ZG9, LFN bei STS+7++ZH0, NB bei STS+7++ZH1)
1492 fn evaluate_571(&self, _ctx: &EvaluationContext) -> ConditionResult {
1493 // Hinweis: Auslösender Marktpartner (LFA bei STS+7++ZG9, LFN bei STS+7++ZH0, NB bei STS+7++ZH1) — informational note, always applies
1494 ConditionResult::True
1495 }
1496
1497 /// [572] Hinweis: Kundenname aus Anmeldung Lieferant neu
1498 fn evaluate_572(&self, _ctx: &EvaluationContext) -> ConditionResult {
1499 // Hinweis: Kundenname aus Anmeldung Lieferant neu — informational note, always applies
1500 ConditionResult::True
1501 }
1502
1503 /// [581] Hinweis: Es ist das nächst mögliche Kündigungsdatum anzugeben
1504 fn evaluate_581(&self, _ctx: &EvaluationContext) -> ConditionResult {
1505 // Hinweis: Es ist das nächst mögliche Kündigungsdatum anzugeben — informational note, always applies
1506 ConditionResult::True
1507 }
1508
1509 /// [583] Hinweis: Verwendung der ID der Marktlokation
1510 fn evaluate_583(&self, _ctx: &EvaluationContext) -> ConditionResult {
1511 // Hinweis: Verwendung der ID der Marktlokation — informational note, always applies
1512 ConditionResult::True
1513 }
1514
1515 /// [584] Hinweis: Verwendung der ID der Messlokation
1516 fn evaluate_584(&self, _ctx: &EvaluationContext) -> ConditionResult {
1517 // Hinweis: Verwendung der ID der Messlokation — informational note, always applies
1518 ConditionResult::True
1519 }
1520
1521 /// [590] Hinweis: Es ist die ID der Marktlokation, welche dem LF zugeordnet sind, sowie alle Identifikatoren der Messlokationen anzugeben
1522 fn evaluate_590(&self, _ctx: &EvaluationContext) -> ConditionResult {
1523 // Hinweis: Es ist die ID der Marktlokation, welche dem LF zugeordnet sind, sowie alle Identifikatoren der Messlokationen anzugeben — informational note, always applies
1524 ConditionResult::True
1525 }
1526
1527 /// [601] Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben.
1528 fn evaluate_601(&self, _ctx: &EvaluationContext) -> ConditionResult {
1529 // Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben — informational note, always applies
1530 ConditionResult::True
1531 }
1532
1533 /// [621] Hinweis: Es ist der MSB anzugeben, welcher ab dem Zeitpunkt der Lokation zugeordnet ist, der in DTM+76 (Datum zum geplanten Leistungsbeginn) genannt ist.
1534 fn evaluate_621(&self, _ctx: &EvaluationContext) -> ConditionResult {
1535 // Hinweis: Es ist der MSB anzugeben, welcher ab dem Zeitpunkt der Lokation zugeordnet ist, der in DTM+76 (Datum zum geplanten Leistungsbeginn) genannt ist.
1536 ConditionResult::True
1537 }
1538
1539 /// [622] Hinweis: Falls die OBIS-Kennzahl für mehrere Marktrollen relevant ist, so muss die Segmentgruppe pro Marktrolle wiederholt werden
1540 fn evaluate_622(&self, _ctx: &EvaluationContext) -> ConditionResult {
1541 // Hinweis: Falls die OBIS-Kennzahl für mehrere Marktrollen relevant ist, so muss die Segmentgruppe pro Marktrolle wiederholt werden
1542 ConditionResult::True
1543 }
1544
1545 /// [636] Hinweis: Dieses RFF klassifiziert mit einem Code im DE1153 die in derselben Segmentgruppe enthaltenen DTM zu einem Markt- bzw. Messlokation relevanten Inhalt
1546 fn evaluate_636(&self, _ctx: &EvaluationContext) -> ConditionResult {
1547 // Hinweis: Dieses RFF klassifiziert mit einem Code im DE1153 die in derselben Segmentgruppe enthaltenen DTM zu einem Markt- bzw. Messlokation relevanten Inhalt
1548 ConditionResult::True
1549 }
1550
1551 /// [637] Hinweis: Bei Verpflichtungsanfrage
1552 fn evaluate_637(&self, _ctx: &EvaluationContext) -> ConditionResult {
1553 // Hinweis: Bei Verpflichtungsanfrage — informational note, always applies
1554 ConditionResult::True
1555 }
1556
1557 /// [638] Hinweis: Bei Aufforderung zur Übernahme der einzelnen Messlokation durch den gMSB
1558 fn evaluate_638(&self, _ctx: &EvaluationContext) -> ConditionResult {
1559 // Hinweis: Bei Aufforderung zur Übernahme der einzelnen Messlokation durch den gMSB — informational note, always applies
1560 ConditionResult::True
1561 }
1562
1563 /// [643] Hinweis: Nachfolgender Netzbetreiber
1564 fn evaluate_643(&self, _ctx: &EvaluationContext) -> ConditionResult {
1565 // Hinweis: Nachfolgender Netzbetreiber — informational note, always applies
1566 ConditionResult::True
1567 }
1568
1569 /// [644] Hinweis: Wenn in der zugehörigen Anmeldung (44001) in diesem Segmente "Einzug in Neuanlage" (SG4 STS+7++E02) enthalten ist, wird in diesem Geschäftsvorfall der Code E01 verwendet
1570 fn evaluate_644(&self, _ctx: &EvaluationContext) -> ConditionResult {
1571 // Hinweis: informational note about E01/E02 usage in Bestätigung — always applies
1572 ConditionResult::True
1573 }
1574
1575 /// [651] Hinweis: Bei einer Marktraumumstellung (Gas) ist zu beachten, dass die tatsächliche Meldung zur Marktraumumstellung auf Ebene der Messlokation durch Angabe der Gasqualität erfolgt. Die betroffene...
1576 fn evaluate_651(&self, _ctx: &EvaluationContext) -> ConditionResult {
1577 // Hinweis: Marktraumumstellung Gas — informational note about Messlokation reporting — always applies
1578 ConditionResult::True
1579 }
1580
1581 /// [654] Hinweis: Es sind ausschließlich die Daten zum Meldepunkt anzugeben, die für den in NAD+MR (Nachrichtenempfänger) adressierten Marktpartner relevant ist
1582 fn evaluate_654(&self, _ctx: &EvaluationContext) -> ConditionResult {
1583 // Hinweis: Only data relevant to the addressed Marktpartner (NAD+MR) should be provided — always applies
1584 ConditionResult::True
1585 }
1586
1587 /// [655] Hinweis: Wenn ein Zähler an einen Mengenumwerter angeschlossen ist werden an dem Zähler keine OBIS-Kennzahlen angegeben Hier gibt es nur OBIS Kennzahlen vom Mengenumwerter
1588 fn evaluate_655(&self, _ctx: &EvaluationContext) -> ConditionResult {
1589 // Hinweis: When a meter is connected to a volume converter, no OBIS codes are given for the meter — always applies
1590 ConditionResult::True
1591 }
1592
1593 /// [902] Format: Möglicher Wert: ≥ 0
1594 fn evaluate_902(&self, ctx: &EvaluationContext) -> ConditionResult {
1595 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, ">=", 0.0))
1596 }
1597
1598 /// [907] Format: max. 4 Nachkommastellen
1599 fn evaluate_907(&self, ctx: &EvaluationContext) -> ConditionResult {
1600 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 4))
1601 }
1602
1603 /// [912] Format: max. 6 Nachkommastellen
1604 fn evaluate_912(&self, ctx: &EvaluationContext) -> ConditionResult {
1605 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 6))
1606 }
1607
1608 /// [930] Format: max. 2 Nachkommastellen
1609 fn evaluate_930(&self, ctx: &EvaluationContext) -> ConditionResult {
1610 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 2))
1611 }
1612
1613 /// [931] Format: ZZZ = +00
1614 fn evaluate_931(&self, ctx: &EvaluationContext) -> ConditionResult {
1615 ctx.format_check("DTM", 0, 1, validate_timezone_utc)
1616 }
1617
1618 /// [934] Format: HHMM = 0400
1619 fn evaluate_934(&self, ctx: &EvaluationContext) -> ConditionResult {
1620 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0400"))
1621 }
1622
1623 /// [935] Format: HHMM = 0500
1624 fn evaluate_935(&self, ctx: &EvaluationContext) -> ConditionResult {
1625 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0500"))
1626 }
1627
1628 /// [937] Format: keine Nachkommastelle
1629 fn evaluate_937(&self, ctx: &EvaluationContext) -> ConditionResult {
1630 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 0))
1631 }
1632
1633 /// [938] Format: Möglicher Wert: <= 10
1634 fn evaluate_938(&self, ctx: &EvaluationContext) -> ConditionResult {
1635 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, "<=", 10.0))
1636 }
1637
1638 /// [950] Format: Marktlokations-ID
1639 // HAND-EDITED (#373): the condition sits on several LOC and RFF C506 1154
1640 // positions, not only on LOC+Z16; judge the value it is attached to.
1641 fn evaluate_950(&self, ctx: &EvaluationContext) -> ConditionResult {
1642 ctx.format_check_resolved(validate_malo_id)
1643 }
1644
1645 /// [951] Format: Zählpunktbezeichnung
1646 // HAND-EDITED (#373): the condition sits on several LOC and RFF C506 1154
1647 // positions, not only on LOC+Z19; judge the value it is attached to.
1648 fn evaluate_951(&self, ctx: &EvaluationContext) -> ConditionResult {
1649 ctx.format_check_resolved(validate_zahlpunkt)
1650 }
1651
1652 /// [952] Format: Gerätenummer nach DIN 43863-5
1653 // REVIEW: DIN 43863-5 Gerätenummer is an alphanumeric device identifier with a max length of 20 characters. No dedicated validator exists, so validate_max_length(20) is used as the structural check. The exact segment/element depends on the AHB table position — IDE is the most common carrier for device IDs in UTILMD Gas, with PIA as a fallback. Medium confidence due to uncertainty about the exact segment without the full AHB table context. (medium confidence)
1654 fn evaluate_952(&self, ctx: &EvaluationContext) -> ConditionResult {
1655 // Format: Gerätenummer nach DIN 43863-5 — alphanumeric, max 20 characters
1656 // DIN 43863-5 device numbers appear in IDE segment (element 1, component 0)
1657 // or in SG8 PIA segments for device identification
1658 let ide_segs = ctx.find_segments("IDE");
1659 if let Some(val) = ide_segs
1660 .first()
1661 .and_then(|s| s.elements.get(1))
1662 .and_then(|e| e.first())
1663 .filter(|v| !v.is_empty())
1664 {
1665 return validate_max_length(val, 20);
1666 }
1667 // Fallback: check PIA segment for device number (qualifier 5 = substitute product)
1668 let pia_segs = ctx.find_segments_with_qualifier("PIA", 0, "5");
1669 match pia_segs
1670 .first()
1671 .and_then(|s| s.elements.get(1))
1672 .and_then(|e| e.first())
1673 {
1674 Some(val) => validate_max_length(val, 20),
1675 None => ConditionResult::False, // segment absent → condition not applicable
1676 }
1677 }
1678
1679 /// [953] Format: Marktlokations-ID oder Zählpunktbezeichnung
1680 fn evaluate_953(&self, ctx: &EvaluationContext) -> ConditionResult {
1681 ctx.format_check("LOC", 1, 0, validate_malo_or_zahlpunkt)
1682 }
1683
1684 /// [2061] Segment bzw. Segmentgruppe ist genau einmal je SG4 IDE (Vorgang) anzugeben
1685 // REVIEW: Condition states the segment/group is to be given exactly once per SG4 IDE (Vorgang). As a boolean applicability condition, this is True when the IDE segment (Vorgangsidentifikator) is present, indicating the SG4 context exists. Cardinality enforcement (exactly once) is a structural rule beyond a simple boolean evaluator. (medium confidence)
1686 fn evaluate_2061(&self, ctx: &EvaluationContext) -> ConditionResult {
1687 ConditionResult::from(ctx.has_segment("IDE"))
1688 }
1689
1690 /// [2119] Je SG8 SEQ+Z13 (Smartmeter-Gateway) ist genau einmal die Segmentgruppe anzugeben
1691 fn evaluate_2119(&self, ctx: &EvaluationContext) -> ConditionResult {
1692 ctx.any_group_has_qualifier("SEQ", 0, "Z13", &["SG4", "SG8"])
1693 }
1694
1695 /// [2284] Für jede Messlokations-ID im SG5 LOC+172 (Meldepunkt) DE3225 genau einmal anzugeben
1696 fn evaluate_2284(&self, ctx: &EvaluationContext) -> ConditionResult {
1697 ctx.any_group_has_qualifier("LOC", 0, "172", &["SG4", "SG5"])
1698 }
1699
1700 /// [2286] Für jede SEQ+Z18 (Daten der Messlokation) mindestens einmal anzugeben
1701 fn evaluate_2286(&self, ctx: &EvaluationContext) -> ConditionResult {
1702 ctx.any_group_has_qualifier("SEQ", 0, "Z18", &["SG4", "SG8"])
1703 }
1704
1705 /// [2287] Für jede SEQ+Z03 (Zähleinrichtungsdaten) mindestens einmal anzugeben
1706 fn evaluate_2287(&self, ctx: &EvaluationContext) -> ConditionResult {
1707 ctx.any_group_has_qualifier("SEQ", 0, "Z03", &["SG4", "SG8"])
1708 }
1709
1710 /// [2335] Für jede SEQ+Z02 (OBIS-Daten der Marktlokation), welche im PIA+5 die OBIS-Kennzahl 7-20:99.33.17/ 7-0:33.86.0 übermittelt, genau einmal anzugeben
1711 // REVIEW: Condition states: to be given exactly once for each SEQ+Z02 (OBIS-Daten der Marktlokation) where PIA+5 transmits OBIS code 7-20:99.33.17 or 7-0:33.86.0. Per segment structure reference, PIA elements[1][0] (DE7140) holds the OBIS code. Checks message-wide PIA+5 for the target OBIS values, then verifies SEQ+Z02 is present. Since PIA is always nested in the same SG8 as its SEQ, message-wide PIA check is a valid approximation when group navigator is unavailable. (medium confidence)
1712 fn evaluate_2335(&self, ctx: &EvaluationContext) -> ConditionResult {
1713 {
1714 // Check for PIA+5 with specific OBIS codes 7-20:99.33.17 or 7-0:33.86.0 at elements[1][0]
1715 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1716 let has_target_obis = pias.iter().any(|pia| {
1717 pia.elements
1718 .get(1)
1719 .and_then(|e| e.first())
1720 .map(|v| v == "7-20:99.33.17" || v == "7-0:33.86.0")
1721 .unwrap_or(false)
1722 });
1723 if !has_target_obis {
1724 return ConditionResult::False;
1725 }
1726 // Also verify SEQ+Z02 (OBIS-Daten der Marktlokation) is present — PIA is always co-located in the same SG8
1727 ctx.any_group_has_qualifier("SEQ", 0, "Z02", &["SG4", "SG8"])
1728 }
1729 }
1730
1731 /// [2353] Für jede SEQ+Z09 (Mengenumwerter-Daten) mindestens einmal anzugeben
1732 fn evaluate_2353(&self, ctx: &EvaluationContext) -> ConditionResult {
1733 ctx.any_group_has_qualifier("SEQ", 0, "Z09", &["SG4", "SG8"])
1734 }
1735}