bab-icon/app/Http/Controllers/Api/MemberController.php

<?php


namespace App\Http\Controllers\Api;


use App\Http\Controllers\FrontController;
use App\Jobs\BarrageJob;
use App\Jobs\MemberShareJob;
use App\Jobs\SaveImGroup;
use App\Models\Comment;
use App\Models\Express;
use App\Models\Goods;
use App\Models\GoodsBrowse;
use App\Models\GoodsCollect;
use App\Models\Member;
use App\Models\MemberAddress;
use App\Models\MemberClan;
use App\Models\MemberCoupon;
use App\Models\MemberOpenId;
use App\Models\Members;
use App\Models\MoneyDetail;
use App\Models\MoneyRecord;
use App\Models\Order;
use App\Models\RefundOrder;
use App\Models\SeckillGoods;
use App\Models\Shop;
use App\Models\ShopCollect;
use App\Models\ShopOrder;
use App\Servers\AddressServer;
use App\Servers\CommonServer;
use App\Servers\ExpressServer;
use App\Servers\GoodsServer;
use App\Servers\ImgServer;
use App\Servers\KdnServer;
use App\Servers\MemberLogsServer;
use App\Servers\MemberServer;
use App\Servers\MergeServer;
use App\Servers\MoneyDetailServer;
use App\Servers\PassServer;
use App\Servers\RedisDataServer;
use App\Servers\SensitiveServer;
use App\Servers\SmsServer;
use App\Servers\WeixinServer;
use App\Servers\WxTemplateServer;
use Carbon\Carbon;
use SimpleSoftwareIO\QrCode\Facades\QrCode;
use SwooleTW\Http\Websocket\Facades\Websocket;

class MemberController extends FrontController
{


    public function __construct()
    {
        parent::__construct();
    }

    function index()
    {

    }

    /**
     * 会员注册
     * @return \Illuminate\Http\JsonResponse
     */
    function register()
    {
        $invite_code = request()->input('invite_code', '');
        if (!empty($invite_code)) {
            $p_member = Member::where('invite_code', $invite_code)->where('status',1)->select(['id', 'phone'])->first();
        }
        if (empty($p_member)) {
            $p_member = Member::where('id', 1)->select(['id', 'phone'])->first();
        }
        $nickname = request()->input('nickname', '张三');
        if(empty($nickname)){
            return $this->apiResponseError('请输入昵称');
        }
        $mobile = request()->input('phone', '13900139110');
        $password = request()->input('password', '123456');
        $password = str_replace(' ', '', $password);
        if (empty($password)) {
            return $this->apiResponseError('请设置登录密码');
        }
        if (strlen($password) < 6) {
            return $this->apiResponseError('登录密码最低6位');
        }
        $code = request()->input('code', '1234');
        if (empty($code)) {
            return $this->apiResponseError('请输入验证码');
        }
        $send_server = SmsServer::creatServer();
        $code_ret = $send_server->verifyCode($mobile, $code, 'register');
        if (empty($code_ret)) {
            return $this->apiResponseError($send_server->getErrorMsg() ?: '验证码错误');
        }
        $member = Member::where('address', $mobile)->where('status',1)->select(['id', 'token_str'])->first();
        if ($member) {
            $token_str = PassServer::creatServer()->getMemberToken($member->{'id'});
            Member::where('id', $member->{'id'})->update(['token_str' => $token_str]);
            return $this->apiResponseSuccess('登陆成功', ['m_id' => $member->{'id'}, 'token' => $token_str]);
        } else {
            $ret = MemberServer::creatServer()->register($mobile, $p_member->{'id'}, $password, '');
            if (empty($ret)) {
                return $this->apiResponseError('注册失败');
            } else {
                return $this->apiResponseSuccess('注册成功', $ret);
            }
        }


    }



    /**
     * 会员登录
     * @return \Illuminate\Http\JsonResponse
     */
    function login()
    {
        $mobile = request()->input('address', '');
        if (empty($mobile)) {
            return $this->apiResponseError('地址信息错误');
        }
        $member = Member::where('address', $mobile)->where('status',1)->select(['id', 'password', 'encrypt'])->first();
        if (empty($member)) {
            return $this->apiResponseError('当前账户未注册');
        }
        $token_str = PassServer::creatServer()->getMemberToken($member->{'id'});
        Member::where('id', $member->{'id'})->update(['token_str' => $token_str]);
        return $this->apiResponseSuccess('登陆成功', ['token' => $token_str]);
    }


