zhuishuyun_quickapp/app/Modules/User/Services/QappUserService.php

<?php


namespace App\Modules\User\Services;

use App\Cache\Lock\LockCache;
use App\Consts\ErrorConst;
use App\Consts\QuickConst;
use App\Jobs\Push\NewUserPushMsgDelay;
use App\Jobs\QappTikTok\QappTikTokUserRequest;
use App\Jobs\QappTikTok\QappTikTokUser;
use App\Libs\Utils;
use App\Modules\Report\Services\ReportService;
use App\Modules\SendOrder\Services\SendOrderService;
use App\Modules\User\Models\QappPackage;
use App\Modules\User\Models\QappUser;
use App\Modules\User\Models\User;
use App\Modules\UserTask\Services\BaseTask;
use App\Modules\UserTask\Services\UserTaskService;
use Exception;
use Illuminate\Support\Facades\DB;
use Tymon\JWTAuth\Facades\JWTAuth;

/**
 *
 */
class QappUserService
{
    /**
     * 登录
     */
    public function login(array $data)
    {
        $codeVersion   = getProp($data, 'codeVersion');
        $lockToken     = '';
        $isNewRegister = false;
        $device_no     = $data['device_no'];
        $channel_id    = $this->findChannelId($data['package']);
        $qapp_user     = $this->getQAppUserByDeviceNo($device_no, $channel_id);
        if (!$qapp_user) {
            // 判断版本号，大于等于1.0.0才做处理
            if (version_compare($codeVersion, '1.0.0', '>=')) {
                // 加锁3秒，否则报错
                $lockToken = md5($device_no . ':' . $channel_id);
                $lock      = LockCache::getLock($lockToken, 3);
                if (!$lock) {
                    Utils::throwError(ErrorConst::QAPP_LOGIN_FREQUENTLY);
                }
            }

            myLog('login')->info('register', compact('codeVersion', 'device_no', 'channel_id', 'lockToken'));
            if($data['package'] == 'com.app.kyy.xnyd'){
                //return [];
            }
            // 初始化新用户
            $isNewRegister = true;
            $qapp_user     = $this->createQuickAppUser($data);
        }
        if ($qapp_user) {
            try {
                if(!isset($qapp_user->user) || empty($qapp_user->user)){
                    myLog('login')->info('undefined:qapp_user:user:error:device_no'.$device_no.' channel_id'.$channel_id.' time:'.date('Y-m-d H:i:s'));
                    usleep(500000);
                    $qapp_user = $this->getQAppUserByDeviceNo($device_no, $channel_id);
                }
                $user  = $qapp_user->user;
                $uid   = $user->id;
                $time  = strtotime("+1 month");
                $token = JWTAuth::fromUser($user);
                if ($data['send_order_id']) {
                    $result = SendOrderService::recordUserSendOrder($uid, $data['send_order_id']);
                    if($result){
                        UserService::setUserSendOrder((int)$uid, (int)$data['send_order_id']);
                    }
                }
                // 新注册统计
                if ($isNewRegister && $qapp_user) {
                    // 注册统计
                    QappAddDeskTopService::incrAddDeskTop($uid, QuickConst::FIELD_REGISTER);
                }
                myLog('login')->info('uid：'.$uid.'-token:'.$token);
                return compact('token', 'time', 'uid');
            } catch (\Exception $e) {
                myLog('login')->info('getQAppUserByDeviceNo:error:'.$e->getMessage());
            }
        } else {
            return [];
        }
    }

    public function getGolableUser()
    {
        $qapp_user = app()->make('qapp_user');
        return $qapp_user;
    }

    /**
     * 注销用户
     * @param $uid
     * @return bool
     */
    public function getLogOff($uid)
    {
        $user = QappUser::getUserByUid($uid);
        if($user && $user->status == 1){
            $res = QappUser::where('uid',$uid)->update(['status' => 0, 'updated_at' => date('Y-m-d H:i:s')]);
            if(!$res){
                return false;
            }
        }
        return true;
    }

