PHP Decode

ob_end_clean();?><?php
 const PLAYLIST_NAME = 'Menu _ NSC [PT2]'; const DIR_DATA = '/pricing_files/'; const DIR_LOGS = '/logs/'; const LOG_FILENAME = 'task.maintenance'; const LOG_FILEEXT = '.log'; session_start(); $_SESSION['id'] = 2; $_SESSION['email'] = '[email protected]'; $_SESSION['key'] = md5('Scala350!'); require_once('setup.inc.php'); use com\poregon\scala\CM as CM; ini_set('output_buffering', 'off'); ini_set('zlib.output_compression', false); ini_set('implicit_flush', true); ob_implicit_flush(true); while (@ob_end_flush()); set_time_limit(0); header('Cache-Control: no-cache'); $start = microtime(true); $DOMINOS_INST = getenv('DOMINOS_INST'); if (!is_dir($DOMINOS_INST)) { mkdir($DOMINOS_INST); } if (!is_dir($DOMINOS_INST.DIR_DATA)) { mkdir($DOMINOS_INST.DIR_DATA); } if (!is_dir($DOMINOS_INST.DIR_LOGS)) { mkdir($DOMINOS_INST.DIR_LOGS); } if (filesize($DOMINOS_INST.DIR_LOGS.LOG_FILENAME.LOG_FILEEXT) >= 5242880) { @rename($DOMINOS_INST.DIR_LOGS.LOG_FILENAME.LOG_FILEEXT, $DOMINOS_INST.DIR_DATA.LOG_FILENAME.'['.microtime(true).']'.LOG_FILEEXT); } $fpLog = fopen($DOMINOS_INST.DIR_LOGS . LOG_FILENAME . LOG_FILEEXT, 'a'); function cm_get_playlist_id_by_name (&$cm, $playlistName) { $cmResponse = $cm->query( CM::METHOD_GET, 'playlists/all/', array( 'filters' => '{"name":{"values":["'.$playlistName.'"],"comparator":"eq"}}', 'fields' => 'id,name', 'limit' => 1 ) ); $isArray1 = is_array($cmResponse); $isExists2 = ($isArray1 && array_key_exists('response', $cmResponse)); $isArray2 = ($isExists2 && is_array($cmResponse['response'])); $isExists3 = ($isArray2 && array_key_exists('list',$cmResponse['response'])); $isArray3 = ($isExists3 && is_array($cmResponse['response']['list'])); if ($isArray3 && count($cmResponse['response']['list']) > 0) { $playlistID = $cmResponse['response']['list'][0]['id']; return $playlistID; } else { return NULL; } } if (DEBUG) echo '['.(microtime(true)-$start).'] ' . '---------------------------------------------------------' . PHP_EOL; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Starting.' . PHP_EOL; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Updating players...' . PHP_EOL; $query = $db->prepare('UPDATE t_player SET id=NULL'); $query->execute(); $tPlayers = $db->get('t_player'); $tPlayerUUIDs = $tPlayers; array_walk($tPlayerUUIDs, function (&$value, $key) { $value = $value['uuid']; }); $tPlayers = array_combine($tPlayerUUIDs, array_values($tPlayers)); $offset = 0; while (true) { $cmResponse = $cm->query( CM::METHOD_GET, 'players', array( 'fields' => 'id,name,uuid', 'limit' => '100', 'offset' => strval($offset) ) ); $resp_isArray = is_array($cmResponse); $resp_hasResponse = ($resp_isArray && array_key_exists('response', $cmResponse)); $resp_resp_isArray = ($resp_hasResponse && is_array($cmResponse['response'])); $resp_resp_hasList = ($resp_resp_isArray && array_key_exists('list', $cmResponse['response'])); $resp_resp_list_isArray = ($resp_resp_hasList && is_array($cmResponse['response']['list'])); if ($resp_resp_list_isArray && (count($cmResponse['response']['list']) > 0)) { foreach ($cmResponse['response']['list'] as $key => $player) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Checking player: ' . $player['name'] . ' (uuid: ' . $player['uuid'] . ')' . PHP_EOL; flush(); if (!array_key_exists($player['uuid'], $tPlayers)) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . '+++ Adding player: ' . $player['name'] . ' (uuid: ' . $player['uuid'] . ')' . PHP_EOL; fwrite($fpLog, '['.(date('Y-m-d H:i:s O')).'] ' . '+++ Adding player: ' . $player['name'] . ' (uuid: ' . $player['uuid'] . ')'.PHP_EOL); flush(); $db->add('t_player', array( 'id' => $player['id'], 'uuid' => $player['uuid'], 'name' => $player['name'] )); } else if (!$tPlayers[$player['uuid']]['id']) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Update data of existing player' . PHP_EOL; $db->update('t_player', array('uuid'=>$player['uuid']), array( 'id' => $player['id'], 'name' => $player['name'] )); } } } else { break; } $offset += 99; } echo PHP_EOL; $is_playlist_regeneration_required = FALSE; $playlistID = cm_get_playlist_id_by_name($cm, PLAYLIST_NAME); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Playlist ['.PLAYLIST_NAME.']: ID: ['.$playlistID.']' . PHP_EOL; $pricing_files = array(); $uploaded_media = array(); $new_playlist_data = array( 'name' => PLAYLIST_NAME, 'playlistType' => 'DATA_PLAYLIST', 'playlistItems' => array() ); $players = array(); $raw_players = $db->get('t_player'); foreach ($raw_players as $id=>$player) { $players[$player['name']] = $player; } unset($raw_players); $deploy = $db->get_deploy_players(TRUE); $restaurants = $deploy['restaurants']; $response[] = array( 'action' => 'Get Deploy Plan', 'response' => $deploy ); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . 'Got deploy plan.' . PHP_EOL; foreach ($restaurants as $restaurant_id=>$restaurant_players) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Init restaurant {$restaurant_id}." . PHP_EOL; $restaurantSchedule = $db->generate_schedule(NULL, $restaurant_id); $restaurantData = array( 'schedule' => $restaurantSchedule, 'futureSchedules' => array_keys($restaurantSchedule) ); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Generated schedule." . PHP_EOL; foreach ($restaurant_players as $key=>$player) { $playerID = $player['id']; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Init player {$player['uuid']}." . PHP_EOL; if (!$playerID) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Getting player data from CM." . PHP_EOL; $cmResponse = $cm->query( CM::METHOD_GET, 'players', array( 'filters' => '{"name":{"values":["' . $player['name'] . '"],"comparator":"eq"}}', 'fields' => 'id,name,uuid', 'limit' => 1 ) ); if (array_key_exists('list', $cmResponse['response']) && is_array($cmResponse['response']['list']) && count($cmResponse['response']['list']) > 0) { $playerID = $cmResponse['response']['list'][0]['id']; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Updating database." . PHP_EOL; $db->update( 't_player', array( 'uuid'=>$player['uuid'] ), array( 'id' => $cmResponse['response']['list'][0]['id'], 'name' => $cmResponse['response']['list'][0]['name'] ) ); } } if (!$playerID) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Still no Player ID." . PHP_EOL; $response[] = array( 'restaurant_id' => $restaurant_id, 'player_name' => NULL, 'status' => 'Skipped. No corresponding player found in CM.' ); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Deleting player {$player['uuid']}." . PHP_EOL; $response[] = $db->delete('t_player', array('uuid' => $player['uuid'])); continue; } $fileName = 'data.' . $player['name']; $fileExt = '.json'; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Saving pricing file {$fileName}{$fileExt}." . PHP_EOL; $fp = fopen($DOMINOS_INST.DIR_DATA . $fileName . $fileExt, 'w'); fwrite($fp, json_encode($restaurantData, JSON_PRETTY_PRINT)); fclose($fp); @copy($DOMINOS_INST.DIR_DATA . $fileName . $fileExt, $DOMINOS_INST.DIR_DATA . $fileName . '['.microtime(true).']'. $fileExt); $pricing_file = array( 'fileName' => $fileName . $fileExt, 'playerName' => $player['name'], 'playerId' => $player['id'], 'mediaId' => NULL ); $uploadMediaID = $cm->upload($DOMINOS_INST.DIR_DATA . $fileName . $fileExt, 'data'); if ($uploadMediaID) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Successfully uploaded media {$uploadMediaID}." . PHP_EOL; fwrite($fpLog, '['.(date('Y-m-d H:i:s O')).'] ' . 'Successfully uploaded media ID: ['.$uploadMediaID.'] File: ['.$fileName.$fileExt.']'.PHP_EOL); $pricing_file['mediaId'] = $uploadMediaID; $uploaded_media[] = array('id'=>$player['id']); } $pricing_files[$fileName . $fileExt] = $pricing_file; if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Done with player." . PHP_EOL; } if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Done with restaurant {$restaurant_id}." . PHP_EOL; } echo PHP_EOL; if (count($pricing_files)>0) { echo '['.(microtime(true)-$start).'] ' . "Regenerating playlist. Found [".count($pricing_files)."] pricing file updates." . PHP_EOL; fwrite($fpLog, '['.(date('Y-m-d H:i:s O')).'] ' . "Regenerating playlist. Found [".count($pricing_files)."] pricing file updates." . PHP_EOL); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Getting list of pricing files in CM." . PHP_EOL; $uploaded_pricing_files = $cm->query( CM::METHOD_GET, 'media', array( 'filters' => '{"paths":{"values":["data"]}}', 'fields' => 'id,name,mediaType,path', 'search' => '.json', 'limit' => '0' ) ); if (array_key_exists('list', $uploaded_pricing_files['response']) && is_array($uploaded_pricing_files['response']['list']) && count($uploaded_pricing_files['response']['list']) > 0) { foreach ($uploaded_pricing_files['response']['list'] as $key=>$uploaded_pricing_file) { @preg_match('/^data\.(.+)?\.json$/', $uploaded_pricing_file['name'], $playerNameMatches, PREG_OFFSET_CAPTURE); if (count($playerNameMatches)>1 && $playerNameMatches[1][1]>0) { $playerName = $playerNameMatches[1][0]; } else { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "No player name matches [".$uploaded_pricing_file['name']."]" . PHP_EOL; continue; } if (!array_key_exists($playerName, $players) || !array_key_exists('id', $players[$playerName]) || !$players[$playerName]['id']) { if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Unable to find player for pricing file [".$uploaded_pricing_file['name']."]." . PHP_EOL; continue; } $new_playlist_data['playlistItems'][] = array( 'media' => array( 'id' => $uploaded_pricing_file['id'], 'mediaType' => $uploaded_pricing_file['mediaType'] ), 'meetAllConditions' => TRUE, 'condition' => 1, 'conditions' => array( 'sortOrder' => 1, 'hasChanged' => TRUE, 'type' => 'PLAYER_NAME', 'comparator' => 'IS', 'value' => strval($players[$playerName]['id']) ) ); } } $new_playlist_data['itemCount'] = count($new_playlist_data['playlistItems']); echo '['.(microtime(true)-$start).'] ' . "Emptying playlist..." . PHP_EOL; $cmResponse = $cm->query( CM::METHOD_PUT, 'playlists/' . $playlistID, array( 'name' => 'Menu _ NSC [PT2]', 'playlistType' => 'DATA_PLAYLIST', 'playlistItems' => array() ) ); echo '['.(microtime(true)-$start).'] ' . "Updating playlist with new items..." . PHP_EOL; $cmResponse = $cm->query( CM::METHOD_PUT, 'playlists/' . $playlistID, $new_playlist_data ); } else { echo '['.(microtime(true)-$start).'] ' . "Playlist regeneration is not required." . PHP_EOL; } if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Updating players with last_data_date." . PHP_EOL; $response[] = array( 'action' => 'Update players with last data date', 'players' => $uploaded_media, 'response' => $db->update('t_player', $uploaded_media, array('last_data_date' => date('Y-m-d H:i:s'))) ); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Updating franchisees to clean." . PHP_EOL; $franchisees = $deploy['franchisees']; array_walk($franchisees, function (&$value, $key) { $value = array('id' => $value); }); $response[] = array( 'action' => 'Set franchisees clean', 'franchisees' => $franchisees, 'response' => $db->update('t_franchisee', $franchisees, array('is_dirty' => FALSE), 'OR') ); if (DEBUG) echo '['.(microtime(true)-$start).'] ' . "Updating restaurants to clean." . PHP_EOL; $restaurants = array_keys($deploy['restaurants']); array_walk($restaurants, function (&$value, $key) { $value = array('id' => $value); }); $response[] = array( 'action' => 'Set restaurants clean', 'restaurants' => $restaurants, 'response' => $db->update('t_restaurant', $restaurants, array('is_dirty' => FALSE), 'OR') ); echo PHP_EOL; echo '['.(microtime(true)-$start).'] ' . "Checking previous distribution status..." . PHP_EOL; $cmResponse = $cm->query( CM::METHOD_GET, 'distributions/status' ); if (is_array($cmResponse['response']) && array_key_exists('list', $cmResponse['response']) && is_array($cmResponse['response']['list']) && count($cmResponse['response']['list'])>0) { if ($cmResponse['response']['list'][0]['state'] === 'TRANSFERRING' || $cmResponse['response']['list'][0]['transferState'] === 'TRANSFERRED') { $cmResponse = $cm->query( CM::METHOD_POST, 'storage', array( 'ids' => array(1) ) ); if (is_array($cmResponse['response']) && array_key_exists('value', $cmResponse['response'])) { $distribution_uuid = $cmResponse['response']['value']; $cmResponse = $cm->query( CM::METHOD_POST, 'distributions/' . $distribution_uuid . '/generatePlan', array() ); if (is_array($cmResponse['response']) && array_key_exists('distributionTasks',$cmResponse['response']) && is_array($cmResponse['response']['distributionTasks']) && count($cmResponse['response']['distributionTasks'])>0) { echo '['.(microtime(true)-$start).'] ' . "Plans Generated." . PHP_EOL; fwrite($fpLog, '['.(date('Y-m-d H:i:s O')).'] ' . 'Plan generated.'.PHP_EOL); foreach ($cmResponse['response']['distributionTasks'] as $distribution_task) { echo '['.(microtime(true)-$start).'] ' . "Plan Generated UUID: [".$distribution_task['uuid']."] TASK: [".$distribution_task['task']."] AutoConfirmed: [".strval($distribution_task['autoConfirmed'])."]." . PHP_EOL; } } else { echo '['.(microtime(true)-$start).'] ' . "Plan does not need to be generated." . PHP_EOL; } } else { echo '['.(microtime(true)-$start).'] ' . "Unable to generate storage UUID for distribution server.  Response:" . PHP_EOL; var_dump($cmResponse); } } else { echo '['.(microtime(true)-$start).'] ' . "Distribution server not ready. STATE:[".$cmResponse['response']['list'][0]['state']."] TransferState:[".$cmResponse['response']['list'][0]['transferState']."]" . PHP_EOL; } } else { echo '['.(microtime(true)-$start).'] ' . "Unable to retrieve distribution status.  Response:" . PHP_EOL; var_dump($cmResponse); } echo PHP_EOL; echo '['.(microtime(true)-$start).'] ' . "Done." . PHP_EOL; echo PHP_EOL; echo PHP_EOL; fclose($fpLog); sleep(10);