Биллинговая система Nodeny

$eurl='';				# end url - строка, дописываемая к запросу в кнопках страниц
$Fw=int $F{w};				# кнопка `Вид` - какие столбцы выводить в списке
$eurl.="&w=$Fw" if $Fw;
$Fed=int $F{ed};			# единица измерения трафика (Мб/кб/байт)
$eurl.="&ed=$Fed" if $Fed;
$Fed||=2;				# по умолчанию целые Мб
$Fed--;

$sdbtr=`date +x%Yx%-mx%-d`;
$au_t=time();
$au_t=$au_t-300;#период вермени за какой будем считать траф если упользователя стоит всегда онлине

# =======================
#         Поиск
# =======================

$sel_from_users="id FROM users WHERE $where_grp";
$sel_from_fullusers="id FROM fullusers WHERE $where_grp";
$sel_from_users=$sel_from_fullusers if abs($F{sort})>5; 

$sel_from_users_au="users.id as id,ip,`in`,`out` from users left join $sdbtr on users.id=$sdbtr.mid where (auth<>'no' and lstate=0) or (time>$au_t  and auth='no' and lstate>0) group by users.id";

 '2' => ["$sel_from_users_au",			'Авторизованные в данный момент'],

  while( %h=%{ $sql2->get_line } )
   {
      $at=$oln='';
      # показать метод авторизации
      if( $show_auth_m && nSql->new({
           dbh	=>$dbh,
           sql	=>"SELECT act,time FROM login WHERE act>0 AND mid=$h{id} ORDER BY time DESC LIMIT 1",
           show	=> 'line',
           comment => 'Последняя авторизация',
           hash	=>\%hh }) )
	{
	    $auth_t=$hh{time}>0 && '('.&the_short_time($hh{time},$t).')';
	    $auth_t=~s| | |g;
	    $auth_t.='  ';
	    $at=$h{auth};
	}else{
	    $auth_t=' ';
	    $sthst=&sql($dbh," select sum(`in`) as `in`,sum(`out`) as `out` from $sdbtr where mid=$h{id} and time>$au_t limit 1");
	    $pst=$sthst->fetchrow_hashref();
	    $tin=$pst->{in};
	    $tout=$pst->{out};
	    if (($tin >0)&($tout>0))
		{
		    $at="on";
		    $oln=1;
		}
	}
	if ($oln == 1)
	    {
		$ips_tbl.=&tag('tr',
		&tag('td',$auth_t,'width=50%').
		&tag('td',&ShowModeAuth($at),'width=1%').
		&tag('td',$h{ip}).
		&tag('td',$h{lstate}? &tag('acronym','♥',"title='всегда online активность входящий=".$tin." исходящий=".$tout."' class=error") : '  ','width=1%')
		 );
	    }else{
		$ips_tbl.=&tag('tr',
		&tag('td',$auth_t,'width=50%').
		&tag('td',&ShowModeAuth($h{auth}),'width=1%').
		&tag('td',$h{ip}).
		&tag('td',$h{lstate}? &tag('acronym','♥',"title='всегда online активность входящий=".$tin." исходящий=".$tout."' class=error") : '  ','width=1%')
		    );
	    }
	$ids.=&RRow('','c',$h{id});
   }

#!/usr/bin/perl

use DBI;
use Time::localtime;
use Time::HiRes qw (gettimeofday tv_interval);
#28 сентябрь 2010
$tme=time();
$capl='/usr/local/nodeny/web/calls.pl';
$main_config='/usr/local/nodeny/nodeny.cfg.pl';
print ("error: not file /usr/local/nodeny/conf.cfg.pl") unless -e $main_config;
eval{require $main_config};
eval{require $capl};

$DSN="DBI:mysql:database=$db_name;host=$db_server;mysql_connect_timeout=$mysql_connect_timeout";
$dbh=DBI->connect($DSN,$user,$pw,{PrintError=>1});

$sdbtr=`date +x%Yx%-mx%-d`;
$au_t=time();
$au_t=$au_t-300;
$sth=$dbh->prepare(" select users.id as id,ip,`in`,`out` from users left join $sdbtr on users.id=$sdbtr.mid where lstate>0 and time>$au_t group by users.id; ");
$sth->execute;
while ($p=$sth->fetchrow_hashref)
    {
	$use_id=$p->{id};
	$tin=$p->{in};
	$tout=$p->{out};
	if (($tin > 0)&($tout > 0))
	    {
		$rsh = $dbh->prepare("INSERT INTO dblogin set mid=$use_id,act=17,time=unix_timestamp()");
		$rsh->execute();
	 }
    }
1;

#!/bin/sh

while true
do
 nice -n -15 perl /usr/local/nodeny/autv.pl
 sleep 120
done

#!/bin/sh

