fastadmin_tailored/application/common/model/commission/Agent.php

<?php

namespace app\common\model\commission;

use app\common\model\User;
use app\common\Enum\AgentType;
use app\common\library\BcMath;
use app\common\model\commission\Level;
use app\common\model\commission\Reward;
use think\Model;
class Agent  extends Model
{
    protected $pk = 'user_id';

    protected $name = 'shop_commission_agent';

    protected $type = [
        'become_time' => 'timestamp',
        'expire_time' => 'timestamp',
        'child_agent_level_1' => 'json',
        'child_agent_level_all' => 'json',
    ];
    protected $append = [
        'status_text',
        'agent_type_text',
        'pending_reward',
        'commission_balance'
    ];

    // 分销商状态 AGENT_STATUS
    const AGENT_STATUS_NORMAL = 'normal';       // 正常 
    const AGENT_STATUS_PENDING = 'pending';     // 审核中 不分佣、不打款、没有团队信息
    const AGENT_STATUS_FREEZE = 'freeze';       // 冻结 正常记录分佣、不打款，记录业绩和团队信息 冻结解除后立即打款
    const AGENT_STATUS_FORBIDDEN = 'forbidden'; // 禁用 不分佣、不记录业绩和团队信息
    const AGENT_STATUS_NEEDINFO = 'needinfo';   // 需要完善表单资料 临时状态
    const AGENT_STATUS_REJECT = 'reject';       // 审核驳回, 重新修改   临时状态
    const AGENT_STATUS_NULL = NULL;             // 未满足成为分销商条件


    // 分销商升级锁 UPGRADE_LOCK
    const UPGRADE_LOCK_OPEN = 1;  // 禁止分销商升级
    const UPGRADE_LOCK_CLOSE = 0;  // 允许分销商升级

    public function statusList()
    {
        return [
            self::AGENT_STATUS_NORMAL => '正常',
            self::AGENT_STATUS_PENDING => '审核中',
            self::AGENT_STATUS_FREEZE => '冻结',
            self::AGENT_STATUS_FORBIDDEN => '禁用',
            self::AGENT_STATUS_REJECT => '拒绝'
        ];
    }

    // public function getExpireTimeAttr($value, $data)
    // {
    //     // 时间格式
    //     if ($value) {
    //         return date('Y-m-d H:i:s', $value);
    //     }
    //     return '';

    // }

    /**
     * 获取状态文本
     */
    public function getStatusTextAttr($value, $data)
    {
        $value = $value ? $value : (isset($data['status']) ? $data['status'] : '');
        $statusList = $this->statusList();
        return isset($statusList[$value]) ? $statusList[$value] : '正常';
    }

    /**
     * 获取代理商类型文本
     */
    public function getAgentTypeTextAttr($value, $data)
    {
        $value = $value ? $value : (isset($data['agent_type']) ? $data['agent_type'] : 'normal');
        return AgentType::getTypeText($value);
    }

    /**
     * 可用分销商
     */
    public function scopeAvaliable($query)
    {
        return $query->where('status', 'in', [self::AGENT_STATUS_NORMAL, self::AGENT_STATUS_FREEZE]);
    }

    public function user()
    {
        return $this->belongsTo(User::class, 'user_id', 'id')->field('id, nickname, avatar, mobile, total_consume, parent_user_id');
    }

    public function levelInfo()
    {
        return $this->belongsTo(Level::class, 'level', 'level')->field(['level', 'name', 'image', 'commission_rules']);
    }
    
    // 添加蛇形命名的关联方法别名
    public function level_info()
    {
        return $this->levelInfo();
    }

    public function getPendingRewardAttr($value, $data)
    {
        $amount = Reward::pending()->where('agent_id', $data['user_id'])->sum('commission');
        // 使用BcMath工具类格式化金额，确保精度
        return BcMath::format($amount);
    }

    /**
     * 获取佣金余额（累计收益 - 已提现金额）
     */
    public function getCommissionBalanceAttr($value, $data)
    {
        $totalIncome = $data['total_income'] ?? '0.00';
        $withdrawnAmount = $data['withdrawn_amount'] ?? '0.00';
        
        // 使用BcMath工具类计算余额，并确保不为负数
        $balance = BcMath::sub($totalIncome, $withdrawnAmount);
        return BcMath::max($balance);
    }

    public function levelStatusInfo()
    {
        return $this->belongsTo(Level::class, 'level_status', 'level');
    }
    
    // 添加蛇形命名的关联方法别名
    public function level_status_info()
    {
        return $this->levelStatusInfo();
    }

    public function upgradeLevel()
    {
        return $this->belongsTo(Level::class, 'level_status', 'level');
    }
    
    // 添加蛇形命名的关联方法别名
    public function upgrade_level()
    {
        return $this->upgradeLevel();
    }
}