X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fphone_avail.pm;h=0d591138c737c4cca28add354e9b7309863a414c;hb=c079fb7da9ff7647611754608378151259b6e2d1;hp=967d7179e4228fedd5e26452f0b4956aa961e024;hpb=a09250fdfe56ce6c9cea038e4e16f3a749460aa4;p=freeside.git diff --git a/FS/FS/phone_avail.pm b/FS/FS/phone_avail.pm index 967d7179e..0d591138c 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; @@ -177,13 +188,28 @@ sub process_batch_import { my $opt = { 'table' => 'phone_avail', 'params' => [ 'availbatch', 'exportnum', 'countrycode' ], - 'formats' => { 'default' => [ 'state', $numsub ] }, + 'formats' => { 'default' => [ 'state', $numsub, 'name' ], }, }; FS::Record::process_batch_import( $job, $opt, @_ ); } +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) = @_;