screen/application/common/model/User.php

<?php

namespace app\common\model;

use think\Cache;
use think\Db;
use think\db\Query;
use think\Model;
use think\model\relation\BelongsToMany;
use think\model\relation\HasMany;

/**
 * 会员模型
 * @property int id
 * @property int coupon_num
 * @method static Query|self expired()
 * @property float level
 * @property int gender
 * @property int age
 * @property int county_id
 * @property int city_id
 * @property int province_id
 * @property string avatar
 * @property string mobile
 * @property string bio
 * @property string nickname
 * @property UserInfo userinfo
 * @property boolean wx_authed 是否已微信授权
 * @property boolean is_vip
 * @property boolean has_answered
 * @property boolean is_visitor
 */
class User extends Model
{
    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',
    ];

    const LEVEL_0=0;
    const LEVEL_10=10;
    const LEVEL_20=20;
    public static $levels=[
        self::LEVEL_0=>'游客',
        self::LEVEL_10=>'安检员',
        self::LEVEL_20=>'正式会员',
    ];

    const SCORE_EDITINFO=1;
    const SCORE_VIEWVIDEO=2;
    const SCORE_WENDA=3;
    const SCORE_COMMENTVIDEO=4;
    const SCORE_SIGN=5;
    const SCORE_GOODS=6;
    public static $scoreTypes=[
        self::SCORE_EDITINFO=>'完善资料',
        self::SCORE_VIEWVIDEO=>'看视频',
        self::SCORE_WENDA=>'答题',
        self::SCORE_COMMENTVIDEO=>'评论',
        self::SCORE_SIGN=>'签到',
        self::SCORE_GOODS=>'兑换商品',
    ];

    /**
     * 获取个人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 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,$field,$type,$extra=[])
    {
        $user = self::lock(true)->find($user_id);
        if ($user && $score != 0) {
            $before = $user->$field;
            $after = $user->$field + $score;
            if($after<0){
                throw_user('积分不足');
            }
            //更新会员信息
            $user->save([$field => $after]);
            //写入日志
            ScoreLog::create(array_merge([
                'field' =>$field,
                'user_id' => $user_id,
                'type'=>$type,
                'score' => $score,
                'before' => $before,
                'after' => $after,
                'memo' => $memo,
            ],$extra));
        }
    }
    /**
     *@return HasMany|UserAddress
     */
    public function address(){
        return $this->hasMany(UserAddress::class);
    }
    /**
     *@return HasMany|UserCorrectRate
     */
    public function crate(){
        return $this->hasMany(UserCorrectRate::class);
    }
    public function userinfo(){
        return $this->hasOne(UserInfo::class);
    }
    public function payment(){
        return $this->hasMany(Payment::class);
    }
    public function sign(){
        return $this->hasMany(UserSign::class);
    }
    /**
     *@return HasMany|MallOrder
     */
    public function mo(){
        return $this->hasMany(MallOrder::class);
    }
    /**
     * 我关注的人
     *@return BelongsToMany|Guest
     */
    public function follow(){
        return $this->belongsToMany(Guest::class,'user_follow')->order('user_follow.id','desc');
    }
    public function comments(){
        return $this->hasMany(Comment::class);
    }
    /**
     *@return VideoPointUser|HasMany
     */
    public function pointUser(){
        return $this->hasMany(VideoPointUser::class);
    }
    /**
     *@return HasMany|Like
     */
    public function like(){
        return $this->hasMany(Like::class);
    }
    /**
     *@return HasMany|Favourite
     */
    public function favourite(){
        return $this->hasMany(Favourite::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);
    }
    /**
     *@return ScoreLog|HasMany
     */
    public function scorelog(){
        return $this->hasMany(ScoreLog::class);
    }
    public function notification(){
        return $this->hasMany(Notification::class);
    }
    public function viewVideo(){
        return $this->belongsToMany(Video::class,'video_user_view');
    }
    public static function recharge($params,Payment $payment){
        self::money($payment['amount'],$payment['uer_id'],MoneyLog::TYPE_CHARGE,'充值');
    }
    public function verification(){
        return $this->hasOne(UserVerification::class);
    }
    /** 模糊搜索 */
    public function scopeDim(Query $query,$keyword){
        $keyword="%{$keyword}%";
        $query
            ->whereLike('nickname',$keyword)
            ->whereOr('mobile','like',$keyword)
            ->whereOr('username','like',$keyword);
    }












    /** scope and expired */
    protected static function init()
    {
        self::beforeWrite(function (self $user){
            $data=$user->getChangedData();
            #升级安检员
            if($user->mobile && $user->level==self::LEVEL_0){
                $user->level=self::LEVEL_10;
            }
        });
        self::afterDelete(function (self $user){
            $user->comments()->delete();
            $user->follow()->delete();
            $user->userinfo()->delete();
            $user->like()->delete();
            VideoUserLog::where('user_id',$user['id'])->delete();
            VideoUserView::where('user_id',$user['id'])->delete();
        });
        self::afterInsert(function (self $user){
            $user->userinfo()->save([]);
        });
    }
    public function scopeExpired(Query $query){
        $query
            ->whereBetween('level_close_at',[0,time()])
            ->where('level','>',0);
    }
    public function scopeType(Query $query,$type){
        $query->where('type',$type);
    }
    public function scopeUser(Query $query,$level){
        $query->where($this->getTable().'.level',$level);
    }








    /** attr */
    #获取地区
    public function appendArea(){
        $this->city_name=Area::where('id',$this->county_id?:0)->cache(true)->value('mergename','');
    }
    public function province(){
        return $this->belongsTo(Area::class,'province_id')->cache(true);
    }
    public function city(){
        return $this->belongsTo(Area::class,'city_id')->cache(true);
    }
    public function county(){
        return $this->belongsTo(Area::class,'county_id')->cache(true);
    }
    protected function getAvatarAttr($a){
        if(!$a){
            return request()->domain().'/assets/img/avatar.png';
        }
        return $a;
    }
    protected function getIsVipAttr($a,$b){
        return $b['level']==self::LEVEL_20;
    }
    protected function getIsVisitorAttr($a,$b){
        return $b['level']==self::LEVEL_0;
    }
    protected function getHasAnsweredAttr($a,$b){
        $user=request()->_user;
        if(!$user){
            return false;
        }
        return Cache::get("user:question:{$user['id']}")==date('Ymd');
    }



    /** set */
    public function setVip(){
        $this['level']=self::LEVEL_20;
        $this->save();
    }
}