Completed
Push — master ( a30943...b7600b )
by Taosikai
14:47
created

PollMessagesRequest::parseContents()   B

Complexity

Conditions 5
Paths 1

Size

Total Lines 22
Code Lines 15

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 5
eloc 15
nc 1
nop 1
dl 0
loc 22
rs 8.6737
c 0
b 0
f 0
1
<?php
2
/*
3
 * This file is part of the slince/smartqq package.
4
 *
5
 * (c) Slince <[email protected]>
6
 *
7
 * For the full copyright and license information, please view the LICENSE
8
 * file that was distributed with this source code.
9
 */
10
11
namespace Slince\SmartQQ\Request;
12
13
use GuzzleHttp\Psr7\Response;
14
use Slince\SmartQQ\Credential;
15
use Slince\SmartQQ\Exception\Code103ResponseException;
16
use Slince\SmartQQ\Exception\ResponseException;
17
use Slince\SmartQQ\Exception\RuntimeException;
18
use Slince\SmartQQ\Message\Content;
19
use Slince\SmartQQ\Message\Font;
20
use Slince\SmartQQ\Message\Response\DiscussMessage;
21
use Slince\SmartQQ\Message\Response\FriendMessage;
22
use Slince\SmartQQ\Message\Response\GroupMessage;
23
use Slince\SmartQQ\Message\Response\Message;
24
25
class PollMessagesRequest extends Request
26
{
27
    protected $uri = 'http://d1.web2.qq.com/channel/poll2';
28
29
    protected $referer = 'http://d1.web2.qq.com/proxy.html?v=20151105001&callback=1&id=2';
30
31
    protected $method = RequestInterface::REQUEST_METHOD_POST;
32
33
    public function __construct(Credential $credential)
34
    {
35
        $this->setParameter('r', \GuzzleHttp\json_encode([
36
            'ptwebqq' => '',
37
            'clientid' => $credential->getClientId(),
38
            'psessionid' => $credential->getPSessionId(),
39
            'key' => '',
40
        ]));
41
    }
42
43
    /**
44
     * 解析响应数据.
45
     *
46
     * @param Response $response
47
     *
48
     * @return Message[]
49
     */
50
    public static function parseResponse(Response $response)
51
    {
52
        $jsonData = \GuzzleHttp\json_decode($response->getBody(), true);
53
        if ($jsonData && 0 == $jsonData['retcode'] && !empty($jsonData['result'])) {
54
            $messages = [];
55
            foreach ($jsonData['result'] as $messageData) {
56
                $messages[] = static::makeResponseMessage($messageData['poll_type'], $messageData);
57
            }
58
59
            return $messages;
60
        } elseif (103 == $jsonData['retcode']) {
61
            throw new Code103ResponseException($response);
62
        }
63
        throw new ResponseException($jsonData['retcode'], $response);
64
    }
65
66
    protected static function makeResponseMessage($type, $messageData)
67
    {
68
        $contents = $messageData['value']['content'];
69
        //消息正文
70
        $content = static::parseContents($contents);
71
        switch ($messageData['poll_type']) {
72
            case Message::TYPE_FRIEND:
73
                $message = new FriendMessage(
74
                    $messageData['value']['to_uin'],
75
                    $messageData['value']['from_uin'],
76
                    $content,
77
                    $messageData['value']['time'],
78
                    $messageData['value']['msg_id'],
79
                    $messageData['value']['msg_type']
80
                );
81
                break;
82
            case Message::TYPE_GROUP:
83
                $message = new GroupMessage(
84
                    $messageData['value']['to_uin'],
85
                    $messageData['value']['from_uin'],
86
                    $messageData['value']['group_code'],
87
                    $messageData['value']['send_uin'],
88
                    $content,
89
                    $messageData['value']['time'],
90
                    $messageData['value']['msg_id'],
91
                    $messageData['value']['msg_type']
92
                );
93
                break;
94
            case Message::TYPE_DISCUSS:
95
                $message = new DiscussMessage(
96
                    $messageData['value']['to_uin'],
97
                    $messageData['value']['from_uin'],
98
                    $messageData['value']['did'],
99
                    $messageData['value']['send_uin'],
100
                    $content,
101
                    $messageData['value']['time'],
102
                    $messageData['value']['msg_id'],
103
                    $messageData['value']['msg_type']
104
                );
105
                break;
106
            default:
107
                throw new RuntimeException(sprintf('Unknown message type [%s]', $type));
108
                break;
0 ignored issues
show
Unused Code introduced by
break; does not seem to be reachable.

This check looks for unreachable code. It uses sophisticated control flow analysis techniques to find statements which will never be executed.

Unreachable code is most often the result of return, die or exit statements that have been added for debug purposes.

function fx() {
    try {
        doSomething();
        return true;
    }
    catch (\Exception $e) {
        return false;
    }

    return false;
}

In the above example, the last return false will never be executed, because a return statement has already been met in every possible execution path.

Loading history...
109
        }
110
111
        return $message;
112
    }
113
114
    /**
115
     * Parse Contents.
116
     *
117
     * @param array $contents
118
     *
119
     * @return Content
120
     */
121
    protected static function parseContents($contents)
122
    {
123
        //正文字体
124
        $fontParameters = $contents[0][1];
125
        $font = new Font($fontParameters['name'],
126
            $fontParameters['color'],
127
            $fontParameters['size'],
128
            $fontParameters['style']
129
        );
130
        unset($contents[0]);
131
        $contentString = implode('', array_map(function($content){
132
            if ($content && is_array($content) && 'face' === $content[0]) { //处理表情
133
                $faceText = Content::searchFaceText($content[1]);
134
135
                return $faceText ? '['.$faceText.']' : '';
136
            } else {
137
                return (string) $content;
138
            }
139
        }, $contents));
140
141
        return new Content($contentString, $font);
142
    }
143
}
144