twong329/crmeb/subscribes/UserSubscribe.php

<?php

namespace crmeb\subscribes;

use app\models\user\User;
use app\models\user\WechatUser;
use think\facade\Cookie;
use app\admin\model\system\SystemAttachment;
use app\models\user\UserLevel;
use think\facade\Log;

/**
 * 用户事件
 * Class UserSubscribe
 * @package crmeb\subscribes
 */
class UserSubscribe
{

    public function handle()
    {

    }

    /**
     * 管理员后台给用户添加金额 AdminAddMoney
     * @param $event
     */
    public function onAdminAddMoney($event)
    {
        list($user, $money) = $event;

        Log::warning('EVENT admin add money ' . $money . ' to ' . $user['uid']);
    }

    /**
     * 微信授权成功后 WechatOauthAfter
     * @param $event
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function onWechatOauthAfter($event)
    {
        list($openid, $wechatInfo, $spreadId, $login_type) = $event;

        if (!User::be(['uid' => $spreadId])) $spreadId = 0;

        $wechatInfo['nickname'] = filter_emoji($wechatInfo['nickname']);
        Cookie::set('is_login', 1);
        if (isset($wechatInfo['unionid']) && $wechatInfo['unionid'] != '' && ($uid = WechatUser::where('unionid', $wechatInfo['unionid'])->where('user_type', '<>', 'h5')->value('uid'))) {
            WechatUser::edit($wechatInfo, $uid, 'uid');
            if (!User::be(['uid' => $uid])) {
                $wechatInfo = WechatUser::where('uid', $uid)->find();
                User::setWechatUser($wechatInfo, $spreadId);
            } else {
                if ($login_type) $wechatInfo['login_type'] = $login_type;
                User::updateWechatUser($wechatInfo, $uid);
            }
        } else if ($uid = WechatUser::where(['openid' => $wechatInfo['openid']])->where('user_type', '<>', 'h5')->value('uid')) {
            WechatUser::edit($wechatInfo, $uid, 'uid');
            if ($login_type) $wechatInfo['login_type'] = $login_type;
            User::updateWechatUser($wechatInfo, $uid);
        } else {
            if (isset($wechatInfo['subscribe_scene'])) unset($wechatInfo['subscribe_scene']);
            if (isset($wechatInfo['qr_scene'])) unset($wechatInfo['qr_scene']);
            if (isset($wechatInfo['qr_scene_str'])) unset($wechatInfo['qr_scene_str']);
//            $isLogin = request()->isLogin();
//            $bind = false;
//            if($isLogin){
//                $loginUid = request()->user();
//                $isUser = $loginUid ? request()->tokenData()->type === 'user' : false;
//                $bind = $loginUid && $isUser && !$loginUid->openid && !User::be(['openid' => $wechatInfo['openid']]);
//                //微信用户绑定 h5用户
//                if ($bind) {
//                    $wechatInfo['uid'] = $loginUid->uid;
//                };
//            }
            $wechatInfo = WechatUser::create($wechatInfo);
//            if ($isLogin && $bind)
//                User::where('uid', $wechatInfo['uid'])
//                    ->limit(1)->update(['openid' => $wechatInfo['openid']]);
//            else
            User::setWechatUser($wechatInfo, $spreadId);
        }
        $uid = WechatUser::openidToUid($openid, 'openid');
        // 设置推广关系
        User::setSpread($spreadId, $uid);

        User::where('uid', $uid)
            ->limit(1)->update(['last_time' => time(), 'last_ip' => app('request')->ip()]);
    }

    /**
     * 用户登录成功 UserLogin
     * @param $event
     */
    public function onUserLogin($event)
    {
        list($userInfo) = $event;
        $request = app('request');
        User::edit(['last_time' => time(), 'last_ip' => $request->ip()], $userInfo->uid, 'uid');

        Log::debug('EVENT user ' . $userInfo->uid . ' login.');
    }

    /**
     * 检查是否能成为会员 UserLevelAfter
     * @param $event
     */
    public function onUserLevelAfter($event)
    {
        list($userUid) = $event;
        try {
            if(UserLevel::setLevelComplete($userUid)) {
                event('UserLevelUp', $event);
            }
        } catch (\Exception $e) {

        }
    }
    
    /**
     * 用户升级成功 UserLevelUp
     */
    public function onUserLevelUp($event)
    {
        list($userUid) = $event;
        $userinfo = User::get($userUid);

        Log::debug("EVENT user " . $userUid . ' update to level ' . $userinfo['level']);
    }

    /**
     * 新用戶注冊 UserRegistered
     */
    public function onUserRegistered($event)
    {
        list('user' => $user) = $event;

        Log::debug('EVENT new user registered:' . $user['uid']);
    }

    /**
     * 首次下訂單 UserFirstOrder
     */
    public function onUserFirstOrder($event)
    {
        list('order' => $order) = $event;

        Log::debug('EVENT user ' . $order['uid'] . ' first order:' . $order['id']);
    }

    /**
     * 用戶提現 UserRequestWithdrawal
     */
    public function onUserRequestWithdrawal($event)
    {
        list('user' => $user, 'info' => $info) = $event;

        Log::debug('EVENT user ' . $user['uid'] . ' withdraw ' . mapped_implode(',', $info));
    }

    /**
     * 首次挖礦得到弊 UserFirstDig
     */
    public function onUserFirstDig($event)
    {

    }

    /**
     * 用户提币 UserWithdrawalCoin
     */
    public function onUserWithdrawalCoin($event)
    {

    }

    /**
     * 用户参加活动 UserActivity
     */
    public function onUserActivity($event)
    {
        
    }
}