Attachment #74692 for bug #19855

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




use Koha::Notice::Messages;
use Koha::DateUtils qw( format_sqldatetime dt_from_string );
use Koha::Patrons;
use Koha::Subscriptions;

use vars qw(@ISA @EXPORT @EXPORT_OK %EXPORT_TAGS);


    require Exporter;
    @ISA = qw(Exporter);
    @EXPORT = qw(
        &GetLetters &GetLettersAvailableForALibrary &GetLetterTemplates &DelLetter &GetPreparedLetter &GetWrappedLetter &SendAlerts &GetPrintMessages &GetMessageTransportTypes
    );
}


    , undef, $branchcode, $module, $code, ( $mtt ? $mtt : () ), ( $lang ? $lang : () ) );
}

=head2 addalert ($borrowernumber, $subscriptionid)

    parameters : 
    - $borrowernumber : the number of the borrower subscribing to the alert
    - $subscriptionid

    create an alert and return the alertid (primary key)

=cut

sub addalert {
    my ( $borrowernumber, $subscriptionid) = @_;
    my $dbh = C4::Context->dbh;
    my $sth =
      $dbh->prepare(
        "insert into alert (borrowernumber, externalid) values (?,?)");
    $sth->execute( $borrowernumber, $subscriptionid );

    # get the alert number newly created and return it
    my $alertid = $dbh->{'mysql_insertid'};
    return $alertid;
}

=head2 delalert ($alertid)

    parameters :
    - alertid : the alert id
    deletes the alert

=cut

sub delalert {
    my $alertid = shift or die "delalert() called without valid argument (alertid)";    # it's gonna die anyway.
    $debug and warn "delalert: deleting alertid $alertid";
    my $sth = C4::Context->dbh->prepare("delete from alert where alertid=?");
    $sth->execute($alertid);
}

=head2 getalert ([$borrowernumber], [$subscriptionid])

    parameters :
    - $borrowernumber : the number of the borrower subscribing to the alert
    - $subscriptionid
    all parameters NON mandatory. If a parameter is omitted, the query is done without the corresponding parameter. For example, without $subscriptionid, returns all alerts for a borrower on a topic.

=cut

sub getalert {
    my ( $borrowernumber, $subscriptionid ) = @_;
    my $dbh   = C4::Context->dbh;
    my $query = "SELECT a.*, b.branchcode FROM alert a JOIN borrowers b USING(borrowernumber) WHERE 1";
    my @bind;
    if ($borrowernumber and $borrowernumber =~ /^\d+$/) {
        $query .= " AND borrowernumber=?";
        push @bind, $borrowernumber;
    }
    if ($subscriptionid) {
        $query .= " AND externalid=?";
        push @bind, $subscriptionid;
    }
    my $sth = $dbh->prepare($query);
    $sth->execute(@bind);
    return $sth->fetchall_arrayref({});
}

