book_admin/application/main/service/BookDotService.php

<?php
/**
 * Created by PhpStorm.
 * User: lts
 * Date: 2019-08-21
 * Time: 20:07
 */

namespace app\main\service;

use app\main\constants\MqConstants;
use app\main\model\object\DotBookCollectObject;

class BookDotService extends BaseService
{
    const exchangeName = 'cps.ex.topic';

    /**
     * @var BookDotService
     */
    protected static $self = null;

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

    /**
     * 打点
     * @param array $data 推送内容
     */
    public function dotBookInfo($data)
    {
        $mq = MqService::instance()->getDotMqInstance();
        LogService::info('[ MQ ] [ DOT ] [BookInfo] ' . print_r(json_encode($mq),
                true) . '::Data::' . print_r(json_encode($data), true));
        $exchangeName = self::exchangeName;
        $mq->transferExchange($data, $exchangeName, MqConstants::ROUTING_KEY_APP_SPENDING, 'topic');
    }

    public function generateBookData(DotBookCollectObject $bookDotInfo)
    {
        $data = [
            'book_id' => $bookDotInfo->bookId,
            'channel_id' => $bookDotInfo->channelId,
            'event_time' => $bookDotInfo->eventTime,
            'recharge_money' => empty($bookDotInfo->rechargeMoney) ? 0 : $bookDotInfo->rechargeMoney,
            'count_kandian' => empty($bookDotInfo->countKandian) ? 0 : $bookDotInfo->countKandian,
            'free_kandian' => empty($bookDotInfo->freeKandian) ? 0 : $bookDotInfo->freeKandian,
            'kandian' => empty($bookDotInfo->kandian) ? 0 : $bookDotInfo->kandian,
            'business_line' => $bookDotInfo->businessLine,
        ];
        return $data;
    }
}