qimall/common/enums/RabbitMqEnum.php

<?php

namespace common\enums;

use common\enums\BaseEnum;


class RabbitMqEnum extends BaseEnum
{
    //队列
    const TASK_QUEUE = 'task_queue'; //多进程任务队列，消息推送，等耗时任务
    const CHAIN_QUEUE = 'chain_queue'; // 供应链任务队列
    const ORDER_QUEUE = 'order_queue'; //多进程任务队列，消息推送，等耗时任务
    const USER_WALLET_QUEUE = 'user_wallet_queue';  //用户钱包队列
    const DELAY_QUEUE = 'delay_queue'; //多进程任务队列，延时任务处理
    const DELAY_HANDLE_QUEUE = 'delay_handle_queue'; //延时任务处理
    const DELAY_RETRY_QUEUE = 'delay_retry_queue';  //延迟重试队列
    const LEVELUP_QUEUE = 'level_up_queue'; //升级队列，多进程任务队列，等耗时任务
    const CHANGE_RELATIONSHIP_QUEUE = 'change_relationship';// 修改关系链队列
    const GOODS_QUEUE = 'goods';// 编辑商品队列
    const GROUP_BUY_QUEUE = 'group_buy_queue';  //拼团队列
    const CENSUS_QUEUE = 'census_queue';
    const IMPORT_USER = 'import_user';
    const LUCKY_GROUP_QUEUE = 'lucky_group_queue';  //幸运拼团开队列
    const STATISTICS_QUEUE = 'statistics_queue';  //统计队列
    const UPLOAD_QUEUE = 'upload_queue';  //上传到第三方

    const CAKE_QUEUE = 'cake_queue';//蛋糕，电影任务队列
    const CAKE_ORDER_QUEUE = 'cake_order_queue';//蛋糕电影订单队列
    const CARD_COUPONS_QUEUE = 'card_coupons_queue';//卡券队列

    const QSC_QUEUE = 'qsc_queue';//千禧供应链
    const QSC_ORDER_QUEUE = 'qsc_order_queue';//千禧供应链

    const IMPORT_KAMI = 'import_kami';

    const LONG_DURATION_QUEUE = 'long_duration_queue';//长耗时队列
    // 因为订单队列消息处理时间过长，所以使用长队列(但是长队列有很多地方使用。所以添加只关于订单的长队列)
    const LONG_ORDER_QUEUE = 'long_order_queue';


    //交换机
    const EXCHANGE_TASK = 'task_exchange';
    const EXCHANGE_CHAIN = 'chain_exchange';
    const EXCHANGE_ORDER = 'order_exchange';
    const EXCHANGE_TASK_USER_WALLET = 'user_wallet_exchange';
    const EXCHANGE_DELAY = 'delay_handle_exchange';
    const EXCHANGE_DELAY_RETRY = 'delay_retry_exchange';
    const EXCHANGE_DELAY_RETRY_CACHE = 'delay_retry_cache_exchange';
    const EXCHANGE_DELAY_CACHE = 'delay_cache_exchange';
    const EXCHANGE_CAKE = 'cake_exchange';
    const EXCHANGE_CAKE_ORDER = 'cake_order_exchange';
    const EXCHANGE_CARD_COUPONS = 'card_coupons_exchange';

    const EXCHANGE_QSC = 'qsc_exchange';    //  千禧供应链
    const EXCHANGE_QSC_ORDER = 'qsc_order_exchange';    //  千禧供应链
    const EXCHANGE_TASK_CHANGE_RELATIONSHIP = 'change_relationship_exchange_task';
    const EXCHANGE_TASK_GOODS = 'goods_exchange_task';
    const EXCHANGE_TASK_GROUP_BUY = 'exchange_task_group_buy';//拼团
    const EXCHANGE_TASK_CENSUS = 'exchange_task_census';//数据统计
    const EXCHANGE_TASK_IMPORT_USER = 'exchange_import_user';//导入会员
    const EXCHANGE_TASK_LUCKY_GROUP = 'exchange_task_lucky_group';//幸运拼团
    const EXCHANGE_STATISTICS = 'exchange_statistics';//统计
    const EXCHANGE_UPLOAD = 'exchange_upload';//上传到第三方

    const EXCHANGE_TASK_IMPORT_KAMI = 'exchange_import_kami';//导入卡密
    const EXCHANGE_LONG_DURATION = 'exchange_long_duration';

    const EXCHANGE_LONG_ORDER =  'exchange_long_order'; // 订单长队列交换机



    //消息前缀
    const RABBITMQ_QUEUE_ID = 'rabbitmq_queue_id';
    const QUEUE_MESSAGE_KEY_PREFIX = 'rabbitmq_queue_content_';
    const DELAY_QUEUE_MESSAGE_KEY_PREFIX = 'rabbitmq_delay_queue_content_';
    const MAX_RETRY_NUM = 3;   //消息最大重试次数

