+sub action_result {
+ my $self = shift;
+
+ # load resultobject
+ $self->{background_job} = SL::DB::Manager::BackgroundJob->find_by(id => $::form->{job});
+
+ my $data = $self->{background_job}->data_as_hash;
+
+ my $profile = SL::DB::Manager::CsvImportProfile->find_by(id => $data->{profile_id});
+
+ $self->profile($profile);
+
+ if ($data->{errors} and my $first_error = $data->{errors}->[0]) {
+ flash('error', $::locale->text('There was an error parsing the csv file: #1 in line #2.', $first_error->[2], $first_error->[0]));
+ }
+
+ if ($data->{progress}{finished} || $data->{errors}) {
+ $self->render('csv_import/_deferred_report', { no_layout => 1 });
+ } else {
+ $self->render('csv_import/_deferred_results', { no_layout => 1 });
+ }
+}
+
+sub action_download_sample {
+ my $self = shift;
+
+ $self->profile_from_form;
+ $self->setup_help;
+
+ my $file_name = 'csv_import_sample_' . $self->type . '.csv';
+ my $file = SL::SessionFile->new($file_name, mode => '>', encoding => $self->profile->get('charset'));
+ my $csv = Text::CSV_XS->new({ binary => 1, map { ( $_ => $self->profile->get($_) ) } qw(sep_char escape_char quote_char),});
+
+ $csv->print($file->fh, [ map { $_->{name} } @{ $self->displayable_columns } ]);
+ $file->fh->print("\r\n");
+ $csv->print($file->fh, [ map { $_->{description} } @{ $self->displayable_columns } ]);
+ $file->fh->print("\r\n");
+
+ $file->fh->close;
+
+ $self->send_file($file->file_name, name => $file_name);
+}
+
+sub action_report {
+ my ($self, %params) = @_;
+
+ my $report_id = $params{report_id} || $::form->{id};
+
+ $self->{report} = SL::DB::Manager::CsvImportReport->find_by(id => $report_id);
+ my $num_rows = SL::DB::Manager::CsvImportReportRow->get_all_count(query => [ csv_import_report_id => $report_id ]);
+ my $num_cols = SL::DB::Manager::CsvImportReportRow->get_all_count(query => [ csv_import_report_id => $report_id, row => 0 ]);
+
+ # manual paginating, yuck
+ my $page = $::form->{page} || 1;
+ my $pages = {};
+ $pages->{per_page} = $::form->{per_page} || 20;
+ $pages->{max} = SL::DB::Helper::Paginated::ceil($num_rows / ($num_cols || 1), $pages->{per_page}) || 1;
+ $pages->{cur} = $page < 1 ? 1
+ : $page > $pages->{max} ? $pages->{max}
+ : $page;
+ $pages->{common} = SL::DB::Helper::Paginated::make_common_pages($pages->{cur}, $pages->{max});
+
+ $self->{display_rows} = [
+ 0,
+ $pages->{per_page} * ($pages->{cur}-1) + 1
+ ..
+ min($pages->{per_page} * $pages->{cur}, $num_rows / ($num_cols || 1) - 1)
+ ];
+
+ my @query = (
+ csv_import_report_id => $report_id,
+ or => [
+ row => 0,
+ and => [
+ row => { gt => $pages->{per_page} * ($pages->{cur}-1) },
+ row => { le => $pages->{per_page} * $pages->{cur} },
+ ]
+ ]
+ );
+
+ my $rows = SL::DB::Manager::CsvImportReportRow->get_all(query => \@query);
+ my $status = SL::DB::Manager::CsvImportReportStatus->get_all(query => \@query);
+
+ $self->{report_rows} = $self->{report}->folded_rows(rows => $rows);
+ $self->{report_status} = $self->{report}->folded_status(status => $status);
+ $self->{pages} = $pages;
+ $self->{base_url} = $self->url_for(action => 'report', id => $report_id, no_layout => $params{no_layout} || $::form->{no_layout} );
+
+ $self->render('csv_import/report', { no_layout => $params{no_layout} || $::form->{no_layout} });
+}
+
+