File Coverage

blib/lib/Mojo/Weixin/Message/Remote/_send_media_message.pm
Criterion Covered Total %
statement 6 48 12.5
branch 0 26 0.0
condition 0 17 0.0
subroutine 2 6 33.3
pod n/a
total 8 97 8.2


line stmt bran cond sub pod time code
1 1     1   7 use strict;
  1         2  
  1         33  
2 1     1   7 use Mojo::Weixin::Const ();
  1         2  
  1         738  
3             sub Mojo::Weixin::_send_media_message {
4 0     0     my $self = shift;
5 0           my $msg = shift;
6 0 0 0       if($msg->format ne "media" or (!defined $msg->media_path and !defined $msg->media_id) ){
      0        
7 0           $self->error("无效的 media msg");
8 0           return;
9             }
10             my $callback = sub{
11 0     0     my $json = shift;
12 0           $msg->_parse_send_status_data($json);
13 0 0 0       if(!$msg->is_success and $msg->ttl > 0){
14 0           $self->debug("消息[ " . $msg->id . " ]发送失败,尝试重新发送,当前TTL: " . $msg->ttl);
15 0           $self->message_queue->put($msg);
16 0           return;
17             }
18             else{
19 0 0         if(ref $msg->cb eq 'CODE'){
20 0           $msg->cb->($self, $msg);
21             }
22 0           $self->emit(send_media => $msg->media_path,$msg->media_data,$msg);
23 0           $self->emit(send_message => $msg);
24             }
25 0           };
26             $self->steps(
27             sub{
28 0     0     my $delay = shift;
29 0 0         defined $msg->media_id ? $delay->begin(0)->($msg): $self->_upload_media($msg,$delay->begin(0,));
30             },
31             sub{
32 0     0     my($delay,$msg,$error) = @_;
33 0 0 0       if(!defined $msg->media_id or $error){
34 0           $msg->send_status(code=>-1,msg=>"发送失败",info=>$error);
35 0 0         if(ref $msg->cb eq 'CODE'){
36 0           $msg->cb->($self, $msg);
37             }
38 0           $self->emit(send_message => $msg);
39 0           return;
40             }
41 0           my $api;
42 0 0         my @query_string = (
43             fun => 'async',
44             f => 'json',
45             $self->pass_ticket?(pass_ticket => $self->url_escape($self->pass_ticket)):()
46             );
47             my $post = {
48             BaseRequest => {
49             DeviceID => $self->deviceid,
50             Sid => $self->wxsid,
51             Skey => $self->skey,
52             Uin => $self->wxuin,
53             },
54             Msg => {
55             ClientMsgId => $msg->uid,
56             FromUserName => $msg->sender_id,
57             MediaId => (split ":",$msg->media_id)[0],
58             LocalID => $msg->uid,
59             ToUserName => ($msg->type eq "group_message"?$msg->group_id:$msg->receiver_id),
60             #Type => $Mojo::Weixin::Const::KEY_MAP_MEDIA_CODE{$msg->media_type} || 6,
61 0 0 0       Type => $msg->media_code || $Mojo::Weixin::Const::KEY_MAP_MEDIA_CODE{$msg->media_type} || 6,
62             },
63             Scene => 0,
64             };
65 0 0 0       if($msg->media_type eq "image"){
    0          
    0          
66 0           $api = 'https://' . $self->domain . '/cgi-bin/mmwebwx-bin/webwxsendmsgimg';
67             }
68             elsif($msg->media_type eq "video" or $msg->media_type eq "microvideo"){
69 0           $api = 'https://' . $self->domain . '/cgi-bin/mmwebwx-bin/webwxsendvideomsg';
70             }
71             #elsif($msg->media_type eq "voice"){
72             #
73             #}
74             elsif($msg->media_type eq "emoticon"){
75 0           $api = 'https://' . $self->domain . '/cgi-bin/mmwebwx-bin/webwxsendemoticon';
76 0 0         @query_string = (
77             fun=>'sys',
78             $self->pass_ticket?(pass_ticket => $self->url_escape($self->pass_ticket)):()
79             );
80 0           $post->{Msg}{EmojiFlag} = 2;
81             }
82             else{
83 0           $api = 'https://' . $self->domain . '/cgi-bin/mmwebwx-bin/webwxsendappmsg';
84 0           my $content =
85             "" .
86             "" . $msg->media_name . "" .
87             "" .
88             "" .
89             "6" .
90             "" .
91             "" .
92             "" .
93             "" .
94             "" . $msg->media_size . "" .
95             "" . (split ":",$msg->media_id)[0] . "" .
96             "" . $msg->media_ext ."" .
97             "" .
98             "" .
99             "";
100 0           $post->{Msg}{Content} = $content;
101             }
102 0 0         $post->{Msg}{Content} =~ s#/#__SLASH__#g if exists $post->{Msg}{Content};
103 0           my $json = $self->to_json($post);
104 0           $json =~ s#__SLASH__#/#g;
105 0           $self->http_post(
106             $self->gen_url($api,@query_string),
107             {json=>1,Referer=>'https://' . $self->domain . '/','Content-Type'=>'application/json'},
108             $json,
109             $callback
110             );
111             },
112 0           );
113             }
114             1;