430 lines
16 KiB
PHP
430 lines
16 KiB
PHP
<?php
|
|
|
|
namespace addons\shopro\controller\zy;
|
|
|
|
use think\Db;
|
|
use think\Exception;
|
|
use app\admin\model\zy\Menber;
|
|
use app\admin\model\zy\Stadium;
|
|
use app\admin\model\zy\game\Game;
|
|
use think\exception\PDOException;
|
|
use app\admin\model\zy\link\Apply;
|
|
use app\admin\model\zy\link\Message;
|
|
use app\admin\model\zy\link\Visitor;
|
|
use app\admin\model\shopro\user\User;
|
|
use app\admin\model\zy\game\Activity;
|
|
use think\exception\ValidateException;
|
|
use app\admin\model\zy\game\Participant;
|
|
use app\admin\model\zy\link\Relation;
|
|
|
|
class Club extends Base
|
|
{
|
|
public function __construct()
|
|
{
|
|
$this->model = new \app\admin\model\zy\Club;
|
|
parent::__construct();
|
|
}
|
|
|
|
public function index()
|
|
{
|
|
$params = $this->request->param();
|
|
$sub = Game::alias('g')
|
|
->join([Participant::$tableName => 'p'], 'p.game_id=g.id', 'LEFT')
|
|
->field('g.id,g.pid,g.club_id,g.act_id,g.date,g.name,g.start_time,g.end_time,g.cost,JSON_ARRAYAGG(p.avatar) as avatar,count(p.id) as join_num')
|
|
->where('g.date', '>=', date('Y-m-d'))
|
|
->order('g.date', 'asc')->group('g.id')->buildSql();
|
|
$query = $this->model->alias('c')
|
|
->join([Stadium::$tableName => 's'], 's.id = c.gym_id', 'LEFT')
|
|
->join([$sub => 'g'], 'g.club_id = c.id', 'LEFT')
|
|
->field("c.*, s.position,s.name as gym_name,JSON_ARRAYAGG(JSON_OBJECT(
|
|
'id', g.id,
|
|
'pid', g.pid,
|
|
'act_id', g.act_id,
|
|
'date', g.date,
|
|
'name', g.name,
|
|
'start_time', g.start_time,
|
|
'end_time', g.end_time,
|
|
'join_num', g.join_num,
|
|
'avatar', g.avatar,
|
|
'cost', g.cost
|
|
)) AS games")->group('c.id');
|
|
if (isset($params['name'])) {
|
|
$query->where('c.name', 'like', '%' . $params['name'] . '%');
|
|
}
|
|
if (isset($params['tag'])) {
|
|
$query->where('c.tags', 'like', '%' . $params['tag'] . '%');
|
|
}
|
|
if (isset($params['gym_id'])) {
|
|
$query->where('c.gym_id', $params['gym_id']);
|
|
}
|
|
if (isset($params['order'])) {
|
|
$query->order($params['order'], $params['sort'] ?? NULL);
|
|
}
|
|
$res = $query->paginate($params['pageSize'] ?? 10);
|
|
$list = $res->items();
|
|
foreach ($list as &$l) {
|
|
$games = json_decode($l['games'], true);
|
|
if (count($games) == 1 && empty($games[0]['id'])) $games = [];
|
|
foreach ($games as &$g) {
|
|
$g['cost'] = json_decode($g['cost'], true);
|
|
}
|
|
$l['games'] = $games;
|
|
}
|
|
$this->success('Success', ['list' => $list, 'count' => $res->total()]);
|
|
}
|
|
|
|
public function view()
|
|
{
|
|
$model = $this->model->get($this->request->param('id'))->toarray();
|
|
|
|
if (empty($model)) {
|
|
$this->error(__('No rows were found'));
|
|
}
|
|
$menber = Menber::alias('m')
|
|
->join([User::$tableName => 'u'], 'u.id = m.user_id')
|
|
->where('club_id', $model['id'])->field('gender,count(*) as num')->group('u.gender')
|
|
->column('count(*) as num', 'gender');
|
|
$model['gender0'] = $menber[0] ?? 0;
|
|
$model['gender1'] = $menber[1] ?? 0;
|
|
$this->model->where('id', $model['id'])->setInc('attention');
|
|
$user = auth_user();
|
|
$visitor = Visitor::where('type', 0)->where('obj_id', $model['id'])->where('user_id', $user['id'])->find();
|
|
if (empty($visitor)) {
|
|
$visitor = new Visitor;
|
|
}
|
|
$visitor->allowField(true)->save([
|
|
'type' => 0,
|
|
'obj_id' => $model['id'],
|
|
'user_id' => $user['id'],
|
|
'nickname' => $user['nickname'],
|
|
'avatar' => $user['avatar'],
|
|
'gender' => $user['gender'],
|
|
'times' => empty($visitor->times) ? 1 : $visitor->times + 1
|
|
]);
|
|
|
|
$this->success('Success', $model);
|
|
}
|
|
|
|
public function add()
|
|
{
|
|
$result = false;
|
|
$params = $this->request->param();
|
|
Db::startTrans();
|
|
try {
|
|
$params['president'] = $this->auth->id;
|
|
$result = $this->model->allowField(true)->save($params);
|
|
$menber = new Menber;
|
|
$menber->allowField(true)->save([
|
|
'club_id' => $this->model->id,
|
|
'user_id' => $this->auth->id,
|
|
'role' => 3
|
|
]);
|
|
Db::commit();
|
|
} catch (ValidateException | PDOException | Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
if ($result === false) {
|
|
$this->error('操作失败');
|
|
}
|
|
$this->success('Success', $result);
|
|
}
|
|
|
|
// 获取俱乐部成员
|
|
public function menber()
|
|
{
|
|
$params = $this->request->param();
|
|
$sub = Relation::field('user_id,target_id,content')->where('user_id', $this->auth->id)->buildSql();
|
|
$query = Db::table(Menber::$tableName)->alias('m')
|
|
->join([User::$tableName => 'u'], 'u.id = m.user_id', 'LEFT')
|
|
->join([$sub => 'r'], 'r.target_id = m.user_id', 'LEFT')
|
|
->field('m.*,u.avatar,u.gender,u.nickname,u.wechat,u.qq,u.mobile,r.content');
|
|
if (empty($params['id'])) {
|
|
return $this->error('参数错误');
|
|
}
|
|
$query->where('club_id', $params['id']);
|
|
if (isset($params['role'])) {
|
|
$query->where('role', 'IN', explode(',', $params['role']));
|
|
} else {
|
|
$query->where('role', '>', 0);
|
|
}
|
|
if (isset($params['nickname'])) {
|
|
$query->where('nickname', 'LIKE', '%' . $params['nickname'] . '%');
|
|
}
|
|
if (isset($params['order'])) {
|
|
$query->order($params['order'], $params['sort'] ?? NULL);
|
|
}
|
|
$res = $query->paginate($params['pageSize'] ?? 10);
|
|
$list = $res->items();
|
|
foreach ($list as &$l) {
|
|
$l['content'] = json_decode($l['content'] ?? '[]', true);
|
|
}
|
|
|
|
$this->success('Success', ['list' => $list, 'count' => $res->total()]);
|
|
}
|
|
|
|
// 获取俱乐部活动
|
|
public function activity()
|
|
{
|
|
$params = $this->request->param();
|
|
$query = Db::table(Activity::$tableName)
|
|
->where('pid', 0) //主活动
|
|
->field('');
|
|
if (isset($params['club_id'])) {
|
|
$query->where('club_id', $params['club_id']);
|
|
}
|
|
if (isset($params['week'])) {
|
|
$query->where('week', $params['week']);
|
|
}
|
|
$res = $query->select();
|
|
|
|
$this->success('Success', $res);
|
|
}
|
|
|
|
// 申请加入俱乐部
|
|
public function apply()
|
|
{
|
|
$params = $this->request->param();
|
|
Db::startTrans();
|
|
try {
|
|
$club = $this->model->get($params['club_id']);
|
|
if (empty($club)) {
|
|
return $this->error('俱乐部不存在');
|
|
}
|
|
if ($club['join_type'] > 1) {
|
|
$this->error('该俱乐部不允许申请');
|
|
}
|
|
$user = Menber::get(['club_id' => $club->id, 'user_id' => $this->auth->id]);
|
|
if (empty($user)) {
|
|
$user = new Menber;
|
|
} else {
|
|
if ($user['role'] > 0) {
|
|
$this->error('您已经是俱乐部成员，无需重复申请');
|
|
} else if ($user['role'] == -1) {
|
|
$this->error('您已被管理员拉黑');
|
|
}
|
|
}
|
|
if ($club['join_type'] == 0) {
|
|
$user->allowField(true)->save([
|
|
'club_id' => $club->id,
|
|
'user_id' => $this->auth->id,
|
|
'role' => 1
|
|
]);
|
|
} else {
|
|
if (Apply::get(['type' => 1, 'user_id' => $this->auth->id, 'target_id' => $club->id, 'status' => 1])) {
|
|
return $this->error('申请审核中');
|
|
}
|
|
$apply = new Apply;
|
|
$apply->allowField(true)->save([ // 记录申请
|
|
'type' => 1,
|
|
'user_id' => $this->auth->id,
|
|
'target_id' => $club->id,
|
|
'content' => json_encode(['reason' => $params['reason'] ?? '']),
|
|
'reason' => $params['reason'],
|
|
'status' => 1
|
|
]);
|
|
// (new Message())->allowField(true)->save([ // 消息通知
|
|
// 'type' => 3,
|
|
// 'name' => $club->name,
|
|
// 'avatar' => $club->logo,
|
|
// 'from_id' => $club->id,
|
|
// 'content' => json_encode([
|
|
// 'topic' => '俱乐部加入申请',
|
|
// '俱乐部名称' => $club->name,
|
|
// '申请人' => $this->user->nickname,
|
|
// '申请时间' => date('Y-m-d H:i:s'),
|
|
// 'reason' => $params['reason'] ?? '',
|
|
// 'apply_id' => $apply->id
|
|
// ])
|
|
// ]);
|
|
}
|
|
Db::commit();
|
|
} catch (ValidateException | PDOException | Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
$this->success('Success');
|
|
}
|
|
//join_type 0:'开放加入，无需审核',1:'开放申请，审核加入',2:'会员邀请，无需审核',3:'会员邀请，审核加入',4:'仅管理员邀请，无需审核'
|
|
|
|
// 邀请加入俱乐部
|
|
public function invite()
|
|
{
|
|
$params = $this->request->param();
|
|
Db::startTrans();
|
|
try {
|
|
$club = $this->model->get($params['club_id']);
|
|
if (empty($club)) {
|
|
return $this->error('俱乐部不存在');
|
|
}
|
|
$user = User::get($params['user_id']);
|
|
if (empty($user)) {
|
|
return $this->error('用户不存在');
|
|
}
|
|
$menber = Menber::where('club_id', $params['club_id'])
|
|
->where('user_id', $this->auth->id)
|
|
->where('role', '>', 0)->find();
|
|
if (empty($menber)) {
|
|
$this->error('您无权邀请加入俱乐部');
|
|
}
|
|
$invate = Menber::get(['user_id' => $params['user_id'], 'club_id' => $params['club_id']]);
|
|
if (empty($invate)) {
|
|
$invate = new Menber;
|
|
} else {
|
|
if ($invate['role'] > 0) {
|
|
$this->error('用户已在俱乐部');
|
|
} else if ($invate['role'] == -1) {
|
|
$this->error('用户已被管理员拉黑');
|
|
}
|
|
}
|
|
if ($menber['role'] > 1 || $club['join_type'] == 0 || $club['join_type'] == 2) { // 管理员或者开放加入
|
|
$invate->allowField(true)->save([
|
|
'club_id' => $club->id,
|
|
'user_id' => $user->id,
|
|
'role' => 1
|
|
]);
|
|
} else {
|
|
if (Apply::get(['type' => 1, 'user_id' => $this->auth->id, 'target_id' => $user->id, 'status' => 1])) {
|
|
return $this->error('申请审核中');
|
|
}
|
|
$apply = new Apply;
|
|
$apply->allowField(true)->save([ // 记录申请
|
|
'type' => 1,
|
|
'user_id' => $user->id,
|
|
'target_id' => $club->id,
|
|
'content' => json_encode(['reason' => $params['reason'] ?? '']),
|
|
'reason' => $params['reason'],
|
|
'status' => 1
|
|
]);
|
|
// (new Message())->allowField(true)->save([ // 消息通知
|
|
// 'type' => 3,
|
|
// 'name' => $club->name,
|
|
// 'avatar' => $club->logo,
|
|
// 'from_id' => $club->id,
|
|
// 'content' => json_encode([
|
|
// 'topic' => '俱乐部加入申请',
|
|
// '俱乐部名称' => $club->name,
|
|
// '申请人' => $user->nickname,
|
|
// '申请时间' => date('Y-m-d H:i:s'),
|
|
// 'reason' => $params['reason'] ?? '',
|
|
// 'apply_id' => $apply->id,
|
|
// ])
|
|
// ]);
|
|
}
|
|
Db::commit();
|
|
} catch (ValidateException | PDOException | Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
$this->success('Success');
|
|
}
|
|
|
|
// 获取申请列表
|
|
public function applyList()
|
|
{
|
|
$params = $this->request->param();
|
|
$club = $this->model->get($params['club_id']);
|
|
if (empty($club)) {
|
|
return $this->error('俱乐部不存在');
|
|
}
|
|
$menber = Menber::where('club_id', $params['club_id'])
|
|
->where('user_id', $this->auth->id)
|
|
->where('role', '>', 1)->find();
|
|
if (empty($menber)) {
|
|
$this->error('您无权处理申请');
|
|
}
|
|
$query = Apply::where('type', 1)->where('target_id', $params['club_id']);
|
|
if (isset($params['status'])) {
|
|
$query->where('status', $params['status']);
|
|
}
|
|
$applyList = $query->select();
|
|
$this->success('Success', $applyList);
|
|
}
|
|
|
|
// 处理申请
|
|
public function handle()
|
|
{
|
|
$params = $this->request->param();
|
|
Db::startTrans();
|
|
try {
|
|
$apply = Apply::get(['id' => $params['apply_id'], 'status' => 1]);
|
|
if (empty($apply)) {
|
|
return $this->error('申请记录不存在');
|
|
}
|
|
$menber = Menber::where('club_id', $apply['target_id'])
|
|
->where('user_id', $this->auth->id)
|
|
->where('role', '>', 1)->find();
|
|
if (empty($menber)) {
|
|
$this->error('您无权处理申请');
|
|
}
|
|
if ($apply['status'] != 1) {
|
|
return $this->error('该申请已处理');
|
|
}
|
|
if ($params['status'] == 2) {
|
|
(new Menber)->allowField(true)->save([
|
|
'club_id' => $apply['target_id'],
|
|
'user_id' => $apply['user_id'],
|
|
'role' => 1
|
|
]);
|
|
}
|
|
$apply->allowField(true)->save([
|
|
'status' => $params['status'],
|
|
'reply' => $params['reply'] ?? ''
|
|
]);
|
|
Db::commit();
|
|
} catch (ValidateException | PDOException | Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
$this->success('Success');
|
|
}
|
|
|
|
// 设置成员角色
|
|
public function setmember()
|
|
{
|
|
$params = $this->request->param();
|
|
$user = Menber::where('club_id', $params['club_id'])
|
|
->where('user_id', $this->auth->id)
|
|
->where('role', '>', 1)->find();
|
|
if (empty($user)) {
|
|
$this->error('无权限');
|
|
}
|
|
if (isset($params['role']) && ($params['role'] < -1 || $params['role'] > 2)) {
|
|
$this->error('非法角色');
|
|
}
|
|
$user_ids = explode(',', $params['user_id'] ?? '');
|
|
$menber = Menber::where('club_id', $params['club_id'])->where('user_id', 'IN', $user_ids)->select();
|
|
if (empty($menber)) {
|
|
$this->error('成员不存在');
|
|
}
|
|
if ($user['role'] != 3) {
|
|
if (isset($params['role']) && $params['role'] > 1) {
|
|
$this->error('只有会长才能设置管理员');
|
|
}
|
|
foreach ($menber as $m) {
|
|
if ($m['role'] > 1) $this->error('只有会长才能修改管理员');
|
|
}
|
|
} else {
|
|
foreach ($menber as $m) {
|
|
if ($m['role'] == 3 && isset($params['role'])) {
|
|
$this->error('不可修改会长角色');
|
|
}
|
|
}
|
|
}
|
|
|
|
$update = [];
|
|
if (isset($params['role'])) $update['role'] = $params['role'];
|
|
if (isset($params['remark'])) $update['remark'] = $params['remark'];
|
|
if (isset($params['tags'])) $update['tags'] = $params['tags'];
|
|
Db::startTrans();
|
|
try {
|
|
Menber::where('club_id', $params['club_id'])->where('user_id', 'IN', $user_ids)->update($update);
|
|
Db::commit();
|
|
} catch (ValidateException | PDOException | Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
$this->success('Success');
|
|
}
|
|
}
|