Two month of work

2026-02-17 10:35:03 +01:00
parent 0ffbeeedff
commit d9fd3d1ccb
158 changed files with 5637 additions and 1512 deletions
@@ -0,0 +1,82 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Controllers\Controller;
+use App\Models\PipelineLane;
+use App\Models\PipelineItem;
+use App\Support\ApiDataTransformer;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Validator;
+use Inertia\Inertia;
+
+class PipelineController extends Controller
+{
+    public function index()
+    {
+        $lanes = PipelineLane::with(['items' => function ($q) {
+            $q->withCount(['notes' => function ($query) {
+                $query->where('notable_type', 'App\Models\PipelineItem');
+            }])->orderBy('position');
+        }])->orderBy('position')->get();
+
+        return $lanes->map(function ($lane) {
+            return ApiDataTransformer::snakeToCamel($lane->toArray());
+        });
+    }
+
+    public function show()
+    {
+        return Inertia::render('Pipeline', [
+            'pipeline' => $this->index(),
+        ]);
+    }
+
+    /**
+     * Update positions in bulk. Expect array of objects with camelCase keys: id, stage, position
+     */
+    public function updatePositions(Request $request)
+    {
+        $payload = $request->all();
+
+        if (!is_array($payload)) {
+            return response()->json(['message' => 'Invalid payload'], 422);
+        }
+
+        $items = array_map(function ($item) {
+            return ApiDataTransformer::camelToSnake((array)$item);
+        }, $payload);
+
+        $validator = Validator::make(['items' => $items], [
+            'items.*.id' => 'required|integer|exists:pipeline_items,id',
+            'items.*.pipeline_lane_id' => 'required|integer|exists:pipeline_lanes,id',
+            'items.*.title' => 'string',
+            'items.*.position' => 'required|integer|min:0',
+            'items.*.expected_revenue' => 'decimal',
+            'items.*.description' => 'string',
+        ]);
+
+        if ($validator->fails()) {
+            return response()->json(['errors' => $validator->errors()], 422);
+        }
+
+        DB::beginTransaction();
+        try {
+            foreach ($items as $it) {
+                PipelineItem::where('id', $it['id'])->update([
+                    'pipeline_lane_id' => $it['pipeline_lane_id'],
+                    'position' => $it['position'],
+                ]);
+            }
+            DB::commit();
+        } catch (\Exception $e) {
+            DB::rollBack();
+            Log::error('Failed to update pipeline positions: ' . $e->getMessage());
+            return response()->json(['message' => 'Failed to update positions'], 500);
+        }
+
+        return response()->json(['status' => 'ok']);
+    }
+}