X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=httemplate%2Fedit%2Fprocess%2Fpart_pkg.cgi;h=5beb0341193e0fc5556f79cb84c7f293a4e4a5a5;hp=36debfce0fcc2c6ac5789a2b628db4a7433732d2;hb=a354fed1dedc65cf62e63d940e1cfb9c4364e6d3;hpb=c648976f0b7975f2328ebd7ba8c711fad0ca4195 diff --git a/httemplate/edit/process/part_pkg.cgi b/httemplate/edit/process/part_pkg.cgi index 36debfce0..5beb03411 100755 --- a/httemplate/edit/process/part_pkg.cgi +++ b/httemplate/edit/process/part_pkg.cgi @@ -1,113 +1,353 @@ -%if ( $error ) { -% $dbh->rollback if $oldAutoCommit; -% $cgi->param('error', $error ); -<% $cgi->redirect(popurl(2). "part_pkg.cgi?". $cgi->query_string ) %> -%} elsif ( $custnum ) { -% $dbh->commit or die $dbh->errstr if $oldAutoCommit; -<% $cgi->redirect(popurl(3). "view/cust_main.cgi?$custnum") %> -%} else { -% $dbh->commit or die $dbh->errstr if $oldAutoCommit; -<% $cgi->redirect(popurl(3). "browse/part_pkg.cgi") %> -%} +<% include( 'elements/process.html', + #'debug' => 1, + 'table' => 'part_pkg', + 'agent_virt' => 1, + 'agent_null_right' => \@agent_null_right, + 'redirect' => $redirect_callback, + 'viewall_dir' => 'browse', + 'viewall_ext' => 'cgi', + 'edit_ext' => 'cgi', + 'precheck_callback' => $precheck_callback, + 'args_callback' => $args_callback, + 'update_svc' => $update_svc, + 'process_locale' => 'pkg', + 'process_m2m' => \@process_m2m, + 'process_o2m' => \@process_o2m, + ) +%> <%init> -my $dbh = dbh; -my $conf = new FS::Conf; +my $customizing = ( ! $cgi->param('pkgpart') && $cgi->param('pkgnum') ); -my $pkgpart = $cgi->param('pkgpart'); - -my $old = qsearchs('part_pkg',{'pkgpart'=>$pkgpart}) if $pkgpart; - -tie my %plans, 'Tie::IxHash', %{ FS::part_pkg::plan_info() }; -my $href = $plans{$cgi->param('plan')}->{'fields'}; - -#fixup plandata -my $error; -my $plandata = $cgi->param('plandata'); -my @plandata = split(',', $plandata); -$cgi->param('plandata', - join('', map { my $parser = sub { shift }; - $parser = $href->{$_}{parse} if exists($href->{$_}{parse}); - my $value = join(', ', &$parser($cgi->param($_))); - my $check = $href->{$_}{check}; - if ( $check && ! &$check($value) ) { - $value = join(', ', $cgi->param($_)); - $error ||= "Illegal ". ($href->{$_}{name}||$_). ": $value"; - } - "$_=$value\n"; - } @plandata ) -); +my $curuser = $FS::CurrentUser::CurrentUser; -foreach (qw( setuptax recurtax disabled )) { - $cgi->param($_, '') unless defined $cgi->param($_); -} +my $edit_global = 'Edit global package definitions'; +my $customize = 'Customize customer package'; -my @agents; -foreach ($cgi->param('agent_type')) { - /^(\d+)$/; - push @agents, $1 if $1; -} -$error = "At least one agent type must be specified." - unless( scalar(@agents) || - $cgi->param('clone') && $cgi->param('clone') =~ /^\d+$/ || - !$pkgpart && $conf->exists('agent-defaultpkg') - ); +die "access denied" + unless $curuser->access_right('Edit package definitions') + || $curuser->access_right($edit_global) + || ( $customizing && $curuser->access_right($customize) ); -my $new = new FS::part_pkg ( { - map { - $_ => scalar($cgi->param($_)); - } fields('part_pkg') -} ); +my @agent_null_right = ( $edit_global ); +push @agent_null_right, $customize if $customizing; -my $oldAutoCommit = $FS::UID::AutoCommit; -local $FS::UID::AutoCommit = 0; -my %pkg_svc = map { $_ => scalar($cgi->param("pkg_svc$_")) } - map { $_->svcpart } - qsearch('part_svc', {} ); +my $precheck_callback = sub { + my( $cgi ) = @_; -my $curuser = $FS::CurrentUser::CurrentUser; + my $conf = new FS::Conf; + + foreach (qw( setuptax recurtax disabled )) { + $cgi->param($_, '') unless defined $cgi->param($_); + } + + return 'Must select a tax class' + if $cgi->param('taxclass') eq '(select)'; + + my @agents = (); + foreach ($cgi->param('agent_type')) { + /^(\d+)$/; + push @agents, $1 if $1; + } + return "At least one agent type must be specified." + unless scalar(@agents) + #wtf? || ( $cgi->param('clone') && $cgi->param('clone') =~ /^\d+$/ ) + || $cgi->param('disabled') + || $cgi->param('agentnum'); + + return ''; + +}; my $custnum = ''; -if ( $error ) { - # fall through +my $args_callback = sub { + my( $cgi, $new ) = @_; + + my @args = ( 'primary_svc' => scalar($cgi->param('pkg_svc_primary')) ); -} elsif ( $cgi->param('taxclass') eq '(select)' ) { + ## + #options + ## + + $cgi->param('plan') =~ /^(\w+)$/ or die 'unparsable plan'; + my $plan = $1; + + tie my %plans, 'Tie::IxHash', %{ FS::part_pkg::plan_info() }; + my $href = $plans{$plan}->{'fields'}; + + my $error = ''; + my $options = $cgi->param($plan."__OPTIONS"); + my @options = split(',', $options); + my %options = + map { my $optionname = $_; + my $param = $plan."__$optionname"; + my $parser = exists($href->{$optionname}{parse}) + ? $href->{$optionname}{parse} + : sub { shift }; + my $value = join(', ', &$parser($cgi->param($param))); + my $check = $href->{$optionname}{check}; + if ( $check && ! &$check($value) ) { + $value = join(', ', $cgi->param($param)); + $error ||= "Illegal ". + ($href->{$optionname}{name}||$optionname). ": $value"; + } + ( $optionname => $value ); + } + grep { $_ !~ /^report_option_/ } + @options; - $error = 'Must select a tax class'; + foreach my $class ( '', split(',', $cgi->param('taxproductnums') ) ) { + my $param = "taxproductnum_$class"; + my $value = $cgi->param($param); -} elsif ( $pkgpart ) { + if ( $value == -1 ) { + my $desc = $cgi->param($param.'_description'); + # insert a new part_pkg_taxproduct + my $engine = FS::TaxEngine->new; + my $obj_or_error = $engine->add_taxproduct($desc); + if (ref $obj_or_error) { + $value = $obj_or_error->taxproductnum; + $cgi->param($param, $value); # for error handling + } else { + die "$obj_or_error (adding tax product)"; + } + } - die "access denied" - unless $curuser->access_right('Edit package definitions') - || $curuser->access_right('Edit global package definitions'); + $error ||= "Illegal $param: $value" + unless ( $value =~ /^\d*$/ ); + if (length($class)) { + $options{"usage_taxproductnum_$class"} = $value; + } else { + $new->set('taxproductnum', $value); + } + } - $error = $new->replace( $old, - pkg_svc => \%pkg_svc, - primary_svc => scalar($cgi->param('pkg_svc_primary')), - ); -} else { + foreach ( grep $_, $cgi->param('report_option') ) { + $error ||= "Illegal optional report class: $_" unless ( $_ =~ /^\d*$/ ); + $options{"report_option_$_"} = 1; + } - die "access denied" - unless $curuser->access_right('Edit package definitions') - || $curuser->access_right('Edit global package definitions') - || ( $cgi->param('pkgnum') && $curuser->access_right('Customize customer package') ); + $options{$_} = scalar( $cgi->param($_) ) + for (qw( setup_fee recur_fee disable_line_item_date_ranges )); + + push @args, 'options' => \%options; - $error = $new->insert( pkg_svc => \%pkg_svc, - primary_svc => scalar($cgi->param('pkg_svc_primary')), - cust_pkg => $cgi->param('pkgnum'), - custnum_ref => \$custnum, - ); - $pkgpart = $new->pkgpart; -} + ### + #part_pkg_currency + ### -unless ( $error || $conf->exists('agent_defaultpkg') ) { - my $error = $new->process_m2m( - 'link_table' => 'type_pkgs', - 'target_table' => 'agent_type', - 'params' => \@agents, + my %part_pkg_currency = ( + map { $_ => scalar($cgi->param($_)) } + #grep /._[A-Z]{3}$/, #support other options + grep /^(setup|recur)_fee_[A-Z]{3}$/, + $cgi->param ); + + push @args, 'part_pkg_currency' => \%part_pkg_currency; + + ### + # fcc options + ### + my $fcc_options_string = $cgi->param('fcc_options_string'); + if ($fcc_options_string) { + push @args, 'fcc_options' => decode_json($fcc_options_string); + } + + ### + #pkg_svc + ### + + my @svcparts = map { $_->svcpart } qsearch('part_svc', {}); + my %pkg_svc = map { $_ => scalar($cgi->param("pkg_svc$_" )) } @svcparts; + my %hidden_svc = map { $_ => scalar($cgi->param("hidden$_" )) } @svcparts; + my %provision_hold = map { $_ => scalar($cgi->param("provision_hold$_" )) } @svcparts; + my %bulk_skip = map { $_ => ( $cgi->param("no_bulk_skip$_") eq 'Y' + ? '' : 'Y' + ) + } @svcparts; + + push @args, 'pkg_svc' => \%pkg_svc, + 'hidden_svc' => \%hidden_svc, + 'provision_hold' => \%provision_hold, + 'bulk_skip' => \%bulk_skip; + + ### + # cust_pkg and custnum_ref (inserts only) + ### + unless ( $cgi->param('pkgpart') ) { + push @args, 'cust_pkg' => scalar($cgi->param('pkgnum')), + 'custnum_ref' => \$custnum; + } + + my %part_pkg_vendor; + foreach my $param ( $cgi->param ) { + if ( $param =~ /^export(\d+)$/ && length($cgi->param($param)) > 0 ) { + $part_pkg_vendor{$1} = $cgi->param($param); + } + } + if ( keys %part_pkg_vendor > 0 ) { + push @args, 'part_pkg_vendor' => \%part_pkg_vendor; + } + + push @args, 'part_pkg_restrict_soft_override' => 1 + if $cgi->param('part_pkg_restrict_soft_override'); + + #warn "args: ".join('/', @args). "\n"; + + @args; + +}; + +## update services upon package change. +my $update_svc = sub { + my $cgi = shift @_; + my $new = shift @_; + my %args = @_; + my $error; + + my @svcs = $new->pkg_svc(); + +## update broadband services getting their up and down speeds from package fcc_477 options + foreach my $svc_part(@svcs) { + my @part_svc_column = qsearch('part_svc_column',{ 'svcpart' => $svc_part->{Hash}->{svcpart}, 'columnflag' => 'P' }); + + if ($svc_part->{Hash}->{svcdb} eq "svc_broadband" && (keys $args{fcc_options}) && @part_svc_column ) { + ## find provisioned services to update + my @svc_svcdb = qsearch({ + 'table' => 'svc_broadband', + 'select' => 'svc_broadband.*, cust_svc.svcpart', + 'addl_from' => 'LEFT JOIN cust_svc USING (svcnum) LEFT JOIN cust_pkg USING (pkgnum)', + 'extra_sql' => " WHERE cust_svc.svcpart = '".$svc_part->{Hash}->{svcpart}."' AND cust_pkg.pkgpart = '".$svc_part->{Hash}->{pkgpart}."'", + }); + foreach my $svc (@svc_svcdb) { + next if ($svc->{Hash}->{speed_down} == $args{fcc_options}->{broadband_downstream} * 1000 && $svc->{Hash}->{speed_up} == $args{fcc_options}->{broadband_upstream} * 1000); + $svc->{Hash}->{speed_down} = $args{fcc_options}->{broadband_downstream} * 1000; + $svc->{Hash}->{speed_up} = $args{fcc_options}->{broadband_upstream} * 1000; + $error = $svc->replace(); + } + } + } + return $error; +}; + +my $redirect_callback = sub { + #my( $cgi, $new ) = @_; + return '' unless $custnum; + my $show = $curuser->default_customer_view =~ /^(jumbo|packages)$/ + ? '' + : ';show=packages'; + #my $frag = "cust_pkg$pkgnum"; #hack for IE ignoring real #fragment + + #can we link back to the specific customized package? it would be nice... + popurl(3). "view/cust_main.cgi?custnum=$custnum$show;dummy="; +}; + +#these should probably move to @args above and be processed by part_pkg.pm... + +$cgi->param('tax_override') =~ /^([\d,]+)$/; +my (@tax_overrides) = (grep "$_", split (",", $1)); + +my @process_m2m = ( + { + 'link_table' => 'part_pkg_taxoverride', + 'target_table' => 'tax_class', + 'params' => \@tax_overrides, + }, + { 'link_table' => 'part_pkg_discount', + 'target_table' => 'discount', + 'params' => [ map $cgi->param($_), + grep /^discountnum/, $cgi->param + ], + }, + { 'link_table' => 'part_pkg_link', + 'target_table' => 'part_pkg', + 'base_field' => 'src_pkgpart', + 'target_field' => 'dst_pkgpart', + 'hashref' => { 'link_type' => 'svc', 'hidden' => '' }, + 'params' => [ map $cgi->param($_), + grep /^svc_dst_pkgpart/, $cgi->param + ], + }, + { 'link_table' => 'part_pkg_link', + 'target_table' => 'part_pkg', + 'base_field' => 'src_pkgpart', + 'target_field' => 'dst_pkgpart', + 'hashref' => { 'link_type' => 'supp', 'hidden' => '' }, + 'params' => [ map $cgi->param($_), + grep /^supp_dst_pkgpart/, $cgi->param + ], + }, + map { + my $hidden = $_; + { 'link_table' => 'part_pkg_link', + 'target_table' => 'part_pkg', + 'base_field' => 'src_pkgpart', + 'target_field' => 'dst_pkgpart', + 'hashref' => { 'link_type' => 'bill', 'hidden' => $hidden }, + 'params' => [ map { $cgi->param($_) } + grep { my $param = "bill_dst_pkgpart__hidden"; + my $digit = ''; + (($digit) = /^bill_dst_pkgpart(\d+)/ ) && + $cgi->param("$param$digit") eq $hidden; + } + $cgi->param + ], + }, + } ( '', 'Y' ), +); + +foreach my $override_class ($cgi->param) { + next unless $override_class =~ /^tax_override_(\w+)$/; + my $class = $1; + + my (@tax_overrides) = (grep "$_", split (",", $1)) + if $cgi->param($override_class) =~ /^([\d,]+)$/; + + push @process_m2m, { + 'link_table' => 'part_pkg_taxoverride', + 'target_table' => 'tax_class', + 'hashref' => { 'usage_class' => $class }, + 'params' => [ @tax_overrides ], + }; + } +my $conf = new FS::Conf; + +my @agents = (); +foreach ($cgi->param('agent_type')) { + /^(\d+)$/; + push @agents, $1 if $1; +} +push @process_m2m, { + 'link_table' => 'type_pkgs', + 'target_table' => 'agent_type', + 'params' => \@agents, +}; + +my $targets = FS::part_pkg_usageprice->targets; +foreach my $amount_param ( grep /^usagepricepart(\d+)_amount$/, $cgi->param ) { + $amount_param =~ /^usagepricepart(\d+)_amount$/ or die 'unpossible'; + my $num = $1; + my $amount = $cgi->param($amount_param); + if ( ! $amount && ! $cgi->param("usagepricepart${num}_price") ) { + #don't add empty rows just because the dropdowns have a value + $cgi->param("usagepricepart${num}_$_", '') for qw( currency action target ); + next; + } + my $target = $cgi->param("usagepricepart${num}_target"); + $amount *= $targets->{$target}{multiplier} if $targets->{$target}{multiplier}; + $cgi->param($amount_param, $amount); +} + +my @process_o2m = ( + { + 'table' => 'part_pkg_usageprice', + 'fields' => [qw( price currency action target amount )], + + } +); +