    /**
     * 修改登录密码
     * @return \Illuminate\Http\JsonResponse
     */
    function retrievePassword()
    {
        $mobile = request()->input('phone', '13900139110');
        $password = request()->input('password', '123456');
        $password = str_replace(' ', '', $password);
        if (empty($password)) {
            return $this->apiResponseError('请设置登录密码');
        }
        if (strlen($password) < 6) {
            return $this->apiResponseError('登录密码最低6位');
        }
        $code = request()->input('code', '1234');
        if (empty($code)) {
            return $this->apiResponseError('请输入验证码');
        }
        $send_server = SmsServer::creatServer();
        $code_ret = $send_server->verifyCode($mobile, $code, 'retrieve');
        if (empty($code_ret)) {
            return $this->apiResponseError($send_server->getErrorMsg() ?: '验证码错误');
        }
        $member = Member::where('id', request()->member['id'])->where('status',1)->select(['id', 'password', 'encrypt'])->first();
        $pass_server = PassServer::creatServer($password, $member->{'encrypt'});
        $new_pass = $pass_server->creatPassword();
        $ret = $member->update(['password' => $new_pass['password']]);
        if (empty($ret)) {
            return $this->apiResponseError('密码修改失败');
        } else {
            return $this->apiResponseSuccess('密码修改成功');
        }
    }


    /**
     * 修改登录密码
     * @return \Illuminate\Http\JsonResponse
     */
    function setPassword()
    {
        $old_password = request()->input('old_password', '123456');
        if (empty($old_password)) {
            return $this->apiResponseError('请输入旧密码');
        }
        $password = request()->input('password', '123456');
        $password = str_replace(' ', '', $password);
        if (empty($password)) {
            return $this->apiResponseError('请设置登录密码');
        }
        $pass_two = request()->input('pass_two', '123456');
        if ($password != $pass_two) {
            return $this->apiResponseError('两次密码输入不一致');
        }
        $member = Member::where('id', request()->member['id'])->where('status',1)->select(['id', 'password', 'encrypt'])->first();
        $pass_server = PassServer::creatServer($old_password, $member->{'encrypt'});
        if (!$pass_server->verifyPass($member->{'password'})) {
            return $this->apiResponseError('旧密码错误');
        }
        $pass_server->setPassword($password);
        $new_pass = $pass_server->creatPassword();
        $ret = $member->update(['password' => $new_pass['password']]);
        if (empty($ret)) {
            return $this->apiResponseError('密码修改失败');
        } else {
            return $this->apiResponseSuccess('密码修改成功');
        }
    }



    /**
     * 设置支付密码
     * @return \Illuminate\Http\JsonResponse
     */
    function setPayPass()
    {
        $password = request()->input('pay_pass', '123456');
        $password = str_replace(' ', '', $password);
        if (empty($password)) {
            return $this->apiResponseError('请设置登录密码');
        }
        $pass_two = request()->input('pass_two', '123456');
        if ($password != $pass_two) {
            return $this->apiResponseError('两次密码输入不一致');
        }
        if (!is_numeric($password) || strlen($password) != 6) {
            return $this->apiResponseError('支付密码必须为6为数字');
        }
        $member = Member::where('id', request()->member['id'])->where('status',1)->select(['id', 'password', 'encrypt', 'phone'])->first();
        $update=[];

        $code = request()->input('code', '1234');
        if (empty($code)) {
            return $this->apiResponseError('请输入验证码');
        }
        $ret = SmsServer::creatServer()->verifyCode($member->{'phone'}, $code, 'set_pay_pass');
        if (empty($ret)) {
            return $this->apiResponseError('验证码错误');
        }

        $pass_server = PassServer::creatServer($password, $member->{'encrypt'});
        $new_pass = $pass_server->creatPassword();
        $update['pay_pass']=$new_pass['password'];
        $update['encrypt']=$new_pass['encrypt'];
        $ret = $member->update($update);
        if (empty($ret)) {
            return $this->apiResponseError('支付密码修改失败');
        } else {
            MemberServer::creatServer()->delMemberCache($member->{'id'});
            return $this->apiResponseSuccess('支付密码修改成功');
        }
    }

    /**
     * 获取用户资产信息
     */
    function getMoneyInfo()
    {
        $member = Member::where('id', request()->member['id'])->where('status',1)->select(['id', 'money'])->first();
        return $this->apiResponseSuccess('获取成功', $member);
    }




