DER2021102201/app/api/model/user/User.php

<?php

namespace app\api\model\user;

use app\common\model\page\CenterMenu as CenterMenuModel;
use think\facade\Cache;
use app\common\exception\BaseException;
use app\common\model\user\User as UserModel;
use app\api\model\plus\agent\Referee as RefereeModel;
use app\common\library\easywechat\AppWx;
use app\common\model\user\Grade as GradeModel;
use app\common\library\wechat\WxBizDataCrypt;

/**
 * 用户模型类
 */
class User extends UserModel
{
    private $token;

    /**
     * 隐藏字段
     */
    protected $hidden = [
        'open_id',
        'is_delete',
        'app_id',
        'create_time',
        'update_time'
    ];

    /**
     * 获取用户信息
     */
    public static function getUser($token)
    {
        $userId = Cache::get($token);
        return (new static())->where(['user_id' => $userId])->with(['address', 'addressDefault', 'grade', 'supplierUser'])->find();
    }

    /**
     * 用户登录
     */
    public function login($post)
    {
        // 微信登录 获取session_key
        $app = AppWx::getApp();
        $session = $app->auth->session($post['code']);
        // 自动注册用户
        $refereeId = isset($post['referee_id']) ? $post['referee_id'] : null;
        $userInfo = json_decode(htmlspecialchars_decode($post['user_info']), true);

        $reg_source = $post['source'];
        $openid = isset($session['openid'])? $session['openid'] : '';
        $user_id = $this->register($openid, $userInfo, $refereeId, $session, $reg_source);
        // 生成token (session3rd)
        $this->token = $this->token($openid);
        // 记录缓存, 7天
        Cache::tag('cache')->set($this->token, $user_id, 86400 * 7);
        return $user_id;
    }

    /**
     * 用户登录
     */
    public function bindMobile($post)
    {
        // 微信登录 获取session_key
        $app = AppWx::getApp();
        $session = $app->auth->session($post['code']);
        $iv = urldecode($post['iv']);
        $encrypted_data = urldecode($post['encrypted_data']);
        $pc = new WxBizDataCrypt($app['config']['app_id'], $session['session_key']);
        $errCode = $pc->decryptData($encrypted_data, $iv, $data);
        if ($errCode == 0) {
            $data = json_decode($data, true);
            return $this->save([
                'mobile' => $data['phoneNumber']
            ]);
        }
        return false;
    }

    /**
     * 获取token
     */
    public function getToken()
    {
        return $this->token;
    }


    /**
     * 生成用户认证的token
     */
    private function token($openid)
    {
        $app_id = self::$app_id;
        // 生成一个不会重复的随机字符串
        $guid = \getGuidV4();
        // 当前时间戳 (精确到毫秒)
        $timeStamp = microtime(true);
        // 自定义一个盐
        $salt = 'token_salt';
        return md5("{$app_id}_{$timeStamp}_{$openid}_{$guid}_{$salt}");
    }

    /**
     * 自动注册用户
     */
    private function register($open_id, $data, $refereeId = null, $decryptedData = [], $reg_source = '')
    {
        //通过unionid查询用户是否存在
        $user = null;
        if (isset($decryptedData['unionid']) && !empty($decryptedData['unionid'])) {
            $data['union_id'] = $decryptedData['unionid'];
            $user = self::detailByUnionid($decryptedData['unionid']);
        }
        if (!$user) {
            // 通过open_id查询用户是否已存在
            $user = self::detail(['open_id' => $open_id]);
        }
        if ($user) {
            $model = $user;
        } else {
            $model = $this;
            $data['referee_id'] = $refereeId;
            $data['reg_source'] = 'wx';
            //默认等级
            $data['grade_id'] = GradeModel::getDefaultGradeId();
        }
        $this->startTrans();
        try {
            // 保存/更新用户记录
            if (!$model->save(array_merge($data, [
                'open_id' => $open_id,
                'app_id' => self::$app_id
            ]))
            ) {
                throw new BaseException(['msg' => '用户注册失败']);
            }
            if (!$user && $refereeId > 0) {
                // 记录推荐人关系
                RefereeModel::createRelation($model['user_id'], $refereeId);
                //更新用户邀请数量
                (new UserModel())->setIncInvite($refereeId);
            }
            $this->commit();
        } catch (\Exception $e) {
            $this->rollback();
            throw new BaseException(['msg' => $e->getMessage()]);
        }
        return $model['user_id'];
    }

    /**
     *统计被邀请人数
     */
    public function getCountInv($user_id)
    {
        return $this->where('referee_id', '=', $user_id)->count('user_id');
    }

