manyuanchun/app/services/order/StoreOrderSuccessServices.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------

namespace app\services\order;


use app\dao\order\StoreOrderDao;
use app\services\activity\lottery\LuckLotteryServices;
use app\services\activity\combination\StorePinkServices;
use app\services\BaseServices;
use app\services\pay\PayServices;
use app\services\pc\UserServices;
use app\services\product\product\StoreProductGiftGroupService;
use app\services\user\UserBrokerageServices;
use crmeb\exceptions\ApiException;

/**
 * Class StoreOrderSuccessServices
 * @package app\services\order
 * @method getOne(array $where, ?string $field = '*', array $with = []) 获取去一条数据
 */
class StoreOrderSuccessServices extends BaseServices
{
    /**
     *
     * StoreOrderSuccessServices constructor.
     * @param StoreOrderDao $dao
     */
    public function __construct(StoreOrderDao $dao)
    {
        $this->dao = $dao;
    }

    /**
     * 0元支付
     * @param array $orderInfo
     * @param int $uid
     * @return bool
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function zeroYuanPayment(array $orderInfo, int $uid, string $payType = PayServices::YUE_PAY)
    {
        if ($orderInfo['paid']) {
            throw new ApiException(410265);
        }
        return $this->paySuccess($orderInfo, $payType);//余额支付成功
    }

    /**
     * 支付成功
     * @param array $orderInfo
     * @param string $paytype
     * @param array $other
     * @return bool
     * @throws \Psr\SimpleCache\InvalidArgumentException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function paySuccess(array $orderInfo, string $paytype = PayServices::WEIXIN_PAY, array $other = [])
    {
        $updata = ['paid' => 1, 'pay_type' => $paytype, 'pay_time' => time()];
        $orderInfo['pay_time'] = $updata['pay_time'];
        $orderInfo['pay_type'] = $paytype;
        if ($other && isset($other['trade_no'])) {
            $updata['trade_no'] = $other['trade_no'];
        }
        /** @var StoreOrderCartInfoServices $orderInfoServices */
        $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
        $orderInfo['storeName'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo['id']);
        $res1 = $this->dao->update($orderInfo['id'], $updata);
        $resPink = true;
        if ($orderInfo['combination_id'] && $res1 && !$orderInfo['refund_status']) {
            /** @var StorePinkServices $pinkServices */
            $pinkServices = app()->make(StorePinkServices::class);
            /** @var StoreOrderServices $orderServices */
            $orderServices = app()->make(StoreOrderServices::class);
            $resPink = $pinkServices->createPink($orderServices->tidyOrder($orderInfo, true));//创建拼团
        }
        //缓存抽奖次数 除过线下支付
        if (isset($orderInfo['pay_type']) && $orderInfo['pay_type'] != 'offline') {
            /** @var LuckLotteryServices $luckLotteryServices */
            $luckLotteryServices = app()->make(LuckLotteryServices::class);
            $luckLotteryServices->setCacheLotteryNum((int)$orderInfo['uid'], 'order');
        }
        $orderInfo['send_name'] = $orderInfo['real_name'];
        //订单支付成功后置事件
        event('OrderPaySuccessListener', [$orderInfo]);
        //用户推送消息事件
        event('NoticeListener', [$orderInfo, 'order_pay_success']);
        //支付成功给客服发送消息
        event('NoticeListener', [$orderInfo, 'admin_pay_success_code']);
        // 推送订单
        event('OutPushListener', ['order_pay_push', ['order_id' => (int)$orderInfo['id']]]);

        //自定义消息-订单支付成功
        $orderInfo['time'] = date('Y-m-d H:i:s');
        $orderInfo['phone'] = $orderInfo['user_phone'];
        event('CustomNoticeListener', [$orderInfo['uid'], $orderInfo, 'order_pay_success']);

        //自定义事件-订单支付
        event('CustomEventListener', ['order_pay', [
            'uid' => $orderInfo['uid'],
            'id' => (int)$orderInfo['id'],
            'order_id' => $orderInfo['order_id'],
            'real_name' => $orderInfo['real_name'],
            'user_phone' => $orderInfo['user_phone'],
            'user_address' => $orderInfo['user_address'],
            'total_num' => $orderInfo['total_num'],
            'pay_price' => $orderInfo['pay_price'],
            'pay_postage' => $orderInfo['pay_postage'],
            'deduction_price' => $orderInfo['deduction_price'],
            'coupon_price' => $orderInfo['coupon_price'],
            'store_name' => $orderInfo['storeName'],
            'add_time' => date('Y-m-d H:i:s', $orderInfo['add_time']),
        ]]);
        if ($orderInfo['lb_spread_uid']>0){  //建立礼包推荐关系
            self::createGiftRecommendationRelationship($orderInfo);
        }
        if ($orderInfo['is_lb']==1){  //赠送礼包推荐奖金
            self::giftRecommendationBonus($orderInfo);
        }
        $res = $res1 && $resPink;
        return false !== $res;
    }

//    创建礼包推荐关系
    public function createGiftRecommendationRelationship($oeder)
    {
        if ($oeder['spread_uid'] > 0) {
//            如果$order['spread_uid']>0，说明是通过推广链接支付的，需要创建礼包推荐关系,关系表是store_product_gift_group,需要保存product_id，uid，group_pid（小组上级），pid（真直推上级），fake_pid（假直推上级（直推上级的下级小组满人下放下来的人）），一个商品加一个pid推荐上级会形成一个小组，第一个加进小组的会是第二个加入的小组上级（group_pid），当一个小组满10人后，就会让第十人作为fake_pid直推上级建立新的10人小组，但pid还是真正的直推上级
// 获取商品ID
            $product_id = $order['cart_info'][0]['product_id'] ?? 0;
            if (!$product_id) return false;

// 获取推广人UID
            $spread_uid = $order['spread_uid'];

// 获取礼包服务
            $giftGroupService = app()->make(StoreProductGiftGroupService::class);

// 检查是否已有该商品的推荐关系
            $existRelation = $giftGroupService->getOne([
                'product_id' => $product_id,
                'uid' => $order['uid']
            ]);

            if ($existRelation) return true;

// 获取直推上级的推荐关系
            $parentRelation = $giftGroupService->getOne([
                'product_id' => $product_id,
                'uid' => $spread_uid
            ]);

// 设置关系数据
            $data = [
                'product_id' => $product_id,
                'uid' => $order['uid'],
                'pid' => $spread_uid, // 真直推上级
                'create_time' => time()
            ];

// 处理小组关系
            if ($parentRelation) {
                // 获取当前小组人数
                $groupCount = $giftGroupService->count([
                    'product_id' => $product_id,
                    'group_pid' => $parentRelation['group_pid'] ?: $parentRelation['uid']
                ]);

                if ($groupCount < 9) {
                    // 小组未满10人，加入当前小组
                    $data['group_pid'] = $parentRelation['group_pid'] ?: $parentRelation['uid'];
                    $data['fake_pid'] = $parentRelation['pid'];
                } else {
                    // 小组已满10人，循环查找小组成员的直推下级小组
                    $group_pid = $parentRelation['group_pid'] ?: $parentRelation['uid'];
                    $foundAvailableGroup = false;

                    // 获取小组所有成员，按加入时间排序
                    $groupMembers = $giftGroupService->getGroupMembers($product_id, $group_pid);

                    // 从最后一个成员开始向前查找（从第10人开始，依次检查第9人、第8人...）
                    for ($i = count($groupMembers) - 1; $i >= 0; $i--) {
                        $member = $groupMembers[$i];
                        $member_uid = $member['uid'];

                        // 检查该成员作为group_pid的小组人数
                        $subGroupCount = $giftGroupService->count([
                            'product_id' => $product_id,
                            'group_pid' => $member_uid
                        ]);

                        if ($subGroupCount < 9) {
                            // 找到未满10人的小组，加入该小组
                            $data['group_pid'] = $member_uid;
                            $data['fake_pid'] = $member['pid'];
                            $foundAvailableGroup = true;
                            break;
                        }
                    }

                    // 如果所有成员的直推下级小组都满10人了，创建新小组
                    if (!$foundAvailableGroup) {
                        $lastMember = $groupMembers[count($groupMembers) - 1];
                        $data['group_pid'] = $lastMember['uid']; // 新小组的上级是当前小组的最后一人
                        $data['fake_pid'] = $lastMember['uid']; // 假直推上级是新小组的创建者
                    }
                }
            } else {
                // 直推上级没有该商品的推荐关系，创建新小组
                $data['group_pid'] = 0;
                $data['fake_pid'] = $spread_uid;
            }

// 保存推荐关系
            return $giftGroupService->save($data);
        }
        return false;
    }

