X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FARAP.pm;h=a2d786400bf267332098c8a7609cc494881f00f6;hb=991369b17d679e2855f4d5086d0b9769dc2ae1aa;hp=dd2bd8e0257c3791641d4a1d3f27b2dff3433b63;hpb=3c681ed26ad805474401dd2b073f97d667c60f2f;p=kivitendo-erp.git diff --git a/SL/ARAP.pm b/SL/ARAP.pm index dd2bd8e02..a2d786400 100644 --- a/SL/ARAP.pm +++ b/SL/ARAP.pm @@ -4,6 +4,7 @@ use SL::AM; use SL::Common; use SL::DBUtils; use SL::MoreCommon; +use SL::DB; use Data::Dumper; use strict; @@ -19,7 +20,7 @@ sub close_orders_if_billed { my $myconfig = \%main::myconfig; my $form = $main::form; - my $dbh = $params{dbh} || $form->get_standard_dbh($myconfig); + my $dbh = $params{dbh} || SL::DB->client->dbh; # First, find all order IDs from which this invoice has been # created. Either directly by a conversion from an order to this invoice @@ -60,13 +61,14 @@ sub close_orders_if_billed { my $q_billed = qq|SELECT i.parts_id, i.qty ${qtyfactor} AS qty, i.unit, p.unit AS partunit FROM invoice i LEFT JOIN parts p ON (i.parts_id = p.id) - WHERE i.trans_id = ?|; + WHERE i.trans_id = ? AND i.assemblyitem is false|; my $h_billed = prepare_query($form, $dbh, $q_billed); my $q_ordered = qq|SELECT oi.parts_id, oi.qty, oi.unit, p.unit AS partunit FROM orderitems oi LEFT JOIN parts p ON (oi.parts_id = p.id) - WHERE oi.trans_id = ?|; + WHERE oi.trans_id = ? + AND not oi.optional|; my $h_ordered = prepare_query($form, $dbh, $q_ordered); my @close_oe_ids; @@ -75,6 +77,10 @@ sub close_orders_if_billed { # said order. Again consider both direct conversions and indirect # conversions via delivery orders. foreach my $oe_id (@oe_ids) { + + # Dont close orders with periodic invoice + next if SL::DB::Manager::PeriodicInvoicesConfig->find_by(oe_id => $oe_id); + # Direct conversions "order -> invoice": @links = RecordLinks->get_links('dbh' => $dbh, 'from_table' => 'oe', @@ -150,10 +156,11 @@ sub close_orders_if_billed { # Close orders that have been billed fully. if (scalar @close_oe_ids) { - my $query = qq|UPDATE oe SET closed = TRUE WHERE id IN (| . join(', ', ('?') x scalar @close_oe_ids) . qq|)|; - do_query($form, $dbh, $query, @close_oe_ids); - - $dbh->commit unless $params{dbh}; + SL::DB->client->with_transaction(sub { + my $query = qq|UPDATE oe SET closed = TRUE WHERE id IN (| . join(', ', ('?') x scalar @close_oe_ids) . qq|)|; + do_query($form, $dbh, $query, @close_oe_ids); + 1; + }) or do { die SL::DB->client->error }; } $main::lxdebug->leave_sub();