Complete grouped collaborative editorial queues and native review coverage

app/Http/Controllers/InvestmentStructureController.php

@@ -11,6 +11,7 @@ use App\Models\ValueChain;
 use App\Services\ClusterCompetitiveness;
 use App\Services\InvestmentGeography;
 use App\Services\PortalAudit;
+use App\Services\PortalEditorialSubjects;
 use App\Services\PortalEditorialWorkflow;
 use Illuminate\Http\RedirectResponse;
 use Illuminate\Http\Request;
@@ -52,12 +53,15 @@ class InvestmentStructureController extends Controller
         $editorialDossier = $id ? app(PortalEditorialWorkflow::class)->structureDossier($structure, $id) : null;
         if ($record && $editorialDossier) {
             $record = app(PortalEditorialWorkflow::class)->workingStructure($record, $editorialDossier);
+        } elseif ($record && app(PortalEditorialSubjects::class)->available()) {
+            $record = clone $record;
+            $record->forceFill(get_object_vars(app(PortalEditorialSubjects::class)->working($structure, (object) $record->getAttributes())));
         }
 
-        return Inertia::render('structures/editor', ['editorialDossier' => $editorialDossier?->id, 'structure' => $structure, 'record' => $record,
+        return Inertia::render('structures/editor', ['editorialDossier' => $editorialDossier?->id, 'editorialSubject' => ! $editorialDossier && $record && app(PortalEditorialSubjects::class)->available() ? '/management/editorial/subjects/'.$structure.'/'.$id : null, 'structuralEditorial' => app(PortalEditorialSubjects::class)->available(), 'structure' => $structure, 'record' => $record,
             'projects' => $structure === 'clusters' && $id ? Project::orderBy('name')->get(['id', 'name', 'code']) : [],
-            'chains' => $structure === 'clusters' && $id ? ValueChain::where('cluster_id', $id)->orderBy('code')->get() : [],
-            'gaps' => $structure === 'clusters' && $id ? InvestmentGap::where('cluster_id', $id)->orderBy('created_at')->get() : [],
+            'chains' => $structure === 'clusters' && $id ? ValueChain::where('cluster_id', $id)->orderBy('code')->get()->map(fn ($row) => app(PortalEditorialSubjects::class)->available() ? app(PortalEditorialSubjects::class)->working('value-chains', (object) $row->getAttributes()) : $row) : [],
+            'gaps' => $structure === 'clusters' && $id ? InvestmentGap::where('cluster_id', $id)->orderBy('created_at')->get()->map(fn ($row) => app(PortalEditorialSubjects::class)->available() ? app(PortalEditorialSubjects::class)->working('investment-gaps', (object) $row->getAttributes()) : $row) : [],
             'chainLinks' => $structure === 'clusters' && $id ? DB::table('value_chain_links')
                 ->join('value_chains as origins', 'origins.id', '=', 'value_chain_links.from_value_chain_id')
                 ->join('value_chains as destinations', 'destinations.id', '=', 'value_chain_links.to_value_chain_id')
@@ -70,7 +74,7 @@ class InvestmentStructureController extends Controller
             'memberships' => $structure === 'clusters' && $id ? DB::table('cluster_projects')
                 ->join('projects', 'projects.id', '=', 'cluster_projects.project_id')
                 ->where('cluster_id', $id)->whereNull('cluster_projects.deleted_at')->whereNull('projects.deleted_at')
-                ->orderBy('projects.name')->get(['cluster_projects.id', 'cluster_projects.project_id', 'cluster_projects.role', 'cluster_projects.association_type', 'cluster_projects.source_reference', 'cluster_projects.evidence_reference', 'cluster_projects.valid_from', 'cluster_projects.valid_until', 'cluster_projects.validation_status', 'cluster_projects.version_no', 'cluster_projects.editor_id', 'projects.name']) : [],
+                ->orderBy('projects.name')->get(['cluster_projects.id', 'cluster_projects.project_id', 'cluster_projects.role', 'cluster_projects.association_type', 'cluster_projects.source_reference', 'cluster_projects.evidence_reference', 'cluster_projects.valid_from', 'cluster_projects.valid_until', 'cluster_projects.validation_status', 'cluster_projects.version_no', 'cluster_projects.editor_id', 'projects.name'])->map(fn ($row) => app(PortalEditorialSubjects::class)->working('cluster-project', $row)) : [],
         ]);
     }
 
@@ -82,12 +86,13 @@ class InvestmentStructureController extends Controller
         $model = $this->model($structure);
         $record = $id ? $model::findOrFail($id) : new $model;
         $editorialDossier = $id ? app(PortalEditorialWorkflow::class)->structureDossier($structure, $id, true) : null;
+        $subjectWrites = ! $editorialDossier && ($id ? app(PortalEditorialSubjects::class)->writes($structure, $id) : app(PortalEditorialSubjects::class)->available());
         $rules = [
             'code' => ['required', 'string', 'max:100', Rule::unique($record->getTable(), 'code')->whereNull('deleted_at')->ignore($record->getKey())],
             'name' => ['required', 'string', 'max:200'],
             'status' => ['required', Rule::in($isProject ? ['draft', 'planned', 'active', 'suspended', 'completed', 'cancelled'] : ($isCluster ? ['planned', 'active', 'inactive'] : ['proposed', 'active', 'closed']))],
         ];
-        if ($editorialDossier) {
+        if ($editorialDossier || ($subjectWrites && $id)) {
             $rules['editorial_version'] = ['required', 'integer', 'min:1'];
         }
         if ($isProject || $isCorridor) {
@@ -119,6 +124,17 @@ class InvestmentStructureController extends Controller
 
             return redirect('/management/'.$structure.'/'.$record->getKey().'/edit')->with('success', 'Dados-base guardados numa edição privada da carteira. A publicação anterior está preservada.');
         }
+        if ($subjectWrites) {
+            DB::transaction(function () use ($request, $record, $structure, $id, $data): void {
+                $fields = array_diff_key($data, ['editorial_version' => true]);
+                if (! $id) {
+                    PortalAudit::save($record, $fields, $request->user()->id);
+                }
+                app(PortalEditorialWorkflow::class)->saveSubject($request->user(), $structure, (string) $record->getKey(), $id ? (int) $data['editorial_version'] : 0, $fields, ! $id);
+            });
+
+            return redirect('/management/'.$structure.'/'.$record->getKey().'/edit')->with('success', 'Proposta privada guardada. Reveja a edição antes de publicar as alterações.');
+        }
         PortalAudit::save($record, $data, $request->user()->id);
 
         return redirect('/management/'.$structure.'/'.$record->getKey().'/edit')->with('success', 'Registo guardado.');
@@ -137,6 +153,7 @@ class InvestmentStructureController extends Controller
 
     public function linkProject(Request $request, EconomicCluster $cluster): RedirectResponse
     {
+        $editorial = app(PortalEditorialSubjects::class)->available();
         $data = $request->validate(['project_id' => ['required', 'uuid', Rule::exists('projects', 'id')->whereNull('deleted_at')],
             'version_no' => ['required', 'integer', 'min:0'],
             'role' => ['required', Rule::in(['anchor', 'complementary', 'supporting'])],
@@ -144,10 +161,21 @@ class InvestmentStructureController extends Controller
             'source_reference' => ['required', 'string', 'min:10', 'max:2000'],
             'evidence_reference' => ['required', 'string', 'min:3', 'max:2000'],
             'valid_from' => ['required', 'date_format:Y-m-d'],
-            'valid_until' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:valid_from']]);
-        DB::transaction(function () use ($cluster, $data, $request) {
+            'valid_until' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:valid_from'],
+            ...($editorial ? ['editorial_version' => ['required', 'integer', 'min:0']] : [])]);
+        DB::transaction(function () use ($cluster, $data, $request, $editorial) {
             EconomicCluster::whereKey($cluster->id)->lockForUpdate()->firstOrFail();
             $link = ClusterProject::where('cluster_id', $cluster->id)->where('project_id', $data['project_id'])->whereNull('deleted_at')->lockForUpdate()->first();
+            if ($editorial || ($link && app(PortalEditorialSubjects::class)->writes('cluster-project', $link->id))) {
+                abort_unless((int) $data['version_no'] === ($link ? (int) $link->version_no : 0), 409, 'A associação foi alterada. Confira a versão actual.');
+                $fields = [...array_diff_key($data, ['version_no' => true, 'editorial_version' => true]), 'cluster_id' => $cluster->id];
+                if (! $link) {
+                    $fields += ['validation_status' => 'pending', 'editor_id' => $request->user()->id, 'validator_id' => null, 'version_no' => 1];
+                }
+                app(PortalEditorialSubjects::class)->stageModel($request->user(), 'cluster-project', $link ?? new ClusterProject, $fields, (int) $data['editorial_version']);
+
+                return;
+            }
             if ($link) {
                 abort_if((int) $link->version_no !== (int) $data['version_no'], 409, 'Versao da associacao alterada.');
                 $changed = false;
@@ -178,10 +206,17 @@ class InvestmentStructureController extends Controller
     public function saveChain(Request $request, EconomicCluster $cluster, ?ValueChain $chain = null): RedirectResponse
     {
         abort_if($chain && $chain->cluster_id !== $cluster->id, 404);
+        $editorial = $chain ? app(PortalEditorialSubjects::class)->writes('value-chains', $chain->id) : app(PortalEditorialSubjects::class)->available();
         $data = $request->validate(['code' => ['required', 'string', 'max:100',
             Rule::unique('value_chains', 'code')->where('cluster_id', $cluster->id)->whereNull('deleted_at')->ignore($chain?->id)],
             'name' => ['required', 'string', 'max:200'],
-            'stage' => ['required', Rule::in(['input', 'production', 'processing', 'logistics', 'market'])]]);
+            'stage' => ['required', Rule::in(['input', 'production', 'processing', 'logistics', 'market'])],
+            ...($editorial && $chain ? ['editorial_version' => ['required', 'integer', 'min:1']] : [])]);
+        if ($editorial) {
+            $edition = app(PortalEditorialSubjects::class)->stageModel($request->user(), 'value-chains', $chain ?? new ValueChain, [...array_diff_key($data, ['editorial_version' => true]), 'cluster_id' => $cluster->id], $chain ? (int) $data['editorial_version'] : 0);
+
+            return redirect('/management/editorial/subjects/value-chains/'.$edition->subject_key)->with('success', 'Etapa guardada numa proposta privada.');
+        }
         PortalAudit::save($chain ?? new ValueChain, [...$data, 'cluster_id' => $cluster->id], $request->user()->id);
 
         return back()->with('success', 'Etapa da cadeia de valor guardada.');