libretime/legacy/application/models/LiveLog.php

<?php

class Application_Model_LiveLog
{
    public static function GetLiveShowDuration($p_keepData = false)
    {
        try {
            $sql = 'SELECT * FROM CC_LIVE_LOG'
                . ' WHERE state = :state'
                . " and (start_time >= (now() - INTERVAL '1 day'))"
                . ' ORDER BY id';
            $rows = Application_Common_Database::prepareAndExecute(
                $sql,
                [':state' => 'L'],
                Application_Common_Database::ALL
            );

            /* Check if last log has end time.
             * If not, set end time to current time
             */
            if ($rows != null) {
                $last_row = self::UpdateLastLogEndTime(array_pop($rows));
                array_push($rows, $last_row);
                $skip = false;
            } else {
                $sql = 'SELECT * FROM CC_LIVE_LOG'
                    . ' WHERE state = :state'
                    . ' ORDER BY id';
                $rows = Application_Common_Database::prepareAndExecute(
                    $sql,
                    [':state' => 'L'],
                    Application_Common_Database::ALL
                );

                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 = :id';
                        Application_Common_Database::prepareAndExecute(
                            $sql_delete,
                            [':id' => $row['id']],
                            Application_Common_Database::EXECUTE
                        );
                    }
                }
                $skip = true;
            }

            $hours = 0;
            $minutes = 0;
            $seconds = 0;

            if (!$skip) {
                foreach ($rows as $row) {
                    $end = new DateTime($row['end_time']);
                    $start = new DateTime($row['start_time']);
                    $duration = $start->diff($end);
                    $duration = $duration->format('%H:%i:%s');
                    $intervals = explode(':', $duration);
                    for ($i = 0; $i < count($intervals); ++$i) {
                        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;
                        $seconds -= 60;
                    }

                    $minutes += $intervals[1];
                    if ($minutes / 60 >= 1) {
                        ++$hours;
                        $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 = :id';
                        Application_Common_Database::prepareAndExecute(
                            $sql_delete,
                            [':id' => $row['id']],
                            Application_Common_Database::EXECUTE
                        );
                    }
                }
                // Trim milliseconds
                $seconds = explode('.', $seconds);
                if (isset($seconds[0])) {
                    $minutes = (float) (($hours * 60) + $minutes . '.' . $seconds[0]);
                } else {
                    $minutes = (float) (($hours * 60) + $minutes);
                }
            }

