qimall/addons/YunfastPay/common/services/HandleMqService.php

<?php

namespace addons\YunfastPay\common\services;

use Exception;
use Yii;

/**
 * Mq队列处理
 * HandleMqService class
 * @package addons\YunfastPay\common\services
 */
class HandleMqService 
{
    /**
     * 处理门店分账代付
     *
     * @param array $data
     * [
     *     id => int,
     *     mall_id => int,
     *     store_id => int,
     * ]
     * @return void
     */
    public static function handleStoreAgent($data)
    {
        $id = $data['id'];
        $mall_id = $data['mall_id'];

        $service = new StoreService(['mall_id' => $mall_id]);
        try {
            $service->agentBySplitBillLogId($id);
        } catch (Exception $e) {
            $message = sprintf('门店分账失败: $s, $s', $e->getLine(), $e->getMessage());
            Yii::error($message);
        }
    }
}