feat/sensor

app/Http/Controllers/Api/Admin/SensorController.php

@@ -0,0 +1,229 @@
+<?php
+
+namespace App\Http\Controllers\Api\Admin;
+
+use App\Http\Controllers\Controller;
+use App\Models\Sensor;
+use App\Models\SensorHistory;
+use Illuminate\Http\Request;
+
+class SensorController extends Controller
+{
+    public function index(Request $request)
+    {
+        $sensors = Sensor::orderBy('created_at', 'desc')->get();
+
+        return response()->json($sensors, 200);
+    }
+
+    public function store(Request $request)
+    {
+        try {
+            \Log::info('Request data:', $request->all());
+
+            $validatedData = $request->validate([
+                'dev_eui' => 'required|string|unique:sensors,dev_eui',
+                'name' => 'required|string|max:255',
+                'latitude' => 'required|numeric',
+                'longitude' => 'required|numeric',
+                'contract_id' => 'required|integer|exists:contracts,id',
+            ]);
+
+            $sensor = Sensor::create($validatedData);
+
+            return response()->json($sensor, 201);
+        } catch (\Illuminate\Validation\ValidationException $e) {
+            return response()->json([
+                'message' => 'Validation failed',
+                'errors' => $e->errors(),
+            ], 422);
+        } catch (\Exception $e) {
+            return response()->json([
+                'message' => 'Error creating sensor: ' . $e->getMessage(),
+            ], 500);
+        }
+    }
+
+    public function show($id)
+    {
+        try {
+            $sensor = Sensor::findOrFail($id);
+            return response()->json($sensor, 200);
+        } catch (\Illuminate\Database\Eloquent\ModelNotFoundException $e) {
+            return response()->json(['message' => 'Sensor not found'], 404);
+        } catch (\Exception $e) {
+            \Log::error('Error fetching sensor:', ['error' => $e->getMessage()]);
+            return response()->json(['message' => 'Error fetching sensor'], 500);
+        }
+    }
+
+    public function update(Request $request, $id)
+    {
+        try {
+            $validatedData = $request->validate([
+                'name' => 'required|string|max:255',
+                'latitude' => 'required|numeric|between:-90,90',
+                'longitude' => 'required|numeric|between:-180,180',
+                'contract_id' => 'required|integer|exists:contracts,id',
+            ]);
+
+            $sensor = Sensor::findOrFail($id);
+            $sensor->update($validatedData);
+
+            return response()->json($sensor, 200);
+        } catch (\Illuminate\Validation\ValidationException $e) {
+            return response()->json([
+                'errors' => $e->errors(),
+            ], 422);
+        } catch (\Exception $e) {
+            return response()->json([
+                'message' => $e->getMessage(),
+            ], 500);
+        }
+    }
+
+    public function destroy($id)
+    {
+        try {
+            $sensor = Sensor::findOrFail($id);
+            $sensor->delete();
+
+            return response()->json(['message' => 'Sensor deleted successfully'], 200);
+        } catch (\Illuminate\Database\Eloquent\ModelNotFoundException $e) {
+            return response()->json(['message' => 'Sensor not found'], 404);
+        } catch (\Exception $e) {
+            \Log::error('Error deleting sensor:', ['error' => $e->getMessage()]);
+            return response()->json(['message' => 'Error deleting sensor'], 500);
+        }
+    }
+
+    public function getSensorHistory(Request $request, $sensorId)
+    {
+        $range = $request->query('range');
+        $startDate = $request->query('startDate');
+        $endDate = $request->query('endDate');
+
+        $query = SensorHistory::where('sensor_id', $sensorId);
+
+        if ($range === 'week') {
+            $query->whereBetween('created_at', [now()->startOfWeek(), now()->endOfWeek()]);
+        } elseif ($range === 'month') {
+            $query->whereBetween('created_at', [now()->startOfMonth(), now()->endOfMonth()]);
+        } elseif ($range === 'custom' && $startDate && $endDate) {
+            $query->whereBetween('created_at', [$startDate, $endDate]);
+        }
+
+        $sensorHistory = $query->select('created_at', 'phi_soil', 'water_soil', 'humidity')->get();
+
+        $groupedData = $sensorHistory->groupBy(function ($item) {
+            return $item->created_at->format('Y-m-d');
+        });
+
+        $labels = $groupedData->keys();
+        $datasets = [
+            [
+                'label' => 'PH Terra',
+                'data' => $groupedData->map(fn($day) => $day->avg('phi_soil') ?? 0)->values(),
+            ],
+            [
+                'label' => 'Humitat Terra',
+                'data' => $groupedData->map(fn($day) => $day->avg('water_soil') ?? 0)->values(),
+            ],
+        ];
+
+        return response()->json([
+            'labels' => $labels,
+            'datasets' => $datasets,
+        ], 200);
+    }
+
+    public function getSensorPH($sensorId)
+    {
+        $sensor = Sensor::findOrFail($sensorId);
+
+        $lastPH = SensorHistory::where('sensor_id', $sensorId)
+            ->orderBy('created_at', 'desc')
+            ->value('phi_soil');
+
+        return response()->json(['ph' => $lastPH ?? 0], 200);
+    }
+
+    public function getSensorPHByDevEui($dev_eui)
+    {
+        try {
+            $sensorData = SensorHistory::whereHas('sensor', function ($query) use ($dev_eui) {
+                $query->where('dev_eui', $dev_eui);
+            })->select('created_at', 'phi_soil', 'water_soil')
+                ->orderBy('created_at', 'asc')
+                ->get();
+
+            if ($sensorData->isEmpty()) {
+                return response()->json(['message' => 'No history found for the specified dev_eui'], 404);
+            }
+
+            return response()->json($sensorData, 200);
+        } catch (\Exception $e) {
+            \Log::error('Error fetching sensor data:', ['error' => $e->getMessage()]);
+            return response()->json([
+                'message' => 'Error fetching sensor data',
+                'error' => $e->getMessage(),
+            ], 500);
+        }
+    }
+
+    public function getAllSensorsHistory(Request $request)
+    {
+        $range = $request->query('range');
+        $startDate = $request->query('startDate');
+        $endDate = $request->query('endDate');
+
+        $query = SensorHistory::query();
+
+        if ($range === 'week') {
+            $query->whereBetween('created_at', [now()->startOfWeek(), now()->endOfWeek()]);
+        } elseif ($range === 'month') {
+            $query->whereBetween('created_at', [now()->startOfMonth(), now()->endOfMonth()]);
+        } elseif ($range === 'custom' && $startDate && $endDate) {
+            $query->whereBetween('created_at', [$startDate, $endDate]);
+        }
+
+        $sensorHistories = $query->select('sensor_id', 'created_at', 'phi_soil', 'temp_soil', 'bat', 'water_soil')->get();
+
+        return response()->json($sensorHistories, 200);
+    }
+
+    public function getSensorHistoryByDevEui($dev_eui)
+    {
+        try {
+            $sensor = Sensor::where('dev_eui', $dev_eui)->first();
+
+            if (!$sensor) {
+                return response()->json(['message' => 'Sensor not found'], 404);
+            }
+
+            $sensorHistory = SensorHistory::where('sensor_id', $sensor->id)
+                ->orderBy('created_at', 'asc')
+                ->get(['created_at', 'phi_soil as ph1_soil', 'water_soil as humidity_soil']);
+
+            if ($sensorHistory->isEmpty()) {
+                return response()->json(['message' => 'No history found for the specified dev_eui'], 404);
+            }
+
+            $formattedHistory = $sensorHistory->map(function ($entry) {
+                return [
+                    'time' => $entry->created_at->toISOString(),
+                    'ph1_soil' => $entry->ph1_soil,
+                    'humidity_soil' => $entry->humidity_soil,
+                ];
+            });
+
+            return response()->json($formattedHistory, 200);
+        } catch (\Exception $e) {
+            \Log::error('Error fetching sensor history by dev_eui:', ['error' => $e->getMessage()]);
+            return response()->json([
+                'message' => 'Error fetching sensor history',
+                'error' => $e->getMessage(),
+            ], 500);
+        }
+    }
+}

