summaryrefslogtreecommitdiff
path: root/FS
diff options
context:
space:
mode:
Diffstat (limited to 'FS')
-rw-r--r--FS/FS/Schema.pm3
-rw-r--r--FS/FS/cust_credit.pm52
-rw-r--r--FS/FS/part_event/Condition/cust_class.pm29
-rw-r--r--FS/FS/part_export/voip_innovations3.pm217
4 files changed, 300 insertions, 1 deletions
diff --git a/FS/FS/Schema.pm b/FS/FS/Schema.pm
index 150a19d95..30a35deb0 100644
--- a/FS/FS/Schema.pm
+++ b/FS/FS/Schema.pm
@@ -1285,11 +1285,12 @@ sub tables_hashref {
'commission_agentnum', 'int', 'NULL', '', '', '', #
'commission_salesnum', 'int', 'NULL', '', '', '', #
'commission_pkgnum', 'int', 'NULL', '', '', '', #
+ 'credbatch', 'varchar', 'NULL', $char_d, '', '',
],
'primary_key' => 'crednum',
'unique' => [],
'index' => [ ['custnum'], ['_date'], ['usernum'], ['eventnum'],
- ['commission_salesnum'],
+ ['commission_salesnum'], ['credbatch'],
],
'foreign_keys' => [
{ columns => [ 'custnum' ],
diff --git a/FS/FS/cust_credit.pm b/FS/FS/cust_credit.pm
index df59950ea..3f8d57c3c 100644
--- a/FS/FS/cust_credit.pm
+++ b/FS/FS/cust_credit.pm
@@ -1103,6 +1103,58 @@ sub credit_lineitems {
=back
+=head1 SUBROUTINES
+
+=over 4
+
+=item process_batch_import
+
+=cut
+
+use List::Util qw( min );
+use FS::cust_bill;
+use FS::cust_credit_bill;
+sub process_batch_import {
+ my $job = shift;
+
+ my $opt = { 'table' => 'cust_credit',
+ 'params' => [ 'credbatch' ],
+ 'formats' => { 'simple' =>
+ [ 'custnum', 'amount', 'reasonnum', 'invnum' ],
+ },
+ 'default_csv' => 1,
+ 'postinsert_callback' => sub {
+ my $cust_credit = shift; #my ($cust_credit, $param ) = @_;
+
+ if ( $cust_credit->invnum ) {
+
+ my $cust_bill = qsearchs('cust_bill', { invnum=>$cust_credit->invnum } );
+ my $amount = min( $cust_credit->credited, $cust_bill->owed );
+
+ my $cust_credit_bill = new FS::cust_credit_bill ( {
+ 'crednum' => $cust_credit->crednum,
+ 'invnum' => $cust_bill->invnum,
+ 'amount' => $amount,
+ } );
+ my $error = $cust_credit_bill->insert;
+ return '' unless $error;
+
+ }
+
+ #apply_payments_and_credits ?
+ $cust_credit->cust_main->apply_credits;
+
+ return '';
+
+ },
+ };
+
+ FS::Record::process_batch_import( $job, $opt, @_ );
+
+}
+
+=back
+
=head1 BUGS
The delete method. The replace method.
diff --git a/FS/FS/part_event/Condition/cust_class.pm b/FS/FS/part_event/Condition/cust_class.pm
new file mode 100644
index 000000000..791bb6378
--- /dev/null
+++ b/FS/FS/part_event/Condition/cust_class.pm
@@ -0,0 +1,29 @@
+package FS::part_event::Condition::cust_class;
+use base qw( FS::part_event::Condition );
+
+use strict;
+
+sub description {
+ 'Customer class';
+}
+
+sub option_fields {
+ (
+ 'cust_class' => { 'label' => 'Customer Class',
+ 'type' => 'select-cust_class',
+ 'multiple' => 1,
+ },
+ );
+}
+
+sub condition {
+ my( $self, $object ) = @_;
+
+ my $cust_main = $self->cust_main($object);
+
+ my $hashref = $self->option('cust_class') || {};
+
+ $hashref->{ $cust_main->classnum };
+}
+
+1;
diff --git a/FS/FS/part_export/voip_innovations3.pm b/FS/FS/part_export/voip_innovations3.pm
new file mode 100644
index 000000000..630d0c41f
--- /dev/null
+++ b/FS/FS/part_export/voip_innovations3.pm
@@ -0,0 +1,217 @@
+package FS::part_export::voip_innovations3;
+
+use vars qw(@ISA %info);
+use Tie::IxHash;
+use FS::Record qw(qsearch dbh);
+use FS::part_export;
+use FS::phone_avail;
+use Data::Dumper;
+
+@ISA = qw(FS::part_export);
+
+tie my %options, 'Tie::IxHash',
+ 'login' => { label=>'VoIP Innovations API login' },
+ 'password' => { label=>'VoIP Innovations API password' },
+ 'endpointgroup' => { label=>'VoIP Innovations endpoint group number' },
+ 'e911' => { label=>'Provision E911 data',
+ type=>'checkbox',
+ },
+ 'no_did_provision' => { label=>'Disable DID provisioning',
+ type=>'checkbox',
+ },
+ 'dry_run' => { label=>"Test mode - don't actually provision",
+ type=>'checkbox',
+ },
+;
+
+%info = (
+ 'svc' => 'svc_phone',
+ 'desc' => 'Provision phone numbers / E911 to VoIP Innovations (API 3.0)',
+ 'options' => \%options,
+ 'no_machine' => 1,
+ 'notes' => <<'END'
+Requires installation of
+<a href="http://search.cpan.org/dist/Net-VoIP_Innovations">Net::VoIP_Innovations</a>
+from CPAN.
+END
+);
+
+sub rebless { shift; }
+
+sub can_get_dids { 0; } #with API 3.0? not yet
+
+sub vi_command {
+ my( $self, $command, @args ) = @_;
+
+ eval "use Net::VoIP_Innovations 3.00;";
+ if ( $@ ) {
+ warn $@;
+ die $@;
+ }
+
+ my $gp = Net::VoIP_Innovations->new(
+ 'login' => $self->option('login'),
+ 'password' => $self->option('password'),
+ #'debug' => $debug,
+ );
+
+ $gp->$command(@args);
+}
+
+
+sub _export_insert {
+ my( $self, $svc_phone ) = (shift, shift);
+
+ return '' if $self->option('dry_run');
+
+ #we want to provision and catch errors now, not queue
+
+ unless ( $self->option('no_provision_did') ) {
+
+ ###
+ # reserveDID
+ ###
+
+ my $r = $self->vi_command('reserveDID',
+ 'did' => $svc_phone->phonenum,
+ 'minutes' => 1,
+ 'endpointgroup' => $self->option('endpointgroup'),
+ );
+
+ my $rdid = $r->{did};
+
+ if ( $rdid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations reserveDID: ".
+ $rdid->{'statuscode'}. ': '. $rdid->{'status'};
+ }
+
+ ###
+ # assignDID
+ ###
+
+ my $a = $self->vi_command('assignDID',
+ 'did' => $svc_phone->phonenum,
+ 'endpointgroup' => $self->option('endpointgroup'),
+ #'rewrite'
+ #'cnam'
+ );
+
+ my $adid = $a->{did};
+
+ if ( $adid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations assignDID: ".
+ $adid->{'statuscode'}. ': '. $adid->{'status'};
+ }
+
+ }
+
+ ###
+ # 911Insert
+ ###
+
+ if ( $self->option('e911') ) {
+
+ my %location_hash = $svc_phone->location_hash;
+ my( $zip, $plus4 ) = split('-', $location_hash->{zip});
+ my $e = $self->vi_command('911Insert',
+ 'did' => $svc_phone->phonenum,
+ 'Address1' => $location_hash{address1},
+ 'Address2' => $location_hash{address2},
+ 'City' => $location_hash{city},
+ 'State' => $location_hash{state},
+ 'ZipCode' => $zip,
+ 'PlusFour' => $plus4,
+ 'CallerName' =>
+ $svc_phone->phone_name
+ || $svc_phone->cust_svc->cust_pkg->cust_main->contact_firstlast,
+ );
+
+ my $edid = $e->{did};
+
+ if ( $edid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations 911Insert: ".
+ $edid->{'statuscode'}. ': '. $edid->{'status'};
+ }
+
+ }
+
+ '';
+}
+
+sub _export_replace {
+ my( $self, $new, $old ) = (shift, shift, shift);
+
+ #hmm, anything to change besides E911 data?
+
+ ###
+ # 911Update
+ ###
+
+ if ( $self->option('e911') ) {
+
+ my %location_hash = $svc_phone->location_hash;
+ my( $zip, $plus4 ) = split('-', $location_hash->{zip});
+ my $e = $self->vi_command('911Update',
+ 'did' => $svc_phone->phonenum,
+ 'Address1' => $location_hash{address1},
+ 'Address2' => $location_hash{address2},
+ 'City' => $location_hash{city},
+ 'State' => $location_hash{state},
+ 'ZipCode' => $zip,
+ 'PlusFour' => $plus4,
+ 'CallerName' =>
+ $svc_phone->phone_name
+ || $svc_phone->cust_svc->cust_pkg->cust_main->contact_firstlast,
+ );
+
+ my $edid = $e->{did};
+
+ if ( $edid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations 911Update: ".
+ $edid->{'statuscode'}. ': '. $edid->{'status'};
+ }
+
+ }
+
+ '';
+}
+
+sub _export_delete {
+ my( $self, $svc_phone ) = (shift, shift);
+
+ return '' if $self->option('dry_run')
+ || $self->option('no_provision_did');
+
+ #probably okay to queue the deletion...?
+ #but hell, let's do it inline anyway, who wants phone numbers hanging around
+
+ my $r = $self->vi_command('releaseDID',
+ 'did' => $svc_phone->phonenum,
+ );
+
+ my $rdid = $r->{did};
+
+ if ( $rdid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations releaseDID: ".
+ $rdid->{'statuscode'}. ': '. $rdid->{'status'};
+ }
+
+ #delete e911 information? assuming release clears all that
+
+ '';
+}
+
+sub _export_suspend {
+ my( $self, $svc_phone ) = (shift, shift);
+ #nop for now
+ '';
+}
+
+sub _export_unsuspend {
+ my( $self, $svc_phone ) = (shift, shift);
+ #nop for now
+ '';
+}
+
+1;
+
generated by cgit v1.2.1 (git 2.18.0) at 2025-10-09 19:40:42 +0000