    /**
     * 绑定手机号
     * 多个账号可以绑定一个手机号
     */
    public function bindPhone(int $uid, string $phone, string $version = "1.0")
    {
        $qapp_user = QappUser::where('uid', $uid)->first();
        if ($qapp_user->phone && $qapp_user->phone != $phone) {
            return false;
        } else {
            try {
                DB::beginTransaction();
                if (!$qapp_user->phone) {
                    $reward = 100;
                    if ($version == "1.0") {
                        User::where('id', $uid)->update(
                            [
                                'balance'        => DB::raw('balance+' . $reward),
                                'reward_balance' => DB::raw('reward_balance+' . $reward)
                            ]
                        );
                    } else {
                        UserTaskService::addUserTaskQueue($uid, BaseTask::bind_phone, UserTaskService::add_trigger);
                    }
                }
                $qapp_user->phone = $phone;
                $qapp_user->save();
                DB::commit();
            } catch (Exception $e) {
                myLog('bindPhone')->error($e->getMessage());
            }
            return true;
        }
    }

    public function setGolableUser(int $uid, string $package)
    {
//        \Log::info('setGolableUser:'.$uid);
        $user_info                     = $this->getQAppUserByUid($uid, $package);
        $qapp_user                     = app()->make('qapp_user');
        $qapp_user->id                 = $user_info->id;
        $qapp_user->uid                = $user_info->uid;
        $qapp_user->send_order_id      = $user_info->send_order_id;
        $qapp_user->device_no          = $user_info->device_no;
        $qapp_user->device_info        = $user_info->device_info;
        $qapp_user->phone              = $user_info->phone;
        $qapp_user->user               = $user_info->user;
        $qapp_user->app_pay_merchat_id = $user_info->app_pay_merchat_id;
        $qapp_user->h5_pay_merchat_id  = $user_info->h5_pay_merchat_id;
        $qapp_user->ali_pay_merchat_id = $user_info->ali_pay_merchat_id;
        $qapp_user->status             = $user_info->status;
//        \Log::info('setGolableUser_uid:'.$uid.' data:'.json_encode($this->getGolableUser()));
    }

    /**
     * 根据设备号获取快应用用户信息
     */
    public function getQAppUserByDeviceNo(string $device_no, int $channel_id)
    {
        $qapp_user = QappUser::where('device_no', $device_no)->where('channel_id', $channel_id)->first();
        if ($qapp_user) {
            $user            = User::find($qapp_user->uid);
            $qapp_user->user = $user;
            if(empty($user->id)){
                myLog('qapp_user_register')->info($device_no.'--'.$channel_id.'--'.json_encode($qapp_user));
            }
        }else{
            myLog('qapp_user_register')->info('qapp_user:no:'.$device_no.'--'.$channel_id);
        }
        return $qapp_user;
    }

    /**
     * 根据uid获取快应用用户信息
     * @param int    $uid
     * @param string $package
     * @return mixed
     */
    public function getQAppUserByUid(int $uid, string $package = '')
    {
        $qapp_user = QappUser::where('uid', $uid)->first();
        if ($qapp_user) {
            $user                     = User::find($uid);
            $qapp_user->user          = $user;
            $qapp_user->send_order_id = UserService::getUserSendOrder($uid);

            // 针对聚裕的包无法支付的问题（注册时传入了仙女阅读的包名，导致支付时取的支付信息不一致）
            if ($package && $package === 'com.juyu.kuaiying.rmyq') {
                $package_info = QappPackage::where('package', $package)->first();
            } else {
                $package_info = QappPackage::where('channel_id', $user->distribution_channel_id)->first();
            }

            // 支付id
            $qapp_user->app_pay_merchat_id = $package_info->app_pay_merchat_id;
            $qapp_user->h5_pay_merchat_id  = $package_info->h5_pay_merchat_id;
            $qapp_user->ali_pay_merchat_id = $package_info->ali_pay_merchat_id;
        }
        return $qapp_user;
    }


