File Coverage

blib/lib/Webqq/Message.pm

Criterion	Covered	Total	%
statement	18	374	4.8
branch	0	164	0.0
condition	0	36	0.0
subroutine	6	61	9.8
pod	0	8	0.0
total	24	643	3.7

package Webqq::Message;
use Webqq::Message::Face;
use JSON;
use Encode;
use Webqq::Client::Util qw(console code2client);
use Scalar::Util qw(blessed);
sub reply_message{
    my $client = shift;
    my $msg = shift;
    my $content = shift;
    unless(blessed($msg)){
        console "输入的msg数据非法\n";
        return 0;
    }
    if($msg->{type} eq 'message'){
        $client->send_message(
            $client->create_msg(to_uin=>$msg->{from_uin},content=>$content)
        );
    }
    elsif($msg->{type} eq 'group_message'){
        $client->send_group_message(
            $client->create_group_msg(
                to_uin=>$msg->{from_uin},
                content=>$content,
                group_code=>$msg->{group_code}
            )
        );
    }
    elsif($msg->{type} eq 'discuss_message'){
        $client->send_discuss_message(
            $client->create_discuss_msg(
                to_uin =>$msg->{did} || $msg->{from_uin},
                content =>$content,
            )
        );
    }
    elsif($msg->{type} eq 'sess_message'){
        #群临时消息
        if($msg->{via} eq 'group'){
            $client->send_sess_message(
                $client->create_sess_msg(
                    to_uin          =>  $msg->{from_uin},
                    content         =>  $content,
                    group_code      =>  $msg->{group_code},
                    gid             =>  $msg->{gid},
                )
            );
        }
        #讨论组临时消息
        elsif($msg->{via} eq 'discuss'){
            $client->send_sess_message(
                $client->create_sess_msg(
                    to_uin          =>  $msg->{from_uin},
                    content         =>  $content,
                    did             =>  $msg->{did},
                )
            );
        }
    }

}
sub create_sess_msg{
    my $client = shift;
    return $client->_create_msg(@_,type=>'sess_message');
}
sub create_group_msg{
    my $client = shift;
    return $client->_create_msg(@_,type=>'group_message');
}
sub create_msg{
    my $client = shift;
    return $client->_create_msg(@_,type=>'message');
}
sub create_discuss_msg{
    my $client = shift;
    return $client->_create_msg(@_,type=>'discuss_message');
}
sub _create_msg {
    my $client = shift;
    my %p = @_;
    $p{content} =~s/\r|\n/\n/g;
    my %msg = (
        type        => $p{type},
        msg_id      => $p{msg_id} || ++$client->{qq_param}{send_msg_id},
        from_uin    => $p{from_uin} || $client->{qq_param}{from_uin},
        to_uin      => $p{to_uin},
        content     => $p{content},
        msg_class   => "send",
        msg_time    => time,
        cb          => $p{cb},
        ttl         => 5,
        allow_plugin => 1,
        client      =>  $client,
    );
    if($p{type} eq 'sess_message'){
        if(defined $p{group_code}){
            $msg{group_code} = $p{group_code};
            $msg{service_type} = 0;
            $msg{via} = 'group';
            my $id = defined $p{gid}?$p{gid}:$client->search_group($p{group_code})->{gid};
            $msg{group_sig} = $client->_get_group_sig($id,$p{to_uin},$msg{service_type});
        }
        elsif(defined $p{gid}){
            $msg{group_code} = $client->get_group_code_from_gid($p{gid});
            $msg{service_type} = 0;
            $msg{via} = 'group';
            my $id = $p{gid};
            $msg{group_sig} = $client->_get_group_sig($id,$p{to_uin},$msg{service_type});
        }
        elsif(defined $p{did}){
            $msg{did} = $p{did};
            $msg{service_type} = 1;
            $msg{via} = 'discuss';
            $msg{group_sig} = $client->_get_group_sig($p{did},$p{to_uin},$msg{service_type});
        }
        else{
            console "create_sess_msg()必须设置group_code或者did\n";
            return ;
        }
    }
    elsif($p{type} eq 'group_message'){
        $msg{group_code} = $p{group_code}||$client->get_group_code_from_gid($p{to_uin});
        $msg{send_uin} = $msg{from_uin};
    }
    elsif($p{type} eq 'discuss_message'){
        $msg{did} = $p{did} || $p{to_uin};
        $msg{send_uin} = $msg{from_uin};
    }
    my $msg_pkg = "\u$p{type}::Send";
    $msg_pkg=~s/_(.)/\u$1/g;
    return $client->_mk_ro_accessors(\%msg,$msg_pkg);

}

