agent_server/Modules/InnerApi/Controllers/UsersController.php

<?php
/**
 * 描述.
 *
 * @author nj
 * @date   2021-07-10 16:41
 */

namespace Modules\InnerApi\Controllers;

use App\Models\Mongo\UsersModel;
use App\Models\Mysql\ChannelModel;
use Modules\InnerApi\Requests\UserIncRequest;
use Modules\InnerApi\Requests\UserLoginRequest;
use Modules\InnerApi\Requests\UserUpRequest;
use Modules\InnerApi\Responses\SuccessCommonResponse;
use Modules\InnerApi\Services\UserService;

class UsersController extends BaseController
{
    /**
     * 新用户.
     * @param UserIncRequest $request
     * @param UserService $service
     * @return SuccessCommonResponse
     */
    public function inc(UserIncRequest $request, UserService $service)
    {

        $arrJson = $this->getJsonData();
        if (!empty($arrJson)) {
            foreach ($arrJson as $k => $item) {
                $item['agent_uid'] = '';
                if (!empty($item['share_code']) && empty($item['invite_uid'])) {
                    // 兼容一下，置顶定义混乱了, share_code, invite_uid.
                    $item['invite_uid'] = $item['share_code'];
                }
                    // 渠道是空字符串，代表官方包.
                    $item['is_deduction'] = 0;
                } else {
                    $channelInfo = ChannelModel::where(['uid' => $item['channel_uid'], 'mom_app_uid' => $item['mom_app_uid']])->first(['agent_uid']);
                    if (!empty($channelInfo)) {
                        $item['agent_uid'] = $channelInfo->agent_uid;
                        // 扣量.
                        $item = $service->oneRandDeduction($item);
                    }
                }
                $arrJson[$k] = $item;
            }
            $users = $service->inc($arrJson);
        }

        return new SuccessCommonResponse();
    }

    /**
     * 登录.
     * @param UserLoginRequest $request
     * @param UserService $service
     * @return SuccessCommonResponse
     */
    public function login(UserLoginRequest $request, UserService $service)
    {
        $arrJson = $this->getJsonData();
        if (!empty($arrJson)) {
            foreach ($arrJson as &$item) {
                $item['agent_uid'] = '';
                if (!empty($item['channel_uid'])) {
                    $channelInfo = ChannelModel::where(['uid' => $item['channel_uid'], 'mom_app_uid' => $item['mom_app_uid']])->first(['agent_uid']);
                    if (!empty($channelInfo)) {
                        $item['agent_uid'] = $channelInfo->agent_uid;
                    }
                }
            }
            $service->login($arrJson);
        }

        return new SuccessCommonResponse();
    }

    /**
     * 用户信息修改
     * @param UserUpRequest $request
     * @param UserService $service
     * @return SuccessCommonResponse
     */
    public function up(UserUpRequest $request, UserService $service)
    {
        $arrJson = $this->getJsonData();
        if (!empty($arrJson)) {
            foreach ($arrJson as $item) {
                UsersModel::query()->where(['uid' => $item['uid'], 'user_id' => $item['user_id'], 'device_no' => $item['device_no']])->update(['mobile' => $item['mobile']]);
            }
        }

        return new SuccessCommonResponse();
    }
}