pet/application/common/model/User.php

<?php

namespace app\common\model;

use think\Db;
use think\db\Query;
use think\Model;
use traits\model\SoftDelete;

/**
 * 会员模型
 * @property int coupon_num
 * @method static Query|self expired()
 * @property float level_discount 折扣点
 * @property boolean wx_authed 是否已微信授权
 */
class User extends Model
{
    use SoftDelete;
    protected $hidden=[
        'password',
        'salt',
        'status',
        'token',
        'updatetime',
        'loginfailure',
        'url',
        'type',
        'openid',
        'unionid',
        'email',
    ];
    // 开启自动写入时间戳字段
    protected $autoWriteTimestamp = 'int';
    // 定义时间戳字段名
    protected $createTime = 'createtime';
    protected $updateTime = 'updatetime';
    // 追加属性
    protected $append = [
        'level_text',
        'has_follow',
        'wx_authed',
    ];

    const LEVEL_0=0;
    const LEVEL_1=1;
    const LEVEL_10=10;
    const LEVEL_20=20;

    const USER=1;
    const SENDER=2;

    public static $levels=[
        self::LEVEL_0=>'普通会员',
        self::LEVEL_1=>'黄金会员',
        self::LEVEL_10=>'白金会员',
        self::LEVEL_20=>'钻石会员',
    ];

    /**
     * 获取个人URL
     * @param string $value
     * @param array  $data
     * @return string
     */
    public function getUrlAttr($value, $data)
    {
        return fullUrl("/u/" . $data['id']);
    }
    public function getLevelTextAttr($value, $data)
    {
        return self::$levels[$data['level']]??'普通会员';
    }

    /**
     * 获取头像
     * @param string $value
     * @param array  $data
     * @return string
     */
   /* public function getAvatarAttr($value, $data)
    {
        if (!$value) {
            //如果不需要启用首字母头像，请使用
            //$value = '/assets/img/avatar.png';
            $value = letter_avatar($data['nickname']);
        }
        return $value;
    }*/

    /**
     * 获取会员的组别
     */
    public function getGroupAttr($value, $data)
    {
        return UserGroup::get($data['group_id']);
    }

    /**
     * 获取验证字段数组值
     * @param string $value
     * @param array  $data
     * @return  object
     */
    /*public function getVerificationAttr($value, $data)
    {
        $value = array_filter((array)json_decode($value, true));
        $value = array_merge(['email' => 0, 'mobile' => 0], $value);
        return (object)$value;
    }*/

    /**
     * 设置验证字段
     * @param mixed $value
     * @return string
     */
    /*public function setVerificationAttr($value)
    {
        $value = is_object($value) || is_array($value) ? json_encode($value) : $value;
        return $value;
    }*/

    /**
     * 变更会员余额
     * @param float    $money   余额
     * @param int    $user_id 会员ID
     * @param string $memo    备注
     */
    public static function money($money, $user_id, $type,$memo='',$extra=[],$changeMoney=true)
    {
        $user = self::lock(true)->find($user_id);
        if($changeMoney && !$user){
            throw_user('用户不存在:'.$user_id);
        }
        if ($money != 0) {
            if($changeMoney){
                $before = $user->money;
                //$after = $user->money + $money;
                $after = function_exists('bcadd') ? bcadd($user->money, $money, 2) : $user->money + $money;
                if($after<0){
                    throw_user("余额不足");
                }
                //更新会员信息
                $user->save(['money' => $after]);
            }
        }
        //写入日志
        MoneyLog::create(array_merge([
            'user_id' => $user_id,
            'type'=>$type,
            'money' => $money,
            'before' => $before??$user->money??0,
            'after' => $after??$user->money??0,
            'memo' => $memo,
        ],$extra));
    }

