WkMessage/application/job/Sendcoupon.php

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

namespace app\job;
use think\queue\Job;
use app\common\model\Coupon;
use think\Db;
class Sendcoupon
{
    public function fire(Job $job, $data)
    {
        $send =new Coupon();
        $result = $send->sendCoupon($data);
        if (isset($result['msg'])&&!empty($result['msg'])) {
            $isJobDone = true;
        }else{
            $isJobDone = false;
        }
        $data['addtime']=date('Y-m-d H:i:s',time());
        if ($isJobDone) {
            //如果任务执行成功， 删除任务
            $data['code']=$result['code'];
            Db::name('send_coupon_log')->insertGetId($data);
            $job->delete(); // 删除任务
        }else{
            if ($job->attempts() > 3) {
                $job->delete(); // 删除任务
            }else{
                //如果任务执行失败， 重发 100秒后在执行
                $job->release(100);
            }
        }
    }
}