admin/vendor/overtrue/easy-sms/src/Gateways/YunxinGateway.php

163 lines
4.6 KiB
PHP

<?php
/*
* This file is part of the overtrue/easy-sms.
*
* (c) overtrue <i@overtrue.me>
*
* This source file is subject to the MIT license that is bundled
* with this source code in the file LICENSE.
*/
namespace Overtrue\EasySms\Gateways;
use Overtrue\EasySms\Contracts\MessageInterface;
use Overtrue\EasySms\Contracts\PhoneNumberInterface;
use Overtrue\EasySms\Exceptions\GatewayErrorException;
use Overtrue\EasySms\Support\Config;
use Overtrue\EasySms\Traits\HasHttpRequest;
/**
* Class YunxinGateway.
*
* @author her-cat <i@her-cat.com>
*
* @see https://dev.yunxin.163.com/docs/product/%E7%9F%AD%E4%BF%A1/%E7%9F%AD%E4%BF%A1%E6%8E%A5%E5%8F%A3%E6%8C%87%E5%8D%97
*/
class YunxinGateway extends Gateway
{
use HasHttpRequest;
const ENDPOINT_TEMPLATE = 'https://api.netease.im/%s/%s.action';
const ENDPOINT_ACTION = 'sendCode';
const SUCCESS_CODE = 200;
/**
* Send a short message.
*
* @param \Overtrue\EasySms\Contracts\PhoneNumberInterface $to
* @param \Overtrue\EasySms\Contracts\MessageInterface $message
* @param \Overtrue\EasySms\Support\Config $config
*
* @return array
*
* @throws GatewayErrorException
*/
public function send(PhoneNumberInterface $to, MessageInterface $message, Config $config)
{
$data = $message->getData($this);
$action = isset($data['action']) ? $data['action'] : self::ENDPOINT_ACTION;
$endpoint = $this->buildEndpoint('sms', $action);
switch ($action) {
case 'sendCode':
$params = $this->buildSendCodeParams($to, $message, $config);
break;
case 'verifyCode':
$params = $this->buildVerifyCodeParams($to, $message);
break;
default:
throw new GatewayErrorException(sprintf('action: %s not supported', $action), 0);
}
$headers = $this->buildHeaders($config);
try {
$result = $this->post($endpoint, $params, $headers);
if (!isset($result['code']) || self::SUCCESS_CODE !== $result['code']) {
$code = isset($result['code']) ? $result['code'] : 0;
$error = isset($result['msg']) ? $result['msg'] : json_encode($result, JSON_UNESCAPED_UNICODE);
throw new GatewayErrorException($error, $code);
}
} catch (\Exception $e) {
throw new GatewayErrorException($e->getMessage(), $e->getCode());
}
return $result;
}
/**
* @param $resource
* @param $function
*
* @return string
*/
protected function buildEndpoint($resource, $function)
{
return sprintf(self::ENDPOINT_TEMPLATE, $resource, strtolower($function));
}
/**
* Get the request headers.
*
* @param Config $config
*
* @return array
*/
protected function buildHeaders(Config $config)
{
$headers = [
'AppKey' => $config->get('app_key'),
'Nonce' => md5(uniqid('easysms')),
'CurTime' => (string) time(),
'Content-Type' => 'application/x-www-form-urlencoded;charset=utf-8',
];
$headers['CheckSum'] = sha1("{$config->get('app_secret')}{$headers['Nonce']}{$headers['CurTime']}");
return $headers;
}
/**
* @param PhoneNumberInterface $to
* @param MessageInterface $message
* @param Config $config
*
* @return array
*/
public function buildSendCodeParams(PhoneNumberInterface $to, MessageInterface $message, Config $config)
{
$data = $message->getData($this);
$template = $message->getTemplate($this);
return [
'mobile' => $to->getUniversalNumber(),
'authCode' => array_key_exists('code', $data) ? $data['code'] : '',
'deviceId' => array_key_exists('device_id', $data) ? $data['device_id'] : '',
'templateid' => is_string($template) ? $template : '',
'codeLen' => $config->get('code_length', 4),
'needUp' => $config->get('need_up', false),
];
}
/**
* @param PhoneNumberInterface $to
* @param MessageInterface $message
*
* @return array
*
* @throws GatewayErrorException
*/
public function buildVerifyCodeParams(PhoneNumberInterface $to, MessageInterface $message)
{
$data = $message->getData($this);
if (!array_key_exists('code', $data)) {
throw new GatewayErrorException('"code" cannot be empty', 0);
}
return [
'mobile' => $to->getUniversalNumber(),
'code' => $data['code'],
];
}
}