Family.php 31 KB

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