This commit was generated by cvs2svn to compensate for changes in r11022,
[freeside.git] / FS / FS / otaker_Mixin.pm
1 package FS::otaker_Mixin;
2
3 use strict;
4 use Carp qw( croak ); #confess );
5 use FS::Record qw( qsearch qsearchs );
6 use FS::access_user;
7 use FS::UID qw( dbh );
8
9 sub otaker {
10   my $self = shift;
11   if ( scalar(@_) ) { #set
12     my $otaker = shift;
13     my $access_user = qsearchs('access_user', { 'username' => $otaker } );
14     if ( !$access_user && $otaker =~ /^(.+), (.+)$/ ) { #same as below..
15       my($lastname, $firstname) = ($1, $2);
16       $otaker = lc($firstname.$lastname);
17       $otaker =~ s/ //g;
18       $access_user =  qsearchs('access_user', { 'first' => $firstname, 
19                                                 'last'  => $lastname  } )
20                    || qsearchs('access_user', { 'username' => $otaker } );
21     }
22     croak "can't set otaker: $otaker not found!" unless $access_user; #confess?
23     $self->usernum( $access_user->usernum );
24     $otaker; #not sure return is used anywhere, but just in case
25   } else { #get
26     if ( $self->usernum ) {
27       $self->access_user->username;
28     } elsif ( length($self->get('otaker')) ) {
29       $self->get('otaker');
30     } else {
31       '';
32     }
33   }
34 }
35
36 sub access_user {
37   my $self = shift;
38   qsearchs('access_user', { 'usernum' => $self->usernum } );
39 }
40
41 sub _upgrade_otaker {
42   my $class = shift;
43   my $table = $class->table;
44
45   my $limit = ( $table eq 'cust_attachment' ? 10 : 1000 );
46
47   while ( 1 ) {
48     my @records = qsearch({
49                     'table'     => $table,
50                     'hashref'   => {},
51                     'extra_sql' => "WHERE otaker IS NOT NULL LIMIT $limit",
52                   });
53     last unless @records;
54
55     foreach my $record (@records) {
56       eval { $record->otaker($record->otaker) };
57       if ( $@ ) {
58         my $username = $record->otaker;
59         my($lastname, $firstname) = ( 'User', 'Legacy' );
60         if ( $username =~ /^(.+), (.+)$/ ) {
61           ($lastname, $firstname) = ($1, $2);
62           $username = lc($firstname.$lastname);
63           $username =~ s/ //g;
64         }
65         my $access_user = new FS::access_user {
66           'username'  => $username,
67           '_password' => 'CHANGEME',
68           'first'     => $firstname,
69           'last'      => $lastname,
70           'disabled'  => 'Y',
71         };
72         my $error = $access_user->insert;
73         die $error if $error;
74         $record->otaker($record->otaker);
75       }
76       $record->set('otaker', '');
77       my $error = $record->replace;
78       die $error if $error;
79     }
80         
81     if ( $table eq 'cust_attachment' ) {
82         warn "  committing (cust_attachment) \n";
83         dbh->commit or die dbh->errstr;
84     }
85
86   }
87
88 }
89
90 1;