欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

laravel框架使用阿里云短信发送消息操作示例

程序员文章站 2022-06-14 13:43:24
本文实例讲述了laravel框架使用阿里云短信发送消息操作。分享给大家供大家参考,具体如下:最新需要用到发送短信的功能,所以就在网上搜索一些写好的扩展。扩展地址:https://github.com/...

本文实例讲述了laravel框架使用阿里云短信发送消息操作。分享给大家供大家参考,具体如下:

最新需要用到发送短信的功能,所以就在网上搜索一些写好的扩展。

扩展地址:

https://github.com/missmycat/aliyun-sms

通过composer安装:

composer require mrgoon/aliyun-sms dev-master

在 config/app.php 中 providers 加入:

mrgoon\alisms\serviceprovider::class,

有需求的可以自行添加 aliases。

然后在控制台运行 :

php artisan vendor:publish

默认会在 config 目录下创建一个 aliyunsms.php 文件:

<?php
return [
  'access_key' => env('aliyun_sms_ak'), // accesskey
  'access_secret' => env('aliyun_sms_as'), // accesssecret
  'sign_name' => env('aliyun_sms_sign_name'), // 签名
];

然后在 .env 中配置相应参数:

aliyun_sms_ak=
aliyun_sms_as=
aliyun_sms_sign_name=

为了能够方便的发送短信,我们可以在 app 目录下,创建一个services目录,并添加 aliyunsms.php 文件。

<?php
namespace app\services;
use mrgoon\alisms\alisms;
/**
 * 阿里云短信类
 */
class aliyunsms
{
  //验证码
  const verification_code = 'verification_code';
  //模板code
  public static $templatecodes = [
    self::verification_code => 'sms_xxxxxxxxxx',
  ];
  /**
   * 发送短信
   */
  public static function sendsms($mobile, $scene, $params = [])
  {
    if (empty($mobile)) {
      throw new \exception('手机号不能为空');
    }
    if (empty($scene)) {
      throw new \exception('场景不能为空');
    }
    if (!isset(self::$templatecodes[$scene])) {
      throw new \exception('请配置场景的模板code');
    }
    $template_code = self::$templatecodes[$scene];
    try {
      $ali_sms = new alisms();
      $response = $ali_sms->sendsms($mobile, $template_code, $params);
      if ($response->code == 'ok') {
        return true;
      }
      throw new \exception($response->message);
    } catch (\throwable $e) {
      throw new \exception($e->getmessage());
    }
  }
}

为了能够记录每次短信发送的状态,我们可以创建一个 sms_logs 表。

create table `sms_logs` (
 `id` int(11) unsigned not null auto_increment comment 'id',
 `type` tinyint(1) not null default '0' comment '类型(0:短信验证码,1:语音验证码,2:短信消息通知)',
 `mobile` varchar(16) not null default '' comment '手机号',
 `code` varchar(12) not null default '' comment '验证码',
 `checked` tinyint(1) not null default '0' comment '是否验证(0:未验证,1:已验证)',
 `status` tinyint(1) not null default '0' comment '状态(0:未发送,1:已发送,2:发送失败)',
 `reason` varchar(255) not null default '' comment '失败原因',
 `remark` varchar(255) not null default '' comment '备注',
 `operator_id` int(11) not null default '0' comment '操作人id',
 `ip` varchar(16) not null default '' comment '操作ip',
 `created` int(11) not null default '0' comment '创建时间',
 `updated` int(11) not null default '0' comment '更新时间',
 primary key (`id`)
) engine=innodb default charset=utf8mb4 comment='短信表';

然后针对该表,我们创建一个 smslog 模型来管理。

