Lines 3323-3328
sub SendCirculationAlert {
Link Here
|
3323 |
}); |
3323 |
}); |
3324 |
my $issues_table = ( $type eq 'CHECKOUT' || $type eq 'RENEWAL' ) ? 'issues' : 'old_issues'; |
3324 |
my $issues_table = ( $type eq 'CHECKOUT' || $type eq 'RENEWAL' ) ? 'issues' : 'old_issues'; |
3325 |
|
3325 |
|
|
|
3326 |
my $schema = Koha::Database->new->schema; |
3326 |
my @transports = keys %{ $borrower_preferences->{transports} }; |
3327 |
my @transports = keys %{ $borrower_preferences->{transports} }; |
3327 |
for my $mtt (@transports) { |
3328 |
for my $mtt (@transports) { |
3328 |
my $letter = C4::Letters::GetPreparedLetter ( |
3329 |
my $letter = C4::Letters::GetPreparedLetter ( |
Lines 3340-3352
sub SendCirculationAlert {
Link Here
|
3340 |
} |
3341 |
} |
3341 |
) or next; |
3342 |
) or next; |
3342 |
|
3343 |
|
|
|
3344 |
$schema->storage->txn_begin; |
3345 |
C4::Context->dbh->do(q|LOCK TABLE message_queue READ|); |
3346 |
C4::Context->dbh->do(q|LOCK TABLE message_queue WRITE|); |
3343 |
my $message = C4::Message->find_last_message($borrower, $type, $mtt); |
3347 |
my $message = C4::Message->find_last_message($borrower, $type, $mtt); |
3344 |
unless ( $message ) { |
3348 |
unless ( $message ) { |
|
|
3349 |
C4::Context->dbh->do(q|UNLOCK TABLES|); |
3345 |
C4::Message->enqueue($letter, $borrower, $mtt); |
3350 |
C4::Message->enqueue($letter, $borrower, $mtt); |
3346 |
} else { |
3351 |
} else { |
3347 |
$message->append($letter); |
3352 |
$message->append($letter); |
3348 |
$message->update; |
3353 |
$message->update; |
3349 |
} |
3354 |
} |
|
|
3355 |
C4::Context->dbh->do(q|UNLOCK TABLES|); |
3356 |
$schema->storage->txn_commit; |
3350 |
} |
3357 |
} |
3351 |
|
3358 |
|
3352 |
return; |
3359 |
return; |
3353 |
- |
|
|