corerequests_report.data

<?php
/*
* File: corerequests_report.data
*
* Purpose:  request contents of core requests from the cucorerequests table
*/

require_once('dms_imp_val.i');
require_once('cu_top');

header('Content-type: application/json');

try {
    $dms_ok = array(
        'action'=>'string',
        'cucode'=>'string',
        'member'=>'string',
        'applianceip'=>'string',
        'requesttype'=>'string',
        'timestart'=>'string',
        'timeend'=>'string'
    );
    dms_import($dms_ok);

    $action = isset($action) ? trim($action) : "";

    $aryResult = array();
    $aryReply = array();

    $dbh = $link;

    switch ($action) {
        case 'search':

            // Setup the where clause depending on parameters
            $sqlWhere = "";

            if (strlen($cucode) > 0) {
                $cucode = strtoupper($cucode);
                $cucode = prep_save($cucode, 12);
                $sqlWhere .= " cu = '{$cucode}' AND";
            }

            if (strlen($member) > 0) {
                $member = trim($member);
                $member = prep_save($member, 12);
                $sqlWhere .= " accountnumber = '{$member}' AND";
            }

            if (strlen($applianceip) > 0) {
                $applianceip = trim($applianceip);
                $applianceip = prep_save($applianceip, 100);
                $sqlWhere .= " appliance_ip = '{$applianceip}' AND";
            }

            if (strlen($requesttype) > 0) {
                $requesttype = trim($requesttype);
                $requesttype = prep_save($requesttype, 20);
                $sqlWhere .= " request_type = '{$requesttype}' AND";
            }

            if (strlen($timestart) > 0) {
                $dateStart = strtotime($timestart);
                $timestart = date('Y-m-d H:i:s', $dateStart);
                $sqlWhere .= " request_start >= '{$timestart}' AND";

                // Since End time must have a start date, we check for end time in side
                // this if statement.
                if (strlen($timeend) > 0) {
                    $dateEnd = strtotime($timeend);
                    $timeend = date('Y-m-d H:i:s', $dateEnd);
                    $sqlWhere .= " request_end <= '{$timeend}'";
                }
            }

            // Trim last occurence of AND
            $sqlWhere = trim($sqlWhere);
            $sqlWhere = rtrim($sqlWhere, "AND");

            $sql = "
                SELECT cu, appliance_ip, accountnumber, request_type, request_url, request_start, request_end, request_elapsed, request_status, remote_ip
                FROM cucorerequests ccr";
            if (strlen($sqlWhere) > 0) {
                $sql .= " WHERE $sqlWhere ORDER BY id";
            }
            logtofile(print_r($sql, true));

            $sqlRs = db_query($sql, $dbh);
            if (!$sqlRs) {
                throw new Exception(db_last_error(), 2);
            }

            $i = 0;
            $aryReply['requests'] = array();
            while ($row = db_fetch_assoc($sqlRs, $i++)) {
                // Must decode this field so it will display properly on client
                $status = json_decode($row['request_status']);
                $row['request_status'] = $status;
                $aryReply['requests'][] = $row;
            }
            break;

        default:
            throw new Exception("Requested action not recognized: $action", 1);
            break;
    }
} catch (Exception $e) {
    $aryReply = array();
    $aryReply['error'] = $e->getMessage();
}

print json_encode(array("Results" => $aryReply));

function logtofile($msg) {
    $fh = fopen('/tmp/mgh.log', 'a+');
    fwrite($fh, $msg);
    fclose($fh);
}
?>