| @@ 92-100 (lines=9) @@ | ||
| 89 | 'id' => $entityId, |
|
| 90 | 'source' => $params['entity'] |
|
| 91 | ]; |
|
| 92 | foreach ($mapper->find('_temporal_reference_aggregate', $aggregateParams) as $aggregate) { |
|
| 93 | foreach ($aggregates as $candidate) { |
|
| 94 | if ($candidate->begin == $aggregate->begin && $candidate->end == $aggregate->end && $candidate->data == $aggregate->data) { |
|
| 95 | $candidate->exists = true; |
|
| 96 | continue 2; |
|
| 97 | } |
|
| 98 | } |
|
| 99 | $mapper->remove($aggregate); |
|
| 100 | } |
|
| 101 | foreach ($aggregates as $aggregate) { |
|
| 102 | if ($aggregate->exists) { |
|
| 103 | continue; |
|
| @@ 271-279 (lines=9) @@ | ||
| 268 | $state->data = array_merge($state->data, $change->data); |
|
| 269 | $state->exists = false; |
|
| 270 | }); |
|
| 271 | foreach ($mapper->find('_temporal_override_aggregate', $params) as $aggregate) { |
|
| 272 | foreach ($states as $state) { |
|
| 273 | if ($state->begin == $aggregate->begin && $state->end == $aggregate->end && $state->data == $aggregate->data) { |
|
| 274 | $state->exists = true; |
|
| 275 | continue 2; |
|
| 276 | } |
|
| 277 | } |
|
| 278 | $mapper->remove($aggregate); |
|
| 279 | } |
|
| 280 | foreach ($states as $aggregate) { |
|
| 281 | if ($aggregate->exists) { |
|
| 282 | continue; |
|