NN2024010801/app/Services/EmailService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services;

use AlibabaCloud\SDK\Dm\V20151123\Models\SingleSendMailRequest;
use AlibabaCloud\Tea\Exception\TeaError;
use AlibabaCloud\Tea\Exception\TeaUnableRetryError;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Dysmsapi;
use App\Models\MemberModel;
use App\Models\MessageModel;
use App\Services\Api\MemberSettingService;
use Darabonba\OpenApi\Models\Config;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\SendSmsRequest;
use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
use Illuminate\Support\Facades\Mail;

/**
 * 邮件服务管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * Class EmailService
 * @package App\Services
 */
class EmailService extends BaseService
{
    // 静态对象
    protected static $instance = null;
    /**
     * 配置参数
     * @var array
     */
    protected $config = [];
    private $errors = [
        'isv.BUSINESS_LIMIT_CONTROL' => '验证码获取频繁，请5分钟后重试~',
    ];

    public function __construct()
    {
        $config = ConfigService::make()->getConfigByGroup(2);
        $mail = config('mail');
        $mailKey = md5(json_encode($mail));
        $mail['default'] = isset($config['mail_mailer']['value']) && $config['mail_mailer']['value'] ? $config['mail_mailer']['value'] : $mail['default'];
        $mail['markdown']['paths'] = [resource_path('views/vendor/mail')];
        $smtp = isset($mail['mailers']['smtp']) ? $mail['mailers']['smtp'] : [];
        $smtp['host'] = isset($config['mail_host']['value']) && $config['mail_host']['value'] ? $config['mail_host']['value'] : $smtp['host'];
        $smtp['port'] = isset($config['mail_port']['value']) && $config['mail_port']['value'] ? $config['mail_port']['value'] : $smtp['port'];
        $smtp['username'] = isset($config['mail_username']['value']) && $config['mail_username']['value'] ? $config['mail_username']['value'] : $smtp['host'];
        $smtp['password'] = isset($config['mail_password']['value']) && $config['mail_password']['value'] ? $config['mail_password']['value'] : $smtp['password'];
        $smtp['timeout'] = isset($config['mail_timeout']['value']) && $config['mail_timeout']['value'] ? $config['mail_timeout']['value'] : $smtp['timeout'];
        $smtp['encryption'] = isset($config['mail_source']['value']) && $config['mail_source']['value'] ? $config['mail_source']['value'] : $smtp['encryption'];
        $smtp['timeout'] = 10;
        if ($mail['default'] != 'smtp') {
            return false;
        }


        $mail['mailers']['smtp'] = $smtp;
        $mail['from']['address'] = $smtp['username'];
        $mail['from']['name'] = ConfigService::make()->getConfigByCode('app_name', '星链社区');
        $this->config = array_merge($config, $smtp);
        if ($mailKey != md5(json_encode($mail))) {
            file_put_contents(base_path() . '/config/mail.php', "<?php \n /* 邮箱服务配置 */ \n return " . var_export($mail, true) . ';' . "\n ?>");
        }
        return true;
    }

    /**
     * 静态入口
     * @return SmsService|static|null
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }

        return self::$instance;
    }

    /**
     * @param $accessKeyId
     * @param $accessKeySecret
     * @return mixed
     */
    public function createClient($accessKeyId, $accessKeySecret, $endpoint)
    {
        $config = new Config([
            // 必填，您的 AccessKey ID
            "accessKeyId" => $accessKeyId,
            // 必填，您的 AccessKey Secret
            "accessKeySecret" => $accessKeySecret
        ]);
        // 访问的域名
        $config->endpoint = $endpoint;
        return new Dysmsapi($config);
    }

