290 lines
10 KiB
PHP
290 lines
10 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\APIS\CustomerApi;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use App\Models\Asset;
|
|
use App\Models\Device;
|
|
use App\Models\TimeseriesKeyMaster;
|
|
use App\Services\CustomerInfoService;
|
|
use Illuminate\Container\Attributes\DB;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\DB as FacadesDB;
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Validator;
|
|
|
|
class TelemetryController extends Controller
|
|
{
|
|
protected $customerInfoService;
|
|
|
|
public function __construct(CustomerInfoService $customerInfoService)
|
|
{
|
|
$this->customerInfoService = $customerInfoService;
|
|
}
|
|
|
|
|
|
|
|
public function telemetryDataAsset(Request $request)
|
|
{
|
|
$validator = Validator::make($request->all(), [
|
|
|
|
'asset_id' => 'required|string',
|
|
]);
|
|
if ($validator->fails()) {
|
|
return jsonResponseWithErrorMessage($validator->errors()->first(), 400);
|
|
}
|
|
|
|
$assetId = $request->input('asset_id');
|
|
$devices = Device::with('deviceProfile')
|
|
->where('asset_id', $assetId)
|
|
->get();
|
|
|
|
if ($devices->isEmpty()) {
|
|
return response()->json(['error' => 'No devices found for the asset'], 404);
|
|
}
|
|
|
|
$startTs = now()->subHours(1)->timestamp * 1000;
|
|
$endTs = now()->timestamp * 1000;
|
|
|
|
$response = [];
|
|
|
|
foreach ($devices as $device) {
|
|
$telemetry = [];
|
|
// ✅ Fetch key names along with additional columns from timeseries_key_master
|
|
$keysData = TimeseriesKeyMaster::where('device_profile_xid', $device->device_profile_id)
|
|
->where(function ($query) {
|
|
$query->where('display_on_dashboard', true)
|
|
->orWhere('display_on_popup', true);
|
|
})
|
|
->get(['key_name', 'display_name', 'display_on_dashboard', 'display_on_popup']);
|
|
$keyNames = $keysData->pluck('key_name')->toArray();
|
|
// dd($keyNames);
|
|
// Log::info('keyNames count', ['count' => count($keyNames)]);
|
|
$telemetryResponse = $this->customerInfoService->getTelemetryData($device, $keyNames, $startTs, $endTs);
|
|
// dd($telemetryResponse);
|
|
foreach ($keysData as $keyData) {
|
|
$keyName = $keyData->key_name;
|
|
|
|
|
|
if (isset($telemetryResponse[$keyName])) {
|
|
foreach ($telemetryResponse[$keyName] as $item) {
|
|
$telemetry[] = [
|
|
'key_name' => $keyName,
|
|
'display_name' => $keyData->display_name,
|
|
'display_on_dashboard' => $keyData->display_on_dashboard,
|
|
'display_on_popup' => $keyData->display_on_popup,
|
|
'timestamp' => $item['ts'] ?? null,
|
|
'value' => $item['value'] ?? null
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!empty($telemetry)) {
|
|
$response[] = [
|
|
'device_id' => (string) $device->id,
|
|
'device_profile_name' => (string) $device->deviceProfile->name,
|
|
'asset_id' => (string) $device->asset_id,
|
|
'device_profile_id' => (string) $device->device_profile_id,
|
|
'telemetry' => $telemetry,
|
|
];
|
|
}
|
|
}
|
|
|
|
return response()->json(['telemetry' => $response]);
|
|
}
|
|
|
|
|
|
|
|
public function telemetryDataDevice(Request $request)
|
|
{
|
|
|
|
$validator = Validator::make($request->all(), [
|
|
|
|
'device_id' => 'required|string',
|
|
]);
|
|
if ($validator->fails()) {
|
|
return jsonResponseWithErrorMessage($validator->errors()->first(), 400);
|
|
}
|
|
$deviceId = $request->input('device_id');
|
|
|
|
|
|
|
|
$devices = Device::with('deviceProfile')
|
|
->where('id', $deviceId)
|
|
->get();
|
|
|
|
|
|
|
|
if ($devices->isEmpty()) {
|
|
return response()->json(['error' => 'No devices found'], 404);
|
|
}
|
|
|
|
$startTs = now()->subHours(1)->timestamp * 1000;
|
|
$endTs = now()->timestamp * 1000;
|
|
|
|
$response = [];
|
|
|
|
foreach ($devices as $device) {
|
|
$telemetry = [];
|
|
|
|
$keyNames = TimeseriesKeyMaster::where('device_profile_xid', $device->device_profile_id)
|
|
->pluck('key_name','display_name')
|
|
->toArray();
|
|
|
|
// ✅ Fetch telemetry data
|
|
$telemetryResponse = $this->customerInfoService->getTelemetryDataDevice($device, $keyNames, $startTs, $endTs);
|
|
|
|
|
|
foreach ($keyNames as $keyName) {
|
|
if (isset($telemetryResponse[$keyName])) {
|
|
foreach ($telemetryResponse[$keyName] as $item) {
|
|
$telemetry[] = [
|
|
'key_name' => $keyName,
|
|
'timestamp' => $item['ts'] ?? null,
|
|
'value' => $item['value'] ?? null,
|
|
'display_name' => $keyName,
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!empty($telemetry)) {
|
|
$response[] = [
|
|
'device_id' => (string) $device->id,
|
|
'device_name' => $device->name,
|
|
'device_profile_name' => (string) $device->deviceProfile->name,
|
|
'device_profile_id' => (string) $device->device_profile_id,
|
|
'telemetry' => $telemetry,
|
|
];
|
|
}
|
|
}
|
|
|
|
return response()->json(['telemetry' => $response]);
|
|
}
|
|
|
|
public function telemetryDataDeviceDiagnostic(Request $request, $deviceId)
|
|
{
|
|
$devices = Device::with('deviceProfile')
|
|
->where('id', $deviceId)
|
|
->get();
|
|
|
|
if ($devices->isEmpty()) {
|
|
return response()->json(['error' => 'No devices found'], 404);
|
|
}
|
|
|
|
$startTs = $request->has('start_date') ? strtotime($request->start_date) * 1000 : null;
|
|
$endTs = $request->has('end_date') ? strtotime($request->end_date) * 1000 : null;
|
|
|
|
$response = [];
|
|
|
|
foreach ($devices as $device) {
|
|
$telemetry = [];
|
|
|
|
$keyNames = TimeseriesKeyMaster::where('device_profile_xid', $device->device_profile_id)
|
|
->pluck('key_name', 'display_name')
|
|
->toArray();
|
|
|
|
$telemetryResponse = $this->customerInfoService->getTelemetryDataDeviceDiagonostic($device, $keyNames, $startTs, $endTs);
|
|
|
|
foreach ($keyNames as $keyName) {
|
|
if (isset($telemetryResponse[$keyName])) {
|
|
foreach ($telemetryResponse[$keyName] as $item) {
|
|
$timestamp = $item['ts'] ?? null;
|
|
|
|
// ✅ Filter telemetry by timestamp range
|
|
if ($timestamp && $timestamp >= $startTs && $timestamp <= $endTs) {
|
|
$telemetry[] = [
|
|
'key_name' => $keyName,
|
|
'timestamp' => $timestamp,
|
|
'start_date' => $startTs,
|
|
'end_date' => $endTs,
|
|
'value' => $item['value'] ?? null,
|
|
'display_name' => $keyName,
|
|
];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!empty($telemetry)) {
|
|
$response[] = [
|
|
'device_id' => (string) $device->id,
|
|
'device_name' => $device->name,
|
|
'device_profile_name' => (string) $device->deviceProfile->name,
|
|
'device_profile_id' => (string) $device->device_profile_id,
|
|
'telemetry' => $telemetry,
|
|
];
|
|
}
|
|
}
|
|
|
|
return response()->json(['telemetry' => $response]);
|
|
}
|
|
|
|
// public function telemetryDataDeviceDiagnostic(Request $request, $deviceId)
|
|
// {
|
|
// // Fetch devices
|
|
// $devices = Device::with('deviceProfile')
|
|
// ->where('id', $deviceId)
|
|
// ->get();
|
|
|
|
// if ($devices->isEmpty()) {
|
|
// return response()->json(['error' => 'No devices found'], 404);
|
|
// }
|
|
|
|
// // Get start and end timestamps from request parameters
|
|
// $startTs = $request->has('start_date') ? strtotime($request->start_date) * 1000 : null;
|
|
// $endTs = $request->has('end_date') ? strtotime($request->end_date) * 1000 : null;
|
|
|
|
// if (!$startTs || !$endTs) {
|
|
// return response()->json(['error' => 'Start date and end date are required'], 400);
|
|
// }
|
|
|
|
// $response = [];
|
|
|
|
// foreach ($devices as $device) {
|
|
// $telemetry = [];
|
|
|
|
// $keyNames = TimeseriesKeyMaster::where('device_profile_xid', $device->device_profile_id)
|
|
// ->pluck('key_name', 'display_name')
|
|
// ->toArray();
|
|
|
|
// $telemetryResponse = $this->customerInfoService->getTelemetryDataDeviceDiagonostic($device, $keyNames, $startTs, $endTs);
|
|
|
|
// foreach ($keyNames as $displayName => $keyName) {
|
|
// if (isset($telemetryResponse[$keyName])) {
|
|
// foreach ($telemetryResponse[$keyName] as $item) {
|
|
// $itemTs = $item['timestamp'] ?? null;
|
|
|
|
// // ✅ Filter only telemetry within the date range
|
|
// if ($itemTs >= $startTs && $itemTs <= $endTs) {
|
|
// $telemetry[] = [
|
|
// 'key_name' => $keyName,
|
|
// 'value' => $item['value'] ?? null,
|
|
// 'display_name' => $displayName,
|
|
// 'timestamp' => $itemTs,
|
|
// 'start_date' => $startTs,
|
|
// 'end_date' => $endTs
|
|
// ];
|
|
// }
|
|
// }
|
|
// }
|
|
// }
|
|
|
|
// if (!empty($telemetry)) {
|
|
// $response[] = [
|
|
// 'device_id' => (string) $device->id,
|
|
// 'device_name' => $device->name,
|
|
// 'device_profile_name' => (string) $device->deviceProfile->name,
|
|
// 'device_profile_id' => (string) $device->device_profile_id,
|
|
// 'telemetry' => $telemetry,
|
|
// ];
|
|
// }
|
|
// }
|
|
|
|
// return response()->json(['telemetry' => $response]);
|
|
// }
|
|
|
|
}
|