modify schema for new CPE stats

[APKPM.git] / lib / APKPM / CRM.pm

diff --git a/lib/APKPM/CRM.pm b/lib/APKPM/CRM.pm
index 6f75a37..1643c9b 100644 (file)
--- a/lib/APKPM/CRM.pm
+++ b/lib/APKPM/CRM.pm
@@ -10,8 +10,9 @@ with 'APKPM::Gearman';
 
 require RPC::XML;
 require RPC::XML::Client;
+use Encode;
 
-$RPC::XML::ENCODING = "utf-8"; # FIXME really used?
+#$RPC::XML::ENCODING = "utf-8"; # FIXME really used?
 
 sub prefix { 'CRM_' }
 
@@ -26,7 +27,7 @@ sub begin {
        warn "# begin ", dump( $workload );
 }
 
-sub search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub search : Job : Encode(e_json_encode) {
        my ( $self, $job, $workload ) = @_;
        warn "# search ",dump($workload);
 
@@ -40,4 +41,12 @@ sub search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
        return ref $resp ? $resp->value->[0] : { error => $resp };
 }
 
+sub e_json_encode {
+       my ($self,$data) = @_;
+       my $json = $self->e_json($data);
+       $json = Encode::decode('utf-8', $json);
+       Encode::from_to($json,'cp1250', 'utf-8');
+       return $json;
+}
+
 1;