    /**
     * 签到更新用户积分
     */
    public function setPoints($user_id, $days, $sign_conf, $sign_date)
    {
        $rank = $sign_conf['ever_sign'];
        if ($sign_conf['is_increase'] == 'true') {
            if ($days >= $sign_conf['no_increase']) {
                $days = $sign_conf['no_increase'] - 1;
            }
            $rank = ($days - 1) * $sign_conf['increase_reward'] + $rank;
        }
        //是否奖励
        if (isset($sign_conf['reward_data'])) {
            $arr = array_column($sign_conf['reward_data'], 'day');
            if (in_array($days, $arr)) {
                $key = array_search($days, $arr);
                if ($sign_conf['reward_data'][$key]['is_point'] == 'true') {
                    $rank = $sign_conf['reward_data'][$key]['point'] + $rank;
                }
            }
        }
        // 新增积分变动明细
        $this->setIncPoints($rank, '用户签到：签到日期' . $sign_date);
        return $rank;
    }

    /**
     * 个人中心菜单列表
     */
    public static function getMenus($user, $source)
    {
        // 系统菜单
        $sys_menus = CenterMenuModel::getAll();
        /*// 查询用户菜单
        $model = new CenterMenuModel();
        $user_menus = $model->getAll();
        $user_menu_tags = [];
        foreach ($user_menus as $menu){
            $menu['sys_tag'] != '' && array_push($user_menu_tags, $menu['sys_tag']);
        }
        $save_data = [];
        foreach($sys_menus as $menu){
            if($menu['sys_tag'] != '' && !in_array($menu['sys_tag'], $user_menu_tags)){
                $save_data[] = array_merge($sys_menus[$menu['sys_tag']], [
                    'sort' => 100,
                    'app_id' => self::$app_id
                ]);
            }
        }
        if(count($save_data) > 0){
            $model->saveAll($save_data);
            Cache::delete('center_menu_' . self::$app_id);
            $user_menus = $model->getAll();
        }*/
        //判断是否入住店铺
        $noShow = [];
        $apply = UserModel::isSupplierApply($user['user_id']);
        if($apply && $apply['status'] != 1){
            array_push($noShow, 'shop','my_shop','shop_apply');
        }else if ($user['user_type'] == 2) {
            // 申请中或者已入驻成功
            array_push($noShow, 'shop','shop_apply');
            // 入驻成功
            if (UserModel::isSupplier($user['user_id'])) {
                array_push($noShow, 'shop_apply_status');
            } else {
                array_push($noShow, 'my_shop');
            }
        }else if($apply){
            // 申请中或者已入驻成功
            array_push($noShow, 'shop','my_shop','shop_apply');
        }else{
            // 申请中或者已入驻成功
            array_push($noShow, 'shop','my_shop','shop_apply_status');
        }

        $menus_arr = [];
        foreach ($sys_menus as $menu) {
            if($menu['sys_tag'] != '' && $menu['status'] == 1 && !in_array($menu['sys_tag'], $noShow)){
                if(strpos($menu['image_url'], 'http') !== 0){
                    $menu['image_url'] = self::$base_url . $menu['image_url'];
                }
                $menus_arr[$menu['sys_tag']] = $menu;
            }
        }
        foreach ($menus_arr as $menus){
            if(strpos($menus['image_url'], 'http') !== 0){
                $menus['image_url'] = self::$base_url . $menus['image_url'];
            }
        }
        return $menus_arr;
    }

    /**
     * 获取收款码
     * @param $sid 门店用户ID
     * @return false|string|string[]|null
     * @throws BaseException
     */
    public static function getQrcode($sid){
        $fileName = '/uploads/qrcode/'.$sid.'_'.md5($sid).'.jpg';
        $cache = Cache::get('caches:qrcode:'.$sid);
        if(!is_dir(app()->getRootPath().'public/uploads/qrcode')){
            mkdir(app()->getRootPath().'public/uploads/qrcode',0755, true);
        }

        if($cache && file_exists(app()->getRootPath().'public'.$fileName)){
            return getPreview($fileName);
        }

        $app = AppWx::getApp();
        $data = $app->app_code->getQrCode('/pages/order/pay?sid='.$sid);
        if(empty($data)){
            return false;
        }

        file_put_contents(app()->getRootPath().'public'.$fileName, $data);
        if(file_exists(app()->getRootPath().'public'.$fileName)){
            Cache::tag('cache')->set('caches:qrcode:'.$sid, $fileName, rand(300, 600));
            return getPreview($fileName);
        }

        return false;
    }
}