mirror of
https://github.com/kuaifan/dootask.git
synced 2026-01-12 00:48:11 +00:00
921 lines
34 KiB
PHP
Executable File
921 lines
34 KiB
PHP
Executable File
<?php
|
||
|
||
namespace App\Http\Controllers\Api;
|
||
|
||
use App\Models\AbstractModel;
|
||
use App\Models\Meeting;
|
||
use App\Models\Project;
|
||
use App\Models\UmengAlias;
|
||
use App\Models\User;
|
||
use App\Models\UserEmailVerification;
|
||
use App\Models\UserTransfer;
|
||
use App\Models\WebSocket;
|
||
use App\Models\WebSocketDialog;
|
||
use App\Models\WebSocketDialogMsg;
|
||
use App\Module\AgoraIO\AgoraTokenGenerator;
|
||
use App\Module\Base;
|
||
use Arr;
|
||
use Cache;
|
||
use Captcha;
|
||
use Carbon\Carbon;
|
||
use Request;
|
||
|
||
/**
|
||
* @apiDefine users
|
||
*
|
||
* 会员
|
||
*/
|
||
class UsersController extends AbstractController
|
||
{
|
||
/**
|
||
* @api {get} api/users/login 01. 登录、注册
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName login
|
||
*
|
||
* @apiParam {String} type 类型
|
||
* - login:登录（默认）
|
||
* - reg:注册
|
||
* @apiParam {String} email 邮箱
|
||
* @apiParam {String} password 密码
|
||
* @apiParam {String} [code] 登录验证码
|
||
* @apiParam {String} [invite] 注册邀请码
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function login()
|
||
{
|
||
$type = trim(Request::input('type'));
|
||
$email = trim(Request::input('email'));
|
||
$password = trim(Request::input('password'));
|
||
$isRegVerify = Base::settingFind('emailSetting', 'reg_verify') === 'open';
|
||
if ($type == 'reg') {
|
||
$setting = Base::setting('system');
|
||
if ($setting['reg'] == 'close') {
|
||
return Base::retError('未开放注册');
|
||
} elseif ($setting['reg'] == 'invite') {
|
||
$invite = trim(Request::input('invite'));
|
||
if (empty($invite) || $invite != $setting['reg_invite']) {
|
||
return Base::retError('请输入正确的邀请码');
|
||
}
|
||
}
|
||
$user = User::reg($email, $password);
|
||
if ($isRegVerify) {
|
||
UserEmailVerification::userEmailSend($user);
|
||
return Base::retError('注册成功，请验证邮箱后登录', ['code' => 'email']);
|
||
}
|
||
} else {
|
||
$needCode = !Base::isError(User::needCode($email));
|
||
if ($needCode) {
|
||
$code = trim(Request::input('code'));
|
||
if (empty($code)) {
|
||
return Base::retError('请输入验证码', ['code' => 'need']);
|
||
}
|
||
if (!Captcha::check($code)) {
|
||
return Base::retError('请输入正确的验证码', ['code' => 'need']);
|
||
}
|
||
}
|
||
//
|
||
$retError = function ($msg) use ($email) {
|
||
Cache::forever("code::" . $email, "need");
|
||
$needCode = !Base::isError(User::needCode($email));
|
||
$needData = ['code' => $needCode ? 'need' : 'no'];
|
||
return Base::retError($msg, $needData);
|
||
};
|
||
$user = User::whereEmail($email)->first();
|
||
if (empty($user)) {
|
||
return $retError('帐号或密码错误');
|
||
}
|
||
if ($user->password != Base::md52($password, $user->encrypt)) {
|
||
return $retError('帐号或密码错误');
|
||
}
|
||
//
|
||
if (in_array('disable', $user->identity)) {
|
||
return $retError('帐号已停用...');
|
||
}
|
||
Cache::forget("code::" . $email);
|
||
if ($isRegVerify && $user->email_verity === 0) {
|
||
UserEmailVerification::userEmailSend($user);
|
||
return Base::retError('您还没有验证邮箱，请先登录邮箱通过验证邮件验证邮箱', ['code' => 'email']);
|
||
}
|
||
}
|
||
//
|
||
$array = [
|
||
'login_num' => $user->login_num + 1,
|
||
'last_ip' => Base::getIp(),
|
||
'last_at' => Carbon::now(),
|
||
'line_ip' => Base::getIp(),
|
||
'line_at' => Carbon::now(),
|
||
];
|
||
$user->updateInstance($array);
|
||
$user->save();
|
||
User::token($user);
|
||
//
|
||
if (!Project::withTrashed()->whereUserid($user->userid)->wherePersonal(1)->exists()) {
|
||
Project::createProject([
|
||
'name' => Base::Lang('个人项目'),
|
||
'desc' => Base::Lang('注册时系统自动创建项目，你可以自由删除。'),
|
||
'personal' => 1,
|
||
], $user->userid);
|
||
}
|
||
//
|
||
return Base::retSuccess($type == 'reg' ? "注册成功" : "登录成功", $user);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/login/needcode 02. 是否需要验证码
|
||
*
|
||
* @apiDescription 用于判断是否需要登录验证码
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName login__needcode
|
||
*
|
||
* @apiParam {String} email 用户名
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1需要、0不需要）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function login__needcode()
|
||
{
|
||
return User::needCode(trim(Request::input('email')));
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/login/codeimg 03. 验证码图片
|
||
*
|
||
* @apiDescription 用于判断是否需要登录验证码
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName login__codeimg
|
||
*
|
||
* @apiSuccess {Image} data 返回数据（直接输出图片）
|
||
*/
|
||
public function login__codeimg()
|
||
{
|
||
return Captcha::create();
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/login/codejson 04. 验证码json
|
||
*
|
||
* @apiDescription 用于判断是否需要登录验证码
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName login__codejson
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function login__codejson()
|
||
{
|
||
$captcha = Captcha::create('default', true);
|
||
return Base::retSuccess('请求成功', $captcha);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/reg/needinvite 05. 是否需要邀请码
|
||
*
|
||
* @apiDescription 用于判断注册是否需要邀请码
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName reg__needinvite
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function reg__needinvite()
|
||
{
|
||
return Base::retSuccess('success', [
|
||
'need' => Base::settingFind('system', 'reg') == 'invite'
|
||
]);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/info 06. 获取我的信息
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName info
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
* @apiSuccessExample {json} data:
|
||
{
|
||
"userid": 1,
|
||
"identity": [ ],
|
||
"az": "",
|
||
"email": "admin@admin.com",
|
||
"nickname": "admin",
|
||
"userimg": "",
|
||
"login_num": 10,
|
||
"changepass": 0,
|
||
"last_ip": "127.0.0.1",
|
||
"last_at": "2021-06-01 12:00:00",
|
||
"line_ip": "127.0.0.1",
|
||
"line_at": "2021-06-01 12:00:00",
|
||
"created_ip": "",
|
||
}
|
||
*/
|
||
public function info()
|
||
{
|
||
$user = User::auth();
|
||
User::token($user);
|
||
//
|
||
$data = $user->toArray();
|
||
$data['nickname_original'] = $user->getRawOriginal('nickname');
|
||
return Base::retSuccess('success', $data);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/editdata 07. 修改自己的资料
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName editdata
|
||
*
|
||
* @apiParam {Object} [userimg] 会员头像（地址）
|
||
* @apiParam {String} [nickname] 昵称
|
||
* @apiParam {String} [profession] 职位/职称
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function editdata()
|
||
{
|
||
$user = User::auth();
|
||
$data = Request::all();
|
||
$user->checkSystem(1);
|
||
//头像
|
||
if (Arr::exists($data, 'userimg')) {
|
||
$userimg = Request::input('userimg');
|
||
if ($userimg) {
|
||
$userimg = is_array($userimg) ? $userimg[0]['path'] : $userimg;
|
||
$user->userimg = Base::unFillUrl($userimg);
|
||
} else {
|
||
$user->userimg = Base::unFillUrl($user->getUserimgAttribute(null));
|
||
}
|
||
}
|
||
//昵称
|
||
if (Arr::exists($data, 'nickname')) {
|
||
$nickname = trim(Request::input('nickname'));
|
||
if ($nickname && mb_strlen($nickname) < 2) {
|
||
return Base::retError('昵称不可以少于2个字');
|
||
} elseif (mb_strlen($nickname) > 20) {
|
||
return Base::retError('昵称最多只能设置20个字');
|
||
} else {
|
||
$user->nickname = $nickname;
|
||
}
|
||
}
|
||
//职位/职称
|
||
if (Arr::exists($data, 'profession')) {
|
||
$profession = trim(Request::input('profession'));
|
||
if ($profession && mb_strlen($profession) < 2) {
|
||
return Base::retError('职位/职称不可以少于2个字');
|
||
} elseif (mb_strlen($profession) > 20) {
|
||
return Base::retError('职位/职称最多只能设置20个字');
|
||
} else {
|
||
$user->profession = $profession;
|
||
}
|
||
}
|
||
//
|
||
$user->save();
|
||
User::token($user);
|
||
User::AZUpdate($user->userid);
|
||
return Base::retSuccess('修改成功', $user);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/editpass 08. 修改自己的密码
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName editpass
|
||
*
|
||
* @apiParam {String} oldpass 旧密码
|
||
* @apiParam {String} newpass 新密码
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function editpass()
|
||
{
|
||
$user = User::auth();
|
||
$user->checkSystem();
|
||
//
|
||
$oldpass = trim(Request::input('oldpass'));
|
||
$newpass = trim(Request::input('newpass'));
|
||
if ($oldpass == $newpass) {
|
||
return Base::retError('新旧密码一致');
|
||
}
|
||
User::passwordPolicy($newpass);
|
||
//
|
||
$verify = User::whereUserid($user->userid)->wherePassword(Base::md52($oldpass, User::token2encrypt()))->count();
|
||
if (empty($verify)) {
|
||
return Base::retError('请填写正确的旧密码');
|
||
}
|
||
//
|
||
$user->encrypt = Base::generatePassword(6);
|
||
$user->password = Base::md52($newpass, $user->encrypt);
|
||
$user->changepass = 0;
|
||
$user->save();
|
||
User::token($user);
|
||
return Base::retSuccess('修改成功', $user);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/search 09. 搜索会员列表
|
||
*
|
||
* @apiDescription 搜索会员列表
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName searchinfo
|
||
*
|
||
* @apiParam {Object} keys 搜索条件
|
||
* - keys.key 昵称、邮箱关键字
|
||
* - keys.disable 0-排除禁止（默认），1-含禁止，2-仅禁止
|
||
* - keys.project_id 在指定项目ID
|
||
* - keys.no_project_id 不在指定项目ID
|
||
* @apiParam {Object} sorts 排序方式
|
||
* - sorts.az 按字母：asc|desc
|
||
* @apiParam {Number} updated_time 在这个时间戳之后更新的
|
||
*
|
||
* @apiParam {Number} [take] 获取数量，10-100
|
||
* @apiParam {Number} [page] 当前页，默认:1（赋值分页模式，take参数无效）
|
||
* @apiParam {Number} [pagesize] 每页显示数量，默认:10，最大:100
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function search()
|
||
{
|
||
$builder = User::select(['userid', 'email', 'nickname', 'profession', 'userimg', 'az', 'line_at', 'disable_at']);
|
||
//
|
||
$keys = Request::input('keys');
|
||
$sorts = Request::input('sorts');
|
||
$updatedTime = intval(Request::input('updated_time'));
|
||
$keys = is_array($keys) ? $keys : [];
|
||
$sorts = is_array($sorts) ? $sorts : [];
|
||
//
|
||
if ($keys['key']) {
|
||
$builder->where(function($query) use ($keys) {
|
||
$query->where("email", "like", "%{$keys['key']}%")
|
||
->orWhere("nickname", "like", "%{$keys['key']}%");
|
||
});
|
||
}
|
||
if (intval($keys['disable']) == 0) {
|
||
$builder->whereNull("disable_at");
|
||
} elseif (intval($keys['disable']) == 2) {
|
||
$builder->whereNotNull("disable_at");
|
||
}
|
||
if ($updatedTime > 0) {
|
||
$builder->where("updated_at", ">=", Carbon::createFromTimestamp($updatedTime));
|
||
}
|
||
if (intval($keys['project_id']) > 0) {
|
||
$builder->whereIn('userid', function ($query) use ($keys) {
|
||
$query->select('userid')->from('project_users')->where('project_id', $keys['project_id']);
|
||
});
|
||
}
|
||
if (intval($keys['no_project_id']) > 0) {
|
||
$builder->whereNotIn('userid', function ($query) use ($keys) {
|
||
$query->select('userid')->from('project_users')->where('project_id', $keys['no_project_id']);
|
||
});
|
||
}
|
||
if (in_array($sorts['az'], ['asc', 'desc'])) {
|
||
$builder->orderBy('az', $sorts['az']);
|
||
}
|
||
//
|
||
if (Request::exists('page')) {
|
||
$list = $builder->orderBy('userid')->paginate(Base::getPaginate(100, 10));
|
||
} else {
|
||
$list = $builder->orderBy('userid')->take(Base::getPaginate(100, 10, 'take'))->get();
|
||
}
|
||
return Base::retSuccess('success', $list);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/basic 10. 获取指定会员基础信息
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName basic
|
||
*
|
||
* @apiParam {Number} userid 会员ID(多个格式：jsonArray，一次最多50个)
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function basic()
|
||
{
|
||
$userid = Request::input('userid');
|
||
$array = Base::json2array($userid);
|
||
if (empty($array)) {
|
||
$array[] = $userid;
|
||
}
|
||
if (count($array) > 50) {
|
||
return Base::retError('一次最多只能获取50条数据');
|
||
}
|
||
$retArray = [];
|
||
foreach ($array AS $id) {
|
||
$basic = User::userid2basic($id);
|
||
if ($basic) {
|
||
$retArray[] = $basic;
|
||
}
|
||
}
|
||
return Base::retSuccess('success', $retArray);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/lists 11. 会员列表（限管理员）
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName lists
|
||
*
|
||
* @apiParam {Object} [keys] 搜索条件
|
||
* - keys.key 邮箱/昵称/职位（赋值后keys.email、keys.nickname、keys.profession失效）
|
||
* - keys.email 邮箱
|
||
* - keys.nickname 昵称
|
||
* - keys.profession 职位
|
||
* - keys.identity 身份（如：admin、noadmin）
|
||
* - keys.disable 是否离职
|
||
* - yes: 仅离职
|
||
* - all: 全部
|
||
* - 其他值: 仅在职（默认）
|
||
* - keys.email_verity 邮箱是否认证
|
||
* - yes: 已认证
|
||
* - no: 未认证
|
||
* - 其他值: 全部（默认）
|
||
*
|
||
* @apiParam {Number} [page] 当前页，默认:1
|
||
* @apiParam {Number} [pagesize] 每页显示数量，默认:20，最大:50
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function lists()
|
||
{
|
||
User::auth('admin');
|
||
//
|
||
$builder = User::select(['*', 'nickname as nickname_original']);
|
||
//
|
||
$keys = Request::input('keys');
|
||
if (is_array($keys)) {
|
||
if ($keys['key']) {
|
||
if (str_contains($keys['key'], "@")) {
|
||
$builder->where("email", "like", "%{$keys['key']}%");
|
||
} else {
|
||
$builder->where(function($query) use ($keys) {
|
||
$query->where("email", "like", "%{$keys['key']}%")
|
||
->orWhere("nickname", "like", "%{$keys['key']}%")
|
||
->orWhere("profession", "like", "%{$keys['key']}%");
|
||
});
|
||
}
|
||
} else {
|
||
if ($keys['email']) {
|
||
$builder->where("email", "like", "%{$keys['email']}%");
|
||
}
|
||
if ($keys['nickname']) {
|
||
$builder->where("nickname", "like", "%{$keys['nickname']}%");
|
||
}
|
||
if ($keys['profession']) {
|
||
$builder->where("profession", "like", "%{$keys['profession']}%");
|
||
}
|
||
}
|
||
if ($keys['identity']) {
|
||
if (Base::leftExists($keys['identity'], "no")) {
|
||
$builder->where("identity", "not like", "%," . Base::leftDelete($keys['identity'], 'no') . ",%");
|
||
} else {
|
||
$builder->where("identity", "like", "%,{$keys['identity']},%");
|
||
}
|
||
}
|
||
if ($keys['disable'] === 'yes') {
|
||
$builder->whereNotNull('disable_at');
|
||
} elseif ($keys['disable'] !== 'all') {
|
||
$builder->whereNull('disable_at');
|
||
}
|
||
if ($keys['email_verity'] === 'yes') {
|
||
$builder->whereEmailVerity(1);
|
||
} elseif ($keys['email_verity'] === 'no') {
|
||
$builder->whereEmailVerity(0);
|
||
}
|
||
} else {
|
||
$builder->whereNull('disable_at');
|
||
}
|
||
$list = $builder->orderByDesc('userid')->paginate(Base::getPaginate(50, 20));
|
||
//
|
||
return Base::retSuccess('success', $list);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/operation 12. 操作会员（限管理员）
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName operation
|
||
*
|
||
* @apiParam {Number} userid 会员ID
|
||
* @apiParam {String} [type] 操作
|
||
* - setadmin 设为管理员
|
||
* - clearadmin 取消管理员
|
||
* - setdisable 设为离职（需要参数 disable_time、transfer_userid）
|
||
* - cleardisable 取消离职
|
||
* - delete 删除会员
|
||
* @apiParam {String} [password] 新的密码
|
||
* @apiParam {String} [nickname] 昵称
|
||
* @apiParam {String} [profession] 职位
|
||
* @apiParam {String} [disable_time] 离职时间
|
||
* @apiParam {String} [transfer_userid] 离职交接人
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function operation()
|
||
{
|
||
$user = User::auth('admin');
|
||
//
|
||
$data = Request::all();
|
||
$userid = intval($data['userid']);
|
||
$type = $data['type'];
|
||
//
|
||
$userInfo = User::find($userid);
|
||
if (empty($userInfo)) {
|
||
return Base::retError('会员不存在或已被删除');
|
||
}
|
||
$userInfo->checkSystem(1);
|
||
//
|
||
$upArray = [];
|
||
$transferUser = null;
|
||
switch ($type) {
|
||
case 'setadmin':
|
||
$upArray['identity'] = array_diff($userInfo->identity, ['admin']);
|
||
$upArray['identity'][] = 'admin';
|
||
break;
|
||
|
||
case 'clearadmin':
|
||
$upArray['identity'] = array_diff($userInfo->identity, ['admin']);
|
||
break;
|
||
|
||
case 'setdisable':
|
||
if ($userInfo->userid === $user->userid) {
|
||
return Base::retError('不能操作自己离职');
|
||
}
|
||
$upArray['identity'] = array_diff($userInfo->identity, ['disable']);
|
||
$upArray['identity'][] = 'disable';
|
||
$upArray['disable_at'] = Carbon::parse($data['disable_time']);
|
||
$transferUserid = is_array($data['transfer_userid']) ? $data['transfer_userid'][0] : $data['transfer_userid'];
|
||
$transferUser = User::find(intval($transferUserid));
|
||
if (empty($transferUser)) {
|
||
return Base::retError('请选择正确的交接人');
|
||
}
|
||
if ($transferUser->userid === $userInfo->userid) {
|
||
return Base::retError('不能移交给自己');
|
||
}
|
||
if (in_array('disable', $transferUser->identity)) {
|
||
return Base::retError('交接人已离职，请选择另一个交接人');
|
||
}
|
||
break;
|
||
|
||
case 'cleardisable':
|
||
$upArray['identity'] = array_diff($userInfo->identity, ['disable']);
|
||
$upArray['disable_at'] = null;
|
||
break;
|
||
|
||
case 'delete':
|
||
if ($userInfo->userid === $user->userid) {
|
||
return Base::retError('不能删除自己');
|
||
}
|
||
$userInfo->deleteUser();
|
||
break;
|
||
}
|
||
if (isset($upArray['identity'])) {
|
||
$upArray['identity'] = "," . implode(",", $upArray['identity']) . ",";
|
||
}
|
||
// 密码
|
||
if (Arr::exists($data, 'password')) {
|
||
$password = trim($data['password']);
|
||
User::passwordPolicy($password);
|
||
$upArray['encrypt'] = Base::generatePassword(6);
|
||
$upArray['password'] = Base::md52($password, $upArray['encrypt']);
|
||
$upArray['changepass'] = 1;
|
||
}
|
||
// 昵称
|
||
if (Arr::exists($data, 'nickname')) {
|
||
$nickname = trim($data['nickname']);
|
||
if ($nickname && mb_strlen($nickname) < 2) {
|
||
return Base::retError('昵称不可以少于2个字');
|
||
} elseif (mb_strlen($nickname) > 20) {
|
||
return Base::retError('昵称最多只能设置20个字');
|
||
} else {
|
||
$upArray['nickname'] = $nickname;
|
||
}
|
||
}
|
||
// 职位/职称
|
||
if (Arr::exists($data, 'profession')) {
|
||
$profession = trim($data['profession']);
|
||
if ($profession && mb_strlen($profession) < 2) {
|
||
return Base::retError('职位/职称不可以少于2个字');
|
||
} elseif (mb_strlen($profession) > 20) {
|
||
return Base::retError('职位/职称最多只能设置20个字');
|
||
} else {
|
||
$upArray['profession'] = $profession;
|
||
}
|
||
}
|
||
if ($upArray) {
|
||
AbstractModel::transaction(function() use ($type, $upArray, $userInfo, $transferUser) {
|
||
$userInfo->updateInstance($upArray);
|
||
$userInfo->save();
|
||
if ($type === 'setdisable') {
|
||
$userTransfer = UserTransfer::createInstance([
|
||
'original_userid' => $userInfo->userid,
|
||
'new_userid' => $transferUser->userid,
|
||
]);
|
||
$userTransfer->save();
|
||
$userTransfer->start();
|
||
}
|
||
});
|
||
}
|
||
//
|
||
return Base::retSuccess('修改成功', $userInfo);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/email/verification 13. 邮箱验证
|
||
*
|
||
* @apiDescription 不需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName email__verification
|
||
*
|
||
* @apiParam {String} code 验证参数
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function email__verification()
|
||
{
|
||
$data = Request::input();
|
||
// 表单验证
|
||
Base::validator($data, [
|
||
'code.required' => '验证码不能为空',
|
||
]);
|
||
//
|
||
$res = UserEmailVerification::whereCode($data['code'])->first();
|
||
if (empty($res)) {
|
||
return Base::retError('无效连接,请重新注册');
|
||
}
|
||
|
||
// 如果已经校验过
|
||
if (intval($res->status) === 1)
|
||
return Base::retError('链接已经使用过', ['code' => 2]);
|
||
|
||
$oldTime = Carbon::parse($res->created_at)->timestamp;
|
||
$time = Base::Time();
|
||
|
||
// 30分钟失效
|
||
if (abs($time - $oldTime) > 1800) {
|
||
return Base::retError("链接已失效，请重新登录/注册");
|
||
}
|
||
UserEmailVerification::whereCode($data['code'])->update([
|
||
'status' => 1
|
||
]);
|
||
User::whereUserid($res->userid)->update([
|
||
'email_verity' => 1
|
||
]);
|
||
|
||
return Base::retSuccess('绑定邮箱成功');
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/umeng/alias 14. 设置友盟别名
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName umeng__alias
|
||
*
|
||
* @apiParam {String} alias 别名
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function umeng__alias()
|
||
{
|
||
$data = Request::input();
|
||
// 表单验证
|
||
Base::validator($data, [
|
||
'alias.required' => '别名不能为空',
|
||
'alias.between:2,20' => '别名的长度在2-20个字符',
|
||
]);
|
||
//
|
||
$agent = strtolower(Request::server('HTTP_USER_AGENT'));
|
||
if (str_contains($agent, 'android')) {
|
||
$platform = 'android';
|
||
} elseif (str_contains($agent, 'iphone') || str_contains($agent, 'ipad')) {
|
||
$platform = 'ios';
|
||
} else {
|
||
return Base::retError('设备类型错误');
|
||
}
|
||
//
|
||
$user = User::auth();
|
||
$inArray = [
|
||
'userid' => $user->userid,
|
||
'alias' => $data['alias'],
|
||
'platform' => $platform,
|
||
];
|
||
if (UmengAlias::where($inArray)->exists()) {
|
||
return Base::retSuccess('别名已存在');
|
||
}
|
||
$row = UmengAlias::createInstance($inArray);
|
||
if ($row->save()) {
|
||
return Base::retSuccess('添加成功');
|
||
} else {
|
||
return Base::retError('添加错误');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/ws/exist 15. websocket是否存在
|
||
*
|
||
* @apiDescription 查询websocket连接是否存在
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName ws__exist
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1存在、0不存在）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据（同"获取我的信息"接口）
|
||
*/
|
||
public function ws__exist()
|
||
{
|
||
$fd = Request::header('fd');
|
||
if (empty($fd)) {
|
||
return Base::retError('empty');
|
||
}
|
||
if (WebSocket::whereFd($fd)->exists()) {
|
||
return Base::retSuccess('success');
|
||
} else {
|
||
return Base::retError('not exist');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/meeting/open 16. 【会议】创建会议、加入会议
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName meeting__open
|
||
*
|
||
* @apiParam {String} type 类型
|
||
* - create: 创建会议，有效参数：name、userids
|
||
* - join: 加入会议，有效参数：meetingid (必填)
|
||
* @apiParam {String} [meetingid] 频道ID（不是数字）
|
||
* @apiParam {String} [name] 会话ID
|
||
* @apiParam {Array} [userids] 邀请成员
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function meeting__open()
|
||
{
|
||
$user = User::auth();
|
||
//
|
||
$type = trim(Request::input('type'));
|
||
$meetingid = trim(Request::input('meetingid'));
|
||
$name = trim(Request::input('name'));
|
||
$userids = Request::input('userids');
|
||
$isCreate = false;
|
||
// 创建、加入
|
||
if ($type === 'join') {
|
||
$meeting = Meeting::whereMeetingid($meetingid)->first();
|
||
if (empty($meeting)) {
|
||
return Base::retError('频道ID不存在');
|
||
}
|
||
} elseif ($type === 'create') {
|
||
$meetingid = strtoupper(Base::generatePassword(11, 1));
|
||
$name = $name ?: "{$user->nickname} 发起的会议";
|
||
$channel = "DooTask:" . substr(md5($meetingid . env("APP_KEY")), 16);
|
||
$meeting = Meeting::createInstance([
|
||
'meetingid' => $meetingid,
|
||
'name' => $name,
|
||
'channel' => $channel,
|
||
'userid' => $user->userid
|
||
]);
|
||
$meeting->save();
|
||
$isCreate = true;
|
||
} else {
|
||
return Base::retError('参数错误');
|
||
}
|
||
$data = $meeting->toArray();
|
||
// 创建令牌
|
||
$meetingSetting = Base::setting('meetingSetting');
|
||
if ($meetingSetting['open'] !== 'open') {
|
||
return Base::retError('会议功能未开启，请联系管理员开启');
|
||
}
|
||
if (empty($meetingSetting['appid']) || empty($meetingSetting['app_certificate'])) {
|
||
return Base::retError('会议功能配置错误，请联系管理员');
|
||
}
|
||
$uid = $user->userid . '_' . Request::header('fd');
|
||
try {
|
||
$service = new AgoraTokenGenerator($meetingSetting['appid'], $meetingSetting['app_certificate'], $meeting->channel, $uid);
|
||
} catch (\Exception $e) {
|
||
return Base::retError($e->getMessage());
|
||
}
|
||
$token = $service->buildToken();
|
||
if (empty($token)) {
|
||
return Base::retError('会议令牌创建失败');
|
||
}
|
||
// 发送给邀请人
|
||
$msgs = [];
|
||
if ($isCreate) {
|
||
foreach ($userids as $userid) {
|
||
if (!User::whereUserid($userid)->exists()) {
|
||
continue;
|
||
}
|
||
$dialog = WebSocketDialog::checkUserDialog($user->userid, $userid);
|
||
if ($dialog) {
|
||
$res = WebSocketDialogMsg::sendMsg($dialog->id, 'meeting', $data, $user->userid);
|
||
if (Base::isSuccess($res)) {
|
||
$msgs[] = $res['data'];
|
||
}
|
||
}
|
||
}
|
||
}
|
||
//
|
||
$data['appid'] = $meetingSetting['appid'];
|
||
$data['uid'] = $uid;
|
||
$data['token'] = $token;
|
||
$data['msgs'] = $msgs;
|
||
return Base::retSuccess('success', $data);
|
||
}
|
||
|
||
/**
|
||
* @api {get} api/users/meeting/invitation 17. 【会议】发送邀请
|
||
*
|
||
* @apiDescription 需要token身份
|
||
* @apiVersion 1.0.0
|
||
* @apiGroup users
|
||
* @apiName meeting__invitation
|
||
*
|
||
* @apiParam {String} meetingid 频道ID（不是数字）
|
||
* @apiParam {Array} userids 邀请成员
|
||
*
|
||
* @apiSuccess {Number} ret 返回状态码（1正确、0错误）
|
||
* @apiSuccess {String} msg 返回信息（错误描述）
|
||
* @apiSuccess {Object} data 返回数据
|
||
*/
|
||
public function meeting__invitation()
|
||
{
|
||
$user = User::auth();
|
||
//
|
||
$meetingid = trim(Request::input('meetingid'));
|
||
$userids = Request::input('userids');
|
||
//
|
||
$meeting = Meeting::whereMeetingid($meetingid)->first();
|
||
if (empty($meeting)) {
|
||
return Base::retError('频道ID不存在');
|
||
}
|
||
$data = $meeting->toArray();
|
||
// 发送给邀请人
|
||
$msgs = [];
|
||
foreach ($userids as $userid) {
|
||
if (!User::whereUserid($userid)->exists()) {
|
||
continue;
|
||
}
|
||
$dialog = WebSocketDialog::checkUserDialog($user->userid, $userid);
|
||
if ($dialog) {
|
||
$res = WebSocketDialogMsg::sendMsg($dialog->id, 'meeting', $data, $user->userid);
|
||
if (Base::isSuccess($res)) {
|
||
$msgs[] = $res['data'];
|
||
}
|
||
}
|
||
}
|
||
//
|
||
$data['msgs'] = $msgs;
|
||
return Base::retSuccess('发送邀请成功', $data);
|
||
}
|
||
}
|