Guild.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use fast\Random;
  5. use think\Db;
  6. use think\Exception;
  7. use Redis;
  8. use app\api\controller\Tenim;
  9. use app\common\service\RoomService;
  10. /**
  11. * 公会控制器
  12. */
  13. class Guild extends Api
  14. {
  15. protected $noNeedLogin = ['getGuildList'];
  16. protected $noNeedRight = ['*'];
  17. /**
  18. * 获取公会信息
  19. */
  20. public function getGuildInfo() {
  21. $guild_id = $this->request->request("guild_id"); //公会ID
  22. $is_member = 0;
  23. if($guild_id <= 0) {
  24. $is_member = 1;
  25. $user_id = $this->auth->id;
  26. // 获取当前用户是否是公会成员
  27. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  28. if($idcardfind) $this->error("您存在加入公会的申请,正在审核中,请耐心等待!");
  29. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
  30. if($memberfind) $guild_id = $memberfind->guild_id;
  31. if(!$guild_id) {
  32. $res["is_member"] = 2; // 是否为派对成员
  33. $this->success("获取成功!",$res);
  34. }
  35. }
  36. $res = [];
  37. $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice")->where(["id"=>$guild_id])->find();
  38. // 获取公会成员信息
  39. $guildMemberInfo = \app\common\model\GuildMember::alias("a")
  40. ->field("a.user_id,a.role,u.nickname,u.avatar,u.gender,u.age")
  41. ->join("hx_user u","a.user_id = u.id")
  42. ->where(["a.guild_id"=>$guild_id])->limit(5)->order("a.role","desc")->select();
  43. if(!$guildInfo || !$guildMemberInfo) $this->error("公会信息获取失败!");
  44. // 获取公会成员总数
  45. $guildMemberCount = \app\common\model\GuildMember::where(["guild_id"=>$guild_id])->count("id");
  46. // 获取会长信息
  47. $guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
  48. // 获取房间信息
  49. $partyInfo = \app\common\model\Party::field("party_logo,party_type,is_online,party_name,party_notice_detail")->where(["id"=>$guildInfo->party_id])->find();
  50. // 派对类型
  51. $partyTypeName = "普通房";
  52. if($partyInfo["party_type"]) {
  53. $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
  54. }
  55. $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
  56. $partyInfo["party_type_color"] = $mod == 0?5:$mod;
  57. $partyInfo["type_name"] = $partyTypeName;
  58. // 返回参数拼接
  59. $res["guildInfo"] = $guildInfo; // 公会基本信息
  60. $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
  61. $res["guildMemberCount"] = $guildMemberCount; // 成员总数
  62. $res["guilderInfo"] = $guilderInfo; // 会长
  63. $res["partyInfo"] = $partyInfo; // 派对悉尼下
  64. $res["is_member"] = $is_member; // 是否为派对成员
  65. $this->success("获取成功!",$res);
  66. }
  67. /**
  68. * 获取公会信息-新
  69. */
  70. public function getGuildInfoNew() {
  71. $guild_id = $this->request->request("guild_id"); //公会ID
  72. $is_member = 0;
  73. if($guild_id <= 0) {
  74. $is_member = 1;
  75. $user_id = $this->auth->id;
  76. // 获取当前用户是否是公会成员
  77. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  78. if($idcardfind) $this->error("您存在加入公会的申请,正在审核中,请耐心等待!");
  79. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
  80. if($memberfind) $guild_id = $memberfind->guild_id;
  81. if(!$guild_id) {
  82. $res["is_member"] = 2; // 是否为派对成员
  83. $this->success("获取成功!",$res);
  84. }
  85. }
  86. $res = [];
  87. $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice")->where(["id"=>$guild_id])->find();
  88. // 获取公会成员信息
  89. $guildMemberInfo = \app\common\model\GuildMember::alias("a")
  90. ->field("a.user_id,a.role,u.nickname,u.avatar")
  91. ->join("hx_user u","a.user_id = u.id")
  92. ->where(["a.guild_id"=>$guild_id])->limit(5)->order("a.role","desc")->select();
  93. if(!$guildInfo || !$guildMemberInfo) $this->error("公会信息获取失败!");
  94. // 获取公会成员总数
  95. $guildMemberCount = \app\common\model\GuildMember::where(["guild_id"=>$guild_id])->count("id");
  96. // 获取会长信息
  97. //$guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
  98. // 获取房间信息
  99. $partyInfo = \app\common\model\Party::field("id,party_logo,party_type,is_online,party_name,party_notice_detail")->where(["id"=>$guildInfo->party_id])->find();
  100. $partyParams = ['party_id' => $guildInfo->party_id];
  101. $roomService = new RoomService();
  102. $partyOnlineRes = $roomService->getPartyUserList($partyParams);
  103. $onlineData = isset($partyOnlineRes['data']) ? $partyOnlineRes['data'] : [];
  104. $partyInfo['user_list'] = isset($onlineData['user_list']) ? $onlineData['user_list'] : [];
  105. $partyInfo['online_num'] = isset($onlineData['online_num']) ? $onlineData['online_num'] : 0;
  106. // 派对类型
  107. $partyTypeName = "普通房";
  108. if($partyInfo["party_type"]) {
  109. $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
  110. }
  111. $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
  112. $partyInfo["party_type_color"] = $mod == 0?5:$mod;
  113. $partyInfo["type_name"] = $partyTypeName;
  114. // 返回参数拼接
  115. $res["guildInfo"] = $guildInfo; // 公会基本信息
  116. $res["partyInfo"] = $partyInfo; // 派对悉尼下
  117. $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
  118. $res["guildMemberCount"] = $guildMemberCount; // 成员总数
  119. //$res["guilderInfo"] = $guilderInfo; // 会长
  120. $res["is_member"] = $is_member; // 是否为派对成员
  121. $this->success("获取成功!",$res);
  122. }
  123. /**
  124. * 更新公会基本信息
  125. */
  126. public function guildSaveInfo() {
  127. $guild_id = $this->request->request("guild_id"); //公会id
  128. $guild_name = $this->request->request("guild_name"); //公会简介
  129. $guild_image = $this->request->request("guild_image"); //公会简介
  130. $guild_desc = $this->request->request("guild_desc"); //公会简介
  131. $guild_notice = $this->request->request("guild_notice"); //公会公告
  132. if(!$guild_name && !$guild_image && !$guild_desc && !$guild_notice) $this->error("请输入要修改的内容!");
  133. $user_id = $this->auth->id;
  134. if (empty($guild_id)) {
  135. $guildInfo = new \app\common\model\Guild();
  136. $guildInfo->user_id = $user_id;
  137. $ids = \app\common\model\Guild::column("g_id");
  138. $guildInfo->g_id = getUinqueId(4, [$ids]);
  139. $guildInfo->status = 0;
  140. } else {
  141. // 获取公会信息
  142. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  143. // 验证更新条件
  144. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  145. }
  146. $guild_name && $guildInfo->name = $guild_name;
  147. $guild_image && $guildInfo->image = $guild_image;
  148. $guild_desc && $guildInfo->desc = $guild_desc;
  149. $guild_notice && $guildInfo->notice = $guild_notice;
  150. $res = $guildInfo->save();
  151. if($res !== false) {
  152. $this->success("操作成功!");
  153. } else {
  154. $this->error("网络错误,请稍后重试!");
  155. }
  156. }
  157. /**
  158. * 获取搜索公会列表
  159. */
  160. public function getGuildList() {
  161. $search = $this->request->request("search","","string"); //搜索的字段 公会名称/公会ID
  162. $page = $this->request->request("page",1);
  163. $pageNum = $this->request->request("pageNum",10);
  164. $offset = ($page-1) * $pageNum;
  165. //if(!$search) $this->error("请输入要搜索的公会名称或公会ID");
  166. global $whereOr;
  167. $where = [];$whereOr = [];
  168. $where['status'] = 1;
  169. if (!empty($search)) {
  170. $whereOr['name'] = array('like', '%' . $search . '%');
  171. $whereOr['g_id'] = $search;
  172. }
  173. $res = \app\common\model\Guild::field("id,g_id,user_id,party_id,name,image,desc,member")
  174. ->where($where)
  175. ->where(function ($query) {
  176. global $whereOr;
  177. $query->whereOr($whereOr);
  178. })
  179. ->limit($offset,$pageNum)
  180. ->select();
  181. $this->success("获取成功!",$res);
  182. }
  183. /**
  184. * 公会申请页面信息
  185. */
  186. public function guildApplyInfo() {
  187. $guild_id = $this->request->request("guild_id"); //公会ID
  188. if($guild_id <= 0) $this->error("参数缺失!");
  189. $guildInfo = \app\common\model\Guild::alias("a")
  190. ->join("hx_user u","u.id = a.user_id","inner")
  191. ->field("a.id,a.image,a.name,a.g_id,a.user_id,u.avatar,u.nickname,u.u_id")
  192. ->where(["a.id"=>$guild_id])
  193. ->find();
  194. $guildInfo["status"] = 0;
  195. // 获取申请用户是否已经有正在申请的记录
  196. $user_id = $this->auth->id;
  197. $joinStatus = \app\common\model\GuildJoinin::where(["user_id"=>$user_id])->value("status");
  198. if($joinStatus === 0) $guildInfo["status"] = 1;
  199. $Member = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->value("id");
  200. if($Member > 0) $guildInfo["status"] = 2;
  201. $this->success("获取成功!",$guildInfo);
  202. }
  203. /**
  204. * 开厅申请
  205. */
  206. public function guildApply() {
  207. $user_id = $this->auth->id;
  208. // 获取用户实名认证信息
  209. $authUserRealname = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("realname");
  210. if(!$authUserRealname) $this->error("未查询到实名认证信息,请实名认证先!");
  211. // 获取用户信息
  212. $userInfo = \app\common\model\User::field("id,mobile,nickname")->where(["id"=>$user_id])->find();
  213. $data = [];
  214. $data["user_id"] = $user_id;
  215. // 查看是否申请过
  216. $applyInfo = \app\common\model\GuildApply::where($data)->find();
  217. if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了,请勿重复发送!");
  218. // 查看是否有加入公会的申请
  219. $joinInfo = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  220. if($joinInfo) $this->error("您存在申请加入公会信息,请联系工会长处理完毕后方可申请开厅!");
  221. // 查看是已经是公会成员
  222. $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
  223. if($memberInfo) $this->error("您已存在签约中的公会,无法开新厅!");
  224. Db::startTrans();
  225. try{
  226. $data["user_name"] = $authUserRealname;
  227. $data["user_nickname"] = $userInfo->nickname;
  228. $data["user_mobile"] = $userInfo->mobile;
  229. $data["createtime"] = time();
  230. $res1 = \app\common\model\GuildApply::insert($data);
  231. // 更新用户状态
  232. $userInfo->is_guild = 1;
  233. $res2 = $userInfo->save();
  234. if($res1 && $res2) {
  235. Db::commit();
  236. $this->success("申请发送成功!");
  237. } else {
  238. $this->error("网络错误,请稍后重试!");
  239. }
  240. }catch (ValidateException $e) {
  241. Db::rollback();
  242. $this->error($e->getMessage());
  243. } catch (PDOException $e) {
  244. Db::rollback();
  245. $this->error($e->getMessage());
  246. } catch (Exception $e) {
  247. Db::rollback();
  248. $this->error($e->getMessage());
  249. }
  250. }
  251. /**
  252. * 公会签约申请
  253. */
  254. public function guildJoinin() {
  255. $join_time = $this->request->request("join_time"); //签约时长:1=3个月,2=6个月,3=12个月
  256. $guild_id = $this->request->request("guild_id"); //公会ID
  257. if(!in_array($join_time,[1,2,3]) || !$guild_id) $this->error("参数错误!");
  258. // 一个身份证号只能申请一次
  259. $user_id = $this->auth->id;
  260. // 实名认证
  261. $userAuthInfo = \app\common\model\UserAuth::where(["user_id"=>$user_id])->find();
  262. if($userAuthInfo) {
  263. if($userAuthInfo->status == 0) {
  264. $this->error("您的实名认证还在这审核中...,请耐心等待!");
  265. } elseif($userAuthInfo->status == 2) {
  266. $this->error("您的实名认证审核未通过,请重新审核!");
  267. }
  268. } else {
  269. $this->error("请先申请实名认证!");
  270. }
  271. // 获取用户实名认证信息
  272. $authUserIdcard = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("idcard");
  273. // 搜索签约申请中是否有此身份证号
  274. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  275. if($idcardfind) $this->error("当前账号正在审核,请耐心等待!");
  276. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id,"status"=>1,"sign_time"=>["gt",time()]])->find();
  277. if($memberfind) $this->error("一个账号只能加入一个公会哟!");
  278. // 查看是否申请过
  279. $applyInfo = \app\common\model\GuildApply::where(["user_id"=>$user_id,"status"=>0])->find();
  280. if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了,请勿重复发送!");
  281. // // 获取公会信息
  282. // $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id,"status"=>1])->find();
  283. // // 验证更新条件
  284. // if($guildInfo) $this->error("您存在公会会长身份,请先解散相应的公会才可申请");
  285. // 获取公会信息
  286. $guildName = \app\common\model\Guild::where(["id"=>$guild_id])->value("name");
  287. // 获取用户信息
  288. $userInfo = \app\common\model\User::field("id,avatar,nickname")->where(["id"=>$user_id])->find();
  289. // 添加数据
  290. $data = [];
  291. $data["user_id"] = $user_id;
  292. $data["guild_id"] = $guild_id;
  293. $data["join_time"] = $join_time;
  294. $data["user_avatar"] = $userInfo->avatar;
  295. $data["user_idcard"] = $authUserIdcard;
  296. $data["user_nickname"] = $userInfo->nickname;
  297. $data["guild_name"] = $guildName;
  298. $data["createtime"] = time();
  299. $res = \app\common\model\GuildJoinin::insert($data);
  300. if($res) {
  301. // +message
  302. // \app\common\model\Message::addMessage($user_id,"公会消息","申请加入公会消息");
  303. $this->success("申请发送成功!");
  304. } else {
  305. $this->error("网络错误,请稍后重试!");
  306. }
  307. }
  308. /**
  309. * 公会签约申请审核
  310. */
  311. public function guildJoininExamine() {
  312. $joinin_id = $this->request->request("joinin_id"); // 申请加入的申请ID
  313. $is_pass = $this->request->request("is_pass"); // 是否通过:1=通过,-1=拒绝
  314. if(!in_array($is_pass,[1,-1]) || !$joinin_id) $this->error("参数错误!");
  315. $user_id = $this->auth->id;
  316. // 获取申请信息
  317. $joininInfo = \app\common\model\GuildJoinin::where(["id"=>$joinin_id])->find();
  318. // 获取公会信息
  319. $guildInfo = \app\common\model\Guild::where(["id"=>$joininInfo->guild_id])->find();
  320. // 验证更新条件
  321. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  322. // 获取用户信息
  323. $userInfo = \app\common\model\User::field("id,u_id,mobile,nickname")->where(["id"=>$joininInfo->user_id])->find();
  324. // 计算签约时间段
  325. $join_time = $joininInfo->join_time;
  326. $timeArr = [1=>3,2=>6,3=>12];
  327. $endtime = strtotime('+'.$timeArr[$join_time].' month');
  328. $sign_time_slot = date("Y.m.d")."-".date('Y.m.d',$endtime);
  329. Db::startTrans();
  330. try{
  331. $data = [];
  332. $data["user_id"] = $joininInfo->user_id;
  333. $data["operator"] = $user_id;
  334. $data["user_nickname"] = $userInfo->nickname;
  335. $data["user_u_id"] = $userInfo->u_id;
  336. $data["guild_id"] = $guildInfo->id;
  337. $data["guild_name"] = $guildInfo->name;
  338. $data["guild_g_id"] = $guildInfo->g_id;
  339. $data["sign_time_slot"] = $sign_time_slot;
  340. $data["status"] = $is_pass;
  341. $data["createtime"] = time();
  342. $res1 = \app\common\model\GuildJoininLog::insert($data);
  343. // 更新申请状态
  344. $joininInfo->status = $is_pass;
  345. $joininInfo->updatetime = time();
  346. $res2 = $joininInfo->save();
  347. if($is_pass == 1) {
  348. // 同意后 加入公会成员
  349. $data = [];
  350. $data["guild_id"] = $guildInfo->id;
  351. $data["user_id"] = $joininInfo->user_id;
  352. $data["role"] = 0;
  353. $data["sign_type"] = $join_time; // 签约类型:1=三个月,2=半年,3=一年
  354. $data["sign_time"] = $endtime;
  355. $data["status"] = 1;
  356. $data["createtime"] = time();
  357. $res3 = \app\common\model\GuildMember::insert($data);
  358. $res4 = \app\common\model\Guild::where(["id"=>$guildInfo->id])->setInc("member");
  359. if($res1 && $res2 && $res3 && $res4) {
  360. // +message
  361. \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","恭喜,您的加入公会审核通过啦!公会ID:".$guildInfo->g_id);
  362. Db::commit();
  363. $this->success("已审核通过!");
  364. }
  365. } else {
  366. if($res1 && $res2) {
  367. // +message
  368. \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","您的公会加入申请,公会长审核失败,没关系,调整姿势再来一遍!");
  369. Db::commit();
  370. $this->success("已审核拒绝!");
  371. }
  372. }
  373. $this->error("网络错误,请稍后重试!");
  374. }catch (ValidateException $e) {
  375. Db::rollback();
  376. $this->error($e->getMessage());
  377. } catch (PDOException $e) {
  378. Db::rollback();
  379. $this->error($e->getMessage());
  380. } catch (Exception $e) {
  381. Db::rollback();
  382. $this->error($e->getMessage());
  383. }
  384. }
  385. /**
  386. * 公会助手列表
  387. */
  388. public function guildAssistantList() {
  389. $user_id = $this->auth->id;
  390. // 获取公会信息
  391. $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id])->find();
  392. if(!$guildInfo) $this->error("公会信息获取失败!");
  393. // 先获取申请列表
  394. $where = [];
  395. $where["guild_id"] = $guildInfo->id;
  396. $where["status"] = 0;
  397. $joinList = \app\common\model\GuildJoinin::field("id,user_avatar,user_nickname,guild_name,createtime")->where($where)->order("createtime","desc")->select();
  398. if($joinList) foreach($joinList as $k => $v) {
  399. $joinList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
  400. }
  401. // 再获取审核记录
  402. $where = [];
  403. $where["a.guild_id"] = $guildInfo->id;
  404. $where["a.user_id"] = $user_id;
  405. $joinlogList = \app\common\model\GuildJoininLog::alias("a")
  406. ->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")
  407. ->join("hx_user u","a.operator = u.id")
  408. ->whereOr($where)
  409. ->order("a.createtime","desc")
  410. ->select();
  411. if($joinlogList) foreach($joinlogList as $k => $v) {
  412. $joinlogList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
  413. }
  414. $res = [];
  415. $res["joinList"] = $joinList;
  416. $res["joinlogList"] = $joinlogList;
  417. $this->success("获取成功!",$res);
  418. }
  419. /**
  420. * 公会申请加入列表
  421. */
  422. public function guildJoinList() {
  423. try {
  424. $user_id = $this->auth->id;
  425. // 获取公会信息
  426. $guildInfo = model('Guild')->where(["user_id"=>$user_id])->find();
  427. if(!$guildInfo) throw new Exception('公会信息获取失败!');
  428. // 先获取申请列表
  429. $where = [];
  430. $where["guild_id"] = $guildInfo->id;
  431. $where["status"] = 0;
  432. $result = model('GuildJoinin')->field("id,user_id,user_avatar,user_nickname,guild_name,createtime")
  433. ->with(['user'=>function($uQuery){
  434. $uQuery->field('id,is_online,onlinetime');
  435. }])
  436. ->where($where)->order("createtime","desc")->select();
  437. if($result) {
  438. foreach($result as $k => &$v) {
  439. $user = isset($v['user']) ? $v['user'] : [];
  440. $onlineText = '';
  441. if (!empty($user)) {
  442. if ($user['is_online'] == 1) {
  443. $onlineText = '在线';
  444. } else {
  445. $onlineTime = get_last_time($user['onlinetime']);
  446. $onlineText = $onlineTime.'在线';
  447. }
  448. }
  449. $v['online_text'] = $onlineText;
  450. $v['createtime'] = !empty($v["createtime"]) ? date("Y-m-d H:i", $v["createtime"]) : '';
  451. unset($v['user']);
  452. }
  453. }
  454. $this->success("获取成功",$result);
  455. } catch (Exception $e) {
  456. $this->error($e->getMessage());
  457. }
  458. }
  459. /**
  460. * 公会成员列表
  461. */
  462. public function guildMember() {
  463. $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
  464. $page = $this->request->request('page',1); // 分页
  465. $pageNum = $this->request->request('pageNum',10); // 分页
  466. // 分页搜索构建
  467. $pageStart = ($page-1)*$pageNum;
  468. if($guild_id <= 0) $this->error("参数错误!");
  469. $where = [];
  470. $where["a.guild_id"] = $guild_id;
  471. $where["a.status"] = 1;
  472. $where["a.sign_time"] = ["gt",time()];
  473. // 获取公会成员总数
  474. $guildMemberCount = \app\common\model\GuildMember::alias("a")->where($where)->count("id");
  475. // 获取公会成员列表
  476. $guildMemberList = \app\common\model\GuildMember::alias("a")
  477. ->field("a.id,u.avatar,u.nickname,u.gender,u.age,a.role")
  478. ->join("hx_user u","a.user_id = u.id")
  479. ->where($where)
  480. ->limit($pageStart,$pageNum)
  481. ->order("a.role","desc")
  482. ->select();
  483. $role = ["","管理","会长"];
  484. if($guildMemberList) foreach($guildMemberList as $k => &$v) {
  485. $v["role"] = $role[$v["role"]];
  486. }
  487. $res = [];
  488. $res["memberCount"] = $guildMemberCount;
  489. $res["memberList"] = $guildMemberList;
  490. $this->success("获取成功!",$res);
  491. }
  492. /**
  493. * 获取公会成员信息
  494. */
  495. public function getGuildMemberInfo() {
  496. $member_id = $this->request->request("member_id",0,"intval"); //公会成员ID
  497. if($member_id <= 0) $this->error("参数错误!");
  498. $memberInfo = \app\common\model\GuildMember::alias("a")
  499. ->join("hx_user u","u.id = a.user_id")
  500. ->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")
  501. ->find($member_id);
  502. if(!$memberInfo) $this->error("用户信息获取失败!");
  503. $memberInfo["createtime"] = date("Y-m-d",$memberInfo["createtime"]);
  504. $memberInfo["logintime"] = date("Y-m-d",$memberInfo["logintime"]);
  505. $memberInfo["my_role"] = \app\common\model\GuildMember::where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo->guild_id])->value("role");
  506. $this->success("获取成功!",$memberInfo);
  507. }
  508. /**
  509. * 公会管理-设为管理员
  510. */
  511. public function guildSetManage() {
  512. $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
  513. $member_user_id = $this->request->request("member_user_id",0,"intval"); //成员用户ID
  514. $type = $this->request->request("type",1); // 设置类型:1=设为管理员,2=取消管理员
  515. if(!$guild_id || !$member_user_id || !in_array($type,[1,2])) $this->error("参数缺失!");
  516. // 先判断是否为公会会长
  517. $user_id = $this->auth->id;
  518. // 获取公会信息
  519. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  520. // 验证更新条件
  521. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  522. $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$member_user_id])->find();
  523. if(!$memberInfo) $this->error("会员信息查询失败!");
  524. if($type == 2) {
  525. $memberInfo->role = 0;
  526. $memberInfo->updatetime = time();
  527. $res = $memberInfo->save();
  528. if($res) {
  529. $this->success("取消成功!");
  530. } else {
  531. $this->error("网络错误,请稍后重试!");
  532. }
  533. }
  534. $memberInfo->role = 1;
  535. $memberInfo->updatetime = time();
  536. $res = $memberInfo->save();
  537. if($res) {
  538. // 获取房间id
  539. $party_id = $guildInfo->party_id;
  540. // 添加房间管理员
  541. $redis = new Redis();
  542. $redisconfig = config("redis");
  543. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  544. if ($redisconfig['redis_pwd']) {
  545. $redis->auth($redisconfig['redis_pwd']);
  546. }
  547. if($redisconfig['redis_selectdb'] > 0){
  548. $redis->select($redisconfig['redis_selectdb']);
  549. }
  550. // 获取成员用户信息
  551. $memberuserInfo = \app\common\model\User::field("id,avatar,nickname,gender,level")->find($member_user_id);
  552. $data = [];
  553. $data["user_id"] = $memberuserInfo->id;
  554. $data["avatar"] = $memberuserInfo->avatar;
  555. $data["nickname"] = $memberuserInfo->nickname;
  556. $data["gender"] = $memberuserInfo->gender;
  557. $data["level"] = $memberuserInfo->level;
  558. $data["item"] = 1;
  559. $data["time"] = 0;
  560. $data["createtime"] = time();
  561. $redis->hSet("party_manage_".$party_id,$memberuserInfo->id."-1",serialize($data));
  562. // 腾讯im设置管理员
  563. $tenim = new Tenim();
  564. $tenim->setImManage($member_user_id,$party_id);
  565. $this->success("设置成功!");
  566. } else {
  567. $this->error("网络错误,请稍后重试!");
  568. }
  569. }
  570. /**
  571. * 公会管理-踢出公会
  572. */
  573. public function guildDelMember() {
  574. $guild_id = $this->request->request("guild_id",0,"intval"); //公会ID
  575. $member_user_id = $this->request->request("member_user_id",0,"intval"); //成员用户ID
  576. if(!$guild_id || !$member_user_id) $this->error("参数缺失!");
  577. // 先判断是否为公会会长
  578. $user_id = $this->auth->id;
  579. // 获取公会信息
  580. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  581. // 验证更新条件
  582. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  583. $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$member_user_id])->find();
  584. if(!$memberInfo) $this->error("会员信息查询失败!");
  585. Db::startTrans();
  586. try{
  587. $res1 = $memberInfo->delete();
  588. $res2 = \app\common\model\Guild::where(["id"=>$guild_id])->setDec("member");
  589. if($res1 && $res2) {
  590. Db::commit();
  591. $this->success("踢出成功!");
  592. } else {
  593. $this->error("网络错误,请稍后重试!");
  594. }
  595. }catch (ValidateException $e) {
  596. Db::rollback();
  597. $this->error($e->getMessage());
  598. } catch (PDOException $e) {
  599. Db::rollback();
  600. $this->error($e->getMessage());
  601. } catch (Exception $e) {
  602. Db::rollback();
  603. $this->error($e->getMessage());
  604. }
  605. }
  606. /**
  607. * 家族贡献榜排行
  608. * @return void
  609. */
  610. public function getRankList()
  611. {
  612. try {
  613. $id = $this->request->param('guild_id',0);
  614. $guildMemberWhere['guild_id'] = $id;
  615. $guildMemberWhere['status'] = 1;
  616. $guildMember = model('GuildMember')->field('id,user_id')->where($guildMemberWhere)->select();
  617. $list = [];
  618. if (!empty($guildMember)) {
  619. $userIds = array_column($guildMember,'user_id');
  620. $where = [];
  621. $where['a.user_to_id'] = ['in', $userIds];
  622. $list = model('GiftUserParty')->alias("a")
  623. ->field('sum(a.value) as total_price,a.user_id,u.avatar,u.nickname')
  624. ->where($where)
  625. ->join('hx_user u','u.id = a.user_id')
  626. ->group('a.user_to_id')
  627. ->order('total_price',"desc")
  628. ->limit(100)
  629. ->select();
  630. if (!empty($list)) {
  631. foreach ($list as $key => &$value) {
  632. $value['total_price_text'] = $value['total_price'];
  633. if ($value['total_price'] >= 10000) {
  634. $value['total_price_text'] = bcdiv($value['total_price'],10000,1).'w';
  635. }
  636. unset($value['total_price']);
  637. }
  638. }
  639. }
  640. $this->success(__('Operation completed'),$list);
  641. } catch (Exception $e) {
  642. $this->error($e->getMessage());
  643. }
  644. }
  645. }