gganli/application/api/controller/Guild.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use think\Exception;
use Redis;
use app\api\controller\Tenim;

/**
 * 公会控制器
 */
class Guild extends Api
{
    protected $noNeedLogin = ['getGuildList'];
    protected $noNeedRight = ['*'];

    /**
     * 获取公会信息
     */
    public function getGuildInfo() {
        $guild_id = $this->request->request("guild_id"); //公会ID
        $is_member = 0;
        if($guild_id <= 0) {
            $is_member = 1;
            $user_id = $this->auth->id;
            // 获取当前用户是否是公会成员
            $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
            if($idcardfind) $this->error("您存在加入公会的申请，正在审核中，请耐心等待！");

            $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
            if($memberfind) $guild_id = $memberfind->guild_id;

            if(!$guild_id) {
                $res["is_member"] = 2; // 是否为派对成员
                $this->success("获取成功！",$res);
            }

        }
        $res = [];
        $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice")->where(["id"=>$guild_id])->find();
        // 获取公会成员信息
        $guildMemberInfo = \app\common\model\GuildMember::alias("a")
            ->field("a.user_id,a.role,u.nickname,u.avatar,u.gender,u.age")
            ->join("hx_user u","a.user_id = u.id")
            ->where(["a.guild_id"=>$guild_id])->limit(5)->order("a.role","desc")->select();
        if(!$guildInfo || !$guildMemberInfo) $this->error("公会信息获取失败！");
        // 获取公会成员总数
        $guildMemberCount = \app\common\model\GuildMember::where(["guild_id"=>$guild_id])->count("id");
        // 获取会长信息
        $guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
        // 获取房间信息
        $partyInfo = \app\common\model\Party::field("party_logo,party_type,is_online,party_name,party_notice_detail")->where(["id"=>$guildInfo->party_id])->find();
        // 派对类型
        $partyTypeName = "普通房";
        if($partyInfo["party_type"]) {
            $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
        }
        $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
        $partyInfo["party_type_color"] = $mod == 0?5:$mod;
        $partyInfo["type_name"] = $partyTypeName;

        // 返回参数拼接
        $res["guildInfo"] = $guildInfo; // 公会基本信息
        $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
        $res["guildMemberCount"] = $guildMemberCount; // 成员总数
        $res["guilderInfo"] = $guilderInfo; // 会长
        $res["partyInfo"] = $partyInfo; // 派对悉尼下
        $res["is_member"] = $is_member; // 是否为派对成员
        $this->success("获取成功！",$res);
    }

    /**
     * 更新公会基本信息
     */
    public function guildSaveInfo() {
        $guild_id = $this->request->request("guild_id"); //公会id
        $guild_name = $this->request->request("guild_name"); //公会简介
        $guild_image = $this->request->request("guild_image"); //公会简介
        $guild_desc = $this->request->request("guild_desc"); //公会简介
        $guild_notice = $this->request->request("guild_notice"); //公会公告
        if(!$guild_id) $this->error("参数错误！");
        if(!$guild_name && !$guild_image && !$guild_desc && !$guild_notice) $this->error("请输入要修改的内容！");
        $user_id = $this->auth->id;

        // 获取公会信息
        $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
        // 验证更新条件
        if($user_id !== $guildInfo->user_id) $this->error("身份验证失败！您不是公会长，无权限更改！");

        $guild_name && $guildInfo->name = $guild_name;
        $guild_image && $guildInfo->image = $guild_image;
        $guild_desc && $guildInfo->desc = $guild_desc;
        $guild_notice && $guildInfo->notice = $guild_notice;
        $res = $guildInfo->save();
        if($res !== false) {
            $this->success("更新成功！");
        } else {
            $this->error("网络错误，请稍后重试！");
        }
    }

    /**
     * 获取搜索公会列表
     */
    public function getGuildList() {
        $search = $this->request->request("search","","string"); //搜索的字段 公会名称/公会ID
        if(!$search) $this->error("请输入要搜索的公会名称或公会ID");
        global $whereOr;
        $where = [];$whereOr = [];
        $where['status'] = 1;
        $whereOr['name'] = array('like', '%' . $search . '%');
        $whereOr['g_id'] = $search;
        $res = \app\common\model\Guild::field("id,g_id,name,image")
            ->where($where)
            ->where(function ($query) {
                global $whereOr;
                $query->whereOr($whereOr);
            })
            ->select();
        $this->success("获取成功！",$res);
    }

