anxinliao/addons/faqueue/library/jobs/SmsJob.php

<?php
/**
 * Created by PhpStorm.
 * User: zhoujun
 * Date: 2018/9/1
 * Time: 11:40
 */
namespace addons\faqueue\library\jobs;

use addons\faqueue\model\FaqueueLog;
use app\common\library\Sms;
use think\Log;
use think\queue\job;

class SmsJob
{
    public function fire(Job $job, $data){

        $method = $data['method'];

        switch ($method){
            case 'send':
                $result = Sms::send($data['mobile'],$data['code'],$data['event']);
                break;
            case 'notice':
                $result = Sms::notice($data['mobile'],$data['smg'],$data['template']);
                break;
            default:
                $result = false;
        }

        if($result){
            Log::write("发送成功，result：".print_r($result,true));
            $job->delete();
            (new FaqueueLog())->log($job->getQueue(),$job->getName(),$data);
        }else{
            $job->release();
            Log::write("短信发送失败：".print_r([
                    'name' => $job->getName(),
                    'result' => $result
                ],true),'error');
        }

    }

    public function failed($data){
        Log::write("短信任务失败：".print_r(['data' => $data,],true),'error');
    }
}