source: temp/trunk/html/admin/batch/daily.php @ 3466

<?php

$daily_php_dir = realpath(dirname( __FILE__));
require_once($daily_php_dir . "/../require.php");

$term = 0;
$start = 1; // ½¸·×´ü´Ö¤Ï¡¢$start¢·$term¤Î´Ö¤È¤Ê¤ë¡£Ä̾ïÁ°Æüʬ¤«¤é¡£
$command = false;

// ½¸·×Âоݴü´Ö¤Î¼èÆÀ¡Ê»ØÄêÆüʬ¤µ¤«¤Î¤Ü¤ë)
if (sfIsInt($argv[1]) && $argv[1] <= 365) {
    $term = $argv[1];
    $command = true;
}

// ½¸·×³«»ÏÆü
if (sfIsInt($argv[2]) && $argv[2] <= 365) {
    $start = $argv[2];
    $command = true;
}

if($term > 0) {
    // ½¸·×¤Î³«»Ï
    lfStartDailyTotal($term, $start, $command);
}

// ½¸·×¤Î³«»Ï
function lfStartDailyTotal($term, $start, $command = false) {
        
    $now_time = time();
        
    // ¥°¥é¥Õ²èÁü¤Îºï½ü
    $path = GRAPH_DIR . "*.png";
    system ("rm -rf $path");
    
    // ºï½ü¤µ¤ì¤¿¼õÃí¥Ç¡¼¥¿¤Î¼õÃí¾ÜºÙ¾ðÊó¤Îºï½ü
    $objQuery = new SC_Query();
    $where = "order_id IN (SELECT order_id FROM dtb_order WHERE delete = 1)";
    $objQuery->delete("dtb_order_detail", $where);
    
    // ºÇ¸å¤Ë¹¹¿·¤µ¤ì¤¿ÆüÉÕ¤ò¼èÆÀ
    $ret = $objQuery->max("dtb_bat_order_daily", "create_date");
    list($batch_last) = split("\.", $ret);
    $pass = $now_time - strtotime($batch_last);
        
    // ºÇ¸å¤Î¥Ð¥Ã¥Á¼Â¹Ô¤«¤éLOAD_BATCH_PASSÉ÷вᤷ¤Æ¤¤¤Ê¤¤¤È¼Â¹Ô¤·¤Ê¤¤¡£
    if($pass < LOAD_BATCH_PASS) {
        gfPrintLog("LAST BATCH " . $arrRet[0]['create_date'] . " > " . $batch_pass . " -> EXIT BATCH $batch_date");
        return;
    }
        
    // ½¸·×
    for ($i = $start; $i < $term; $i++) {
        // ´ðËÜ»þ´Ö¤«¤é$iÆüʬ¤µ¤«¤Î¤Ü¤ë
        $tmp_time = $now_time - ($i * 24 * 3600);
                
        $batch_date = date("Y/m/d", $tmp_time);
        gfPrintLog("LOADING BATCH $batch_date");
                    
        lfBatOrderDaily($tmp_time);
        lfBatOrderDailyHour($tmp_time);
        lfBatOrderAge($tmp_time);
    }
}

// ¥ê¥¢¥ë¥¿¥¤¥à¤Ç½¸·×¤ò¼Â»Ü¤¹¤ë¡£½¸·×¤¬½ªÎ»¤·¤Æ¤¤¤ë¥ì¥³¡¼¥É¤Ï¼Â»Ü¤·¤Ê¤¤¡£
/*
    $sdate:YYYY-MM-DD hh:mm:ss·Á¼°¤ÎÆüÉÕ
    $edate:YYYY-MM-DD hh:mm:ss·Á¼°¤ÎÆüÉÕ
*/
function lfRealTimeDailyTotal($sdate, $edate) {
    $pass = strtotime($edate) - strtotime($sdate);
    $loop = intval($pass / 86400);
    
    for($i = 0; $i <= $loop; $i++) {
        $tmp_time = strtotime($sdate) + ($i * 86400);
        $batch_date = date("Y/m/d H:i:s", $tmp_time);
        $objQuery = new SC_Query();
        $arrRet = $objQuery->select("order_date, create_date", "dtb_bat_order_daily", "order_date = ?", array($batch_date));
        // ¤¹¤Ç¤Ë¥Ð¥Ã¥Á½èÍý¤¬½ªÎ»¤·¤Æ¤¤¤ë¤«¥Á¥§¥Ã¥¯¤¹¤ë¡£
        if(count($arrRet) > 0) {
            list($create_date) = split("\.", $arrRet[0]['create_date']);
            list($order_date) = split("\.", $arrRet[0]['order_date']);
            $create_time = strtotime($create_date);
            $order_time = strtotime($order_date);
            // ¥ª¡¼¥À¡¼³«»ÏÆü¤è¤ê°ìÆü°Ê¾å¸å¤Ë½¸·×¤µ¤ì¤Æ¤¤¤ë¾ì¹ç¤Ï½¸·×¤·¤Ê¤ª¤µ¤Ê¤¤
            if($order_time + 86400 < $create_time) {
                gfPrintLog("EXIT BATCH $batch_date");
            }
        }
        gfPrintLog("LOADING BATCH $batch_date");
        lfBatOrderDaily($tmp_time);
        lfBatOrderDailyHour($tmp_time);
        lfBatOrderAge($tmp_time);
    }
}

