bab-icon/app/Servers/MemberServer.php

<?php


namespace App\Servers;

use App\Jobs\RelevanceJob;
use App\Jobs\UploadingImgJob;
use App\Models\ErrorRecord;
use App\Models\ImService;
use App\Models\Member;
use App\Models\MemberClan;
use App\Models\MemberOpenId;
use App\Models\MoneyDetail;
use App\Models\MoneyRecord;
use App\Models\Order;
use App\Models\Shop;
use App\Models\ShopBean;
use App\Models\ShopCommission;
use App\Models\ShopFans;
use App\Models\ShopMoney;
use App\Models\ShopSet;
use App\Models\ShopUser;
use Intervention\Image\Facades\Image;


/**
 * 会员
 */
class MemberServer
{

    /**
     * 错误信息
     * @var string
     */
    private $errorMsg = '';

    static private $server = '';

    private $level_arr = [
        0 => '系统',
        1 => '省级代理',
        2 => '市级代理',
        3 => '区级代理',
        4 => '分销商',
        5 => '实体店',
        6 => '自营店',
        7 => '厂家',
        8 => '会员',
    ];

    private $sex_arr = [
        1 => '男',
        2 => '女',
        3 => '保密',
    ];


    private function __construct()
    {

    }

    /**
     * 创建对象
     * @return MemberServer
     */
    static function creatServer()
    {
        if (empty(self::$server)) {
            self::$server = new MemberServer();
        }
        return self::$server;
    }

    /**
     * 获取对应类型名称
     * @param $level_id
     * @return string
     */
    public function getLevelName($level_id)
    {
        return empty($this->level_arr[$level_id]) ? '' : $this->level_arr[$level_id];
    }

    /**
     * 获取性别
     * @param $sex
     * @return string
     */
    public function getSexArr($sex)
    {
        return empty($this->sex_arr[$sex]) ? '' : $this->sex_arr[$sex];
    }

    /**
     * 注册会员
     * @param $mobile
     * @param $p_id
     * @param string $password
     * @param string $nickname
     * @param string $head_img
     * @param string $level_id
     * @return array|false
     */
    function register($mobile, $p_id, $password = '', $nickname = '', $head_img = '', $sex=0, $level_id = '8')
    {
        $member_info = [];
        $pass_server = PassServer::creatServer($password);
        if ($password) {
            $member_info = $pass_server->creatPassword();
        }
        $member_info['phone'] = $mobile;
        $member_info['invite_code'] = $pass_server->getInviteCode();
        $nickname=$this->emojiFilter($nickname);
        $member_info['nickname'] = empty($nickname) ? ('' . $member_info['invite_code']) : $nickname;

        $member_info['head_img'] = $head_img ?: 'https://jhnewshop.oss-cn-chengdu.aliyuncs.com/storage/attest/20210927/949e48fb7c286836097efdd4ba4d0bd9.jpg';
        $member_info['recom_id'] = $p_id;
        $member_info['status'] = 1;
        $member_info['level_id'] = $level_id;
        $member_info['describe'] = '';
        $member_info['source'] = 0;
        $member_info['sex'] = $sex;

        $member_info = Member::create($member_info);
        if (empty($member_info)) {
            return false;
        }
        //注册赠送消费金
        $consume_money=CommonServer::creatServer()->getConfigValue('consume_money');
        if($consume_money>0){
            MoneyDetailServer::creatServer()->write(2,5,$consume_money,1,$member_info->{'id'},'注册赠送消费金');
        }
        MemberClanServer::creatServer()->creatRelevance($member_info);
        $token_str = PassServer::creatServer()->getMemberToken($member_info->{'id'});
        Member::where('id', $member_info->{'id'})->update(['token_str' => $token_str]);
        return ['m_id' => $member_info->{'id'}, 'token' => $token_str];
    }

    /**
     * 获取团队信息
     * @param Member $member
     */
    function getTeamEarnings(Member $member)
    {


    }