sub _load_extra_accessor {
    *Webqq::Message::DiscussMessage::Recv::discuss_name = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $d = $client->search_discuss($msg->{did});
        return defined $d?$d->{name}:undef ;
    };
    *Webqq::Message::DiscussMessage::Recv::from_dname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $d = $client->search_discuss($msg->{did});
        return defined $d?$d->{name}:undef ;
    };
    *Webqq::Message::DiscussMessage::Recv::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $m = $client->search_member_in_discuss($msg->{did},$msg->{send_uin});
        return defined $m?$m->{ruin}:$client->get_qq_from_uin($msg->{send_uin});
    };
    *Webqq::Message::DiscussMessage::Recv::from_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $m = $client->search_member_in_discuss($msg->{did},$msg->{send_uin});
        return defined $m?$m->{nick}:undef;
    };

    *Webqq::Message::DiscussMessage::Send::discuss_name = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $d  = $client->search_discuss($msg->{did});
        return defined $d?$d->{name}:undef;
    };
    *Webqq::Message::DiscussMessage::Send::to_dname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $d  = $client->search_discuss($msg->{did});
        return defined $d?$d->{name}:undef;
    };
    *Webqq::Message::DiscussMessage::Send::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };
    *Webqq::Message::DiscussMessage::Send::from_nick = sub{
        return "我";
    };

    *Webqq::Message::GroupMessage::Recv::group_name = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $g = $client->search_group($msg->{group_code});
        return defined $g?$g->{name}:undef ;
    };
    *Webqq::Message::GroupMessage::Recv::from_gname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $g = $client->search_group($msg->{group_code});
        return defined $g?$g->{name}:undef ;
    };
    *Webqq::Message::GroupMessage::Recv::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->get_qq_from_uin($msg->{send_uin});
    };
    *Webqq::Message::GroupMessage::Recv::from_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $m = $client->search_member_in_group($msg->{group_code},$msg->{send_uin});
        return defined $m?$m->{nick}:undef;
    };
    *Webqq::Message::GroupMessage::Recv::from_card = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $m = $client->search_member_in_group($msg->{group_code},$msg->{send_uin});
        return defined $m?$m->{card}:undef;
    };
    *Webqq::Message::GroupMessage::Recv::from_city = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $m = $client->search_member_in_group($msg->{group_code},$msg->{send_uin});
        return defined $m?$m->{city}:undef;
    };

    *Webqq::Message::GroupMessage::Send::group_name = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $g  = $client->search_group($msg->{group_code});
        return defined $g?$g->{name}:undef;
    };
    *Webqq::Message::GroupMessage::Send::to_gname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $g  = $client->search_group($msg->{group_code});
        return defined $g?$g->{name}:undef;
    };
    *Webqq::Message::GroupMessage::Send::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };
    *Webqq::Message::GroupMessage::Send::from_nick = sub{
        return "我";
    };


    *Webqq::Message::SessMessage::Recv::from_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        if($msg->{via} eq 'group'){
            my $m = $client->search_member_in_group($msg->{group_code},$msg->{from_uin});
            return defined $m?$m->{nick}:undef;
        }
        elsif($msg->{via} eq 'discuss'){
            my $m = $client->search_member_in_discuss($msg->{did},$msg->{from_uin});
            return defined $m?$m->{nick}:undef;
        }
        else{return undef}
    };
    *Webqq::Message::SessMessage::Recv::from_qq = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return $msg->{ruin};
    };
    *Webqq::Message::SessMessage::Recv::to_nick = sub{
        return "我";
    };
    *Webqq::Message::SessMessage::Recv::to_qq = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };

    *Webqq::Message::SessMessage::Recv::via_type = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return      $msg->{via} eq 'group'      ?       "群"
                :   $msg->{via} eq 'discuss'    ?       "讨论组"
                :                                       undef
                ;
    };
    *Webqq::Message::SessMessage::Recv::via_name = sub {
        my $msg = shift;
        my $client = $msg->{client};
        if($msg->{via} eq 'group'){
            my $g = $client->search_group($msg->{group_code});
            return defined $g?$g->{name}:undef;
        }
        elsif($msg->{via} eq 'discuss'){
            my $d = $client->search_discuss($msg->{did});
            return defined $d?$d->{name}:undef;
        }
        else{return }
    };


    *Webqq::Message::SessMessage::Send::from_nick = sub{
        return "我";
    };
    *Webqq::Message::SessMessage::Send::from_qq = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };
    *Webqq::Message::SessMessage::Send::to_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        if($msg->{via} eq 'group'){
            my $m = $client->search_member_in_group($msg->{group_code},$msg->{to_uin});
            return defined $m?$m->{nick}:undef;
        }
        elsif($msg->{via} eq 'discuss'){
            my $m = $client->search_member_in_discuss($msg->{did},$msg->{to_uin});
            return defined $m?$m->{nick}:undef;
        }
        else{return }
    };
    *Webqq::Message::SessMessage::Send::to_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->get_qq_from_uin($msg->{to_uin});
    };
    *Webqq::Message::SessMessage::Send::via_name = sub{
        my $msg = shift;
        my $client = $msg->{client};
        if($msg->{via} eq 'group'){
            my $g = $client->search_group($msg->{group_code});
            return defined $g?$g->{name}:undef;
        }
        elsif($msg->{via} eq 'discuss'){
            my $d = $client->search_discuss($msg->{did});
            return defined $d?$d->{name}:undef;
        }
        else{return}
    };

    *Webqq::Message::SessMessage::Send::via_type = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return      $msg->{via} eq 'group'      ?       "群"
                :   $msg->{via} eq 'discuss'    ?       "讨论组"
                :                                       undef
                ;
    };
    *Webqq::Message::Message::Recv::from_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{from_uin});
        return defined $f?$f->{nick}:undef;
    };
    *Webqq::Message::Message::Recv::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->get_qq_from_uin($msg->{from_uin});
    };
    *Webqq::Message::Message::Recv::from_markname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{from_uin});
        return defined $f?$f->{markname}:undef;
    };
    *Webqq::Message::Message::Recv::from_categories = sub {
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{from_uin});
        return defined $f?$f->{categories}:undef;
    };

    *Webqq::Message::Message::Recv::from_city = sub {
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{from_uin});
        return defined $f?$f->{city}:undef;
    };

    *Webqq::Message::Message::Recv::to_nick = sub{
        return "我";
    };
    *Webqq::Message::Message::Recv::to_qq = sub {
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };


    *Webqq::Message::Message::Send::from_nick = sub{
        return "我";
    };
    *Webqq::Message::Message::Send::from_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->{qq_param}{qq};
    };
    *Webqq::Message::Message::Send::to_nick = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{to_uin});
        return defined $f?$f->{nick}:undef;
    };
    *Webqq::Message::Message::Send::to_qq = sub{
        my $msg = shift;
        my $client = $msg->{client};
        return $client->get_qq_from_uin($msg->{to_uin});
    };
    *Webqq::Message::Message::Send::to_markname = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{to_uin});
        return defined $f?$f->{markname}:undef;
    };
    *Webqq::Message::Message::Send::to_categories = sub{
        my $msg = shift;
        my $client = $msg->{client};
        my $f = $client->search_friend($msg->{to_uin});
        return defined $f?$f->{categories}:undef;
    };

}

