diff --git a/app/Services/Pacs/Sync/Pipes/InsertStudies.php b/app/Services/Pacs/Sync/Pipes/InsertStudies.php index f52f2df..e9b6532 100644 --- a/app/Services/Pacs/Sync/Pipes/InsertStudies.php +++ b/app/Services/Pacs/Sync/Pipes/InsertStudies.php @@ -20,6 +20,10 @@ public function __invoke(StudiesSync $sync, Closure $next): StudiesSync } $payload = $sync->transformData($study); + if (empty($payload)) { + continue; + } + $row = Study::create($payload['study']); $payload['details']['study_id'] = $row->id; $payload['details']['orthanc_uuid'] = $orthanc_uuid; diff --git a/app/Services/Pacs/Sync/Pipes/UpdateStudies.php b/app/Services/Pacs/Sync/Pipes/UpdateStudies.php index 93e6f38..4145c6f 100644 --- a/app/Services/Pacs/Sync/Pipes/UpdateStudies.php +++ b/app/Services/Pacs/Sync/Pipes/UpdateStudies.php @@ -25,6 +25,10 @@ public function __invoke(StudiesSync $sync, Closure $next): StudiesSync } $payload = $sync->transformData($study); + if (empty($payload)) { + continue; + } + unset($payload['study']['orthanc_uuid']); $payload['study']['updated_at'] = now(); DB::table('studies')->where('id', $study_id)->update($payload['study']);