Lines 3366-3371
sub SendCirculationAlert {
Link Here
|
3366 |
}); |
3366 |
}); |
3367 |
my $issues_table = ( $type eq 'CHECKOUT' || $type eq 'RENEWAL' ) ? 'issues' : 'old_issues'; |
3367 |
my $issues_table = ( $type eq 'CHECKOUT' || $type eq 'RENEWAL' ) ? 'issues' : 'old_issues'; |
3368 |
|
3368 |
|
|
|
3369 |
my $schema = Koha::Database->new->schema; |
3369 |
my @transports = keys %{ $borrower_preferences->{transports} }; |
3370 |
my @transports = keys %{ $borrower_preferences->{transports} }; |
3370 |
for my $mtt (@transports) { |
3371 |
for my $mtt (@transports) { |
3371 |
my $letter = C4::Letters::GetPreparedLetter ( |
3372 |
my $letter = C4::Letters::GetPreparedLetter ( |
Lines 3383-3395
sub SendCirculationAlert {
Link Here
|
3383 |
} |
3384 |
} |
3384 |
) or next; |
3385 |
) or next; |
3385 |
|
3386 |
|
|
|
3387 |
$schema->storage->txn_begin; |
3388 |
C4::Context->dbh->do(q|LOCK TABLE message_queue READ|); |
3389 |
C4::Context->dbh->do(q|LOCK TABLE message_queue WRITE|); |
3386 |
my $message = C4::Message->find_last_message($borrower, $type, $mtt); |
3390 |
my $message = C4::Message->find_last_message($borrower, $type, $mtt); |
3387 |
unless ( $message ) { |
3391 |
unless ( $message ) { |
|
|
3392 |
C4::Context->dbh->do(q|UNLOCK TABLES|); |
3388 |
C4::Message->enqueue($letter, $borrower, $mtt); |
3393 |
C4::Message->enqueue($letter, $borrower, $mtt); |
3389 |
} else { |
3394 |
} else { |
3390 |
$message->append($letter); |
3395 |
$message->append($letter); |
3391 |
$message->update; |
3396 |
$message->update; |
3392 |
} |
3397 |
} |
|
|
3398 |
C4::Context->dbh->do(q|UNLOCK TABLES|); |
3399 |
$schema->storage->txn_commit; |
3393 |
} |
3400 |
} |
3394 |
|
3401 |
|
3395 |
return; |
3402 |
return; |
3396 |
- |
|
|