gonghuixiangqin/application/common/model/User.php

<?php

namespace app\common\model;

use app\common\model\Order;
use app\common\model\Sms;
use Firebase\JWT\JWT;
use think\Model;
use app\common\library\Common;
use think\facade\Validate;
use think\Request;
use think\Db;
use app\common\library\WxService;
use app\common\library\WxPay;
use app\common\library\AliPay;
use EasyWeChat\Factory;


header('Access-Control-Allow-Origin: *');
/**
 * 会员模型
 */
class User Extends Model
{
    // 开启自动写入时间戳字段
    protected $autoWriteTimestamp = 'TIMESTAMP';
    // 定义时间戳字段名
    protected $createTime = 'create_at';
    protected $updateTime = 'update_at';
    // 追加属性
    protected $append = [
    ];

    protected $table = 'q_user';

    /**
     * 微信授权登录、注册
     */
    public static function wechatLogin($code,$rawData){
        $appid = Config::get_values('wechat_appid');
        $secret = Config::get_values('wechat_appsecret');
        $url = "https://api.weixin.qq.com/sns/jscode2session?appid=" . $appid . "&secret=" . $secret . "&js_code=" . $code . "&grant_type=authorization_code";
        $session_key = Common::curlRequest($url);
        if (!empty($session_key['session_key'])) {
            $openid = $session_key['openid'];
            //数据库是否已注册
            $user = Db::name('q_member')
                ->where('openid',$openid)
                ->where('is_deleted',1)
                ->find();
            if ($user){
                $token = JWT::encode($user,config('jwt.key'));
                $result['token'] = $token;
                return Common::return_success('授权成功',$result);
            }else{
                $data['sex'] = 0;
                if ($rawData){
                    $data['rawdata'] = $rawData;
                    $rawData = json_decode($rawData,true);
                    $data['nickname'] = $rawData['nickName'];
                    $data['openid'] = $openid;
                    $data['sex'] = $rawData['gender'];
                    $data['headimg'] = $rawData['avatarUrl'];
                }
                Db::startTrans();
                try {
                    $user = self::create($data);
                    Db::commit();
                    $userId =$user->id;
                    $use =  Db::name('q_user')->where('id',$userId)->find();
                    $token = JWT::encode($use,config('jwt.key'));
                    $result['token'] = $token;
                    return Common::return_success('授权成功',$result);
                }catch (Exception $e) {
                    Db::rollback();
                    return Common::return_error('授权失败');
                }
            }

        }else{
            return Common::return_error('获取session_key失败！');
        }
    }

    /**
     * 根据手机号获取用户信息
     */
    public static function getByMobile($phone){
        $userinfo = self::where('phone',$phone)->find();
        return $userinfo;
    }

    /**
     * 获取用户信息
     */
    public static function getUserInfo($id){
        $info = self::where('id',$id)->find();
        return $info;
    }

    /**
     * 修改密码
     */
    public static function editPayPassword($user_id,$ver_code,$password){
        $phone_use = self::where('id',$user_id)->find();
        //获取最后的验证码
         $time = time()-90;
        $sms = Sms::where(['mobile' => $phone_use['phone'], 'event' => 'changepwd'])
            ->where('createtime','>',$time)
            ->order('id', 'DESC')
            ->find();
        if (!$sms || $sms->code != $ver_code){
            return Common::return_error('短信验证码不正确！');
        }
        $phone_use->pay_password = md5($password);
        Db::startTrans();
        try {
            $phone_use->save();
            Db::commit();
            return Common::return_success('修改成功');
        }catch (Exception $e) {
            Db::rollback();
            return Common::return_error('修改失败');
        }
    }


    /**
     * 编辑用户资料
     */
    public static function EditUserInfo($user_id,$data){
        if (self::where('id',$user_id)->update($data)){
            return Common::return_success('编辑成功');
        }else{
            return Common::return_error('编辑失败');
        }
    }

    /**
     * 我的送检人列表
     */
    public static function peoplelist($user_id){
        $list = MakesPeople::where('user_id',$user_id)
            ->order('id asc')
            ->select();
        return Common::return_success('成功',$list);
    }


    /**
     * 添加，修改送检人
     */
    public static function AddEditPeoplelist($user_id,$data,$id){
        if ($id){
            $address = MakesPeople::where('id',$id)->where('user_id',$user_id)->find();
            if (!$address) return Common::return_error('信息不存在');
            //编辑
            if ($address->save($data)){
                return Common::return_success('编辑成功');
            }else{
                return Common::return_error('编辑失败');
            }
        }else{
            $data['user_id'] = $user_id;
            $addre = MakesPeople::create($data);
            if ($addre){
                return Common::return_success('添加成功');
            }else{
                return Common::return_error('添加失败');
            }
        }
    }

    /**
     * 删除送检人
     */
    public static function DelPeoplelist($user_id,$id){
        $address = MakesPeople::where('id',$id)->where('user_id',$user_id)->find();
        if (!$address) return Common::return_error('信息不存在');
        if (MakesPeople::where('id',$id)->delete()){
            return Common::return_success('删除成功');
        }else{
            return Common::return_error('删除失败');
        }
    }





    /**
     * 变更会员余额
     * @param int $money    余额
     * @param int $user_id  会员ID
     * @param string $memo  备注
     */
    public static function money($money, $user_id, $memo, $type,$pm = 0,$phone='',$fee=0,$status=0)
    {
        $user = self::get($user_id);
        if ($user)
        {
            switch ($type){
                case 1:
                    $user_money = $user->equity_integral;
                    $field = 'equity_integral';
                    break;
                case 2:
                    $user_money = $user->usable_integral;
                    $field = 'usable_integral';
                    break;
                case 3:
                    $user_money = $user->repertory_integral;
                    $field = 'repertory_integral';
                    break;
                case 4:
                    $user_money = $user->coupon;
                    $field = 'coupon';
                    break;
            }
            $before = $user_money;
            if ($pm==1){
                $after = $user_money + $money;
            }else{
                $after = $user_money - $money;
            }
            //更新会员信息
            $user->save([$field => $after]);
            //写入日志
            MoneyLog::create(['user_id' => $user_id,'pm' => $pm, 'change_money' => $money, 'before' => $before, 'after' => $after, 'title' => $memo,'type'=>$type,'phone'=>$phone,'fee'=>$fee,'status'=>$status]);
        }
    }



}