CC-3993: Validate that reporting stats are correct on Airtime PRO instances
-done -if no log data for the past 24 hours, update current record with current date, and delete old records
This commit is contained in:
denise
parent
27a6326c58
commit
9ac024fa72
|
|
@ -20,58 +20,77 @@ class Application_Model_LiveLog
|
||||||
if ($rows != null) {
|
if ($rows != null) {
|
||||||
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
||||||
array_push($rows, $last_row);
|
array_push($rows, $last_row);
|
||||||
|
$skip = false;
|
||||||
|
} else {
|
||||||
|
$sql = "SELECT * FROM CC_LIVE_LOG"
|
||||||
|
." WHERE state = 'L'"
|
||||||
|
." ORDER BY id";
|
||||||
|
$rows = $con->query($sql)->fetchAll();
|
||||||
|
|
||||||
|
if ($rows != null) {
|
||||||
|
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
||||||
|
array_push($rows, $last_row);
|
||||||
|
foreach ($rows as $row) {
|
||||||
|
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
||||||
|
." WHERE id = '{$row['id']}'";
|
||||||
|
$con->exec($sql_delete);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
$skip = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
$hours = 0;
|
$hours = 0;
|
||||||
$minutes = 0;
|
$minutes = 0;
|
||||||
$seconds = 0;
|
$seconds = 0;
|
||||||
|
|
||||||
foreach ($rows as $row) {
|
if (!$skip) {
|
||||||
$end = new DateTime($row['end_time']);
|
foreach ($rows as $row) {
|
||||||
$start = new DateTime($row['start_time']);
|
$end = new DateTime($row['end_time']);
|
||||||
$duration = $start->diff($end);
|
$start = new DateTime($row['start_time']);
|
||||||
$duration = $duration->format("%H:%i:%s");
|
$duration = $start->diff($end);
|
||||||
$intervals = explode(":", $duration);
|
$duration = $duration->format("%H:%i:%s");
|
||||||
for ($i = 0; $i < sizeof($intervals); $i++) {
|
$intervals = explode(":", $duration);
|
||||||
if (!isset($intervals[$i])) {
|
for ($i = 0; $i < sizeof($intervals); $i++) {
|
||||||
$intervals[$i] = 0;
|
if (!isset($intervals[$i])) {
|
||||||
|
$intervals[$i] = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Trim milliseconds (DateInterval does not support)
|
||||||
|
$sec = explode(".", $intervals[2]);
|
||||||
|
if (isset($sec[0])) {
|
||||||
|
$intervals[2] = $sec[0];
|
||||||
|
}
|
||||||
|
|
||||||
|
$seconds += $intervals[2];
|
||||||
|
if ($seconds / 60 >= 1) {
|
||||||
|
$minutes += 1;
|
||||||
|
$seconds -= 60;
|
||||||
|
}
|
||||||
|
|
||||||
|
$minutes += $intervals[1];
|
||||||
|
if ($minutes / 60 >= 1) {
|
||||||
|
$hours += 1;
|
||||||
|
$minutes -= 60;
|
||||||
|
}
|
||||||
|
|
||||||
|
$hours += $intervals[0];
|
||||||
|
|
||||||
|
if (!$p_keepData) {
|
||||||
|
// Delete data we just used to start a new log history
|
||||||
|
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
||||||
|
." WHERE id = '{$row['id']}'";
|
||||||
|
$con->exec($sql_delete);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
//Trim milliseconds
|
||||||
// Trim milliseconds (DateInterval does not support)
|
$seconds = explode(".", $seconds);
|
||||||
$sec = explode(".", $intervals[2]);
|
if (isset($seconds[0])) {
|
||||||
if (isset($sec[0])) {
|
$minutes = (double)(($hours*60)+$minutes . "." . $seconds[0]);
|
||||||
$intervals[2] = $sec[0];
|
|
||||||
}
|
}
|
||||||
|
else {
|
||||||
$seconds += $intervals[2];
|
$minutes = (double)(($hours*60)+$minutes);
|
||||||
if ($seconds / 60 >= 1) {
|
|
||||||
$minutes += 1;
|
|
||||||
$seconds -= 60;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$minutes += $intervals[1];
|
|
||||||
if ($minutes / 60 >= 1) {
|
|
||||||
$hours += 1;
|
|
||||||
$minutes -= 60;
|
|
||||||
}
|
|
||||||
|
|
||||||
$hours += $intervals[0];
|
|
||||||
|
|
||||||
if (!$p_keepData) {
|
|
||||||
// Delete data we just used to start a new log history
|
|
||||||
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
|
||||||
." WHERE id = '{$row['id']}'";
|
|
||||||
$con->exec($sql_delete);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
//Trim milliseconds
|
|
||||||
$seconds = explode(".", $seconds);
|
|
||||||
if (isset($seconds[0])) {
|
|
||||||
$minutes = (double)(($hours*60)+$minutes . "." . $seconds[0]);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
$minutes = (double)(($hours*60)+$minutes);
|
|
||||||
}
|
}
|
||||||
return $minutes;
|
return $minutes;
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
|
|
@ -99,121 +118,141 @@ class Application_Model_LiveLog
|
||||||
if ($rows != null) {
|
if ($rows != null) {
|
||||||
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
||||||
array_push($rows, $last_row);
|
array_push($rows, $last_row);
|
||||||
|
$skip = false;
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
$sql = "SELECT * FROM CC_LIVE_LOG"
|
||||||
|
." WHERE state = 'S'"
|
||||||
|
." ORDER BY id";
|
||||||
|
$rows = $con->query($sql)->fetchAll();
|
||||||
|
|
||||||
|
if ($rows != null) {
|
||||||
|
$last_row = self::UpdateLastLogEndTime(array_pop($rows));
|
||||||
|
array_push($rows, $last_row);
|
||||||
|
foreach ($rows as $row) {
|
||||||
|
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
||||||
|
." WHERE id = '{$row['id']}'";
|
||||||
|
$con->exec($sql_delete);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
$skip = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
$hours = 0;
|
$hours = 0;
|
||||||
$minutes = 0;
|
$minutes = 0;
|
||||||
$seconds = 0;
|
$seconds = 0;
|
||||||
|
|
||||||
/* Get all shows and tracks from cc_schedule that played
|
if (!$skip) {
|
||||||
* during a scheduled state
|
/* Get all shows and tracks from cc_schedule that played
|
||||||
*/
|
* during a scheduled state
|
||||||
foreach ($rows as $row) {
|
*/
|
||||||
$sql_get_tracks = "SELECT * FROM cc_schedule"
|
foreach ($rows as $row) {
|
||||||
." WHERE starts >= '{$row['start_time']}'"
|
$sql_get_tracks = "SELECT * FROM cc_schedule"
|
||||||
." AND starts < '{$row['end_time']}'"
|
." WHERE starts >= '{$row['start_time']}'"
|
||||||
." AND file_id IS NOT NULL"
|
." AND starts < '{$row['end_time']}'"
|
||||||
." AND media_item_played IS TRUE";
|
." AND file_id IS NOT NULL"
|
||||||
$tracks = $con->query($sql_get_tracks)->fetchAll();
|
." AND media_item_played IS TRUE";
|
||||||
foreach ($tracks as $track) {
|
$tracks = $con->query($sql_get_tracks)->fetchAll();
|
||||||
if ($track['ends'] > $row['end_time']) {
|
foreach ($tracks as $track) {
|
||||||
$scheduled_ends = new DateTime($row['end_time']);
|
if ($track['ends'] > $row['end_time']) {
|
||||||
$track_ends = new DateTime($track['ends']);
|
$scheduled_ends = new DateTime($row['end_time']);
|
||||||
$extra_time = $scheduled_ends->diff($track_ends);
|
$track_ends = new DateTime($track['ends']);
|
||||||
|
$extra_time = $scheduled_ends->diff($track_ends);
|
||||||
|
|
||||||
/* Get difference between clip_length
|
/* Get difference between clip_length
|
||||||
* and the extra time. We need to subtract
|
* and the extra time. We need to subtract
|
||||||
* this difference from the track's
|
* this difference from the track's
|
||||||
* clip length.
|
* clip length.
|
||||||
*/
|
*/
|
||||||
$clip_length = $track['clip_length'];
|
$clip_length = $track['clip_length'];
|
||||||
//Convert clip_length into seconds
|
//Convert clip_length into seconds
|
||||||
$clip_length_intervals = explode(":", $clip_length);
|
$clip_length_intervals = explode(":", $clip_length);
|
||||||
for ($i = 0; $i < sizeof($clip_length_intervals); $i++) {
|
for ($i = 0; $i < sizeof($clip_length_intervals); $i++) {
|
||||||
if (!isset($clip_length_intervals[$i])) {
|
if (!isset($clip_length_intervals[$i])) {
|
||||||
$clip_length_intervals[$i] = 0;
|
$clip_length_intervals[$i] = 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
$clip_length_seconds = $clip_length_intervals[0]*3600 + $clip_length_intervals[1]*60 + $clip_length_intervals[2];
|
||||||
$clip_length_seconds = $clip_length_intervals[0]*3600 + $clip_length_intervals[1]*60 + $clip_length_intervals[2];
|
|
||||||
|
$extra_time = $extra_time->format("%H:%i:%s");
|
||||||
$extra_time = $extra_time->format("%H:%i:%s");
|
//Convert extra_time into seconds;
|
||||||
//Convert extra_time into seconds;
|
$extra_time_intervals = explode(":", $extra_time);
|
||||||
$extra_time_intervals = explode(":", $extra_time);
|
for ($i = 0; $i < sizeof($extra_time_intervals); $i++) {
|
||||||
for ($i = 0; $i < sizeof($extra_time_intervals); $i++) {
|
if (!isset($extra_time_intervals[$i])) {
|
||||||
if (!isset($extra_time_intervals[$i])) {
|
$extra_time_intervals[$i] = 0;
|
||||||
$extra_time_intervals[$i] = 0;
|
}
|
||||||
}
|
}
|
||||||
}
|
$extra_time_seconds = $extra_time_intervals[0]*3600 + $extra_time_intervals[1]*60 + $extra_time_intervals[2];
|
||||||
$extra_time_seconds = $extra_time_intervals[0]*3600 + $extra_time_intervals[1]*60 + $extra_time_intervals[2];
|
|
||||||
|
|
||||||
$clip_length_seconds -= $extra_time_seconds;
|
$clip_length_seconds -= $extra_time_seconds;
|
||||||
|
|
||||||
//Convert new clip_length into "H-i-s" format
|
//Convert new clip_length into "H-i-s" format
|
||||||
$clip_length_arr = array();
|
$clip_length_arr = array();
|
||||||
if ($clip_length_seconds / 3600 >= 1) {
|
if ($clip_length_seconds / 3600 >= 1) {
|
||||||
array_push($clip_length_arr, str_pad(floor($clip_length_seconds / 3600), 2, "0", STR_PAD_LEFT));
|
array_push($clip_length_arr, str_pad(floor($clip_length_seconds / 3600), 2, "0", STR_PAD_LEFT));
|
||||||
$clip_length_seconds -= floor($clip_length_seconds / 3600);
|
$clip_length_seconds -= floor($clip_length_seconds / 3600);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
array_push($clip_length_arr, "00");
|
||||||
|
}
|
||||||
|
if ($clip_length_seconds / 60 >= 1) {
|
||||||
|
array_push($clip_length_arr, str_pad(floor($clip_length_seconds / 60), 2, "0", STR_PAD_LEFT));
|
||||||
|
$clip_length_seconds -= floor($clip_length_seconds / 60);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
array_push($clip_length_arr, "00");
|
||||||
|
}
|
||||||
|
|
||||||
|
array_push($clip_length_arr, str_pad($clip_length_seconds, 2, "0", STR_PAD_LEFT));
|
||||||
|
$clip_length = implode(":", $clip_length_arr);
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
array_push($clip_length_arr, "00");
|
$clip_length = $track['clip_length'];
|
||||||
}
|
|
||||||
if ($clip_length_seconds / 60 >= 1) {
|
|
||||||
array_push($clip_length_arr, str_pad(floor($clip_length_seconds / 60), 2, "0", STR_PAD_LEFT));
|
|
||||||
$clip_length_seconds -= floor($clip_length_seconds / 60);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
array_push($clip_length_arr, "00");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
array_push($clip_length_arr, str_pad($clip_length_seconds, 2, "0", STR_PAD_LEFT));
|
$intervals = explode(":", $clip_length);
|
||||||
$clip_length = implode(":", $clip_length_arr);
|
for ($i = 0; $i < sizeof($intervals); $i++) {
|
||||||
}
|
if (!isset($intervals[$i])) {
|
||||||
else {
|
$intervals[$i] = 0;
|
||||||
$clip_length = $track['clip_length'];
|
}
|
||||||
}
|
|
||||||
|
|
||||||
$intervals = explode(":", $clip_length);
|
|
||||||
for ($i = 0; $i < sizeof($intervals); $i++) {
|
|
||||||
if (!isset($intervals[$i])) {
|
|
||||||
$intervals[$i] = 0;
|
|
||||||
}
|
}
|
||||||
}
|
// Trim milliseconds (DateInteral does not support)
|
||||||
// Trim milliseconds (DateInteral does not support)
|
$sec = explode(".", $intervals[2]);
|
||||||
$sec = explode(".", $intervals[2]);
|
if (isset($sec[0])) {
|
||||||
if (isset($sec[0])) {
|
$intervals[2] = $sec[0];
|
||||||
$intervals[2] = $sec[0];
|
}
|
||||||
|
|
||||||
|
$seconds += $intervals[2];
|
||||||
|
if ($seconds / 60 >= 1) {
|
||||||
|
$minutes += 1;
|
||||||
|
$seconds -= 60;
|
||||||
|
}
|
||||||
|
|
||||||
|
$minutes += $intervals[1];
|
||||||
|
if ($minutes / 60 >= 1) {
|
||||||
|
$hours += 1;
|
||||||
|
$minutes -= 60;
|
||||||
|
}
|
||||||
|
|
||||||
|
$hours += $intervals[0];
|
||||||
}
|
}
|
||||||
|
|
||||||
$seconds += $intervals[2];
|
if (!$p_keepData) {
|
||||||
if ($seconds / 60 >= 1) {
|
//Delete row because we do not need data anymore
|
||||||
$minutes += 1;
|
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
||||||
$seconds -= 60;
|
." WHERE id = '{$row['id']}'";
|
||||||
|
$con->exec($sql_delete);
|
||||||
}
|
}
|
||||||
|
|
||||||
$minutes += $intervals[1];
|
|
||||||
if ($minutes / 60 >= 1) {
|
|
||||||
$hours += 1;
|
|
||||||
$minutes -= 60;
|
|
||||||
}
|
|
||||||
|
|
||||||
$hours += $intervals[0];
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!$p_keepData) {
|
|
||||||
//Delete row because we do not need data anymore
|
$seconds = explode(".", $seconds);
|
||||||
$sql_delete = "DELETE FROM CC_LIVE_LOG"
|
if (isset($seconds[0])) {
|
||||||
." WHERE id = '{$row['id']}'";
|
$minutes = (double)(($hours*60)+$minutes . "." . $seconds[0]);
|
||||||
$con->exec($sql_delete);
|
}
|
||||||
|
else {
|
||||||
|
$minutes = (double)(($hours*60)+$minutes);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
$seconds = explode(".", $seconds);
|
|
||||||
if (isset($seconds[0])) {
|
|
||||||
$minutes = (double)(($hours*60)+$minutes . "." . $seconds[0]);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
$minutes = (double)(($hours*60)+$minutes);
|
|
||||||
}
|
}
|
||||||
return $minutes;
|
return $minutes;
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue