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\user\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']),
        ]]);
        
        // 获取购物车信息
        $orderCartInfo = $orderInfoServices->getCartColunm(
            ['oid' => $orderInfo['id']], 
            'cart_info', 
            'unique'
        );
        $orderInfo['cart_info'] = [];
        foreach ($orderCartInfo as $k => $v) {
            $cart_info = is_string($v) ? json_decode($v, true) : $v;
            $orderInfo['cart_info'][] = $cart_info;
        }
        
        if ($orderInfo['lb_spread_uid'] > 0) {  //建立礼包推荐关系
            @file_put_contents('quanju.txt', $orderInfo['lb_spread_uid'] . "-礼包推荐人2\r\n", 8);
            self::createGiftRecommendationRelationship($orderInfo);
        }
        if ($orderInfo['is_lb'] == 1) {  //赠送礼包推荐奖金
            @file_put_contents('quanju.txt', $orderInfo['is_lb'] . "-礼包订单2\r\n", 8);

            self::giftRecommendationBonus($orderInfo);
        }
        $res = $res1 && $resPink;
        return false !== $res;
    }

//    创建礼包推荐关系
    public function createGiftRecommendationRelationship($order)
    {
//        @file_put_contents('quanju.txt', json_encode($order) . "-创建礼包推荐关系\r\n", 8);

        try {
            if ($order['lb_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['lb_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 {
                    // 直推上级没有该商品的推荐关系，链式结构：每个人都作为下一个人的group_pid
                    // 获取该推广链接下该商品的所有成员，按加入时间排序
                    $groupMembers = $giftGroupService->getGroupMembersByPid($product_id, $spread_uid);

                    if (count($groupMembers) > 0) {
                        // 已有成员，最后一个成员的uid作为新成员的group_pid
                        $lastMember = $groupMembers[count($groupMembers) - 1];
                        $data['group_pid'] = $lastMember['uid'];
                        $data['fake_pid'] = $lastMember['pid'] ?: $spread_uid;
                    } else {
                        // 还没有成员，创建新小组（第一个成员）
                        $data['group_pid'] = 0;
                        $data['fake_pid'] = $spread_uid;
                    }
                }

// 保存推荐关系
                return $giftGroupService->save($data);
            }
            return false;
        } catch (\Exception $e) {
            @file_put_contents('quanju4.txt', $e->getMessage() . "-创建订单报错内容\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getFile() . "-文件\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getLine() . "-位置\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getTraceAsString() . "-堆栈\r\n", 8);

        }
    }

//    礼包上级分红
    public function giftRecommendationBonus($order)
    {
        try {
        @file_put_contents('quanju.txt', json_encode($order) . "-礼包上级分红\r\n", 8);

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

            // 检查 cart_info 是否存在且非空
            @file_put_contents('quanju4.txt', '开始检查cart_info' . "\r\n", 8);
            if (!isset($order['cart_info']) || empty($order['cart_info'])) {
                @file_put_contents('quanju4.txt', 'cart_info不存在或为空' . "\r\n", 8);
                return false;
            }
            @file_put_contents('quanju4.txt', 'cart_info存在: ' . json_encode($order['cart_info'][0]) . "\r\n", 8);

            // 获取商品ID和商品价格作为佣金计算基数
            $product_id = $order['cart_info'][0]['product_id'] ?? 0;
            $brokerage_price = $order['cart_info'][0]['truePrice'] ?? 0;
            @file_put_contents('quanju4.txt', 'product_id=' . $product_id . ', brokerage_price=' . $brokerage_price . "\r\n", 8);

            if (!$product_id || !$brokerage_price) {
                @file_put_contents('quanju4.txt', 'product_id或brokerage_price为0，返回false' . "\r\n", 8);
                return false;
            }
            @file_put_contents('quanju4.txt', $product_id . "-商品id\r\n", 8);

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

            if (!$userRelation) return false;
            $userInfo = $userServices->getOne(['uid' => $order['uid']]);

            // 获取佣金服务（一次性创建，复用）
            /** @var UserBrokerageServices $userBrokerageServices */
            $userBrokerageServices = app()->make(UserBrokerageServices::class);
            //冻结时间
            $frozenTime = time() + intval(sys_config('extract_time')) * 86400;

            // 直推上级分成
            $directBrokerage = $brokerage_price * 0.3;
            @file_put_contents('quanju4.txt', json_encode($userRelation) . "-礼包推荐关系表\r\n", 8);

            if ($userRelation['pid'] == $userRelation['fake_pid']) {
                // 真直推上级和假直推上级相同，全部给直推上级
                $pid_brokerage = $userServices->getOne(['uid' => $userRelation['pid']]);
                $userServices->bcInc($userRelation['pid'], 'brokerage_price', $directBrokerage, 'uid');
                @file_put_contents('quanju4.txt', $directBrokerage . "-直推奖励\r\n", 8);

                $balance = bcadd($pid_brokerage['brokerage_price'], $directBrokerage,2);
                $userBrokerageServices->income('get_direct_referral_brokerage', $userRelation['pid'], [
                    'nickname' => $userInfo['nickname'],
                    'pay_price' => floatval($order['pay_price']),
                    'number' => $directBrokerage,
                    'frozen_time' => $frozenTime
                ], $balance, $order['id']);
            } else {
                // 真直推上级和假直推上级不同，各分50%
                $halfBrokerage = $directBrokerage * 0.5;

                // 真上级分得50%
                $pid_brokerage = $userServices->getOne(['uid' => $userRelation['pid']]);
                $userServices->bcInc($userRelation['pid'], 'brokerage_price', $halfBrokerage, 'uid');
                $balance = bcadd($pid_brokerage['brokerage_price'], $halfBrokerage,2);
                $userBrokerageServices->income('get_direct_referral_brokerage', $userRelation['pid'], [
                    'nickname' => $userInfo['nickname'],
                    'pay_price' => floatval($order['pay_price']),
                    'number' => $halfBrokerage,
                    'frozen_time' => $frozenTime
                ], $balance, $order['id']);

                // 假上级分得50%
                $fake_pid_brokerage = $userServices->getOne(['uid' => $userRelation['fake_pid']]);
                $userServices->bcInc($userRelation['fake_pid'], 'brokerage_price', $halfBrokerage, 'uid');
                $balance = bcadd($fake_pid_brokerage['brokerage_price'], $halfBrokerage,2);
                $userBrokerageServices->income('get_direct_referral_brokerage', $userRelation['fake_pid'], [
                    'nickname' => $userInfo['nickname'],
                    'pay_price' => floatval($order['pay_price']),
                    'number' => $halfBrokerage,
                    'frozen_time' => $frozenTime
                ], $balance, $order['id']);
            }

            // 见点奖处理
            $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;

                $currentBrokerage = $userServices->getOne(['uid' => $currentUid]);
                $userServices->bcInc($currentUid, 'brokerage_price', $spotBrokerage, 'uid');
                $balance = bcadd($currentBrokerage['brokerage_price'], $spotBrokerage);
                $userBrokerageServices->income('get_spot_brokerage', $currentUid, [
                    'nickname' => $userInfo['nickname'],
                    'pay_price' => floatval($order['pay_price']),
                    'number' => $spotBrokerage,
                    'frozen_time' => $frozenTime
                ], $balance, $order['id']);
                $totalSpots++;
                $currentUid = $parentRelation['pid'];
            }

            // 2. 同组下找5人（根据pid查找链式成员）
            $chainMembers = $giftGroupService->getGroupMembersByPid($product_id, $userRelation['pid']);
            $currentIndex = array_search($order['uid'], array_column($chainMembers, 'uid'));

            if ($currentIndex !== false) {
                @file_put_contents('quanju4.txt', '找到当前用户在链中的位置: ' . $currentIndex . ', 链成员总数: ' . count($chainMembers) . "\r\n", 8);
                // 从当前用户的下一个位置开始找，最多找5人
                for ($i = $currentIndex + 1; $i < count($chainMembers) && $totalSpots < 5; $i++) {
                    $memberBrokerage = $userServices->getOne(['uid' => $chainMembers[$i]['uid']]);
                    $userServices->bcInc($chainMembers[$i]['uid'], 'brokerage_price', $spotBrokerage, 'uid');
                    $balance = bcadd($memberBrokerage['brokerage_price'], $spotBrokerage);
                    $userBrokerageServices->income('get_spot_brokerage', $chainMembers[$i]['uid'], [
                        'nickname' => $userInfo['nickname'],
                        'pay_price' => floatval($order['pay_price']),
                        'number' => $spotBrokerage,
                        'frozen_time' => $frozenTime
                    ], $balance, $order['id']);
                    @file_put_contents('quanju4.txt', '发放见点奖给链成员: uid=' . $chainMembers[$i]['uid'] . ', 金额=' . $spotBrokerage . "\r\n", 8);
                    $totalSpots++;
                }
                @file_put_contents('quanju4.txt', '链式发放完成，共发放: ' . $totalSpots . '人' . "\r\n", 8);
            } else {
                @file_put_contents('quanju4.txt', '未找到当前用户在链中的位置' . "\r\n", 8);
            }

            // 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) {
                    $subBrokerage = $userServices->getOne(['uid' => $subordinate['uid']]);
                    $userServices->bcInc($subordinate['uid'], 'brokerage_price', $spotBrokerage, 'uid');
                    $balance = bcadd($subBrokerage['brokerage_price'], $spotBrokerage);
                    $userBrokerageServices->income('get_spot_brokerage', $subordinate['uid'], [
                        'nickname' => $userInfo['nickname'],
                        'pay_price' => floatval($order['pay_price']),
                        'number' => $spotBrokerage,
                        'frozen_time' => $frozenTime
                    ], $balance, $order['id']);
                    $totalSpots++;
                }
            }

            return true;
        } catch (\Exception $e) {
            @file_put_contents('quanju4.txt', $e->getMessage() . "-上级分红报错内容\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getFile() . "-文件\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getLine() . "-位置\r\n", 8);
            @file_put_contents('quanju4.txt', $e->getTraceAsString() . "-堆栈\r\n", 8);

        }
    }


}