php/app/controller/api/Test.php

<?php

namespace app\controller\api;

use app\common\dao\shared\SharedProsperityUserDao;
use app\common\enum\CommonEnum;
use app\common\enum\shared\SharedProsperityRewardRecordEnum;
use app\common\model\shared\SharedProsperityUser;
use app\common\repositories\shared\SharedProsperityUserRepository;
use app\common\repositories\store\order\StoreGroupOrderRepository;
use app\common\repositories\store\order\StoreOrderRepository;
use app\common\repositories\user\UserRepository;
use app\traits\GzcApiRequest;
use think\facade\Db;

class Test
{
    public function test()
    {


        // // 1、获取订单数据
        // /** @var StoreGroupOrderRepository $storeGroupOrderRepository */
        // $storeGroupOrderRepository = app()->make(StoreGroupOrderRepository::class);
        // // 获取订单组数据
        // $groupOrderSn = 'wx177442719463317087';
        // $storeGroupOrderEntity = $storeGroupOrderRepository->getStoreGroupOrderEntityByGroupOrderSn($groupOrderSn);
        // /** @var StoreOrderRepository $storeOrderRepository */
        // $storeOrderRepository = app()->make(StoreOrderRepository::class);
        // // 获取订单集合
        // $storeOrderEntityList = $storeOrderRepository->getStoreOrderEntityListByGroupOrderId($storeGroupOrderEntity->getGroupOrderId());
        // try {
        //     Db::transaction(function () use (
        //         $storeGroupOrderRepository,
        //         $storeGroupOrderEntity
        //     ) {
        //         $storeGroupOrderRepository->storeGroupOrderPaySuccess($storeGroupOrderEntity->getGroupOrderId());
        //     });
        // } catch (\Throwable $e) {
        //     Db::name("log")
        //         ->insert([
        //             'data' => '【订单支付回调】【结算订单失败】:时间：' . date('Y-m-d H:i:s', time()) . '；订单编号：1111订单失败原因：' . json_encode([
        //                     'error_message' => $e->getMessage(),
        //                     'error_file' => $e->getFile(),
        //                     'error_line' => $e->getLine(),
        //                     'error_code' => $e->getCode(),
        //                     'exception_class' => get_class($e),
        //                     'trace' => $e->getTraceAsString()
        //                 ], JSON_UNESCAPED_UNICODE)
        //         ]);
        //     dd($e->getMessage());
        // }
        //
        //
        // die;

        //
        // $title = '系统补贴';
        // $map = [
        //     294 => 165,
        //     186 => 860
        // ];
        //
        // foreach ($map as $uid => $money) {
        //     $bill = [
        //         'uid' => $uid,
        //         'link_id' => 0,
        //         'pm' => 1,
        //         'title' => $title,
        //         'category' => 'now_money',
        //         'type' => 'commission',
        //         'number' => $money,
        //         'balance' => 0,
        //         'mark' => $title,
        //         'create_time' => date('Y-m-d H:i:s'),
        //         'status' => 1,
        //         'commission_type' => CommonEnum::COMMISSION_TYPE['SYSTEM_SUBSIDY_COMMISSION']['code'],
        //         'order_sn' => 0,
        //         'tripartite' => 0,
        //         'type_shop' => 0,
        //         'mer_id' => 0,
        //         'source' => 0,
        //         'order_type' => 1,
        //         'is_red_brokerage' => 0,
        //         'gzc' => 3,
        //         'take_time' => time(),
        //         'district_id' => '',
        //         'street_id' => '',
        //         'month' => '',
        //     ];
        //     $a = Db::name('user_bill')->insert($bill);
        //
        //     $b = Db::name('user')->where('uid', $uid)->inc('brokerage_price', $money)->update();
        // }
        // die;


        // $sharedUserPvCount = Db::name('shared_prosperity_reward_record')
        //     ->where(['type' => SharedProsperityRewardRecordEnum::TYPE['PV']['code'], 'status' => SharedProsperityRewardRecordEnum::STATUS['VALID']['code'], 'pm' => SharedProsperityRewardRecordEnum::PM['INCOME']['code']])
        //     ->whereNotIn('user_id',$testUids)
        //     ->sum('number'); // 共富会员专区总业绩
        // dd($sharedUserPvCount);
        // die;

        //
        $total = 2756.48;
        $map = [
            1 => 0.3,
            2 => 0.15,
            3 => 0.03,
            4 => 0.008,
        ];
        $groupMap = [
            1 => 0.05,
            2 => 0.1
        ];
        $testUids = Db::name('user')->where('test_user',  '1')->column('uid');

        $users = Db::name('shared_prosperity_user')->whereNotIn('user_id',$testUids)->group('partner_level')->field('partner_level,count(*) as num')->select()->toArray();

        $res = [];
        foreach ($users as $user) {
            if ($user['partner_level'] == 0 || $user['partner_level'] == 5) {
                continue;
            }
            $res[$user['partner_level']] = [
                'num' => $user['num'],
                'money' => $total * $map[$user['partner_level']] / $user['num']
            ];
        }

        $groupRes = [];
        $groupUsers = Db::name('shared_prosperity_group_user')->whereNotIn('user_id',$testUids)->group('group_id')->field('group_id,count(*)as num')->select()->toArray();
        foreach ($groupUsers as $groupUser) {
            $groupRes[$groupUser['group_id']] = [
                'num' => $groupUser['num'],
                'money' => $total * $groupMap[$groupUser['group_id']] / $groupUser['num']
            ];
        }
        dd($res, $groupRes);


        // 18201226770 4858下的单  改成   13716268932 5064下单

        // 上下级关系正确

        // 订单所属已修改

        // 订单产生的共富奖励已修改

        // 佣金修改


        // 查询团队业绩
        // $ids = [
        //     1213
        // ];
        // $res = [];
        // foreach ($ids as $id) {
        //     /** @var SharedProsperityUserDao $dao */
        //     $dao = app()->make(SharedProsperityUserDao::class);
        //     $userIds = $dao->getAllSubordinateUserIds($id,true,5);
        //     /** @var SharedProsperityUser $model */
        //     $sum = SharedProsperityUser::getDB()
        //         ->whereIn('user_id', $userIds)
        //         ->sum('pv');
        //     $res[$id] = $sum;
        // }
        // dd($res);


        /** @var SharedProsperityUserRepository $userRepository */
        $userRepository = app()->make(SharedProsperityUserRepository::class);
        $list = $userRepository->getUserTree(294);
        // var_dump(json_encode($list));
        // $field = request()->param('field');
        // /** @var UserRepository $userRepository */
        // $userRepository = app()->make(UserRepository::class);
        // $list = $userRepository->getUserForTree($field, 0);
        var_dump(json_encode($list));
        // return app('json')->success($list);
    }
}