projekt kivitendo

package SL::BackgroundJob::ShopPartMassUpload;

use strict;

use warnings;

use parent qw(SL::BackgroundJob::Base);

use SL::DBUtils;

use SL::DB::ShopPart;

use SL::Shop;

use constant WAITING_FOR_EXECUTION        => 0;

use constant UPLOAD_TO_WEBSHOP            => 1;

use constant DONE                         => 2;

# Data format:

# my $data                  = {

#     shop_part_record_ids         => [ 603, 604, 605 ],

#     todo                         => $::form->{upload_todo},

#     status                       => SL::BackgroundJob::ShopPartMassUpload->WAITING_FOR_EXECUTION(),

#     num_uploaded                 => 0,

#     conversation                 => [ { id => 603 , number => 2, message => "Ok" or $@ }, ],

# };

sub update_webarticles {

  my ( $self ) = @_;

  my $job_obj = $self->{job_obj};

  my $db      = $job_obj->db;

  $job_obj->set_data(UPLOAD_TO_WEBSHOP())->save;

  my $num_uploaded = 0;

  foreach my $shop_part_id (@{ $job_obj->data_as_hash->{shop_part_record_ids} }) {

    my $data  = $job_obj->data_as_hash;

    eval {

      my $shop_part = SL::DB::Manager::ShopPart->find_by(id => $shop_part_id);

      unless($shop_part){

        push @{ $data->{conversion} }, { id => $shop_part_id, number => '', message => 'Shoppart not found' };

      }

      my $shop = SL::Shop->new( config => $shop_part->shop );

      my $return    = $shop->connector->update_part($shop_part, $data->{todo});

      if ( $return == 1 ) {

        my $now = DateTime->now;

        my $attributes->{last_update} = $now;

        $shop_part->assign_attributes(%{ $attributes });

        $shop_part->save;

        $data->{num_uploaded} = $num_uploaded++;

        push @{ $data->{conversion} }, { id => $shop_part_id, number => $shop_part->part->partnumber, message => 'uploaded' };

      }else{

      push @{ $data->{conversion} }, { id => $shop_part_id, number => $shop_part->part->partnumber, message => $return };

      }

      1;

    } or do {

      push @{ $data->{conversion} }, { id => $shop_part_id, number => '', message => $@ };

    };

    $job_obj->update_attributes(data_as_hash => $data);

  }

}

sub run {

  my ($self, $job_obj) = @_;

  $self->{job_obj}         = $job_obj;

  $self->update_webarticles;

  $job_obj->set_data(status => DONE())->save;

  return 1;

}

1;