sub _mk_ro_accessors {
    my $client = shift;
    my $msg =shift;
    my $msg_pkg = shift;
    no strict 'refs';
    for my $field (keys %$msg){
        *{"Webqq::Message::${msg_pkg}::$field"} = sub{
            my $self = shift;
            my $pkg = ref $self;
            die "the value of \"$field\" in $pkg is read-only\n" if @_!=0;
            return $self->{$field};
        };
    }

    $msg = bless $msg,"Webqq::Message::$msg_pkg";
    return $msg;
}

sub parse_send_status_msg{
    my $client = shift;
    my ($json_txt) = @_;
    my $json     = undef;
    eval{$json = JSON->new->utf8->decode($json_txt)};
    console "解析消息失败: $@ 对应的消息内容为: $json_txt\n" if $@ and $client->{debug};
    if(ref $json eq 'HASH' and $json->{retcode}==0){
        return {is_success=>1,status=>"发送成功"};
    }
    else{
        return {is_success=>0,status=>"发送失败"};
    }
}
#消息的后期处理
sub msg_put{
    my $client = shift;
    my $msg = shift;
    $msg->{raw_content} = [];
    my $msg_content;
    shift @{ $msg->{content} };
    for my $c (@{ $msg->{content} }){
        if(ref $c eq 'ARRAY'){
            if($c->[0] eq 'cface'){
                push @{$msg->{raw_content}},{
                    type    =>  'cface',
                    content =>  '[图片]',
                    name    =>  $c->[1]{name},
                    file_id =>  $c->[1]{file_id},
                    key     =>  $c->[1]{key},
                    server  =>  $c->[1]{server},
                };
                $c="[图片]";
            }
            elsif($c->[0] eq 'offpic'){
                push @{$msg->{raw_content}},{
                    type        =>  'offpic',
                    content     =>  '[图片]',
                    file_path   =>  $c->[1]{file_path},
                };
                $c="[图片]";
            }
            elsif($c->[0] eq 'face'){
                push @{$msg->{raw_content}},{
                    type    =>  'face',
                    content =>  face_to_txt($c),
                    id      =>  $c->[1],
                };
                $c=face_to_txt($c);
            }
            else{
                push @{$msg->{raw_content}},{
                    type    =>  'unknown',
                    content =>  '[未识别内容]',
                };
                $c = "[未识别内容]";
            }
        }
        elsif($c eq " "){
            next;
        }
        else{
            $c=encode("utf8",$c);
            $c=~s/ $//;
            $c=~s/\r|\n/\n/g;
            #{"retcode":0,"result":[{"poll_type":"group_message","value":{"msg_id":538,"from_uin":2859929324,"to_uin":3072574066,"msg_id2":545490,"msg_type":43,"reply_ip":182424361,"group_code":2904892801,"send_uin":1951767953,"seq":3024,"time":1418955773,"info_seq":390179723,"content":[["font",{"size":12,"color":"000000","style":[0,0,0],"name":"\u5FAE\u8F6F\u96C5\u9ED1"}],"[\u50BB\u7B11]\u0001 "]}}]}
            #if($c=~/\[[^\[\]]+?\]\x{01}/)
            push @{$msg->{raw_content}},{
                type    =>  'txt',
                content =>  $c,
            };
        }
        $msg_content .= $c;
    }
    $msg->{content} = $msg_content;
    $msg->{client} = $client;
    #将整个hash从unicode转为UTF8编码
    #$msg->{$_} = encode("utf8",$msg->{$_} ) for grep {$_ ne 'raw_content'}  keys %$msg;
    #$msg->{content}=~s/\r|\n/\n/g;
    if($msg->{content}=~/\(\d+\) 被管理员禁言\d+(分钟|小时|天)$/ or $msg->{content}=~/\(\d+\) 被管理员解除禁言$/){
        $msg->{type} = "sys_g_msg";
        return;
    }
    my $msg_pkg = "\u$msg->{type}::Recv"; $msg_pkg=~s/_(.)/\u$1/g;
    $msg = $client->_mk_ro_accessors($msg,$msg_pkg) ;
    $client->{receive_message_queue}->put($msg);
}

