mall/models/UserNode.php

<?php
/**
 * 厦门云联储网络科技有限公司
 * https://www.baokuaiyun.com
 * Copyright (c) 2023 爆块云 All rights reserved.
 */

namespace app\models;

use Yii;
use yii\behaviors\TimestampBehavior;
use yii\db\ActiveRecord;
use yii\db\Expression;
use yii\helpers\ArrayHelper;
use yii\helpers\Json;

use app\constants\OptionSetting;

/**
 * This is the model class for table "{{%user_node}}".
 *
 * @property integer $id
 * @property integer $store_id
 * @property integer $user_id
 * @property integer $parent_id
 * @property integer $parent_node
 * @property string $recommend_relation
 * @property integer $layer
 * @property string $recommend_relation_node
 * @property integer $layer_node
 * @property integer $team_num
 * @property integer $area_key
 * @property integer $layer_rank
 * @property integer $created_at
 * @property integer $updated_at
 */
class UserNode extends \yii\db\ActiveRecord
{
    /**
     * @inheritdoc
     */
    public static function tableName()
    {
        return '{{%user_node}}';
    }

    public function behaviors()
    {
        return [
            [
                'class' => TimestampBehavior::class,
                'attributes' => [
                    ActiveRecord::EVENT_BEFORE_INSERT => ['created_at'],
                    ActiveRecord::EVENT_BEFORE_UPDATE => ['updated_at']
                ]
            ]
        ];
    }

    /**
     * @inheritdoc
     */
    public function rules()
    {
        return [
            [['recommend_relation', 'recommend_relation_node'], 'string'],
            [
                [
                    'store_id', 'user_id', 'parent_id', 'layer', 'layer_node', 'created_at', 'updated_at', 'parent_node',
                    'team_num', 'area_key', 'layer_rank'
                ],
                'integer'
            ],
        ];
    }

    /**
     * @inheritdoc
     */
    public function attributeLabels()
    {
        return [
            'id' => 'ID',
            'store_id' => '店铺id',
            'user_id' => '用户id',
            'parent_id' => '分销上级id',
            'parent_node' => '父节点',
            'recommend_relation_node' => '节点推荐关系',
            'layer_node' => '节点层级',
            'recommend_relation' => '分销推荐关系',
            'layer' => '分销层级',
            'area_key' => '区域Key',
            'layer_rank' => '层级排位',
            'team_num' => '团队人数',
            'created_at' => '创建时间',
            'updated_at' => '更新时间',
        ];
    }

