616 行
27 KiB
PHP
616 行
27 KiB
PHP
<?php
|
||
|
||
namespace app\admin\controller\shopro\commission;
|
||
|
||
use app\admin\controller\shopro\Common;
|
||
use app\admin\model\shopro\commission\Agent as AgentModel;
|
||
use app\admin\model\shopro\user\User as UserModel;
|
||
use app\admin\model\shopro\commission\Log as LogModel;
|
||
use app\admin\model\shopro\commission\Level as LevelModel;
|
||
use addons\shopro\service\commission\Agent as AgentService;
|
||
use think\Db;
|
||
|
||
class Agent extends Common
|
||
{
|
||
protected $noNeedRight = ['select', 'identity'];
|
||
|
||
protected $model = null;
|
||
|
||
public function _initialize()
|
||
{
|
||
parent::_initialize();
|
||
$this->model = new AgentModel();
|
||
}
|
||
|
||
/**
|
||
* 查看
|
||
*/
|
||
public function index()
|
||
{
|
||
if (!$this->request->isAjax()) {
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
$list = $this->model->sheepFilter()->with(['user.parent_user', 'level_info', 'level_status_info', 'upgrade_level'])->paginate($this->request->param('list_rows', 10));
|
||
|
||
$this->success('分销商列表', null, $list);
|
||
}
|
||
|
||
/**
|
||
* 详情
|
||
*
|
||
* @param $id
|
||
*/
|
||
public function detail($id)
|
||
{
|
||
if (!$this->request->isAjax()) {
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
$detail = $this->model->with(['user.parent_user', 'level_info', 'level_status_info', 'upgrade_level'])->where('user_id', $id)->find();
|
||
if (!$detail) {
|
||
$this->error(__('No Results were found'));
|
||
}
|
||
|
||
$amounts = \addons\shopro\service\partner\PartnerConfig::push3Amounts();
|
||
$seq = intval($detail->direct_order_seq ?? 0);
|
||
$next = $amounts[$seq % count($amounts)] ?? 398;
|
||
$last = intval($detail->last_self_order_time ?? 0);
|
||
$days = \addons\shopro\service\partner\PartnerConfig::activeDays();
|
||
$ago = $last ? intval(floor((time() - $last) / 86400)) : null;
|
||
|
||
$identityInfo = \addons\shopro\service\partner\IdentityService::build($detail);
|
||
$isPartner = !empty($identityInfo['is_partner']);
|
||
$isAdvanced = !empty($identityInfo['is_advanced']);
|
||
$detail->is_partner = $isPartner ? 1 : 0;
|
||
$detail->is_advanced = $isAdvanced ? 1 : 0;
|
||
|
||
$detail->next_push3_amount = number_format((float) $next, 2, '.', '');
|
||
$detail->next_push3_text = '第 ' . ($seq + 1) . ' 单将返 ' . $detail->next_push3_amount;
|
||
$detail->last_self_order_text = $last ? date('Y-m-d H:i:s', $last) : '从未下单';
|
||
|
||
// 业务核心规范：进阶角色（创客V1~V6、酒道馆、区县代理、合伙人）需自购考核；基础会员及品酒师免自购考核
|
||
if (!$isAdvanced) {
|
||
$detail->active_status_text = '免自购考核 (基础会员/品酒师)';
|
||
} else {
|
||
$detail->active_status_text = !empty($detail->active_30d)
|
||
? '正常领取'
|
||
: ('已暂停' . ($ago !== null ? '（距今 ' . $ago . ' 天）' : ''));
|
||
}
|
||
|
||
$cashTypes = \addons\shopro\service\partner\PartnerConfig::cashTypes();
|
||
$totalCash = \app\admin\model\shopro\partner\Reward::where('user_id', $id)
|
||
->whereIn('reward_type', $cashTypes)
|
||
->where('status', 1)
|
||
->where('amount', '>', 0)
|
||
->sum('amount');
|
||
$push3Cash = \app\admin\model\shopro\partner\Reward::where('user_id', $id)
|
||
->where('status', 1)
|
||
->where('amount', '>', 0)
|
||
->where('reward_type', 'push3')
|
||
->sum('amount');
|
||
$partnerExclusiveCash = \app\admin\model\shopro\partner\Reward::where('user_id', $id)
|
||
->whereIn('reward_type', $cashTypes)
|
||
->where('status', 1)
|
||
->where('amount', '>', 0)
|
||
->where('reward_type', '<>', 'push3')
|
||
->sum('amount');
|
||
|
||
$alignedIncome = number_format(max(floatval($detail->total_income ?? 0), (float) $totalCash), 2, '.', '');
|
||
$detail->income_total_cash = $alignedIncome;
|
||
$detail->total_income = $alignedIncome;
|
||
$detail->partner_cash_income = $alignedIncome;
|
||
$detail->push3_cash_income = number_format((float) $push3Cash, 2, '.', '');
|
||
$userData = $detail->user ? $detail->user->getData() : [];
|
||
$userMoney = $userData['money'] ?? 0;
|
||
$userCommission = $userData['commission'] ?? 0;
|
||
$detail->user_money = number_format(floatval($userMoney), 2, '.', '');
|
||
$detail->user_commission = number_format(floatval($userCommission), 2, '.', '');
|
||
$detail->partner_mode = \addons\shopro\service\partner\PartnerConfig::isPartnerMode() ? 1 : 0;
|
||
$rate = (new \addons\shopro\service\partner\RateService())->currentRate();
|
||
$detail->madow_value = \addons\shopro\service\partner\IdentityService::formatMoney((float) ($detail->madow ?? 0) * (float) $rate);
|
||
$detail->custom_role_names = \addons\shopro\service\partner\PartnerConfig::roleNames();
|
||
$detail->role_names = $detail->custom_role_names;
|
||
$detail->operational_stats = $this->getOperationalStats($detail, $id);
|
||
|
||
$this->success('分销商详情', null, $detail);
|
||
}
|
||
|
||
/**
|
||
* 构建运营官全景统计数据看板
|
||
*/
|
||
private function getOperationalStats($detail, $id)
|
||
{
|
||
// 建立邻接表，使用广度优先遍历(BFS)安全获取全部后代节点，杜绝潜在脏数据循环引用死循环
|
||
$allUsers = \think\Db::name('user')->column('parent_user_id', 'id');
|
||
$children = [];
|
||
foreach ($allUsers as $cid => $pid) {
|
||
if ($pid) {
|
||
$children[$pid][] = (int)$cid;
|
||
}
|
||
}
|
||
$descIds = [];
|
||
$queue = [(int)$id];
|
||
$visited = [(int)$id => true];
|
||
while (!empty($queue)) {
|
||
$curr = array_shift($queue);
|
||
if (!empty($children[$curr])) {
|
||
foreach ($children[$curr] as $cid) {
|
||
if (!isset($visited[$cid])) {
|
||
$visited[$cid] = true;
|
||
$descIds[] = $cid;
|
||
$queue[] = $cid;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
$directIds = $children[(int)$id] ?? [];
|
||
|
||
// 1. 团队角色拓扑
|
||
$directCount = count($directIds);
|
||
$directPaidCount = empty($directIds) ? 0 : \think\Db::name('user')->whereIn('id', $directIds)->where('total_consume', '>', 0)->count();
|
||
$directMakerCount = empty($directIds) ? 0 : \think\Db::name('shopro_commission_agent')->whereIn('user_id', $directIds)->where('level', '>=', 2)->count();
|
||
|
||
$teamDescCount = count($descIds);
|
||
$teamPaidCount = empty($descIds) ? 0 : \think\Db::name('user')->whereIn('id', $descIds)->where('total_consume', '>', 0)->count();
|
||
$teamMakerAgents = empty($descIds) ? [] : \think\Db::name('shopro_commission_agent')->whereIn('user_id', $descIds)->where('level', '>=', 2)->column('level');
|
||
$teamMakerCount = count($teamMakerAgents);
|
||
$teamMakerDistribution = array_count_values($teamMakerAgents);
|
||
ksort($teamMakerDistribution);
|
||
$makerDistribution = [
|
||
'v1' => intval($teamMakerDistribution[2] ?? 0),
|
||
'v2' => intval($teamMakerDistribution[3] ?? 0),
|
||
'v3' => intval($teamMakerDistribution[4] ?? 0),
|
||
'v4' => intval($teamMakerDistribution[5] ?? 0),
|
||
'v5' => intval($teamMakerDistribution[6] ?? 0),
|
||
'v6' => intval($teamMakerDistribution[7] ?? 0),
|
||
];
|
||
$teamVenueCount = empty($descIds) ? 0 : \think\Db::name('shopro_commission_agent')->whereIn('user_id', $descIds)->where('is_venue', 1)->count();
|
||
$teamCountyCount = empty($descIds) ? 0 : \think\Db::name('shopro_commission_agent')->whereIn('user_id', $descIds)->where('is_county', 1)->count();
|
||
$conversionRate = $teamDescCount > 0 ? round(($teamPaidCount / $teamDescCount) * 100, 1) : 0.0;
|
||
|
||
// 2. 收益分成细项
|
||
$rewards = \think\Db::name('shopro_partner_reward')
|
||
->where('user_id', $id)
|
||
->where('status', 1)
|
||
->group('reward_type')
|
||
->column('sum(amount)', 'reward_type');
|
||
|
||
$push3Income = (float)($rewards['push3'] ?? 0);
|
||
$makerDiffIncome = (float)($rewards['maker_diff'] ?? 0);
|
||
$makerPeerIncome = (float)(($rewards['maker_peer'] ?? 0) + ($rewards['maker_overtaken'] ?? 0));
|
||
$teamSplitIncome = (float)(($rewards['team_venue'] ?? 0) + ($rewards['team_county'] ?? 0));
|
||
$sharePoolIncome = (float)(($rewards['venue_share'] ?? 0) + ($rewards['county_share'] ?? 0));
|
||
|
||
// 3. 业绩与订单分类
|
||
$selfOrderMoney = number_format((float)($detail->child_order_money_0 ?? 0), 2, '.', '');
|
||
$selfOrderCount = intval($detail->child_order_count_0 ?? 0);
|
||
$directOrderMoney = number_format((float)($detail->child_order_money_1 ?? 0), 2, '.', '');
|
||
$directOrderCount = intval($detail->child_order_count_1 ?? 0);
|
||
$teamOrderMoney = number_format((float)($detail->child_order_money_all ?? 0), 2, '.', '');
|
||
$teamOrderCount = intval($detail->child_order_count_all ?? 0);
|
||
|
||
$indirectOrderMoney = number_format(max(0, (float)$teamOrderMoney - (float)$directOrderMoney - (float)$selfOrderMoney), 2, '.', '');
|
||
$indirectOrderCount = max(0, $teamOrderCount - $directOrderCount - $selfOrderCount);
|
||
|
||
// 4. 晋升考核差距雷达
|
||
$currentLevel = intval($detail->level ?? 1);
|
||
$currentLevelRow = \think\Db::name('shopro_commission_level')->where('level', $currentLevel)->find();
|
||
$currentLevelName = $currentLevelRow ? $currentLevelRow['name'] : ($currentLevel >= 2 ? '创客V' . ($currentLevel - 1) : '品酒师');
|
||
|
||
$nextLevel = $currentLevel + 1;
|
||
$nextLevelRow = \think\Db::name('shopro_commission_level')->where('level', $nextLevel)->find();
|
||
|
||
if ($nextLevelRow) {
|
||
$nextRules = json_decode($nextLevelRow['upgrade_rules'] ?? '[]', true) ?: [];
|
||
$targetDirectUsers = intval($nextRules['child_user_count_1'] ?? 0);
|
||
$targetTeamOrders = intval($nextRules['child_order_count_all'] ?? 0);
|
||
|
||
// 解析直推有效品酒师/创客指标要求
|
||
$targetDirectAgents = 0;
|
||
if (!empty($nextRules['child_agent_level_1']) && is_array($nextRules['child_agent_level_1'])) {
|
||
foreach ($nextRules['child_agent_level_1'] as $al) {
|
||
$targetDirectAgents += intval($al['count'] ?? 0);
|
||
}
|
||
} elseif (!empty($nextRules['child_agent_count_1'])) {
|
||
$targetDirectAgents = intval($nextRules['child_agent_count_1']);
|
||
}
|
||
|
||
$currentDirectUsers = intval($detail->child_user_count_1 ?? $directCount);
|
||
$currentDirectAgents = intval($detail->child_agent_count_1 ?? $directPaidCount);
|
||
$currentTeamOrders = intval($detail->child_order_count_all ?? 0);
|
||
$currentSelfMoney = (float)($detail->child_order_money_0 ?? 0);
|
||
|
||
$directUserGap = max(0, $targetDirectUsers - $currentDirectUsers);
|
||
$directAgentGap = max(0, $targetDirectAgents - $currentDirectAgents);
|
||
$teamOrderGap = max(0, $targetTeamOrders - $currentTeamOrders);
|
||
$isSelfPaid = ($selfOrderCount > 0 || $currentSelfMoney >= 1398);
|
||
|
||
$directUserPercent = $targetDirectUsers > 0 ? min(100, (int)round(($currentDirectUsers / $targetDirectUsers) * 100)) : 100;
|
||
$directAgentPercent = $targetDirectAgents > 0 ? min(100, (int)round(($currentDirectAgents / $targetDirectAgents) * 100)) : 100;
|
||
$teamOrderPercent = $targetTeamOrders > 0 ? min(100, (int)round(($currentTeamOrders / $targetTeamOrders) * 100)) : 100;
|
||
|
||
$upgradeRadar = [
|
||
'current_level' => $currentLevel,
|
||
'current_level_name' => $currentLevelName,
|
||
'next_level' => $nextLevel,
|
||
'next_level_name' => $nextLevelRow['name'],
|
||
'target_direct_users' => $targetDirectUsers,
|
||
'current_direct_users' => $currentDirectUsers,
|
||
'direct_user_gap' => $directUserGap,
|
||
'direct_user_reached' => ($directUserGap === 0),
|
||
'direct_user_percent' => $directUserPercent,
|
||
'target_direct_agents' => $targetDirectAgents,
|
||
'current_direct_agents' => $currentDirectAgents,
|
||
'direct_agent_gap' => $directAgentGap,
|
||
'direct_agent_reached' => ($directAgentGap === 0),
|
||
'direct_agent_percent' => $directAgentPercent,
|
||
'target_team_orders' => $targetTeamOrders,
|
||
'current_team_orders' => $currentTeamOrders,
|
||
'team_order_gap' => $teamOrderGap,
|
||
'team_order_reached' => ($teamOrderGap === 0),
|
||
'team_order_percent' => $teamOrderPercent,
|
||
'self_paid_reached' => $isSelfPaid,
|
||
'all_reached' => ($directUserGap === 0 && $directAgentGap === 0 && $teamOrderGap === 0 && $isSelfPaid),
|
||
'upgrade_lock' => intval($detail->upgrade_lock ?? 0)
|
||
];
|
||
} else {
|
||
$upgradeRadar = [
|
||
'current_level' => $currentLevel,
|
||
'current_level_name' => $currentLevelName,
|
||
'next_level' => 0,
|
||
'next_level_name' => '已达最高职级',
|
||
'target_direct_users' => 0,
|
||
'current_direct_users' => intval($detail->child_user_count_1 ?? $directCount),
|
||
'direct_user_gap' => 0,
|
||
'direct_user_reached' => true,
|
||
'direct_user_percent' => 100,
|
||
'target_direct_agents' => 0,
|
||
'current_direct_agents' => intval($detail->child_agent_count_1 ?? $directPaidCount),
|
||
'direct_agent_gap' => 0,
|
||
'direct_agent_reached' => true,
|
||
'direct_agent_percent' => 100,
|
||
'target_team_orders' => 0,
|
||
'current_team_orders' => intval($detail->child_order_count_all ?? 0),
|
||
'team_order_gap' => 0,
|
||
'team_order_reached' => true,
|
||
'team_order_percent' => 100,
|
||
'self_paid_reached' => true,
|
||
'all_reached' => true,
|
||
];
|
||
}
|
||
|
||
return [
|
||
'roles' => [
|
||
'direct_total' => $directCount,
|
||
'direct_paid' => $directPaidCount,
|
||
'direct_unpaid' => max(0, $directCount - $directPaidCount),
|
||
'direct_maker' => $directMakerCount,
|
||
'team_total' => $teamDescCount,
|
||
'team_paid' => $teamPaidCount,
|
||
'team_unpaid' => max(0, $teamDescCount - $teamPaidCount),
|
||
'team_conversion_rate' => $conversionRate,
|
||
'team_maker' => $teamMakerCount,
|
||
'team_maker_distribution' => $makerDistribution,
|
||
'team_venue' => $teamVenueCount,
|
||
'team_county' => $teamCountyCount,
|
||
],
|
||
'orders' => [
|
||
'self_money' => $selfOrderMoney,
|
||
'self_count' => $selfOrderCount,
|
||
'direct_money' => $directOrderMoney,
|
||
'direct_count' => $directOrderCount,
|
||
'indirect_money' => $indirectOrderMoney,
|
||
'indirect_count' => $indirectOrderCount,
|
||
'team_money' => $teamOrderMoney,
|
||
'team_count' => $teamOrderCount,
|
||
],
|
||
'rewards' => [
|
||
'push3' => number_format($push3Income, 2, '.', ''),
|
||
'maker_diff' => number_format($makerDiffIncome, 2, '.', ''),
|
||
'maker_peer' => number_format($makerPeerIncome, 2, '.', ''),
|
||
'maker_total' => number_format($makerDiffIncome + $makerPeerIncome, 2, '.', ''),
|
||
'team_split' => number_format($teamSplitIncome, 2, '.', ''),
|
||
'share_pool' => number_format($sharePoolIncome, 2, '.', ''),
|
||
],
|
||
'assets' => [
|
||
'wallet_money' => $detail->user_money,
|
||
'total_income' => $detail->total_income,
|
||
'untransfer_commission' => $detail->user_commission,
|
||
'dmepa_madow' => number_format((float)($detail->madow ?? 0), 4, '.', ''),
|
||
'dmepa_value' => $detail->madow_value,
|
||
'voucher_total' => number_format((float)($detail->voucher_total ?? 0), 2, '.', ''),
|
||
'voucher_released' => number_format((float)($detail->voucher_released ?? 0), 2, '.', ''),
|
||
'voucher_available' => number_format(max(0, (float)($detail->voucher_released ?? 0) - (float)($detail->voucher_used ?? 0)), 2, '.', ''),
|
||
],
|
||
'upgrade_radar' => $upgradeRadar
|
||
];
|
||
}
|
||
|
||
|
||
/**
|
||
* 团队
|
||
*
|
||
* @param $id
|
||
*/
|
||
public function team($id)
|
||
{
|
||
if (!$this->request->isAjax()) {
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
$detail = $this->model->with(['user.parent_user', 'level_info'])->where('user_id', $id)->find();
|
||
if (!$detail) {
|
||
$this->error(__('No Results were found'));
|
||
}
|
||
|
||
$detail->agent_team = AgentModel::hasWhere('user', function ($query) use ($detail) {
|
||
return $query->where('parent_user_id', $detail->user_id);
|
||
})->with(['user', 'level_info'])->select();
|
||
$this->success('分销商详情', null, $detail);
|
||
}
|
||
|
||
// 选择分销商
|
||
public function select()
|
||
{
|
||
if (!$this->request->isAjax()) {
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
$data = $this->model->sheepFilter()->with(['user', 'level_info', 'level_status_info', 'upgrade_level'])
|
||
->paginate($this->request->param('list_rows', 10));
|
||
|
||
$this->success('选择分销商', null, $data);
|
||
}
|
||
|
||
/**
|
||
* 编辑
|
||
*
|
||
* @param $id
|
||
*/
|
||
public function edit($id = null)
|
||
{
|
||
$params = $this->request->only(['status', 'upgrade_lock', 'level_status', 'level', 'apply_info', 'is_venue', 'is_county', 'county_code']);
|
||
|
||
$result = Db::transaction(function () use ($id, $params) {
|
||
$row = $this->model->with(['user', 'level_info', 'level_status_info', 'upgrade_level'])->where('user_id', $id)->find();
|
||
if (!$row) {
|
||
$this->error('未找到该分销商');
|
||
}
|
||
|
||
foreach ($params as $field => $value) {
|
||
switch ($field) {
|
||
case 'status': // 修改状态
|
||
return $this->changeStatus($row, $value);
|
||
break;
|
||
case 'level_status': // 审核等级
|
||
return $this->changeLevelStatus($row, $value);
|
||
break;
|
||
case 'level': // 修改等级
|
||
return $this->changeLevel($row, $value);
|
||
break;
|
||
case 'is_venue':
|
||
case 'is_county':
|
||
case 'county_code':
|
||
$result = $row->save([$field => $value]);
|
||
if ($result) {
|
||
LogModel::add($row->user_id, 'agent', ['type' => 'identity', 'field' => $field, 'value' => $value]);
|
||
}
|
||
return $result;
|
||
default:
|
||
return $row->save([$field => $value]);
|
||
}
|
||
}
|
||
});
|
||
if ($result) {
|
||
$this->success('更新成功', null, $result);
|
||
} else {
|
||
$this->error('更新失败');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 开通 / 调整身份（弹窗一次提交）
|
||
*/
|
||
public function identity($id = null)
|
||
{
|
||
if (!$this->auth->check('shopro/commission/agent/edit')) {
|
||
$this->error(__('You have no permission'));
|
||
}
|
||
$params = $this->request->only(['level', 'is_venue', 'is_county', 'county_code', 'upgrade_lock', 'remark']);
|
||
if ($id === null || $id === '') {
|
||
$this->error('请选择用户');
|
||
}
|
||
|
||
$level = intval($params['level'] ?? 0);
|
||
if ($level < 1 || $level > 7) {
|
||
$this->error('请选择品酒师或创客等级');
|
||
}
|
||
$isVenue = intval($params['is_venue'] ?? 0) ? 1 : 0;
|
||
$isCounty = intval($params['is_county'] ?? 0) ? 1 : 0;
|
||
$countyCode = trim((string) ($params['county_code'] ?? ''));
|
||
if ($isCounty && $countyCode === '') {
|
||
$this->error('开通区县代理时请选择区县');
|
||
}
|
||
if (!$isCounty) {
|
||
$countyCode = '';
|
||
}
|
||
$upgradeLock = array_key_exists('upgrade_lock', $params) ? intval($params['upgrade_lock']) : null;
|
||
$remark = trim((string) ($params['remark'] ?? ''));
|
||
|
||
$result = Db::transaction(function () use ($id, $level, $isVenue, $isCounty, $countyCode, $upgradeLock, $remark) {
|
||
$service = new AgentService(intval($id));
|
||
if (!$service->user) {
|
||
$this->error('未找到该用户');
|
||
}
|
||
if (!$service->agent) {
|
||
$service->createNewAgent('user');
|
||
$service = new AgentService(intval($id));
|
||
}
|
||
$row = $service->agent;
|
||
if (!$row) {
|
||
$this->error('未能生成分销身份');
|
||
}
|
||
|
||
$before = \addons\shopro\service\partner\IdentityService::build($row);
|
||
$levelModel = LevelModel::find($level);
|
||
if (!$levelModel) {
|
||
$this->error('未找到该等级');
|
||
}
|
||
|
||
$save = [
|
||
'level' => $level,
|
||
'is_venue' => $isVenue,
|
||
'is_county' => $isCounty,
|
||
'county_code' => $countyCode,
|
||
];
|
||
if ($upgradeLock !== null) {
|
||
$save['upgrade_lock'] = $upgradeLock ? 1 : 0;
|
||
}
|
||
$row->save($save);
|
||
|
||
$after = \addons\shopro\service\partner\IdentityService::build($row);
|
||
$logRemark = $remark !== ''
|
||
? $remark
|
||
: sprintf('将「%s」从 %s 调整为 %s。已入账收益不追溯。', $service->user->nickname ?: $id, $before['identity_text'] ?: '未开通', $after['identity_text'] ?: '-');
|
||
LogModel::add($row->user_id, 'agent', [
|
||
'type' => 'identity',
|
||
'field' => 'bundle',
|
||
'value' => $after['identity_text'],
|
||
'before' => $before['identity_text'],
|
||
], null, $logRemark);
|
||
LogModel::add($row->user_id, 'agent', ['type' => 'level', 'level' => $levelModel]);
|
||
(new AgentService($row->user_id))->createAsyncAgentUpgrade();
|
||
|
||
return [
|
||
'identity_text' => $after['identity_text'],
|
||
'level' => $level,
|
||
'is_venue' => $isVenue,
|
||
'is_county' => $isCounty,
|
||
'county_code' => $countyCode,
|
||
];
|
||
});
|
||
|
||
$this->success('身份已更新', null, $result);
|
||
}
|
||
|
||
|
||
// 修改状态
|
||
private function changeStatus($row, $value)
|
||
{
|
||
$result = $row->save(['status' => $value]);
|
||
if ($result) {
|
||
LogModel::add($row->user_id, 'agent', ['type' => 'status', 'value' => $value]);
|
||
(new AgentService($row->user_id))->createAsyncAgentUpgrade();
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
// 审核等级
|
||
private function changeLevelStatus($row, $value)
|
||
{
|
||
if ($row->level_status == 0 && $value > 0) {
|
||
$this->error('非法操作');
|
||
}
|
||
|
||
if ($value == 0) { // 拒绝操作
|
||
return $row->save(['level_status' => 0]);
|
||
} else { // 同意操作
|
||
if ($row->upgrade_level) {
|
||
$result = $row->save(['level_status' => 0, 'level' => $row->upgrade_level->level]);
|
||
if ($result) {
|
||
LogModel::add($row->user_id, 'agent', ['type' => 'level', 'level' => $row->upgrade_level]);
|
||
(new AgentService($row->user_id))->createAsyncAgentUpgrade();
|
||
}
|
||
return $result;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
// 修改等级
|
||
private function changeLevel($row, $value)
|
||
{
|
||
$level = LevelModel::find($value);
|
||
if ($level) {
|
||
$result = $row->save(['level' => $level->level]);
|
||
if ($result) {
|
||
LogModel::add($row->user_id, 'agent', ['type' => 'level', 'level' => $level]);
|
||
(new AgentService($row->user_id))->createAsyncAgentUpgrade();
|
||
}
|
||
return $result;
|
||
} else {
|
||
$this->error('未找到该等级');
|
||
}
|
||
}
|
||
|
||
// 更换推荐人
|
||
public function changeParentUser($id)
|
||
{
|
||
$userAgent = new AgentService($id);
|
||
|
||
if (!$userAgent->user) {
|
||
$this->error('未找到该用户');
|
||
}
|
||
|
||
$parentUserId = $this->request->param('parent_user_id', 0);
|
||
|
||
// 更换推荐人检查
|
||
if ($parentUserId != 0) {
|
||
$parentAgent = new AgentService($parentUserId);
|
||
if (!$parentAgent->isAgentAvaliable()) {
|
||
$this->error('选中用户暂未成为分销商,不能成为推荐人');
|
||
}
|
||
if (!$this->checkChangeParentAgent($id, $parentUserId)) {
|
||
$this->error('不能绑定该上级');
|
||
}
|
||
LogModel::add($parentUserId, 'share', ['user' => $userAgent->user]);
|
||
|
||
if ($userAgent->isAgentAvaliable()) {
|
||
LogModel::add($id, 'bind', ['user' => $parentAgent->user ?? NULL]);
|
||
}
|
||
}
|
||
|
||
$lastParentUserId = $userAgent->user->parent_user_id;
|
||
|
||
$userAgent->user->parent_user_id = $parentUserId;
|
||
$userAgent->user->save();
|
||
|
||
if ($lastParentUserId > 0) {
|
||
$userAgent->createAsyncAgentUpgrade($lastParentUserId);
|
||
}
|
||
|
||
if ($parentUserId > 0) {
|
||
$userAgent->createAsyncAgentUpgrade($parentUserId);
|
||
}
|
||
$this->success('绑定成功');
|
||
}
|
||
|
||
// 递归往上找推荐人，防止出现推荐循环
|
||
private function checkChangeParentAgent($userId, $parentUserId)
|
||
{
|
||
if ($userId == $parentUserId) {
|
||
|
||
$this->error('推荐人不能是本人');
|
||
}
|
||
if ($parentUserId == 0) {
|
||
return true;
|
||
}
|
||
|
||
$parentAgent = UserModel::find($parentUserId);
|
||
|
||
if ($parentAgent) {
|
||
if ($parentAgent->parent_user_id == $userId) {
|
||
$this->error("已选中分销商的上级团队中已存在该用户");
|
||
}
|
||
if ($parentAgent->parent_user_id == 0) {
|
||
return true;
|
||
} else {
|
||
return $this->checkChangeParentAgent($userId, $parentAgent->parent_user_id);
|
||
}
|
||
}
|
||
|
||
return false;
|
||
}
|
||
}
|