UserService.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507
  1. <?php
  2. namespace App\JsonRpc;
  3. use App\Model\Role;
  4. use App\Model\RoleLog;
  5. use App\Model\RoleUser;
  6. use App\Model\User;
  7. use App\Model\UserInfo;
  8. use App\Model\UserLogin;
  9. use App\Model\Wechat;
  10. use App\Tools\Result;
  11. use Hyperf\DbConnection\Db;
  12. use Hyperf\RpcServer\Annotation\RpcService;
  13. #[RpcService(name: "UserService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
  14. class UserService implements UserServiceInterface
  15. {
  16. /**
  17. * @param string $name
  18. * @param int $gender
  19. * @return string
  20. */
  21. public function createUser(array $data): array
  22. {
  23. Db::beginTransaction();
  24. try{
  25. $dataUserReq = [
  26. 'user_name'=>$data['user_name'],
  27. 'password'=>md5(md5($data['password']).$data['salt']),
  28. 'avatar'=>$data['avatar']??'',
  29. 'type_id'=>$data['type_id']??'20000',
  30. 'mobile'=>$data['mobile']??'', //手机号
  31. 'status'=>$data['status']??1,
  32. 'email'=>$data['email']??'',
  33. 'salt'=>$data['salt'],
  34. 'admin_id'=>isset($data['admin_id']) && $data['admin_id']!=''?$data['admin_id']:0,
  35. // 'level_id'=>$data['level_id']??0, //会员等级
  36. 'nickname'=>$data['nickname']??'',
  37. 'last_login_ip'=>$data['last_login_ip']??'',
  38. ];
  39. var_dump("user:",$dataUserReq);
  40. $userid = User::query()->insertGetId($dataUserReq);
  41. $dataUserInfoReq = [
  42. 'user_id'=>$userid,
  43. 'id_card'=>$data['id_card']??'',
  44. 'gender'=>$data['gender']??0,
  45. 'real_name'=>$data['real_name']??'',
  46. 'business_name'=>$data['business_name']??'',
  47. 'job'=>$data['job']??'',
  48. 'city_id'=>$data['city_id']??0,
  49. 'birthday'=>$data['birthday']??'',
  50. 'number'=>$data['number']??'',
  51. 'city_arr_id'=>$data['city_arr_id']??'',
  52. 'from_time'=>$data['from_time']??null,
  53. 'to_time'=>$data['to_time']??null,
  54. 'long_time'=>$data['long_time']??0,
  55. 'native_place_id'=>$data['native_place_id']??0,
  56. 'native_place_arr_id'=>$data['native_place_arr_id']??'',
  57. 'qq'=>$data['qq']??'',
  58. 'zip_code'=>$data['zip_code']??'',
  59. 'address_arr_id'=>$data['address_arr_id']??'',
  60. 'address_id'=>$data['address_id']??0,
  61. 'address'=>$data['address']??'',
  62. 'other'=>$data['other']??'',
  63. 'remark'=>$data['remark']??'',
  64. 'fax'=>$data['fax']??'',
  65. 'position'=>$data['position']??'',
  66. 'legal_person_real_name'=>$data['legal_person_real_name']??'',
  67. 'legal_person_mobile'=>$data['legal_person_mobile']??'',
  68. 'legal_person_id_card'=>$data['legal_person_id_card']??'',
  69. 'administrative_unit_arr_id'=>$data['administrative_unit_arr_id']??'',
  70. 'administrative_unit_id'=>$data['administrative_unit_id']??0,
  71. ];
  72. var_dump("UserINfo:::",$dataUserInfoReq);
  73. $userInfoId = UserInfo::query()->insertGetId($dataUserInfoReq);
  74. $roleUserData = [
  75. 'role_id'=>isset($data['role_id']) && $data['role_id']!=''?$data['role_id']:0,
  76. 'user_id'=>$userid,
  77. 'admin_user_id'=>isset($data['admin_id']) && $data['admin_id']!=''?$data['admin_id']:0,
  78. ];
  79. RoleUser::insert($roleUserData);
  80. var_dump("userInfo:",$userInfoId);
  81. Db::commit();
  82. } catch(\Throwable $ex){
  83. Db::rollBack();
  84. var_dump($ex->getMessage());
  85. $message = $ex->getMessage();
  86. return Result::error($message,0);
  87. }
  88. return $userInfoId ? Result::success(["id"=>$userid]) : Result::error("创建失败",0);
  89. }
  90. /**
  91. * @return array
  92. */
  93. public function getUserList(array $data): array
  94. {
  95. $where = [];
  96. if(isset($data['keyword']) && $data['keyword']){
  97. array_push($where, ['user.user_name','like','%'.$data['keyword'].'%']);
  98. }
  99. if(isset($data['type_id']) && $data['type_id']){
  100. array_push($where, ['user.type_id','=',$data['type_id']]);
  101. }
  102. if(isset($data['status']) && $data['status']!='' && intval($data['status'])>=0 ){
  103. array_push($where, ['user.status','=',$data['status']]);
  104. }
  105. $result = User::where($where)
  106. ->leftJoin('user_info', 'user.id', '=', 'user_info.user_id')
  107. ->leftJoin("user as userA",'user.admin_id',"userA.id")
  108. ->orderBy("user.id","desc")->paginate(intval($data['pageSize']),
  109. [
  110. 'user.id',
  111. 'user.user_name',
  112. 'user_info.real_name',
  113. 'user.mobile',
  114. 'user.type_id',
  115. 'user.created_at',
  116. 'user.status',
  117. 'userA.nickname as admin_nickname'
  118. ],
  119. 'page', intval($data['page']));
  120. $count = $result->total();
  121. if (empty($result)) {
  122. return Result::error("没有数据",0);
  123. }
  124. $rep = $result->items();
  125. //1:个人会员 2:政务会员 3:企业会员 4:调研员 10000:管理员 20000:游客
  126. $type = ['1'=>"个人会员",'2'=>"政务会员",'3'=>"企业会员",'4'=>'调研员','10000'=>'管理员','20000'=>'游客'];
  127. if($rep){
  128. foreach ($rep as $k=>$v){
  129. $rep[$k]['type_name'] = $type[$v['type_id']];
  130. // $rep[$k]['gender_name'] = $gender[$v['gender']];
  131. // $rep[$k]['status_name'] = $status[$v['status']];
  132. // $rep[$k]['city_id'] = $v['city_id']?json_decode($v['city_id']):[];
  133. }
  134. }
  135. $data = [
  136. 'rows'=>$rep,
  137. 'count'=>$count
  138. ];
  139. return Result::success($data);
  140. }
  141. /**
  142. * @param int $id
  143. * @return array
  144. */
  145. public function getUserInfo(int $id): array
  146. {
  147. $userInfo = Db::table('user')
  148. ->leftJoin('user_info', 'user.id', '=', 'user_info.user_id')
  149. ->leftJoin('role_user', 'role_user.user_id', '=', 'user.id')
  150. ->select('user.*',
  151. 'user_info.id as user_info_id',
  152. 'user_info.real_name',
  153. 'user_info.id_card',
  154. 'user_info.birthday',
  155. 'user_info.gender',
  156. 'user_info.city_id',
  157. 'user_info.business_name',
  158. 'user_info.job',
  159. 'user_info.number',
  160. 'user_info.city_arr_id',
  161. 'user_info.from_time',
  162. 'user_info.to_time',
  163. 'user_info.long_time',
  164. 'user_info.native_place_id',
  165. 'user_info.native_place_arr_id',
  166. 'user_info.qq',
  167. 'user_info.zip_code',
  168. 'user_info.address_arr_id',
  169. 'user_info.address_id',
  170. 'user_info.address',
  171. 'user_info.other',
  172. 'user_info.remark',
  173. 'user_info.fax',
  174. 'user_info.position',
  175. 'user_info.legal_person_real_name',
  176. 'user_info.legal_person_mobile',
  177. 'user_info.legal_person_id_card',
  178. 'user_info.administrative_unit_arr_id',
  179. 'user_info.administrative_unit_id',
  180. 'role_user.role_id',
  181. )
  182. ->where('user.id','=',$id)->first();
  183. if (empty($userInfo)) {
  184. return Result::error("找不到用户",0,[]);
  185. }
  186. return Result::success($userInfo);
  187. }
  188. /**
  189. * 检测用户是否存在
  190. * @param array $data
  191. * @return array
  192. */
  193. public function verifyUserInfo(array $data): array
  194. {
  195. if(isset($data['id'])){
  196. $data[] = ['id',"!=",$data['id']];
  197. unset($data['id']);
  198. }
  199. $userInfo = User::query()->where($data)->first();
  200. if (empty($userInfo)) {
  201. return Result::error("找不到用户",0);
  202. }
  203. return Result::success($userInfo->toArray());
  204. }
  205. /**
  206. * @param array $data
  207. * @return array
  208. */
  209. public function createUserLogin(array $data): array
  210. {
  211. $id = UserLogin::insertGetId($data);
  212. if (empty($id)) {
  213. return Result::error("创建登录日志失败",0);
  214. }
  215. return Result::success(["id"=>$id]);
  216. }
  217. /**
  218. * 更新用户信息和userInfo
  219. * @param array $data
  220. * @return array
  221. */
  222. public function updateUser(array $data): array{
  223. Db::beginTransaction();
  224. try{
  225. $dataUserReq = [
  226. 'user_name'=>$data['user_name'],
  227. 'avatar'=>$data['avatar']??'',
  228. 'type_id'=>$data['type_id']??'20000',
  229. 'mobile'=>$data['mobile']??'', //手机号
  230. 'status'=>$data['status']??1,
  231. 'email'=>$data['email']??'',
  232. 'admin_id'=>$data['admin_id'],
  233. 'nickname'=>$data['nickname']??'',
  234. 'last_login_ip'=>$data['last_login_ip']??'',
  235. ];
  236. $userRep = User::where(['id'=>$data['id']])->update($dataUserReq);
  237. var_dump("修改user:",$userRep);
  238. $dataUserInfoReq = [
  239. 'id_card'=>$data['id_card']??'',
  240. 'gender'=>$data['gender']??0,
  241. 'real_name'=>$data['real_name']??'',
  242. 'job'=>$data['job']??'',
  243. 'city_id'=>$data['city_id']??0,
  244. 'birthday'=>$data['birthday']??'',
  245. 'number'=>$data['number']??'',
  246. 'city_arr_id'=>$data['city_arr_id']??'',
  247. 'from_time'=>$data['from_time']??null,
  248. 'business_name'=>$data['business_name']??'',
  249. 'to_time'=>$data['to_time']??null,
  250. 'long_time'=>$data['long_time']??0,
  251. 'native_place_id'=>$data['native_place_id']??0,
  252. 'native_place_arr_id'=>$data['native_place_arr_id']??'',
  253. 'qq'=>$data['qq']??'',
  254. 'zip_code'=>$data['zip_code']??'',
  255. 'address_arr_id'=>$data['address_arr_id']??'',
  256. 'address_id'=>$data['address_id']??0,
  257. 'address'=>$data['address']??'',
  258. 'other'=>$data['other']??'',
  259. 'remark'=>$data['remark']??'',
  260. 'fax'=>$data['fax']??'',
  261. 'position'=>$data['position']??'',
  262. 'legal_person_real_name'=>$data['legal_person_real_name']??'',
  263. 'legal_person_mobile'=>$data['legal_person_mobile']??'',
  264. 'legal_person_id_card'=>$data['legal_person_id_card']??'',
  265. 'administrative_unit_arr_id'=>$data['administrative_unit_arr_id']??'',
  266. 'administrative_unit_id'=>$data['administrative_unit_id']??0,
  267. ];
  268. $userInfoRep = UserInfo::where(['user_id'=>$data['id']])->update($dataUserInfoReq);
  269. var_dump("修改userInfo:",$userInfoRep);
  270. $roleUserData = [
  271. 'role_id'=>$data['role_id'],
  272. 'admin_user_id'=>$data['admin_id']
  273. ];
  274. $resultRoleUserRep = RoleUser::where(['user_id'=>$data['id']])->update($roleUserData);
  275. var_dump("修改用户角色权限:",$resultRoleUserRep);
  276. Db::commit();
  277. } catch(\Throwable $ex){
  278. Db::rollBack();
  279. var_dump($ex->getMessage());
  280. return Result::error("创建失败",0);
  281. }
  282. return Result::success([]);
  283. }
  284. /**
  285. * @param array $data
  286. * @return array
  287. */
  288. public function updateUserInfo(array $data): array{
  289. return 1;
  290. }
  291. /**
  292. * @param int $id
  293. * @return array
  294. */
  295. public function delUser(int $id) :array{
  296. Db::beginTransaction();
  297. try{
  298. User::where(['id'=>$id])->delete();
  299. UserInfo::where(['user_id'=>$id])->delete();
  300. Db::commit();
  301. } catch(\Throwable $ex){
  302. Db::rollBack();
  303. return Result::error("删除失败",0);
  304. }
  305. return Result::success([]);
  306. }
  307. /**
  308. * @param array $data
  309. * @return array
  310. */
  311. public function addRole(array $data) :array
  312. {
  313. Db::beginTransaction();
  314. try{
  315. Role::insertGetId($data);
  316. $logData = [
  317. 'user_id'=>$data['user_id'],
  318. 'data'=>json_encode($data),
  319. 'type'=>1
  320. ];
  321. RoleLog::insertGetId($logData);
  322. Db::commit();
  323. } catch(\Throwable $ex){
  324. Db::rollBack();
  325. return Result::error("新增失败",0);
  326. }
  327. return Result::success([]);
  328. }
  329. /**
  330. * @param array $data
  331. * @return array
  332. */
  333. public function delRole(array $data) :array
  334. {
  335. Db::beginTransaction();
  336. try{
  337. $roleInfo = Role::where(['id'=>$data['id']])->first();
  338. $logData = [
  339. 'user_id'=>$data['user_id'],
  340. 'data'=>json_encode($roleInfo->toArray()),
  341. 'type'=>2
  342. ];
  343. RoleLog::insertGetId($logData);
  344. RoleUser::where(['role_id'=>$data['id']])->delete();
  345. $result = Role::where(['id'=>$data['id']])->delete();
  346. Db::commit();
  347. } catch(\Throwable $ex){
  348. Db::rollBack();
  349. return Result::error("删除失败",0);
  350. }
  351. return Result::success($result);
  352. }
  353. /**
  354. * @param array $data
  355. * @return array
  356. */
  357. public function updateRole(array $data) :array
  358. {
  359. Db::beginTransaction();
  360. try{
  361. $result = Role::where(['id'=>$data['id']])->update($data);
  362. $logData = [
  363. 'user_id'=>$data['user_id'],
  364. 'data'=>json_encode($data),
  365. 'type'=>3
  366. ];
  367. RoleLog::insertGetId($logData);
  368. Db::commit();
  369. } catch(\Throwable $ex){
  370. Db::rollBack();
  371. return Result::error("更新失败");
  372. }
  373. return Result::success($result);
  374. }
  375. /**
  376. * @param array $data
  377. * @return array
  378. */
  379. public function roleInfo(array $data) :array
  380. {
  381. $roleInfo = Role::where(['id'=>$data['id']])->first();
  382. if($roleInfo){
  383. return Result::success($roleInfo->toArray());
  384. }else{
  385. return Result::error("没有数据");
  386. }
  387. }
  388. /**
  389. * @param array $data
  390. * @return array
  391. */
  392. public function roleList(array $data) :array
  393. {
  394. $where = [];
  395. if(isset($data['keyword']) && $data['keyword']){
  396. array_push($where, ['role.role_name','like','%'.$data['keyword'].'%']);
  397. }
  398. $result = Role::withCount('users')->where($where)->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])->get();
  399. $count = Role::where($where)->count();
  400. if (empty($result)) {
  401. return Result::error("没有数据",0);
  402. }
  403. $data = [
  404. 'rows'=>$result->toArray(),
  405. 'count'=>$count
  406. ];
  407. return Result::success($data);
  408. }
  409. /**
  410. * 获取小程序注册信息
  411. * @param array $data
  412. * @return array
  413. */
  414. public function getWechatInfo(array $data) :array
  415. {
  416. $where = [
  417. 'purePhoneNumber'=>$data['purePhoneNumber'],
  418. 'openid'=>$data['openid']
  419. ];
  420. $result = Wechat::where($where)->first();
  421. var_dump($result);
  422. if($result){
  423. return Result::success($result);
  424. }else{
  425. return Result::error('没有数据');
  426. }
  427. }
  428. /**
  429. * 添加小程序 注册信息
  430. * @param array $data
  431. * @return array
  432. */
  433. public function addWechatInfo(array $data) :array
  434. {
  435. $result = Wechat::insertGetId($data);
  436. if($result){
  437. return Result::success($result);
  438. }else{
  439. return Result::error('添加失败');
  440. }
  441. }
  442. /**
  443. * 修改密码
  444. * @param array $data
  445. * @return array
  446. */
  447. public function changePassword(array $data) :array
  448. {
  449. Db::beginTransaction();
  450. $userInfo = User::where(['id' => $data['user_id']])->first();
  451. // return Result::success($userInfo);
  452. try {
  453. $dataUserReq = [
  454. 'password' => md5(md5($data['new_password1']) . $userInfo['salt']),
  455. ];
  456. if ($userInfo['password'] != md5(md5($data['password']) . $userInfo['salt'])) {
  457. return Result::error('您输入的密码错误');
  458. }
  459. $userRep = User::where(['id' => $data['user_id']])->update($dataUserReq);
  460. Db::commit();
  461. } catch (\Throwable $ex) {
  462. Db::rollBack();
  463. var_dump($ex->getMessage());
  464. return Result::error("创建失败", 0);
  465. }
  466. return Result::success([]);
  467. }
  468. /**
  469. * 修改用户状态
  470. * @param array $data
  471. * @return array
  472. */
  473. public function upUserStatus(array $data) :array
  474. {
  475. $where = [
  476. 'id'=>$data['id']
  477. ];
  478. $result = User::where($where)->update($data);
  479. if($result){
  480. return Result::success($result);
  481. }else{
  482. return Result::error('修改失败');
  483. }
  484. }
  485. }