WkMessage/application/job/Sendsms.php

<?php
/***
 * User: jun_hy
 * Date: 2022/7/14
 * Time: 10:48
 */

namespace app\job;
use think\queue\Job;
use app\common\model\Assms;
use think\Db;
class Sendsms
{
    public function fire(Job $job, $data)
    {
        $send =new Assms();
        $result = $send->sendSms($data);
        if (isset($result['msg'])&&!empty($result['msg'])) {
            $isJobDone = true;
        }else{
            $isJobDone = false;
        }
        $new['uptime']=time();
        $new['status']=3;
        if ($isJobDone) {
            //如果任务执行成功， 删除任务
            $log_id =$data['log_id'];
            Db::name('sms_log')->where($log_id)->update($new);
            $job->delete(); // 删除任务
        }else{
            if ($job->attempts() > 3) {
                $job->delete(); // 删除任务
            }else{
                //如果任务执行失败， 重发 100秒后在执行
                $job->release(100);
            }
        }
    }
}