vendor/codeages/biz-order-pay/src/Order/Subscriber/OrderSubscriber.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Codeages\Biz\Order\Subscriber;

use Codeages\Biz\Framework\Event\Event;
use Codeages\Biz\Framework\Event\EventSubscriber;
use Codeages\Biz\Framework\Util\ArrayToolkit;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class OrderSubscriber extends EventSubscriber implements EventSubscriberInterface
{
    public static function getSubscribedEvents()
    {
        return array(
            'payment_trade.paid' => 'onPaid',
            'payment_trade.refunded' => 'onTradeRefunded'
        );
    }

    public function onTradeRefunded(Event $event)
    {
        $trade = $event->getSubject();
        $order = $this->getOrderService()->getOrderBySn($trade['order_sn']);
        $orderItems = $this->getOrderService()->findOrderItemsByOrderId($order['id']);
        $refundIds = ArrayToolkit::column($orderItems, 'refund_id');
        $refundIds = array_unique($refundIds);
        foreach ($refundIds as $refundId) {
            $this->getWorkflowService()->setRefunded($refundId);
        }
    }

    public function onPaid(Event $event)
    {
        $trade = $event->getSubject();
        $args = $event->getArguments();
        $data = array(
            'trade_sn' => $trade['trade_sn'],
            'pay_time' => $args['paid_time'],
            'payment' => $trade['platform'],
            'order_sn' => $trade['order_sn'],
            'paid_cash_amount' => $trade['cash_amount'],
            'paid_coin_amount' => $trade['coin_amount'],
        );

        if ($trade['cash_amount'] == 0 && $trade['coin_amount'] > 0) {
            $data['payment'] = 'coin';
        }

        $this->getWorkflowService()->paid($data);
    }

    protected function getWorkflowService()
    {
        return $this->getBiz()->service('Order:WorkflowService');
    }

    protected function getOrderService()
    {
        return $this->getBiz()->service('Order:OrderService');
    }