<?php
require_once(__DIR__ . '/../../../vendor/autoload.php');
use Orchard\Mysqli\QueryData;
use Orchard\Mysqli\Wrapper as MysqliWrapper;
$readWrapperObj = new MysqliWrapper($mysqli_r);

$varTotalLabels = 0;
$pendingArr = array();
$varReleaseReceived = 0;
$varTotalESTReleases = 0;

$labels = array();

$non_orch_owner = ownerFilterSubQuery(' AND v.owner');
$dataParams = new QueryData();
$sql = 'SELECT v.est_total_releases, v.vendor_id, v.est_total_tracks
            FROM vendor v
            WHERE  v.status = "signed"
                AND v.vendor_id > 0';
if ($aggregator_login) {
    $sql .= $non_orch_owner;
    $dataParams = addSessionOwnerDataParam($dataParams);
} elseif ($summary_user_id) {
    $sql .= ' AND v.assigned_to = ?';
    $dataParams->addDataParam('i', $summary_user_id);
} else {
    $sql .= ' AND v.assigned_to != 0 AND v.assigned_to IS NOT NULL';
}
$vendor_results = $readWrapperObj->executeQuery($sql, $dataParams);
if ($vendor_results === false) {
    showierror($sql);
}
foreach ($vendor_results as $vendor_row) {
    $labels[$vendor_row['vendor_id']] = array('est_release'=>$vendor_row['est_total_releases'], 'est_track'=>$vendor_row['est_total_tracks']);
    $varTotalESTReleases += $vendor_row['est_total_releases'];
}
$varTotalLabels = count($labels);

$dataParams = new QueryData();
$sql = 'SELECT COUNT(DISTINCT x.upc) AS total_releases, x.vendor_id, SUM(x.total_tracks) AS total_tracks
            FROM (
                SELECT r.upc, a.vendor_id, COUNT(t.id) AS total_tracks
                FROM releases r
                    INNER JOIN artist_info a ON   r.artist_id = a.artist_id
                    INNER JOIN vendor v ON v.vendor_id = a.vendor_id
                    LEFT JOIN track t ON t.upc = r.upc
                WHERE r.release_status = "in_content" AND v.status = "signed"
                    AND r.upc > 0';
if ($aggregator_login) {
    $sql .= $non_orch_owner;
    $dataParams = addSessionOwnerDataParam($dataParams);
} elseif ($summary_user_id) {
    $sql .= ' AND v.assigned_to = ?';
    $dataParams->addDataParam('i', $summary_user_id);
} else {
    $sql .= ' AND v.assigned_to != 0 AND v.assigned_to IS NOT NULL';
}
$sql .= ' GROUP BY r.upc 
    UNION
    SELECT cd.upc, cd.vendor_id, cd.total_tracks
    FROM cd_receive cd
        INNER JOIN vendor v ON v.vendor_id = cd.vendor_id
    WHERE v.status = "signed"
        AND cd.upc > 0';

if ($aggregator_login) {
    $sql .= $non_orch_owner;
    $dataParams = addSessionOwnerDataParam($dataParams);
} elseif ($summary_user_id) {
    $sql .= ' AND v.assigned_to = ?';
    $dataParams->addDataParam('i', $summary_user_id);
} else {
    $sql .= ' AND v.assigned_to != 0 AND v.assigned_to IS NOT NULL';
}
$sql .= ' GROUP BY cd.upc 
        ) x
        GROUP BY x.vendor_id';

$rel_results = $readWrapperObj->executeQuery($sql, $dataParams);
if ($rel_results === false) {
    showierror($sql);
}
foreach ($rel_results as $rel_row) {
    if (!isset($labels[$rel_row['vendor_id']]))
    $labels[$rel_row['vendor_id']] = array('est_release'=>0, 'est_track'=>0);

    $labels[$rel_row['vendor_id']]['total_release'] = $rel_row['total_releases'];
    $labels[$rel_row['vendor_id']]['total_track'] = $rel_row['total_tracks'];

    $pendingArr[$rel_row['vendor_id']] = array('releases_pending' => (($labels[$rel_row['vendor_id']]['est_release'] - $rel_row['total_releases']) > 0 ? $labels[$rel_row['vendor_id']]['est_release'] - $rel_row['total_releases'] : 0), 'tracks_pending' => (($labels[$rel_row['vendor_id']]['est_track'] - $rel_row['total_releases']) > 0 ? $labels[$rel_row['vendor_id']]['est_track'] - $rel_row['total_releases'] : 0));
    $varReleaseReceived += $rel_row['total_releases'];
}
?>