<?php
|
|
namespace app\common\model\plus\agent;
|
|
use app\common\model\BaseModel;
|
use app\api\model\plus\team\Referee as TeamRefereeModel;
|
use app\common\model\plus\team\Apply as TeamApplyModel;
|
use app\common\model\plus\agent\Relation as RelationModel;
|
|
/**
|
* 分销商推荐关系模型
|
*/
|
class Referee extends BaseModel
|
{
|
protected $name = 'agent_referee';
|
protected $pk = 'id';
|
|
/**
|
* 关联用户表
|
*/
|
public function user()
|
{
|
return $this->belongsTo('app\\common\\model\\user\\User');
|
}
|
|
/**
|
* 关联分销商用户表
|
*/
|
public function agent()
|
{
|
return $this->belongsTo('app\\common\\model\\plus\\agent\\User', 'user_id', 'user_id')->where('is_delete', '=', 0);
|
}
|
|
/**
|
* 关联分销商用户表
|
*/
|
public function agent1()
|
{
|
return $this->belongsTo('app\\common\\model\\plus\\agent\\User', 'agent_id')->where('is_delete', '=', 0);
|
}
|
|
/**
|
* 获取上级用户id
|
*/
|
public static function getRefereeUserId($user_id, $level, $is_agent = false)
|
{
|
$agent_id = (new self)->where(compact('user_id', 'level'))
|
->value('agent_id');
|
if (!$agent_id) return 0;
|
return $is_agent ? (User::isAgentUser($agent_id) ? $agent_id : 0) : $agent_id;
|
}
|
|
/**
|
* 获取我的团队列表
|
*/
|
public function getList($user_id, $level = -1)
|
{
|
$model = $this;
|
if($level > -1){
|
$model = $model->where('referee.level', '=', $level);
|
}
|
return $model->with(['agent', 'user'=>['grade']])
|
->alias('referee')
|
->field('referee.*')
|
->join('user', 'user.user_id = referee.user_id','left')
|
->where('referee.agent_id', '=', $user_id)
|
->where('user.is_delete', '=', 0)
|
->order(['referee.create_time' => 'desc'])
|
->paginate(15);
|
}
|
|
/**
|
* 创建推荐关系
|
*/
|
public static function createRelation($user_id, $referee_id)
|
{
|
// 分销商基本设置
|
$setting = Setting::getItem('basic');
|
// 是否开启分销功能
|
if (!$setting['is_open']) {
|
return false;
|
}
|
// 自分享
|
if ($user_id == $referee_id) {
|
return false;
|
}
|
// # 记录一级推荐关系
|
// 判断当前用户是否已存在推荐关系
|
if (self::isExistReferee($user_id)) {
|
return false;
|
}
|
// 判断推荐人是否为分销商
|
if (!User::isAgentUser($referee_id)) {
|
return false;
|
}
|
// 新增关系记录
|
$model = new self;
|
$model->add($referee_id, $user_id, 1);
|
// # 记录二级推荐关系
|
if ($setting['level'] >= 2) {
|
// 二级分销商id
|
$referee_2_id = self::getRefereeUserId($referee_id, 1, true);
|
// 新增关系记录
|
$referee_2_id > 0 && $model->add($referee_2_id, $user_id, 2);
|
}
|
// # 记录三级推荐关系
|
if ($setting['level'] == 3) {
|
// 三级分销商id
|
$referee_3_id = self::getRefereeUserId($referee_id, 2, true);
|
// 新增关系记录
|
$referee_3_id > 0 && $model->add($referee_3_id, $user_id, 3);
|
}
|
|
// 建立团队分红关系 by yj
|
TeamRefereeModel::createRelation($user_id, $referee_id);
|
// 记录所有层级关系 by yj
|
RelationModel::updateRelation($user_id, $referee_id);
|
|
return true;
|
}
|
|
/**
|
* 新增关系记录
|
*/
|
private function add($agent_id, $user_id, $level = 1)
|
{
|
// 新增推荐关系
|
$app_id = self::$app_id;
|
$create_time = time();
|
$this->insert(compact('agent_id', 'user_id', 'level', 'app_id', 'create_time'));
|
// 记录分销商成员数量
|
User::setMemberInc($agent_id, $level);
|
|
// 团队分红添加队长 by lyzflash
|
$model = new TeamApplyModel;
|
$model->becomeTeamByAgent($agent_id, 40, $app_id);
|
$model->becomeTeamByAgent($user_id, 70,$app_id);
|
|
return true;
|
}
|
|
/**
|
* 创建推荐关系
|
*/
|
public static function updateRelation($user_id, $referee_id)
|
{
|
// 自分享
|
if ($user_id == $referee_id) {
|
return false;
|
}
|
// 新增关系记录
|
$model = new self;
|
$model->add($referee_id, $user_id, 1);
|
// # 记录二级推荐关系
|
// 二级分销商id
|
$referee_2_id = self::getRefereeUserId($referee_id, 1, true);
|
// 新增关系记录
|
$referee_2_id > 0 && $model->add($referee_2_id, $user_id, 2);
|
// # 记录三级推荐关系
|
// 三级分销商id
|
$referee_3_id = self::getRefereeUserId($referee_id, 2, true);
|
// 新增关系记录
|
$referee_3_id > 0 && $model->add($referee_3_id, $user_id, 3);
|
// 更新推荐人关系(全部) by yj
|
Relation::deleteRelation($user_id);
|
RelationModel::updateRelation($user_id, $referee_id);
|
return true;
|
}
|
|
/**
|
* 是否已存在推荐关系
|
*/
|
private static function isExistReferee($user_id)
|
{
|
return !!(new static())->where(['user_id' => $user_id])->find();
|
}
|
|
/**
|
* 获取用户推荐关系的排序位置 by yj
|
*/
|
public static function getSortNumber($user_id, $level = 1)
|
{
|
$user = (new self)->where('user_id', '=', $user_id)
|
->where('level', '=', 1)
|
->find();
|
return (new static())->where('agent_id', '=', $user['agent_id'])
|
->where('level', '=', $level)
|
->where('create_time', '<=', strtotime($user['create_time']))
|
->count();
|
}
|
}
|