<?php
namespace app\models;
use app\services\aliyunsms;
class smslog extends model
{
  protected $fillable = [
    'type',
    'mobile',
    'code',
    'checked',
    'status',
    'reason',
    'remark',
    'operator_id',
    'ip',
  ];
  //类型(0:短信验证码,1:语音验证码,2:短信消息通知)
  const type_code = 0;
  const type_voice = 1;
  const type_message = 2;
  //是否验证(0:未验证,1:已验证)
  const checked_unverified = 0;
  const checked_verified = 1;
  //状态(0:未发送,1:已发送,2:发送失败)
  const status_no_send = 0;
  const status_send = 1;
  const status_fail = 2;
  //短信发送间隔时间,默认60秒
  const send_interval_time = 60;
  /**
   * 检测短信验证码
   */
  protected function checkcode($mobile, $code)
  {
    if (!$mobile) {
      throw new \exception('手机号不能为空');
    }
    if (!checkmobile($mobile)) {
      throw new \exception('手机号不正确');
    }
    if (!$code) {
      throw new \exception('验证码不能为空');
    }
    $sms_log = $this->where([
      ['type', self::type_code],
      ['mobile', $mobile],
      ['status', self::status_send],
      ['checked', self::checked_unverified],
    ])->orderby('created', 'desc')->first();
    if (!$sms_log) {
      throw new \exception('验证码不存在,请重新获取');
    }
    if ($code != $sms_log->code) {
      throw new \exception('验证码错误');
    }
    $sms_log->checked = self::checked_verified;
    $sms_log->save();
    return true;
  }
  /**
   * 检测短信频率
   */
  protected function checkrate($mobile)
  {
    if (!$mobile) {
      throw new \exception('手机号不能为空');
    }
    $sms_log = $this->where([
      ['mobile', $mobile],
      ['status', self::status_send],
    ])->orderby('created', 'desc')->first();
    $now = time();
    if ($sms_log) {
      if (($now - strtotime($sms_log->created)) < self::send_interval_time) {
        throw new \exception('短信发送太频繁,请稍后再试');
      }
    }
    return true;
  }
  /**
   * 发送短信验证码
   */
  protected function sendverifycode($mobile)
  {
    self::checkrate($mobile);
    $code = mt_rand(1000, 9999);
    $sms_log = $this->create([
      'type' => self::type_code,
      'mobile' => $mobile,
      'code' => $code,
      'checked' => self::checked_unverified,
      'status' => self::status_no_send,
      'ip' => getrealip(),
    ]);
    try {
      aliyunsms::sendsms($mobile, aliyunsms::verification_code, ['code' => $code]);
      $sms_log->status = self::status_send;
      $sms_log->save();
      return true;
    } catch (\exception $e) {
      $sms_log->status = self::status_fail;
      $sms_log->reason = $e->getmessage();
      $sms_log->save();
      throw new \exception($e->getmessage());
    }
  }
}

这样,我们就可以在项目中通过 smslog::sendverifycode() 发送短信了。

getrealip() 和 checkmobile() 方法为公共方法,存放在 app/helpers 的 functions.php 中。

/**
 * 获取真实ip地址
 */
function getrealip()
{
  $ip = false;
  if (getenv("http_client_ip") && strcasecmp(getenv("http_client_ip"), "unknown")) {
    $ip = getenv("http_client_ip");
  } else if (getenv("http_x_forwarded_for") && strcasecmp(getenv("http_x_forwarded_for"), "unknown")) {
    $ips = explode(", ", getenv("http_x_forwarded_for"));
    if ($ip) {
      array_unshift($ips, $ip);
      $ip = false;
    }
    $ipscount = count($ips);
    for ($i = 0; $i < $ipscount; $i++) {
      if (!preg_match("/^(10|172\.16|192\.168)\./i", $ips[$i])) {
        $ip = $ips[$i];
        break;
      }
    }
  } else if (getenv("remote_addr") && strcasecmp(getenv("remote_addr"), "unknown")) {
    $ip = getenv("remote_addr");
  } else if (isset($_server['remote_addr']) && $_server['remote_addr'] && strcasecmp($_server['remote_addr'], "unknown")) {
    $ip = $_server['remote_addr'];
  } else {
    $ip = "unknown";
  }
  return isip($ip) ? $ip : "unknown";
}
/**
 * 检查是否是合法的ip
 */
function isip($ip)
{
  if (preg_match('/^((\d|[1-9]\d|2[0-4]\d|25[0-5]|1\d\d)(?:\.(\d|[1-9]\d|2[0-4]\d|25[0-5]|1\d\d)){3})$/', $ip)) {
    return true;
  } else {
    return false;
  }
}
/**
 * 验证手机号
 */
function checkmobile($mobile)
{
  return preg_match('/^((13[0-9])|(14[5,7])|(15[0-3,5-9])|(17[0,3,5-8])|(18[0-9])|166|198|199|(147))\d{8}$/i', $mobile);
}