<?php
|
|
namespace app\common\model\plus\agent;
|
|
use app\common\model\BaseModel;
|
use app\common\model\user\User as UserModel;
|
use app\common\model\plus\agent\Referee as RefereeModel;
|
|
/**
|
* 分销商推荐关系模型（所有层级）
|
*/
|
class Relation extends BaseModel
|
{
|
protected $name = 'agent_relation';
|
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', '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 function getAllIds($agent_id)
|
{
|
return $this->where('agent_id', '=', $agent_id)->column('user_id');
|
}
|
|
/**
|
* 获取指定用户的下线列表
|
*/
|
public function getAllList($userId)
|
{
|
return $this->with(['team1'])->where('agent_id', '=', $userId)->select();
|
}
|
|
/**
|
* 获取指定用户的下线列表
|
*/
|
public function getListByIds($userIds, $with = [])
|
{
|
return $this->getListByInArray('agent_id', $userIds, $with);
|
}
|
|
/**
|
* 获取指定用户的下线列表
|
*/
|
private function getListByInArray($field, $data, $with = [])
|
{
|
return $this->with($with)
|
->where($field, 'in', $data)
|
->select();
|
}
|
|
/**
|
* 创建推荐关系
|
*/
|
public static function updateRelation($user_id, $referee_id, $level = 1, $later = array())
|
{
|
// 自分享
|
if ($user_id == $referee_id) {
|
return false;
|
}
|
if (!empty($later)) {
|
if (self::inArray($referee_id, $later)) {
|
return UserModel::detail($referee_id);
|
}
|
} else {
|
$later[] = $user_id;
|
}
|
$later[] = $referee_id;
|
$level = max($level, 1);
|
$model = new self;
|
if ( $level == 1 ) {
|
$model->add($referee_id, $user_id, 1);
|
}
|
$parent_id = RefereeModel::getRefereeUserId($referee_id, 1);
|
if (empty($parent_id )) {
|
return false;
|
} else {
|
if ($user_id == $parent_id) {
|
return UserModel::detail($user_id);
|
}
|
$model->add($parent_id, $user_id, ++$level);
|
return self::updateRelation($user_id, $parent_id, $level, $later);
|
}
|
return true;
|
}
|
|
/**
|
* 删除推荐关系
|
*/
|
public static function deleteRelation($user_id)
|
{
|
$model = new self;
|
$parent = $model->where('agent_id', '=', $user_id)->select();
|
if ($parent) {
|
foreach ($parent as $p) {
|
$model->where('user_id', '=', $p['user_id'])->where('level', '>=', $p['level'])->delete();
|
}
|
}
|
$model->where('user_id', '=', $user_id)->delete();
|
}
|
|
/**
|
* 删除推荐关系
|
*/
|
public static function modifyRelation($user_id, $agent_id = NULL)
|
{
|
$model = new self;
|
$model->where('user_id', '=', $user_id)->delete();
|
if( !empty($agent_id) ) {
|
self::updateRelation($user_id, $agent_id);
|
}
|
$parent = $model->where('agent_id', '=', $user_id)->select();
|
if ($parent) {
|
foreach ($parent as $p) {
|
$model->where('user_id', '=', $p['user_id'])->where('level', '>', $p['level'])->delete();
|
self::updateRelation($p['id'], $p['agent_id'], $p['level']);
|
}
|
}
|
}
|
|
/**
|
* 新增关系记录
|
*/
|
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'));
|
return true;
|
}
|
|
private static function inArray($item, $array)
|
{
|
$flipArray = array_flip($array);
|
return isset($flipArray[$item]);
|
}
|
}
|
