zhishifufei_php/application/index/job/PullDoPink.php

<?php

/**
 * 文件路径： \application\index\job\Hello.php
 * 这是一个消费者类，用于处理 helloJobQueue 队列中的任务
 */
// +----------------------------------------------------------------------
// | 天诚科技 [ 刘海东 17600099397赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.tczxkj.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 该系统并不是自由软件，未经许可不能去掉相关版权
// +----------------------------------------------------------------------
// | Author:甘肃天诚志信电子商务有限公司 刘海东 联系电话维系17600099397
// +----------------------------------------------------------------------

namespace app\index\job;

use app\admin\model\ump\StorePink;
use app\wap\model\special\SpecialBuy;
use think\queue\Job;

class PullDoPink
{

    /**
     * fire方法是消息队列默认调用的方法
     * @param Job $job 当前的任务对象
     * @param array|mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data)
    {
        // 有些消息在到达消费者时,可能已经不再需要执行了
        $isJobStillNeedToBeDone = $this->checkDatabaseToSeeIfJobNeedToBeDone($data);
        if (!$isJobStillNeedToBeDone) {
            $job->delete();
            return;
        }
        if (isset($data['doName']) && $data['doName']) {
            $doName = $data['doName'];
            $isJobDone = $this->$doName($data);
        } else
            $isJobDone = $this->doPinkJob($data);


        if ($isJobDone) {
            // 如果任务执行成功， 记得删除任务
            $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|mixed $data 发布任务时自定义的数据
     * @return boolean                 任务执行的结果
     */
    private function checkDatabaseToSeeIfJobNeedToBeDone($data)
    {
        return true;
    }

    /**
     * 根据消息中的数据进行实际的业务处理...
     */
    private function doPinkJob($data)
    {
        $pink_id = $data['pinkInfo']['pink_id'];
        if ($pink_id) {
            $pink_info = \app\wap\model\store\StorePink::where(['id' => $pink_id, 'k_id' => 0, 'status' => 1])->find();
            if ($pink_info ? $pink_info = $pink_info->toArray() : []) {
                list($pinkAll, $pinkT, $count, $idAll) = \app\wap\model\store\StorePink::getPinkMemberAndPinkK($pink_info);
                \app\wap\model\store\StorePink::PinkFail($pink_info['uid'], $idAll, $pinkAll, $pinkT, $count, 1, [], true, true);
            }
        }
        return true;
    }

    private function doLiveStudioJob($data)
    {
        $item = $data['pinkInfo'];
        if ($item) {
            if ($item['pay_type'] == 1 && $item['member_pay_type'] == 1) {
                $orderList = \app\wap\model\store\StoreOrder::where(['cart_id' => $item['special_id'], 'type' => 0])->column("uid");
            } elseif ($item['pay_type'] == 1 && $item['member_pay_type'] == 0) {
                $order = \app\wap\model\store\StoreOrder::where(['cart_id' => $item['special_id'], 'type' => 0])->column("uid");
                $user = \app\wap\model\user\User::where('is_h5user', 0)->where('level', 1)->column("uid");
                $orderList = array_merge($order, $user);
            } else {
                $orderList = \app\wap\model\user\User::where('is_h5user', 0)->column("uid");
            }
            if (count($orderList) <= 0) return true;
            $site_url = \service\SystemConfigService::get('site_url');
            $orderList = array_unique($orderList);
            foreach ($orderList as $k => $v) {
                if ($openId = \app\wap\model\user\WechatUser::where('uid', $v)->value('openid')) {
                    $wechat_notification_message = \service\SystemConfigService::get('wechat_notification_message');
                    if ($wechat_notification_message == 1) {
                        \service\WechatTemplateService::sendTemplate($openId, \service\WechatTemplateService::LIVE_START_NOTICE, [
                            'first' => '叮！直播马上开始啦，精彩不容错过！',
                            'keyword1' => $item['live_title'],
                            'keyword2' => $item['start_play_time'],
                            'remark' => '直播间通道'
                        ], $site_url . \think\Url::build('wap/special/details', ['id' => $item['special_id']]));
                    } else {
                        $data['thing5']['value'] = $item['live_title'];
                        $data['time2']['value'] = $item['start_play_time'];
                        \app\wap\model\routine\RoutineTemplate::sendBroadcastReminder($data, $v, $site_url . \think\Url::build('wap/special/details', ['id' => $item['special_id']]));
                    }
                }
                $dat['title'] = $item['live_title'];
                \app\wap\model\wap\SmsTemplate::sendSms($v, $dat, 'LIVE_START_NOTICE');
            }
        }
        return true;
    }
}