    /**
     * 清除会员缓存
     * @param $m_id
     */
    function delMemberCache($m_id)
    {
        RedisDataServer::creatServer()->delData('member_' . $m_id);
        RedisDataServer::creatServer()->delData('login_' . $m_id);
        RedisDataServer::creatServer()->delData('my_shop_'.$m_id);
    }

    /**
     * 生成推广图
     * @param Member $member
     * @return string
     */
    function setShareImg(Member $member)
    {
        $share_img = public_path('code/qr_background.png');
        $member_share_img = public_path('code/code_img/' . $member->{'id'} . 'share_img.png');
        // create new Intervention Image
        $img = Image::make($share_img);
        $member_share_img = Image::make($member_share_img)->widen(240);
        $img->insert($member_share_img, 'top-left', 140, 335);
        $head_img = Image::make($member->{'head_img'})->resize(90, 90);
        $tx_bg = public_path('code/tx_bg.png');
        $tx_bg = Image::make($tx_bg)->widen(90)->heighten(90);
        $head_img->insert($tx_bg, 'top-left', 0, 0);
        $img->insert($head_img, 'top-left', 55, 159);
        $img->text($member->{'nickname'}, 150, 177, function ($font) {
            $font->file(public_path('/fonts/PINGFANG-A.ttf'));
            $font->color('#000000');
            $font->size(24);
        });

        $img->text('推荐码：' . $member->{'invite_code'}, 150, 217, function ($font) {
            $font->file(public_path('/fonts/PINGFANG-A.ttf'));
            $font->color('#6f6f6f');
            $font->size(20);
        });
        $share_img = 'code/share_img/' . date('Ymd') . '/';
        CommonServer::creatServer()->creatDir($share_img);
        $img->save(public_path($share_img . 'share_img' . $member->{'id'} . '.jpg'), 100);
        return $share_img . 'share_img' . $member->{'id'} . '.jpg';
    }

    /**
     * 微信登陆
     * @param $wx_info
     * @param $invite_code
     * @return array|false
     */
    function setWxOpen($wx_info, $invite_code = '')
    {
//        file_put_contents('a.txt', json_encode($wx_info));
        $m_id = MemberOpenId::where('openid', $wx_info['openid'])->where('type', 1)->value('m_id');
        if (empty($m_id)) {
            if ($invite_code) $p_id = Member::where('invite_code', $invite_code)->value('id');
            else{
                $shop_code=request()->input('shop_code');
                if($shop_code){
                    $p_id=Shop::where('shop_code', $shop_code)->value('m_id');
                }
            }
            if (empty($p_id)) $p_id = 1;
            $info = $this->register('', $p_id, 1, '', $wx_info['nickname'], $wx_info['headimgurl'], $wx_info['sex']);
            UploadingImgJob::dispatch($info['m_id'], $wx_info['headimgurl'])->onConnection('redis')->onQueue('uploading');
            MemberOpenId::create([
                'm_id' => $info['m_id'],
                'openid' => $wx_info['openid'],
                'unopenid' => '',
                'type' => '1',
            ]);
        } else {
            $token_str = PassServer::creatServer()->getMemberToken($m_id);
            Member::where('id', $m_id)->update(['token_str' => $token_str]);
            $info = ['m_id' => $m_id, 'token' => $token_str];
            RedisDataServer::creatServer()->setData('new_m_'.$m_id,['nickname'=>$wx_info['nickname'],'head_img'=>$wx_info['headimgurl']],'json',900);
        }
        return $info;
    }

    /**
     * 截取掉微信表情
     * @param $str
     * @return mixed|string
     */
    function emojiFilter($str)
    {
        if ($str) {
            $nickname = $str;
            $nickname = preg_replace('/[\x{1F600}-\x{1F64F}]/u', '', $nickname);
            $nickname = preg_replace('/[\x{1F300}-\x{1F5FF}]/u', '', $nickname);
            $nickname = preg_replace('/[\x{1F680}-\x{1F6FF}]/u', '', $nickname);
            $nickname = preg_replace('/[\x{2600}-\x{26FF}]/u', '', $nickname);
            $nickname = preg_replace('/[\x{2700}-\x{27BF}]/u', '', $nickname);
            $nickname = str_replace(array('"','\''), '', $nickname);
            return addslashes(trim($nickname));
        } else {
            $return = '';
        }
        return $return;

    }

