sheji_admin/application/common/model/User.php

<?php

namespace app\common\model;

use app\common\model\Sms;
use app\common\library\Email;
use app\common\model\Order;
use Firebase\JWT\JWT;
use phpDocumentor\Reflection\Type;
use app\common\model\UserIntegralLog;
use think\Model;
use app\common\library\Common;
use think\facade\Validate;
use think\Request;
use think\Db;
use function foo\func;
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 register($phone,$password,$ver_code){
        $phone_use = self::where('phone',$phone)->find();
        if ($phone_use){
            return Common::return_error('手机号已注册！');
        }

        //获取最后的验证码
//        $time = time()-90;
//        $sms = Sms::where(['mobile' => $phone, 'event' => 'register'])
//            ->where('createtime','>',$time)
//            ->order('id', 'DESC')
//            ->find();
//        if (!$sms || $sms->code != $ver_code){
//            return Common::return_error('短信验证码不正确！');
//        }

        $data['phone'] = $phone;
        $data['password'] = md5($password);
        $data['ip'] = request()->ip();
        Db::startTrans();
        try {
            self::create($data);
            Db::commit();
            return Common::return_success('注册成功');
        }catch (Exception $e) {
            Db::rollback();
            return Common::return_error('注册失败');
        }
    }


    /**
     * 登录
     */
    public static function login($phone,$password,$type,$ver_code){
        $phone_use = self::where('phone',$phone)->find();
        if (!$phone_use){
            return Common::return_error('手机号未注册！');
        }
        if ($phone_use['status']!=1){
            return Common::return_error('账号已禁用！');
        }
        if ($type==1){
            if ($phone_use['password'] != md5($password)){
                return Common::return_error('密码错误！');
            }
        }elseif ($type==2){
            //获取最后的验证码
//            $time = time()-90;
//            $sms = Sms::where(['mobile' => $phone, 'event' => 'login'])
//                ->where('createtime','>',$time)
//                ->order('id', 'DESC')
//                ->find();
//            if (!$sms || $sms->code != $ver_code){
//                return Common::return_error('短信验证码不正确！');
//            }
        }
        self::where('id',$phone_use['id'])->update(['ip'=>request()->ip()]);
        LoginLog::create(['user_id'=>$phone_use['id'],'ip'=>request()->ip()]);
        $token = JWT::encode($phone_use,config('jwt.key'));
        return Common::return_success('登录成功',['token'=>$token]);
    }



    /**
     * 微信授权登录
     * @param $code
     */
    public static function wechatLogin($code){
        $appid = Config::get_values('wechat_appid');
        $secret = Config::get_values('wechat_appsecret');
        $url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=$appid&secret=$secret&code=$code&grant_type=authorization_code";
        $result = Common::httpcurl($url);
        if (isset($result['access_token'])){
            $access_token=$result['access_token'];
            $openid=$result['openid'];
            $urltoc = "https://api.weixin.qq.com/sns/userinfo?access_token=$access_token&openid=$openid&lang=zh_CN";
            $resinfos =Common::httpcurl($urltoc);

            //数据库是否已注册
            $user =  self::where('status',1)->where('openid',$resinfos['openid'])->find();
            if ($user){
                self::where('id',$user['id'])->update(['ip'=>request()->ip()]);
                LoginLog::create(['user_id'=>$user['id'],'ip'=>request()->ip()]);
                $token = JWT::encode($user,config('jwt.key'));
                return Common::return_success('登录成功',['token'=>$token]);
            }else{
                return Common::return_error('未注册！');
            }
        }else{
            return Common::return_error('获取access_token失败');
        }
    }


    /**
     * 获取微信session_key
     */
    public static function getSessionKey($code){
//        $appid = Config::get_values('wechat_appid');
//        $secret = Config::get_values('wechat_appsecret');
        $appid = Config::get_values('small_wechat_id');
        $secret = Config::get_values('small_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);
        return $session_key;
    }

    /**
     * 微信登录绑定手机号
     */
    public static function wechatLoginBindPhone($code,$rawData,$phone,$ver_code,$password){
        header('Access-Control-Allow-Origin: *');
        $phone_use = self::where('phone',$phone)->find();
        if ($phone_use && $phone_use['openid']!=''){
            return Common::return_error('手机号已被绑定！');
        }
        if ($phone_use['status']!=1){
            return Common::return_error('账号已禁用！');
        }
        //获取最后的验证码
        //$time = time()-90;
//        $sms = Sms::where(['mobile' => $phone, 'event' => 'bindwechat'])
//            ->where('createtime','>',$time)
//            ->order('id', 'DESC')
//            ->find();
//        if (!$sms || $sms->code != $ver_code){
//            return Common::return_error('短信验证码不正确！');
//        }

        $session_key = self::getSessionKey($code);
        if (empty($session_key['session_key'])) {
            return Common::return_error('获取session_key失败！');
        }
        $openid = $session_key['openid'];
        if (!$phone_use){
            $data['phone'] = $phone;
            $data['nickname'] = $rawData['nickName'];
            $data['headimg'] = $rawData['avatarUrl'];
            $data['openid'] = $openid;
            $data['password'] = md5($password);
            $data['ip'] = request()->ip();
            Db::startTrans();
            try {
                $user = self::create($data);
                Db::commit();
                $userId =$user->id;
                LoginLog::create(['user_id'=>$userId,'ip'=>request()->ip()]);
                $user = self::where('id',$userId)->find();
                $token = JWT::encode($user,config('jwt.key'));
                return Common::return_success('授权成功',['token'=>$token]);
            }catch (Exception $e) {
                Db::rollback();
                return Common::return_error('失败');
            }
        }else{
            if (self::where('id',$phone_use['id'])->update(['openid'=>$openid])){
                LoginLog::create(['user_id'=>$phone_use['id'],'ip'=>request()->ip()]);
                $token = JWT::encode($phone_use,config('jwt.key'));
                return Common::return_success('绑定成功',['token'=>$token]);
            }else{
                return Common::return_error('失败');
            }
        }
    }







    /**
     * 忘记密码
     */
    public static function forgotPassword($phone,$password,$ver_code){
        $phone_use = self::where('phone',$phone)->find();
        if (!$phone_use){
            return Common::return_error('手机号未注册！');
        }
        //获取最后的验证码
//        $time = time()-90;
//        $sms = Sms::where(['mobile' => $phone, 'event' => 'forgetpwd'])
//            ->where('createtime','>',$time)
//            ->order('id', 'DESC')
//            ->find();
//        if (!$sms || $sms->code != $ver_code){
//            return Common::return_error('短信验证码不正确！');
//        }
        $phone_use->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 changePassword($user_id,$password,$ver_code){
        $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->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 MyAddress($user_id,$Nowpage,$limits){
        $list = Address::where('is_del',0)
            ->where('user_id',$user_id)
            ->page($Nowpage,$limits)
            ->order('is_default desc,id desc')
            ->select();
        $data['count'] = count($list);
        $data['list'] = $list;
        return Common::return_success('成功',$data);
    }


    /**
     * 添加，修改收货地址
     */
    public static function AddEditAddress($user_id,$data,$address_id){
        if ($address_id){
            $address = Address::where('id',$address_id)->where('user_id',$user_id)->find();
            if (!$address) return Common::return_error('地址不存在');
            //编辑
            if ($address->save($data)){
                if ($data['is_default']==1){
                    Address::where('user_id',$user_id)
                        ->where('is_del',0)
                        ->where('id','neq',$address_id)
                        ->update(['is_default'=>0]);
                }
                return Common::return_success('编辑成功');
            }else{
                return Common::return_error('编辑失败');
            }
        }else{
            $data['user_id'] = $user_id;
            $addre = Address::create($data);
            if ($addre){
                $address_id =  $addre->id;
                if ($data['is_default']==1){
                    Address::where('user_id',$user_id)
                        ->where('is_del',0)
                        ->where('id','neq',$address_id)
                        ->update(['is_default'=>0]);
                }
                return Common::return_success('添加成功');
            }else{
                return Common::return_error('添加失败');
            }
        }
    }



    /**
     * 设为默认地址
     */
    public static function SetAddressDefault($user_id,$address_id){
        $address = Address::where('id',$address_id)
            ->where('user_id',$user_id)
            ->find();
        if (!$address)  return Common::return_error('地址不存在');
        if ($address->save(['is_default'=>1])){
            Address::where('user_id',$user_id)
                ->where('is_del',0)
                ->where('id','neq',$address_id)
                ->update(['is_default'=>0]);
            return Common::return_success('设置成功');
        }else{
            return Common::return_error('设置失败');
        }
    }


    /**
     * 删除收货地址
     */
    public static function DelAddress($user_id,$address_id){
        $address = Address::where('id',$address_id)->where('user_id',$user_id)->find();
        if (!$address) return Common::return_error('地址不存在');
        if ($address->save(['is_del'=>time()])){
            return Common::return_success('删除成功');
        }else{
            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 applyDesigner($user_id,$data){
        $data['type'] = 1;
        $data['audit'] = 1;
        Db::startTrans();
        try {
            self::where('id',$user_id)->update($data);
            Db::commit();
            return Common::return_success('提交成功');
        }catch (Exception $e) {
            Db::rollback();
            return Common::return_error('提交失败');
        }
    }


    /**
     * 投诉
     */
    public static function Message($user_id,$content){
        $data['content'] = $content;
        $data['user_id'] = $user_id;
        if (Message::create($data))  return Common::return_success('提交成功');
        return Common::return_error('提交失败');
    }


    /**
     * 时间管理
     */
    public static function timeList($user_id){
        $time = time();
        //组合数据
        $date = [];
        for ($i=1; $i<=7; $i++){
            $date[$i] = date('Y-m-d' ,strtotime( $i .' days', $time));
        }
        $array = [];
        foreach ($date as &$v){
            $da = UserTime::where('user_id',$user_id)->where('time',$v)->find();
            if ($da){
                $array2['switch'] = $da['switch'];
            }else{
                $array2['switch'] = 2;
            }
            $array2['date'] = $v;
            array_push($array,$array2);
        }
        return Common::return_success('成功',$array);
    }


    /**
     * 时间设置开关
     */
    public static function timeSwitch($user_id,$date,$switch){
        $info = UserTime::where('user_id',$user_id)->where('time',$date)->find();
        if ($info){
            if (UserTime::where('id',$info['id'])->update(['switch'=>$switch])){
                return Common::return_success('成功');
            }else{
                return Common::return_error('失败');
            }
        }else{
            if (UserTime::create(
                [
                    'user_id'=>$user_id,
                    'time'=>$date,
                    'switch'=>$switch,
                ]
            )){
                return Common::return_success('成功');
            }else{
                return Common::return_error('失败');
            }
        }
    }




    /**
     * 余额提现
     */
    public static function userWithdraw($user_id,$money,$withdraw_type){
        $userinfo = self::where('id',$user_id)->find();
        if ($userinfo['money']<$money)
            return Common::return_error('余额不足');
        $data['user_id'] = $user_id;
        $order_no = Common::getNewOrderId($user_id);
        $data['order_no'] = $order_no;
        $data['withdraw_type'] = $withdraw_type;
        $data['price'] = $money;
        Db::startTrans();
        try {
            UserWithdraw::create($data);
            User::money($money,$user_id,$withdraw_type=='weixin' ? '微信提现' : '支付宝提现' .$money.'元');
            Db::commit();
            return Common::return_success('提交成功');
        }catch (Exception $e) {
            Db::rollback();
            return Common::return_error('提交失败');
        }
    }


    /**
     * 提现记录
     */
    public static function withdrawRecord($user_id,$Nowpage,$limits){
        $count = UserWithdraw::where('user_id',$user_id)->count();
        if ($count){
            $list = UserWithdraw::where('user_id',$user_id)->order('id desc')->page($Nowpage,$limits)->select();
            foreach ($list as $k=>$v){
                if ($v['pay_time']){
                    $list[$k]['pay_time'] = date('Y-m-d H:i',$v['pay_time']);
                }
            }
        }else{
            $list = [];
        }
        $data['count'] = $count;
        $data['list'] = $list;
        return Common::return_success('成功',$data);
    }




    /**
     * 首页设计师列表
     */
    public static function Designer($user_id,$Nowpage,$limits,$design_classifi,$keywords,$lat,$log,$city,$distance,$price,$evaluation,$date){
        $count = self::designerByWhere($user_id,$design_classifi,$keywords,$city,$date)->count();
        if ($count){
            $field = ['id','phone','name','nickname','headimg','price','design_classifi','skills_label','good_type','good_style','evaluation'];
            $field['ROUND(6378.138 * 2 * ASIN(SQRT(POW( SIN( ( ' . $lat . ' * PI( ) / 180 - wd * PI( ) / 180 ) / 2 ), 2 ) + COS( ' . $lat . ' * PI( ) / 180 ) * COS( wd * PI( ) / 180 ) * POW( SIN( ( ' . $log . ' * PI( ) / 180 - jd * PI( ) / 180 ) / 2 ), 2 ))) * 1000)'] = 'distance';
            $list = self::designerByWhere($user_id,$design_classifi,$keywords,$city,$date)
                ->field($field)
                ->when($distance,function ($query) use ($distance){
                    $query->order('distance '.$distance);
                })
                ->when($price,function ($query) use ($price){
                    $query->order('price '.$price);
                })
                ->when($evaluation,function ($query) use ($evaluation){
                    $query->order('evaluation '.$evaluation);
                })
                ->page($Nowpage,$limits)
                ->select();

            $time = time();
            //组合数据
            $date = [];
            for ($i=1; $i<=7; $i++){
                $date[$i] = date('Y-m-d' ,strtotime( $i .' days', $time));
            }
            foreach ($list as &$v){
                $array = [];
                foreach ($date as &$a){
                    $da = UserTime::where('user_id',$user_id)->where('time',$a)->find();
                    if ($da){
                        $order = Order::where('designer_id',$v['id'])
                            ->where('yy_date',$a)
                            ->where('is_del',1)
                            ->whereIn('status','1,2')
                            ->count();
                        if ($order){
                            $array2['switch'] = 2;
                        }else{
                            $array2['switch'] = $da['switch'];
                        }
                    }else{
                        $array2['switch'] = 2;
                    }
                    $array2['date'] = $a;
                    array_push($array,$array2);
                }
                $v['date_list'] = $array;
            }
        }else{
            $list = [];
        }
        return Common::return_success('成功',compact('count','list'));
    }


    /**
     * 首页设计师列表where条件
     */
    public static function designerByWhere($user_id,$design_classifi,$keywords,$city,$date){
        $query = self::where('status',1)
            ->when($design_classifi,function ($query) use ($design_classifi){
                $query->where('design_classifi',$design_classifi);
            })
            ->when($keywords,function ($query) use ($keywords){
                $query->whereLike('name|nickname|skills_label|design_classifi|good_type|good_style',$keywords);
            })
            ->when($city,function ($query) use ($city){
                $query->where('city',$city);
            })
            ->when($date,function ($query) use ($date){
                $ids1 = UserTime::where('time',$date)
                    ->where('switch',1)
                    ->column('user_id');
                $ids2 = Order::where('yy_date',$date)
                    ->where('is_del',1)
                    ->whereIn('status','1,2')
                    ->column('designer_id');
                $ids = array_diff($ids1,$ids2);  //对比两数组差异
                $query->whereIn('id',$ids);
            })
            //->where('id','neq',$user_id)
            ->where('type',2);
        return $query;
    }



    /**
     * 获取可使用优惠券列表
     */
    public static function getCouponList($user_id,$money){
        CouponUser::couponsTimeOut($user_id);
        $list = CouponUser::where('user_id',$user_id)
            ->where('use_min_price','<=',$money)
            ->where('end_time','>',time())
            ->where('status',0)
            ->select();
        return Common::return_success('成功',$list);
    }



    /**
     * 下单
     */
    public static function PlaceOrder($user_id,$address_id,$designer_id,$yy_date,$project_name,$coupon_id,$pay_type){
        $designer = self::where('id',$designer_id)
            ->where('type',2)
            ->where('status',1)
            ->find();
        if (!$designer) Common::return_error('设计师不存在');
        $address = Address::where('id',$address_id)
            ->where('user_id',$user_id)
            ->where('is_del',0)
            ->find();
        if (!$address)  Common::return_error('地址不存在');
        $time = UserTime::where('user_id',$user_id)
            ->where('time',$yy_date)
            ->where('switch',1)
            ->find();
        $order = Order::where('designer_id',$designer_id)
            ->where('is_del',1)
            ->whereIn('status','1,2')
            ->where('yy_date',$yy_date)
            ->find();
        if (!$time || $order) Common::return_error('预约日期设计师已接单');
        //价格
        $price = $designer['price'];
        $coupon_price = 0;
        $pay_price = $price;
        if ($coupon_id){
            $coupon = CouponUser::where('id',$coupon_id)
                ->where('user_id',$user_id)
                ->where('status',0)
                ->find();
            if (!$coupon) Common::return_error('优惠券不存在');
            $coupon_price = $coupon['coupon_price'];
            $pay_price = bcsub($pay_price,$coupon_price,2);
        }
        //服务时间
        $servicing_time = Config::get_values('service_start_time').'-'.Config::get_values('service_end_time');

        //订单号
        $order_no = Common::getNewOrderId($user_id);
        $data = [
            'order_no'=>$order_no,
            'user_id'=>$user_id,
            'designer_id'=>$designer_id,
            'address_id'=>$address_id,
            'name'=>$address['name'],
            'phone'=>$address['phone'],
            'province'=>$address['province'],
            'city'=>$address['city'],
            'area'=>$address['area'],
            'address'=>$address['address'],
            'yy_date'=>$yy_date,
            'servicing_time'=>$servicing_time,
            'project_name'=>$project_name,
            'coupon_id'=>$coupon_id,
            'pay_type'=>$pay_type,
            'price'=>$price,
            'coupon_price'=>$coupon_price,
            'pay_price'=>$pay_price,
        ];
        Db::startTrans();
        try {
            $order = self::create($data);
            $order_id = $order->id;
            Common::order_status($order_id,'订单生成');
            switch ($pay_type){
                case 'weixin':
                    $wx = new WxPay();//实例化微信torganizationid支付控制器
                    $body = '订单号' . $order_no;//支付说明
                    $total_fee = $pay_price * 100;//支付金额(乘以100)
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/pay/pay_order';//回调地址
                    $out_trade_no = $order_no;//订单号

                    $config = $wx->retrunconfig2();
                    try{
                        $app    =   Factory::payment($config);
                        $result = $app->order->unify([
                            'body' => $body,
                            'out_trade_no' => $out_trade_no,
                            'total_fee' => $total_fee,
                            'notify_url' => $notify_url, // 支付结果通知网址，如果不设置则会使用配置里的默认地址
                            'trade_type' => 'APP', // 请对应换成你的支付方式对应的值类型
                        ]);
                        $jssdk      =   $app->jssdk;
                        $order1 = $jssdk->appConfig($result['prepay_id']);
                        self::where('order_no',$order_no)->update(['wx_order'=>json_encode($order1,true)]);
                        Db::commit();
                        $retrun_data['order_no'] = $order_no;
                        $retrun_data['pay'] = $order1;
                        return Common::return_success('成功',$retrun_data);

                    }catch (Exception $e){
                        Db::rollback();
                        return Common::return_error($order['return_msg']);
                    }
                    break;

                case 'zfb':
                    if ($coupon_id){
                        $coupon = self::checkCoupon($user['id'],$coupon_id,$price);
                        if (!$coupon)  return Common::return_error('优惠券不可用');
                        $coupon_price = $coupon['coupon_price'];
                        $price2 = bcsub($price,$coupon_price,2);
                        $difference_money = $price2;
                    }else{
                        $difference_money = 0;
                        $coupon_price = 0;
                        $price2 = $price;
                    }
                    self::where('order_no',$order_no)->update(['pay_type'=>$pay_type,'coupon_price'=>$coupon_price,'difference_money'=>$difference_money,'all_money'=>$price]);
                    $zfb = new AliPay();//实例化支付宝支付控制器
                    $body = '全民创商品支付';//支付说明
                    $out_trade_no = $order_no;//订单号
                    $total_fee = $price2;//支付金额(乘以100)
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/pay/alipay_order';//回调地址
                    $order = $zfb->aliPay($body, $total_fee, $out_trade_no, $notify_url);//调用支付宝支付的方法
                    $retrun_data['order_no'] = $order_no;
                    $retrun_data['pay'] = $order;
                    Db::commit();
                    return Common::return_success('成功',$retrun_data);
                    break;
            }
        }catch (Exception $e) {
            Db::rollback();
            return Common::return_error('失败');
        }
    }





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

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




    /**
     * 变更会员余额
     * @param int $money    余额
     * @param int $user_id  会员ID
     * @param string $memo  备注
     */
    public static function money($money, $user_id, $memo, $pm = 0)
    {
        $user = self::get($user_id);
        if ($user)
        {
            $before = $user->money;
            if ($pm==1){
                $after = $user->money + $money;
            }else{
                $after = $user->money - $money;
            }
            //更新会员信息
            $user->save(['money' => $after]);
            //写入日志
            MoneyLog::create(['user_id' => $user_id,'pm' => $pm, 'change_money' => $money, 'before' => $before, 'after' => $after, 'title' => $memo]);
        }
    }




}