    /**
     * 公会申请页面信息
     */
    public function guildApplyInfo() {
        $guild_id = $this->request->request("guild_id"); //公会ID
        if($guild_id <= 0) $this->error("参数缺失！");
        $guildInfo = \app\common\model\Guild::alias("a")
            ->join("hx_user u","u.id = a.user_id","inner")
            ->field("a.id,a.image,a.name,a.g_id,a.user_id,u.avatar,u.nickname,u.u_id")
            ->where(["a.id"=>$guild_id])
            ->find();

        $guildInfo["status"] = 0;
        // 获取申请用户是否已经有正在申请的记录
        $user_id = $this->auth->id;
        $joinStatus = \app\common\model\GuildJoinin::where(["user_id"=>$user_id])->value("status");
        if($joinStatus === 0) $guildInfo["status"] = 1;

        $Member = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->value("id");
        if($Member > 0) $guildInfo["status"] = 2;

        $this->success("获取成功！",$guildInfo);
    }

    /**
     * 开厅申请
     */
    public function guildApply() {
        $user_id = $this->auth->id;
        // 获取用户实名认证信息
        $authUserRealname = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("realname");
        if(!$authUserRealname) $this->error("未查询到实名认证信息，请实名认证先！");
        // 获取用户信息
        $userInfo = \app\common\model\User::field("id,mobile,nickname")->where(["id"=>$user_id])->find();
        $data = [];
        $data["user_id"] = $user_id;
        // 查看是否申请过
        $applyInfo = \app\common\model\GuildApply::where($data)->find();
        if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了，请勿重复发送！");
        // 查看是否有加入公会的申请
        $joinInfo = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
        if($joinInfo) $this->error("您存在申请加入公会信息，请联系工会长处理完毕后方可申请开厅！");
        // 查看是已经是公会成员
        $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
        if($memberInfo) $this->error("您已存在签约中的公会，无法开新厅！");


        Db::startTrans();
        try{
            $data["user_name"] = $authUserRealname;
            $data["user_nickname"] = $userInfo->nickname;
            $data["user_mobile"] = $userInfo->mobile;
            $data["createtime"] = time();
            $res1 = \app\common\model\GuildApply::insert($data);
            // 更新用户状态
            $userInfo->is_guild = 1;
            $res2 = $userInfo->save();
            if($res1 && $res2) {
                Db::commit();
                $this->success("申请发送成功！");
            } else {
                $this->error("网络错误，请稍后重试！");
            }

        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }

    /**
     * 公会签约申请
     */
    public function guildJoinin() {
        $join_time = $this->request->request("join_time"); //签约时长:1=3个月,2=6个月,3=12个月
        $guild_id = $this->request->request("guild_id"); //公会ID
        if(!in_array($join_time,[1,2,3]) || !$guild_id) $this->error("参数错误！");

        // 一个身份证号只能申请一次
        $user_id = $this->auth->id;
        // 实名认证
        $userAuthInfo = \app\common\model\UserAuth::where(["user_id"=>$user_id])->find();
        if($userAuthInfo) {
            if($userAuthInfo->status == 0) {
                $this->error("您的实名认证还在这审核中...，请耐心等待！");
            } elseif($userAuthInfo->status == 2) {
                $this->error("您的实名认证审核未通过，请重新审核！");
            }
        } else {
            $this->error("请先申请实名认证！");
        }

        // 获取用户实名认证信息
        $authUserIdcard = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("idcard");
        // 搜索签约申请中是否有此身份证号
        $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
        if($idcardfind) $this->error("当前账号正在审核，请耐心等待！");

        $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
        if($memberfind) $this->error("一个账号只能加入一个公会哟！");

        // 查看是否申请过
        $applyInfo = \app\common\model\GuildApply::where(["user_id"=>$user_id,"status"=>0])->find();
        if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了，请勿重复发送！");

//        // 获取公会信息
//        $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id,"status"=>1])->find();
//        // 验证更新条件
//        if($guildInfo) $this->error("您存在公会会长身份，请先解散相应的公会才可申请");

        // 获取公会信息
        $guildName = \app\common\model\Guild::where(["id"=>$guild_id])->value("name");
        // 获取用户信息
        $userInfo = \app\common\model\User::field("id,avatar,nickname")->where(["id"=>$user_id])->find();
        // 添加数据
        $data = [];
        $data["user_id"] = $user_id;
        $data["guild_id"] = $guild_id;
        $data["join_time"] = $join_time;
        $data["user_avatar"] = $userInfo->avatar;
        $data["user_idcard"] = $authUserIdcard;
        $data["user_nickname"] = $userInfo->nickname;
        $data["guild_name"] = $guildName;
        $data["createtime"] = time();
        $res = \app\common\model\GuildJoinin::insert($data);
        if($res) {
            // +message
//            \app\common\model\Message::addMessage($user_id,"公会消息","申请加入公会消息");
            $this->success("申请发送成功！");
        } else {
            $this->error("网络错误，请稍后重试！");
        }
    }

    /**
     * 公会签约申请审核
     */
    public function guildJoininExamine() {
        $joinin_id = $this->request->request("joinin_id"); // 申请加入的申请ID
        $is_pass = $this->request->request("is_pass"); // 是否通过:1=通过,-1=拒绝
        if(!in_array($is_pass,[1,-1]) || !$joinin_id) $this->error("参数错误！");
        $user_id = $this->auth->id;
        // 获取申请信息
        $joininInfo =  \app\common\model\GuildJoinin::where(["id"=>$joinin_id])->find();
        // 获取公会信息
        $guildInfo = \app\common\model\Guild::where(["id"=>$joininInfo->guild_id])->find();
        // 验证更新条件
        if($user_id !== $guildInfo->user_id) $this->error("身份验证失败！您不是公会长，无权限更改！");

        // 获取用户信息
        $userInfo = \app\common\model\User::field("id,u_id,mobile,nickname")->where(["id"=>$joininInfo->user_id])->find();

        // 计算签约时间段
        $join_time = $joininInfo->join_time;
        $timeArr = [1=>3,2=>6,3=>12];
        $endtime = strtotime('+'.$timeArr[$join_time].' month');
        $sign_time_slot = date("Y.m.d")."-".date('Y.m.d',$endtime);
        Db::startTrans();
        try{
            $data = [];
            $data["user_id"] = $joininInfo->user_id;
            $data["operator"] = $user_id;
            $data["user_nickname"] = $userInfo->nickname;
            $data["user_u_id"] = $userInfo->u_id;
            $data["guild_id"] = $guildInfo->id;
            $data["guild_name"] = $guildInfo->name;
            $data["guild_g_id"] = $guildInfo->g_id;
            $data["sign_time_slot"] = $sign_time_slot;
            $data["status"] = $is_pass;
            $data["createtime"] = time();
            $res1 = \app\common\model\GuildJoininLog::insert($data);
            // 更新申请状态
            $joininInfo->status = $is_pass;
            $joininInfo->updatetime = time();
            $res2 = $joininInfo->save();
            if($is_pass == 1) {
                // 同意后 加入公会成员
                $data = [];
                $data["guild_id"] = $guildInfo->id;
                $data["user_id"] = $joininInfo->user_id;
                $data["role"] = 0;
                $data["sign_type"] = $join_time; // 签约类型:1=三个月,2=半年,3=一年
                $data["sign_time"] = $endtime;
                $data["status"] = 1;
                $data["createtime"] = time();
                $res3 = \app\common\model\GuildMember::insert($data);
                $res4 = \app\common\model\Guild::where(["id"=>$guildInfo->id])->setInc("member");
                if($res1 && $res2 && $res3 && $res4) {
                    // +message
                    \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","恭喜，您的加入公会审核通过啦！公会ID：".$guildInfo->g_id);
                    Db::commit();
                    $this->success("已审核通过！");
                }
            } else {
                if($res1 && $res2) {
                    // +message
                    \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","您的公会加入申请，公会长审核失败，没关系，调整姿势再来一遍！");
                    Db::commit();
                    $this->success("已审核拒绝！");
                }
            }
            $this->error("网络错误，请稍后重试！");


        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }

    /**
     * 公会助手列表
     */
    public function guildAssistantList() {
        $user_id = $this->auth->id;
        // 获取公会信息
        $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id])->find();
        if(!$guildInfo) $this->error("公会信息获取失败！");
        // 先获取申请列表
        $where = [];
        $where["guild_id"] = $guildInfo->id;
        $where["status"] = 0;
        $joinList = \app\common\model\GuildJoinin::field("id,user_avatar,user_nickname,guild_name,createtime")->where($where)->order("createtime","desc")->select();
        if($joinList) foreach($joinList as $k => $v) {
            $joinList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
        }

        // 再获取审核记录
        $where = [];
        $where["a.guild_id"] = $guildInfo->id;
        $where["a.user_id"] = $user_id;
        $joinlogList = \app\common\model\GuildJoininLog::alias("a")
            ->field("a.id,a.user_nickname,a.user_u_id,a.guild_name,a.guild_g_id,a.sign_time_slot,a.status,u.nickname as operator,a.createtime")
            ->join("hx_user u","a.operator = u.id")
            ->whereOr($where)
            ->order("a.createtime","desc")
            ->select();
        if($joinlogList) foreach($joinlogList as $k => $v) {
            $joinlogList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
        }
        $res = [];
        $res["joinList"] = $joinList;
        $res["joinlogList"] = $joinlogList;
        $this->success("获取成功！",$res);
    }

