Family.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780
  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. if($is_pass == 1){
  294. $memberfind = \app\common\model\Family::where(["user_id"=>$memberInfo['user_id'],"status"=>['IN',[0,1]] ])->find();
  295. if($memberfind) {
  296. $this->error("该用户已申请了自己的家族!");
  297. }
  298. }
  299. Db::startTrans();
  300. try{
  301. // 更新申请状态
  302. $memberInfo->status = $is_pass;
  303. $memberInfo->updatetime = time();
  304. $res2 = $memberInfo->save();
  305. if($is_pass == 1) {
  306. //[环信]把用户加到群组里
  307. $easemob = new Easemob();
  308. $easemob->group_addGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  309. $res4 = \app\common\model\Family::where(["id"=>$guildInfo->id])->setInc("member");
  310. if($res2 && $res4) {
  311. // +message
  312. \app\common\model\Message::addMessage($memberInfo->user_id,"家族审核通知","恭喜,您的加入家族审核通过啦!");
  313. Db::commit();
  314. $this->success("已审核通过!");
  315. }
  316. } else {
  317. if($res2) {
  318. // +message
  319. \app\common\model\Message::addMessage($memberInfo->user_id,"家族审核通知","您的家族加入申请,族长审核拒绝,没关系,调整姿势再来一遍!");
  320. Db::commit();
  321. $this->success("已审核拒绝!");
  322. }
  323. }
  324. $this->error("网络错误,请稍后重试!");
  325. }catch (ValidateException $e) {
  326. Db::rollback();
  327. $this->error($e->getMessage());
  328. } catch (PDOException $e) {
  329. Db::rollback();
  330. $this->error($e->getMessage());
  331. } catch (Exception $e) {
  332. Db::rollback();
  333. $this->error($e->getMessage());
  334. }
  335. }
  336. /**
  337. * 公会申请加入列表
  338. */
  339. public function guildauditList() {
  340. $user_id = $this->auth->id;
  341. // 获取公会信息
  342. $guildInfo = model('Family')->where(["user_id"=>$user_id])->find();
  343. if(!$guildInfo) {
  344. $this->success("获取成功",[]);
  345. }
  346. // 先获取申请列表
  347. $where = [];
  348. $where["m.guild_id"] = $guildInfo->id;
  349. $where["m.status"] = 0;
  350. $result = Db::name('family_member')->alias('m')
  351. ->field("m.id,m.user_id,m.createtime,user.is_online,user.onlinetime,user.nickname,user.avatar")
  352. ->join('user','m.user_id = user.id','LEFT')
  353. ->where($where)->order("m.id","asc")->select();
  354. $result = list_domain_image($result,['avatar']);
  355. if($result) {
  356. foreach($result as $k => &$v) {
  357. if ($v['is_online'] == 1) {
  358. $onlineText = '在线';
  359. } else {
  360. $onlineTime = get_last_time($v['onlinetime']);
  361. $onlineText = $onlineTime.'在线';
  362. $limitTime = time() - (3600 * 6);
  363. if ($v['onlinetime'] < $limitTime) {
  364. $onlineText = '离线';
  365. }
  366. }
  367. $v['online_text'] = $onlineText;
  368. unset($v['user']);
  369. }
  370. }
  371. $this->success("获取成功",$result);
  372. }
  373. /**
  374. * 公会成员列表
  375. */
  376. public function guildMember() {
  377. $guild_id = input("guild_id",0,"intval"); //公会ID
  378. if($guild_id <= 0) $this->error("参数错误!");
  379. $where = [];
  380. $where["a.guild_id"] = $guild_id;
  381. $where["a.status"] = 1;
  382. // 获取公会成员总数
  383. $guildMemberCount = \app\common\model\FamilyMember::alias("a")->where($where)->count("id");
  384. // 获取公会成员列表
  385. $guildMemberList = \app\common\model\FamilyMember::alias("a")
  386. ->field("a.id,a.user_id,u.avatar,u.nickname,u.gender,a.role,u.is_online,u.onlinetime")
  387. ->join("user u","a.user_id = u.id")
  388. ->where($where)
  389. ->autopage()
  390. ->order("a.role","desc")
  391. ->select();
  392. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  393. if($guildMemberList) {
  394. foreach($guildMemberList as $k => &$v) {
  395. $v["role_text"] = $role[$v["role"]];
  396. if ($v['is_online'] == 1) {
  397. $onlineText = '在线';
  398. } else {
  399. $onlineTime = get_last_time($v['onlinetime']);
  400. $onlineText = $onlineTime.'在线';
  401. $limitTime = time() - (3600 * 6);
  402. if ($v['onlinetime'] < $limitTime) {
  403. $onlineText = '离线';
  404. }
  405. }
  406. $v['online_text'] = $onlineText;
  407. }
  408. }
  409. $res = [];
  410. $res["memberCount"] = $guildMemberCount;
  411. $res["memberList"] = $guildMemberList;
  412. $this->success("获取成功!",$res);
  413. }
  414. /**
  415. * 获取公会成员信息,待修改
  416. */
  417. public function getGuildMemberInfo() {
  418. $member_id = input("member_id",0,"intval"); //公会成员ID
  419. if($member_id <= 0) $this->error("参数错误!");
  420. //成员信息
  421. $memberData = Db::name('family_member')->field('id,user_id')->find($member_id);
  422. //更新成员的 财富值 ,魅力值,收到的礼物数量
  423. $userService = new UserService();
  424. $userService->updateFamilyMember(['user_id'=>$memberData['user_id']]);
  425. //从user表拿一些用户信息
  426. $memberInfo = model('FamilyMember')->alias('m')
  427. ->join('user','m.user_id = user.id','LEFT')
  428. ->field('m.id,m.user_id,m.wealth,m.charm,m.gift_num,m.role,m.guild_id,m.createtime,
  429. user.avatar,user.nickname,user.gender,user.logintime,user.is_online,user.onlinetime')
  430. ->where('m.id',$member_id)
  431. ->find();
  432. if(!$memberInfo) $this->error("用户信息获取失败!");
  433. $memberInfo = info_domain_image($memberInfo,['avatar']);
  434. //角色
  435. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  436. $memberInfo["role_text"] = $role[$memberInfo["role"]];
  437. //在线
  438. if ($memberInfo['is_online'] == 1) {
  439. $onlineText = '在线';
  440. } else {
  441. $onlineTime = get_last_time($memberInfo['onlinetime']);
  442. $onlineText = $onlineTime.'在线';
  443. $limitTime = time() - (3600 * 6);
  444. if ($memberInfo['onlinetime'] < $limitTime) {
  445. $onlineText = '离线';
  446. }
  447. }
  448. $memberInfo['online_text'] = $onlineText;
  449. //我在这个公会的角色
  450. $myGuildMember = model('FamilyMember')->field('role')->where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo['guild_id']])->find();
  451. $memberInfo["my_role"] = !empty($myGuildMember) ? $myGuildMember['role'] : 3;
  452. //几个比较大的值,改w单位
  453. $fieldArr = ['wealth','charm','gift_num'];
  454. foreach ($fieldArr as $fkey => $fval) {
  455. if ($memberInfo[$fval] > 10000) {
  456. $memberInfo[$fval] = bcdiv($memberInfo[$fval],10000,2).'w';
  457. }
  458. }
  459. $this->success("获取成功!",$memberInfo);
  460. }
  461. /**
  462. * 公会管理-设为管理员
  463. */
  464. public function guildSetManage() {
  465. $guild_id = input("guild_id",0,"intval"); //公会ID
  466. $member_id = input("member_id",0,"intval"); //成员ID
  467. $type = input("type",1); // 设置类型:1=设为管理员,2=取消管理员
  468. if(!$guild_id || !$member_id || !in_array($type,[1,2])) $this->error("参数缺失!");
  469. $user_id = $this->auth->id;
  470. // 获取公会信息
  471. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  472. // 验证更新条件
  473. if($user_id !== $guildInfo['user_id']) $this->error("身份验证失败!您不是族长,无权限更改!");
  474. $memberInfo = \app\common\model\FamilyMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->where('status',1)->find();
  475. if(!$memberInfo) $this->error("会员信息查询失败!");
  476. //取消管理员
  477. if($type == 2) {
  478. $memberInfo->role = 0;
  479. $memberInfo->updatetime = time();
  480. $res = $memberInfo->save();
  481. if($res) {
  482. //[环信]取消群组管理员
  483. $easemob = new Easemob();
  484. $easemob->group_removeGroupAdmin($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  485. $this->success("取消成功!");
  486. } else {
  487. $this->error("网络错误,请稍后重试!");
  488. }
  489. }
  490. //设置管理员
  491. $memberInfo->role = 1;
  492. $memberInfo->updatetime = time();
  493. $res = $memberInfo->save();
  494. if($res) {
  495. //[环信]设置群组管理员
  496. $easemob = new Easemob();
  497. $easemob->group_addGroupAdmin($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  498. $this->success("设置成功!");
  499. } else {
  500. $this->error("网络错误,请稍后重试!");
  501. }
  502. }
  503. /**
  504. * 公会管理-踢出公会
  505. */
  506. public function guildDelMember() {
  507. $guild_id = input("guild_id",0,"intval"); //公会ID
  508. $member_id = input("member_id",0,"intval"); //成员ID
  509. if(!$guild_id || !$member_id) $this->error("参数缺失!");
  510. // 获取公会信息
  511. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  512. $memberInfo = \app\common\model\FamilyMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->find();
  513. if(!$memberInfo) {
  514. $this->error("会员信息查询失败!");
  515. }
  516. if($memberInfo['role'] == 2 || $memberInfo['user_id'] == $guildInfo['user_id']){
  517. $this->error('族长不能被踢出家族');
  518. }
  519. if($memberInfo['role'] == 1 && $this->auth->id !== $guildInfo->user_id) {
  520. $this->error("族长才能踢出管理员");
  521. }
  522. Db::startTrans();
  523. try{
  524. $res1 = $memberInfo->delete();
  525. $res2 = \app\common\model\Family::where(["id"=>$guild_id])->setDec("member");
  526. if($res1 && $res2) {
  527. Db::commit();
  528. //[环信]移除群组成员
  529. $easemob = new Easemob();
  530. $easemob->group_removeGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  531. $this->success("踢出成功!");
  532. } else {
  533. $this->error("网络错误,请稍后重试!");
  534. }
  535. }catch (ValidateException $e) {
  536. Db::rollback();
  537. $this->error($e->getMessage());
  538. } catch (PDOException $e) {
  539. Db::rollback();
  540. $this->error($e->getMessage());
  541. } catch (Exception $e) {
  542. Db::rollback();
  543. $this->error($e->getMessage());
  544. }
  545. }
  546. /**
  547. * 公会管理-自己退出公会
  548. */
  549. public function guildMemberQuit() {
  550. $guild_id = input("guild_id",0,"intval"); //公会ID
  551. if(!$guild_id) $this->error("参数缺失!");
  552. // 获取公会信息
  553. $guildInfo = \app\common\model\Family::where(["id"=>$guild_id])->find();
  554. $memberInfo = \app\common\model\FamilyMember::where(["user_id"=>$this->auth->id,'guild_id'=>$guild_id])->find();
  555. if(!$memberInfo) {
  556. $this->error("会员信息查询失败!");
  557. }
  558. if($memberInfo['role'] == 2){
  559. $this->error('族长不能退出家族');
  560. }
  561. Db::startTrans();
  562. try{
  563. $res1 = $memberInfo->delete();
  564. $res2 = \app\common\model\Family::where(["id"=>$guild_id])->setDec("member");
  565. if($res1 && $res2) {
  566. Db::commit();
  567. //[环信]移除群组成员
  568. $easemob = new Easemob();
  569. $easemob->group_removeGroupMember($guildInfo['easemob_group_id'],$memberInfo['user_id']);
  570. $this->success("退出成功!");
  571. } else {
  572. $this->error("网络错误,请稍后重试!");
  573. }
  574. }catch (ValidateException $e) {
  575. Db::rollback();
  576. $this->error($e->getMessage());
  577. } catch (PDOException $e) {
  578. Db::rollback();
  579. $this->error($e->getMessage());
  580. } catch (Exception $e) {
  581. Db::rollback();
  582. $this->error($e->getMessage());
  583. }
  584. }
  585. /**
  586. * 家族贡献榜排行
  587. * @return void
  588. */
  589. public function getRankList()
  590. {
  591. try {
  592. $id = input('guild_id',0);
  593. $guildMemberWhere['guild_id'] = $id;
  594. $guildMemberWhere['status'] = 1;
  595. $guildMember = model('FamilyMember')->field('id,user_id,role')->where($guildMemberWhere)->select();
  596. $list = [];
  597. if (!empty($guildMember)) {
  598. $userIds = array_column($guildMember,'user_id');
  599. $where = [];
  600. $where['a.user_to_id'] = ['in', $userIds];
  601. $list = model('GiftUserParty')->alias("a")
  602. ->field('sum(a.value) as total_price,a.user_to_id,u.avatar,u.nickname,u.is_online,u.onlinetime')
  603. ->where($where)
  604. ->join('user u','u.id = a.user_to_id')
  605. ->group('a.user_to_id')
  606. ->order('total_price',"desc")
  607. ->autopage()
  608. ->select();
  609. if (!empty($list)) {
  610. $role = [0=>'成员',1=>'副族长',2=>'族长'];
  611. $guildMemberData = [];
  612. foreach ($guildMember as $mKey => $mVal) {
  613. $guildMemberData[$mVal['user_id']] = [
  614. 'id' => $mVal['id'],
  615. 'role' => $mVal['role'],
  616. 'role_text' => isset($role[$mVal['role']]) ? $role[$mVal['role']] : '',
  617. ];
  618. }
  619. foreach ($list as $key => &$value) {
  620. $member = isset($guildMemberData[$value['user_to_id']]) ? $guildMemberData[$value['user_to_id']] : [];
  621. $value['member_id'] = isset($member['id']) ? $member['id'] : 0;
  622. $value['role'] = isset($member['role']) ? $member['role'] : 0;
  623. $value['role_text'] = isset($member['role_text']) ? $member['role_text'] : '';
  624. if ($value['is_online'] == 1) {
  625. $onlineText = '在线';
  626. } else {
  627. $onlineTime = get_last_time($value['onlinetime']);
  628. $onlineText = $onlineTime.'在线';
  629. $limitTime = time() - (3600 * 6);
  630. if ($value['onlinetime'] < $limitTime) {
  631. $onlineText = '离线';
  632. }
  633. }
  634. $value['online_text'] = $onlineText;
  635. $value['total_price_text'] = $value['total_price'];
  636. if ($value['total_price'] >= 10000) {
  637. $value['total_price_text'] = bcdiv($value['total_price'],10000,1).'w';
  638. }
  639. unset($value['total_price']);
  640. }
  641. }
  642. }
  643. $this->success(__('Operation completed'),$list);
  644. } catch (Exception $e) {
  645. $this->error($e->getMessage());
  646. }
  647. }
  648. /**
  649. * 获取家族状态
  650. * @return void
  651. */
  652. public function getStatus()
  653. {
  654. $id = input('guild_id',0);
  655. if (!empty($id)) {
  656. $where['id'] = $id;
  657. } else {
  658. $where['user_id'] = $this->auth->id;
  659. }
  660. $field = 'id,status';
  661. $guild = model('Family')->field($field)->where($where)->find();
  662. $this->success('获取成功', $guild);
  663. }
  664. }