    /**
     * 创建快应用用户信息
     */
    public function createQuickAppUser(array $data)
    {
        try {
            DB::beginTransaction();
            $user            = $this->createUser($data);
            $channel_id      = $user->distribution_channel_id;
            $qapp_user       = QappUser::firstOrCreate([
                'device_no'  => $data['device_no'],
                'channel_id' => $channel_id,
            ], [
                'imei'        => $data['imei'],
                'androidid'   => $data['androidid'],
                'mac'         => $data['mac'],
                'uid'         => $user->id,
                'device_info' => $data['device_info'],
            ]);
            $qapp_user->user = $user;
            if (empty($user->id) || empty($qapp_user->id)) {
                myLog('qapp_user_register')->info(json_encode($data));
                DB::rollback();
                return false;
            }
            DB::commit();
            $this->syncHandle($user, $data);
            return $qapp_user;

        } catch (Exception $e) {
            DB::rollback();
            myLog('create_user')->error($e->getMessage());
        }
    }

    /**
     * 新用户异步处理数据
     */
    private function syncHandle(User $user, array $data)
    {
        // 队列处理回传业务
        try {
            $tikTokRegisterRequest                = new QappTikTokUserRequest();
            $tikTokRegisterRequest->ip            = $user->register_ip;
            $tikTokRegisterRequest->device_no     = $data['device_no'];
            $tikTokRegisterRequest->mac           = $data['mac'];
            $tikTokRegisterRequest->channel_id    = $user->distribution_channel_id;
            $tikTokRegisterRequest->uid           = $user->id;
            $tikTokRegisterRequest->register_time = $user->created_at->format('Y-m-d H:i:s');
            $tikTokRegisterRequest->send_order_id = $data['send_order_id'];
            myLog('qapp_register')->info('', compact('tikTokRegisterRequest'));
            $start = time();
            // 回传业务
            $job = new QappTikTokUser($tikTokRegisterRequest);
            dispatch($job->onConnection('redis_queue')->onQueue('{qapp_tiktok_user_register_queue}'));
            $time = time() - $start;
            if ($time >= 1 ){
                myLog('mq-put-timeout')->info("注册qapp_tiktok_user_register_queue-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 270行");
            }
            $start = time();
            UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);

            $job = new NewUserPushMsgDelay($user->id);
            dispatch($job->onConnection('redis_queue')->onQueue('{new_user_push_msg}'));
            $time = time() - $start;
            if ($time >= 1 ){
                myLog('mq-put-timeout')->info("注册new_user_push_msg-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 279行");
            }
            // 同步数据
            $user->channel_id = $user->distribution_channel_id;
            // ReportService::reportRegister($user); // 取消上报
        }catch (Exception $exception){
            // \Log::info('login_fail_user_syncHandle_error_data:',$data);
            // \Log::info('login_fail_user_syncHandle_error_msg:'.$exception->getMessage());
        }
    }

    private function findChannelId(string $package)
    {
        $channel_id = env('QUICKAPP_SITE');
        if ($package) {
            $package_info = QappPackage::where('package', $package)->first();
            $channel_id   = $package_info ? $package_info->channel_id : $channel_id;
        }
        return $channel_id;
    }

    /**
     * 创建用户
     */
    private function createUser(array $data): User
    {
        $openid                  = $data['device_no'];
        $unionid                 = $data['device_no'];
        $register_ip             = _getIp();
        $distribution_channel_id = $this->findChannelId($data['package']);
        $send_order_id           = $data['send_order_id'];
        $unique_key              = compact('unionid', 'distribution_channel_id');
        $data                    = compact('openid', 'register_ip', 'send_order_id');
        return User::firstOrCreate($unique_key, $data);
    }
}