1 package FS::cust_pkg::Import;
4 use vars qw( $DEBUG ); #$conf );
6 use FS::Misc::DateTime qw( parse_datetime );
7 use FS::Record qw( qsearchs );
17 #install_callback FS::UID sub {
18 # $conf = new FS::Conf;
23 FS::cust_pkg::Import - Batch customer importing
27 use FS::cust_pkg::Import;
30 FS::cust_pkg::Import::batch_import( {
31 file => $file, #filename
32 type => $type, #csv or xls
33 format => $format, #extended, extended-plus_company, svc_external,
34 # or svc_external_svc_phone
35 agentnum => $agentnum,
36 job => $job, #optional job queue job, for progressbar updates
37 pkgbatch => $pkgbatch, #optional batch unique identifier
42 use FS::UI::Web::JSRPC;
44 new FS::UI::Web::JSRPC 'FS::cust_pkg::Import::process_batch_import', $cgi;
45 print $server->process;
49 Batch package importing.
53 =item process_batch_import
55 Load a batch import as a queued JSRPC job
59 sub process_batch_import {
62 warn Dumper($param) if $DEBUG;
64 my $files = $param->{'uploaded_files'}
65 or die "No files provided.\n";
67 my (%files) = map { /^(\w+):([\.\w]+)$/ ? ($1,$2):() } split /,/, $files;
69 my $dir = '%%%FREESIDE_CACHE%%%/cache.'. $FS::UID::datasrc. '/';
70 my $file = $dir. $files{'file'};
73 if ( $file =~ /\.(\w+)$/i ) {
77 warn "can't parse file type from filename $file; defaulting to CSV";
82 FS::cust_pkg::Import::batch_import( {
86 'params' => { pkgbatch => $param->{pkgbatch} },
87 agentnum => $param->{'agentnum'},
88 'format' => $param->{'format'},
93 die "$error\n" if $error;
104 'svc_acct' => [qw( username _password domsvc )],
105 'svc_phone' => [qw( countrycode phonenum sip_password pin )],
106 'svc_external' => [qw( id title )],
107 'location' => [qw( address1 address2 city state zip country )],
108 'quan_price' => [qw( quantity setup_fee recur_fee invoice_details )],
115 my %import_options = (
116 'table' => 'cust_pkg',
118 'preinsert_callback' => sub {
119 my($record, $param) = @_;
121 my @location_params = grep { /^location\./ && length($param->{$_}) }
123 if (@location_params) {
124 my $cust_location = FS::cust_location->new({
125 'custnum' => $record->custnum,
127 foreach my $p (@location_params) {
128 $p =~ /^location.(\w+)$/;
129 $cust_location->set($1, $param->{$p});
132 my $error = $cust_location->find_or_insert; # this avoids duplicates
133 return "error creating location: $error" if $error;
134 $record->set('locationnum', $cust_location->locationnum);
137 $record->quantity( $param->{'quan_price.quantity'} )
138 if $param->{'quan_price.quantity'} > 0;
140 my $s = $param->{'quan_price.setup_fee'};
141 my $r = $param->{'quan_price.recur_fee'};
142 my $part_pkg = $record->part_pkg;
143 if ( ( length($s) && $s != $part_pkg->option('setup_fee') )
144 or ( length($r) && $r != $part_pkg->option('recur_fee') )
148 local($FS::part_pkg::skip_pkg_svc_hack) = 1;
150 my $custom_part_pkg = $part_pkg->clone;
151 $custom_part_pkg->disabled('Y');
152 my %options = $part_pkg->options;
153 $options{'setup_fee'} = $s if length($s);
154 $options{'recur_fee'} = $r if length($r);
155 my $error = $custom_part_pkg->insert( options=>\%options );
156 return "error customizing package: $error" if $error;
158 #not ->pkg_svc, we want to ignore links and clone the actual package def
159 foreach my $pkg_svc ( $part_pkg->_pkg_svc ) {
160 my $c_pkg_svc = new FS::pkg_svc { $pkg_svc->hash };
161 $c_pkg_svc->pkgsvcnum('');
162 $c_pkg_svc->pkgpart( $custom_part_pkg->pkgpart );
163 my $error = $c_pkg_svc->insert;
164 return "error customizing package: $error" if $error;
167 $record->pkgpart( $custom_part_pkg->pkgpart );
174 'postinsert_callback' => sub {
175 my( $record, $param ) = @_;
177 if ( $param->{'quan_price.invoice_details'} ) {
180 foreach my $detail (split(/\|/, $param->{'quan_price.invoice_details'})) {
182 my $cust_pkg_detail = new FS::cust_pkg_detail {
183 'pkgnum' => $record->pkgnum,
186 'weight' => $weight++,
189 my $error = $cust_pkg_detail->insert;
190 return "error inserting invoice detail: $error" if $error;
196 my $formatfields = _formatfields;
197 foreach my $svc_x ( grep /^svc/, keys %$formatfields ) {
199 my $ff = $formatfields->{$svc_x};
201 if ( grep $param->{"$svc_x.$_"}, @$ff ) {
203 my $svc = "FS::$svc_x"->new( {
204 'pkgnum' => $record->pkgnum,
205 'svcpart' => $record->part_pkg->svcpart($svc_x),
206 map { $_ => $param->{"$svc_x.$_"} } @$ff
209 #this whole thing should be turned into a callback or config to turn on
210 if ( $svc_x eq 'svc_acct' && $svc->username =~ /\@/ ) {
211 my($username, $domain) = split(/\@/, $svc->username);
212 my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } )
213 || new FS::svc_domain { 'svcpart' => 1,
214 'domain' => $domain, };
215 unless ( $svc_domain->svcnum ) {
216 my $error = $svc_domain->insert;
217 return "error auto-inserting domain: $error" if $error;
219 $svc->username($username);
220 $svc->domsvc($svc_domain->svcnum);
223 my $error = $svc->insert;
224 return "error inserting service: $error" if $error;
234 sub _import_options {
241 my $iopt = _import_options;
242 $opt->{$_} = $iopt->{$_} foreach keys %$iopt;
244 my $agentnum = delete $opt->{agentnum}; # i like closures (delete though?)
246 my $format = delete $opt->{'format'};
249 if ( $format =~ /^(.*)-agent_custid(-agent_pkgid)?$/ ) {
251 my $agent_pkgid = $2;
254 my( $self, $value ) = @_; # $conf, $param
255 my $cust_main = qsearchs('cust_main', {
256 'agentnum' => $agentnum,
257 'agent_custid' => $value,
259 $self->custnum($cust_main->custnum) if $cust_main;
262 push @fields, 'agent_pkgid' if $agent_pkgid;
264 @fields = ( 'custnum' );
267 if ( $format =~ /^(.*)-locationnum$/ ) {
269 push @fields, 'locationnum';
272 if ( $format =~ /^bulk_(.*)$/ ) {
276 $opt->{'postinsert_callback'} = sub {
277 my( $record, $param ) = @_;
279 my $formatfields = _formatfields;
280 foreach my $svc_x ( grep /^svc/, keys %$formatfields ) {
282 my $ff = $formatfields->{$svc_x};
284 if ( grep $param->{"$svc_x.$_"}, @$ff ) {
286 $param->{'svc_phone.phonenum'} =~ /^\s*(\d+)\s*\-\s*(\d+)\s*$/
287 or return 'Enter a phone number range, with dash as the separator';
288 my($start, $end) = ($1, $2);
289 if ( length($end) < length($start) ) {
290 $end = substr($start, 0, length($start) - length($end) ). $end;
293 foreach my $phonenum ( "$start" .. "$end" ) {
295 my $svc = "FS::$svc_x"->new( {
296 'pkgnum' => $record->pkgnum,
297 'svcpart' => $record->part_pkg->svcpart($svc_x),
298 map { $_ => $param->{"$svc_x.$_"} } @$ff
301 $svc->phonenum($phonenum);
302 #$svc->set_default_and_fixed;
303 my $error = $svc->insert;
304 return "error inserting service: $error" if $error;
318 push @fields, ( 'pkgpart', 'discountnum' );
320 my @date_fields = ();
321 if ( $format =~ /all_dates/ ) {
324 start_date setup bill last_bill susp adjourn
331 start_date setup bill last_bill susp adjourn
336 foreach my $field (@date_fields) {
338 my( $self, $value ) = @_; # $conf, $param
339 #->$field has undesirable effects
340 $self->set($field, parse_datetime($value) ); #$field closure
344 my @formats = split /-/, $format;
345 foreach my $f (@formats){
347 my $formatfields = _formatfields();
348 die "unknown format $format" unless $formatfields->{$f};
350 foreach my $field ( @{ $formatfields->{$f} } ) {
353 my( $self, $value, $conf, $param ) = @_;
354 $param->{"$f.$field"} = $value;
360 $opt->{'fields'} = \@fields;
362 FS::Record::batch_import( $opt );
368 Not enough documentation.
372 L<FS::cust_main>, L<FS::cust_pkg>,
373 L<FS::svc_acct>, L<FS::svc_external>, L<FS::svc_phone>