//    礼包上级分红
    public function giftRecommendationBonus($order)
    {
// 获取礼包服务
        $giftGroupService = app()->make(StoreProductGiftGroupService::class);
        $userServices = app()->make(UserServices::class);

// 获取商品ID和佣金金额
        $product_id = $order['cart_info'][0]['product_id'] ?? 0;
        $brokerage_price = $order['brokerage_price'] ?? 0;
        if (!$product_id || !$brokerage_price) return false;

// 获取用户的推荐关系
        $userRelation = $giftGroupService->getOne([
            'product_id' => $product_id,
            'uid' => $order['uid']
        ]);

        if (!$userRelation) return false;

// 直推上级分成
        $directBrokerage = $brokerage_price * 0.3;
        if ($userRelation['pid'] == $userRelation['fake_pid']) {
            // 真直推上级和假直推上级相同，全部给直推上级
            $userServices->addBrokerage($userRelation['pid'], $directBrokerage, '礼包直推奖');
            // 添加佣金记录
            /** @var UserBrokerageServices $userBrokerageServices */
            $userBrokerageServices = app()->make(UserBrokerageServices::class);
            //冻结时间
            $frozenTime = time() + intval(sys_config('extract_time')) * 86400;
            $res1 = $userBrokerageServices->income('get_two_brokerage', $spread_two_uid, [
                'nickname' => $userInfo['nickname'],
                'pay_price' => floatval($orderInfo['pay_price']),
                'number' => floatval($brokeragePrice),
                'frozen_time' => $frozenTime
            ], $balance, $orderInfo['id']);
        } else {
            // 真直推上级和假直推上级不同，各分50%
            $halfBrokerage = $directBrokerage * 0.5;
            $userServices->addBrokerage($userRelation['pid'], $halfBrokerage, '礼包直推奖(真上级)');
            $userServices->addBrokerage($userRelation['fake_pid'], $halfBrokerage, '礼包直推奖(假上级)');
        }

// 见点奖处理
        $spotBrokerage = $brokerage_price * 0.025;
        $totalSpots = 0;

// 1. 真直推链上找15人
        $currentUid = $userRelation['pid'];
        for ($i = 0; $i < 15; $i++) {
            $parentRelation = $giftGroupService->getOne([
                'product_id' => $product_id,
                'uid' => $currentUid
            ]);
            if (!$parentRelation) break;

            $userServices->addBrokerage($currentUid, $spotBrokerage, '礼包见点奖(上级链)');
            $totalSpots++;
            $currentUid = $parentRelation['pid'];
        }

// 2. 同组下找5人
        if ($userRelation['group_pid'] > 0) {
            $groupMembers = $giftGroupService->getGroupMembers($product_id, $userRelation['group_pid']);
            $currentIndex = array_search($order['uid'], array_column($groupMembers, 'uid'));

            if ($currentIndex !== false) {
                for ($i = $currentIndex + 1; $i < count($groupMembers) && $totalSpots < 5; $i++) {
                    $userServices->addBrokerage($groupMembers[$i]['uid'], $spotBrokerage, '礼包见点奖(同组下级)');
                    $totalSpots++;
                }
            }
        }

// 3. 如果同组下级不足5人，找自己的直推下级
        if ($totalSpots < 5) {
            $directSubordinates = $giftGroupService->getList([
                'product_id' => $product_id,
                'pid' => $order['uid']
            ], '*', 0, 5 - $totalSpots, 'create_time asc');

            foreach ($directSubordinates as $subordinate) {
                $userServices->addBrokerage($subordinate['uid'], $spotBrokerage, '礼包见点奖(直推下级)');
                $totalSpots++;
            }
        }

        return true;

    }



}