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 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["E14"])
717 }
718
719 /// [51] Bei rückwirkendem Lieferende/Lieferbeginn
720 /// EXTERNAL: Requires context from outside the message.
721 fn evaluate_51(&self, ctx: &EvaluationContext) -> ConditionResult {
722 ctx.external.evaluate("retroactive_delivery_change")
723 }
724
725 /// [58] Wenn in diesem CCI das DE3055 mit dem Code 293 vorhanden
726 // 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)
727 fn evaluate_58(&self, ctx: &EvaluationContext) -> ConditionResult {
728 let ccis = ctx.find_segments("CCI");
729 ConditionResult::from(ccis.iter().any(|s| {
730 s.elements
731 .get(2)
732 .and_then(|e| e.get(2))
733 .is_some_and(|v| v == "293")
734 }))
735 }
736
737 /// [64] Wenn SG4 DTM+158 (Bilanzierungsbeginn) vorhanden
738 fn evaluate_64(&self, ctx: &EvaluationContext) -> ConditionResult {
739 ctx.has_qualifier("DTM", 0, "158")
740 }
741
742 /// [65] Wenn Marktgebietsüber-lappung besteht, sind alle Bilanzkreise des LF zu melden in denen freie Kapazitäten beim NB bestehen
743 /// EXTERNAL: Requires context from outside the message.
744 fn evaluate_65(&self, ctx: &EvaluationContext) -> ConditionResult {
745 ctx.external.evaluate("market_area_overlap_exists")
746 }
747
748 /// [66] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als einmal vorhanden
749 fn evaluate_66(&self, ctx: &EvaluationContext) -> ConditionResult {
750 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
751 ConditionResult::from(count > 1)
752 }
753
754 /// [68] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als zweimal vorhanden
755 fn evaluate_68(&self, ctx: &EvaluationContext) -> ConditionResult {
756 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
757 ConditionResult::from(count > 2)
758 }
759
760 /// [69] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als dreimal vorhanden
761 fn evaluate_69(&self, ctx: &EvaluationContext) -> ConditionResult {
762 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
763 ConditionResult::from(count > 3)
764 }
765
766 /// [70] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang fünfmal vorhanden
767 fn evaluate_70(&self, ctx: &EvaluationContext) -> ConditionResult {
768 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
769 ConditionResult::from(count == 5)
770 }
771
772 /// [77] Wenn SG8 SEQ+Z03 (Zähleinrichtungsdaten) CAV+Z30 (Identifikation/Nummer des Gerätes) nicht vorhanden
773 fn evaluate_77(&self, ctx: &EvaluationContext) -> ConditionResult {
774 ctx.any_group_has_qualifier_without("SEQ", 0, "Z03", "CAV", 0, "Z30", &["SG4", "SG8"])
775 }
776
777 /// [78] Wenn SG4 STS+7++E02 (Transaktionsgrund: Einzug in Neuanlage) nicht vorhanden
778 fn evaluate_78(&self, ctx: &EvaluationContext) -> ConditionResult {
779 let result = ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]);
780 match result {
781 ConditionResult::True => ConditionResult::False,
782 ConditionResult::False => ConditionResult::True,
783 ConditionResult::Unknown => ConditionResult::Unknown,
784 }
785 }
786
787 /// [81] Wenn SG4 FTX+ABO+Z05 (Beschreibung der Abweichung zur übermittelten Liste: Änderung vorhanden) vorhanden
788 fn evaluate_81(&self, ctx: &EvaluationContext) -> ConditionResult {
789 ctx.has_qualified_value("FTX", 0, "ABO", 2, 0, &["Z05"])
790 }
791
792 /// [84] Wenn SG4 STS+E01++Z35 (Status der Antwort: Ablehnung der Abmeldeanfrage) vorhanden
793 fn evaluate_84(&self, ctx: &EvaluationContext) -> ConditionResult {
794 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z35"])
795 }
796
797 /// [92] Wenn Wert innerhalb SG bzw. Segment geändert wird
798 /// EXTERNAL: Requires context from outside the message.
799 // 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)
800 fn evaluate_92(&self, ctx: &EvaluationContext) -> ConditionResult {
801 ctx.external.evaluate("value_changed_in_segment")
802 }
803
804 /// [98] Wenn MP-ID in SG2 NAD+MS (Nachrichtenabsender) in der Rolle NB
805 /// EXTERNAL: Requires context from outside the message.
806 // 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)
807 fn evaluate_98(&self, ctx: &EvaluationContext) -> ConditionResult {
808 ctx.external.evaluate("sender_is_nb")
809 }
810
811 /// [106] Wenn in dieser SG8 SEQ+Z01 SG10 CCI+++ZA6 (Prognosegrundlage der Marktlokation: Prognose auf Basis von Profilen) vorhanden
812 fn evaluate_106(&self, ctx: &EvaluationContext) -> ConditionResult {
813 ctx.filtered_parent_child_has_qualifier(
814 &["SG4", "SG8"],
815 "SEQ",
816 0,
817 "Z01",
818 "SG10",
819 "CCI",
820 2,
821 "ZA6",
822 )
823 }
824
825 /// [108] Wenn Kundenwertverfahren (z. B. TU München)
826 /// EXTERNAL: Requires context from outside the message.
827 // 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)
828 fn evaluate_108(&self, ctx: &EvaluationContext) -> ConditionResult {
829 ctx.external.evaluate("kundenwertverfahren")
830 }
831
832 /// [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...
833 // 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)
834 fn evaluate_123(&self, ctx: &EvaluationContext) -> ConditionResult {
835 let nav = match ctx.navigator() {
836 Some(n) => n,
837 None => {
838 let seqs = ctx.find_segments_with_qualifier("SEQ", 0, "Z20");
839 if seqs.len() < 2 {
840 return ConditionResult::False;
841 }
842 return ConditionResult::Unknown;
843 }
844 };
845 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
846 let mut device_ids: Vec<String> = Vec::new();
847 for i in 0..sg8_count {
848 let seqs = nav.find_segments_in_group("SEQ", &["SG4", "SG8"], i);
849 let has_z20 = seqs.iter().any(|s| {
850 s.elements
851 .first()
852 .and_then(|e| e.first())
853 .is_some_and(|v| v == "Z20")
854 });
855 if !has_z20 {
856 continue;
857 }
858 let rffs = nav.find_segments_in_group("RFF", &["SG4", "SG8"], i);
859 for rff in &rffs {
860 let qual = rff
861 .elements
862 .first()
863 .and_then(|e| e.first())
864 .map(|s| s.as_str());
865 if matches!(qual, Some("MG") | Some("Z11")) {
866 if let Some(id) = rff.elements.first().and_then(|e| e.get(1)) {
867 if !id.is_empty() {
868 device_ids.push(id.clone());
869 }
870 }
871 }
872 }
873 }
874 for i in 0..device_ids.len() {
875 for j in (i + 1)..device_ids.len() {
876 if device_ids[i] == device_ids[j] {
877 return ConditionResult::True;
878 }
879 }
880 }
881 ConditionResult::False
882 }
883
884 /// [127] Hat der Lieferant auf Grund seines Vertrags Kenntnis, dass der Kunde keine hohe KA hat so muss er dies dem NB mitteilen
885 /// EXTERNAL: Requires context from outside the message.
886 // 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)
887 fn evaluate_127(&self, ctx: &EvaluationContext) -> ConditionResult {
888 ctx.external.evaluate("supplier_knows_no_high_ka")
889 }
890
891 /// [128] Wenn SG10 CAV+TAS/ TKS/ SAS/ KAS vorhanden
892 fn evaluate_128(&self, ctx: &EvaluationContext) -> ConditionResult {
893 ctx.any_group_has_any_qualifier(
894 "CAV",
895 0,
896 &["TAS", "TKS", "SAS", "KAS"],
897 &["SG4", "SG8", "SG10"],
898 )
899 }
900
901 /// [129] Hat der Lieferant auf Grund seines Vertrags Kenntnis über die Höhe der Sonder-KA, so muss er diesen dem NB mitteilen
902 /// EXTERNAL: Requires context from outside the message.
903 // 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)
904 fn evaluate_129(&self, ctx: &EvaluationContext) -> ConditionResult {
905 ctx.external.evaluate("supplier_knows_special_ka_amount")
906 }
907
908 /// [130] Wenn an Messlokation vorhanden
909 // 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)
910 fn evaluate_130(&self, ctx: &EvaluationContext) -> ConditionResult {
911 ctx.has_qualifier("SEQ", 0, "Z18")
912 }
913
914 /// [133] Wenn an der übermittelten Marktlokation / Messlokation vorhanden
915 /// EXTERNAL: Requires context from outside the message.
916 // 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)
917 fn evaluate_133(&self, ctx: &EvaluationContext) -> ConditionResult {
918 ctx.external.evaluate("at_marktlokation_or_messlokation")
919 }
920
921 /// [137] Nicht bei Neuanlage
922 // 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)
923 fn evaluate_137(&self, ctx: &EvaluationContext) -> ConditionResult {
924 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]) {
925 ConditionResult::True => ConditionResult::False,
926 ConditionResult::False => ConditionResult::True,
927 ConditionResult::Unknown => ConditionResult::Unknown,
928 }
929 }
930
931 /// [138] Wenn SG5 LOC+172 (Meldepunkt) nicht vorhanden
932 fn evaluate_138(&self, ctx: &EvaluationContext) -> ConditionResult {
933 ctx.lacks_qualifier("LOC", 0, "172")
934 }
935
936 /// [147] Wenn in Anfrage vorhanden
937 /// EXTERNAL: Requires context from outside the message.
938 // 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)
939 fn evaluate_147(&self, ctx: &EvaluationContext) -> ConditionResult {
940 ctx.external.evaluate("present_in_request")
941 }
942
943 /// [165] Wenn bekannt
944 /// EXTERNAL: Requires context from outside the message.
945 fn evaluate_165(&self, ctx: &EvaluationContext) -> ConditionResult {
946 ctx.external.evaluate("date_known")
947 }
948
949 /// [166] Wenn vorhanden
950 /// EXTERNAL: Requires context from outside the message.
951 // 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)
952 fn evaluate_166(&self, ctx: &EvaluationContext) -> ConditionResult {
953 ctx.external.evaluate("data_available")
954 }
955
956 /// [200] Wenn BGM+Z26 (Vorläufige Meldung zur Marktraumumstellung) vorhanden
957 fn evaluate_200(&self, ctx: &EvaluationContext) -> ConditionResult {
958 ctx.has_qualifier("BGM", 0, "Z26")
959 }
960
961 /// [202] Wenn SG4 STS+E01+ZG2 (Status der Antwort: Gültiges Ergebnis nach der Datenprüfung) vorhanden
962 fn evaluate_202(&self, ctx: &EvaluationContext) -> ConditionResult {
963 ctx.has_qualified_value("STS", 0, "E01", 1, 0, &["ZG2"])
964 }
965
966 /// [205] Wenn SG9 QTY+Y02 (TUM Kundenwert) nicht vorhanden
967 fn evaluate_205(&self, ctx: &EvaluationContext) -> ConditionResult {
968 ctx.lacks_qualifier("QTY", 0, "Y02")
969 }
970
971 /// [209] Wenn im selben Segment im DE2379 der Code 303 vorhanden ist
972 fn evaluate_209(&self, ctx: &EvaluationContext) -> ConditionResult {
973 ConditionResult::from(ctx.self_segment_value_equals("DTM", 0, 2, "303"))
974 }
975
976 /// [212] Wenn im selben SG12 NAD DE3124 nicht vorhanden
977 // 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)
978 fn evaluate_212(&self, ctx: &EvaluationContext) -> ConditionResult {
979 let nads = ctx.find_segments("NAD");
980 ConditionResult::from(nads.iter().any(|s| {
981 s.elements
982 .get(2)
983 .map(|e| e.first().map(|v| v.is_empty()).unwrap_or(true))
984 .unwrap_or(true)
985 }))
986 }
987
988 /// [213] Wenn SG12 NAD+Z09 (Kunde des Lieferanten) vorhanden
989 fn evaluate_213(&self, ctx: &EvaluationContext) -> ConditionResult {
990 ctx.has_qualifier("NAD", 0, "Z09")
991 }
992
993 /// [216] Wenn CCI+++Z88 (Netznutzung) CAV+Z74:::Z08 (Netznutzungsvertrag: Direkter Vertrag zwischen Kunden und NB) vorhanden
994 // 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)
995 fn evaluate_216(&self, ctx: &EvaluationContext) -> ConditionResult {
996 let nav = match ctx.navigator() {
997 Some(n) => n,
998 None => {
999 let cavs = ctx.find_segments("CAV");
1000 return ConditionResult::from(cavs.iter().any(|s| {
1001 let e0 = s.elements.first();
1002 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1003 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1004 }));
1005 }
1006 };
1007 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
1008 for i in 0..sg8_count {
1009 let sg10_count = nav.child_group_instance_count(&["SG4", "SG8"], i, "SG10");
1010 for j in 0..sg10_count {
1011 let ccis = nav.find_segments_in_child_group("CCI", &["SG4", "SG8"], i, "SG10", j);
1012 let has_cci_z88 = ccis.iter().any(|s| {
1013 s.elements
1014 .get(2)
1015 .and_then(|e| e.first())
1016 .is_some_and(|v| v == "Z88")
1017 });
1018 if has_cci_z88 {
1019 let cavs =
1020 nav.find_segments_in_child_group("CAV", &["SG4", "SG8"], i, "SG10", j);
1021 if cavs.iter().any(|s| {
1022 let e0 = s.elements.first();
1023 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1024 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1025 }) {
1026 return ConditionResult::True;
1027 }
1028 }
1029 }
1030 }
1031 ConditionResult::False
1032 }
1033
1034 /// [219] Wenn an Marktlokation vorhanden
1035 /// EXTERNAL: Requires context from outside the message.
1036 // 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)
1037 fn evaluate_219(&self, ctx: &EvaluationContext) -> ConditionResult {
1038 ctx.external.evaluate("at_marktlokation")
1039 }
1040
1041 /// [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
1042 // 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)
1043 fn evaluate_230(&self, ctx: &EvaluationContext) -> ConditionResult {
1044 {
1045 // DTM+Z21 (Termin der Netznutzungsabrechnung): elements[0][1], format 106/104
1046 let z21_val = ctx
1047 .find_segments_with_qualifier("DTM", 0, "Z21")
1048 .into_iter()
1049 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1050 .unwrap_or_default();
1051 // DTM+Z09 (Nächste Netznutzungsabrechnung): elements[0][1], format 602
1052 let z09_val = ctx
1053 .find_segments_with_qualifier("DTM", 0, "Z09")
1054 .into_iter()
1055 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1056 .unwrap_or_default();
1057 // DTM+92 (Beginn zum): elements[0][1], format 303 (CCYYMMDDHHMM)
1058 let dtm92_val = match ctx
1059 .find_segments_with_qualifier("DTM", 0, "92")
1060 .into_iter()
1061 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1062 {
1063 Some(v) if !v.is_empty() => v,
1064 _ => return ConditionResult::Unknown,
1065 };
1066 // Use the later of Z21 and Z09 as the end date of the Turnuszeitraum
1067 // Note: formats differ (Z21=106/104, Z09=602, DTM+92=303) — use first 6 chars (CCYYMM) for comparison
1068 let end_date = match (z21_val.is_empty(), z09_val.is_empty()) {
1069 (false, false) => {
1070 if z21_val >= z09_val {
1071 z21_val
1072 } else {
1073 z09_val
1074 }
1075 }
1076 (false, true) => z21_val,
1077 (true, false) => z09_val,
1078 (true, true) => return ConditionResult::Unknown,
1079 };
1080 // Compare first 6 chars (CCYYMM) — both reference dates have at least CCYYMM
1081 let end_ym = &end_date[..end_date.len().min(6)];
1082 let begin_ym = &dtm92_val[..dtm92_val.len().min(6)];
1083 if end_ym.len() < 6 || begin_ym.len() < 6 {
1084 return ConditionResult::Unknown;
1085 }
1086 ConditionResult::from(end_ym >= begin_ym)
1087 }
1088 }
1089
1090 /// [241] Wenn MP-ID in SG2 NAD+MR (Nachrichtenempfänger) in der Rolle MSB
1091 /// EXTERNAL: Requires context from outside the message.
1092 fn evaluate_241(&self, ctx: &EvaluationContext) -> ConditionResult {
1093 ctx.external.evaluate("recipient_is_msb")
1094 }
1095
1096 /// [249] Innerhalb eines SG4 IDE müssen alle DE1131 der SG4 STS+E01 den identischen Wert enthalten
1097 // 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)
1098 fn evaluate_249(&self, ctx: &EvaluationContext) -> ConditionResult {
1099 let sts_segs = ctx.find_segments("STS");
1100 let sts_e01: Vec<_> = sts_segs
1101 .iter()
1102 .filter(|s| {
1103 s.elements
1104 .first()
1105 .and_then(|e| e.first())
1106 .is_some_and(|v| v == "E01")
1107 })
1108 .collect();
1109 if sts_e01.is_empty() {
1110 return ConditionResult::Unknown;
1111 }
1112 let first_val = sts_e01
1113 .first()
1114 .and_then(|s| s.elements.get(2))
1115 .and_then(|e| e.get(1))
1116 .map(|v| v.as_str())
1117 .unwrap_or("");
1118 ConditionResult::from(sts_e01.iter().all(|s| {
1119 s.elements
1120 .get(2)
1121 .and_then(|e| e.get(1))
1122 .map(|v| v.as_str())
1123 .unwrap_or("")
1124 == first_val
1125 }))
1126 }
1127
1128 /// [252] Wenn DE0068 vorhanden
1129 // 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)
1130 fn evaluate_252(&self, ctx: &EvaluationContext) -> ConditionResult {
1131 let unh_segs = ctx.find_segments("UNH");
1132 ConditionResult::from(unh_segs.iter().any(|s| {
1133 s.elements
1134 .get(2)
1135 .and_then(|e| e.first())
1136 .is_some_and(|v| !v.is_empty())
1137 }))
1138 }
1139
1140 /// [257] Wenn in derselben SG8 SEQ+Z02 (OBIS-Daten der Marktlokation) das PIA+5+7-0?:33.86.0 vorhanden
1141 fn evaluate_257(&self, ctx: &EvaluationContext) -> ConditionResult {
1142 ctx.any_group_has_co_occurrence(
1143 "SEQ",
1144 0,
1145 &["Z02"],
1146 "PIA",
1147 1,
1148 0,
1149 &["7-0:33.86.0"],
1150 &["SG4", "SG8"],
1151 )
1152 }
1153
1154 /// [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
1155 /// EXTERNAL: Requires context from outside the message.
1156 fn evaluate_268(&self, ctx: &EvaluationContext) -> ConditionResult {
1157 ctx.external.evaluate("country_has_postal_code_requirement")
1158 }
1159
1160 /// [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 / ...
1161 // 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)
1162 fn evaluate_274(&self, ctx: &EvaluationContext) -> ConditionResult {
1163 let obis_suffixes = [
1164 ":3.0.0", ":6.0.0", ":3.1.0", ":6.1.0", ":3.2.0", ":6.2.0", ":13.2.0", ":16.2.0",
1165 ":1.0.0", ":2.0.0", ":4.0.0", ":5.0.0", ":11.2.0", ":12.2.0", ":14.2.0", ":15.2.0",
1166 ];
1167 let has_seq_pia_co = ctx.any_group_has_co_occurrence(
1168 "SEQ",
1169 0,
1170 &["Z20"],
1171 "PIA",
1172 0,
1173 0,
1174 &["5"],
1175 &["SG4", "SG8"],
1176 );
1177 if !matches!(has_seq_pia_co, ConditionResult::True) {
1178 return has_seq_pia_co;
1179 }
1180 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1181 ConditionResult::from(pias.iter().any(|s| {
1182 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
1183 v.starts_with("7-") && obis_suffixes.iter().any(|suf| v.ends_with(suf))
1184 })
1185 }))
1186 }
1187
1188 /// [276] Wenn SG4 DTM+92 (Beginn zum) vorhanden
1189 fn evaluate_276(&self, ctx: &EvaluationContext) -> ConditionResult {
1190 ctx.has_qualifier("DTM", 0, "92")
1191 }
1192
1193 /// [277] Wenn Zuordnung vorhanden
1194 // 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)
1195 fn evaluate_277(&self, ctx: &EvaluationContext) -> ConditionResult {
1196 ctx.has_qualifier("STS", 0, "Z18")
1197 }
1198
1199 /// [283] Wenn Empfänger der Nachricht der zum Nachrichtendatum aktuell zugeordnete Lieferant ist
1200 /// EXTERNAL: Requires context from outside the message.
1201 fn evaluate_283(&self, ctx: &EvaluationContext) -> ConditionResult {
1202 ctx.external.evaluate("recipient_is_current_supplier")
1203 }
1204
1205 /// [336] Wenn in Änderungsmeldung gefüllt
1206 /// EXTERNAL: Requires context from outside the message.
1207 // 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)
1208 fn evaluate_336(&self, ctx: &EvaluationContext) -> ConditionResult {
1209 ctx.external.evaluate("field_filled_in_amendment_message")
1210 }
1211
1212 /// [345] Wenn 33-stelliger Meldepunkt im SG5 LOC+172 (Meldepunkt) vorhanden
1213 fn evaluate_345(&self, ctx: &EvaluationContext) -> ConditionResult {
1214 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
1215 ConditionResult::from(locs.iter().any(|s| {
1216 s.elements
1217 .get(1)
1218 .and_then(|e| e.first())
1219 .map(|id| id.len() == 33)
1220 .unwrap_or(false)
1221 }))
1222 }
1223
1224 /// [361] Wenn STS+E01++A03/ A04 nicht vorhanden
1225 fn evaluate_361(&self, ctx: &EvaluationContext) -> ConditionResult {
1226 let found = ctx
1227 .find_segments_with_qualifier("STS", 0, "E01")
1228 .iter()
1229 .any(|s| {
1230 s.elements
1231 .get(2)
1232 .and_then(|e| e.first())
1233 .map(|v| v == "A03" || v == "A04")
1234 .unwrap_or(false)
1235 });
1236 ConditionResult::from(!found)
1237 }
1238
1239 /// [362] Wenn STS+E01++A03/ A17 nicht vorhanden
1240 fn evaluate_362(&self, ctx: &EvaluationContext) -> ConditionResult {
1241 let found = ctx
1242 .find_segments_with_qualifier("STS", 0, "E01")
1243 .iter()
1244 .any(|s| {
1245 s.elements
1246 .get(2)
1247 .and_then(|e| e.first())
1248 .map(|v| v == "A03" || v == "A17")
1249 .unwrap_or(false)
1250 });
1251 ConditionResult::from(!found)
1252 }
1253
1254 /// [367] Wenn SG4 STS+E01++A04 vorhanden
1255 fn evaluate_367(&self, ctx: &EvaluationContext) -> ConditionResult {
1256 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["A04"])
1257 }
1258
1259 /// [368] Es sind alle Codes aus der Codeliste G_0009 erlaubt
1260 fn evaluate_368(&self, _ctx: &EvaluationContext) -> ConditionResult {
1261 ConditionResult::True
1262 }
1263
1264 /// [427] Messprodukt-Code aus Kapitel 3 "Codeliste der Standard-Messprodukte Gas" der Codeliste der Konfigurationen
1265 /// EXTERNAL: Requires context from outside the message.
1266 fn evaluate_427(&self, ctx: &EvaluationContext) -> ConditionResult {
1267 ctx.external.evaluate("messprodukt_code_gas_valid")
1268 }
1269
1270 /// [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
1271 // REVIEW: Condition is True when NO SG8 with SEQ+Z09 (Mengenumwerterdaten) has a co-occurring RFF+MG. Implemented by negating any_group_has_co_occurrence. Medium confidence because the 'same device number as meter' cross-reference aspect cannot be fully validated without knowing which meter device number to compare against. (medium confidence)
1272 fn evaluate_442(&self, ctx: &EvaluationContext) -> ConditionResult {
1273 let result = ctx.any_group_has_co_occurrence(
1274 "SEQ",
1275 0,
1276 &["Z09"],
1277 "RFF",
1278 0,
1279 0,
1280 &["MG"],
1281 &["SG4", "SG8"],
1282 );
1283 match result {
1284 ConditionResult::True => ConditionResult::False,
1285 ConditionResult::False => ConditionResult::True,
1286 ConditionResult::Unknown => ConditionResult::Unknown,
1287 }
1288 }
1289
1290 /// [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
1291 fn evaluate_490(&self, ctx: &EvaluationContext) -> ConditionResult {
1292 match ctx.resolved_value {
1293 Some(val) => is_mesz_utc(val),
1294 None => ConditionResult::False,
1295 }
1296 }
1297
1298 /// [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
1299 fn evaluate_491(&self, ctx: &EvaluationContext) -> ConditionResult {
1300 match ctx.resolved_value {
1301 Some(val) => is_mez_utc(val),
1302 None => ConditionResult::False,
1303 }
1304 }
1305
1306 /// [494] Das hier genannte Datum muss der Zeitpunkt sein, zu dem das Dokument erstellt wurde, oder ein Zeitpunkt, der davor liegt
1307 fn evaluate_494(&self, _ctx: &EvaluationContext) -> ConditionResult {
1308 // Hinweis: Das genannte Datum muss dem Dokumenterstellungszeitpunkt oder einem früheren Zeitpunkt entsprechen — informational annotation
1309 ConditionResult::True
1310 }
1311
1312 /// [500] Hinweis: Code ist gemäß der Kategorie der zu stornierenden Meldung zu wählen
1313 fn evaluate_500(&self, _ctx: &EvaluationContext) -> ConditionResult {
1314 // Hinweis: Code ist gemäß der Kategorie der zu stornierenden Meldung zu wählen — informational note, always applies
1315 ConditionResult::True
1316 }
1317
1318 /// [501] Hinweis: Die Angabe wird aus dem DTM+157 (Änderung zum) der Zuordnungsliste übernommen
1319 fn evaluate_501(&self, _ctx: &EvaluationContext) -> ConditionResult {
1320 // Hinweis: Die Angabe wird aus dem DTM+157 (Änderung zum) der Zuordnungsliste übernommen — informational note, always applies
1321 ConditionResult::True
1322 }
1323
1324 /// [507] Hinweis: Ursprünglich vom NB bestätigtes Beginndatum
1325 fn evaluate_507(&self, _ctx: &EvaluationContext) -> ConditionResult {
1326 // Hinweis: Informational note — 'ursprünglich vom NB bestätigtes Beginndatum'.
1327 // Documents the semantic meaning of the date field; no boolean logic.
1328 ConditionResult::Unknown
1329 }
1330
1331 /// [508] Hinweis: Beginndatum beim neuen NB
1332 fn evaluate_508(&self, _ctx: &EvaluationContext) -> ConditionResult {
1333 // Hinweis: Informational note — 'Beginndatum beim neuen NB'.
1334 // Documents the semantic meaning of the date field; no boolean logic.
1335 ConditionResult::Unknown
1336 }
1337
1338 /// [510] Hinweis: Zu verwenden bei der Abmeldung der ESV
1339 fn evaluate_510(&self, _ctx: &EvaluationContext) -> ConditionResult {
1340 // Hinweis: Informational note — to be used for deregistration of ESV (Ersatzversorgung).
1341 // Documents usage context; no boolean logic.
1342 ConditionResult::Unknown
1343 }
1344
1345 /// [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...
1346 // 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)
1347 fn evaluate_513(&self, ctx: &EvaluationContext) -> ConditionResult {
1348 // Hinweis: If QTY+Y02 (TUM Kundenwert) is present, only QTY+Y02 (not QTY+31) is
1349 // to be used for billing and MMM settlement. This is a documentation note about
1350 // precedence, not a simple presence/absence condition.
1351 // Best approximation: True if QTY+Y02 is present (signalling the rule applies).
1352 ctx.has_qualifier("QTY", 0, "Y02")
1353 }
1354
1355 /// [527] Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben
1356 fn evaluate_527(&self, _ctx: &EvaluationContext) -> ConditionResult {
1357 // Hinweis: Informational note — ID of Marktlokation AND all Messlokation
1358 // identifiers must be provided. No evaluatable boolean logic.
1359 ConditionResult::Unknown
1360 }
1361
1362 /// [528] Hinweis: Es ist das Datum/ Daten aus der Anfrage zu verwenden
1363 fn evaluate_528(&self, _ctx: &EvaluationContext) -> ConditionResult {
1364 // Hinweis: Informational note — the date(s) from the original request must be used.
1365 // No evaluatable boolean logic.
1366 ConditionResult::Unknown
1367 }
1368
1369 /// [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...
1370 fn evaluate_530(&self, _ctx: &EvaluationContext) -> ConditionResult {
1371 // Hinweis: Informational note — all data valid at 'Änderung zum' date for the
1372 // reporting point must be provided, possibly requiring repeated segment groups.
1373 // No evaluatable boolean logic.
1374 ConditionResult::Unknown
1375 }
1376
1377 /// [556] Hinweis: Wenn keine Korrespondenzanschrift des Endverbrauchers/ Kunden vorliegt, ist die Anschrift der Marktlokation zu übermitteln
1378 fn evaluate_556(&self, _ctx: &EvaluationContext) -> ConditionResult {
1379 // Hinweis: Wenn keine Korrespondenzanschrift des Endverbrauchers/Kunden vorliegt, ist die Anschrift der Marktlokation zu übermitteln — informational note, always applies
1380 ConditionResult::True
1381 }
1382
1383 /// [558] Hinweis: Diese Information kann freiwillig ausgetauscht werden
1384 fn evaluate_558(&self, _ctx: &EvaluationContext) -> ConditionResult {
1385 // Hinweis: This information can be exchanged voluntarily.
1386 // No evaluatable boolean logic — purely documentary.
1387 ConditionResult::Unknown
1388 }
1389
1390 /// [559] Hinweis: Die Korrespondenzanschrift des Endverbrauchers/Kunden wird nicht zur Identifikation genutzt
1391 fn evaluate_559(&self, _ctx: &EvaluationContext) -> ConditionResult {
1392 // Hinweis: Correspondence address of end consumer/customer is not used for identification.
1393 // No evaluatable boolean logic — purely documentary.
1394 ConditionResult::Unknown
1395 }
1396
1397 /// [560] Hinweis: Die Angabe Name und Adresse für die Ablesekarte wird nicht zur Identifikation genutzt
1398 fn evaluate_560(&self, _ctx: &EvaluationContext) -> ConditionResult {
1399 // Hinweis: Name and address for Ablesekarte (meter reading card) is not used
1400 // for identification purposes. No evaluatable boolean logic — purely documentary.
1401 ConditionResult::Unknown
1402 }
1403
1404 /// [566] Hinweis: Altlieferant
1405 fn evaluate_566(&self, _ctx: &EvaluationContext) -> ConditionResult {
1406 // Hinweis: 'Altlieferant' (previous supplier). Informational label for the
1407 // market participant role context; no evaluatable boolean logic.
1408 ConditionResult::Unknown
1409 }
1410
1411 /// [567] Hinweis: Neulieferant
1412 fn evaluate_567(&self, _ctx: &EvaluationContext) -> ConditionResult {
1413 // Hinweis: 'Neulieferant' (new supplier). Informational label for the
1414 // market participant role context; no evaluatable boolean logic.
1415 ConditionResult::Unknown
1416 }
1417
1418 /// [570] Hinweis: Netzbetreiber Alt
1419 fn evaluate_570(&self, _ctx: &EvaluationContext) -> ConditionResult {
1420 // Hinweis: Netzbetreiber Alt — informational note, always applies
1421 ConditionResult::True
1422 }
1423
1424 /// [571] Hinweis: Auslösender Marktpartner (LFA bei STS+7++ZG9, LFN bei STS+7++ZH0, NB bei STS+7++ZH1)
1425 fn evaluate_571(&self, _ctx: &EvaluationContext) -> ConditionResult {
1426 // Hinweis: Auslösender Marktpartner (LFA bei STS+7++ZG9, LFN bei STS+7++ZH0, NB bei STS+7++ZH1) — informational note, always applies
1427 ConditionResult::True
1428 }
1429
1430 /// [572] Hinweis: Kundenname aus Anmeldung Lieferant neu
1431 fn evaluate_572(&self, _ctx: &EvaluationContext) -> ConditionResult {
1432 // Hinweis: Kundenname aus Anmeldung Lieferant neu — informational note, always applies
1433 ConditionResult::True
1434 }
1435
1436 /// [581] Hinweis: Es ist das nächst mögliche Kündigungsdatum anzugeben
1437 fn evaluate_581(&self, _ctx: &EvaluationContext) -> ConditionResult {
1438 // Hinweis: Es ist das nächst mögliche Kündigungsdatum anzugeben — informational note, always applies
1439 ConditionResult::True
1440 }
1441
1442 /// [583] Hinweis: Verwendung der ID der Marktlokation
1443 fn evaluate_583(&self, _ctx: &EvaluationContext) -> ConditionResult {
1444 // Hinweis: Verwendung der ID der Marktlokation — informational note, always applies
1445 ConditionResult::True
1446 }
1447
1448 /// [584] Hinweis: Verwendung der ID der Messlokation
1449 fn evaluate_584(&self, _ctx: &EvaluationContext) -> ConditionResult {
1450 // Hinweis: Verwendung der ID der Messlokation — informational note, always applies
1451 ConditionResult::True
1452 }
1453
1454 /// [590] Hinweis: Es ist die ID der Marktlokation, welche dem LF zugeordnet sind, sowie alle Identifikatoren der Messlokationen anzugeben
1455 fn evaluate_590(&self, _ctx: &EvaluationContext) -> ConditionResult {
1456 // Hinweis: Es ist die ID der Marktlokation, welche dem LF zugeordnet sind, sowie alle Identifikatoren der Messlokationen anzugeben — informational note, always applies
1457 ConditionResult::True
1458 }
1459
1460 /// [601] Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben.
1461 fn evaluate_601(&self, _ctx: &EvaluationContext) -> ConditionResult {
1462 // Hinweis: Es ist die ID der Marktlokation und alle Identifikatoren der Messlokationen anzugeben — informational note, always applies
1463 ConditionResult::True
1464 }
1465
1466 /// [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.
1467 fn evaluate_621(&self, _ctx: &EvaluationContext) -> ConditionResult {
1468 // Hinweis: Es ist der MSB anzugeben, welcher ab dem Zeitpunkt der Lokation zugeordnet ist, der in DTM+76 (Datum zum geplanten Leistungsbeginn) genannt ist.
1469 ConditionResult::True
1470 }
1471
1472 /// [622] Hinweis: Falls die OBIS-Kennzahl für mehrere Marktrollen relevant ist, so muss die Segmentgruppe pro Marktrolle wiederholt werden
1473 fn evaluate_622(&self, _ctx: &EvaluationContext) -> ConditionResult {
1474 // Hinweis: Falls die OBIS-Kennzahl für mehrere Marktrollen relevant ist, so muss die Segmentgruppe pro Marktrolle wiederholt werden
1475 ConditionResult::True
1476 }
1477
1478 /// [636] Hinweis: Dieses RFF klassifiziert mit einem Code im DE1153 die in derselben Segmentgruppe enthaltenen DTM zu einem Markt- bzw. Messlokation relevanten Inhalt
1479 fn evaluate_636(&self, _ctx: &EvaluationContext) -> ConditionResult {
1480 // Hinweis: Dieses RFF klassifiziert mit einem Code im DE1153 die in derselben Segmentgruppe enthaltenen DTM zu einem Markt- bzw. Messlokation relevanten Inhalt
1481 ConditionResult::True
1482 }
1483
1484 /// [637] Hinweis: Bei Verpflichtungsanfrage
1485 fn evaluate_637(&self, _ctx: &EvaluationContext) -> ConditionResult {
1486 // Hinweis: Bei Verpflichtungsanfrage — informational note, always applies
1487 ConditionResult::True
1488 }
1489
1490 /// [638] Hinweis: Bei Aufforderung zur Übernahme der einzelnen Messlokation durch den gMSB
1491 fn evaluate_638(&self, _ctx: &EvaluationContext) -> ConditionResult {
1492 // Hinweis: Bei Aufforderung zur Übernahme der einzelnen Messlokation durch den gMSB — informational note, always applies
1493 ConditionResult::True
1494 }
1495
1496 /// [643] Hinweis: Nachfolgender Netzbetreiber
1497 fn evaluate_643(&self, _ctx: &EvaluationContext) -> ConditionResult {
1498 // Hinweis: Nachfolgender Netzbetreiber — informational note, always applies
1499 ConditionResult::True
1500 }
1501
1502 /// [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
1503 fn evaluate_644(&self, _ctx: &EvaluationContext) -> ConditionResult {
1504 // Hinweis: informational note about E01/E02 usage in Bestätigung — always applies
1505 ConditionResult::True
1506 }
1507
1508 /// [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...
1509 fn evaluate_651(&self, _ctx: &EvaluationContext) -> ConditionResult {
1510 // Hinweis: Marktraumumstellung Gas — informational note about Messlokation reporting — always applies
1511 ConditionResult::True
1512 }
1513
1514 /// [654] Hinweis: Es sind ausschließlich die Daten zum Meldepunkt anzugeben, die für den in NAD+MR (Nachrichtenempfänger) adressierten Marktpartner relevant ist
1515 fn evaluate_654(&self, _ctx: &EvaluationContext) -> ConditionResult {
1516 // Hinweis: Only data relevant to the addressed Marktpartner (NAD+MR) should be provided — always applies
1517 ConditionResult::True
1518 }
1519
1520 /// [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
1521 fn evaluate_655(&self, _ctx: &EvaluationContext) -> ConditionResult {
1522 // Hinweis: When a meter is connected to a volume converter, no OBIS codes are given for the meter — always applies
1523 ConditionResult::True
1524 }
1525
1526 /// [902] Format: Möglicher Wert: ≥ 0
1527 fn evaluate_902(&self, ctx: &EvaluationContext) -> ConditionResult {
1528 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, ">=", 0.0))
1529 }
1530
1531 /// [907] Format: max. 4 Nachkommastellen
1532 fn evaluate_907(&self, ctx: &EvaluationContext) -> ConditionResult {
1533 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 4))
1534 }
1535
1536 /// [912] Format: max. 6 Nachkommastellen
1537 fn evaluate_912(&self, ctx: &EvaluationContext) -> ConditionResult {
1538 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 6))
1539 }
1540
1541 /// [930] Format: max. 2 Nachkommastellen
1542 fn evaluate_930(&self, ctx: &EvaluationContext) -> ConditionResult {
1543 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 2))
1544 }
1545
1546 /// [931] Format: ZZZ = +00
1547 fn evaluate_931(&self, ctx: &EvaluationContext) -> ConditionResult {
1548 ctx.format_check("DTM", 0, 1, validate_timezone_utc)
1549 }
1550
1551 /// [934] Format: HHMM = 0400
1552 fn evaluate_934(&self, ctx: &EvaluationContext) -> ConditionResult {
1553 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0400"))
1554 }
1555
1556 /// [935] Format: HHMM = 0500
1557 fn evaluate_935(&self, ctx: &EvaluationContext) -> ConditionResult {
1558 ctx.format_check("DTM", 0, 1, |val| validate_hhmm_equals(val, "0500"))
1559 }
1560
1561 /// [937] Format: keine Nachkommastelle
1562 fn evaluate_937(&self, ctx: &EvaluationContext) -> ConditionResult {
1563 ctx.format_check("QTY", 0, 1, |val| validate_max_decimal_places(val, 0))
1564 }
1565
1566 /// [938] Format: Möglicher Wert: <= 10
1567 fn evaluate_938(&self, ctx: &EvaluationContext) -> ConditionResult {
1568 ctx.format_check("QTY", 0, 1, |val| validate_numeric(val, "<=", 10.0))
1569 }
1570
1571 /// [950] Format: Marktlokations-ID
1572 fn evaluate_950(&self, ctx: &EvaluationContext) -> ConditionResult {
1573 ctx.format_check_qualified("LOC", 0, "Z16", 1, 0, validate_malo_id)
1574 }
1575
1576 /// [951] Format: Zählpunktbezeichnung
1577 fn evaluate_951(&self, ctx: &EvaluationContext) -> ConditionResult {
1578 ctx.format_check_qualified("LOC", 0, "Z19", 1, 0, validate_zahlpunkt)
1579 }
1580
1581 /// [952] Format: Gerätenummer nach DIN 43863-5
1582 // 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)
1583 fn evaluate_952(&self, ctx: &EvaluationContext) -> ConditionResult {
1584 // Format: Gerätenummer nach DIN 43863-5 — alphanumeric, max 20 characters
1585 // DIN 43863-5 device numbers appear in IDE segment (element 1, component 0)
1586 // or in SG8 PIA segments for device identification
1587 let ide_segs = ctx.find_segments("IDE");
1588 if let Some(val) = ide_segs
1589 .first()
1590 .and_then(|s| s.elements.get(1))
1591 .and_then(|e| e.first())
1592 .filter(|v| !v.is_empty())
1593 {
1594 return validate_max_length(val, 20);
1595 }
1596 // Fallback: check PIA segment for device number (qualifier 5 = substitute product)
1597 let pia_segs = ctx.find_segments_with_qualifier("PIA", 0, "5");
1598 match pia_segs
1599 .first()
1600 .and_then(|s| s.elements.get(1))
1601 .and_then(|e| e.first())
1602 {
1603 Some(val) => validate_max_length(val, 20),
1604 None => ConditionResult::False, // segment absent → condition not applicable
1605 }
1606 }
1607
1608 /// [953] Format: Marktlokations-ID oder Zählpunktbezeichnung
1609 fn evaluate_953(&self, ctx: &EvaluationContext) -> ConditionResult {
1610 ctx.format_check("LOC", 1, 0, validate_malo_or_zahlpunkt)
1611 }
1612
1613 /// [2061] Segment bzw. Segmentgruppe ist genau einmal je SG4 IDE (Vorgang) anzugeben
1614 // 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)
1615 fn evaluate_2061(&self, ctx: &EvaluationContext) -> ConditionResult {
1616 ConditionResult::from(ctx.has_segment("IDE"))
1617 }
1618
1619 /// [2119] Je SG8 SEQ+Z13 (Smartmeter-Gateway) ist genau einmal die Segmentgruppe anzugeben
1620 fn evaluate_2119(&self, ctx: &EvaluationContext) -> ConditionResult {
1621 ctx.any_group_has_qualifier("SEQ", 0, "Z13", &["SG4", "SG8"])
1622 }
1623
1624 /// [2284] Für jede Messlokations-ID im SG5 LOC+172 (Meldepunkt) DE3225 genau einmal anzugeben
1625 fn evaluate_2284(&self, ctx: &EvaluationContext) -> ConditionResult {
1626 ctx.any_group_has_qualifier("LOC", 0, "172", &["SG4", "SG5"])
1627 }
1628
1629 /// [2286] Für jede SEQ+Z18 (Daten der Messlokation) mindestens einmal anzugeben
1630 fn evaluate_2286(&self, ctx: &EvaluationContext) -> ConditionResult {
1631 ctx.any_group_has_qualifier("SEQ", 0, "Z18", &["SG4", "SG8"])
1632 }
1633
1634 /// [2287] Für jede SEQ+Z03 (Zähleinrichtungsdaten) mindestens einmal anzugeben
1635 fn evaluate_2287(&self, ctx: &EvaluationContext) -> ConditionResult {
1636 ctx.any_group_has_qualifier("SEQ", 0, "Z03", &["SG4", "SG8"])
1637 }
1638
1639 /// [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
1640 // 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)
1641 fn evaluate_2335(&self, ctx: &EvaluationContext) -> ConditionResult {
1642 {
1643 // Check for PIA+5 with specific OBIS codes 7-20:99.33.17 or 7-0:33.86.0 at elements[1][0]
1644 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1645 let has_target_obis = pias.iter().any(|pia| {
1646 pia.elements
1647 .get(1)
1648 .and_then(|e| e.first())
1649 .map(|v| v == "7-20:99.33.17" || v == "7-0:33.86.0")
1650 .unwrap_or(false)
1651 });
1652 if !has_target_obis {
1653 return ConditionResult::False;
1654 }
1655 // Also verify SEQ+Z02 (OBIS-Daten der Marktlokation) is present — PIA is always co-located in the same SG8
1656 ctx.any_group_has_qualifier("SEQ", 0, "Z02", &["SG4", "SG8"])
1657 }
1658 }
1659
1660 /// [2353] Für jede SEQ+Z09 (Mengenumwerter-Daten) mindestens einmal anzugeben
1661 fn evaluate_2353(&self, ctx: &EvaluationContext) -> ConditionResult {
1662 ctx.any_group_has_qualifier("SEQ", 0, "Z09", &["SG4", "SG8"])
1663 }
1664}