    /**
     * 验证码
     * @param $email
     * @param string $scene
     * @return bool
     */
    public function send($email, $scene = 'login')
    {
        $key = $email?explode('@', $email)[0] : $email;
        $cacheKey = "caches:email:{$key}:{$scene}";
        if (RedisService::get($cacheKey . '_lock')) {
            $this->error = 2011;
            return false;
        }

        if (empty($email)) {
            $this->error = 2014;
            return false;
        }

        try {
            $appName = ConfigService::make()->getConfigByCode('app_name', '星链社交');
            $title = isset($this->config['mail_title_' . $scene]['value']) && $this->config['mail_title_' . $scene]['value'] ? $this->config['mail_title_' . $scene]['value'] : "邮箱验证码";
            $template = isset($this->config['mail_template_' . $scene]['value']) && $this->config['mail_template_' . $scene]['value'] ? $this->config['mail_template_' . $scene]['value'] : "您的验证码是：{code}，10分钟有效期，请勿泄漏给他人！！！";
            $template = $template . '\n\n' . $appName;

            // 生成验证码
            $code = rand(1000, 9999);
            $template = str_replace('\n', "<br/>", $template);
            $template = str_replace('{code}', "<span class='code'>{$code}</span>", $template);
            $template = htmlspecialchars_decode($template);

            //
            $appLogo = get_image_url(ConfigService::make()->getConfigByCode('app_logo', '/logo.png'));
            RedisService::set($cacheKey . '_lock', ['email' => $email, 'code' => $code, 'date' => date('Y-m-d H:i:s')], rand(5, 10));
            Mail::send('emails.index', ['title' => $title, 'template' => $template, 'logo' => $appLogo, 'app_name' => $appName], function ($mail) use ($email, $title) {
                $mail->from($this->config['username'], '星链社交'); // 发送者
                $mail->subject($title);  // 标题
                $mail->to($email);  // 接受者
            });
            $error = Mail::failures();
            if (!$error) {
                RedisService::set($cacheKey, ['email' => $email, 'code' => $code, 'date' => date('Y-m-d H:i:s')], 600);
                return true;
            }

            return false;
        } catch (\Exception $exception) {
            $this->error = $exception->getMessage();
            return false;
        }
    }

    /**
     * 发送平台消息
     * @param $message 消息内容
     * @param $title 标题
     * @return bool
     */
    public function sendPlatformEmail($message, $title='')
    {
        $email = ConfigService::make()->getConfigByCode('manage_email', '');
        if ($email) {
            try {
                $appName = ConfigService::make()->getConfigByCode('app_name', '星链社交');
                if(empty($title)){
                    $title = isset($this->config['mail_title_platform']) && $this->config['mail_title_platform']['value'] ? $this->config['mail_title_platform']['value'] : "来自星链社交的管理员消息通知";
                }
                $appLogo = get_image_url(ConfigService::make()->getConfigByCode('app_logo', '/logo.png'));
                Mail::send('emails.index', ['title' => $title, 'template' => $message, 'logo' => $appLogo, 'app_name' => $appName], function ($mail) use ($email, $title) {
                    $mail->from($this->config['username'], '星链社交'); // 发送者
                    $mail->subject($title);  // 标题
                    $mail->to($email);  // 接受者
                });
                $error = Mail::failures();
                if (!$error) {
                    return true;
                }

                return false;
            } catch (\Exception $exception) {
                $this->error = $exception->getMessage();
                return false;
            }
        }
    }


    /**
     * 发送用户消息
     * @param $userId 用户ID
     * @param $message 消息内容
     * @param $title 标题
     * @return bool
     */
    public function sendUserEmail($userId, $message, $title='', $type=1)
    {
        if ($userId && $message) {
            try {
                $appName = ConfigService::make()->getConfigByCode('app_name', '星链社交');
                if(empty($title)){
                    $title = isset($this->config['mail_title_user']) && $this->config['mail_title_user']['value'] ? $this->config['mail_title_user']['value'] : "消息通知";
                }

                // 系统消息
                $userInfo = MemberModel::where(['id'=> $userId])->select(['id','email','nickname','avatar'])->first();
                $email = isset($userInfo['email'])? $userInfo['email'] : '';
                $types = [4,5];
                $pushStatus = false;
                $datas = MemberSettingService::make()->getSetting($userId);
                if($datas){
                    foreach ($datas as $k => $v){
                        if($v==1){
                            if($k == 'receive_app'){
                                $pushStatus = true;
                                $types[] = 1;
                            }else if ($k == 'receive_order'){
                                $types[] = 2;
                            }else if ($k == 'receive_account'){
                                $types[] = 3;
                            }
                        }

                    }
                }else{
                    $pushStatus = true;
                    $types = [1,2,3,4,5];
                }

                if($userInfo && $userId && $pushStatus && in_array($type, $types)){
                    $log = [
                        'to_uid'=> $userId,
                        'to_user_name'=> isset($userInfo['nickname'])? $userInfo['nickname'] : '',
                        'to_user_avatar'=> isset($userInfo['avatar'])? $userInfo['avatar'] : '',
                        'from_user_name'=> $appName,
                        'chat_type'=> 0,
                        'type'=> $type,
                        'title'=> $title,
                        'description'=> $title,
                        'content'=> $message,
                        'chat_key'=> "0{$userId}",
                        'create_time'=> time(),
                        'status'=> 1,
                        'mark'=> 1,
                    ];
                    MessageModel::insert($log);
                }

                // 发送邮件
                if(in_array($type, [2,3]) && $email){
                    $appLogo = get_image_url(ConfigService::make()->getConfigByCode('app_logo', '/logo.png'));
                    Mail::send('emails.index', ['title' => $title, 'template' => $message, 'logo' => $appLogo, 'app_name' => $appName], function ($mail) use ($email, $title) {
                        $mail->from($this->config['username'], '星链社交'); // 发送者
                        $mail->subject($title);  // 标题
                        $mail->to($email);  // 接受者
                    });
                    $error = Mail::failures();
                    if ($error) {
                        return false;
                    }
                }


                return true;
            } catch (\Exception $exception) {
                $this->error = $exception->getMessage();
                return false;
            }
        }
    }

