<?php

namespace app\common\model\plus\team;

use app\common\model\BaseModel;
use app\common\model\user\User as UserModel;
use app\common\model\plus\agent\Relation as RelationModel;
use app\common\model\plus\shareholder\Apply as ShareholderApplyModel;

/**
 * 队长推荐关系模型
 */

class Referee extends BaseModel
{
    protected $name = 'team_referee';
    protected $pk = 'id';

    /**
     * 关联用户表
     */

    public function user()
    {
        return $this->belongsTo('app\\common\\model\\user\\User');
    }

    /**
     * 关联队长用户表
     */

    public function team()
    {
        return $this->belongsTo('app\\common\\model\\plus\\team\\User')->where('is_delete', '=', 0);
    }

    /**
     * 关联队长用户表
     */
    public function team1()
    {
        return $this->belongsTo('app\\common\\model\\plus\\team\\User', 'team_id')->where('is_delete', '=', 0);
    }

    /**
     * 获取用户的队长id
     */
    public static function getHeadsId($user_id)
    {
        $heads_id = (new self)->where('user_id', '=', $user_id)
            ->value('heads_id');
            //log_write('user_id'. $user_id .'的heads_id:'.$heads_id);
        if (!$heads_id) return 0;
        return User::isteamUser($heads_id) ? $heads_id : 0;
    }


    /**
     * 获取我的团队列表
     */
    public function getList($user_id)

    {
        $model = $this;
        return $model->with(['user'])

            ->alias('referee')

            ->field('referee.*')

            ->join('user', 'user.user_id = referee.user_id','left')

            ->where('referee.heads_id', '=', $user_id)

            ->where('user.is_delete', '=', 0)

            ->order(['referee.create_time' => 'desc'])

            ->paginate(15);

    }


    public static function detail($user_id)
    {
        return (new static())->where('user_id', '=', $user_id)->find();
    }


    /**
     * 团队人数统计
     */
    public static function teamCount($heads_id)
    {
        return (new static())->where('heads_id', '=', $heads_id)->count();
    }

    /**
     * 创建团队关系
     */
    public static function updateTeamRelation($user_id, $referee_id)
    {
        if ($user_id == $referee_id) {
            return false;
        }

        // 如果上级不是队长，获取上级的队长
        if (!User::isteamUser($referee_id)) {
           $referee_id = self::getHeadsId($referee_id);
        } 

        // 新增关系记录
        $model = new self;
        $model->add($referee_id, $user_id);
        return true;
    }


    /**
     * 新增关系记录
     */
    private function add($heads_id, $user_id)
    {
        $model = static::detail($user_id) ?: new static;
        $model->save([
            'heads_id' => $heads_id,
            'user_id' => $user_id,
            'app_id' => self::$app_id
            ]);
        // 记录队长成员数量
        User::setMemberInc($heads_id);
        // 更新队长等级
        event('TeamUserGrade', $model['heads_id']);
        //根据团队人数判断股东 by yj
        $shareholderModel = new ShareholderApplyModel;
        $shareholderModel->becomeShareholderByTeam($heads_id, 80, self::$app_id);
        // 更新股东等级 by yj
        event('ShareholderUserGrade', $model['heads_id']);
        return true;
    }


    /**
     * 创建队长团队
     */
    public static function createTeam($user_id)
    {
        if (!User::isteamUser($user_id)) {
            return false;
        }

        $data = (new RelationModel)->getAllList($user_id);
        if (!empty($data)) {
            $heads = array( );
			$later = array( );
			$ids = array( );
            foreach( $data as $k => $v )
			{
				if( !empty($v["team1"]) )
				{
					$heads[] = $v["user_id"];
					//continue;
				}
				$ids[] = $v["user_id"];
			}
			if( !empty($heads) )
			{
				$later = (new RelationModel)->getListByIds($heads)->toArray();
			}
			if( !empty($ids) )
			{
				if( !empty($later) )
				{
					$later = array_column($later, "user_id");
					$ids = array_diff($ids, $later);
				}
				// 更新
                (new self)->where('user_id' , 'in', $ids)->data([
                    'heads_id' => $user_id
                ])->update();
                User::setMemberInc($user_id);
			}
        }
        return true;
    }


    /**

     * 获取用户所有级差队长

     */

    public static function getAllJcUser($heads_id, $jcUser = [], $percent_total = 0, $is_add = true)

    {

        $user = User::detail($heads_id, $width = ['grade', 'referee']);

        $is_add && $percent_total += $user['grade']['equity'] - $percent_total;

        if($user['referee']['heads_id']) {

            $is_add = false;

            $parent = User::detail($user['referee']['heads_id'], $width = ['grade', 'referee']);

            if ($parent['grade']['weight'] > $user['grade']['weight'] && $parent['grade']['equity'] > $percent_total) {

                $jcUser[] = [

                    'heads_id' => $user['referee']['heads_id'],

                    'bonus_type' => 20,

                    'bonus_percent' => $parent['grade']['equity'] - $percent_total //分红比例

                ];

                $is_add = true;

            }

            if($parent['referee']['heads_id']) {

                return self::getAllJcUser($user['referee']['heads_id'], $jcUser, $percent_total, $is_add);

            }

        }

        return $jcUser;

    }

	
    /**

     * 获取用户所有平级队长

     * 每个级别都发放$pjaward_level层平级奖

     */

    public static function getAllPjUser($heads_id, $pjaward_level, $pjUser = [])

    {

        $user = User::detail($heads_id, $width = ['grade', 'referee']);

        $pj_user[$user['grade_id']][] = [];

        $pj_user = self::getPjUser($heads_id, $pj_user);

        if ($pj_user) {

            foreach ($pj_user as $u) {

                foreach ($u as $k => $item) {

                    if ($k > 0 && $k <= $pjaward_level) {

                        $pjUser[] = $item; 

                    }

                }

            }

        }

        return $pjUser;

    }


    /**

     * 获取所有平级队长

     */

    private static function getPjUser($heads_id, $pj_user = [])

    {

        $user = User::detail($heads_id, $width = ['grade', 'referee']);

        if($user['referee']['heads_id']) {

            $parent = User::detail($user['referee']['heads_id'], $width = ['grade', 'referee']);

            // 记录平级用户

            if($parent && $parent['grade']['weight'] >= $user['grade']['weight']) {

                $pj_user[$parent['grade_id']][] = [

                    'heads_id' => $parent['user_id'],

                    'bonus_type' => 30,

                    'bonus_percent' => $parent['grade']['pjaward_percent'] ? $parent['grade']['pjaward_percent'] : 0, // 平级分红比例

                ];

            }

            if($parent['referee']['heads_id']) {

                return self::getPjUser($parent['user_id'], $pj_user);

            }

        }

        return $pj_user;

    }

}