sub parse_receive_msg{
    my $client = shift;
    return if $client->{is_stop} ;
    my ($json_txt) = @_;
    my $json     = undef;
    eval{$json = JSON->new->utf8->decode($json_txt)};
    console "解析消息失败: $@ 对应的消息内容为: $json_txt\n" if $@ and $client->{debug};
    if($json){
        #一个普通的消息
        if($json->{retcode}==0){
            $client->{poll_failure_count} = 0;
            for my $m (@{ $json->{result} }){
                #收到群临时消息
                if($m->{poll_type} eq 'sess_message'){
                    my $msg = {
                        type        =>  'sess_message',
                        msg_id      =>  $m->{value}{msg_id},
                        from_uin    =>  $m->{value}{from_uin},
                        to_uin      =>  $m->{value}{to_uin},
                        msg_time    =>  $m->{value}{'time'},
                        content     =>  $m->{value}{content},
                        service_type=>  $m->{value}{service_type},
                        ruin        =>  $m->{value}{ruin},
                        msg_class   =>  "recv",
                        ttl         =>  5,
                        allow_plugin => 1,
                    };
                    #service_type =0 表示群临时消息，1 表示讨论组临时消息
                    if($m->{value}{service_type} == 0){
                        $msg->{gid} = $m->{value}{id};
                        $msg->{group_code}  =  $client->get_group_code_from_gid($m->{value}{id}),
                        $msg->{via}  = 'group';
                    }
                    elsif($m->{value}{service_type} == 1){
                        $msg->{did} = $m->{value}{id};
                        $msg->{via}  = 'discuss';
                    }
                    else{return}
                    $client->msg_put($msg);
                }
                #收到的消息是普通消息
                elsif($m->{poll_type} eq 'message'){
                    my $msg = {
                        type        =>  'message',
                        msg_id      =>  $m->{value}{msg_id},
                        from_uin    =>  $m->{value}{from_uin},
                        to_uin      =>  $m->{value}{to_uin},
                        msg_time    =>  $m->{value}{'time'},
                        content     =>  $m->{value}{content},
                        msg_class   =>  "recv",
                        ttl         =>  5,
                        allow_plugin => 1,
                    };
                    $client->msg_put($msg);
                }
                #收到的消息是群消息
                elsif($m->{poll_type} eq 'group_message'){
                    my $msg = {
                        type        =>  'group_message',
                        msg_id      =>  $m->{value}{msg_id},
                        from_uin    =>  $m->{value}{from_uin},
                        to_uin      =>  $m->{value}{to_uin},
                        msg_time    =>  $m->{value}{'time'},
                        content     =>  $m->{value}{content},
                        send_uin    =>  $m->{value}{send_uin},
                        group_code  =>  $m->{value}{group_code},
                        msg_class   =>  "recv",
                        ttl         =>  5,
                        allow_plugin => 1,
                    };
                    $client->msg_put($msg);
                }
                #收到讨论组消息
                elsif($m->{poll_type} eq 'discu_message'){
                    my $msg = {
                        type        =>  'discuss_message',
                        did         =>  $m->{value}{did},
                        from_uin    =>  $m->{value}{from_uin},
                        msg_id      =>  $m->{value}{msg_id},
                        send_uin    =>  $m->{value}{send_uin},
                        msg_time    =>  $m->{value}{'time'},
                        to_uin      =>  $m->{value}{'to_uin'},
                        content     =>  $m->{value}{content},
                        msg_class   =>  "recv",
                        ttl         =>  5,
                        allow_plugin => 1,
                    };
                    $client->msg_put($msg);
                }
                elsif($m->{poll_type} eq 'buddies_status_change'){
                    my $msg = {
                        type        =>  'buddies_status_change',
                        uin         =>  $m->{value}{uin},
                        state       =>  $m->{value}{status},
                        client_type =>  code2client($m->{value}{client_type}),
                    };
                    $client->msg_put($msg);
                }
                #收到系统消息
                elsif($m->{poll_type} eq 'sys_g_msg'){
                    #my $msg = {
                    #    type        =>  'sys_g_msg',
                    #    msg_id      =>  $m->{value}{msg_id},
                    #    from_uin    =>  $m->{value}{from_uin},
                    #    to_uin      =>  $m->{value}{to_uin},
                    #
                    #};
                    #$client->msg_put($msg);
                }
                #收到强制下线消息
                elsif($m->{poll_type} eq 'kick_message'){
                    if($m->{value}{show_reason} ==1){
                        my $reason = encode("utf8",$m->{value}{reason});
                        console "$reason\n";
                        $client->stop();
                    }
                    else {console "您已被迫下线\n";$client->stop(); }
                }
                #还未识别和处理的消息
                else{

                }
            }
        }
        #可以忽略的消息，暂时不做任何处理
        elsif($json->{retcode} == 102 or $json->{retcode} == 109 or $json->{retcode} == 110 ){
            $client->{poll_failure_count} = 0;
        }
        #更新客户端ptwebqq值
        elsif($json->{retcode} == 116){$client->{qq_param}{ptwebqq} = $json->{p};}
        #未重新登录
        elsif($json->{retcode} ==100){
            console "因网络或其他原因与服务器失去联系，客户端需要重新登录...\n";
            $client->relogin();
        }
        #重新连接失败
        elsif($json->{retcode} ==120 or $json->{retcode} ==121 ){
            console "因网络或其他原因与服务器失去联系，客户端需要重新连接...\n";
            $client->_relink();
        }
        #其他未知消息
        else{
            $client->{poll_failure_count}++;
            console "获取消息失败，当前失败次数: $client->{poll_failure_count}\n";
            if($client->{poll_failure_count} > $client->{poll_failure_count_max}){
                console "接收消息失败次数超过最大值，尝试进行重新连接...\n";
                $client->{poll_failure_count}   =  0;
                $client->_relink();
            }
        }
    }
}
1;