twong329/crmeb/subscribes/OrderSubscribe.php

<?php

namespace crmeb\subscribes;

use app\models\user\UserNotice;
use think\Event;
use app\admin\model\order\StoreOrder as AdminStoreOrder;
use app\models\store\StoreOrder;
use app\models\user\User;
use crmeb\repositories\NoticeRepositories;
use crmeb\services\workerman\ChannelService;
use think\facade\Config;

/**
 * 订单事件
 * Class OrderSubscribe
 * @package crmeb\subscribes
 */
class OrderSubscribe
{

    public function handle()
    {
    }

    /**
     * 送货发送模板消息
     * @param $event
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function onStoreProductOrderDeliveryAfter($event)
    {
        list($data, $oid) = $event;
        AdminStoreOrder::orderPostageAfter($oid, $data);
    }

    /**
     * 发货发送模板消息
     * @param $event
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function onStoreProductOrderDeliveryGoodsAfter($event)
    {
        list($data, $oid) = $event;
        AdminStoreOrder::orderPostageAfter($oid, $data);
    }

    /**
     * 订单状态不退款 发送模板消息
     * @param $event
     */
    public function onStoreProductOrderRefundNAfter($event)
    {
        list($data, $order) = $event;
        AdminStoreOrder::refundNoPrieTemplate($order['id'], $data);
        // TODO: 发送消息
        $icon = Config::get('app.header_cs_1', '');
        UserNotice::sendNoticeTo(
            $order['uid'],
            '您的退款申请已处理',
            '您申请退款的订单号： ' . $order['order_id']
                . ' 未成功退款；原因：' . $data . '。如有问题，请联系客服。',
            $icon
        );
    }

    /**
     * 线下付款成功后
     * @param $event
     */
    public function onStoreProductOrderOffline($event)
    {
        list($id) = $event;
        //订单编号  $id
    }

    /**
     * 修改订单金额
     * @param $event
     */
    public function onStoreProductOrderEditAfter($event)
    {
        list($data, $id) = $event;
        //$data  total_price 商品总价   pay_price 实际支付
        //订单编号  $id
    }

    /**
     * 修改配送信息
     * @param $event
     */
    public function onStoreProductOrderDistributionAfter($event)
    {
        list($data, $id) = $event;
        //$data   送货人姓名/快递公司   送货人电话/快递单号
        //订单编号  $id
    }

    /**
     * 订单全部产品评价完
     * @param $event
     */
    public function onStoreProductOrderOver($event)
    {
        list($oid) = $event;
    }

    /**
     * 回退所有  未支付和已退款的状态下才可以退积分退库存退优惠券
     * @param $event
     */
    public function onStoreOrderRegressionAllAfter($event)
    {
        list($order) = $event;
        StoreOrder::RegressionStock($order) && StoreOrder::RegressionIntegral($order) && StoreOrder::RegressionCoupon($order);
    }

    /**
     * 订单支付成功 OrderPaySuccess
     * @param array $event
     */
    public function onOrderPaySuccess($event)
    {
        list($order, $formId) = $event;
        //更新用户支付订单数量
        $userInfo = User::get($order['uid']);
        if ($userInfo) {
            if (intval($userInfo->pay_count) <= 0) {
                event('UserFirstOrder', ['order' => $order]);
            }
            $userInfo->pay_count = $userInfo->pay_count + 1;
            $becomingPromoter = false; // flag
            if (!$userInfo->is_promoter) {
                $price = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'uid' => $userInfo->uid])->sum('pay_price');
                $status = is_brokerage_statu($price);
                if ($status) {
                    $becomingPromoter = true;
                    $userInfo->is_promoter = 1;
                }
            }
            $userInfo->save();
            if ($becomingPromoter) {
                event('UserBecomedPromoter', [$userInfo->toArray()]);
            }
        }

        //发送模版消息、客服消息、短信、小票打印给客户和管理员
        NoticeRepositories::noticeOrderPaySuccess($order);
        //检测会员等级
        event('UserLevelAfter', [$order['uid']]);

        try {
            //向后台发送新订单消息
            ChannelService::instance()->send('NEW_ORDER', ['order_id' => $order['order_id']]);
        } catch (\Throwable $e) {
        }
    }
}