app/Http/Controllers/SensorController.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Http;
+
+class SensorController extends Controller
+{
+    public function fetchSensors()
+    {
+        $response = Http::get('http://microservice-url/api/sensors');
+        return response()->json($response->json(), $response->status());
+    }
+
+    public function fetchSensorHistory($id)
+    {
+        $response = Http::get("http://microservice-url/api/sensors/{$id}/history");
+        return response()->json($response->json(), $response->status());
+    }
+}

app/Models/Sensor.php

@@ -7,11 +7,41 @@
 class Sensor extends Model
 {
     protected $fillable = [
+        'dev_eui', // Cambiado de 'device_eui' a 'dev_eui'
+        'name',
+        'latitude',
+        'longitude',
         'contract_id',
     ];
 
+    public $incrementing = true;
+    protected $keyType = 'integer';
+
     public function contracts()
     {
         return $this->belongsTo(Contract::class, 'contract_id');
     }
+
+    public function contract()
+    {
+        return $this->belongsTo(Contract::class, 'contract_id');
+    }
+
+    public function scopeUniqueByEuiAndName($query)
+    {
+        return $query->select('id', 'dev_eui', 'name', 'latitude', 'longitude', 'contract_id')
+            ->groupBy('dev_eui', 'name');
+    }
+
+    public function scopeUniqueByDeviceEui($query)
+    {
+        return $query->select('id', 'dev_eui', 'name', 'latitude', 'longitude', 'contract_id')
+            ->groupBy('dev_eui');
+    }
+
+    public function scopeUniqueByDevEui($query)
+    {
+        return $query->select('id', 'dev_eui', 'name', 'latitude', 'longitude', 'contract_id')
+            ->groupBy('dev_eui');
+    }
 }

app/Models/SensorHistory.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use App\Models\Sensor;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+
+class SensorHistory extends Model
+{
+    public int $sensor_id;
+
+    public ?float $temperature;
+
+    public ?int $humidity;
+
+    public ?int $inclination;
+
+    protected $fillable = ['sensor_id', 'temperature', 'humidity', 'inclination', 'phi_soil', 'temp_soil', 'created_at'];
+
+    protected static function getTableName(): string
+    {
+        return 'sensor_history';
+    }
+
+    protected static function mapDataToModel($data): SensorHistory
+    {
+        $sensor_history = new self;
+        $sensor_history->sensor_id = $data['sensor_id'];
+        $sensor_history->device_eui = $data['device_eui'];
+        $sensor_history->temperature = $data['temperature'];
+        $sensor_history->humidity = $data['humidity'];
+        $sensor_history->inclination = $data['inclination'];
+        $sensor_history->created_at = $data['created_at'];
+        $sensor_history->updated_at = $data['updated_at'];
+        $sensor_history->deleted_at = $data['deleted_at'];
+
+        return $sensor_history;
+    }
+
+    public function sensor(): BelongsTo
+    {
+        return $this->belongsTo(Sensor::class, 'sensor_id');
+    }
+}