X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fphone_avail.pm;h=677195d9248938bd2ca3a392c7d0f88ee30fa815;hb=38458c0c9135228828b5a477ed1710ef687ec3d3;hp=967d7179e4228fedd5e26452f0b4956aa961e024;hpb=a09250fdfe56ce6c9cea038e4e16f3a749460aa4;p=freeside.git diff --git a/FS/FS/phone_avail.pm b/FS/FS/phone_avail.pm index 967d7179e..677195d92 100644 --- a/FS/FS/phone_avail.pm +++ b/FS/FS/phone_avail.pm @@ -162,6 +162,17 @@ sub cust_svc { qsearchs('cust_svc', { 'svcnum' => $self->svcnum }); } +=item part_export + +=cut + +sub part_export { + my $self = shift; + return '' unless $self->exportnum; + qsearchs('part_export', { 'exportnum' => $self->exportnum }); +} + + sub process_batch_import { my $job = shift; @@ -184,6 +195,21 @@ sub process_batch_import { } +sub flush { # evil direct SQL + my $opt = shift; + + if ( $opt->{'ratecenter'} =~ /^[\w\s]+$/ + && $opt->{'state'} =~ /^[A-Z][A-Z]$/ + && $opt->{'exportnum'} =~ /^\d+$/) { + my $sth = dbh->prepare('delete from phone_avail where exportnum = ? '. + ' and state = ? and name = ?'); + $sth->execute($opt->{'exportnum'},$opt->{'state'},$opt->{'ratecenter'}) + or die $sth->errstr; + } + + ''; +} + # Used by FS::Upgrade to migrate to a new database. sub _upgrade_data { my ($class, %opts) = @_;