Merge branch 'develop' into epic/FOUR-29101

Author: sanjacornelius

ProcessMaker/Console/Kernel.php

@@ -24,7 +24,8 @@ protected function schedule(Schedule $schedule)
     {
         $schedule->command('bpmn:timer')
                  ->everyMinute()
-                 ->onOneServer();
+                 ->onOneServer()
+                 ->withoutOverlapping(config('app.scheduler.bpmn_timer_overlap_minutes', 5));
 
         $schedule->command('processmaker:sync-recommendations --queue')
                  ->daily()

ProcessMaker/Events/CaseDeleted.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace ProcessMaker\Events;
+
+use Carbon\Carbon;
+use Illuminate\Foundation\Events\Dispatchable;
+use ProcessMaker\Contracts\SecurityLogEventInterface;
+use ProcessMaker\Traits\FormatSecurityLogChanges;
+
+class CaseDeleted implements SecurityLogEventInterface
+{
+    use Dispatchable;
+    use FormatSecurityLogChanges;
+
+    private string $caseNumber;
+
+    private string $caseTitle;
+
+    /**
+     * Create a new event instance.
+     *
+     * @return void
+     */
+    public function __construct(string $caseNumber, string $caseTitle)
+    {
+        $this->caseNumber = $caseNumber;
+        $this->caseTitle = $caseTitle;
+    }
+
+    /**
+     * Get specific data related to the event
+     *
+     * @return array
+     */
+    public function getData(): array
+    {
+        return [
+            'name' => $this->caseTitle,
+            'case_number' => $this->caseNumber,
+            'deleted_at' => Carbon::now(),
+        ];
+    }
+
+    /**
+     * Get specific data related to the event
+     *
+     * @return array
+     */
+    public function getChanges(): array
+    {
+        return [
+            'case_number' => $this->caseNumber,
+        ];
+    }
+
+    /**
+     * Get the Event name
+     *
+     * @return string
+     */
+    public function getEventName(): string
+    {
+        return 'CaseDeleted';
+    }
+}

ProcessMaker/Http/Controllers/Api/Actions/Cases/DeleteCase.php

@@ -0,0 +1,118 @@
+<?php
+
+namespace ProcessMaker\Http\Controllers\Api\Actions\Cases;
+
+use Illuminate\Support\Facades\DB;
+use ProcessMaker\Events\CaseDeleted;
+use ProcessMaker\Models\CaseStarted;
+use ProcessMaker\Models\ProcessRequest;
+use ProcessMaker\Models\ProcessRequestToken;
+use ProcessMaker\Models\TaskDraft;
+
+class DeleteCase
+{
+    use DeletesCaseRecords;
+
+    public function __invoke(string $caseNumber): void
+    {
+        $requestIds = $this->getRequestIds($caseNumber);
+
+        if ($requestIds === []) {
+            abort(404);
+        }
+
+        $caseTitle = $this->getCaseTitle($caseNumber);
+        $tokenIds = $this->getRequestTokenIds($requestIds);
+
+        DB::transaction(function () use ($caseNumber, $requestIds, $tokenIds) {
+            $this->deleteInboxRuleLogs($tokenIds);
+            $this->deleteInboxRules($tokenIds);
+            $this->deleteProcessRequestLocks($requestIds, $tokenIds);
+            $this->deleteProcessAbeRequestTokens($requestIds, $tokenIds);
+            $this->deleteScheduledTasks($requestIds, $tokenIds);
+            $this->deleteEllucianEthosSyncTasks($tokenIds);
+            $draftIds = $this->getTaskDraftIds($tokenIds);
+            $this->deleteTaskDraftMedia($draftIds);
+            $this->deleteTaskDrafts($tokenIds);
+            $this->deleteComments($caseNumber, $requestIds, $tokenIds);
+            $this->deleteNotifications($requestIds);
+            $this->deleteRequestMedia($requestIds);
+            $this->deleteCaseNumbers($requestIds);
+            $this->deleteCasesStarted($caseNumber);
+            $this->deleteCasesParticipated($caseNumber);
+            $this->deleteProcessRequestTokens($requestIds);
+            $this->deleteProcessRequests($requestIds);
+        });
+
+        CaseDeleted::dispatch($caseNumber, $caseTitle);
+
+        $this->dispatchSavedSearchRecount();
+    }
+
+    private function getRequestIds(string $caseNumber): array
+    {
+        return ProcessRequest::query()
+            ->where('case_number', $caseNumber)
+            ->pluck('id')
+            ->all();
+    }
+
+    private function getCaseTitle(string $caseNumber): string
+    {
+        $caseStarted = CaseStarted::query()
+            ->where('case_number', $caseNumber)
+            ->first();
+
+        if ($caseStarted) {
+            return $caseStarted->case_title ?? "Case #{$caseNumber}";
+        } else {
+            // If CaseStarted doesn't exist, get case title from the first ProcessRequest
+            $firstRequest = ProcessRequest::query()
+            ->where('case_number', $caseNumber)
+            ->whereNull('parent_request_id')
+            ->first();
+
+            return $firstRequest?->case_title ?? "Case #{$caseNumber}";
+        }
+    }
+
+    private function getRequestTokenIds(array $requestIds): array
+    {
+        if ($requestIds === []) {
+            return [];
+        }
+
+        return ProcessRequestToken::query()
+            ->whereIn('process_request_id', $requestIds)
+            ->pluck('id')
+            ->all();
+    }
+
+    private function getTaskDraftIds(array $tokenIds): array
+    {
+        if ($tokenIds === []) {
+            return [];
+        }
+
+        return TaskDraft::query()
+            ->whereIn('task_id', $tokenIds)
+            ->pluck('id')
+            ->all();
+    }
+
+    private function dispatchSavedSearchRecount(): void
+    {
+        if (!config('savedsearch.count', false)) {
+            return;
+        }
+
+        $jobClass = 'ProcessMaker\\Package\\SavedSearch\\Jobs\\RecountAllSavedSearches';
+        if (!class_exists($jobClass)) {
+            return;
+        }
+
+        DB::afterCommit(static function () use ($jobClass): void {
+            $jobClass::dispatch(['request', 'task']);
+        });
+    }
+}