Lines 1038-1044
Returns number of messages sent.
Link Here
|
1038 |
sub SendQueuedMessages { |
1038 |
sub SendQueuedMessages { |
1039 |
my $params = shift; |
1039 |
my $params = shift; |
1040 |
|
1040 |
|
1041 |
my $unsent_messages = _get_unsent_messages( { limit => $params->{limit} } ); |
1041 |
my $which_unsent_messages = { |
|
|
1042 |
'limit' => $params->{'limit'} // 0, |
1043 |
'borrowernumber' => $params->{'borrowernumber'} // q{}, |
1044 |
'letter_code' => $params->{'letter_code'} // q{}, |
1045 |
}; |
1046 |
my $unsent_messages = _get_unsent_messages( $which_unsent_messages ); |
1042 |
MESSAGE: foreach my $message ( @$unsent_messages ) { |
1047 |
MESSAGE: foreach my $message ( @$unsent_messages ) { |
1043 |
# warn Data::Dumper->Dump( [ $message ], [ 'message' ] ); |
1048 |
# warn Data::Dumper->Dump( [ $message ], [ 'message' ] ); |
1044 |
warn sprintf( 'sending %s message to patron: %s', |
1049 |
warn sprintf( 'sending %s message to patron: %s', |
Lines 1282-1294
sub _get_unsent_messages {
Link Here
|
1282 |
my @query_params = ('pending'); |
1287 |
my @query_params = ('pending'); |
1283 |
if ( ref $params ) { |
1288 |
if ( ref $params ) { |
1284 |
if ( $params->{'message_transport_type'} ) { |
1289 |
if ( $params->{'message_transport_type'} ) { |
1285 |
$statement .= ' AND message_transport_type = ? '; |
1290 |
$statement .= ' AND mq.message_transport_type = ? '; |
1286 |
push @query_params, $params->{'message_transport_type'}; |
1291 |
push @query_params, $params->{'message_transport_type'}; |
1287 |
} |
1292 |
} |
1288 |
if ( $params->{'borrowernumber'} ) { |
1293 |
if ( $params->{'borrowernumber'} ) { |
1289 |
$statement .= ' AND borrowernumber = ? '; |
1294 |
$statement .= ' AND mq.borrowernumber = ? '; |
1290 |
push @query_params, $params->{'borrowernumber'}; |
1295 |
push @query_params, $params->{'borrowernumber'}; |
1291 |
} |
1296 |
} |
|
|
1297 |
if ( $params->{'letter_code'} ) { |
1298 |
$statement .= ' AND mq.letter_code = ? '; |
1299 |
push @query_params, $params->{'letter_code'}; |
1300 |
} |
1292 |
if ( $params->{'limit'} ) { |
1301 |
if ( $params->{'limit'} ) { |
1293 |
$statement .= ' limit ? '; |
1302 |
$statement .= ' limit ? '; |
1294 |
push @query_params, $params->{'limit'}; |
1303 |
push @query_params, $params->{'limit'}; |