QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 05:01:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

CE-1955 propagate errors from child (association) records up to main record

Browse Source
This commit is contained in:
darin.kelkhoff
2024-12-26 18:53:27 -06:00
parent 7e475e2c18
commit 6b7d3ac26d
1 changed files with 36 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/bulk/insert/BulkInsertTransformStep.java
View File

@ -197,6 +197,14 @@ public class BulkInsertTransformStep extends AbstractTransformStep
List<QRecord> recordsWithSomeErrors = new ArrayList<>();
for(QRecord record : runBackendStepInput.getRecords())
{
List<QErrorMessage> errorsFromAssociations = getErrorsFromAssociations(record);
if(CollectionUtils.nullSafeHasContents(errorsFromAssociations))
{
List<QErrorMessage> recordErrors = Objects.requireNonNullElseGet(record.getErrors(), () -> new ArrayList<>());
recordErrors.addAll(errorsFromAssociations);
record.setErrors(recordErrors);
}
if(CollectionUtils.nullSafeHasContents(record.getErrors()))
{
recordsWithSomeErrors.add(record);
@ -351,6 +359,34 @@ public class BulkInsertTransformStep extends AbstractTransformStep
/***************************************************************************
**
***************************************************************************/
private List<QErrorMessage> getErrorsFromAssociations(QRecord record)
{
List<QErrorMessage> rs = null;
for(Map.Entry<String, List<QRecord>> entry : CollectionUtils.nonNullMap(record.getAssociatedRecords()).entrySet())
{
for(QRecord associatedRecord : CollectionUtils.nonNullList(entry.getValue()))
{
if(CollectionUtils.nullSafeHasContents(associatedRecord.getErrors()))
{
rs = Objects.requireNonNullElseGet(rs, () -> new ArrayList<>());
rs.addAll(associatedRecord.getErrors());
List<QErrorMessage> childErrors = getErrorsFromAssociations(associatedRecord);
if(CollectionUtils.nullSafeHasContents(childErrors))
{
rs.addAll(childErrors);
}
}
}
}
return (rs);
}
/***************************************************************************
**
***************************************************************************/