    /**
     * 会员支付注册
     * @param $open_id
     * @param $shop_id
     * @param $pay_type
     * @return mixed
     */
    function payRegister($open_id, $shop_id, $pay_type)
    {

        //会员支付注册
        $m_id = MemberOpenId::where('openid', $open_id)->where('type', $pay_type)->value('m_id');
        $shop=Shop::where('id',$shop_id)->select(['status','m_id'])->first();
        $is_recom=0;
        $p_id = empty($shop->{'m_id'})?1:$shop->{'m_id'};
        if (empty($m_id)) {
            //当前open_id未注册则进行注册
            $is_recom = 1;
            $info = $this->register('', $p_id, $pay_type, '', '');
            MemberOpenId::create([
                'm_id' => $info['m_id'],
                'openid' => $open_id,
                'unopenid' => '',
                'type' => $pay_type,
            ]);
            $m_id = $info['m_id'];
            if ($pay_type == 1) {
                $user_info = WeixinServer::creatServer()->getUserInfo($open_id);
                if (!empty($user_info['headimgurl']) && !empty($user_info['nickname']) && !empty($user_info['sex'])) {
                    UploadingImgJob::dispatch($info['m_id'], $user_info['headimgurl'])->onConnection('redis')->onQueue('uploading');
                    Member::where('id', $m_id)->update(['nickname' => $user_info['nickname'], 'sex' => $user_info['sex']]);
                }

            } else {

            }
        }else{
            $m_pid=Member::where('id',$m_id)->value('recom_id');
            if($p_id==$m_pid && $p_id!=1){
                $is_recom=1;
            }
        }
//        $shop_status=Shop::where('id',$shop_id)->value('status');
        $shop_status=empty($shop->{'status'})?0:$shop->{'status'};
        if($shop_status!=1){
            return  false;
        }
        //店铺锁粉
        $max_num = ShopSet::where('shop_id', $shop_id)->value('fans_num');
        if (empty($max_num)) $max_num = 5000;
        $shop_fans_num = ShopFans::where('shop_id', $shop_id)->where('status','1')->count();
        if ($shop_fans_num < $max_num) {
            $fans_info = ShopFans::where('m_id', $m_id)->first();
            if (empty($fans_info)) {
                ShopFans::create([
                    'is_recom' => $is_recom,
                    'shop_id' => $shop_id,
                    'm_id' => $m_id
                ]);
            } elseif (empty($fans_info->{'shop_id'}) || $fans_info->{'status'}!=1) {
                $fans_info->update(['shop_id' => $shop_id,'status'=>1,'is_recom' => $is_recom]);
            }
        }
        //验证当前账户是否创建公益豆管理信息
        $num = ShopBean::where('shop_id', $shop_id)->where('m_id', $m_id)->count();
        if ($num <= 0) {
            ShopBean::create([
                'm_id' => $m_id,
                'shop_id' => $shop_id,
                'bean_money' => 0
            ]);
        }
        return $m_id;

    }

    /**
     * 检查是否是新用户
     * @param $m_id
     * @return bool
     */
    function checkNewMember($m_id){
        $res = Order::where('m_id',$m_id)->where('order_status','>',1)->where('order_status','<>',6)->count();
        if($res){
            return 0;
        }else{
            return 1;
        }
    }

    /**
     * 检查该用户是否绑定了店铺员工
     * @param $m_id
     * @return bool
     */
    function checkStaffBind($m_id){
        $res = ShopUser::where('m_id',$m_id)->where('is_del',0)->select(['id'])->first();
        if ($res) {
            return true;
        } else {
            return false;
        }
    }
}