Broken pipe

#!/usr/bin/perl
use strict;
use DBI;
 
my $debug=1; 
my $prefix_add_count=7; #К-во знаков в локальном наборе (меньше этого будем прибавлять prefix_add)
my $prefix_add='7812'; #Что прибавлять
 
my $allow_nowmonth_credit=1; # Разрешить не отключать локльную связь в этом месяце
 
open F , "/etc/bill.conf" or die ("Can't open config file: /etc/bill.conf\n");
my @lines=;
my $config;
foreach (@lines){
 chomp;
 next if /^#/;
 next if /^;/;
 ~s/\s//g;
 my ($name,$value)=split(/=/);
 $config->{$name}=$value;
}
close F;
 
my ($dbase,$user,$password);
 
$dbase = "DBI:mysql:".$config->{dbase}.":".$config->{dbhost} if (defined $config->{dbhost} && defined $config->{dbase});
$user = $config->{dbuser} if (defined $config->{dbuser});
$password = $config->{dbpassword} if (defined $config->{dbpassword});
 
die ("Database, username or password not specified in /etc/bill.conf!\n") if (!($dbase && $user && $password));
 
my $db = DBI->connect($dbase,$user,$password) or { die("Cannot open database $_") };
 
# Setup some variables
my %AGI; 
 
while() {
 chomp;
 last unless length($_);
 if (/^agi_(\w+)\:\s+(.*)$/) {
 $AGI{$1} = $2; 
 }
}
 
if ($debug){
 print "VERBOSE \"BILLING_CLIENT_OUT: AGI Environment Dump:\" 5\n";
 foreach my $i (sort keys %AGI) {
 print STDERR " -- \n";
 print "VERBOSE \"BILLING_CLIENT_OUT: AGI VARIABLE $i = $AGI{$i}\" 5\n" ;
 } 
}
my $dst_number=fix_number($AGI{extension});
verbose("DIALING NUMBER = $dst_number");
 
my $src_channel;
if ($AGI{channel}=~/^.*?\/(.*?)-[^-]+$/i){
 $src_channel=$1; 
 verbose("SOURCE CHANNEL = $src_channel");
}
 
my $phone_id=$AGI{accountcode};
verbose("ACCOUNT CODE = $phone_id");
 
my $force_max_duration=50*60;
 
