game-sdk/simplewind/extend/huoIdentify/lib/queue/controller/ReportQueue.php

<?php
/**
 * ReportQueue.php UTF-8
 *
 * @date    : 2021/5/6 17:12
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : chenbingling <cbl@huosdk.com>
 * @version : HUOSDK-IDENTITY 1.0
 */

namespace huoIdentify\lib\queue\controller;

use huoIdentify\controller\Common;
use huoIdentify\lib\queue\constant\ClassConst;
use huoIdentify\lib\queue\constant\JobConst;
use think\Config;

class ReportQueue extends Common {
    /**
     * 入队列处理
     *
     * @param $app_id
     * @param $mem_id
     * @param $is_login
     *
     * @return bool
     */
    public function push($app_id, $mem_id, $is_login) {
        $_queue_status = Config::get('IDENTIFY_QUEUE');
        if (false === $_queue_status) {
            return false;
        }
        if (empty($mem_id) || empty($app_id)) {
            return false;
        }
        $_queue_data = [
            'app_id'       => $app_id,
            'mem_id'       => $mem_id,
            'is_login'     => $is_login,
            'report_class' => ClassConst::CLASS_IDENTIFY_REPORT_CLASS,
        ];
        $_queue_class = new Queue();
        $_queue_class->setJobClass(ClassConst::CLASS_IDENTIFY_REPORT_FIRE);
        $_queue_class->setJobName(JobConst::JOB_IDENTIFY_REPORT);
        $_queue_class->setParam($_queue_data);
        $_queue_class->pushQueue();

        return true;
    }

    /**
     * 入队列处理
     *
     * @param $app_id
     * @param $mem_id
     * @param $is_login
     *
     * @return bool
     */
    public function unionPush($app_id, $mem_id, $is_login) {
        $_queue_status = Config::get('IDENTIFY_QUEUE');
        if (false === $_queue_status) {
            return false;
        }
        if (empty($mem_id) || empty($app_id)) {
            return false;
        }
        $_queue_data = [
            'app_id'       => $app_id,
            'mem_id'       => $mem_id,
            'is_login'     => $is_login,
            'report_class' => ClassConst::CLASS_IDENTIFY_REPORT_CLASS_UNION,
        ];
        $_queue_class = new Queue();
        $_queue_class->setJobClass(ClassConst::CLASS_IDENTIFY_REPORT_FIRE);
        $_queue_class->setJobName(JobConst::JOB_IDENTIFY_REPORT);
        $_queue_class->setParam($_queue_data);
        $_queue_class->pushQueue();

        return true;
    }
}