src/Biz/Distributor/Event/OrderStatusSubscriber.php

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

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

<?php

namespace Biz\Distributor\Event;

use AppBundle\Common\ArrayToolkit;
use Biz\Distributor\Util\DistributorUtil;
use Codeages\Biz\Framework\Event\Event;
use Codeages\Biz\Framework\Event\EventSubscriber;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class OrderStatusSubscriber extends EventSubscriber implements EventSubscriberInterface
{
    public static function getSubscribedEvents()
    {
        return array(
            'order.finished' => 'onOrderChangeStatus',
            'order.success' => 'onOrderChangeStatus',
            'order.refunded' => 'onOrderChangeStatus',
        );
    }

    public function onOrderChangeStatus(Event $event)
    {
        $context = $event->getSubject();

        $orderIdItems = ArrayToolkit::index($context['items'], 'order_id');
        $orderIds = array_keys($orderIdItems);

        $orders = $this->getOrderService()->findOrdersByIds($orderIds);

        $userIds = ArrayToolkit::column($orders, 'user_id');
        $users = $this->getUserService()->findUsersByIds($userIds);

        $distributorProductOrders = array();  //商品分销订单
        $distributorUserOrders = array();     //用户拉新订单
        foreach ($orders as $order) {
            if (!empty($orderIdItems[$order['id']]['create_extra']['distributorToken'])) {
                $productToken = $orderIdItems[$order['id']]['create_extra']['distributorToken'];
                $productType = DistributorUtil::getTypeByToken($productToken);
                if (empty($distributorProductOrders[$productType])) {
                    $distributorProductOrders[$productType] = array();
                }
                $distributorProductOrders[$productType][] = $order;
            } elseif (!empty($users[$order['user_id']])) {
                $user = $users[$order['user_id']];
                if ('distributor' == $user['type']) {
                    $distributorUserOrders[] = $order;
                }
            }
        }

        $this->getDistributorOrderService()->batchCreateJobData($distributorUserOrders);

        foreach ($distributorProductOrders as $type => $orders) {
            DistributorUtil::getDistributorServiceByType($this->getBiz(), $type)->batchCreateJobData($orders);
        }
    }

    protected function getOrderService()
    {