xyzshop/helper/async/register.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2017/11/2
 * Time: 下午7:57
 */

namespace async;

use search;
use push_helper;
use bonus;
use bonus_helper;
use member_info;
use Log;
use Exception;
use account_helper;

class register extends IAsync
{
    private $cur_user;
    private $cur_info;
    private $last_inviter;

    const max_inviters = 10;

    public function __construct($user,$inviter)
    {
        $mod_member = Model('member');

        $minfo = $mod_member->getMemberInfo(['member_id' => $user], '*', true);
        $this->cur_user = $user;
        $this->cur_info = new member_info($minfo);
        if($this->cur_info->binded_wechat() == false) {
            throw new Exception('为防止欺诈，需要微信授权登录');
        }
        $this->last_inviter = $inviter;
    }

    private function inviters()
    {
        if($this->last_inviter <= 0){
            return [];
        }
        else
        {
            $inviters = [];
            $parent_inviters = search\relation_client::instance()->fetch_inviters(['user_id' => $this->last_inviter]);
            $inviters[] = $this->last_inviter;
            foreach ($parent_inviters as $inviter) {
                $inviters[] = $inviter;
            }
            return $inviters;
        }
    }

    public function run()
    {
        if($this->cur_info->rewared_inviter()) return false;

        if($this->tag_rewarded($this->cur_user))
        {
            $unionid = $this->cur_info->unionid();
            $mod_member = Model('member');
            $count = $mod_member->getMemberCount(['member_wxunionid' => $unionid]);
            if($count <= 1) {
                $this->reward_user();
                $inviters = $this->inviters();
                $this->notify_inviter($inviters);
            }
            $this->add_invitee($this->last_inviter);
        }
        return true;
    }

    private function notify_inviter($inviters)
    {
        if(empty($inviters)) return false;

        $level = 0;
        $ex_invitee = $this->cur_user;
        foreach ($inviters as $inviter)
        {
            $this->reward_inviter($inviter,$level);
            $invitees = search\relation_client::instance()->fetch_invitees(['user_id' => $inviter]);
            $invitees = $this->ex_user($invitees,$ex_invitee);
            //$this->reward_invitees($inviter,$invitees,$level);
            $ex_invitee = $inviter;
            $level += 1;
        }
        return true;
    }

    //给Level 级的邀请者发奖励
    private function reward_inviter($inviter, $level)
    {
        $inviter_info = new member_info($inviter);
        if($inviter_info->invitees() > register::max_inviters) return false;

        $params = bonus\parameters::guide_inviter($this->cur_info->nickname(),$level);
        foreach ($params as $param)
        {
            $type = bonus_helper::create_type_input($param);
            $money = $type->getTotal_amount();
            $rate  = $type->bonus_rate();
            $ret = bonus_helper::make_bonus($param,$param['rate_money']);

            if($ret != false)
            {
                $type_sn = $ret['type_sn'];
                $fSuccess = bonus_helper::send($type_sn,[$inviter]);
                if($fSuccess == false) {
                    Log::record("send bonus error: type_sn={$type_sn}",Log::DEBUG);
                }
                else {
                    push_helper::inviter_bonus($inviter,$this->cur_user,$level + 1,$money,$rate,$type_sn);
                    $this->add_reward($inviter,$money);
                }
            }
            else {
                return false;
            }
        }
        return true;
    }

    private function reward_invitees($inviter, $invitees, $level)
    {
        if(empty($invitees)) return false;
        $inviter_info = new member_info($inviter);

        if($level > 1) return false;

        $num = count($invitees);
        $params = bonus\parameters::guide_invitee($inviter_info->nickname(),$this->cur_info->nickname(),$level,$num);
        foreach ($params as $param)
        {
            $type = bonus_helper::create_type_input($param);
            $money = $type->getTotal_amount();
            $rate  = $type->bonus_rate();
            $ret = bonus_helper::make_bonus($param,$param['rate_money']);

            if($ret != false)
            {
                $type_sn = $ret['type_sn'];
                bonus_helper::send($type_sn,$invitees);

                $i = 0;
                foreach ($invitees as $invitee)
                {
                    $amount = $money / $num;
                    $this->add_reward($invitee,$amount);
                    if($i < self::max_level_pushs) {
                        push_helper::invitee_bonus($inviter, $invitee, $this->cur_info, $level + 1, $amount, $rate, $type_sn);
                    }
                    $i++;
                }
            } else {
                return false;
            }
        }
        return true;
    }

    private function reward_user()
    {
        if($this->last_inviter > 0)
        {
            $params = bonus\parameters::user_reigster_fixed();
            foreach ($params as $param) {
                $type = bonus_helper::create_type_input($param);
                $money = $type->getTotal_amount();
                $ret = bonus_helper::make_bonus($param, $param['rate_money']);

                if ($ret != false) {
                    $type_sn = $ret['type_sn'];
                    bonus_helper::send($type_sn, [$this->cur_user]);
                    push_helper::register_bonus($this->cur_user, $money, $type_sn);
                } else {
                    return false;
                }
            }
        }
        else {
            $type_sn = account_helper::invite_bonus(0);
            if($type_sn != false) {
                bonus_helper::send($type_sn, [$this->cur_user]);
                push_helper::register_bonus($this->cur_user, 100, $type_sn);
            }
        }

        return true;
    }
}