if ($phone_id){
 my $mask_info=$db->selectrow_hashref("
 SELECT trfzone_id,
 group_id,
 mask
 FROM phones_masks
 WHERE is_active=1 AND '".$dst_number."' LIKE CONCAT ( country_code, mask, '%' )
 ORDER BY LENGTH ( CONCAT ( country_code, mask ) ) DESC
 LIMIT 1
 ");
 if ($mask_info){
 my $user_info=$db->selectrow_hashref("
 SELECT up.allow_city,
 up.allow_mobile,
 up.allow_crosscity,
 up.allow_crosscountry,
 up.enabled,
 us.uid,
 u.balance + COALESCE((SELECT SUM(summ) FROM pays_promise WHERE uid=u.id AND date_end>NOW() AND completed=0),0) as balance,
 u.lim_money,
 u.paytype,
 ua.status,
 EXTRACT(YEAR_MONTH FROM ua.refdate) as yearmonth_status,
 EXTRACT(YEAR_MONTH FROM NOW()) as yearmonth_now,
 ttz.price_min
 
 FROM users_phones up
 JOIN users_services us ON (up.service=us.id)
 JOIN users u ON (us.uid=u.id)
 JOIN users_active ua ON (u.curstatus_id=ua.id)
 JOIN users_services_tarif ust ON (us.curr_service_tarif_id=ust.id)
 JOIN tarifs t ON (ust.tarif=t.trf_id)
 JOIN tarifs_trfzones ttz ON (ttz.trf_id=t.trf_id AND ttz.is_active=1 AND ttz.trfzone_id=$mask_info->{trfzone_id})
 
 WHERE up.id = $phone_id
 ");
 
 if ($user_info){
 if ($user_info->{enabled}){
 if ($user_info->{status}==1){ 
 if (($mask_info->{group_id}==1 && $user_info->{allow_city}) ||
 ($mask_info->{group_id}==2 && $user_info->{allow_mobile}) ||
 ($mask_info->{group_id}==3 && $user_info->{allow_crosscity}) ||
 ($mask_info->{group_id}==4 && $user_info->{allow_crosscountry})){ 
 #verbose("BALANCE:".$user_info->{balance});
 my $maxduration;
 if ($user_info->{paytype}==1 || $user_info->{balance}>=$user_info->{lim_money} || $user_info->{price_min}==0){
 $maxduration=int($user_info->{balance}/$user_info->{price_min})*60 if ($user_info->{price_min});
 if (!$maxduration || $maxduration$force_max_duration){
 $maxduration=$force_max_duration;
 verbose("Setting max duration to 50 minutes");
 }
 #$maxduration=30;
 print "SET VARIABLE TIMEOUT(absolute) \"$maxduration\" \n" if ($maxduration);
 verbose("allow, cost per minute: ".$user_info->{price_min}." maximum call duration: ".$maxduration." seconds" ); 
 } else {
 verbose("Balance < 0");
 forbidden();
 } 
 } else {
 #this type of service was disabled
 verbose("this type of service is disabled");
 forbidden();
 }
 } else {
 if ($allow_nowmonth_credit && $user_info->{yearmonth_status} eq $user_info->{yearmonth_now} && $user_info->{price_min}==0){
 #was disabled in current month
 #allow free calls
 print "SET VARIABLE TIMEOUT(absolute) \"$force_max_duration\" \n" if ($force_max_duration);
 verbose("allow, cost per minute: ".$user_info->{price_min}." maximum call duration: ".$force_max_duration." seconds" ); 
 } else { 
 verbose("billing status=".$user_info->{status});
 forbidden_nomoney();
 }
 } 
 } else {
 #enable!=1
 verbose("enable!=1");
 forbidden();
 }
 } else { 
 verbose("account_code not found");
 forbidden();
 }
 } else {
 # UNKNOWN MASK
 verbose("no such mask"); 
 forbidden();
 } 
}
 
sub verbose{
 my $message=shift;
 my $level=shift || 1;
 print "VERBOSE \"BILLING_CLIENT_OUT: [account:".$AGI{accountcode}."] dialing ".fix_number($AGI{extension}).": ".$message."\" ".$level."\n";
}
 
sub forbidden{
 verbose("access forbidden"); 
 print "EXEC PLAYBACK \"custom/bill/message_call_forbidden\" \n";
 #print "EXEC PLAYBACK \"custom/bill/curstatusis&custom/bill/curstatusis-nomoney\" \n";
 print "HANGUP ".$AGI{channel}."\n";
}
 
sub forbidden_nomoney{
 verbose("access forbidden: no money"); 
 print "EXEC PLAYBACK \"custom/bill/message_call_forbidden_nomoney\" \n";
 #print "EXEC PLAYBACK \"custom/bill/curstatusis&custom/bill/curstatusis-nomoney\" \n";
 print "HANGUP ".$AGI{channel}."\n";
}
 
sub fix_number{
 my $number=shift;
 $number=$prefix_add.$number if (length($number)> agi_request: bill/client_out.pl
AGI Tx >> agi_channel: SIP/78126409768-00064f44
AGI Tx >> agi_language: en
AGI Tx >> agi_type: SIP
AGI Tx >> agi_uniqueid: 1309263202.413508
AGI Tx >> agi_version: 1.6.2.11
AGI Tx >> agi_callerid: 78126409768
AGI Tx >> agi_calleridname: 78126409768
AGI Tx >> agi_callingpres: 0
AGI Tx >> agi_callingani2: 0
AGI Tx >> agi_callington: 0
AGI Tx >> agi_callingtns: 0
AGI Tx >> agi_dnid: 6408640
AGI Tx >> agi_rdnis: unknown
AGI Tx >> agi_context: silverbill4-out
AGI Tx >> agi_extension: 6408640
AGI Tx >> agi_priority: 1
AGI Tx >> agi_enhanced: 0.0
AGI Tx >> agi_accountcode: 221
AGI Tx >> agi_threadid: 140528377334032
AGI Tx >> 
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx > 200 result=1
[Jun 28 16:13:22] ERROR[26638]: utils.c:1128 ast_carefulwrite: write() returned error: Broken pipe
AGI Rx