X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FHelper%2FShippedQty.pm;h=6b878a972d54f43a75fe2b936c58c70728798a80;hb=08e48f66590f580cbe2c8e3df76883d88b4c0fef;hp=1b3fe81d7430ad38a2869a3e4e94a9b7aa13647e;hpb=4720b32a11bf3a7719af1bc2844a7207ca58343b;p=kivitendo-erp.git diff --git a/SL/Helper/ShippedQty.pm b/SL/Helper/ShippedQty.pm index 1b3fe81d7..6b878a972 100644 --- a/SL/Helper/ShippedQty.pm +++ b/SL/Helper/ShippedQty.pm @@ -14,7 +14,7 @@ use SL::Locale::String qw(t8); use Rose::Object::MakeMethods::Generic ( 'scalar' => [ qw(objects objects_or_ids shipped_qty keep_matches) ], - 'scalar --get_set_init' => [ qw(oe_ids dbh require_stock_out fill_up item_identity_fields oi2oe oi_qty delivered matches) ], + 'scalar --get_set_init' => [ qw(oe_ids dbh require_stock_out oi2oe oi_qty delivered matches services_deliverable) ], ); my $no_stock_item_links_query = <<''; @@ -25,31 +25,6 @@ my $no_stock_item_links_query = <<''; WHERE oi.trans_id IN (%s) ORDER BY oi.trans_id, oi.position -# oi not item linked. takes about 250ms for 100k hits -my $fill_up_oi_query = <<''; - SELECT oi.id, oi.trans_id, oi.position, oi.parts_id, oi.description, oi.reqdate, oi.serialnumber, oi.qty, oi.unit - FROM orderitems oi - WHERE oi.trans_id IN (%s) - ORDER BY oi.trans_id, oi.position - -# doi linked by record, but not by items; 250ms for 100k hits -my $no_stock_fill_up_doi_query = <<''; - SELECT doi.id, doi.delivery_order_id, doi.position, doi.parts_id, doi.description, doi.reqdate, doi.serialnumber, doi.qty, doi.unit - FROM delivery_order_items doi - WHERE doi.delivery_order_id IN ( - SELECT to_id - FROM record_links - WHERE from_id IN (%s) - AND from_table = 'oe' - AND to_table = 'delivery_orders' - AND to_id = doi.delivery_order_id) - AND NOT EXISTS ( - SELECT NULL - FROM record_links - WHERE from_table = 'orderitems' - AND to_table = 'delivery_order_items' - AND to_id = doi.id) - my $stock_item_links_query = <<''; SELECT oi.trans_id, oi.id AS oi_id, oi.qty AS oi_qty, oi.unit AS oi_unit, doi.id AS doi_id, (CASE WHEN doe.customer_id > 0 THEN -1 ELSE 1 END) * i.qty AS doi_qty, p.unit AS doi_unit @@ -63,43 +38,6 @@ my $stock_item_links_query = <<''; WHERE oi.trans_id IN (%s) ORDER BY oi.trans_id, oi.position -my $stock_fill_up_doi_query = <<''; - SELECT doi.id, doi.delivery_order_id, doi.position, doi.parts_id, doi.description, doi.reqdate, doi.serialnumber, - (CASE WHEN doe.customer_id > 0 THEN -1 ELSE 1 END) * i.qty, p.unit - FROM delivery_order_items doi - INNER JOIN parts p ON p.id = doi.parts_id - INNER JOIN delivery_order_items_stock dois ON dois.delivery_order_item_id = doi.id - INNER JOIN delivery_orders doe ON doe.id = doi.delivery_order_id - INNER JOIN inventory i ON dois.id = i.delivery_order_items_stock_id - WHERE doi.delivery_order_id IN ( - SELECT to_id - FROM record_links - WHERE from_id IN (%s) - AND from_table = 'oe' - AND to_table = 'delivery_orders' - AND to_id = doi.delivery_order_id) - AND NOT EXISTS ( - SELECT NULL - FROM record_links - WHERE from_table = 'orderitems' - AND to_table = 'delivery_order_items' - AND to_id = doi.id) - -my $oe_do_record_links = <<''; - SELECT from_id, to_id - FROM record_links - WHERE from_id IN (%s) - AND from_table = 'oe' - AND to_table = 'delivery_orders' - -my @known_item_identity_fields = qw(parts_id description reqdate serialnumber); -my %item_identity_fields = ( - parts_id => t8('Part'), - description => t8('Description'), - reqdate => t8('Reqdate'), - serialnumber => t8('Serial Number'), -); - sub calculate { my ($self, $data) = @_; @@ -110,7 +48,6 @@ sub calculate { return $self unless @{ $self->oe_ids }; $self->calculate_item_links; - $self->calculate_fill_up if $self->fill_up; $self; } @@ -137,74 +74,6 @@ sub calculate_item_links { } } -sub _intersect { - my ($a1, $a2) = @_; - my %seen; - grep { $seen{$_}++ } @$a1, @$a2; -} - -sub calculate_fill_up { - my ($self) = @_; - - my @oe_ids = @{ $self->oe_ids }; - - my $fill_up_doi_query = $self->require_stock_out ? $stock_fill_up_doi_query : $no_stock_fill_up_doi_query; - - my $oi_query = sprintf $fill_up_oi_query, join (', ', ('?')x@oe_ids); - my $doi_query = sprintf $fill_up_doi_query, join (', ', ('?')x@oe_ids); - my $rl_query = sprintf $oe_do_record_links, join (', ', ('?')x@oe_ids); - - my $oi = selectall_hashref_query($::form, $self->dbh, $oi_query, @oe_ids); - - return unless @$oi; - - my $doi = selectall_hashref_query($::form, $self->dbh, $doi_query, @oe_ids); - my $rl = selectall_hashref_query($::form, $self->dbh, $rl_query, @oe_ids); - - my %oi_by_identity = partition_by { $self->item_identity($_) } @$oi; - my %doi_by_id = partition_by { $_->{delivery_order_id} } @$doi; - my %doi_by_trans_id; - push @{ $doi_by_trans_id{$_->{from_id}} //= [] }, @{ $doi_by_id{$_->{to_id}} } - for grep { exists $doi_by_id{$_->{to_id}} } @$rl; - - my %doi_by_identity = partition_by { $self->item_identity($_) } @$doi; - - for my $match (sort keys %oi_by_identity) { - next unless exists $doi_by_identity{$match}; - - my %oi_by_oe = partition_by { $_->{trans_id} } @{ $oi_by_identity{$match} }; - for my $trans_id (sort { $a <=> $b } keys %oi_by_oe) { - next unless my @sorted_doi = _intersect($doi_by_identity{$match}, $doi_by_trans_id{$trans_id}); - - # sorting should be quite fast here, because there are usually only a handful of matches - next unless my @sorted_oi = sort { $a->{position} <=> $b->{position} } @{ $oi_by_oe{$trans_id} }; - - # parallel walk through sorted oi/doi entries - my $oi_i = my $doi_i = 0; - my ($oi, $doi) = ($sorted_oi[$oi_i], $sorted_doi[$doi_i]); - while ($oi_i < @sorted_oi && $doi_i < @sorted_doi) { - $oi = $sorted_oi[++$oi_i], next if $oi->{qty} <= $self->shipped_qty->{$oi->{id}}; - $doi = $sorted_doi[++$doi_i], next if 0 == $doi->{qty}; - - my $factor = AM->convert_unit($doi->{unit} => $oi->{unit}); - my $min_qty = min($oi->{qty} - $self->shipped_qty->{$oi->{id}}, $doi->{qty} * $factor); - - # min_qty should never be 0 now. the first part triggers the first next, - # the second triggers the second next and factor must not be 0 - # but it would lead to an infinite loop, so catch that. - die 'panic! invalid shipping quantity' unless $min_qty; - - $self->shipped_qty->{$oi->{id}} += $min_qty; - $doi->{qty} -= $min_qty / $factor; # TODO: find a way to avoid float rounding - push @{ $self->matches }, [ $oi->{id}, $doi->{id}, $min_qty, 0 ] if $self->keep_matches; - } - } - } - - $self->oi2oe->{$_->{id}} = $_->{trans_id} for @$oi; - $self->oi_qty->{$_->{id}} = $_->{qty} for @$oi; -} - sub write_to { my ($self, $objects) = @_; @@ -217,12 +86,13 @@ sub write_to { $obj->{shipped_qty} = $shipped_qty->{$obj->id} //= 0; $obj->{delivered} = $shipped_qty->{$obj->id} == $obj->qty; } elsif ('SL::DB::Order' eq ref $obj) { - if (defined $obj->{orderitems}) { - $self->write_to($obj->{orderitems}); - $obj->{delivered} = all { $_->{delivered} } @{ $obj->{orderitems} }; + # load all orderitems unless not already loaded + $obj->orderitems unless (defined $obj->{orderitems}); + $self->write_to($obj->{orderitems}); + if ($self->services_deliverable) { + $obj->{delivered} = all { $_->{delivered} } grep { !$_->{optional} } @{ $obj->{orderitems} }; } else { - # don't force a load on items. just compute by oe_id directly - $obj->{delivered} = $self->delivered->{$obj->id}; + $obj->{delivered} = all { $_->{delivered} } grep { !$_->{optional} && !$_->part->is_service } @{ $obj->{orderitems} }; } } else { die "unknown reference '@{[ ref $obj ]}' for @{[ __PACKAGE__ ]}::write_to"; @@ -241,12 +111,6 @@ sub write_to_objects { $self->write_to($self->objects); } -sub item_identity { - my ($self, $row) = @_; - - join $;, map $row->{$_}, @{ $self->item_identity_fields }; -} - sub normalize_input { my ($self, $data) = @_; @@ -266,9 +130,6 @@ sub normalize_input { $self->shipped_qty({}); } -sub available_item_identity_fields { - map { [ $_ => $item_identity_fields{$_} ] } @known_item_identity_fields; -} sub init_oe_ids { my ($self) = @_; @@ -287,6 +148,7 @@ sub init_oi_qty { {} } sub init_matches { [] } sub init_delivered { my ($self) = @_; + my $d = { }; for (keys %{ $self->oi_qty }) { my $oe_id = $self->oi2oe->{$_}; @@ -297,8 +159,17 @@ sub init_delivered { } sub init_require_stock_out { $::instance_conf->get_shipped_qty_require_stock_out } -sub init_item_identity_fields { [ grep $item_identity_fields{$_}, @{ $::instance_conf->get_shipped_qty_item_identity_fields } ] } -sub init_fill_up { $::instance_conf->get_shipped_qty_fill_up } + +sub init_services_deliverable { + my ($self) = @_; + if (($::form->{type}//'') =~ m/^sales_/ || $self->{objects}->[0]->{customer_id}) { + $::instance_conf->get_sales_delivery_order_check_service; + } elsif (($::form->{type}//'') =~ m/^purchase_/ || $self->{objects}->[0]->{vendor_id}) { + $::instance_conf->get_purchase_delivery_order_check_service; + } else { + croak "wrong call, no customer or vendor object referenced"; + } +} 1; @@ -315,7 +186,6 @@ SL::Helper::ShippedQty - Algorithmic module for calculating shipped qty use SL::Helper::ShippedQty; my $helper = SL::Helper::ShippedQty->new( - fill_up => 0, require_stock_out => 0, item_identity_fields => [ qw(parts_id description reqdate serialnumber) ], ); @@ -327,7 +197,7 @@ SL::Helper::ShippedQty - Algorithmic module for calculating shipped qty $helper->calculate($oe_id); $helper->calculate(\@oe_ids); - # if these are items set elivered and shipped_qty + # if these are items set delivered and shipped_qty # if these are orders, iterate through their items and set delivered on order $helper->write_to($objects); @@ -367,30 +237,13 @@ inventory it will mean when the delivery order is saved. =item * -How to find the correct matching elements. After the changes -to record item links it's natural to assume that each position is linked, but -for various reasons this might not be the case. Positions that are not linked -in the database need to be matched by marching. - -=item * - -Double links need to be accounted for (these can stem from buggy code). - -=item * - orderitems and oe entries may link to many of their counterparts in -delivery_orders. delivery_orders my be created from multiple orders. The +delivery_orders. delivery_orders may be created from multiple orders. The only constant is that a single entry in delivery_order_items has at most one link from an orderitem. =item * -For the fill up case the identity of positions is not clear. The naive approach -is just the same part, but description, charge number, reqdate and qty can all -be part of the identity of a position for finding shipped matches. - -=item * - Certain delivery orders might not be eligible for qty calculations if delivery orders are used for other purposes. @@ -417,7 +270,9 @@ include a bulk mode to speed up multiple objects. =item C -Creates a new helper object. PARAMS may include: +Creates a new helper object, $::form->{type} is mandatory. + +PARAMS may include: =over 4 @@ -426,28 +281,6 @@ Creates a new helper object. PARAMS may include: Boolean. If set, delivery orders must be stocked out to be considered delivered. The default is a client setting. -=item * C - -Boolean. If set, unlinked delivery order items will be used to fill up -undelivered order items. Not needed in newer installations. The default is a -client setting. - -=item * C - -If set, the fields are used to compute the identity of matching positions. The -default is a client setting. Possible values include: - -=over 4 - -=item * C - -=item * C - -=item * C - -=item * C - -=back =item * C @@ -457,6 +290,7 @@ than this modules provides. See C for the returned format. + =back =item C