Skip to content

Commit 66c01ca

Browse files
samirromdhanisamirromdhani
committed
feat / deconstructing compas-flow
Signed-off-by: Samir Romdhani <[email protected]>
1 parent 10f72f9 commit 66c01ca

19 files changed

+41
-1608
lines changed

‎sct-commons/src/main/java/org/lfenergy/compas/sct/commons/ExtRefEditorService.java‎

Lines changed: 3 additions & 135 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// SPDX-FileCopyrightText: 2023 RTE FRANCE
1+
// SPDX-FileCopyrightText: 2023 2024 RTE FRANCE
22
//
33
// SPDX-License-Identifier: Apache-2.0
44

@@ -20,16 +20,13 @@
2020
import org.lfenergy.compas.sct.commons.scl.ied.IEDAdapter;
2121
import org.lfenergy.compas.sct.commons.scl.ldevice.LDeviceAdapter;
2222
import org.lfenergy.compas.sct.commons.scl.ln.AbstractLNAdapter;
23-
import org.lfenergy.compas.sct.commons.scl.ln.LN0Adapter;
2423
import org.lfenergy.compas.sct.commons.util.ActiveStatus;
2524
import org.lfenergy.compas.sct.commons.util.PrivateEnum;
2625
import org.lfenergy.compas.sct.commons.util.PrivateUtils;
2726
import org.lfenergy.compas.sct.commons.util.Utils;
2827

2928
import java.math.BigInteger;
3029
import java.util.*;
31-
import java.util.function.BinaryOperator;
32-
import java.util.function.Function;
3330
import java.util.stream.Collectors;
3431

