roomTypeArr = [1=>"party",2=>"live"]; } /** * 获取搜索公会列表 */ public function getGuildList() { $search = input("search","","string"); //搜索的字段 公会名称/公会ID $where = [];$whereOr = []; $where['g.status'] = 1; if (!empty($search)) { $whereOr['g.name'] = array('like', '%' . $search . '%'); $whereOr['g.g_id'] = $search; } $res = Db::name('guild')->alias('g')->field("g.id,g.g_id,g.user_id,g.party_id,g.name,g.image,g.desc,g.member, area.province_name,area.name as city_name") ->join('shopro_area area','g.city_id = area.id','LEFT') ->where($where) ->where(function ($query) use($whereOr) { $query->whereOr($whereOr); }) ->autopage() ->select(); $res = list_domain_image($res,['image']); $this->success("获取成功!",$res); } /** * 获取公会信息-新 */ public function getGuildInfoNew() { $guild_id = input("guild_id"); //公会ID $user_id = $this->auth->id; //结果 $res = []; //公会信息 $guildInfo = \app\common\model\Guild::field("id,image,name,desc,g_id,user_id,party_id,desc,notice,info,status,province_id,city_id")->where(["id"=>$guild_id])->find(); if(!$guildInfo) $this->error("公会信息获取失败!"); $guildInfo['province_name'] = ''; $guildInfo['city_name'] = ''; $area_info = Db::name('shopro_area')->where('id',$guildInfo['city_id'])->field('name,province_name')->find(); if($area_info){ $guildInfo['province_name'] = $area_info['province_name']; $guildInfo['city_name'] = $area_info['name']; } // 获取公会成员信息 $guildMemberInfo = \app\common\model\GuildMember::alias("a") ->field("a.id,a.user_id,a.role,u.nickname,u.avatar,u.gender") ->join("user u","a.user_id = u.id") ->where(["a.guild_id"=>$guild_id])->limit(10)->order("a.role","desc")->select(); // 获取公会成员总数 $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("id,party_logo,party_type,is_online,party_name")->where(["id"=>$guildInfo->party_id])->find(); $partyParams = ['party_id' => $guildInfo->party_id]; $roomService = new RoomService(); $partyOnlineRes = $roomService->getPartyUserList($partyParams); $onlineData = isset($partyOnlineRes['data']) ? $partyOnlineRes['data'] : []; if (!empty($partyInfo)) { $partyInfo['user_list'] = isset($onlineData['member_list']) ? $onlineData['member_list'] : []; $partyInfo['online_num'] = isset($onlineData['online_num']) ? $onlineData['online_num'] : 0; // 派对类型 $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1; $partyInfo["party_type_color"] = $mod == 0?5:$mod; $partyInfo["type_name"] = '公会房'; } //获取公会角色 角色:0=成员,1=副会长,2=会长,3=非会员 $guildMember = \app\common\model\GuildMember::field('id,role')->where(['guild_id'=>$guild_id,'user_id'=>$this->auth->id])->find(); if (!empty($guildMember)) { $guildRole = $guildMember['role']; }else{ $guildRole = 3; } // 返回参数拼接 $res["guildInfo"] = $guildInfo; // 公会基本信息 $res["partyInfo"] = $partyInfo; // 派对基本信息 $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表 $res["guildMemberCount"] = $guildMemberCount; // 成员总数 $res["guilderInfo"] = $guilderInfo; // 会长 $res['guild_role'] = $guildRole; //公会角色 $this->success("获取成功!",$res); } /** * 更新公会基本信息 */ public function guildSaveInfo() { Db::startTrans(); try { if($this->auth->is_auth != 2){ $this->error('请先完成实名认证'); } $guild_id = input("guild_id"); //公会id $guild_name = input("guild_name"); //公会名 $guild_image = input("guild_image"); //logo $guild_desc = input("guild_desc"); //公会简介 $guild_notice = input("guild_notice"); //公会公告 $guild_info = input("guild_info"); //公会宣言 $province_id = input("province_id"); //省id $city_id = input("city_id"); //市id if(!$guild_name || !$guild_image){ throw new Exception("公会名和logo必填!"); } $user_id = $this->auth->id; if (empty($guild_id)) { //检查 $guildWhere['user_id'] = $user_id; $guildWhere['status'] = ['in',[0,1]]; $guildData = model('Guild')->where($guildWhere)->find(); if (!empty($guildData)) { if($guildData['status'] == 1){ throw new Exception('您已创建过公会!'); }else{ throw new Exception('您创建的公会正在审核中!'); } } //检查不能是其他家族的成员 $checkmember = model('GuildMember')->where('user_id',$this->auth->id)->find(); if (!empty($checkmember)) { $this->error('您已经加入了其他公会'); } //检查删除这个人的所有加入申请 $joinData = model('GuildJoinin')->where('user_id',$this->auth->id)->where('status',0)->find(); if (!empty($joinData)) { $this->error('您已经申请加入了其他公会,需等待被拒或退出,才能创建公会'); } //准备创建 $guildInfo = new \app\common\model\Guild(); $ids = \app\common\model\Guild::column("g_id"); $guildInfo->user_id = $user_id; $guildInfo->g_id = getUinqueId(4, [$ids]); $guildInfo->status = 0; //去派对建个房间 $party_info = $this->createParty($user_id,$guild_name,$guild_image,$guild_desc,$guild_notice,8,1,1,$guildInfo['status']); $guildInfo->party_id = $party_info['party_id']; $guildInfo->easemob_room_id = $party_info['easemob_room_id']; } else { // 获取公会信息 $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find(); // 验证更新条件 if($user_id !== $guildInfo->user_id) throw new Exception("身份验证失败!您不是公会长,无权限更改!"); //去派对建个房间 if(!$guildInfo['party_id']){ $party_info = $this->createParty($user_id,$guild_name,$guild_image,$guild_desc,$guild_notice,8,1,1,$guildInfo['status']); $guildInfo->party_id = $party_info['party_id']; $guildInfo->easemob_room_id = $party_info['easemob_room_id']; } } //传参信息 $guild_name && $guildInfo->name = $guild_name; $guild_image && $guildInfo->image = $guild_image; $guild_desc && $guildInfo->desc = $guild_desc; $guild_notice && $guildInfo->notice = $guild_notice; $guild_info && $guildInfo->info = $guild_info; $province_id && $guildInfo->province_id = $province_id; $city_id && $guildInfo->city_id = $city_id; $res = $guildInfo->save(); if($res !== false) { if (empty($guild_id)) { //新公会,会长也是成员之一 $guildMemberData = [ 'guild_id' => $guildInfo->id, 'user_id' => $user_id, 'role' => 2, //角色:0=成员,1=副会长,2=会长 // 'sign_type' => 3,//签约类型:1=三个月,2=半年,3=一年 // 'sign_time' => 0, // 'status' => 1, //状态:1=签约中,2=已解约 'createtime' => time(), ]; $guildRes = model('GuildMember')->insertGetId($guildMemberData); if (!$guildRes) { throw new Exception('生成成员失败'); } //更新用户资料 $userWhere['id'] = $user_id; $user = model('User')->where($userWhere)->find(); if (!empty($user) && $user['guild_id'] != $guildInfo->id) { $userRes = model('User')->where($userWhere)->update(['is_guild'=>3,'guild_id'=>$guildInfo->id]); if (!$userRes) { throw new Exception('用户绑定公会失败'); } } } Db::commit(); $this->success("操作成功!"); } else { throw new Exception("网络错误,请稍后重试!"); } } catch (Exception $e) { Db::rollback(); $this->error($e->getMessage()); } } /** * 创建/进入派对 */ private function createParty($user_id,$party_name,$party_logo,$guild_desc,$guild_notice,$seatnum = 8,$is_public = 1,$room_type = 1,$status = 0) { $partyModel = new \app\common\model\Party(); // 判断派对是否存在 // sql中不存在派对信息 $party_type = 7; // 派对类型(情感互动,心动点单 等) $party_notice = $guild_desc; // 派对公告 $party_notice_detail = $guild_notice; // 派对公告详情 $party_ids = $partyModel->column("party_id"); // 创建派对ID (临时ID四位,派对数不超过8999) $party_id = $this->auth->getUinqueId(4,$party_ids); if($party_id > 9999) { $this->error("房间超限,请联系客服"); } //创建房间,初始化环信 $easemob_room_id = $this->easemob_createroom($party_name,$party_logo,$seatnum,$is_public,$room_type); //写入派对 $data = []; $data["user_id"] = $user_id; $data["room_type"] = $room_type; $data["party_id"] = $party_id; $data["party_hot"] = 0; $data["party_name"] = $party_name; $data["party_logo"] = $party_logo; $data["party_type"] = $party_type; $data["party_notice"] = $party_notice; $data["party_notice_detail"] = $party_notice_detail; $data["is_online"] = 1; $data["status"] = $status;//跟随公会状态 $data["is_recommend"] = 0; $data["createtime"] = time(); $data["easemob_room_id"] = $easemob_room_id; if($room_type == 1){ $data["platRate"] = config('site.party_party_platrate'); $data["guilderRate"] = config('site.party_party_guilderrate'); }else{ $data["platRate"] = config('site.party_live_platrate'); $data["guilderRate"] = config('site.party_live_guilderrate'); } $id = $partyModel->insertGetId($data); if(!$id) { $this->error("公会房间创建失败,请稍后重试!"); } $data["id"] = $id; $partyInfo = $partyModel->where(["id"=>$id])->find(); $partyInfo["is_new"] = 1; $partyInfo["type_name"] = '公会房'; //redis $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']); } // 加入缓存排序,rediskey:派对热度 $redis->zAdd($this->roomTypeArr[$room_type]."Rank", $partyInfo['party_hot'], $partyInfo["id"]); // 加入缓存,rediskey:派对详情 $redis->set($this->roomTypeArr[$room_type]."_".$partyInfo["id"],json_encode($partyInfo)); //更新家族 party_id $rs = [ 'party_id' => $id, 'easemob_room_id' => $easemob_room_id, ]; return $rs; //声网三个token // $partyInfo['shengwang_token'] = $this->shengwang_token_private($easemob_room_id); } //创建房间,初始化环信 private function easemob_createroom($party_name,$party_logo,$seatnum,$is_public,$room_type){ //[环信]创建聊天室 $easemob = new Easemob(); $easemob_room_id = $easemob->room_createRoom($party_name,$party_name,$this->auth->id); if(empty($easemob_room_id)){ $this->error('创建房间失败'); } //[环信]初始化房间,初始化自定义属性 $matedata = [ 'seatnum'=> $seatnum,//麦位数量 'waitsing_list' => json_encode([]),//已点歌曲列表 'party_name' => $party_name,//房名字 'party_logo' => $party_logo,//logo 'is_public' => $is_public,//是否公开 'room_type' => $room_type,//房间类型 'online_user_num' => 0,//当前房间在线的人 'wealth_top3_userlist' => json_encode([]),//财富榜前3个人列表 'background' => '', //房间背景 ]; $rs = $easemob->room_setRoomCustomAttributeForced($easemob_room_id,$this->auth->id,$matedata); //[环信]初始化N个麦位 $seatdata = []; for($i=0;$i<$seatnum;$i++){ $seat = [ 'charm' => 0, //红心,魅力值 'isMaster' => false, // 是否是房主 'headUrl' => '', // 头像 'userNo' => '', // 座位上用户no 'rtcUid' => '', // 座位上用户id,与rtc的userId一致 'name' => '', // 座位上用户昵称 'seatIndex' => -1, // 座位编号 'chorusSongCode' => '', // 是否合唱 'isAudioMuted' => 1, // 是否静音 'isVideoMuted' => 0, // 是否开启视频 'checked' => false, // 用于送礼物选择用户 'isUsed' => true, // 用于送礼物选择用户 'gender' => 1, //性别 ]; //创建完房间就进入,所以房主直接在麦位0 if($i == 0){ $seat['isMaster'] = true; $seat['headUrl'] = localpath_to_netpath($this->auth->avatar); $seat['userNo'] = $this->auth->id; $seat['rtcUid'] = $this->auth->id; $seat['name'] = $this->auth->nickname; $seat['seatIndex'] = $i; } $seatdata['seat'.$i] = json_encode($seat); } $rs = $easemob->room_setRoomCustomAttributeForced($easemob_room_id,$this->auth->id,$seatdata); return $easemob_room_id; } /** * 公会签约申请 */ public function guildJoinin() { $guild_id = input("guild_id"); //公会ID // 一个身份证号只能申请一次 $user_id = $this->auth->id; // 实名认证 if($this->auth->is_auth != 2){ $this->error("请完成实名认证!"); } $check = \app\common\model\Guild::where(["user_id"=>$this->auth->id])->find(); if($check){ if($check['status'] == 1){ $this->error('您已经有自己的公会了'); }elseif($check['status'] == 0){ $this->error('您已经申请了自己的公会了'); } } // 搜索签约申请中是否有此身份证号 $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,'guild_id'=>$guild_id,"status"=>0])->find(); if($idcardfind) $this->error("您的申请正在审核,请耐心等待!"); $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id])->find(); if($memberfind) $this->error("一个账号只能加入一个公会哟!"); // 添加数据 $data = []; $data["user_id"] = $user_id; $data["guild_id"] = $guild_id; $data["createtime"] = time(); $res = \app\common\model\GuildJoinin::insert($data); if($res) { $this->success("申请发送成功!"); } else { $this->error("网络错误,请稍后重试!"); } } /** * 公会签约申请审核 */ public function guildJoininExamine() { $joinin_id = input("joinin_id"); // 申请加入的申请ID $is_pass = input("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(); if(empty($joininInfo)){ $this->error('未找到申请信息'); } // 获取公会信息 $guildInfo = \app\common\model\Guild::where(["id"=>$joininInfo->guild_id])->find(); // 验证更新条件 if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!"); //判断重复 if($is_pass == 1){ $memberfind = \app\common\model\GuildMember::where(["user_id"=>$joininInfo['user_id']])->find(); if($memberfind) $this->error("该用户已有公会!");//包括成员,副会,会长角色 } //清理其他公会未审核的数据 if ($is_pass == 1) { $joinWhere['user_id'] = $joininInfo['user_id']; $joinWhere['guild_id'] = ['neq',$joininInfo['guild_id']]; $joinWhere['status'] = 0; $joinData = model('GuildJoinin')->where($joinWhere)->delete(); } // 计算签约时间段 Db::startTrans(); try{ // 更新申请状态 $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["createtime"] = time(); $res3 = \app\common\model\GuildMember::insert($data); $res4 = \app\common\model\Guild::where(["id"=>$guildInfo->id])->setInc("member"); if($res2 && $res3 && $res4) { // +message \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","恭喜,您的加入公会审核通过啦!"); Db::commit(); $this->success("已审核通过!"); } } else { if($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 guildJoinList() { $user_id = $this->auth->id; // 获取公会信息 $guildInfo = model('Guild')->where(["user_id"=>$user_id])->find(); if(!$guildInfo) { $this->success("获取成功",[]); } // 先获取申请列表 $where = []; $where["m.guild_id"] = $guildInfo->id; $where["m.status"] = 0; $result = Db::name('guild_joinin')->alias('m') ->field("m.id,m.user_id,m.createtime,user.is_online,user.onlinetime,user.nickname,user.avatar") ->join('user','m.user_id = user.id','LEFT') ->where($where)->order("createtime","desc")->select(); if($result) { foreach($result as $k => &$v) { if ($v['is_online'] == 1) { $onlineText = '在线'; } else { $onlineTime = get_last_time($v['onlinetime']); $onlineText = $onlineTime.'在线'; $limitTime = time() - (3600 * 6); if ($v['onlinetime'] < $limitTime) { $onlineText = '离线'; } } $v['online_text'] = $onlineText; unset($v['user']); } } $this->success("获取成功",$result); } /** * 公会成员列表 */ public function guildMember() { $guild_id = input("guild_id",0,"intval"); //公会ID if($guild_id <= 0) $this->error("参数错误!"); $where = []; $where["a.guild_id"] = $guild_id; // 获取公会成员总数 $guildMemberCount = \app\common\model\GuildMember::alias("a")->where($where)->count("id"); // 获取公会成员列表 $guildMemberList = \app\common\model\GuildMember::alias("a") ->field("a.id,a.user_id,u.avatar,u.nickname,u.gender,a.role,u.is_online,u.onlinetime") ->join("user u","a.user_id = u.id") ->where($where) ->autopage() ->order("a.role","desc") ->select(); $role = [0=>'成员',1=>'副会长',2=>'会长']; if($guildMemberList) { foreach($guildMemberList as $k => &$v) { $v["role_text"] = $role[$v["role"]]; if ($v['is_online'] == 1) { $onlineText = '在线'; } else { $onlineTime = get_last_time($v['onlinetime']); $onlineText = $onlineTime.'在线'; $limitTime = time() - (3600 * 6); if ($v['onlinetime'] < $limitTime) { $onlineText = '离线'; } } $v['online_text'] = $onlineText; } } $res = []; $res["memberCount"] = $guildMemberCount; $res["memberList"] = $guildMemberList; $this->success("获取成功!",$res); } /** * 获取公会成员信息 */ public function getGuildMemberInfo() { $member_id = input("member_id",0,"intval"); //公会成员ID if($member_id <= 0) $this->error("参数错误!"); //成员信息 $memberData = model('GuildMember')->field('id,user_id')->find($member_id); //更新成员的 财富值 ,魅力值,收到的礼物数量 $userService = new UserService(); $userService->updateGuildMember(['user_id'=>$memberData['user_id']]); //从user表拿一些用户信息 $memberInfo = model('GuildMember')->alias('m') ->join('user','m.user_id = user.id','LEFT') ->field('m.id,m.user_id,m.wealth,m.charm,m.gift_num,m.role,m.guild_id,m.createtime, user.avatar,user.nickname,user.gender,user.logintime,user.is_online,user.onlinetime') ->where('m.id',$member_id) ->find(); if(!$memberInfo) $this->error("用户信息获取失败!"); $memberInfo = info_domain_image($memberInfo,['avatar']); //角色 $role = [0=>'成员',1=>'副会长',2=>'公会长']; $memberInfo["role_text"] = $role[$memberInfo["role"]]; //在线 if ($memberInfo['is_online'] == 1) { $onlineText = '在线'; } else { $onlineTime = get_last_time($memberInfo['onlinetime']); $onlineText = $onlineTime.'在线'; $limitTime = time() - (3600 * 6); if ($memberInfo['onlinetime'] < $limitTime) { $onlineText = '离线'; } } $memberInfo['online_text'] = $onlineText; //我在这个公会的角色 $myGuildMember = model('GuildMember')->field('role')->where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo->guild_id])->find(); $memberInfo["my_role"] = !empty($myGuildMember) ? $myGuildMember['role'] : 3; //几个比较大的值,改w单位 $fieldArr = ['wealth','charm','gift_num']; foreach ($fieldArr as $fkey => $fval) { if ($memberInfo[$fval] > 10000) { $memberInfo[$fval] = bcdiv($memberInfo[$fval],10000,2).'w'; } } $this->success("获取成功!",$memberInfo); } /** * 公会管理-设为管理员 */ public function guildSetManage() { $guild_id = input("guild_id",0,"intval"); //公会ID $member_id = input("member_id",0,"intval"); //成员ID $type = input("type",1); // 设置类型:1=设为管理员,2=取消管理员 if(!$guild_id || !$member_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(["id"=>$member_id,'guild_id'=>$guild_id])->find(); if(!$memberInfo) $this->error("会员信息查询失败!"); //取消管理员 if($type == 2) { $memberInfo->role = 0; $memberInfo->updatetime = time(); $res = $memberInfo->save(); if($res) { //[环信]取消聊天室管理员 $easemob = new Easemob(); $easemob->room_demoteRoomAdmin($guildInfo['easemob_room_id'],$memberInfo['user_id']); $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")->where('id',$memberInfo['user_id'])->find(); $data = []; $data["user_id"] = $memberuserInfo->id; $data["avatar"] = $memberuserInfo->avatar; $data["nickname"] = $memberuserInfo->nickname; $data["gender"] = $memberuserInfo->gender; $data["item"] = 1; $data["time"] = 0; $data["createtime"] = time(); $redis->hSet("party_manage_".$party_id,$memberuserInfo->id."-1",serialize($data)); //[环信]设置群组管理员 $easemob = new Easemob(); $easemob->room_promoteRoomAdmin($guildInfo['easemob_room_id'],$memberInfo['user_id']); $this->success("设置成功!"); } else { $this->error("网络错误,请稍后重试!"); } } /** * 公会管理-踢出公会 */ public function guildDelMember() { $guild_id = input("guild_id",0,"intval"); //公会ID $member_id = input("member_id",0,"intval"); //成员ID if(!$guild_id || !$member_id) $this->error("参数缺失!"); // 获取公会信息 $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find(); $memberInfo = \app\common\model\GuildMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->find(); if(!$memberInfo) $this->error("会员信息查询失败!"); if($memberInfo['role'] == 2 || $memberInfo['user_id'] == $guildInfo['user_id']){ $this->error('会长不能被踢出公会'); } if($memberInfo['role'] == 1 && $this->auth->id !== $guildInfo->user_id) { $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()); } } /** * 公会管理-自己退出公会 */ public function guildMemberQuit() { $guild_id = input("guild_id",0,"intval"); //公会ID if(!$guild_id) $this->error("参数缺失!"); // 获取公会信息 $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find(); $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$this->auth->id,'guild_id'=>$guild_id])->find(); if(!$memberInfo) { $this->error("会员信息查询失败!"); } if($memberInfo['role'] == 2){ $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()); } } /** * 公会贡献榜排行 * @return void */ public function getRankList() { try { $id = input('guild_id',0); $guildMemberWhere['guild_id'] = $id; // $guildMemberWhere['status'] = 1; $guildMember = model('GuildMember')->field('id,user_id,role')->where($guildMemberWhere)->select(); $list = []; if (!empty($guildMember)) { $userIds = array_column($guildMember,'user_id'); $where = []; $where['a.user_to_id'] = ['in', $userIds]; $list = model('GiftUserParty')->alias("a") ->field('sum(a.value) as total_price,a.user_to_id,u.avatar,u.nickname,u.is_online,u.onlinetime') ->where($where) ->join('user u','u.id = a.user_to_id') ->group('a.user_to_id') ->order('total_price',"desc") ->autopage() ->select(); if (!empty($list)) { $role = [0=>'成员',1=>'副会长',2=>'会长']; $guildMemberData = []; foreach ($guildMember as $mKey => $mVal) { $guildMemberData[$mVal['user_id']] = [ 'id' => $mVal['id'], 'role' => $mVal['role'], 'role_text' => isset($role[$mVal['role']]) ? $role[$mVal['role']] : '', ]; } foreach ($list as $key => &$value) { $member = isset($guildMemberData[$value['user_to_id']]) ? $guildMemberData[$value['user_to_id']] : []; $value['member_id'] = isset($member['id']) ? $member['id'] : 0; $value['role'] = isset($member['role']) ? $member['role'] : 0; $value['role_text'] = isset($member['role_text']) ? $member['role_text'] : ''; if ($value['is_online'] == 1) { $onlineText = '在线'; } else { $onlineTime = get_last_time($value['onlinetime']); $onlineText = $onlineTime.'在线'; $limitTime = time() - (3600 * 6); if ($value['onlinetime'] < $limitTime) { $onlineText = '离线'; } } $value['online_text'] = $onlineText; $value['total_price_text'] = $value['total_price']; if ($value['total_price'] >= 10000) { $value['total_price_text'] = bcdiv($value['total_price'],10000,1).'w'; } unset($value['total_price']); } } } $this->success(__('Operation completed'),$list); } catch (Exception $e) { $this->error($e->getMessage()); } } /** * 获取公会状态 * @return void */ public function getStatus() { $id = input('guild_id',0); if (!empty($id)) { $where['id'] = $id; } else { $where['user_id'] = $this->auth->id; } $field = 'id,status'; $guild = model('Guild')->field($field)->where($where)->find(); $this->success('获取成功', $guild); } ///////////////没用到的/////////// /** * 开厅申请 */ 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])->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 guildApplyInfo() { $guild_id = input("guild_id"); //公会ID if($guild_id <= 0) $this->error("参数缺失!"); $guildInfo = \app\common\model\Guild::alias("a") ->join("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])->value("id"); if($Member > 0) $guildInfo["status"] = 2; $this->success("获取成功!",$guildInfo); } }