Family.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use app\common\service\UserService;
  5. use think\Db;
  6. use think\Exception;
  7. use app\common\library\Easemob;
  8. /**
  9. * 家族控制器
  10. */
  11. class Family extends Api
  12. {
  13. protected $noNeedLogin = ['getGuildList'];
  14. protected $noNeedRight = ['*'];
  15. /**
  16. * 获取搜索公会列表
  17. */
  18. public function getGuildList() {
  19. $search = input("search","","string"); //搜索的字段 公会名称/公会ID
  20. $where = [];$whereOr = [];
  21. $where['status'] = 1;
  22. if (!empty($search)) {
  23. $whereOr['name'] = array('like', '%' . $search . '%');
  24. $whereOr['g_id'] = $search;
  25. }
  26. $res = Db::name('family')->field("id,g_id,user_id,easemob_group_id,name,image,desc,notice,member")
  27. ->where($where)
  28. ->where(function ($query) use($whereOr) {
  29. $query->whereOr($whereOr);
  30. })
  31. ->autopage()
  32. ->select();
  33. $res = list_domain_image($res,['image']);
  34. $this->success("获取成功!",$res);
  35. }
  36. //我创建的家族列表
  37. public function getGuildList_mycreate(){
  38. $where = [
  39. 'user_id'=> $this->auth->id,
  40. 'status' => 1,
  41. ];
  42. $res = Db::name('family')->field("id,g_id,user_id,easemob_group_id,name,image,desc,notice,member")
  43. ->where($where)
  44. ->autopage()
  45. ->select();
  46. $res = list_domain_image($res,['image']);
  47. $this->success("获取成功!",$res);
  48. }
  49. //我已经加入的家族列表
  50. public function getGuildList_myjoinin(){
  51. $where = [
  52. 'fm.user_id'=> $this->auth->id,
  53. 'fm.status' => 1,
  54. ];
  55. $res = Db::name('family_member')->alias('fm')
  56. ->field("f.id,f.g_id,f.user_id,f.easemob_group_id,f.name,f.image,f.desc,f.notice,f.member")
  57. ->join('family f','fm.guild_id = f.id','LEFT')
  58. ->where($where)
  59. ->autopage()
  60. ->select();
  61. $res = list_domain_image($res,['image']);
  62. $this->success("获取成功!",$res);
  63. }
  64. /**
  65. * 获取公会信息-新
  66. */
  67. public function getGuildInfoNew() {
  68. $guild_id = input("guild_id",0); //公会ID
  69. $easemob_group_id = input("easemob_group_id",0); //公会群组ID
  70. if(!$guild_id && !$easemob_group_id){
  71. $this->error('不存在的家族');
  72. }
  73. //结果
  74. $res = [];
  75. //公会信息
  76. $map = [];
  77. if($guild_id){
  78. $map['id'] = $guild_id;
  79. }else{
  80. $map['easemob_group_id'] = $easemob_group_id;
  81. }
  82. $guildInfo = \app\common\model\Family::field("id,image,name,g_id,user_id,easemob_group_id,desc,notice,status")->where($map)->find();
  83. if(!$guildInfo) $this->error("家族信息获取失败!");
  84. // 获取公会成员信息
  85. /*$guildMemberInfo = \app\common\model\FamilyMember::alias("a")
  86. ->field("a.id,a.user_id,a.role,u.nickname,u.avatar,u.gender")
  87. ->join("user u","a.user_id = u.id")
  88. ->where(["a.guild_id"=>$guild_id])->where('a.status',1)->limit(10)->order("a.role","desc")->select();*/
  89. // 获取公会成员总数
  90. //$guildMemberCount = \app\common\model\FamilyMember::where(["guild_id"=>$guild_id])->where('status',1)->count("id");
  91. // 获取会长信息
  92. // $guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
  93. //获取家族角色 角色:0=成员,1=副会长,2=会长,3=非会员
  94. $guildMember = \app\common\model\FamilyMember::field('id,role,status')->where(['guild_id'=>$guildInfo['id'],'user_id'=>$this->auth->id,'status'=>1])->find();
  95. if (!empty($guildMember)) {
  96. $guildRole = $guildMember['role'];
  97. }else{
  98. $guildRole = 3;
  99. }
  100. // 返回参数拼接
  101. $res["guildInfo"] = $guildInfo; // 公会基本信息
  102. // $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
  103. //$res["guildMemberCount"] = $guildMemberCount; // 成员总数
  104. //$res["guilderInfo"] = $guilderInfo; // 会长
  105. // $res['guild_status'] = $guildStatus; //家族状态
  106. $res['guild_role'] = $guildRole; //家族角色
  107. $this->success("获取成功!",$res);
  108. }
  109. /**
  110. * 更新公会基本信息
  111. */
  112. public function guildSaveInfo() {
  113. Db::startTrans();
  114. try {
  115. if($this->auth->is_auth != 2){
  116. $this->error('请先完成实名认证');
  117. }
  118. $guild_id = input("guild_id"); //公会id
  119. $guild_name = input("guild_name"); //公会名
  120. $guild_image = input("guild_image"); //logo
  121. $guild_desc = input("guild_desc"); //公会简介
  122. $guild_notice = input("guild_notice"); //公会公告
  123. if(!$guild_name || !$guild_image){
  124. throw new Exception("家族名和logo必填!");
  125. }
  126. $user_id = $this->auth->id;
  127. if (empty($guild_id)) {//新创建
  128. //检查
  129. $guildWhere['user_id'] = $user_id;
  130. $guildWhere['status'] = ['in',[0,1]];
  131. $guildData = model('Family')->where($guildWhere)->find();
  132. if (!empty($guildData)) {
  133. if($guildData['status'] == 1){
  134. throw new Exception('您已创建过家族!');
  135. }else{
  136. throw new Exception('您创建的家族正在审核中!');
  137. }
  138. }
  139. //检查不能是其他家族的成员
  140. $checkmember = model('FamilyMember')->where('user_id',$this->auth->id)->where('status',1)->find();
  141. if (!empty($checkmember)) {
  142. $this->error('您已经加入了其他家族');
  143. }
  144. //检查删除这个人的所有加入申请
  145. $joinData = model('FamilyMember')->where('user_id',$this->auth->id)->where('status',0)->find();
  146. if (!empty($joinData)) {
  147. $this->error('您已经申请加入了其他家族,需等待被拒或退出,才能创建家族');
  148. }
  149. //准备创建
  150. $guildInfo = new \app\common\model\Family();
  151. $ids = \app\common\model\Family::column("g_id");
  152. $guildInfo->user_id = $user_id;
  153. $guildInfo->g_id = getUinqueId(4, [$ids]);
  154. $guildInfo->status = 0;
  155. //去环信建个群组
  156. $easemob = new Easemob();
  157. $maxusers = 300; //普通群:专业版300,旗舰版3000。大型群不支持离线推送
  158. $easemob_group_id = $easemob->group_createPublicGroup($user_id,$guild_name,$guild_desc,$maxusers);
  159. $guildInfo->easemob_group_id = $easemob_group_id;
  160. } else {
  161. // 获取公会信息
  162. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  163. // 验证更新条件
  164. if($user_id !== $guildInfo->user_id) throw new Exception("身份验证失败!您不是族长,无权限更改!");
  165. //如果没有环信群组,给建一个
  166. if(!$guildInfo->easemob_group_id){
  167. //去环信建个群组
  168. $easemob = new Easemob();
  169. $maxusers = 300; //普通群:专业版300,旗舰版3000。大型群不支持离线推送
  170. $easemob_group_id = $easemob->group_createPublicGroup($user_id,$guild_name,$guild_desc,$maxusers);
  171. $guildInfo->easemob_group_id = $easemob_group_id;
  172. }
  173. }
  174. //传参信息
  175. $guild_name && $guildInfo->name = $guild_name;
  176. $guild_image && $guildInfo->image = $guild_image;
  177. $guild_desc && $guildInfo->desc = $guild_desc;
  178. $guild_notice && $guildInfo->notice = $guild_notice;
  179. $res = $guildInfo->save();
  180. if($res === false) {
  181. throw new Exception("网络错误,请稍后重试!");
  182. }
  183. if (empty($guild_id)) {//新创建
  184. //新公会,会长也是成员之一
  185. $guildMemberData = [
  186. 'guild_id' => $guildInfo->id,
  187. 'user_id' => $user_id,
  188. 'role' => 2, //角色:0=成员,1=副会长,2=会长
  189. 'status' => 1,
  190. 'createtime' => time(),
  191. ];
  192. $guildRes = model('FamilyMember')->insertGetId($guildMemberData);
  193. if (!$guildRes) {
  194. throw new Exception('生成成员失败');
  195. }
  196. //更新用户资料
  197. $userWhere['id'] = $user_id;
  198. $user = model('User')->where($userWhere)->find();
  199. if (!empty($user) && $user['family_id'] != $guildInfo->id) {
  200. $userRes = model('User')->where($userWhere)->update(['is_family'=>3,'family_id'=>$guildInfo->id]);
  201. if (!$userRes) {
  202. throw new Exception('用户绑定家族失败');
  203. }
  204. }
  205. }
  206. Db::commit();
  207. $this->success("操作成功!");
  208. } catch (Exception $e) {
  209. Db::rollback();
  210. $this->error($e->getMessage());
  211. }
  212. }
  213. /**
  214. * 公会签约申请
  215. */
  216. public function guildJoinin() {
  217. $guild_id = input("guild_id"); //公会ID
  218. // 一个身份证号只能申请一次
  219. $user_id = $this->auth->id;
  220. // 实名认证
  221. if($this->auth->is_auth != 2){
  222. $this->error('请先完成实名认证');
  223. }
  224. $check = \app\common\model\Family::where(["user_id"=>$this->auth->id])->find();
  225. if($check){
  226. if($check['status'] == 1){
  227. $this->error('您已经有自己的家族了');
  228. }elseif($check['status'] == 0){
  229. $this->error('您已经申请了自己的家族了');
  230. }
  231. }
  232. $check = \app\common\model\FamilyMember::where(["user_id"=>$this->auth->id,'guild_id'=>$guild_id])->find();
  233. if($check){
  234. if($check['status'] == 0){
  235. $this->error('您已经申请进入该家族了,请等待审核');
  236. }
  237. if($check['status'] == 1){
  238. $this->error('您已经是该家族的成员了');
  239. }
  240. }
  241. //
  242. Db::startTrans();
  243. $memberfind = \app\common\model\FamilyMember::where(["user_id"=>$user_id,"status"=>['neq',-1]])->count();
  244. if($memberfind >= 1){
  245. $card = Db::name('user_decorate_family')->where(["user_id"=>$user_id,'decorate_id'=>1,"is_using"=>0])->lock(true)->find();
  246. if(!$card){
  247. Db::rollback();
  248. $this->error('家族卡数量不足');
  249. }
  250. $rs = Db::name('user_decorate_family')->where('id',$card['id'])->update(["is_using"=>1,'updatetime'=>time()]);
  251. if(!$rs){
  252. Db::rollback();
  253. $this->error('使用家族卡失败');
  254. }
  255. }
  256. // 添加数据
  257. $data = [];
  258. $data["user_id"] = $user_id;
  259. $data["guild_id"] = $guild_id;
  260. $data["role"] = 0;
  261. $data["wealth"] = 0;
  262. $data["charm"] = 0;
  263. $data["gift_num"] = 0;
  264. $data["status"] = 0;
  265. $data["createtime"] = time();
  266. $res = \app\common\model\FamilyMember::insert($data);
  267. if($res) {
  268. Db::commit();
  269. $this->success("申请发送成功!");
  270. } else {
  271. Db::rollback();
  272. $this->error("网络错误,请稍后重试!");
  273. }
  274. }
  275. /**
  276. * 公会签约申请审核
  277. */
  278. public function guildMemberExamine() {
  279. $member_id = input("member_id"); // 申请加入的申请ID
  280. $is_pass = input("is_pass"); // 是否通过:1=通过,-1=拒绝
  281. if(!in_array($is_pass,[1,-1]) || !$member_id) $this->error("参数错误!");
  282. $user_id = $this->auth->id;
  283. // 获取申请信息
  284. $memberInfo = \app\common\model\FamilyMember::where(["id"=>$member_id])->find();
  285. if(empty($memberInfo)){
  286. $this->error('未找到申请信息');
  287. }
  288. // 获取公会信息
  289. $guildInfo = \app\common\model\Family::where(["id"=>$memberInfo->guild_id])->find();
  290. // 验证更新条件
  291. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是族长,无权限!");
  292. //判断重复
  293. $memberfind = \app\common\model\Family::where(["user_id"=>$memberInfo['user_id'],"status"=>['IN',[0,1]] ])->find();
  294. if($memberfind) $this->error("该用户已申请了自己的家族!");
  295. Db::startTrans();
  296. try{
  297. // 更新申请状态
  298. $memberInfo->status = $is_pass;
  299. $memberInfo->updatetime = time();
  300. $res2 = $memberInfo->save();
  301. if($is_pass == 1) {
  302. //[环信]把用户加到群组里
  303. $easemob = new Easemob();
  304. $easemob->group_addGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  305. $res4 = \app\common\model\Family::where(["id"=>$guildInfo->id])->setInc("member");
  306. if($res2 && $res4) {
  307. // +message
  308. \app\common\model\Message::addMessage($memberInfo->user_id,"家族审核通知","恭喜,您的加入家族审核通过啦!");
  309. Db::commit();
  310. $this->success("已审核通过!");
  311. }
  312. } else {
  313. if($res2) {
  314. // +message
  315. \app\common\model\Message::addMessage($memberInfo->user_id,"家族审核通知","您的家族加入申请,族长审核拒绝,没关系,调整姿势再来一遍!");
  316. Db::commit();
  317. $this->success("已审核拒绝!");
  318. }
  319. }
  320. $this->error("网络错误,请稍后重试!");
  321. }catch (ValidateException $e) {
  322. Db::rollback();
  323. $this->error($e->getMessage());
  324. } catch (PDOException $e) {
  325. Db::rollback();
  326. $this->error($e->getMessage());
  327. } catch (Exception $e) {
  328. Db::rollback();
  329. $this->error($e->getMessage());
  330. }
  331. }
  332. /**
  333. * 公会申请加入列表
  334. */
  335. public function guildauditList() {
  336. $user_id = $this->auth->id;
  337. // 获取公会信息
  338. $guildInfo = model('Family')->where(["user_id"=>$user_id])->find();
  339. if(!$guildInfo) {
  340. $this->success("获取成功",[]);
  341. }
  342. // 先获取申请列表
  343. $where = [];
  344. $where["m.guild_id"] = $guildInfo->id;
  345. $where["m.status"] = 0;
  346. $result = Db::name('family_member')->alias('m')
  347. ->field("m.id,m.user_id,m.createtime,user.is_online,user.onlinetime,user.nickname,user.avatar")
  348. ->join('user','m.user_id = user.id','LEFT')
  349. ->where($where)->order("m.id","asc")->select();
  350. $result = list_domain_image($result,['avatar']);
  351. if($result) {
  352. foreach($result as $k => &$v) {
  353. if ($v['is_online'] == 1) {
  354. $onlineText = '在线';
  355. } else {
  356. $onlineTime = get_last_time($v['onlinetime']);
  357. $onlineText = $onlineTime.'在线';
  358. $limitTime = time() - (3600 * 6);
  359. if ($v['onlinetime'] < $limitTime) {
  360. $onlineText = '离线';
  361. }
  362. }
  363. $v['online_text'] = $onlineText;
  364. unset($v['user']);
  365. }
  366. }
  367. $this->success("获取成功",$result);
  368. }
  369. /**
  370. * 公会成员列表
  371. */
  372. public function guildMember() {
  373. $guild_id = input("guild_id",0,"intval"); //公会ID
  374. if($guild_id <= 0) $this->error("参数错误!");
  375. $where = [];
  376. $where["a.guild_id"] = $guild_id;
  377. $where["a.status"] = 1;
  378. // 获取公会成员总数
  379. $guildMemberCount = \app\common\model\FamilyMember::alias("a")->where($where)->count("id");
  380. // 获取公会成员列表
  381. $guildMemberList = \app\common\model\FamilyMember::alias("a")
  382. ->field("a.id,a.user_id,u.avatar,u.nickname,u.gender,a.role,u.is_online,u.onlinetime")
  383. ->join("user u","a.user_id = u.id")
  384. ->where($where)
  385. ->autopage()
  386. ->order("a.role","desc")
  387. ->select();
  388. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  389. if($guildMemberList) {
  390. foreach($guildMemberList as $k => &$v) {
  391. $v["role_text"] = $role[$v["role"]];
  392. if ($v['is_online'] == 1) {
  393. $onlineText = '在线';
  394. } else {
  395. $onlineTime = get_last_time($v['onlinetime']);
  396. $onlineText = $onlineTime.'在线';
  397. $limitTime = time() - (3600 * 6);
  398. if ($v['onlinetime'] < $limitTime) {
  399. $onlineText = '离线';
  400. }
  401. }
  402. $v['online_text'] = $onlineText;
  403. }
  404. }
  405. $res = [];
  406. $res["memberCount"] = $guildMemberCount;
  407. $res["memberList"] = $guildMemberList;
  408. $this->success("获取成功!",$res);
  409. }
  410. /**
  411. * 获取公会成员信息,待修改
  412. */
  413. public function getGuildMemberInfo() {
  414. $member_id = input("member_id",0,"intval"); //公会成员ID
  415. if($member_id <= 0) $this->error("参数错误!");
  416. //成员信息
  417. $memberData = Db::name('family_member')->field('id,user_id')->find($member_id);
  418. //更新成员的 财富值 ,魅力值,收到的礼物数量
  419. $userService = new UserService();
  420. $userService->updateFamilyMember(['user_id'=>$memberData['user_id']]);
  421. //从user表拿一些用户信息
  422. $memberInfo = model('FamilyMember')->alias('m')
  423. ->join('user','m.user_id = user.id','LEFT')
  424. ->field('m.id,m.user_id,m.wealth,m.charm,m.gift_num,m.role,m.guild_id,m.createtime,
  425. user.avatar,user.nickname,user.gender,user.logintime,user.is_online,user.onlinetime')
  426. ->where('m.id',$member_id)
  427. ->find();
  428. if(!$memberInfo) $this->error("用户信息获取失败!");
  429. $memberInfo = info_domain_image($memberInfo,['avatar']);
  430. //角色
  431. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  432. $memberInfo["role_text"] = $role[$memberInfo["role"]];
  433. //在线
  434. if ($memberInfo['is_online'] == 1) {
  435. $onlineText = '在线';
  436. } else {
  437. $onlineTime = get_last_time($memberInfo['onlinetime']);
  438. $onlineText = $onlineTime.'在线';
  439. $limitTime = time() - (3600 * 6);
  440. if ($memberInfo['onlinetime'] < $limitTime) {
  441. $onlineText = '离线';
  442. }
  443. }
  444. $memberInfo['online_text'] = $onlineText;
  445. //我在这个公会的角色
  446. $myGuildMember = model('FamilyMember')->field('role')->where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo['guild_id']])->find();
  447. $memberInfo["my_role"] = !empty($myGuildMember) ? $myGuildMember['role'] : 3;
  448. //几个比较大的值,改w单位
  449. $fieldArr = ['wealth','charm','gift_num'];
  450. foreach ($fieldArr as $fkey => $fval) {
  451. if ($memberInfo[$fval] > 10000) {
  452. $memberInfo[$fval] = bcdiv($memberInfo[$fval],10000,2).'w';
  453. }
  454. }
  455. $this->success("获取成功!",$memberInfo);
  456. }
  457. /**
  458. * 公会管理-设为管理员
  459. */
  460. public function guildSetManage() {
  461. $guild_id = input("guild_id",0,"intval"); //公会ID
  462. $member_id = input("member_id",0,"intval"); //成员ID
  463. $type = input("type",1); // 设置类型:1=设为管理员,2=取消管理员
  464. if(!$guild_id || !$member_id || !in_array($type,[1,2])) $this->error("参数缺失!");
  465. $user_id = $this->auth->id;
  466. // 获取公会信息
  467. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  468. // 验证更新条件
  469. if($user_id !== $guildInfo['user_id']) $this->error("身份验证失败!您不是族长,无权限更改!");
  470. $memberInfo = \app\common\model\FamilyMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->where('status',1)->find();
  471. if(!$memberInfo) $this->error("会员信息查询失败!");
  472. //取消管理员
  473. if($type == 2) {
  474. $memberInfo->role = 0;
  475. $memberInfo->updatetime = time();
  476. $res = $memberInfo->save();
  477. if($res) {
  478. //[环信]取消群组管理员
  479. $easemob = new Easemob();
  480. $easemob->group_removeGroupAdmin($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  481. $this->success("取消成功!");
  482. } else {
  483. $this->error("网络错误,请稍后重试!");
  484. }
  485. }
  486. //设置管理员
  487. $memberInfo->role = 1;
  488. $memberInfo->updatetime = time();
  489. $res = $memberInfo->save();
  490. if($res) {
  491. //[环信]设置群组管理员
  492. $easemob = new Easemob();
  493. $easemob->group_addGroupAdmin($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  494. $this->success("设置成功!");
  495. } else {
  496. $this->error("网络错误,请稍后重试!");
  497. }
  498. }
  499. /**
  500. * 公会管理-踢出公会
  501. */
  502. public function guildDelMember() {
  503. $guild_id = input("guild_id",0,"intval"); //公会ID
  504. $member_id = input("member_id",0,"intval"); //成员ID
  505. if(!$guild_id || !$member_id) $this->error("参数缺失!");
  506. // 获取公会信息
  507. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  508. $memberInfo = \app\common\model\FamilyMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->find();
  509. if(!$memberInfo) {
  510. $this->error("会员信息查询失败!");
  511. }
  512. if($memberInfo['role'] == 2 || $memberInfo['user_id'] == $guildInfo['user_id']){
  513. $this->error('族长不能被踢出家族');
  514. }
  515. if($memberInfo['role'] == 1 && $this->auth->id !== $guildInfo->user_id) {
  516. $this->error("族长才能踢出管理员");
  517. }
  518. Db::startTrans();
  519. try{
  520. $res1 = $memberInfo->delete();
  521. $res2 = \app\common\model\Family::where(["id"=>$guild_id])->setDec("member");
  522. if($res1 && $res2) {
  523. Db::commit();
  524. //[环信]移除群组成员
  525. $easemob = new Easemob();
  526. $easemob->group_removeGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  527. $this->success("踢出成功!");
  528. } else {
  529. $this->error("网络错误,请稍后重试!");
  530. }
  531. }catch (ValidateException $e) {
  532. Db::rollback();
  533. $this->error($e->getMessage());
  534. } catch (PDOException $e) {
  535. Db::rollback();
  536. $this->error($e->getMessage());
  537. } catch (Exception $e) {
  538. Db::rollback();
  539. $this->error($e->getMessage());
  540. }
  541. }
  542. /**
  543. * 公会管理-自己退出公会
  544. */
  545. public function guildMemberQuit() {
  546. $guild_id = input("guild_id",0,"intval"); //公会ID
  547. if(!$guild_id) $this->error("参数缺失!");
  548. // 获取公会信息
  549. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  550. $memberInfo = \app\common\model\FamilyMember::where(["user_id"=>$this->auth->id,'guild_id'=>$guild_id])->find();
  551. if(!$memberInfo) {
  552. $this->error("会员信息查询失败!");
  553. }
  554. if($memberInfo['role'] == 2){
  555. $this->error('族长不能退出家族');
  556. }
  557. Db::startTrans();
  558. try{
  559. $res1 = $memberInfo->delete();
  560. $res2 = \app\common\model\Family::where(["id"=>$guild_id])->setDec("member");
  561. if($res1 && $res2) {
  562. Db::commit();
  563. //[环信]移除群组成员
  564. $easemob = new Easemob();
  565. $easemob->group_removeGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  566. $this->success("退出成功!");
  567. } else {
  568. $this->error("网络错误,请稍后重试!");
  569. }
  570. }catch (ValidateException $e) {
  571. Db::rollback();
  572. $this->error($e->getMessage());
  573. } catch (PDOException $e) {
  574. Db::rollback();
  575. $this->error($e->getMessage());
  576. } catch (Exception $e) {
  577. Db::rollback();
  578. $this->error($e->getMessage());
  579. }
  580. }
  581. /**
  582. * 家族贡献榜排行
  583. * @return void
  584. */
  585. public function getRankList()
  586. {
  587. try {
  588. $id = input('guild_id',0);
  589. $guildMemberWhere['guild_id'] = $id;
  590. $guildMemberWhere['status'] = 1;
  591. $guildMember = model('FamilyMember')->field('id,user_id,role')->where($guildMemberWhere)->select();
  592. $list = [];
  593. if (!empty($guildMember)) {
  594. $userIds = array_column($guildMember,'user_id');
  595. $where = [];
  596. $where['a.user_to_id'] = ['in', $userIds];
  597. $list = model('GiftUserParty')->alias("a")
  598. ->field('sum(a.value) as total_price,a.user_to_id,u.avatar,u.nickname,u.is_online,u.onlinetime')
  599. ->where($where)
  600. ->join('user u','u.id = a.user_to_id')
  601. ->group('a.user_to_id')
  602. ->order('total_price',"desc")
  603. ->autopage()
  604. ->select();
  605. if (!empty($list)) {
  606. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  607. $guildMemberData = [];
  608. foreach ($guildMember as $mKey => $mVal) {
  609. $guildMemberData[$mVal['user_id']] = [
  610. 'id' => $mVal['id'],
  611. 'role' => $mVal['role'],
  612. 'role_text' => isset($role[$mVal['role']]) ? $role[$mVal['role']] : '',
  613. ];
  614. }
  615. foreach ($list as $key => &$value) {
  616. $member = isset($guildMemberData[$value['user_to_id']]) ? $guildMemberData[$value['user_to_id']] : [];
  617. $value['member_id'] = isset($member['id']) ? $member['id'] : 0;
  618. $value['role'] = isset($member['role']) ? $member['role'] : 0;
  619. $value['role_text'] = isset($member['role_text']) ? $member['role_text'] : '';
  620. if ($value['is_online'] == 1) {
  621. $onlineText = '在线';
  622. } else {
  623. $onlineTime = get_last_time($value['onlinetime']);
  624. $onlineText = $onlineTime.'在线';
  625. $limitTime = time() - (3600 * 6);
  626. if ($value['onlinetime'] < $limitTime) {
  627. $onlineText = '离线';
  628. }
  629. }
  630. $value['online_text'] = $onlineText;
  631. $value['total_price_text'] = $value['total_price'];
  632. if ($value['total_price'] >= 10000) {
  633. $value['total_price_text'] = bcdiv($value['total_price'],10000,1).'w';
  634. }
  635. unset($value['total_price']);
  636. }
  637. }
  638. }
  639. $this->success(__('Operation completed'),$list);
  640. } catch (Exception $e) {
  641. $this->error($e->getMessage());
  642. }
  643. }
  644. /**
  645. * 获取家族状态
  646. * @return void
  647. */
  648. public function getStatus()
  649. {
  650. $id = input('guild_id',0);
  651. if (!empty($id)) {
  652. $where['id'] = $id;
  653. } else {
  654. $where['user_id'] = $this->auth->id;
  655. }
  656. $field = 'id,status';
  657. $guild = model('Family')->field($field)->where($where)->find();
  658. $this->success('获取成功', $guild);
  659. }
  660. }