game-sdk/simplewind/huo/controller/queue/CpaReversalQueue.php

<?php
/**
 * CpaReversalQueue.php UTF-8
 * Cpa倒量通知异步队列
 *
 * @date    : 2019/03/21 15:24
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : chenbingling <cbl@huosdk.com>
 * @version : HuoMp 1.0
 */

namespace huo\controller\queue;

use huo\controller\common\Base;
use huolib\queue\constant\ClassConst;
use huolib\queue\constant\JobConst;
use huolib\status\CommonStatus;
use think\Queue;

class CpaReversalQueue extends Base {
    protected $param     = [];
    protected $job_class = '';
    protected $job_name  = '';

    public function __construct($s_data = []) {
        $this->job_class = ClassConst::CLASS_CPA_REVERSAL_FIRE;
        $this->job_name = JobConst::JOB_CPA_REVERSAL;
        $this->param = $s_data;
        $this->param['ts'] = time();
    }

    /**
     * 返回数据
     *
     * @param int   $code
     * @param array $data
     *
     * @return array
     */
    protected function retSucMsg($code = CommonStatus::NO_ERROR, $data = []) {
        /* 数据录入LOG */
        $this->param['queue'] = '1';

        return $this->huoSuccess($code, CommonStatus::getMsg($code), $data);
    }

    /**
     * 返回数据
     *
     * @param $code
     *
     * @return array|mixed
     */
    protected function retErrMsg($code = CommonStatus::PUSH_QUEUE_ERROR) {
        /* 数据录入LOG */
        $this->param['queue'] = '0';

        return $this->huoError($code, CommonStatus::getMsg($code));
    }

    /**
     * 入队列
     *
     * @return array
     */
    public function pushQueue() {
        if (class_exists('think\\Queue')) {
            $_is_pushed = Queue::push($this->job_class, $this->param, $this->job_name);
            if ($_is_pushed === false) {
                return $this->retErrMsg();
            }
        }

        return $this->retSucMsg();
    }

    /**
     * @return array
     */
    public function getParam() {
        return $this->param;
    }

    /**
     * @param array $param
     */
    public function setParam($param) {
        $this->param = $param;
    }

    /**
     * @return string
     */
    public function getJobClass() {
        return $this->job_class;
    }

    /**
     * @param string $job_class
     */
    public function setJobClass($job_class) {
        $this->job_class = $job_class;
    }

    /**
     * @return string
     */
    public function getJobName() {
        return $this->job_name;
    }

    /**
     * @param string $job_name
     */
    public function setJobName($job_name) {
        $this->job_name = $job_name;
    }
}