<?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 think\exception\PDOException;
use app\admin\model\zy\link\Apply;
use app\admin\model\zy\link\Message;
use app\admin\model\shopro\user\User;
use app\admin\model\zy\game\Activity;
use think\exception\ValidateException;

class Club extends Base
{
    public function __construct()
    {
        $this->model = new \app\admin\model\zy\Club;
        parent::__construct();
    }

    public function index()
    {
        $params = $this->request->param();
        $query = $this->model->alias('c')
            ->join([Stadium::$tableName => 's'], 's.id = c.gym_id', 'LEFT')
            ->field('c.*, s.name as gym_name');
        if (isset($params['name'])) {
            $query->where('c.name', 'like', '%' . $params['name'] . '%');
        }
        if (isset($params['gym_id'])) {
            $query->where('c.gym_id',  $params['gym_id']);
        }
        $res = $query->paginate($params['pageSize'] ?? 10);
        $this->success('Success', ['list' =>  $res->items(), 'count' => $res->total()]);
    }

    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();
        $query = Db::table(Menber::$tableName)->alias('m')
            ->join([User::$tableName => 'u'], 'u.id = m.user_id')
            ->field('m.*,u.avatar,u.gender,u.nickname');
        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->select();

        $this->success('Success', $res);
    }

    //  获取俱乐部活动
    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' => $this->auth->id,
                    'target_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' => $this->auth->id,
                    'target_id' => $params['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('非法角色');
        }
        $menber = Menber::where('club_id', $params['club_id'])->where('user_id', 'IN', explode(',', $params['user_id']))->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', explode(',', $params['user_id']))->update($update);
            Db::commit();
        } catch (ValidateException | PDOException | Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        $this->success('Success');
    }
}