$roomData) { $devicesData = DeviceManager::getAllDevicesInRoom($roomData['room_id']); foreach ($devicesData as $deviceKey => $deviceData) { $traids = []; $attributes = []; //Google Compatibile Action Type $actionType = GoogleHomeDeviceTypes::getAction($deviceData['type']); if ($actionType == "") continue; $subDevicesData = SubDeviceManager::getAllSubDevices($deviceData['device_id']); foreach ($subDevicesData as $subDeviceKey => $subDeviceData) { $deviceTraid = GoogleHomeDeviceTypes::getTraid($subDeviceData['type']); if ($deviceTraid != "") { $traids[] = $deviceTraid; } $deviceAttributes = GoogleHomeDeviceTypes::getAttribute($subDeviceData['type']); if ($deviceAttributes != "") { $attributes += $deviceAttributes; } } if ($traids < 1) { continue; } $tempDevice = [ 'id' => (string) $deviceData['device_id'], 'type' => $actionType, 'traits' => $traids, 'attributes' => $attributes, 'name' => [ 'name' => $deviceData['name'], ], 'willReportState' => false, 'roomHint' => $roomData['name'] ]; if ($tempDevice['attributes'] == null) unset($tempDevice['attributes']); //traids & Attributes $devices[] = $tempDevice; } } $response = [ 'requestId' => $requestId, 'payload' => [ 'agentUserId' => '651351531531', 'devices' => array_values($devices), ], ]; $apiLogManager = new LogManager('../logs/google-home/' . date("Y-m-d") . '.log'); $apiLogManager->setLevel(LOGLEVEL); $apiLogManager->write("[API][$requestId] request response\n" . json_encode($response, JSON_PRETTY_PRINT), LogRecordTypes::INFO); echo json_encode($response); } static function query($requestId, $payload) { $devices = []; $num = 0; foreach ($payload['devices'] as $deviceId) { $tempDevice[$deviceId['id']] = [ 'online' => false, 'status' => 'OFFLINE', ]; if ($subDevicesData = SubDeviceManager::getAllSubDevices($deviceId['id'])) { foreach ($subDevicesData as $key => $subDeviceData) { $lastRecord = RecordManager::getLastRecord($subDeviceData['subdevice_id']); if ($lastRecord != false && $lastRecord['execuded'] == 1) { $tempDevice[$deviceId['id']]['online'] = true; $tempDevice[$deviceId['id']]['status'] = "SUCCESS"; } else { $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($deviceId['id'], 6) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $tempDevice[$deviceId['id']]['online'] = true; } } switch ($subDeviceData['type']) { case 'temp_cont': $tempDevice[$deviceId['id']]['thermostatMode'] = 'off'; if ($lastRecord['value'] != 0) { $tempDevice[$deviceId['id']]['thermostatMode'] = 'heat'; } $tempDevice[$deviceId['id']]['thermostatTemperatureAmbient'] = $lastRecord['value']; $tempDevice[$deviceId['id']]['thermostatTemperatureSetpoint'] = $lastRecord['value']; break; case 'vol_cont': $tempDevice[$deviceId['id']]['currentVolume'] = $lastRecord['value']; break; case 'media_apps': $tempDevice[$deviceId['id']]['currentApplication'] = "kodi"; break; case 'media_input': $tempDevice[$deviceId['id']]['currentInput'] = "pc"; break; case 'media_status': $tempDevice[$deviceId['id']]['activityState'] = "ACTIVE"; $tempDevice[$deviceId['id']]['playbackState'] = "PLAYING"; break; case 'on/off': $tempDevice[$deviceId['id']]['on'] = ($lastRecord['value'] == 1 ? true : false); break; } } } // $lastRecord = RecordManager::getLastRecord($deviceId['id']); // //var_dump($lastRecord); // if ($lastRecord['execuded'] == 1) { // $online = true; // $status = 'SUCCESS'; // } else { $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($deviceId['id'], 6) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; } // } $devices = $tempDevice; if (count($devices)> 1){ $devices[] = $tempDevice; } } $response = [ 'requestId' => $requestId, 'payload' => [ 'devices' => $devices, ], ]; $apiLogManager = new LogManager('../logs/google-home/' . date("Y-m-d") . '.log'); $apiLogManager->write("[API][$requestId] request response\n" . json_encode($response, JSON_PRETTY_PRINT), LogRecordTypes::INFO); $apiLogManager->setLevel(LOGLEVEL); echo json_encode($response); } static function execute($requestId, $payload) { $commands = []; foreach ($payload['commands'] as $key => $command) { foreach ($command['devices'] as $key2 => $device) { $executionCommand = $command['execution'][0]; if (isset($command['execution'][$key])) { $executionCommand = $command['execution'][$key]; } $deviceType = GoogleHomeDeviceTypes::getType($executionCommand['command']); if ($subDeviceId = SubDeviceManager::getSubDeviceByMasterAndType($device['id'], $deviceType)) { $subDeviceId = $subDeviceId['subdevice_id']; switch ($executionCommand['command']) { case 'action.devices.commands.OnOff': $commands[] = self::executeSwitch($subDeviceId, $executionCommand); break; case 'action.devices.commands.ThermostatTemperatureSetpoint': $commands[] = self::executeTermostatValue($subDeviceId, $executionCommand); break; case 'action.devices.commands.ThermostatSetMode': $commands[] = self::executeTermostatMode($subDeviceId, $executionCommand); break; case 'action.devices.commands.setVolume': $commands[] = self::executeVolume($subDeviceId, $executionCommand); break; case 'action.devices.commands.appSelect': $commands[] = self::executeApp($subDeviceId, $executionCommand); break; case 'action.devices.commands.SetInput': $commands[] = self::executeInput($subDeviceId, $executionCommand); break; case 'action.devices.commands.mediaNext': $commands[] = self::executeMediaCont($subDeviceId, $executionCommand); break; case 'action.devices.commands.mediaPrevious': $commands[] = self::executeMediaCont($subDeviceId, $executionCommand); break; case 'action.devices.commands.mediaPause': $commands[] = self::executeMediaCont($subDeviceId, $executionCommand); break; case 'action.devices.commands.mediaResume': $commands[] = self::executeMediaCont($subDeviceId, $executionCommand); break; case 'action.devices.commands.mediaStop': $commands[] = self::executeMediaCont($subDeviceId, $executionCommand); break; } } } } $response = [ 'requestId' => $requestId, 'payload' => [ 'commands' => $commands, ], ]; $apiLogManager = new LogManager('../logs/google-home/' . date("Y-m-d") . '.log'); $apiLogManager->setLevel(LOGLEVEL); $apiLogManager->write("[API][EXECUTE][$requestId]\n" . json_encode($response, JSON_PRETTY_PRINT), LogRecordTypes::INFO); echo json_encode($response); } static function executeSwitch($subDeviceId, $executionCommand) { $value = 0; $status = 'OFFLINE'; $online = false; if ($executionCommand['params']['on']) $value = 1; RecordManager::createWithSubId($subDeviceId, $value); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'on' => $executionCommand['params']['on'], 'online' => $online, ], ]; return $commandTemp; } static function executeTermostatValue($subDeviceId, $executionCommand) { $value = 0; $status = 'OFFLINE'; $online = false; if (isset($executionCommand['params']['thermostatTemperatureSetpoint'])) { $value = $executionCommand['params']['thermostatTemperatureSetpoint']; } RecordManager::createWithSubId($subDeviceId, $value); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $lastValue) { if ($lastValue['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true;; } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'thermostatMode' => 'heat', 'thermostatTemperatureSetpoint' => $value, 'thermostatTemperatureAmbient' => $value, 'online' => $online, //ambient z dalšího zenzoru v roomu ], ]; return $commandTemp; } static function executeTermostatMode($subDeviceId, $executionCommand) { $mode = "off"; $value = 0; $status = 'OFFLINE'; $online = false; if (isset($executionCommand['params']['thermostatMode']) && $executionCommand['params']['thermostatMode'] != 'off') { $mode = $executionCommand['params']['thermostatMode']; $value = RecordManager::getLastRecordNotNull($subDeviceId)['value']; } RecordManager::createWithSubId($subDeviceId, $value); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'thermostatMode' => $mode, 'online' => $online, ], ]; return $commandTemp; } static function executeVolume($subDeviceId, $executionCommand) { //echo $executionCommand['params']['volumeLevel']; $status = 'OFFLINE'; $online = false; $currentVolume = RecordManager::getLastRecord($subDeviceId)['value']; if (isset($executionCommand['params']['volumeLevel'])) { RecordManager::createWithSubId($subDeviceId, $executionCommand['params']['volumeLevel']); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; $currentVolume = $executionCommand['params']['volumeLevel']; } } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'currentVolume' => $currentVolume, 'online' => $online, ], ]; return $commandTemp; } static function executeApp($subDeviceId, $executionCommand) { //echo $executionCommand['params']['newApplication']; $status = 'OFFLINE'; $online = false; $currentApplication = RecordManager::getLastRecord($subDeviceId)['value']; if (isset($executionCommand['params']['newApplication'])) { RecordManager::createWithSubId($subDeviceId, $executionCommand['params']['newApplication']); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; $currentApplication = $executionCommand['params']['newApplication']; } } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'currentApplication' => $currentApplication, 'online' => $online, ], ]; return $commandTemp; } static function executeInput($subDeviceId, $executionCommand) { //echo $executionCommand['params']['newInput']; $status = 'OFFLINE'; $online = false; $currentInput = RecordManager::getLastRecord($subDeviceId)['value']; if (isset($executionCommand['params']['newInput'])) { RecordManager::createWithSubId($subDeviceId, $executionCommand['params']['newInput']); $executed = 0; $waiting = 0; foreach (RecordManager::getLastRecord($subDeviceId, 4) as $key => $value) { if ($value['execuded'] == 1) { $executed++; } else { $waiting++; } } if ($waiting < $executed) { $status = "PENDING"; $online = true; $currentInput = $executionCommand['params']['newInput']; } } $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'currentInput' => $currentInput, 'online' => $online, ], ]; return $commandTemp; } static function executeMediaCont($subDeviceId, $executionCommand) { $status = 'SUCCESS'; $online = true; $deviceId = SubDeviceManager::getSubDeviceMaster($subDeviceId)['device_id']; $commandTemp = [ 'ids' => [(string) $deviceId], 'status' => $status, 'states' => [ 'online' => $online, ], ]; return $commandTemp; } }