Guild.php 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use app\common\service\UserService;
  5. use fast\Random;
  6. use think\Db;
  7. use think\Exception;
  8. use Redis;
  9. use app\api\controller\Tenim;
  10. use app\common\service\RoomService;
  11. /**
  12. * 公会控制器
  13. */
  14. class Guild extends Api
  15. {
  16. protected $noNeedLogin = ['getGuildList'];
  17. protected $noNeedRight = ['*'];
  18. /**
  19. * 获取搜索公会列表
  20. */
  21. public function getGuildList() {
  22. $search = input("search","","string"); //搜索的字段 公会名称/公会ID
  23. $where = [];$whereOr = [];
  24. $where['status'] = 1;
  25. if (!empty($search)) {
  26. $whereOr['name'] = array('like', '%' . $search . '%');
  27. $whereOr['g_id'] = $search;
  28. }
  29. $res = Db::name('guild')->field("id,g_id,user_id,party_id,name,image,desc,member")
  30. ->where($where)
  31. ->where(function ($query) use($whereOr) {
  32. $query->whereOr($whereOr);
  33. })
  34. ->autopage()
  35. ->select();
  36. $res = list_domain_image($res,['image']);
  37. $this->success("获取成功!",$res);
  38. }
  39. /**
  40. * 获取公会信息
  41. */
  42. public function getGuildInfo() {
  43. $guild_id = input("guild_id"); //公会ID
  44. $is_member = 0;
  45. $user_id = $this->auth->id;
  46. if($guild_id <= 0) {
  47. $is_member = 1;
  48. // 获取当前用户是否是公会成员
  49. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  50. if($idcardfind) $this->error("您存在加入公会的申请,正在审核中,请耐心等待!");
  51. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id])->find();
  52. if($memberfind) $guild_id = $memberfind->guild_id;
  53. if(!$guild_id) {
  54. $res["is_member"] = 2; // 是否为派对成员
  55. $this->success("获取成功!",$res);
  56. }
  57. }
  58. //结果
  59. $res = [];
  60. //公会信息
  61. $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice,status")->where(["id"=>$guild_id])->find();
  62. // 获取公会成员信息
  63. $guildMemberInfo = \app\common\model\GuildMember::alias("a")
  64. ->field("a.id,a.user_id,a.role,u.nickname,u.avatar,u.gender")
  65. ->join("hx_user u","a.user_id = u.id")
  66. ->where(["a.guild_id"=>$guild_id])->limit(10)->order("a.role","desc")->select();
  67. if(!$guildInfo || !$guildMemberInfo) $this->error("公会信息获取失败!");
  68. // 获取公会成员总数
  69. $guildMemberCount = \app\common\model\GuildMember::where(["guild_id"=>$guild_id])->count("id");
  70. // 获取会长信息
  71. $guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
  72. // 获取房间信息
  73. $partyInfo = \app\common\model\Party::field("id,party_logo,party_type,is_online,party_name,party_notice_detail")->where(["id"=>$guildInfo->party_id])->find();
  74. // 派对类型
  75. $partyTypeName = "普通房";
  76. if($partyInfo["party_type"]) {
  77. $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
  78. }
  79. $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
  80. $partyInfo["party_type_color"] = $mod == 0?5:$mod;
  81. $partyInfo["type_name"] = $partyTypeName;
  82. // 返回参数拼接
  83. $res["guildInfo"] = $guildInfo; // 公会基本信息
  84. $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
  85. $res["guildMemberCount"] = $guildMemberCount; // 成员总数
  86. $res["guilderInfo"] = $guilderInfo; // 会长
  87. $res["partyInfo"] = $partyInfo; // 派对悉尼下
  88. $res["is_member"] = $is_member; // 是否为派对成员
  89. $this->success("获取成功!",$res);
  90. }
  91. /**
  92. * 获取公会信息-新
  93. */
  94. public function getGuildInfoNew() {
  95. $guild_id = input("guild_id"); //公会ID
  96. $is_member = 0;
  97. $user_id = $this->auth->id;
  98. if($guild_id <= 0) {
  99. $is_member = 1;
  100. // 获取当前用户是否是公会成员
  101. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  102. if($idcardfind) $this->error("您存在加入公会的申请,正在审核中,请耐心等待!");
  103. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id])->find();
  104. if($memberfind) {
  105. $guild_id = $memberfind->guild_id;
  106. }
  107. $guildWhere['user_id'] = $user_id;
  108. $guildWhere['status'] = ['in',[0,1]];
  109. $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice,status")->where($guildWhere)->find();
  110. if(!$guild_id) {
  111. $res["is_member"] = 2; // 是否为派对成员
  112. $res["guild_status"] = isset($guildInfo['status']) ? (int)$guildInfo['status'] : -2; // 是否为派对成员
  113. $this->success("获取成功!",$res);
  114. }
  115. }
  116. //结果
  117. $res = [];
  118. //公会信息
  119. $guildInfo = \app\common\model\Guild::field("id,image,name,g_id,user_id,party_id,desc,notice,status")->where(["id"=>$guild_id])->find();
  120. // 获取公会成员信息
  121. $guildMemberInfo = \app\common\model\GuildMember::alias("a")
  122. ->field("a.id,a.user_id,a.role,u.nickname,u.avatar,u.gender")
  123. ->join("hx_user u","a.user_id = u.id")
  124. ->where(["a.guild_id"=>$guild_id])->limit(10)->order("a.role","desc")->select();
  125. if(!$guildInfo) $this->error("公会信息获取失败!");
  126. // 获取公会成员总数
  127. $guildMemberCount = \app\common\model\GuildMember::where(["guild_id"=>$guild_id])->count("id");
  128. // 获取会长信息
  129. $guilderInfo = \app\common\model\User::field("avatar,nickname,u_id")->where(["id"=>$guildInfo->user_id])->find();
  130. // 获取房间信息
  131. $partyInfo = \app\common\model\Party::field("id,party_logo,party_type,is_online,party_name,party_notice_detail")->where(["id"=>$guildInfo->party_id])->find();
  132. $partyParams = ['party_id' => $guildInfo->party_id];
  133. $roomService = new RoomService();
  134. $partyOnlineRes = $roomService->getPartyUserList($partyParams);
  135. $onlineData = isset($partyOnlineRes['data']) ? $partyOnlineRes['data'] : [];
  136. if (!empty($partyInfo)) {
  137. $partyInfo['user_list'] = isset($onlineData['member_list']) ? $onlineData['member_list'] : [];
  138. $partyInfo['online_num'] = isset($onlineData['online_num']) ? $onlineData['online_num'] : 0;
  139. // 派对类型
  140. $partyTypeName = "普通房";
  141. if(isset($partyInfo["party_type"])) {
  142. $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
  143. }
  144. $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
  145. $partyInfo["party_type_color"] = $mod == 0?5:$mod;
  146. $partyInfo["type_name"] = $partyTypeName;
  147. }
  148. //获取家族角色
  149. $userService = new UserService();
  150. $userParams = [
  151. 'user_id' => $user_id,
  152. 'guild_id' => $guild_id,
  153. ];
  154. $userRes = $userService->getGuildRole($userParams);
  155. $guildStatus = isset($userRes['data']['guild_role']) ? $userRes['data']['guild_role'] : 4;
  156. // 返回参数拼接
  157. $res["guildInfo"] = $guildInfo; // 公会基本信息
  158. $res["partyInfo"] = $partyInfo; // 派对悉尼下
  159. $res["guildMemberInfo"] = $guildMemberInfo; // 成员列表
  160. $res["guildMemberCount"] = $guildMemberCount; // 成员总数
  161. $res["guilderInfo"] = $guilderInfo; // 会长
  162. $res["is_member"] = $is_member; // 是否为派对成员
  163. $res['guild_status'] = $guildStatus; //家族状态
  164. $res['guild_role'] = $guildStatus; //家族角色:1组长,2副族长,3成员,4非成员
  165. $this->success("获取成功!",$res);
  166. }
  167. /**
  168. * 更新公会基本信息
  169. */
  170. public function guildSaveInfo() {
  171. Db::startTrans();
  172. try {
  173. $guild_id = input("guild_id"); //公会id
  174. $guild_name = input("guild_name"); //公会名
  175. $guild_image = input("guild_image"); //logo
  176. $guild_desc = input("guild_desc"); //公会简介
  177. $guild_notice = input("guild_notice"); //公会公告
  178. $guild_info = input("guild_info"); //公会宣言
  179. $province_id = input("province_id"); //省id
  180. $city_id = input("city_id"); //市id
  181. if(!$guild_name || !$guild_image){
  182. throw new Exception("公会名和logo必填!");
  183. }
  184. $user_id = $this->auth->id;
  185. if (empty($guild_id)) {
  186. //检查
  187. $guildWhere['user_id'] = $user_id;
  188. $guildWhere['status'] = ['in',[0,1]];
  189. $guildData = model('Guild')->where($guildWhere)->find();
  190. if (!empty($guildData)) {
  191. throw new Exception('您已创建过家族!');
  192. }
  193. //准备创建
  194. $guildInfo = new \app\common\model\Guild();
  195. $guildInfo->user_id = $user_id;
  196. $ids = \app\common\model\Guild::column("g_id");
  197. $guildInfo->g_id = getUinqueId(4, [$ids]);
  198. $guildInfo->status = 0;
  199. } else {
  200. // 获取公会信息
  201. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  202. // 验证更新条件
  203. if($user_id !== $guildInfo->user_id) throw new Exception("身份验证失败!您不是公会长,无权限更改!");
  204. }
  205. //传参信息
  206. $guild_name && $guildInfo->name = $guild_name;
  207. $guild_image && $guildInfo->image = $guild_image;
  208. $guild_desc && $guildInfo->desc = $guild_desc;
  209. $guild_notice && $guildInfo->notice = $guild_notice;
  210. $guild_info && $guildInfo->info = $guild_info;
  211. $province_id && $guildInfo->province_id = $province_id;
  212. $city_id && $guildInfo->city_id = $city_id;
  213. $res = $guildInfo->save();
  214. if($res !== false) {
  215. if (empty($guild_id)) {
  216. //新公会,会长也是成员之一
  217. $guildMemberData = [
  218. 'guild_id' => $guildInfo->id,
  219. 'user_id' => $user_id,
  220. 'role' => 2, //角色:0=成员,1=副会长,2=会长
  221. // 'sign_type' => 3,//签约类型:1=三个月,2=半年,3=一年
  222. // 'sign_time' => 0,
  223. // 'status' => 1, //状态:1=签约中,2=已解约
  224. 'createtime' => time(),
  225. ];
  226. $guildRes = model('GuildMember')->insertGetId($guildMemberData);
  227. if (!$guildRes) {
  228. throw new Exception('生成成员失败');
  229. }
  230. //更新用户资料
  231. $userWhere['id'] = $user_id;
  232. $user = model('User')->where($userWhere)->find();
  233. if (!empty($user) && $user['guild_id'] != $guildInfo->id) {
  234. $userRes = model('User')->where($userWhere)->update(['is_guild'=>3,'guild_id'=>$guildInfo->id]);
  235. if (!$userRes) {
  236. throw new Exception('用户绑定家族失败');
  237. }
  238. }
  239. }
  240. Db::commit();
  241. $this->success("操作成功!");
  242. } else {
  243. throw new Exception("网络错误,请稍后重试!");
  244. }
  245. } catch (Exception $e) {
  246. Db::rollback();
  247. $this->error($e->getMessage());
  248. }
  249. }
  250. /**
  251. * 公会签约申请
  252. */
  253. public function guildJoinin() {
  254. $join_time = input("join_time",1); //签约时长:1=3个月,2=6个月,3=12个月
  255. $guild_id = input("guild_id"); //公会ID
  256. //if(!in_array($join_time,[1,2,3]) || !$guild_id) $this->error("参数错误!");
  257. // 一个身份证号只能申请一次
  258. $user_id = $this->auth->id;
  259. // 实名认证
  260. if($this->auth->is_auth != 2){
  261. $this->error("请完成实名认证!");
  262. }
  263. // 获取用户实名认证信息
  264. $authUserIdcard = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("idcard");
  265. // 搜索签约申请中是否有此身份证号
  266. $idcardfind = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,'guild_id'=>$guild_id,"status"=>0])->find();
  267. if($idcardfind) $this->error("当前账号正在审核,请耐心等待!");
  268. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$user_id])->find();
  269. if($memberfind) $this->error("一个账号只能加入一个公会哟!");
  270. // 查看是否申请过
  271. /*$applyInfo = \app\common\model\GuildApply::where(["user_id"=>$user_id,"status"=>0])->find();
  272. if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了,请勿重复发送!");*/
  273. // // 获取公会信息
  274. // $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id,"status"=>1])->find();
  275. // // 验证更新条件
  276. // if($guildInfo) $this->error("您存在公会会长身份,请先解散相应的公会才可申请");
  277. // 获取公会信息
  278. $guildName = \app\common\model\Guild::where(["id"=>$guild_id])->value("name");
  279. // 获取用户信息
  280. $userInfo = \app\common\model\User::field("id,avatar,nickname")->where(["id"=>$user_id])->find();
  281. // 添加数据
  282. $data = [];
  283. $data["user_id"] = $user_id;
  284. $data["guild_id"] = $guild_id;
  285. //$data["join_time"] = $join_time;
  286. $data["user_avatar"] = $userInfo->avatar;
  287. $data["user_idcard"] = $authUserIdcard;
  288. $data["user_nickname"] = $userInfo->nickname;
  289. $data["guild_name"] = $guildName;
  290. $data["createtime"] = time();
  291. $res = \app\common\model\GuildJoinin::insert($data);
  292. if($res) {
  293. // +message
  294. // \app\common\model\Message::addMessage($user_id,"公会消息","申请加入公会消息");
  295. $this->success("申请发送成功!");
  296. } else {
  297. $this->error("网络错误,请稍后重试!");
  298. }
  299. }
  300. /**
  301. * 公会签约申请审核
  302. */
  303. public function guildJoininExamine() {
  304. $joinin_id = input("joinin_id"); // 申请加入的申请ID
  305. $is_pass = input("is_pass"); // 是否通过:1=通过,-1=拒绝
  306. if(!in_array($is_pass,[1,-1]) || !$joinin_id) $this->error("参数错误!");
  307. $user_id = $this->auth->id;
  308. // 获取申请信息
  309. $joininInfo = \app\common\model\GuildJoinin::where(["id"=>$joinin_id])->find();
  310. if(empty($joininInfo)){
  311. $this->error('未找到申请信息');
  312. }
  313. // 获取公会信息
  314. $guildInfo = \app\common\model\Guild::where(["id"=>$joininInfo->guild_id])->find();
  315. // 验证更新条件
  316. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是族长,无权限更改!");
  317. //判断重复
  318. $memberfind = \app\common\model\GuildMember::where(["user_id"=>$joininInfo['user_id']])->find();
  319. if($memberfind) $this->error("该用户已有家族!");
  320. //清理其他公会未审核的数据
  321. if ($is_pass == 1) {
  322. $joinWhere['user_id'] = $joininInfo['user_id'];
  323. $joinWhere['guild_id'] = ['neq',$joininInfo['guild_id']];
  324. $joinWhere['status'] = 0;
  325. $joinData = model('GuildJoinin')->where($joinWhere)->delete();
  326. }
  327. // 获取用户信息
  328. $userInfo = \app\common\model\User::field("id,u_id,mobile,nickname")->where(["id"=>$joininInfo->user_id])->find();
  329. // 计算签约时间段
  330. $join_time = $joininInfo->join_time;
  331. $timeArr = [1=>3,2=>6,3=>12];
  332. $endtime = strtotime('+'.$timeArr[$join_time].' month');
  333. $sign_time_slot = date("Y.m.d")."-".date('Y.m.d',$endtime);
  334. Db::startTrans();
  335. try{
  336. //记个无用的日志
  337. $data = [];
  338. $data["user_id"] = $joininInfo->user_id;
  339. $data["operator"] = $user_id;
  340. $data["user_nickname"] = $userInfo->nickname;
  341. $data["user_u_id"] = $userInfo->u_id;
  342. $data["guild_id"] = $guildInfo->id;
  343. $data["guild_name"] = $guildInfo->name;
  344. $data["guild_g_id"] = $guildInfo->g_id;
  345. $data["sign_time_slot"] = $sign_time_slot;
  346. $data["status"] = $is_pass;
  347. $data["createtime"] = time();
  348. $res1 = \app\common\model\GuildJoininLog::insert($data);
  349. // 更新申请状态
  350. $joininInfo->status = $is_pass;
  351. $joininInfo->updatetime = time();
  352. $res2 = $joininInfo->save();
  353. if($is_pass == 1) {
  354. // 同意后 加入公会成员
  355. $data = [];
  356. $data["guild_id"] = $guildInfo->id;
  357. $data["user_id"] = $joininInfo->user_id;
  358. $data["role"] = 0;
  359. // $data["sign_type"] = $join_time; // 签约类型:1=三个月,2=半年,3=一年
  360. // $data["sign_time"] = $endtime;
  361. $data["status"] = 1;
  362. $data["createtime"] = time();
  363. $res3 = \app\common\model\GuildMember::insert($data);
  364. $res4 = \app\common\model\Guild::where(["id"=>$guildInfo->id])->setInc("member");
  365. if($res1 && $res2 && $res3 && $res4) {
  366. // +message
  367. \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","恭喜,您的加入公会审核通过啦!公会ID:".$guildInfo->g_id);
  368. Db::commit();
  369. $this->success("已审核通过!");
  370. }
  371. } else {
  372. if($res1 && $res2) {
  373. // +message
  374. \app\common\model\Message::addMessage($joininInfo->user_id,"公会审核通知","您的公会加入申请,会长审核拒绝,没关系,调整姿势再来一遍!");
  375. Db::commit();
  376. $this->success("已审核拒绝!");
  377. }
  378. }
  379. $this->error("网络错误,请稍后重试!");
  380. }catch (ValidateException $e) {
  381. Db::rollback();
  382. $this->error($e->getMessage());
  383. } catch (PDOException $e) {
  384. Db::rollback();
  385. $this->error($e->getMessage());
  386. } catch (Exception $e) {
  387. Db::rollback();
  388. $this->error($e->getMessage());
  389. }
  390. }
  391. /**
  392. * 公会申请加入列表
  393. */
  394. public function guildJoinList() {
  395. try {
  396. $user_id = $this->auth->id;
  397. // 获取公会信息
  398. $guildInfo = model('Guild')->where(["user_id"=>$user_id])->find();
  399. if(!$guildInfo) throw new Exception('公会信息获取失败!');
  400. // 先获取申请列表
  401. $where = [];
  402. $where["guild_id"] = $guildInfo->id;
  403. $where["status"] = 0;
  404. $result = model('GuildJoinin')->field("id,user_id,user_avatar,user_nickname,guild_name,createtime")
  405. ->with(['user'=>function($uQuery){
  406. $uQuery->field('id,is_online,onlinetime');
  407. }])
  408. ->where($where)->order("createtime","desc")->select();
  409. if($result) {
  410. foreach($result as $k => &$v) {
  411. $user = isset($v['user']) ? $v['user'] : [];
  412. $onlineText = '';
  413. if (!empty($user)) {
  414. if ($user['is_online'] == 1) {
  415. $onlineText = '在线';
  416. } else {
  417. $onlineTime = get_last_time($user['onlinetime']);
  418. $onlineText = $onlineTime.'在线';
  419. $limitTime = time() - (3600 * 6);
  420. if ($user['onlinetime'] < $limitTime) {
  421. $onlineText = '离线';
  422. }
  423. }
  424. }
  425. $v['online_text'] = $onlineText;
  426. $v['createtime'] = !empty($v["createtime"]) ? date("Y-m-d H:i", $v["createtime"]) : '';
  427. unset($v['user']);
  428. }
  429. }
  430. $this->success("获取成功",$result);
  431. } catch (Exception $e) {
  432. $this->error($e->getMessage());
  433. }
  434. }
  435. /**
  436. * 公会成员列表
  437. */
  438. public function guildMember() {
  439. $guild_id = input("guild_id",0,"intval"); //公会ID
  440. $page = input('page',1); // 分页
  441. $pageNum = input('listrow',10); // 分页
  442. // 分页搜索构建
  443. $pageStart = ($page-1)*$pageNum;
  444. if($guild_id <= 0) $this->error("参数错误!");
  445. $where = [];
  446. $where["a.guild_id"] = $guild_id;
  447. $where["a.status"] = 1;
  448. //$where["a.sign_time"] = ["gt",time()];
  449. // 获取公会成员总数
  450. $guildMemberCount = \app\common\model\GuildMember::alias("a")->where($where)->count("id");
  451. // 获取公会成员列表
  452. $guildMemberList = \app\common\model\GuildMember::alias("a")
  453. ->field("a.id,a.user_id,u.avatar,u.nickname,u.gender,u.age,a.role,u.is_online,u.onlinetime")
  454. ->join("hx_user u","a.user_id = u.id")
  455. ->where($where)
  456. ->limit($pageStart,$pageNum)
  457. ->order("a.role","desc")
  458. ->select();
  459. $role = [0=>'成员',1=>'副会长',2=>'会长'];
  460. if($guildMemberList) {
  461. foreach($guildMemberList as $k => &$v) {
  462. $v["role_text"] = $role[$v["role"]];
  463. if ($v['is_online'] == 1) {
  464. $onlineText = '在线';
  465. } else {
  466. $onlineTime = get_last_time($v['onlinetime']);
  467. $onlineText = $onlineTime.'在线';
  468. $limitTime = time() - (3600 * 6);
  469. if ($v['onlinetime'] < $limitTime) {
  470. $onlineText = '离线';
  471. }
  472. }
  473. $v['online_text'] = $onlineText;
  474. }
  475. }
  476. $res = [];
  477. $res["memberCount"] = $guildMemberCount;
  478. $res["memberList"] = $guildMemberList;
  479. $this->success("获取成功!",$res);
  480. }
  481. /**
  482. * 获取公会成员信息
  483. */
  484. public function getGuildMemberInfo() {
  485. $member_id = input("member_id",0,"intval"); //公会成员ID
  486. if($member_id <= 0) $this->error("参数错误!");
  487. //成员信息
  488. $memberData = model('GuildMember')->field('id,user_id')->find($member_id);
  489. //更新成员的 财富值 ,魅力值,收到的礼物数量
  490. $userService = new UserService();
  491. $userService->updateGuildMember(['user_id'=>$memberData['user_id']]);
  492. //从user表拿一些用户信息
  493. $memberInfo = model('GuildMember')
  494. ->field('id,user_id,wealth,charm,gift_num,role,guild_id,createtime')
  495. ->with(['user'=>function($uQuery){
  496. $uQuery->field('id,avatar,nickname,gender,age,logintime,age_id,constellation_id,province_id,city_id');
  497. }])->find($member_id);
  498. if(!$memberInfo) $this->error("用户信息获取失败!");
  499. $userData = isset($memberInfo['user']) ? $memberInfo['user'] : [];
  500. $gender = isset($userData['gender']) ? $userData['gender'] : 1;
  501. $logintime = isset($userData['logintime']) ? $userData['logintime'] : 0;
  502. $userFieldInt = ['age'];
  503. $userFieldStr = ['avatar','nickname','age_text','constellation_text','province_text','city_text'];
  504. foreach ($userFieldInt as $keyInt => $valInt) {
  505. if (!isset($memberInfo[$valInt])) {
  506. $memberInfo[$valInt] = isset($userData[$valInt]) ? $userData[$valInt] : 0;
  507. }
  508. }
  509. foreach ($userFieldStr as $keyStr => $valStr) {
  510. if (!isset($memberInfo[$valStr])) {
  511. $memberInfo[$valStr] = isset($userData[$valStr]) ? $userData[$valStr] : '';
  512. }
  513. }
  514. unset($memberInfo['user']);
  515. $memberInfo['gender_text'] = $gender == 1 ? '男' : '女';
  516. $memberInfo["createtime"] = !empty($memberInfo["createtime"]) ? date("Y-m-d", $memberInfo["createtime"]) : '';
  517. $memberInfo["logintime"] = !empty($logintime) ? date("Y-m-d", $logintime) : '';
  518. //我在这个公会的角色
  519. $myGuildMember = model('GuildMember')->field('role')->where(["user_id"=>$this->auth->id,"guild_id"=>$memberInfo->guild_id])->find();
  520. $memberInfo["my_role"] = !empty($myGuildMember) ? $myGuildMember['role'] : -1;
  521. //几个比较大的值,改w单位
  522. $fieldArr = ['wealth','charm','gift_num'];
  523. foreach ($fieldArr as $fkey => $fval) {
  524. if ($memberInfo[$fval] > 10000) {
  525. $memberInfo[$fval] = bcdiv($memberInfo[$fval],10000,2).'w';
  526. }
  527. }
  528. $this->success("获取成功!",$memberInfo);
  529. }
  530. /**
  531. * 公会管理-设为管理员
  532. */
  533. public function guildSetManage() {
  534. $guild_id = input("guild_id",0,"intval"); //公会ID
  535. $member_id = input("member_id",0,"intval"); //成员ID
  536. $type = input("type",1); // 设置类型:1=设为管理员,2=取消管理员
  537. if(!$guild_id || !$member_id || !in_array($type,[1,2])) $this->error("参数缺失!");
  538. $user_id = $this->auth->id;
  539. // 获取公会信息
  540. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  541. // 验证更新条件
  542. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  543. $memberInfo = \app\common\model\GuildMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->find();
  544. if(!$memberInfo) $this->error("会员信息查询失败!");
  545. //取消管理员
  546. if($type == 2) {
  547. $memberInfo->role = 0;
  548. $memberInfo->updatetime = time();
  549. $res = $memberInfo->save();
  550. if($res) {
  551. $this->success("取消成功!");
  552. } else {
  553. $this->error("网络错误,请稍后重试!");
  554. }
  555. }
  556. //设置管理员
  557. $memberInfo->role = 1;
  558. $memberInfo->updatetime = time();
  559. $res = $memberInfo->save();
  560. if($res) {
  561. // 获取房间id
  562. $party_id = $guildInfo->party_id;
  563. // 添加房间管理员
  564. $redis = new Redis();
  565. $redisconfig = config("redis");
  566. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  567. if ($redisconfig['redis_pwd']) {
  568. $redis->auth($redisconfig['redis_pwd']);
  569. }
  570. if($redisconfig['redis_selectdb'] > 0){
  571. $redis->select($redisconfig['redis_selectdb']);
  572. }
  573. // 获取成员用户信息
  574. $memberuserInfo = \app\common\model\User::field("id,avatar,nickname,gender,level")->where('id',$memberInfo['user_id'])->find();
  575. $data = [];
  576. $data["user_id"] = $memberuserInfo->id;
  577. $data["avatar"] = $memberuserInfo->avatar;
  578. $data["nickname"] = $memberuserInfo->nickname;
  579. $data["gender"] = $memberuserInfo->gender;
  580. $data["level"] = $memberuserInfo->level;
  581. $data["item"] = 1;
  582. $data["time"] = 0;
  583. $data["createtime"] = time();
  584. $redis->hSet("party_manage_".$party_id,$memberuserInfo->id."-1",serialize($data));
  585. // 腾讯im设置管理员
  586. // $tenim = new Tenim();
  587. // $tenim->setImManage($memberInfo['user_id'],$party_id);
  588. $this->success("设置成功!");
  589. } else {
  590. $this->error("网络错误,请稍后重试!");
  591. }
  592. }
  593. /**
  594. * 公会管理-踢出公会
  595. */
  596. public function guildDelMember() {
  597. $guild_id = input("guild_id",0,"intval"); //公会ID
  598. $member_id = input("member_id",0,"intval"); //成员ID
  599. if(!$guild_id || !$member_id) $this->error("参数缺失!");
  600. // 先判断是否为公会会长
  601. $user_id = $this->auth->id;
  602. // 获取公会信息
  603. $guildInfo = \app\common\model\Guild::where(["id"=>$guild_id])->find();
  604. // 验证更新条件
  605. if($user_id !== $guildInfo->user_id) $this->error("身份验证失败!您不是公会长,无权限更改!");
  606. $memberInfo = \app\common\model\GuildMember::where(["id"=>$member_id,'guild_id'=>$guild_id])->find();
  607. if(!$memberInfo) $this->error("会员信息查询失败!");
  608. if($memberInfo['role'] == 2 || $memberInfo['user_id'] == $guildInfo['user_id']){
  609. $this->error('会长不能被踢出公会');
  610. }
  611. Db::startTrans();
  612. try{
  613. $res1 = $memberInfo->delete();
  614. $res2 = \app\common\model\Guild::where(["id"=>$guild_id])->setDec("member");
  615. if($res1 && $res2) {
  616. Db::commit();
  617. $this->success("踢出成功!");
  618. } else {
  619. $this->error("网络错误,请稍后重试!");
  620. }
  621. }catch (ValidateException $e) {
  622. Db::rollback();
  623. $this->error($e->getMessage());
  624. } catch (PDOException $e) {
  625. Db::rollback();
  626. $this->error($e->getMessage());
  627. } catch (Exception $e) {
  628. Db::rollback();
  629. $this->error($e->getMessage());
  630. }
  631. }
  632. /**
  633. * 家族贡献榜排行
  634. * @return void
  635. */
  636. public function getRankList()
  637. {
  638. try {
  639. $id = input('guild_id',0);
  640. $guildMemberWhere['guild_id'] = $id;
  641. $guildMemberWhere['status'] = 1;
  642. $guildMember = model('GuildMember')->field('id,user_id,role')->where($guildMemberWhere)->select();
  643. $list = [];
  644. if (!empty($guildMember)) {
  645. $userIds = array_column($guildMember,'user_id');
  646. $where = [];
  647. $where['a.user_to_id'] = ['in', $userIds];
  648. $list = model('GiftUserParty')->alias("a")
  649. ->field('sum(a.value) as total_price,a.user_to_id,u.avatar,u.nickname,u.is_online,u.onlinetime')
  650. ->where($where)
  651. ->join('hx_user u','u.id = a.user_to_id')
  652. ->group('a.user_to_id')
  653. ->order('total_price',"desc")
  654. ->autopage()
  655. ->select();
  656. if (!empty($list)) {
  657. $role = [0=>'成员',1=>'副会长',2=>'会长'];
  658. $guildMemberData = [];
  659. foreach ($guildMember as $mKey => $mVal) {
  660. $guildMemberData[$mVal['user_id']] = [
  661. 'id' => $mVal['id'],
  662. 'role' => $mVal['role'],
  663. 'role_text' => isset($role[$mVal['role']]) ? $role[$mVal['role']] : '',
  664. ];
  665. }
  666. foreach ($list as $key => &$value) {
  667. $member = isset($guildMemberData[$value['user_to_id']]) ? $guildMemberData[$value['user_to_id']] : [];
  668. $value['member_id'] = isset($member['id']) ? $member['id'] : 0;
  669. $value['role'] = isset($member['role']) ? $member['role'] : 0;
  670. $value['role_text'] = isset($member['role_text']) ? $member['role_text'] : '';
  671. if ($value['is_online'] == 1) {
  672. $onlineText = '在线';
  673. } else {
  674. $onlineTime = get_last_time($value['onlinetime']);
  675. $onlineText = $onlineTime.'在线';
  676. $limitTime = time() - (3600 * 6);
  677. if ($value['onlinetime'] < $limitTime) {
  678. $onlineText = '离线';
  679. }
  680. }
  681. $value['online_text'] = $onlineText;
  682. $value['total_price_text'] = $value['total_price'];
  683. if ($value['total_price'] >= 10000) {
  684. $value['total_price_text'] = bcdiv($value['total_price'],10000,1).'w';
  685. }
  686. unset($value['total_price']);
  687. }
  688. }
  689. }
  690. $this->success(__('Operation completed'),$list);
  691. } catch (Exception $e) {
  692. $this->error($e->getMessage());
  693. }
  694. }
  695. /**
  696. * 获取家族状态
  697. * @return void
  698. */
  699. public function getStatus()
  700. {
  701. try {
  702. $id = input('guild_id',0);
  703. if (!empty($id)) {
  704. $where['id'] = $id;
  705. } else {
  706. $where['user_id'] = $this->auth->id;
  707. }
  708. $field = 'id,status';
  709. $guild = model('Guild')->field($field)->where($where)->find();
  710. $this->success('获取成功', $guild);
  711. } catch (Exception $e) {
  712. $this->error($e->getMessage());
  713. }
  714. }
  715. ///////////////没用到的///////////
  716. /**
  717. * 开厅申请
  718. */
  719. public function guildApply() {
  720. $user_id = $this->auth->id;
  721. // 获取用户实名认证信息
  722. $authUserRealname = \app\common\model\UserAuth::where(["user_id"=>$user_id])->value("realname");
  723. if(!$authUserRealname) $this->error("未查询到实名认证信息,请实名认证先!");
  724. // 获取用户信息
  725. $userInfo = \app\common\model\User::field("id,mobile,nickname")->where(["id"=>$user_id])->find();
  726. $data = [];
  727. $data["user_id"] = $user_id;
  728. // 查看是否申请过
  729. $applyInfo = \app\common\model\GuildApply::where($data)->find();
  730. if($applyInfo && $applyInfo->status>=0) $this->error("您已经发送过开厅申请了,请勿重复发送!");
  731. // 查看是否有加入公会的申请
  732. $joinInfo = \app\common\model\GuildJoinin::where(["user_id"=>$user_id,"status"=>0])->find();
  733. if($joinInfo) $this->error("您存在申请加入公会信息,请联系公会长处理完毕后方可申请开厅!");
  734. // 查看是已经是公会成员
  735. $memberInfo = \app\common\model\GuildMember::where(["user_id"=>$user_id])->find();
  736. if($memberInfo) $this->error("您已存在签约中的公会,无法开新厅!");
  737. Db::startTrans();
  738. try{
  739. $data["user_name"] = $authUserRealname;
  740. $data["user_nickname"] = $userInfo->nickname;
  741. $data["user_mobile"] = $userInfo->mobile;
  742. $data["createtime"] = time();
  743. $res1 = \app\common\model\GuildApply::insert($data);
  744. // 更新用户状态
  745. $userInfo->is_guild = 1;
  746. $res2 = $userInfo->save();
  747. if($res1 && $res2) {
  748. Db::commit();
  749. $this->success("申请发送成功!");
  750. } else {
  751. $this->error("网络错误,请稍后重试!");
  752. }
  753. }catch (ValidateException $e) {
  754. Db::rollback();
  755. $this->error($e->getMessage());
  756. } catch (PDOException $e) {
  757. Db::rollback();
  758. $this->error($e->getMessage());
  759. } catch (Exception $e) {
  760. Db::rollback();
  761. $this->error($e->getMessage());
  762. }
  763. }
  764. /**
  765. * 公会申请页面信息
  766. */
  767. public function guildApplyInfo() {
  768. $guild_id = input("guild_id"); //公会ID
  769. if($guild_id <= 0) $this->error("参数缺失!");
  770. $guildInfo = \app\common\model\Guild::alias("a")
  771. ->join("hx_user u","u.id = a.user_id","inner")
  772. ->field("a.id,a.image,a.name,a.g_id,a.user_id,u.avatar,u.nickname,u.u_id")
  773. ->where(["a.id"=>$guild_id])
  774. ->find();
  775. $guildInfo["status"] = 0;
  776. // 获取申请用户是否已经有正在申请的记录
  777. $user_id = $this->auth->id;
  778. $joinStatus = \app\common\model\GuildJoinin::where(["user_id"=>$user_id])->value("status");
  779. if($joinStatus === 0) $guildInfo["status"] = 1;
  780. $Member = \app\common\model\GuildMember::where(["user_id"=>$user_id])->value("id");
  781. if($Member > 0) $guildInfo["status"] = 2;
  782. $this->success("获取成功!",$guildInfo);
  783. }
  784. /**
  785. * 公会助手列表
  786. */
  787. public function guildAssistantList() {
  788. $user_id = $this->auth->id;
  789. // 获取公会信息
  790. $guildInfo = \app\common\model\Guild::where(["user_id"=>$user_id])->find();
  791. if(!$guildInfo) $this->error("公会信息获取失败!");
  792. // 先获取申请列表
  793. $where = [];
  794. $where["guild_id"] = $guildInfo->id;
  795. $where["status"] = 0;
  796. $joinList = \app\common\model\GuildJoinin::field("id,user_avatar,user_nickname,guild_name,createtime")->where($where)->order("createtime","desc")->select();
  797. if($joinList) foreach($joinList as $k => $v) {
  798. $joinList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
  799. }
  800. // 再获取审核记录
  801. $where = [];
  802. $where["a.guild_id"] = $guildInfo->id;
  803. $where["a.user_id"] = $user_id;
  804. $joinlogList = \app\common\model\GuildJoininLog::alias("a")
  805. ->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")
  806. ->join("hx_user u","a.operator = u.id")
  807. ->whereOr($where)
  808. ->order("a.createtime","desc")
  809. ->select();
  810. if($joinlogList) foreach($joinlogList as $k => $v) {
  811. $joinlogList[$k]["createtime"] = date("Y-m-d H:i",$v["createtime"]);
  812. }
  813. $res = [];
  814. $res["joinList"] = $joinList;
  815. $res["joinlogList"] = $joinlogList;
  816. $this->success("获取成功!",$res);
  817. }
  818. }