while true
do
 nice -n -15 perl /usr/local/nodeny/autv.pl
 sleep 120
done

#!/usr/bin/perl -w

use strict;
use DBI;

my $config = "/usr/local/nodeny/nodeny.cfg.pl";
print "error: $!\n" if ! -e $config;
eval{require $config};
our($query,$traf_tbl,$dbh,$db_name,$db_server,$user,$pw);

my($sec,$min,$hour,$mday,$mon,$year) = localtime;
$traf_tbl=sprintf("x%dx%dx%d",$year+1900,$mon+1,$mday);
$query = "INSERT INTO dblogin (mid,act,time) SELECT `users`.`id`,'17',UNIX_TIMESTAMP() FROM `users` LEFT JOIN `$traf_tbl` ON `users`.`id`=`$traf_tbl`.`mid` WHERE `in` > 0 AND `out` > 0 AND `$traf_tbl`.`time`>=(SELECT time FROM traf_info ORDER BY time DESC LIMIT 1) AND `users`.`lstate`>0";
$dbh = DBI->connect("DBI:mysql:$db_name:$db_server",$user,$pw,{ PrintError => 1}) or die;
print "error: $!\n" if $dbh->do($query) lt 0;
$dbh->disconnect;

#!/usr/bin/perl -w

use strict;
use DBI;

my $config = "/usr/local/nodeny/nodeny.cfg";
print "error: $!\n" if ! -e $config;
eval{require $config};
our($query,$traf_tbl,$dbh,$Db_name,$Db_server,$Db_user,$Db_pw);

my($sec,$min,$hour,$mday,$mon,$year) = localtime;
$traf_tbl=sprintf("x%dx%dx%d",$year+1900,$mon+1,$mday);
$query = <<QUERY;
INSERT INTO dblogin (mid,act,time)
        SELECT `users`.`id`,'17',UNIX_TIMESTAMP()
        FROM `users`
        LEFT JOIN `$traf_tbl` ON `users`.`id`=`$traf_tbl`.`mid`
        WHERE `in` > 0 AND `out` > 0 AND `$traf_tbl`.`time`>=%s AND `users`.`lstate`>0
QUERY
$dbh = DBI->connect("DBI:mysql:$Db_name:$Db_server",$Db_user,$Db_pw,{ PrintError => 1}) or die;
if ($ARGV[0] && $ARGV[0] eq "trigger"){
        print "Trigger\n";
        $query = sprintf($query,"NEW.time");
        $dbh->do("DROP TRIGGER IF EXISTS `tr_aoauth`");
        $dbh->do("CREATE TRIGGER `tr_aoauth` AFTER INSERT ON `traf_info` FOR EACH ROW BEGIN $query; END");
        exit;
}
$query = sprintf($query,"(SELECT time FROM traf_info ORDER BY time DESC LIMIT 1)");
print "error: $!\n" if $dbh->do($query) lt 0;
$dbh->disconnect;

$dbh->do("CREATE TRIGGER `tr_aoauth` AFTER INSERT ON `traf_info` FOR EACH ROW BEGIN $query; END");

$dbh->do("CREATE TRIGGER `tr_aoauth` AFTER INSERT ON `traf_info` FOR EACH ROW BEGIN IF NEW.cod=1 THEN $query; END IF; END");

