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#[allow(unused_imports)]
8use crate::eval::format_validators::*;
9use crate::eval::{ConditionEvaluator, ConditionResult, EvaluationContext};
10
11/// Generated condition evaluator for UTILMD_Gas FV2604.
12pub struct UtilmdGasConditionEvaluatorFV2604 {
13 // External condition IDs that require runtime context.
14 external_conditions: std::collections::HashSet<u32>,
15}
16
17impl Default for UtilmdGasConditionEvaluatorFV2604 {
18 fn default() -> Self {
19 let mut external_conditions = std::collections::HashSet::new();
20 external_conditions.insert(1);
21 external_conditions.insert(3);
22 external_conditions.insert(4);
23 external_conditions.insert(5);
24 external_conditions.insert(14);
25 external_conditions.insert(17);
26 external_conditions.insert(29);
27 external_conditions.insert(39);
28 external_conditions.insert(51);
29 external_conditions.insert(65);
30 external_conditions.insert(92);
31 external_conditions.insert(98);
32 external_conditions.insert(108);
33 external_conditions.insert(127);
34 external_conditions.insert(129);
35 external_conditions.insert(133);
36 external_conditions.insert(147);
37 external_conditions.insert(165);
38 external_conditions.insert(166);
39 external_conditions.insert(219);
40 external_conditions.insert(241);
41 external_conditions.insert(268);
42 external_conditions.insert(283);
43 external_conditions.insert(315);
44 external_conditions.insert(324);
45 external_conditions.insert(336);
46 external_conditions.insert(427);
47 external_conditions.insert(490);
48 external_conditions.insert(491);
49 Self {
50 external_conditions,
51 }
52 }
53}
54
55impl ConditionEvaluator for UtilmdGasConditionEvaluatorFV2604 {
56 fn message_type(&self) -> &str {
57 "UTILMD_Gas"
58 }
59
60 fn format_version(&self) -> &str {
61 "FV2604"
62 }
63
64 fn evaluate(&self, condition: u32, ctx: &EvaluationContext) -> ConditionResult {
65 match condition {
66 1 => self.evaluate_1(ctx),
67 2 => self.evaluate_2(ctx),
68 3 => self.evaluate_3(ctx),
69 4 => self.evaluate_4(ctx),
70 5 => self.evaluate_5(ctx),
71 7 => self.evaluate_7(ctx),
72 9 => self.evaluate_9(ctx),
73 10 => self.evaluate_10(ctx),
74 11 => self.evaluate_11(ctx),
75 12 => self.evaluate_12(ctx),
76 13 => self.evaluate_13(ctx),
77 14 => self.evaluate_14(ctx),
78 15 => self.evaluate_15(ctx),
79 16 => self.evaluate_16(ctx),
80 17 => self.evaluate_17(ctx),
81 18 => self.evaluate_18(ctx),
82 19 => self.evaluate_19(ctx),
83 24 => self.evaluate_24(ctx),
84 25 => self.evaluate_25(ctx),
85 26 => self.evaluate_26(ctx),
86 28 => self.evaluate_28(ctx),
87 29 => self.evaluate_29(ctx),
88 32 => self.evaluate_32(ctx),
89 33 => self.evaluate_33(ctx),
90 35 => self.evaluate_35(ctx),
91 36 => self.evaluate_36(ctx),
92 37 => self.evaluate_37(ctx),
93 39 => self.evaluate_39(ctx),
94 46 => self.evaluate_46(ctx),
95 47 => self.evaluate_47(ctx),
96 48 => self.evaluate_48(ctx),
97 51 => self.evaluate_51(ctx),
98 58 => self.evaluate_58(ctx),
99 64 => self.evaluate_64(ctx),
100 65 => self.evaluate_65(ctx),
101 66 => self.evaluate_66(ctx),
102 68 => self.evaluate_68(ctx),
103 69 => self.evaluate_69(ctx),
104 70 => self.evaluate_70(ctx),
105 77 => self.evaluate_77(ctx),
106 78 => self.evaluate_78(ctx),
107 81 => self.evaluate_81(ctx),
108 84 => self.evaluate_84(ctx),
109 92 => self.evaluate_92(ctx),
110 98 => self.evaluate_98(ctx),
111 106 => self.evaluate_106(ctx),
112 108 => self.evaluate_108(ctx),
113 123 => self.evaluate_123(ctx),
114 127 => self.evaluate_127(ctx),
115 128 => self.evaluate_128(ctx),
116 129 => self.evaluate_129(ctx),
117 130 => self.evaluate_130(ctx),
118 133 => self.evaluate_133(ctx),
119 137 => self.evaluate_137(ctx),
120 138 => self.evaluate_138(ctx),
121 147 => self.evaluate_147(ctx),
122 165 => self.evaluate_165(ctx),
123 166 => self.evaluate_166(ctx),
124 200 => self.evaluate_200(ctx),
125 202 => self.evaluate_202(ctx),
126 203 => self.evaluate_203(ctx),
127 205 => self.evaluate_205(ctx),
128 209 => self.evaluate_209(ctx),
129 212 => self.evaluate_212(ctx),
130 213 => self.evaluate_213(ctx),
131 216 => self.evaluate_216(ctx),
132 219 => self.evaluate_219(ctx),
133 230 => self.evaluate_230(ctx),
134 241 => self.evaluate_241(ctx),
135 249 => self.evaluate_249(ctx),
136 252 => self.evaluate_252(ctx),
137 257 => self.evaluate_257(ctx),
138 268 => self.evaluate_268(ctx),
139 274 => self.evaluate_274(ctx),
140 276 => self.evaluate_276(ctx),
141 277 => self.evaluate_277(ctx),
142 283 => self.evaluate_283(ctx),
143 315 => self.evaluate_315(ctx),
144 324 => self.evaluate_324(ctx),
145 328 => self.evaluate_328(ctx),
146 333 => self.evaluate_333(ctx),
147 336 => self.evaluate_336(ctx),
148 345 => self.evaluate_345(ctx),
149 361 => self.evaluate_361(ctx),
150 362 => self.evaluate_362(ctx),
151 367 => self.evaluate_367(ctx),
152 368 => self.evaluate_368(ctx),
153 427 => self.evaluate_427(ctx),
154 442 => self.evaluate_442(ctx),
155 490 => self.evaluate_490(ctx),
156 491 => self.evaluate_491(ctx),
157 494 => self.evaluate_494(ctx),
158 500 => self.evaluate_500(ctx),
159 501 => self.evaluate_501(ctx),
160 502 => self.evaluate_502(ctx),
161 504 => self.evaluate_504(ctx),
162 505 => self.evaluate_505(ctx),
163 507 => self.evaluate_507(ctx),
164 508 => self.evaluate_508(ctx),
165 510 => self.evaluate_510(ctx),
166 511 => self.evaluate_511(ctx),
167 513 => self.evaluate_513(ctx),
168 527 => self.evaluate_527(ctx),
169 528 => self.evaluate_528(ctx),
170 530 => self.evaluate_530(ctx),
171 556 => self.evaluate_556(ctx),
172 558 => self.evaluate_558(ctx),
173 559 => self.evaluate_559(ctx),
174 560 => self.evaluate_560(ctx),
175 566 => self.evaluate_566(ctx),
176 567 => self.evaluate_567(ctx),
177 570 => self.evaluate_570(ctx),
178 571 => self.evaluate_571(ctx),
179 572 => self.evaluate_572(ctx),
180 581 => self.evaluate_581(ctx),
181 583 => self.evaluate_583(ctx),
182 584 => self.evaluate_584(ctx),
183 590 => self.evaluate_590(ctx),
184 601 => self.evaluate_601(ctx),
185 621 => self.evaluate_621(ctx),
186 622 => self.evaluate_622(ctx),
187 636 => self.evaluate_636(ctx),
188 637 => self.evaluate_637(ctx),
189 638 => self.evaluate_638(ctx),
190 643 => self.evaluate_643(ctx),
191 644 => self.evaluate_644(ctx),
192 651 => self.evaluate_651(ctx),
193 654 => self.evaluate_654(ctx),
194 655 => self.evaluate_655(ctx),
195 902 => self.evaluate_902(ctx),
196 907 => self.evaluate_907(ctx),
197 912 => self.evaluate_912(ctx),
198 930 => self.evaluate_930(ctx),
199 931 => self.evaluate_931(ctx),
200 934 => self.evaluate_934(ctx),
201 935 => self.evaluate_935(ctx),
202 937 => self.evaluate_937(ctx),
203 938 => self.evaluate_938(ctx),
204 950 => self.evaluate_950(ctx),
205 951 => self.evaluate_951(ctx),
206 952 => self.evaluate_952(ctx),
207 953 => self.evaluate_953(ctx),
208 2061 => self.evaluate_2061(ctx),
209 2119 => self.evaluate_2119(ctx),
210 2284 => self.evaluate_2284(ctx),
211 2286 => self.evaluate_2286(ctx),
212 2287 => self.evaluate_2287(ctx),
213 2335 => self.evaluate_2335(ctx),
214 2353 => self.evaluate_2353(ctx),
215 _ => ConditionResult::Unknown,
216 }
217 }
218
219 fn is_external(&self, condition: u32) -> bool {
220 self.external_conditions.contains(&condition)
221 }
222 fn is_known(&self, condition: u32) -> bool {
223 matches!(
224 condition,
225 1 | 2
226 | 3
227 | 4
228 | 5
229 | 7
230 | 9
231 | 10
232 | 11
233 | 12
234 | 13
235 | 14
236 | 15
237 | 16
238 | 17
239 | 18
240 | 19
241 | 24
242 | 25
243 | 26
244 | 28
245 | 29
246 | 32
247 | 33
248 | 35
249 | 36
250 | 37
251 | 39
252 | 46
253 | 47
254 | 48
255 | 51
256 | 58
257 | 64
258 | 65
259 | 66
260 | 68
261 | 69
262 | 70
263 | 77
264 | 78
265 | 81
266 | 84
267 | 92
268 | 98
269 | 106
270 | 108
271 | 123
272 | 127
273 | 128
274 | 129
275 | 130
276 | 133
277 | 137
278 | 138
279 | 147
280 | 165
281 | 166
282 | 200
283 | 202
284 | 203
285 | 205
286 | 209
287 | 212
288 | 213
289 | 216
290 | 219
291 | 230
292 | 241
293 | 249
294 | 252
295 | 257
296 | 268
297 | 274
298 | 276
299 | 277
300 | 283
301 | 315
302 | 324
303 | 328
304 | 333
305 | 336
306 | 345
307 | 361
308 | 362
309 | 367
310 | 368
311 | 427
312 | 442
313 | 490
314 | 491
315 | 494
316 | 500
317 | 501
318 | 502
319 | 504
320 | 505
321 | 507
322 | 508
323 | 510
324 | 511
325 | 513
326 | 527
327 | 528
328 | 530
329 | 556
330 | 558
331 | 559
332 | 560
333 | 566
334 | 567
335 | 570
336 | 571
337 | 572
338 | 581
339 | 583
340 | 584
341 | 590
342 | 601
343 | 621
344 | 622
345 | 636
346 | 637
347 | 638
348 | 643
349 | 644
350 | 651
351 | 654
352 | 655
353 | 902
354 | 907
355 | 912
356 | 930
357 | 931
358 | 934
359 | 935
360 | 937
361 | 938
362 | 950
363 | 951
364 | 952
365 | 953
366 | 2061
367 | 2119
368 | 2284
369 | 2286
370 | 2287
371 | 2335
372 | 2353
373 )
374 }
375}
376
377impl UtilmdGasConditionEvaluatorFV2604 {
378 /// [2] Wenn UNH DE0070 (Übermittlungsfolgenummer) mit 1 vorhanden
379 fn evaluate_2(&self, ctx: &EvaluationContext) -> ConditionResult {
380 let unh_segs = ctx.find_segments("UNH");
381 match unh_segs.first() {
382 Some(unh) => match unh.elements.get(3).and_then(|e| e.first()) {
383 Some(val) => ConditionResult::from(val == "1"),
384 None => ConditionResult::False,
385 },
386 None => ConditionResult::False, // segment absent → condition not applicable
387 }
388 }
389
390 /// [3] Bei Aufteilung, in der Nachricht mit der höchsten Übermittlungsfolgenummer
391 /// EXTERNAL: Requires context from outside the message.
392 fn evaluate_3(&self, ctx: &EvaluationContext) -> ConditionResult {
393 ctx.external.evaluate("is_highest_sequence_number_in_split")
394 }
395
396 /// [203] Wenn STS+7++E06 / Z39 / ZC6 / ZC7 / ZT6 / ZT7
397 fn evaluate_203(&self, ctx: &EvaluationContext) -> ConditionResult {
398 ctx.has_qualified_value(
399 "STS",
400 0,
401 "7",
402 2,
403 0,
404 &["E06", "Z39", "ZC6", "ZC7", "ZT6", "ZT7"],
405 )
406 }
407
408 /// [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...
409 /// EXTERNAL: Requires context from outside the message.
410 fn evaluate_315(&self, ctx: &EvaluationContext) -> ConditionResult {
411 ctx.external.evaluate("obis_kennzahlen_mindestumfang_valid")
412 }
413
414 /// [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...
415 /// EXTERNAL: Requires context from outside the message.
416 fn evaluate_324(&self, ctx: &EvaluationContext) -> ConditionResult {
417 ctx.external
418 .evaluate("zaehler_obis_kennzahlen_mindestumfang_valid")
419 }
420
421 /// [328] Wenn IMD++Z36+Z12 (Identifikationslogik: Marktlokations-ID) vorhanden
422 fn evaluate_328(&self, ctx: &EvaluationContext) -> ConditionResult {
423 ctx.has_segment_matching("IMD", &[(1, 0, "Z36"), (2, 0, "Z12")])
424 }
425
426 /// [333] Wenn IMD+Z36+Z13 (Identifikationslogik: Alle Identifikationsdaten) vorhanden
427 fn evaluate_333(&self, ctx: &EvaluationContext) -> ConditionResult {
428 ctx.has_segment_matching("IMD", &[(1, 0, "Z36"), (2, 0, "Z13")])
429 }
430
431 /// [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...
432 fn evaluate_502(&self, _ctx: &EvaluationContext) -> ConditionResult {
433 // 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
434 ConditionResult::True
435 }
436
437 /// [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
438 fn evaluate_504(&self, _ctx: &EvaluationContext) -> ConditionResult {
439 // 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
440 ConditionResult::True
441 }
442
443 /// [505] Hinweis: Übergangsversorgung gibt es nur bei Marktlokationen, die unter § 38a EnWG fallen. Grundlage ist eine bilaterale Vereinbarung
444 fn evaluate_505(&self, _ctx: &EvaluationContext) -> ConditionResult {
445 // Hinweis: Übergangsversorgung gibt es nur bei Marktlokationen, die unter § 38a EnWG fallen. Grundlage ist eine bilaterale Vereinbarung — informational note, always applies
446 ConditionResult::True
447 }
448
449 /// [511] Hinweis: Zu verwenden bei der Abmeldung der Übergangsversorgung
450 fn evaluate_511(&self, _ctx: &EvaluationContext) -> ConditionResult {
451 // Hinweis: Zu verwenden bei der Abmeldung der Übergangsversorgung — informational note, always applies
452 ConditionResult::True
453 }
454
455 /// [1] Wenn Aufteilung vorhanden
456 /// EXTERNAL: Requires context from outside the message.
457 fn evaluate_1(&self, ctx: &EvaluationContext) -> ConditionResult {
458 ctx.external.evaluate("message_splitting")
459 }
460
461 /// [4] Wenn MP-ID in SG2 NAD+MR (Nachrichtenempfänger) in der Rolle LF
462 /// EXTERNAL: Requires context from outside the message.
463 fn evaluate_4(&self, ctx: &EvaluationContext) -> ConditionResult {
464 ctx.external.evaluate("recipient_is_lf")
465 }
466
467 /// [5] Wenn MP-ID in SG2 NAD+MS (Nachrichtenabsender) in der Rolle LF
468 /// EXTERNAL: Requires context from outside the message.
469 fn evaluate_5(&self, ctx: &EvaluationContext) -> ConditionResult {
470 ctx.external.evaluate("sender_is_lf")
471 }
472
473 /// [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
474 fn evaluate_7(&self, ctx: &EvaluationContext) -> ConditionResult {
475 ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZG9", "ZH1", "ZH2"])
476 }
477
478 /// [9] Wenn SG4 STS+7++ZE4 (Transaktionsgrund: Weggefallene Markt- bzw. Messlokation) nicht vorhanden
479 fn evaluate_9(&self, ctx: &EvaluationContext) -> ConditionResult {
480 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZE4"]) {
481 ConditionResult::True => ConditionResult::False,
482 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
483 }
484 }
485
486 /// [10] Wenn SG4 STS+Z17 (Transaktionsgrund für befristete Anmeldung) vorhanden
487 fn evaluate_10(&self, ctx: &EvaluationContext) -> ConditionResult {
488 ctx.has_qualifier("STS", 0, "Z17")
489 }
490
491 /// [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
492 fn evaluate_11(&self, ctx: &EvaluationContext) -> ConditionResult {
493 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["ZG9", "ZH1", "ZH2"]) {
494 ConditionResult::True => ConditionResult::False,
495 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
496 }
497 }
498
499 /// [12] Wenn SG4 DTM+471 (Ende zum nächstmöglichem Termin) nicht vorhanden
500 fn evaluate_12(&self, ctx: &EvaluationContext) -> ConditionResult {
501 ctx.lacks_qualifier("DTM", 0, "471")
502 }
503
504 /// [13] Wenn SG4 STS+E01++Z01 (Status der Antwort: Zustimmung mit Terminänderung) nicht vorhanden
505 fn evaluate_13(&self, ctx: &EvaluationContext) -> ConditionResult {
506 match ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z01"]) {
507 ConditionResult::True => ConditionResult::False,
508 ConditionResult::False | ConditionResult::Unknown => ConditionResult::True,
509 }
510 }
511
512 /// [14] Wenn Datum bekannt
513 /// EXTERNAL: Requires context from outside the message.
514 fn evaluate_14(&self, ctx: &EvaluationContext) -> ConditionResult {
515 ctx.external.evaluate("date_known")
516 }
517
518 /// [15] Wenn SG4 STS+E01++Z34 (Status der Antwort: Ablehnung Mehrfachkündigung) vorhanden
519 fn evaluate_15(&self, ctx: &EvaluationContext) -> ConditionResult {
520 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z34"])
521 }
522
523 /// [16] Wenn SG4 STS+E01++Z12 (Status der Antwort: Ablehnung Vertragsbindung) vorhanden
524 fn evaluate_16(&self, ctx: &EvaluationContext) -> ConditionResult {
525 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z12"])
526 }
527
528 /// [17] Wenn bereits eine bestätigte Kündigung durch Kunde oder MP vorhanden
529 /// EXTERNAL: Requires context from outside the message.
530 fn evaluate_17(&self, ctx: &EvaluationContext) -> ConditionResult {
531 ctx.external.evaluate("confirmed_cancellation_present")
532 }
533
534 /// [18] Wenn SG4 DTM+93 (Ende zum) nicht vorhanden
535 fn evaluate_18(&self, ctx: &EvaluationContext) -> ConditionResult {
536 ctx.lacks_qualifier("DTM", 0, "93")
537 }
538
539 /// [19] Wenn SG8 SEQ+Z01 (Daten der Marktlokation) SG10 CCI+++ZC0 (Prognose auf Basis von Werten) vorhanden
540 fn evaluate_19(&self, ctx: &EvaluationContext) -> ConditionResult {
541 ctx.filtered_parent_child_has_qualifier(
542 &["SG4", "SG8"],
543 "SEQ",
544 0,
545 "Z01",
546 "SG10",
547 "CCI",
548 2,
549 "ZC0",
550 )
551 }
552
553 /// [24] Wenn SG6 DTM+Z21 (Termin der Netznutzungsabrechnung) vorhanden
554 fn evaluate_24(&self, ctx: &EvaluationContext) -> ConditionResult {
555 ctx.has_qualifier("DTM", 0, "Z21")
556 }
557
558 /// [25] Wenn der Meldepunkt im SG5 LOC+172 (Meldepunkt) DE3225 das Format der Marktlokations-ID hat
559 // 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)
560 fn evaluate_25(&self, ctx: &EvaluationContext) -> ConditionResult {
561 let segs = ctx.find_segments_with_qualifier("LOC", 0, "172");
562 if segs.is_empty() {
563 return ConditionResult::Unknown;
564 }
565 for seg in &segs {
566 if let Some(val) = seg.elements.get(1).and_then(|e| e.first()) {
567 if !val.is_empty() && val.chars().all(|c| c.is_ascii_digit()) {
568 return ConditionResult::True;
569 }
570 }
571 }
572 ConditionResult::False
573 }
574
575 /// [26] Wenn der Meldepunkt im SG5 LOC+172 (Meldepunkt) DE3225 das Format der Zählpunktbezeichnung hat
576 // 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)
577 fn evaluate_26(&self, ctx: &EvaluationContext) -> ConditionResult {
578 let segs = ctx.find_segments_with_qualifier("LOC", 0, "172");
579 if segs.is_empty() {
580 return ConditionResult::Unknown;
581 }
582 for seg in &segs {
583 if let Some(val) = seg.elements.get(1).and_then(|e| e.first()) {
584 if !val.is_empty() && !val.chars().all(|c| c.is_ascii_digit()) {
585 return ConditionResult::True;
586 }
587 }
588 }
589 ConditionResult::False
590 }
591
592 /// [28] Wenn SG4 DTM+93 (Ende zum) vorhanden
593 fn evaluate_28(&self, ctx: &EvaluationContext) -> ConditionResult {
594 ctx.has_qualifier("DTM", 0, "93")
595 }
596
597 /// [29] Wenn eine Bilanzierung stattfindet
598 /// EXTERNAL: Requires context from outside the message.
599 fn evaluate_29(&self, ctx: &EvaluationContext) -> ConditionResult {
600 ctx.external.evaluate("balancing_takes_place")
601 }
602
603 /// [32] Wenn BGM+E03 (Änderungsmeldungen) vorhanden
604 fn evaluate_32(&self, ctx: &EvaluationContext) -> ConditionResult {
605 ctx.has_qualifier("BGM", 0, "E03")
606 }
607
608 /// [33] Wenn in Abmeldung ein Bilanzierungsende vorhanden
609 // 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)
610 fn evaluate_33(&self, ctx: &EvaluationContext) -> ConditionResult {
611 let has_abmeldung = !ctx.find_segments_with_qualifier("BGM", 0, "E02").is_empty();
612 let has_bilanzierungsende = !ctx.find_segments_with_qualifier("DTM", 0, "159").is_empty();
613 ConditionResult::from(has_abmeldung && has_bilanzierungsende)
614 }
615
616 /// [35] Wenn das DE2380 von SG4 DTM+Z01 (Kündigungsfrist des Vertrags) an vierter Stelle T (Termin) enthält
617 fn evaluate_35(&self, ctx: &EvaluationContext) -> ConditionResult {
618 let segs = ctx.find_segments_with_qualifier("DTM", 0, "Z01");
619 match segs.first() {
620 Some(dtm) => {
621 match dtm
622 .elements
623 .first()
624 .and_then(|e| e.get(1))
625 .map(|s| s.as_str())
626 {
627 Some(value) => match value.chars().nth(3) {
628 Some('T') => ConditionResult::True,
629 Some(_) => ConditionResult::False,
630 None => ConditionResult::False, // segment absent → condition not applicable
631 },
632 None => ConditionResult::False, // segment absent → condition not applicable
633 }
634 }
635 None => ConditionResult::False, // segment absent → condition not applicable
636 }
637 }
638
639 /// [36] Wenn SG4 STS+E01++ZC5 (Status der Antwort: Ablehnung andere Anmeldung in Bearbeitung) vorhanden
640 fn evaluate_36(&self, ctx: &EvaluationContext) -> ConditionResult {
641 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["ZC5"])
642 }
643
644 /// [37] Wenn Anmeldung/ Änderung befristet
645 fn evaluate_37(&self, ctx: &EvaluationContext) -> ConditionResult {
646 // Same check as [10]: STS+Z17 indicates befristete Anmeldung in Gas
647 ctx.has_qualifier("STS", 0, "Z17")
648 }
649
650 /// [39] Wenn LF beabsichtigt Zählerstand zu übermitteln
651 /// EXTERNAL: Requires context from outside the message.
652 fn evaluate_39(&self, ctx: &EvaluationContext) -> ConditionResult {
653 ctx.external
654 .evaluate("lf_intends_to_transmit_meter_reading")
655 }
656
657 /// [46] Wenn in SG8 SEQ+Z35 ein SG10 CCI+Z12 (Lastprofil) CAV (Lastprofil) DE3055 der Wert 293 enthalten ist
658 // 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)
659 fn evaluate_46(&self, ctx: &EvaluationContext) -> ConditionResult {
660 let seq_values = ctx.collect_group_values("SEQ", 0, 0, &["SG4", "SG8"]);
661 let z35_instances: Vec<usize> = seq_values
662 .iter()
663 .filter(|(_, v)| v == "Z35")
664 .map(|(i, _)| *i)
665 .collect();
666 if z35_instances.is_empty() {
667 return ConditionResult::False;
668 }
669 let nav = match ctx.navigator() {
670 Some(n) => n,
671 None => return ConditionResult::Unknown,
672 };
673 for i in z35_instances {
674 let sg10_count = nav.child_group_instance_count(&["SG4", "SG8"], i, "SG10");
675 for j in 0..sg10_count {
676 let ccis = nav.find_segments_in_child_group("CCI", &["SG4", "SG8"], i, "SG10", j);
677 let has_z12 = ccis.iter().any(|s| {
678 s.elements
679 .first()
680 .and_then(|e| e.first())
681 .is_some_and(|v| v == "Z12")
682 });
683 if !has_z12 {
684 continue;
685 }
686 // Check Klimazone CCI (Z99/ZA0) for DE3055=293 at elements[2][2]
687 let has_293 = ccis.iter().any(|s| {
688 s.elements
689 .get(2)
690 .and_then(|e| e.get(2))
691 .is_some_and(|v| v == "293")
692 });
693 if has_293 {
694 return ConditionResult::True;
695 }
696 }
697 }
698 ConditionResult::False
699 }
700
701 /// [47] Wenn in SG8 SEQ+Z35 ein SG10 CCI+Z12 (Lastprofil) CAV (Lastprofil) DE3055 der Wert 293 nicht enthalten ist
702 // 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)
703 fn evaluate_47(&self, ctx: &EvaluationContext) -> ConditionResult {
704 match self.evaluate_46(ctx) {
705 ConditionResult::True => ConditionResult::False,
706 ConditionResult::False => ConditionResult::True,
707 ConditionResult::Unknown => ConditionResult::Unknown,
708 }
709 }
710
711 /// [48] Wenn in dieser SG4 das STS+E01++E14 (Status der Antwort: Ablehnung Sonstiges) vorhanden
712 fn evaluate_48(&self, ctx: &EvaluationContext) -> ConditionResult {
713 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["E14"])
714 }
715
716 /// [51] Bei rückwirkendem Lieferende/Lieferbeginn
717 /// EXTERNAL: Requires context from outside the message.
718 fn evaluate_51(&self, ctx: &EvaluationContext) -> ConditionResult {
719 ctx.external.evaluate("retroactive_delivery_change")
720 }
721
722 /// [58] Wenn in diesem CCI das DE3055 mit dem Code 293 vorhanden
723 // 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)
724 fn evaluate_58(&self, ctx: &EvaluationContext) -> ConditionResult {
725 let ccis = ctx.find_segments("CCI");
726 ConditionResult::from(ccis.iter().any(|s| {
727 s.elements
728 .get(2)
729 .and_then(|e| e.get(2))
730 .is_some_and(|v| v == "293")
731 }))
732 }
733
734 /// [64] Wenn SG4 DTM+158 (Bilanzierungsbeginn) vorhanden
735 fn evaluate_64(&self, ctx: &EvaluationContext) -> ConditionResult {
736 ctx.has_qualifier("DTM", 0, "158")
737 }
738
739 /// [65] Wenn Marktgebietsüber-lappung besteht, sind alle Bilanzkreise des LF zu melden in denen freie Kapazitäten beim NB bestehen
740 /// EXTERNAL: Requires context from outside the message.
741 fn evaluate_65(&self, ctx: &EvaluationContext) -> ConditionResult {
742 ctx.external.evaluate("market_area_overlap_exists")
743 }
744
745 /// [66] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als einmal vorhanden
746 fn evaluate_66(&self, ctx: &EvaluationContext) -> ConditionResult {
747 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
748 ConditionResult::from(count > 1)
749 }
750
751 /// [68] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als zweimal vorhanden
752 fn evaluate_68(&self, ctx: &EvaluationContext) -> ConditionResult {
753 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
754 ConditionResult::from(count > 2)
755 }
756
757 /// [69] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang mehr als dreimal vorhanden
758 fn evaluate_69(&self, ctx: &EvaluationContext) -> ConditionResult {
759 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
760 ConditionResult::from(count > 3)
761 }
762
763 /// [70] Wenn SG10 CCI+Z19 (Bilanzkreis) im Vorgang fünfmal vorhanden
764 fn evaluate_70(&self, ctx: &EvaluationContext) -> ConditionResult {
765 let count = ctx.find_segments_with_qualifier("CCI", 0, "Z19").len();
766 ConditionResult::from(count == 5)
767 }
768
769 /// [77] Wenn SG8 SEQ+Z03 (Zähleinrichtungsdaten) CAV+Z30 (Identifikation/Nummer des Gerätes) nicht vorhanden
770 fn evaluate_77(&self, ctx: &EvaluationContext) -> ConditionResult {
771 ctx.any_group_has_qualifier_without("SEQ", 0, "Z03", "CAV", 0, "Z30", &["SG4", "SG8"])
772 }
773
774 /// [78] Wenn SG4 STS+7++E02 (Transaktionsgrund: Einzug in Neuanlage) nicht vorhanden
775 fn evaluate_78(&self, ctx: &EvaluationContext) -> ConditionResult {
776 let result = ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]);
777 match result {
778 ConditionResult::True => ConditionResult::False,
779 ConditionResult::False => ConditionResult::True,
780 ConditionResult::Unknown => ConditionResult::Unknown,
781 }
782 }
783
784 /// [81] Wenn SG4 FTX+ABO+Z05 (Beschreibung der Abweichung zur übermittelten Liste: Änderung vorhanden) vorhanden
785 fn evaluate_81(&self, ctx: &EvaluationContext) -> ConditionResult {
786 ctx.has_qualified_value("FTX", 0, "ABO", 2, 0, &["Z05"])
787 }
788
789 /// [84] Wenn SG4 STS+E01++Z35 (Status der Antwort: Ablehnung der Abmeldeanfrage) vorhanden
790 fn evaluate_84(&self, ctx: &EvaluationContext) -> ConditionResult {
791 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["Z35"])
792 }
793
794 /// [92] Wenn Wert innerhalb SG bzw. Segment geändert wird
795 /// EXTERNAL: Requires context from outside the message.
796 // 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)
797 fn evaluate_92(&self, ctx: &EvaluationContext) -> ConditionResult {
798 ctx.external.evaluate("value_changed_in_segment")
799 }
800
801 /// [98] Wenn MP-ID in SG2 NAD+MS (Nachrichtenabsender) in der Rolle NB
802 /// EXTERNAL: Requires context from outside the message.
803 // 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)
804 fn evaluate_98(&self, ctx: &EvaluationContext) -> ConditionResult {
805 ctx.external.evaluate("sender_is_nb")
806 }
807
808 /// [106] Wenn in dieser SG8 SEQ+Z01 SG10 CCI+++ZA6 (Prognosegrundlage der Marktlokation: Prognose auf Basis von Profilen) vorhanden
809 fn evaluate_106(&self, ctx: &EvaluationContext) -> ConditionResult {
810 ctx.filtered_parent_child_has_qualifier(
811 &["SG4", "SG8"],
812 "SEQ",
813 0,
814 "Z01",
815 "SG10",
816 "CCI",
817 2,
818 "ZA6",
819 )
820 }
821
822 /// [108] Wenn Kundenwertverfahren (z. B. TU München)
823 /// EXTERNAL: Requires context from outside the message.
824 // 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)
825 fn evaluate_108(&self, ctx: &EvaluationContext) -> ConditionResult {
826 ctx.external.evaluate("kundenwertverfahren")
827 }
828
829 /// [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...
830 // 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)
831 fn evaluate_123(&self, ctx: &EvaluationContext) -> ConditionResult {
832 let nav = match ctx.navigator() {
833 Some(n) => n,
834 None => {
835 let seqs = ctx.find_segments_with_qualifier("SEQ", 0, "Z20");
836 if seqs.len() < 2 {
837 return ConditionResult::False;
838 }
839 return ConditionResult::Unknown;
840 }
841 };
842 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
843 let mut device_ids: Vec<String> = Vec::new();
844 for i in 0..sg8_count {
845 let seqs = nav.find_segments_in_group("SEQ", &["SG4", "SG8"], i);
846 let has_z20 = seqs.iter().any(|s| {
847 s.elements
848 .first()
849 .and_then(|e| e.first())
850 .is_some_and(|v| v == "Z20")
851 });
852 if !has_z20 {
853 continue;
854 }
855 let rffs = nav.find_segments_in_group("RFF", &["SG4", "SG8"], i);
856 for rff in &rffs {
857 let qual = rff
858 .elements
859 .first()
860 .and_then(|e| e.first())
861 .map(|s| s.as_str());
862 if matches!(qual, Some("MG") | Some("Z11")) {
863 if let Some(id) = rff.elements.first().and_then(|e| e.get(1)) {
864 if !id.is_empty() {
865 device_ids.push(id.clone());
866 }
867 }
868 }
869 }
870 }
871 for i in 0..device_ids.len() {
872 for j in (i + 1)..device_ids.len() {
873 if device_ids[i] == device_ids[j] {
874 return ConditionResult::True;
875 }
876 }
877 }
878 ConditionResult::False
879 }
880
881 /// [127] Hat der Lieferant auf Grund seines Vertrags Kenntnis, dass der Kunde keine hohe KA hat so muss er dies dem NB mitteilen
882 /// EXTERNAL: Requires context from outside the message.
883 // 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)
884 fn evaluate_127(&self, ctx: &EvaluationContext) -> ConditionResult {
885 ctx.external.evaluate("supplier_knows_no_high_ka")
886 }
887
888 /// [128] Wenn SG10 CAV+TAS/ TKS/ SAS/ KAS vorhanden
889 fn evaluate_128(&self, ctx: &EvaluationContext) -> ConditionResult {
890 ctx.any_group_has_any_qualifier(
891 "CAV",
892 0,
893 &["TAS", "TKS", "SAS", "KAS"],
894 &["SG4", "SG8", "SG10"],
895 )
896 }
897
898 /// [129] Hat der Lieferant auf Grund seines Vertrags Kenntnis über die Höhe der Sonder-KA, so muss er diesen dem NB mitteilen
899 /// EXTERNAL: Requires context from outside the message.
900 // 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)
901 fn evaluate_129(&self, ctx: &EvaluationContext) -> ConditionResult {
902 ctx.external.evaluate("supplier_knows_special_ka_amount")
903 }
904
905 /// [130] Wenn an Messlokation vorhanden
906 // 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)
907 fn evaluate_130(&self, ctx: &EvaluationContext) -> ConditionResult {
908 ctx.has_qualifier("SEQ", 0, "Z18")
909 }
910
911 /// [133] Wenn an der übermittelten Marktlokation / Messlokation vorhanden
912 /// EXTERNAL: Requires context from outside the message.
913 // 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)
914 fn evaluate_133(&self, ctx: &EvaluationContext) -> ConditionResult {
915 ctx.external.evaluate("at_marktlokation_or_messlokation")
916 }
917
918 /// [137] Nicht bei Neuanlage
919 // 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)
920 fn evaluate_137(&self, ctx: &EvaluationContext) -> ConditionResult {
921 match ctx.has_qualified_value("STS", 0, "7", 2, 0, &["E02"]) {
922 ConditionResult::True => ConditionResult::False,
923 ConditionResult::False => ConditionResult::True,
924 ConditionResult::Unknown => ConditionResult::Unknown,
925 }
926 }
927
928 /// [138] Wenn SG5 LOC+172 (Meldepunkt) nicht vorhanden
929 fn evaluate_138(&self, ctx: &EvaluationContext) -> ConditionResult {
930 ctx.lacks_qualifier("LOC", 0, "172")
931 }
932
933 /// [147] Wenn in Anfrage vorhanden
934 /// EXTERNAL: Requires context from outside the message.
935 // 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)
936 fn evaluate_147(&self, ctx: &EvaluationContext) -> ConditionResult {
937 ctx.external.evaluate("present_in_request")
938 }
939
940 /// [165] Wenn bekannt
941 /// EXTERNAL: Requires context from outside the message.
942 fn evaluate_165(&self, ctx: &EvaluationContext) -> ConditionResult {
943 ctx.external.evaluate("date_known")
944 }
945
946 /// [166] Wenn vorhanden
947 /// EXTERNAL: Requires context from outside the message.
948 // 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)
949 fn evaluate_166(&self, ctx: &EvaluationContext) -> ConditionResult {
950 ctx.external.evaluate("data_available")
951 }
952
953 /// [200] Wenn BGM+Z26 (Vorläufige Meldung zur Marktraumumstellung) vorhanden
954 fn evaluate_200(&self, ctx: &EvaluationContext) -> ConditionResult {
955 ctx.has_qualifier("BGM", 0, "Z26")
956 }
957
958 /// [202] Wenn SG4 STS+E01+ZG2 (Status der Antwort: Gültiges Ergebnis nach der Datenprüfung) vorhanden
959 fn evaluate_202(&self, ctx: &EvaluationContext) -> ConditionResult {
960 ctx.has_qualified_value("STS", 0, "E01", 1, 0, &["ZG2"])
961 }
962
963 /// [205] Wenn SG9 QTY+Y02 (TUM Kundenwert) nicht vorhanden
964 fn evaluate_205(&self, ctx: &EvaluationContext) -> ConditionResult {
965 ctx.lacks_qualifier("QTY", 0, "Y02")
966 }
967
968 /// [209] Wenn im selben Segment im DE2379 der Code 303 vorhanden ist
969 // REVIEW: Checks if any DTM segment has DE2379 (elements[0][2]) equal to '303'. 'Im selben Segment' implies checking the format code component within the same DTM segment context; falls back to message-wide check without segment-level navigation. (medium confidence)
970 fn evaluate_209(&self, ctx: &EvaluationContext) -> ConditionResult {
971 let dtm_segs = ctx.find_segments("DTM");
972 ConditionResult::from(dtm_segs.iter().any(|s| {
973 s.elements
974 .first()
975 .and_then(|e| e.get(2))
976 .is_some_and(|v| v == "303")
977 }))
978 }
979
980 /// [212] Wenn im selben SG12 NAD DE3124 nicht vorhanden
981 // 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)
982 fn evaluate_212(&self, ctx: &EvaluationContext) -> ConditionResult {
983 let nads = ctx.find_segments("NAD");
984 ConditionResult::from(nads.iter().any(|s| {
985 s.elements
986 .get(2)
987 .map(|e| e.first().map(|v| v.is_empty()).unwrap_or(true))
988 .unwrap_or(true)
989 }))
990 }
991
992 /// [213] Wenn SG12 NAD+Z09 (Kunde des Lieferanten) vorhanden
993 fn evaluate_213(&self, ctx: &EvaluationContext) -> ConditionResult {
994 ctx.has_qualifier("NAD", 0, "Z09")
995 }
996
997 /// [216] Wenn CCI+++Z88 (Netznutzung) CAV+Z74:::Z08 (Netznutzungsvertrag: Direkter Vertrag zwischen Kunden und NB) vorhanden
998 // 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)
999 fn evaluate_216(&self, ctx: &EvaluationContext) -> ConditionResult {
1000 let nav = match ctx.navigator() {
1001 Some(n) => n,
1002 None => {
1003 let cavs = ctx.find_segments("CAV");
1004 return ConditionResult::from(cavs.iter().any(|s| {
1005 let e0 = s.elements.first();
1006 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1007 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1008 }));
1009 }
1010 };
1011 let sg8_count = nav.group_instance_count(&["SG4", "SG8"]);
1012 for i in 0..sg8_count {
1013 let sg10_count = nav.child_group_instance_count(&["SG4", "SG8"], i, "SG10");
1014 for j in 0..sg10_count {
1015 let ccis = nav.find_segments_in_child_group("CCI", &["SG4", "SG8"], i, "SG10", j);
1016 let has_cci_z88 = ccis.iter().any(|s| {
1017 s.elements
1018 .get(2)
1019 .and_then(|e| e.first())
1020 .is_some_and(|v| v == "Z88")
1021 });
1022 if has_cci_z88 {
1023 let cavs =
1024 nav.find_segments_in_child_group("CAV", &["SG4", "SG8"], i, "SG10", j);
1025 if cavs.iter().any(|s| {
1026 let e0 = s.elements.first();
1027 e0.and_then(|e| e.first()).is_some_and(|v| v == "Z74")
1028 && e0.and_then(|e| e.get(3)).is_some_and(|v| v == "Z08")
1029 }) {
1030 return ConditionResult::True;
1031 }
1032 }
1033 }
1034 }
1035 ConditionResult::False
1036 }
1037
1038 /// [219] Wenn an Marktlokation vorhanden
1039 /// EXTERNAL: Requires context from outside the message.
1040 // 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)
1041 fn evaluate_219(&self, ctx: &EvaluationContext) -> ConditionResult {
1042 ctx.external.evaluate("at_marktlokation")
1043 }
1044
1045 /// [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
1046 // 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)
1047 fn evaluate_230(&self, ctx: &EvaluationContext) -> ConditionResult {
1048 {
1049 // DTM+Z21 (Termin der Netznutzungsabrechnung): elements[0][1], format 106/104
1050 let z21_val = ctx
1051 .find_segments_with_qualifier("DTM", 0, "Z21")
1052 .into_iter()
1053 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1054 .unwrap_or_default();
1055 // DTM+Z09 (Nächste Netznutzungsabrechnung): elements[0][1], format 602
1056 let z09_val = ctx
1057 .find_segments_with_qualifier("DTM", 0, "Z09")
1058 .into_iter()
1059 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1060 .unwrap_or_default();
1061 // DTM+92 (Beginn zum): elements[0][1], format 303 (CCYYMMDDHHMM)
1062 let dtm92_val = match ctx
1063 .find_segments_with_qualifier("DTM", 0, "92")
1064 .into_iter()
1065 .find_map(|s| s.elements.first().and_then(|e| e.get(1)).cloned())
1066 {
1067 Some(v) if !v.is_empty() => v,
1068 _ => return ConditionResult::Unknown,
1069 };
1070 // Use the later of Z21 and Z09 as the end date of the Turnuszeitraum
1071 // Note: formats differ (Z21=106/104, Z09=602, DTM+92=303) — use first 6 chars (CCYYMM) for comparison
1072 let end_date = match (z21_val.is_empty(), z09_val.is_empty()) {
1073 (false, false) => {
1074 if z21_val >= z09_val {
1075 z21_val
1076 } else {
1077 z09_val
1078 }
1079 }
1080 (false, true) => z21_val,
1081 (true, false) => z09_val,
1082 (true, true) => return ConditionResult::Unknown,
1083 };
1084 // Compare first 6 chars (CCYYMM) — both reference dates have at least CCYYMM
1085 let end_ym = &end_date[..end_date.len().min(6)];
1086 let begin_ym = &dtm92_val[..dtm92_val.len().min(6)];
1087 if end_ym.len() < 6 || begin_ym.len() < 6 {
1088 return ConditionResult::Unknown;
1089 }
1090 ConditionResult::from(end_ym >= begin_ym)
1091 }
1092 }
1093
1094 /// [241] Wenn MP-ID in SG2 NAD+MR (Nachrichtenempfänger) in der Rolle MSB
1095 /// EXTERNAL: Requires context from outside the message.
1096 fn evaluate_241(&self, ctx: &EvaluationContext) -> ConditionResult {
1097 ctx.external.evaluate("recipient_is_msb")
1098 }
1099
1100 /// [249] Innerhalb eines SG4 IDE müssen alle DE1131 der SG4 STS+E01 den identischen Wert enthalten
1101 // 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)
1102 fn evaluate_249(&self, ctx: &EvaluationContext) -> ConditionResult {
1103 let sts_segs = ctx.find_segments("STS");
1104 let sts_e01: Vec<_> = sts_segs
1105 .iter()
1106 .filter(|s| {
1107 s.elements
1108 .first()
1109 .and_then(|e| e.first())
1110 .is_some_and(|v| v == "E01")
1111 })
1112 .collect();
1113 if sts_e01.is_empty() {
1114 return ConditionResult::Unknown;
1115 }
1116 let first_val = sts_e01
1117 .first()
1118 .and_then(|s| s.elements.get(2))
1119 .and_then(|e| e.get(1))
1120 .map(|v| v.as_str())
1121 .unwrap_or("");
1122 ConditionResult::from(sts_e01.iter().all(|s| {
1123 s.elements
1124 .get(2)
1125 .and_then(|e| e.get(1))
1126 .map(|v| v.as_str())
1127 .unwrap_or("")
1128 == first_val
1129 }))
1130 }
1131
1132 /// [252] Wenn DE0068 vorhanden
1133 // 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)
1134 fn evaluate_252(&self, ctx: &EvaluationContext) -> ConditionResult {
1135 let unh_segs = ctx.find_segments("UNH");
1136 ConditionResult::from(unh_segs.iter().any(|s| {
1137 s.elements
1138 .get(2)
1139 .and_then(|e| e.first())
1140 .is_some_and(|v| !v.is_empty())
1141 }))
1142 }
1143
1144 /// [257] Wenn in derselben SG8 SEQ+Z02 (OBIS-Daten der Marktlokation) das PIA+5+7-0?:33.86.0 vorhanden
1145 fn evaluate_257(&self, ctx: &EvaluationContext) -> ConditionResult {
1146 ctx.any_group_has_co_occurrence(
1147 "SEQ",
1148 0,
1149 &["Z02"],
1150 "PIA",
1151 1,
1152 0,
1153 &["7-0:33.86.0"],
1154 &["SG4", "SG8"],
1155 )
1156 }
1157
1158 /// [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
1159 /// EXTERNAL: Requires context from outside the message.
1160 fn evaluate_268(&self, ctx: &EvaluationContext) -> ConditionResult {
1161 ctx.external.evaluate("country_has_postal_code_requirement")
1162 }
1163
1164 /// [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 / ...
1165 // 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)
1166 fn evaluate_274(&self, ctx: &EvaluationContext) -> ConditionResult {
1167 let obis_suffixes = [
1168 ":3.0.0", ":6.0.0", ":3.1.0", ":6.1.0", ":3.2.0", ":6.2.0", ":13.2.0", ":16.2.0",
1169 ":1.0.0", ":2.0.0", ":4.0.0", ":5.0.0", ":11.2.0", ":12.2.0", ":14.2.0", ":15.2.0",
1170 ];
1171 let has_seq_pia_co = ctx.any_group_has_co_occurrence(
1172 "SEQ",
1173 0,
1174 &["Z20"],
1175 "PIA",
1176 0,
1177 0,
1178 &["5"],
1179 &["SG4", "SG8"],
1180 );
1181 if !matches!(has_seq_pia_co, ConditionResult::True) {
1182 return has_seq_pia_co;
1183 }
1184 let pias = ctx.find_segments_with_qualifier("PIA", 0, "5");
1185 ConditionResult::from(pias.iter().any(|s| {
1186 s.elements.get(1).and_then(|e| e.first()).is_some_and(|v| {
1187 v.starts_with("7-") && obis_suffixes.iter().any(|suf| v.ends_with(suf))
1188 })
1189 }))
1190 }
1191
1192 /// [276] Wenn SG4 DTM+92 (Beginn zum) vorhanden
1193 fn evaluate_276(&self, ctx: &EvaluationContext) -> ConditionResult {
1194 ctx.has_qualifier("DTM", 0, "92")
1195 }
1196
1197 /// [277] Wenn Zuordnung vorhanden
1198 // 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)
1199 fn evaluate_277(&self, ctx: &EvaluationContext) -> ConditionResult {
1200 ctx.has_qualifier("STS", 0, "Z18")
1201 }
1202
1203 /// [283] Wenn Empfänger der Nachricht der zum Nachrichtendatum aktuell zugeordnete Lieferant ist
1204 /// EXTERNAL: Requires context from outside the message.
1205 fn evaluate_283(&self, ctx: &EvaluationContext) -> ConditionResult {
1206 ctx.external.evaluate("recipient_is_current_supplier")
1207 }
1208
1209 /// [336] Wenn in Änderungsmeldung gefüllt
1210 /// EXTERNAL: Requires context from outside the message.
1211 // 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)
1212 fn evaluate_336(&self, ctx: &EvaluationContext) -> ConditionResult {
1213 ctx.external.evaluate("field_filled_in_amendment_message")
1214 }
1215
1216 /// [345] Wenn 33-stelliger Meldepunkt im SG5 LOC+172 (Meldepunkt) vorhanden
1217 fn evaluate_345(&self, ctx: &EvaluationContext) -> ConditionResult {
1218 let locs = ctx.find_segments_with_qualifier("LOC", 0, "172");
1219 ConditionResult::from(locs.iter().any(|s| {
1220 s.elements
1221 .get(1)
1222 .and_then(|e| e.first())
1223 .map(|id| id.len() == 33)
1224 .unwrap_or(false)
1225 }))
1226 }
1227
1228 /// [361] Wenn STS+E01++A03/ A04 nicht vorhanden
1229 fn evaluate_361(&self, ctx: &EvaluationContext) -> ConditionResult {
1230 let found = ctx
1231 .find_segments_with_qualifier("STS", 0, "E01")
1232 .iter()
1233 .any(|s| {
1234 s.elements
1235 .get(2)
1236 .and_then(|e| e.first())
1237 .map(|v| v == "A03" || v == "A04")
1238 .unwrap_or(false)
1239 });
1240 ConditionResult::from(!found)
1241 }
1242
1243 /// [362] Wenn STS+E01++A03/ A17 nicht vorhanden
1244 fn evaluate_362(&self, ctx: &EvaluationContext) -> ConditionResult {
1245 let found = ctx
1246 .find_segments_with_qualifier("STS", 0, "E01")
1247 .iter()
1248 .any(|s| {
1249 s.elements
1250 .get(2)
1251 .and_then(|e| e.first())
1252 .map(|v| v == "A03" || v == "A17")
1253 .unwrap_or(false)
1254 });
1255 ConditionResult::from(!found)
1256 }
1257
1258 /// [367] Wenn SG4 STS+E01++A04 vorhanden
1259 fn evaluate_367(&self, ctx: &EvaluationContext) -> ConditionResult {
1260 ctx.has_qualified_value("STS", 0, "E01", 2, 0, &["A04"])
1261 }
1262
1263 /// [368] Es sind alle Codes aus der Codeliste G_0009 erlaubt
1264 fn evaluate_368(&self, _ctx: &EvaluationContext) -> ConditionResult {
1265 ConditionResult::True
1266 }
1267
1268 /// [427] Messprodukt-Code aus Kapitel 3 "Codeliste der Standard-Messprodukte Gas" der Codeliste der Konfigurationen
1269 /// EXTERNAL: Requires context from outside the message.
1270 fn evaluate_427(&self, ctx: &EvaluationContext) -> ConditionResult {
1271 ctx.external.evaluate("messprodukt_code_gas_valid")
1272 }
1273
1274 /// [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
1275 // 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)
1276 fn evaluate_442(&self, ctx: &EvaluationContext) -> ConditionResult {
1277 let result = ctx.any_group_has_co_occurrence(
1278 "SEQ",
1279 0,
1280 &["Z09"],
1281 "RFF",
1282 0,
1283 0,
1284 &["MG"],
1285 &["SG4", "SG8"],
1286 );
1287 match result {
1288 ConditionResult::True => ConditionResult::False,
1289 ConditionResult::False => ConditionResult::True,
1290 ConditionResult::Unknown => ConditionResult::Unknown,
1291 }
1292 }
1293
1294 /// [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
1295 /// EXTERNAL: Requires context from outside the message.
1296 fn evaluate_490(&self, ctx: &EvaluationContext) -> ConditionResult {
1297 ctx.external.evaluate("date_in_mesz_period")
1298 }
1299
1300 /// [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
1301 /// EXTERNAL: Requires context from outside the message.
1302 fn evaluate_491(&self, ctx: &EvaluationContext) -> ConditionResult {
1303 ctx.external.evaluate("date_in_mez_period")
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}