Familymember.php 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132
  1. <?php
  2. namespace app\admin\controller;
  3. use app\common\controller\Backend;
  4. use think\Db;
  5. /**
  6. * 家族成员管理
  7. *
  8. * @icon fa fa-circle-o
  9. */
  10. class Familymember extends Backend
  11. {
  12. /**
  13. * Familymember模型对象
  14. * @var \app\admin\model\Familymember
  15. */
  16. protected $model = null;
  17. public function _initialize()
  18. {
  19. parent::_initialize();
  20. $this->model = new \app\admin\model\Familymember;
  21. $this->view->assign("roleList", $this->model->getRoleList());
  22. $this->view->assign("statusList", $this->model->getStatusList());
  23. }
  24. public function import()
  25. {
  26. parent::import();
  27. }
  28. /**
  29. * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
  30. * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
  31. * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
  32. */
  33. /**
  34. * 查看
  35. */
  36. public function index()
  37. {
  38. //当前是否为关联查询
  39. $this->relationSearch = true;
  40. //设置过滤方法
  41. $this->request->filter(['strip_tags', 'trim']);
  42. if ($this->request->isAjax()) {
  43. //如果发送的来源是Selectpage,则转发到Selectpage
  44. if ($this->request->request('keyField')) {
  45. return $this->selectpage();
  46. }
  47. list($where, $sort, $order, $offset, $limit) = $this->buildparams();
  48. $list = $this->model
  49. ->with(['family','user'])
  50. ->where($where)
  51. ->order($sort, $order)
  52. ->paginate($limit);
  53. foreach ($list as $row) {
  54. $row->getRelation('family')->visible(['name']);
  55. $row->getRelation('user')->visible(['username']);
  56. }
  57. $result = array("total" => $list->total(), "rows" => $list->items());
  58. return json($result);
  59. }
  60. return $this->view->fetch();
  61. }
  62. /**
  63. * 审核
  64. */
  65. public function audit(){
  66. $id = input('id');
  67. $info = Db::name('family_member')
  68. ->where('id',$id)
  69. ->find();
  70. // 获取公会信息
  71. $guildInfo = \app\common\model\Family::where(["id"=>$info['guild_id']])->find();
  72. if ($this->request->isPost()) {
  73. $status = input('status',0);
  74. Db::startTrans();
  75. if($status == 1){
  76. //判断重复
  77. $memberfind = \app\common\model\Family::where(["user_id"=>$info['user_id'],"status"=>['IN',[0,1]] ])->find();
  78. if($memberfind) {
  79. Db::rollback();
  80. $this->error("该用户已申请了自己的家族!");
  81. }
  82. //[环信]把用户加到群组里
  83. $easemob = new Easemob();
  84. $easemob->group_addGroupMember($guildInfo['easemob_group_id'],$info['user_id']);
  85. $res4 = \app\common\model\Family::where(["id"=>$info['guild_id']])->setInc("member");
  86. //系统消息
  87. $msg_id = \app\common\model\Message::addMessage($info['user_id'],'家族审核','家族审核已经通过');
  88. }elseif($status == -1){
  89. //系统消息
  90. $msg_id = \app\common\model\Message::addMessage($info['user_id'],'家族审核','家族审核已经被拒绝');
  91. }
  92. $data = [
  93. 'status' => $status,
  94. 'updatetime' => time(),
  95. ];
  96. $rs = Db::name('family_member')->where('id',$id)->update($data);
  97. Db::commit();
  98. $this->success('审核完成');
  99. }
  100. $this->assign('row',$info);
  101. return $this->view->fetch();
  102. }
  103. }