book_admin/application/main/service/MqUserPaySuccessService.php

<?php
namespace app\main\service;

use app\common\service\CampaignService;
use app\main\service\BaseService;
use app\main\service\MqService;
use think\Config;

class MqUserPaySuccessService extends BaseService
{
    protected const EXCHANGE_NAME ='cps.ex.delay.topic';

    protected const ROUTING_KEY = 'user.recharge.success';


    /**
     * @var MqUserPayCancelService
     */
    protected static $self = null;
    /**
     * @return BaseService|MqUserPayCancelService
     */
    public static function instance()
    {
        if (self::$self == NULL) {
            self::$self = new self();
        }
        return self::$self;
    }

    /**
     * 充值成功 活动推送
     */
    public function sendActiveToUser( $order, $userInfo )
    {
        $createDate = date('Ymd',$userInfo['createtime']);//用户注册时间不是当天的
        if ( $userInfo['id'] && date('Ymd',time()) != $createDate ){
            $activeId = CampaignService::instance()->checkActive($userInfo['id']);
            LogService::info('充值成功-活动id'.$activeId);
            if ( $activeId > 0 ){
                $host = getCurrentDomain($userInfo['channel_id']);
                $url = $host."/index/recharge/campaignIndex?from=wechat&user_id=".$userInfo['id']."&active_id=".$activeId;
                $data['user_id'] = $userInfo['id'];
                $data['channel_id'] = $userInfo['channel_id'];
                $data['openid'] = $userInfo['openid'];
                $data['goods_id'] = $order['goods_id'];
                $data['active_id'] = $activeId;
                $msg2['title'] = "您已充值".$order['money']."元，获得".$order['kandian']."书币。";
                $msg2['image'] = $host."assets/img/campaign_push.png";
                $msg2['url'] = $url;
                $msg2['description'] = '恭喜获得读书挑战赛资格，快来一起瓜分书币大奖吧~';
                $data['msg'] = $msg2;
                $timeout  = 60;
                $mq = MqService::instance()->getDotMqInstance();
                $mq->transferDelayExchange($data, self::ROUTING_KEY,$timeout,self::EXCHANGE_NAME,  'topic');
            }
        }

        return;
    }
}