1 package SL::BackgroundJob::CsvImport;
5 use parent qw(SL::BackgroundJob::Base);
9 use SL::DB::CsvImportProfile;
12 my ($self_or_class, %params) = @_;
14 my $package = ref($self_or_class) || $self_or_class;
15 $package =~ s/SL::BackgroundJob:://;
17 my $profile = delete $params{profile} || SL::DB::CsvImportProfile->new;
18 my $new_profile = $profile->clone_and_reset_deep;
23 profile_id => $new_profile->id,
24 session_id => $::auth->get_session_id,
27 my $job = SL::DB::BackgroundJob->new(
30 package_name => $package,
31 data => YAML::Dump(\%data),
40 if (!$self->{profile}) {
41 my $data = YAML::Load($self->{db_obj}->data);
42 $self->{profile} = SL::DB::Manager::CsvImportProfile->find_by(id => $data->{profile_id});
45 return $self->{profile};
50 $self->{db_obj} = shift;
58 require SL::Controller::CsvImport;
59 my $c = SL::Controller::CsvImport->new;
60 my $job = $self->{db_obj};
62 $c->profile($self->profile);
63 $c->mappings(SL::JSON::from_json($self->profile->get('json_mappings'))) if $self->profile->get('json_mappings');
64 $c->type($job->data_as_hash->{type});
65 $c->{employee_id} = $job->data_as_hash->{employee_id};
67 my $test = $job->data_as_hash->{test};
70 # $::locale->text('parsing csv')
71 # $::locale->text('building data')
72 # $::locale->text('saving data')
73 # $::locale->text('building report')
74 $self->track_progress(
79 ( 'saving data' => 3, )x!$test,
80 'building report' => ($test ? 3 : 4),
82 num_phases => ($test ? 3 : 4),
84 $c->add_progress_tracker($self);
86 my $session_id = $job->data_as_hash->{session_id};
88 $c->test_and_import(test => $test, session_id => $session_id);
94 $result = $::locale->text('Import finished with errors.');
97 my $report_id = $c->save_report(session_id => $session_id, test => $test);
98 $job->set_data(report_id => $report_id)->save;
100 $c->track_progress(finished => 1);
101 $result = $::locale->text('Import finished without errors.');
108 my ($self, %params) = @_;
110 my $data = $self->{db_obj}->data_as_hash;
111 my $progress = $data->{progress} || {};
113 $progress->{$_} = $params{$_} for keys %params;
114 $self->{db_obj}->set_data(progress => $progress);
115 $self->{db_obj}->save;
126 SL::Background::CsvImport - backend for automatic imports of csv data
131 use SL::BackgroundJob::CsvImport;
134 From a controller or external source:
136 my $job = SL::BackgroundJob::CsvImport->create_job(
149 Sven Schoeling E<lt>s.schoeling@linet-services.deE<gt>