=head2 SendAlerts

    my $err = &SendAlerts($type, $externalid, $letter_code);

             return;

        my %letter;
        # find the list of subscribers to notify
        my $subscription = Koha::Subscriptions->find( $subscriptionid );
        my $subscribers = $subscription->subscribers;
        while ( my $patron = $subscribers->next ) {
            next unless $patron; # Just in case
            my $email = $patron->email or next;

#                    warn "sending issues...";
            my $userenv = C4::Context->userenv;
            my $library = $patron->library;
            my $letter = GetPreparedLetter (
                module => 'serial',
                letter_code => $letter_code,
                branchcode => $userenv->{branch},
                tables => {
                    'branches'    => $library->branchcode,
                    'biblio'      => $biblionumber,
                    'biblioitems' => $biblionumber,
                    'borrowers'   => $patron->unblessed,




    return scalar Koha::Acquisition::Booksellers->find($self->aqbooksellerid);
}

=head3 subscribers

my $subscribers = $subscription->subscribers;

return a Koha::Patrons object

=cut

sub subscribers {
    my ($self) = @_;
    my $schema = Koha::Database->new->schema;
    my @borrowernumbers = $schema->resultset('Alert')->search({ externalid => $self->subscriptionid })->get_column( 'borrowernumber' )->all;
    return Koha::Patrons->search({ borrowernumber => {-in => \@borrowernumbers } });
}

=head3 add_subscriber

$subscription->add_subscriber( $patron );

Add a new subscriber (Koha::Patron) to this subscription

=cut

sub add_subscriber {
    my ( $self, $patron )  = @_;
    my $schema = Koha::Database->new->schema;
    my $rs = $schema->resultset('Alert');
    $rs->create({ externalid => $self->subscriptionid, borrowernumber => $patron->borrowernumber });
}

=head3 remove_subscriber

$subscription->remove_subscriber( $subscriber );

Remove a subscriber (Koha::Patron) from this subscription

=cut

sub remove_subscriber {
    my ($self, $patron) = @_;
    my $schema = Koha::Database->new->schema;
    my $rs = $schema->resultset('Alert');
    my $subscriber = $rs->find({ externalid => $self->subscriptionid, borrowernumber => $patron->borrowernumber });
    $subscriber->delete if $subscriber;
}

=head3 type

=cut




    <span class="label">Subscription:</span> <a href="subscription-detail.pl?subscriptionid=[% subscriptionid %]">[% bibliotitle %] #[% subscriptionid %]</a>
</p>

[% IF subscribers.count %]
    <table>
        <tr>
            <th>Patron name</th>
        </tr>
        [% FOREACH subscriber IN subscribers %]
        <tr>
            [%# FIXME use patron-title when 18403 will be pushed %]
            <td><a href="/cgi-bin/koha/members/moremember.pl?borrowernumber=[% subscriber.borrowernumber %]">[% subscriber.firstname %] [% subscriber.surname %]</a></td>
        </tr>
        [% END %]
    </table>

Lines 834-842 Link Here

(-)a/koha-tmpl/opac-tmpl/bootstrap/en/modules/opac-detail.tt (-2 / +2 lines)
834	[% IF ( subscription.letter ) %]<span class="email_notifications">	834	[% IF ( subscription.letter ) %]<span class="email_notifications">
835	[% IF ( loggedinusername ) %]	835	[% IF ( loggedinusername ) %]
836	[% IF ( subscription.hasalert ) %]	836	[% IF ( subscription.hasalert ) %]
837	<span>You have subscribed to email notification on new issues. </span><a style="color:#000;" class="btn" title="Cancel email notification" href="/cgi-bin/koha/opac-alert-subscribe.pl?op=cancel&externalid=[% subscription.subscriptionid %]&biblionumber=[% subscription.biblionumber %]">Cancel email notification</a>	837	<span>You have subscribed to email notification on new issues. </span><a style="color:#000;" class="btn" title="Cancel email notification" href="/cgi-bin/koha/opac-alert-subscribe.pl?op=cancel&subscriptionid=[% subscription.subscriptionid %]&biblionumber=[% subscription.biblionumber %]">Cancel email notification</a>
838	[% ELSE %]	838	[% ELSE %]
839	<a style="color:#000;" class="btn" title="Subscribe to email notification on new issues" href="/cgi-bin/koha/opac-alert-subscribe.pl?externalid=[% subscription.subscriptionid %]&biblionumber=[% subscription.biblionumber %]">Subscribe to email notification on new issues</a>	839	<a style="color:#000;" class="btn" title="Subscribe to email notification on new issues" href="/cgi-bin/koha/opac-alert-subscribe.pl?subscriptionid=[% subscription.subscriptionid %]&biblionumber=[% subscription.biblionumber %]">Subscribe to email notification on new issues</a>
840	[% END %]	840	[% END %]
841	[% ELSE %]	841	[% ELSE %]
842	<span>You must log in if you want to subscribe to email notification on new issues</span>	842	<span>You must log in if you want to subscribe to email notification on new issues</span>

Lines 137-147 Link Here

(-)a/koha-tmpl/opac-tmpl/bootstrap/en/modules/opac-serial-issues.tt (-2 / +2 lines)
137	[% IF ( subscription_LOO.letter ) %]	137	[% IF ( subscription_LOO.letter ) %]
138	[% IF ( loggedinusername ) %]	138	[% IF ( loggedinusername ) %]
139	[% IF ( subscription_LOO.hasalert ) %]	139	[% IF ( subscription_LOO.hasalert ) %]
140	You have subscribed to email notification on new issues <a href="opac-alert-subscribe.pl?op=cancel&externalid=[% subscription_LOO.subscriptionid %]&referer=serial&biblionumber=[% subscription_LOO.biblionumber %]" class="btn" title="Cancel email notification">	140	You have subscribed to email notification on new issues <a href="opac-alert-subscribe.pl?op=cancel&subscriptionid=[% subscription_LOO.subscriptionid %]&referer=serial&biblionumber=[% subscription_LOO.biblionumber %]" class="btn" title="Cancel email notification">
141	Cancel email notification	141	Cancel email notification
142	</a>	142	</a>
143	[% ELSE %]	143	[% ELSE %]
144	<a href="opac-alert-subscribe.pl?externalid=[% subscription_LOO.subscriptionid %]&referer=serial&biblionumber=[% subscription_LOO.biblionumber %]" class="btn" title="Subscribe to email notification on new issues">	144	<a href="opac-alert-subscribe.pl?subscriptionid=[% subscription_LOO.subscriptionid %]&referer=serial&biblionumber=[% subscription_LOO.biblionumber %]" class="btn" title="Subscribe to email notification on new issues">
145	Subscribe to email notification on new issues	145	Subscribe to email notification on new issues
146	</a>	146	</a>
147	[% END %]	147	[% END %]

Lines 36-42 my $dbh = C4::Context->dbh; Link Here

(-)a/opac/opac-alert-subscribe.pl (-10 / +9 lines)
36		36
37	my $sth;	37	my $sth;
38	my ( $template, $loggedinuser, $cookie );	38	my ( $template, $loggedinuser, $cookie );
39	my $externalid = $query->param('externalid');	39	my $subscriptionid = $query->param('subscriptionid');
40	my $referer = $query->param('referer') \|\| 'detail';	40	my $referer = $query->param('referer') \|\| 'detail';
41	my $biblionumber = $query->param('biblionumber');	41	my $biblionumber = $query->param('biblionumber');
42		42
Lines 51-58 my $biblionumber = $query->param('biblionumber'); Link Here
51	}	51	}
52	);	52	);
53		53
		54	my $subscription = Koha::Subscriptions->find( $subscriptionid );
		55	my $logged_in_patron = Koha::Patrons->find( $loggedinuser );
		56