            return $minutes;
        } catch (Exception $e) {
            header('HTTP/1.0 503 Service Unavailable');
            Logging::info('GetLiveShowDuration - Could not connect to database.');

            exit;
        }
    }

    public static function GetScheduledDuration($p_keepData = false)
    {
        try {
            $sql_get_logs = 'SELECT * FROM CC_LIVE_LOG'
                . ' WHERE state = :state'
                . " and (start_time >= (now() - INTERVAL '1 day'))"
                . ' ORDER BY id';

            $rows = Application_Common_Database::prepareAndExecute(
                $sql_get_logs,
                [':state' => 'S'],
                Application_Common_Database::ALL
            );

            /* Check if last log has end time.
             * If not, set end time to current time
             */
            if ($rows != null) {
                $last_row = self::UpdateLastLogEndTime(array_pop($rows));
                array_push($rows, $last_row);
                $skip = false;
            } else {
                $sql = 'SELECT * FROM CC_LIVE_LOG'
                    . ' WHERE state = :state'
                    . ' ORDER BY id';
                $rows = Application_Common_Database::prepareAndExecute(
                    $sql,
                    [':state' => 'S'],
                    Application_Common_Database::ALL
                );

                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 = :id';
                        Application_Common_Database::prepareAndExecute(
                            $sql_delete,
                            [':id' => $row['id']],
                            Application_Common_Database::EXECUTE
                        );
                    }
                }
                $skip = true;
            }

            $hours = 0;
            $minutes = 0;
            $seconds = 0;

            if (!$skip) {
                /* 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'
                        . ' WHERE starts >= :starts1'
                        . ' AND starts < :starts2'
                        . ' AND file_id IS NOT NULL'
                        . ' AND media_item_played IS TRUE';
                    $params = [
                        ':starts1' => $row['start_time'],
                        ':starts2' => $row['end_time'],
                    ];
                    $tracks = Application_Common_Database::prepareAndExecute(
                        $sql_get_tracks,
                        $params,
                        Application_Common_Database::ALL
                    );

                    foreach ($tracks as $track) {
                        if ($track['ends'] > $row['end_time']) {
                            $scheduled_ends = new DateTime($row['end_time']);
                            $track_ends = new DateTime($track['ends']);
                            $extra_time = $scheduled_ends->diff($track_ends);

                            /* Get difference between clip_length
                             * and the extra time. We need to subtract
                             * this difference from the track's
                             * clip length.
                             */
                            $clip_length = $track['clip_length'];
                            // Convert clip_length into seconds
                            $clip_length_intervals = explode(':', $clip_length);
                            for ($i = 0; $i < count($clip_length_intervals); ++$i) {
                                if (!isset($clip_length_intervals[$i])) {
                                    $clip_length_intervals[$i] = 0;
                                }
                            }
                            $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');
                            // Convert extra_time into seconds;
                            $extra_time_intervals = explode(':', $extra_time);
                            for ($i = 0; $i < count($extra_time_intervals); ++$i) {
                                if (!isset($extra_time_intervals[$i])) {
                                    $extra_time_intervals[$i] = 0;
                                }
                            }
                            $extra_time_seconds = $extra_time_intervals[0] * 3600 + $extra_time_intervals[1] * 60 + $extra_time_intervals[2];

                            $clip_length_seconds -= $extra_time_seconds;

                            // Convert new clip_length into "H-i-s" format
                            $clip_length_arr = [];
                            if ($clip_length_seconds / 3600 >= 1) {
                                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);
                            } 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 {
                            $clip_length = $track['clip_length'];
                        }

                        $intervals = explode(':', $clip_length);
                        for ($i = 0; $i < count($intervals); ++$i) {
                            if (!isset($intervals[$i])) {
                                $intervals[$i] = 0;
                            }
                        }
                        // Trim milliseconds (DateInteral does not support)
                        $sec = explode('.', $intervals[2]);
                        if (isset($sec[0])) {
                            $intervals[2] = $sec[0];
                        }

                        $seconds += $intervals[2];
                        if ($seconds / 60 >= 1) {
                            ++$minutes;
                            $seconds -= 60;
                        }

                        $minutes += $intervals[1];
                        if ($minutes / 60 >= 1) {
                            ++$hours;
                            $minutes -= 60;
                        }

                        $hours += $intervals[0];
                    }

                    if (!$p_keepData) {
                        // Delete row because we do not need data anymore
                        $sql_delete = 'DELETE FROM CC_LIVE_LOG'
                            . ' WHERE id = :id';
                        Application_Common_Database::prepareAndExecute(
                            $sql_delete,
                            [':id' => $row['id']],
                            Application_Common_Database::EXECUTE
                        );
                    }
                }

                $seconds = explode('.', $seconds);
                if (isset($seconds[0])) {
                    $minutes = (float) (($hours * 60) + $minutes . '.' . $seconds[0]);
                } else {
                    $minutes = (float) (($hours * 60) + $minutes);
                }
            }

            return $minutes;
        } catch (Exception $e) {
            header('HTTP/1.0 503 Service Unavailable');
            Logging::info('GetScheduledDuration - Could not connect to database.');

            exit;
        }
    }

    public static function UpdateLastLogEndTime($log)
    {
        if ($log['end_time'] == null) {
            $current_time = new DateTime('now', new DateTimeZone('UTC'));
            $log['end_time'] = $current_time;
            $log['end_time'] = $log['end_time']->format(DEFAULT_TIMESTAMP_FORMAT);
            self::SetEndTime($log['state'], $current_time, true);
            self::SetNewLogTime($log['state'], $current_time);
        }

        return $log;
    }

    public static function SetNewLogTime($state, $dateTime)
    {
        try {
            $scheduled = Application_Model_Preference::GetSourceSwitchStatus('scheduled_play');
            if ($state == 'L' && $scheduled == 'on') {
                self::SetEndTime('S', $dateTime);
            }

            /* Only insert new state if last log
             * has ended
             */
            $sql_select = 'SELECT max(id) from CC_LIVE_LOG'
                . ' WHERE (state= :state1 and end_time is NULL) or (state= :state2 and end_time is NULL)';
            $params = [
                ':state1' => 'L',
                ':state2' => 'S',
            ];
            $id = Application_Common_Database::prepareAndExecute(
                $sql_select,
                $params,
                Application_Common_Database::COLUMN
            );

            if ($id == null) {
                $sql_insert = 'INSERT INTO CC_LIVE_LOG (state, start_time)'
                    . ' VALUES (:state, :start)';
                $params = [
                    ':state' => $state,
                    ':start' => $dateTime->format(DEFAULT_TIMESTAMP_FORMAT),
                ];
                Application_Common_Database::prepareAndExecute(
                    $sql_insert,
                    $params,
                    Application_Common_Database::EXECUTE
                );
                if ($state == 'S') {
                    // if scheduled play source is getting broadcasted
                    Application_Model_Schedule::UpdateBrodcastedStatus($dateTime, 1);
                }
            }
        } catch (Exception $e) {
            header('HTTP/1.0 503 Service Unavailable');
            Logging::info('SetNewLogTime - Could not connect to database.');

            exit;
        }
    }

    public static function SetEndTime($state, $dateTime, $override = false)
    {
        try {
            $dj_live = Application_Model_Preference::GetSourceSwitchStatus('live_dj');
            $master_live = Application_Model_Preference::GetSourceSwitchStatus('master_dj');

            if (($dj_live == 'off' && $master_live == 'off') || $state == 'S' || $override) {
                $sql = 'SELECT id, state from cc_live_log'
                    . ' where id in (select max(id) from cc_live_log)';
                $row = Application_Common_Database::prepareAndExecute(
                    $sql,
                    [],
                    Application_Common_Database::SINGLE
                );

                /* Only set end time if state recevied ($state)
                 * is the last row in cc_live_log
                 */
                if ($row['state'] == $state) {
                    $update_sql = 'UPDATE CC_LIVE_LOG'
                        . ' SET end_time = :end'
                        . ' WHERE id = :id';
                    $params = [
                        ':end' => $dateTime->format(DEFAULT_TIMESTAMP_FORMAT),
                        ':id' => $row['id'],
                    ];
                    Application_Common_Database::prepareAndExecute(
                        $update_sql,
                        $params,
                        Application_Common_Database::EXECUTE
                    );
                }

                // If live broadcasting is off, turn scheduled play on
                $scheduled = Application_Model_Preference::GetSourceSwitchStatus('scheduled_play');
                if ($state == 'L' && $scheduled == 'on' && !$override) {
                    self::SetNewLogTime('S', $dateTime);
                }
            }
        } catch (Exception $e) {
            header('HTTP/1.0 503 Service Unavailable');
            Logging::info('SetEndTime - Could not connect to database.');

            exit;
        }
    }
}