Attachment #25927 for bug #8000

View | Details | Raw Unified | Return to bug 8000
Collapse All | Expand All





    my $dbh = C4::Context->dbh();
    my $statement = << 'ENDSQL';
SELECT message_id, borrowernumber, subject, content, message_transport_type, status, time_queued, sentto_address
FROM message_queue
ENDSQL



    my $member = C4::Members::GetMember( 'borrowernumber' => $message->{'borrowernumber'} );
    my $to_address = $message->{'to_address'};
    if (!$to_address && $member) {
        $to_address = C4::Members::GetNoticeEmailAddress( $message->{'borrowernumber'} );
    }
    my $sendAllEmailsTo = C4::Context->preference('SendAllEmailsTo');
    $to_address = $sendAllEmailsTo if ($sendAllEmailsTo && $sendAllEmailsTo =~ /@/ ); # some validation.  This could be improved.
    unless ($to_address) {
        if (!$member) {
            warn "FAIL: No 'to_address' and INVALID borrowernumber ($message->{borrowernumber})";
            _set_message_status( { message_id => $message->{'message_id'},
                                   status     => 'failed' } );
            return;
        }
        else {
        unless ($to_address) {  
            # warn "FAIL: No 'to_address' and no email for " . ($member->{surname} ||'') . ", borrowernumber ($message->{borrowernumber})";
            # warning too verbose for this more common case?
            _set_message_status( { message_id => $message->{'message_id'},


    _update_message_to_address($message->{'message_id'},$to_address) unless $message->{to_address}; #if initial message address was empty, coming here means that a to address was found and queue should be updated
    if ( sendmail( %sendmail_params ) ) {
        _set_message_status( { message_id     => $message->{'message_id'},
                               status         => 'sent',
                               sentto_address => $to_address } );
        return 1;
    } else {
        _set_message_status( { message_id => $message->{'message_id'},

        return unless exists $params->{ $required_parameter };
    }

    my $dbh = C4::Context->dbh();
    my $statement = 'UPDATE message_queue SET status= ? WHERE message_id = ?';
    my @values;
    push @values,$params->{'status'};
    if (exists($params->{'sentto_address'})) {
        $statement = 'UPDATE message_queue SET status=?, sentto_address=? WHERE message_id = ?';
        push @values,$params->{'sentto_address'};
    }
    push @values,$params->{'message_id'};
    my $dbh = C4::Context->dbh();
    print STDERR "statement: $statement\n",@values,"\n";
    my $sth = $dbh->prepare( $statement );
    my $result = $sth->execute( @values );
                                $params->{'message_id'} );
    return $result;
}


Lines 19-29 Link Here

(-)a/t/db_dependent/Letters.t (-3 / +31 lines)
19		19
20	use Modern::Perl;	20	use Modern::Perl;
21		21
22	use Test::More tests => 5;	22	use Test::More tests => 8;
23		23
24	use C4::Context;	24	use C4::Context;
25	use C4::Letters;	25	use C4::Letters;
26	use C4::Members;	26	use C4::Members;
		27	use Data::Dumper;
27		28
28	my $dbh = C4::Context->dbh;	29	my $dbh = C4::Context->dbh;
29		30
Lines 56-61 my $message_id = C4::Letters::EnqueueLetter({ Link Here
56	});	57	});
57		58
58	# used to trigger _send_message_by_email in C4::Letter	59	# used to trigger _send_message_by_email in C4::Letter
		60	# first override.
		61	C4::Context->disable_syspref_cache();
		62	my $rv = $dbh->do("UPDATE systempreferences SET value='override\@example.com' WHERE variable='SendAllEmailsTo';");
		63	print "RV: $rv\n";
59	my $message_id2 = C4::Letters::EnqueueLetter({	64	my $message_id2 = C4::Letters::EnqueueLetter({
60	borrowernumber => $borrowernumber,	65	borrowernumber => $borrowernumber,
61	message_transport_type => 'email',	66	message_transport_type => 'email',
Lines 76-83 ok(defined $message_id2 && $message_id2 > 0, 'new message successfully queued'); Link Here
76	my $messages_processed = C4::Letters::SendQueuedMessages();	81	my $messages_processed = C4::Letters::SendQueuedMessages();
77	is($messages_processed, 2, 'all queued messages processed');	82	is($messages_processed, 2, 'all queued messages processed');
78		83
		84	# used to trigger _send_message_by_email in C4::Letter
		85	# second no override.
		86	$rv = $dbh->do("UPDATE systempreferences SET value='' WHERE variable='SendAllEmailsTo';");
		87	print "RV: $rv\n";
		88	my $message_id3 = C4::Letters::EnqueueLetter({
		89	borrowernumber => $borrowernumber,
		90	message_transport_type => 'email',
		91	to_address => 'to@example.com',
		92	from_address => 'from@example.com',
		93	letter => {
		94	content => 'a message',
		95	title => 'message title',
		96	metadata => 'metadata',
		97	code => 'TEST_MESSAGE',
		98	content_type => 'text/plain',
		99	},
		100	});
		101
		102	$messages_processed = C4::Letters::SendQueuedMessages();
		103	is($messages_processed, 1, 'third queued message processed');
		104
79	my $messages = C4::Letters::GetQueuedMessages({ borrowernumber => $borrowernumber });	105	my $messages = C4::Letters::GetQueuedMessages({ borrowernumber => $borrowernumber });
80	is(scalar(@$messages), 2, 'two messages stored for the borrower');	106	is(scalar(@$messages), 3, 'three messages stored for the borrower');
81		107
82	is(	108	is(
83	$messages->[0]->{status},	109	$messages->[0]->{status},
Lines 85-88 is( Link Here
85	'message marked failed if tried to send SMS message for borrower with no smsalertnumber set (bug 11208)'	111	'message marked failed if tried to send SMS message for borrower with no smsalertnumber set (bug 11208)'
86	);	112	);
87		113
		114	is ( $messages->[1]->{sentto_address},'override@example.com','Second message sent to override.');
		115	is ( $messages->[2]->{sentto_address},'to@example.com','Third message sent to default.');
		116
88	$dbh->rollback;	117	$dbh->rollback;
89	-

Return to bug 8000

Lines 826-832 sub GetQueuedMessages { Link Here

(-)a/C4/Letters.pm (-9 / +19 lines)
826		826
827	my $dbh = C4::Context->dbh();	827	my $dbh = C4::Context->dbh();
828	my $statement = << 'ENDSQL';	828	my $statement = << 'ENDSQL';
829	SELECT message_id, borrowernumber, subject, content, message_transport_type, status, time_queued	829	SELECT message_id, borrowernumber, subject, content, message_transport_type, status, time_queued, sentto_address
830	FROM message_queue	830	FROM message_queue
831	ENDSQL	831	ENDSQL
832		832
Lines 937-953 sub _send_message_by_email { Link Here
937		937
938	my $member = C4::Members::GetMember( 'borrowernumber' => $message->{'borrowernumber'} );	938	my $member = C4::Members::GetMember( 'borrowernumber' => $message->{'borrowernumber'} );
939	my $to_address = $message->{'to_address'};	939	my $to_address = $message->{'to_address'};
		940	if (!$to_address && $member) {
		941	$to_address = C4::Members::GetNoticeEmailAddress( $message->{'borrowernumber'} );
		942	}
940	my $sendAllEmailsTo = C4::Context->preference('SendAllEmailsTo');	943	my $sendAllEmailsTo = C4::Context->preference('SendAllEmailsTo');
941	$to_address = $sendAllEmailsTo if ($sendAllEmailsTo && $sendAllEmailsTo =~ /@/ ); # some validation. This could be improved.	944	$to_address = $sendAllEmailsTo if ($sendAllEmailsTo && $sendAllEmailsTo =~ /@/ ); # some validation. This could be improved.
942	unless ($to_address) {	945	unless ($to_address) {
943	unless ($member) {	946	if (!$member) {
944	warn "FAIL: No 'to_address' and INVALID borrowernumber ($message->{borrowernumber})";	947	warn "FAIL: No 'to_address' and INVALID borrowernumber ($message->{borrowernumber})";
945	_set_message_status( { message_id => $message->{'message_id'},	948	_set_message_status( { message_id => $message->{'message_id'},
946	status => 'failed' } );	949	status => 'failed' } );
947	return;	950	return;
948	}	951	}
949	$to_address = C4::Members::GetNoticeEmailAddress( $message->{'borrowernumber'} );	952	else {
950	unless ($to_address) {
951	# warn "FAIL: No 'to_address' and no email for " . ($member->{surname} \|\|'') . ", borrowernumber ($message->{borrowernumber})";	953	# warn "FAIL: No 'to_address' and no email for " . ($member->{surname} \|\|'') . ", borrowernumber ($message->{borrowernumber})";
952	# warning too verbose for this more common case?	954	# warning too verbose for this more common case?
953	_set_message_status( { message_id => $message->{'message_id'},	955	_set_message_status( { message_id => $message->{'message_id'},
Lines 980-987 sub _send_message_by_email { Link Here
980		982
981	_update_message_to_address($message->{'message_id'},$to_address) unless $message->{to_address}; #if initial message address was empty, coming here means that a to address was found and queue should be updated	983	_update_message_to_address($message->{'message_id'},$to_address) unless $message->{to_address}; #if initial message address was empty, coming here means that a to address was found and queue should be updated
982	if ( sendmail( %sendmail_params ) ) {	984	if ( sendmail( %sendmail_params ) ) {
983	_set_message_status( { message_id => $message->{'message_id'},	985	_set_message_status( { message_id => $message->{'message_id'},
984	status => 'sent' } );	986	status => 'sent',
		987	sentto_address => $to_address } );
985	return 1;	988	return 1;
986	} else {	989	} else {
987	_set_message_status( { message_id => $message->{'message_id'},	990	_set_message_status( { message_id => $message->{'message_id'},
Lines 1043-1053 sub _set_message_status { Link Here
1043	return unless exists $params->{ $required_parameter };	1046	return unless exists $params->{ $required_parameter };
1044	}	1047	}
1045		1048
1046	my $dbh = C4::Context->dbh();
1047	my $statement = 'UPDATE message_queue SET status= ? WHERE message_id = ?';	1049	my $statement = 'UPDATE message_queue SET status= ? WHERE message_id = ?';
		1050	my @values;
		1051	push @values,$params->{'status'};
		1052	if (exists($params->{'sentto_address'})) {
		1053	$statement = 'UPDATE message_queue SET status=?, sentto_address=? WHERE message_id = ?';
		1054	push @values,$params->{'sentto_address'};
		1055	}
		1056	push @values,$params->{'message_id'};
		1057	my $dbh = C4::Context->dbh();
		1058	print STDERR "statement: $statement\n",@values,"\n";
1048	my $sth = $dbh->prepare( $statement );	1059	my $sth = $dbh->prepare( $statement );
1049	my $result = $sth->execute( $params->{'status'},	1060	my $result = $sth->execute( @values );
1050	$params->{'message_id'} );
1051	return $result;	1061	return $result;
1052	}	1062	}
1053		1063