X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FWH.pm;h=f363ae50e53a3a5e666433c48b88d2f0e81ea71f;hb=7349649bae8d80eabfd253592d59f8455f9ef6b0;hp=04b1914e003a29456e96e0f67483552a3d98dfd7;hpb=f71b2873b17c2c17ad9b71139cb389f689645ad4;p=kivitendo-erp.git diff --git a/SL/WH.pm b/SL/WH.pm index 04b1914e0..f363ae50e 100644 --- a/SL/WH.pm +++ b/SL/WH.pm @@ -37,95 +37,119 @@ package WH; use SL::AM; use SL::DBUtils; use SL::Form; +use SL::Util qw(trim); use warnings; use strict; sub transfer { - $main::lxdebug->enter_sub(); + $::lxdebug->enter_sub; - my $self = shift; + my ($self, @args) = @_; - if (!@_) { - $main::lxdebug->leave_sub(); + if (!@args) { + $::lxdebug->leave_sub; return; } - my $myconfig = \%main::myconfig; - my $form = $main::form; - - my $dbh = $form->get_standard_dbh($myconfig); - - my $units = AM->retrieve_units($myconfig, $form); - - my $query = qq|SELECT * FROM transfer_type|; - my $sth = prepare_execute_query($form, $dbh, $query); - - my %transfer_types; - - while (my $ref = $sth->fetchrow_hashref()) { - $transfer_types{$ref->{direction}} ||= { }; - $transfer_types{$ref->{direction}}->{$ref->{description}} = $ref->{id}; - } + require SL::DB::TransferType; + require SL::DB::Part; + require SL::DB::Employee; + require SL::DB::Inventory; - my @part_ids = map { $_->{parts_id} } @_; - my %partunits = selectall_as_map($form, $dbh, qq|SELECT id, unit FROM parts WHERE id IN (| . join(', ', map { '?' } @part_ids ) . qq|)|, 'id', 'unit', @part_ids); + my $employee = SL::DB::Manager::Employee->find_by(login => $::myconfig{login}); + my ($now) = selectrow_query($::form, $::form->get_standard_dbh, qq|SELECT current_date|); + my @directions = (undef, qw(out in transfer)); - my ($now) = selectrow_query($form, $dbh, qq|SELECT current_date|); + my $objectify = sub { + my ($transfer, $field, $class, @find_by) = @_; - $query = qq|INSERT INTO inventory (warehouse_id, bin_id, parts_id, chargenumber, bestbefore, - oe_id, orderitems_id, shippingdate, - employee_id, project_id, trans_id, trans_type_id, comment, qty) - VALUES (?, ?, ?, ?, ?, ?, ?, ?, (SELECT id FROM employee WHERE login = ?), ?, ?, ?, ?, ?)|; + @find_by = (description => $transfer->{$field}) unless @find_by; - $sth = prepare_query($form, $dbh, $query); - - my @directions = (undef, 'out', 'in', 'transfer'); - - while (@_) { - my $transfer = shift; - my ($trans_id) = selectrow_query($form, $dbh, qq|SELECT nextval('id')|); - - my ($direction, @values) = (0); - - $direction |= 1 if ($transfer->{src_warehouse_id} && $transfer->{src_bin_id}); - $direction |= 2 if ($transfer->{dst_warehouse_id} && $transfer->{dst_bin_id}); - - push @values, conv_i($transfer->{parts_id}), "$transfer->{chargenumber}", conv_date($transfer->{bestbefore}), conv_i($transfer->{oe_id}), conv_i($transfer->{orderitems_id}); - push @values, $transfer->{shippingdate} eq 'current_date' ? $now : conv_date($transfer->{shippingdate}), $form->{login}, conv_i($transfer->{project_id}), $trans_id; - - if ($transfer->{transfer_type_id}) { - push @values, $transfer->{transfer_type_id}; - } else { - push @values, $transfer_types{$directions[$direction]}->{$transfer->{transfer_type}}; + if ($transfer->{$field} || $transfer->{"${field}_id"}) { + return ref $transfer->{$field} && $transfer->{$field}->isa($class) ? $transfer->{$field} + : $transfer->{$field} ? $class->_get_manager_class->find_by(@find_by) + : $class->_get_manager_class->find_by(id => $transfer->{"${field}_id"}); } - - $transfer->{comment} = defined($transfer->{comment}) ? $transfer->{comment} : ''; - push @values, "$transfer->{comment}"; - - my $qty = $transfer->{qty}; + return; + }; + + my @trans_ids; + + my $db = SL::DB::Inventory->new->db; + $db->with_transaction(sub{ + while (my $transfer = shift @args) { + my ($trans_id) = selectrow_query($::form, $::form->get_standard_dbh, qq|SELECT nextval('id')|); + + my $part = $objectify->($transfer, 'parts', 'SL::DB::Part'); + my $unit = $objectify->($transfer, 'unit', 'SL::DB::Unit', name => $transfer->{unit}); + my $qty = $transfer->{qty}; + my $src_bin = $objectify->($transfer, 'src_bin', 'SL::DB::Bin'); + my $dst_bin = $objectify->($transfer, 'dst_bin', 'SL::DB::Bin'); + my $src_wh = $objectify->($transfer, 'src_warehouse', 'SL::DB::Warehouse'); + my $dst_wh = $objectify->($transfer, 'dst_warehouse', 'SL::DB::Warehouse'); + my $project = $objectify->($transfer, 'project', 'SL::DB::Project'); + + $src_wh ||= $src_bin->warehouse if $src_bin; + $dst_wh ||= $dst_bin->warehouse if $dst_bin; + + my $direction = 0; # bit mask + $direction |= 1 if $src_bin; + $direction |= 2 if $dst_bin; + + my $transfer_type = $objectify->($transfer, 'transfer_type', 'SL::DB::TransferType', direction => $directions[$direction], + description => $transfer->{transfer_type}); + + my %params = ( + part => $part, + employee => $employee, + trans_type => $transfer_type, + project => $project, + trans_id => $trans_id, + shippingdate => !$transfer->{shippingdate} || $transfer->{shippingdate} eq 'current_date' + ? $now : $transfer->{shippingdate}, + map { $_ => $transfer->{$_} } qw(chargenumber bestbefore oe_id delivery_order_items_stock_id invoice_id comment), + ); + + if ($unit) { + $qty = $unit->convert_to($qty, $part->unit_obj); + } - if ($transfer->{unit}) { - my $partunit = $partunits{$transfer->{parts_id}}; + $params{chargenumber} ||= ''; - $qty *= $units->{$transfer->{unit}}->{factor}; - $qty /= $units->{$partunit}->{factor} || 1 if ($partunit); - } + if ($direction & 1) { + SL::DB::Inventory->new( + %params, + warehouse => $src_wh, + bin => $src_bin, + qty => $qty * -1, + )->save; + } - if ($direction & 1) { - do_statement($form, $sth, $query, conv_i($transfer->{src_warehouse_id}), conv_i($transfer->{src_bin_id}), @values, $qty * -1); - } + if ($direction & 2) { + SL::DB::Inventory->new( + %params, + warehouse => $dst_wh->id, + bin => $dst_bin->id, + qty => $qty, + )->save; + # Standardlagerplatz in Stammdaten gleich mitverschieben + if (defined($transfer->{change_default_bin})){ + $part->update_attributes(warehouse_id => $dst_wh->id, bin_id => $dst_bin->id); + } + } - if ($direction & 2) { - do_statement($form, $sth, $query, conv_i($transfer->{dst_warehouse_id}), conv_i($transfer->{dst_bin_id}), @values, $qty); + push @trans_ids, $trans_id; } - } - $sth->finish(); + 1; + }) or do { + $::form->error("Warehouse transfer error: " . join("\n", (split(/\n/, $db->error))[0..2])); + }; - $dbh->commit(); + $::lxdebug->leave_sub; - $main::lxdebug->leave_sub(); + return @trans_ids; } sub transfer_assembly { @@ -146,28 +170,35 @@ sub transfer_assembly { # # ... Standard-Check oben Ende. Hier die eigentliche SQL-Abfrage # select parts_id,qty from assembly where id=1064; - # Erweiterung für bug 935 am 23.4.09 - + # Erweiterung für bug 935 am 23.4.09 - # Erzeugnisse können Dienstleistungen enthalten, die ja nicht 'lagerbar' sind. - # select parts_id,qty from assembly inner join parts on assembly.parts_id = parts.id + # select parts_id,qty from assembly inner join parts on assembly.parts_id = parts.id # where assembly.id=1066 and inventory_accno_id IS NOT NULL; # - # Erweiterung für bug 23.4.09 -2 Erzeugnisse in Erzeugnissen können nicht ausgelagert werden, + # Erweiterung für bug 23.4.09 -2 Erzeugnisse in Erzeugnissen können nicht ausgelagert werden, # wenn assembly nicht überprüft wird ... # patch von joachim eingespielt 24.4.2009: # my $query = qq|select parts_id,qty from assembly inner join parts # on assembly.parts_id = parts.id where assembly.id = ? and # (inventory_accno_id IS NOT NULL or parts.assembly = TRUE)|; + # Lager in dem die Bestandteile gesucht werden kann entweder das Ziellager sein oder ist per Mandantenkonfig + # auf das Standardlager des Bestandteiles schaltbar - my $query = qq|select parts_id,qty from assembly inner join parts on assembly.parts_id = parts.id - where assembly.id = ? and (inventory_accno_id IS NOT NULL or parts.assembly = TRUE)|; + my $use_default_warehouse = $::instance_conf->get_transfer_default_warehouse_for_assembly; + + my $query = qq|SELECT assembly.parts_id, assembly.qty, parts.warehouse_id + FROM assembly INNER JOIN parts ON assembly.parts_id = parts.id + WHERE assembly.id = ? AND (inventory_accno_id IS NOT NULL OR parts.assembly = TRUE)|; my $sth_part_qty_assembly = prepare_execute_query($form, $dbh, $query, $params{assembly_id}); # Hier wird das prepared Statement für die Schleife über alle Lagerplätze vorbereitet - my $transferPartSQL = qq|INSERT INTO inventory (parts_id, warehouse_id, bin_id, chargenumber, bestbefore, comment, employee_id, qty, trans_id, trans_type_id) + my $transferPartSQL = qq|INSERT INTO inventory (parts_id, warehouse_id, bin_id, chargenumber, bestbefore, comment, employee_id, qty, + trans_id, trans_type_id, shippingdate) VALUES (?, ?, ?, ?, ?, ?, (SELECT id FROM employee WHERE login = ?), ?, nextval('id'), - (SELECT id FROM transfer_type WHERE direction = 'out' AND description = 'used'))|; + (SELECT id FROM transfer_type WHERE direction = 'out' AND description = 'used'), + (SELECT current_date))|; my $sthTransferPartSQL = prepare_query($form, $dbh, $transferPartSQL); # der return-string für die fehlermeldung inkl. welche waren zum fertigen noch fehlen @@ -176,19 +207,53 @@ sub transfer_assembly { my $schleife_durchlaufen=0; # Falls die Schleife nicht ausgeführt wird -> Keine Einzelteile definiert. Bessere Idee? jan while (my $hash_ref = $sth_part_qty_assembly->fetchrow_hashref()) { #Schleife für select parts_id,(...) from assembly $schleife_durchlaufen=1; # Erzeugnis definiert - my $partsQTY = $hash_ref->{qty} * $params{qty}; # benötigte teile * anzahl erzeugnisse - my $currentPart_ID = $hash_ref->{parts_id}; + my $partsQTY = $hash_ref->{qty} * $params{qty}; # benötigte teile * anzahl erzeugnisse + my $currentPart_ID = $hash_ref->{parts_id}; + + my $currentPart_WH_ID = $use_default_warehouse && $hash_ref->{warehouse_id} ? $hash_ref->{warehouse_id} : $params{dst_warehouse_id}; + my $no_check = 0; + + # Prüfen ob Erzeugnis-Teile Standardlager haben. + if ($use_default_warehouse && ! $hash_ref->{warehouse_id}) { + # Prüfen ob in Mandantenkonfiguration ein Standardlager aktiviert isti. + if ($::instance_conf->get_transfer_default_ignore_onhand) { + $currentPart_WH_ID = $::instance_conf->get_warehouse_id_ignore_onhand; + $no_check = 1; + } else { + $kannNichtFertigen .= "Kein Standardlager: " . + " Die Ware " . $self->get_part_description(parts_id => $currentPart_ID) . + " hat kein Standardlager definiert " . + ", um das Erzeugnis herzustellen.
"; + next; + } + } + my $warehouse_info = $self->get_basic_warehouse_info('id'=> $currentPart_WH_ID); + my $warehouse_desc = $warehouse_info->{"warehouse_description"}; + + # Fertigen ohne Prüfung nach Bestand + if ($no_check) { + my $temppart_bin_id = $::instance_conf->get_bin_id_ignore_onhand; + my $temppart_chargenumber = ""; + my $temppart_bestbefore = localtime(); + my $temppart_qty = $partsQTY * -1; + + do_statement($form, $sthTransferPartSQL, $transferPartSQL, $currentPart_ID, $currentPart_WH_ID, + $temppart_bin_id, $temppart_chargenumber, $temppart_bestbefore, 'Verbraucht für ' . + $self->get_part_description(parts_id => $params{assembly_id}), $params{login}, $temppart_qty); + next; + } # Überprüfen, ob diese Anzahl gefertigt werden kann - my $max_parts = $self->get_max_qty_parts(parts_id => $currentPart_ID, # $self->method() == this.method() - warehouse_id => $params{dst_warehouse_id}); + my $max_parts = $self->get_max_qty_parts(parts_id => $currentPart_ID, # $self->method() == this.method() + warehouse_id => $currentPart_WH_ID); if ($partsQTY > $max_parts){ - # Gibt es hier ein Problem mit nicht "escapten" Zeichen? + # Gibt es hier ein Problem mit nicht "escapten" Zeichen? # 25.4.09 Antwort: Ja. Aber erst wenn im Frontend die locales-Funktion aufgerufen wird - - $kannNichtFertigen .= "Zum Fertigen fehlen:" . abs($partsQTY - $max_parts) . - " Einheiten der Ware:" . $self->get_part_description(parts_id => $currentPart_ID) . + + $kannNichtFertigen .= "Zum Fertigen fehlen: " . abs($partsQTY - $max_parts) . + " Einheiten der Ware: " . $self->get_part_description(parts_id => $currentPart_ID) . + " im Lager: " . $warehouse_desc . ", um das Erzeugnis herzustellen.
"; # Konnte die Menge nicht mit der aktuellen Anzahl der Waren fertigen next; # die weiteren Überprüfungen sind unnötig, daher das nächste elemente prüfen (genaue Ausgabe, was noch fehlt) } @@ -200,9 +265,9 @@ sub transfer_assembly { # und lösen den Rest dann so wie bei xplace im Barcode-Programm # S.a. Kommentar im bin/mozilla-Code mb übernimmt und macht das in ordentlich - my $tempquery = qq|SELECT SUM(qty), bin_id, chargenumber, bestbefore FROM inventory + my $tempquery = qq|SELECT SUM(qty), bin_id, chargenumber, bestbefore FROM inventory WHERE warehouse_id = ? AND parts_id = ? GROUP BY bin_id, chargenumber, bestbefore having SUM(qty)>0|; - my $tempsth = prepare_execute_query($form, $dbh, $tempquery, $params{dst_warehouse_id}, $currentPart_ID); + my $tempsth = prepare_execute_query($form, $dbh, $tempquery, $currentPart_WH_ID, $currentPart_ID); # Alle Werte zu dem einzelnen Artikel, die wir später auslagern my $tmpPartsQTY = $partsQTY; @@ -213,14 +278,14 @@ sub transfer_assembly { my $temppart_bestbefore = conv_date($temphash_ref->{bestbefore}); my $temppart_qty = $temphash_ref->{sum}; - if ($tmpPartsQTY > $temppart_qty) { # wir haben noch mehr waren zum wegbuchen. + if ($tmpPartsQTY > $temppart_qty) { # wir haben noch mehr waren zum wegbuchen. # Wir buchen den kompletten Lagerplatzbestand und zählen die Hilfsvariable runter $tmpPartsQTY = $tmpPartsQTY - $temppart_qty; - $temppart_qty = $temppart_qty * -1; # TODO beim analyiseren des sql-trace, war dieser wert positiv, - # wenn * -1 als berechnung in der parameter-übergabe angegeben wird. - # Dieser Wert IST und BLEIBT positiv!! Hilfe. + $temppart_qty = $temppart_qty * -1; # TODO beim analyiseren des sql-trace, war dieser wert positiv, + # wenn * -1 als berechnung in der parameter-übergabe angegeben wird. + # Dieser Wert IST und BLEIBT positiv!! Hilfe. # Liegt das daran, dass dieser Wert aus einem SQL-Statement stammt? - do_statement($form, $sthTransferPartSQL, $transferPartSQL, $currentPart_ID, $params{dst_warehouse_id}, + do_statement($form, $sthTransferPartSQL, $transferPartSQL, $currentPart_ID, $currentPart_WH_ID, $temppart_bin_id, $temppart_chargenumber, $temppart_bestbefore, 'Verbraucht für ' . $self->get_part_description(parts_id => $params{assembly_id}), $params{login}, $temppart_qty); @@ -230,7 +295,7 @@ sub transfer_assembly { # auf jeden fall war der internal-server-error nach aktivierung von strict und warnings plus ein paar my-definitionen weg } else { # okay, wir haben weniger oder gleich Waren die wir wegbuchen müssen, wir können also aufhören $tmpPartsQTY *=-1; - do_statement($form, $sthTransferPartSQL, $transferPartSQL, $currentPart_ID, $params{dst_warehouse_id}, + do_statement($form, $sthTransferPartSQL, $transferPartSQL, $currentPart_ID, $currentPart_WH_ID, $temppart_bin_id, $temppart_chargenumber, $temppart_bestbefore, 'Verbraucht für ' . $self->get_part_description(parts_id => $params{assembly_id}), $params{login}, $tmpPartsQTY); last; # beendet die schleife (springt zum letzten element) @@ -251,11 +316,12 @@ sub transfer_assembly { # soweit alles gut. Jetzt noch die wirkliche Lagerbewegung für das Erzeugnis ausführen ... my $transferAssemblySQL = qq|INSERT INTO inventory (parts_id, warehouse_id, bin_id, chargenumber, bestbefore, - comment, employee_id, qty, trans_id, trans_type_id) + comment, employee_id, qty, trans_id, trans_type_id, shippingdate) VALUES (?, ?, ?, ?, ?, ?, (SELECT id FROM employee WHERE login = ?), ?, nextval('id'), - (SELECT id FROM transfer_type WHERE direction = 'in' AND description = 'stock'))|; + (SELECT id FROM transfer_type WHERE direction = 'in' AND description = 'assembled'), + (select current_date))|; my $sthTransferAssemblySQL = prepare_query($form, $dbh, $transferAssemblySQL); - do_statement($form, $sthTransferAssemblySQL, $transferAssemblySQL, $params{assembly_id}, $params{dst_warehouse_id}, + do_statement($form, $sthTransferAssemblySQL, $transferAssemblySQL, $params{assembly_id}, $params{dst_warehouse_id}, $params{dst_bin_id}, $params{chargenumber}, conv_date($params{bestbefore}), $params{comment}, $params{login}, $params{qty}); $dbh->commit(); @@ -292,32 +358,32 @@ sub get_warehouse_journal { if ($filter{partnumber}) { push @filter_ary, "p.partnumber ILIKE ?"; - push @filter_vars, '%' . $filter{partnumber} . '%'; + push @filter_vars, like($filter{partnumber}); } if ($filter{description}) { push @filter_ary, "(p.description ILIKE ?)"; - push @filter_vars, '%' . $filter{description} . '%'; + push @filter_vars, like($filter{description}); } if ($filter{chargenumber}) { push @filter_ary, "i1.chargenumber ILIKE ?"; - push @filter_vars, '%' . $filter{chargenumber} . '%'; + push @filter_vars, like($filter{chargenumber}); } - if ($form->{bestbefore}) { + if (trim($form->{bestbefore})) { push @filter_ary, "?::DATE = i1.bestbefore::DATE"; - push @filter_vars, $form->{bestbefore}; + push @filter_vars, trim($form->{bestbefore}); } - if ($form->{fromdate}) { - push @filter_ary, "?::DATE <= i1.itime::DATE"; - push @filter_vars, $form->{fromdate}; + if (trim($form->{fromdate})) { + push @filter_ary, "? <= i1.shippingdate"; + push @filter_vars, trim($form->{fromdate}); } - if ($form->{todate}) { - push @filter_ary, "?::DATE >= i1.itime::DATE"; - push @filter_vars, $form->{todate}; + if (trim($form->{todate})) { + push @filter_ary, "? >= i1.shippingdate"; + push @filter_vars, trim($form->{todate}); } if ($form->{l_employee}) { @@ -346,12 +412,12 @@ sub get_warehouse_journal { my $sort_order = $form->{order}; $sort_col = $filter{sort} unless $sort_col; - $sort_order = ($sort_col = 'itime') unless $sort_col; - $sort_col = 'itime' if $sort_col eq 'date'; + $sort_order = ($sort_col = 'shippingdate') unless $sort_col; + $sort_col = 'shippingdate' if $sort_col eq 'date'; $sort_order = $filter{order} unless $sort_order; my $sort_spec = "${sort_col} " . ($sort_order ? " DESC" : " ASC"); - my $where_clause = join(" AND ", @filter_ary) . " AND " if (@filter_ary); + my $where_clause = @filter_ary ? join(" AND ", @filter_ary) . " AND " : ''; $select_tokens{'trans'} = { "parts_id" => "i1.parts_id", @@ -371,8 +437,10 @@ sub get_warehouse_journal { "trans_type" => "tt.description", "trans_id" => "i1.trans_id", "oe_id" => "COALESCE(i1.oe_id, i2.oe_id)", - "date" => "i1.itime::DATE", + "invoice_id" => "COALESCE(i1.invoice_id, i2.invoice_id)", + "date" => "i1.shippingdate", "itime" => "i1.itime", + "shippingdate" => "i1.shippingdate", "employee" => "e.name", "projectnumber" => "COALESCE(pr.projectnumber, '$filter{na}')", }; @@ -387,17 +455,20 @@ sub get_warehouse_journal { "warehouse_from" => "'$filter{na}'", }; + $form->{l_invoice_id} = $form->{l_oe_id} if $form->{l_oe_id}; + # build the select clauses. # take all the requested ones from the first hash and overwrite them from the out/in hashes if present. for my $i ('trans', 'out', 'in') { $select{$i} = join ', ', map { +/^l_/; ($select_tokens{$i}{"$'"} || $select_tokens{'trans'}{"$'"}) . " AS r_$'" } - ( grep( { !/qty$/ and /^l_/ and $form->{$_} eq 'Y' } keys %$form), qw(l_parts_id l_qty l_partunit l_itime) ); + ( grep( { !/qty$/ and /^l_/ and $form->{$_} eq 'Y' } keys %$form), qw(l_parts_id l_qty l_partunit l_shippingdate) ); } my $group_clause = join ", ", map { +/^l_/; "r_$'" } - ( grep( { !/qty$/ and /^l_/ and $form->{$_} eq 'Y' } keys %$form), qw(l_parts_id l_partunit l_itime) ); + ( grep( { !/qty$/ and /^l_/ and $form->{$_} eq 'Y' } keys %$form), qw(l_parts_id l_partunit l_shippingdate) ); $where_clause = defined($where_clause) ? $where_clause : ''; + my $query = qq|SELECT DISTINCT $select{trans} FROM inventory i1 @@ -486,6 +557,18 @@ sub get_warehouse_journal { SELECT ap.id AS id, ap.invnumber AS number, 'purchase_invoice' AS type FROM ap WHERE ap.id = ? + + UNION + + SELECT ar.id AS id, ar.invnumber AS number, 'sales_invoice' AS type + FROM ar + WHERE ar.id = (SELECT trans_id FROM invoice WHERE id = ?) + + UNION + + SELECT ap.id AS id, ap.invnumber AS number, 'purchase_invoice' AS type + FROM ap + WHERE ap.id = (SELECT trans_id FROM invoice WHERE id = ?) SQL $h_oe_id = prepare_query($form, $dbh, $q_oe_id); } @@ -506,8 +589,9 @@ SQL next if (('<=' eq $f_qty_op) && ($qty > $f_qty)); } - if ($h_oe_id && $ref->{oe_id}) { - do_statement($form, $h_oe_id, $q_oe_id, ($ref->{oe_id}) x 4); + if ($h_oe_id && ($ref->{oe_id} || $ref->{invoice_id})) { + my $id = $ref->{oe_id} ? $ref->{oe_id} : $ref->{invoice_id}; + do_statement($form, $h_oe_id, $q_oe_id, ($id) x 6); $ref->{oe_id_info} = $h_oe_id->fetchrow_hashref() || {}; } @@ -576,12 +660,12 @@ sub get_warehouse_report { if ($filter{partnumber}) { push @filter_ary, "p.partnumber ILIKE ?"; - push @filter_vars, '%' . $filter{partnumber} . '%'; + push @filter_vars, like($filter{partnumber}); } if ($filter{description}) { push @filter_ary, "p.description ILIKE ?"; - push @filter_vars, '%' . $filter{description} . '%'; + push @filter_vars, like($filter{description}); } if ($filter{partsid}) { @@ -591,17 +675,25 @@ sub get_warehouse_report { if ($filter{chargenumber}) { push @filter_ary, "i.chargenumber ILIKE ?"; - push @filter_vars, '%' . $filter{chargenumber} . '%'; + push @filter_vars, like($filter{chargenumber}); } - if ($form->{bestbefore}) { + if (trim($form->{bestbefore})) { push @filter_ary, "?::DATE = i.bestbefore::DATE"; - push @filter_vars, $form->{bestbefore}; + push @filter_vars, trim($form->{bestbefore}); } if ($filter{ean}) { push @filter_ary, "p.ean ILIKE ?"; - push @filter_vars, '%' . $filter{ean} . '%'; + push @filter_vars, like($filter{ean}); + } + + if (trim($filter{date})) { + push @filter_ary, "i.shippingdate <= ?"; + push @filter_vars, trim($filter{date}); + } + if (!$filter{include_invalid_warehouses}){ + push @filter_ary, "NOT (w.invalid)"; } # prepare qty comparison for later filtering @@ -824,6 +916,40 @@ sub get_basic_bin_info { return map { $_->{bin_id} => $_ } @{ $result }; } + +sub get_basic_warehouse_info { + $main::lxdebug->enter_sub(); + + my $self = shift; + my %params = @_; + + Common::check_params(\%params, qw(id)); + + my $myconfig = \%main::myconfig; + my $form = $main::form; + + my $dbh = $params{dbh} || $form->get_standard_dbh(); + + my @ids = 'ARRAY' eq ref $params{id} ? @{ $params{id} } : ($params{id}); + + my $query = + qq|SELECT w.id AS warehouse_id, w.description AS warehouse_description + FROM warehouse w + WHERE w.id IN (| . join(', ', ('?') x scalar(@ids)) . qq|)|; + + my $result = selectall_hashref_query($form, $dbh, $query, map { conv_i($_) } @ids); + + if ('' eq ref $params{id}) { + $result = $result->[0] || { }; + $main::lxdebug->leave_sub(); + + return $result; + } + + $main::lxdebug->leave_sub(); + + return map { $_->{warehouse_id} => $_ } @{ $result }; +} # # Eingabe: Teilenummer, Lagernummer (warehouse) # Ausgabe: Die maximale Anzahl der Teile in diesem Lager @@ -842,9 +968,9 @@ $main::lxdebug->enter_sub(); my $dbh = $params{dbh} || $form->get_standard_dbh(); my $query = qq| SELECT SUM(qty), bin_id, chargenumber, bestbefore FROM inventory where parts_id = ? AND warehouse_id = ? GROUP BY bin_id, chargenumber, bestbefore|; - my $sth_QTY = prepare_execute_query($form, $dbh, $query, ,$params{parts_id}, $params{warehouse_id}); #info: aufruf an DBUtils.pm + my $max_qty_parts = 0; #Initialisierung mit 0 while (my $ref = $sth_QTY->fetchrow_hashref()) { # wir laufen über alle Haltbarkeiten, chargen und Lagerorte (s.a. SQL-Query oben) $max_qty_parts += $ref->{sum}; @@ -883,6 +1009,163 @@ $main::lxdebug->enter_sub(); return $part_description; } +# +# Eingabe: Teilenummer, Lagerplatz_Id (bin_id) +# Ausgabe: Die maximale Anzahl der Teile in diesem Lagerplatz +# Bzw. Fehler, falls Chargen oder bestbefore +# bei eingelagerten Teilen definiert sind. +# +sub get_max_qty_parts_bin { +$main::lxdebug->enter_sub(); + + my $self = shift; + my %params = @_; + + Common::check_params(\%params, qw(parts_id bin_id)); #die brauchen wir + + my $myconfig = \%main::myconfig; + my $form = $main::form; + + my $dbh = $params{dbh} || $form->get_standard_dbh(); + + my $query = qq| SELECT SUM(qty), chargenumber, bestbefore FROM inventory where parts_id = ? + AND bin_id = ? GROUP BY chargenumber, bestbefore|; + + my $sth_QTY = prepare_execute_query($form, $dbh, $query, ,$params{parts_id}, $params{bin_id}); #info: aufruf an DBUtils.pm + + my $max_qty_parts = 0; #Initialisierung mit 0 + # falls derselbe artikel mehrmals eingelagert ist + # chargennummer, muss entsprechend händisch agiert werden + my $i = 0; + my $error; + while (my $ref = $sth_QTY->fetchrow_hashref()) { # wir laufen über alle Haltbarkeiten und Chargen(s.a. SQL-Query oben) + $max_qty_parts += $ref->{sum}; + $i++; + if (($ref->{chargenumber} || $ref->{bestbefore}) && $ref->{sum} != 0){ + $error = 1; + } + } + $main::lxdebug->leave_sub(); + + return ($max_qty_parts, $error); +} + +1; + +__END__ + +=head1 NAME + +SL::WH - Warehouse backend + +=head1 SYNOPSIS + + use SL::WH; + WH->transfer(\%params); + +=head1 DESCRIPTION + +Backend for kivitendo warehousing functions. + +=head1 FUNCTIONS + +=head2 transfer \%PARAMS, [ \%PARAMS, ... ] + +This is the main function to manipulate warehouse contents. A typical transfer +is called like this: + + WH->transfer->({ + parts_id => 6342, + qty => 12.45, + transfer_type => 'transfer', + src_warehouse_id => 12, + src_bin_id => 23, + dst_warehouse_id => 25, + dst_bin_id => 167, + }); + +It will generate an entry in inventory representing the transfer. Note that +parts_id, qty, and transfer_type are mandatory. Depending on the transfer_type +a destination or a src is mandatory. + +transfer accepts more than one transaction parameter, each being a hash ref. If +more than one is supplied, it is guaranteed, that all are processed in the same +transaction. + +Here is a full list of parameters. All "_id" parameters except oe and +orderitems can be called without id with RDB objects as well. + +=over 4 + +=item parts_id + +The id of the article transferred. Does not check if the article is a service. +Mandatory. + +=item qty + +Quantity of the transaction. Mandatory. + +=item unit + +Unit of the transaction. Optional. + +=item transfer_type + +=item transfer_type_id + +The type of transaction. The first version is a string describing the +transaction (the types 'transfer' 'in' 'out' and a few others are present on +every system), the id is the hard id of a transfer_type from the database. + +Depending of the direction of the transfer_type, source and/or destination must +be specified. + +One of transfer_type or transfer_type_id is mandatory. + +=item src_warehouse_id + +=item src_bin_id + +Warehouse and bin from which to transfer. Mandatory in transfer and out +directions. Ignored in in directions. + +=item dst_warehouse_id + +=item dst_bin_id + +Warehouse and bin to which to transfer. Mandatory in transfer and in +directions. Ignored in out directions. + +=item chargenumber + +If given, the transfer will transfer only articles with this chargenumber. +Optional. + +=item orderitem_id + +Reference to an orderitem for which this transfer happened. Optional + +=item oe_id + +Reference to an order for which this transfer happened. Optional + +=item comment + +An optional comment. + +=item best_before + +An expiration date. Note that this is not by default used by C. + +=back + +=head1 BUGS + +None yet. + +=head1 AUTHOR +=cut 1;