mCorerequestsReport.data

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

// ** Include required SCRIPTS
$monLibrary= dirname(__FILE__) . "/../library";
$monIncludes= dirname(__FILE__) . "/../includes";
$sharedLibrary= dirname(__FILE__) . "/../../shared/library";
require_once("$monLibrary/cu_top.i");
require_once("$monLibrary/ck_hticket.i");
require_once("$monIncludes/cu_remote_top.prg");
require_once("$sharedLibrary/cutrusted.i");
require_once("$sharedLibrary/hcuErrorReport.i");

try {

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

        $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;

            case "read_cus":
        /*
        * list the cu codes from database for odyssey
        */
                try {

                    $sql = "SELECT user_name FROM cuinfo ORDER BY user_name";
                    if (!$sql) {
                        throw new Exception(db_last_error(), 2);
                    }

                    $rs = db_query($sql, $dbh);
                    $cuList = array();
                    $iRow = 0;
                    $aryReply = array();
                    while ( $cuRow = db_fetch_assoc($rs, $iRow++) ) {
                        $cuList[] = trim( $cuRow["user_name"] );
                    }

                } catch (Exception $ex) {
                    $cuList[] = [];

                }

                $aryReply['data'] = $cuList;

                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);
}
?>