Compare commits

...

3 Commits

Author SHA1 Message Date
Ali Oezyetimoglu
0908cbc96e RED-7679: changed stream to get row number to differ between same named components 2023-10-27 17:08:16 +02:00
Ali Oezyetimoglu
aaed6f229b RED-7679: logs for debugging 2023-10-27 13:16:31 +02:00
Ali Oezyetimoglu
e79bbe0584 RED-7679: Changed joining from same table row 2023-10-26 16:13:57 +02:00

View File

@ -100,9 +100,15 @@ public class ComponentCreationService {
*/ */
public void create(String ruleIdentifier, String name, String value, String valueDescription, Collection<Entity> references) { public void create(String ruleIdentifier, String name, String value, String valueDescription, Collection<Entity> references) {
System.out.println("AAAA: " + ruleIdentifier + " ; " + name + " ; " + value + " ; " + valueDescription + " ; " + references);
referencedEntities.addAll(references); referencedEntities.addAll(references);
kieSession.insert(Component.builder().matchedRule(RuleIdentifier.fromString(ruleIdentifier)).name(name).value(value).valueDescription(valueDescription) kieSession.insert(Component.builder()
.matchedRule(RuleIdentifier.fromString(ruleIdentifier))
.name(name)
.value(value)
.valueDescription(valueDescription)
.references(new LinkedList<>(references)) .references(new LinkedList<>(references))
.build()); .build());
} }
@ -354,7 +360,9 @@ public class ComponentCreationService {
*/ */
public void createComponentsForUnMappedEntities(String ruleIdentifier, Collection<Entity> entities) { public void createComponentsForUnMappedEntities(String ruleIdentifier, Collection<Entity> entities) {
entities.stream().filter(entity -> !referencedEntities.contains(entity)).sorted(EntityComparators.first()) entities.stream()
.filter(entity -> !referencedEntities.contains(entity))
.sorted(EntityComparators.first())
.forEach(entity -> create(ruleIdentifier, entity.getType(), entity.getValue(), "Unmapped Entity", List.of(entity))); .forEach(entity -> create(ruleIdentifier, entity.getType(), entity.getValue(), "Unmapped Entity", List.of(entity)));
} }
@ -422,21 +430,20 @@ public class ComponentCreationService {
} }
groupedEntities.stream() groupedEntities.stream()
.filter(entity -> !(entity.getContainingNode() instanceof TableCell))
.forEach(entity -> create(ruleIdentifier, name, entity.getValue(), valueDescription, entity));
groupedEntities.stream()
.filter(entity -> entity.getContainingNode() instanceof TableCell)
.collect(Collectors.groupingBy(entity -> ((TableCell) entity.getContainingNode()).getRow())) .collect(Collectors.groupingBy(entity -> ((TableCell) entity.getContainingNode()).getRow()))
.entrySet() .entrySet()
.stream() .stream()
.sorted(Comparator.comparingInt(Map.Entry::getKey)) .sorted(Comparator.comparingInt(Map.Entry::getKey))
.map(Map.Entry::getValue) // .map(Map.Entry::getValue)
.forEach(entitiesInSameRow -> create(ruleIdentifier, .forEach(integerListEntry -> {
name, var rowNumber = integerListEntry.getKey();
entitiesInSameRow.stream().sorted(Comparator.comparing(Entity::getType).reversed()).map(Entity::getValue).collect(Collectors.joining(", ")), var entitiesInSameRow = integerListEntry.getValue();
valueDescription, create(ruleIdentifier,
entitiesInSameRow)); name + rowNumber,
entitiesInSameRow.stream().sorted(EntityComparators.first()).map(Entity::getValue).collect(Collectors.joining(", ")),
valueDescription,
entitiesInSameRow);
});
}); });
} }
@ -479,7 +486,9 @@ public class ComponentCreationService {
*/ */
public void create(String ruleIdentifier, String name, String value) { public void create(String ruleIdentifier, String name, String value) {
kieSession.insert(Component.builder().matchedRule(RuleIdentifier.fromString(ruleIdentifier)).name(name) kieSession.insert(Component.builder()
.matchedRule(RuleIdentifier.fromString(ruleIdentifier))
.name(name)
.value(value) .value(value)
.valueDescription("") .valueDescription("")
.references(Collections.emptyList()) .references(Collections.emptyList())