NN2023021801/app/admin/logic/UserLogic.php

<?php


namespace app\admin\logic;


use app\admin\model\dao\User;
use think\facade\Cache;
use think\facade\Db;

class UserLogic
{
    public function getList($page, $limit, $where, $sort, $userMap)
    {
        $userDao = new User();
        $count   = $userDao->getCount($where, $userMap);
        $list    = $userDao->getPageList($page, $limit, $where, $sort, $userMap);

        foreach ($list as &$item) {
            //团队会员（包括1、2级和自身）的积分账户合计、余额账户合计
            // 计算团队成员（包括1、2级和自身）ID

            $teamIds = $this->getTeamMoneyAndScore($item['id']);

            // 积分账户合计
            $item['score_total'] = $teamIds['score'];
            // 余额账户合计
            $item['money_total'] = $teamIds['money'];
        }

        $data = [
            'code'  => 0,
            'msg'   => Db::getLastSql(),
            'count' => $count,
            'data'  => $list,
        ];
        return json($data);
    }

    /**
     * 获取团队
     * @param $uid
     */
    private function getTeamMoneyAndScore($uid)
    {
        $cacheKey = 'userLogicTeamIds_' . $uid;

        if (!Cache::has($cacheKey)) {

            // 自身
            $user = Db::table(User::$table)
                ->where('id', $uid)
                ->field(['id', 'score', 'money'])
                ->find();

            $totalScore = $user['score'];
            $totalMoney = $user['money'];


            // 一级子用户
            Db::table(User::$table)
                ->where('pid', $uid)
                ->field(['id', 'score', 'money'])
                ->chunk(100, function ($users) use (&$totalScore, &$totalMoney) {
                    foreach ($users as $user) {
                        $uids[]     = $user['id'];
                        $totalScore += $user['score'];
                        $totalMoney += $user['money'];
                    }

                    // 二级子用户
                    Db::table(User::$table)
                        ->whereIn('pid', $uids)
                        ->field(['id', 'score', 'money'])
                        ->chunk(100, function ($users) use (&$totalScore, &$totalMoney) {
                            foreach ($users as $user) {
                                $totalScore += $user['score'];
                                $totalMoney += $user['money'];
                            }
                        });

                }, ['score', 'money']);

            Cache::set($cacheKey, ['score' => $totalScore, 'money' => sprintf("%.2f", $totalMoney)], 5 * 60);
        }

        return Cache::get($cacheKey);

    }

    /**
     * 修改用户手机号码
     * @param mixed $uid
     * @param mixed $phone
     */
    public function modifyPhone($uid, $phone)
    {
        // 判断手机号码是否使用过
        $user = User::getUserById($uid);
        if ($user['mobile'] == $phone) {
            return "请输入新的手机号码";
        }

        $user = User::getUserByMobile($phone);

        if ($user) {
            return "该手机号码已注册";
        }

        // 修改用户信息
        try {
            $result = User::ModifyMobile($uid, $phone);
            if (!$result) {
                return "更新手机号码失败，请稍后重试";
            }
        } catch (\Exception $e) {
            return '失败' . $e->getMessage();
        }

        return true;

    }

    /**
     * 修改余额
     * @param mixed $uid
     * @param mixed $post
     */
    public function modifyMoney($uid, $post)
    {
        $user = User::getUserById($uid);
        if (empty($user)) {
            return "用户不存在";
        }

        Db::
    }

}