Lines 922-951
sub EnqueueLetter {
Link Here
|
922 |
); |
922 |
); |
923 |
} |
923 |
} |
924 |
|
924 |
|
925 |
my $dbh = C4::Context->dbh(); |
925 |
my $message = Koha::Notice::Message->new( |
926 |
my $statement = << 'ENDSQL'; |
926 |
{ |
927 |
INSERT INTO message_queue |
927 |
letter_id => $params->{letter}->{id} || undef, |
928 |
( letter_id, borrowernumber, subject, content, metadata, letter_code, message_transport_type, status, time_queued, to_address, from_address, reply_address, content_type, failure_code ) |
928 |
borrowernumber => $params->{borrowernumber}, |
929 |
VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, CAST(NOW() AS DATETIME), ?, ?, ?, ?, ? ) |
929 |
subject => $params->{letter}->{title}, |
930 |
ENDSQL |
930 |
content => $params->{letter}->{content}, |
931 |
|
931 |
metadata => $params->{letter}->{metadata} || q{}, |
932 |
my $sth = $dbh->prepare($statement); |
932 |
letter_code => $params->{letter}->{code} || q{}, |
933 |
my $result = $sth->execute( |
933 |
message_transport_type => $params->{message_transport_type}, |
934 |
$params->{letter}->{id} || undef, # letter.id |
934 |
status => 'pending', |
935 |
$params->{'borrowernumber'}, # borrowernumber |
935 |
time_queued => dt_from_string(), |
936 |
$params->{'letter'}->{'title'}, # subject |
936 |
to_address => $params->{to_address}, |
937 |
$params->{'letter'}->{'content'}, # content |
937 |
from_address => $params->{from_address}, |
938 |
$params->{'letter'}->{'metadata'} || '', # metadata |
938 |
reply_address => $params->{reply_address}, |
939 |
$params->{'letter'}->{'code'} || '', # letter_code |
939 |
content_type => $params->{letter}->{'content-type'}, |
940 |
$params->{'message_transport_type'}, # message_transport_type |
940 |
failure_code => $params->{failure_code} || q{}, |
941 |
'pending', # status |
941 |
} |
942 |
$params->{'to_address'}, # to_address |
942 |
)->store(); |
943 |
$params->{'from_address'}, # from_address |
943 |
return $message->id; |
944 |
$params->{'reply_address'}, # reply_address |
|
|
945 |
$params->{'letter'}->{'content-type'}, # content_type |
946 |
$params->{'failure_code'} || '', # failure_code |
947 |
); |
948 |
return $dbh->last_insert_id(undef,undef,'message_queue', undef); |
949 |
} |
944 |
} |
950 |
|
945 |
|
951 |
=head2 SendQueuedMessages ([$hashref]) |
946 |
=head2 SendQueuedMessages ([$hashref]) |
952 |
- |
|
|