universesupermarket_api/application/api/controller/Sms.php

<?php

namespace app\api\controller;

use app\common\library\Common;
use app\common\library\Jiyan;
use think\Db;
use think\facade\Validate;
use think\Request;
use AlibabaCloud\Client\AlibabaCloud;

/**
 * @title 发送短信
 * @controller Sms

 */
class Sms extends Base
{
    /**
     * @title 发送短信
     * @desc 发送短信
     * @url /api/Sms/send
     * @method POST
     * @tag 基础
     * @header
     * @param  name:phone type:string require:1 default:-- desc:手机号
     * @param  name:event type:string require:0 default:register desc:发送类型register：注册forgetpwd：找回密码login：找回密码
     */
    public function send()
    {
        $phone = input("phone");
        $event = input("event",'register');
        if (!$phone || !Validate::regex($phone, "^1\d{10}$")) {
            $this->error('手机号不正确');
        }

//        $lot_number = input('lot_number');
//        $captcha_output = input('captcha_output');
//        $pass_token = input('pass_token');
//        $gen_time = input('gen_time');
//        if (!$lot_number || !$captcha_output || !$pass_token || !$gen_time) $this->error('参数错误');
//
//        $jy = new Jiyan();
//        $result = $jy->jy($lot_number,$captcha_output,$pass_token,$gen_time,1);
//        if ($result['result']=='fail') $this->error('校验失败，请稍后重试');

        $last = Db::name('store_sms')->where(['mobile' => $phone, 'event' => $event])
            ->order('id', 'DESC')
            ->find();
        if ($last && (time() - $last['createtime'])< 60) {
            $this->error('发送频繁！');
        }
//        $ipSendTotal = Db::name('store_sms')->where(['ip' => request()->ip()])->whereTime('createtime', '-1 hours')->count();
//        if ($ipSendTotal >= 5) {
//            $this->error('发送频繁！');
//        }

        $member = Db::name('store_member')
            ->where('phone',$phone)
            ->where('is_deleted',0)
            ->count();
        switch ($event){
            case 'register':
                if ($member) $this->error('手机号已注册');
                break;
            case 'forgetpwd': case 'login':
                if (!$member) $this->error('手机号未注册');
                break;
        }

        //发送阿里云短信
        $ret = $this->accessKeyClient($event, $phone, mt_rand(100000, 999999));
        if ($ret['Code'] === 'OK') {
            $this->success('发送成功！');
        } elseif ($ret['Code'] === 'isv.BUSINESS_LIMIT_CONTROL') {
            $this->error('发送太过频繁！');
        } else {
            $this->error($ret['msg']);
        }
    }

    function accessKeyClient($event, $mobile, $num)
    {
        $sett = [
            'ali_accesskey',
            'ali_accesskey_secret',
            'templateCode',
            'sign_name'
        ];
        $array = getConfig($sett);

        $ali_accesskey = $array['ali_accesskey'];
        $ali_accesskey_secret = $array['ali_accesskey_secret'];
        $templateCode = $array['templateCode'];
        AlibabaCloud::accessKeyClient($ali_accesskey, $ali_accesskey_secret)
            ->regionId('cn-hangzhou')
            ->asDefaultClient();

        try {
            $result = AlibabaCloud::rpc()
                ->product('Dysmsapi')
                // ->scheme('https') // https | http
                ->version('2017-05-25')
                ->action('SendSms')
                ->method('POST')
                ->host('dysmsapi.aliyuncs.com')
                ->options([
                    'query' => [
                        'PhoneNumbers' => $mobile,
                        'SignName' => $array['sign_name'],
                        'TemplateCode' => $templateCode,
                        'TemplateParam' => '{"code":' . $num . '}',
                    ],
                ])
                ->request();
            $info = $result->toArray();
            if ($info['Code'] == 'OK') {
                $ip = request()->ip();
                Db::name('store_sms')->insert(['event' => $event, 'mobile' => $mobile, 'createtime'=>time(),'code' => $num, 'ip' => $ip]);
            }
            return $info;
        } catch (ClientException $e) {
            echo $e->getErrorMessage() . PHP_EOL;
        } catch (ServerException $e) {
            echo $e->getErrorMessage() . PHP_EOL;
        }
    }
}