game-sdk/simplewind/huolib/queue/job/OrderQrFire.php

<?php
/**
 * OrderQrFire.php UTF-8
 * 订单二维码处理
 *
 * @date    : 2018/10/19 17:27
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : wuyonghong <wyh@huosdk.com>
 * @version : HuoMp 1.0
 */

namespace huolib\queue\job;

use huomp\controller\order\OrderOut;
use think\queue\Job;

class OrderQrFire extends Fire {
    static $g_i = 0;

    /**
     * fire方法是消息队列默认调用的方法
     *
     * @param Job         $job  当前的任务对象
     * @param array|mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data) {
        self::$g_i++;
        $_is_job_done = $this->doJob($data);
        $runtime = round(microtime(true) - THINK_START_TIME, 10);
        echo $runtime.'  '.self::$g_i;
        if ($_is_job_done) {
            //如果任务执行成功， 记得删除任务
            $job->delete();
//            print("<info>Hello Job has been done and deleted"."</info>\n");
        } else {
            if ($job->attempts() > 3) {
                //通过这个方法可以检查这个任务已经重试了几次了
//                print("<warn>Hello Job has been retried more than 3 times!"."</warn>\n");
                $job->delete();
                // 也可以重新发布这个任务
//                print("<info>Hello Job will be availabe again after 2s."."</info>\n");
                //$job->release(2); //$delay为延迟时间，表示该任务延迟2秒后再执行
            }
        }
    }

    /**
     * 根据消息中的数据进行实际的业务处理
     *
     * @param array $data 发布任务时自定义的数据
     *
     * @return bool 任务执行的结果
     */
    public function doJob($data) {
        $_order_id = isset($data['order_id']) ? $data['order_id'] : '';
        if (empty($_order_id) && !empty($data['mem_id']) && !empty($data['app_id'])) {
            $_mem_id = $data['mem_id'];
            $_app_id = $data['app_id'];
            $_rs = (new OrderOut())->genMemAppQrCodeQueue($_mem_id, $_app_id);
        } elseif (!empty($_order_id)) {
            $_rs = (new OrderOut())->genOrderQrQueue($_order_id);
        } else {
            $_rs = false;
        }

        return $_rs;
    }
}