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 )],
114 my %import_options = (
115 'table' => 'cust_pkg',
117 'preinsert_callback' => sub {
118 my($record, $param) = @_;
119 my @location_params = grep /^location\./, keys %$param;
120 if (@location_params) {
121 my $cust_location = FS::cust_location->new({
122 'custnum' => $record->custnum,
124 foreach my $p (@location_params) {
125 $p =~ /^location.(\w+)$/;
126 $cust_location->set($1, $param->{$p});
129 my $error = $cust_location->find_or_insert; # this avoids duplicates
130 return "error creating location: $error" if $error;
131 $record->set('locationnum', $cust_location->locationnum);
136 'postinsert_callback' => sub {
137 my( $record, $param ) = @_;
139 my $formatfields = _formatfields;
140 foreach my $svc_x ( grep /^svc/, keys %$formatfields ) {
142 my $ff = $formatfields->{$svc_x};
144 if ( grep $param->{"$svc_x.$_"}, @$ff ) {
145 my $svc = "FS::$svc_x"->new( {
146 'pkgnum' => $record->pkgnum,
147 'svcpart' => $record->part_pkg->svcpart($svc_x),
148 map { $_ => $param->{"$svc_x.$_"} } @$ff
151 #this whole thing should be turned into a callback or config to turn on
152 if ( $svc_x eq 'svc_acct' && $svc->username =~ /\@/ ) {
153 my($username, $domain) = split(/\@/, $svc->username);
154 my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } )
155 || new FS::svc_domain { 'svcpart' => 1,
156 'domain' => $domain, };
157 unless ( $svc_domain->svcnum ) {
158 my $error = $svc_domain->insert;
159 return "error auto-inserting domain: $error" if $error;
161 $svc->username($username);
162 $svc->domsvc($svc_domain->svcnum);
165 my $error = $svc->insert;
166 return "error inserting service: $error" if $error;
176 sub _import_options {
183 my $iopt = _import_options;
184 $opt->{$_} = $iopt->{$_} foreach keys %$iopt;
186 my $agentnum = delete $opt->{agentnum}; # i like closures (delete though?)
188 my $format = delete $opt->{'format'};
191 if ( $format =~ /^(.*)-agent_custid(-agent_pkgid)?$/ ) {
193 my $agent_pkgid = $2;
196 my( $self, $value ) = @_; # $conf, $param
197 my $cust_main = qsearchs('cust_main', {
198 'agentnum' => $agentnum,
199 'agent_custid' => $value,
201 $self->custnum($cust_main->custnum) if $cust_main;
204 push @fields, 'agent_pkgid' if $agent_pkgid;
206 @fields = ( 'custnum' );
209 if ( $format =~ /^(.*)-locationnum$/ ) {
211 push @fields, 'locationnum';
214 if ( $format =~ /^bulk_(.*)$/ ) {
218 $opt->{'postinsert_callback'} = sub {
219 my( $record, $param ) = @_;
221 my $formatfields = _formatfields;
222 foreach my $svc_x ( grep /^svc/, keys %$formatfields ) {
224 my $ff = $formatfields->{$svc_x};
226 if ( grep $param->{"$svc_x.$_"}, @$ff ) {
228 $param->{'svc_phone.phonenum'} =~ /^\s*(\d+)\s*\-\s*(\d+)\s*$/
229 or return 'Enter a phone number range, with dash as the separator';
230 my($start, $end) = ($1, $2);
231 if ( length($end) < length($start) ) {
232 $end = substr($start, 0, length($start) - length($end) ). $end;
235 foreach my $phonenum ( "$start" .. "$end" ) {
237 my $svc = "FS::$svc_x"->new( {
238 'pkgnum' => $record->pkgnum,
239 'svcpart' => $record->part_pkg->svcpart($svc_x),
240 map { $_ => $param->{"$svc_x.$_"} } @$ff
243 $svc->phonenum($phonenum);
244 #$svc->set_default_and_fixed;
245 my $error = $svc->insert;
246 return "error inserting service: $error" if $error;
260 push @fields, ( 'pkgpart', 'discountnum' );
262 my @date_fields = ();
263 if ( $format =~ /all_dates/ ) {
266 start_date setup bill last_bill susp adjourn
273 start_date setup bill last_bill susp adjourn
278 foreach my $field (@date_fields) {
280 my( $self, $value ) = @_; # $conf, $param
281 #->$field has undesirable effects
282 $self->set($field, parse_datetime($value) ); #$field closure
286 my $formatfields = _formatfields();
288 die "unknown format $format" unless $formatfields->{$format};
290 foreach my $field ( @{ $formatfields->{$format} } ) {
293 my( $self, $value, $conf, $param ) = @_;
294 $param->{"$format.$field"} = $value;
299 $opt->{'fields'} = \@fields;
301 FS::Record::batch_import( $opt );
307 Not enough documentation.
311 L<FS::cust_main>, L<FS::cust_pkg>,
312 L<FS::svc_acct>, L<FS::svc_external>, L<FS::svc_phone>