SL/BackgroundJob/CsvImport.pm

   1 package SL::BackgroundJob::CsvImport;
   2
   3 use strict;
   4
   5 use parent qw(SL::BackgroundJob::Base);
   6
   7 use SL::JSON;
   8 use SL::YAML;
   9 use SL::DB::CsvImportProfile;
  10
  11 sub create_job {
  12   my ($self_or_class, %params) = @_;
  13
  14   my $package       = ref($self_or_class) || $self_or_class;
  15   $package          =~ s/SL::BackgroundJob:://;
  16
  17   my %data = (
  18     %params,
  19     session_id => $::auth->get_session_id,
  20   );
  21
  22   my $job = SL::DB::BackgroundJob->new(
  23     type         => 'once',
  24     active       => 1,
  25     package_name => $package,
  26     data         => SL::YAML::Dump(\%data),
  27   );
  28
  29   return $job;
  30 }
  31
  32 sub profile {
  33   my ($self) = @_;
  34
  35   if (!$self->{profile}) {
  36     my $data = SL::YAML::Load($self->{db_obj}->data);
  37     $self->{profile} = SL::DB::Manager::CsvImportProfile->find_by(id => $data->{profile_id});
  38   }
  39
  40   return $self->{profile};
  41 }
  42
  43 sub run {
  44   my $self        = shift;
  45   $self->{db_obj} = shift;
  46
  47   $self->do_import;
  48 }
  49
  50 sub do_import {
  51   my ($self) = @_;
  52
  53   require SL::Controller::CsvImport;
  54   my $c = SL::Controller::CsvImport->new;
  55   my $job = $self->{db_obj};
  56
  57   $c->profile($self->profile);
  58   $c->mappings(SL::JSON::from_json($self->profile->get('json_mappings'))) if $self->profile->get('json_mappings');
  59   $c->type($job->data_as_hash->{type});
  60   $c->{employee_id} = $job->data_as_hash->{employee_id};
  61
  62   my $test = $job->data_as_hash->{test};
  63
  64
  65   # $::locale->text('parsing csv')
  66   # $::locale->text('building data')
  67   # $::locale->text('saving data')
  68   # $::locale->text('building report')
  69   $self->track_progress(
  70     progress => 0,
  71     plan => {
  72       'parsing csv'     => 1,
  73       'building data'   => 2,
  74     ( 'saving data'     => 3, )x!$test,
  75       'building report' => ($test ? 3 : 4),
  76     },
  77     num_phases => ($test ? 3 : 4),
  78   );
  79   $c->add_progress_tracker($self);
  80
  81   my $session_id = $job->data_as_hash->{session_id};
  82
  83   $c->test_and_import(test => $test, session_id => $session_id);
  84   my $result;
  85   if ($c->errors) {
  86     $job->set_data(
  87       errors   => $c->errors,
  88     )->save;
  89     $result = $::locale->text('Import finished with errors.');
  90   } else {
  91
  92     my $report_id = $c->save_report(session_id => $session_id, test => $test);
  93     $job->set_data(report_id => $report_id)->save;
  94
  95     $c->track_progress(finished => 1);
  96     $result = $::locale->text('Import finished without errors.');
  97   }
  98
  99   return $result;
 100 }
 101
 102 sub track_progress {
 103   my ($self, %params) = @_;
 104
 105   my $data = $self->{db_obj}->data_as_hash;
 106   my $progress = $data->{progress} || {};
 107
 108   $progress->{$_} = $params{$_} for keys %params;
 109   $self->{db_obj}->set_data(progress => $progress);
 110   $self->{db_obj}->save;
 111 }
 112
 113 1;
 114
 115 __END__
 116
 117 =encoding utf-8
 118
 119 =head1 NAME
 120
 121 SL::Background::CsvImport - backend for automatic imports of csv data
 122
 123 =head1 SYNOPSIS
 124
 125
 126 use SL::BackgroundJob::CsvImport;
 127
 128
 129 From a controller or external source:
 130
 131   my $job = SL::BackgroundJob::CsvImport->create_job(
 132     file => $file,
 133     %import_options
 134   );
 135
 136 =head1 DESCRIPTION
 137
 138 =head1 FUNCTIONS
 139
 140 =head1 BUGS
 141
 142 =head1 AUTHOR
 143
 144 Sven Schoeling E<lt>s.schoeling@linet-services.deE<gt>
 145
 146 =cut