<?php
/**
 * Created by PhpStorm.
 * User: Bear
 * Date: 2018/11/29
 * Time: 下午5:42
 */

namespace app\main\service;


use app\common\library\Rabbitmq;
use think\Config;
use app\main\model\object\DotObject;
use think\Log;

class MqService extends BaseService
{
    /**
     * @var MqService
     */
    protected static $self = NULL;

    /**
     * @var Rabbitmq
     */
    protected $mq = null;

    /**
     * @return MqService
     */
    public static function instance()
    {
        if (self::$self == NULL) {
            self::$self = new self();
        }

        return self::$self;
    }


    /**
     * @return Rabbitmq
     */
    public function getDotMqInstance()
    {
        if (!$this->mq) {
            $this->mq = new Rabbitmq(Config::get('rabbitmq-dot'));
        }
        return $this->mq;
    }

    /**
     * @param DotObject $dotObject array
     * @return \app\main\model\object\ReturnObject
     */
    public function sendMessage(DotObject $dotObject)
    {
        try {
            $userdotservice = UserdotService::instance();
            $userdotservice->handleTask($dotObject);
        } catch (\Exception $e) {
            return $this->getExceptionReturn($e);
        }
    }

}