54	if ( $op eq 'alert_confirmed' ) {	57	if ( $op eq 'alert_confirmed' ) {
55	addalert( $loggedinuser, $externalid );	58	$subscription->add_subscriber( $logged_in_patron );
56	if ( $referer eq 'serial' ) {	59	if ( $referer eq 'serial' ) {
57	print $query->redirect(	60	print $query->redirect(
58	"opac-serial-issues.pl?biblionumber=$biblionumber");	61	"opac-serial-issues.pl?biblionumber=$biblionumber");
Lines 64-75 if ( $op eq 'alert_confirmed' ) { Link Here
64	}	67	}
65	}	68	}
66	elsif ( $op eq 'cancel_confirmed' ) {	69	elsif ( $op eq 'cancel_confirmed' ) {
67	my $alerts = getalert( $loggedinuser, $externalid );	70	$subscription->remove_subscriber( $logged_in_patron );
68	warn "CANCEL confirmed : $loggedinuser, $externalid".Data::Dumper::Dumper( $alerts );	71	warn "CANCEL confirmed : $loggedinuser, $subscriptionid";
69	foreach (@$alerts)
70	{ # we are supposed to have only 1 result, but just in case...
71	delalert( $_->{alertid} );
72	}
73	if ( $referer eq 'serial' ) {	72	if ( $referer eq 'serial' ) {
74	print $query->redirect(	73	print $query->redirect(
75	"opac-serial-issues.pl?biblionumber=$biblionumber");	74	"opac-serial-issues.pl?biblionumber=$biblionumber");
Lines 83-95 elsif ( $op eq 'cancel_confirmed' ) { Link Here
83		82
84	}	83	}
85	else {	84	else {
86	my $subscription = &GetSubscription($externalid);	85	my $subscription = &GetSubscription($subscriptionid);
87	$template->param(	86	$template->param(
88	referer => $referer,	87	referer => $referer,
89	"typeissue$op" => 1,	88	"typeissue$op" => 1,
90	bibliotitle => $subscription->{bibliotitle},	89	bibliotitle => $subscription->{bibliotitle},
91	notes => $subscription->{notes},	90	notes => $subscription->{notes},
92	externalid => $externalid,	91	subscriptionid => $subscriptionid,
93	biblionumber => $biblionumber,	92	biblionumber => $biblionumber,
94	);	93	);
95	}	94	}

Lines 589-598 foreach my $subscription (@subscriptions) { Link Here

(-)a/opac/opac-detail.pl (-4 / +3 lines)
589	$cell{latestserials} =	589	$cell{latestserials} =
590	GetLatestSerials( $subscription->{subscriptionid}, $serials_to_display );	590	GetLatestSerials( $subscription->{subscriptionid}, $serials_to_display );
591	if ( $borrowernumber ) {	591	if ( $borrowernumber ) {
592	my $sub = getalert($borrowernumber, $subscription->{subscriptionid});	592	my $subscription_object = Koha::Subscriptions->find( $subscription->{subscriptionid} );
593	if (@$sub[0]) {	593	my $subscriber = $subscription_object->subscribers->find( $borrowernumber );
594	$cell{hasalert} = 1;	594	$cell{hasalert} = 1 if $subscriber;
595	}
596	}	595	}
597	push @subs, \%cell;	596	push @subs, \%cell;
598	}	597	}




    # now, check is there is an alert subscription for one of the subscriptions
    if ($loggedinuser) {
        foreach (@$subscriptions) {
            my $subscription = Koha::Subscriptions->find( $_->{subscriptionid} );
            my $subscriber = $subscription->subscribers->find( $loggedinuser );
            $_->{hasalert} = 1 if $subscriber;
            }
        }
    }



    my $subscriptions = GetSubscriptionsFromBiblionumber($biblionumber);
    # now, check is there is an alert subscription for one of the subscriptions
    if ($loggedinuser) {
        foreach (@$subscriptions) {
            my $subscription = Koha::Subscriptions->find( $_->{subscriptionid} );
            my $subscriber = $subscription->subscribers->find( $loggedinuser );
            $_->{hasalert} = 1 if $subscriber;
            }
        }
    }





use C4::Auth;
use C4::Context;
use C4::Output;
use C4::Koha;
use C4::Letters;
use C4::Serials;

use Koha::Subscriptions;

my $input = new CGI;
my $print = $input->param('print');

my ($template, $loggedinuser, $cookie)
    = get_template_and_user({template_name => 'serials/viewalerts.tt',

                 debug => 1,
                 });

my $subscriptionid = $input->param('subscriptionid');

my $subscription = Koha::Subscriptions->find( $subscriptionid );
# FIXME raise a message if subscription does not exist (easy with 18403)

my $subscribers = $subscription->subscribers;

$template->param(
    subscribers    => $subscribers,
    bibliotitle    => $subscription->biblio->title,
    subscriptionid => $subscriptionid,
);
                subscriptionid => $subscriptionid,
                (uc(C4::Context->preference("marcflavour"))) => 1
                );