3532
import static org.apache.commons.lang3.StringUtils.*;
@@ -38,18 +35,10 @@
3835
@RequiredArgsConstructor
3936
public class ExtRefEditorService implements ExtRefEditor {
4037
private static final String INVALID_OR_MISSING_ATTRIBUTES_IN_EXT_REF_BINDING_INFO = "Invalid or missing attributes in ExtRef binding info";
41-
private static final Map<String, String> voltageCodification = Map.of(
42-
"3", "HT",
43-
"4", "HT",
44-
"5", "THT",
45-
"6", "THT",
46-
"7", "THT"
47-
);
4838

4939
private final IedService iedService;
5040
private final LdeviceService ldeviceService;
5141
private final LnEditor lnEditor;
52-
private final ExtRefService extRefService;
5342
private final DataTypeTemplatesService dataTypeTemplatesService;
5443

5544
/**
@@ -274,31 +263,6 @@ public TExtRef updateExtRefSource(SCL scd, ExtRefInfo extRefInfo) throws ScdExce
274263
return anLNAdapter.updateExtRefSource(extRefInfo);
275264
}
276265

277-
@Override
278-
public List<SclReportItem> updateAllExtRefIedNames(SCL scd) {
279-
SclRootAdapter sclRootAdapter = new SclRootAdapter(scd);
280-
List<SclReportItem> iedErrors = validateIed(sclRootAdapter);
281-
if (!iedErrors.isEmpty()) {
282-
return iedErrors;
283-
}
284-
Map<String, IEDAdapter> icdSystemVersionToIed = sclRootAdapter.streamIEDAdapters()
285-
.collect(Collectors.toMap(
286-
iedAdapter -> iedAdapter.getCompasICDHeader()
287-
.map(TCompasICDHeader::getICDSystemVersionUUID)
288-
.orElseThrow(), // Value presence is checked by method validateIed called above
289-
Function.identity()
290-
));
291-
292-
return sclRootAdapter.streamIEDAdapters()
293-
.flatMap(IEDAdapter::streamLDeviceAdapters)
294-
.filter(LDeviceAdapter::hasLN0)
295-
.map(LDeviceAdapter::getLN0Adapter)
296-
.filter(LN0Adapter::hasInputs)
297-
.map(LN0Adapter::getInputsAdapter)
298-
.map(inputsAdapter -> inputsAdapter.updateAllExtRefIedNames(icdSystemVersionToIed))
299-
.flatMap(List::stream).toList();
300-
}
301-
302266
@Override
303267
public List<SclReportItem> manageBindingForLDEPF(SCL scd, EPF epf) {
304268
List<SclReportItem> sclReportItems = new ArrayList<>();
@@ -456,116 +420,20 @@ private String computeDaiValue(AbstractLNAdapter<?> lnAdapter, TExtRef extRef, S
456420
return extRef.getIedName() +
457421
extRef.getLdInst() + "/" +
458422
trimToEmpty(extRef.getPrefix()) +
459-
extRef.getLnClass().get(0) +
423+
extRef.getLnClass().getFirst() +
460424
trimToEmpty(extRef.getLnInst()) + "." +
461425
extRef.getDoName() + "." + Q_DA_NAME;
462426
} else {
463427
return extRef.getIedName() +
464428
extRef.getLdInst() + "/" +
465429
trimToEmpty(extRef.getPrefix()) +
466-
extRef.getLnClass().get(0) +
430+
extRef.getLnClass().getFirst() +
467431
trimToEmpty(extRef.getLnInst()) + "." +
468432
extRef.getDoName() + "." +
469433
daName;
470434
}
471435
}
472436

473-
@Override
474-
public void debindCompasFlowsAndExtRefsBasedOnVoltageLevel(SCL scd) {
475-
scd.getSubstation()
476-
.stream()
477-
.flatMap(tSubstation -> tSubstation.getVoltageLevel().stream())
478-
.map(TVoltageLevel::getName)
479-
.filter(tVoltageLevelName -> !"0".equals(tVoltageLevelName))
480-
.forEach(tVoltageLevelName -> scd.getIED().stream()
481-
.flatMap(ldeviceService::getLdevices)
482-
.filter(TLDevice::isSetLN0)
483-
.filter(tlDevice -> tlDevice.getLN0().isSetInputs())
484-
.forEach(tlDevice -> {
485-
String flowSource = voltageCodification.get(tVoltageLevelName);
486-
extRefService.getCompasFlows(tlDevice)
487-
.filter(TCompasFlow::isSetFlowSourceVoltageLevel)
488-
.filter(TCompasFlow::isSetExtRefiedName)
489-
.forEach(tCompasFlow -> {
490-
if (!tCompasFlow.getFlowSourceVoltageLevel().equals(flowSource)) {
491-
//debind extRefs correspondind to compas flow
492-
extRefService.getMatchingExtRefs(tlDevice, tCompasFlow)
493-
.forEach(extRefService::clearExtRefBinding);
494-
//debind all compas flow
495-
extRefService.clearCompasFlowBinding(tCompasFlow);
496-
}
497-
});
498-
})
499-
);
500-
}
501-
502-
503-
@Override
504-
public List<SclReportItem> updateIedNameBasedOnLnode(SCL scl) {
505-
Map<TopoKey, TBay> bayByTopoKey = scl.getSubstation().stream()
506-
.flatMap(tSubstation -> tSubstation.getVoltageLevel().stream())
507-
.flatMap(tVoltageLevel -> tVoltageLevel.getBay().stream())
508-
.map(tBay -> PrivateUtils.extractCompasPrivate(tBay, TCompasTopo.class)
509-
.filter(tCompasTopo -> isNotBlank(tCompasTopo.getNode()) && Objects.nonNull(tCompasTopo.getNodeOrder()))
510-
.map(tCompasTopo -> new BayTopoKey(tBay, new TopoKey(tCompasTopo.getNode(), tCompasTopo.getNodeOrder())))
511-
)
512-
.flatMap(Optional::stream)
513-
.collect(Collectors.toMap(BayTopoKey::topoKey, BayTopoKey::bay));
514-
515-
List<SclReportItem> sclReportItems = new ArrayList<>();
516-
scl.getIED().stream()
517-
.flatMap(ldeviceService::getLdevices)
518-
.forEach(tlDevice ->
519-
extRefService.getCompasFlows(tlDevice)
520-
.filter(tCompasFlow -> Objects.nonNull(tCompasFlow.getFlowSourceBayNode()) && Objects.nonNull(tCompasFlow.getFlowSourceBayNodeOrder()))
521-
.forEach(tCompasFlow ->
522-
Optional.ofNullable(bayByTopoKey.get(new TopoKey(tCompasFlow.getFlowSourceBayNode().toString(), tCompasFlow.getFlowSourceBayNodeOrder())))
523-
.flatMap(tBay -> tBay.getFunction().stream()
524-
.flatMap(tFunction -> tFunction.getLNode().stream())
525-
.filter(tlNode -> Objects.equals(tlNode.getLdInst(), tCompasFlow.getExtRefldinst())
526-
&& Objects.equals(tlNode.getLnInst(), tCompasFlow.getExtReflnInst())
527-
&& Utils.lnClassEquals(tlNode.getLnClass(), tCompasFlow.getExtReflnClass())
528-
&& Objects.equals(tlNode.getPrefix(), tCompasFlow.getExtRefprefix()))
529-
.filter(tlNode -> {
530-
Optional<TCompasICDHeader> tCompasICDHeader = PrivateUtils.extractCompasPrivate(tlNode, TCompasICDHeader.class);
531-
if (tCompasICDHeader.isPresent()) {
532-
return Objects.equals(tCompasFlow.getFlowSourceIEDType(), tCompasICDHeader.get().getIEDType())
533-
&& Objects.equals(tCompasFlow.getFlowIEDSystemVersioninstance(), tCompasICDHeader.get().getIEDSystemVersioninstance())
534-
&& Objects.equals(tCompasFlow.getFlowSourceIEDredundancy(), tCompasICDHeader.get().getIEDredundancy());
535-
} else {
536-
sclReportItems.add(SclReportItem.error("", ("The substation LNode with following attributes : IedName:%s / LdInst:%s / LnClass:%s / LnInst:%s " +
537-
"does not contain the needed (COMPAS - ICDHeader) private")
538-
.formatted(tlNode.getIedName(), tlNode.getLdInst(), tlNode.getLnClass().getFirst(), tlNode.getLnInst())));
539-
return false;
540-
}
541-
})
542-
.map(TLNode::getIedName)
543-
.reduce(checkOnlyOneIed(tCompasFlow, tBay, sclReportItems))
544-
)
545-
.ifPresentOrElse(iedName -> {
546-
extRefService.getMatchingExtRefs(tlDevice, tCompasFlow).forEach(tExtRef -> tExtRef.setIedName(iedName));
547-
tCompasFlow.setExtRefiedName(iedName);
548-
},
549-
() -> {
550-
extRefService.getMatchingExtRefs(tlDevice, tCompasFlow).forEach(extRefService::clearExtRefBinding);
551-
extRefService.clearCompasFlowBinding(tCompasFlow);
552-
}
553-
)
554-
)
555-
);
556-
return sclReportItems;
557-
}
558-
559-
private static BinaryOperator<String> checkOnlyOneIed(TCompasFlow tCompasFlow, TBay tBay, List<SclReportItem> sclReportItems) {
560-
return (iedName1, iedName2) -> {
561-
sclReportItems.add(SclReportItem.error("",
562-
("Several LNode@IedName ('%s', '%s') are found in the bay '%s' for the following compas-flow attributes :" +
563-
" @FlowSourceIEDType '%s' @FlowSourceIEDredundancy '%s' @FlowIEDSystemVersioninstance '%s'").
564-
formatted(iedName1, iedName2, tBay.getName(), tCompasFlow.getFlowSourceIEDType(), tCompasFlow.getFlowSourceIEDredundancy(), tCompasFlow.getFlowIEDSystemVersioninstance())));
565-
return iedName1;
566-
};
567-
}
568-
569437
record TopoKey(String FlowNode, BigInteger FlowNodeOrder) {
570438
}
571439

‎sct-commons/src/main/java/org/lfenergy/compas/sct/commons/api/ExtRefEditor.java‎

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
* <ol>
2222
* <li>{@link ExtRefEditor#updateExtRefBinders <em>Update the <b>TExtRef </b> reference object for given <b>ExtRefBindingInfo </b> model</em>}</li>
2323
* <li>{@link ExtRefEditor#updateExtRefSource <em>Update the <b>TExtRef </b> reference object for given <b>ExtRefSourceInfo </b> model</em>}</li>
24-
* <li>{@link ExtRefEditor#updateAllExtRefIedNames <em>Update the iedName attribute in all <b>TExtRef</b></em>}</li>
2524
* <li>{@link ExtRefEditor#manageBindingForLDEPF <em>Manage <b>TExtRef</b> Binding For LDevice (inst=LDEPF) within LDEPF configuration</em>}</li>
2625
* </ol>
2726
* </ul>
@@ -47,13 +46,6 @@ public interface ExtRefEditor {
4746
*/
4847
TExtRef updateExtRefSource(SCL scd, ExtRefInfo extRefInfo) throws ScdException;
4948

50-
/**
51-
* Updates iedName attribute of all ExtRefs in the Scd.
52-
*
53-
* @return list of encountered errors
54-
*/
55-
List<SclReportItem> updateAllExtRefIedNames(SCL scd);
56-
5749
/**
5850
* ExtRef Binding For LDevice (inst=LDEPF) that matching EPF configuration
5951
*
@@ -71,18 +63,4 @@ public interface ExtRefEditor {
7163
*/
7264
void epfPostProcessing(SCL scd);
7365

74-
/**
75-
* Debinding of Private CompasFlows and ExtRef signals based on voltageLevel
76-
*
77-
* @param scd SCL file in which ExtRef and Private CompasFlow should be debind
78-
*/
79-
void debindCompasFlowsAndExtRefsBasedOnVoltageLevel(SCL scd);
80-
81-
/**
82-
* Update compas:Flow.ExtRefiedName and ExtRef.iedName, based on Substation LNode iedName
83-
* @param scd SCL
84-
* @return list of encoutered errors
85-
*/
86-
List<SclReportItem> updateIedNameBasedOnLnode(SCL scd);
87-
8866
}

