| @@ 101-110 (lines=10) @@ | ||
| 98 | } |
|
| 99 | $mapper->remove($aggregate); |
|
| 100 | } |
|
| 101 | foreach ($aggregates as $aggregate) { |
|
| 102 | if ($aggregate->exists) { |
|
| 103 | continue; |
|
| 104 | } |
|
| 105 | $mapper->create('_temporal_reference_aggregate', array_merge($aggregateParams, [ |
|
| 106 | 'begin' => $aggregate->begin, |
|
| 107 | 'end' => $aggregate->end, |
|
| 108 | 'data' => $aggregate->data, |
|
| 109 | ])); |
|
| 110 | } |
|
| 111 | } |
|
| 112 | } |
|
| 113 | ||
| @@ 280-289 (lines=10) @@ | ||
| 277 | } |
|
| 278 | $mapper->remove($aggregate); |
|
| 279 | } |
|
| 280 | foreach ($states as $aggregate) { |
|
| 281 | if ($aggregate->exists) { |
|
| 282 | continue; |
|
| 283 | } |
|
| 284 | $mapper->create('_temporal_override_aggregate', array_merge($params, [ |
|
| 285 | 'begin' => $aggregate->begin, |
|
| 286 | 'end' => $aggregate->end, |
|
| 287 | 'data' => $aggregate->data, |
|
| 288 | ])); |
|
| 289 | } |
|
| 290 | } |
|
| 291 | ||
| 292 | private function generateStates($changes, $callback) |
|