1 package OpenILS::Application::Actor::Stage;
2 use strict; use warnings;
3 use base 'OpenILS::Application';
4 use OpenILS::Application::AppUtils;
5 use OpenILS::Utils::CStoreEditor q/:funcs/;
6 use OpenSRF::Utils::Logger q/$logger/;
7 use OpenILS::Utils::Fieldmapper;
8 my $U = "OpenILS::Application::AppUtils";
11 __PACKAGE__->register_method (
12 method => 'create_user_stage',
13 api_name => 'open-ils.actor.user.stage.create',
16 Creates a new pending user account including addresses and statcats.
17 Users are added to staging tables pending staff review.
20 {desc => 'user', type => 'object', class => 'stgu'},
21 {desc => 'Mailing address. Optional', type => 'object', class => 'stgma'},
22 {desc => 'Billing address. Optional', type => 'object', class => 'stgba'},
23 {desc => 'Statcats. Optional. This is an array of "stgsc" objects', type => 'array'},
26 desc => 'username on success, Event on error',
33 sub create_user_stage {
34 my($self, $conn, $user, $mail_addr, $bill_addr, $statcats) = @_; # more?
36 return OpenILS::Event->new('BAD_PARAMS') unless $user;
37 return 0 unless $U->ou_ancestor_setting_value($user->home_ou, 'opac.allow_pending_user');
39 my $e = new_editor(xact => 1);
41 my $uname = $user->usrname || $U->create_uuid_string;
42 $user->usrname($uname);
44 # see if this username is already taken
45 return OpenILS::Event->new('USERNAME_EXISTS') if
46 $e->search_staging_user_stage({usrname => $uname})->[0];
48 $e->create_staging_user_stage($user) or return $e->die_event;
51 $mail_addr->usrname($uname);
52 $e->create_staging_mailing_address_stage($mail_addr) or return $e->die_event;
56 $bill_addr->usrname($uname);
57 $e->create_staging_billing_address_stage($bill_addr) or return $e->die_event;
61 foreach (@$statcats) {
63 $e->create_staging_statcat_stage($_) or return $e->die_event;
68 $conn->respond_complete($uname);
70 $U->create_events_for_hook('stgu.create', $user, $user->home_ou);
74 __PACKAGE__->register_method (
75 method => 'user_stage_by_org',
76 api_name => 'open-ils.actor.user.stage.retrieve.by_org',
80 sub user_stage_by_org {
81 my($self, $conn, $auth, $org_id, $limit, $offset) = @_;
83 my $e = new_editor(authtoken => $auth);
84 return $e->event unless $e->checkauth;
85 $org_id ||= $e->requestor->ws_ou;
86 return $e->event unless $e->allowed('VIEW_USER', $org_id);
91 my $stage_ids = $e->search_staging_user_stage(
93 { home_ou => $org_id, complete => 'f'},
96 order_by => {stgu => 'row_id'}
102 $conn->respond(flesh_user_stage($e, $_)) for @$stage_ids;
106 sub flesh_user_stage {
107 my($e, $row_id) = @_;
108 my $user = $e->retrieve_staging_user_stage($row_id) or return undef;
111 billing_addresses => $e->search_staging_billing_address_stage({usrname => $user->usrname}),
112 mailing_addresses => $e->search_staging_mailing_address_stage({usrname => $user->usrname}),
113 cards => $e->search_staging_card_stage({usrname => $user->usrname}),
114 statcats => $e->search_staging_statcat_stage({usrname => $user->usrname})
119 __PACKAGE__->register_method (
120 method => 'user_stage_by_uname',
121 api_name => 'open-ils.actor.user.stage.retrieve.by_username',
124 sub user_stage_by_uname {
125 my($self, $conn, $auth, $username) = @_;
127 my $e = new_editor(authtoken => $auth);
128 return $e->event unless $e->checkauth;
130 my $user = $e->search_staging_user_stage({
131 usrname => $username,
133 })->[0] or return $e->event;
135 return $e->event unless $e->allowed('VIEW_USER', $user->home_ou);
136 return flesh_user_stage($e, $user->row_id);
142 __PACKAGE__->register_method (
143 method => 'delete_user_stage',
144 api_name => 'open-ils.actor.user.stage.delete',
147 sub delete_user_stage {
148 my($self, $conn, $auth, $row_id) = @_;
150 my $e = new_editor(authtoken => $auth, xact => 1);
151 return $e->die_event unless $e->checkauth;
152 my $data = flesh_user_stage($e, $row_id) or return $e->die_event;
154 return $e->die_event unless $e->allowed('UPDATE_USER', $data->{user}->home_ou);
156 $e->delete_staging_user_stage($data->{user}) or return $e->die_event;
158 for my $addr (@{$data->{mailing_addresses}}) {
159 $e->delete_staging_mailing_address_stage($addr) or return $e->die_event;
162 for my $addr (@{$data->{billing_addresses}}) {
163 $e->delete_staging_billing_address_stage($addr) or return $e->die_event;
166 for my $card (@{$data->{cards}}) {
167 $e->delete_staging_card_stage($card) or return $e->die_event;
170 for my $statcat (@{$data->{statcats}}) {
171 $e->delete_staging_statcat_stage($statcat) or return $e->die_event;