output_html_with_http_headers $input, $cookie, $template->output;





use Modern::Perl;

use Test::More tests => 3;

use Koha::Subscriptions;
use Koha::Biblio;

    })->store();

    my $b = $subscription->biblio;
    is($b->biblionumber, $biblio->biblionumber, 'Koha::Subscription->biblio returns the correct biblio');
};

subtest 'Notifications on new issues - add_subscriber|remove_subscriber|subscribers' => sub {
    plan tests => 5;
    my $subscriber_1 = $builder->build_object( { class => 'Koha::Patrons' });
    my $subscriber_2 = $builder->build_object( { class => 'Koha::Patrons' });

    my $subscription = Koha::Subscription->new({
        biblionumber => Koha::Biblio->new->store->biblionumber,
    })->store();

    my $subscribers = $subscription->subscribers;
    is( $subscribers->count, 0, '->subscribers should return 0 if there are no subscribers');
    is( ref($subscribers), 'Koha::Patrons', '->subscribers should return a Koha::Patrons object');

    $subscription->add_subscriber( $subscriber_1 );
    $subscription->add_subscriber( $subscriber_2 );

    $subscribers = $subscription->subscribers;
    is( $subscribers->count, 2, '->subscribers should return 2 if there are 2 subscribers' );

    $subscription->remove_subscriber( $subscriber_1 );

    $subscribers = $subscription->subscribers;
    is( $subscribers->count, 1, '->remove_subscriber should have remove the subscriber' );

    $subscription->remove_subscriber( $subscriber_1 ); # We do not explode if the patron is not a subscriber

    my $is_subscriber = $subscribers->find( $subscriber_2->borrowernumber );
    ok( $is_subscriber, 'This structure is used in the code and should work as expected' );

};