1953   $rows=0;
1954    foreach $i (1..8)
1955   {
1956       $rows=$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if (!$rows && $IN[$i] gt 0 && $OUT[$i] gt 0);

1953 $dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if ($IN[1] gt 0 && $OUT[1] gt 0);

  foreach $i (1..7)
   {
      next unless $IN[$i]+$OUT[$i];
      if( $ModTraf{$mId}{$i} )
      {  # платеж-опция указывает трафик направления $i перераспределить на направление 8
         $IN[8]+=$IN[$i];
$rows=0;
foreach $i (1..8)
{
$rows=$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if (!$rows && $IN[$i] gt 0 && $OUT $i] gt 0);
         $IN[$i]=0;
         $OUT[8]+=$OUT[$i];
         $OUT[$i]=0;
      }
   }

foreach $i (1..8)
{
   next unless $IN[$i]+$OUT[$i];

$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if ($IN[1] gt 0 && $OUT[1] gt 0);

$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if ($IN[1] gt 0 && $OUT[1] gt 0);
foreach $i (1..8)
{
   next unless $IN[$i]+$OUT[$i];

$rows=0;
foreach $i (1..8)
{
$rows=$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if (!$rows && $IN[$i] gt 0 && $OUT[$i] gt 0);
next unless $IN[$i]+$OUT[$i];

 $rows=0;
 $ao=$dbh->do("SELECT count(id) FROM users WHERE lstate=1 AND id=$id LIMIT 1") if !$rows;
 foreach $i (1..8)
 {
    $rows=$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if ($ao && !$rows && $IN[$i] gt 0 && $OUT[$i] gt 0);

$ao=$dbh->do("SELECT count(id) FROM users WHERE lstate=1 AND id=$id LIMIT 1");
$dbh->do("INSERT INTO dblogin (mid,time,act) VALUES($id,UNIX_TIMESTAMP(),'17')") if ($ao && $IN[1] gt 0 && $OUT[1] gt 0);

$Kern_t_traf*2

1974    &CountMoney($id);
1975  }
1976
1977  $dbh->do("INSERT INTO dblogin (mid,act,time) SELECT `users`.`id`,'17',UNIX_TIMESTAMP() FROM `users` LEFT JOIN `$x_traf_tbl` ON `users`.`id`=`$x_traf_tbl`.`mid` WHERE `in` > 0 AND `out` > 0 AND `$x_traf_tbl`.`time`>$t-$Kern_t_traf*2 and `users`.`lstate`>0 group by users.id");
1978
1979  &SaveTrafTime(3,tv_interval($t0));

1974    &CountMoney($id);
1975  }
1976
1977  $dbh->do("INSERT INTO dblogin (mid,act,time) SELECT `users`.`id`,'17',UNIX_TIMESTAMP() FROM `users` LEFT JOIN `$x_traf_tbl` ON `users`.`id`=`$x_traf_tbl`.`mid` WHERE `in` > 0 AND `out` > 0 AND `$x_traf_tbl`.`time`>$t-$Kern_t_traf*2 and `users`.`lstate`>0 group by users.id");
1978
1979  &SaveTrafTime(3,tv_interval($t0));

 892 # Показывает режим авторизации в виде ключика определенного цвета
 893 sub ShowModeAuth
 894 {
 895  my ($mod)=@_;
 896  local $_="<img src='$img_dir";
 897  return ("$_/spacer.gif' width=16>") if $mod eq 'no';
 898  return ("$_/on.gif' title='Авторизован. Доступ разрешен'>") if $mod eq 'on';
 899  return ("$_/off.gif' title='Авторизован в режиме \"сеть\"'>") if $mod eq 'off';
 900  return ("$_/on2.gif' title='Авторизован. Разрешен только $c2 трафик'>") if $mod eq 'ong';
 901  return ("$_/block.gif' title='Авторизован. Доступ заблокирован: превышен лимит трафика''>") if $mod eq '1';
 902  return ("$_/block.gif' title='Авторизован. Доступ заблокирован: превышен лимит денежной задолженности'>") if $mod eq '2';
 903  return ("$_/block.gif' title='Авторизован. Доступ заблокирован: в данное время суток по условию пакета'>") if $mod eq '4';
 904  return ("$_/block.gif' title='Авторизован. Доступ заблокирован.'>") if $mod eq '5';
 905  return ("$_/spacer.gif'>");
 906 }

1974    &CountMoney($id);
1975  }
1976
1977  $dbh->do("INSERT INTO dblogin (mid,act,time) SELECT `users`.`id`,'17',UNIX_TIMESTAMP() FROM `users` LEFT JOIN `$x_traf_tbl` ON `users`.`id`=`$x_traf_tbl`.`mid` WHERE `in` > 0 AND `out` > 0 AND `$x_traf_tbl`.`time`>$t-$Kern_t_traf*2 and `users`.`lstate`>0 group by users.id");
1978
1979  &SaveTrafTime(3,tv_interval($t0));

return ("$_/on2.gif' title='Авторизован. Всегда онлайн.'>") if $mod eq '17';

# Показывает режим авторизации в виде ключика определенного цвета
sub ShowModeAuth
{
 my ($mod)=@_;
 local $_="<img src='$img_dir";
 return ("$_/spacer.gif' width=16>") if $mod eq 'no';
 return ("$_/on.gif' title='Авторизован. Доступ разрешен'>") if $mod eq 'on';
 return ("$_/off.gif' title='Авторизован в режиме \"сеть\"'>") if $mod eq 'off';
 return ("$_/on2.gif' title='Авторизован. Разрешен только $c2 трафик'>") if $mod eq 'ong';
 return ("$_/block.gif' title='Авторизован. Доступ заблокирован: превышен лимит трафика''>") if $mod eq '1';
 return ("$_/block.gif' title='Авторизован. Доступ заблокирован: превышен лимит денежной задолженности'>") if $mod eq '2';
 return ("$_/block.gif' title='Авторизован. Доступ заблокирован: в данное время суток по условию пакета'>") if $mod eq '4';
 return ("$_/block.gif' title='Авторизован. Доступ заблокирован.'>") if $mod eq '5';
 return ("$_/spacer.gif'>");
}

$auth_src=(' ','Авторизатор','На порту','Web-авторизация','PPPoE','','','','')[int($act/10)];

$tmr=30;

$tmr=time-30;