    /**
     * 发送阿里云邮件
     * @param $email
     * @param string $scene
     * @return bool
     */
    public function aliSend($email, $scene = 'login')
    {
        $key = $email?explode('@', $email)[0] : $email;
        $cacheKey = "caches:email:{$key}:ali_{$scene}";
        if (RedisService::get($cacheKey . '_lock')) {
            $this->error = 2011;
            return false;
        }

        if (empty($email)) {
            $this->error = 2014;
            return false;
        }

        $config = ConfigService::make()->getConfigOptionByGroup(3);
        $accessKey = isset($config['ali_email_access_key']) ? trim($config['ali_email_access_key']) : '';
        $accessSecret = isset($config['ali_email_access_secret']) ? trim($config['ali_email_access_secret']) : '';
        $accountName = isset($config['mail_username']) ? trim($config['mail_username']) : '';
        $endpoint = isset($config['ali_email_endpoint']) ? trim($config['ali_email_endpoint']) : '';
        if (empty($accessKey) || empty($accessSecret) || empty($templateCode) || empty($smsAccountName) || empty($endpoint)) {
            $this->error = 2019;
            return false;
        }

        $title = isset($this->config['mail_title_' . $scene]['value']) && $this->config['mail_title_' . $scene]['value'] ? $this->config['mail_title_' . $scene]['value'] : "星链注册邮箱验证码";
        $template = isset($this->config['mail_template_' . $scene]['value']) && $this->config['mail_template_' . $scene]['value'] ? $this->config['mail_template_' . $scene]['value'] : "您的验证码是：{code}，10分钟有效期，请勿泄漏给他人！！！";

        // 生成验证码
        $code = rand(1000, 9999);
        $template = str_replace('{code}', $code, $template);

        $client = $this->createClient($accessKey, $accessSecret, $endpoint);
        $params = [
            "templateName" => $templateCode,
            "accountName" => $accountName,
            "addressType" => 1,
            "replyToAddress" => false,
            "toAddress" => $email,
            "subject" => $title,
            "htmlBody" => $template,
        ];
        $singleSendMailRequest = new SingleSendMailRequest($params);

        $runtime = new RuntimeOptions([]);
        try {
            $client->singleSendMailWithOptions($singleSendMailRequest, $runtime);
            $this->error = 2020;
            return true;
        } catch (\Exception $exception) {
            RedisService::set($cacheKey . '_error', ['params' => $params, 'error' => $exception->getMessage()], 3600);
            $this->error = 2021;
            return false;
        }
    }

    /**
     * 短信验证码验证
     * @param string $email 邮箱地址
     * @param string $code 当前验证码
     * @param string $type 验证码场景类型，login-登录，reg-注册
     * @return bool
     */
    public function check($email, $code, $type = 'login')
    {
        if ($code == '1100') {
            return true;
        }
        $key = $email?explode('@', $email)[0] : $email;
        $cacheKey = "caches:email:{$key}:{$type}";
        $data = RedisService::get($cacheKey);
        $smsCode = isset($data['code']) ? $data['code'] : '';
        if (empty($data) || empty($smsCode)) {
            $this->error = '2012';
            return false;
        }

        if ($smsCode != $code) {
            $this->error = '2013';
            return false;
        }

        RedisService::clear($cacheKey);
        return true;
    }

    /**
     * 短信验证码验证
     * @param string $email 邮箱地址
     * @param string $code 当前验证码
     * @param string $type 验证码场景类型，login-登录，reg-注册
     * @return bool
     */
    public function checkAli($email, $code, $type = 'login')
    {
        if ($code == '1100') {
            return true;
        }

        $key = $email?explode('@', $email)[0] : $email;
        $cacheKey = "caches:email:{$key}:ali_{$type}";
        $data = RedisService::get($cacheKey);
        $smsCode = isset($data['code']) ? $data['code'] : '';
        if (empty($data) || empty($smsCode)) {
            $this->error = '2012';
            return false;
        }

        if ($smsCode != $code) {
            $this->error = '2013';
            return false;
        }

        RedisService::clear($cacheKey);
        return true;
    }
}