Vib360/backend_vib360_laravel
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modify code

Browse Source
This commit is contained in:
sayliraut
2025-03-28 13:35:40 +05:30
parent 42b2766003
commit 3dbef32bbe
4 changed files with 197 additions and 98 deletions
Download Patch File Download Diff File Expand all files Collapse all files

185
app/Http/Controllers/AlarmControllerCommon.php Normal file
View File

@@ -0,0 +1,185 @@
<?php
namespace App\Http\Controllers;
use App\Services\AlarmService;
use Carbon\Carbon;
use Illuminate\Support\Facades\Log;
use Exception;
use Illuminate\Support\Facades\Http;
use Illuminate\Http\Request;
class AlarmControllerCommon extends Controller
{
protected $alarmService;
public function __construct(AlarmService $alarmService)
{
$this->alarmService = $alarmService;
}
public function createOrUpdateAlarm(Request $request)
{
try {
$alarmData = [
'type' => $request->type ?? null,
'severity' => $request->severity ?? null,
'acknowledged' => false ?? null,
'cleared' => $request->cleared ?? Carbon::now()->timestamp,
'startTs' => $request->startTs ?? Carbon::now()->timestamp,
'endTs' => $request->endTs ?? Carbon::now()->timestamp,
'details' => $request->details ?? [],
'propagate' => $request->propagate ?? false,
'propagateToOwner' => $request->propagateToOwner ?? false,
'propagateToTenant' => $request->propagateToTenant ?? false,
'originator' => $request->originator ?? 1,
'assigneeId' => $request->assigneeId ?? 1,
];
// Handle updating existing alarm
if (!empty($request->id)) {
$alarmData['id'] = $request->id;
}
// Call Service to create/update device
$apiResponse = $this->alarmService->createOrUpdateAlarm($alarmData);
return jsonResponseWithSuccessMessage(
!empty($request->id) ? 'Alarm updated successfully' : 'Alarm created successfully',
['api_response' => $apiResponse]
);
} catch (Exception $e) {
Log::error("Error: " . $e->getMessage());
$errorResponse = json_decode($e->getMessage(), true);
if (json_last_error() === JSON_ERROR_NONE) {
return jsonResponseWithErrorMessage($errorResponse['message'] ?? 'Something went wrong', 400, $errorResponse);
}
return jsonResponseWithErrorMessage($e->getMessage(), 500);
}
}
public function getAlarmById($id)
{
try {
$token = app('App\Services\AdminService')->getToken(); // Fetch cached token
$url = env('THINGSBOARD_URL') . "/api/alarm/{$id}";
$response = Http::withHeaders([
'X-Authorization' => 'Bearer ' . $token,
'accept' => 'application/json',
])->get($url);
if ($response->successful()) {
$responseData = $response->json();
$data = $responseData['data'] ?? $responseData ?? [];
if (empty($data)) {
return jsonResponseWithErrorMessage('No data found for the provided ID', 404);
}
$filteredData = [
'originator' => $data['originator'] ?? null,
'severity' => $data['severity'] ?? null,
'startTs' => $data['startTs'] ?? null,
'type' => $data['type'] ?? null,
'status' => $data['status'] ?? null,
'assignee' => $data['assigneeId'] ?? null,
];
return jsonResponseWithSuccessMessage('Alarm data fetched successfully', $filteredData);
}
return jsonResponseWithErrorMessage('Failed to fetch alarm data: ' . $response->body(), $response->status());
} catch (\Exception $e) {
return jsonResponseWithErrorMessage('An error occurred while fetching the alarm: ' . $e->getMessage(), 500);
}
}
public function acknowledgeAlarmById($id)
{
try {
$token = app('App\Services\AdminService')->getToken(); // Fetch cached token
$url = env('THINGSBOARD_URL') . "/api/alarm/{$id}";
$getResponse = Http::withHeaders([
'X-Authorization' => 'Bearer ' . $token,
'accept' => 'application/json',
])->get($url);
if (!$getResponse->successful()) {
return jsonResponseWithErrorMessage('Failed to fetch alarm: ' . $getResponse->body(), $getResponse->status());
}
$alarmData = $getResponse->json();
if ($alarmData['acknowledged'] ?? false) {
return jsonResponseWithSuccessMessage('Alarm is already acknowledged', [
'id' => $alarmData['id']['id'] ?? $id,
'acknowledged' => true,
'ackTs' => $alarmData['ackTs'] ?? null,
'status' => $alarmData['status'] ?? 'UNKNOWN'
]);
}
$ackUrl = env('THINGSBOARD_URL') . "/api/alarm/{$id}/ack";
$ackResponse = Http::withHeaders([
'X-Authorization' => 'Bearer ' . $token,
'accept' => 'application/json',
])->post($ackUrl);
if ($ackResponse->successful()) {
$ackData = $ackResponse->json();
return jsonResponseWithSuccessMessage('Alarm acknowledged successfully', [
'id' => $ackData['id']['id'] ?? $id,
'acknowledged' => $ackData['acknowledged'] ?? true,
'ackTs' => $ackData['ackTs'] ?? now()->timestamp,
'status' => $ackData['status'] ?? 'ACTIVE_ACK'
]);
}
return jsonResponseWithErrorMessage('Failed to acknowledge alarm: ' . $ackResponse->body(), $ackResponse->status());
} catch (\Exception $e) {
return jsonResponseWithErrorMessage('An error occurred: ' . $e->getMessage(), 500);
}
}
public function filterAlarm(Request $request)
{
try {
$alarmData = $request->only([
// 'statusList',
'severity',
// 'type',
// 'assigneeId',
'pageSize',
'page',
// 'textSearch',
// 'sortProperty',
// 'sortOrder',
'startTs',
'endTs'
]);
$apiResponse = $this->alarmService->filterAlarm($alarmData);
return jsonResponseWithSuccessMessage('Alarm data retrieved successfully', ['api_response' => $apiResponse]);
} catch (Exception $e) {
Log::error("Error: " . $e->getMessage());
$errorResponse = json_decode($e->getMessage(), true);
if (json_last_error() === JSON_ERROR_NONE) {
return jsonResponseWithErrorMessage($errorResponse['message'] ?? 'Something went wrong', 400, $errorResponse);
}
return jsonResponseWithErrorMessage($e->getMessage(), 500);
}
}
}