    /**
     * 获取会员详情
     */
    function getMemberInfo()
    {
        $m_id = request()->member['id'];
        //弹幕广播
        $info['m_id'] = $m_id;

        $member = RedisDataServer::creatServer()->getData('member_' . $m_id, 'json');
        if (empty($member)  ) {
            $member = Member::where('id', $m_id)->where('status',1)->select(['id',  'money',  'phone', 'nickname', 'head_img', 'invite_code', 'level_id', 'sex','describe','recom_id'])->first();
            if (empty($member)) {
                return $this->apiResponseError('账户信息错误', 401);
            }
            //获取推荐关联信息
            $member->recomMember();
            $member->{'phone_num'} = $member->{'phone'};
            $member->{'money'} = CommonServer::creatServer()->setFormatNum($member->{'money'});;
            $member->{'head_img'} = CommonServer::creatServer()->ossCompress($member->{'head_img'}, 50, 2);
            if ($member->{'phone'}) {
                $member->{'phone'} = CommonServer::creatServer()->concealStr($member->{'phone'}, 0, 4, 4, 4);
            }
            $member->{'level_name'} = MemberServer::creatServer()->getLevelName($member->{'level_id'});
            $member->{'recommend_name'} = $member->recomMember->{'nickname'};
            RedisDataServer::creatServer()->setData('member_' . $m_id, $member, 'json', 30);
        }
        return $this->apiResponseSuccess('获取信息成功', $member);

    }



    /**
     * 保存会员信息
     * @return \Illuminate\Http\JsonResponse
     */
    function updateMemberInfo()
    {
        $nickname = CommonServer::creatServer()->filtrationStr('nickname');
        $sex = request()->input('sex', '');
        $head_img = request()->input('head_img', '');
        $update = compact('nickname', 'sex', 'head_img');
        $update = array_filter($update);
        if ($sex != '' && !in_array($sex, ['3', '1', '2','0'])) {
            return $this->apiResponseError('性别选择错误');
        }elseif ($sex==''){
            $update['sex']='0';
        }else{
            $update['sex']=$sex;
        }

        if (empty($update)) {
            return $this->apiResponseError('暂无可以更新的内容');
        }
        $m_id = request()->member['id'];
        $ret = Member::where('id', $m_id)->update($update);
        if ($ret) {
            $renew['group_type'] = 1;
            $renew['name'] = $nickname;
            $renew['logo'] = $head_img;
            //进入队列
            MemberServer::creatServer()->delMemberCache(request()->member['id']);
            return $this->apiResponseSuccess('信息保存成功');
        } else {
            return $this->apiResponseError('信息保存失败');
        }
    }





    /**
     * 获取推广团队基本信息
     * @return \Illuminate\Http\JsonResponse
     */
    function getTeamInfo()
    {
        $m_id = request()->member['id'];
        $member = Member::where('id', $m_id)->select(['id', 'nickname', 'head_img', 'recom_id'])->first();
        if (empty($member->{'recom_id'})) {
            $parent = ['id' => 0, 'nickname' => '', 'head_img' => ''];
        } else {
            $parent = Member::where('id', $member->{'recom_id'})->select(['id', 'nickname', 'head_img', 'recom_id'])->first();
        }
        $total_num = MemberClan::from('member_clans as c')
            ->leftJoin('members as m', 'm.id', '=', 'c.m_id')
            ->where('c.one_m_id', $m_id)
            ->where([['m.status',1], ['m.is_del',0]])
            ->count();
        return $this->apiResponseSuccess('获取数据成功', ['parent' => $parent, 'member' => $member, 'team_num' => $total_num]);


    }

    /**
     * 获取团队列表
     * @return \Illuminate\Http\JsonResponse
     */
    function getTeamList()
    {
        $type = request()->input('type', '1');
        $m_id = request()->member['id'];
        $where = [];
        if ($type == 1) {
            $where[] = ['c.one_m_id', $m_id];
        } elseif ($type == 2) {
            $where[] = ['c.two_m_id', $m_id];
        } else {
            $where[] = ['c.one_m_id', '=', $m_id, 'or'];
            $where[] = ['c.two_m_id', '=', $m_id, 'or'];
        }
        $list = MemberClan::from('member_clans as c')
            ->leftJoin('members as m', 'm.id', '=', 'c.m_id')
            ->where($where)
            ->where([['status',1], ['is_del',0]])
            ->select(['m.id', 'm.recom_id', 'nickname', 'head_img', 'm.created_at'])
            ->paginate(15);
        foreach ($list as $item) {
            $item->{'type'} = $item->{'recom_id'} == $m_id ? 1 : 2;
        }
        return $this->apiResponseSuccess('获取数据成功', ['total_num' => $list->total(), 'items' => $list->items()]);

    }






}