projekt kivitendo

package SL::BackgroundJob::ShopOrderMassTransfer;

use strict;

use warnings;

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

use SL::DBUtils;

use SL::DB::ShopOrder;

use SL::DB::ShopOrderItem;

use SL::DB::Order;

use SL::DB::History;

use SL::DB::DeliveryOrder;

use SL::DB::Inventory;

use Sort::Naturally ();

use SL::Locale::String qw(t8);

use constant WAITING_FOR_EXECUTION        => 0;

use constant CONVERTING_TO_ORDER          => 1;

use constant DONE                         => 2;

# Data format:

# my $data                  = {

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

#     num_order_created           => 0,

#     orders_ids                  => [1,2,3]

#     conversion_errors         => [ { id => 603 , item => 2, message => "Out of stock"}, ],

# };

#

sub create_order {

  my ( $self ) = @_;

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

  my $db      = $job_obj->db;

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

  my $data = $job_obj->data_as_hash;

  foreach my $shop_order_id (@{ $data->{shop_order_record_ids} }) {

    my $shop_order = SL::DB::ShopOrder->new(id => $shop_order_id)->load;

    unless($shop_order){

      push @{ $data->{conversion_errors} }, { id => $shop_order->id, number => $shop_order->shop_ordernumber, message => t8('Shoporder not found') };

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

    }

    my $customer = SL::DB::Manager::Customer->find_by(id => $shop_order->{kivi_customer_id});

    unless($customer){

      push @{ $data->{conversion_errors} }, { id => $shop_order->id, number => $shop_order->shop_ordernumber, message => t8('Customer not found') };

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

    }

    my $employee = SL::DB::Manager::Employee->current;

    my $items = SL::DB::Manager::ShopOrderItem->get_all( where => [shop_order_id => $shop_order_id], );

    if ($customer->{order_lock} == 0) {

      $shop_order->{shop_order_items} = $items;

      $db->with_transaction( sub {

        my $order = $shop_order->convert_to_sales_order(customer => $customer, employee => $employee);

        if ($order->{error}){

          push @{ $data->{conversion_errors} }, { id => $shop_order->id, number => $shop_order->shop_ordernumber, message => \@{$order->{errors}} };

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

        }else{

          $order->save;

          $order->calculate_prices_and_taxes;

          my $snumbers = "ordernumber_" . $order->ordnumber;

          SL::DB::History->new(

                            trans_id    => $order->id,

                            snumbers    => $snumbers,

                            employee_id => SL::DB::Manager::Employee->current->id,

                            addition    => 'SAVED',

                            what_done   => 'Shopimport->Order(MassTransfer)',

                          )->save();

          $shop_order->transferred(1);

          $shop_order->transfer_date(DateTime->now_local);

          $shop_order->save;

          $shop_order->link_to_record($order);

          $data->{num_order_created} ++;

          push @{ $data->{orders_ids} }, $order->id;

          push @{ $data->{shop_orders_ids} }, $shop_order->id;

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

        }

        1;

      })or do {

        push @{ $data->{conversion_errors} }, { id => $shop_order->id, number => $shop_order->shop_ordernumber, message => $@ };

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

      }

    }else{

      push @{ $data->{conversion_errors} }, { id => $shop_order->id, number => $shop_order->shop_ordernumber, message => t8('Customerorderlock') };

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

    }

  }

}

sub run {

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

  $self->{job_obj}         = $job_obj;

  $self->create_order;

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

  return 1;

}

1;