X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FRecordLinks.pm;h=77086ba70660aedf1d87f285467174cbd77d931a;hb=a8b18c65bfd47c845e641fb0fff9587f4122bf9d;hp=c5049987457b736f9a754c8b1af364d1510cb7df;hpb=3af71f2e27419024b28a2ff65e8b4d7cf499035d;p=kivitendo-erp.git diff --git a/SL/RecordLinks.pm b/SL/RecordLinks.pm index c50499874..77086ba70 100644 --- a/SL/RecordLinks.pm +++ b/SL/RecordLinks.pm @@ -1,7 +1,12 @@ package RecordLinks; +use utf8; +use strict; + use SL::Common; use SL::DBUtils; +use Data::Dumper; +use List::Util qw(reduce); sub create_links { $main::lxdebug->enter_sub(); @@ -130,8 +135,8 @@ sub get_links_via { my $myconfig = \%main::myconfig; my $form = $main::form; - my $last_hop = shift @hops; - my @links = undef; + my $last_hop = shift @hops; + my @links; for my $hop (@hops) { my @temp_links = $self->get_links( @@ -141,25 +146,136 @@ sub get_links_via { to_id => $hop->{id}, ); - if (@links) { - @links = grep { $_ } - cross { - if ( $a->{to_table} eq $b->{from_table} - && $a->{to_id} eq $b->{from_id} ) { - +{ $a->{from_table}, $a->{from_id}, - $b->{to_table}, $b->{to_table} } - } - } @links, @temp_links; - } else { - @links = @temp_links; - } + # short circuit if any of these are empty + return wantarray ? () : [] unless scalar @temp_links; - $last_hop = $hop; + push @links, \@temp_links; + $last_hop = $hop; } + my $result = reduce { + [ + grep { $_ } + cross { + if ( $a->{to_table} eq $b->{from_table} + && $a->{to_id} eq $b->{from_id} ) { + +{ from_table => $a->{from_table}, + from_id => $a->{from_id}, + to_table => $b->{to_table}, + to_id => $b->{to_id} } + } + } @{ $a }, @{ $b } + ] + } @links; + $main::lxdebug->leave_sub(); - return wantarray ? @links : \@links; + return wantarray ? @{ $result } : $result; +} + +sub delete { + $main::lxdebug->enter_sub(); + + my $self = shift; + my %params = @_; + + Common::check_params(\%params, [ qw(from_table from_id to_table to_id) ]); + + my $myconfig = \%main::myconfig; + my $form = $main::form; + + my $dbh = $params{dbh} || $form->get_standard_dbh($myconfig); + + # content + my (@where_tokens, @where_values); + + for my $col (qw(from_table from_id to_table to_id)) { + add_token(\@where_tokens, \@where_values, col => $col, val => $params{$col}) if $params{$col}; + } + + my $where = @where_tokens ? "WHERE ". join ' AND ', map { "($_)" } @where_tokens : ''; + my $query = "DELETE FROM record_links $where"; + + do_query($form, $dbh, $query, @where_values); + + $dbh->commit() unless ($params{dbh}); + + $main::lxdebug->leave_sub(); } 1; + +__END__ + +=head1 NAME + +SL::RecordLinks - Verlinkung von kivitendo Objekten. + +=head1 SYNOPSIS + + use SL::RecordLinks; + + my @links = RecordLinks->get_links( + from_table => 'ar', + from_id => 2, + to_table => 'oe', + ); + my @links = RecordLinks->get_links_via( + from_table => 'oe', + to_id => '14', + via => [ + { id => 12 }, + { id => 13}, + ], + ); + + RecordLinks->create_links( + mode => 'ids', + from_table => 'ar', + from_id => 1, + to_table => 'oe', + to_ids => [4, 6, 9], + ) + RecordLinks->create_links(@links); + + delete + +=head1 DESCRIPTION + +Transitive RecordLinks mit get_links_via. + +get_links_via erwartet den zusätzlichen parameter via. via ist ein +hashref mit den jeweils optionalen Einträgen table und id, die sich +genauso verhalten wie die from/to_table/id werte der get_links funktion. + +Alternativ kann via auch ein Array dieser Hashes sein: + + get_links_via( + from_table => 'oe', + from_id => 1, + to_table => 'ar', + via => { + table => 'delivery_orders' + }, + ) + + get_links_via( + from_table => 'oe', + to_id => '14', + via => [ + { id => 12 }, + { id => 13}, + ], + ) + +Die Einträge in einem via-Array werden exakt in dieser Reihenfolge +benutzt und sind nicht optional. Da obige Beispiel würde also die +Verknüpfung: + + oe:11 -> ar:12 -> is:13 -> do:14 + +finden, nicht aber: + + oe:11 -> ar:13 -> do:14 + +=cut