<?php
|
|
namespace app\operations\model\plus\bonus;
|
|
use app\operations\model\plus\bonus\Referee as RefereeModel;
|
use app\common\model\plus\bonus\User as UserModel;
|
use app\common\model\user\User as UserModel1;
|
use app\common\model\plus\agent\User as agentUser;
|
use app\common\model\plus\agent\Referee as agentReferee;
|
use app\common\library\helper;
|
use app\operations\service\order\ExportService;
|
|
/**
|
* 队长用户模型
|
* Class User
|
* @package app\operations\model\plus\bonus
|
*/
|
class User extends UserModel
|
{
|
/**
|
* 获取队长用户列表
|
*/
|
public function getList($keyword, $search_type = 'user_id', $params = [])
|
{
|
// 构建查询规则
|
$model = $this->alias('bonus')
|
->field('bonus.*, user.nickName, user.avatarUrl')
|
->with(['referee','grade','parent','agentuser'])
|
->join('user', 'user.user_id = bonus.user_id')
|
->where('bonus.is_delete', '=', 0)
|
->order(['bonus.tree_level' => 'asc', 'level_num' => 'asc', 'agent_time' => '']);
|
// 查询条件
|
if (!empty($keyword)) {
|
if ($search_type == 'user_id') {
|
$model = $model->where('bonus.user_id', '=', $keyword);
|
} else {
|
if ($search_type == 'nickName') {
|
$search_field = 'user.' . $search_type;
|
} else {
|
$search_field = 'bonus.' . $search_type;
|
}
|
$model = $model->where($search_field, 'like', '%' . $keyword . '%');
|
}
|
}
|
// 获取列表数据
|
$list = $model->paginate($params);
|
$setting = Setting::getItem('basic');
|
$userData = [];
|
foreach ($list as &$user){
|
$user['total_money'] = sprintf('%.2f', $user['money'] + $user['freeze_money'] + $user['total_money']);
|
// 排位有效期
|
$user['remain_time'] = UserModel::getExpireTime($user['user_id']);
|
// $user['is_expire'] = UserModel::isExpire($user['user_id']);
|
|
// 初始化最新推荐人推荐时间
|
// $agentuser = $user['agentuser']->toArray();
|
// if($agentuser) {
|
// $agent_time = strtotime($agentuser[0]['create_time']);
|
// } else {
|
// $agent_time = strtotime($user['create_time']);
|
// }
|
// $userData[] = [
|
// 'user_id' => $user['user_id'],
|
// 'agent_time' => $agent_time
|
// ];
|
}
|
unset($user);
|
// $this->saveAll($userData);
|
return $list;
|
}
|
/**
|
* 编辑队长用户
|
* @param $data
|
* @return bool
|
*/
|
public function edit($data)
|
{
|
//如果更换用户
|
$new_user_id = $data['new_user_id'];
|
unset($data['new_user_id']);
|
if($new_user_id) {
|
$new_data = $data;
|
$new_user = UserModel1::detail($new_user_id);
|
$new_data['user_id'] = $new_user_id;
|
$new_data['referee_id'] = $new_user['referee_id'];
|
$setting = Setting::getItem('basic', $new_user['app_id']);
|
// 如果不保留资产 by lyzflash
|
if ($setting['keep_assets'] == 0) {
|
$new_data['money'] = 0;
|
$new_data['freeze_money'] = 0;
|
$new_data['freeze_money_second'] = 0;
|
$new_data['total_money'] = 0;
|
}
|
if ($this->where(['user_id' => $data['user_id']])->save($new_data)) {
|
//将原用户下级改为新用户下级
|
$this->updateParentId($data['user_id'], $new_user_id);
|
//更新关系表
|
RefereeModel::updateReferee($data['user_id'], $new_user_id);
|
//同时成为分销商
|
$config = Setting::getItem('basic', $new_user['app_id']);
|
if ($config['become_agent']) {
|
agentUser::add($new_user_id, [
|
'referee_id' => agentReferee::getRefereeUserId($new_user_id, 1),
|
'app_id' => $new_user['app_id'],
|
]);
|
}
|
return true;
|
}
|
return false;
|
}
|
return $this->save($data) !== false;
|
}
|
|
/**
|
* 删除队长用户
|
* @return mixed
|
*/
|
public function setDelete()
|
{
|
return $this->transaction(function () {
|
// 获取一级团队成员ID集
|
$RefereeModel = new RefereeModel;
|
$bonus1Ids = $RefereeModel->getBonusUserIds($this['user_id'], 1);
|
if (!empty($bonus1Ids)) {
|
// 一级团队成员归属到平台
|
$this->setFromplatform($bonus1Ids);
|
// 一级推荐人ID
|
$referee1Id = RefereeModel::getRefereeUserId($this['user_id'], 1, true);
|
if ($referee1Id > 0) {
|
// 一级推荐人的成员数量(二级)
|
$this->setDecBonusNum($referee1Id, 2, count($bonus1Ids));
|
// 一级推荐人的成员数量(三级)
|
$bonus2Ids = $RefereeModel->getBonusUserIds($this['user_id'], 2);
|
!empty($bonus2Ids) && $this->setDecBonusNum($referee1Id, 3, count($bonus2Ids));
|
// 二级推荐人的成员数量(三级)
|
$referee2Id = RefereeModel::getRefereeUserId($this['user_id'], 2, true);
|
$referee2Id > 0 && $this->setDecBonusNum($referee2Id, 3, count($bonus1Ids));
|
// 清空队长下级成员与上级推荐人的关系记录
|
$RefereeModel->onClearTop(array_merge($bonus1Ids, $bonus2Ids));
|
}
|
}
|
// 清空下级推荐记录
|
$RefereeModel->onClearBonus($this['user_id']);
|
// 标记当前队长记录为已删除
|
return $this->save([
|
'is_delete' => 1
|
]);
|
});
|
}
|
|
/**
|
* 更改用户的parent_id
|
* @param $user_id
|
* @param $new_user_id
|
* @return false|int
|
*/
|
private function updateParentId($user_id, $new_user_id)
|
{
|
return $this->where('parent_id', '=', $user_id)
|
->save(['parent_id' => $new_user_id]);
|
}
|
|
/**
|
* 一级团队成员归属到平台
|
* @param $userIds
|
* @return false|int
|
*/
|
private function setFromplatform($userIds)
|
{
|
return $this->where('user_id', 'in', $userIds)
|
->where('is_delete', '=', 0)
|
->save(['referee_id' => 0]);
|
}
|
|
/**
|
* 递减队长成员数量
|
*/
|
private function setDecBonusNum($bonus_id, $level, $number)
|
{
|
$field = [1 => 'first_num', 2 => 'second_num', 3 => 'third_num'];
|
return $this->where('user_id', '=', $bonus_id)
|
->where('is_delete', '=', 0)
|
->dec($field[$level], $number);
|
}
|
|
/**
|
* 删除用户的上级推荐关系
|
* @param $userId
|
* @return bool
|
* @throws \think\Exception
|
*/
|
public function onDeleteReferee($userId)
|
{
|
// 获取推荐人列表
|
$list = RefereeModel::getRefereeList($userId);
|
if (!$list->isEmpty()) {
|
// 递减推荐人的下级成员数量
|
foreach ($list as $item) {
|
$item['bonus1'] && $this->setDecBonusNum($item['bonus_id'], $item['level'], 1);
|
}
|
// 清空上级推荐关系
|
(new RefereeModel)->onClearReferee($userId);
|
}
|
return true;
|
}
|
|
/**
|
* 获取平台的总销售额
|
*/
|
public function getTotalMoney($type = 'all_money')
|
{
|
$model = $this;
|
if($type == 'money'){
|
return $model->sum('money');
|
} else if($type == 'freeze_money'){
|
return $model->sum('freeze_money');
|
} else if($type == 'freeze_money_second'){
|
return $model->sum('freeze_money_second');
|
} else if($type == 'total_money'){
|
return $model->sum('total_money');
|
} else if($type == 'all_money'){
|
return $model->sum('total_money') + $model->sum('freeze_money') + $model->sum('money');
|
}
|
return 0;
|
}
|
|
public function getArchitecture($search = '', $type = 0)
|
{
|
$model = new UserModel();
|
$model = $model->alias('bonus')
|
->field('bonus.*, user.nickName, user.avatarUrl')
|
->with(['referee','grade','parent'])
|
->join('user', 'user.user_id = bonus.user_id')
|
->where('bonus.is_delete', '=', 0);
|
if (!empty($search)) {
|
if ($type) {
|
if (intval($search)) {
|
$model = $model->where('bonus.user_id', '=', $search);
|
} else {
|
$model = $model->where('user.nickName|bonus.real_name|bonus.mobile', 'like', '%' . $search . '%');
|
}
|
} else {
|
$model = $model->where('bonus.user_id', '=', $search);
|
}
|
} else {
|
$model = $model->where('bonus.tree_level', '=', 1);
|
}
|
$firstUser = $model->find();
|
if (!$firstUser) {
|
return false;
|
}
|
$secondUser = $this->getArchitectureSubUser($firstUser);
|
$thirdUser = [];
|
foreach ($secondUser as &$user) {
|
$thirdUser = array_merge($thirdUser, $this->getArchitectureSubUser($user));
|
}
|
unset($user);
|
return ['firstUser' => $firstUser, 'secondUser' => $secondUser, 'thirdUser' => $thirdUser];
|
}
|
|
private function getArchitectureSubUser($user)
|
{
|
if ($user) {
|
$model = new UserModel();
|
$subUser = $model->alias('bonus')
|
->field('bonus.*, user.nickName, user.avatarUrl')
|
->with(['referee','grade','parent'])
|
->join('user', 'user.user_id = bonus.user_id')
|
->where('parent_id', '=', $user['user_id'])
|
->where('bonus.is_delete', '=', 0)
|
->order(['level_num' => 'asc'])
|
->select()->toArray();
|
} else {
|
$subUser = [];
|
}
|
// 补全3个位置
|
if (count($subUser) < 3) {
|
$emptyArr = [];
|
for ($i = 0; $i < 3 - count($subUser); $i++) {
|
$emptyArr[] = [];
|
}
|
$subUser = array_merge($subUser, $emptyArr);
|
}
|
return $subUser;
|
}
|
|
/**
|
* 获取队长用户列表
|
*/
|
public function exportList($keyword, $search_type = 'user_id', $params = [])
|
{
|
// 构建查询规则
|
$model = $this->alias('bonus')
|
->field('bonus.*, user.nickName, user.avatarUrl')
|
->with(['referee','grade','parent','agentuser'])
|
->join('user', 'user.user_id = bonus.user_id')
|
->where('bonus.is_delete', '=', 0)
|
->order(['bonus.tree_level' => 'asc', 'level_num' => 'asc', 'agent_time' => '']);
|
// 查询条件
|
if (!empty($keyword)) {
|
if ($search_type == 'user_id') {
|
$model = $model->where('bonus.user_id', '=', $keyword);
|
} else {
|
if ($search_type == 'nickName') {
|
$search_field = 'user.' . $search_type;
|
} else {
|
$search_field = 'bonus.' . $search_type;
|
}
|
$model = $model->where($search_field, 'like', '%' . $keyword . '%');
|
}
|
}
|
// 获取列表数据
|
$list = $model->select();
|
foreach ($list as &$user){
|
$user['total_money'] = sprintf('%.2f', $user['money'] + $user['freeze_money'] + $user['total_money']);
|
// 排位有效期
|
$user['remain_time'] = UserModel::getExpireTime($user['user_id']);
|
}
|
unset($user);
|
// 导出excel文件
|
(new Exportservice)->bonusUserList($list);
|
}
|
}
|
