lib/APKPM/CRM.pm

   1 package APKPM::CRM;
   2
   3 use base qw(Gearman::Driver::Worker);
   4 use Moose;
   5 use Time::HiRes;
   6 use Data::Dump qw(dump);
   7
   8 with 'APKPM::Config';
   9 with 'APKPM::Gearman';
  10
  11 require RPC::XML;
  12 require RPC::XML::Client;
  13 use Encode;
  14
  15 #$RPC::XML::ENCODING = "utf-8"; # FIXME really used?
  16
  17 sub prefix { 'CRM_' }
  18
  19 sub process_name {
  20         my ( $self, $orig, $job_name ) = @_;
  21         warn "# process_name $orig $job_name\n";
  22         return "$orig ($job_name)";
  23 }
  24
  25 sub begin {
  26         my ( $self, $job, $workload ) = @_;
  27         warn "# begin ", dump( $workload );
  28 }
  29
  30 sub search : Job : Encode(e_json_encode) {
  31         my ( $self, $job, $workload ) = @_;
  32         warn "# search ",dump($workload);
  33
  34         my $field = 'USERNAME';
  35         my $value = '%' . $workload . '%';
  36         ($field,$value) = split(/[:=]/,$workload,2) if $workload =~ m/[:=]/;
  37
  38         my $cli = RPC::XML::Client->new($self->config('crmxml'));
  39         warn "RPC::XML $field $value";
  40         my $resp = $cli->send_request('search',RPC::XML::array->new( $field => $value ));
  41         return ref $resp ? $resp->value->[0] : { error => $resp };
  42 }
  43
  44 sub e_json_encode {
  45         my ($self,$data) = @_;
  46         my $json = $self->e_json($data);
  47         $json = Encode::decode('utf-8', $json);
  48         Encode::from_to($json,'cp1250', 'utf-8');
  49         return $json;
  50 }
  51
  52 1;