Code Duplication    Length = 29-33 lines in 2 locations

app/Support/Tencent/XgPush/XingeApp.php 2 locations

@@ 163-191 (lines=29) @@
160
    /**
161
     * 推送消息给单个设备
162
     */
163
    public function PushSingleDevice($deviceToken, $message, $environment = 0)
164
    {
165
        $ret = array('ret_code' => -1, 'err_msg' => 'message not valid');
166
167
        if (!($message instanceof Message) && !($message instanceof MessageIOS)) return $ret;
168
        if (!$this->ValidateMessageType($message)) {
169
            $ret['err_msg'] = 'message type not fit accessId';
170
            return $ret;
171
        }
172
        if ($message instanceof MessageIOS) {
173
            if ($environment != XingeApp::IOSENV_DEV && $environment != XingeApp::IOSENV_PROD) {
174
                $ret['err_msg'] = "ios message environment invalid";
175
                return $ret;
176
            }
177
        }
178
        if (!$message->isValid()) return $ret;
179
        $params = array();
180
        $params['access_id'] = $this->accessId;
181
        $params['expire_time'] = $message->getExpireTime();
182
        $params['send_time'] = $message->getSendTime();
183
        if ($message instanceof Message) $params['multi_pkg'] = $message->getMultiPkg();
184
        $params['device_token'] = $deviceToken;
185
        $params['message_type'] = $message->getType();
186
        $params['message'] = $message->toJson();
187
        $params['timestamp'] = time();
188
        $params['environment'] = $environment;
189
190
        return $this->callRestful(self::RESTAPI_PUSHSINGLEDEVICE, $params);
191
    }
192
193
    /**
194
     * 推送消息给单个账户
@@ 392-424 (lines=33) @@
389
    /**
390
     * 创建批量推送任务
391
     */
392
    public function CreateMultipush($message, $environment = 0)
393
    {
394
        $ret = array('ret_code' => -1);
395
        if (!($message instanceof Message) && !($message instanceof MessageIOS)) {
396
            $ret['err_msg'] = 'message is not android or ios';
397
            return $ret;
398
        }
399
        if (!$this->ValidateMessageType($message)) {
400
            $ret['err_msg'] = 'message type not fit accessId';
401
            return $ret;
402
        }
403
        if ($message instanceof MessageIOS) {
404
            if ($environment != XingeApp::IOSENV_DEV && $environment != XingeApp::IOSENV_PROD) {
405
                $ret['err_msg'] = "ios message environment invalid";
406
                return $ret;
407
            }
408
        }
409
        if (!$message->isValid()) {
410
            $ret['err_msg'] = 'message not valid';
411
            return $ret;
412
        }
413
        $params = array();
414
        $params['access_id'] = $this->accessId;
415
        $params['expire_time'] = $message->getExpireTime();
416
        if ($message instanceof Message)
417
            $params['multi_pkg'] = $message->getMultiPkg();
418
        $params['message_type'] = $message->getType();
419
        $params['message'] = $message->toJson();
420
        $params['timestamp'] = time();
421
        $params['environment'] = $environment;
422
423
        return $this->callRestful(self::RESTAPI_CREATEMULTIPUSH, $params);
424
    }
425
426
    /**
427
     * 按帐号大批量推送