    /**
     * 加入节点
     * @param $store_id
     * @param $user_id
     * @return bool
     */
    public static function joinNode($store_id, $user_id)
    {
        // $share_setting = Option::get('share_basic_setting', $store_id);
        $share_setting = Option::get(OptionSetting::SHARE_STRING_CODE_DEFAULT_SETTING, $store_id, OptionSetting::SHARE_GROUP_NAME, '{}');
        
        $share_setting = $share_setting ? Json::decode($share_setting['value']) : [];
        if (!$share_setting) {
            //debug_log([__METHOD__, __LINE__, '加入串码节点：未开启分销设置'], strtolower(__CLASS__ . '.log'));
            return false;
        }
        // if (!is_array($share_setting['is_string_code']) || empty($share_setting['is_string_code']['value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未开启串码节点功能'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }
        // if (!is_array($share_setting['string_code_layer_max']) || empty($share_setting['string_code_layer_max']['value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置串码最大层级'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }
        // if (!is_array($share_setting['string_code_condition_coin']) || empty($share_setting['string_code_condition_coin']['value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置贡献积分条件'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }
        // if (!is_array($share_setting['string_code_root_user_id']) || !isset($share_setting['string_code_root_user_id']['value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置默认根节点'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }
        // if (!is_array($share_setting['string_code_add_sort']) || !isset($share_setting['string_code_add_sort']['value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置串码顺序'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }
        if (!is_array($share_setting['string_code_max_layer'])) {
            //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置串码最大层级'], strtolower(__CLASS__ . '.log'));
            return false;
        }
        if (!is_array($share_setting['string_code_condition_value'])) {
            //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置贡献积分条件'], strtolower(__CLASS__ . '.log'));
            return false;
        }
        if (!is_array($share_setting['string_code_root_user_id'])) {
            //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置默认根节点'], strtolower(__CLASS__ . '.log'));
            return false;
        }
        // if (!is_array($share_setting['string_code_shop_value'])) {
        //     //debug_log([__METHOD__, __LINE__, '加入串码节点：未设置串码顺序'], strtolower(__CLASS__ . '.log'));
        //     return false;
        // }

        // 判断是否满足条件
        $user = User::findOne(['id' => $user_id]);
        if ($user['total_coin'] < $share_setting['string_code_condition_value']) {
            //debug_log([__METHOD__, __LINE__, '加入串码节点：用户贡献积分不足'], strtolower(__CLASS__ . '.log'));
            return false;
        }
        $user_string_code = self::findOne(['user_id' => $user_id]);
        if ($user_string_code) {
            //debug_log([__METHOD__, __LINE__, "加入串码节点：用户:{$user_id}已加入串码节点"], strtolower(__CLASS__ . '.log'));
            return false;
        }
        // 锁定 root 节点
        if (!$user['parent_id']) {
            $parent_id = (int)$share_setting['string_code_root_user_id'];
        } else {
            $parent_id = $user['parent_id'];
        }

        $parent_string_code = self::findOne(['user_id' => $parent_id]);
        // $share_setting['string_code_add_sort']['value'] = 1;
        // // $parent_id = 73;
        // if (empty($share_setting['string_code_add_sort']['value'])) {
            // 从上至下，从左至右
            list($real_parent_node, $layer_rank, $area_key) = self::getRealParentNode($store_id, $user_id, $parent_id, $share_setting['string_code_max_layer']);
        // } else {
        //     // 深度优先，从左至右
        //     list($real_parent_node, $layer_rank, $area_key) = self::getRealParentNodePlus($store_id, $user_id, $parent_id, $share_setting['string_code_max_layer']);
        // }

        if (empty($real_parent_node['recommend_relation_node'])) {
            $recommend_relation_node = ',' . $real_parent_node->user_id . ',';
        } else {
            $recommend_relation_node = $real_parent_node['recommend_relation_node'] . $real_parent_node->user_id . ',';
        }
        if (empty($parent_string_code['recommend_relation'])) {
            $recommend_relation = ',' . $parent_string_code->user_id . ',';
        } else {
            $recommend_relation = $real_parent_node['recommend_relation'] . $parent_string_code->user_id . ',';
        }

        // 保存节点数据
        $user_string_code = new self();
        $user_string_code->store_id = $store_id;
        $user_string_code->user_id = $user_id;
        $user_string_code->parent_id = $parent_id;
        $user_string_code->parent_node = $real_parent_node['user_id'];
        $user_string_code->recommend_relation_node = $recommend_relation_node;
        $user_string_code->layer_node = $real_parent_node['layer_node'] + 1;
        $user_string_code->recommend_relation = $recommend_relation;
        $user_string_code->layer = $parent_string_code['layer'] + 1;
        $user_string_code->area_key = $area_key;
        $user_string_code->layer_rank = $layer_rank;
        if (!$user_string_code->save()) {
            var_dump($user_string_code->getErrors());
        }

        // 所有上级节点 团队人数 + 1
        self::setTeamCountInc($user_id);

        return true;
    }

    /**
     * 指定用户上级所有节点团队人数 + 1
     * @param $user_id
     * @return int
     */
    public static function setTeamCountInc($user_id)
    {
        $parent_node_ids = self::getAllParentNodeIds($user_id);
        if ($parent_node_ids) {
            return self::updateAll(
                ['team_num' => new Expression('team_num + 1')],
                ['in', 'user_id', $parent_node_ids]
            );
        } else {
            return 0;
        }
    }

