NN2023021801/app/admin/logic/UserLogic.php

<?php


namespace app\admin\logic;


use app\admin\model\dao\ShopOrder;
use app\admin\model\dao\User;
use app\common\model\User as UserModel;
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 $pid
     */
    public function modifypid($uid, $pid)
    {
        // 查询pid是否存在用户path中
        $user = User::getUserById($uid);

        if ($uid == $pid) {
            return "不能修改自己为上级";
        }

        if ($user['pid'] == $pid) {
            return "该用户已所属待变更的上级，不能修改";
        }

        // 当前用户关系层级链路
        $newUserPath = "";

        if ($pid == 0) {
            $newPathPrefix = $user['id'];

        } else {
            $pUser = User::getUserById($pid);
            if (empty($pUser)) {
                return "待变更的上级用户不存在";
            }

            $userPathArr = explode(',', $user['path']);
            if (in_array($pid, $userPathArr)) {
                $pidIndex          = array_search($pid, $userPathArr);
                $userPathArrPrefix = array_slice($userPathArr, 0, $pidIndex + 1);
            } else {
                $pidIndex            = array_search($user['pid'], $userPathArr);
                $userPathArrPrefix   = array_slice($userPathArr, 0, $pidIndex);
                $userPathArrPrefix[] = $pid;
            }
            $newUserPath = implode(',', $userPathArrPrefix);

            // 子级用户Path待替换关系层级前部分链表
            $userPathArrPrefix[] = $user['id'];
            $newPathPrefix       = implode(',', $userPathArrPrefix);
        }

        // 子级用户Path被替换关系层级前部分链表
        $oldPathPrefix = $user['path'] == 0 ? $uid : $user['path'] . ',' . $uid;


        Db::startTrans();
        try {
            // 子级path变更
            $result = Db::table(User::$table)
                ->where([
                    ['path', 'like', $oldPathPrefix . '%'],
                    ['id', '<>', $uid]
                ])
                ->field(['id', 'path'])
                ->chunk(100, function ($users) use ($pid, $oldPathPrefix, $newPathPrefix, $uid) {
                    foreach ($users as $user) {

                        $userPathArr    = explode(',', $user['path']);
                        $uidIndex       = array_search($uid, $userPathArr);
                        $userPathArrSub = array_slice($userPathArr, $uidIndex);
                        if (in_array($uid, $userPathArrSub)) {
                            return false;
                        }
                        $newPath = str_replace($oldPathPrefix, $newPathPrefix, $user['path']);
                        User::modifyUserPath($user['id'], $newPath);
                    }
                });
            if (!$result) {
                Db::rollback();
                return "修改用户所属上级失败,请确认用户的层级关系";
            }

            // 更新用户Pid,Path
            User::modifyUserPidAndPath($uid, $pid, $newUserPath);

            Db::commit();
        } catch (\Exception $exception) {
            Db::rollback();
            return "失败:" . $exception->getMessage();
        }

        return true;

    }
}