GroupUser.php 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244
  1. <?php
  2. namespace app\api\controller;
  3. use app\api\service\auth\GroupMysqlAdapter;
  4. use app\api\service\auth\ApiAuthGroupService;
  5. use app\api\validate\User as UserValidate;
  6. use think\exception\ValidateException;
  7. use app\common\model\GroupUser as GroupUserModel;
  8. use app\common\model\User as UserModel;
  9. use \think\facade\Filesystem;
  10. class GroupUser extends Base
  11. {
  12. protected $noNeedLogin = ['login'];
  13. public function userinfo(GroupUserModel $userModel)
  14. {
  15. $user = $userModel->find($this->userinfo['id']);
  16. return $this->success('ok', $user);
  17. }
  18. //编辑用户
  19. public function edit(GroupUserModel $userModel)
  20. {
  21. $data = $this->request->post();
  22. try {
  23. validate(UserValidate::class)->scene('edit')->check($data);
  24. $user = $userModel->find($this->userinfo['id']);
  25. if (!$user) {
  26. return $this->error('用户不存在');
  27. }
  28. $user->save($data);
  29. return $this->success('ok');
  30. } catch (ValidateException $e) {
  31. return $this->error($e->getError());
  32. }
  33. }
  34. //修改密码
  35. public function password(GroupUserModel $userModel)
  36. {
  37. $data = $this->request->post();
  38. try {
  39. validate(UserValidate::class)->scene('password')->check($data);
  40. $user = $userModel->find($this->userinfo['id']);
  41. if (!$user) {
  42. return $this->error('用户不存在');
  43. }
  44. if ($user->password != md5(md5($data['oldpassword'] . $user->salt))) {
  45. return $this->error('旧密码错误');
  46. }
  47. $user->password = md5(md5($data['password'] . $user->salt));
  48. $user->save();
  49. return $this->success('ok');
  50. } catch (ValidateException $e) {
  51. return $this->error($e->getError());
  52. }
  53. }
  54. public function login(ApiAuthGroupService $authService, GroupUserModel $userModel)
  55. {
  56. $data = $this->request->post();
  57. try {
  58. validate(UserValidate::class)->scene('login')->check($data);
  59. $terminal = $this->request->post('terminal/d', 0);
  60. $user = $authService->login($data['username'], $data['password'], $terminal);
  61. } catch (ValidateException $e) {
  62. return $this->error($e->getError());
  63. } catch (\Exception $e) {
  64. return $this->error($e->getMessage());
  65. }
  66. return $this->success('ok', $user);
  67. }
  68. //退出登录
  69. public function logout()
  70. {
  71. GroupMysqlAdapter::logout($this->userinfo['id']);
  72. return $this->success('ok');
  73. }
  74. //获取全部人员
  75. public function getAllUser(GroupUserModel $userModel)
  76. {
  77. $list = $userModel->where('status', 'normal')->field('id,nickname,avatar')->select();
  78. return $this->success('ok', $list);
  79. }
  80. //组员列表
  81. public function group_list(GroupUserModel $userModel)
  82. {
  83. $list = $userModel->where('status', 'normal')->where('pid', $this->userinfo['id'])->select();
  84. return $this->success('ok', $list);
  85. }
  86. //添加组员
  87. public function add_group_user(GroupUserModel $groupUserModel,UserModel $userModel)
  88. {
  89. $file = request()->file('avatar');
  90. $param = $this->request->post();
  91. try {
  92. validate(UserValidate::class)->scene('add_group_user')->check($param);
  93. $todayTime = strtotime('today');
  94. //判断手机号和身份证号是否注册今天是否添加到该团队
  95. $where_item_id_card = [];
  96. $where_item_id_card[]=['pid', '=',$this->userinfo['id']];
  97. $where_item_id_card[]=['id_card', '=',$param['id_card']];
  98. $where_item_id_card[]=['createtime', '>=',$todayTime];
  99. $group_user_data = $groupUserModel->where($where_item_id_card)->find();
  100. if(!empty($group_user_data)) return $this->error('该身份证号已添加',$param['id_card']);
  101. $where_item_mobile = [];
  102. $where_item_mobile[]=['pid', '=',$this->userinfo['id']];
  103. $where_item_mobile[]=['mobile', '=',$param['mobile']];
  104. $where_item_mobile[]=['createtime', '>=',$todayTime];
  105. $group_user_data = $groupUserModel->where($where_item_mobile)->find();
  106. if(!empty($group_user_data)) return $this->error('该手机号已添加');
  107. $user = $userModel->find($this->userinfo['id']);
  108. $pid=$user['id'];
  109. $time=time();
  110. $add_data=[
  111. 'pid'=>$pid,
  112. 'nickname'=>$param['nickname'],
  113. 'id_card'=>$param['id_card'],
  114. 'avatar'=>'',
  115. 'mobile'=>$param['mobile'],
  116. 'sex'=>$param['sex'],
  117. 'role'=>'1',
  118. 'status'=>'normal',
  119. 'joinip'=>request()->ip(),
  120. 'jointime'=>$time
  121. ];
  122. if (!empty($file)) {
  123. // 文件夹
  124. $folder = strtotime('today');
  125. $fileName = time() . '_' . mt_rand(1000, 9999) . '.png';
  126. $avatar = $file->move('uploads/avatar/' . $folder, $fileName);
  127. //检查目标文件是否存在
  128. if (!empty($avatar)) {
  129. //有图片上传,进行添加用户
  130. $add_data['avatar']=$avatar;
  131. $res=$groupUserModel->save($add_data);
  132. if($res) return $this->success('添加成功',$res);
  133. }
  134. }
  135. } catch (ValidateException $e) {
  136. return $this->error($e->getError());
  137. }
  138. return $this->error('添加失败');
  139. }
  140. //修改组员
  141. public function edit_group_user(GroupUserModel $groupUserModel,UserModel $userModel)
  142. {
  143. $file = request()->file('avatar');
  144. $param = $this->request->post();
  145. try {
  146. validate(UserValidate::class)->scene('edit_group_user')->check($param);
  147. $edit_data=$groupUserModel->find($param['id']);
  148. $todayTime = strtotime('today');
  149. //判断手机号和身份证号是否注册今天是否添加到该团队
  150. $where_item_id_card = [];
  151. $where_item_id_card[]=['pid', '=',$this->userinfo['id']];
  152. $where_item_id_card[]=['id_card', '=',$param['id_card']];
  153. $where_item_id_card[]=['id_card', '<>',$edit_data['id_card']];
  154. $where_item_id_card[]=['createtime', '>=',$todayTime];
  155. $group_user_data = $groupUserModel->where($where_item_id_card)->find();
  156. if(!empty($group_user_data)) return $this->error('该身份证号已添加',$param['id_card']);
  157. $where_item_mobile = [];
  158. $where_item_mobile[]=['pid', '=',$this->userinfo['id']];
  159. $where_item_mobile[]=['mobile', '=',$param['mobile']];
  160. $where_item_mobile[]=['mobile', '<>',$edit_data['mobile']];
  161. $where_item_mobile[]=['createtime', '>=',$todayTime];
  162. $group_user_data = $groupUserModel->where($where_item_mobile)->find();
  163. if(!empty($group_user_data)) return $this->error('该手机号已添加');
  164. $user = $userModel->find($this->userinfo['id']);
  165. $pid=$user['id'];
  166. $time=time();
  167. $add_data=[
  168. 'pid'=>$pid,
  169. 'nickname'=>$param['nickname'],
  170. 'id_card'=>$param['id_card'],
  171. 'mobile'=>$param['mobile'],
  172. 'sex'=>$param['sex'],
  173. 'role'=>'1',
  174. 'status'=>'normal',
  175. 'joinip'=>request()->ip(),
  176. 'updatetime'=>$time
  177. ];
  178. if (!empty($file)) {
  179. // 文件夹
  180. $folder = strtotime('today');
  181. $fileName = time() . '_' . mt_rand(1000, 9999) . '.png';
  182. $avatar = $file->move('uploads/avatar/' . $folder, $fileName);
  183. //检查目标文件是否存在
  184. if (!empty($avatar)) {
  185. if(!empty($edit_data['avatar'])){
  186. $avatar_file=root_path() . 'public' . DS . $edit_data['avatar'];
  187. if (file_exists($avatar_file)) {
  188. unlink($avatar_file);
  189. }
  190. }
  191. //有图片上传,进行添加用户
  192. $add_data['avatar']=$avatar;
  193. $res=$edit_data->save($add_data);
  194. if($res) return $this->success('修改成功',$res);
  195. }
  196. }else{
  197. $res=$edit_data->save($add_data);
  198. if($res) return $this->success('修改成功',$res);
  199. }
  200. } catch (ValidateException $e) {
  201. return $this->error($e->getError());
  202. }
  203. return $this->error('修改失败');
  204. }
  205. }