// ¥Ð¥Ã¥Á½¸·×ÍѤÎSQLʸ¤ò¼èÆÀ¤¹¤ë¡£
function lfGetOrderDailySQL() {
    $sql = "SELECT ";
    $sql.= "COUNT(*) AS total_order, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE customer_id = 0)) AS nonmember, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE customer_id <> 0 GROUP BY customer_id)) AS member, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 1)) AS men, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 2)) AS women, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 1 AND customer_id <> 0)) AS men_member, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 1 AND customer_id = 0)) AS men_nonmember, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 2 AND customer_id <> 0)) AS women_member, ";
    $sql.= "SUM((SELECT COUNT(*) WHERE order_sex = 2 AND customer_id = 0)) AS women_nonmember, ";
    $sql.= "SUM(total) AS total, ";
    $sql.= "int4(AVG(total)) AS total_average ";
    $sql.= "FROM dtb_order AS T1 LEFT JOIN dtb_customer AS T2 USING ( customer_id ) ";
    $sql.= "WHERE T1.delete = 0 AND T1.create_date BETWEEN ? AND ?";        // ¼õÃíºîÀ®Æü¤Ç¸¡º÷¤¹¤ë
    return $sql;
}

// Çä¾å¤²½¸·×¥Ð¥Ã¥Á½èÍý(ÆüÊÌ)
function lfBatOrderDaily($time) {
    global $arrWDAY;
    
    $sql = lfGetOrderDailySQL();
    
    // ½¸·×ÂоÝÆü¤ò¼èÆÀ¤¹¤ë
    $date = date("Y-m-d", $time);
    
    $start = $date . " 00:00:00";
    $end = $date . " 23:59:59";
    
    $objQuery = new SC_Query();
    $arrRet = $objQuery->getall($sql, array($start, $end)); 
        
    $sqlval = $arrRet[0];
    
    // ¶õʸ»ú¤ò"0"¤ËÊÑ´¹
    foreach($sqlval as $key => $val) {
        if ($val == "") {
            $sqlval[$key] = "0";
        }
    }
    
    $sqlval['order_date'] = $start;
    $sqlval['year'] = date("Y", $time);
    $sqlval['month'] = date("m", $time);
    $sqlval['day'] = date("d", $time);
    $sqlval['wday'] = date("w", $time);
    $sqlval['key_day'] = sprintf("%02d/%02d/%02d", substr($sqlval['year'],2), $sqlval['month'], $sqlval['day']);
    $sqlval['key_month'] = sprintf("%02d/%02d", substr($sqlval['year'],2), $sqlval['month']);
    $sqlval['key_year'] = sprintf("%d", $sqlval['year']);
    $sqlval['key_wday'] = sprintf("%s", $arrWDAY[$sqlval['wday']]);
    
    $objQuery->delete("dtb_bat_order_daily", "order_date = ?", array($start));
    $objQuery->insert("dtb_bat_order_daily", $sqlval);
}

// Çä¾å¤²½¸·×¥Ð¥Ã¥Á½èÍý(»þ´ÖÊÌ) 
function lfBatOrderDailyHour($time) {
    
    $sql = lfGetOrderDailySQL();
    
    // ½¸·×ÂоÝÆü¤ò¼èÆÀ¤¹¤ë
    $date = date("Y-m-d", $time);
    $objQuery = new SC_Query();
    
    $start = $date . " 00:00:00";
    $objQuery->delete("dtb_bat_order_daily_hour", "order_date = ?", array($start));
    
    // 1»þ´ÖËè¤Ë½¸·×¤¹¤ë¡£
    for($i = 0; $i < 24; $i++) {
        $sdate = sprintf("%s %02d:00:00", $date, $i);
        $edate = sprintf("%s %02d:59:59", $date, $i);
        $arrRet = $objQuery->getall($sql, array($sdate, $edate));
        $sqlval = $arrRet[0];
        // ¶õʸ»ú¤ò"0"¤ËÊÑ´¹
        foreach($sqlval as $key => $val) {
            if ($val == "") {
                $sqlval[$key] = "0";
            }
        }
        $sqlval['order_date'] = $start;
        $sqlval['hour'] = "$i";
        $objQuery->insert("dtb_bat_order_daily_hour", $sqlval);
    }   
}