‎sct-commons/src/main/java/org/lfenergy/compas/sct/commons/scl/ExtRefService.java‎

Lines changed: 1 addition & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* // SPDX-FileCopyrightText: 2023 RTE FRANCE
2+
* // SPDX-FileCopyrightText: 2023 2024 RTE FRANCE
33
* //
44
* // SPDX-License-Identifier: Apache-2.0
55
*/
@@ -52,18 +52,6 @@ public Stream<TCompasFlow> getMatchingCompasFlows(TInputs inputs, TExtRef tExtRe
5252
.filter(compasFlow -> isMatchingExtRef(compasFlow, tExtRef));
5353
}
5454

55-
/**
56-
* Retrieves ExtRefs corresponding to given CompasFlow
57-
*
58-
* @param tlDevice LDevice containing CompasFlows and ExtRefs
59-
* @param tCompasFlow corresponding to Extrefs we are searching
60-
* @return stream of matching ExtRefs
61-
*/
62-
public Stream<TExtRef> getMatchingExtRefs(TLDevice tlDevice, TCompasFlow tCompasFlow) {
63-
return getExtRefs(tlDevice)
64-
.filter(tExtRef -> isMatchingExtRef(tCompasFlow, tExtRef));
65-
}
66-
6755
/**
6856
* Debind ExtRef
6957
*
@@ -85,18 +73,6 @@ public void clearExtRefBinding(TExtRef extRef) {
8573
extRef.unsetSrcLNClass();
8674
}
8775

88-
/**
89-
* Debind CompasFlow
90-
*
91-
* @param tCompasFlow to debind
92-
*/
93-
public void clearCompasFlowBinding(TCompasFlow tCompasFlow) {
94-
tCompasFlow.setExtRefiedName(null);
95-
tCompasFlow.setExtRefldinst(null);
96-
tCompasFlow.setExtReflnClass(null);
97-
tCompasFlow.setExtReflnInst(null);
98-
tCompasFlow.setExtRefprefix(null);
99-
}
10076

10177
/**
10278
* Check if extRef matches CompasFlow

0 commit comments

Comments
 (0)