<?php
// Переменные для коннекта к базе mysql.
$hostname = "localhost";
$username = "root";
$password = "asdfasdfasdfasdf";
$dbName = "UTM5";

// Соединенте с базой.
mysql_connect($hostname,$username,$password) OR DIE("Не могу создать соединение ");
mysql_select_db($dbName) or die(mysql_error());

$log_file = "/netup/utm5/log/bonuses/bonus_".date("Y_m_d").".log";
$file_handle = fopen($log_file,"a+");

fwrite($file_handle, date("d.m.Y H:i:s")."\r\n");

//echo "Выбираем расчетные периоды которые закончался не ранее чем через сутки,
//но! выбираем только расчетыне периоды длинной более 28 дней (високосный февраль).";
$query0 = "SELECT `id` ,from_unixtime(`start_date`), from_unixtime(`end_date`),
            `periodic_type`, `next_discount_period_id`, `discount_interval`,
            `canonical_len`, `is_expired`, `custom_duration`, `static_id`
           FROM `discount_periods`
           WHERE `canonical_len` >= 2419200
            AND `is_expired` = 0
            AND `end_date` <= ( unix_timestamp( CURDATE( ) ) + 172799)";
mysql_query("SET NAMES utf8");
$res0 = mysql_query($query0) or die(mysql_error());
$number = mysql_num_rows($res0);

if ($number=='0') {
    $pr = "Нет таковых на сегодняшний день... \n";
    fwrite($file_handle, date("d.m.Y H:i:s")."\r\n".print_r($pr ,true)."\r\n");
    exit;
}

while ($row0 = mysql_fetch_array($res0)) {
    $i++;
    $dpid = $row0[0];
    $expdate = $row0[1];
    $query1 = "SELECT `id`, `account_id`, `tariff_id`, `next_tariff_id`,
                `discount_period_id`, `is_deleted`, from_unixtime(`link_date`)
               FROM `account_tariff_link`
               WHERE `is_deleted` = 0 AND `discount_period_id` =".$dpid;
    mysql_query("SET NAMES utf8");
    $res1 = mysql_query($query1) or die(mysql_error());

    while ($row1 = mysql_fetch_array($res1)) {
        $acid = $row1[1];
        $tid = $row1[2];
        $tnid = $row1[3];
        $cost = 0;
        $query2 = "SELECT `id`, `tariff_id`, `service_id`, `is_deleted`
                   FROM `tariffs_services_link`
                   WHERE `is_deleted` = 0 AND `tariff_id` =".$tnid;
        mysql_query("SET NAMES utf8");
        $res2 = mysql_query($query2) or die(mysql_error());
        while ($row2 = mysql_fetch_array($res2)) {
            $slid = $row2[2];
            $query3 = "SELECT `id`, `cost`, `discount_method`, `start_date`,
                        `expire_date`, `radius_sessions_limit`, `is_deleted`
                       FROM `periodic_services_data`
                       WHERE `is_deleted`= 0 and `id` =".$slid;
            mysql_query("SET NAMES utf8");
            $res3 = mysql_query($query3) or die(mysql_error());
            while ($row3 = mysql_fetch_array($res3)) {
                $cost = $cost+$row3[1];
            }
        }
#       $discont=$cost*0.1;
        $query4 = "SELECT `id`, `account_id`, `block_type`, from_unixtime(`start_date`),
                    from_unixtime(`expire_date`), `is_planning`, `is_deleted`, `unabon`,
                    `unprepay`
                   FROM `blocks_info`
                   WHERE expire_date >= unix_timestamp(DATE_SUB(NOW(), INTERVAL 90 DAY))
                    AND `account_id`=".$acid;
        mysql_query("SET NAMES utf8");
        $res4 = mysql_query($query4) or die(mysql_error());
        $number4 = mysql_num_rows($res4);
        if ($number4=='0') {
            $query5 = "SELECT * FROM `users` WHERE `is_deleted`=0
                        AND `is_juridical`=0
                        AND `id`=".$acid;
            mysql_query("SET NAMES utf8");
            $res5 = mysql_query($query5) or die(mysql_error());
            $row5 = mysql_fetch_array($res5);
            $createdate = $row5[5];
            $timestamp = time();
            print "Create date     : ".$createdate." - ".date( 'H:i d-m-y', $createdate)."\n";
            print "Now date        : ".$timestamp." - ".date( 'H:i d-m-y', $timestamp)."\n";
            $oneyear = $timestamp-(60*60*24*30*12);
            $twoyear = $timestamp-(60*60*24*30*24);
#           print "12 month lather : ".$oneyear." - ".date( 'H:i d-m-y', $oneyear)."\n";
#           print "24 month lather : ".$twoyear." - ".date( 'H:i d-m-y', $twoyear)."\n";
            if ($createdate>$twoyear) { $discount = 3; }
            if ($createdate<$oneyear) { $discount = 5; }
            if ($createdate<$twoyear) { $discount = 10; }
            print "Discaunt : ".$discount."\n";
            $discont = $cost*$discount/100;
            $a = "Можно начислить бонус этому абоненту... \n ";
            $b = "Аккаунт абонента: ".$row1[1]." \n ID текущего тарифа: ".$row1[2]." \n ID Следующего тарифа: ".$row1[3]." \n ";
            $c = "ID услуги: ".$slid." \n ";
            $d = "Стоимость тарифа : ".$cost." рублей. \n ";
            $e = "Возможный бонус : ".$discont." рублей  \n ";
            $insert = "INSERT INTO my.bonus (id, name, description, date_start, date_stop,
                        account, summa, active )
                       VALUES (NULL , 'Бонус \"Точно в срок\"',
                        'Уважаемый абонент ООО \"Интертелеком\". Вы в течении последних 90 суток в срок производили оплату услуг, в связи с этим вам начислен бонус, в размере ".$discount."% от стоимости вашего тарифного плана. Процент бонуса засисит от продолжительности обсуживания в нашей компании.',
                        CURDATE( ) , (CURDATE( ) + INTERVAL 30 DAY), '".$row1[1]."', '".$discont."', '1')";
            print $a.$b.$c.$d.$e."\n";
            $f = $insert;
            print $insert."\n";
            mysql_query("SET NAMES utf8");
            $result = mysql_query($insert) or die(mysql_error());
            $g = $result;
            $pr = $a.$b.$c.$d.$e.$f.$g." \n ";
            fwrite($file_handle, print_r($pr,true)."\r\n");
            $bonus = 1;
            $summ_bonus = $summ_bonus + $discont;
        }
        if ($number4>'0') { $bonus = 0; }
        $count_bonus = $count_bonus + $bonus;
    }
}

$a1 = "Всего записей найдено: ".$i." \n ";
$b1 = "Можно начислить бонусов: ".$count_bonus." \n ";
$c1 = "На сумму: ".$summ_bonus." рублей \n ";
$d1 = " \n ---------------------------------------------------------------- \n ";
$pr = $a1.$b1.$c1.$d1;
fwrite($file_handle, print_r($pr,true)."\r\n");
?>