zhongshen_project/app/model/member/Register.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com
 * =========================================================
 */

namespace app\model\member;

use addon\wechat\model\Message as WechatMessage;
use app\model\BaseModel;
use app\model\message\Sms;
use addon\coupon\model\Coupon;
use app\model\system\Stat;

/**
 * 登录
 *
 * @author Administrator
 *
 */
class Register extends BaseModel
{

    /**
     * 用户名密码注册(必传username， password),之前检测重复性,判断用户名是否为手机，邮箱
     * @param $data
     * @return array|mixed
     */
    public function usernameRegister($data)
    {
        $examine_username_exit = $this->usernameExist($data[ 'username' ], $data[ 'site_id' ]);
        if ($examine_username_exit) return $this->error('', '用户名已存在');
        $this->cancelBind($data);
        $member_level = new MemberLevel();
        $member_level_info = $member_level->getMemberLevelInfo([ [ 'site_id', '=', $data[ 'site_id' ] ], [ 'level_type', '=', 0 ], [ 'growth', '=', 0 ] ], '*')[ 'data' ];
        if (isset($data[ 'source_member' ]) && !empty($data[ 'source_member' ])) {
            $count = model("member")->getCount([ [ 'member_id', '=', $data[ 'source_member' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
            if (!$count) $data[ 'source_member' ] = 0;
        }

        $nickname = $data[ 'username' ];
        if (isset($data[ 'nickname' ]) && !empty($data[ 'nickname' ])) {
            $nickname = preg_replace_callback('/./u',
                function(array $match) {
                    return strlen($match[ 0 ]) >= 4 ? '' : $match[ 0 ];
                },
                $data[ 'nickname' ]);
        }

        $data_reg = [
            'site_id' => $data[ 'site_id' ],
            'source_member' => isset($data[ 'source_member' ]) ? $data[ 'source_member' ] : 0,
            'username' => $data[ 'username' ],
            'nickname' => $nickname, //默认昵称为用户名
            'password' => data_md5($data[ 'password' ]),
            'qq_openid' => isset($data[ 'qq_openid' ]) ? $data[ 'qq_openid' ] : '',
            'wx_openid' => isset($data[ 'wx_openid' ]) ? $data[ 'wx_openid' ] : '',
            'weapp_openid' => isset($data[ 'weapp_openid' ]) ? $data[ 'weapp_openid' ] : '',
            'wx_unionid' => isset($data[ 'wx_unionid' ]) ? $data[ 'wx_unionid' ] : '',
            'ali_openid' => isset($data[ 'ali_openid' ]) ? $data[ 'ali_openid' ] : '',
            'baidu_openid' => isset($data[ 'baidu_openid' ]) ? $data[ 'baidu_openid' ] : '',
            'toutiao_openid' => isset($data[ 'toutiao_openid' ]) ? $data[ 'toutiao_openid' ] : '',
            'headimg' => isset($data[ 'headimg' ]) ? $data[ 'headimg' ] : '',
            'member_level' => !empty($member_level_info) ? $member_level_info[ 'level_id' ] : 0,
            'member_level_name' => !empty($member_level_info) ? $member_level_info[ 'level_name' ] : '',
            'is_member' => !empty($member_level_info) ? 1 : 0,
            'member_time' => !empty($member_level_info) ? time() : 0,
            'reg_time' => time(),
            'login_time' => time(),
            'last_login_time' => time(),
            'login_type' => $data[ 'app_type' ] ?? '',
            'login_type_name' => $data[ 'app_type_name' ] ?? '',
        ];
        $res = model("member")->add($data_reg);
        if ($res) {
            // 发放等级奖励
            if (!empty($member_level_info)) {
                $member_account_model = new MemberAccount();
                //赠送红包
                if ($member_level_info[ 'send_balance' ] > 0) {
                    $balance = $member_level_info[ 'send_balance' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'balance', $balance, 'upgrade', '会员升级得红包' . $balance, '会员等级升级奖励');
                }
                //赠送积分
                if ($member_level_info[ 'send_point' ] > 0) {
                    $send_point = $member_level_info[ 'send_point' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'point', $send_point, 'upgrade', '会员升级得积分' . $send_point, '会员等级升级奖励');
                }
                //给用户发放优惠券
                $coupon_model = new Coupon();
                $coupon_array = empty($member_level_info[ 'send_coupon' ]) ? [] : explode(',', $member_level_info[ 'send_coupon' ]);
                if (!empty($coupon_array)) {
                    foreach ($coupon_array as $k => $v) {
                        $coupon_model->receiveCoupon($v, $data[ 'site_id' ], $res, 3);
                    }
                }
            }

            //会员注册事件
            event("MemberRegister", [ 'member_id' => $res, 'site_id' => $data[ 'site_id' ] ]);
            $data[ 'member_id' ] = $res;
            $this->pullHeadimg($data);
            //更新最后访问时间
            Member::modifyLastVisitTime($res);
            //添加统计
            $stat = new Stat();
            $stat->switchStat([ 'type' => 'add_member', 'data' => [ 'member_count' => 1, 'site_id' => $data[ 'site_id' ] ] ]);
            return $this->success($res);
        } else {
            return $this->error();
        }
    }

    /**
     * 手机号密码注册(必传mobile， password),之前检测重复性
     * @param $data
     * @return array|mixed
     */
    public function mobileRegister($data)
    {
        $examine_mobile_exit = $this->mobileExist($data[ 'mobile' ], $data[ 'site_id' ]);
        if ($examine_mobile_exit) return $this->error('', '手机号已存在');
        $this->cancelBind($data);
        $member_level = new MemberLevel();
        $member_level_info = $member_level->getMemberLevelInfo([ [ 'site_id', '=', $data[ 'site_id' ] ], [ 'level_type', '=', 0 ], [ 'growth', '=', 0 ] ], '*')[ 'data' ];
        if (isset($data[ 'source_member' ]) && !empty($data[ 'source_member' ])) {
            $count = model("member")->getCount([ [ 'member_id', '=', $data[ 'source_member' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
            if (!$count) $data[ 'source_member' ] = 0;
        }
        $nickname = $data[ 'mobile' ];
        if (isset($data[ 'nickname' ]) && !empty($data[ 'nickname' ])) {
            $nickname = preg_replace_callback('/./u',
                function(array $match) {
                    return strlen($match[ 0 ]) >= 4 ? '' : $match[ 0 ];
                },
                $data[ 'nickname' ]);
        }

        $data_reg = [
            'site_id' => $data[ 'site_id' ],
            'source_member' => isset($data[ 'source_member' ]) ? $data[ 'source_member' ] : 0,
            'mobile' => $data[ 'mobile' ],
            'nickname' => $nickname, //默认昵称为手机号
            'password' => isset($data[ 'password' ]) && !empty($data[ 'password' ]) ? data_md5($data[ 'password' ]) : '',
            'qq_openid' => isset($data[ 'qq_openid' ]) ? $data[ 'qq_openid' ] : '',
            'wx_openid' => isset($data[ 'wx_openid' ]) ? $data[ 'wx_openid' ] : '',
            'weapp_openid' => isset($data[ 'weapp_openid' ]) ? $data[ 'weapp_openid' ] : '',
            'wx_unionid' => isset($data[ 'wx_unionid' ]) ? $data[ 'wx_unionid' ] : '',
            'ali_openid' => isset($data[ 'ali_openid' ]) ? $data[ 'ali_openid' ] : '',
            'baidu_openid' => isset($data[ 'baidu_openid' ]) ? $data[ 'baidu_openid' ] : '',
            'toutiao_openid' => isset($data[ 'toutiao_openid' ]) ? $data[ 'toutiao_openid' ] : '',
            'headimg' => isset($data[ 'headimg' ]) ? $data[ 'headimg' ] : '',
            'member_level' => !empty($member_level_info) ? $member_level_info[ 'level_id' ] : 0,
            'member_level_name' => !empty($member_level_info) ? $member_level_info[ 'level_name' ] : '',
            'is_member' => !empty($member_level_info) ? 1 : 0,
            'member_time' => !empty($member_level_info) ? time() : 0,
            'reg_time' => time(),
            'login_time' => time(),
            'last_login_time' => time(),
            'is_edit_username' => 1,
            'login_type' => $data[ 'app_type' ] ?? '',
            'login_type_name' => $data[ 'app_type_name' ] ?? '',
            'username' => isset($data[ 'username' ]) ? $data[ 'username' ] : $this->createRandUsername($data[ 'site_id' ])
        ];

        $res = model("member")->add($data_reg);
        if ($res) {
            if (!empty($member_level_info)) {
                $member_account_model = new MemberAccount();
                //赠送红包
                if ($member_level_info[ 'send_balance' ] > 0) {
                    $balance = $member_level_info[ 'send_balance' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'balance', $balance, 'upgrade', '会员升级得红包' . $balance, '会员等级升级奖励');
                }
                //赠送积分
                if ($member_level_info[ 'send_point' ] > 0) {
                    $send_point = $member_level_info[ 'send_point' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'point', $send_point, 'upgrade', '会员升级得积分' . $send_point, '会员等级升级奖励');
                }
                //给用户发放优惠券
                $coupon_model = new Coupon();
                $coupon_array = empty($member_level_info[ 'send_coupon' ]) ? [] : explode(',', $member_level_info[ 'send_coupon' ]);
                if (!empty($coupon_array)) {
                    foreach ($coupon_array as $k => $v) {
                        $coupon_model->receiveCoupon($v, $data[ 'site_id' ], $res, 3);
                    }
                }
            }

            //会员注册事件
            event("MemberRegister", [ 'member_id' => $res, 'site_id' => $data[ 'site_id' ] ]);
            $data[ 'member_id' ] = $res;
            $this->pullHeadimg($data);
            //更新最后访问时间
            Member::modifyLastVisitTime($res);
            //添加统计
            $stat = new Stat();
            $stat->switchStat([ 'type' => 'add_member', 'data' => [ 'member_count' => 1, 'site_id' => $data[ 'site_id' ] ] ]);

            return $this->success($res);
        } else {
            return $this->error();
        }
    }

    /**
     * 第三方注册
     * @param $data
     */
    public function authRegister($data)
    {
        $this->cancelBind($data);

        $member_level = new MemberLevel();
        $member_level_info = $member_level->getMemberLevelInfo([ [ 'site_id', '=', $data[ 'site_id' ] ], [ 'level_type', '=', 0 ], [ 'growth', '=', 0 ] ], '*')[ 'data' ];

        if (isset($data[ 'source_member' ]) && !empty($data[ 'source_member' ])) {
            $count = model("member")->getCount([ [ 'member_id', '=', $data[ 'source_member' ] ], [ 'site_id', '=', $data[ 'site_id' ] ] ]);
            if (!$count) $data[ 'source_member' ] = 0;
        }

        $username = $this->createRandUsername($data[ 'site_id' ]);
        $nickname = $username;
        if (isset($data[ 'nickName' ]) && !empty($data[ 'nickName' ])) {
            $nickname = preg_replace_callback('/./u',
                function(array $match) {
                    return strlen($match[ 0 ]) >= 4 ? '' : $match[ 0 ];
                },
                $data[ 'nickName' ]);
        }

        $data_reg = [
            'site_id' => $data[ 'site_id' ],
            'source_member' => isset($data[ 'source_member' ]) ? $data[ 'source_member' ] : 0,
            'username' => $username,
            'nickname' => $nickname,
            'password' => '',
            'qq_openid' => isset($data[ 'qq_openid' ]) ? $data[ 'qq_openid' ] : '',
            'wx_openid' => isset($data[ 'wx_openid' ]) ? $data[ 'wx_openid' ] : '',
            'weapp_openid' => isset($data[ 'weapp_openid' ]) ? $data[ 'weapp_openid' ] : '',
            'wx_unionid' => isset($data[ 'wx_unionid' ]) ? $data[ 'wx_unionid' ] : '',
            'ali_openid' => isset($data[ 'ali_openid' ]) ? $data[ 'ali_openid' ] : '',
            'baidu_openid' => isset($data[ 'baidu_openid' ]) ? $data[ 'baidu_openid' ] : '',
            'toutiao_openid' => isset($data[ 'toutiao_openid' ]) ? $data[ 'toutiao_openid' ] : '',
            'headimg' => isset($data[ 'avatarUrl' ]) ? $data[ 'avatarUrl' ] : '',
            'member_level' => !empty($member_level_info) ? $member_level_info[ 'level_id' ] : 0,
            'member_level_name' => !empty($member_level_info) ? $member_level_info[ 'level_name' ] : '',
            'is_member' => !empty($member_level_info) ? 1 : 0,
            'member_time' => !empty($member_level_info) ? time() : 0,
            'reg_time' => time(),
            'login_time' => time(),
            'last_login_time' => time(),
            'is_edit_username' => 1,
            'login_type' => $data[ 'app_type' ] ?? '',
            'login_type_name' => $data[ 'app_type_name' ] ?? '',
        ];
        $res = model("member")->add($data_reg);
        if ($res) {
            if (!empty($member_level_info)) {
                $member_account_model = new MemberAccount();
                //赠送红包
                if ($member_level_info[ 'send_balance' ] > 0) {
                    $balance = $member_level_info[ 'send_balance' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'balance', $balance, 'upgrade', '会员升级得红包' . $balance, '会员等级升级奖励');
                }
                //赠送积分
                if ($member_level_info[ 'send_point' ] > 0) {
                    $send_point = $member_level_info[ 'send_point' ];
                    $member_account_model->addMemberAccount($data[ 'site_id' ], $res, 'point', $send_point, 'upgrade', '会员升级得积分' . $send_point, '会员等级升级奖励');
                }
                //给用户发放优惠券
                $coupon_model = new Coupon();
                $coupon_array = empty($member_level_info[ 'send_coupon' ]) ? [] : explode(',', $member_level_info[ 'send_coupon' ]);
                if (!empty($coupon_array)) {
                    foreach ($coupon_array as $k => $v) {
                        $coupon_model->receiveCoupon($v, $data[ 'site_id' ], $res, 3);
                    }
                }
            }

            //会员注册事件
            event("MemberRegister", [ 'member_id' => $res, 'site_id' => $data[ 'site_id' ] ]);
            $data[ 'member_id' ] = $res;
            $this->pullHeadimg($data);
            //更新最后访问时间
            Member::modifyLastVisitTime($res);
            //添加统计
            $stat = new Stat();
//            $stat->addShopStat([ 'member_count' => 1, 'site_id' => $data[ 'site_id' ] ]);
            $stat->switchStat([ 'type' => 'add_member', 'data' => [ 'member_count' => 1, 'site_id' => $data[ 'site_id' ] ] ]);

            return $this->success($res);
        } else {
            return $this->error();
        }
    }

    /**
     * 生成随机用户名
     * @param $site_id
     */
    private function createRandUsername($site_id)
    {
        $usernamer = 'u_' . random_keys(10);
        $count = model('member')->getCount([ [ 'username', '=', $usernamer ], [ 'site_id', '=', $site_id ] ]);
        if ($count) {
            $usernamer = $this->createRandUsername($site_id);
            return $usernamer;
        } else {
            return $usernamer;
        }
    }

    /**
     * 清除账号绑定(用户重新进行绑定)
     * @param $data
     * @return array
     */
    public function cancelBind($data)
    {

        $data = [
            'qq_openid' => isset($data[ 'qq_openid' ]) ? $data[ 'qq_openid' ] : '',
            'wx_openid' => isset($data[ 'wx_openid' ]) ? $data[ 'wx_openid' ] : '',
            'weapp_openid' => isset($data[ 'weapp_openid' ]) ? $data[ 'weapp_openid' ] : '',
            'wx_unionid' => isset($data[ 'wx_unionid' ]) ? $data[ 'wx_unionid' ] : '',
            'ali_openid' => isset($data[ 'ali_openid' ]) ? $data[ 'ali_openid' ] : '',
            'baidu_openid' => isset($data[ 'baidu_openid' ]) ? $data[ 'baidu_openid' ] : '',
            'toutiao_openid' => isset($data[ 'toutiao_openid' ]) ? $data[ 'toutiao_openid' ] : '',
            'site_id' => $data[ 'site_id' ]
        ];
        if (!empty($data[ 'qq_openid' ])) {
            model("member")->update([ 'qq_openid' => '' ], [ [ 'qq_openid', '=', $data[ 'qq_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'wx_openid' ])) {
            model("member")->update([ 'wx_openid' => '' ], [ [ 'wx_openid', '=', $data[ 'wx_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'weapp_openid' ])) {
            model("member")->update([ 'weapp_openid' => '' ], [ [ 'weapp_openid', '=', $data[ 'weapp_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'wx_unionid' ])) {
            model("member")->update([ 'wx_unionid' => '' ], [ [ 'wx_unionid', '=', $data[ 'wx_unionid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'ali_openid' ])) {
            model("member")->update([ 'ali_openid' => '' ], [ [ 'ali_openid', '=', $data[ 'ali_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'baidu_openid' ])) {
            model("member")->update([ 'baidu_openid' => '' ], [ [ 'baidu_openid', '=', $data[ 'baidu_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        if (!empty($data[ 'toutiao_openid' ])) {
            model("member")->update([ 'toutiao_openid' => '' ], [ [ 'toutiao_openid', '=', $data[ 'toutiao_openid' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        }
        return $this->success();

    }

    /**
     * 重置用户微信openid
     * @param $data
     * @return array
     */
    public function wxopenidBind($data)
    {
        $res = model("member")->update([ 'wx_openid' => $data[ 'wx_openid' ] ], [ [ 'member_id', '=', $data[ 'member_id' ] ], [ 'site_id', '=', $data[ 'site_id' ] ], [ 'is_delete', '=', 0 ] ]);
        if ($res) {
            return $this->success($res);
        } else {
            return $this->error();
        }
    }

    /**
     * 检测用户存在性(用户名)
     * @param $username
     * @return int
     */
    public function usernameExist($username, $site_id)
    {
        $member_info = model("member")->getInfo(
            [
                [ 'username|mobile', '=', $username ],
                [ 'site_id', '=', $site_id ],
                [ 'is_delete', '=', 0 ]
            ], 'member_id'
        );
        if (!empty($member_info)) {
            return 1;
        } else {
            return 0;
        }
    }

    /**
     * 检测用户存在性(用户名) 存在返回1
     * @param $mobile
     * @return int
     */
    public function mobileExist($mobile, $site_id)
    {
        $member_info = model("member")->getInfo([
            [ 'mobile', '=', $mobile ],
            [ 'site_id', '=', $site_id ],
            [ 'is_delete', '=', 0 ] ], 'member_id');
        if (!empty($member_info)) {
            return 1;
        } else {
            return 0;
        }
    }

    /**
     * 检测用户存在性(wx_openid) 存在返回1 新增2021.06.18
     * @param $mobile
     * @return int
     */
    public function openidExist($mobile, $site_id)
    {
        $member_info = model("member")->getInfo(
            [
                [ 'mobile', '=', $mobile ],
                [ 'site_id', '=', $site_id ],
                [ 'is_delete', '=', 0 ]
            ], 'wx_openid'
        );
        if (!empty($member_info[ 'wx_openid' ])) {
            return 1;
        } else {
            return 0;
        }
    }

    /**
     * 获取用户ID 新增2021.06.18
     * @param $mobile
     * @return int
     */
    public function getMemberId($mobile, $site_id)
    {
        $member_info = model("member")->getInfo(
            [
                [ 'mobile', '=', $mobile ],
                [ 'site_id', '=', $site_id ],
                [ 'is_delete', '=', 0 ]
            ], 'member_id'
        );
        if (!empty($member_info)) {
            return $member_info[ 'member_id' ];
        } else {
            return 0;
        }
    }

    /**
     * 注册发送验证码
     * @param $data
     * @return array|mixed|void
     */
    public function registerCode($data)
    {
        //发送短信
        $sms_model = new Sms();
        $var_parse = array (
            "code" => $data[ "code" ],//验证码
        );
        $data[ "sms_account" ] = $data[ "mobile" ] ?? '';//手机号
        $data[ "var_parse" ] = $var_parse;
        $sms_result = $sms_model->sendMessage($data);
        if ($sms_result[ "code" ] < 0)
            return $sms_result;

        return $this->success();
    }

    /**
     * 注册成功通知
     * @param $data
     * @return array|mixed|void
     */
    public function registerSuccess($data)
    {

        $member_model = new Member();
        $member_info_result = $member_model->getMemberInfo([ [ "member_id", "=", $data[ "member_id" ] ] ], "username,mobile,email,reg_time,wx_openid,last_login_type,nickname");
        $member_info = $member_info_result[ "data" ];
        $name = $member_info[ "nickname" ] == '' ? $member_info[ "mobile" ] : $member_info[ "nickname" ];
        //发送短信
        $var_parse = [
            "shopname" => replaceSpecialChar($data[ 'site_info' ][ 'site_name' ]),   //商城名称
            "username" => replaceSpecialChar($name),    //会员名称
        ];
        $data[ "sms_account" ] = $member_info[ "mobile" ] ?? '';//手机号
        $data[ "var_parse" ] = $var_parse;
        $sms_model = new Sms();
        $sms_result = $sms_model->sendMessage($data);
//        if ($sms_result["code"] < 0) return $sms_result;

        //发送模板消息
        $wechat_model = new WechatMessage();
        $data[ "openid" ] = $member_info[ "wx_openid" ];

        $data[ "template_data" ] = [
            'keyword1' => $member_info[ "nickname" ],
            'keyword2' => time_to_date($member_info[ "reg_time" ]),
        ];
        $data[ "page" ] = '';
        $wechat_model->sendMessage($data);

        return $this->success();
    }

    /**
     * 拉取用户头像
     * @param unknown $info
     */
    private function pullHeadimg($data)
    {
        if (!empty($data[ 'headimg' ]) && is_url($data[ 'headimg' ])) {
            $url = __ROOT__ . '/api/member/pullheadimg?member_id=' . $data[ 'member_id' ];
            http($url, 1);
        }
    }
}