    /**
     * 变更会员积分
     * @param int    $score   积分
     * @param int    $user_id 会员ID
     * @param string $memo    备注
     */
    public static function score($score, $user_id, $memo)
    {
        Db::startTrans();
        try {
            $user = self::lock(true)->find($user_id);
            if ($user && $score != 0) {
                $before = $user->score;
                $after = $user->score + $score;
                //更新会员信息
                $user->save(['score' => $after]);
                //写入日志
                ScoreLog::create(['user_id' => $user_id, 'score' => $score, 'before' => $before, 'after' => $after, 'memo' => $memo]);
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
        }
    }
    public function address(){
        return $this->hasMany(UserAddress::class);
    }
    public function coupon(){
        return $this->hasMany(UserCoupon::class);
    }
    public function orders(){
        return $this->hasMany(UserOrder::class);
    }
    public function payment(){
        return $this->hasMany(Payment::class);
    }
    public function info(){
        return $this->hasMany(Info::class);
    }
    public function theme(){
        return $this->hasMany(Theme::class);
    }
    public function follow(){
        return $this->hasMany(UserFollow::class);
    }
    public function comments(){
        return $this->hasMany(Comment::class);
    }
    public function like(){
        return $this->hasMany(Like::class);
    }
    public function feedback(){
        return $this->hasMany(Feedback::class);
    }
    public function getHasFollowAttr(){
        $user=request()->_user;
        if(!$user){
            return false;
        }
        return (bool)UserFollow::where('user_id',$user['id'])->where('follow_id',$this['id'])->value('id');
    }
    public function moneylog(){
        return $this->hasMany(MoneyLog::class);
    }
    public function notification(){
        return $this->hasMany(Notification::class);
    }
    public function notificationFrom(){
        return $this->hasMany(Notification::class,'from_user_id');
    }
    public static function recharge($params,Payment $payment){
        self::money($payment['amount'],$payment['uer_id'],MoneyLog::TYPE_CHARGE,'充值');
    }
    /**
     * @return \think\model\relation\HasMany|SenderOrder
     */
    public function senderOrder(){
        return $this->hasMany(SenderOrder::class);
    }
    public function takeCash(){
        return $this->hasMany(TakeCash::class);
    }
    public function verification(){
        return $this->hasOne(UserVerification::class);
    }
    /** 配送方式 */
    public function send(){
        return $this->hasMany(UserSend::class);
    }
    public function getAuthsAttr($v,$data){
        return $this->auth()->column('route');
    }
    public function scopeUser(Query $query){
        $query->where('type',self::USER)->order('id','desc');
    }
    public function scopeSender(Query $query){
        $query->where('type',self::SENDER)->order('id','desc');
    }
    /** 模糊搜索 */
    public function scopeDim(Query $query,$keyword){
        $keyword="%{$keyword}%";
        $query
            ->whereLike('nickname',$keyword)
            ->whereOr('mobile','like',$keyword)
            ->whereOr('username','like',$keyword);
    }
    /** 代理区域 */
    public function area(){
        return $this->belongsToMany(Area::class,'user_area');
    }
    public function getCouponNumAttr(){
        return $this->coupon()->use()->count();
    }
    /**
     * 获取配送类型
     * @return 1取2送
     */
    const SEND_GET=1;
    const SEND_SEND=2;
    public static $sendType=[
        self::SEND_GET,
        self::SEND_SEND,
    ];
    public function getSendType(UserOrder $order){
        $addr=$this->area()->column('name');
        $order_type=$order->currentSenderOrder($this['id'])->value('type');
        if($order_type){
            return $order_type;
        }
        if(in_array($order['from_city'],$addr)){
            return self::SEND_GET;
        }elseif (in_array($order['to_city'],$addr)){
            return self::SEND_SEND;
        }
        throw_user('操作失败：您非取送地配送员');
    }
    public function isSendGet($type){
        return self::SEND_GET==$type;
    }
    public function isSendSend($type){
        return self::SEND_SEND==$type;
    }
    /** 保存配送方式 */
    public function saveSend(array $freight){
        $this->send()->delete();
        $freight=array_unique(array_filter($freight));
        $this->send()->saveAll(collection($freight)->each(function ($res){
            return [
                'type'=>$res,
            ];
        })->toArray());
    }
    /** 保存配送地区 */
    public function saveSendArea(array $area){
        $area=array_unique(array_filter($area));
        $this->area()->sync(collection($area)->each(function ($res){
            if(is_numeric($res)) {
                $area=Area::city()->find($res);
                if (!$area) {
                    throw_user('地区ID[' . $res . ']不存在');
                }
                if(UserArea::hasArea($res)){
                    throw_user("地区[{$area['name']}]已被分配，无法再次分配");
                }
                return $res;
            }else{
                $area=Area::city()->where('name',$res)->find();
                if (!$area) {
                    throw_user('地区[' . $res . ']不存在');
                }
                if(UserArea::hasArea($area['id'])){
                    throw_user("地区[{$area['name']}]已被分配，无法再次分配");
                }
                return $area['id'];
            }
        })->toArray());
    }













    /** scope and expired */
    protected static function init()
    {
        self::beforeWrite(function (self $user){
            $data=$user->getChangedData();
            if(!empty($data['level_close_at']) && isset($data['level'])){
                $user['level_open_at']=time();
            }
        });
    }
    public function scopeExpired(Query $query){
        $query
            ->where('level_close_at','>',0)
            ->where('level_close_at','<',time())
            ->where('level','>',0);
    }
    public function scopeType(Query $query,$type){
        $query->where('type',$type);
    }








    /** attr */
    /**
     *获取等级优惠点
     */
    public function getLevelDiscountAttr($v,$data){
        static $config;
        if(!$config){
            $config=SysConfig::look(SysConfig::level_config,[]);
        }
        $userLevel=$data['level']??self::LEVEL_0;
        $levelDiscount=$config[$userLevel]['value']??100;
        if($userLevel==0 || $levelDiscount<=0){
            return 0;
        }
        #如果是一位数则加个0
        if($levelDiscount<10){
            $levelDiscount*=10;
        }
        return bcdiv(100-$levelDiscount,100);
    }
    protected function getWxAuthedAttr($v,$data){
        return (bool)$this['openid'];
    }
}