qimall/addons/ReservationService/common/services/NoticeService.php

<?php

namespace addons\ReservationService\common\services;

use addons\ReservationService\common\enums\ReservationServiceEnum;
use addons\ReservationService\common\logic\SmsMessage;
use addons\ReservationService\common\models\ReservationServiceNotice;
use common\enums\RabbitMqEnum;
use common\enums\StatusEnum;
use common\models\mall\Mall;
use Overtrue\EasySms\PhoneNumber;
use common\helpers\sms\Sms;

class NoticeService
{
    public function task()
    {
        $mall_ids = [];
        foreach (Mall::getEnableMallIds() as $mall_id) {
            //  判断是否开启当前插件
            $config = \Yii::$app->services->setting->addons->get($mall_id, ReservationServiceEnum::ADDONS_NAME, 'basic');
            if (!empty($config['is_enable'])) {
                $mall_ids[] = $mall_id;
            }
        }

        if (!empty($mall_ids)) {
            foreach (ReservationServiceNotice::find()->where(['mall_id' => $mall_ids])
                         ->andWhere(['<=', 'send_at', time()])
                         ->andWhere(['status' => StatusEnum::ENABLED])->each() as $item) {
                $item->status = StatusEnum::DISABLED;
                if ($item->save()) {
                    //  入列
                    \Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_TASK, RabbitMqEnum::TASK_QUEUE, [
                        'id' => $item->id,
                    ],
                        self::class, 'async_handle');
                }
            }
        }
    }

    /**
     * @param array $params
     * @return bool|void
     */
    public function async_handle(array $params)
    {
        if (empty($params)) return;
        $data = ReservationServiceNotice::getOne([
            ['id' => $params['id']]
        ]);
        if (empty($data)) return;

        try {
            $sms = new Sms($data->mall_id, $data->gateway);
            $message = new SmsMessage($data->content);
            //  接受角色不一样，有可能是买家，有可能是团长
            $mobile = new PhoneNumber($data->mobile, $data->area_code);
            if ($message->mall_sms != 'qcloud') {
                $resp = $sms->easySms->send($mobile, $message);
            } else {
                $resp = $sms->easySms->send($data->mobile, $message);
            }
            $data->status = StatusEnum::DELETE;
        } catch (\Throwable $e) {
            $err = [
                'file'  => $e->getFile(),
                'msg'   => $e->getMessage(),
                'line'  => $e->getLine()
            ];
        }
        $data->res = [
            'resp'  => $resp ?? [],
            'err'   => $err ?? [],
        ];
        if (!$data->save() || !empty($err)) {
            \Yii::error(__METHOD__ . " -> " . $data->getErrorMessage());
            return false;
        }
        return true;
    }
}