    // 用户资金服务执行结果前缀
    const USER_WALLET_RESUALT_KEY_PREFIX = 'user_wallet_result_';

    /**
     * @return array
     */
    public static function getMap(): array
    {
        return [
            self::TASK_QUEUE =>  '任务队列', //多进程任务队列，消息推送，等耗时任务,
            self::ORDER_QUEUE =>  '订单队列', //多进程任务队列，消息推送，等耗时任务,
            self::DELAY_QUEUE =>  '延时队列', //多进程任务队列，延时任务处理,
            self::LEVELUP_QUEUE =>  '异步升级', //升级队列，多进程任务队列，等耗时任务,
            self::DELAY_RETRY_QUEUE =>  '重试队列',  //延迟重试队列,
            self::CHANGE_RELATIONSHIP_QUEUE =>  '改关系链',// 修改关系链队列,
            self::GOODS_QUEUE =>  '商品队列',// 编辑商品队列,
            self::USER_WALLET_QUEUE =>  '用户钱包队列',  //用户钱包队列,

            self::EXCHANGE_TASK =>  'task_exchange',
            self::EXCHANGE_ORDER =>  'task_order_exchange',
            self::EXCHANGE_DELAY =>  'delay_handle_exchange',
            self::EXCHANGE_DELAY_RETRY =>  'delay_retry_exchange',
            self::EXCHANGE_DELAY_RETRY_CACHE =>  'delay_retry_cache_exchange',
            self::EXCHANGE_TASK_CHANGE_RELATIONSHIP =>  'change_relationship_exchange_task',
            self::EXCHANGE_TASK_GOODS =>  'goods_exchange_task',
            self::EXCHANGE_TASK_USER_WALLET =>  'user_wallet_exchange',
            self::RABBITMQ_QUEUE_ID => 'rabbitmq_queue_id',
            self::QUEUE_MESSAGE_KEY_PREFIX =>  'rabbitmq_queue_content_',
            self::DELAY_QUEUE_MESSAGE_KEY_PREFIX =>  'rabbitmq_delay_queue_content_',
            self::MAX_RETRY_NUM =>  3,   //消息最大重试次数,
            self::USER_WALLET_RESUALT_KEY_PREFIX => 'user_wallet_result_',


        ];
    }

    /**
     * 获取对接交换机
     * @Author：lun
     * @Date：2023-11-20 14:19
     * @Copyright：copyright（c）2023 广东七件事集团
     * @param $key
     * @return string[]
     */
    public static function getConsumeType($key = 'task')
    {
        $data = [
            'task' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK,
                'queue_name' =>  RabbitMqEnum::TASK_QUEUE,
            ],
            'order' => [
                'exchange' => RabbitMqEnum::EXCHANGE_ORDER,
                'queue_name' => RabbitMqEnum::ORDER_QUEUE,
            ],
            'task_user_wallet' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_USER_WALLET,
                'queue_name' => RabbitMqEnum::USER_WALLET_QUEUE,
            ],
            'task_change_relationship' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_CHANGE_RELATIONSHIP,
                'queue_name' => RabbitMqEnum::CHANGE_RELATIONSHIP_QUEUE,
            ],
            'delay_retry' => [
                'exchange' => RabbitMqEnum::EXCHANGE_DELAY_RETRY,
                'queue_name' => RabbitMqEnum::DELAY_RETRY_QUEUE,
            ],
            'task_group_buy' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_GROUP_BUY,
                'queue_name' => RabbitMqEnum::GROUP_BUY_QUEUE,
            ],
            'task_census' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_CENSUS,
                'queue_name' => RabbitMqEnum::CENSUS_QUEUE,
            ],
            'task_lucky_group' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_LUCKY_GROUP,
                'queue_name' => RabbitMqEnum::LUCKY_GROUP_QUEUE,
            ],
            'delay' => [
                'exchange' => RabbitMqEnum::EXCHANGE_DELAY,
                'queue_name' => RabbitMqEnum::DELAY_HANDLE_QUEUE,
            ],
            'statistics' => [
                'exchange' => RabbitMqEnum::EXCHANGE_STATISTICS,
                'queue_name' => RabbitMqEnum::STATISTICS_QUEUE,
            ],
            'task_import_user' => [
                'exchange' => RabbitMqEnum::EXCHANGE_TASK_IMPORT_USER,
                'queue_name' => RabbitMqEnum::IMPORT_USER,
            ],
            'chain' => [
                'exchange'      => RabbitMqEnum::EXCHANGE_CHAIN,
                'queue_name'    => RabbitMqEnum::CHAIN_QUEUE,
            ],
            'upload' => [
                'exchange'      => RabbitMqEnum::EXCHANGE_UPLOAD,
                'queue_name'    => RabbitMqEnum::UPLOAD_QUEUE,
            ]
        ];

        return $data[$key];
    }
}