C4/Acquisition.pm

   1 package C4::Acquisition;
   2
   3 # Copyright 2000-2002 Katipo Communications
   4 #
   5 # This file is part of Koha.
   6 #
   7 # Koha is free software; you can redistribute it and/or modify it
   8 # under the terms of the GNU General Public License as published by
   9 # the Free Software Foundation; either version 3 of the License, or
  10 # (at your option) any later version.
  11 #
  12 # Koha is distributed in the hope that it will be useful, but
  13 # WITHOUT ANY WARRANTY; without even the implied warranty of
  14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15 # GNU General Public License for more details.
  16 #
  17 # You should have received a copy of the GNU General Public License
  18 # along with Koha; if not, see <http://www.gnu.org/licenses>.
  19
  20
  21 use Modern::Perl;
  22 use Carp;
  23 use C4::Context;
  24 use C4::Debug;
  25 use C4::Suggestions;
  26 use C4::Biblio;
  27 use C4::Contract;
  28 use C4::Debug;
  29 use C4::Templates qw(gettemplate);
  30 use Koha::DateUtils qw( dt_from_string output_pref );
  31 use Koha::Acquisition::Baskets;
  32 use Koha::Acquisition::Booksellers;
  33 use Koha::Acquisition::Orders;
  34 use Koha::Biblios;
  35 use Koha::Exceptions;
  36 use Koha::Items;
  37 use Koha::Number::Price;
  38 use Koha::Libraries;
  39 use Koha::CsvProfiles;
  40 use Koha::Patrons;
  41
  42 use C4::Koha;
  43
  44 use MARC::Field;
  45 use MARC::Record;
  46
  47 use Time::localtime;
  48
  49 use vars qw(@ISA @EXPORT);
  50
  51 BEGIN {
  52     require Exporter;
  53     @ISA    = qw(Exporter);
  54     @EXPORT = qw(
  55         &GetBasket &NewBasket &CloseBasket &ReopenBasket &DelBasket &ModBasket
  56         &GetBasketAsCSV &GetBasketGroupAsCSV
  57         &GetBasketsByBookseller &GetBasketsByBasketgroup
  58         &GetBasketsInfosByBookseller
  59
  60         &GetBasketUsers &ModBasketUsers
  61         &CanUserManageBasket
  62
  63         &ModBasketHeader
  64
  65         &ModBasketgroup &NewBasketgroup &DelBasketgroup &GetBasketgroup &CloseBasketgroup
  66         &GetBasketgroups &ReOpenBasketgroup
  67
  68         &DelOrder &ModOrder &GetOrder &GetOrders &GetOrdersByBiblionumber
  69         &GetLateOrders &GetOrderFromItemnumber
  70         &SearchOrders &GetHistory &GetRecentAcqui
  71         &ModReceiveOrder &CancelReceipt
  72         &TransferOrder
  73         &GetLastOrderNotReceivedFromSubscriptionid &GetLastOrderReceivedFromSubscriptionid
  74         &ModItemOrder
  75
  76         &GetParcels
  77
  78         &GetInvoices
  79         &GetInvoice
  80         &GetInvoiceDetails
  81         &AddInvoice
  82         &ModInvoice
  83         &CloseInvoice
  84         &ReopenInvoice
  85         &DelInvoice
  86         &MergeInvoices
  87
  88         &AddClaim
  89         &GetBiblioCountByBasketno
  90
  91         &GetOrderUsers
  92         &ModOrderUsers
  93         &NotifyOrderUsers
  94
  95         &FillWithDefaultValues
  96
  97         &get_rounded_price
  98         &get_rounding_sql
  99     );
 100 }
 101
 102
 103
 104
 105
 106 sub GetOrderFromItemnumber {
 107     my ($itemnumber) = @_;
 108     my $dbh          = C4::Context->dbh;
 109     my $query        = qq|
 110
 111     SELECT  * from aqorders    LEFT JOIN aqorders_items
 112     ON (     aqorders.ordernumber = aqorders_items.ordernumber   )
 113     WHERE itemnumber = ?  |;
 114
 115     my $sth = $dbh->prepare($query);
 116
 117 #    $sth->trace(3);
 118
 119     $sth->execute($itemnumber);
 120
 121     my $order = $sth->fetchrow_hashref;
 122     return ( $order  );
 123
 124 }
 125
 126 =head1 NAME
 127
 128 C4::Acquisition - Koha functions for dealing with orders and acquisitions
 129
 130 =head1 SYNOPSIS
 131
 132 use C4::Acquisition;
 133
 134 =head1 DESCRIPTION
 135
 136 The functions in this module deal with acquisitions, managing book
 137 orders, basket and parcels.
 138
 139 =head1 FUNCTIONS
 140
 141 =head2 FUNCTIONS ABOUT BASKETS
 142
 143 =head3 GetBasket
 144
 145   $aqbasket = &GetBasket($basketnumber);
 146
 147 get all basket informations in aqbasket for a given basket
 148
 149 B<returns:> informations for a given basket returned as a hashref.
 150
 151 =cut
 152
 153 sub GetBasket {
 154     my ($basketno) = @_;
 155     my $dbh        = C4::Context->dbh;
 156     my $query = "
 157         SELECT  aqbasket.*,
 158                 concat( b.firstname,' ',b.surname) AS authorisedbyname
 159         FROM    aqbasket
 160         LEFT JOIN borrowers b ON aqbasket.authorisedby=b.borrowernumber
 161         WHERE basketno=?
 162     ";
 163     my $sth=$dbh->prepare($query);
 164     $sth->execute($basketno);
 165     my $basket = $sth->fetchrow_hashref;
 166     return ( $basket );
 167 }
 168
 169 #------------------------------------------------------------#
 170
 171 =head3 NewBasket
 172
 173   $basket = &NewBasket( $booksellerid, $authorizedby, $basketname,
 174       $basketnote, $basketbooksellernote, $basketcontractnumber, $deliveryplace, $billingplace, $is_standing, $create_items );
 175
 176 Create a new basket in aqbasket table
 177
 178 =over
 179
 180 =item C<$booksellerid> is a foreign key in the aqbasket table
 181
 182 =item C<$authorizedby> is the username of who created the basket
 183
 184 =back
 185
 186 The other parameters are optional, see ModBasketHeader for more info on them.
 187
 188 =cut
 189
 190 sub NewBasket {
 191     my ( $booksellerid, $authorisedby, $basketname, $basketnote,
 192         $basketbooksellernote, $basketcontractnumber, $deliveryplace,
 193         $billingplace, $is_standing, $create_items ) = @_;
 194     my $dbh = C4::Context->dbh;
 195     my $query =
 196         'INSERT INTO aqbasket (creationdate,booksellerid,authorisedby) '
 197       . 'VALUES  (now(),?,?)';
 198     $dbh->do( $query, {}, $booksellerid, $authorisedby );
 199
 200     my $basket = $dbh->{mysql_insertid};
 201     $basketname           ||= q{}; # default to empty strings
 202     $basketnote           ||= q{};
 203     $basketbooksellernote ||= q{};
 204     ModBasketHeader( $basket, $basketname, $basketnote, $basketbooksellernote,
 205         $basketcontractnumber, $booksellerid, $deliveryplace, $billingplace, $is_standing, $create_items );
 206     return $basket;
 207 }
 208
 209 #------------------------------------------------------------#
 210
 211 =head3 CloseBasket
 212
 213   &CloseBasket($basketno);
 214
 215 close a basket (becomes unmodifiable, except for receives)
 216
 217 =cut
 218
 219 sub CloseBasket {
 220     my ($basketno) = @_;
 221     my $dbh        = C4::Context->dbh;
 222     $dbh->do('UPDATE aqbasket SET closedate=now() WHERE basketno=?', {}, $basketno );
 223
 224     $dbh->do(
 225 q{UPDATE aqorders SET orderstatus = 'ordered' WHERE basketno = ? AND orderstatus NOT IN ( 'complete', 'cancelled')},
 226         {}, $basketno
 227     );
 228     return;
 229 }
 230
 231 =head3 ReopenBasket
 232
 233   &ReopenBasket($basketno);
 234
 235 reopen a basket
 236
 237 =cut
 238
 239 sub ReopenBasket {
 240     my ($basketno) = @_;
 241     my $dbh        = C4::Context->dbh;
 242     $dbh->do( q{UPDATE aqbasket SET closedate=NULL WHERE  basketno=?}, {}, $basketno );
 243
 244     $dbh->do( q{
 245         UPDATE aqorders
 246         SET orderstatus = 'new'
 247         WHERE basketno = ?
 248         AND orderstatus NOT IN ( 'complete', 'cancelled' )
 249         }, {}, $basketno);
 250     return;
 251 }
 252
 253 #------------------------------------------------------------#
 254
 255 =head3 GetBasketAsCSV
 256
 257   &GetBasketAsCSV($basketno);
 258
 259 Export a basket as CSV
 260
 261 $cgi parameter is needed for column name translation
 262
 263 =cut
 264
 265 sub GetBasketAsCSV {
 266     my ($basketno, $cgi, $csv_profile_id) = @_;
 267     my $basket = GetBasket($basketno);
 268     my @orders = GetOrders($basketno);
 269     my $contract = GetContract({
 270         contractnumber => $basket->{'contractnumber'}
 271     });
 272
 273     my $template = C4::Templates::gettemplate("acqui/csv/basket.tt", "intranet", $cgi);
 274     my @rows;
 275     if ($csv_profile_id) {
 276         my $csv_profile = Koha::CsvProfiles->find( $csv_profile_id );
 277         Koha::Exceptions::ObjectNotFound->throw( 'There is no valid csv profile given') unless $csv_profile;
 278
 279         my $csv = Text::CSV_XS->new({'quote_char'=>'"','escape_char'=>'"','sep_char'=>$csv_profile->csv_separator,'binary'=>1});
 280         my $csv_profile_content = $csv_profile->content;
 281         my ( @headers, @fields );
 282         while ( $csv_profile_content =~ /
 283             ([^=\|]+) # header
 284             =?
 285             ([^\|]*) # fieldname (table.row or row)
 286             \|? /gxms
 287         ) {
 288             my $header = $1;
 289             my $field = ($2 eq '') ? $1 : $2;
 290
 291             $header =~ s/^\s+|\s+$//g; # Trim whitespaces
 292             push @headers, $header;
 293
 294             $field =~ s/[^\.]*\.{1}//; # Remove the table name if exists.
 295             $field =~ s/^\s+|\s+$//g; # Trim whitespaces
 296             push @fields, $field;
 297         }
 298         for my $order (@orders) {
 299             my @row;
 300             my $biblio = Koha::Biblios->find( $order->{biblionumber} );
 301             my $biblioitem = $biblio->biblioitem;
 302             $order = { %$order, %{ $biblioitem->unblessed } };
 303             if ($contract) {
 304                 $order = {%$order, %$contract};
 305             }
 306             $order = {%$order, %$basket, %{ $biblio->unblessed }};
 307             for my $field (@fields) {
 308                 push @row, $order->{$field};
 309             }
 310             push @rows, \@row;
 311         }
 312         my $content = join( $csv_profile->csv_separator, @headers ) . "\n";
 313         for my $row ( @rows ) {
 314             $csv->combine(@$row);
 315             my $string = $csv->string;
 316             $content .= $string . "\n";
 317         }
 318         return $content;
 319     }
 320     else {
 321         foreach my $order (@orders) {
 322             my $biblio = Koha::Biblios->find( $order->{biblionumber} );
 323             my $biblioitem = $biblio->biblioitem;
 324             my $row = {
 325                 contractname => $contract->{'contractname'},
 326                 ordernumber => $order->{'ordernumber'},
 327                 entrydate => $order->{'entrydate'},
 328                 isbn => $order->{'isbn'},
 329                 author => $biblio->author,
 330                 title => $biblio->title,
 331                 publicationyear => $biblioitem->publicationyear,
 332                 publishercode => $biblioitem->publishercode,
 333                 collectiontitle => $biblioitem->collectiontitle,
 334                 notes => $order->{'order_vendornote'},
 335                 quantity => $order->{'quantity'},
 336                 rrp => $order->{'rrp'},
 337             };
 338             for my $place ( qw( deliveryplace billingplace ) ) {
 339                 if ( my $library = Koha::Libraries->find( $row->{deliveryplace} ) ) {
 340                     $row->{$place} = $library->branchname
 341                 }
 342             }
 343             foreach(qw(
 344                 contractname author title publishercode collectiontitle notes
 345                 deliveryplace billingplace
 346             ) ) {
 347                 # Double the quotes to not be interpreted as a field end
 348                 $row->{$_} =~ s/"/""/g if $row->{$_};
 349             }
 350             push @rows, $row;
 351          }
 352
 353         @rows = sort {
 354             if(defined $a->{publishercode} and defined $b->{publishercode}) {
 355                 $a->{publishercode} cmp $b->{publishercode};
 356             }
 357         } @rows;
 358
 359         $template->param(rows => \@rows);
 360
 361         return $template->output;
 362     }
 363 }
 364
 365
 366 =head3 GetBasketGroupAsCSV
 367
 368   &GetBasketGroupAsCSV($basketgroupid);
 369
 370 Export a basket group as CSV
 371
 372 $cgi parameter is needed for column name translation
 373
 374 =cut
 375
 376 sub GetBasketGroupAsCSV {
 377     my ($basketgroupid, $cgi) = @_;
 378     my $baskets = GetBasketsByBasketgroup($basketgroupid);
 379
 380     my $template = C4::Templates::gettemplate('acqui/csv/basketgroup.tt', 'intranet', $cgi);
 381
 382     my @rows;
 383     for my $basket (@$baskets) {
 384         my @orders     = GetOrders( $basket->{basketno} );
 385         my $contract   = GetContract({
 386             contractnumber => $basket->{contractnumber}
 387         });
 388         my $bookseller = Koha::Acquisition::Booksellers->find( $basket->{booksellerid} );
 389         my $basketgroup = GetBasketgroup( $$basket{basketgroupid} );
 390
 391         foreach my $order (@orders) {
 392             my $biblio = Koha::Biblios->find( $order->{biblionumber} );
 393             my $biblioitem = $biblio->biblioitem;
 394             my $row = {
 395                 clientnumber => $bookseller->accountnumber,
 396                 basketname => $basket->{basketname},
 397                 ordernumber => $order->{ordernumber},
 398                 author => $biblio->author,
 399                 title => $biblio->title,
 400                 publishercode => $biblioitem->publishercode,
 401                 publicationyear => $biblioitem->publicationyear,
 402                 collectiontitle => $biblioitem->collectiontitle,
 403                 isbn => $order->{isbn},
 404                 quantity => $order->{quantity},
 405                 rrp_tax_included => $order->{rrp_tax_included},
 406                 rrp_tax_excluded => $order->{rrp_tax_excluded},
 407                 discount => $bookseller->discount,
 408                 ecost_tax_included => $order->{ecost_tax_included},
 409                 ecost_tax_excluded => $order->{ecost_tax_excluded},
 410                 notes => $order->{order_vendornote},
 411                 entrydate => $order->{entrydate},
 412                 booksellername => $bookseller->name,
 413                 bookselleraddress => $bookseller->address1,
 414                 booksellerpostal => $bookseller->postal,
 415                 contractnumber => $contract->{contractnumber},
 416                 contractname => $contract->{contractname},
 417             };
 418             my $temp = {
 419                 basketgroupdeliveryplace => $basketgroup->{deliveryplace},
 420                 basketgroupbillingplace  => $basketgroup->{billingplace},
 421                 basketdeliveryplace      => $basket->{deliveryplace},
 422                 basketbillingplace       => $basket->{billingplace},
 423             };
 424             for my $place (qw( basketgroupdeliveryplace basketgroupbillingplace basketdeliveryplace basketbillingplace )) {
 425                 if ( my $library = Koha::Libraries->find( $temp->{$place} ) ) {
 426                     $row->{$place} = $library->branchname;
 427                 }
 428             }
 429             foreach(qw(
 430                 basketname author title publishercode collectiontitle notes
 431                 booksellername bookselleraddress booksellerpostal contractname
 432                 basketgroupdeliveryplace basketgroupbillingplace
 433                 basketdeliveryplace basketbillingplace
 434             ) ) {
 435                 # Double the quotes to not be interpreted as a field end
 436                 $row->{$_} =~ s/"/""/g if $row->{$_};
 437             }
 438             push @rows, $row;
 439          }
 440      }
 441     $template->param(rows => \@rows);
 442
 443     return $template->output;
 444
 445 }
 446
 447 =head3 CloseBasketgroup
 448
 449   &CloseBasketgroup($basketgroupno);
 450
 451 close a basketgroup
 452
 453 =cut
 454
 455 sub CloseBasketgroup {
 456     my ($basketgroupno) = @_;
 457     my $dbh        = C4::Context->dbh;
 458     my $sth = $dbh->prepare("
 459         UPDATE aqbasketgroups
 460         SET    closed=1
 461         WHERE  id=?
 462     ");
 463     $sth->execute($basketgroupno);
 464 }
 465
 466 #------------------------------------------------------------#
 467
 468 =head3 ReOpenBaskergroup($basketgroupno)
 469
 470   &ReOpenBaskergroup($basketgroupno);
 471
 472 reopen a basketgroup
 473
 474 =cut
 475
 476 sub ReOpenBasketgroup {
 477     my ($basketgroupno) = @_;
 478     my $dbh        = C4::Context->dbh;
 479     my $sth = $dbh->prepare("
 480         UPDATE aqbasketgroups
 481         SET    closed=0
 482         WHERE  id=?
 483     ");
 484     $sth->execute($basketgroupno);
 485 }
 486
 487 #------------------------------------------------------------#
 488
 489
 490 =head3 DelBasket
 491
 492   &DelBasket($basketno);
 493
 494 Deletes the basket that has basketno field $basketno in the aqbasket table.
 495
 496 =over
 497
 498 =item C<$basketno> is the primary key of the basket in the aqbasket table.
 499
 500 =back
 501
 502 =cut
 503
 504 sub DelBasket {
 505     my ( $basketno ) = @_;
 506     my $query = "DELETE FROM aqbasket WHERE basketno=?";
 507     my $dbh = C4::Context->dbh;
 508     my $sth = $dbh->prepare($query);
 509     $sth->execute($basketno);
 510     return;
 511 }
 512
 513 #------------------------------------------------------------#
 514
 515 =head3 ModBasket
 516
 517   &ModBasket($basketinfo);
 518
 519 Modifies a basket, using a hashref $basketinfo for the relevant information, only $basketinfo->{'basketno'} is required.
 520
 521 =over
 522
 523 =item C<$basketno> is the primary key of the basket in the aqbasket table.
 524
 525 =back
 526
 527 =cut
 528
 529 sub ModBasket {
 530     my $basketinfo = shift;
 531     my $query = "UPDATE aqbasket SET ";
 532     my @params;
 533     foreach my $key (keys %$basketinfo){
 534         if ($key ne 'basketno'){
 535             $query .= "$key=?, ";
 536             push(@params, $basketinfo->{$key} || undef );
 537         }
 538     }
 539 # get rid of the "," at the end of $query
 540     if (substr($query, length($query)-2) eq ', '){
 541         chop($query);
 542         chop($query);
 543         $query .= ' ';
 544     }
 545     $query .= "WHERE basketno=?";
 546     push(@params, $basketinfo->{'basketno'});
 547     my $dbh = C4::Context->dbh;
 548     my $sth = $dbh->prepare($query);
 549     $sth->execute(@params);
 550
 551     return;
 552 }
 553
 554 #------------------------------------------------------------#
 555
 556 =head3 ModBasketHeader
 557
 558   &ModBasketHeader($basketno, $basketname, $note, $booksellernote, $contractnumber, $booksellerid);
 559
 560 Modifies a basket's header.
 561
 562 =over
 563
 564 =item C<$basketno> is the "basketno" field in the "aqbasket" table;
 565
 566 =item C<$basketname> is the "basketname" field in the "aqbasket" table;
 567
 568 =item C<$note> is the "note" field in the "aqbasket" table;
 569
 570 =item C<$booksellernote> is the "booksellernote" field in the "aqbasket" table;
 571
 572 =item C<$contractnumber> is the "contractnumber" (foreign) key in the "aqbasket" table.
 573
 574 =item C<$booksellerid> is the id (foreign) key in the "aqbooksellers" table for the vendor.
 575
 576 =item C<$deliveryplace> is the "deliveryplace" field in the aqbasket table.
 577
 578 =item C<$billingplace> is the "billingplace" field in the aqbasket table.
 579
 580 =item C<$is_standing> is the "is_standing" field in the aqbasket table.
 581
 582 =item C<$create_items> should be set to 'ordering', 'receiving' or 'cataloguing' (or undef, in which
 583 case the AcqCreateItem syspref takes precedence).
 584
 585 =back
 586
 587 =cut
 588
 589 sub ModBasketHeader {
 590     my ($basketno, $basketname, $note, $booksellernote, $contractnumber, $booksellerid, $deliveryplace, $billingplace, $is_standing, $create_items) = @_;
 591
 592     $is_standing ||= 0;
 593     my $query = qq{
 594         UPDATE aqbasket
 595         SET basketname=?, note=?, booksellernote=?, booksellerid=?, deliveryplace=?, billingplace=?, is_standing=?, create_items=?
 596         WHERE basketno=?
 597     };
 598
 599     my $dbh = C4::Context->dbh;
 600     my $sth = $dbh->prepare($query);
 601     $sth->execute($basketname, $note, $booksellernote, $booksellerid, $deliveryplace, $billingplace, $is_standing, $create_items || undef, $basketno);
 602
 603     if ( $contractnumber ) {
 604         my $query2 ="UPDATE aqbasket SET contractnumber=? WHERE basketno=?";
 605         my $sth2 = $dbh->prepare($query2);
 606         $sth2->execute($contractnumber,$basketno);
 607     }
 608     return;
 609 }
 610
 611 #------------------------------------------------------------#
 612
 613 =head3 GetBasketsByBookseller
 614
 615   @results = &GetBasketsByBookseller($booksellerid, $extra);
 616
 617 Returns a list of hashes of all the baskets that belong to bookseller 'booksellerid'.
 618
 619 =over
 620
 621 =item C<$booksellerid> is the 'id' field of the bookseller in the aqbooksellers table
 622
 623 =item C<$extra> is the extra sql parameters, can be
 624
 625  $extra->{groupby}: group baskets by column
 626     ex. $extra->{groupby} = aqbasket.basketgroupid
 627  $extra->{orderby}: order baskets by column
 628  $extra->{limit}: limit number of results (can be helpful for pagination)
 629
 630 =back
 631
 632 =cut
 633
 634 sub GetBasketsByBookseller {
 635     my ($booksellerid, $extra) = @_;
 636     my $query = "SELECT * FROM aqbasket WHERE booksellerid=?";
 637     if ($extra){
 638         if ($extra->{groupby}) {
 639             $query .= " GROUP by $extra->{groupby}";
 640         }
 641         if ($extra->{orderby}){
 642             $query .= " ORDER by $extra->{orderby}";
 643         }
 644         if ($extra->{limit}){
 645             $query .= " LIMIT $extra->{limit}";
 646         }
 647     }
 648     my $dbh = C4::Context->dbh;
 649     my $sth = $dbh->prepare($query);
 650     $sth->execute($booksellerid);
 651     return $sth->fetchall_arrayref({});
 652 }
 653
 654 =head3 GetBasketsInfosByBookseller
 655
 656     my $baskets = GetBasketsInfosByBookseller($supplierid, $allbaskets);
 657
 658 The optional second parameter allbaskets is a boolean allowing you to
 659 select all baskets from the supplier; by default only active baskets (open or
 660 closed but still something to receive) are returned.
 661
 662 Returns in a arrayref of hashref all about booksellers baskets, plus:
 663     total_biblios: Number of distinct biblios in basket
 664     total_items: Number of items in basket
 665     expected_items: Number of non-received items in basket
 666
 667 =cut
 668
 669 sub GetBasketsInfosByBookseller {
 670     my ($supplierid, $allbaskets) = @_;
 671
 672     return unless $supplierid;
 673
 674     my $dbh = C4::Context->dbh;
 675     my $query = q{
 676         SELECT aqbasket.basketno, aqbasket.basketname, aqbasket.note, aqbasket.booksellernote, aqbasket.contractnumber, aqbasket.creationdate, aqbasket.closedate, aqbasket.booksellerid, aqbasket.authorisedby, aqbasket.booksellerinvoicenumber, aqbasket.basketgroupid, aqbasket.deliveryplace, aqbasket.billingplace, aqbasket.branch, aqbasket.is_standing, aqbasket.create_items,
 677           SUM(aqorders.quantity) AS total_items,
 678           SUM(
 679             IF ( aqorders.orderstatus = 'cancelled', aqorders.quantity, 0 )
 680           ) AS total_items_cancelled,
 681           COUNT(DISTINCT aqorders.biblionumber) AS total_biblios,
 682           SUM(
 683             IF(aqorders.datereceived IS NULL
 684               AND (aqorders.datecancellationprinted IS NULL OR aqorders.datecancellationprinted='0000-00-00')
 685             , aqorders.quantity
 686             , 0)
 687           ) AS expected_items,
 688         SUM( aqorders.uncertainprice ) AS uncertainprices
 689         FROM aqbasket
 690           LEFT JOIN aqorders ON aqorders.basketno = aqbasket.basketno
 691         WHERE booksellerid = ?};
 692
 693     $query.=" GROUP BY aqbasket.basketno, aqbasket.basketname, aqbasket.note, aqbasket.booksellernote, aqbasket.contractnumber, aqbasket.creationdate, aqbasket.closedate, aqbasket.booksellerid, aqbasket.authorisedby, aqbasket.booksellerinvoicenumber, aqbasket.basketgroupid, aqbasket.deliveryplace, aqbasket.billingplace, aqbasket.branch, aqbasket.is_standing, aqbasket.create_items";
 694
 695     unless ( $allbaskets ) {
 696         # Don't show the basket if it's NOT CLOSED or is FULLY RECEIVED
 697         $query.=" HAVING (closedate IS NULL OR (
 698           SUM(
 699             IF(aqorders.datereceived IS NULL
 700               AND (aqorders.datecancellationprinted IS NULL OR aqorders.datecancellationprinted='0000-00-00')
 701             , aqorders.quantity
 702             , 0)
 703             ) > 0))"
 704     }
 705
 706     my $sth = $dbh->prepare($query);
 707     $sth->execute($supplierid);
 708     my $baskets = $sth->fetchall_arrayref({});
 709
 710     # Retrieve the number of biblios cancelled
 711     my $cancelled_biblios = $dbh->selectall_hashref( q|
 712         SELECT COUNT(DISTINCT(biblionumber)) AS total_biblios_cancelled, aqbasket.basketno
 713         FROM aqbasket
 714         LEFT JOIN aqorders ON aqorders.basketno = aqbasket.basketno
 715         WHERE booksellerid = ?
 716         AND aqorders.orderstatus = 'cancelled'
 717         GROUP BY aqbasket.basketno
 718     |, 'basketno', {}, $supplierid );
 719     map {
 720         $_->{total_biblios_cancelled} = $cancelled_biblios->{$_->{basketno}}{total_biblios_cancelled} || 0
 721     } @$baskets;
 722
 723     return $baskets;
 724 }
 725
 726 =head3 GetBasketUsers
 727
 728     $basketusers_ids = &GetBasketUsers($basketno);
 729
 730 Returns a list of all borrowernumbers that are in basket users list
 731
 732 =cut
 733
 734 sub GetBasketUsers {
 735     my $basketno = shift;
 736
 737     return unless $basketno;
 738
 739     my $query = qq{
 740         SELECT borrowernumber
 741         FROM aqbasketusers
 742         WHERE basketno = ?
 743     };
 744     my $dbh = C4::Context->dbh;
 745     my $sth = $dbh->prepare($query);
 746     $sth->execute($basketno);
 747     my $results = $sth->fetchall_arrayref( {} );
 748
 749     my @borrowernumbers;
 750     foreach (@$results) {
 751         push @borrowernumbers, $_->{'borrowernumber'};
 752     }
 753
 754     return @borrowernumbers;
 755 }
 756
 757 =head3 ModBasketUsers
 758
 759     my @basketusers_ids = (1, 2, 3);
 760     &ModBasketUsers($basketno, @basketusers_ids);
 761
 762 Delete all users from basket users list, and add users in C<@basketusers_ids>
 763 to this users list.
 764
 765 =cut
 766
 767 sub ModBasketUsers {
 768     my ($basketno, @basketusers_ids) = @_;
 769
 770     return unless $basketno;
 771
 772     my $dbh = C4::Context->dbh;
 773     my $query = qq{
 774         DELETE FROM aqbasketusers
 775         WHERE basketno = ?
 776     };
 777     my $sth = $dbh->prepare($query);
 778     $sth->execute($basketno);
 779
 780     $query = qq{
 781         INSERT INTO aqbasketusers (basketno, borrowernumber)
 782         VALUES (?, ?)
 783     };
 784     $sth = $dbh->prepare($query);
 785     foreach my $basketuser_id (@basketusers_ids) {
 786         $sth->execute($basketno, $basketuser_id);
 787     }
 788     return;
 789 }
 790
 791 =head3 CanUserManageBasket
 792
 793     my $bool = CanUserManageBasket($borrower, $basket[, $userflags]);
 794     my $bool = CanUserManageBasket($borrowernumber, $basketno[, $userflags]);
 795
 796 Check if a borrower can manage a basket, according to system preference
 797 AcqViewBaskets, user permissions and basket properties (creator, users list,
 798 branch).
 799
 800 First parameter can be either a borrowernumber or a hashref as returned by
 801 Koha::Patron->unblessed
 802
 803 Second parameter can be either a basketno or a hashref as returned by
 804 C4::Acquisition::GetBasket.
 805
 806 The third parameter is optional. If given, it should be a hashref as returned
 807 by C4::Auth::getuserflags. If not, getuserflags is called.
 808
 809 If user is authorised to manage basket, returns 1.
 810 Otherwise returns 0.
 811
 812 =cut
 813
 814 sub CanUserManageBasket {
 815     my ($borrower, $basket, $userflags) = @_;
 816
 817     if (!ref $borrower) {
 818         # FIXME This needs to be replaced
 819         # We should not accept both scalar and array
 820         # Tests need to be updated
 821         $borrower = Koha::Patrons->find( $borrower )->unblessed;
 822     }
 823     if (!ref $basket) {
 824         $basket = GetBasket($basket);
 825     }
 826
 827     return 0 unless ($basket and $borrower);
 828
 829     my $borrowernumber = $borrower->{borrowernumber};
 830     my $basketno = $basket->{basketno};
 831
 832     my $AcqViewBaskets = C4::Context->preference('AcqViewBaskets');
 833
 834     if (!defined $userflags) {
 835         my $dbh = C4::Context->dbh;
 836         my $sth = $dbh->prepare("SELECT flags FROM borrowers WHERE borrowernumber = ?");
 837         $sth->execute($borrowernumber);
 838         my ($flags) = $sth->fetchrow_array;
 839         $sth->finish;
 840
 841         $userflags = C4::Auth::getuserflags($flags, $borrower->{userid}, $dbh);
 842     }
 843
 844     unless ($userflags->{superlibrarian}
 845     || (ref $userflags->{acquisition} && $userflags->{acquisition}->{order_manage_all})
 846     || (!ref $userflags->{acquisition} && $userflags->{acquisition}))
 847     {
 848         if (not exists $userflags->{acquisition}) {
 849             return 0;
 850         }
 851
 852         if ( (ref $userflags->{acquisition} && !$userflags->{acquisition}->{order_manage})
 853         || (!ref $userflags->{acquisition} && !$userflags->{acquisition}) ) {
 854             return 0;
 855         }
 856
 857         if ($AcqViewBaskets eq 'user'
 858         && $basket->{authorisedby} != $borrowernumber
 859         && ! grep { $borrowernumber eq $_ } GetBasketUsers($basketno)) {
 860              return 0;
 861         }
 862
 863         if ($AcqViewBaskets eq 'branch' && defined $basket->{branch}
 864         && $basket->{branch} ne $borrower->{branchcode}) {
 865             return 0;
 866         }
 867     }
 868
 869     return 1;
 870 }
 871
 872 #------------------------------------------------------------#
 873
 874 =head3 GetBasketsByBasketgroup
 875
 876   $baskets = &GetBasketsByBasketgroup($basketgroupid);
 877
 878 Returns a reference to all baskets that belong to basketgroup $basketgroupid.
 879
 880 =cut
 881
 882 sub GetBasketsByBasketgroup {
 883     my $basketgroupid = shift;
 884     my $query = qq{
 885         SELECT *, aqbasket.booksellerid as booksellerid
 886         FROM aqbasket
 887         LEFT JOIN aqcontract USING(contractnumber) WHERE basketgroupid=?
 888     };
 889     my $dbh = C4::Context->dbh;
 890     my $sth = $dbh->prepare($query);
 891     $sth->execute($basketgroupid);
 892     return $sth->fetchall_arrayref({});
 893 }
 894
 895 #------------------------------------------------------------#
 896
 897 =head3 NewBasketgroup
 898
 899   $basketgroupid = NewBasketgroup(\%hashref);
 900
 901 Adds a basketgroup to the aqbasketgroups table, and add the initial baskets to it.
 902
 903 $hashref->{'booksellerid'} is the 'id' field of the bookseller in the aqbooksellers table,
 904
 905 $hashref->{'name'} is the 'name' field of the basketgroup in the aqbasketgroups table,
 906
 907 $hashref->{'basketlist'} is a list reference of the 'id's of the baskets that belong to this group,
 908
 909 $hashref->{'billingplace'} is the 'billingplace' field of the basketgroup in the aqbasketgroups table,
 910
 911 $hashref->{'deliveryplace'} is the 'deliveryplace' field of the basketgroup in the aqbasketgroups table,
 912
 913 $hashref->{'freedeliveryplace'} is the 'freedeliveryplace' field of the basketgroup in the aqbasketgroups table,
 914
 915 $hashref->{'deliverycomment'} is the 'deliverycomment' field of the basketgroup in the aqbasketgroups table,
 916
 917 $hashref->{'closed'} is the 'closed' field of the aqbasketgroups table, it is false if 0, true otherwise.
 918
 919 =cut
 920
 921 sub NewBasketgroup {
 922     my $basketgroupinfo = shift;
 923     die "booksellerid is required to create a basketgroup" unless $basketgroupinfo->{'booksellerid'};
 924     my $query = "INSERT INTO aqbasketgroups (";
 925     my @params;
 926     foreach my $field (qw(name billingplace deliveryplace freedeliveryplace deliverycomment closed)) {
 927         if ( defined $basketgroupinfo->{$field} ) {
 928             $query .= "$field, ";
 929             push(@params, $basketgroupinfo->{$field});
 930         }
 931     }
 932     $query .= "booksellerid) VALUES (";
 933     foreach (@params) {
 934         $query .= "?, ";
 935     }
 936     $query .= "?)";
 937     push(@params, $basketgroupinfo->{'booksellerid'});
 938     my $dbh = C4::Context->dbh;
 939     my $sth = $dbh->prepare($query);
 940     $sth->execute(@params);
 941     my $basketgroupid = $dbh->{'mysql_insertid'};
 942     if( $basketgroupinfo->{'basketlist'} ) {
 943         foreach my $basketno (@{$basketgroupinfo->{'basketlist'}}) {
 944             my $query2 = "UPDATE aqbasket SET basketgroupid=? WHERE basketno=?";
 945             my $sth2 = $dbh->prepare($query2);
 946             $sth2->execute($basketgroupid, $basketno);
 947         }
 948     }
 949     return $basketgroupid;
 950 }
 951
 952 #------------------------------------------------------------#
 953
 954 =head3 ModBasketgroup
 955
 956   ModBasketgroup(\%hashref);
 957
 958 Modifies a basketgroup in the aqbasketgroups table, and add the baskets to it.
 959
 960 $hashref->{'id'} is the 'id' field of the basketgroup in the aqbasketgroup table, this parameter is mandatory,
 961
 962 $hashref->{'name'} is the 'name' field of the basketgroup in the aqbasketgroups table,
 963
 964 $hashref->{'basketlist'} is a list reference of the 'id's of the baskets that belong to this group,
 965
 966 $hashref->{'billingplace'} is the 'billingplace' field of the basketgroup in the aqbasketgroups table,
 967
 968 $hashref->{'deliveryplace'} is the 'deliveryplace' field of the basketgroup in the aqbasketgroups table,
 969
 970 $hashref->{'freedeliveryplace'} is the 'freedeliveryplace' field of the basketgroup in the aqbasketgroups table,
 971
 972 $hashref->{'deliverycomment'} is the 'deliverycomment' field of the basketgroup in the aqbasketgroups table,
 973
 974 $hashref->{'closed'} is the 'closed' field of the aqbasketgroups table, it is false if 0, true otherwise.
 975
 976 =cut
 977
 978 sub ModBasketgroup {
 979     my $basketgroupinfo = shift;
 980     die "basketgroup id is required to edit a basketgroup" unless $basketgroupinfo->{'id'};
 981     my $dbh = C4::Context->dbh;
 982     my $query = "UPDATE aqbasketgroups SET ";
 983     my @params;
 984     foreach my $field (qw(name billingplace deliveryplace freedeliveryplace deliverycomment closed)) {
 985         if ( defined $basketgroupinfo->{$field} ) {
 986             $query .= "$field=?, ";
 987             push(@params, $basketgroupinfo->{$field});
 988         }
 989     }
 990     chop($query);
 991     chop($query);
 992     $query .= " WHERE id=?";
 993     push(@params, $basketgroupinfo->{'id'});
 994     my $sth = $dbh->prepare($query);
 995     $sth->execute(@params);
 996
 997     $sth = $dbh->prepare('UPDATE aqbasket SET basketgroupid = NULL WHERE basketgroupid = ?');
 998     $sth->execute($basketgroupinfo->{'id'});
 999
1000     if($basketgroupinfo->{'basketlist'} && @{$basketgroupinfo->{'basketlist'}}){
1001         $sth = $dbh->prepare("UPDATE aqbasket SET basketgroupid=? WHERE basketno=?");
1002         foreach my $basketno (@{$basketgroupinfo->{'basketlist'}}) {
1003             $sth->execute($basketgroupinfo->{'id'}, $basketno);
1004         }
1005     }
1006     return;
1007 }
1008
1009 #------------------------------------------------------------#
1010
1011 =head3 DelBasketgroup
1012
1013   DelBasketgroup($basketgroupid);
1014
1015 Deletes a basketgroup in the aqbasketgroups table, and removes the reference to it from the baskets,
1016
1017 =over
1018
1019 =item C<$basketgroupid> is the 'id' field of the basket in the aqbasketgroup table
1020
1021 =back
1022
1023 =cut
1024
1025 sub DelBasketgroup {
1026     my $basketgroupid = shift;
1027     die "basketgroup id is required to edit a basketgroup" unless $basketgroupid;
1028     my $query = "DELETE FROM aqbasketgroups WHERE id=?";
1029     my $dbh = C4::Context->dbh;
1030     my $sth = $dbh->prepare($query);
1031     $sth->execute($basketgroupid);
1032     return;
1033 }
1034
1035 #------------------------------------------------------------#
1036
1037
1038 =head2 FUNCTIONS ABOUT ORDERS
1039
1040 =head3 GetBasketgroup
1041
1042   $basketgroup = &GetBasketgroup($basketgroupid);
1043
1044 Returns a reference to the hash containing all information about the basketgroup.
1045
1046 =cut
1047
1048 sub GetBasketgroup {
1049     my $basketgroupid = shift;
1050     die "basketgroup id is required to edit a basketgroup" unless $basketgroupid;
1051     my $dbh = C4::Context->dbh;
1052     my $result_set = $dbh->selectall_arrayref(
1053         'SELECT * FROM aqbasketgroups WHERE id=?',
1054         { Slice => {} },
1055         $basketgroupid
1056     );
1057     return $result_set->[0];    # id is unique
1058 }
1059
1060 #------------------------------------------------------------#
1061
1062 =head3 GetBasketgroups
1063
1064   $basketgroups = &GetBasketgroups($booksellerid);
1065
1066 Returns a reference to the array of all the basketgroups of bookseller $booksellerid.
1067
1068 =cut
1069
1070 sub GetBasketgroups {
1071     my $booksellerid = shift;
1072     die 'bookseller id is required to edit a basketgroup' unless $booksellerid;
1073     my $query = 'SELECT * FROM aqbasketgroups WHERE booksellerid=? ORDER BY id DESC';
1074     my $dbh = C4::Context->dbh;
1075     my $sth = $dbh->prepare($query);
1076     $sth->execute($booksellerid);
1077     return $sth->fetchall_arrayref({});
1078 }
1079
1080 #------------------------------------------------------------#
1081
1082 =head2 FUNCTIONS ABOUT ORDERS
1083
1084 =head3 GetOrders
1085
1086   @orders = &GetOrders( $basketno, { orderby => 'biblio.title', cancelled => 0|1 } );
1087
1088 Looks up the pending (non-cancelled) orders with the given basket
1089 number.
1090
1091 If cancelled is set, only cancelled orders will be returned.
1092
1093 =cut
1094
1095 sub GetOrders {
1096     my ( $basketno, $params ) = @_;
1097
1098     return () unless $basketno;
1099
1100     my $orderby = $params->{orderby};
1101     my $cancelled = $params->{cancelled} || 0;
1102
1103     my $dbh   = C4::Context->dbh;
1104     my $query = q|
1105         SELECT biblio.*,biblioitems.*,
1106                 aqorders.*,
1107                 aqbudgets.*,
1108         |;
1109     $query .= $cancelled
1110       ? q|
1111                 aqorders_transfers.ordernumber_to AS transferred_to,
1112                 aqorders_transfers.timestamp AS transferred_to_timestamp
1113     |
1114       : q|
1115                 aqorders_transfers.ordernumber_from AS transferred_from,
1116                 aqorders_transfers.timestamp AS transferred_from_timestamp
1117     |;
1118     $query .= q|
1119         FROM    aqorders
1120             LEFT JOIN aqbudgets        ON aqbudgets.budget_id = aqorders.budget_id
1121             LEFT JOIN biblio           ON biblio.biblionumber = aqorders.biblionumber
1122             LEFT JOIN biblioitems      ON biblioitems.biblionumber =biblio.biblionumber
1123     |;
1124     $query .= $cancelled
1125       ? q|
1126             LEFT JOIN aqorders_transfers ON aqorders_transfers.ordernumber_from = aqorders.ordernumber
1127     |
1128       : q|
1129             LEFT JOIN aqorders_transfers ON aqorders_transfers.ordernumber_to = aqorders.ordernumber
1130
1131     |;
1132     $query .= q|
1133         WHERE   basketno=?
1134     |;
1135
1136     if ($cancelled) {
1137         $orderby ||= q|biblioitems.publishercode, biblio.title|;
1138         $query .= q|
1139             AND (datecancellationprinted IS NOT NULL
1140                AND datecancellationprinted <> '0000-00-00')
1141         |;
1142     }
1143     else {
1144         $orderby ||=
1145           q|aqorders.datecancellationprinted desc, aqorders.timestamp desc|;
1146         $query .= q|
1147             AND (datecancellationprinted IS NULL OR datecancellationprinted='0000-00-00')
1148         |;
1149     }
1150
1151     $query .= " ORDER BY $orderby";
1152     my $orders =
1153       $dbh->selectall_arrayref( $query, { Slice => {} }, $basketno );
1154     return @{$orders};
1155
1156 }
1157
1158 #------------------------------------------------------------#
1159
1160 =head3 GetOrdersByBiblionumber
1161
1162   @orders = &GetOrdersByBiblionumber($biblionumber);
1163
1164 Looks up the orders with linked to a specific $biblionumber, including
1165 cancelled orders and received orders.
1166
1167 return :
1168 C<@orders> is an array of references-to-hash, whose keys are the
1169 fields from the aqorders, biblio, and biblioitems tables in the Koha database.
1170
1171 =cut
1172
1173 sub GetOrdersByBiblionumber {
1174     my $biblionumber = shift;
1175     return unless $biblionumber;
1176     my $dbh   = C4::Context->dbh;
1177     my $query  ="
1178         SELECT biblio.*,biblioitems.*,
1179                 aqorders.*,
1180                 aqbudgets.*
1181         FROM    aqorders
1182             LEFT JOIN aqbudgets        ON aqbudgets.budget_id = aqorders.budget_id
1183             LEFT JOIN biblio           ON biblio.biblionumber = aqorders.biblionumber
1184             LEFT JOIN biblioitems      ON biblioitems.biblionumber =biblio.biblionumber
1185         WHERE   aqorders.biblionumber=?
1186     ";
1187     my $result_set =
1188       $dbh->selectall_arrayref( $query, { Slice => {} }, $biblionumber );
1189     return @{$result_set};
1190
1191 }
1192
1193 #------------------------------------------------------------#
1194
1195 =head3 GetOrder
1196
1197   $order = &GetOrder($ordernumber);
1198
1199 Looks up an order by order number.
1200
1201 Returns a reference-to-hash describing the order. The keys of
1202 C<$order> are fields from the biblio, biblioitems, aqorders tables of the Koha database.
1203
1204 =cut
1205
1206 sub GetOrder {
1207     my ($ordernumber) = @_;
1208     return unless $ordernumber;
1209
1210     my $dbh      = C4::Context->dbh;
1211     my $query = qq{SELECT
1212                 aqorders.*,
1213                 biblio.title,
1214                 biblio.author,
1215                 aqbasket.basketname,
1216                 borrowers.branchcode,
1217                 biblioitems.publicationyear,
1218                 biblio.copyrightdate,
1219                 biblioitems.editionstatement,
1220                 biblioitems.isbn,
1221                 biblioitems.ean,
1222                 biblio.seriestitle,
1223                 biblioitems.publishercode,
1224                 aqorders.rrp              AS unitpricesupplier,
1225                 aqorders.ecost            AS unitpricelib,
1226                 aqorders.claims_count     AS claims_count,
1227                 aqorders.claimed_date     AS claimed_date,
1228                 aqbudgets.budget_name     AS budget,
1229                 aqbooksellers.name        AS supplier,
1230                 aqbooksellers.id          AS supplierid,
1231                 biblioitems.publishercode AS publisher,
1232                 ADDDATE(aqbasket.closedate, INTERVAL aqbooksellers.deliverytime DAY) AS estimateddeliverydate,
1233                 DATE(aqbasket.closedate)  AS orderdate,
1234                 aqorders.quantity - COALESCE(aqorders.quantityreceived,0)                 AS quantity_to_receive,
1235                 (aqorders.quantity - COALESCE(aqorders.quantityreceived,0)) * aqorders.rrp AS subtotal,
1236                 DATEDIFF(CURDATE( ),closedate) AS latesince
1237                 FROM aqorders LEFT JOIN biblio ON biblio.biblionumber = aqorders.biblionumber
1238                 LEFT JOIN biblioitems ON biblioitems.biblionumber = biblio.biblionumber
1239                 LEFT JOIN aqbudgets ON aqorders.budget_id = aqbudgets.budget_id,
1240                 aqbasket LEFT JOIN borrowers  ON aqbasket.authorisedby = borrowers.borrowernumber
1241                 LEFT JOIN aqbooksellers       ON aqbasket.booksellerid = aqbooksellers.id
1242                 WHERE aqorders.basketno = aqbasket.basketno
1243                     AND ordernumber=?};
1244     my $result_set =
1245       $dbh->selectall_arrayref( $query, { Slice => {} }, $ordernumber );
1246
1247     # result_set assumed to contain 1 match
1248     return $result_set->[0];
1249 }
1250
1251 =head3 GetLastOrderNotReceivedFromSubscriptionid
1252
1253   $order = &GetLastOrderNotReceivedFromSubscriptionid($subscriptionid);
1254
1255 Returns a reference-to-hash describing the last order not received for a subscription.
1256
1257 =cut
1258
1259 sub GetLastOrderNotReceivedFromSubscriptionid {
1260     my ( $subscriptionid ) = @_;
1261     my $dbh                = C4::Context->dbh;
1262     my $query              = qq|
1263         SELECT * FROM aqorders
1264         LEFT JOIN subscription
1265             ON ( aqorders.subscriptionid = subscription.subscriptionid )
1266         WHERE aqorders.subscriptionid = ?
1267             AND aqorders.datereceived IS NULL
1268         LIMIT 1
1269     |;
1270     my $result_set =
1271       $dbh->selectall_arrayref( $query, { Slice => {} }, $subscriptionid );
1272
1273     # result_set assumed to contain 1 match
1274     return $result_set->[0];
1275 }
1276
1277 =head3 GetLastOrderReceivedFromSubscriptionid
1278
1279   $order = &GetLastOrderReceivedFromSubscriptionid($subscriptionid);
1280
1281 Returns a reference-to-hash describing the last order received for a subscription.
1282
1283 =cut
1284
1285 sub GetLastOrderReceivedFromSubscriptionid {
1286     my ( $subscriptionid ) = @_;
1287     my $dbh                = C4::Context->dbh;
1288     my $query              = qq|
1289         SELECT * FROM aqorders
1290         LEFT JOIN subscription
1291             ON ( aqorders.subscriptionid = subscription.subscriptionid )
1292         WHERE aqorders.subscriptionid = ?
1293             AND aqorders.datereceived =
1294                 (
1295                     SELECT MAX( aqorders.datereceived )
1296                     FROM aqorders
1297                     LEFT JOIN subscription
1298                         ON ( aqorders.subscriptionid = subscription.subscriptionid )
1299                         WHERE aqorders.subscriptionid = ?
1300                             AND aqorders.datereceived IS NOT NULL
1301                 )
1302         ORDER BY ordernumber DESC
1303         LIMIT 1
1304     |;
1305     my $result_set =
1306       $dbh->selectall_arrayref( $query, { Slice => {} }, $subscriptionid, $subscriptionid );
1307
1308     # result_set assumed to contain 1 match
1309     return $result_set->[0];
1310
1311 }
1312
1313 #------------------------------------------------------------#
1314
1315 =head3 ModOrder
1316
1317   &ModOrder(\%hashref);
1318
1319 Modifies an existing order. Updates the order with order number
1320 $hashref->{'ordernumber'} and biblionumber $hashref->{'biblionumber'}. All
1321 other keys of the hash update the fields with the same name in the aqorders
1322 table of the Koha database.
1323
1324 =cut
1325
1326 sub ModOrder {
1327     my $orderinfo = shift;
1328
1329     die "Ordernumber is required" if $orderinfo->{'ordernumber'} eq '';
1330
1331     my $dbh = C4::Context->dbh;
1332     my @params;
1333
1334     # update uncertainprice to an integer, just in case (under FF, checked boxes have the value "ON" by default)
1335     $orderinfo->{uncertainprice}=1 if $orderinfo->{uncertainprice};
1336
1337 #    delete($orderinfo->{'branchcode'});
1338     # the hash contains a lot of entries not in aqorders, so get the columns ...
1339     my $sth = $dbh->prepare("SELECT * FROM aqorders LIMIT 1;");
1340     $sth->execute;
1341     my $colnames = $sth->{NAME};
1342         #FIXME Be careful. If aqorders would have columns with diacritics,
1343         #you should need to decode what you get back from NAME.
1344         #See report 10110 and guided_reports.pl
1345     my $query = "UPDATE aqorders SET ";
1346
1347     foreach my $orderinfokey (grep(!/ordernumber/, keys %$orderinfo)){
1348         # ... and skip hash entries that are not in the aqorders table
1349         # FIXME : probably not the best way to do it (would be better to have a correct hash)
1350         next unless grep(/^$orderinfokey$/, @$colnames);
1351             $query .= "$orderinfokey=?, ";
1352             push(@params, $orderinfo->{$orderinfokey});
1353     }
1354
1355     $query .= "timestamp=NOW()  WHERE  ordernumber=?";
1356     push(@params, $orderinfo->{'ordernumber'} );
1357     $sth = $dbh->prepare($query);
1358     $sth->execute(@params);
1359     return;
1360 }
1361
1362 #------------------------------------------------------------#
1363
1364 =head3 ModItemOrder
1365
1366     ModItemOrder($itemnumber, $ordernumber);
1367
1368 Modifies the ordernumber of an item in aqorders_items.
1369
1370 =cut
1371
1372 sub ModItemOrder {
1373     my ($itemnumber, $ordernumber) = @_;
1374
1375     return unless ($itemnumber and $ordernumber);
1376
1377     my $dbh = C4::Context->dbh;
1378     my $query = qq{
1379         UPDATE aqorders_items
1380         SET ordernumber = ?
1381         WHERE itemnumber = ?
1382     };
1383     my $sth = $dbh->prepare($query);
1384     return $sth->execute($ordernumber, $itemnumber);
1385 }
1386
1387 #------------------------------------------------------------#
1388
1389 =head3 ModReceiveOrder
1390
1391     my ( $date_received, $new_ordernumber ) = ModReceiveOrder(
1392         {
1393             biblionumber         => $biblionumber,
1394             order                => $order,
1395             quantityreceived     => $quantityreceived,
1396             user                 => $user,
1397             invoice              => $invoice,
1398             budget_id            => $budget_id,
1399             received_itemnumbers => \@received_itemnumbers,
1400             order_internalnote   => $order_internalnote,
1401         }
1402     );
1403
1404 Updates an order, to reflect the fact that it was received, at least
1405 in part.
1406
1407 If a partial order is received, splits the order into two.
1408
1409 Updates the order with biblionumber C<$biblionumber> and ordernumber
1410 C<$order->{ordernumber}>.
1411
1412 =cut
1413
1414
1415 sub ModReceiveOrder {
1416     my ($params)       = @_;
1417     my $biblionumber   = $params->{biblionumber};
1418     my $order          = { %{ $params->{order} } }; # Copy the order, we don't want to modify it
1419     my $invoice        = $params->{invoice};
1420     my $quantrec       = $params->{quantityreceived};
1421     my $user           = $params->{user};
1422     my $budget_id      = $params->{budget_id};
1423     my $received_items = $params->{received_items};
1424
1425     my $dbh = C4::Context->dbh;
1426     my $datereceived = ( $invoice and $invoice->{datereceived} ) ? $invoice->{datereceived} : dt_from_string;
1427     my $suggestionid = GetSuggestionFromBiblionumber( $biblionumber );
1428     if ($suggestionid) {
1429         ModSuggestion( {suggestionid=>$suggestionid,
1430                         STATUS=>'AVAILABLE',
1431                         biblionumber=> $biblionumber}
1432                         );
1433     }
1434
1435     my $result_set = $dbh->selectrow_arrayref(
1436             q{SELECT aqbasket.is_standing
1437             FROM aqbasket
1438             WHERE basketno=?},{ Slice => {} }, $order->{basketno});
1439     my $is_standing = $result_set->[0];  # we assume we have a unique basket
1440
1441     my $new_ordernumber = $order->{ordernumber};
1442     if ( $is_standing || $order->{quantity} > $quantrec ) {
1443         # Split order line in two parts: the first is the original order line
1444         # without received items (the quantity is decreased),
1445         # the second part is a new order line with quantity=quantityrec
1446         # (entirely received)
1447         my $query = q|
1448             UPDATE aqorders
1449             SET quantity = ?,
1450                 orderstatus = 'partial'|;
1451         $query .= q| WHERE ordernumber = ?|;
1452         my $sth = $dbh->prepare($query);
1453
1454         $sth->execute(
1455             ( $is_standing ? 1 : ($order->{quantity} - $quantrec) ),
1456             $order->{ordernumber}
1457         );
1458
1459         if ( not $order->{subscriptionid} && defined $order->{order_internalnote} ) {
1460             $dbh->do(
1461                 q|UPDATE aqorders
1462                 SET order_internalnote = ?
1463                 WHERE ordernumber = ?|, {},
1464                 $order->{order_internalnote}, $order->{ordernumber}
1465             );
1466         }
1467
1468         # Recalculate tax_value
1469         $dbh->do(q|
1470             UPDATE aqorders
1471             SET
1472                 tax_value_on_ordering = quantity * | . get_rounding_sql(q|ecost_tax_excluded|) . q| * tax_rate_on_ordering,
1473                 tax_value_on_receiving = quantity * | . get_rounding_sql(q|unitprice_tax_excluded|) . q| * tax_rate_on_receiving
1474             WHERE ordernumber = ?
1475         |, undef, $order->{ordernumber});
1476
1477         delete $order->{ordernumber};
1478         $order->{budget_id} = ( $budget_id || $order->{budget_id} );
1479         $order->{quantity} = $quantrec;
1480         $order->{quantityreceived} = $quantrec;
1481         $order->{ecost_tax_excluded} //= 0;
1482         $order->{tax_rate_on_ordering} //= 0;
1483         $order->{unitprice_tax_excluded} //= 0;
1484         $order->{tax_rate_on_receiving} //= 0;
1485         $order->{tax_value_on_ordering} = $order->{quantity} * get_rounded_price($order->{ecost_tax_excluded}) * $order->{tax_rate_on_ordering};
1486         $order->{tax_value_on_receiving} = $order->{quantity} * get_rounded_price($order->{unitprice_tax_excluded}) * $order->{tax_rate_on_receiving};
1487         $order->{datereceived} = $datereceived;
1488         $order->{invoiceid} = $invoice->{invoiceid};
1489         $order->{orderstatus} = 'complete';
1490         $new_ordernumber = Koha::Acquisition::Order->new($order)->store->ordernumber; # TODO What if the store fails?
1491
1492         if ($received_items) {
1493             foreach my $itemnumber (@$received_items) {
1494                 ModItemOrder($itemnumber, $new_ordernumber);
1495             }
1496         }
1497     } else {
1498         my $query = q|
1499             UPDATE aqorders
1500             SET quantityreceived = ?,
1501                 datereceived = ?,
1502                 invoiceid = ?,
1503                 budget_id = ?,
1504                 orderstatus = 'complete'
1505         |;
1506
1507         $query .= q|
1508             , replacementprice = ?
1509         | if defined $order->{replacementprice};
1510
1511         $query .= q|
1512             , unitprice = ?, unitprice_tax_included = ?, unitprice_tax_excluded = ?
1513         | if defined $order->{unitprice};
1514
1515         $query .= q|
1516             ,tax_value_on_receiving = ?
1517         | if defined $order->{tax_value_on_receiving};
1518
1519         $query .= q|
1520             ,tax_rate_on_receiving = ?
1521         | if defined $order->{tax_rate_on_receiving};
1522
1523         $query .= q|
1524             , order_internalnote = ?
1525         | if defined $order->{order_internalnote};
1526
1527         $query .= q| where biblionumber=? and ordernumber=?|;
1528
1529         my $sth = $dbh->prepare( $query );
1530         my @params = ( $quantrec, $datereceived, $invoice->{invoiceid}, ( $budget_id ? $budget_id : $order->{budget_id} ) );
1531
1532         if ( defined $order->{replacementprice} ) {
1533             push @params, $order->{replacementprice};
1534         }
1535
1536         if ( defined $order->{unitprice} ) {
1537             push @params, $order->{unitprice}, $order->{unitprice_tax_included}, $order->{unitprice_tax_excluded};
1538         }
1539
1540         if ( defined $order->{tax_value_on_receiving} ) {
1541             push @params, $order->{tax_value_on_receiving};
1542         }
1543
1544         if ( defined $order->{tax_rate_on_receiving} ) {
1545             push @params, $order->{tax_rate_on_receiving};
1546         }
1547
1548         if ( defined $order->{order_internalnote} ) {
1549             push @params, $order->{order_internalnote};
1550         }
1551
1552         push @params, ( $biblionumber, $order->{ordernumber} );
1553
1554         $sth->execute( @params );
1555
1556         # All items have been received, sent a notification to users
1557         NotifyOrderUsers( $order->{ordernumber} );
1558
1559     }
1560     return ($datereceived, $new_ordernumber);
1561 }
1562
1563 =head3 CancelReceipt
1564
1565     my $parent_ordernumber = CancelReceipt($ordernumber);
1566
1567     Cancel an order line receipt and update the parent order line, as if no
1568     receipt was made.
1569     If items are created at receipt (AcqCreateItem = receiving) then delete
1570     these items.
1571
1572 =cut
1573
1574 sub CancelReceipt {
1575     my $ordernumber = shift;
1576
1577     return unless $ordernumber;
1578
1579     my $dbh = C4::Context->dbh;
1580     my $query = qq{
1581         SELECT datereceived, parent_ordernumber, quantity
1582         FROM aqorders
1583         WHERE ordernumber = ?
1584     };
1585     my $sth = $dbh->prepare($query);
1586     $sth->execute($ordernumber);
1587     my $order = $sth->fetchrow_hashref;
1588     unless($order) {
1589         warn "CancelReceipt: order $ordernumber does not exist";
1590         return;
1591     }
1592     unless($order->{'datereceived'}) {
1593         warn "CancelReceipt: order $ordernumber is not received";
1594         return;
1595     }
1596
1597     my $parent_ordernumber = $order->{'parent_ordernumber'};
1598
1599     my $order_obj = Koha::Acquisition::Orders->find( $ordernumber ); # FIXME rewrite all this subroutine using this object
1600     my @itemnumbers = $order_obj->items->get_column('itemnumber');
1601
1602     if($parent_ordernumber == $ordernumber || not $parent_ordernumber) {
1603         # The order line has no parent, just mark it as not received
1604         $query = qq{
1605             UPDATE aqorders
1606             SET quantityreceived = ?,
1607                 datereceived = ?,
1608                 invoiceid = ?,
1609                 orderstatus = 'ordered'
1610             WHERE ordernumber = ?
1611         };
1612         $sth = $dbh->prepare($query);
1613         $sth->execute(0, undef, undef, $ordernumber);
1614         _cancel_items_receipt( $order_obj );
1615     } else {
1616         # The order line has a parent, increase parent quantity and delete
1617         # the order line.
1618         $query = qq{
1619             SELECT quantity, datereceived
1620             FROM aqorders
1621             WHERE ordernumber = ?
1622         };
1623         $sth = $dbh->prepare($query);
1624         $sth->execute($parent_ordernumber);
1625         my $parent_order = $sth->fetchrow_hashref;
1626         unless($parent_order) {
1627             warn "Parent order $parent_ordernumber does not exist.";
1628             return;
1629         }
1630         if($parent_order->{'datereceived'}) {
1631             warn "CancelReceipt: parent order is received.".
1632                 " Can't cancel receipt.";
1633             return;
1634         }
1635         $query = qq{
1636             UPDATE aqorders
1637             SET quantity = ?,
1638                 orderstatus = 'ordered'
1639             WHERE ordernumber = ?
1640         };
1641         $sth = $dbh->prepare($query);
1642         my $rv = $sth->execute(
1643             $order->{'quantity'} + $parent_order->{'quantity'},
1644             $parent_ordernumber
1645         );
1646         unless($rv) {
1647             warn "Cannot update parent order line, so do not cancel".
1648                 " receipt";
1649             return;
1650         }
1651
1652         # Recalculate tax_value
1653         $dbh->do(q|
1654             UPDATE aqorders
1655             SET
1656                 tax_value_on_ordering = quantity * | . get_rounding_sql(q|ecost_tax_excluded|) . q| * tax_rate_on_ordering,
1657                 tax_value_on_receiving = quantity * | . get_rounding_sql(q|unitprice_tax_excluded|) . q| * tax_rate_on_receiving
1658             WHERE ordernumber = ?
1659         |, undef, $parent_ordernumber);
1660
1661         _cancel_items_receipt( $order_obj, $parent_ordernumber );
1662         # Delete order line
1663         $query = qq{
1664             DELETE FROM aqorders
1665             WHERE ordernumber = ?
1666         };
1667         $sth = $dbh->prepare($query);
1668         $sth->execute($ordernumber);
1669
1670     }
1671
1672     if( $order_obj->basket->effective_create_items eq 'ordering' ) {
1673         my @affects = split q{\|}, C4::Context->preference("AcqItemSetSubfieldsWhenReceiptIsCancelled");
1674         if ( @affects ) {
1675             for my $in ( @itemnumbers ) {
1676                 my $item = Koha::Items->find( $in ); # FIXME We do not need that, we already have Koha::Items from $order_obj->items
1677                 my $biblio = $item->biblio;
1678                 my ( $itemfield ) = GetMarcFromKohaField( 'items.itemnumber' );
1679                 my $item_marc = C4::Items::GetMarcItem( $biblio->biblionumber, $in );
1680                 for my $affect ( @affects ) {
1681                     my ( $sf, $v ) = split q{=}, $affect, 2;
1682                     foreach ( $item_marc->field($itemfield) ) {
1683                         $_->update( $sf => $v );
1684                     }
1685                 }
1686                 C4::Items::ModItemFromMarc( $item_marc, $biblio->biblionumber, $in );
1687             }
1688         }
1689     }
1690
1691     return $parent_ordernumber;
1692 }
1693
1694 sub _cancel_items_receipt {
1695     my ( $order, $parent_ordernumber ) = @_;
1696     $parent_ordernumber ||= $order->ordernumber;
1697
1698     my $items = $order->items;
1699     if ( $order->basket->effective_create_items eq 'receiving' ) {
1700         # Remove items that were created at receipt
1701         my $query = qq{
1702             DELETE FROM items, aqorders_items
1703             USING items, aqorders_items
1704             WHERE items.itemnumber = ? AND aqorders_items.itemnumber = ?
1705         };
1706         my $dbh = C4::Context->dbh;
1707         my $sth = $dbh->prepare($query);
1708         while ( my $item = $items->next ) {
1709             $sth->execute($item->itemnumber, $item->itemnumber);
1710         }
1711     } else {
1712         # Update items
1713         while ( my $item = $items->next ) {
1714             ModItemOrder($item->itemnumber, $parent_ordernumber);
1715         }
1716     }
1717 }
1718
1719 #------------------------------------------------------------#
1720
1721 =head3 SearchOrders
1722
1723 @results = &SearchOrders({
1724     ordernumber => $ordernumber,
1725     search => $search,
1726     ean => $ean,
1727     booksellerid => $booksellerid,
1728     basketno => $basketno,
1729     basketname => $basketname,
1730     basketgroupname => $basketgroupname,
1731     owner => $owner,
1732     pending => $pending
1733     ordered => $ordered
1734     biblionumber => $biblionumber,
1735     budget_id => $budget_id
1736 });
1737
1738 Searches for orders filtered by criteria.
1739
1740 C<$ordernumber> Finds matching orders or transferred orders by ordernumber.
1741 C<$search> Finds orders matching %$search% in title, author, or isbn.
1742 C<$owner> Finds order for the logged in user.
1743 C<$pending> Finds pending orders. Ignores completed and cancelled orders.
1744 C<$ordered> Finds orders to receive only (status 'ordered' or 'partial').
1745
1746
1747 C<@results> is an array of references-to-hash with the keys are fields
1748 from aqorders, biblio, biblioitems and aqbasket tables.
1749
1750 =cut
1751
1752 sub SearchOrders {
1753     my ( $params ) = @_;
1754     my $ordernumber = $params->{ordernumber};
1755     my $search = $params->{search};
1756     my $ean = $params->{ean};
1757     my $booksellerid = $params->{booksellerid};
1758     my $basketno = $params->{basketno};
1759     my $basketname = $params->{basketname};
1760     my $basketgroupname = $params->{basketgroupname};
1761     my $owner = $params->{owner};
1762     my $pending = $params->{pending};
1763     my $ordered = $params->{ordered};
1764     my $biblionumber = $params->{biblionumber};
1765     my $budget_id = $params->{budget_id};
1766
1767     my $dbh = C4::Context->dbh;
1768     my @args = ();
1769     my $query = q{
1770         SELECT aqbasket.basketno,
1771                borrowers.surname,
1772                borrowers.firstname,
1773                biblio.*,
1774                biblioitems.isbn,
1775                biblioitems.biblioitemnumber,
1776                biblioitems.publishercode,
1777                biblioitems.publicationyear,
1778                aqbasket.authorisedby,
1779                aqbasket.booksellerid,
1780                aqbasket.closedate,
1781                aqbasket.creationdate,
1782                aqbasket.basketname,
1783                aqbasketgroups.id as basketgroupid,
1784                aqbasketgroups.name as basketgroupname,
1785                aqorders.*
1786         FROM aqorders
1787             LEFT JOIN aqbasket ON aqorders.basketno = aqbasket.basketno
1788             LEFT JOIN aqbasketgroups ON aqbasket.basketgroupid = aqbasketgroups.id
1789             LEFT JOIN borrowers ON aqbasket.authorisedby=borrowers.borrowernumber
1790             LEFT JOIN biblio ON aqorders.biblionumber=biblio.biblionumber
1791             LEFT JOIN biblioitems ON biblioitems.biblionumber=biblio.biblionumber
1792     };
1793
1794     # If we search on ordernumber, we retrieve the transferred order if a transfer has been done.
1795     $query .= q{
1796             LEFT JOIN aqorders_transfers ON aqorders_transfers.ordernumber_to = aqorders.ordernumber
1797     } if $ordernumber;
1798
1799     $query .= q{
1800         WHERE (datecancellationprinted is NULL)
1801     };
1802
1803     if ( $pending or $ordered ) {
1804         $query .= q{
1805             AND (
1806                 ( aqbasket.is_standing AND aqorders.orderstatus IN ( "new", "ordered", "partial" ) )
1807                 OR (
1808                     ( quantity > quantityreceived OR quantityreceived is NULL )
1809         };
1810
1811         if ( $ordered ) {
1812             $query .= q{ AND aqorders.orderstatus IN ( "ordered", "partial" )};
1813         }
1814         $query .= q{
1815                 )
1816             )
1817         };
1818     }
1819
1820     my $userenv = C4::Context->userenv;
1821     if ( C4::Context->preference("IndependentBranches") ) {
1822         unless ( C4::Context->IsSuperLibrarian() ) {
1823             $query .= q{
1824                 AND (
1825                     borrowers.branchcode = ?
1826                     OR borrowers.branchcode  = ''
1827                 )
1828             };
1829             push @args, $userenv->{branch};
1830         }
1831     }
1832
1833     if ( $ordernumber ) {
1834         $query .= ' AND ( aqorders.ordernumber = ? OR aqorders_transfers.ordernumber_from = ? ) ';
1835         push @args, ( $ordernumber, $ordernumber );
1836     }
1837     if ( $biblionumber ) {
1838         $query .= 'AND aqorders.biblionumber = ?';
1839         push @args, $biblionumber;
1840     }
1841     if( $search ) {
1842         $query .= ' AND (biblio.title LIKE ? OR biblio.author LIKE ? OR biblioitems.isbn LIKE ?)';
1843         push @args, ("%$search%","%$search%","%$search%");
1844     }
1845     if ( $ean ) {
1846         $query .= ' AND biblioitems.ean = ?';
1847         push @args, $ean;
1848     }
1849     if ( $booksellerid ) {
1850         $query .= 'AND aqbasket.booksellerid = ?';
1851         push @args, $booksellerid;
1852     }
1853     if( $basketno ) {
1854         $query .= 'AND aqbasket.basketno = ?';
1855         push @args, $basketno;
1856     }
1857     if( $basketname ) {
1858         $query .= 'AND aqbasket.basketname LIKE ?';
1859         push @args, "%$basketname%";
1860     }
1861     if( $basketgroupname ) {
1862         $query .= ' AND aqbasketgroups.name LIKE ?';
1863         push @args, "%$basketgroupname%";
1864     }
1865
1866     if ( $owner ) {
1867         $query .= ' AND aqbasket.authorisedby=? ';
1868         push @args, $userenv->{'number'};
1869     }
1870
1871     if ( $budget_id ) {
1872         $query .= ' AND aqorders.budget_id = ?';
1873         push @args, $budget_id;
1874     }
1875
1876     $query .= ' ORDER BY aqbasket.basketno';
1877
1878     my $sth = $dbh->prepare($query);
1879     $sth->execute(@args);
1880     return $sth->fetchall_arrayref({});
1881 }
1882
1883 #------------------------------------------------------------#
1884
1885 =head3 DelOrder
1886
1887   &DelOrder($biblionumber, $ordernumber);
1888
1889 Cancel the order with the given order and biblio numbers. It does not
1890 delete any entries in the aqorders table, it merely marks them as
1891 cancelled.
1892
1893 =cut
1894
1895 sub DelOrder {
1896     my ( $bibnum, $ordernumber, $delete_biblio, $reason ) = @_;
1897     my $error;
1898     my $dbh = C4::Context->dbh;
1899     my $query = "
1900         UPDATE aqorders
1901         SET    datecancellationprinted=now(), orderstatus='cancelled'
1902     ";
1903     if($reason) {
1904         $query .= ", cancellationreason = ? ";
1905     }
1906     $query .= "
1907         WHERE biblionumber=? AND ordernumber=?
1908     ";
1909     my $sth = $dbh->prepare($query);
1910     if($reason) {
1911         $sth->execute($reason, $bibnum, $ordernumber);
1912     } else {
1913         $sth->execute( $bibnum, $ordernumber );
1914     }
1915     $sth->finish;
1916
1917     my $order = Koha::Acquisition::Orders->find($ordernumber);
1918     my $items = $order->items;
1919     while ( my $item = $items->next ) { # Should be moved to Koha::Acquisition::Order->delete
1920         my $delcheck = C4::Items::DelItemCheck( $bibnum, $item->itemnumber );
1921
1922         if($delcheck != 1) {
1923             $error->{'delitem'} = 1;
1924         }
1925     }
1926
1927     if($delete_biblio) {
1928         # We get the number of remaining items
1929         my $biblio = Koha::Biblios->find( $bibnum );
1930         my $itemcount = $biblio->items->count;
1931
1932         # If there are no items left,
1933         if ( $itemcount == 0 ) {
1934             # We delete the record
1935             my $delcheck = DelBiblio($bibnum);
1936
1937             if($delcheck) {
1938                 $error->{'delbiblio'} = 1;
1939             }
1940         }
1941     }
1942
1943     return $error;
1944 }
1945
1946 =head3 TransferOrder
1947
1948     my $newordernumber = TransferOrder($ordernumber, $basketno);
1949
1950 Transfer an order line to a basket.
1951 Mark $ordernumber as cancelled with an internal note 'Cancelled and transferred
1952 to BOOKSELLER on DATE' and create new order with internal note
1953 'Transferred from BOOKSELLER on DATE'.
1954 Move all attached items to the new order.
1955 Received orders cannot be transferred.
1956 Return the ordernumber of created order.
1957
1958 =cut
1959
1960 sub TransferOrder {
1961     my ($ordernumber, $basketno) = @_;
1962
1963     return unless ($ordernumber and $basketno);
1964
1965     my $order = Koha::Acquisition::Orders->find( $ordernumber ) or return;
1966     return if $order->datereceived;
1967
1968     $order = $order->unblessed;
1969
1970     my $basket = GetBasket($basketno);
1971     return unless $basket;
1972
1973     my $dbh = C4::Context->dbh;
1974     my ($query, $sth, $rv);
1975
1976     $query = q{
1977         UPDATE aqorders
1978         SET datecancellationprinted = CAST(NOW() AS date), orderstatus = ?
1979         WHERE ordernumber = ?
1980     };
1981     $sth = $dbh->prepare($query);
1982     $rv = $sth->execute('cancelled', $ordernumber);
1983
1984     delete $order->{'ordernumber'};
1985     delete $order->{parent_ordernumber};
1986     $order->{'basketno'} = $basketno;
1987
1988     my $newordernumber = Koha::Acquisition::Order->new($order)->store->ordernumber;
1989
1990     $query = q{
1991         UPDATE aqorders_items
1992         SET ordernumber = ?
1993         WHERE ordernumber = ?
1994     };
1995     $sth = $dbh->prepare($query);
1996     $sth->execute($newordernumber, $ordernumber);
1997
1998     $query = q{
1999         INSERT INTO aqorders_transfers (ordernumber_from, ordernumber_to)
2000         VALUES (?, ?)
2001     };
2002     $sth = $dbh->prepare($query);
2003     $sth->execute($ordernumber, $newordernumber);
2004
2005     return $newordernumber;
2006 }
2007
2008 =head3 get_rounding_sql
2009
2010     $rounding_sql = get_rounding_sql($column_name);
2011
2012 returns the correct SQL routine based on OrderPriceRounding system preference.
2013
2014 =cut
2015
2016 sub get_rounding_sql {
2017     my ( $round_string ) = @_;
2018     my $rounding_pref = C4::Context->preference('OrderPriceRounding') // q{};
2019     if ( $rounding_pref eq "nearest_cent"  ) {
2020         return "CAST($round_string*100 AS SIGNED)/100";
2021     }
2022     return $round_string;
2023 }
2024
2025 =head3 get_rounded_price
2026
2027     $rounded_price = get_rounded_price( $price );
2028
2029 returns a price rounded as specified in OrderPriceRounding system preference.
2030
2031 =cut
2032
2033 sub get_rounded_price {
2034     my ( $price ) =  @_;
2035     my $rounding_pref = C4::Context->preference('OrderPriceRounding') // q{};
2036     if( $rounding_pref eq 'nearest_cent' ) {
2037         return Koha::Number::Price->new( $price )->round();
2038     }
2039     return $price;
2040 }
2041
2042
2043 =head2 FUNCTIONS ABOUT PARCELS
2044
2045 =head3 GetParcels
2046
2047   $results = &GetParcels($bookseller, $order, $code, $datefrom, $dateto);
2048
2049 get a lists of parcels.
2050
2051 * Input arg :
2052
2053 =over
2054
2055 =item $bookseller
2056 is the bookseller this function has to get parcels.
2057
2058 =item $order
2059 To know on what criteria the results list has to be ordered.
2060
2061 =item $code
2062 is the booksellerinvoicenumber.
2063
2064 =item $datefrom & $dateto
2065 to know on what date this function has to filter its search.
2066
2067 =back
2068
2069 * return:
2070 a pointer on a hash list containing parcel informations as such :
2071
2072 =over
2073
2074 =item Creation date
2075
2076 =item Last operation
2077
2078 =item Number of biblio
2079
2080 =item Number of items
2081
2082 =back
2083
2084 =cut
2085
2086 sub GetParcels {
2087     my ($bookseller,$order, $code, $datefrom, $dateto) = @_;
2088     my $dbh    = C4::Context->dbh;
2089     my @query_params = ();
2090     my $strsth ="
2091         SELECT  aqinvoices.invoicenumber,
2092                 datereceived,purchaseordernumber,
2093                 count(DISTINCT biblionumber) AS biblio,
2094                 sum(quantity) AS itemsexpected,
2095                 sum(quantityreceived) AS itemsreceived
2096         FROM   aqorders LEFT JOIN aqbasket ON aqbasket.basketno = aqorders.basketno
2097         LEFT JOIN aqinvoices ON aqorders.invoiceid = aqinvoices.invoiceid
2098         WHERE aqbasket.booksellerid = ? and datereceived IS NOT NULL
2099     ";
2100     push @query_params, $bookseller;
2101
2102     if ( defined $code ) {
2103         $strsth .= ' and aqinvoices.invoicenumber like ? ';
2104         # add a % to the end of the code to allow stemming.
2105         push @query_params, "$code%";
2106     }
2107
2108     if ( defined $datefrom ) {
2109         $strsth .= ' and datereceived >= ? ';
2110         push @query_params, $datefrom;
2111     }
2112
2113     if ( defined $dateto ) {
2114         $strsth .=  'and datereceived <= ? ';
2115         push @query_params, $dateto;
2116     }
2117
2118     $strsth .= "group by aqinvoices.invoicenumber,datereceived ";
2119
2120     # can't use a placeholder to place this column name.
2121     # but, we could probably be checking to make sure it is a column that will be fetched.
2122     $strsth .= "order by $order " if ($order);
2123
2124     my $sth = $dbh->prepare($strsth);
2125
2126     $sth->execute( @query_params );
2127     my $results = $sth->fetchall_arrayref({});
2128     return @{$results};
2129 }
2130
2131 #------------------------------------------------------------#
2132
2133 =head3 GetLateOrders
2134
2135   @results = &GetLateOrders;
2136
2137 Searches for bookseller with late orders.
2138
2139 return:
2140 the table of supplier with late issues. This table is full of hashref.
2141
2142 =cut
2143
2144 sub GetLateOrders {
2145     my $delay      = shift;
2146     my $supplierid = shift;
2147     my $branch     = shift;
2148     my $estimateddeliverydatefrom = shift;
2149     my $estimateddeliverydateto = shift;
2150
2151     my $dbh = C4::Context->dbh;
2152
2153     #BEWARE, order of parenthesis and LEFT JOIN is important for speed
2154     my $dbdriver = C4::Context->config("db_scheme") || "mysql";
2155
2156     my @query_params = ();
2157     my $select = "
2158     SELECT aqbasket.basketno,
2159         aqorders.ordernumber,
2160         DATE(aqbasket.closedate)  AS orderdate,
2161         aqbasket.basketname       AS basketname,
2162         aqbasket.basketgroupid    AS basketgroupid,
2163         aqbasketgroups.name       AS basketgroupname,
2164         aqorders.rrp              AS unitpricesupplier,
2165         aqorders.ecost            AS unitpricelib,
2166         aqorders.claims_count     AS claims_count,
2167         aqorders.claimed_date     AS claimed_date,
2168         aqbudgets.budget_name     AS budget,
2169         borrowers.branchcode      AS branch,
2170         aqbooksellers.name        AS supplier,
2171         aqbooksellers.id          AS supplierid,
2172         biblio.author, biblio.title,
2173         biblioitems.publishercode AS publisher,
2174         biblioitems.publicationyear,
2175         ADDDATE(aqbasket.closedate, INTERVAL aqbooksellers.deliverytime DAY) AS estimateddeliverydate,
2176     ";
2177     my $from = "
2178     FROM
2179         aqorders LEFT JOIN biblio     ON biblio.biblionumber         = aqorders.biblionumber
2180         LEFT JOIN biblioitems         ON biblioitems.biblionumber    = biblio.biblionumber
2181         LEFT JOIN aqbudgets           ON aqorders.budget_id          = aqbudgets.budget_id,
2182         aqbasket LEFT JOIN borrowers  ON aqbasket.authorisedby       = borrowers.borrowernumber
2183         LEFT JOIN aqbooksellers       ON aqbasket.booksellerid       = aqbooksellers.id
2184         LEFT JOIN aqbasketgroups      ON aqbasket.basketgroupid      = aqbasketgroups.id
2185         WHERE aqorders.basketno = aqbasket.basketno
2186         AND ( datereceived = ''
2187             OR datereceived IS NULL
2188             OR aqorders.quantityreceived < aqorders.quantity
2189         )
2190         AND aqbasket.closedate IS NOT NULL
2191         AND (aqorders.datecancellationprinted IS NULL OR aqorders.datecancellationprinted='0000-00-00')
2192     ";
2193     if ($dbdriver eq "mysql") {
2194         $select .= "
2195         aqorders.quantity - COALESCE(aqorders.quantityreceived,0)                 AS quantity,
2196         (aqorders.quantity - COALESCE(aqorders.quantityreceived,0)) * aqorders.rrp AS subtotal,
2197         DATEDIFF(CAST(now() AS date),closedate) AS latesince
2198         ";
2199         if ( defined $delay ) {
2200             $from .= " AND (closedate <= DATE_SUB(CAST(now() AS date),INTERVAL ? DAY)) " ;
2201             push @query_params, $delay;
2202         }
2203         $from .= " AND aqorders.quantity - COALESCE(aqorders.quantityreceived,0) <> 0";
2204     } else {
2205         # FIXME: account for IFNULL as above
2206         $select .= "
2207                 aqorders.quantity                AS quantity,
2208                 aqorders.quantity * aqorders.rrp AS subtotal,
2209                 (CAST(now() AS date) - closedate)            AS latesince
2210         ";
2211         if ( defined $delay ) {
2212             $from .= " AND (closedate <= (CAST(now() AS date) -(INTERVAL ? DAY)) ";
2213             push @query_params, $delay;
2214         }
2215         $from .= " AND aqorders.quantity <> 0";
2216     }
2217     if (defined $supplierid) {
2218         $from .= ' AND aqbasket.booksellerid = ? ';
2219         push @query_params, $supplierid;
2220     }
2221     if (defined $branch) {
2222         $from .= ' AND borrowers.branchcode LIKE ? ';
2223         push @query_params, $branch;
2224     }
2225
2226     if ( defined $estimateddeliverydatefrom or defined $estimateddeliverydateto ) {
2227         $from .= ' AND aqbooksellers.deliverytime IS NOT NULL ';
2228     }
2229     if ( defined $estimateddeliverydatefrom ) {
2230         $from .= ' AND ADDDATE(aqbasket.closedate, INTERVAL aqbooksellers.deliverytime DAY) >= ?';
2231         push @query_params, $estimateddeliverydatefrom;
2232     }
2233     if ( defined $estimateddeliverydateto ) {
2234         $from .= ' AND ADDDATE(aqbasket.closedate, INTERVAL aqbooksellers.deliverytime DAY) <= ?';
2235         push @query_params, $estimateddeliverydateto;
2236     }
2237     if ( defined $estimateddeliverydatefrom and not defined $estimateddeliverydateto ) {
2238         $from .= ' AND ADDDATE(aqbasket.closedate, INTERVAL aqbooksellers.deliverytime DAY) <= CAST(now() AS date)';
2239     }
2240     if (C4::Context->preference("IndependentBranches")
2241             && !C4::Context->IsSuperLibrarian() ) {
2242         $from .= ' AND borrowers.branchcode LIKE ? ';
2243         push @query_params, C4::Context->userenv->{branch};
2244     }
2245     $from .= " AND orderstatus <> 'cancelled' ";
2246     my $query = "$select $from \nORDER BY latesince, basketno, borrowers.branchcode, supplier";
2247     $debug and print STDERR "GetLateOrders query: $query\nGetLateOrders args: " . join(" ",@query_params);
2248     my $sth = $dbh->prepare($query);
2249     $sth->execute(@query_params);
2250     my @results;
2251     while (my $data = $sth->fetchrow_hashref) {
2252         push @results, $data;
2253     }
2254     return @results;
2255 }
2256
2257 #------------------------------------------------------------#
2258
2259 =head3 GetHistory
2260
2261   \@order_loop = GetHistory( %params );
2262
2263 Retreives some acquisition history information
2264
2265 params:
2266   title
2267   author
2268   name
2269   isbn
2270   ean
2271   from_placed_on
2272   to_placed_on
2273   basket                  - search both basket name and number
2274   booksellerinvoicenumber
2275   basketgroupname
2276   budget
2277   orderstatus (note that orderstatus '' will retrieve orders
2278                of any status except cancelled)
2279   managing_library
2280   biblionumber
2281   get_canceled_order (if set to a true value, cancelled orders will
2282                       be included)
2283
2284 returns:
2285     $order_loop is a list of hashrefs that each look like this:
2286             {
2287                 'author'           => 'Twain, Mark',
2288                 'basketno'         => '1',
2289                 'biblionumber'     => '215',
2290                 'count'            => 1,
2291                 'creationdate'     => 'MM/DD/YYYY',
2292                 'datereceived'     => undef,
2293                 'ecost'            => '1.00',
2294                 'id'               => '1',
2295                 'invoicenumber'    => undef,
2296                 'name'             => '',
2297                 'ordernumber'      => '1',
2298                 'quantity'         => 1,
2299                 'quantityreceived' => undef,
2300                 'title'            => 'The Adventures of Huckleberry Finn',
2301                 'managing_library' => 'CPL'
2302             }
2303
2304 =cut
2305
2306 sub GetHistory {
2307 # don't run the query if there are no parameters (list would be too long for sure !)
2308     croak "No search params" unless @_;
2309     my %params = @_;
2310     my $title = $params{title};
2311     my $author = $params{author};
2312     my $isbn   = $params{isbn};
2313     my $ean    = $params{ean};
2314     my $name = $params{name};
2315     my $from_placed_on = $params{from_placed_on};
2316     my $to_placed_on = $params{to_placed_on};
2317     my $basket = $params{basket};
2318     my $booksellerinvoicenumber = $params{booksellerinvoicenumber};
2319     my $basketgroupname = $params{basketgroupname};
2320     my $budget = $params{budget};
2321     my $orderstatus = $params{orderstatus};
2322     my $biblionumber = $params{biblionumber};
2323     my $get_canceled_order = $params{get_canceled_order} || 0;
2324     my $ordernumber = $params{ordernumber};
2325     my $search_children_too = $params{search_children_too} || 0;
2326     my $created_by = $params{created_by} || [];
2327     my $managing_library = $params{managing_library};
2328     my $ordernumbers = $params{ordernumbers} || [];
2329     my $additional_fields = $params{additional_fields} // [];
2330
2331     my @order_loop;
2332     my $total_qty         = 0;
2333     my $total_qtyreceived = 0;
2334     my $total_price       = 0;
2335
2336     #get variation of isbn
2337     my @isbn_params;
2338     my @isbns;
2339     if ($isbn){
2340         if ( C4::Context->preference("SearchWithISBNVariations") ){
2341             @isbns = C4::Koha::GetVariationsOfISBN( $isbn );
2342             foreach my $isb (@isbns){
2343                 push @isbn_params, '?';
2344             }
2345         }
2346         unless (@isbns){
2347             push @isbns, $isbn;
2348             push @isbn_params, '?';
2349         }
2350     }
2351
2352     my $dbh   = C4::Context->dbh;
2353     my $query ="
2354         SELECT
2355             COALESCE(biblio.title,     deletedbiblio.title)     AS title,
2356             COALESCE(biblio.author,    deletedbiblio.author)    AS author,
2357             COALESCE(biblioitems.isbn, deletedbiblioitems.isbn) AS isbn,
2358             COALESCE(biblioitems.ean,  deletedbiblioitems.ean)  AS ean,
2359             aqorders.basketno,
2360             aqbasket.basketname,
2361             aqbasket.basketgroupid,
2362             aqbasket.authorisedby,
2363             concat( borrowers.firstname,' ',borrowers.surname) AS authorisedbyname,
2364             branch as managing_library,
2365             aqbasketgroups.name as groupname,
2366             aqbooksellers.name,
2367             aqbasket.creationdate,
2368             aqorders.datereceived,
2369             aqorders.quantity,
2370             aqorders.quantityreceived,
2371             aqorders.ecost,
2372             aqorders.ordernumber,
2373             aqorders.invoiceid,
2374             aqinvoices.invoicenumber,
2375             aqbooksellers.id as id,
2376             aqorders.biblionumber,
2377             aqorders.orderstatus,
2378             aqorders.parent_ordernumber,
2379             aqbudgets.budget_name
2380             ";
2381     $query .= ", aqbudgets.budget_id AS budget" if defined $budget;
2382     $query .= "
2383         FROM aqorders
2384         LEFT JOIN aqbasket ON aqorders.basketno=aqbasket.basketno
2385         LEFT JOIN aqbasketgroups ON aqbasket.basketgroupid=aqbasketgroups.id
2386         LEFT JOIN aqbooksellers ON aqbasket.booksellerid=aqbooksellers.id
2387         LEFT JOIN biblioitems ON biblioitems.biblionumber=aqorders.biblionumber
2388         LEFT JOIN biblio ON biblio.biblionumber=aqorders.biblionumber
2389         LEFT JOIN aqbudgets ON aqorders.budget_id=aqbudgets.budget_id
2390         LEFT JOIN aqinvoices ON aqorders.invoiceid = aqinvoices.invoiceid
2391         LEFT JOIN deletedbiblio ON deletedbiblio.biblionumber=aqorders.biblionumber
2392         LEFT JOIN deletedbiblioitems ON deletedbiblioitems.biblionumber=aqorders.biblionumber
2393         LEFT JOIN borrowers ON aqbasket.authorisedby=borrowers.borrowernumber
2394         ";
2395
2396     $query .= " WHERE 1 ";
2397
2398     unless ($get_canceled_order or (defined $orderstatus and $orderstatus eq 'cancelled')) {
2399         $query .= " AND (datecancellationprinted is NULL or datecancellationprinted='0000-00-00') ";
2400     }
2401
2402     my @query_params  = ();
2403
2404     if ( $biblionumber ) {
2405         $query .= " AND biblio.biblionumber = ?";
2406         push @query_params, $biblionumber;
2407     }
2408
2409     if ( $title ) {
2410         $query .= " AND biblio.title LIKE ? ";
2411         $title =~ s/\s+/%/g;
2412         push @query_params, "%$title%";
2413     }
2414
2415     if ( $author ) {
2416         $query .= " AND biblio.author LIKE ? ";
2417         push @query_params, "%$author%";
2418     }
2419
2420     if ( @isbns ) {
2421         $query .= " AND ( biblioitems.isbn LIKE " . join (" OR biblioitems.isbn LIKE ", @isbn_params ) . ")";
2422         foreach my $isb (@isbns){
2423             push @query_params, "%$isb%";
2424         }
2425     }
2426
2427     if ( $ean ) {
2428         $query .= " AND biblioitems.ean = ? ";
2429         push @query_params, "$ean";
2430     }
2431     if ( $name ) {
2432         $query .= " AND aqbooksellers.name LIKE ? ";
2433         push @query_params, "%$name%";
2434     }
2435
2436     if ( $budget ) {
2437         $query .= " AND aqbudgets.budget_id = ? ";
2438         push @query_params, "$budget";
2439     }
2440
2441     if ( $from_placed_on ) {
2442         $query .= " AND creationdate >= ? ";
2443         push @query_params, $from_placed_on;
2444     }
2445
2446     if ( $to_placed_on ) {
2447         $query .= " AND creationdate <= ? ";
2448         push @query_params, $to_placed_on;
2449     }
2450
2451     if ( defined $orderstatus and $orderstatus ne '') {
2452         $query .= " AND aqorders.orderstatus = ? ";
2453         push @query_params, "$orderstatus";
2454     }
2455
2456     if ($basket) {
2457         if ($basket =~ m/^\d+$/) {
2458             $query .= " AND aqorders.basketno = ? ";
2459             push @query_params, $basket;
2460         } else {
2461             $query .= " AND aqbasket.basketname LIKE ? ";
2462             push @query_params, "%$basket%";
2463         }
2464     }
2465
2466     if ($booksellerinvoicenumber) {
2467         $query .= " AND aqinvoices.invoicenumber LIKE ? ";
2468         push @query_params, "%$booksellerinvoicenumber%";
2469     }
2470
2471     if ($basketgroupname) {
2472         $query .= " AND aqbasketgroups.name LIKE ? ";
2473         push @query_params, "%$basketgroupname%";
2474     }
2475
2476     if ($ordernumber) {
2477         $query .= " AND (aqorders.ordernumber = ? ";
2478         push @query_params, $ordernumber;
2479         if ($search_children_too) {
2480             $query .= " OR aqorders.parent_ordernumber = ? ";
2481             push @query_params, $ordernumber;
2482         }
2483         $query .= ") ";
2484     }
2485
2486     if ( @$created_by ) {
2487         $query .= ' AND aqbasket.authorisedby IN ( ' . join( ',', ('?') x @$created_by ) . ')';
2488         push @query_params, @$created_by;
2489     }
2490
2491     if ( $managing_library ) {
2492         $query .= " AND aqbasket.branch = ? ";
2493         push @query_params, $managing_library;
2494     }
2495
2496     if ( @$ordernumbers ) {
2497         $query .= ' AND (aqorders.ordernumber IN ( ' . join (',', ('?') x @$ordernumbers ) . '))';
2498         push @query_params, @$ordernumbers;
2499     }
2500     if ( @$additional_fields ) {
2501         my @baskets = Koha::Acquisition::Baskets->filter_by_additional_fields($additional_fields);
2502
2503         return [] unless @baskets;
2504
2505         # No parameterization because record IDs come directly from DB
2506         $query .= ' AND aqbasket.basketno IN ( ' . join( ',', map { $_->basketno } @baskets ) . ' )';
2507     }
2508
2509     if ( C4::Context->preference("IndependentBranches") ) {
2510         unless ( C4::Context->IsSuperLibrarian() ) {
2511             $query .= " AND (borrowers.branchcode = ? OR borrowers.branchcode ='' ) ";
2512             push @query_params, C4::Context->userenv->{branch};
2513         }
2514     }
2515     $query .= " ORDER BY id";
2516
2517     return $dbh->selectall_arrayref( $query, { Slice => {} }, @query_params );
2518 }
2519
2520 =head2 GetRecentAcqui
2521
2522   $results = GetRecentAcqui($days);
2523
2524 C<$results> is a ref to a table which contains hashref
2525
2526 =cut
2527
2528 sub GetRecentAcqui {
2529     my $limit  = shift;
2530     my $dbh    = C4::Context->dbh;
2531     my $query = "
2532         SELECT *
2533         FROM   biblio
2534         ORDER BY timestamp DESC
2535         LIMIT  0,".$limit;
2536
2537     my $sth = $dbh->prepare($query);
2538     $sth->execute;
2539     my $results = $sth->fetchall_arrayref({});
2540     return $results;
2541 }
2542
2543 #------------------------------------------------------------#
2544
2545 =head3 AddClaim
2546
2547   &AddClaim($ordernumber);
2548
2549 Add a claim for an order
2550
2551 =cut
2552
2553 sub AddClaim {
2554     my ($ordernumber) = @_;
2555     my $dbh          = C4::Context->dbh;
2556     my $query        = "
2557         UPDATE aqorders SET
2558             claims_count = claims_count + 1,
2559             claimed_date = CURDATE()
2560         WHERE ordernumber = ?
2561         ";
2562     my $sth = $dbh->prepare($query);
2563     $sth->execute($ordernumber);
2564 }
2565
2566 =head3 GetInvoices
2567
2568     my @invoices = GetInvoices(
2569         invoicenumber => $invoicenumber,
2570         supplierid => $supplierid,
2571         suppliername => $suppliername,
2572         shipmentdatefrom => $shipmentdatefrom, # ISO format
2573         shipmentdateto => $shipmentdateto, # ISO format
2574         billingdatefrom => $billingdatefrom, # ISO format
2575         billingdateto => $billingdateto, # ISO format
2576         isbneanissn => $isbn_or_ean_or_issn,
2577         title => $title,
2578         author => $author,
2579         publisher => $publisher,
2580         publicationyear => $publicationyear,
2581         branchcode => $branchcode,
2582         order_by => $order_by
2583     );
2584
2585 Return a list of invoices that match all given criteria.
2586
2587 $order_by is "column_name (asc|desc)", where column_name is any of
2588 'invoicenumber', 'booksellerid', 'shipmentdate', 'billingdate', 'closedate',
2589 'shipmentcost', 'shipmentcost_budgetid'.
2590
2591 asc is the default if omitted
2592
2593 =cut
2594
2595 sub GetInvoices {
2596     my %args = @_;
2597
2598     my @columns = qw(invoicenumber booksellerid shipmentdate billingdate
2599         closedate shipmentcost shipmentcost_budgetid);
2600
2601     my $dbh = C4::Context->dbh;
2602     my $query = qq{
2603         SELECT aqinvoices.invoiceid, aqinvoices.invoicenumber, aqinvoices.booksellerid, aqinvoices.shipmentdate, aqinvoices.billingdate, aqinvoices.closedate, aqinvoices.shipmentcost, aqinvoices.shipmentcost_budgetid, aqinvoices.message_id,
2604             aqbooksellers.name AS suppliername,
2605           COUNT(
2606             DISTINCT IF(
2607               aqorders.datereceived IS NOT NULL,
2608               aqorders.biblionumber,
2609               NULL
2610             )
2611           ) AS receivedbiblios,
2612           COUNT(
2613              DISTINCT IF(
2614               aqorders.subscriptionid IS NOT NULL,
2615               aqorders.subscriptionid,
2616               NULL
2617             )
2618           ) AS is_linked_to_subscriptions,
2619           SUM(aqorders.quantityreceived) AS receiveditems
2620         FROM aqinvoices
2621           LEFT JOIN aqbooksellers ON aqbooksellers.id = aqinvoices.booksellerid
2622           LEFT JOIN aqorders ON aqorders.invoiceid = aqinvoices.invoiceid
2623           LEFT JOIN aqbasket ON aqbasket.basketno=aqorders.basketno
2624           LEFT JOIN borrowers ON aqbasket.authorisedby=borrowers.borrowernumber
2625           LEFT JOIN biblio ON aqorders.biblionumber = biblio.biblionumber
2626           LEFT JOIN biblioitems ON biblio.biblionumber = biblioitems.biblionumber
2627           LEFT JOIN subscription ON biblio.biblionumber = subscription.biblionumber
2628     };
2629
2630     my @bind_args;
2631     my @bind_strs;
2632     if($args{supplierid}) {
2633         push @bind_strs, " aqinvoices.booksellerid = ? ";
2634         push @bind_args, $args{supplierid};
2635     }
2636     if($args{invoicenumber}) {
2637         push @bind_strs, " aqinvoices.invoicenumber LIKE ? ";
2638         push @bind_args, "%$args{invoicenumber}%";
2639     }
2640     if($args{suppliername}) {
2641         push @bind_strs, " aqbooksellers.name LIKE ? ";
2642         push @bind_args, "%$args{suppliername}%";
2643     }
2644     if($args{shipmentdatefrom}) {
2645         push @bind_strs, " aqinvoices.shipmentdate >= ? ";
2646         push @bind_args, $args{shipmentdatefrom};
2647     }
2648     if($args{shipmentdateto}) {
2649         push @bind_strs, " aqinvoices.shipmentdate <= ? ";
2650         push @bind_args, $args{shipmentdateto};
2651     }
2652     if($args{billingdatefrom}) {
2653         push @bind_strs, " aqinvoices.billingdate >= ? ";
2654         push @bind_args, $args{billingdatefrom};
2655     }
2656     if($args{billingdateto}) {
2657         push @bind_strs, " aqinvoices.billingdate <= ? ";
2658         push @bind_args, $args{billingdateto};
2659     }
2660     if($args{isbneanissn}) {
2661         push @bind_strs, " (biblioitems.isbn LIKE CONCAT('%', ?, '%') OR biblioitems.ean LIKE CONCAT('%', ?, '%') OR biblioitems.issn LIKE CONCAT('%', ?, '%') ) ";
2662         push @bind_args, $args{isbneanissn}, $args{isbneanissn}, $args{isbneanissn};
2663     }
2664     if($args{title}) {
2665         push @bind_strs, " biblio.title LIKE CONCAT('%', ?, '%') ";
2666         push @bind_args, $args{title};
2667     }
2668     if($args{author}) {
2669         push @bind_strs, " biblio.author LIKE CONCAT('%', ?, '%') ";
2670         push @bind_args, $args{author};
2671     }
2672     if($args{publisher}) {
2673         push @bind_strs, " biblioitems.publishercode LIKE CONCAT('%', ?, '%') ";
2674         push @bind_args, $args{publisher};
2675     }
2676     if($args{publicationyear}) {
2677         push @bind_strs, " ((biblioitems.publicationyear LIKE CONCAT('%', ?, '%')) OR (biblio.copyrightdate LIKE CONCAT('%', ?, '%'))) ";
2678         push @bind_args, $args{publicationyear}, $args{publicationyear};
2679     }
2680     if($args{branchcode}) {
2681         push @bind_strs, " borrowers.branchcode = ? ";
2682         push @bind_args, $args{branchcode};
2683     }
2684     if($args{message_id}) {
2685         push @bind_strs, " aqinvoices.message_id = ? ";
2686         push @bind_args, $args{message_id};
2687     }
2688
2689     $query .= " WHERE " . join(" AND ", @bind_strs) if @bind_strs;
2690     $query .= " GROUP BY aqinvoices.invoiceid, aqinvoices.invoicenumber, aqinvoices.booksellerid, aqinvoices.shipmentdate, aqinvoices.billingdate, aqinvoices.closedate, aqinvoices.shipmentcost, aqinvoices.shipmentcost_budgetid, aqinvoices.message_id, aqbooksellers.name";
2691
2692     if($args{order_by}) {
2693         my ($column, $direction) = split / /, $args{order_by};
2694         if(grep /^$column$/, @columns) {
2695             $direction ||= 'ASC';
2696             $query .= " ORDER BY $column $direction";
2697         }
2698     }
2699
2700     my $sth = $dbh->prepare($query);
2701     $sth->execute(@bind_args);
2702
2703     my $results = $sth->fetchall_arrayref({});
2704     return @$results;
2705 }
2706
2707 =head3 GetInvoice
2708
2709     my $invoice = GetInvoice($invoiceid);
2710
2711 Get informations about invoice with given $invoiceid
2712
2713 Return a hash filled with aqinvoices.* fields
2714
2715 =cut
2716
2717 sub GetInvoice {
2718     my ($invoiceid) = @_;
2719     my $invoice;
2720
2721     return unless $invoiceid;
2722
2723     my $dbh = C4::Context->dbh;
2724     my $query = qq{
2725         SELECT *
2726         FROM aqinvoices
2727         WHERE invoiceid = ?
2728     };
2729     my $sth = $dbh->prepare($query);
2730     $sth->execute($invoiceid);
2731
2732     $invoice = $sth->fetchrow_hashref;
2733     return $invoice;
2734 }
2735
2736 =head3 GetInvoiceDetails
2737
2738     my $invoice = GetInvoiceDetails($invoiceid)
2739
2740 Return informations about an invoice + the list of related order lines
2741
2742 Orders informations are in $invoice->{orders} (array ref)
2743
2744 =cut
2745
2746 sub GetInvoiceDetails {
2747     my ($invoiceid) = @_;
2748
2749     if ( !defined $invoiceid ) {
2750         carp 'GetInvoiceDetails called without an invoiceid';
2751         return;
2752     }
2753
2754     my $dbh = C4::Context->dbh;
2755     my $query = q{
2756         SELECT aqinvoices.*, aqbooksellers.name AS suppliername
2757         FROM aqinvoices
2758           LEFT JOIN aqbooksellers ON aqinvoices.booksellerid = aqbooksellers.id
2759         WHERE invoiceid = ?
2760     };
2761     my $sth = $dbh->prepare($query);
2762     $sth->execute($invoiceid);
2763
2764     my $invoice = $sth->fetchrow_hashref;
2765
2766     $query = q{
2767         SELECT aqorders.*,
2768                 biblio.*,
2769                 biblio.copyrightdate,
2770                 biblioitems.isbn,
2771                 biblioitems.publishercode,
2772                 biblioitems.publicationyear,
2773                 aqbasket.basketname,
2774                 aqbasketgroups.id AS basketgroupid,
2775                 aqbasketgroups.name AS basketgroupname
2776         FROM aqorders
2777           LEFT JOIN aqbasket ON aqorders.basketno = aqbasket.basketno
2778           LEFT JOIN aqbasketgroups ON aqbasket.basketgroupid = aqbasketgroups.id
2779           LEFT JOIN biblio ON aqorders.biblionumber = biblio.biblionumber
2780           LEFT JOIN biblioitems ON aqorders.biblionumber = biblioitems.biblionumber
2781         WHERE invoiceid = ?
2782     };
2783     $sth = $dbh->prepare($query);
2784     $sth->execute($invoiceid);
2785     $invoice->{orders} = $sth->fetchall_arrayref({});
2786     $invoice->{orders} ||= []; # force an empty arrayref if fetchall_arrayref fails
2787
2788     return $invoice;
2789 }
2790
2791 =head3 AddInvoice
2792
2793     my $invoiceid = AddInvoice(
2794         invoicenumber => $invoicenumber,
2795         booksellerid => $booksellerid,
2796         shipmentdate => $shipmentdate,
2797         billingdate => $billingdate,
2798         closedate => $closedate,
2799         shipmentcost => $shipmentcost,
2800         shipmentcost_budgetid => $shipmentcost_budgetid
2801     );
2802
2803 Create a new invoice and return its id or undef if it fails.
2804
2805 =cut
2806
2807 sub AddInvoice {
2808     my %invoice = @_;
2809
2810     return unless(%invoice and $invoice{invoicenumber});
2811
2812     my @columns = qw(invoicenumber booksellerid shipmentdate billingdate
2813         closedate shipmentcost shipmentcost_budgetid message_id);
2814
2815     my @set_strs;
2816     my @set_args;
2817     foreach my $key (keys %invoice) {
2818         if(0 < grep(/^$key$/, @columns)) {
2819             push @set_strs, "$key = ?";
2820             push @set_args, ($invoice{$key} || undef);
2821         }
2822     }
2823
2824     my $rv;
2825     if(@set_args > 0) {
2826         my $dbh = C4::Context->dbh;
2827         my $query = "INSERT INTO aqinvoices SET ";
2828         $query .= join (",", @set_strs);
2829         my $sth = $dbh->prepare($query);
2830         $rv = $sth->execute(@set_args);
2831         if($rv) {
2832             $rv = $dbh->last_insert_id(undef, undef, 'aqinvoices', undef);
2833         }
2834     }
2835     return $rv;
2836 }
2837
2838 =head3 ModInvoice
2839
2840     ModInvoice(
2841         invoiceid => $invoiceid,    # Mandatory
2842         invoicenumber => $invoicenumber,
2843         booksellerid => $booksellerid,
2844         shipmentdate => $shipmentdate,
2845         billingdate => $billingdate,
2846         closedate => $closedate,
2847         shipmentcost => $shipmentcost,
2848         shipmentcost_budgetid => $shipmentcost_budgetid
2849     );
2850
2851 Modify an invoice, invoiceid is mandatory.
2852
2853 Return undef if it fails.
2854
2855 =cut
2856
2857 sub ModInvoice {
2858     my %invoice = @_;
2859
2860     return unless(%invoice and $invoice{invoiceid});
2861
2862     my @columns = qw(invoicenumber booksellerid shipmentdate billingdate
2863         closedate shipmentcost shipmentcost_budgetid);
2864
2865     my @set_strs;
2866     my @set_args;
2867     foreach my $key (keys %invoice) {
2868         if(0 < grep(/^$key$/, @columns)) {
2869             push @set_strs, "$key = ?";
2870             push @set_args, ($invoice{$key} || undef);
2871         }
2872     }
2873
2874     my $dbh = C4::Context->dbh;
2875     my $query = "UPDATE aqinvoices SET ";
2876     $query .= join(",", @set_strs);
2877     $query .= " WHERE invoiceid = ?";
2878
2879     my $sth = $dbh->prepare($query);
2880     $sth->execute(@set_args, $invoice{invoiceid});
2881 }
2882
2883 =head3 CloseInvoice
2884
2885     CloseInvoice($invoiceid);
2886
2887 Close an invoice.
2888
2889 Equivalent to ModInvoice(invoiceid => $invoiceid, closedate => undef);
2890
2891 =cut
2892
2893 sub CloseInvoice {
2894     my ($invoiceid) = @_;
2895
2896     return unless $invoiceid;
2897
2898     my $dbh = C4::Context->dbh;
2899     my $query = qq{
2900         UPDATE aqinvoices
2901         SET closedate = CAST(NOW() AS DATE)
2902         WHERE invoiceid = ?
2903     };
2904     my $sth = $dbh->prepare($query);
2905     $sth->execute($invoiceid);
2906 }
2907
2908 =head3 ReopenInvoice
2909
2910     ReopenInvoice($invoiceid);
2911
2912 Reopen an invoice
2913
2914 Equivalent to ModInvoice(invoiceid => $invoiceid, closedate => output_pref({ dt=>dt_from_string, dateonly=>1, otputpref=>'iso' }))
2915
2916 =cut
2917
2918 sub ReopenInvoice {
2919     my ($invoiceid) = @_;
2920
2921     return unless $invoiceid;
2922
2923     my $dbh = C4::Context->dbh;
2924     my $query = qq{
2925         UPDATE aqinvoices
2926         SET closedate = NULL
2927         WHERE invoiceid = ?
2928     };
2929     my $sth = $dbh->prepare($query);
2930     $sth->execute($invoiceid);
2931 }
2932
2933 =head3 DelInvoice
2934
2935     DelInvoice($invoiceid);
2936
2937 Delete an invoice if there are no items attached to it.
2938
2939 =cut
2940
2941 sub DelInvoice {
2942     my ($invoiceid) = @_;
2943
2944     return unless $invoiceid;
2945
2946     my $dbh   = C4::Context->dbh;
2947     my $query = qq{
2948         SELECT COUNT(*)
2949         FROM aqorders
2950         WHERE invoiceid = ?
2951     };
2952     my $sth = $dbh->prepare($query);
2953     $sth->execute($invoiceid);
2954     my $res = $sth->fetchrow_arrayref;
2955     if ( $res && $res->[0] == 0 ) {
2956         $query = qq{
2957             DELETE FROM aqinvoices
2958             WHERE invoiceid = ?
2959         };
2960         my $sth = $dbh->prepare($query);
2961         return ( $sth->execute($invoiceid) > 0 );
2962     }
2963     return;
2964 }
2965
2966 =head3 MergeInvoices
2967
2968     MergeInvoices($invoiceid, \@sourceids);
2969
2970 Merge the invoices identified by the IDs in \@sourceids into
2971 the invoice identified by $invoiceid.
2972
2973 =cut
2974
2975 sub MergeInvoices {
2976     my ($invoiceid, $sourceids) = @_;
2977
2978     return unless $invoiceid;
2979     foreach my $sourceid (@$sourceids) {
2980         next if $sourceid == $invoiceid;
2981         my $source = GetInvoiceDetails($sourceid);
2982         foreach my $order (@{$source->{'orders'}}) {
2983             $order->{'invoiceid'} = $invoiceid;
2984             ModOrder($order);
2985         }
2986         DelInvoice($source->{'invoiceid'});
2987     }
2988     return;
2989 }
2990
2991 =head3 GetBiblioCountByBasketno
2992
2993 $biblio_count = &GetBiblioCountByBasketno($basketno);
2994
2995 Looks up the biblio's count that has basketno value $basketno
2996
2997 Returns a quantity
2998
2999 =cut
3000
3001 sub GetBiblioCountByBasketno {
3002     my ($basketno) = @_;
3003     my $dbh          = C4::Context->dbh;
3004     my $query        = "
3005         SELECT COUNT( DISTINCT( biblionumber ) )
3006         FROM   aqorders
3007         WHERE  basketno = ?
3008             AND (datecancellationprinted IS NULL OR datecancellationprinted='0000-00-00')
3009         ";
3010
3011     my $sth = $dbh->prepare($query);
3012     $sth->execute($basketno);
3013     return $sth->fetchrow;
3014 }
3015
3016 =head3 populate_order_with_prices
3017
3018 $order = populate_order_with_prices({
3019     order        => $order #a hashref with the order values
3020     booksellerid => $booksellerid #FIXME - should obtain from order basket
3021     receiving    => 1 # boolean representing order stage, should pass only this or ordering
3022     ordering     => 1 # boolean representing order stage
3023 });
3024
3025
3026 Sets calculated values for an order - all values are stored with full precision
3027 regardless of rounding preference except for tax value which is calculated
3028 on rounded values if requested
3029
3030 For ordering the values set are:
3031     rrp_tax_included
3032     rrp_tax_excluded
3033     ecost_tax_included
3034     ecost_tax_excluded
3035     tax_value_on_ordering
3036 For receiving the value set are:
3037     unitprice_tax_included
3038     unitprice_tax_excluded
3039     tax_value_on_receiving
3040
3041 Note: When receiving, if the rounded value of the unitprice matches the rounded
3042 value of the ecost then then ecost (full precision) is used.
3043
3044 Returns a hashref of the order
3045
3046 FIXME: Move this to Koha::Acquisition::Order.pm
3047
3048 =cut
3049
3050 sub populate_order_with_prices {
3051     my ($params) = @_;
3052
3053     my $order        = $params->{order};
3054     my $booksellerid = $params->{booksellerid};
3055     return unless $booksellerid;
3056
3057     my $bookseller = Koha::Acquisition::Booksellers->find( $booksellerid );
3058
3059     my $receiving = $params->{receiving};
3060     my $ordering  = $params->{ordering};
3061     my $discount  = $order->{discount};
3062     $discount /= 100 if $discount > 1;
3063
3064     if ($ordering) {
3065         $order->{tax_rate_on_ordering} //= $order->{tax_rate};
3066         if ( $bookseller->listincgst ) {
3067
3068             # The user entered the prices tax included
3069             $order->{unitprice_tax_included} = $order->{unitprice};
3070             $order->{rrp_tax_included} = $order->{rrp};
3071
3072             # price tax excluded = price tax included / ( 1 + tax rate )
3073             $order->{unitprice_tax_excluded} = $order->{unitprice_tax_included} / ( 1 + $order->{tax_rate_on_ordering} );
3074             $order->{rrp_tax_excluded} = $order->{rrp_tax_included} / ( 1 + $order->{tax_rate_on_ordering} );
3075
3076             # ecost tax included = rrp tax included  ( 1 - discount )
3077             $order->{ecost_tax_included} = $order->{rrp_tax_included} * ( 1 - $discount );
3078
3079             # ecost tax excluded = rrp tax excluded * ( 1 - discount )
3080             $order->{ecost_tax_excluded} = $order->{rrp_tax_excluded} * ( 1 - $discount );
3081
3082             # tax value = quantity * ecost tax excluded * tax rate
3083             # we should use the unitprice if included
3084             my $cost_tax_included = $order->{unitprice_tax_included} || $order->{ecost_tax_included};
3085             my $cost_tax_excluded = $order->{unitprice_tax_excluded} || $order->{ecost_tax_excluded};
3086             $order->{tax_value_on_ordering} = ( get_rounded_price($cost_tax_included) - get_rounded_price($cost_tax_excluded) ) * $order->{quantity};
3087
3088         }
3089         else {
3090             # The user entered the prices tax excluded
3091             $order->{unitprice_tax_excluded} = $order->{unitprice};
3092             $order->{rrp_tax_excluded} = $order->{rrp};
3093
3094             # price tax included = price tax excluded * ( 1 - tax rate )
3095             $order->{unitprice_tax_included} = $order->{unitprice_tax_excluded} * ( 1 + $order->{tax_rate_on_ordering} );
3096             $order->{rrp_tax_included} = $order->{rrp_tax_excluded} * ( 1 + $order->{tax_rate_on_ordering} );
3097
3098             # ecost tax excluded = rrp tax excluded * ( 1 - discount )
3099             $order->{ecost_tax_excluded} = $order->{rrp_tax_excluded} * ( 1 - $discount );
3100
3101             # ecost tax included = rrp tax excluded * ( 1 + tax rate ) * ( 1 - discount ) = ecost tax excluded * ( 1 + tax rate )
3102             $order->{ecost_tax_included} = $order->{ecost_tax_excluded} * ( 1 + $order->{tax_rate_on_ordering} );
3103
3104             # tax value = quantity * ecost tax included * tax rate
3105             # we should use the unitprice if included
3106             my $cost_tax_excluded = $order->{unitprice_tax_excluded} || $order->{ecost_tax_excluded};
3107             $order->{tax_value_on_ordering} = $order->{quantity} * get_rounded_price($cost_tax_excluded) * $order->{tax_rate_on_ordering};
3108         }
3109     }
3110
3111     if ($receiving) {
3112         $order->{tax_rate_on_receiving} //= $order->{tax_rate};
3113         if ( $bookseller->invoiceincgst ) {
3114             # Trick for unitprice. If the unit price rounded value is the same as the ecost rounded value
3115             # we need to keep the exact ecost value
3116             if ( Koha::Number::Price->new( $order->{unitprice} )->round == Koha::Number::Price->new( $order->{ecost_tax_included} )->round ) {
3117                 $order->{unitprice} = $order->{ecost_tax_included};
3118             }
3119
3120             # The user entered the unit price tax included
3121             $order->{unitprice_tax_included} = $order->{unitprice};
3122
3123             # unit price tax excluded = unit price tax included / ( 1 + tax rate )
3124             $order->{unitprice_tax_excluded} = $order->{unitprice_tax_included} / ( 1 + $order->{tax_rate_on_receiving} );
3125         }
3126         else {
3127             # Trick for unitprice. If the unit price rounded value is the same as the ecost rounded value
3128             # we need to keep the exact ecost value
3129             if ( Koha::Number::Price->new( $order->{unitprice} )->round == Koha::Number::Price->new( $order->{ecost_tax_excluded} )->round ) {
3130                 $order->{unitprice} = $order->{ecost_tax_excluded};
3131             }
3132
3133             # The user entered the unit price tax excluded
3134             $order->{unitprice_tax_excluded} = $order->{unitprice};
3135
3136
3137             # unit price tax included = unit price tax included * ( 1 + tax rate )
3138             $order->{unitprice_tax_included} = $order->{unitprice_tax_excluded} * ( 1 + $order->{tax_rate_on_receiving} );
3139         }
3140
3141         # tax value = quantity * unit price tax excluded * tax rate
3142         $order->{tax_value_on_receiving} = $order->{quantity} * get_rounded_price($order->{unitprice_tax_excluded}) * $order->{tax_rate_on_receiving};
3143     }
3144
3145     return $order;
3146 }
3147
3148 =head3 GetOrderUsers
3149
3150     $order_users_ids = &GetOrderUsers($ordernumber);
3151
3152 Returns a list of all borrowernumbers that are in order users list
3153
3154 =cut
3155
3156 sub GetOrderUsers {
3157     my ($ordernumber) = @_;
3158
3159     return unless $ordernumber;
3160
3161     my $query = q|
3162         SELECT borrowernumber
3163         FROM aqorder_users
3164         WHERE ordernumber = ?
3165     |;
3166     my $dbh = C4::Context->dbh;
3167     my $sth = $dbh->prepare($query);
3168     $sth->execute($ordernumber);
3169     my $results = $sth->fetchall_arrayref( {} );
3170
3171     my @borrowernumbers;
3172     foreach (@$results) {
3173         push @borrowernumbers, $_->{'borrowernumber'};
3174     }
3175
3176     return @borrowernumbers;
3177 }
3178
3179 =head3 ModOrderUsers
3180
3181     my @order_users_ids = (1, 2, 3);
3182     &ModOrderUsers($ordernumber, @basketusers_ids);
3183
3184 Delete all users from order users list, and add users in C<@order_users_ids>
3185 to this users list.
3186
3187 =cut
3188
3189 sub ModOrderUsers {
3190     my ( $ordernumber, @order_users_ids ) = @_;
3191
3192     return unless $ordernumber;
3193
3194     my $dbh   = C4::Context->dbh;
3195     my $query = q|
3196         DELETE FROM aqorder_users
3197         WHERE ordernumber = ?
3198     |;
3199     my $sth = $dbh->prepare($query);
3200     $sth->execute($ordernumber);
3201
3202     $query = q|
3203         INSERT INTO aqorder_users (ordernumber, borrowernumber)
3204         VALUES (?, ?)
3205     |;
3206     $sth = $dbh->prepare($query);
3207     foreach my $order_user_id (@order_users_ids) {
3208         $sth->execute( $ordernumber, $order_user_id );
3209     }
3210 }
3211
3212 sub NotifyOrderUsers {
3213     my ($ordernumber) = @_;
3214
3215     my @borrowernumbers = GetOrderUsers($ordernumber);
3216     return unless @borrowernumbers;
3217
3218     my $order = GetOrder( $ordernumber );
3219     for my $borrowernumber (@borrowernumbers) {
3220         my $patron = Koha::Patrons->find( $borrowernumber );
3221         my $library = $patron->library->unblessed;
3222         my $biblio = Koha::Biblios->find( $order->{biblionumber} )->unblessed;
3223         my $letter = C4::Letters::GetPreparedLetter(
3224             module      => 'acquisition',
3225             letter_code => 'ACQ_NOTIF_ON_RECEIV',
3226             branchcode  => $library->{branchcode},
3227             lang        => $patron->lang,
3228             tables      => {
3229                 'branches'    => $library,
3230                 'borrowers'   => $patron->unblessed,
3231                 'biblio'      => $biblio,
3232                 'aqorders'    => $order,
3233             },
3234         );
3235         if ( $letter ) {
3236             C4::Letters::EnqueueLetter(
3237                 {
3238                     letter         => $letter,
3239                     borrowernumber => $borrowernumber,
3240                     LibraryName    => C4::Context->preference("LibraryName"),
3241                     message_transport_type => 'email',
3242                 }
3243             ) or warn "can't enqueue letter $letter";
3244         }
3245     }
3246 }
3247
3248 =head3 FillWithDefaultValues
3249
3250 FillWithDefaultValues( $marc_record );
3251
3252 This will update the record with default value defined in the ACQ framework.
3253 For all existing fields, if a default value exists and there are no subfield, it will be created.
3254 If the field does not exist, it will be created too.
3255
3256 =cut
3257
3258 sub FillWithDefaultValues {
3259     my ($record) = @_;
3260     my $tagslib = C4::Biblio::GetMarcStructure( 1, 'ACQ', { unsafe => 1 } );
3261     if ($tagslib) {
3262         my ($itemfield) =
3263           C4::Biblio::GetMarcFromKohaField( 'items.itemnumber' );
3264         for my $tag ( sort keys %$tagslib ) {
3265             next unless $tag;
3266             next if $tag == $itemfield;
3267             for my $subfield ( sort keys %{ $tagslib->{$tag} } ) {
3268                 next if IsMarcStructureInternal($tagslib->{$tag}{$subfield});
3269                 my $defaultvalue = $tagslib->{$tag}{$subfield}{defaultvalue};
3270                 if ( defined $defaultvalue and $defaultvalue ne '' ) {
3271                     my @fields = $record->field($tag);
3272                     if (@fields) {
3273                         for my $field (@fields) {
3274                             unless ( defined $field->subfield($subfield) ) {
3275                                 $field->add_subfields(
3276                                     $subfield => $defaultvalue );
3277                             }
3278                         }
3279                     }
3280                     else {
3281                         $record->insert_fields_ordered(
3282                             MARC::Field->new(
3283                                 $tag, '', '', $subfield => $defaultvalue
3284                             )
3285                         );
3286                     }
3287                 }
3288             }
3289         }
3290     }
3291 }
3292
3293 1;
3294 __END__
3295
3296 =head1 AUTHOR
3297
3298 Koha Development Team <http://koha-community.org/>
3299
3300 =cut