    /**
     * 获取用户最后一个节点
     * 从上至下，从左至右
     * @param $store_id 店铺ID
     * @param $user_id 下单用户ID
     * @param $parent_id 下单用户上级ID
     * @param $max_layer 限制最大层数
     * @return array
     */
    public static function getRealParentNode($store_id, $order_user_id, $parent_id, $max_layer)
    {
        // 针对父节点对应的区
        $real_area_key = 0;
        // 针对根节点对应的排序
        $real_layer_rank = 0;

        $parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $parent_id]);
        $children_list = self::findOne(['store_id' => $store_id, 'parent_node' => $parent_id]);
        // 未有子节点
        if (!$children_list) {
            //debug_log([__METHOD__, __LINE__, "未有子节点"], strtolower(__CLASS__ . '.log'));
            $real_parent_node = $parent_node;
            return [$real_parent_node, $real_area_key, $real_layer_rank];
        }

        // 先判断 最大层级下 第一列能否能占位
        $temp_parent_id = $parent_id;
        //debug_log([__METHOD__, __LINE__, "最大层数：{$max_layer}"], strtolower(__CLASS__ . '.log'));
        for ($i = 0; $i < $max_layer; $i++) {
            //debug_log([__METHOD__, __LINE__, "第1区循环：{$i}，用户ID：{$temp_parent_id}"], strtolower(__CLASS__ . '.log'));
            $temp_node = self::findOne(['store_id' => $store_id, 'parent_node' => $temp_parent_id, 'area_key' => $real_area_key]);
            if (!$temp_node) {
                $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $temp_parent_id]);
                return [$real_parent_node, $real_layer_rank, $real_area_key];
            } else {
                $temp_parent_id = $temp_node['user_id'];
            }
        }

        // 广度优先遍历
        $queue = [];
        $queue[] = $parent_node;
        while (!empty($queue)) {
            // 当前节点
            $current_node = array_shift($queue);
            // 当前层数
            $current_layer = $current_node['layer_node'] - $parent_node['layer_node'];
            //debug_log([__METHOD__, __LINE__, "当前节点ID：{$current_node['user_id']}，当前层数：{$current_layer}"], strtolower(__CLASS__ . '.log'));

            // 判断用户第1区有无落点
            $parent_first_col_auth = self::findOne(['store_id' => $store_id, 'parent_node' => $current_node['user_id'], 'area_key' => 0]);
            if (!$parent_first_col_auth) {
                $real_area_key = 0;
                //debug_log([__METHOD__, __LINE__, "当前节点ID:{$current_node['user_id']}，1区没人，落第1区"], strtolower(__CLASS__ . '.log'));
                $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $current_node['user_id']]);
                $current_layer_rank = self::find()
                    ->where(['store_id' => $store_id, 'layer_node' => $real_parent_node['layer_node'] + 1])
                    ->max('layer_rank');
                $real_layer_rank = $current_layer_rank + 1;
                return [$real_parent_node, $real_layer_rank, $real_area_key];
            }

            // 判断用户能否开第2区
            $parent_second_col_auth = self::checkSecondColumnAuthPlus($store_id, $order_user_id, $current_node['user_id'], $max_layer);
            if ($parent_second_col_auth) {
                // 判断第2区第一个有无占位
                $real_area_key = 1;
                $temp_node = self::findOne(['store_id' => $store_id, 'parent_node' => $current_node['user_id'], 'area_key' => $real_area_key]);
                if (!$temp_node) {
                    //debug_log([__METHOD__, __LINE__, "当前节点ID:{$current_node['user_id']}，可开第2区，落第2区"], strtolower(__CLASS__ . '.log'));
                    $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $current_node['user_id']]);
                    $current_layer_rank = self::find()
                        ->where(['store_id' => $store_id, 'layer_node' => $real_parent_node['layer_node'] + 1])
                        ->max('layer_rank');
                    $real_layer_rank = $current_layer_rank + 1;
                    return [$real_parent_node, $real_layer_rank, $real_area_key];
                }
            }

            // 判断用户能否开第3区
            $parent_multi_col_auth = self::checkMultiColumnAuth($store_id, $current_node['user_id']);
            if ($parent_multi_col_auth) {
                // 判断第3区第一个有无占位
                $real_area_key = 2;
                $temp_node = self::findOne(['store_id' => $store_id, 'parent_node' => $current_node['user_id'], 'area_key' => $real_area_key]);
                if (!$temp_node) {
                    //debug_log([__METHOD__, __LINE__, "当前节点ID:{$current_node['user_id']}，可开第3区，落第3区"], strtolower(__CLASS__ . '.log'));
                    $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $current_node['user_id']]);
                    $current_layer_rank = self::find()
                        ->where(['store_id' => $store_id, 'layer_node' => $real_parent_node['layer_node'] + 1])
                        ->max('layer_rank');
                    $real_layer_rank = $current_layer_rank + 1;
                    return [$real_parent_node, $real_layer_rank, $real_area_key];
                }
            }

            // 查询当前节点的子节点（假设最多有3个子节点情况，根据实际parent_id关联查询）
            $children_nodes = self::find()->where(['store_id' => $store_id, 'parent_node' => $current_node['user_id']])->orderBy("area_key ASC")->all();
            if ($children_nodes) {
                foreach ($children_nodes as $node) {
                    $queue[] = $node;
                }
            }
        }
    }

    /**
     * 获取用户最后一个节点
     * 深度优先，从左至右
     * @param $store_id 店铺ID
     * @param $user_id 下单用户ID
     * @param $parent_id 下单用户上级ID
     * @param $max_layer 限制最大层数
     * @return array
     */
    public static function getRealParentNodePlus($store_id, $order_user_id, $parent_id, $max_layer)
    {
        // 针对父节点对应的区
        $real_area_key = 0;
        // 针对根节点对应的排序
        $real_layer_rank = 0;

        $parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $parent_id]);
        $children_list = self::findOne(['store_id' => $store_id, 'parent_node' => $parent_id]);
        // 未有子节点
        if (!$children_list) {
            //debug_log([__METHOD__, __LINE__, "未有子节点"], strtolower(__CLASS__ . '.log'));
            $real_parent_node = $parent_node;
            return [$real_parent_node, $real_area_key, $real_layer_rank];
        }

        // 广度优先遍历
        $queue = [];
        $queue[] = $parent_node;
        while (!empty($queue)) {
            // 当前节点
            $current_node = array_shift($queue);
            // 当前层数
            $current_layer = $current_node['layer_node'] - $parent_node['layer_node'];
            //debug_log([__METHOD__, __LINE__, "当前节点ID：{$current_node['user_id']}，当前层数：{$current_layer}"], strtolower(__CLASS__ . '.log'));

            // 深度优先
            $dfs_parent_node = self::findLastNodeDFS($current_node, $max_layer);
            if ($dfs_parent_node) {
                //debug_log([__METHOD__, __LINE__, "深度优先：查找到节点用户ID：{$dfs_parent_node['user_id']}"], strtolower(__CLASS__ . '.log'));
                $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $dfs_parent_node['user_id']]);
                $current_layer_rank = self::find()
                    ->where(['store_id' => $store_id, 'layer_node' => $real_parent_node['layer_node'] + 1])
                    ->max('layer_rank');
                $real_layer_rank = is_null($current_layer_rank) ? 0 : $current_layer_rank + 1;
                $current_area_key = self::find()
                    ->where(['store_id' => $store_id, 'parent_node' => $real_parent_node['user_id']])
                    ->max('area_key');
                $real_area_key = is_null($current_area_key) ? 0 : $current_area_key + 1;
                return [$real_parent_node, $real_layer_rank, $real_area_key];
            }

            // 取1~n区子节点
            // 判断用户第1区有无落点
            $parent_first_col_auth = self::findOne(['store_id' => $store_id, 'parent_node' => $current_node['user_id'], 'area_key' => 0]);
            if (!$parent_first_col_auth) {
                $real_area_key = 0;
                //debug_log([__METHOD__, __LINE__, "当前节点ID:{$current_node['user_id']}，1区没人，落第1区"], strtolower(__CLASS__ . '.log'));
                $real_parent_node = self::findOne(['store_id' => $store_id, 'user_id' => $current_node['user_id']]);
                $current_layer_rank = self::find()
                    ->where(['store_id' => $store_id, 'layer_node' => $real_parent_node['layer_node'] + 1])
                    ->max('layer_rank');
                $real_layer_rank = $current_layer_rank + 1;
                return [$real_parent_node, $real_layer_rank, $real_area_key];
            }

            // 查询当前节点的子节点（假设最多有3个子节点情况，根据实际parent_id关联查询）
            $children_nodes = self::find()->where(['store_id' => $store_id, 'parent_node' => $current_node['user_id']])->orderBy("area_key ASC")->all();
            if ($children_nodes) {
                foreach ($children_nodes as $node) {
                    $queue[] = $node;
                }
            }
        }
    }

    /**
     * 深度优先搜索
     * @param $node
     * @return mixed
     */
    public static function findLastNodeDFS($node, $depth, $current_depth = 0)
    {
        // 达到指定深度，退出
        if ($current_depth + 1 >= $depth) {
            return null;
        }

        $last_node = $node;
        $children_nodes = self::find()->where(['store_id' => $last_node['store_id'], 'parent_node' => $last_node['user_id']])->orderBy("area_key ASC")->all();
        // 递归处理所有子树
        foreach ($children_nodes as $children_node) {
            //debug_log([__METHOD__, __LINE__, "深度遍历：查找到子节点用户ID：{$children_node['user_id']}，当前深度：{$current_depth}，最大深度：{$depth}"], strtolower(__CLASS__ . '.log'));
            $temp = self::findLastNodeDFS($children_node, $depth, $current_depth + 1);
            if ($temp) {
                $last_node = $temp;
            }
        }
        return $last_node;
    }

    public static function getAllParentIds($user_id)
    {
        $relation = self::findOne(['user_id' => $user_id]);
        $recommon_relation = trim($relation['recommend_relation'], ',');
        if (!$recommon_relation) return [];
        return explode(',', $recommon_relation);
    }

    public static function getAllParentNodeIds($user_id)
    {
        $relation = self::findOne(['user_id' => $user_id]);
        $recommon_relation_node = trim($relation['recommend_relation_node'], ',');
        if (!$recommon_relation_node) return [];
        return explode(',', $recommon_relation_node);
    }

    public static function getChildNodeIdsByUserId($user_id, $node_key = '', $level = 0, $scope = 'all')
    {
        $user_node = self::find()->select(['layer_node'])->where(['user_id' => $user_id])->asArray()->one();
        $layer_node = (int)$user_node['layer_node'];
        $query = self::find()->select(['user_id'])->where(['like', 'recommend_relation_node', (',' . $user_id . ',')]);
        if ($node_key) $query->andWhere(['node_key' => $node_key]);
        //查询多N代全部子用户
        if ($level > 0 && $scope == 'all') $query->andWhere(['>=', 'layer_node', $level + $layer_node]);
        //查询指定代子用户
        if ($level > 0 && $scope == 'equal') $query->andWhere(['=', 'layer_node', $level + $layer_node]);
        return $query->asArray()->column();
    }

    /**
     * 查询用户指定部门的所有用户
     * @param $user_id
     * @param $node_key
     * @return array
     */
    public static function getChildNodeIdsByNodeKey($user_id, $department_key)
    {
        // if ($department_key) {
        //     // 其他 部门
        //     $first_node = self::find()->select(['user_id'])
        //         ->where(['parent_id' => $user_id, 'node_key' => $department_key])
        //         ->asArray()
        //         ->one();
        //     if (!$first_node) return [];
        //     $res = self::find()->select(['user_id'])
        //         ->where(['or', ['user_id' => $first_node['user_id']], ['like', 'recommend_relation_node', (',' . $first_node['user_id'] . ',')]])
        //         ->asArray()->column();
        // } else {
        //     // A 部门
        //     $res = self::find()->select(['user_id'])
        //         ->where(['like', 'recommend_relation_node', (',' . $user_id . ',')])
        //         ->asArray()->column();
        // }

        $res = UserNodeDepartment::find()->select(['child_id'])
                ->where(['user_id' => $user_id, 'department_key' => $department_key])
                ->asArray()->column();
        return $res;
    }

    public static function getAllParentList($user_id)
    {
        $relation = self::findOne(['user_id' => $user_id]);
        $recommon_relation = trim($relation['recommend_relation'], ',');
        $relation_arr = explode(',', $recommon_relation);
        if (empty($relation_arr)) {
            return [];
        }

        $list = Share::find()->alias('s')->where(array('in', 's.user_id', $relation_arr))
            ->andWhere(['sl.is_delete' => 0])
            ->leftJoin(['sl' => ShareLevel::tableName()], 'sl.level=s.level')
            ->select('s.user_id, sl.order_layer, sl.point_reward')
            ->asArray()
            ->all();
        if (empty($list)) {
            return [];
        }

        $level_list = ArrayHelper::index($list, "user_id");

        $res = [];
        foreach ($relation_arr as $v) {
            $temp = [];
            $temp['user_id'] = $v;
            $temp['order_layer'] = $level_list[$v]['order_layer'] ?? 0;
            $temp['point_reward'] = $level_list[$v]['point_reward'] ?? 0;
            $temp['is_bonus'] = isset($level_list[$v]);
            $res[] = $temp;
        }

        return $res;
    }

    public static function getAllParentNodeList($user_id)
    {
        $relation = self::findOne(['user_id' => $user_id]);
        $recommon_relation_node = trim($relation['recommend_relation_node'], ',');
        $relation_arr = explode(',', $recommon_relation_node);
        if (empty($relation_arr)) {
            return [];
        }

        $list = Share::find()->alias('s')->where(array('in', 's.user_id', $relation_arr))
            ->andWhere(['sl.is_delete' => 0])
            ->leftJoin(['sl' => ShareLevel::tableName()], 'sl.level=s.level')
            ->select('s.user_id, sl.order_layer, sl.point_reward')
            ->asArray()
            ->all();
        if (empty($list)) {
            return [];
        }

        $level_list = ArrayHelper::index($list, "user_id");

        $res = [];
        foreach ($relation_arr as $v) {
            $temp = [];
            $temp['user_id'] = $v;
            $temp['order_layer'] = $level_list[$v]['order_layer'] ?? 0;
            $temp['point_reward'] = $level_list[$v]['point_reward'] ?? 0;
            $temp['is_bonus'] = isset($level_list[$v]);
            $res[] = $temp;
        }

        return $res;
    }

    public static function getRecommendRelationByUserId($user_id)
    {
        $res = "";
        $parentList = [];
        self::getParentList($user_id, $parentList);
        if ($parentList) {
            $res = "," . implode(',', array_reverse($parentList)) . ",";
        }
        return $res;
    }

    public static function getParentList($user_id, &$parentList)
    {
        $user = User::findOne(['id' => $user_id]);
        if ($user['parent_id']) {
            $parentList[] = $user['parent_id'];
            $parent = User::findOne(['id' => $user['parent_id']]);
            if ($parent) {
                return self::getParentList($parent['id'], $parentList);
            }
        }
        return $parentList;
    }

    public static function getLayerByUserId($user_id)
    {
        $res = 1;
        $parentList = [];
        self::getParentList($user_id, $parentList);
        if ($parentList) {
            $res += count($parentList);
        }
        return $res;
    }

    public static function createUserNode($store_id, $user_id)
    {
        $user_node = UserNode::findOne(['user_id' => $user_id]);
        if (!$user_node) {
            $user = User::findOne(['id' => $user_id]);

            $user_node = new UserNode();
            $user_node->store_id = $store_id;
            $user_node->user_id = $user_id;
            $user_node->parent_id = $user['parent_id'];
            $user_node->recommend_relation = self::getRecommendRelationByUserId($user_id);
            $user_node->layer = self::getLayerByUserId($user_id);
            $user_node->recommend_relation_node = "";
            $user_node->layer_node = 0;
            $user_node->created_at = time();
            if (!$user_node->save()) {
                //debug_log([__METHOD__, __LINE__, "用户：{$user_id}，节点信息保存失败"], 'share_bind.log');
            }
        }
        return $user_node;
    }

    public static function getChildNodeCount($user_id)
    {
        $node_count = self::find()->select('COUNT(id) as node_count')->where(['like', 'recommend_relation_node', (',' . $user_id . ',')])->scalar();
         return (int)$node_count;
    }

    public static function getTeamNodeOrderPrice($user_id)
    {
        $child_ids = self::getChildNodeIdsByUserId($user_id);
        $team_ids = array_merge($child_ids, [$user_id]);
        return User::find()->select('SUM(`total_coin`) as node_order_price')->where(['in', 'id', $team_ids])->scalar();
    }

    /**
     * 获取用户部门列表
     * @param $user_id
     * @return array
     */
    public static function getUserDepartmentList($user_id)
    {
        $user = User::findOne(['id' => $user_id]);
        $user_share_holder_level = ShareHolder::findOne(['user_id' => $user_id]);

        if ($user['total_coin'] < 50) {
            // 未消费大礼包只有A部门
            $department_key_highest = 0;
        } else {
            // 有消费则有A,B等多部门
            if ($user_share_holder_level['level_id'] < 9) {
                // 股东等级小于V7只有A,B两条线
                $department_key_highest = 1;
            } else {
                // 大于等于V7可开多线
                $department_key_highest = self::getLastNodeKeyByUserId($user_id) + 1;
            }
        }

        $res = [];
        for ($department_key = 0; $department_key <= $department_key_highest; $department_key++) {
            $last_user_id = self::getLastUserByDepartmentKey($user_id, $department_key);
            $last_user = User::findOne(['id' => $last_user_id]);
            $department_name = $department_key + 1;
            $temp = [];
            $temp['id'] = $department_key;
            $temp['department_key'] = $department_key;
            $temp['user_id'] = $last_user_id;
            $temp['department_name'] = "{$department_name}-部门";
            $temp['nickname'] = $last_user['nickname'];
            $temp['mobile'] = $last_user['binding'];
            $res[] = $temp;
        }

        return $res;
    }

    /**
     * 获取指定用户最高部门 node_key
     * @param $user_id
     * @return int|mixed
     */
    public static function getLastNodeKeyByUserId($user_id)
    {
        $last_node_key = 0;
        $node_list = UserNode::find()
            ->where(['parent_id' => $user_id])
            ->orderBy('node_key DESC')
            ->asArray()
            ->one();
        if ($node_list) {
            $last_node_key = $node_list['node_key'];
        }
        return $last_node_key;
    }

    /**
     * 获取指定用户的部门最后一个用户
     * @param $user_id
     * @param $department_name
     * @return int
     */
    public static function getLastUserByDepartmentKey($user_id, $department_key)
    {
        // $first_node = self::find()->select(['user_id'])
        //     ->where(['parent_id' => $user_id, 'node_key' => $department_key])
        //     ->asArray()
        //     ->one();
        // if (!$first_node) return (int)$user_id;
        //
        // $last_user_node = UserNode::find()
        //     ->where(['or', ['user_id' => $first_node['user_id']], ['like', 'recommend_relation_node', (',' . $first_node['user_id'] . ',')]])
        //     ->orderBy('layer_node DESC')
        //     ->asArray()
        //     ->one();
        //
        // if ($last_user_node) {
        //     return (int)$last_user_node['user_id'];
        // } else {
        //     return (int)$user_id;
        // }

        $last = UserNodeDepartment::find()
            ->where(['user_id' => $user_id, 'department_key' => $department_key])
            ->orderBy('id DESC')
            ->asArray()
            ->one();
        return $last['user_id'];
    }

    public static function getLastParentNodeLeader($user_id)
    {
        $user_node = self::findOne(['user_id' => $user_id]);
        if ($user_node->parent_id == $user_node->parent_node) {
            return self::findOne(['user_id' => $user_node->parent_id]);
        } else {
            return self::getLastParentNodeLeader($user_node->parent_node);
        }
    }

}