    /**
     * 公会申请加入列表
     */
    public function guildJoinList() {
        try {
            $user_id = $this->auth->id;
            // 获取公会信息
            $guildInfo = model('Guild')->where(["user_id"=>$user_id])->find();
            if(!$guildInfo) throw new Exception('公会信息获取失败！');
            // 先获取申请列表
            $where = [];
            $where["guild_id"] = $guildInfo->id;
            $where["status"] = 0;
            $result = model('GuildJoinin')->field("id,user_id,user_avatar,user_nickname,guild_name,createtime")
                ->with(['user'=>function($uQuery){
                    $uQuery->field('id,is_online,onlinetime');
                }])
                ->where($where)->order("createtime","desc")->select();
            if($result) {
                foreach($result as $k => &$v) {
                    $user = isset($v['user']) ? $v['user'] : [];
                    $onlineText = '';
                    if (!empty($user)) {
                        if ($user['is_online'] == 1) {
                            $onlineText = '在线';
                        } else {
                            $onlineTime = get_last_time($user['onlinetime']);
                            $onlineText = $onlineTime.'在线';
                        }
                    }
                    $v['online_text'] = $onlineText;
                    $v['createtime'] = !empty($v["createtime"]) ? date("Y-m-d H:i", $v["createtime"]) : '';
                    unset($v['user']);
                }
            }
            $this->success("获取成功",$result);
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
    }

    /**
     * 公会成员列表
     */
    public function guildMember() {
        $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
        $page = $this->request->request('page',1); // 分页
        $pageNum = $this->request->request('pageNum',10); // 分页
        // 分页搜索构建
        $pageStart = ($page-1)*$pageNum;
        if($guild_id <= 0) $this->error("参数错误！");
        $where = [];
        $where["a.guild_id"] = $guild_id;
        $where["a.status"] = 1;
        $where["a.sign_time"] = ["gt",time()];
        // 获取公会成员总数
        $guildMemberCount = \app\common\model\GuildMember::alias("a")->where($where)->count("id");
        // 获取公会成员列表
        $guildMemberList = \app\common\model\GuildMember::alias("a")
            ->field("a.id,u.avatar,u.nickname,u.gender,u.age,a.role")
            ->join("hx_user u","a.user_id = u.id")
            ->where($where)
            ->limit($pageStart,$pageNum)
            ->order("a.role","desc")
            ->select();
        $role = ["","管理","会长"];
        if($guildMemberList) foreach($guildMemberList as $k => &$v) {
            $v["role"] = $role[$v["role"]];
        }
        $res = [];
        $res["memberCount"] = $guildMemberCount;
        $res["memberList"] = $guildMemberList;

        $this->success("获取成功！",$res);
    }

    /**
     * 获取公会成员信息
     */
    public function getGuildMemberInfo() {
        $member_id = $this->request->request("member_id",0,"intval"); //公会成员ID
        if($member_id <= 0) $this->error("参数错误！");
        $memberInfo = \app\common\model\GuildMember::alias("a")
            ->join("hx_user u","u.id = a.user_id")
            ->field("u.id,u.avatar,u.nickname,u.gender,u.age,a.wealth,a.charm,a.gift_num,a.role,a.guild_id,a.createtime,u.logintime")
            ->find($member_id);
        if(!$memberInfo) $this->error("用户信息获取失败！");
        $memberInfo["createtime"] = date("Y-m-d",$memberInfo["createtime"]);
        $memberInfo["logintime"] = date("Y-m-d",$memberInfo["logintime"]);
        $memberInfo["my_role"] = \app\common\model\GuildMember::where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo->guild_id])->value("role");
        $this->success("获取成功！",$memberInfo);
    }

    /**
     * 公会管理-设为管理员
     */
    public function guildSetManage() {
        $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
        $member_user_id = $this->request->request("member_user_id",0,"intval"); //成员用户ID
        $type = $this->request->request("type",1); // 设置类型:1=设为管理员,2=取消管理员
        if(!$guild_id || !$member_user_id || !in_array($type,[1,2])) $this->error("参数缺失！");
        // 先判断是否为公会会长
        $user_id = $this->auth->id;
        // 获取公会信息
        $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
        // 验证更新条件
        if($user_id !== $guildInfo->user_id) $this->error("身份验证失败！您不是公会长，无权限更改！");
        $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$member_user_id])->find();
        if(!$memberInfo) $this->error("会员信息查询失败！");
        if($type == 2) {
            $memberInfo->role = 0;
            $memberInfo->updatetime = time();
            $res = $memberInfo->save();
            if($res) {
                $this->success("取消成功！");
            } else {
                $this->error("网络错误，请稍后重试！");
            }
        }

        $memberInfo->role = 1;
        $memberInfo->updatetime = time();
        $res = $memberInfo->save();
        if($res) {
            // 获取房间id
            $party_id = $guildInfo->party_id;
            // 添加房间管理员
            $redis = new Redis();
            $redisconfig = config("redis");
            $redis->connect($redisconfig["host"], $redisconfig["port"]);
            if ($redisconfig['redis_pwd']) {
                $redis->auth($redisconfig['redis_pwd']);
            }
            if($redisconfig['redis_selectdb'] > 0){
                $redis->select($redisconfig['redis_selectdb']);
            }
            // 获取成员用户信息
            $memberuserInfo = \app\common\model\User::field("id,avatar,nickname,gender,level")->find($member_user_id);
            $data = [];
            $data["user_id"] = $memberuserInfo->id;
            $data["avatar"] = $memberuserInfo->avatar;
            $data["nickname"] = $memberuserInfo->nickname;
            $data["gender"] = $memberuserInfo->gender;
            $data["level"] = $memberuserInfo->level;
            $data["item"] = 1;
            $data["time"] = 0;
            $data["createtime"] = time();

            $redis->hSet("party_manage_".$party_id,$memberuserInfo->id."-1",serialize($data));

            // 腾讯im设置管理员
            $tenim = new Tenim();
            $tenim->setImManage($member_user_id,$party_id);

            $this->success("设置成功！");
        } else {
            $this->error("网络错误，请稍后重试！");
        }
    }

    /**
     * 公会管理-踢出公会
     */
    public function guildDelMember() {
        $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
        $member_user_id = $this->request->request("member_user_id",0,"intval"); //成员用户ID
        if(!$guild_id || !$member_user_id) $this->error("参数缺失！");
        // 先判断是否为公会会长
        $user_id = $this->auth->id;
        // 获取公会信息
        $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
        // 验证更新条件
        if($user_id !== $guildInfo->user_id) $this->error("身份验证失败！您不是公会长，无权限更改！");

        $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$member_user_id])->find();
        if(!$memberInfo) $this->error("会员信息查询失败！");
        Db::startTrans();
        try{
            $res1 = $memberInfo->delete();
            $res2 = \app\common\model\Guild::where(["id"=>$guild_id])->setDec("member");
            if($res1 && $res2) {
                Db::commit();
                $this->success("踢出成功！");
            } else {
                $this->error("网络错误，请稍后重试！");
            }
        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }


}