subtest 'Koha::Subscription->vendor' => sub {

Lines 18-24 Link Here

(-)a/t/db_dependent/Letters.t (-39 / +5 lines)
18	# along with Koha; if not, see <http://www.gnu.org/licenses>.	18	# along with Koha; if not, see <http://www.gnu.org/licenses>.
19		19
20	use Modern::Perl;	20	use Modern::Perl;
21	use Test::More tests => 75;	21	use Test::More tests => 64;
22	use Test::MockModule;	22	use Test::MockModule;
23	use Test::Warn;	23	use Test::Warn;
24		24
Lines 48-53 use Koha::Acquisition::Bookseller::Contacts; Link Here
48	use Koha::Acquisition::Orders;	48	use Koha::Acquisition::Orders;
49	use Koha::Libraries;	49	use Koha::Libraries;
50	use Koha::Notice::Templates;	50	use Koha::Notice::Templates;
		51	use Koha::Patrons;
		52	use Koha::Subscriptions;
51	my $schema = Koha::Database->schema;	53	my $schema = Koha::Database->schema;
52	$schema->storage->txn_begin();	54	$schema->storage->txn_begin();
53		55
Lines 236-276 my $branchcode = 'FFL'; Link Here
236	my $letter14206_c = C4::Letters::getletter('my module', $overdue_rules->{"letter$i"}, $branchcode);	238	my $letter14206_c = C4::Letters::getletter('my module', $overdue_rules->{"letter$i"}, $branchcode);
237	is( $letter14206_c->{message_transport_type}, 'print', 'Bug 14206 - correct mtt detected for call from overdue_notices.pl' );	239	is( $letter14206_c->{message_transport_type}, 'print', 'Bug 14206 - correct mtt detected for call from overdue_notices.pl' );
238		240
239	# addalert
240	my $externalid = 'my external id';
241	my $alert_id = C4::Letters::addalert($borrowernumber, $externalid);
242	isnt( $alert_id, undef, 'addalert does not return undef' );
243
244
245	# getalert
246	my $alerts = C4::Letters::getalert();
247	is( @$alerts, 1, 'getalert should not fail without parameter' );
248	$alerts = C4::Letters::getalert($borrowernumber);
249	is( @$alerts, 1, 'addalert adds an alert' );
250	is( $alerts->[0]->{alertid}, $alert_id, 'addalert returns the alert id correctly' );
251	is( $alerts->[0]->{externalid}, $externalid, 'addalert stores the externalid correctly' );
252
253	$alerts = C4::Letters::getalert($borrowernumber);
254	is( @$alerts, 1, 'getalert returns the correct number of alerts' );
255	$alerts = C4::Letters::getalert($borrowernumber, $externalid);
256	is( @$alerts, 1, 'getalert returns the correct number of alerts' );
257	$alerts = C4::Letters::getalert($borrowernumber, 'another external id');
258	is( @$alerts, 0, 'getalert returns the correct number of alerts' );
259
260
261	# delalert
262	eval {
263	C4::Letters::delalert();
264	};
265	isnt( $@, undef, 'delalert without argument returns an error' );
266	$alerts = C4::Letters::getalert($borrowernumber);
267	is( @$alerts, 1, 'delalert without argument does not remove an alert' );
268
269	C4::Letters::delalert($alert_id);
270	$alerts = C4::Letters::getalert($borrowernumber);
271	is( @$alerts, 0, 'delalert removes an alert' );
272
273
274	# GetPreparedLetter	241	# GetPreparedLetter
275	t::lib::Mocks::mock_preference('OPACBaseURL', 'http://thisisatest.com');	242	t::lib::Mocks::mock_preference('OPACBaseURL', 'http://thisisatest.com');
276		243
Lines 509-516 my $borrowernumber = AddMember( Link Here
509	dateofbirth => $date,	476	dateofbirth => $date,
510	email => 'john.smith@test.de',	477	email => 'john.smith@test.de',
511	);	478	);
512	my $alert_id = C4::Letters::addalert($borrowernumber, $subscriptionid);	479	my $subscription = Koha::Subscriptions->find( $subscriptionid );
513		480	$subscription->add_subscriber( scalar Koha::Patrons->find( $borrowernumber ) );
514		481
515	my $err2;	482	my $err2;
516	warning_is {	483	warning_is {
517	-

Return to bug 19855

Lines 39-44 use Koha::Email; Link Here

(-)a/C4/Letters.pm (-73 / +8 lines)
39	use Koha::Notice::Messages;	39	use Koha::Notice::Messages;
40	use Koha::DateUtils qw( format_sqldatetime dt_from_string );	40	use Koha::DateUtils qw( format_sqldatetime dt_from_string );
41	use Koha::Patrons;	41	use Koha::Patrons;
		42	use Koha::Subscriptions;
42		43
43	use vars qw(@ISA @EXPORT @EXPORT_OK %EXPORT_TAGS);	44	use vars qw(@ISA @EXPORT @EXPORT_OK %EXPORT_TAGS);
44		45
Lines 46-52 BEGIN { Link Here
46	require Exporter;	47	require Exporter;
47	@ISA = qw(Exporter);	48	@ISA = qw(Exporter);
48	@EXPORT = qw(	49	@EXPORT = qw(
49	&GetLetters &GetLettersAvailableForALibrary &GetLetterTemplates &DelLetter &GetPreparedLetter &GetWrappedLetter &addalert &getalert &delalert &SendAlerts &GetPrintMessages &GetMessageTransportTypes	50	&GetLetters &GetLettersAvailableForALibrary &GetLetterTemplates &DelLetter &GetPreparedLetter &GetWrappedLetter &SendAlerts &GetPrintMessages &GetMessageTransportTypes
50	);	51	);
51	}	52	}
52		53
Lines 266-336 sub DelLetter { Link Here
266	, undef, $branchcode, $module, $code, ( $mtt ? $mtt : () ), ( $lang ? $lang : () ) );	267	, undef, $branchcode, $module, $code, ( $mtt ? $mtt : () ), ( $lang ? $lang : () ) );
267	}	268	}
268		269
269	=head2 addalert ($borrowernumber, $subscriptionid)
270
271	parameters :
272	- $borrowernumber : the number of the borrower subscribing to the alert
273	- $subscriptionid
274
275	create an alert and return the alertid (primary key)
276
277	=cut
278
279	sub addalert {
280	my ( $borrowernumber, $subscriptionid) = @_;
281	my $dbh = C4::Context->dbh;
282	my $sth =
283	$dbh->prepare(
284	"insert into alert (borrowernumber, externalid) values (?,?)");
285	$sth->execute( $borrowernumber, $subscriptionid );
286
287	# get the alert number newly created and return it
288	my $alertid = $dbh->{'mysql_insertid'};
289	return $alertid;
290	}
291
292	=head2 delalert ($alertid)
293
294	parameters :
295	- alertid : the alert id
296	deletes the alert
297
298	=cut
299
300	sub delalert {
301	my $alertid = shift or die "delalert() called without valid argument (alertid)"; # it's gonna die anyway.
302	$debug and warn "delalert: deleting alertid $alertid";
303	my $sth = C4::Context->dbh->prepare("delete from alert where alertid=?");
304	$sth->execute($alertid);
305	}
306
307	=head2 getalert ([$borrowernumber], [$subscriptionid])
308
309	parameters :
310	- $borrowernumber : the number of the borrower subscribing to the alert
311	- $subscriptionid
312	all parameters NON mandatory. If a parameter is omitted, the query is done without the corresponding parameter. For example, without $subscriptionid, returns all alerts for a borrower on a topic.
313
314	=cut
315
316	sub getalert {
317	my ( $borrowernumber, $subscriptionid ) = @_;
318	my $dbh = C4::Context->dbh;
319	my $query = "SELECT a.*, b.branchcode FROM alert a JOIN borrowers b USING(borrowernumber) WHERE 1";
320	my @bind;
321	if ($borrowernumber and $borrowernumber =~ /^\d+$/) {
322	$query .= " AND borrowernumber=?";
323	push @bind, $borrowernumber;
324	}
325	if ($subscriptionid) {
326	$query .= " AND externalid=?";
327	push @bind, $subscriptionid;
328	}
329	my $sth = $dbh->prepare($query);
330	$sth->execute(@bind);
331	return $sth->fetchall_arrayref({});
332	}
333
334	=head2 SendAlerts	270	=head2 SendAlerts
335		271
336	my $err = &SendAlerts($type, $externalid, $letter_code);	272	my $err = &SendAlerts($type, $externalid, $letter_code);
Lines 379-400 sub SendAlerts { Link Here
379	return;	315	return;
380		316
381	my %letter;	317	my %letter;
382	# find the list of borrowers to alert	318	# find the list of subscribers to notify
383	my $alerts = getalert( '', $subscriptionid );	319	my $subscription = Koha::Subscriptions->find( $subscriptionid );
384	foreach (@$alerts) {	320	my $subscribers = $subscription->subscribers;
385	my $patron = Koha::Patrons->find( $_->{borrowernumber} );	321	while ( my $patron = $subscribers->next ) {
386	next unless $patron; # Just in case
387	my $email = $patron->email or next;	322	my $email = $patron->email or next;
388		323
389	# warn "sending issues...";	324	# warn "sending issues...";
390	my $userenv = C4::Context->userenv;	325	my $userenv = C4::Context->userenv;
391	my $library = Koha::Libraries->find( $_->{branchcode} );	326	my $library = $patron->library;
392	my $letter = GetPreparedLetter (	327	my $letter = GetPreparedLetter (
393	module => 'serial',	328	module => 'serial',
394	letter_code => $letter_code,	329	letter_code => $letter_code,
395	branchcode => $userenv->{branch},	330	branchcode => $userenv->{branch},
396	tables => {	331	tables => {
397	'branches' => $_->{branchcode},	332	'branches' => $library->branchcode,
398	'biblio' => $biblionumber,	333	'biblio' => $biblionumber,
399	'biblioitems' => $biblionumber,	334	'biblioitems' => $biblionumber,
400	'borrowers' => $patron->unblessed,	335	'borrowers' => $patron->unblessed,

Lines 60-65 sub vendor { Link Here

(-)a/Koha/Subscription.pm (+46 lines)
60	return scalar Koha::Acquisition::Booksellers->find($self->aqbooksellerid);	60	return scalar Koha::Acquisition::Booksellers->find($self->aqbooksellerid);
61	}	61	}
62		62
		63	=head3 subscribers
		64
		65	my $subscribers = $subscription->subscribers;
		66
		67	return a Koha::Patrons object
		68
		69	=cut
		70
		71	sub subscribers {
		72	my ($self) = @_;
		73	my $schema = Koha::Database->new->schema;
		74	my @borrowernumbers = $schema->resultset('Alert')->search({ externalid => $self->subscriptionid })->get_column( 'borrowernumber' )->all;
		75	return Koha::Patrons->search({ borrowernumber => {-in => \@borrowernumbers } });
		76	}
		77
		78	=head3 add_subscriber
		79
		80	$subscription->add_subscriber( $patron );
		81
		82	Add a new subscriber (Koha::Patron) to this subscription
		83
		84	=cut
		85
		86	sub add_subscriber {
		87	my ( $self, $patron ) = @_;
		88	my $schema = Koha::Database->new->schema;
		89	my $rs = $schema->resultset('Alert');
		90	$rs->create({ externalid => $self->subscriptionid, borrowernumber => $patron->borrowernumber });
		91	}
		92
		93	=head3 remove_subscriber
		94
		95	$subscription->remove_subscriber( $subscriber );
		96
		97	Remove a subscriber (Koha::Patron) from this subscription
		98
		99	=cut
		100
		101	sub remove_subscriber {
		102	my ($self, $patron) = @_;
		103	my $schema = Koha::Database->new->schema;
		104	my $rs = $schema->resultset('Alert');
		105	my $subscriber = $rs->find({ externalid => $self->subscriptionid, borrowernumber => $patron->borrowernumber });
		106	$subscriber->delete if $subscriber;
		107	}
		108
63	=head3 type	109	=head3 type
64		110
65	=cut	111	=cut

Lines 19-32 Link Here

(-)a/koha-tmpl/intranet-tmpl/prog/en/modules/serials/viewalerts.tt (-3 / +4 lines)
19	<span class="label">Subscription:</span> <a href="subscription-detail.pl?subscriptionid=[% subscriptionid %]">[% bibliotitle %] #[% subscriptionid %]</a>	19	<span class="label">Subscription:</span> <a href="subscription-detail.pl?subscriptionid=[% subscriptionid %]">[% bibliotitle %] #[% subscriptionid %]</a>
20	</p>	20	</p>
21		21
22	[% IF ( alertloop ) %]	22	[% IF subscribers.count %]
23	<table>	23	<table>
24	<tr>	24	<tr>
25	<th>Patron name</th>	25	<th>Patron name</th>
26	</tr>	26	</tr>
27	[% FOREACH alertloo IN alertloop %]	27	[% FOREACH subscriber IN subscribers %]
28	<tr>	28	<tr>
29	<td><a href="/cgi-bin/koha/members/moremember.pl?borrowernumber=[% alertloo.borrowernumber %]">[% alertloo.name %]</a></td>	29	[%# FIXME use patron-title when 18403 will be pushed %]
		30	<td><a href="/cgi-bin/koha/members/moremember.pl?borrowernumber=[% subscriber.borrowernumber %]">[% subscriber.firstname %] [% subscriber.surname %]</a></td>
30	</tr>	31	</tr>
31	[% END %]	32	[% END %]
32	</table>	33	</table>

Lines 24-30 Link Here

(-)a/koha-tmpl/opac-tmpl/bootstrap/en/modules/opac-alert-subscribe.tt (-2 / +2 lines)
24	<p>Do you want to receive an email when a new issue for this subscription arrives?</p>	24	<p>Do you want to receive an email when a new issue for this subscription arrives?</p>
25	<h4>[% bibliotitle %]</h4>	25	<h4>[% bibliotitle %]</h4>
26	[% IF ( notes ) %]<p>[% notes %]</p>[% END %]	26	[% IF ( notes ) %]<p>[% notes %]</p>[% END %]
27	<input type="hidden" name="externalid" value="[% externalid %]">	27	<input type="hidden" name="subscriptionid" value="[% subscriptionid %]">
28	<input type="hidden" name="referer" value="[% referer %]">	28	<input type="hidden" name="referer" value="[% referer %]">
29	<input type="hidden" name="biblionumber" value="[% biblionumber \| html %]">	29	<input type="hidden" name="biblionumber" value="[% biblionumber \| html %]">
30	<input type="hidden" name="op" value="alert_confirmed">	30	<input type="hidden" name="op" value="alert_confirmed">
Lines 38-44 Link Here
38	<p>Please confirm that you do not want to receive email when a new issue arrives for this subscription.</p>	38	<p>Please confirm that you do not want to receive email when a new issue arrives for this subscription.</p>
39	<h4>[% bibliotitle %]</h4>	39	<h4>[% bibliotitle %]</h4>
40	[% IF ( notes ) %]<p>[% notes %]</p>[% END %]	40	[% IF ( notes ) %]<p>[% notes %]</p>[% END %]
41	<input type="hidden" name="externalid" value="[% externalid %]">	41	<input type="hidden" name="subscriptionid" value="[% subscriptionid %]">
42	<input type="hidden" name="referer" value="[% referer %]">	42	<input type="hidden" name="referer" value="[% referer %]">
43	<input type="hidden" name="biblionumber" value="[% biblionumber \| html %]">	43	<input type="hidden" name="biblionumber" value="[% biblionumber \| html %]">
44	<input type="hidden" name="op" value="cancel_confirmed">	44	<input type="hidden" name="op" value="cancel_confirmed">

Lines 62-71 if ( $selectview eq "full" ) { Link Here

(-)a/opac/opac-serial-issues.pl (-9 / +7 lines)
62	# now, check is there is an alert subscription for one of the subscriptions	62	# now, check is there is an alert subscription for one of the subscriptions
63	if ($loggedinuser) {	63	if ($loggedinuser) {
64	foreach (@$subscriptions) {	64	foreach (@$subscriptions) {
65	my $sub = getalert($loggedinuser, $_->{subscriptionid});	65	my $subscription = Koha::Subscriptions->find( $_->{subscriptionid} );
66	if ($sub) {	66	my $subscriber = $subscription->subscribers->find( $loggedinuser );
67	$_->{hasalert} = 1;	67	$_->{hasalert} = 1 if $subscriber;
68	}
69	}	68	}
70	}	69	}
71		70
Lines 100-111 else { Link Here
100		99
101	my $subscriptions = GetSubscriptionsFromBiblionumber($biblionumber);	100	my $subscriptions = GetSubscriptionsFromBiblionumber($biblionumber);
102	# now, check is there is an alert subscription for one of the subscriptions	101	# now, check is there is an alert subscription for one of the subscriptions
103	if ($loggedinuser){	102	if ($loggedinuser) {
104	foreach (@$subscriptions) {	103	foreach (@$subscriptions) {
105	my $subscription = getalert($loggedinuser, $_->{subscriptionid});	104	my $subscription = Koha::Subscriptions->find( $_->{subscriptionid} );
106	if (@$subscription[0]) {	105	my $subscriber = $subscription->subscribers->find( $loggedinuser );
107	$_->{hasalert} = 1;	106	$_->{hasalert} = 1 if $subscriber;
108	}
109	}	107	}
110	}	108	}
111		109

Lines 23-36 use CGI qw ( -utf8 ); Link Here

(-)a/serials/viewalerts.pl (-20 / +13 lines)
23	use C4::Auth;	23	use C4::Auth;
24	use C4::Context;	24	use C4::Context;
25	use C4::Output;	25	use C4::Output;
26	use C4::Koha;
27	use C4::Letters;
28	use C4::Serials;
29		26
30	my $dbh = C4::Context->dbh;	27	use Koha::Subscriptions;
31		28
32	my $input = new CGI;	29	my $input = new CGI;
33	my $print = $input->param('print');
34		30
35	my ($template, $loggedinuser, $cookie)	31	my ($template, $loggedinuser, $cookie)
36	= get_template_and_user({template_name => 'serials/viewalerts.tt',	32	= get_template_and_user({template_name => 'serials/viewalerts.tt',
Lines 41-60 my ($template, $loggedinuser, $cookie) Link Here
41	debug => 1,	37	debug => 1,
42	});	38	});
43		39
44	my $subscriptionid=$input->param('subscriptionid');	40	my $subscriptionid = $input->param('subscriptionid');
45		41
46	my $borrowers = getalert('', $subscriptionid);	42	my $subscription = Koha::Subscriptions->find( $subscriptionid );
47	my $subscription = GetSubscription($subscriptionid);	43	# FIXME raise a message if subscription does not exist (easy with 18403)
48		44
49	for my $borrowernumber (@$borrowers) {	45	my $subscribers = $subscription->subscribers;
50	my $patron = Koha::Patrons->find( $borrowernumber );	46
51	next unless $borrowernumber; # Just in case...	47	$template->param(
52	$borrowers->{name} = join( ' ', $patron->firstname, $patron->surname );	48	subscribers => $subscribers,
53	}	49	bibliotitle => $subscription->biblio->title,
54	$template->param(alertloop => $borrowers,	50	subscriptionid => $subscriptionid,
55	bibliotitle => $subscription->{bibliotitle},	51	);
56	subscriptionid => $subscriptionid,
57	(uc(C4::Context->preference("marcflavour"))) => 1
58	);
59		52
60	output_html_with_http_headers $input, $cookie, $template->output;	53	output_html_with_http_headers $input, $cookie, $template->output;

Lines 19-25 Link Here

(-)a/t/db_dependent/Koha/Subscription.t (-2 / +33 lines)
19		19
20	use Modern::Perl;	20	use Modern::Perl;
21		21
22	use Test::More tests => 2;	22	use Test::More tests => 3;
23		23
24	use Koha::Subscriptions;	24	use Koha::Subscriptions;
25	use Koha::Biblio;	25	use Koha::Biblio;
Lines 40-46 subtest 'Koha::Subscription->biblio' => sub { Link Here
40	})->store();	40	})->store();
41		41
42	my $b = $subscription->biblio;	42	my $b = $subscription->biblio;
43	is($b->biblionumber, $biblio->biblionumber, 'Koha::Subscription::biblio returns the correct biblio');	43	is($b->biblionumber, $biblio->biblionumber, 'Koha::Subscription->biblio returns the correct biblio');
		44	};
		45
		46	subtest 'Notifications on new issues - add_subscriber\|remove_subscriber\|subscribers' => sub {
		47	plan tests => 5;
		48	my $subscriber_1 = $builder->build_object( { class => 'Koha::Patrons' });
		49	my $subscriber_2 = $builder->build_object( { class => 'Koha::Patrons' });
		50
		51	my $subscription = Koha::Subscription->new({
		52	biblionumber => Koha::Biblio->new->store->biblionumber,
		53	})->store();
		54
		55	my $subscribers = $subscription->subscribers;
		56	is( $subscribers->count, 0, '->subscribers should return 0 if there are no subscribers');
		57	is( ref($subscribers), 'Koha::Patrons', '->subscribers should return a Koha::Patrons object');
		58
		59	$subscription->add_subscriber( $subscriber_1 );
		60	$subscription->add_subscriber( $subscriber_2 );
		61
		62	$subscribers = $subscription->subscribers;
		63	is( $subscribers->count, 2, '->subscribers should return 2 if there are 2 subscribers' );
		64
		65	$subscription->remove_subscriber( $subscriber_1 );
		66
		67	$subscribers = $subscription->subscribers;
		68	is( $subscribers->count, 1, '->remove_subscriber should have remove the subscriber' );
		69
		70	$subscription->remove_subscriber( $subscriber_1 ); # We do not explode if the patron is not a subscriber
		71
		72	my $is_subscriber = $subscribers->find( $subscriber_2->borrowernumber );
		73	ok( $is_subscriber, 'This structure is used in the code and should work as expected' );
		74
44	};	75	};
45		76
46	subtest 'Koha::Subscription->vendor' => sub {	77	subtest 'Koha::Subscription->vendor' => sub {