// Çä¾å¤²½¸·×¥Ð¥Ã¥Á½èÍý(ǯÎðÊÌ) 
function lfBatOrderAge($time) {
    
    $age_loop = intval(BAT_ORDER_AGE / 10);
    
    // ǯÎð¤ÎÈϰϤò»ØÄꤷ¤Æ¥Ç¡¼¥¿Ãê½Ð
    $sql.= "SELECT COUNT(*) AS order_count, SUM(total) AS total, int4(AVG(total)) AS total_average ";
    $sql.= "FROM dtb_order ";
    
    // ½¸·×ÂоÝÆü¤ò¼èÆÀ¤¹¤ë
    $date = date("Y-m-d", $time);
    
    $start = $date . " 00:00:00";
    $end = $date . " 23:59:59";
    
    $objQuery = new SC_Query();
    $objQuery->delete("dtb_bat_order_daily_age", "order_date = ?", array($start));
    
    /* ²ñ°÷½¸·× */
    
    $base_where = "WHERE (create_date BETWEEN ? AND ?) AND customer_id <> 0 AND delete = 0 ";
    $where = $base_where . " AND (to_number(to_char(age(current_timestamp, order_birth), 'YYY'), 999) BETWEEN ? AND ?) ";
    
    // ǯÎðËè¤Ë½¸·×¤¹¤ë¡£
    for($i = 0; $i <= $age_loop; $i++) {
        $start_age = $i * 10;
        $end_age = $start_age + 9;
        if($i >= $age_loop) {
            $end_age = 999;
        }
        lfBatOrderAgeSub($sql . $where, $start, $end, $start_age, $end_age, 1);
    }
    
    // ÃÂÀ¸ÆüÆþÎϤʤ·
    $where = $base_where . " AND order_birth IS NULL ";
    lfBatOrderAgeSub($sql . $where, $start, $end, NULL, NULL, 1);
    
    /* Èó²ñ°÷½¸·× */
    
    $base_where = "WHERE (create_date BETWEEN ? AND ?) AND customer_id = 0 AND delete = 0";
    $where = $base_where . " AND (to_number(to_char(age(current_timestamp, order_birth), 'YYY'), 999) BETWEEN ? AND ?) ";
    
    // ǯÎðËè¤Ë½¸·×¤¹¤ë¡£
    for($i = 0; $i <= $age_loop; $i++) {
        $start_age = $i * 10;
        $end_age = $start_age + 9;
        if($i >= $age_loop) {
            $end_age = 999;
        }
        lfBatOrderAgeSub($sql . $where, $start, $end, $start_age, $end_age, 0);
    }
    
    // ÃÂÀ¸ÆüÆþÎϤʤ·
    $where = $base_where . " AND order_birth IS NULL AND delete = 0";
    lfBatOrderAgeSub($sql . $where, $start, $end, NULL, NULL, 0);   
}

// Çä¾å¤²½¸·×¥Ð¥Ã¥Á½èÍý(ǯÎðÊÌ) ÅÐÏ¿Éôʬ
function lfBatOrderAgeSub($sql, $start, $end, $start_age, $end_age, $member) {
    $objQuery = new SC_Query();
    
    if($start_age != NULL || $end_age != NULL) {
        $arrRet = $objQuery->getall($sql, array($start, $end, $start_age, $end_age));
    } else {
        $arrRet = $objQuery->getall($sql, array($start, $end));
    }
    $sqlval = $arrRet[0];
    
    // ¶õʸ»ú¤ò"0"¤ËÊÑ´¹
    foreach($sqlval as $key => $val) {
        if ($val == "") {
            $sqlval[$key] = "0";
        }
    }
        
    $sqlval['order_date'] = $start;
    $sqlval['start_age'] = "$start_age";
    $sqlval['end_age'] = "$end_age";
    $sqlval['member'] = "$member";

    $objQuery->insert("dtb_bat_order_daily_age", $sqlval);
}

?>