X-Git-Url: http://wagnertech.de/gitweb/gitweb.cgi/mfinanz.git/blobdiff_plain/2b32359da2778b424667ab9e2c27438bf1ccd980..000588da:/SL/DO.pm diff --git a/SL/DO.pm b/SL/DO.pm index 2e05f1d29..469d36592 100644 --- a/SL/DO.pm +++ b/SL/DO.pm @@ -386,18 +386,10 @@ SQL dbh => $dbh); } - # search for orphaned doi - $query = sprintf 'SELECT id FROM delivery_order_items WHERE delivery_order_id = ? AND NOT id IN (%s)', join ', ', ("?") x scalar @processed_doi; - @values = (conv_i($form->{id}), map { conv_i($_) } @processed_doi); - my @orphaned_ids = map { $_->{id} } selectall_hashref_query($form, $dbh, $query, @values); - if (scalar @orphaned_ids) { - # clean up delivery_order_items - $query = sprintf 'DELETE FROM delivery_order_items WHERE id IN (%s)', join ', ', ("?") x scalar @orphaned_ids; - do_query($form, $dbh, $query, @orphaned_ids); - } - # search for orphaned dois + # 1. search for orphaned dois; processed_dois may be empty (no transfer) TODO: be supersafe and alter same statement for doi and oi $query = sprintf 'SELECT id FROM delivery_order_items_stock WHERE delivery_order_item_id in - (select id from delivery_order_items where delivery_order_id = ?) AND NOT id IN (%s)', join ', ', ("?") x scalar @processed_dois; + (select id from delivery_order_items where delivery_order_id = ?)'; + $query .= sprintf ' AND NOT id IN (%s)', join ', ', ("?") x scalar @processed_dois if (scalar @processed_dois); @values = (conv_i($form->{id}), map { conv_i($_) } @processed_dois); my @orphaned_dois_ids = map { $_->{id} } selectall_hashref_query($form, $dbh, $query, @values); if (scalar @orphaned_dois_ids) { @@ -405,6 +397,15 @@ SQL $query = sprintf 'DELETE FROM delivery_order_items_stock WHERE id IN (%s)', join ', ', ("?") x scalar @orphaned_dois_ids; do_query($form, $dbh, $query, @orphaned_dois_ids); } + # 2. search for orphaned doi + $query = sprintf 'SELECT id FROM delivery_order_items WHERE delivery_order_id = ? AND NOT id IN (%s)', join ', ', ("?") x scalar @processed_doi; + @values = (conv_i($form->{id}), map { conv_i($_) } @processed_doi); + my @orphaned_ids = map { $_->{id} } selectall_hashref_query($form, $dbh, $query, @values); + if (scalar @orphaned_ids) { + # clean up delivery_order_items + $query = sprintf 'DELETE FROM delivery_order_items WHERE id IN (%s)', join ', ', ("?") x scalar @orphaned_ids; + do_query($form, $dbh, $query, @orphaned_ids); + } $h_item->finish(); $h_item_stock->finish();